software.amazon.kinesis.coordinator

Class StreamInfoManager

java.lang.Object

software.amazon.kinesis.coordinator.StreamInfoManager

public class StreamInfoManager
extends Object

Constructor Summary

Constructors

Constructor and Description
StreamInfoManager()

Method Summary

Modifier and Type	Method and Description
void	createStreamInfo(StreamIdentifier streamIdentifier) Creates new streamInfo
void	deleteStreamInfo(StreamIdentifier streamIdentifier) Deletes StreamInfo if it does exist.
void	start()
void	stop(boolean isShutdown)

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamInfoManager

public StreamInfoManager()

Method Detail

start

public void start()

stop

public void stop(boolean isShutdown)

createStreamInfo

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

Creates new streamInfo

Parameters:

streamIdentifier - streamIdentifier to create streamInfo for

Throws:

DependencyException

InvalidStateException

ProvisionedThroughputException

deleteStreamInfo

public void deleteStreamInfo(StreamIdentifier streamIdentifier)
                      throws ProvisionedThroughputException,
                             InvalidStateException,
                             DependencyException

Deletes StreamInfo if it does exist.

Parameters:

streamIdentifier - streamIdentifier to create streamInfo for

Throws:

DependencyException

InvalidStateException

ProvisionedThroughputException