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

Class RetrieveServiceGrpc.RetrieveServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<RetrieveServiceGrpc.RetrieveServiceStub>

cz.o2.proxima.direct.server.rpc.proto.service.RetrieveServiceGrpc.RetrieveServiceStub

Enclosing class:

RetrieveServiceGrpc

public static final class RetrieveServiceGrpc.RetrieveServiceStub
extends io.grpc.stub.AbstractAsyncStub<RetrieveServiceGrpc.RetrieveServiceStub>

A stub to allow clients to do asynchronous rpc calls to service RetrieveService.

 Service that serves for retrieving data from the system
 (via stream or random access calls).
 

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
void	begin(Rpc.BeginTransactionRequest request, io.grpc.stub.StreamObserver<Rpc.BeginTransactionResponse> responseObserver)	Synchronous request to begin a transaction.
protected RetrieveServiceGrpc.RetrieveServiceStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void	get(Rpc.GetRequest request, io.grpc.stub.StreamObserver<Rpc.GetResponse> responseObserver)	Synchronous request to fetch a value of a specified attribute.
void	listAttributes(Rpc.ListRequest request, io.grpc.stub.StreamObserver<Rpc.ListResponse> responseObserver)	Synchronous request to list attributes of a specified entity by prefix.
void	multifetch(Rpc.MultifetchRequest request, io.grpc.stub.StreamObserver<Rpc.MultifetchResponse> responseObserver)	Synchronous request to fetch a list of multiple requests.
void	scan(Rpc.ScanRequest request, io.grpc.stub.StreamObserver<Rpc.ScanResult> responseObserver)	Scan complete attributes.

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

build

protected RetrieveServiceGrpc.RetrieveServiceStub build(io.grpc.Channel channel,
                                                        io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<RetrieveServiceGrpc.RetrieveServiceStub>

get

public void get(Rpc.GetRequest request,
                io.grpc.stub.StreamObserver<Rpc.GetResponse> responseObserver)

 Synchronous request to fetch a value of a specified attribute. 
 

listAttributes

public void listAttributes(Rpc.ListRequest request,
                           io.grpc.stub.StreamObserver<Rpc.ListResponse> responseObserver)

 Synchronous request to list attributes of a specified entity by prefix. 
 

multifetch

public void multifetch(Rpc.MultifetchRequest request,
                       io.grpc.stub.StreamObserver<Rpc.MultifetchResponse> responseObserver)

 Synchronous request to fetch a list of multiple requests. The returned list contains responses
 in the same order as specified in the input list.
 

begin

public void begin(Rpc.BeginTransactionRequest request,
                  io.grpc.stub.StreamObserver<Rpc.BeginTransactionResponse> responseObserver)

 Synchronous request to begin a transaction.
 Returns most importantly the ID of the transaction that should be the used in subsequent read operations.
 

scan

public void scan(Rpc.ScanRequest request,
                 io.grpc.stub.StreamObserver<Rpc.ScanResult> responseObserver)

 Scan complete attributes.