public class KeyValueStoreGrpcImplLocalDispatcher extends KeyValueStoreGrpc.KeyValueStoreImplBase
KeyValueStoreGrpc.KeyValueStoreImplBase
that dispatches the
gRPC requests to the appropriately named local ReadOnlyKeyValueStore
obtained
from given KafkaStreams
instance.Constructor and Description |
---|
KeyValueStoreGrpcImplLocalDispatcher(org.apache.kafka.streams.KafkaStreams streams,
KeyValueSerde.Registry keyValueSerdeRegistry,
FilterPredicate<?,?> filterPredicate) |
Modifier and Type | Method and Description |
---|---|
void |
all(VoidReq request,
io.grpc.stub.StreamObserver<KeyValue> responseObserver)
KeyValueIterator<K, V> all();
|
void |
allKeys(VoidReq request,
io.grpc.stub.StreamObserver<Key> responseObserver)
Iterator<K> allKeys();
|
void |
approximateNumEntries(VoidReq request,
io.grpc.stub.StreamObserver<Size> responseObserver)
long approximateNumEntries();
|
void |
filter(FilterReq request,
io.grpc.stub.StreamObserver<KeyValue> responseObserver)
KeyValueIterator<K, V> filter(String filter);
|
void |
get(KeyReq request,
io.grpc.stub.StreamObserver<Value> responseObserver)
V get(K key);
|
void |
range(KeyFromKeyToReq request,
io.grpc.stub.StreamObserver<KeyValue> responseObserver)
KeyValueIterator<K, V> range(K from, K to);
|
bindService
public KeyValueStoreGrpcImplLocalDispatcher(org.apache.kafka.streams.KafkaStreams streams, KeyValueSerde.Registry keyValueSerdeRegistry, FilterPredicate<?,?> filterPredicate)
public void allKeys(VoidReq request, io.grpc.stub.StreamObserver<Key> responseObserver)
KeyValueStoreGrpc.KeyValueStoreImplBase
Iterator<K> allKeys();
allKeys
in class KeyValueStoreGrpc.KeyValueStoreImplBase
public void filter(FilterReq request, io.grpc.stub.StreamObserver<KeyValue> responseObserver)
KeyValueStoreGrpc.KeyValueStoreImplBase
KeyValueIterator<K, V> filter(String filter);
filter
in class KeyValueStoreGrpc.KeyValueStoreImplBase
public void get(KeyReq request, io.grpc.stub.StreamObserver<Value> responseObserver)
KeyValueStoreGrpc.KeyValueStoreImplBase
V get(K key);
get
in class KeyValueStoreGrpc.KeyValueStoreImplBase
public void range(KeyFromKeyToReq request, io.grpc.stub.StreamObserver<KeyValue> responseObserver)
KeyValueStoreGrpc.KeyValueStoreImplBase
KeyValueIterator<K, V> range(K from, K to);
range
in class KeyValueStoreGrpc.KeyValueStoreImplBase
public void all(VoidReq request, io.grpc.stub.StreamObserver<KeyValue> responseObserver)
KeyValueStoreGrpc.KeyValueStoreImplBase
KeyValueIterator<K, V> all();
all
in class KeyValueStoreGrpc.KeyValueStoreImplBase
public void approximateNumEntries(VoidReq request, io.grpc.stub.StreamObserver<Size> responseObserver)
KeyValueStoreGrpc.KeyValueStoreImplBase
long approximateNumEntries();
approximateNumEntries
in class KeyValueStoreGrpc.KeyValueStoreImplBase
Copyright © 2020 Red Hat. All rights reserved.