repository

Nov 21, 2024

Changes in this version

+ type CreateCronWorkflowTriggerOpts struct

+ AdditionalMetadata map[string]interface{}

+ Cron string

+ Input map[string]interface{}

+ Name string

+ WorkflowId string

+ type CreateScheduledWorkflowRunForWorkflowOpts struct

+ AdditionalMetadata map[string]interface{}

+ Input map[string]interface{}

+ ScheduledTrigger time.Time

+ WorkflowId string

type CreateWorkflowRunOpts

+ CronName *string

type CreateWorkflowStepOpts

+ RetryBackoffFactor *float64

+ RetryBackoffMaxSeconds *int

type StepRunEngineRepository

+ CleanupRetryQueueItems func(ctx context.Context, tenantId string) error

+ ListRetryableStepRuns func(ctx context.Context, tenantId string) (bool, []*dbsqlc.GetStepRunForEngineRow, error)

+ StepRunRetryBackoff func(ctx context.Context, tenantId, stepRunId string, retryAfter time.Time) error

type WorkflowAPIRepository

+ CreateCronWorkflow func(ctx context.Context, tenantId string, opts *CreateCronWorkflowTriggerOpts) (*dbsqlc.ListCronWorkflowsRow, error)

+ CreateScheduledWorkflow func(ctx context.Context, tenantId string, ...) (*dbsqlc.ListScheduledWorkflowsRow, error)

+ DeleteCronWorkflow func(ctx context.Context, tenantId, id string) error

+ GetCronWorkflow func(ctx context.Context, tenantId, cronWorkflowId string) (*dbsqlc.ListCronWorkflowsRow, error)

+ ListCronWorkflows func(ctx context.Context, tenantId string, opts *ListCronWorkflowsOpts) ([]*dbsqlc.ListCronWorkflowsRow, int64, error)

Nov 7, 2024

Changes in this version

type StepRunEngineRepository

+ ListStepRunsToCancel func(ctx context.Context, tenantId, jobRunId string) ([]*dbsqlc.GetStepRunForEngineRow, error)

Nov 6, 2024

Changes in this version

+ type TenantScopedCallback func(string, T) error

+ func (c TenantScopedCallback[T]) Do(l *zerolog.Logger, tenantId string, v T)

+ type UnscopedCallback func(T) error

+ func (c UnscopedCallback[T]) Do(l *zerolog.Logger, v T)

type UserRepository

+ RegisterCreateCallback func(callback UnscopedCallback[*db.UserModel])

Nov 5, 2024

Changes in this version

type CreateWorkflowSchedulesOpts

+ AdditionalMetadata []byte

+ type ListCronWorkflowsOpts struct

+ AdditionalMetadata map[string]interface{}

+ Limit *int

+ Offset *int

+ OrderBy *string

+ OrderDirection *string

+ WorkflowId *string

+ type ListScheduledWorkflowsOpts struct

+ AdditionalMetadata map[string]interface{}

+ IncludeFuture *bool

+ Limit *int

+ Offset *int

+ OrderBy *string

+ OrderDirection *string

+ ParentStepRunId *string

+ ParentWorkflowRunId *string

+ Statuses *[]db.WorkflowRunStatus

+ WorkflowId *string

type WorkflowRunAPIRepository

+ DeleteScheduledWorkflow func(ctx context.Context, tenantId, scheduledWorkflowId string) error

+ GetScheduledWorkflow func(ctx context.Context, tenantId, scheduledWorkflowId string) (*dbsqlc.ListScheduledWorkflowsRow, error)

+ ListCronWorkflows func(ctx context.Context, tenantId string, opts *ListCronWorkflowsOpts) ([]*dbsqlc.ListCronWorkflowsRow, int64, error)

+ ListScheduledWorkflows func(ctx context.Context, tenantId string, opts *ListScheduledWorkflowsOpts) ([]*dbsqlc.ListScheduledWorkflowsRow, int64, error)

+ UpdateScheduledWorkflow func(ctx context.Context, tenantId, scheduledWorkflowId string, triggerAt time.Time) error

type WorkflowRunEngineRepository

+ GetFailureDetails func(ctx context.Context, tenantId, workflowRunId string) ([]*dbsqlc.GetFailureDetailsRow, error)

Oct 30, 2024

Changes in this version

type CreateWorkerOpts

+ RuntimeInfo *RuntimeInfo

+ type RuntimeInfo struct

+ Extra *string

+ Language *contracts.SDKS

+ LanguageVersion *string

+ Os *string

+ SdkVersion *string

Oct 25, 2024

Changes in this version

type WorkerEngineRepository

+ GetDispatcherIdsForWorkers func(ctx context.Context, tenantId string, workerIds []string) (map[string][]string, error)

Oct 23, 2024

Changes in this version

+ type ChildWorkflowRun struct

+ ChildIndex int

+ Childkey *string

+ ParentId string

+ ParentStepRunId string

type CreateWorkflowRunOpts

+ TenantId string

type JobRunEngineRepository

+ GetJobRunsByWorkflowRunId func(ctx context.Context, tenantId, workflowRunId string) ([]*dbsqlc.GetJobRunsByWorkflowRunIdRow, error)

type StepRunEngineRepository

+ GetStepRunBulkDataForEngine func(ctx context.Context, tenantId string, stepRunIds []string) ([]*dbsqlc.GetStepRunBulkDataForEngineRow, error)

+ StepRunAcked func(ctx context.Context, tenantId, workflowRunId, stepRunId string, ...) error

type TenantEngineRepository

+ CreateSchedulerPartition func(ctx context.Context) (string, error)

+ DeleteSchedulerPartition func(ctx context.Context, id string) error

+ ListTenantsBySchedulerPartition func(ctx context.Context, schedulerPartitionId string) ([]*dbsqlc.Tenant, error)

+ RebalanceAllSchedulerPartitions func(ctx context.Context) error

+ RebalanceInactiveSchedulerPartitions func(ctx context.Context) error

+ UpdateSchedulerPartitionHeartbeat func(ctx context.Context, partitionId string) (string, error)

type WorkflowEngineRepository

+ GetLatestWorkflowVersions func(ctx context.Context, tenantId string, workflowIds []string) ([]*dbsqlc.GetWorkflowVersionForEngineRow, error)

+ GetWorkflowsByNames func(ctx context.Context, tenantId string, workflowNames []string) ([]*dbsqlc.Workflow, error)

type WorkflowRunAPIRepository

+ GetWorkflowRunByIds func(ctx context.Context, tenantId string, runIds []string) ([]*dbsqlc.GetWorkflowRunByIdsRow, error)

type WorkflowRunEngineRepository

+ CreateDeDupeKey func(ctx context.Context, ...) error

+ CreateNewWorkflowRuns func(ctx context.Context, tenantId string, opts []*CreateWorkflowRunOpts) ([]*dbsqlc.WorkflowRun, error)

+ GetChildWorkflowRuns func(ctx context.Context, childWorkflowRuns []ChildWorkflowRun) ([]*dbsqlc.WorkflowRun, error)

+ GetWorkflowRunByIds func(ctx context.Context, tenantId string, runId []string) ([]*dbsqlc.GetWorkflowRunRow, error)

Oct 11, 2024

Changes in this version

type TenantAlertingEngineRepository

+ GetTenantResourceLimitState func(ctx context.Context, tenantId string, resource string) (*dbsqlc.GetTenantResourceLimitRow, error)

Oct 7, 2024

Changes in this version

type CreateStepRunEventOpts

+ StepRunId string

type EventEngineRepository

+ BulkCreateEventSharedTenant func(ctx context.Context, opts []*CreateEventOpts) ([]*dbsqlc.Event, error)

+ type ProcessStepRunUpdatesResultV2 struct

+ CompletedWorkflowRuns []*dbsqlc.ResolveWorkflowRunStatusRow

+ Continue bool

+ SucceededStepRuns []*dbsqlc.GetStepRunForEngineRow

type StepRunEngineRepository

+ ListInitialStepRunsForJobRun func(ctx context.Context, tenantId, jobRunId string) ([]*dbsqlc.GetStepRunForEngineRow, error)

+ ProcessStepRunUpdatesV2 func(ctx context.Context, qlp *zerolog.Logger, tenantId string) (ProcessStepRunUpdatesResultV2, error)

Sep 29, 2024

Changes in this version

+ type UpdateWorkflowOpts struct

+ IsPaused *bool

type WorkflowAPIRepository

+ UpdateWorkflow func(ctx context.Context, tenantId, workflowId string, opts *UpdateWorkflowOpts) (*dbsqlc.Workflow, error)

type WorkflowRunEngineRepository

+ ProcessUnpausedWorkflowRuns func(ctx context.Context, tenantId string) ([]*dbsqlc.GetWorkflowRunRow, bool, error)

+ QueuePausedWorkflowRun func(ctx context.Context, tenantId, workflowId, workflowRunId string) error

Sep 27, 2024

Changes in this version

+ var ErrDagParentNotFound = errors.New("dag parent not found")

Sep 27, 2024

Changes in this version

+ type CreateExpressionEvalOpt struct

+ Key string

+ Kind dbsqlc.StepExpressionKind

+ ValueInt *int

+ ValueStr *string

type CreateWorkflowStepRateLimitOpts

+ Duration *string

+ KeyExpr *string

+ LimitExpr *string

+ UnitsExpr *string

type EngineRepository

+ Step func() StepRepository

type JobRunAPIRepository

+ RegisterWorkflowRunRunningCallback func(callback Callback[pgtype.UUID])

type JobRunEngineRepository

+ RegisterWorkflowRunRunningCallback func(callback Callback[pgtype.UUID])

+ type ListRateLimitOpts struct

+ Limit *int

+ Offset *int

+ OrderBy *string

+ OrderDirection *string

+ Search *string

+ type ListRateLimitsResult struct

+ Count int

+ Rows []*dbsqlc.ListRateLimitsForTenantNoMutateRow

type ListWorkflowRunsOpts

+ FinishedBefore *time.Time

type QueueStepRunOpts

+ ExpressionEvals []CreateExpressionEvalOpt

type RateLimitEngineRepository

+ ListRateLimits func(ctx context.Context, tenantId string, opts *ListRateLimitOpts) (*ListRateLimitsResult, error)

type StepRepository

+ ListStepExpressions func(ctx context.Context, stepId string) ([]*dbsqlc.StepExpression, error)

type StepRunEngineRepository

+ RegisterWorkflowRunCompletedCallback func(callback Callback[*dbsqlc.ResolveWorkflowRunStatusRow])

type WorkflowRunEngineRepository

+ RegisterQueuedCallback func(callback Callback[pgtype.UUID])

Sep 24, 2024

Changes in this version

type StepRunEngineRepository

+ GetQueueCounts func(ctx context.Context, tenantId string) (map[string]int, error)

Sep 23, 2024

Changes in this version

+ type BulkCreateEventOpts struct

+ Events []*CreateEventOpts

+ TenantId string

+ type BulkCreateEventResult struct

+ Events []*dbsqlc.Event

type EventEngineRepository

+ BulkCreateEvent func(ctx context.Context, opts *BulkCreateEventOpts) (*BulkCreateEventResult, error)

Sep 19, 2024

Changes in this version

type WorkflowAPIRepository

+ GetWorkflowWorkerCount func(tenantId, workflowId string) (int, int, error)

Sep 19, 2024

Changes in this version

+ var ErrAlreadyQueued = fmt.Errorf("step run is already queued")

+ var ErrAlreadyRunning = fmt.Errorf("step run is already running")

type CreateWorkflowConcurrencyOpts

+ Expression *string

+ type UpdateWorkflowRunFromGroupKeyEvalOpts struct

+ Error *string

+ GroupKey *string

type WorkflowRunEngineRepository

+ GetWorkflowRunInputData func(tenantId, workflowRunId string) (map[string]interface{}, error)

+ ProcessWorkflowRunUpdates func(ctx context.Context, tenantId string) (bool, error)

+ UpdateWorkflowRunFromGroupKeyEval func(ctx context.Context, tenantId, workflowRunId string, ...) error

Sep 16, 2024

Changes in this version

type CreateStepRunEventOpts

+ Timestamp *time.Time

+ type GetStepRunFull struct

+ ChildWorkflowRuns []string

type JobRunAPIRepository

+ ListJobRunByWorkflowRunId func(ctx context.Context, tenantId, WorkflowRunId string) ([]*dbsqlc.ListJobRunsForWorkflowRunFullRow, error)

type ListEventOpts

+ Ids []string

type ProcessStepRunUpdatesResult

+ SucceededStepRuns []*dbsqlc.GetStepRunForEngineRow

type StepRunAPIRepository

+ ListStepRunEventsByWorkflowRunId func(ctx context.Context, tenantId, workflowRunId string, lastId *int32) (*ListStepRunEventResult, error)

+ type StepRunForJobRun struct

+ ChildWorkflowsCount int

type WorkflowRunAPIRepository

+ GetStepRunsForJobRuns func(ctx context.Context, tenantId string, jobRunIds []string) ([]*StepRunForJobRun, error)

+ GetStepsForJobs func(ctx context.Context, tenantId string, jobIds []string) ([]*dbsqlc.GetStepsForJobsRow, error)

Sep 9, 2024

Changes in this version

type WorkerEngineRepository

+ DeleteOldWorkerEvents func(ctx context.Context, tenantId string, lastHeartbeatAfter time.Time) error

Sep 6, 2024

Changes in this version

+ type ProcessStepRunUpdatesResult struct

+ CompletedWorkflowRuns []*dbsqlc.ResolveWorkflowRunStatusRow

+ Continue bool

+ type QueueStepRunOpts struct

+ Input []byte

+ IsInternalRetry bool

+ IsRetry bool

type StepRunEngineRepository

+ CleanupInternalQueueItems func(ctx context.Context, tenantId string) error

+ ProcessStepRunUpdates func(ctx context.Context, qlp *zerolog.Logger, tenantId string) (ProcessStepRunUpdatesResult, error)

+ StepRunCancelled func(ctx context.Context, tenantId, stepRunId string, cancelledAt time.Time, ...) error

+ StepRunFailed func(ctx context.Context, tenantId, stepRunId string, failedAt time.Time, ...) error

+ StepRunStarted func(ctx context.Context, tenantId, stepRunId string, startedAt time.Time) error

+ StepRunSucceeded func(ctx context.Context, tenantId, stepRunId string, finishedAt time.Time, ...) error

+ UpdateWorkerSemaphoreCounts func(ctx context.Context, qlp *zerolog.Logger, tenantId string) (shouldContinue bool, releasedSlots bool, err error)

type WorkerEngineRepository

+ DeleteOldWorkers func(ctx context.Context, tenantId string, lastHeartbeatBefore time.Time) (bool, error)

Aug 29, 2024

Changes in this version

type StepRunEngineRepository

+ CleanupQueueItems func(ctx context.Context, tenantId string) error

Aug 28, 2024

Changes in this version

type TenantEngineRepository

+ UpdateControllerPartitionHeartbeat func(ctx context.Context, partitionId string) (string, error)

+ UpdateWorkerPartitionHeartbeat func(ctx context.Context, partitionId string) (string, error)

Aug 26, 2024

Changes in this version

type CreateWorkflowRunOpts

+ Priority *int32

type CreateWorkflowVersionOpts

+ DefaultPriority *int32

Aug 23, 2024

Changes in this version

+ var ErrDuplicateKey = fmt.Errorf("duplicate key error")

+ type CreateWebhookWorkerOpts struct

+ Deleted *bool

+ Name string

+ Secret string

+ TenantId string

+ TokenID *string

+ TokenValue *string

+ URL string

+ type UpdateWebhookWorkerTokenOpts struct

+ TokenID *string

+ TokenValue *string

type WebhookWorkerEngineRepository

+ CreateWebhookWorker func(ctx context.Context, opts *CreateWebhookWorkerOpts) (*dbsqlc.WebhookWorker, error)

+ HardDeleteWebhookWorker func(ctx context.Context, id string, tenantId string) error

+ InsertWebhookWorkerRequest func(ctx context.Context, webhookWorkerId string, method string, statusCode int32) error

+ ListWebhookWorkerRequests func(ctx context.Context, webhookWorkerId string) ([]*dbsqlc.WebhookWorkerRequest, error)

+ SoftDeleteWebhookWorker func(ctx context.Context, id string, tenantId string) error

+ UpdateWebhookWorkerToken func(ctx context.Context, id string, tenantId string, ...) (*dbsqlc.WebhookWorker, error)

type WorkerAPIRepository

+ GetWorkerActionsByWorkerId func(tenantid, workerId string) ([]pgtype.Text, error)

Aug 21, 2024

Changes in this version

type CreateWorkerOpts

+ WebhookId *string

type WorkerEngineRepository

+ UpdateWorkersByWebhookId func(ctx context.Context, opts dbsqlc.UpdateWorkersByWebhookIdParams) error

Aug 20, 2024

Changes in this version

type ListWorkflowRunsOpts

+ CreatedBefore *time.Time

type WorkflowRunsMetricsOpts

+ CreatedAfter *time.Time

+ CreatedBefore *time.Time

Aug 12, 2024

Changes in this version

type HealthRepository

+ PgStat func() *pgxpool.Stat

+ type QueueStepRunsResult struct

+ Continue bool

+ Queued []QueuedStepRun

+ SchedulingTimedOut []string

+ type QueuedStepRun struct

+ DispatcherId string

+ StepRunId string

+ WorkerId string

type StepRunEngineRepository

+ QueueStepRuns func(ctx context.Context, tenantId string) (QueueStepRunsResult, error)

type TenantEngineRepository

+ UpdatePartitionHeartbeat func(ctx context.Context, partitionId string) error

type TickerEngineRepository

+ DeactivateTicker func(ctx context.Context, tickerId string) error

type WorkerAPIRepository

+ ListWorkerState func(tenantId, workerId string, failed bool) ([]*dbsqlc.ListSemaphoreSlotsWithStateForWorkerRow, ...)

type WorkerEngineRepository

+ UpdateWorkerHeartbeat func(ctx context.Context, tenantId, workerId string, lastHeartbeatAt time.Time) error

Jul 29, 2024

Changes in this version

type CreateWorkflowVersionOpts

+ Kind *string

type ListWorkflowRunsOpts

+ Kinds *[]dbsqlc.WorkflowKind

type StepRunEngineRepository

+ GetStepRunMetaForEngine func(ctx context.Context, tenantId, stepRunId string) (*dbsqlc.GetStepRunMetaRow, error)

type StreamEventsEngineRepository

+ GetStreamEventMeta func(ctx context.Context, tenantId string, stepRunId string) (*dbsqlc.GetStreamEventMetaRow, error)

type WorkflowRunEngineRepository

+ GetWorkflowRunAdditionalMeta func(ctx context.Context, tenantId, workflowRunId string) (*dbsqlc.GetWorkflowRunAdditionalMetaRow, error)

Jul 26, 2024

Changes in this version

type CreateWorkflowRunOpts

+ DedupeValue *string

+ DesiredWorkerId *string

type CreateWorkflowStepOpts

+ DesiredWorkerLabels map[string]DesiredWorkerLabelOpts

type CreateWorkflowVersionOpts

+ Sticky *string

+ type DesiredWorkerLabelOpts struct

+ Comparator *string

+ IntValue *int32

+ Key string

+ Required *bool

+ StrValue *string

+ Weight *int32

+ type ErrDedupeValueExists struct

+ DedupeValue string

+ func (e ErrDedupeValueExists) Error() string

+ type UpsertWorkerLabelOpts struct

+ IntValue *int32

+ Key string

+ StrValue *string

type WorkerAPIRepository

+ ListWorkerLabels func(tenantId, workerId string) ([]*dbsqlc.ListWorkerLabelsRow, error)

type WorkerEngineRepository

+ UpsertWorkerLabels func(ctx context.Context, workerId pgtype.UUID, opts []UpsertWorkerLabelOpts) ([]*dbsqlc.WorkerLabel, error)

type WorkflowRunAPIRepository

+ GetWorkflowRunInputData func(tenantId, workflowRunId string) (map[string]interface{}, error)

Jul 18, 2024

Changes in this version

type EventEngineRepository

+ ClearEventPayloadData func(ctx context.Context, tenantId string) (bool, error)

+ SoftDeleteExpiredEvents func(ctx context.Context, tenantId string, before time.Time) (bool, error)

type JobRunEngineRepository

+ ClearJobRunPayloadData func(ctx context.Context, tenantId string) (bool, error)

type StepRunEngineRepository

+ ClearStepRunPayloadData func(ctx context.Context, tenantId string) (bool, error)

type WorkflowRunEngineRepository

+ ReplayWorkflowRun func(ctx context.Context, tenantId, workflowRunId string) (*dbsqlc.GetWorkflowRunRow, error)

+ SoftDeleteExpiredWorkflowRuns func(ctx context.Context, tenantId string, statuses []dbsqlc.WorkflowRunStatus, ...) (bool, error)

Jul 16, 2024

Changes in this version

type CreateAPITokenOpts

+ Internal bool

Jul 15, 2024

Changes in this version

type StepRunEngineRepository

+ DeferredStepRunEvent func(stepRunId pgtype.UUID, reason dbsqlc.StepRunEventReason, ...)

+ UnassignStepRunFromWorker func(ctx context.Context, tenantId, stepRunId string) error

Jul 14, 2024

Changes in this version

type StepRunEngineRepository

+ GetStepRunDataForEngine func(ctx context.Context, tenantId, stepRunId string) (*dbsqlc.GetStepRunDataForEngineRow, error)

Jul 12, 2024

Changes in this version

type StepRunEngineRepository

+ ListStepRunsToTimeout func(ctx context.Context, tenantId string) ([]*dbsqlc.GetStepRunForEngineRow, error)

+ ResolveRelatedStatuses func(ctx context.Context, tenantId pgtype.UUID, stepRunId pgtype.UUID) (*StepRunUpdateInfo, error)

type TickerEngineRepository

+ PollUnresolvedFailedStepRuns func(ctx context.Context) ([]*dbsqlc.PollUnresolvedFailedStepRunsRow, error)

type WorkflowRunEngineRepository

+ ListActiveQueuedWorkflowVersions func(ctx context.Context) ([]*dbsqlc.ListActiveQueuedWorkflowVersionsRow, error)

Jul 10, 2024

Changes in this version

+ var ErrStepRunIsNotAssigned = fmt.Errorf("step run is not assigned")

Jul 6, 2024

Changes in this version

type CreateTenantOpts

+ DataRetentionPeriod *string

type EventEngineRepository

+ DeleteExpiredEvents func(ctx context.Context, tenantId string, before time.Time) (int, int, error)

type WorkflowRunEngineRepository

+ DeleteExpiredWorkflowRuns func(ctx context.Context, tenantId string, statuses []dbsqlc.WorkflowRunStatus, ...) (int, int, error)

Jul 1, 2024

Changes in this version

+ type ApiUpdateWorkerOpts struct

+ IsPaused *bool

type WorkerAPIRepository

+ UpdateWorker func(tenantId string, workerId string, opts ApiUpdateWorkerOpts) (*dbsqlc.Worker, error)

Jun 26, 2024

Changes in this version

type APIRepository

+ SecurityCheck func() SecurityCheckRepository

+ type ListStepRunArchivesOpts struct

+ Limit *int

+ Offset *int

+ type ListStepRunArchivesResult struct

+ Count int

+ Rows []*dbsqlc.StepRunResultArchive

+ type SecurityCheckRepository interface

+ GetIdent func() (string, error)

type StepRunAPIRepository

+ ListStepRunArchives func(tenantId, stepRunId string, opts *ListStepRunArchivesOpts) (*ListStepRunArchivesResult, error)

type TenantEngineRepository

+ CreateControllerPartition func(ctx context.Context, id string) error

+ CreateTenantWorkerPartition func(ctx context.Context, id string) error

+ DeleteControllerPartition func(ctx context.Context, id string) error

+ DeleteTenantWorkerPartition func(ctx context.Context, id string) error

+ ListTenantsByControllerPartition func(ctx context.Context, controllerPartitionId string) ([]*dbsqlc.Tenant, error)

+ ListTenantsByWorkerPartition func(ctx context.Context, workerPartitionId string) ([]*dbsqlc.Tenant, error)

+ RebalanceAllControllerPartitions func(ctx context.Context) error

+ RebalanceAllTenantWorkerPartitions func(ctx context.Context) error

+ RebalanceInactiveControllerPartitions func(ctx context.Context) error

+ RebalanceInactiveTenantWorkerPartitions func(ctx context.Context) error

type WebhookWorkerEngineRepository

+ ListWebhookWorkersByPartitionId func(ctx context.Context, partitionId string) ([]*dbsqlc.WebhookWorker, error)

Jun 26, 2024

Changes in this version

type UpsertWebhookWorkerOpts

+ Deleted *bool

Jun 25, 2024

Changes in this version

type APIRepository

+ WebhookWorker func() WebhookWorkerRepository

+ type Callback func(T) error

+ func (c Callback[T]) Do(v T) (err error)

type EngineRepository

+ WebhookWorker func() WebhookWorkerEngineRepository

type EventEngineRepository

+ RegisterCreateCallback func(callback Callback[*dbsqlc.Event])

+ type UpsertWebhookWorkerOpts struct

+ Name string

+ Secret string

+ TenantId string

+ TokenID *string

+ TokenValue *string

+ URL string

+ type WebhookWorkerEngineRepository interface

+ DeleteWebhookWorker func(ctx context.Context, id string, tenantId string) error

+ ListActiveWebhookWorkers func(ctx context.Context, tenantId string) ([]*dbsqlc.WebhookWorker, error)

+ ListWebhookWorkers func(ctx context.Context, tenantId string) ([]*dbsqlc.WebhookWorker, error)

+ UpsertWebhookWorker func(ctx context.Context, opts *UpsertWebhookWorkerOpts) (*dbsqlc.WebhookWorker, error)

+ type WebhookWorkerRepository interface

+ GetWebhookWorkerByID func(id string) (*db.WebhookWorkerModel, error)

type WorkerEngineRepository

+ UpdateWorkersByName func(ctx context.Context, opts dbsqlc.UpdateWorkersByNameParams) error

type WorkflowRunAPIRepository

+ RegisterCreateCallback func(callback Callback[*db.WorkflowRunModel])

type WorkflowRunEngineRepository

+ RegisterCreateCallback func(callback Callback[*dbsqlc.WorkflowRun])

Jun 25, 2024

Changes in this version

+ type Limit struct

+ Alarm int32

+ CustomValueMeter bool

+ Limit int32

+ Resource dbsqlc.LimitResource

+ Window *time.Duration

+ type PlanLimitMap map[string][]Limit

type TenantLimitRepository

+ DefaultLimits func() []Limit

+ SelectOrInsertTenantLimits func(ctx context.Context, tenantId string, plan *string) error

+ SetPlanLimitMap func(planLimitMap PlanLimitMap) error

+ UpsertTenantLimits func(ctx context.Context, tenantId string, plan *string) error

Jun 19, 2024

Changes in this version

+ var ErrNoWorkerAvailable = fmt.Errorf("no worker available")

+ var ErrPreflightReplayChildStepRunNotInFinalState = fmt.Errorf("child step run is not in a final state")

+ var ErrPreflightReplayStepRunNotInFinalState = fmt.Errorf("step run is not in a final state")

+ var ErrRateLimitExceeded = fmt.Errorf("rate limit exceeded")

+ var ErrStepRunIsNotPending = fmt.Errorf("step run is not pending")

+ var ErrWorkflowRunNotFound = fmt.Errorf("workflow run not found")

+ func BoolPtr(b bool) *bool

+ func HashPassword(pw string) (*string, error)

+ func IsFinalJobRunStatus(status dbsqlc.JobRunStatus) bool

+ func IsFinalStepRunStatus(status dbsqlc.StepRunStatus) bool

+ func IsFinalWorkflowRunStatus(status dbsqlc.WorkflowRunStatus) bool

+ func JobRunStatusPtr(status db.JobRunStatus) *db.JobRunStatus

+ func StepRunEventReasonPtr(reason dbsqlc.StepRunEventReason) *dbsqlc.StepRunEventReason

+ func StepRunEventSeverityPtr(severity dbsqlc.StepRunEventSeverity) *dbsqlc.StepRunEventSeverity

+ func StepRunStatusPtr(status db.StepRunStatus) *db.StepRunStatus

+ func StringPtr(s string) *string

+ func VerifyPassword(hashedPW, candidate string) (bool, error)

+ type APIRepository interface

+ APIToken func() APITokenRepository

+ Event func() EventAPIRepository

+ Github func() GithubRepository

+ Health func() HealthRepository

+ JobRun func() JobRunAPIRepository

+ Log func() LogsAPIRepository

+ SNS func() SNSRepository

+ Slack func() SlackRepository

+ Step func() StepRepository

+ StepRun func() StepRunAPIRepository

+ Tenant func() TenantAPIRepository

+ TenantAlertingSettings func() TenantAlertingAPIRepository

+ TenantInvite func() TenantInviteRepository

+ User func() UserRepository

+ UserSession func() UserSessionRepository

+ Worker func() WorkerAPIRepository

+ Workflow func() WorkflowAPIRepository

+ WorkflowRun func() WorkflowRunAPIRepository

+ type APITokenRepository interface

+ GetAPITokenById func(id string) (*db.APITokenModel, error)

+ ListAPITokensByTenant func(tenantId string) ([]db.APITokenModel, error)

+ RevokeAPIToken func(id string) error

+ type CreateAPITokenOpts struct

+ ExpiresAt time.Time

+ ID string

+ Name *string

+ TenantId *string

+ type CreateDispatcherOpts struct

+ ID string

+ type CreateEventOpts struct

+ AdditionalMetadata []byte

+ Data []byte

+ Key string

+ ReplayedEvent *string

+ TenantId string

+ type CreateGithubAppOAuthOpts struct

+ AccessToken []byte

+ Config *types.JSON

+ ExpiresAt *time.Time

+ GithubUserID int

+ RefreshToken *[]byte

+ type CreateGithubWebhookOpts struct

+ RepoName string

+ RepoOwner string

+ SigningSecret []byte

+ func NewGithubWebhookCreateOpts(enc encryption.EncryptionService, repoOwner string, repoName string) (opts *CreateGithubWebhookOpts, signingSecret string, err error)

+ type CreateGroupKeyRunOpts struct

+ Input []byte

+ type CreateInstallationOpts struct

+ AccountAvatarURL *string

+ AccountID int

+ AccountName string

+ Config *types.JSON

+ InstallationID int

+ InstallationSettingsURL *string

+ type CreateLogLineOpts struct

+ CreatedAt *time.Time

+ Level *string

+ Message string

+ Metadata []byte

+ StepRunId string

+ type CreateSNSIntegrationOpts struct

+ TopicArn string

+ type CreateSessionOpts struct

+ Data *types.JSON

+ ExpiresAt time.Time

+ ID string

+ UserId *string

+ type CreateStepRunEventOpts struct

+ EventData *map[string]interface{}

+ EventMessage *string

+ EventReason *dbsqlc.StepRunEventReason

+ EventSeverity *dbsqlc.StepRunEventSeverity

+ type CreateStreamEventOpts struct

+ CreatedAt *time.Time

+ Message []byte

+ Metadata []byte

+ StepRunId string

+ type CreateTenantAlertGroupOpts struct

+ Emails []string

+ type CreateTenantInviteOpts struct

+ ExpiresAt time.Time

+ InviteeEmail string

+ InviterEmail string

+ Role string

+ type CreateTenantMemberOpts struct

+ Role string

+ UserId string

+ type CreateTenantOpts struct

+ ID *string

+ Name string

+ Slug string

+ type CreateTickerOpts struct

+ ID string

+ type CreateUserOpts struct

+ Email string

+ EmailVerified *bool

+ Name *string

+ OAuth *OAuthOpts

+ Password *string

+ type CreateWorkerOpts struct

+ Actions []string

+ DispatcherId string

+ MaxRuns *int

+ Name string

+ Services []string

+ type CreateWorkflowConcurrencyOpts struct

+ Action string

+ LimitStrategy *string

+ MaxRuns *int32

+ type CreateWorkflowJobOpts struct

+ Description *string

+ Kind string

+ Name string

+ Steps []CreateWorkflowStepOpts

+ type CreateWorkflowRunOpt func(*CreateWorkflowRunOpts)

+ func WithParent(parentId, parentStepRunId string, childIndex int, childKey *string) CreateWorkflowRunOpt

+ type CreateWorkflowRunOpts struct

+ AdditionalMetadata map[string]interface{}

+ ChildIndex *int

+ ChildKey *string

+ Cron *string

+ CronParentId *string

+ DisplayName *string

+ GetGroupKeyRun *CreateGroupKeyRunOpts

+ InputData []byte

+ ManualTriggerInput *string

+ ParentId *string

+ ParentStepRunId *string

+ ScheduledWorkflowId *string

+ TriggeredBy string

+ TriggeringEventId *string

+ WorkflowVersionId string

+ func GetCreateWorkflowRunOptsFromCron(cron, cronParentId string, ...) (*CreateWorkflowRunOpts, error)

+ func GetCreateWorkflowRunOptsFromEvent(eventId string, workflowVersion *dbsqlc.GetWorkflowVersionForEngineRow, ...) (*CreateWorkflowRunOpts, error)

+ func GetCreateWorkflowRunOptsFromManual(workflowVersion *dbsqlc.GetWorkflowVersionForEngineRow, input []byte, ...) (*CreateWorkflowRunOpts, error)

+ func GetCreateWorkflowRunOptsFromParent(workflowVersion *dbsqlc.GetWorkflowVersionForEngineRow, input []byte, ...) (*CreateWorkflowRunOpts, error)

+ func GetCreateWorkflowRunOptsFromSchedule(scheduledWorkflowId string, ...) (*CreateWorkflowRunOpts, error)

+ type CreateWorkflowRunPullRequestOpts struct

+ PullRequestBaseBranch string

+ PullRequestHeadBranch string

+ PullRequestID int

+ PullRequestNumber int

+ PullRequestState string

+ PullRequestTitle string

+ RepositoryName string

+ RepositoryOwner string

+ type CreateWorkflowSchedulesOpts struct

+ Input []byte

+ ScheduledTriggers []time.Time

+ type CreateWorkflowStepOpts struct

+ Action string

+ Parents []string

+ RateLimits []CreateWorkflowStepRateLimitOpts

+ ReadableId string

+ Retries *int

+ Timeout *string

+ UserData *string

+ type CreateWorkflowStepRateLimitOpts struct

+ Key string

+ Units int

+ type CreateWorkflowTagOpts struct

+ Color *string

+ Name string

+ type CreateWorkflowVersionOpts struct

+ Concurrency *CreateWorkflowConcurrencyOpts

+ CronInput []byte

+ CronTriggers []string

+ Description *string

+ EventTriggers []string

+ Jobs []CreateWorkflowJobOpts

+ Name string

+ OnFailureJob *CreateWorkflowJobOpts

+ ScheduleTimeout *string

+ ScheduledTriggers []time.Time

+ Tags []CreateWorkflowTagOpts

+ Version *string

+ func (o *CreateWorkflowVersionOpts) Checksum() (string, error)

+ type DispatcherEngineRepository interface

+ CreateNewDispatcher func(ctx context.Context, opts *CreateDispatcherOpts) (*dbsqlc.Dispatcher, error)

+ Delete func(ctx context.Context, dispatcherId string) error

+ UpdateDispatcher func(ctx context.Context, dispatcherId string, opts *UpdateDispatcherOpts) (*dbsqlc.Dispatcher, error)

+ UpdateStaleDispatchers func(ctx context.Context, ...) error

+ type EngineRepository interface

+ APIToken func() EngineTokenRepository

+ Dispatcher func() DispatcherEngineRepository

+ Event func() EventEngineRepository

+ GetGroupKeyRun func() GetGroupKeyRunEngineRepository

+ Health func() HealthRepository

+ JobRun func() JobRunEngineRepository

+ Log func() LogsEngineRepository

+ RateLimit func() RateLimitEngineRepository

+ StepRun func() StepRunEngineRepository

+ StreamEvent func() StreamEventsEngineRepository

+ Tenant func() TenantEngineRepository

+ TenantAlertingSettings func() TenantAlertingEngineRepository

+ Ticker func() TickerEngineRepository

+ Worker func() WorkerEngineRepository

+ Workflow func() WorkflowEngineRepository

+ WorkflowRun func() WorkflowRunEngineRepository

+ type EngineTokenRepository interface

+ CreateAPIToken func(ctx context.Context, opts *CreateAPITokenOpts) (*dbsqlc.APIToken, error)

+ GetAPITokenById func(ctx context.Context, id string) (*dbsqlc.APIToken, error)

+ type EntitlementsRepository interface

+ TenantLimit func() TenantLimitRepository

+ type EventAPIRepository interface

+ GetEventById func(id string) (*db.EventModel, error)

+ ListEventKeys func(tenantId string) ([]string, error)

+ ListEvents func(tenantId string, opts *ListEventOpts) (*ListEventResult, error)

+ ListEventsById func(tenantId string, ids []string) ([]db.EventModel, error)

+ type EventEngineRepository interface

+ CreateEvent func(ctx context.Context, opts *CreateEventOpts) (*dbsqlc.Event, error)

+ GetEventForEngine func(ctx context.Context, tenantId, id string) (*dbsqlc.Event, error)

+ ListEventsByIds func(ctx context.Context, tenantId string, ids []string) ([]*dbsqlc.Event, error)

+ type GetGroupKeyRunEngineRepository interface

+ AssignGetGroupKeyRunToTicker func(ctx context.Context, tenantId, getGroupKeyRunId string) (tickerId string, err error)

+ AssignGetGroupKeyRunToWorker func(ctx context.Context, tenantId, getGroupKeyRunId string) (workerId string, dispatcherId string, err error)

+ GetGroupKeyRunForEngine func(ctx context.Context, tenantId, getGroupKeyRunId string) (*dbsqlc.GetGroupKeyRunForEngineRow, error)

+ ListGetGroupKeyRunsToReassign func(ctx context.Context, tenantId string) ([]*dbsqlc.GetGroupKeyRun, error)

+ ListGetGroupKeyRunsToRequeue func(ctx context.Context, tenantId string) ([]*dbsqlc.GetGroupKeyRun, error)

+ UpdateGetGroupKeyRun func(ctx context.Context, tenantId, getGroupKeyRunId string, ...) (*dbsqlc.GetGroupKeyRunForEngineRow, error)

+ type GetQueueMetricsOpts struct

+ AdditionalMetadata map[string]interface{}

+ WorkflowIds []string

+ type GetQueueMetricsResponse struct

+ ByWorkflowId map[string]QueueMetric

+ Total QueueMetric

+ type GetTenantAlertingSettingsResponse struct

+ EmailGroups []*TenantAlertEmailGroupForSend

+ Settings *dbsqlc.TenantAlertingSettings

+ SlackWebhooks []*dbsqlc.SlackAppWebhook

+ Tenant *dbsqlc.Tenant

+ type GetWorkflowMetricsOpts struct

+ GroupKey *string

+ Status *string

+ type GithubRepository interface

+ AddGithubUserIdToInstallation func(installationID, accountID, githubUserId int) (*db.GithubAppInstallationModel, error)

+ CanUserAccessInstallation func(installationId, userId string) (bool, error)

+ CreateGithubWebhook func(tenantId string, opts *CreateGithubWebhookOpts) (*db.GithubWebhookModel, error)

+ CreateInstallation func(githubUserId int, opts *CreateInstallationOpts) (*db.GithubAppInstallationModel, error)

+ DeleteInstallation func(installationId, accountId int) (*db.GithubAppInstallationModel, error)

+ GetPullRequest func(tenantId, repoOwner, repoName string, prNumber int) (*db.GithubPullRequestModel, error)

+ ListGithubAppInstallationsByUserID func(userId string) ([]db.GithubAppInstallationModel, error)

+ ReadGithubAppInstallationByID func(installationId string) (*db.GithubAppInstallationModel, error)

+ ReadGithubAppInstallationByInstallationAndAccountID func(installationID, accountID int) (*db.GithubAppInstallationModel, error)

+ ReadGithubAppOAuthByGithubUserID func(githubUserID int) (*db.GithubAppOAuthModel, error)

+ ReadGithubWebhook func(tenantId, repoOwner, repoName string) (*db.GithubWebhookModel, error)

+ ReadGithubWebhookById func(id string) (*db.GithubWebhookModel, error)

+ UpdatePullRequest func(tenantId, prId string, opts *UpdatePullRequestOpts) (*db.GithubPullRequestModel, error)

+ UpsertGithubAppOAuth func(userId string, opts *CreateGithubAppOAuthOpts) (*db.GithubAppOAuthModel, error)

+ type HealthRepository interface

+ IsHealthy func() bool

+ type JobRunAPIRepository interface

+ SetJobRunStatusRunning func(tenantId, jobRunId string) error

+ type JobRunEngineRepository interface

+ GetJobRunByWorkflowRunIdAndJobId func(ctx context.Context, tenantId, workflowRunId, jobId string) (*dbsqlc.GetJobRunByWorkflowRunIdAndJobIdRow, error)

+ ListJobRunsForWorkflowRun func(ctx context.Context, tenantId, workflowRunId string) ([]*dbsqlc.ListJobRunsForWorkflowRunRow, error)

+ SetJobRunStatusRunning func(ctx context.Context, tenantId, jobRunId string) error

+ type JobRunHasCycleError struct

+ JobName string

+ func (e *JobRunHasCycleError) Error() string

+ type ListAllJobRunsOpts struct

+ NoTickerId *bool

+ Status *db.JobRunStatus

+ TickerId *string

+ type ListEventOpts struct

+ AdditionalMetadata []byte

+ Keys []string

+ Limit *int

+ Offset *int

+ OrderBy *string

+ OrderDirection *string

+ ReplayedEvent *string

+ Search *string

+ WorkflowRunStatus []db.WorkflowRunStatus

+ Workflows []string

+ type ListEventResult struct

+ Count int

+ Rows []*dbsqlc.ListEventsRow

+ type ListGetGroupKeyRunsOpts struct

+ Status *db.StepRunStatus

+ type ListLogsOpts struct

+ Levels []string

+ Limit *int

+ Offset *int

+ OrderBy *string

+ OrderDirection *string

+ Search *string

+ StepRunId *string

+ type ListLogsResult struct

+ Count int

+ Rows []*dbsqlc.LogLine

+ type ListPullRequestsForWorkflowRunOpts struct

+ State *string

+ type ListStepRunEventOpts struct

+ Limit *int

+ Offset *int

+ type ListStepRunEventResult struct

+ Count int

+ Rows []*dbsqlc.StepRunEvent

+ type ListStepRunsOpts struct

+ JobRunId *string

+ Status *dbsqlc.StepRunStatus

+ WorkflowRunIds []string

+ type ListTenantInvitesOpts struct

+ Expired *bool

+ Status *string

+ type ListTickerOpts struct

+ Active *bool

+ LatestHeartbeatAfter *time.Time

+ type ListWorkersOpts struct

+ Action *string

+ Assignable *bool

+ LastHeartbeatAfter *time.Time

+ type ListWorkflowRunRoundRobinsOpts struct

+ Limit *int

+ Offset *int

+ Status *db.WorkflowRunStatus

+ WorkflowId *string

+ WorkflowVersionId *string

+ type ListWorkflowRunsOpts struct

+ AdditionalMetadata map[string]interface{}

+ CreatedAfter *time.Time

+ EventId *string

+ FinishedAfter *time.Time

+ GroupKey *string

+ Ids []string

+ Limit *int

+ Offset *int

+ OrderBy *string

+ OrderDirection *string

+ ParentId *string

+ ParentStepRunId *string

+ Statuses *[]db.WorkflowRunStatus

+ WorkflowId *string

+ WorkflowVersionId *string

+ type ListWorkflowRunsResult struct

+ Count int

+ Rows []*dbsqlc.ListWorkflowRunsRow

+ type ListWorkflowsOpts struct

+ EventKey *string

+ Limit *int

+ Offset *int

+ type ListWorkflowsResult struct

+ Count int

+ Rows []*ListWorkflowsRow

+ type ListWorkflowsRow struct

+ LatestRun *db.WorkflowRunModel

+ type LogsAPIRepository interface

+ ListLogLines func(tenantId string, opts *ListLogsOpts) (*ListLogsResult, error)

+ type LogsEngineRepository interface

+ PutLog func(ctx context.Context, tenantId string, opts *CreateLogLineOpts) (*dbsqlc.LogLine, error)

+ type OAuthOpts struct

+ AccessToken []byte

+ ExpiresAt *time.Time

+ Provider string

+ ProviderUserId string

+ RefreshToken *[]byte

+ type QueueMetric struct

+ Pending int

+ PendingAssignment int

+ Running int

+ type RateLimitEngineRepository interface

+ UpsertRateLimit func(ctx context.Context, tenantId string, key string, opts *UpsertRateLimitOpts) (*dbsqlc.RateLimit, error)

+ type RefreshTimeoutBy struct

+ IncrementTimeoutBy string

+ type SNSRepository interface

+ CreateSNSIntegration func(tenantId string, opts *CreateSNSIntegrationOpts) (*db.SNSIntegrationModel, error)

+ DeleteSNSIntegration func(tenantId, id string) error

+ GetSNSIntegration func(tenantId, topicArn string) (*db.SNSIntegrationModel, error)

+ GetSNSIntegrationById func(id string) (*db.SNSIntegrationModel, error)

+ ListSNSIntegrations func(tenantId string) ([]db.SNSIntegrationModel, error)

+ type SlackRepository interface

+ DeleteSlackWebhook func(tenantId string, id string) error

+ GetSlackWebhookById func(id string) (*db.SlackAppWebhookModel, error)

+ ListSlackWebhooks func(tenantId string) ([]db.SlackAppWebhookModel, error)

+ UpsertSlackWebhook func(tenantId string, opts *UpsertSlackWebhookOpts) (*db.SlackAppWebhookModel, error)

+ type StepRepository interface

+ ListStepsByActions func(tenantId string, actions []string) ([]db.StepModel, error)

+ type StepRunAPIRepository interface

+ GetFirstArchivedStepRunResult func(tenantId, stepRunId string) (*db.StepRunResultArchiveModel, error)

+ GetStepRunById func(tenantId, stepRunId string) (*db.StepRunModel, error)

+ ListStepRunEvents func(stepRunId string, opts *ListStepRunEventOpts) (*ListStepRunEventResult, error)

+ type StepRunEngineRepository interface

+ ArchiveStepRunResult func(ctx context.Context, tenantId, stepRunId string) error

+ AssignStepRunToWorker func(ctx context.Context, stepRun *dbsqlc.GetStepRunForEngineRow) (workerId string, dispatcherId string, err error)

+ CreateStepRunEvent func(ctx context.Context, tenantId, stepRunId string, opts CreateStepRunEventOpts) error

+ GetStepRunForEngine func(ctx context.Context, tenantId, stepRunId string) (*dbsqlc.GetStepRunForEngineRow, error)

+ ListStartableStepRuns func(ctx context.Context, tenantId, jobRunId string, parentStepRunId *string) ([]*dbsqlc.GetStepRunForEngineRow, error)

+ ListStepRuns func(ctx context.Context, tenantId string, opts *ListStepRunsOpts) ([]*dbsqlc.GetStepRunForEngineRow, error)

+ ListStepRunsToReassign func(ctx context.Context, tenantId string) ([]*dbsqlc.GetStepRunForEngineRow, error)

+ ListStepRunsToRequeue func(ctx context.Context, tenantId string) ([]*dbsqlc.GetStepRunForEngineRow, error)

+ PreflightCheckReplayStepRun func(ctx context.Context, tenantId, stepRunId string) error

+ QueueStepRun func(ctx context.Context, tenantId, stepRunId string, opts *UpdateStepRunOpts) (*dbsqlc.GetStepRunForEngineRow, error)

+ RefreshTimeoutBy func(ctx context.Context, tenantId, stepRunId string, opts RefreshTimeoutBy) (*dbsqlc.StepRun, error)

+ ReleaseStepRunSemaphore func(ctx context.Context, tenantId, stepRunId string) error

+ ReplayStepRun func(ctx context.Context, tenantId, stepRunId string, opts *UpdateStepRunOpts) (*dbsqlc.GetStepRunForEngineRow, error)

+ UnlinkStepRunFromWorker func(ctx context.Context, tenantId, stepRunId string) error

+ UpdateStepRun func(ctx context.Context, tenantId, stepRunId string, opts *UpdateStepRunOpts) (*dbsqlc.GetStepRunForEngineRow, *StepRunUpdateInfo, error)

+ UpdateStepRunInputSchema func(ctx context.Context, tenantId, stepRunId string, schema []byte) ([]byte, error)

+ UpdateStepRunOverridesData func(ctx context.Context, tenantId, stepRunId string, ...) ([]byte, error)

+ type StepRunUpdateInfo struct

+ JobRunFinalState bool

+ WorkflowRunFinalState bool

+ WorkflowRunId string

+ WorkflowRunStatus string

+ type StreamEventsEngineRepository interface

+ CleanupStreamEvents func(ctx context.Context) error

+ GetStreamEvent func(ctx context.Context, tenantId string, streamEventId int64) (*dbsqlc.StreamEvent, error)

+ PutStreamEvent func(ctx context.Context, tenantId string, opts *CreateStreamEventOpts) (*dbsqlc.StreamEvent, error)

+ type TenantAPIRepository interface

+ CreateTenant func(opts *CreateTenantOpts) (*db.TenantModel, error)

+ CreateTenantMember func(tenantId string, opts *CreateTenantMemberOpts) (*db.TenantMemberModel, error)

+ DeleteTenantMember func(memberId string) (*db.TenantMemberModel, error)

+ GetQueueMetrics func(tenantId string, opts *GetQueueMetricsOpts) (*GetQueueMetricsResponse, error)

+ GetTenantByID func(tenantId string) (*db.TenantModel, error)

+ GetTenantBySlug func(slug string) (*db.TenantModel, error)

+ GetTenantMemberByEmail func(tenantId string, email string) (*db.TenantMemberModel, error)

+ GetTenantMemberByID func(memberId string) (*db.TenantMemberModel, error)

+ GetTenantMemberByUserID func(tenantId string, userId string) (*db.TenantMemberModel, error)

+ ListTenantMembers func(tenantId string) ([]db.TenantMemberModel, error)

+ UpdateTenant func(tenantId string, opts *UpdateTenantOpts) (*db.TenantModel, error)

+ UpdateTenantMember func(memberId string, opts *UpdateTenantMemberOpts) (*db.TenantMemberModel, error)

+ type TenantAlertEmailGroupForSend struct

+ Emails []string

+ TenantId pgtype.UUID

+ type TenantAlertingAPIRepository interface

+ CreateTenantAlertGroup func(tenantId string, opts *CreateTenantAlertGroupOpts) (*db.TenantAlertEmailGroupModel, error)

+ DeleteTenantAlertGroup func(tenantId string, id string) error

+ GetTenantAlertGroupById func(id string) (*db.TenantAlertEmailGroupModel, error)

+ GetTenantAlertingSettings func(tenantId string) (*db.TenantAlertingSettingsModel, error)

+ ListTenantAlertGroups func(tenantId string) ([]db.TenantAlertEmailGroupModel, error)

+ UpdateTenantAlertGroup func(id string, opts *UpdateTenantAlertGroupOpts) (*db.TenantAlertEmailGroupModel, error)

+ UpsertTenantAlertingSettings func(tenantId string, opts *UpsertTenantAlertingSettingsOpts) (*db.TenantAlertingSettingsModel, error)

+ type TenantAlertingEngineRepository interface

+ GetTenantAlertingSettings func(ctx context.Context, tenantId string) (*GetTenantAlertingSettingsResponse, error)

+ UpdateTenantAlertingSettings func(ctx context.Context, tenantId string, opts *UpdateTenantAlertingSettingsOpts) error

+ type TenantEngineRepository interface

+ GetTenantByID func(ctx context.Context, tenantId string) (*dbsqlc.Tenant, error)

+ ListTenants func(ctx context.Context) ([]*dbsqlc.Tenant, error)

+ type TenantInviteRepository interface

+ CreateTenantInvite func(tenantId string, opts *CreateTenantInviteOpts) (*db.TenantInviteLinkModel, error)

+ DeleteTenantInvite func(id string) error

+ GetTenantInvite func(id string) (*db.TenantInviteLinkModel, error)

+ ListTenantInvitesByEmail func(email string) ([]db.TenantInviteLinkModel, error)

+ ListTenantInvitesByTenantId func(tenantId string, opts *ListTenantInvitesOpts) ([]db.TenantInviteLinkModel, error)

+ UpdateTenantInvite func(id string, opts *UpdateTenantInviteOpts) (*db.TenantInviteLinkModel, error)

+ type TenantLimitConfig struct

+ EnforceLimits bool

+ type TenantLimitRepository interface

+ CanCreate func(ctx context.Context, resource dbsqlc.LimitResource, tenantId string) (bool, int, error)

+ CreateTenantDefaultLimits func(ctx context.Context, tenantId string) error

+ GetLimits func(ctx context.Context, tenantId string) ([]*dbsqlc.TenantResourceLimit, error)

+ Meter func(ctx context.Context, resource dbsqlc.LimitResource, tenantId string) (*dbsqlc.TenantResourceLimit, error)

+ ResolveAllTenantResourceLimits func(ctx context.Context) error

+ type TickerEngineRepository interface

+ CreateNewTicker func(ctx context.Context, opts *CreateTickerOpts) (*dbsqlc.Ticker, error)

+ Delete func(ctx context.Context, tickerId string) error

+ ListTickers func(ctx context.Context, opts *ListTickerOpts) ([]*dbsqlc.Ticker, error)

+ PollCronSchedules func(ctx context.Context, tickerId string) ([]*dbsqlc.PollCronSchedulesRow, error)

+ PollExpiringTokens func(ctx context.Context) ([]*dbsqlc.PollExpiringTokensRow, error)

+ PollGetGroupKeyRuns func(ctx context.Context, tickerId string) ([]*dbsqlc.GetGroupKeyRun, error)

+ PollScheduledWorkflows func(ctx context.Context, tickerId string) ([]*dbsqlc.PollScheduledWorkflowsRow, error)

+ PollStepRuns func(ctx context.Context, tickerId string) ([]*dbsqlc.StepRun, error)

+ PollTenantAlerts func(ctx context.Context, tickerId string) ([]*dbsqlc.PollTenantAlertsRow, error)

+ PollTenantResourceLimitAlerts func(ctx context.Context) ([]*dbsqlc.TenantResourceLimitAlert, error)

+ UpdateTicker func(ctx context.Context, tickerId string, opts *UpdateTickerOpts) (*dbsqlc.Ticker, error)

+ type UpdateDispatcherOpts struct

+ LastHeartbeatAt *time.Time

+ type UpdateGetGroupKeyRunOpts struct

+ CancelledAt *time.Time

+ CancelledReason *string

+ Error *string

+ FailedAt *time.Time

+ FinishedAt *time.Time

+ Output *string

+ RequeueAfter *time.Time

+ ScheduleTimeoutAt *time.Time

+ StartedAt *time.Time

+ Status *db.StepRunStatus

+ type UpdateInstallationOpts struct

+ type UpdateJobRunLookupDataOpts struct

+ Data []byte

+ FieldPath []string

+ type UpdatePullRequestOpts struct

+ BaseBranch *string

+ HeadBranch *string

+ State *string

+ Title *string

+ type UpdateSessionOpts struct

+ Data *types.JSON

+ UserId *string

+ type UpdateStepRunOpts struct

+ CancelledAt *time.Time

+ CancelledReason *string

+ Error *string

+ Event *CreateStepRunEventOpts

+ FailedAt *time.Time

+ FinishedAt *time.Time

+ Input []byte

+ IsRerun bool

+ Output []byte

+ RequeueAfter *time.Time

+ RetryCount *int

+ ScheduleTimeoutAt *time.Time

+ StartedAt *time.Time

+ Status *db.StepRunStatus

+ type UpdateStepRunOverridesDataOpts struct

+ CallerFile *string

+ Data []byte

+ OverrideKey string

+ type UpdateTenantAlertGroupOpts struct

+ Emails []string

+ type UpdateTenantAlertingSettingsOpts struct

+ LastAlertedAt *time.Time

+ type UpdateTenantInviteOpts struct

+ Role *string

+ Status *string

+ type UpdateTenantMemberOpts struct

+ Role *string

+ type UpdateTenantOpts struct

+ AlertMemberEmails *bool

+ AnalyticsOptOut *bool

+ Name *string

+ type UpdateTickerOpts struct

+ LastHeartbeatAt *time.Time

+ type UpdateUserOpts struct

+ EmailVerified *bool

+ Name *string

+ OAuth *OAuthOpts

+ Password *string

+ type UpdateWorkerOpts struct

+ Actions []string

+ DispatcherId *string

+ IsActive *bool

+ LastHeartbeatAt *time.Time

+ type UpsertRateLimitOpts struct

+ Duration *string

+ Limit int

+ type UpsertSlackWebhookOpts struct

+ ChannelId string

+ ChannelName string

+ TeamId string

+ TeamName string

+ WebhookURL []byte

+ type UpsertTenantAlertingSettingsOpts struct

+ EnableExpiringTokenAlerts *bool

+ EnableTenantResourceLimitAlerts *bool

+ EnableWorkflowRunFailureAlerts *bool

+ MaxFrequency *string

+ type UpsertWorkflowDeploymentConfigOpts struct

+ GitRepoBranch string

+ GitRepoName string

+ GitRepoOwner string

+ GithubAppInstallationId string

+ type UserRepository interface

+ CreateUser func(*CreateUserOpts) (*db.UserModel, error)

+ GetUserByEmail func(email string) (*db.UserModel, error)

+ GetUserByID func(id string) (*db.UserModel, error)

+ GetUserPassword func(id string) (*db.UserPasswordModel, error)

+ ListTenantMemberships func(userId string) ([]db.TenantMemberModel, error)

+ UpdateUser func(id string, opts *UpdateUserOpts) (*db.UserModel, error)

+ type UserSessionRepository interface

+ Create func(opts *CreateSessionOpts) (*db.UserSessionModel, error)

+ Delete func(sessionId string) (*db.UserSessionModel, error)

+ GetById func(sessionId string) (*db.UserSessionModel, error)

+ Update func(sessionId string, opts *UpdateSessionOpts) (*db.UserSessionModel, error)

+ type WorkerAPIRepository interface

+ GetWorkerById func(workerId string) (*db.WorkerModel, error)

+ ListRecentWorkerStepRuns func(tenantId, workerId string) ([]db.StepRunModel, error)

+ ListWorkers func(tenantId string, opts *ListWorkersOpts) ([]*dbsqlc.ListWorkersWithStepCountRow, error)

+ type WorkerEngineRepository interface

+ CreateNewWorker func(ctx context.Context, tenantId string, opts *CreateWorkerOpts) (*dbsqlc.Worker, error)

+ DeleteWorker func(ctx context.Context, tenantId, workerId string) error

+ GetWorkerForEngine func(ctx context.Context, tenantId, workerId string) (*dbsqlc.GetWorkerForEngineRow, error)

+ ResolveWorkerSemaphoreSlots func(ctx context.Context) (int64, error)

+ UpdateWorker func(ctx context.Context, tenantId, workerId string, opts *UpdateWorkerOpts) (*dbsqlc.Worker, error)

+ UpdateWorkerActiveStatus func(ctx context.Context, tenantId, workerId string, isActive bool, ...) (*dbsqlc.Worker, error)

+ type WorkerWithStepCount struct

+ StepRunCount int

+ Worker *db.WorkerModel

+ type WorkflowAPIRepository interface

+ DeleteWorkflow func(tenantId, workflowId string) (*db.WorkflowModel, error)

+ GetWorkflowById func(workflowId string) (*db.WorkflowModel, error)

+ GetWorkflowByName func(tenantId, workflowName string) (*db.WorkflowModel, error)

+ GetWorkflowMetrics func(tenantId, workflowId string, opts *GetWorkflowMetricsOpts) (*WorkflowMetrics, error)

+ GetWorkflowVersionById func(tenantId, workflowId string) (*db.WorkflowVersionModel, error)

+ ListWorkflows func(tenantId string, opts *ListWorkflowsOpts) (*ListWorkflowsResult, error)

+ UpsertWorkflowDeploymentConfig func(workflowId string, opts *UpsertWorkflowDeploymentConfigOpts) (*db.WorkflowDeploymentConfigModel, error)

+ type WorkflowEngineRepository interface

+ CreateNewWorkflow func(ctx context.Context, tenantId string, opts *CreateWorkflowVersionOpts) (*dbsqlc.GetWorkflowVersionForEngineRow, error)

+ CreateSchedules func(ctx context.Context, tenantId, workflowVersionId string, ...) ([]*dbsqlc.WorkflowTriggerScheduledRef, error)

+ CreateWorkflowVersion func(ctx context.Context, tenantId string, opts *CreateWorkflowVersionOpts) (*dbsqlc.GetWorkflowVersionForEngineRow, error)

+ GetLatestWorkflowVersion func(ctx context.Context, tenantId, workflowId string) (*dbsqlc.GetWorkflowVersionForEngineRow, error)

+ GetWorkflowByName func(ctx context.Context, tenantId, workflowName string) (*dbsqlc.Workflow, error)

+ GetWorkflowVersionById func(ctx context.Context, tenantId, workflowId string) (*dbsqlc.GetWorkflowVersionForEngineRow, error)

+ ListWorkflowsForEvent func(ctx context.Context, tenantId, eventKey string) ([]*dbsqlc.GetWorkflowVersionForEngineRow, error)

+ type WorkflowMetrics struct

+ GroupKeyCount int

+ GroupKeyRunsCount int

+ type WorkflowRunAPIRepository interface

+ CreateNewWorkflowRun func(ctx context.Context, tenantId string, opts *CreateWorkflowRunOpts) (*db.WorkflowRunModel, error)

+ CreateWorkflowRunPullRequest func(tenantId, workflowRunId string, opts *CreateWorkflowRunPullRequestOpts) (*db.GithubPullRequestModel, error)

+ GetWorkflowRunById func(tenantId, runId string) (*db.WorkflowRunModel, error)

+ ListPullRequestsForWorkflowRun func(tenantId, workflowRunId string, opts *ListPullRequestsForWorkflowRunOpts) ([]db.GithubPullRequestModel, error)

+ ListWorkflowRuns func(tenantId string, opts *ListWorkflowRunsOpts) (*ListWorkflowRunsResult, error)

+ WorkflowRunMetricsCount func(tenantId string, opts *WorkflowRunsMetricsOpts) (*dbsqlc.WorkflowRunsMetricsCountRow, error)

+ type WorkflowRunEngineRepository interface

+ CreateNewWorkflowRun func(ctx context.Context, tenantId string, opts *CreateWorkflowRunOpts) (string, error)

+ GetChildWorkflowRun func(ctx context.Context, parentId, parentStepRunId string, childIndex int, ...) (*dbsqlc.WorkflowRun, error)

+ GetScheduledChildWorkflowRun func(ctx context.Context, parentId, parentStepRunId string, childIndex int, ...) (*dbsqlc.WorkflowTriggerScheduledRef, error)

+ GetWorkflowRunById func(ctx context.Context, tenantId, runId string) (*dbsqlc.GetWorkflowRunRow, error)

+ ListWorkflowRuns func(ctx context.Context, tenantId string, opts *ListWorkflowRunsOpts) (*ListWorkflowRunsResult, error)

+ PopWorkflowRunsRoundRobin func(ctx context.Context, tenantId, workflowId string, maxRuns int) ([]*dbsqlc.WorkflowRun, error)

+ type WorkflowRunMetricsCountOpts struct

+ WorkflowId *string

+ WorkflowVersionId *string

+ type WorkflowRunsMetricsOpts struct

+ AdditionalMetadata map[string]interface{}

+ EventId *string

+ ParentId *string

+ ParentStepRunId *string

+ WorkflowId *string

+ WorkflowVersionId *string