task

type DefaultClusterGetter interface {
	DefaultCluster() (string, error)
}

type EnvRunner struct {
	// Count of the tasks to be launched.
	Count int
	// Group Name of the tasks that use the same task definition.
	GroupName string

	// App and Env in which the tasks will be launched.
	App string
	Env string

	// Interfaces to interact with dependencies. Must not be nil.
	VPCGetter     VPCGetter
	ClusterGetter ResourceGetter
	Starter       TaskRunner
}

type EventsWriter struct {
	GroupName string
	Tasks     []*Task

	Writer       io.Writer
	EventsLogger TaskEventsLogger
	Describer    TasksDescriber
	// contains filtered or unexported fields
}

type NetworkConfigRunner struct {
	// Count of the tasks to be launched.
	Count int
	// Group Name of the tasks that use the same task definition.
	GroupName string

	// Network configuration
	Subnets        []string
	SecurityGroups []string

	// Interfaces to interact with dependencies. Must not be nil.
	ClusterGetter DefaultClusterGetter
	Starter       TaskRunner

	// Must not be nil if using default subnets.
	VPCGetter VPCGetter
}

type ResourceGetter interface {
	GetResourcesByTags(resourceType string, tags map[string]string) ([]*resourcegroups.Resource, error)
}

type Task struct {
	TaskARN    string
	ClusterARN string
	StartedAt  *time.Time
}

type TaskEventsLogger interface {
	TaskLogEvents(logGroupName string,
		streamLastEventTime map[string]int64,
		opts ...cloudwatchlogs.GetLogEventsOpts) (*cloudwatchlogs.LogEventsOutput, error)
}

type TaskRunner interface {
	RunTask(input ecs.RunTaskInput) ([]*ecs.Task, error)
}

type TasksDescriber interface {
	DescribeTasks(cluster string, taskARNs []string) ([]*ecs.Task, error)
}

type VPCGetter interface {
	SubnetIDs(filters ...ec2.Filter) ([]string, error)
	SecurityGroups(filters ...ec2.Filter) ([]string, error)
	PublicSubnetIDs(filters ...ec2.Filter) ([]string, error)
}