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:

cz.o2.proxima.direct.server.rpc.proto.service.IngestServiceGrpc.AsyncService, io.grpc.BindableService

public class IngestService
extends cz.o2.proxima.direct.server.rpc.proto.service.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(cz.o2.proxima.direct.server.rpc.proto.service.Rpc.TransactionCommitRequest request, io.grpc.stub.StreamObserver<cz.o2.proxima.direct.server.rpc.proto.service.Rpc.TransactionCommitResponse> responseObserver)
void	ingest(cz.o2.proxima.direct.server.rpc.proto.service.Rpc.Ingest request, io.grpc.stub.StreamObserver<cz.o2.proxima.direct.server.rpc.proto.service.Rpc.Status> responseObserver)
io.grpc.stub.StreamObserver<cz.o2.proxima.direct.server.rpc.proto.service.Rpc.IngestBulk>	ingestBulk(io.grpc.stub.StreamObserver<cz.o2.proxima.direct.server.rpc.proto.service.Rpc.StatusBulk> responseObserver)
io.grpc.stub.StreamObserver<cz.o2.proxima.direct.server.rpc.proto.service.Rpc.Ingest>	ingestSingle(io.grpc.stub.StreamObserver<cz.o2.proxima.direct.server.rpc.proto.service.Rpc.Status> responseObserver)

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(cz.o2.proxima.direct.server.rpc.proto.service.Rpc.Ingest request,
                   io.grpc.stub.StreamObserver<cz.o2.proxima.direct.server.rpc.proto.service.Rpc.Status> responseObserver)

ingestSingle

public io.grpc.stub.StreamObserver<cz.o2.proxima.direct.server.rpc.proto.service.Rpc.Ingest> ingestSingle(io.grpc.stub.StreamObserver<cz.o2.proxima.direct.server.rpc.proto.service.Rpc.Status> responseObserver)

ingestBulk

public io.grpc.stub.StreamObserver<cz.o2.proxima.direct.server.rpc.proto.service.Rpc.IngestBulk> ingestBulk(io.grpc.stub.StreamObserver<cz.o2.proxima.direct.server.rpc.proto.service.Rpc.StatusBulk> responseObserver)

commit

public void commit(cz.o2.proxima.direct.server.rpc.proto.service.Rpc.TransactionCommitRequest request,
                   io.grpc.stub.StreamObserver<cz.o2.proxima.direct.server.rpc.proto.service.Rpc.TransactionCommitResponse> responseObserver)