Uses of Class
io.streamthoughts.azkarra.api.streams.StreamsServerInfo
-
-
Uses of StreamsServerInfo in io.streamthoughts.azkarra.api
Methods in io.streamthoughts.azkarra.api that return types with arguments of type StreamsServerInfo Modifier and Type Method Description Set<StreamsServerInfo>AzkarraStreamsService. getStreamsInstancesById(String applicationId)Gets all local and remote streams instances for the specified streams application. -
Uses of StreamsServerInfo in io.streamthoughts.azkarra.api.query
Methods in io.streamthoughts.azkarra.api.query with parameters of type StreamsServerInfo Modifier and Type Method Description <K,V>
CompletableFuture<QueryResult<K,V>>RemoteQueryClient. query(StreamsServerInfo server, QueryInfo query, Queried options)Executes a query to the specified server. -
Uses of StreamsServerInfo in io.streamthoughts.azkarra.api.streams
Methods in io.streamthoughts.azkarra.api.streams that return types with arguments of type StreamsServerInfo Modifier and Type Method Description Set<StreamsServerInfo>KafkaStreamsContainer. getAllMetadata()Collection<StreamsServerInfo>KafkaStreamsContainer. getAllMetadataForStore(String storeName)Optional<StreamsServerInfo>KafkaStreamsContainer. getLocalServerInfo()<K> Optional<StreamsServerInfo>KafkaStreamsContainer. getMetadataForStoreAndKey(String storeName, K key, org.apache.kafka.common.serialization.Serializer<K> keySerializer) -
Uses of StreamsServerInfo in io.streamthoughts.azkarra.http.query
Methods in io.streamthoughts.azkarra.http.query with parameters of type StreamsServerInfo Modifier and Type Method Description <K,V>
CompletableFuture<QueryResult<K,V>>HttpRemoteQueryClient. query(StreamsServerInfo serverInfo, QueryInfo query, Queried options)Executes a query to the specified server. -
Uses of StreamsServerInfo in io.streamthoughts.azkarra.runtime.service
Methods in io.streamthoughts.azkarra.runtime.service that return types with arguments of type StreamsServerInfo Modifier and Type Method Description Set<StreamsServerInfo>LocalAzkarraStreamsService. getStreamsInstancesById(String applicationId)Gets all local and remote streams instances for the specified streams application.
-