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 + type Job struct + Alert json.RawMessage + Assets map[string]string + CreatedAt time.Time + DeletedAt sql.NullTime + Description string + Destination string + HTTPUpstreams json.RawMessage + Hooks json.RawMessage + ID uuid.UUID + Labels map[string]string + Metadata json.RawMessage + Name string + NamespaceName string + Owner string + ProjectName string + Schedule json.RawMessage + Sources pq.StringArray + StaticUpstreams pq.StringArray + TaskConfig map[string]string + TaskName string + UpdatedAt time.Time + Version int + WindowSpec json.RawMessage + func FromRow(row pgx.Row) (*Job, error) + type JobRepository struct + func NewJobProviderRepository(pool *pgxpool.Pool) *JobRepository + func (j *JobRepository) GetAll(ctx context.Context, projectName tenant.ProjectName) ([]*scheduler.JobWithDetails, error) + func (j *JobRepository) GetJob(ctx context.Context, projectName tenant.ProjectName, jobName scheduler.JobName) (*scheduler.Job, error) + func (j *JobRepository) GetJobDetails(ctx context.Context, projectName tenant.ProjectName, jobName scheduler.JobName) (*scheduler.JobWithDetails, error) + func (j *JobRepository) GetJobs(ctx context.Context, projectName tenant.ProjectName, jobs []string) ([]*scheduler.JobWithDetails, error) + type JobRunRepository struct + func NewJobRunRepository(pool *pgxpool.Pool) *JobRunRepository + func (j *JobRunRepository) Create(ctx context.Context, t tenant.Tenant, jobName scheduler.JobName, ...) error + func (j *JobRunRepository) GetByID(ctx context.Context, id scheduler.JobRunID) (*scheduler.JobRun, error) + func (j *JobRunRepository) GetByScheduledAt(ctx context.Context, t tenant.Tenant, jobName scheduler.JobName, ...) (*scheduler.JobRun, error) + func (j *JobRunRepository) Update(ctx context.Context, jobRunID uuid.UUID, endTime time.Time, ...) error + func (j *JobRunRepository) UpdateMonitoring(ctx context.Context, jobRunID uuid.UUID, monitoringValues map[string]any) error + func (j *JobRunRepository) UpdateSLA(ctx context.Context, slaObjects []*scheduler.SLAObject) error + func (j *JobRunRepository) UpdateState(ctx context.Context, jobRunID uuid.UUID, status scheduler.State) error + type JobUpstreams struct + CreatedAt time.Time + JobID uuid.UUID + JobName string + ProjectName string + UpdatedAt time.Time + UpstreamExternal sql.NullBool + UpstreamHost sql.NullString + UpstreamJobID uuid.UUID + UpstreamJobName sql.NullString + UpstreamNamespaceName sql.NullString + UpstreamProjectName sql.NullString + UpstreamResourceUrn sql.NullString + UpstreamState string + UpstreamTaskName sql.NullString + UpstreamType string + type Metadata struct + Resource *MetadataResource + Scheduler map[string]string + type MetadataResource struct + Limit *MetadataResourceConfig + Request *MetadataResourceConfig + type MetadataResourceConfig struct + CPU string + Memory string + type OperatorRunRepository struct + func NewOperatorRunRepository(pool *pgxpool.Pool) *OperatorRunRepository + func (o *OperatorRunRepository) CreateOperatorRun(ctx context.Context, name string, operatorType scheduler.OperatorType, ...) error + func (o *OperatorRunRepository) GetOperatorRun(ctx context.Context, name string, operatorType scheduler.OperatorType, ...) (*scheduler.OperatorRun, error) + func (o *OperatorRunRepository) UpdateOperatorRun(ctx context.Context, operatorType scheduler.OperatorType, ...) error + type ReplayRepository struct + func NewReplayRepository(db *pgxpool.Pool) *ReplayRepository + func (r ReplayRepository) GetReplayByID(ctx context.Context, replayID uuid.UUID) (*scheduler.ReplayWithRun, error) + func (r ReplayRepository) GetReplayJobConfig(ctx context.Context, jobTenant tenant.Tenant, jobName scheduler.JobName, ...) (map[string]string, error) + func (r ReplayRepository) GetReplayRequestsByStatus(ctx context.Context, statusList []scheduler.ReplayState) ([]*scheduler.Replay, error) + func (r ReplayRepository) GetReplayToExecute(ctx context.Context) (*scheduler.ReplayWithRun, error) + func (r ReplayRepository) GetReplaysByProject(ctx context.Context, projectName tenant.ProjectName, dayLimits int) ([]*scheduler.Replay, error) + func (r ReplayRepository) RegisterReplay(ctx context.Context, replay *scheduler.Replay, runs []*scheduler.JobRunStatus) (uuid.UUID, error) + func (r ReplayRepository) UpdateReplay(ctx context.Context, id uuid.UUID, replayStatus scheduler.ReplayState, ...) error + func (r ReplayRepository) UpdateReplayStatus(ctx context.Context, id uuid.UUID, replayStatus scheduler.ReplayState, ...) error + type Retry struct + Count int + Delay int32 + ExponentialBackoff bool + type Schedule struct + DependsOnPast bool + EndDate *time.Time + Interval string + Retry *Retry + StartDate time.Time + type Window struct + WindowOffset string + WindowSize string + WindowTruncateTo string
Go to main page