BiFunction
that returns an asynchronous CompletionStage
result.AsyncBiFunctionService
providing Serde
implementations:
AsyncBiFunctionService.WithSerdes.keySerde()
, AsyncBiFunctionService.WithSerdes.reqSerde()
and AsyncBiFunctionService.WithSerdes.resSerde()
.io.apicurio.registry.streams.diservice.proto.BiFunctionReq
io.apicurio.registry.streams.diservice.proto.BiFunctionReq
io.apicurio.registry.streams.diservice.proto.BiFunctionRes
io.apicurio.registry.streams.diservice.proto.BiFunctionRes
string filter = 1;
bytes key = 1;
bytes key = 1;
bytes key = 1;
bytes key = 1;
bytes keyFrom = 1;
bytes keyTo = 2;
string over = 2;
bytes req = 2;
bytes res = 1;
string serviceName = 3;
int64 Size = 1;
string storeName = 3;
string storeName = 3;
string storeName = 2;
string storeName = 1;
bytes value = 2;
bytes value = 1;
ReadOnlyKeyValueStore
that is distributed among KafkaStreams processing nodes comprising
the distributed streams application.KafkaStreams
processing
nodes comprising the distributed streams application.io.apicurio.registry.streams.distore.proto.FilterReq
io.apicurio.registry.streams.distore.proto.FilterReq
ForeachAction
implementation that dispatches ForeachAction.apply(Object, Object)
invocation to registered
actions.string filter = 1;
string filter = 1;
string filter = 1;
string filter = 1;
string filter = 1;
string filter = 1;
bytes key = 1;
bytes key = 1;
bytes key = 1;
bytes key = 1;
bytes key = 1;
bytes key = 1;
bytes key = 1;
bytes key = 1;
bytes key = 1;
bytes key = 1;
bytes key = 1;
bytes key = 1;
bytes keyFrom = 1;
bytes keyFrom = 1;
bytes keyFrom = 1;
bytes keyTo = 2;
bytes keyTo = 2;
bytes keyTo = 2;
string over = 2;
string over = 2;
string over = 2;
string over = 2;
string over = 2;
string over = 2;
bytes req = 2;
bytes req = 2;
bytes req = 2;
bytes res = 1;
bytes res = 1;
bytes res = 1;
string serviceName = 3;
string serviceName = 3;
string serviceName = 3;
string serviceName = 3;
string serviceName = 3;
string serviceName = 3;
int64 Size = 1;
int64 Size = 1;
int64 Size = 1;
string storeName = 3;
string storeName = 3;
string storeName = 3;
string storeName = 3;
string storeName = 3;
string storeName = 3;
string storeName = 2;
string storeName = 2;
string storeName = 2;
string storeName = 1;
string storeName = 1;
string storeName = 1;
string storeName = 3;
string storeName = 3;
string storeName = 3;
string storeName = 3;
string storeName = 3;
string storeName = 3;
string storeName = 2;
string storeName = 2;
string storeName = 2;
string storeName = 1;
string storeName = 1;
string storeName = 1;
bytes value = 2;
bytes value = 2;
bytes value = 2;
bytes value = 1;
bytes value = 1;
bytes value = 1;
io.apicurio.registry.streams.distore.proto.Key
io.apicurio.registry.streams.distore.proto.Key
io.apicurio.registry.streams.distore.proto.KeyFromKeyToReq
io.apicurio.registry.streams.distore.proto.KeyFromKeyToReq
io.apicurio.registry.streams.distore.proto.KeyReq
io.apicurio.registry.streams.distore.proto.KeyReq
io.apicurio.registry.streams.distore.proto.KeyValue
io.apicurio.registry.streams.distore.proto.KeyValue
KeyValueStoreGrpc.KeyValueStoreImplBase
that dispatches the
gRPC requests to the appropriately named local ReadOnlyKeyValueStore
obtained
from given KafkaStreams
instance.ReadOnlyKeyValueStore
.string filter = 1;
string filter = 1;
bytes key = 1;
bytes key = 1;
bytes key = 1;
bytes key = 1;
bytes keyFrom = 1;
bytes keyTo = 2;
string over = 2;
string over = 2;
bytes req = 2;
bytes res = 1;
string serviceName = 3;
string serviceName = 3;
int64 Size = 1;
string storeName = 3;
string storeName = 3;
string storeName = 2;
string storeName = 1;
string storeName = 3;
string storeName = 3;
string storeName = 2;
string storeName = 1;
bytes value = 2;
bytes value = 1;
io.apicurio.registry.streams.distore.proto.Size
io.apicurio.registry.streams.distore.proto.Size
Spliterator
implementation that emits elements as they are received by the
gRPC client which calls into it with new data via StreamObserver
interface.Stream
<KeyValue
<K, V>> to
KeyValueIterator
<K, V> and lazily evaluates it when 1st queried.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
io.apicurio.registry.streams.distore.proto.Value
io.apicurio.registry.streams.distore.proto.Value
io.apicurio.registry.streams.distore.proto.VoidReq
io.apicurio.registry.streams.distore.proto.VoidReq
Copyright © 2020 Red Hat. All rights reserved.