com.srotya.minuteman.rocksdb.rpc

Class RocksServiceImpl

java.lang.Object

com.srotya.minuteman.rocksdb.rpc.RocksServiceGrpc.RocksServiceImplBase

com.srotya.minuteman.rocksdb.rpc.RocksServiceImpl

All Implemented Interfaces:

io.grpc.BindableService

public class RocksServiceImpl
extends RocksServiceGrpc.RocksServiceImplBase

Author:

ambud

Constructor Summary

Constructors

Constructor and Description
RocksServiceImpl(int shards, WALManager mgr, org.rocksdb.RocksDB rocks)

Method Summary

Modifier and Type	Method and Description
void	delete(DeleteRequest request, io.grpc.stub.StreamObserver<GenericResponse> responseObserver)
void	get(GetRequest request, io.grpc.stub.StreamObserver<GetResponse> responseObserver)
static Node	getLeaderNode(String str, WALManager mgr, int shards)
void	put(PutRequest request, io.grpc.stub.StreamObserver<GenericResponse> responseObserver)

Methods inherited from class com.srotya.minuteman.rocksdb.rpc.RocksServiceGrpc.RocksServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

RocksServiceImpl

public RocksServiceImpl(int shards,
                        WALManager mgr,
                        org.rocksdb.RocksDB rocks)

Method Detail

get

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

Overrides:

get in class RocksServiceGrpc.RocksServiceImplBase

delete

public void delete(DeleteRequest request,
                   io.grpc.stub.StreamObserver<GenericResponse> responseObserver)

Overrides:

delete in class RocksServiceGrpc.RocksServiceImplBase

getLeaderNode

public static Node getLeaderNode(String str,
                                 WALManager mgr,
                                 int shards)

put

public void put(PutRequest request,
                io.grpc.stub.StreamObserver<GenericResponse> responseObserver)

Overrides:

put in class RocksServiceGrpc.RocksServiceImplBase