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

Interface RetrieveServiceGrpc.AsyncService

All Known Implementing Classes:

RetrieveService, RetrieveServiceGrpc.RetrieveServiceImplBase

Enclosing class:

RetrieveServiceGrpc

public static interface RetrieveServiceGrpc.AsyncService

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

Method Summary

Modifier and Type	Method	Description
default void	begin(Rpc.BeginTransactionRequest request, io.grpc.stub.StreamObserver<Rpc.BeginTransactionResponse> responseObserver)	Synchronous request to begin a transaction.
default void	get(Rpc.GetRequest request, io.grpc.stub.StreamObserver<Rpc.GetResponse> responseObserver)	Synchronous request to fetch a value of a specified attribute.
default void	listAttributes(Rpc.ListRequest request, io.grpc.stub.StreamObserver<Rpc.ListResponse> responseObserver)	Synchronous request to list attributes of a specified entity by prefix.
default void	multifetch(Rpc.MultifetchRequest request, io.grpc.stub.StreamObserver<Rpc.MultifetchResponse> responseObserver)	Synchronous request to fetch a list of multiple requests.
default void	scan(Rpc.ScanRequest request, io.grpc.stub.StreamObserver<Rpc.ScanResult> responseObserver)	Scan complete attributes.

Method Detail

get

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

 Synchronous request to fetch a value of a specified attribute. 
 

listAttributes

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

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

multifetch

default 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

default 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

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

 Scan complete attributes.