Interface StreamingServiceGrpc.AsyncService

All Known Implementing Classes:
StreamingServiceGrpc.StreamingServiceImplBase
Enclosing class:
StreamingServiceGrpc

public static interface StreamingServiceGrpc.AsyncService
 Streaming service for receiving and sending packets.
 
  • Method Details

    • sendPackets

      default io.grpc.stub.StreamObserver<SendPacketsRequest> sendPackets(io.grpc.stub.StreamObserver<SendPacketsResponse> responseObserver)
       Send packets to the series.
       
    • receivePackets

      default io.grpc.stub.StreamObserver<ReceivePacketsRequest> receivePackets(io.grpc.stub.StreamObserver<ReceivePacketsResponse> responseObserver)
       Receive packets from the series.
       
    • receiveEvents

      default io.grpc.stub.StreamObserver<ReceiveEventsRequest> receiveEvents(io.grpc.stub.StreamObserver<ReceiveEventsResponse> responseObserver)
       Receive events given the stream name.
       
    • acquireLease

      default void acquireLease(AcquireLeaseRequest request, io.grpc.stub.StreamObserver<Lease> responseObserver)
       AcquireLease acquires a lease.
       
    • renewLease

      default void renewLease(RenewLeaseRequest request, io.grpc.stub.StreamObserver<Lease> responseObserver)
       RenewLease renews a lease.
       
    • releaseLease

      default void releaseLease(ReleaseLeaseRequest request, io.grpc.stub.StreamObserver<ReleaseLeaseResponse> responseObserver)
       RleaseLease releases a lease.