Uses of Class
io.streamthoughts.azkarra.api.util.Endpoint
-
-
Uses of Endpoint in io.streamthoughts.azkarra.api.query
Methods in io.streamthoughts.azkarra.api.query that return types with arguments of type Endpoint Modifier and Type Method Description Set<Endpoint>
LocalStoreAccessProvider. findAllEndpointsForStore(String storeName)
-
Uses of Endpoint in io.streamthoughts.azkarra.api.streams
Methods in io.streamthoughts.azkarra.api.streams that return Endpoint Modifier and Type Method Description Endpoint
KafkaStreamsInstance. endpoint()
Methods in io.streamthoughts.azkarra.api.streams that return types with arguments of type Endpoint Modifier and Type Method Description Optional<Endpoint>
KafkaStreamsContainer. endpoint()
Gets the endpoint configured for thisKafkaStreams
instance.Methods in io.streamthoughts.azkarra.api.streams with parameters of type Endpoint Modifier and Type Method Description boolean
KafkaStreamsContainer. checkEndpoint(Endpoint endpoint)
Checks whether the givenEndpoint
is the same as this container.Constructors in io.streamthoughts.azkarra.api.streams with parameters of type Endpoint Constructor Description KafkaStreamsInstance(String id, Endpoint endpoint, boolean isLocal, KafkaStreamsMetadata metadata)
Creates a newKafkaStreamsInstance
instance. -
Uses of Endpoint in io.streamthoughts.azkarra.api.util
Methods in io.streamthoughts.azkarra.api.util that return Endpoint Modifier and Type Method Description static Endpoint
Endpoint. of(String endpoint)
-
Uses of Endpoint in io.streamthoughts.azkarra.http.data
Methods in io.streamthoughts.azkarra.http.data that return Endpoint Modifier and Type Method Description Endpoint
StreamsInstanceInfo. getEndpoint()
Methods in io.streamthoughts.azkarra.http.data with parameters of type Endpoint Modifier and Type Method Description StreamsInstanceInfo.Builder
StreamsInstanceInfo.Builder. setEndpoint(Endpoint endpoint)
Constructors in io.streamthoughts.azkarra.http.data with parameters of type Endpoint Constructor Description StreamsInstanceInfo(String id, long since, String name, String version, String description, Endpoint endpoint, StreamsInstanceInfo.State state, String exception)
-
Uses of Endpoint in io.streamthoughts.azkarra.http.query
Methods in io.streamthoughts.azkarra.http.query with parameters of type Endpoint Modifier and Type Method Description <K,V>
QueryCall<K,V>RestApiQueryCallFactory. create(String applicationId, Endpoint localEndpoint, Endpoint remoteEndpoint, QueryRequest queryRequest)
Constructors in io.streamthoughts.azkarra.http.query with parameters of type Endpoint Constructor Description RestApiQueryCall(String applicationId, Endpoint localEndpoint, Endpoint remoteEndpoint, AzkarraV1Api api, QueryRequest request)
Creates a newRestApiQueryCall
instance. -
Uses of Endpoint in io.streamthoughts.azkarra.runtime.query
Methods in io.streamthoughts.azkarra.runtime.query that return Endpoint Modifier and Type Method Description Endpoint
LocalQueryCall. getLocalEndpoint()
Methods in io.streamthoughts.azkarra.runtime.query with parameters of type Endpoint Modifier and Type Method Description <K,V>
QueryCall<K,V>RemoteQueryCallFactory. create(String applicationServer, Endpoint localEndpoint, Endpoint remoteEndpoint, QueryRequest query)
-
Uses of Endpoint in io.streamthoughts.azkarra.runtime.streams
Methods in io.streamthoughts.azkarra.runtime.streams that return types with arguments of type Endpoint Modifier and Type Method Description Optional<Endpoint>
LocalKafkaStreamsContainer. endpoint()
Gets the endpoint configured for thisKafkaStreams
instance.Set<Endpoint>
LocalKafkaStreamsContainer. findAllEndpointsForStore(String storeName)
Methods in io.streamthoughts.azkarra.runtime.streams with parameters of type Endpoint Modifier and Type Method Description boolean
LocalKafkaStreamsContainer. checkEndpoint(Endpoint endpoint)
Checks whether the givenEndpoint
is the same as this container.
-