Package com.dtsx.astra.sdk.db

Class DbCdcsClient

java.lang.Object

com.dtsx.astra.sdk.AbstractApiClient

com.dtsx.astra.sdk.db.DbCdcsClient

public class DbCdcsClient
extends AbstractApiClient

Group Operation regarding Cdc for a DB

Field Summary

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

environment, token

Constructor Summary

Constructors

Constructor	Description
DbCdcsClient(String token, ApiLocator.AstraEnvironment env, String databaseId)	As immutable object use builder to initiate the object.
DbCdcsClient(String token, String databaseId)	As immutable object use builder to initiate the object.

Method Summary

Modifier and Type	Method	Description
void	create(String keyspace, String table, String tenant, int topicPartition)	Create cdc from definition.
void	delete(String cdcId)	Delete cdc from its identifier.
void	delete(String keyspace, String table, String tenant)	Delete cdc from its identifier.
Stream<CdcDefinition>	findAll()	Access Cdc component for a DB.
Optional<CdcDefinition>	findByDefinition(String keyspace, String table, String tenant)	Find the cdc based on its components.
Optional<CdcDefinition>	findById(String cdcId)	Find a cdc by its id.

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

DbCdcsClient

public DbCdcsClient(String token,
 String databaseId)

As immutable object use builder to initiate the object.

Parameters:

token - authenticated token

databaseId - database identifier

DbCdcsClient

public DbCdcsClient(String token,
 ApiLocator.AstraEnvironment env,
 String databaseId)

As immutable object use builder to initiate the object.

Parameters:

env - define target environment to be used

token - authenticated token

databaseId - database identifier

Method Details

findAll

public Stream<CdcDefinition> findAll()

Access Cdc component for a DB.

Returns:

list of cdc

findById

public Optional<CdcDefinition> findById(String cdcId)

Find a cdc by its id.

Parameters:

cdcId - identifier

Returns:

cdc definition if exist

findByDefinition

public Optional<CdcDefinition> findByDefinition(String keyspace,
 String table,
 String tenant)

Find the cdc based on its components.

Parameters:

keyspace - keyspace name

table - table name

tenant - tenant identifier

Returns:

definition if present

create

public void create(String keyspace,
 String table,
 String tenant,
 int topicPartition)

Create cdc from definition.

Parameters:

keyspace - keyspace name

table - table name

tenant - tenant identifier

topicPartition - topic partition

delete

public void delete(String cdcId)

Delete cdc from its identifier.

Parameters:

cdcId - cdc identifier

delete

public void delete(String keyspace,
 String table,
 String tenant)

Delete cdc from its identifier.

Parameters:

keyspace - keyspace name

table - table name

tenant - tenant identifier