software.amazon.kinesis.coordinator.streamInfo

Class StreamInfoDAO

java.lang.Object

software.amazon.kinesis.coordinator.streamInfo.StreamInfoDAO

public class StreamInfoDAO
extends Object

Constructor Summary

Constructors

Constructor and Description
StreamInfoDAO(CoordinatorStateDAO coordinatorStateDAO, software.amazon.awssdk.services.kinesis.KinesisAsyncClient kinesisAsyncClient)

Method Summary

Modifier and Type	Method and Description
boolean	createStreamInfo(StreamIdentifier streamIdentifier) Create a new StreamInfo if it does not exist.
boolean	deleteStreamInfo(String key) Deletes StreamInfo if it does exist.
StreamInfo	getStreamInfo(String key)
List<StreamInfo>	listStreamInfo() List all the StreamInfo from the DDB table synchronously

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamInfoDAO

public StreamInfoDAO(CoordinatorStateDAO coordinatorStateDAO,
                     software.amazon.awssdk.services.kinesis.KinesisAsyncClient kinesisAsyncClient)

Method Detail

createStreamInfo

public boolean createStreamInfo(StreamIdentifier streamIdentifier)
                         throws InvalidStateException,
                                DependencyException,
                                ProvisionedThroughputException

Create a new StreamInfo if it does not exist.

Parameters:

streamIdentifier - the stream identifier used to create the StreamInfo

Returns:

true if state was streamInfo, false if it already exists

Throws:

DependencyException - if DynamoDB put fails in an unexpected way

InvalidStateException - if Coordinator table does not exist

ProvisionedThroughputException - if DynamoDB put fails due to lack of capacity

deleteStreamInfo

public boolean deleteStreamInfo(String key)
                         throws ProvisionedThroughputException,
                                DependencyException,
                                InvalidStateException

Deletes StreamInfo if it does exist.

Parameters:

key - the key to delete

Returns:

true if state was deleted, false if you cannot be deleted

Throws:

DependencyException - if DynamoDB delete fails in an unexpected way

InvalidStateException - if Coordinator table does not exist

ProvisionedThroughputException - if DynamoDB delete fails due to lack of capacity

listStreamInfo

public List<StreamInfo> listStreamInfo()
                                throws DependencyException,
                                       ProvisionedThroughputException,
                                       InvalidStateException

List all the StreamInfo from the DDB table synchronously

Returns:

list of state

Throws:

DependencyException - if DynamoDB scan fails in an unexpected way

InvalidStateException - if ddb Coordinator does not exist

ProvisionedThroughputException - if DynamoDB scan fails due to lack of capacity

getStreamInfo

public StreamInfo getStreamInfo(String key)
                         throws ProvisionedThroughputException,
                                DependencyException,
                                InvalidStateException

Parameters:

key - Get the StreamInfo for this key.

Returns:

state for the specified key, or null if one doesn't exist

Throws:

InvalidStateException - if ddb table does not exist

ProvisionedThroughputException - if DynamoDB get fails due to lack of capacity

DependencyException - if DynamoDB get fails in an unexpected way