software.amazon.kinesis.coordinator.streamInfo

Class StreamIdCacheManager

java.lang.Object

software.amazon.kinesis.coordinator.streamInfo.StreamIdCacheManager

public class StreamIdCacheManager
extends Object

Constructor Summary

Constructors

Constructor and Description
StreamIdCacheManager(ScheduledExecutorService scheduledExecutorService, StreamInfoDAO streamInfoDAO, Map<StreamIdentifier,StreamConfig> currentStreamConfigMap, StreamIdOnboardingState streamIdOnboardingState, boolean isMultiStreamMode, @NotNull MetricsFactory metricsFactory)

Method Summary

Modifier and Type	Method and Description
String	get(StreamIdentifier streamIdentifier) Get a value from streamIdCache
Set<String>	getAllCachedStreamIdKey()
void	removeStreamId(String streamIdKey)
void	resolveStreamId(StreamIdentifier streamIdentifier) Resolves the stream ID for the given StreamIdentifier and adds it to the cache.
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamIdCacheManager

public StreamIdCacheManager(ScheduledExecutorService scheduledExecutorService,
                            StreamInfoDAO streamInfoDAO,
                            Map<StreamIdentifier,StreamConfig> currentStreamConfigMap,
                            StreamIdOnboardingState streamIdOnboardingState,
                            boolean isMultiStreamMode,
                            @NotNull
                            @NotNull MetricsFactory metricsFactory)

Method Detail

getAllCachedStreamIdKey

public Set<String> getAllCachedStreamIdKey()

get

public String get(StreamIdentifier streamIdentifier)
           throws InvalidStateException

Get a value from streamIdCache

Parameters:

streamIdentifier - name of the stream

Returns:

the stream ID or null or throws exception if stream ID is not found in ONBOARDED mode

Throws:

InvalidStateException

resolveStreamId

public void resolveStreamId(StreamIdentifier streamIdentifier)

Resolves the stream ID for the given StreamIdentifier and adds it to the cache.

Parameters:

streamIdentifier - streamIdentifier whose StreamId needs to be resolved

removeStreamId

public void removeStreamId(String streamIdKey)

stop

public void stop()