Interface StreamingServiceGrpc.AsyncService (0.12.0)

public static interface StreamingServiceGrpc.AsyncService

Streaming service for receiving and sending packets.

Methods

acquireLease(AcquireLeaseRequest request, StreamObserver<Lease> responseObserver)

public default void acquireLease(AcquireLeaseRequest request, StreamObserver<Lease> responseObserver)

AcquireLease acquires a lease.

Parameters
Name Description
request AcquireLeaseRequest
responseObserver io.grpc.stub.StreamObserver<Lease>

receiveEvents(StreamObserver<ReceiveEventsResponse> responseObserver)

public default StreamObserver<ReceiveEventsRequest> receiveEvents(StreamObserver<ReceiveEventsResponse> responseObserver)

Receive events given the stream name.

Parameter
Name Description
responseObserver io.grpc.stub.StreamObserver<ReceiveEventsResponse>
Returns
Type Description
io.grpc.stub.StreamObserver<ReceiveEventsRequest>

receivePackets(StreamObserver<ReceivePacketsResponse> responseObserver)

public default StreamObserver<ReceivePacketsRequest> receivePackets(StreamObserver<ReceivePacketsResponse> responseObserver)

Receive packets from the series.

Parameter
Name Description
responseObserver io.grpc.stub.StreamObserver<ReceivePacketsResponse>
Returns
Type Description
io.grpc.stub.StreamObserver<ReceivePacketsRequest>

releaseLease(ReleaseLeaseRequest request, StreamObserver<ReleaseLeaseResponse> responseObserver)

public default void releaseLease(ReleaseLeaseRequest request, StreamObserver<ReleaseLeaseResponse> responseObserver)

RleaseLease releases a lease.

Parameters
Name Description
request ReleaseLeaseRequest
responseObserver io.grpc.stub.StreamObserver<ReleaseLeaseResponse>

renewLease(RenewLeaseRequest request, StreamObserver<Lease> responseObserver)

public default void renewLease(RenewLeaseRequest request, StreamObserver<Lease> responseObserver)

RenewLease renews a lease.

Parameters
Name Description
request RenewLeaseRequest
responseObserver io.grpc.stub.StreamObserver<Lease>

sendPackets(StreamObserver<SendPacketsResponse> responseObserver)

public default StreamObserver<SendPacketsRequest> sendPackets(StreamObserver<SendPacketsResponse> responseObserver)

Send packets to the series.

Parameter
Name Description
responseObserver io.grpc.stub.StreamObserver<SendPacketsResponse>
Returns
Type Description
io.grpc.stub.StreamObserver<SendPacketsRequest>