Package cz.o2.proxima.direct.server

Class IngestService

java.lang.Object

cz.o2.proxima.direct.server.rpc.proto.service.IngestServiceGrpc.IngestServiceImplBase

cz.o2.proxima.direct.server.IngestService

All Implemented Interfaces:

IngestServiceGrpc.AsyncService, io.grpc.BindableService

public class IngestService
extends IngestServiceGrpc.IngestServiceImplBase

The ingestion service.

Constructor Summary

Constructors

Constructor	Description
IngestService(Repository repo, DirectDataOperator direct, TransactionContext transactionContext, java.util.concurrent.ScheduledExecutorService scheduler)

Method Summary

Modifier and Type	Method	Description
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 cz.o2.proxima.direct.server.rpc.proto.service.IngestServiceGrpc.IngestServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

IngestService

public IngestService(Repository repo,
                     DirectDataOperator direct,
                     TransactionContext transactionContext,
                     java.util.concurrent.ScheduledExecutorService scheduler)

Method Detail

ingest

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

Description copied from interface: IngestServiceGrpc.AsyncService

 Synchronous ingest request.
 

ingestSingle

public io.grpc.stub.StreamObserver<Rpc.Ingest> ingestSingle(io.grpc.stub.StreamObserver<Rpc.Status> responseObserver)

Description copied from interface: IngestServiceGrpc.AsyncService

 Stream ingestion with single ingest requests. Use this method when
 sending small isolated and infrequent ingest requests.
 

ingestBulk

public io.grpc.stub.StreamObserver<Rpc.IngestBulk> ingestBulk(io.grpc.stub.StreamObserver<Rpc.StatusBulk> responseObserver)

Description copied from interface: IngestServiceGrpc.AsyncService

 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.
 

commit

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

Description copied from interface: IngestServiceGrpc.AsyncService

 A synchronous request to commit a transaction.