Skip navigation links
A B C D E F G H I K L M N O P R S T U V W 

A

AbstractStreamToIteratorAdapter<I,O> - Class in io.apicurio.registry.utils.streams.distore
Stream to CloseableIterator
AbstractStreamToIteratorAdapter(Stream<I>) - Constructor for class io.apicurio.registry.utils.streams.distore.AbstractStreamToIteratorAdapter
 
accept(I) - Method in class io.apicurio.registry.utils.streams.distore.AbstractStreamToIteratorAdapter
 
accept(KeyValue<K, V>) - Method in class io.apicurio.registry.utils.streams.distore.StreamToKeyValueIteratorAdapter
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.Key.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.Size.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.Value.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
 
all() - Method in class io.apicurio.registry.utils.streams.distore.DistributedReadOnlyKeyValueStore
 
all() - Method in class io.apicurio.registry.utils.streams.distore.ExtReadOnlyKeyValueStoreImpl
 
all(VoidReq, StreamObserver<KeyValue>) - Method in class io.apicurio.registry.utils.streams.distore.KeyValueStoreGrpcImplLocalDispatcher
 
all(VoidReq) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreBlockingStub
KeyValueIterator<K, V> all();
all(VoidReq, StreamObserver<KeyValue>) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreImplBase
KeyValueIterator<K, V> all();
all(VoidReq, StreamObserver<KeyValue>) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreStub
KeyValueIterator<K, V> all();
all() - Method in class io.apicurio.registry.utils.streams.distore.ReadOnlyKeyValueStoreGrpcClient
 
allKeys() - Method in class io.apicurio.registry.utils.streams.distore.DistributedReadOnlyKeyValueStore
 
allKeys() - Method in interface io.apicurio.registry.utils.streams.distore.ExtReadOnlyKeyValueStore
All keys, as a stream.
allKeys() - Method in class io.apicurio.registry.utils.streams.distore.ExtReadOnlyKeyValueStoreImpl
 
allKeys(VoidReq, StreamObserver<Key>) - Method in class io.apicurio.registry.utils.streams.distore.KeyValueStoreGrpcImplLocalDispatcher
 
allKeys(VoidReq) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreBlockingStub
Iterator<K> allKeys();
allKeys(VoidReq, StreamObserver<Key>) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreImplBase
Iterator<K> allKeys();
allKeys(VoidReq, StreamObserver<Key>) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreStub
Iterator<K> allKeys();
allKeys() - Method in class io.apicurio.registry.utils.streams.distore.ReadOnlyKeyValueStoreGrpcClient
 
allServices() - Method in class io.apicurio.registry.utils.streams.diservice.DistributedService
 
allServicesForStore() - Method in class io.apicurio.registry.utils.streams.diservice.DistributedService
 
allServicesForStoreStream() - Method in class io.apicurio.registry.utils.streams.diservice.DistributedService
 
allServicesStream() - Method in class io.apicurio.registry.utils.streams.diservice.DistributedService
 
apply() - Method in interface io.apicurio.registry.utils.streams.diservice.AsyncBiFunctionService
Apply to all services, with null key and request - if they can handle it.
apply(K, REQ) - Method in class io.apicurio.registry.utils.streams.diservice.AsyncBiFunctionServiceGrpcClient
 
apply() - Method in class io.apicurio.registry.utils.streams.diservice.AsyncBiFunctionServiceGrpcClient
 
apply(BiFunctionReq, StreamObserver<BiFunctionRes>) - Method in class io.apicurio.registry.utils.streams.diservice.AsyncBiFunctionServiceGrpcLocalDispatcher
 
apply(HostInfo) - Method in class io.apicurio.registry.utils.streams.diservice.DefaultGrpcChannelProvider
 
apply(K, REQ) - Method in class io.apicurio.registry.utils.streams.diservice.DistributedAsyncBiFunctionService
 
apply() - Method in class io.apicurio.registry.utils.streams.diservice.DistributedAsyncBiFunctionService
 
apply(BiFunctionReq) - Method in class io.apicurio.registry.utils.streams.diservice.proto.AsyncBiFunctionServiceGrpc.AsyncBiFunctionServiceBlockingStub
CompletionStage<RES> apply(K key, REQ req);
apply(BiFunctionReq) - Method in class io.apicurio.registry.utils.streams.diservice.proto.AsyncBiFunctionServiceGrpc.AsyncBiFunctionServiceFutureStub
CompletionStage<RES> apply(K key, REQ req);
apply(BiFunctionReq, StreamObserver<BiFunctionRes>) - Method in class io.apicurio.registry.utils.streams.diservice.proto.AsyncBiFunctionServiceGrpc.AsyncBiFunctionServiceImplBase
CompletionStage<RES> apply(K key, REQ req);
apply(BiFunctionReq, StreamObserver<BiFunctionRes>) - Method in class io.apicurio.registry.utils.streams.diservice.proto.AsyncBiFunctionServiceGrpc.AsyncBiFunctionServiceStub
CompletionStage<RES> apply(K key, REQ req);
apply(K, V) - Method in class io.apicurio.registry.utils.streams.ext.ForeachActionDispatcher
 
applyForStore() - Method in interface io.apicurio.registry.utils.streams.diservice.AsyncBiFunctionService
Apply to all services for store, with null key and request - if they can handle it.
applyForStore() - Method in class io.apicurio.registry.utils.streams.diservice.AsyncBiFunctionServiceGrpcClient
 
applyForStore() - Method in class io.apicurio.registry.utils.streams.diservice.DistributedAsyncBiFunctionService
 
approximateNumEntries() - Method in class io.apicurio.registry.utils.streams.distore.DistributedReadOnlyKeyValueStore
 
approximateNumEntries() - Method in class io.apicurio.registry.utils.streams.distore.ExtReadOnlyKeyValueStoreImpl
 
approximateNumEntries(VoidReq, StreamObserver<Size>) - Method in class io.apicurio.registry.utils.streams.distore.KeyValueStoreGrpcImplLocalDispatcher
 
approximateNumEntries(VoidReq) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreBlockingStub
long approximateNumEntries();
approximateNumEntries(VoidReq) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreFutureStub
long approximateNumEntries();
approximateNumEntries(VoidReq, StreamObserver<Size>) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreImplBase
long approximateNumEntries();
approximateNumEntries(VoidReq, StreamObserver<Size>) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreStub
long approximateNumEntries();
approximateNumEntries() - Method in class io.apicurio.registry.utils.streams.distore.ReadOnlyKeyValueStoreGrpcClient
 
AsyncBiFunctionService<K,REQ,RES> - Interface in io.apicurio.registry.utils.streams.diservice
A BiFunction that returns an asynchronous CompletionStage result.
AsyncBiFunctionService.WithSerdes<K,REQ,RES> - Interface in io.apicurio.registry.utils.streams.diservice
AsyncBiFunctionServiceGrpc - Class in io.apicurio.registry.utils.streams.diservice.proto
 
AsyncBiFunctionServiceGrpc.AsyncBiFunctionServiceBlockingStub - Class in io.apicurio.registry.utils.streams.diservice.proto
 
AsyncBiFunctionServiceGrpc.AsyncBiFunctionServiceFutureStub - Class in io.apicurio.registry.utils.streams.diservice.proto
 
AsyncBiFunctionServiceGrpc.AsyncBiFunctionServiceImplBase - Class in io.apicurio.registry.utils.streams.diservice.proto
 
AsyncBiFunctionServiceGrpc.AsyncBiFunctionServiceStub - Class in io.apicurio.registry.utils.streams.diservice.proto
 
AsyncBiFunctionServiceGrpcClient<K,REQ,RES> - Class in io.apicurio.registry.utils.streams.diservice
 
AsyncBiFunctionServiceGrpcClient(String, Channel, Serde<K>, Serde<REQ>, Serde<RES>) - Constructor for class io.apicurio.registry.utils.streams.diservice.AsyncBiFunctionServiceGrpcClient
 
AsyncBiFunctionServiceGrpcLocalDispatcher - Class in io.apicurio.registry.utils.streams.diservice
 
AsyncBiFunctionServiceGrpcLocalDispatcher(Collection<LocalService<? extends AsyncBiFunctionService.WithSerdes<?, ?, ?>>>) - Constructor for class io.apicurio.registry.utils.streams.diservice.AsyncBiFunctionServiceGrpcLocalDispatcher
 
AsyncBiFunctionServiceImplBase() - Constructor for class io.apicurio.registry.utils.streams.diservice.proto.AsyncBiFunctionServiceGrpc.AsyncBiFunctionServiceImplBase
 

B

BiFunctionReq - Class in io.apicurio.registry.utils.streams.diservice.proto
Protobuf type io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
BiFunctionReq.Builder - Class in io.apicurio.registry.utils.streams.diservice.proto
Protobuf type io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
BiFunctionReqOrBuilder - Interface in io.apicurio.registry.utils.streams.diservice.proto
 
BiFunctionRes - Class in io.apicurio.registry.utils.streams.diservice.proto
Protobuf type io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
BiFunctionRes.Builder - Class in io.apicurio.registry.utils.streams.diservice.proto
Protobuf type io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
BiFunctionResOrBuilder - Interface in io.apicurio.registry.utils.streams.diservice.proto
 
bindService() - Method in class io.apicurio.registry.utils.streams.diservice.proto.AsyncBiFunctionServiceGrpc.AsyncBiFunctionServiceImplBase
 
bindService() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreImplBase
 
build(Channel, CallOptions) - Method in class io.apicurio.registry.utils.streams.diservice.proto.AsyncBiFunctionServiceGrpc.AsyncBiFunctionServiceBlockingStub
 
build(Channel, CallOptions) - Method in class io.apicurio.registry.utils.streams.diservice.proto.AsyncBiFunctionServiceGrpc.AsyncBiFunctionServiceFutureStub
 
build(Channel, CallOptions) - Method in class io.apicurio.registry.utils.streams.diservice.proto.AsyncBiFunctionServiceGrpc.AsyncBiFunctionServiceStub
 
build() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
 
build() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes.Builder
 
build() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
 
build() - Method in class io.apicurio.registry.utils.streams.distore.proto.Key.Builder
 
build() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
 
build() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
 
build() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
 
build(Channel, CallOptions) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreBlockingStub
 
build(Channel, CallOptions) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreFutureStub
 
build(Channel, CallOptions) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreStub
 
build() - Method in class io.apicurio.registry.utils.streams.distore.proto.Size.Builder
 
build() - Method in class io.apicurio.registry.utils.streams.distore.proto.Value.Builder
 
build() - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
 
buildPartial() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
 
buildPartial() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes.Builder
 
buildPartial() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
 
buildPartial() - Method in class io.apicurio.registry.utils.streams.distore.proto.Key.Builder
 
buildPartial() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
 
buildPartial() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
 
buildPartial() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
 
buildPartial() - Method in class io.apicurio.registry.utils.streams.distore.proto.Size.Builder
 
buildPartial() - Method in class io.apicurio.registry.utils.streams.distore.proto.Value.Builder
 
buildPartial() - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
 

C

clear() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
 
clear() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes.Builder
 
clear() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
 
clear() - Method in class io.apicurio.registry.utils.streams.distore.proto.Key.Builder
 
clear() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
 
clear() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
 
clear() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
 
clear() - Method in class io.apicurio.registry.utils.streams.distore.proto.Size.Builder
 
clear() - Method in class io.apicurio.registry.utils.streams.distore.proto.Value.Builder
 
clear() - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class io.apicurio.registry.utils.streams.distore.proto.Key.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class io.apicurio.registry.utils.streams.distore.proto.Size.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class io.apicurio.registry.utils.streams.distore.proto.Value.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
 
clearFilter() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
string filter = 1;
clearKey() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
bytes key = 1;
clearKey() - Method in class io.apicurio.registry.utils.streams.distore.proto.Key.Builder
bytes key = 1;
clearKey() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
bytes key = 1;
clearKey() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
bytes key = 1;
clearKeyFrom() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
bytes keyFrom = 1;
clearKeyTo() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
bytes keyTo = 2;
clearOneof(Descriptors.OneofDescriptor) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class io.apicurio.registry.utils.streams.distore.proto.Key.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class io.apicurio.registry.utils.streams.distore.proto.Size.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class io.apicurio.registry.utils.streams.distore.proto.Value.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
 
clearOver() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
string over = 2;
clearReq() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
bytes req = 2;
clearRes() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes.Builder
bytes res = 1;
clearServiceName() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
string serviceName = 3;
clearSize() - Method in class io.apicurio.registry.utils.streams.distore.proto.Size.Builder
int64 Size = 1;
clearStoreName() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
string storeName = 3;
clearStoreName() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
string storeName = 3;
clearStoreName() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
string storeName = 2;
clearStoreName() - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
string storeName = 1;
clearValue() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
bytes value = 2;
clearValue() - Method in class io.apicurio.registry.utils.streams.distore.proto.Value.Builder
bytes value = 1;
clone() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
 
clone() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes.Builder
 
clone() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
 
clone() - Method in class io.apicurio.registry.utils.streams.distore.proto.Key.Builder
 
clone() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
 
clone() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
 
clone() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
 
clone() - Method in class io.apicurio.registry.utils.streams.distore.proto.Size.Builder
 
clone() - Method in class io.apicurio.registry.utils.streams.distore.proto.Value.Builder
 
clone() - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
 
close() - Method in class io.apicurio.registry.utils.streams.diservice.AsyncBiFunctionServiceGrpcClient
 
close() - Method in class io.apicurio.registry.utils.streams.diservice.DistributedService
 
close() - Method in class io.apicurio.registry.utils.streams.distore.AbstractStreamToIteratorAdapter
 
close() - Method in class io.apicurio.registry.utils.streams.distore.ReadOnlyKeyValueStoreGrpcClient
 
close() - Method in class io.apicurio.registry.utils.streams.distore.StreamToKeyValueIteratorAdapter
 

D

DefaultGrpcChannelProvider - Class in io.apicurio.registry.utils.streams.diservice
Default plain-text gRPC Channel provider.
DefaultGrpcChannelProvider() - Constructor for class io.apicurio.registry.utils.streams.diservice.DefaultGrpcChannelProvider
 
deregister(ForeachAction<? super K, ? super V>) - Method in class io.apicurio.registry.utils.streams.ext.ForeachActionDispatcher
 
deserialize(I) - Method in class io.apicurio.registry.utils.streams.distore.AbstractStreamToIteratorAdapter
 
deserialize(K) - Method in class io.apicurio.registry.utils.streams.distore.StreamToIteratorAdapter
 
deserialize(Key) - Method in class io.apicurio.registry.utils.streams.distore.StreamToKeyIteratorAdapter
 
deserializeKey(byte[]) - Method in class io.apicurio.registry.utils.streams.distore.KeyValueSerde
 
deserializeKey(String, byte[]) - Method in class io.apicurio.registry.utils.streams.distore.KeyValueSerde.Registry
 
deserializeVal(byte[]) - Method in class io.apicurio.registry.utils.streams.distore.KeyValueSerde
 
deserializeVal(String, byte[]) - Method in class io.apicurio.registry.utils.streams.distore.KeyValueSerde.Registry
 
Diservice - Class in io.apicurio.registry.utils.streams.diservice.proto
 
Distore - Class in io.apicurio.registry.utils.streams.distore.proto
 
DistributedAsyncBiFunctionService<K,REQ,RES> - Class in io.apicurio.registry.utils.streams.diservice
 
DistributedAsyncBiFunctionService(KafkaStreams, HostInfo, String, LocalService<? extends AsyncBiFunctionService.WithSerdes<K, REQ, RES>>, Function<? super HostInfo, ? extends Channel>) - Constructor for class io.apicurio.registry.utils.streams.diservice.DistributedAsyncBiFunctionService
 
DistributedReadOnlyKeyValueStore<K,V> - Class in io.apicurio.registry.utils.streams.distore
A ReadOnlyKeyValueStore that is distributed among KafkaStreams processing nodes comprising the distributed streams application.
DistributedReadOnlyKeyValueStore(KafkaStreams, HostInfo, String, Serde<K>, Serde<V>, Function<? super HostInfo, ? extends Channel>, boolean, FilterPredicate<K, V>) - Constructor for class io.apicurio.registry.utils.streams.distore.DistributedReadOnlyKeyValueStore
 
DistributedReadOnlyStateStore<K,V,ROS> - Class in io.apicurio.registry.utils.streams.distore
A read-only StateStore base class for stores that are distributed among KafkaStreams processing nodes comprising the distributed streams application.
DistributedReadOnlyStateStore(KafkaStreams, HostInfo, String, Serde<K>, Serde<V>, Function<? super HostInfo, ? extends Channel>, boolean) - Constructor for class io.apicurio.registry.utils.streams.distore.DistributedReadOnlyStateStore
 
DistributedService<K,S> - Class in io.apicurio.registry.utils.streams.diservice
A service base class for services that are distributed among KafkaStreams processing nodes comprising the distributed streams application.
DistributedService(KafkaStreams, HostInfo, String, Serde<K>, Function<? super HostInfo, ? extends Channel>, boolean) - Constructor for class io.apicurio.registry.utils.streams.diservice.DistributedService
 

E

equals(Object) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
equals(Object) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
equals(Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
equals(Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
equals(Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
equals(Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
equals(Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
equals(Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
equals(Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
equals(Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
ExtReadOnlyKeyValueStore<K,V> - Interface in io.apicurio.registry.utils.streams.distore
Extend ReadOnlyKeyValueStore functionality a bit.
ExtReadOnlyKeyValueStoreImpl<K,V> - Class in io.apicurio.registry.utils.streams.distore
Local ExtReadOnlyKeyValueStore impl.
ExtReadOnlyKeyValueStoreImpl(ReadOnlyKeyValueStore<K, V>, FilterPredicate<K, V>) - Constructor for class io.apicurio.registry.utils.streams.distore.ExtReadOnlyKeyValueStoreImpl
 

F

filter(String, String) - Method in class io.apicurio.registry.utils.streams.distore.DistributedReadOnlyKeyValueStore
 
filter(String, String) - Method in interface io.apicurio.registry.utils.streams.distore.ExtReadOnlyKeyValueStore
Get filtered stream.
filter(String, String) - Method in class io.apicurio.registry.utils.streams.distore.ExtReadOnlyKeyValueStoreImpl
 
filter(FilterReq, StreamObserver<KeyValue>) - Method in class io.apicurio.registry.utils.streams.distore.KeyValueStoreGrpcImplLocalDispatcher
 
filter(FilterReq) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreBlockingStub
KeyValueIterator<K, V> filter(String filter);
filter(FilterReq, StreamObserver<KeyValue>) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreImplBase
KeyValueIterator<K, V> filter(String filter);
filter(FilterReq, StreamObserver<KeyValue>) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreStub
KeyValueIterator<K, V> filter(String filter);
filter(String, String) - Method in class io.apicurio.registry.utils.streams.distore.ReadOnlyKeyValueStoreGrpcClient
 
FILTER_FIELD_NUMBER - Static variable in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
FilterPredicate<K,V> - Interface in io.apicurio.registry.utils.streams.distore
Filter predicate.
FilterReq - Class in io.apicurio.registry.utils.streams.distore.proto
Protobuf type io.apicurio.registry.utils.streams.distore.proto.FilterReq
FilterReq.Builder - Class in io.apicurio.registry.utils.streams.distore.proto
Protobuf type io.apicurio.registry.utils.streams.distore.proto.FilterReq
FilterReqOrBuilder - Interface in io.apicurio.registry.utils.streams.distore.proto
 
ForeachActionDispatcher<K,V> - Class in io.apicurio.registry.utils.streams.ext
An ForeachAction implementation that dispatches ForeachAction.apply(Object, Object) invocation to registered actions.
ForeachActionDispatcher() - Constructor for class io.apicurio.registry.utils.streams.ext.ForeachActionDispatcher
 

G

get(String) - Method in class io.apicurio.registry.utils.streams.diservice.LocalService.Registry
 
get(K) - Method in class io.apicurio.registry.utils.streams.distore.DistributedReadOnlyKeyValueStore
 
get(K) - Method in class io.apicurio.registry.utils.streams.distore.ExtReadOnlyKeyValueStoreImpl
 
get(KeyReq, StreamObserver<Value>) - Method in class io.apicurio.registry.utils.streams.distore.KeyValueStoreGrpcImplLocalDispatcher
 
get(KeyReq) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreBlockingStub
V get(K key);
get(KeyReq, StreamObserver<Value>) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreImplBase
V get(K key);
get(KeyReq, StreamObserver<Value>) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreStub
V get(K key);
get(K) - Method in class io.apicurio.registry.utils.streams.distore.ReadOnlyKeyValueStoreGrpcClient
 
getAllKeysMethod() - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc
 
getAllMethod() - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc
 
getApplyMethod() - Static method in class io.apicurio.registry.utils.streams.diservice.proto.AsyncBiFunctionServiceGrpc
 
getApproximateNumEntriesMethod() - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc
 
getDefaultInstance() - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
getDefaultInstance() - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
getDefaultInstance() - Static method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
getDefaultInstance() - Static method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
getDefaultInstance() - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
getDefaultInstance() - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
getDefaultInstance() - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
getDefaultInstance() - Static method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
getDefaultInstance() - Static method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
getDefaultInstance() - Static method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
getDefaultInstanceForType() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
 
getDefaultInstanceForType() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
getDefaultInstanceForType() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes.Builder
 
getDefaultInstanceForType() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
getDefaultInstanceForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
 
getDefaultInstanceForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
getDefaultInstanceForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.Key.Builder
 
getDefaultInstanceForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
getDefaultInstanceForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
 
getDefaultInstanceForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
getDefaultInstanceForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
 
getDefaultInstanceForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
getDefaultInstanceForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
 
getDefaultInstanceForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
getDefaultInstanceForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.Size.Builder
 
getDefaultInstanceForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
getDefaultInstanceForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.Value.Builder
 
getDefaultInstanceForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
getDefaultInstanceForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
 
getDefaultInstanceForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
getDescriptor() - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
 
getDescriptor() - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
getDescriptor() - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes.Builder
 
getDescriptor() - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
getDescriptor() - Static method in class io.apicurio.registry.utils.streams.diservice.proto.Diservice
 
getDescriptor() - Static method in class io.apicurio.registry.utils.streams.distore.proto.Distore
 
getDescriptor() - Static method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
 
getDescriptor() - Static method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
getDescriptor() - Static method in class io.apicurio.registry.utils.streams.distore.proto.Key.Builder
 
getDescriptor() - Static method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
getDescriptor() - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
 
getDescriptor() - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
getDescriptor() - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
 
getDescriptor() - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
getDescriptor() - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
 
getDescriptor() - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
getDescriptor() - Static method in class io.apicurio.registry.utils.streams.distore.proto.Size.Builder
 
getDescriptor() - Static method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
getDescriptor() - Static method in class io.apicurio.registry.utils.streams.distore.proto.Value.Builder
 
getDescriptor() - Static method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
getDescriptor() - Static method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
 
getDescriptor() - Static method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
getDescriptorForType() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
 
getDescriptorForType() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes.Builder
 
getDescriptorForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
 
getDescriptorForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.Key.Builder
 
getDescriptorForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
 
getDescriptorForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
 
getDescriptorForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
 
getDescriptorForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.Size.Builder
 
getDescriptorForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.Value.Builder
 
getDescriptorForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
 
getFilter() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
string filter = 1;
getFilter() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
string filter = 1;
getFilter() - Method in interface io.apicurio.registry.utils.streams.distore.proto.FilterReqOrBuilder
string filter = 1;
getFilterBytes() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
string filter = 1;
getFilterBytes() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
string filter = 1;
getFilterBytes() - Method in interface io.apicurio.registry.utils.streams.distore.proto.FilterReqOrBuilder
string filter = 1;
getFilterMethod() - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc
 
getGetMethod() - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc
 
getKey() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
bytes key = 1;
getKey() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
bytes key = 1;
getKey() - Method in interface io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReqOrBuilder
bytes key = 1;
getKey() - Method in class io.apicurio.registry.utils.streams.distore.proto.Key.Builder
bytes key = 1;
getKey() - Method in class io.apicurio.registry.utils.streams.distore.proto.Key
bytes key = 1;
getKey() - Method in interface io.apicurio.registry.utils.streams.distore.proto.KeyOrBuilder
bytes key = 1;
getKey() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
bytes key = 1;
getKey() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
bytes key = 1;
getKey() - Method in interface io.apicurio.registry.utils.streams.distore.proto.KeyReqOrBuilder
bytes key = 1;
getKey() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
bytes key = 1;
getKey() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
bytes key = 1;
getKey() - Method in interface io.apicurio.registry.utils.streams.distore.proto.KeyValueOrBuilder
bytes key = 1;
getKeyFrom() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
bytes keyFrom = 1;
getKeyFrom() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
bytes keyFrom = 1;
getKeyFrom() - Method in interface io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReqOrBuilder
bytes keyFrom = 1;
getKeySerde() - Method in class io.apicurio.registry.utils.streams.diservice.DistributedService
 
getKeyTo() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
bytes keyTo = 2;
getKeyTo() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
bytes keyTo = 2;
getKeyTo() - Method in interface io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReqOrBuilder
bytes keyTo = 2;
getNext() - Method in interface io.apicurio.registry.utils.streams.ext.LongGenerator
 
getNext() - Method in class io.apicurio.registry.utils.streams.ext.LongGenerator.HiLo
 
getOver() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
string over = 2;
getOver() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
string over = 2;
getOver() - Method in interface io.apicurio.registry.utils.streams.distore.proto.FilterReqOrBuilder
string over = 2;
getOverBytes() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
string over = 2;
getOverBytes() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
string over = 2;
getOverBytes() - Method in interface io.apicurio.registry.utils.streams.distore.proto.FilterReqOrBuilder
string over = 2;
getParserForType() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
getParserForType() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
getParserForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
getParserForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
getParserForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
getParserForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
getParserForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
getParserForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
getParserForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
getParserForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
getRangeMethod() - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc
 
getReq() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
bytes req = 2;
getReq() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
bytes req = 2;
getReq() - Method in interface io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReqOrBuilder
bytes req = 2;
getRes() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes.Builder
bytes res = 1;
getRes() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
bytes res = 1;
getRes() - Method in interface io.apicurio.registry.utils.streams.diservice.proto.BiFunctionResOrBuilder
bytes res = 1;
getSerializedSize() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
getSerializedSize() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
getSerializedSize() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
getSerializedSize() - Method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
getSerializedSize() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
getSerializedSize() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
getSerializedSize() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
getSerializedSize() - Method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
getSerializedSize() - Method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
getSerializedSize() - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
getService() - Method in class io.apicurio.registry.utils.streams.diservice.LocalService
 
getServiceDescriptor() - Static method in class io.apicurio.registry.utils.streams.diservice.proto.AsyncBiFunctionServiceGrpc
 
getServiceDescriptor() - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc
 
getServiceName() - Method in class io.apicurio.registry.utils.streams.diservice.LocalService
 
getServiceName() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
string serviceName = 3;
getServiceName() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
string serviceName = 3;
getServiceName() - Method in interface io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReqOrBuilder
string serviceName = 3;
getServiceNameBytes() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
string serviceName = 3;
getServiceNameBytes() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
string serviceName = 3;
getServiceNameBytes() - Method in interface io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReqOrBuilder
string serviceName = 3;
getSize() - Method in class io.apicurio.registry.utils.streams.distore.proto.Size.Builder
int64 Size = 1;
getSize() - Method in class io.apicurio.registry.utils.streams.distore.proto.Size
int64 Size = 1;
getSize() - Method in interface io.apicurio.registry.utils.streams.distore.proto.SizeOrBuilder
int64 Size = 1;
getStoreName() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
string storeName = 3;
getStoreName() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
string storeName = 3;
getStoreName() - Method in interface io.apicurio.registry.utils.streams.distore.proto.FilterReqOrBuilder
string storeName = 3;
getStoreName() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
string storeName = 3;
getStoreName() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
string storeName = 3;
getStoreName() - Method in interface io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReqOrBuilder
string storeName = 3;
getStoreName() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
string storeName = 2;
getStoreName() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
string storeName = 2;
getStoreName() - Method in interface io.apicurio.registry.utils.streams.distore.proto.KeyReqOrBuilder
string storeName = 2;
getStoreName() - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
string storeName = 1;
getStoreName() - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
string storeName = 1;
getStoreName() - Method in interface io.apicurio.registry.utils.streams.distore.proto.VoidReqOrBuilder
string storeName = 1;
getStoreNameBytes() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
string storeName = 3;
getStoreNameBytes() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
string storeName = 3;
getStoreNameBytes() - Method in interface io.apicurio.registry.utils.streams.distore.proto.FilterReqOrBuilder
string storeName = 3;
getStoreNameBytes() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
string storeName = 3;
getStoreNameBytes() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
string storeName = 3;
getStoreNameBytes() - Method in interface io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReqOrBuilder
string storeName = 3;
getStoreNameBytes() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
string storeName = 2;
getStoreNameBytes() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
string storeName = 2;
getStoreNameBytes() - Method in interface io.apicurio.registry.utils.streams.distore.proto.KeyReqOrBuilder
string storeName = 2;
getStoreNameBytes() - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
string storeName = 1;
getStoreNameBytes() - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
string storeName = 1;
getStoreNameBytes() - Method in interface io.apicurio.registry.utils.streams.distore.proto.VoidReqOrBuilder
string storeName = 1;
getUnknownFields() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
getUnknownFields() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
getUnknownFields() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
getUnknownFields() - Method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
getUnknownFields() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
getUnknownFields() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
getUnknownFields() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
getUnknownFields() - Method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
getUnknownFields() - Method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
getUnknownFields() - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
getValue() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
bytes value = 2;
getValue() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
bytes value = 2;
getValue() - Method in interface io.apicurio.registry.utils.streams.distore.proto.KeyValueOrBuilder
bytes value = 2;
getValue() - Method in class io.apicurio.registry.utils.streams.distore.proto.Value.Builder
bytes value = 1;
getValue() - Method in class io.apicurio.registry.utils.streams.distore.proto.Value
bytes value = 1;
getValue() - Method in interface io.apicurio.registry.utils.streams.distore.proto.ValueOrBuilder
bytes value = 1;

H

hashCode() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
hashCode() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
hashCode() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
hashCode() - Method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
hashCode() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
hashCode() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
hashCode() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
hashCode() - Method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
hashCode() - Method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
hashCode() - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
hasNext() - Method in class io.apicurio.registry.utils.streams.distore.AbstractStreamToIteratorAdapter
 
hasNext() - Method in class io.apicurio.registry.utils.streams.distore.StreamToKeyValueIteratorAdapter
 
HiLo(LongGenerator) - Constructor for class io.apicurio.registry.utils.streams.ext.LongGenerator.HiLo
 
HiLo(LongGenerator, int) - Constructor for class io.apicurio.registry.utils.streams.ext.LongGenerator.HiLo
 

I

interceptCall(ServerCall<ReqT, RespT>, Metadata, ServerCallHandler<ReqT, RespT>) - Method in class io.apicurio.registry.utils.streams.distore.UnknownStatusDescriptionInterceptor
 
internalGetFieldAccessorTable() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
 
internalGetFieldAccessorTable() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
internalGetFieldAccessorTable() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes.Builder
 
internalGetFieldAccessorTable() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
internalGetFieldAccessorTable() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
 
internalGetFieldAccessorTable() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
internalGetFieldAccessorTable() - Method in class io.apicurio.registry.utils.streams.distore.proto.Key.Builder
 
internalGetFieldAccessorTable() - Method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
internalGetFieldAccessorTable() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
 
internalGetFieldAccessorTable() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
internalGetFieldAccessorTable() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
 
internalGetFieldAccessorTable() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
internalGetFieldAccessorTable() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
 
internalGetFieldAccessorTable() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
internalGetFieldAccessorTable() - Method in class io.apicurio.registry.utils.streams.distore.proto.Size.Builder
 
internalGetFieldAccessorTable() - Method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
internalGetFieldAccessorTable() - Method in class io.apicurio.registry.utils.streams.distore.proto.Value.Builder
 
internalGetFieldAccessorTable() - Method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
internalGetFieldAccessorTable() - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
 
internalGetFieldAccessorTable() - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
io.apicurio.registry.utils.streams.diservice - package io.apicurio.registry.utils.streams.diservice
 
io.apicurio.registry.utils.streams.diservice.proto - package io.apicurio.registry.utils.streams.diservice.proto
 
io.apicurio.registry.utils.streams.distore - package io.apicurio.registry.utils.streams.distore
 
io.apicurio.registry.utils.streams.distore.proto - package io.apicurio.registry.utils.streams.distore.proto
 
io.apicurio.registry.utils.streams.ext - package io.apicurio.registry.utils.streams.ext
 
isInitialized() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
 
isInitialized() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
isInitialized() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes.Builder
 
isInitialized() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
isInitialized() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
 
isInitialized() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
isInitialized() - Method in class io.apicurio.registry.utils.streams.distore.proto.Key.Builder
 
isInitialized() - Method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
isInitialized() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
 
isInitialized() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
isInitialized() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
 
isInitialized() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
isInitialized() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
 
isInitialized() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
isInitialized() - Method in class io.apicurio.registry.utils.streams.distore.proto.Size.Builder
 
isInitialized() - Method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
isInitialized() - Method in class io.apicurio.registry.utils.streams.distore.proto.Value.Builder
 
isInitialized() - Method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
isInitialized() - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
 
isInitialized() - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
isRunning() - Method in interface io.apicurio.registry.utils.streams.ext.Lifecycle
 

K

Key - Class in io.apicurio.registry.utils.streams.distore.proto
Protobuf type io.apicurio.registry.utils.streams.distore.proto.Key
Key.Builder - Class in io.apicurio.registry.utils.streams.distore.proto
Protobuf type io.apicurio.registry.utils.streams.distore.proto.Key
KEY_FIELD_NUMBER - Static variable in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
KEY_FIELD_NUMBER - Static variable in class io.apicurio.registry.utils.streams.distore.proto.Key
 
KEY_FIELD_NUMBER - Static variable in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
KEY_FIELD_NUMBER - Static variable in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
KEYFROM_FIELD_NUMBER - Static variable in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
KeyFromKeyToReq - Class in io.apicurio.registry.utils.streams.distore.proto
Protobuf type io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
KeyFromKeyToReq.Builder - Class in io.apicurio.registry.utils.streams.distore.proto
Protobuf type io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
KeyFromKeyToReqOrBuilder - Interface in io.apicurio.registry.utils.streams.distore.proto
 
KeyOrBuilder - Interface in io.apicurio.registry.utils.streams.distore.proto
 
KeyReq - Class in io.apicurio.registry.utils.streams.distore.proto
Protobuf type io.apicurio.registry.utils.streams.distore.proto.KeyReq
KeyReq.Builder - Class in io.apicurio.registry.utils.streams.distore.proto
Protobuf type io.apicurio.registry.utils.streams.distore.proto.KeyReq
KeyReqOrBuilder - Interface in io.apicurio.registry.utils.streams.distore.proto
 
keySerde() - Method in interface io.apicurio.registry.utils.streams.diservice.AsyncBiFunctionService.WithSerdes
 
KEYTO_FIELD_NUMBER - Static variable in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
KeyValue - Class in io.apicurio.registry.utils.streams.distore.proto
Protobuf type io.apicurio.registry.utils.streams.distore.proto.KeyValue
KeyValue.Builder - Class in io.apicurio.registry.utils.streams.distore.proto
Protobuf type io.apicurio.registry.utils.streams.distore.proto.KeyValue
KeyValueOrBuilder - Interface in io.apicurio.registry.utils.streams.distore.proto
 
KeyValueSerde<K,V> - Class in io.apicurio.registry.utils.streams.distore
 
KeyValueSerde(String, Serde<K>, Serde<V>) - Constructor for class io.apicurio.registry.utils.streams.distore.KeyValueSerde
 
keyValueSerde(String) - Method in class io.apicurio.registry.utils.streams.distore.KeyValueSerde.Registry
 
KeyValueSerde.Registry - Class in io.apicurio.registry.utils.streams.distore
 
KeyValueStoreGrpc - Class in io.apicurio.registry.utils.streams.distore.proto
 
KeyValueStoreGrpc.KeyValueStoreBlockingStub - Class in io.apicurio.registry.utils.streams.distore.proto
 
KeyValueStoreGrpc.KeyValueStoreFutureStub - Class in io.apicurio.registry.utils.streams.distore.proto
 
KeyValueStoreGrpc.KeyValueStoreImplBase - Class in io.apicurio.registry.utils.streams.distore.proto
 
KeyValueStoreGrpc.KeyValueStoreStub - Class in io.apicurio.registry.utils.streams.distore.proto
 
KeyValueStoreGrpcImplLocalDispatcher - Class in io.apicurio.registry.utils.streams.distore
Concrete implementation of KeyValueStoreGrpc.KeyValueStoreImplBase that dispatches the gRPC requests to the appropriately named local ReadOnlyKeyValueStore obtained from given KafkaStreams instance.
KeyValueStoreGrpcImplLocalDispatcher(KafkaStreams, KeyValueSerde.Registry, FilterPredicate<?, ?>) - Constructor for class io.apicurio.registry.utils.streams.distore.KeyValueStoreGrpcImplLocalDispatcher
 
KeyValueStoreImplBase() - Constructor for class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreImplBase
 

L

Lifecycle - Interface in io.apicurio.registry.utils.streams.ext
 
localService(String, KafkaStreams) - Method in class io.apicurio.registry.utils.streams.diservice.DistributedAsyncBiFunctionService
 
localService(String, KafkaStreams) - Method in class io.apicurio.registry.utils.streams.diservice.DistributedService
 
LocalService<S> - Class in io.apicurio.registry.utils.streams.diservice
A holder of local streams service with accompanying serviceName
LocalService(String, S) - Constructor for class io.apicurio.registry.utils.streams.diservice.LocalService
 
localService(String, KafkaStreams) - Method in class io.apicurio.registry.utils.streams.distore.DistributedReadOnlyKeyValueStore
 
LocalService.Registry<S> - Class in io.apicurio.registry.utils.streams.diservice
 
LoggingStateRestoreListener - Class in io.apicurio.registry.utils.streams.ext
 
LoggingStateRestoreListener() - Constructor for class io.apicurio.registry.utils.streams.ext.LoggingStateRestoreListener
 
LongGenerator - Interface in io.apicurio.registry.utils.streams.ext
 
LongGenerator.HiLo - Class in io.apicurio.registry.utils.streams.ext
 

M

mergeFrom(Message) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
 
mergeFrom(BiFunctionReq) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
 
mergeFrom(Message) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes.Builder
 
mergeFrom(BiFunctionRes) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes.Builder
 
mergeFrom(Message) - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
 
mergeFrom(FilterReq) - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
 
mergeFrom(Message) - Method in class io.apicurio.registry.utils.streams.distore.proto.Key.Builder
 
mergeFrom(Key) - Method in class io.apicurio.registry.utils.streams.distore.proto.Key.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.apicurio.registry.utils.streams.distore.proto.Key.Builder
 
mergeFrom(Message) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
 
mergeFrom(KeyFromKeyToReq) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
 
mergeFrom(Message) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
 
mergeFrom(KeyReq) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
 
mergeFrom(Message) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
 
mergeFrom(KeyValue) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
 
mergeFrom(Message) - Method in class io.apicurio.registry.utils.streams.distore.proto.Size.Builder
 
mergeFrom(Size) - Method in class io.apicurio.registry.utils.streams.distore.proto.Size.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.apicurio.registry.utils.streams.distore.proto.Size.Builder
 
mergeFrom(Message) - Method in class io.apicurio.registry.utils.streams.distore.proto.Value.Builder
 
mergeFrom(Value) - Method in class io.apicurio.registry.utils.streams.distore.proto.Value.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.apicurio.registry.utils.streams.distore.proto.Value.Builder
 
mergeFrom(Message) - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
 
mergeFrom(VoidReq) - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class io.apicurio.registry.utils.streams.distore.proto.Key.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class io.apicurio.registry.utils.streams.distore.proto.Size.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class io.apicurio.registry.utils.streams.distore.proto.Value.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
 

N

newBlockingStub(Channel) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.AsyncBiFunctionServiceGrpc
Creates a new blocking-style stub that supports unary and streaming output calls on the service
newBlockingStub(Channel) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc
Creates a new blocking-style stub that supports unary and streaming output calls on the service
newBuilder() - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
newBuilder(BiFunctionReq) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
newBuilder() - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
newBuilder(BiFunctionRes) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
newBuilder() - Static method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
newBuilder(FilterReq) - Static method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
newBuilder() - Static method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
newBuilder(Key) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
newBuilder() - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
newBuilder(KeyFromKeyToReq) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
newBuilder() - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
newBuilder(KeyReq) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
newBuilder() - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
newBuilder(KeyValue) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
newBuilder() - Static method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
newBuilder(Size) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
newBuilder() - Static method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
newBuilder(Value) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
newBuilder() - Static method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
newBuilder(VoidReq) - Static method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
newBuilderForType() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
newBuilderForType() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
newBuilderForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
newBuilderForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
newBuilderForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
newBuilderForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
newBuilderForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
newBuilderForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
newBuilderForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
newBuilderForType() - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
newFutureStub(Channel) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.AsyncBiFunctionServiceGrpc
Creates a new ListenableFuture-style stub that supports unary calls on the service
newFutureStub(Channel) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc
Creates a new ListenableFuture-style stub that supports unary calls on the service
newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
newRegistry() - Static method in class io.apicurio.registry.utils.streams.distore.KeyValueSerde
 
newStub(Channel) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.AsyncBiFunctionServiceGrpc
Creates a new async stub that supports all call types for the service
newStub(Channel) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc
Creates a new async stub that supports all call types for the service
next() - Method in class io.apicurio.registry.utils.streams.distore.AbstractStreamToIteratorAdapter
 
next() - Method in class io.apicurio.registry.utils.streams.distore.StreamToKeyValueIteratorAdapter
 

O

onBatchRestored(TopicPartition, String, long, long) - Method in class io.apicurio.registry.utils.streams.ext.LoggingStateRestoreListener
 
onCompleted() - Method in class io.apicurio.registry.utils.streams.diservice.StreamObserverCompletableFuture
 
onCompleted() - Method in class io.apicurio.registry.utils.streams.distore.StreamObserverSpliterator
 
onError(Throwable) - Method in class io.apicurio.registry.utils.streams.diservice.StreamObserverCompletableFuture
 
onError(Throwable) - Method in class io.apicurio.registry.utils.streams.distore.StreamObserverSpliterator
 
onNext(T) - Method in class io.apicurio.registry.utils.streams.diservice.StreamObserverCompletableFuture
 
onNext(T) - Method in class io.apicurio.registry.utils.streams.distore.StreamObserverSpliterator
 
onRestoreEnd(TopicPartition, String, long) - Method in class io.apicurio.registry.utils.streams.ext.LoggingStateRestoreListener
 
onRestoreStart(TopicPartition, String, long, long) - Method in class io.apicurio.registry.utils.streams.ext.LoggingStateRestoreListener
 
OVER_FIELD_NUMBER - Static variable in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 

P

parseDelimitedFrom(InputStream) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
parseDelimitedFrom(InputStream) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
parseDelimitedFrom(InputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
parseDelimitedFrom(InputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
parseDelimitedFrom(InputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
parseDelimitedFrom(InputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
parseDelimitedFrom(InputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
parseDelimitedFrom(InputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
parseDelimitedFrom(InputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
parseDelimitedFrom(InputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
parseFrom(ByteBuffer) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
parseFrom(ByteString) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
parseFrom(byte[]) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
parseFrom(InputStream) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
parseFrom(CodedInputStream) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
parseFrom(ByteBuffer) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
parseFrom(ByteString) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
parseFrom(byte[]) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
parseFrom(InputStream) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
parseFrom(CodedInputStream) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
parseFrom(ByteBuffer) - Static method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
parseFrom(ByteString) - Static method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
parseFrom(byte[]) - Static method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
parseFrom(InputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
parseFrom(CodedInputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
parseFrom(ByteBuffer) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
parseFrom(ByteString) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
parseFrom(byte[]) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
parseFrom(InputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
parseFrom(CodedInputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
parseFrom(ByteBuffer) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
parseFrom(ByteString) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
parseFrom(byte[]) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
parseFrom(InputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
parseFrom(CodedInputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
parseFrom(ByteBuffer) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
parseFrom(ByteString) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
parseFrom(byte[]) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
parseFrom(InputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
parseFrom(CodedInputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
parseFrom(ByteBuffer) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
parseFrom(ByteString) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
parseFrom(byte[]) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
parseFrom(InputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
parseFrom(CodedInputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
parseFrom(ByteBuffer) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
parseFrom(ByteString) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
parseFrom(byte[]) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
parseFrom(InputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
parseFrom(CodedInputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
parseFrom(ByteBuffer) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
parseFrom(ByteString) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
parseFrom(byte[]) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
parseFrom(InputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
parseFrom(CodedInputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
parseFrom(ByteBuffer) - Static method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
parseFrom(ByteString) - Static method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
parseFrom(byte[]) - Static method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
parseFrom(InputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
parseFrom(CodedInputStream) - Static method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
parser() - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
parser() - Static method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
parser() - Static method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
parser() - Static method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
parser() - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
parser() - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
parser() - Static method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
parser() - Static method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
parser() - Static method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
parser() - Static method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
peekNextKey() - Method in class io.apicurio.registry.utils.streams.distore.StreamToKeyValueIteratorAdapter
 

R

range(K, K) - Method in class io.apicurio.registry.utils.streams.distore.DistributedReadOnlyKeyValueStore
 
range(K, K) - Method in class io.apicurio.registry.utils.streams.distore.ExtReadOnlyKeyValueStoreImpl
 
range(KeyFromKeyToReq, StreamObserver<KeyValue>) - Method in class io.apicurio.registry.utils.streams.distore.KeyValueStoreGrpcImplLocalDispatcher
 
range(KeyFromKeyToReq) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreBlockingStub
KeyValueIterator<K, V> range(K from, K to);
range(KeyFromKeyToReq, StreamObserver<KeyValue>) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreImplBase
KeyValueIterator<K, V> range(K from, K to);
range(KeyFromKeyToReq, StreamObserver<KeyValue>) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc.KeyValueStoreStub
KeyValueIterator<K, V> range(K from, K to);
range(K, K) - Method in class io.apicurio.registry.utils.streams.distore.ReadOnlyKeyValueStoreGrpcClient
 
ReadOnlyKeyValueStoreGrpcClient<K,V> - Class in io.apicurio.registry.utils.streams.distore
A gRPC based client of some remote ReadOnlyKeyValueStore.
ReadOnlyKeyValueStoreGrpcClient(String, Channel, Serde<K>, Serde<V>) - Constructor for class io.apicurio.registry.utils.streams.distore.ReadOnlyKeyValueStoreGrpcClient
 
register(String, Serde<K>, Serde<V>) - Method in class io.apicurio.registry.utils.streams.distore.KeyValueSerde.Registry
 
register(ForeachAction<? super K, ? super V>) - Method in class io.apicurio.registry.utils.streams.ext.ForeachActionDispatcher
 
registerAllExtensions(ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.Diservice
 
registerAllExtensions(ExtensionRegistry) - Static method in class io.apicurio.registry.utils.streams.diservice.proto.Diservice
 
registerAllExtensions(ExtensionRegistryLite) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Distore
 
registerAllExtensions(ExtensionRegistry) - Static method in class io.apicurio.registry.utils.streams.distore.proto.Distore
 
Registry(Collection<LocalService<? extends S>>) - Constructor for class io.apicurio.registry.utils.streams.diservice.LocalService.Registry
 
remoteServiceGrpcClient(String, Channel, Serde<K>) - Method in class io.apicurio.registry.utils.streams.diservice.DistributedAsyncBiFunctionService
 
remoteServiceGrpcClient(String, Channel, Serde<K>) - Method in class io.apicurio.registry.utils.streams.diservice.DistributedService
 
remoteServiceGrpcClient(String, Channel, Serde<K>, Serde<V>) - Method in class io.apicurio.registry.utils.streams.distore.DistributedReadOnlyKeyValueStore
 
remoteServiceGrpcClient(String, Channel, Serde<K>) - Method in class io.apicurio.registry.utils.streams.distore.DistributedReadOnlyStateStore
 
remoteServiceGrpcClient(String, Channel, Serde<K>, Serde<V>) - Method in class io.apicurio.registry.utils.streams.distore.DistributedReadOnlyStateStore
 
REQ_FIELD_NUMBER - Static variable in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
reqSerde() - Method in interface io.apicurio.registry.utils.streams.diservice.AsyncBiFunctionService.WithSerdes
 
RES_FIELD_NUMBER - Static variable in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
resSerde() - Method in interface io.apicurio.registry.utils.streams.diservice.AsyncBiFunctionService.WithSerdes
 

S

serializeKey(String, K) - Method in class io.apicurio.registry.utils.streams.distore.KeyValueSerde.Registry
 
serializeKey(K) - Method in class io.apicurio.registry.utils.streams.distore.KeyValueSerde
 
serializeVal(String, V) - Method in class io.apicurio.registry.utils.streams.distore.KeyValueSerde.Registry
 
serializeVal(V) - Method in class io.apicurio.registry.utils.streams.distore.KeyValueSerde
 
SERVICE_NAME - Static variable in class io.apicurio.registry.utils.streams.diservice.proto.AsyncBiFunctionServiceGrpc
 
SERVICE_NAME - Static variable in class io.apicurio.registry.utils.streams.distore.proto.KeyValueStoreGrpc
 
serviceForKey(K) - Method in class io.apicurio.registry.utils.streams.diservice.DistributedService
 
SERVICENAME_FIELD_NUMBER - Static variable in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
setField(Descriptors.FieldDescriptor, Object) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.Key.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.Size.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.Value.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
 
setFilter(String) - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
string filter = 1;
setFilterBytes(ByteString) - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
string filter = 1;
setKey(ByteString) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
bytes key = 1;
setKey(ByteString) - Method in class io.apicurio.registry.utils.streams.distore.proto.Key.Builder
bytes key = 1;
setKey(ByteString) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
bytes key = 1;
setKey(ByteString) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
bytes key = 1;
setKeyFrom(ByteString) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
bytes keyFrom = 1;
setKeyTo(ByteString) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
bytes keyTo = 2;
setOver(String) - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
string over = 2;
setOverBytes(ByteString) - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
string over = 2;
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.Key.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.Size.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.Value.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
 
setReq(ByteString) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
bytes req = 2;
setRes(ByteString) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes.Builder
bytes res = 1;
setServiceName(String) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
string serviceName = 3;
setServiceNameBytes(ByteString) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
string serviceName = 3;
setSize(long) - Method in class io.apicurio.registry.utils.streams.distore.proto.Size.Builder
int64 Size = 1;
setStoreName(String) - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
string storeName = 3;
setStoreName(String) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
string storeName = 3;
setStoreName(String) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
string storeName = 2;
setStoreName(String) - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
string storeName = 1;
setStoreNameBytes(ByteString) - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
string storeName = 3;
setStoreNameBytes(ByteString) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
string storeName = 3;
setStoreNameBytes(ByteString) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
string storeName = 2;
setStoreNameBytes(ByteString) - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
string storeName = 1;
setUnknownFields(UnknownFieldSet) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class io.apicurio.registry.utils.streams.distore.proto.Key.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class io.apicurio.registry.utils.streams.distore.proto.Size.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class io.apicurio.registry.utils.streams.distore.proto.Value.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq.Builder
 
setValue(ByteString) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue.Builder
bytes value = 2;
setValue(ByteString) - Method in class io.apicurio.registry.utils.streams.distore.proto.Value.Builder
bytes value = 1;
Size - Class in io.apicurio.registry.utils.streams.distore.proto
Protobuf type io.apicurio.registry.utils.streams.distore.proto.Size
Size.Builder - Class in io.apicurio.registry.utils.streams.distore.proto
Protobuf type io.apicurio.registry.utils.streams.distore.proto.Size
SIZE_FIELD_NUMBER - Static variable in class io.apicurio.registry.utils.streams.distore.proto.Size
 
SizeOrBuilder - Interface in io.apicurio.registry.utils.streams.distore.proto
 
start() - Method in interface io.apicurio.registry.utils.streams.ext.Lifecycle
 
stop() - Method in interface io.apicurio.registry.utils.streams.ext.Lifecycle
 
STORENAME_FIELD_NUMBER - Static variable in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
STORENAME_FIELD_NUMBER - Static variable in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
STORENAME_FIELD_NUMBER - Static variable in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
STORENAME_FIELD_NUMBER - Static variable in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
stream() - Method in class io.apicurio.registry.utils.streams.distore.StreamObserverSpliterator
 
StreamObserverCompletableFuture<T> - Class in io.apicurio.registry.utils.streams.diservice
 
StreamObserverCompletableFuture() - Constructor for class io.apicurio.registry.utils.streams.diservice.StreamObserverCompletableFuture
 
StreamObserverSpliterator<T> - Class in io.apicurio.registry.utils.streams.distore
A Spliterator implementation that emits elements as they are received by the gRPC client which calls into it with new data via StreamObserver interface.
StreamObserverSpliterator() - Constructor for class io.apicurio.registry.utils.streams.distore.StreamObserverSpliterator
 
StreamToIteratorAdapter<K> - Class in io.apicurio.registry.utils.streams.distore
Stream to CloseableIterator
StreamToIteratorAdapter(Stream<K>) - Constructor for class io.apicurio.registry.utils.streams.distore.StreamToIteratorAdapter
 
StreamToKeyIteratorAdapter<K> - Class in io.apicurio.registry.utils.streams.distore
Stream to CloseableIterator
StreamToKeyIteratorAdapter(Stream<Key>, KeyValueSerde<K, ?>) - Constructor for class io.apicurio.registry.utils.streams.distore.StreamToKeyIteratorAdapter
 
StreamToKeyValueIteratorAdapter<K,V> - Class in io.apicurio.registry.utils.streams.distore
An adapter that adapts Stream<KeyValue<K, V>> to KeyValueIterator<K, V> and lazily evaluates it when 1st queried.
StreamToKeyValueIteratorAdapter(Stream<KeyValue<K, V>>) - Constructor for class io.apicurio.registry.utils.streams.distore.StreamToKeyValueIteratorAdapter
 

T

test(String, String, K, V) - Method in interface io.apicurio.registry.utils.streams.distore.FilterPredicate
Predicate like for filtering keyvalue store.
toBuilder() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
toBuilder() - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
toBuilder() - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
toBuilder() - Method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
toBuilder() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
toBuilder() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
toBuilder() - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
toBuilder() - Method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
toBuilder() - Method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
toBuilder() - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
toStream(CloseableIterator<K>) - Static method in class io.apicurio.registry.utils.streams.distore.StreamToIteratorAdapter
 
toStream(KeyValueIterator<K, V>) - Static method in class io.apicurio.registry.utils.streams.distore.StreamToKeyValueIteratorAdapter
 
tryAdvance(Consumer<? super T>) - Method in class io.apicurio.registry.utils.streams.distore.StreamObserverSpliterator
 

U

UnknownStatusDescriptionInterceptor - Class in io.apicurio.registry.utils.streams.distore
A gRPC ServerInterceptor that changes the Status of responses that have Status.Code#UNKNOWN and don't have any Status.getDescription() but do have the Status.getCause() such that the changed Status is obtained from the provided map of exception root classes -> statuses augmented with the following: cause is set to original status cause description is set to original cause's stack trace
UnknownStatusDescriptionInterceptor(Map<Class<? extends Throwable>, Status>) - Constructor for class io.apicurio.registry.utils.streams.distore.UnknownStatusDescriptionInterceptor
 

V

Value - Class in io.apicurio.registry.utils.streams.distore.proto
Protobuf type io.apicurio.registry.utils.streams.distore.proto.Value
Value.Builder - Class in io.apicurio.registry.utils.streams.distore.proto
Protobuf type io.apicurio.registry.utils.streams.distore.proto.Value
VALUE_FIELD_NUMBER - Static variable in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
VALUE_FIELD_NUMBER - Static variable in class io.apicurio.registry.utils.streams.distore.proto.Value
 
ValueOrBuilder - Interface in io.apicurio.registry.utils.streams.distore.proto
 
VoidReq - Class in io.apicurio.registry.utils.streams.distore.proto
Protobuf type io.apicurio.registry.utils.streams.distore.proto.VoidReq
VoidReq.Builder - Class in io.apicurio.registry.utils.streams.distore.proto
Protobuf type io.apicurio.registry.utils.streams.distore.proto.VoidReq
VoidReqOrBuilder - Interface in io.apicurio.registry.utils.streams.distore.proto
 

W

writeTo(CodedOutputStream) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionReq
 
writeTo(CodedOutputStream) - Method in class io.apicurio.registry.utils.streams.diservice.proto.BiFunctionRes
 
writeTo(CodedOutputStream) - Method in class io.apicurio.registry.utils.streams.distore.proto.FilterReq
 
writeTo(CodedOutputStream) - Method in class io.apicurio.registry.utils.streams.distore.proto.Key
 
writeTo(CodedOutputStream) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyFromKeyToReq
 
writeTo(CodedOutputStream) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyReq
 
writeTo(CodedOutputStream) - Method in class io.apicurio.registry.utils.streams.distore.proto.KeyValue
 
writeTo(CodedOutputStream) - Method in class io.apicurio.registry.utils.streams.distore.proto.Size
 
writeTo(CodedOutputStream) - Method in class io.apicurio.registry.utils.streams.distore.proto.Value
 
writeTo(CodedOutputStream) - Method in class io.apicurio.registry.utils.streams.distore.proto.VoidReq
 
A B C D E F G H I K L M N O P R S T U V W 
Skip navigation links

Copyright © 2020 Red Hat. All rights reserved.