scheduler

Oct 21, 2024

Changes in this version

type JobName

+ func (n JobName) GetJobURN(tnnt tenant.Tenant) string

+ type JobRunDetailsList []*JobRunWithDetails

+ func (j JobRunDetailsList) FilterRunsManagedByReplay(runs []*JobRunStatus) JobRunDetailsList

+ func (j JobRunDetailsList) GetSortedRunsByStates(states []State) []*JobRunWithDetails

type JobRunStatus

+ func (j JobRunStatus) GetScheduledAt() time.Time

+ func (j JobRunStatus) GetState() State

+ type JobRunWithDetails struct

+ DagID string

+ DagRunID string

+ ExternalTrigger bool

+ RunType string

+ ScheduledAt time.Time

+ State State

+ func (j JobRunWithDetails) GetState() State

type Replay

+ func (r *Replay) UpdatedAt() time.Time

type ReplayNotificationAttrs

+ State ReplayState

type ReplayState

+ const ReplayStateTimeout

type State

+ const StateCanceled

+ const StateRestarting

+ const StateUpForRetry

Sep 24, 2024

Changes in this version

+ const ReplayCreated

+ type ReplayEventType string

+ func (j ReplayEventType) String() string

+ type ReplayNotificationAttrs struct

+ EventType ReplayEventType

+ JobName string

+ JobURN string

+ ReplayID string

+ Tenant tenant.Tenant

Apr 3, 2024

Changes in this version

+ const StatusFiring

+ const StatusResolved

+ type AlertAttrs struct

+ JobEvent *Event

+ JobURN string

+ Owner string

+ SchedulerHost string

+ Status EventStatus

+ Title string

type Event

+ URN string

+ type EventStatus string

type Job

+ func (j *Job) URN() string

type State

+ const StateNotScheduled

Mar 13, 2024

Changes in this version

+ const EventCategoryJobSuccess

+ const MetricNotificationSend

+ type JobRunMeta struct

+ DestinationURN string

+ Labels map[string]string

type JobWithDetails

+ Webhook []Webhook

+ type Webhook struct

+ Endpoints []WebhookEndPoint

+ On JobEventCategory

+ type WebhookAttrs struct

+ Headers map[string]string

+ JobEvent *Event

+ Meta *JobRunMeta

+ Owner string

+ Route string

+ type WebhookEndPoint struct

+ Headers map[string]string

+ URL string

Mar 5, 2024

Changes in this version

+ var ReplayNonTerminalStates = []ReplayState

+ var ReplayTerminalStates = []ReplayState

type JobRunStatusList

+ func (j JobRunStatusList) GetJobRunStatusSummary() string

type Replay

+ func (r *Replay) IsTerminated() bool

type ReplayState

+ const ReplayStateCancelled

Dec 6, 2023

Changes in this version

type JobRunStatusList

+ func (j JobRunStatusList) GetJobRunStatusSummaryMap() map[State]int

+ func (j JobRunStatusList) IsAllTerminated() bool

+ func (j JobRunStatusList) IsAnyFailure() bool

Nov 17, 2023

Changes in this version

type JobWithDetails

+ func (j *JobWithDetails) GetSafeLabels() map[string]string

Sep 14, 2023

Changes in this version

type Job

+ WindowConfig window.Config

Sep 11, 2023

Changes in this version

type JobRun

+ SLADefinition int64

+ func (j *JobRun) HasSLABreached() bool

Sep 4, 2023

Changes in this version

type Job

+ ID uuid.UUID

Aug 1, 2023

Changes in this version

type JobRunStatusList

+ func (j JobRunStatusList) OverrideWithStatus(status State) []*JobRunStatus

type State

+ const StateMissing

Jun 21, 2023

Changes in this version

+ const MetricNotificationQueue

+ const MetricNotificationWorkerBatch

+ const MetricNotificationWorkerSendErr

+ const ReplayUserStateCreated

+ const ReplayUserStateFailed

+ const ReplayUserStateInProgress

+ const ReplayUserStateInvalid

+ const ReplayUserStateSuccess

type Replay

+ func (r *Replay) UserState() ReplayUserState

+ type ReplayUserState string

+ func (j ReplayUserState) String() string

Jun 13, 2023

Changes in this version

type JobRunStatusList

+ func (j JobRunStatusList) GetSortedRunsByScheduledAt() []*JobRunStatus

type JobWithDetails

+ func (j *JobWithDetails) GetUniqueLabelValues() []string

May 11, 2023

Changes in this version

+ const UpstreamTypeInferred

+ const UpstreamTypeStatic

+ var TaskEndStates = []State

type JobEventType

+ func (event JobEventType) String() string

type JobRun

+ ScheduledAt time.Time

type JobRunStatus

+ func (j JobRunStatus) GetLogicalTime(jobCron *cron.ScheduleSpec) time.Time

+ type JobRunStatusList []*JobRunStatus

+ func (j JobRunStatusList) GetSortedRunsByStates(states []State) []*JobRunStatus

+ func (j JobRunStatusList) MergeWithUpdatedRuns(updatedRunMap map[time.Time]State) []*JobRunStatus

+ func (j JobRunStatusList) ToRunStatusMap() map[time.Time]State

+ type Replay struct

+ func NewReplay(id uuid.UUID, jobName JobName, tenant tenant.Tenant, config *ReplayConfig, ...) *Replay

+ func NewReplayRequest(jobName JobName, tenant tenant.Tenant, config *ReplayConfig, state ReplayState) *Replay

+ func (r *Replay) Config() *ReplayConfig

+ func (r *Replay) CreatedAt() time.Time

+ func (r *Replay) ID() uuid.UUID

+ func (r *Replay) JobName() JobName

+ func (r *Replay) Message() string

+ func (r *Replay) State() ReplayState

+ func (r *Replay) Tenant() tenant.Tenant

+ type ReplayConfig struct

+ Description string

+ EndTime time.Time

+ JobConfig map[string]string

+ Parallel bool

+ StartTime time.Time

+ func NewReplayConfig(startTime, endTime time.Time, parallel bool, jobConfig map[string]string, ...) *ReplayConfig

+ type ReplayState string

+ const EntityReplay

+ const ReplayStateCreated

+ const ReplayStateFailed

+ const ReplayStateInProgress

+ const ReplayStateInvalid

+ const ReplayStatePartialReplayed

+ const ReplayStateReplayed

+ const ReplayStateSuccess

+ func ReplayStateFromString(state string) (ReplayState, error)

+ func (j ReplayState) String() string

+ type ReplayWithRun struct

+ Replay *Replay

+ Runs []*JobRunStatus

+ func (r *ReplayWithRun) GetFirstExecutableRun() *JobRunStatus

+ func (r *ReplayWithRun) GetLastExecutableRun() *JobRunStatus

type State

+ const StateInProgress

+ const StateReplayed

+ const StateWaitUpstream

Mar 22, 2023

Changes in this version

+ const EntityEvent

+ const EventCategoryJobFailure

+ const EventCategorySLAMiss

+ const HookFailEvent

+ const HookRetryEvent

+ const HookStartEvent

+ const HookSuccessEvent

+ const ISODateFormat

+ const JobFailureEvent

+ const JobSuccessEvent

+ const SLAMissEvent

+ const SensorFailEvent

+ const SensorRetryEvent

+ const SensorStartEvent

+ const SensorSuccessEvent

+ const TaskFailEvent

+ const TaskRetryEvent

+ const TaskStartEvent

+ const TaskSuccessEvent

+ func GroupJobsByTenant(j []*JobWithDetails) map[tenant.Tenant][]*JobWithDetails

+ type Alert struct

+ Channels []string

+ Config map[string]string

+ On JobEventCategory

+ type ConfigMap map[string]string

+ type Event struct

+ EventTime time.Time

+ JobName JobName

+ JobScheduledAt time.Time

+ OperatorName string

+ SLAObjectList []*SLAObject

+ Status State

+ Tenant tenant.Tenant

+ Type JobEventType

+ Values map[string]any

+ func EventFrom(eventTypeName string, eventValues map[string]any, jobName JobName, ...) (Event, error)

+ type EventName string

+ type Executor struct

+ Name string

+ Type ExecutorType

+ func ExecutorFrom(name string, executorType ExecutorType) (Executor, error)

+ func ExecutorFromEnum(name, enum string) (Executor, error)

+ type ExecutorInput struct

+ Configs ConfigMap

+ Files ConfigMap

+ Secrets ConfigMap

+ type ExecutorType string

+ const ExecutorHook

+ const ExecutorTask

+ func ExecutorTypeFrom(val string) (ExecutorType, error)

+ func (e ExecutorType) String() string

+ type HTTPUpstreams struct

+ Headers map[string]string

+ Name string

+ Params map[string]string

+ URL string

+ type Hook struct

+ Config map[string]string

+ Name string

+ type Job struct

+ Assets map[string]string

+ Destination string

+ Hooks []*Hook

+ Name JobName

+ Task *Task

+ Tenant tenant.Tenant

+ Window models.Window

+ func (j *Job) GetHook(hookName string) (*Hook, error)

+ type JobEventCategory string

+ type JobEventType string

+ func FromStringToEventType(name string) (JobEventType, error)

+ func (incomingEvent JobEventType) IsOfType(category JobEventCategory) bool

+ type JobMetadata struct

+ Description string

+ Labels map[string]string

+ Owner string

+ Version int

+ type JobName string

+ func JobNameFrom(name string) (JobName, error)

+ func (n JobName) String() string

+ type JobRun struct

+ EndTime time.Time

+ ID uuid.UUID

+ JobName JobName

+ Monitoring map[string]any

+ SLAAlert bool

+ StartTime time.Time

+ State State

+ Tenant tenant.Tenant

+ type JobRunID uuid.UUID

+ func JobRunIDFromString(runID string) (JobRunID, error)

+ func (i JobRunID) IsEmpty() bool

+ func (i JobRunID) UUID() uuid.UUID

+ type JobRunStatus struct

+ ScheduledAt time.Time

+ State State

+ func JobRunStatusFrom(scheduledAt time.Time, state string) (JobRunStatus, error)

+ type JobRunsCriteria struct

+ EndDate time.Time

+ Filter []string

+ Name string

+ OnlyLastRun bool

+ StartDate time.Time

+ func (c JobRunsCriteria) ExecutionEndDate(jobCron *cron.ScheduleSpec) time.Time

+ func (c JobRunsCriteria) ExecutionStart(cron *cron.ScheduleSpec) time.Time

+ type JobUpstream struct

+ DestinationURN string

+ External bool

+ Host string

+ JobName string

+ State string

+ TaskName string

+ Tenant tenant.Tenant

+ Type string

+ type JobWithDetails struct

+ Alerts []Alert

+ Job *Job

+ JobMetadata *JobMetadata

+ Name JobName

+ Priority int

+ Retry Retry

+ RuntimeConfig RuntimeConfig

+ Schedule *Schedule

+ Upstreams Upstreams

+ func (j *JobWithDetails) GetLabelsAsString() string

+ func (j JobWithDetails) GetName() string

+ func (j JobWithDetails) SLADuration() (int64, error)

+ type NotifyAttrs struct

+ JobEvent Event

+ Owner string

+ Route string

+ Secret string

+ type OperatorRun struct

+ EndTime time.Time

+ ID uuid.UUID

+ JobRunID uuid.UUID

+ Name string

+ OperatorType OperatorType

+ StartTime time.Time

+ Status State

+ type OperatorType string

+ const EntityJobRun

+ const OperatorHook

+ const OperatorSensor

+ const OperatorTask

+ func (o OperatorType) String() string

+ type Resource struct

+ Limit *ResourceConfig

+ Request *ResourceConfig

+ type ResourceConfig struct

+ CPU string

+ Memory string

+ type Retry struct

+ Count int

+ Delay int32

+ ExponentialBackoff bool

+ type RunConfig struct

+ Executor Executor

+ JobRunID JobRunID

+ ScheduledAt time.Time

+ func RunConfigFrom(executor Executor, scheduledAt time.Time, runID string) (RunConfig, error)

+ type RuntimeConfig struct

+ Resource *Resource

+ Scheduler map[string]string

+ type SLAObject struct

+ JobName JobName

+ JobScheduledAt time.Time

+ func (s *SLAObject) String() string

+ type Schedule struct

+ CatchUp bool

+ DependsOnPast bool

+ EndDate *time.Time

+ Interval string

+ StartDate time.Time

+ type State string

+ const StateAccepted

+ const StateFailed

+ const StatePending

+ const StateQueued

+ const StateRetry

+ const StateRunning

+ const StateSuccess

+ func StateFromString(state string) (State, error)

+ func (j State) String() string

+ type Task struct

+ Config map[string]string

+ Name string

+ type Upstreams struct

+ HTTP []*HTTPUpstreams

+ UpstreamJobs []*JobUpstream