emr_serverless

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

type CheckRunner interface {
	Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error
}

type Client struct {
	Config
}

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

type Config struct {
	AccessKey     string `yaml:"access_key"`
	SecretKey     string `yaml:"secret_key"`
	ApplicationID string `yaml:"application_id"`
	ExecutionRole string `yaml:"execution_role"`
	Region        string `yaml:"region"`
	Workspace     string `yaml:"workspace"`
}

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

type CustomCheckRunner interface {
	Check(ctx context.Context, ti *scheduler.CustomCheckInstance) error
}

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
	Workspace     string
}

type LogConsumer interface {
	Next() []LogLine
}

type LogLine struct {
	Message string
	Source  LogSource
}

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

type MissingFieldsError struct {
	Fields []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
}