repository

Jun 7, 2024

Changes in this version

+ type EntitlementsRepository interface

+ TenantLimit func() TenantLimitRepository

+ 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

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

type UpsertTenantAlertingSettingsOpts

+ EnableTenantResourceLimitAlerts *bool

Jun 4, 2024

Changes in this version

+ type TenantAlertEmailGroupForSend struct

+ Emails []string

+ TenantId pgtype.UUID

type TickerEngineRepository

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

type UpdateTenantOpts

+ AlertMemberEmails *bool

type UpsertTenantAlertingSettingsOpts

+ EnableExpiringTokenAlerts *bool

+ EnableWorkflowRunFailureAlerts *bool

May 31, 2024

Changes in this version

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

May 21, 2024

Changes in this version

type WorkerEngineRepository

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

May 21, 2024

Changes in this version

type UpdateWorkerOpts

+ IsActive *bool

May 17, 2024

Changes in this version

+ 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")

type StepRunEngineRepository

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

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

May 16, 2024

Changes in this version

+ type RefreshTimeoutBy struct

+ IncrementTimeoutBy string

type StepRunEngineRepository

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

May 14, 2024

Changes in this version

+ type CreateStepRunEventOpts struct

+ EventData *map[string]interface{}

+ EventMessage *string

+ EventReason *dbsqlc.StepRunEventReason

+ EventSeverity *dbsqlc.StepRunEventSeverity

type StepRunEngineRepository

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

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

type UpdateStepRunOpts

+ Event *CreateStepRunEventOpts

type WorkerEngineRepository

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

May 9, 2024

Changes in this version

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

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

+ type ListStepRunEventOpts struct

+ Limit *int

+ Offset *int

+ type ListStepRunEventResult struct

+ Count int

+ Rows []*dbsqlc.StepRunEvent

type StepRunAPIRepository

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

type UpdateStepRunOpts

+ EventMessage *string

+ EventReason *dbsqlc.StepRunEventReason

+ EventSeverity *dbsqlc.StepRunEventSeverity

May 8, 2024

Changes in this version

type ListWorkflowRunsOpts

+ FinishedAfter *time.Time

May 8, 2024

Changes in this version

+ func IsFinalJobRunStatus(status dbsqlc.JobRunStatus) bool

+ func IsFinalStepRunStatus(status dbsqlc.StepRunStatus) bool

+ func IsFinalWorkflowRunStatus(status dbsqlc.WorkflowRunStatus) bool

type APIRepository

+ Slack func() SlackRepository

+ TenantAlertingSettings func() TenantAlertingAPIRepository

type CreateEventOpts

+ AdditionalMetadata []byte

+ type CreateTenantAlertGroupOpts struct

+ Emails []string

type CreateWorkflowJobOpts

+ Kind string

type CreateWorkflowRunOpts

+ AdditionalMetadata map[string]interface{}

type CreateWorkflowVersionOpts

+ OnFailureJob *CreateWorkflowJobOpts

type EngineRepository

+ TenantAlertingSettings func() TenantAlertingEngineRepository

+ type GetTenantAlertingSettingsResponse struct

+ EmailGroups []*dbsqlc.TenantAlertEmailGroup

+ Settings *dbsqlc.TenantAlertingSettings

+ SlackWebhooks []*dbsqlc.SlackAppWebhook

+ Tenant *dbsqlc.Tenant

type JobRunEngineRepository

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

type ListEventOpts

+ AdditionalMetadata []byte

type ListWorkflowRunsOpts

+ AdditionalMetadata map[string]interface{}

+ CreatedAfter *time.Time

+ 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 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 TickerEngineRepository

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

+ type UpdateTenantAlertGroupOpts struct

+ Emails []string

+ type UpdateTenantAlertingSettingsOpts struct

+ LastAlertedAt *time.Time

type UpdateTenantOpts

+ Name *string

+ type UpsertSlackWebhookOpts struct

+ ChannelId string

+ ChannelName string

+ TeamId string

+ TeamName string

+ WebhookURL []byte

+ type UpsertTenantAlertingSettingsOpts struct

+ MaxFrequency *string

type WorkflowRunsMetricsOpts

+ AdditionalMetadata map[string]interface{}

May 5, 2024

Changes in this version

type TenantAPIRepository

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

+ type UpdateTenantOpts struct

+ AnalyticsOptOut *bool

May 1, 2024

Changes in this version

type StepRunEngineRepository

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

Apr 29, 2024

Changes in this version

type WorkflowRunAPIRepository

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

+ type WorkflowRunMetricsCountOpts struct

+ WorkflowId *string

+ WorkflowVersionId *string

+ type WorkflowRunsMetricsOpts struct

+ EventId *string

+ ParentId *string

+ ParentStepRunId *string

+ WorkflowId *string

+ WorkflowVersionId *string

Apr 19, 2024

Changes in this version

type ListStepRunsOpts

+ WorkflowRunIds []string

type ListWorkflowRunsOpts

+ Ids []string

+ Statuses *[]db.WorkflowRunStatus

type StepRunEngineRepository

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

Apr 4, 2024

Changes in this version

+ type GetWorkflowMetricsOpts struct

+ GroupKey *string

+ Status *string

type WorkflowAPIRepository

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

+ type WorkflowMetrics struct

+ GroupKeyCount int

+ GroupKeyRunsCount int

Apr 2, 2024

Changes in this version

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

+ type CreateStreamEventOpts struct

+ CreatedAt *time.Time

+ Message []byte

+ Metadata []byte

+ StepRunId string

type CreateWorkflowStepOpts

+ RateLimits []CreateWorkflowStepRateLimitOpts

+ type CreateWorkflowStepRateLimitOpts struct

+ Key string

+ Units int

type CreateWorkflowVersionOpts

+ CronInput []byte

type EngineRepository

+ RateLimit func() RateLimitEngineRepository

+ StreamEvent func() StreamEventsEngineRepository

+ type RateLimitEngineRepository interface

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

+ type StreamEventsEngineRepository interface

+ CleanupStreamEvents func() error

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

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

type UpdateUserOpts

+ Password *string

+ type UpsertRateLimitOpts struct

+ Duration *string

+ Limit int

Mar 29, 2024

Changes in this version

+ type CreateWorkflowRunOpt func(*CreateWorkflowRunOpts)

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

type CreateWorkflowRunOpts

+ ChildIndex *int

+ ChildKey *string

+ ParentId *string

+ ParentStepRunId *string

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

type ListWorkflowRunsOpts

+ ParentId *string

+ ParentStepRunId *string

type WorkflowRunEngineRepository

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

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

Mar 21, 2024

Changes in this version

+ type APIRepository interface

+ APIToken func() APITokenRepository

+ Event func() EventAPIRepository

+ Github func() GithubRepository

+ Health func() HealthRepository

+ JobRun func() JobRunAPIRepository

+ Log func() LogsAPIRepository

+ SNS func() SNSRepository

+ Step func() StepRepository

+ StepRun func() StepRunAPIRepository

+ Tenant func() TenantAPIRepository

+ TenantInvite func() TenantInviteRepository

+ User func() UserRepository

+ UserSession func() UserSessionRepository

+ Worker func() WorkerAPIRepository

+ Workflow func() WorkflowAPIRepository

+ WorkflowRun func() WorkflowRunAPIRepository

+ type DispatcherEngineRepository interface

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

+ Delete func(dispatcherId string) error

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

+ UpdateStaleDispatchers func(onStale func(dispatcherId string, getValidDispatcherId func() string) error) 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

+ StepRun func() StepRunEngineRepository

+ Tenant func() TenantEngineRepository

+ Ticker func() TickerEngineRepository

+ Worker func() WorkerEngineRepository

+ Workflow func() WorkflowEngineRepository

+ WorkflowRun func() WorkflowRunEngineRepository

+ type EngineTokenRepository interface

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

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

+ 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(tenantId, id string) (*dbsqlc.Event, error)

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

+ type GetGroupKeyRunEngineRepository interface

+ AssignGetGroupKeyRunToTicker func(tenantId, getGroupKeyRunId string) (tickerId string, err error)

+ AssignGetGroupKeyRunToWorker func(tenantId, getGroupKeyRunId string) (workerId string, dispatcherId string, err error)

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

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

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

+ UpdateGetGroupKeyRun func(tenantId, getGroupKeyRunId string, opts *UpdateGetGroupKeyRunOpts) (*dbsqlc.GetGroupKeyRunForEngineRow, error)

+ type JobRunAPIRepository interface

+ SetJobRunStatusRunning func(tenantId, jobRunId string) error

+ type JobRunEngineRepository interface

+ ListJobRunsForWorkflowRun func(tenantId, workflowRunId string) ([]pgtype.UUID, error)

+ SetJobRunStatusRunning func(tenantId, jobRunId string) error

type ListTickerOpts

+ LatestHeartbeatAfter *time.Time

+ type LogsAPIRepository interface

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

+ type LogsEngineRepository interface

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

+ type StepRunAPIRepository interface

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

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

+ type StepRunEngineRepository interface

+ ArchiveStepRunResult func(tenantId, stepRunId string) error

+ AssignStepRunToWorker func(tenantId, stepRunId string) (workerId string, dispatcherId string, err error)

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

+ ListRunningStepRunsForTicker func(tickerId string) ([]*dbsqlc.GetStepRunForEngineRow, error)

+ ListRunningStepRunsForWorkflowRun func(tenantId, workflowRunId string) ([]*dbsqlc.GetStepRunForEngineRow, error)

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

+ ListStepRunsToReassign func(tenantId string) ([]*dbsqlc.StepRun, error)

+ ListStepRunsToRequeue func(tenantId string) ([]*dbsqlc.StepRun, error)

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

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

+ UpdateStepRunInputSchema func(tenantId, stepRunId string, schema []byte) ([]byte, error)

+ UpdateStepRunOverridesData func(tenantId, stepRunId string, opts *UpdateStepRunOverridesDataOpts) ([]byte, 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)

+ 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)

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

+ type TenantEngineRepository interface

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

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

+ type TickerEngineRepository interface

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

+ Delete func(tickerId string) error

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

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

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

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

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

+ UpdateTicker func(tickerId string, opts *UpdateTickerOpts) (*dbsqlc.Ticker, 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(tenantId string, opts *CreateWorkerOpts) (*dbsqlc.Worker, error)

+ DeleteWorker func(tenantId, workerId string) error

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

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

+ 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)

+ 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(tenantId string, opts *CreateWorkflowVersionOpts) (*dbsqlc.GetWorkflowVersionForEngineRow, error)

+ CreateSchedules func(tenantId, workflowVersionId string, opts *CreateWorkflowSchedulesOpts) ([]*dbsqlc.WorkflowTriggerScheduledRef, error)

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

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

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

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

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

+ 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)

+ type WorkflowRunEngineRepository interface

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

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

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

+ PopWorkflowRunsRoundRobin func(tenantId, workflowVersionId string, maxRuns int) ([]*dbsqlc.WorkflowRun, error)

Mar 12, 2024

Changes in this version

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

type CreateWorkflowRunOpts

+ InputData []byte

+ TriggeredBy string

type EventRepository

+ GetEventForEngine func(tenantId, id string) (*dbsqlc.GetEventForEngineRow, error)

type GetGroupKeyRunRepository

+ AssignGetGroupKeyRunToTicker func(tenantId, getGroupKeyRunId string) (tickerId string, err error)

+ AssignGetGroupKeyRunToWorker func(tenantId, getGroupKeyRunId string) (workerId string, dispatcherId string, err error)

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

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

type StepRunRepository

+ AssignStepRunToTicker func(tenantId, stepRunId string) (tickerId string, err error)

+ AssignStepRunToWorker func(tenantId, stepRunId string) (workerId string, dispatcherId string, err error)

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

type WorkerRepository

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

Mar 7, 2024

Changes in this version

+ type CreateSNSIntegrationOpts struct

+ TopicArn string

type SNSRepository

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

+ DeleteSNSIntegration func(tenantId, id string) error

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

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

Mar 4, 2024

Changes in this version

type ListEventOpts

+ WorkflowRunStatus []db.WorkflowRunStatus

type Repository

+ SNS func() SNSRepository

+ type SNSRepository interface

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

Mar 4, 2024

Changes in this version

type StepRunRepository

+ ListStepRunsToReassign func(tenantId string) ([]*dbsqlc.StepRun, error)

Mar 1, 2024

Changes in this version

+ type CreateLogLineOpts struct

+ CreatedAt *time.Time

+ Level *string

+ Message string

+ Metadata []byte

+ StepRunId string

+ 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 LogsRepository interface

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

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

type Repository

+ Log func() LogsRepository

Feb 28, 2024

Changes in this version

type CreateWorkflowVersionOpts

+ ScheduleTimeout *string

type GetGroupKeyRunRepository

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

Feb 27, 2024

Changes in this version

+ type HealthRepository interface

+ IsHealthy func() bool

type Repository

+ Health func() HealthRepository

type StepRunRepository

+ ListStepRunsToRequeue func(tenantId string) ([]*dbsqlc.StepRun, error)

Feb 26, 2024

Changes in this version

type CreateWorkerOpts

+ MaxRuns *int

type ListWorkersOpts

+ Assignable *bool

+ type ListWorkflowRunRoundRobinsOpts struct

+ Limit *int

+ Offset *int

+ Status *db.WorkflowRunStatus

+ WorkflowId *string

+ WorkflowVersionId *string

type WorkflowRunRepository

+ PopWorkflowRunsRoundRobin func(tenantId, workflowVersionId string, maxRuns int) ([]*dbsqlc.WorkflowRun, error)

Feb 19, 2024

Changes in this version

+ 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 CreateInstallationOpts struct

+ AccountAvatarURL *string

+ AccountID int

+ AccountName string

+ Config *types.JSON

+ InstallationID int

+ InstallationSettingsURL *string

+ type CreateWorkflowRunPullRequestOpts struct

+ PullRequestBaseBranch string

+ PullRequestHeadBranch string

+ PullRequestID int

+ PullRequestNumber int

+ PullRequestState string

+ PullRequestTitle string

+ RepositoryName string

+ RepositoryOwner string

type CreateWorkflowStepOpts

+ Retries *int

+ 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 JobRunRepository

+ SetJobRunStatusRunning func(tenantId, jobRunId string) error

+ type ListPullRequestsForWorkflowRunOpts struct

+ State *string

type Repository

+ Github func() GithubRepository

type StepRunRepository

+ ArchiveStepRunResult func(tenantId, stepRunId string) error

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

+ ListArchivedStepRunResults func(tenantId, stepRunId string) ([]db.StepRunResultArchiveModel, error)

+ UpdateStepRunInputSchema func(tenantId, stepRunId string, schema []byte) ([]byte, error)

+ UpdateStepRunOverridesData func(tenantId, stepRunId string, opts *UpdateStepRunOverridesDataOpts) ([]byte, error)

+ type UpdateInstallationOpts struct

+ type UpdatePullRequestOpts struct

+ BaseBranch *string

+ HeadBranch *string

+ State *string

+ Title *string

type UpdateStepRunOpts

+ RetryCount *int

+ type UpdateStepRunOverridesDataOpts struct

+ CallerFile *string

+ Data []byte

+ OverrideKey string

+ type UpsertWorkflowDeploymentConfigOpts struct

+ GitRepoBranch string

+ GitRepoName string

+ GitRepoOwner string

+ GithubAppInstallationId string

type WorkflowRepository

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

type WorkflowRunRepository

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

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

Feb 15, 2024

Changes in this version

type CreateWorkflowStepOpts

+ UserData *string

+ type StepRunUpdateInfo struct

+ JobRunFinalState bool

+ WorkflowRunFinalState bool

+ WorkflowRunId string

+ WorkflowRunStatus string

Feb 3, 2024

Changes in this version

type UpdateStepRunOpts

+ IsRerun bool

Feb 2, 2024

Changes in this version

type CreateWorkflowRunOpts

+ DisplayName *string

+ ManualTriggerInput *string

+ func GetCreateWorkflowRunOptsFromManual(workflowVersion *db.WorkflowVersionModel, input []byte) (*CreateWorkflowRunOpts, error)

Jan 29, 2024

Changes in this version

+ type CreateGroupKeyRunOpts struct

+ Input []byte

+ type CreateWorkflowConcurrencyOpts struct

+ Action string

+ LimitStrategy *string

+ MaxRuns *int32

type CreateWorkflowRunOpts

+ GetGroupKeyRun *CreateGroupKeyRunOpts

type CreateWorkflowVersionOpts

+ Concurrency *CreateWorkflowConcurrencyOpts

+ type GetGroupKeyRunRepository interface

+ GetGroupKeyRunById func(tenantId, getGroupKeyRunId string) (*db.GetGroupKeyRunModel, error)

+ ListGetGroupKeyRuns func(tenantId string, opts *ListGetGroupKeyRunsOpts) ([]db.GetGroupKeyRunModel, error)

+ UpdateGetGroupKeyRun func(tenantId, getGroupKeyRunId string, opts *UpdateGetGroupKeyRunOpts) (*db.GetGroupKeyRunModel, error)

+ type ListGetGroupKeyRunsOpts struct

+ Requeuable *bool

+ Status *db.StepRunStatus

type ListStepRunsOpts

+ WorkflowRunId *string

type ListWorkflowRunsOpts

+ GroupKey *string

+ OrderBy *string

+ OrderDirection *string

+ Status *db.WorkflowRunStatus

+ WorkflowVersionId *string

type Repository

+ GetGroupKeyRun func() GetGroupKeyRunRepository

type TickerRepository

+ AddGetGroupKeyRun func(tickerId, getGroupKeyRunId string) (*db.TickerModel, error)

+ 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 WorkerRepository

+ AddGetGroupKeyRun func(tenantId, workerId, getGroupKeyRunId string) error

Jan 27, 2024

Changes in this version

+ type APITokenRepository interface

+ CreateAPIToken func(opts *CreateAPITokenOpts) (*db.APITokenModel, error)

+ 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 CreateWorkflowVersionOpts

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

type Repository

+ APIToken func() APITokenRepository

Jan 22, 2024

Changes in this version

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

+ func BoolPtr(b bool) *bool

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

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

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

+ func StringPtr(s string) *string

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

+ type CreateDispatcherOpts struct

+ ID string

+ type CreateEventOpts struct

+ Data *db.JSON

+ Key string

+ ReplayedEvent *string

+ TenantId string

+ type CreateSessionOpts struct

+ Data *types.JSON

+ ExpiresAt time.Time

+ ID string

+ UserId *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

+ Name string

+ Services []string

+ type CreateWorkflowJobOpts struct

+ Description *string

+ Name string

+ Steps []CreateWorkflowStepOpts

+ Timeout *string

+ type CreateWorkflowJobRunOpts struct

+ InputData []byte

+ JobId string

+ RequeueAfter *time.Time

+ StepRuns []CreateWorkflowStepRunOpts

+ TriggeredBy string

+ type CreateWorkflowRunOpts struct

+ Cron *string

+ CronParentId *string

+ JobRuns []CreateWorkflowJobRunOpts

+ ScheduledWorkflowId *string

+ TriggeringEventId *string

+ WorkflowVersionId string

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

+ func GetCreateWorkflowRunOptsFromEvent(event *db.EventModel, workflowVersion *db.WorkflowVersionModel) (*CreateWorkflowRunOpts, error)

+ func GetCreateWorkflowRunOptsFromSchedule(scheduledTrigger *db.WorkflowTriggerScheduledRefModel, ...) (*CreateWorkflowRunOpts, error)

+ type CreateWorkflowSchedulesOpts struct

+ Input *db.JSON

+ ScheduledTriggers []time.Time

+ type CreateWorkflowStepOpts struct

+ Action string

+ Parents []string

+ ReadableId string

+ Timeout *string

+ type CreateWorkflowStepRunOpts struct

+ StepId string

+ type CreateWorkflowTagOpts struct

+ Color *string

+ Name string

+ type CreateWorkflowVersionOpts struct

+ CronTriggers []string

+ Description *string

+ EventTriggers []string

+ Jobs []CreateWorkflowJobOpts

+ Name string

+ ScheduledTriggers []time.Time

+ Tags []CreateWorkflowTagOpts

+ Version string

+ type DispatcherRepository interface

+ AddWorker func(dispatcherId, workerId string) (*db.DispatcherModel, error)

+ CreateNewDispatcher func(opts *CreateDispatcherOpts) (*db.DispatcherModel, error)

+ Delete func(dispatcherId string) error

+ GetDispatcherForWorker func(workerId string) (*db.DispatcherModel, error)

+ UpdateDispatcher func(dispatcherId string, opts *UpdateDispatcherOpts) (*db.DispatcherModel, error)

+ UpdateStaleDispatchers func(onStale func(dispatcherId string, getValidDispatcherId func() string) error) error

+ type EventRepository interface

+ CreateEvent func(ctx context.Context, opts *CreateEventOpts) (*db.EventModel, error)

+ 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 JobRunHasCycleError struct

+ JobName string

+ func (e *JobRunHasCycleError) Error() string

+ type JobRunRepository interface

+ GetJobRunById func(tenantId, jobRunId string) (*db.JobRunModel, error)

+ GetJobRunLookupData func(tenantId, jobRunId string) (*db.JobRunLookupDataModel, error)

+ ListAllJobRuns func(opts *ListAllJobRunsOpts) ([]db.JobRunModel, error)

+ UpdateJobRun func(tenantId, jobRunId string, opts *UpdateJobRunOpts) (*db.JobRunModel, error)

+ UpdateJobRunLookupData func(tenantId, jobRunId string, opts *UpdateJobRunLookupDataOpts) error

+ type ListAllJobRunsOpts struct

+ NoTickerId *bool

+ Status *db.JobRunStatus

+ TickerId *string

+ type ListAllStepRunsOpts struct

+ NoTickerId *bool

+ Status *db.StepRunStatus

+ TickerId *string

+ type ListEventOpts struct

+ Keys []string

+ Limit *int

+ Offset *int

+ OrderBy *string

+ OrderDirection *string

+ ReplayedEvent *string

+ Search *string

+ Workflows []string

+ type ListEventResult struct

+ Count int

+ Rows []*dbsqlc.ListEventsRow

+ type ListStepRunsOpts struct

+ JobRunId *string

+ Requeuable *bool

+ Status *db.StepRunStatus

+ type ListTenantInvitesOpts struct

+ Expired *bool

+ Status *string

+ type ListTickerOpts struct

+ Active *bool

+ LatestHeartbeatAt *time.Time

+ type ListWorkersOpts struct

+ Action *string

+ LastHeartbeatAfter *time.Time

+ type ListWorkflowRunsOpts struct

+ EventId *string

+ Limit *int

+ Offset *int

+ WorkflowId *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 OAuthOpts struct

+ AccessToken string

+ ExpiresAt *time.Time

+ Provider string

+ ProviderUserId string

+ RefreshToken *string

+ type Repository interface

+ Dispatcher func() DispatcherRepository

+ Event func() EventRepository

+ JobRun func() JobRunRepository

+ Step func() StepRepository

+ StepRun func() StepRunRepository

+ Tenant func() TenantRepository

+ TenantInvite func() TenantInviteRepository

+ Ticker func() TickerRepository

+ User func() UserRepository

+ UserSession func() UserSessionRepository

+ Worker func() WorkerRepository

+ Workflow func() WorkflowRepository

+ WorkflowRun func() WorkflowRunRepository

+ type StepRepository interface

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

+ type StepRunRepository interface

+ CancelPendingStepRuns func(tenantId, jobRunId, reason string) error

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

+ ListAllStepRuns func(opts *ListAllStepRunsOpts) ([]db.StepRunModel, error)

+ ListStartableStepRuns func(tenantId, jobRunId, parentStepRunId string) ([]*dbsqlc.StepRun, error)

+ ListStepRuns func(tenantId string, opts *ListStepRunsOpts) ([]db.StepRunModel, error)

+ QueueStepRun func(tenantId, stepRunId string, opts *UpdateStepRunOpts) (*db.StepRunModel, error)

+ UpdateStepRun func(tenantId, stepRunId string, opts *UpdateStepRunOpts) (*db.StepRunModel, 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 TenantRepository interface

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

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

+ DeleteTenantMember func(memberId string) (*db.TenantMemberModel, 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)

+ ListTenants func() ([]db.TenantModel, error)

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

+ type TickerRepository interface

+ AddCron func(tickerId string, cron *db.WorkflowTriggerCronRefModel) (*db.TickerModel, error)

+ AddJobRun func(tickerId string, jobRun *db.JobRunModel) (*db.TickerModel, error)

+ AddScheduledWorkflow func(tickerId string, schedule *db.WorkflowTriggerScheduledRefModel) (*db.TickerModel, error)

+ AddStepRun func(tickerId, stepRunId string) (*db.TickerModel, error)

+ CreateNewTicker func(opts *CreateTickerOpts) (*db.TickerModel, error)

+ Delete func(tickerId string) error

+ GetTickerById func(tickerId string) (*db.TickerModel, error)

+ ListTickers func(opts *ListTickerOpts) ([]db.TickerModel, error)

+ RemoveCron func(tickerId string, cron *db.WorkflowTriggerCronRefModel) (*db.TickerModel, error)

+ RemoveScheduledWorkflow func(tickerId string, schedule *db.WorkflowTriggerScheduledRefModel) (*db.TickerModel, error)

+ UpdateStaleTickers func(onStale func(tickerId string, getValidTickerId func() string) error) error

+ UpdateTicker func(tickerId string, opts *UpdateTickerOpts) (*db.TickerModel, error)

+ type UpdateDispatcherOpts struct

+ LastHeartbeatAt *time.Time

+ type UpdateJobRunLookupDataOpts struct

+ Data []byte

+ FieldPath []string

+ type UpdateJobRunOpts struct

+ Status *db.JobRunStatus

+ type UpdateSessionOpts struct

+ Data *types.JSON

+ UserId *string

+ type UpdateStepRunOpts struct

+ CancelledAt *time.Time

+ CancelledReason *string

+ Error *string

+ FailedAt *time.Time

+ FinishedAt *time.Time

+ Input []byte

+ Output []byte

+ RequeueAfter *time.Time

+ ScheduleTimeoutAt *time.Time

+ StartedAt *time.Time

+ Status *db.StepRunStatus

+ type UpdateTenantInviteOpts struct

+ Role *string

+ Status *string

+ type UpdateTenantMemberOpts struct

+ Role *string

+ type UpdateTickerOpts struct

+ LastHeartbeatAt *time.Time

+ type UpdateUserOpts struct

+ EmailVerified *bool

+ Name *string

+ OAuth *OAuthOpts

+ type UpdateWorkerOpts struct

+ Actions []string

+ DispatcherId *string

+ LastHeartbeatAt *time.Time

+ Status *db.WorkerStatus

+ 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 WorkerRepository interface

+ AddStepRun func(tenantId, workerId, stepRunId string) error

+ CreateNewWorker func(tenantId string, opts *CreateWorkerOpts) (*db.WorkerModel, error)

+ DeleteWorker func(tenantId, workerId string) error

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

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

+ ListWorkers func(tenantId string, opts *ListWorkersOpts) ([]WorkerWithStepCount, error)

+ UpdateWorker func(tenantId, workerId string, opts *UpdateWorkerOpts) (*db.WorkerModel, error)

+ type WorkerWithStepCount struct

+ StepRunCount int

+ Worker *db.WorkerModel

+ type WorkflowRepository interface

+ CreateNewWorkflow func(tenantId string, opts *CreateWorkflowVersionOpts) (*db.WorkflowVersionModel, error)

+ CreateSchedules func(tenantId, workflowVersionId string, opts *CreateWorkflowSchedulesOpts) ([]*db.WorkflowTriggerScheduledRefModel, error)

+ CreateWorkflowVersion func(tenantId string, opts *CreateWorkflowVersionOpts) (*db.WorkflowVersionModel, error)

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

+ GetScheduledById func(tenantId, scheduleTriggerId string) (*db.WorkflowTriggerScheduledRefModel, error)

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

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

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

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

+ ListWorkflowsForEvent func(ctx context.Context, tenantId, eventKey string) ([]db.WorkflowVersionModel, error)

+ type WorkflowRunRepository interface

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

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

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