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:

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

public class RetrieveService
extends cz.o2.proxima.direct.server.rpc.proto.service.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(cz.o2.proxima.direct.server.rpc.proto.service.Rpc.BeginTransactionRequest request, io.grpc.stub.StreamObserver<cz.o2.proxima.direct.server.rpc.proto.service.Rpc.BeginTransactionResponse> responseObserver)
void	get(cz.o2.proxima.direct.server.rpc.proto.service.Rpc.GetRequest request, io.grpc.stub.StreamObserver<cz.o2.proxima.direct.server.rpc.proto.service.Rpc.GetResponse> responseObserver)
void	listAttributes(cz.o2.proxima.direct.server.rpc.proto.service.Rpc.ListRequest request, io.grpc.stub.StreamObserver<cz.o2.proxima.direct.server.rpc.proto.service.Rpc.ListResponse> responseObserver)
void	multifetch(cz.o2.proxima.direct.server.rpc.proto.service.Rpc.MultifetchRequest request, io.grpc.stub.StreamObserver<cz.o2.proxima.direct.server.rpc.proto.service.Rpc.MultifetchResponse> responseObserver)
void	scan(cz.o2.proxima.direct.server.rpc.proto.service.Rpc.ScanRequest request, io.grpc.stub.StreamObserver<cz.o2.proxima.direct.server.rpc.proto.service.Rpc.ScanResult> responseObserver)

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

listAttributes

public void listAttributes(cz.o2.proxima.direct.server.rpc.proto.service.Rpc.ListRequest request,
                           io.grpc.stub.StreamObserver<cz.o2.proxima.direct.server.rpc.proto.service.Rpc.ListResponse> responseObserver)

get

public void get(cz.o2.proxima.direct.server.rpc.proto.service.Rpc.GetRequest request,
                io.grpc.stub.StreamObserver<cz.o2.proxima.direct.server.rpc.proto.service.Rpc.GetResponse> responseObserver)

multifetch

public void multifetch(cz.o2.proxima.direct.server.rpc.proto.service.Rpc.MultifetchRequest request,
                       io.grpc.stub.StreamObserver<cz.o2.proxima.direct.server.rpc.proto.service.Rpc.MultifetchResponse> responseObserver)

scan

public void scan(cz.o2.proxima.direct.server.rpc.proto.service.Rpc.ScanRequest request,
                 io.grpc.stub.StreamObserver<cz.o2.proxima.direct.server.rpc.proto.service.Rpc.ScanResult> responseObserver)