stream

type CloudWatchDescriber interface {
	AlarmStatuses(opts ...cloudwatch.DescribeAlarmOpts) ([]cloudwatch.AlarmStatus, error)
}

type ECSDeployment struct {
	Status          string
	TaskDefRevision string
	DesiredCount    int
	RunningCount    int
	FailedCount     int
	PendingCount    int
	RolloutState    string
	CreatedAt       time.Time
	UpdatedAt       time.Time
	Id              string
}

type ECSDeploymentStreamer struct {
	// contains filtered or unexported fields
}

type ECSService struct {
	Deployments         []ECSDeployment
	LatestFailureEvents []string
	Alarms              []cloudwatch.AlarmStatus
	StoppedTasks        []ecs.Task
}

type ECSServiceDescriber interface {
	Service(clusterName, serviceName string) (*ecs.Service, error)
	StoppedServiceTasks(cluster, service string) ([]*ecs.Task, error)
}

type StackEvent struct {
	LogicalResourceID    string
	PhysicalResourceID   string
	ResourceType         string
	ResourceStatus       string
	ResourceStatusReason string
	Timestamp            time.Time
}

type StackEventsDescriber interface {
	DescribeStackEvents(*cloudformation.DescribeStackEventsInput) (*cloudformation.DescribeStackEventsOutput, error)
}

type StackSetDescriber interface {
	InstanceSummaries(name string, opts ...stackset.InstanceSummariesOption) ([]stackset.InstanceSummary, error)
	DescribeOperation(name, opID string) (stackset.Operation, error)
}

type StackSetOpEvent struct {
	Name      string // The name of the stack set.
	Operation stackset.Operation
}

type StackSetStreamer struct {
	// contains filtered or unexported fields
}

type StackStreamer struct {
	// contains filtered or unexported fields
}

type Streamer interface {
	// Fetch fetches events, updates the internal state of the Streamer with new events and returns the next time
	// the Fetch call should be attempted. On failure, Fetch returns an error.
	Fetch() (next time.Time, done bool, err error)

	// Notify publishes all new event updates to subscribers.
	Notify()

	// Close notifies all subscribers that no more events will be sent.
	Close()
}