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

Interface IngestServiceGrpc.AsyncService

All Known Implementing Classes:

IngestService, IngestServiceGrpc.IngestServiceImplBase

Enclosing class:

IngestServiceGrpc

public static interface IngestServiceGrpc.AsyncService

 Ingest service serves as data entry point. All data
 is sent to the system via this endpoint.
 

Method Summary

Modifier and Type	Method	Description
default void	commit(Rpc.TransactionCommitRequest request, io.grpc.stub.StreamObserver<Rpc.TransactionCommitResponse> responseObserver)	A synchronous request to commit a transaction.
default void	ingest(Rpc.Ingest request, io.grpc.stub.StreamObserver<Rpc.Status> responseObserver)	Synchronous ingest request.
default io.grpc.stub.StreamObserver<Rpc.IngestBulk>	ingestBulk(io.grpc.stub.StreamObserver<Rpc.StatusBulk> responseObserver)	The main ingest method.
default io.grpc.stub.StreamObserver<Rpc.Ingest>	ingestSingle(io.grpc.stub.StreamObserver<Rpc.Status> responseObserver)	Stream ingestion with single ingest requests.

Method Detail

ingestBulk

default 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

default 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

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

 Synchronous ingest request.
 

commit

default void commit(Rpc.TransactionCommitRequest request,
                    io.grpc.stub.StreamObserver<Rpc.TransactionCommitResponse> responseObserver)

 A synchronous request to commit a transaction.