NewApp returns a new App.

NewCloudWatchEventEmitter returns a new CloudWatchEventEmitter.

NewClusterState returns a new ClusterState.

NewElasticsearchFacade returns a new ElasticsearchFacade.

NewFlags returns a new Flags.

NewInstrumentation returns a new Metrics.

NewLifecycleAction returns a new LifecycleAction from a CloudWatchEvent.

NewLifecycleActionPostponer returns a new LifecycleActionPostponer.

ErrTestLifecycleAction is return by NewLifecycleAction when the passed CloudWatchEvent doesn't represent a valid LifecycleAction.

ErrLifecycleActionTimeout is returned by PostponeLifecycleHookAction when the lifecycle action times out (or isn't found in the first place).

App holds application state.

CloudWatchEventEmitter consumes CloudWatch events from an SQS queue and emits them as github.com/olebedev/emitter events.

ClusterState represents the state of an Elasticsearch cluster.

ElasticsearchFacade provides a facade for the drainer app's interactions with the ElasticsearchFacade API.

Flags holds command line flags for the drainer App.

Instrumentation holds Prometheus metrics specific to the drainer App.

LifecycleAction contains information about on on-going AWS AutoScaling Group scaling event, as related to a Lifecycle Hook on that Group.

LifecycleActionPostponer prevents LifecycleActions from timing out.

ElasticsearchFacadeIface is an interface for Elasticsearch so it can be mocked during tests.