Package cz.o2.proxima.direct.server.rpc.proto.service

Class IngestServiceGrpc.IngestServiceStub

  • Enclosing class:
    IngestServiceGrpc
    public static final class IngestServiceGrpc.IngestServiceStub
extends io.grpc.stub.AbstractAsyncStub<IngestServiceGrpc.IngestServiceStub>
    A stub to allow clients to do asynchronous rpc calls to service IngestService. 
    
 Ingest service serves as data entry point. All data
 is sent to the system via this endpoint.

    • Nested Class Summary

      • Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

        io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected IngestServiceGrpc.IngestServiceStub build​(io.grpc.Channel channel, io.grpc.CallOptions callOptions)  
      void commit​(Rpc.TransactionCommitRequest request, io.grpc.stub.StreamObserver<Rpc.TransactionCommitResponse> responseObserver)
      A synchronous request to commit a transaction.
      void ingest​(Rpc.Ingest request, io.grpc.stub.StreamObserver<Rpc.Status> responseObserver)
      Synchronous ingest request.
      io.grpc.stub.StreamObserver<Rpc.IngestBulk> ingestBulk​(io.grpc.stub.StreamObserver<Rpc.StatusBulk> responseObserver)
      The main ingest method.
      io.grpc.stub.StreamObserver<Rpc.Ingest> ingestSingle​(io.grpc.stub.StreamObserver<Rpc.Status> responseObserver)
      Stream ingestion with single ingest requests.

      • Methods inherited from class io.grpc.stub.AbstractAsyncStub

        newStub, newStub

      • Methods inherited from class io.grpc.stub.AbstractStub

        getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Method Detail

      • ingestBulk

        public io.grpc.stub.StreamObserver<Rpc.IngestBulk> ingestBulk​(io.grpc.stub.StreamObserver<Rpc.StatusBulk> responseObserver)
        
 The main ingest method. Use this for high performance ingest requests.
 Note that the returned StatusBulk will not be necesarilly corresponding
 the the input bulk. So each IngestBulk can result in any number of
 StatusBulk messages. It is up to the application to handle the
 StatusBulk as a stream of individual Statuses.

      • ingestSingle

        public io.grpc.stub.StreamObserver<Rpc.Ingest> ingestSingle​(io.grpc.stub.StreamObserver<Rpc.Status> responseObserver)
        
 Stream ingestion with single ingest requests. Use this method when
 sending small isolated and infrequent ingest requests.

      • ingest

        public void ingest​(Rpc.Ingest request,
                   io.grpc.stub.StreamObserver<Rpc.Status> responseObserver)
        
 Synchronous ingest request.