Package com.dtsx.astra.sdk.streaming

Class TenantStatsClient

java.lang.Object

com.dtsx.astra.sdk.AbstractApiClient

com.dtsx.astra.sdk.streaming.TenantStatsClient

public class TenantStatsClient
extends AbstractApiClient

Access metrics on a tenant.

Field Summary

Fields inherited from class com.dtsx.astra.sdk.AbstractApiClient

environment, observers, token

Constructor Summary

Constructors

Constructor	Description
TenantStatsClient(String token, AstraEnvironment env, String tenantId)	As immutable object use builder to initiate the object.
TenantStatsClient(String token, String tenantId)	As immutable object use builder to initiate the object.

Method Summary

Modifier and Type	Method	Description
String	getEndpointStatisticsNamespaces()	Endpoint for namespace statistics.
String	getEndpointStatisticsTopics()	Endpoint for topics statistics.
String	getEndpointStreamingAdminV2()	Endpoint for admin
String	getServiceName()	Provide a service Name.
Optional<Statistics>	keyspace(String namespace)	Retrieve Statistics for one namespace.
Stream<Statistics>	keyspaces()	Retrieve Statistics for all namespaces.
Stream<Statistics>	topics()	Retrieve Statistics for all topics.
Stream<Statistics>	topics(String keyspace)	Retrieve Statistics for topics of a keyspace

Methods inherited from class com.dtsx.astra.sdk.AbstractApiClient

assertHttpCodeAccepted, DELETE, GET, getHttpClient, getOperationName, HEAD, PATCH, POST, POST, PUT

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TenantStatsClient

public TenantStatsClient(String token,
 String tenantId)

As immutable object use builder to initiate the object.

Parameters:

token - authenticated token

tenantId - unique tenant identifier

TenantStatsClient

public TenantStatsClient(String token,
 AstraEnvironment env,
 String tenantId)

As immutable object use builder to initiate the object.

Parameters:

token - authenticated token

env - define target environment to be used

tenantId - unique tenant identifier

Method Details

getServiceName

public String getServiceName()

Provide a service Name.

Specified by:

getServiceName in class AbstractApiClient

Returns:

service name

keyspaces

public Stream<Statistics> keyspaces()

Retrieve Statistics for all namespaces.

Returns:

statistics

keyspace

public Optional<Statistics> keyspace(String namespace)

Retrieve Statistics for one namespace.

Parameters:

namespace - current pulsar namespace

Returns:

statistics

topics

public Stream<Statistics> topics()

Retrieve Statistics for all topics.

Returns:

statistics

topics

public Stream<Statistics> topics(String keyspace)

Retrieve Statistics for topics of a keyspace

Parameters:

keyspace - current pulsar keyspace

Returns:

statistics

getEndpointStreamingAdminV2

public String getEndpointStreamingAdminV2()

Endpoint for admin

Returns:

database endpoint

getEndpointStatisticsNamespaces

public String getEndpointStatisticsNamespaces()

Endpoint for namespace statistics.

Returns:

endpoint

getEndpointStatisticsTopics

public String getEndpointStatisticsTopics()

Endpoint for topics statistics.

Returns:

endpoint