job

type Alert struct {
	On       string
	Config   map[string]string
	Channels []string
	Severity string
	Team     string
}

type Asset struct {
	Name  string
	Value string
}

type Change struct {
	Property string `json:"attribute_name"`
	Diff     string `json:"diff"`
}

type ChangeLog struct {
	Change []Change
	Type   string
	Time   time.Time
}

type Config struct {
	Configs map[string]string
}

type Downstream struct {
	JobName       string `json:"job_name"`
	ProjectName   string `json:"project_name"`
	NamespaceName string `json:"namespace_name"`
	TaskName      string `json:"task_name"`
}

type Hook struct {
	Name        string               `json:"name,omitempty"`
	Version     string               `json:"version,omitempty"`
	Config      map[string]string    `json:"config,omitempty"`
	AlertConfig *OperatorAlertConfig `json:"alert_config,omitempty"`
}

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

type JobWithThirdPartyUpstream struct {
	JobName                      string            `json:"job_name"`
	ProjectName                  string            `json:"project_name"`
	UpstreamThirdPartyType       string            `json:"upstream_third_party_type"`
	UpstreamThirdPartyIdentifier string            `json:"upstream_third_party_identifier"`
	UpstreamThirdPartyConfig     map[string]string `json:"upstream_third_party_config"`
}

type JobWithUpstream struct {
	JobName               string         `json:"job_name"`
	ProjectName           string         `json:"project_name"`
	UpstreamJobName       sql.NullString `json:"upstream_job_name"`
	UpstreamResourceURN   sql.NullString `json:"upstream_resource_urn"`
	UpstreamProjectName   sql.NullString `json:"upstream_project_name"`
	UpstreamNamespaceName sql.NullString `json:"upstream_namespace_name"`
	UpstreamTaskName      sql.NullString `json:"upstream_task_name"`
	UpstreamHost          sql.NullString `json:"upstream_host"`
	UpstreamType          string         `json:"upstream_type"`
	UpstreamState         string         `json:"upstream_state"`
	UpstreamExternal      sql.NullBool   `json:"upstream_external"`
}

type Metadata struct {
	Resource  *MetadataResource
	Scheduler map[string]string
}

type MetadataResource struct {
	Request *MetadataResourceConfig
	Limit   *MetadataResourceConfig
}

type MetadataResourceConfig struct {
	CPU    string
	Memory string
}

type OperatorAlertConfig struct {
	SLAAlertConfigs []*SLAAlertConfig `json:"sla_alert_configs,omitempty"`
	Team            string            `json:"team,omitempty"`
}

type ProjectAndJobNames struct {
	ProjectName string `json:"project_name"`
	JobName     string `json:"job_name"`
}

type Retry struct {
	Count              int
	Delay              int64
	ExponentialBackoff bool
}

type SLAAlertConfig struct {
	DurationThreshold time.Duration `json:"duration_threshold,omitempty"`
	Severity          string        `json:"severity,omitempty"`
	Team              string        `json:"team,omitempty"`
	AutoThreshold     bool          `json:"auto_threshold,omitempty"`
}

type Schedule struct {
	StartDate     time.Time
	EndDate       *time.Time `json:",omitempty"`
	Interval      string
	DependsOnPast bool
	CatchUp       bool
	Retry         *Retry
}

type Spec struct {
	ID          uuid.UUID
	Name        string
	Version     int
	Owner       string
	Description string
	Labels      map[string]string
	State       string

	Schedule   json.RawMessage
	WindowSpec json.RawMessage

	Alert   json.RawMessage
	Webhook json.RawMessage

	StaticUpstreams pq.StringArray
	HTTPUpstreams   json.RawMessage

	TaskName   string
	TaskConfig json.RawMessage

	Hooks json.RawMessage

	Assets map[string]string

	Metadata json.RawMessage

	Destination string
	Sources     pq.StringArray

	ProjectName   string `json:"project_name"`
	NamespaceName string `json:"namespace_name"`

	CreatedAt time.Time
	UpdatedAt time.Time
	DeletedAt sql.NullTime

	IsDirty bool
}

type TaskConfig struct {
	Version     string               `json:"version,omitempty"`
	Config      map[string]string    `json:"config,omitempty"`
	AlertConfig *OperatorAlertConfig `json:"alert_config,omitempty"`
}

type Webhook struct {
	On        string
	Endpoints []WebhookEndpoint
}

type WebhookEndpoint struct {
	URL     string
	Headers map[string]string
}

type Window struct {
	WindowSize       string `json:",omitempty"`
	WindowShiftBy    string `json:",omitempty"`
	WindowTruncateTo string `json:",omitempty"`
	WindowLocation   string `json:",omitempty"`
	WindowOffset     string `json:",omitempty"`
	Preset           string `json:",omitempty"`
	Type             string
}