Versions in this module Expand all Collapse all v0 v0.7.1 Jul 25, 2023 v0.7.0 Jul 20, 2023 Changes in this version + const EntityEvent + const EntityJobRun + const EntityReplay + const EventCategoryJobFailure + const EventCategorySLAMiss + const HookFailEvent + const HookRetryEvent + const HookStartEvent + const HookSuccessEvent + const ISODateFormat + const JobFailureEvent + const JobSuccessEvent + const MetricNotificationQueue + const MetricNotificationWorkerBatch + const MetricNotificationWorkerSendErr + const OperatorHook + const OperatorSensor + const OperatorTask + const ReplayStateCreated + const ReplayStateFailed + const ReplayStateInProgress + const ReplayStateInvalid + const ReplayStatePartialReplayed + const ReplayStateReplayed + const ReplayStateSuccess + const ReplayUserStateCreated + const ReplayUserStateFailed + const ReplayUserStateInProgress + const ReplayUserStateInvalid + const ReplayUserStateSuccess + const SLAMissEvent + const SensorFailEvent + const SensorRetryEvent + const SensorStartEvent + const SensorSuccessEvent + const TaskFailEvent + const TaskRetryEvent + const TaskStartEvent + const TaskSuccessEvent + const UpstreamTypeInferred + const UpstreamTypeStatic + var TaskEndStates = []State + 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 (event JobEventType) IsOfType(category JobEventCategory) bool + func (event JobEventType) String() string + 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 + ScheduledAt time.Time + 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) + func (j JobRunStatus) GetLogicalTime(jobCron *cron.ScheduleSpec) time.Time + type JobRunStatusList []*JobRunStatus + func (j JobRunStatusList) GetSortedRunsByScheduledAt() []*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 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) GetUniqueLabelValues() []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 + func (o OperatorType) String() string + 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 + func (r *Replay) UserState() ReplayUserState + 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 + func ReplayStateFromString(state string) (ReplayState, error) + func (j ReplayState) String() string + type ReplayUserState string + func (j ReplayUserState) String() string + type ReplayWithRun struct + Replay *Replay + Runs []*JobRunStatus + func (r *ReplayWithRun) GetFirstExecutableRun() *JobRunStatus + func (r *ReplayWithRun) GetLastExecutableRun() *JobRunStatus + 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 + DependsOnPast bool + EndDate *time.Time + Interval string + StartDate time.Time + type State string + const StateAccepted + const StateFailed + const StateInProgress + const StatePending + const StateQueued + const StateRetry + const StateRunning + const StateSuccess + const StateWaitUpstream + 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
Go to main page