emr_serverless

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

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

type JobRunParams struct {
	ApplicationID string
	ExecutionRole string
	Entrypoint    string
	Args          []string
	Config        string
	Timeout       time.Duration
	Region        string
	Logs          string
}

type LogConsumer interface {
	Next() []LogLine
}

type LogLine struct {
	Message string
	Source  LogSource
}

type LogSource struct {
	URI    *url.URL
	Name   string
	Stream string
}

type NoOpLogConsumer struct{}

type PollTimer struct {
	BaseDuration time.Duration
	RetryCount   int
	MaxRetry     int
}

type S3LogConsumer struct {
	Ctx   context.Context //nolint
	S3cli *s3.Client
	URI   *url.URL
	RunID string
	AppID string
	// contains filtered or unexported fields
}