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

Class IngestServiceGrpc.IngestServiceBlockingV2Stub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractBlockingStub<IngestServiceGrpc.IngestServiceBlockingV2Stub>

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

Enclosing class:

IngestServiceGrpc

public static final class IngestServiceGrpc.IngestServiceBlockingV2Stub
extends io.grpc.stub.AbstractBlockingStub<IngestServiceGrpc.IngestServiceBlockingV2Stub>

A stub to allow clients to do synchronous 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

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

Methods inherited from class io.grpc.stub.AbstractBlockingStub

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

build

protected IngestServiceGrpc.IngestServiceBlockingV2Stub build(io.grpc.Channel channel,
                                                              io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<IngestServiceGrpc.IngestServiceBlockingV2Stub>

ingestBulk

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<Rpc.IngestBulk,Rpc.StatusBulk> ingestBulk()

 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

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.grpc.stub.BlockingClientCall<Rpc.Ingest,Rpc.Status> ingestSingle()

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

ingest

public Rpc.Status ingest(Rpc.Ingest request)

 Synchronous ingest request.
 

commit

public Rpc.TransactionCommitResponse commit(Rpc.TransactionCommitRequest request)

 A synchronous request to commit a transaction.