Uses of Interface
io.streamthoughts.azkarra.client.openapi.ApiCallback

Packages that use ApiCallback

Package	Description
io.streamthoughts.azkarra.client.openapi
io.streamthoughts.azkarra.client.openapi.apis
io.streamthoughts.azkarra.http.query

Uses of ApiCallback in io.streamthoughts.azkarra.client.openapi

Methods in io.streamthoughts.azkarra.client.openapi with parameters of type ApiCallback

Modifier and Type	Method	Description
okhttp3.Call	ApiClient.buildCall(String path, String method, List<Pair> queryParams, List<Pair> collectionQueryParams, Object body, Map<String,String> headerParams, Map<String,String> cookieParams, Map<String,Object> formParams, String[] authNames, ApiCallback callback)	Build HTTP call with the given options.
okhttp3.Request	ApiClient.buildRequest(String path, String method, List<Pair> queryParams, List<Pair> collectionQueryParams, Object body, Map<String,String> headerParams, Map<String,String> cookieParams, Map<String,Object> formParams, String[] authNames, ApiCallback callback)	Build an HTTP request with the given options.
<T> void	ApiClient.executeAsync(okhttp3.Call call, ApiCallback<T> callback)	ApiClient.executeAsync(Call, Type, ApiCallback)
<T> void	ApiClient.executeAsync(okhttp3.Call call, Type returnType, ApiCallback<T> callback)	Execute HTTP call asynchronously.

Constructors in io.streamthoughts.azkarra.client.openapi with parameters of type ApiCallback

Constructor	Description
ProgressRequestBody(okhttp3.RequestBody requestBody, ApiCallback callback)
ProgressResponseBody(okhttp3.ResponseBody responseBody, ApiCallback callback)

Uses of ApiCallback in io.streamthoughts.azkarra.client.openapi.apis

Methods in io.streamthoughts.azkarra.client.openapi.apis with parameters of type ApiCallback

Modifier and Type	Method	Description
okhttp3.Call	AzkarraVersionApi.getCurrentVersionAsync(ApiCallback<Version> _callback)	(asynchronously) get the API current version
okhttp3.Call	AzkarraVersionApi.getCurrentVersionCall(ApiCallback _callback)	Build call for getCurrentVersion
okhttp3.Call	AzkarraV1Api.getStreamsInstanceConfigAsync(String containerId, ApiCallback<Map<String,Object>> _callback)	(asynchronously) get the configuration of the KafkaStreams instance
okhttp3.Call	AzkarraV1Api.getStreamsInstanceConfigCall(String containerId, ApiCallback _callback)	Build call for getStreamsInstanceConfig
okhttp3.Call	AzkarraV1Api.getStreamsInstanceConsumerOffsetsAsync(String containerId, ApiCallback<V1StreamsConsumerGroupOffsets> _callback)	(asynchronously) get the offset posititions for the consumers of the Kafka Streams instance
okhttp3.Call	AzkarraV1Api.getStreamsInstanceConsumerOffsetsCall(String containerId, ApiCallback _callback)	Build call for getStreamsInstanceConsumerOffsets
okhttp3.Call	AzkarraV1Api.getStreamsInstanceDetailsAsync(String containerId, ApiCallback<V1StreamsDetails> _callback)	(asynchronously) get details about a Kafka Streams instance
okhttp3.Call	AzkarraV1Api.getStreamsInstanceDetailsCall(String containerId, ApiCallback _callback)	Build call for getStreamsInstanceDetails
okhttp3.Call	AzkarraV1Api.getStreamsInstanceMetadataAsync(String containerId, ApiCallback<V1StreamsMetadata> _callback)	(asynchronously) list the KafkaStreams instances currently active on the local Azkarra application
okhttp3.Call	AzkarraV1Api.getStreamsInstanceMetadataCall(String containerId, ApiCallback _callback)	Build call for getStreamsInstanceMetadata
okhttp3.Call	AzkarraV1Api.getStreamsInstanceMetricByGroupAndNameAsync(String containerId, String group, String name, ApiCallback<V1MetricGroup> _callback)	(asynchronously) get the current metric for the streams instance, metric group and name
okhttp3.Call	AzkarraV1Api.getStreamsInstanceMetricByGroupAndNameCall(String containerId, String group, String name, ApiCallback _callback)	Build call for getStreamsInstanceMetricByGroupAndName
okhttp3.Call	AzkarraV1Api.getStreamsInstanceMetricsAsync(String containerId, ApiCallback<List<V1MetricGroup>> _callback)	(asynchronously) get the metrics for the Kafka Streams instance
okhttp3.Call	AzkarraV1Api.getStreamsInstanceMetricsByGroupAsync(String containerId, String group, ApiCallback<List<V1MetricGroup>> _callback)	(asynchronously) get the metrics for the Kafka Streams instance
okhttp3.Call	AzkarraV1Api.getStreamsInstanceMetricsByGroupCall(String containerId, String group, ApiCallback _callback)	Build call for getStreamsInstanceMetricsByGroup
okhttp3.Call	AzkarraV1Api.getStreamsInstanceMetricsCall(String containerId, ApiCallback _callback)	Build call for getStreamsInstanceMetrics
okhttp3.Call	AzkarraV1Api.getStreamsInstanceMetricValueAsync(String containerId, String group, String name, ApiCallback<String> _callback)	(asynchronously) get the current metric value for the streams application, metric group and name
okhttp3.Call	AzkarraV1Api.getStreamsInstanceMetricValueCall(String containerId, String group, String name, ApiCallback _callback)	Build call for getStreamsInstanceMetricValue
okhttp3.Call	AzkarraV1Api.getStreamsInstanceStatusAsync(String containerId, ApiCallback<V1StreamsStatus> _callback)	(asynchronously) get the status about the running tasks of the KafkaStreams instance
okhttp3.Call	AzkarraV1Api.getStreamsInstanceStatusCall(String containerId, ApiCallback _callback)	Build call for getStreamsInstanceStatus
okhttp3.Call	AzkarraV1Api.getStreamsInstanceStoreOffsetsAsync(String containerId, ApiCallback<List<V1LocalStatePartitionsInfo>> _callback)	(asynchronously) gets the partition lag and restoration info for all local state store
okhttp3.Call	AzkarraV1Api.getStreamsInstanceStoreOffsetsCall(String containerId, ApiCallback _callback)	Build call for getStreamsInstanceStoreOffsets
okhttp3.Call	AzkarraV1Api.getStreamsInstanceTopologyAsync(String containerId, ApiCallback<V1StreamsTopology> _callback)	(asynchronously) get the topology graph of the Kafka Streams instance
okhttp3.Call	AzkarraV1Api.getStreamsInstanceTopologyCall(String containerId, ApiCallback _callback)	Build call for getStreamsInstanceTopology
okhttp3.Call	AzkarraV1Api.listKafkaStreamsApplicationIdsAsync(ApiCallback<List<String>> _callback)	(asynchronously) list all ids for the Kafka Streams applications for which at least one instance is currently running.
okhttp3.Call	AzkarraV1Api.listKafkaStreamsApplicationIdsCall(ApiCallback _callback)	Build call for listKafkaStreamsApplicationIds
okhttp3.Call	AzkarraV1Api.listStreamsInstanceIdsAsync(ApiCallback<List<String>> _callback)	(asynchronously) list the KafkaStreams instances currently active on the local Azkarra application
okhttp3.Call	AzkarraV1Api.listStreamsInstanceIdsCall(ApiCallback _callback)	Build call for listStreamsInstanceIds
okhttp3.Call	AzkarraV1Api.queryStateStoreAsync(String applicationId, String storeName, V1Query v1Query, ApiCallback<V1QueryResult> _callback)	(asynchronously) Query a Kafka Streams state store, also known as executing an 'Interactive Query'.
okhttp3.Call	AzkarraV1Api.queryStateStoreCall(String applicationId, String storeName, V1Query v1Query, ApiCallback _callback)	Build call for queryStateStore
okhttp3.Call	AzkarraV1Api.restartStreamsInstanceAsync(String containerId, ApiCallback<Void> _callback)	(asynchronously) restart a running KafkaStreams instance
okhttp3.Call	AzkarraV1Api.restartStreamsInstanceCall(String containerId, ApiCallback _callback)	Build call for restartStreamsInstance
okhttp3.Call	AzkarraV1Api.stopStreamsInstanceAsync(String containerId, V1Options v1Options, ApiCallback<Void> _callback)	(asynchronously) stop a running KafkaStreams instance
okhttp3.Call	AzkarraV1Api.stopStreamsInstanceCall(String containerId, V1Options v1Options, ApiCallback _callback)	Build call for stopStreamsInstance

Uses of ApiCallback in io.streamthoughts.azkarra.http.query

Classes in io.streamthoughts.azkarra.http.query that implement ApiCallback

Modifier and Type	Class	Description
class	AsyncQueryApiCallback<K,V>