Package cz.o2.proxima.direct.server

Class RetrieveService

java.lang.Object

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

cz.o2.proxima.direct.server.RetrieveService

All Implemented Interfaces:

RetrieveServiceGrpc.AsyncService, io.grpc.BindableService

public class RetrieveService
extends RetrieveServiceGrpc.RetrieveServiceImplBase

Service for reading data.

Constructor Summary

Constructors

Constructor	Description
RetrieveService(Repository repo, DirectDataOperator direct, TransactionContext transactionContext)

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.
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 cz.o2.proxima.direct.server.rpc.proto.service.RetrieveServiceGrpc.RetrieveServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

RetrieveService

public RetrieveService(Repository repo,
                       DirectDataOperator direct,
                       TransactionContext transactionContext)

Method Detail

begin

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

Description copied from interface: RetrieveServiceGrpc.AsyncService

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

listAttributes

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

Description copied from interface: RetrieveServiceGrpc.AsyncService

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

get

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

Description copied from interface: RetrieveServiceGrpc.AsyncService

 Synchronous request to fetch a value of a specified attribute. 
 

multifetch

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

Description copied from interface: RetrieveServiceGrpc.AsyncService

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

scan

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

Description copied from interface: RetrieveServiceGrpc.AsyncService

 Scan complete attributes.