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, token

Constructor Summary

Constructors

Constructor	Description
TenantStatsClient(String token, ApiLocator.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
Optional<Statistics>	namespace(String namespace)	Retrieve Statistics for one namespace.
Stream<Statistics>	namespaces()	Retrieve Statistics for all namespaces.
Stream<Statistics>	topics()	Retrieve Statistics for all topics.
Stream<Statistics>	topics(String namespace)	Retrieve Statistics for topics of a namespace

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

assertHttpCodeAccepted, DELETE, GET, getHttpClient, getToken, 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:

tenantId - unique tenant identifier

token - authenticated token

TenantStatsClient

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

As immutable object use builder to initiate the object.

Parameters:

env - define target environment to be used

token - authenticated token

Method Details

namespaces

public Stream<Statistics> namespaces()

Retrieve Statistics for all namespaces.

Returns:

statistics

namespace

public Optional<Statistics> namespace(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 namespace)

Retrieve Statistics for topics of a namespace

Parameters:

namespace - current pulsar namespace

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