logging

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

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

type HumanJSONStringer interface {
	HumanString() string
	JSONString() (string, error)
}

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

type NewAppRunnerServiceLoggerOpts struct {
	*NewWorkloadLoggerOpts
	ConfigStore describe.ConfigStoreSvc
}

type NewWorkloadLoggerOpts struct {
	App  string
	Env  string
	Name string
	Sess *session.Session
}

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

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

type WriteLogEventsOpts struct {
	Follow    bool
	Limit     *int64
	StartTime *int64
	EndTime   *int64
	// OnEvents is a handler that's invoked when logs are retrieved from the service.
	OnEvents func(w io.Writer, logs []HumanJSONStringer) error
	LogGroup string

	// Job specific options.
	IncludeStateMachineLogs bool
	// LogStreamLimit is an optional parameter for jobs and tasks to speed up CW queries
	// involving multiple log streams.
	LogStreamLimit int

	// ECS specific options.
	ContainerName string
	TaskIDs       []string
}