Package | Description |
---|---|
io.apicurio.registry.streams | |
io.apicurio.registry.streams.diservice |
Modifier and Type | Method and Description |
---|---|
AsyncBiFunctionServiceGrpc.AsyncBiFunctionServiceImplBase |
StreamsRegistryConfiguration.storageAsyncBiFunctionServiceGrpcImpl(LocalService<AsyncBiFunctionService.WithSerdes<String,Long,Str.Data>> localWaitForDataService,
LocalService<AsyncBiFunctionService.WithSerdes<Void,Void,org.apache.kafka.streams.KafkaStreams.State>> localStateService) |
Modifier and Type | Method and Description |
---|---|
Lifecycle |
StreamsRegistryConfiguration.storageGrpcServer(org.apache.kafka.streams.state.HostInfo storageLocalHost,
KeyValueStoreGrpc.KeyValueStoreImplBase storageStoreGrpcImpl,
AsyncBiFunctionServiceGrpc.AsyncBiFunctionServiceImplBase storageAsyncBiFunctionServiceGrpcImpl) |
Modifier and Type | Class and Description |
---|---|
class |
AsyncBiFunctionServiceGrpcLocalDispatcher |
Copyright © 2020 Red Hat. All rights reserved.