dbsqlc

May 31, 2024

Changes in this version

type GetWorkerForEngineRow

+ DispatcherLastHeartbeatAt pgtype.Timestamp

May 21, 2024

Changes in this version

type GetWorkerForEngineRow

+ LastListenerEstablished pgtype.Timestamp

type Queries

+ func (q *Queries) UpdateWorkerActiveStatus(ctx context.Context, db DBTX, arg UpdateWorkerActiveStatusParams) (*Worker, error)

+ type UpdateWorkerActiveStatusParams struct

+ ID pgtype.UUID

+ Isactive bool

+ LastListenerEstablished pgtype.Timestamp

type Worker

+ LastListenerEstablished pgtype.Timestamp

May 21, 2024

Changes in this version

type GetWorkerForEngineRow

+ IsActive bool

type UpdateWorkerParams

+ IsActive pgtype.Bool

type Worker

+ IsActive bool

May 17, 2024

Changes in this version

+ type GetLaterStepRunsForReplayParams struct

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type ListNonFinalChildStepRunsParams struct

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

type Queries

+ func (q *Queries) GetLaterStepRunsForReplay(ctx context.Context, db DBTX, arg GetLaterStepRunsForReplayParams) ([]*StepRun, error)

+ func (q *Queries) ListNonFinalChildStepRuns(ctx context.Context, db DBTX, arg ListNonFinalChildStepRunsParams) ([]*StepRun, error)

+ func (q *Queries) ReplayStepRunResetJobRun(ctx context.Context, db DBTX, jobrunid pgtype.UUID) (*JobRun, error)

+ func (q *Queries) ReplayStepRunResetLaterStepRuns(ctx context.Context, db DBTX, arg ReplayStepRunResetLaterStepRunsParams) ([]*StepRun, error)

+ func (q *Queries) ReplayStepRunResetWorkflowRun(ctx context.Context, db DBTX, jobrunid pgtype.UUID) (*WorkflowRun, error)

+ type ReplayStepRunResetLaterStepRunsParams struct

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

type StepRunEventReason

+ const StepRunEventReasonRETRIEDBYUSER

May 16, 2024

Changes in this version

type Queries

+ func (q *Queries) RefreshTimeoutBy(ctx context.Context, db DBTX, arg RefreshTimeoutByParams) (*StepRun, error)

+ type RefreshTimeoutByParams struct

+ IncrementTimeoutBy pgtype.Text

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

type StepRunEventReason

+ const StepRunEventReasonTIMEOUTREFRESHED

May 14, 2024

Changes in this version

type Queries

+ func (q *Queries) ResolveWorkerSemaphoreSlots(ctx context.Context, db DBTX) (int64, error)

type StepRun

+ SemaphoreReleased bool

type StepRunEventReason

+ const StepRunEventReasonREASSIGNED

+ const StepRunEventReasonSLOTRELEASED

+ const StepRunEventReasonTIMEDOUT

type UpdateStepRunParams

+ SemaphoreReleased pgtype.Bool

May 9, 2024

Changes in this version

+ type CreateStepRunEventParams struct

+ Data []byte

+ Message string

+ Reason StepRunEventReason

+ Severity StepRunEventSeverity

+ Steprunid pgtype.UUID

+ type ListStepRunEventsParams struct

+ Limit interface{}

+ Offset interface{}

+ Steprunid pgtype.UUID

+ type NullStepRunEventReason struct

+ StepRunEventReason StepRunEventReason

+ Valid bool

+ func (ns *NullStepRunEventReason) Scan(value interface{}) error

+ func (ns NullStepRunEventReason) Value() (driver.Value, error)

+ type NullStepRunEventSeverity struct

+ StepRunEventSeverity StepRunEventSeverity

+ Valid bool

+ func (ns *NullStepRunEventSeverity) Scan(value interface{}) error

+ func (ns NullStepRunEventSeverity) Value() (driver.Value, error)

type Queries

+ func (q *Queries) CountStepRunEvents(ctx context.Context, db DBTX, steprunid pgtype.UUID) (int64, error)

+ func (q *Queries) CreateStepRunEvent(ctx context.Context, db DBTX, arg CreateStepRunEventParams) error

+ func (q *Queries) ListStepRunEvents(ctx context.Context, db DBTX, arg ListStepRunEventsParams) ([]*StepRunEvent, error)

+ type StepRunEvent struct

+ Count int32

+ Data []byte

+ ID int64

+ Message string

+ Reason StepRunEventReason

+ Severity StepRunEventSeverity

+ StepRunId pgtype.UUID

+ TimeFirstSeen pgtype.Timestamp

+ TimeLastSeen pgtype.Timestamp

+ type StepRunEventReason string

+ const StepRunEventReasonASSIGNED

+ const StepRunEventReasonCANCELLED

+ const StepRunEventReasonFAILED

+ const StepRunEventReasonFINISHED

+ const StepRunEventReasonREQUEUEDNOWORKER

+ const StepRunEventReasonREQUEUEDRATELIMIT

+ const StepRunEventReasonRETRYING

+ const StepRunEventReasonSCHEDULINGTIMEDOUT

+ const StepRunEventReasonSTARTED

+ func (e *StepRunEventReason) Scan(src interface{}) error

+ type StepRunEventSeverity string

+ const StepRunEventSeverityCRITICAL

+ const StepRunEventSeverityINFO

+ const StepRunEventSeverityWARNING

+ func (e *StepRunEventSeverity) Scan(src interface{}) error

May 8, 2024

Changes in this version

type CountWorkflowRunsParams

+ FinishedAfter pgtype.Timestamp

type ListWorkflowRunsParams

+ FinishedAfter pgtype.Timestamp

May 8, 2024

Changes in this version

type CountWorkflowRunsParams

+ AdditionalMetadata []byte

+ CreatedAfter pgtype.Timestamp

type CreateEventParams

+ Additionalmetadata []byte

type CreateJobParams

+ Kind NullJobKind

type CreateWorkflowRunParams

+ Additionalmetadata []byte

type Event

+ AdditionalMetadata []byte

+ type GetJobRunByWorkflowRunIdAndJobIdParams struct

+ Jobid pgtype.UUID

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ type GetJobRunByWorkflowRunIdAndJobIdRow struct

+ ID pgtype.UUID

+ JobId pgtype.UUID

+ Status JobRunStatus

type GetStepRunForEngineRow

+ JobKind JobKind

type Job

+ Kind JobKind

+ type JobKind string

+ const JobKindDEFAULT

+ const JobKindONFAILURE

+ func (e *JobKind) Scan(src interface{}) error

+ type LinkOnFailureJobParams struct

+ Jobid pgtype.UUID

+ Workflowversionid pgtype.UUID

type ListEventsParams

+ AdditionalMetadata []byte

+ type ListJobRunsForWorkflowRunRow struct

+ ID pgtype.UUID

+ JobId pgtype.UUID

type ListWorkersWithStepCountRow

+ Slots int32

type ListWorkflowRunsParams

+ AdditionalMetadata []byte

+ CreatedAfter pgtype.Timestamp

+ type NullJobKind struct

+ JobKind JobKind

+ Valid bool

+ func (ns *NullJobKind) Scan(value interface{}) error

+ func (ns NullJobKind) Value() (driver.Value, error)

+ type PollTenantAlertsRow struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ LastAlertedAt pgtype.Timestamp

+ MaxFrequency string

+ PrevLastAlertedAt pgtype.Timestamp

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

type Queries

+ func (q *Queries) GetEmailGroups(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]*TenantAlertEmailGroup, error)

+ func (q *Queries) GetJobRunByWorkflowRunIdAndJobId(ctx context.Context, db DBTX, arg GetJobRunByWorkflowRunIdAndJobIdParams) (*GetJobRunByWorkflowRunIdAndJobIdRow, error)

+ func (q *Queries) GetSlackWebhooks(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]*SlackAppWebhook, error)

+ func (q *Queries) GetTenantAlertingSettings(ctx context.Context, db DBTX, tenantid pgtype.UUID) (*TenantAlertingSettings, error)

+ func (q *Queries) LinkOnFailureJob(ctx context.Context, db DBTX, arg LinkOnFailureJobParams) (*WorkflowVersion, error)

+ func (q *Queries) PollTenantAlerts(ctx context.Context, db DBTX, tickerid pgtype.UUID) ([]*PollTenantAlertsRow, error)

+ func (q *Queries) UpdateTenantAlertingSettings(ctx context.Context, db DBTX, arg UpdateTenantAlertingSettingsParams) (*TenantAlertingSettings, error)

+ type SlackAppWebhook struct

+ ChannelId string

+ ChannelName string

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ TeamId string

+ TeamName string

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ WebhookURL []byte

+ type TenantAlertEmailGroup struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ Emails string

+ ID pgtype.UUID

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type TenantAlertingSettings struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ LastAlertedAt pgtype.Timestamp

+ MaxFrequency string

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type UpdateTenantAlertingSettingsParams struct

+ LastAlertedAt pgtype.Timestamp

+ TenantId pgtype.UUID

type WorkflowRun

+ AdditionalMetadata []byte

type WorkflowRunsMetricsCountParams

+ AdditionalMetadata []byte

type WorkflowVersion

+ OnFailureJobId pgtype.UUID

May 5, 2024

Changes in this version

type Tenant

+ AnalyticsOptOut bool

May 1, 2024

Changes in this version

type Queries

+ func (q *Queries) UnlinkStepRunFromWorker(ctx context.Context, db DBTX, arg UnlinkStepRunFromWorkerParams) (*StepRun, error)

+ type UnlinkStepRunFromWorkerParams struct

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

Apr 29, 2024

Changes in this version

type Queries

+ func (q *Queries) WorkflowRunsMetricsCount(ctx context.Context, db DBTX, arg WorkflowRunsMetricsCountParams) (*WorkflowRunsMetricsCountRow, error)

+ type WorkflowRunsMetricsCountParams struct

+ EventId pgtype.UUID

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

+ Tenantid pgtype.UUID

+ WorkflowId pgtype.UUID

+ type WorkflowRunsMetricsCountRow struct

+ FAILED int64

+ PENDING int64

+ QUEUED int64

+ RUNNING int64

+ SUCCEEDED int64

Apr 24, 2024

Changes in this version

type PollCronSchedulesRow

+ Enabled bool

type WorkflowTriggerCronRef

+ Enabled bool

Apr 19, 2024

Changes in this version

type AssignStepRunToWorkerRow

+ TsTotalSlots int32

+ type GetTotalSlotsParams struct

+ Actionid string

+ Tenantid pgtype.UUID

+ type GetTotalSlotsRow struct

+ ID pgtype.UUID

+ Slots int32

+ TsTotalSlots int32

type Queries

+ func (q *Queries) GetTotalSlots(ctx context.Context, db DBTX, arg GetTotalSlotsParams) ([]*GetTotalSlotsRow, error)

Apr 19, 2024

Changes in this version

type CountWorkflowRunsParams

+ Ids []pgtype.UUID

+ Statuses []string

type ListStepRunsParams

+ TenantId pgtype.UUID

+ WorkflowRunIds []pgtype.UUID

type ListWorkflowRunsParams

+ Ids []pgtype.UUID

+ Statuses []string

Apr 4, 2024

Changes in this version

+ type CountRoundRobinGroupKeysParams struct

+ Status NullWorkflowRunStatus

+ Tenantid pgtype.UUID

+ Workflowid pgtype.UUID

+ type CountWorkflowRunsRoundRobinParams struct

+ GroupKey pgtype.Text

+ Status NullWorkflowRunStatus

+ Tenantid pgtype.UUID

+ Workflowid pgtype.UUID

type ListEventsRow

+ Queuedruns int64

type PopWorkflowRunsRoundRobinParams

+ Tenantid pgtype.UUID

+ Workflowid pgtype.UUID

type Queries

+ func (q *Queries) CountRoundRobinGroupKeys(ctx context.Context, db DBTX, arg CountRoundRobinGroupKeysParams) (int64, error)

+ func (q *Queries) CountWorkflowRunsRoundRobin(ctx context.Context, db DBTX, arg CountWorkflowRunsRoundRobinParams) (int64, error)

Apr 2, 2024

Changes in this version

+ type CreateStepRateLimitParams struct

+ Ratelimitkey string

+ Stepid pgtype.UUID

+ Tenantid pgtype.UUID

+ Units int32

+ type CreateStreamEventParams struct

+ CreatedAt pgtype.Timestamp

+ Message []byte

+ Metadata []byte

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

type CreateWorkflowTriggerCronRefParams

+ Input []byte

+ type GetStreamEventParams struct

+ ID int64

+ Tenantid pgtype.UUID

type Queries

+ func (q *Queries) CleanupStreamEvents(ctx context.Context, db DBTX) error

+ func (q *Queries) CreateStepRateLimit(ctx context.Context, db DBTX, arg CreateStepRateLimitParams) (*StepRateLimit, error)

+ func (q *Queries) CreateStreamEvent(ctx context.Context, db DBTX, arg CreateStreamEventParams) (*StreamEvent, error)

+ func (q *Queries) GetStreamEvent(ctx context.Context, db DBTX, arg GetStreamEventParams) (*StreamEvent, error)

+ func (q *Queries) UpdateStepRateLimits(ctx context.Context, db DBTX, arg UpdateStepRateLimitsParams) ([]*RateLimit, error)

+ func (q *Queries) UpsertRateLimit(ctx context.Context, db DBTX, arg UpsertRateLimitParams) (*RateLimit, error)

+ type RateLimit struct

+ Key string

+ LastRefill pgtype.Timestamp

+ LimitValue int32

+ TenantId pgtype.UUID

+ Value int32

+ Window string

+ type StepRateLimit struct

+ RateLimitKey string

+ StepId pgtype.UUID

+ TenantId pgtype.UUID

+ Units int32

+ type StreamEvent struct

+ CreatedAt pgtype.Timestamp

+ ID int64

+ Message []byte

+ Metadata []byte

+ StepRunId pgtype.UUID

+ TenantId pgtype.UUID

+ type UpdateStepRateLimitsParams struct

+ Stepid pgtype.UUID

+ Tenantid pgtype.UUID

+ type UpsertRateLimitParams struct

+ Key string

+ Limit int32

+ Tenantid pgtype.UUID

+ Window pgtype.Text

Apr 1, 2024

Changes in this version

type AssignStepRunToWorkerParams

+ Actionid string

+ StepTimeout pgtype.Text

+ type CreateWorkerSemaphoreParams struct

+ MaxRuns pgtype.Int4

+ Workerid pgtype.UUID

type GetStepRunForEngineRow

+ StepTimeout pgtype.Text

type Queries

+ func (q *Queries) CreateWorkerSemaphore(ctx context.Context, db DBTX, arg CreateWorkerSemaphoreParams) (*WorkerSemaphore, error)

+ func (q *Queries) UpdateWorkerSemaphore(ctx context.Context, db DBTX, arg UpdateWorkerSemaphoreParams) (*UpdateWorkerSemaphoreRow, error)

+ type UpdateWorkerSemaphoreParams struct

+ Inc int32

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type UpdateWorkerSemaphoreRow struct

+ ID pgtype.UUID

+ MaxRuns pgtype.Int4

+ Slots int32

+ WorkerId pgtype.UUID

+ type WorkerSemaphore struct

+ Slots int32

+ WorkerId pgtype.UUID

Mar 29, 2024

Changes in this version

type CountWorkflowRunsParams

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

type CreateWorkflowRunParams

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

+ type GetChildWorkflowRunParams struct

+ ChildKey pgtype.Text

+ Childindex pgtype.Int4

+ Parentid pgtype.UUID

+ Parentsteprunid pgtype.UUID

+ type GetScheduledChildWorkflowRunParams struct

+ ChildKey pgtype.Text

+ Childindex pgtype.Int4

+ Parentid pgtype.UUID

+ Parentsteprunid pgtype.UUID

type ListWorkflowRunsParams

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

type PollScheduledWorkflowsRow

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ ParentStepRunId pgtype.UUID

+ ParentWorkflowRunId pgtype.UUID

type Queries

+ func (q *Queries) GetChildWorkflowRun(ctx context.Context, db DBTX, arg GetChildWorkflowRunParams) (*WorkflowRun, error)

+ func (q *Queries) GetScheduledChildWorkflowRun(ctx context.Context, db DBTX, arg GetScheduledChildWorkflowRunParams) (*WorkflowTriggerScheduledRef, error)

type WorkflowRun

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

type WorkflowTriggerScheduledRef

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ ParentStepRunId pgtype.UUID

+ ParentWorkflowRunId pgtype.UUID

Mar 21, 2024

Changes in this version

+ type CreateAPITokenParams struct

+ Expiresat pgtype.Timestamp

+ ID pgtype.UUID

+ Name pgtype.Text

+ TenantId pgtype.UUID

+ type CreateSchedulesParams struct

+ Input []byte

+ Triggertimes []pgtype.Timestamp

+ Workflowrunid pgtype.UUID

+ type CreateWorkerParams struct

+ Dispatcherid pgtype.UUID

+ MaxRuns pgtype.Int4

+ Name string

+ Tenantid pgtype.UUID

type GetStepRunForEngineParams

+ TenantId pgtype.UUID

+ type GetWorkflowByNameParams struct

+ Name string

+ Tenantid pgtype.UUID

+ type GetWorkflowRunParams struct

+ Ids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetWorkflowRunRow struct

+ ConcurrencyLimitStrategy NullConcurrencyLimitStrategy

+ ConcurrencyMaxRuns pgtype.Int4

+ GetGroupKeyRunId pgtype.UUID

+ WorkflowName pgtype.Text

+ WorkflowRun WorkflowRun

+ WorkflowRunTriggeredBy WorkflowRunTriggeredBy

+ WorkflowVersion WorkflowVersion

type GetWorkflowVersionForEngineRow

+ ConcurrencyLimitStrategy NullConcurrencyLimitStrategy

+ ConcurrencyMaxRuns pgtype.Int4

+ type LinkActionsToWorkerParams struct

+ Actionids []pgtype.UUID

+ Workerid pgtype.UUID

+ type LinkServicesToWorkerParams struct

+ Services []pgtype.UUID

+ Workerid pgtype.UUID

+ type ListEventsByIDsParams struct

+ Ids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type ListStepRunsParams struct

+ JobRunId pgtype.UUID

+ Status NullStepRunStatus

+ Tenantid pgtype.UUID

+ TickerId pgtype.UUID

+ WorkflowRunId pgtype.UUID

+ type ListTickersParams struct

+ IsActive bool

+ LastHeartbeatAfter pgtype.Timestamp

+ type PollCronSchedulesRow struct

+ Cron string

+ Input []byte

+ ParentId pgtype.UUID

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ WorkflowVersionId pgtype.UUID

+ type PollScheduledWorkflowsRow struct

+ ID pgtype.UUID

+ Input []byte

+ ParentId pgtype.UUID

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ TriggerAt pgtype.Timestamp

+ WorkflowVersionId pgtype.UUID

type Queries

+ func (q *Queries) CreateAPIToken(ctx context.Context, db DBTX, arg CreateAPITokenParams) (*APIToken, error)

+ func (q *Queries) CreateDispatcher(ctx context.Context, db DBTX, id pgtype.UUID) (*Dispatcher, error)

+ func (q *Queries) CreateSchedules(ctx context.Context, db DBTX, arg CreateSchedulesParams) ([]*WorkflowTriggerScheduledRef, error)

+ func (q *Queries) CreateTicker(ctx context.Context, db DBTX, id pgtype.UUID) (*Ticker, error)

+ func (q *Queries) CreateWorker(ctx context.Context, db DBTX, arg CreateWorkerParams) (*Worker, error)

+ func (q *Queries) DeleteDispatcher(ctx context.Context, db DBTX, id pgtype.UUID) (*Dispatcher, error)

+ func (q *Queries) DeleteTicker(ctx context.Context, db DBTX, id pgtype.UUID) (*Ticker, error)

+ func (q *Queries) DeleteWorker(ctx context.Context, db DBTX, id pgtype.UUID) (*Worker, error)

+ func (q *Queries) GetAPITokenById(ctx context.Context, db DBTX, id pgtype.UUID) (*APIToken, error)

+ func (q *Queries) GetTenantByID(ctx context.Context, db DBTX, id pgtype.UUID) (*Tenant, error)

+ func (q *Queries) GetWorkflowByName(ctx context.Context, db DBTX, arg GetWorkflowByNameParams) (*Workflow, error)

+ func (q *Queries) GetWorkflowLatestVersion(ctx context.Context, db DBTX, workflowid pgtype.UUID) (pgtype.UUID, error)

+ func (q *Queries) GetWorkflowRun(ctx context.Context, db DBTX, arg GetWorkflowRunParams) ([]*GetWorkflowRunRow, error)

+ func (q *Queries) LinkActionsToWorker(ctx context.Context, db DBTX, arg LinkActionsToWorkerParams) error

+ func (q *Queries) LinkServicesToWorker(ctx context.Context, db DBTX, arg LinkServicesToWorkerParams) error

+ func (q *Queries) ListEventsByIDs(ctx context.Context, db DBTX, arg ListEventsByIDsParams) ([]*Event, error)

+ func (q *Queries) ListJobRunsForWorkflowRun(ctx context.Context, db DBTX, workflowrunid pgtype.UUID) ([]pgtype.UUID, error)

+ func (q *Queries) ListStepRuns(ctx context.Context, db DBTX, arg ListStepRunsParams) ([]pgtype.UUID, error)

+ func (q *Queries) ListTenants(ctx context.Context, db DBTX) ([]*Tenant, error)

+ func (q *Queries) PollCronSchedules(ctx context.Context, db DBTX, tickerid pgtype.UUID) ([]*PollCronSchedulesRow, error)

+ func (q *Queries) PollGetGroupKeyRuns(ctx context.Context, db DBTX, tickerid pgtype.UUID) ([]*GetGroupKeyRun, error)

+ func (q *Queries) PollScheduledWorkflows(ctx context.Context, db DBTX, tickerid pgtype.UUID) ([]*PollScheduledWorkflowsRow, error)

+ func (q *Queries) PollStepRuns(ctx context.Context, db DBTX, tickerid pgtype.UUID) ([]*StepRun, error)

+ func (q *Queries) UpdateDispatcher(ctx context.Context, db DBTX, arg UpdateDispatcherParams) (*Dispatcher, error)

+ func (q *Queries) UpdateTicker(ctx context.Context, db DBTX, arg UpdateTickerParams) (*Ticker, error)

+ func (q *Queries) UpdateWorker(ctx context.Context, db DBTX, arg UpdateWorkerParams) (*Worker, error)

+ func (q *Queries) UpsertService(ctx context.Context, db DBTX, arg UpsertServiceParams) (*Service, error)

+ type UpdateDispatcherParams struct

+ ID pgtype.UUID

+ LastHeartbeatAt pgtype.Timestamp

+ type UpdateTickerParams struct

+ ID pgtype.UUID

+ LastHeartbeatAt pgtype.Timestamp

+ type UpdateWorkerParams struct

+ DispatcherId pgtype.UUID

+ ID pgtype.UUID

+ LastHeartbeatAt pgtype.Timestamp

+ MaxRuns pgtype.Int4

+ Status NullWorkerStatus

+ type UpsertServiceParams struct

+ Name string

+ Tenantid pgtype.UUID

Mar 12, 2024

Changes in this version

+ type AssignGetGroupKeyRunToTickerParams struct

+ Getgroupkeyrunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type AssignGetGroupKeyRunToTickerRow struct

+ ID pgtype.UUID

+ TickerId pgtype.UUID

+ type AssignGetGroupKeyRunToWorkerParams struct

+ Getgroupkeyrunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type AssignGetGroupKeyRunToWorkerRow struct

+ DispatcherId pgtype.UUID

+ ID pgtype.UUID

+ WorkerId pgtype.UUID

+ type AssignStepRunToTickerParams struct

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type AssignStepRunToTickerRow struct

+ ID pgtype.UUID

+ TickerId pgtype.UUID

+ type AssignStepRunToWorkerParams struct

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type AssignStepRunToWorkerRow struct

+ DispatcherId pgtype.UUID

+ ID pgtype.UUID

+ WorkerId pgtype.UUID

+ type CreateJobRunsParams struct

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ Workflowversionid pgtype.UUID

+ type CreateStepRunsParams struct

+ Jobrunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetEventForEngineRow struct

+ Data []byte

+ ID pgtype.UUID

+ Key string

+ TenantId pgtype.UUID

+ type GetGroupKeyRunForEngineParams struct

+ Ids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetGroupKeyRunForEngineRow struct

+ ActionId string

+ GetGroupKeyRun GetGroupKeyRun

+ WorkflowId pgtype.UUID

+ WorkflowRunId pgtype.UUID

+ WorkflowVersionId pgtype.UUID

+ type GetStepRunForEngineParams struct

+ Ids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetStepRunForEngineRow struct

+ ActionId string

+ JobId pgtype.UUID

+ JobName string

+ JobRunId pgtype.UUID

+ JobRunLookupData []byte

+ StepCustomUserData []byte

+ StepId pgtype.UUID

+ StepReadableId pgtype.Text

+ StepRetries int32

+ StepRun StepRun

+ StepScheduleTimeout string

+ WorkflowId pgtype.UUID

+ WorkflowName string

+ WorkflowRunId pgtype.UUID

+ WorkflowVersionId pgtype.UUID

+ type GetWorkerForEngineParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetWorkerForEngineRow struct

+ DispatcherId pgtype.UUID

+ ID pgtype.UUID

+ TenantId pgtype.UUID

+ type GetWorkflowVersionForEngineParams struct

+ Ids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetWorkflowVersionForEngineRow struct

+ HasWorkflowConcurrency bool

+ WorkflowName string

+ WorkflowVersion WorkflowVersion

type ListStartableStepRunsParams

+ ParentStepRunId pgtype.UUID

+ type ListWorkflowsForEventParams struct

+ Eventkey string

+ Tenantid pgtype.UUID

type Queries

+ func (q *Queries) AssignGetGroupKeyRunToTicker(ctx context.Context, db DBTX, arg AssignGetGroupKeyRunToTickerParams) (*AssignGetGroupKeyRunToTickerRow, error)

+ func (q *Queries) AssignGetGroupKeyRunToWorker(ctx context.Context, db DBTX, arg AssignGetGroupKeyRunToWorkerParams) (*AssignGetGroupKeyRunToWorkerRow, error)

+ func (q *Queries) AssignStepRunToTicker(ctx context.Context, db DBTX, arg AssignStepRunToTickerParams) (*AssignStepRunToTickerRow, error)

+ func (q *Queries) AssignStepRunToWorker(ctx context.Context, db DBTX, arg AssignStepRunToWorkerParams) (*AssignStepRunToWorkerRow, error)

+ func (q *Queries) CreateJobRuns(ctx context.Context, db DBTX, arg CreateJobRunsParams) ([]pgtype.UUID, error)

+ func (q *Queries) CreateStepRuns(ctx context.Context, db DBTX, arg CreateStepRunsParams) error

+ func (q *Queries) GetEventForEngine(ctx context.Context, db DBTX, id pgtype.UUID) (*GetEventForEngineRow, error)

+ func (q *Queries) GetGroupKeyRunForEngine(ctx context.Context, db DBTX, arg GetGroupKeyRunForEngineParams) ([]*GetGroupKeyRunForEngineRow, error)

+ func (q *Queries) GetStepRunForEngine(ctx context.Context, db DBTX, arg GetStepRunForEngineParams) ([]*GetStepRunForEngineRow, error)

+ func (q *Queries) GetWorkerForEngine(ctx context.Context, db DBTX, arg GetWorkerForEngineParams) (*GetWorkerForEngineRow, error)

+ func (q *Queries) GetWorkflowVersionForEngine(ctx context.Context, db DBTX, arg GetWorkflowVersionForEngineParams) ([]*GetWorkflowVersionForEngineRow, error)

+ func (q *Queries) ListGetGroupKeyRunsToReassign(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]*GetGroupKeyRun, error)

+ func (q *Queries) ListWorkflowsForEvent(ctx context.Context, db DBTX, arg ListWorkflowsForEventParams) ([]pgtype.UUID, error)

+ func (q *Queries) UpdateJobRunStatus(ctx context.Context, db DBTX, arg UpdateJobRunStatusParams) (*JobRun, error)

+ type UpdateJobRunStatusParams struct

+ ID pgtype.UUID

+ Status JobRunStatus

+ Tenantid pgtype.UUID

Mar 4, 2024

Changes in this version

type CountEventsParams

+ Statuses []string

type ListEventsParams

+ Statuses []string

+ type SNSIntegration struct

+ CreatedAt pgtype.Timestamp

+ ID pgtype.UUID

+ TenantId pgtype.UUID

+ TopicArn string

+ UpdatedAt pgtype.Timestamp

Mar 4, 2024

Changes in this version

type Queries

+ func (q *Queries) ListStepRunsToReassign(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]*StepRun, error)

Mar 1, 2024

Changes in this version

+ type CountLogLinesParams struct

+ Levels []LogLineLevel

+ Search pgtype.Text

+ StepRunId pgtype.UUID

+ Tenantid pgtype.UUID

+ type CreateLogLineParams struct

+ CreatedAt pgtype.Timestamp

+ Level NullLogLineLevel

+ Message string

+ Metadata []byte

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type ListLogLinesParams struct

+ Levels []LogLineLevel

+ Limit interface{}

+ Offset interface{}

+ OrderBy pgtype.Text

+ Search pgtype.Text

+ StepRunId pgtype.UUID

+ Tenantid pgtype.UUID

+ type LogLine struct

+ CreatedAt pgtype.Timestamp

+ ID int64

+ Level LogLineLevel

+ Message string

+ Metadata []byte

+ StepRunId pgtype.UUID

+ TenantId pgtype.UUID

+ type LogLineLevel string

+ const LogLineLevelDEBUG

+ const LogLineLevelERROR

+ const LogLineLevelINFO

+ const LogLineLevelWARN

+ func (e *LogLineLevel) Scan(src interface{}) error

+ type NullLogLineLevel struct

+ LogLineLevel LogLineLevel

+ Valid bool

+ func (ns *NullLogLineLevel) Scan(value interface{}) error

+ func (ns NullLogLineLevel) Value() (driver.Value, error)

type Queries

+ func (q *Queries) CountLogLines(ctx context.Context, db DBTX, arg CountLogLinesParams) (int64, error)

+ func (q *Queries) CreateLogLine(ctx context.Context, db DBTX, arg CreateLogLineParams) (*LogLine, error)

+ func (q *Queries) ListLogLines(ctx context.Context, db DBTX, arg ListLogLinesParams) ([]*LogLine, error)

Feb 28, 2024

Changes in this version

type CreateGetGroupKeyRunParams

+ Scheduletimeoutat pgtype.Timestamp

type CreateStepParams

+ ScheduleTimeout pgtype.Text

type CreateWorkflowVersionParams

+ ScheduleTimeout pgtype.Text

type GetGroupKeyRun

+ ScheduleTimeoutAt pgtype.Timestamp

type Queries

+ func (q *Queries) ListGetGroupKeyRunsToRequeue(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]*GetGroupKeyRun, error)

type Step

+ ScheduleTimeout string

type UpdateGetGroupKeyRunParams

+ ScheduleTimeoutAt pgtype.Timestamp

type WorkflowVersion

+ ScheduleTimeout string

Feb 27, 2024

Changes in this version

type Queries

+ func (q *Queries) Health(ctx context.Context, db DBTX) ([]pgtype.UUID, error)

+ func (q *Queries) ListStepRunsToRequeue(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]*StepRun, error)

Feb 26, 2024

Changes in this version

type ConcurrencyLimitStrategy

+ const ConcurrencyLimitStrategyGROUPROUNDROBIN

+ type ListWorkersWithStepCountParams struct

+ ActionId pgtype.Text

+ Assignable pgtype.Bool

+ LastHeartbeatAfter pgtype.Timestamp

+ Tenantid pgtype.UUID

+ type ListWorkersWithStepCountRow struct

+ RunningStepRuns int64

+ Worker Worker

+ type PopWorkflowRunsRoundRobinParams struct

+ ID pgtype.UUID

+ Maxruns int32

+ TenantId pgtype.UUID

type Queries

+ func (q *Queries) ListWorkersWithStepCount(ctx context.Context, db DBTX, arg ListWorkersWithStepCountParams) ([]*ListWorkersWithStepCountRow, error)

+ func (q *Queries) PopWorkflowRunsRoundRobin(ctx context.Context, db DBTX, arg PopWorkflowRunsRoundRobinParams) ([]*WorkflowRun, error)

+ func (q *Queries) UpdateManyWorkflowRun(ctx context.Context, db DBTX, arg UpdateManyWorkflowRunParams) ([]*WorkflowRun, error)

+ type UpdateManyWorkflowRunParams struct

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ Ids []pgtype.UUID

+ StartedAt pgtype.Timestamp

+ Status NullWorkflowRunStatus

+ Tenantid pgtype.UUID

type Worker

+ MaxRuns pgtype.Int4

Feb 19, 2024

Changes in this version

+ type ArchiveStepRunResultFromStepRunParams struct

+ ID pgtype.UUID

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

type CreateStepParams

+ Retries pgtype.Int4

+ type GithubAppInstallation struct

+ AccountAvatarURL pgtype.Text

+ AccountId int32

+ AccountName string

+ Config []byte

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ GithubAppOAuthId pgtype.UUID

+ ID pgtype.UUID

+ InstallationId int32

+ InstallationSettingsURL pgtype.Text

+ TenantId pgtype.UUID

+ TenantVcsProviderId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type GithubAppInstallationToGithubWebhook struct

+ A pgtype.UUID

+ B pgtype.UUID

+ type GithubAppOAuth struct

+ AccessToken []byte

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ExpiresAt pgtype.Timestamp

+ GithubUserID int32

+ ID pgtype.UUID

+ RefreshToken []byte

+ UpdatedAt pgtype.Timestamp

+ type GithubAppOAuthToUser struct

+ A pgtype.UUID

+ B pgtype.UUID

+ type GithubPullRequest struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ PullRequestBaseBranch string

+ PullRequestHeadBranch string

+ PullRequestID int32

+ PullRequestNumber int32

+ PullRequestState string

+ PullRequestTitle string

+ RepositoryName string

+ RepositoryOwner string

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type GithubPullRequestComment struct

+ CommentID int32

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ ModuleID string

+ PullRequestID pgtype.UUID

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type GithubPullRequestToWorkflowRun struct

+ A pgtype.UUID

+ B pgtype.UUID

+ type GithubWebhook struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ RepositoryName string

+ RepositoryOwner string

+ SigningSecret []byte

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type NullVcsProvider struct

+ Valid bool

+ VcsProvider VcsProvider

+ func (ns *NullVcsProvider) Scan(value interface{}) error

+ func (ns NullVcsProvider) Value() (driver.Value, error)

type Queries

+ func (q *Queries) ArchiveStepRunResultFromStepRun(ctx context.Context, db DBTX, arg ArchiveStepRunResultFromStepRunParams) (*StepRunResultArchive, error)

+ func (q *Queries) UpdateStepRunInputSchema(ctx context.Context, db DBTX, arg UpdateStepRunInputSchemaParams) ([]byte, error)

+ func (q *Queries) UpdateStepRunOverridesData(ctx context.Context, db DBTX, arg UpdateStepRunOverridesDataParams) ([]byte, error)

+ func (q *Queries) UpdateWorkflowRun(ctx context.Context, db DBTX, arg UpdateWorkflowRunParams) (*WorkflowRun, error)

type Step

+ Retries int32

type StepRun

+ CallerFiles []byte

+ GitRepoBranch pgtype.Text

+ InputSchema []byte

+ RetryCount int32

+ type StepRunResultArchive struct

+ CancelledAt pgtype.Timestamp

+ CancelledError pgtype.Text

+ CancelledReason pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Input []byte

+ Order int64

+ Output []byte

+ StartedAt pgtype.Timestamp

+ StepRunId pgtype.UUID

+ TimeoutAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ type TenantVcsProvider struct

+ Config []byte

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ VcsProvider VcsProvider

+ type UpdateStepRunInputSchemaParams struct

+ InputSchema []byte

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type UpdateStepRunOverridesDataParams struct

+ Callerfile string

+ Fieldpath []string

+ Jsondata []byte

+ Overrideskey []string

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

type UpdateStepRunParams

+ RetryCount pgtype.Int4

+ type UpdateWorkflowRunParams struct

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ StartedAt pgtype.Timestamp

+ Status NullWorkflowRunStatus

+ Tenantid pgtype.UUID

+ type VcsProvider string

+ const VcsProviderGITHUB

+ func (e *VcsProvider) Scan(src interface{}) error

+ type WorkflowDeploymentConfig struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ GitRepoBranch string

+ GitRepoName string

+ GitRepoOwner string

+ GithubAppInstallationId pgtype.UUID

+ ID pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ WorkflowId pgtype.UUID

type WorkflowRun

+ GitRepoBranch pgtype.Text

Feb 15, 2024

Changes in this version

type CreateStepParams

+ CustomUserData []byte

type Step

+ CustomUserData []byte

Feb 3, 2024

Changes in this version

type UpdateStepRunParams

+ Rerun pgtype.Bool

Feb 2, 2024

Changes in this version

type CreateWorkflowRunParams

+ DisplayName pgtype.Text

type WorkflowRun

+ DisplayName pgtype.Text

type WorkflowRunTriggeredBy

+ Input []byte

Jan 29, 2024

Changes in this version

+ type ConcurrencyLimitStrategy string

+ const ConcurrencyLimitStrategyCANCELINPROGRESS

+ const ConcurrencyLimitStrategyDROPNEWEST

+ const ConcurrencyLimitStrategyQUEUENEWEST

+ func (e *ConcurrencyLimitStrategy) Scan(src interface{}) error

type CountWorkflowRunsParams

+ GroupKey pgtype.Text

+ Status NullWorkflowRunStatus

+ WorkflowVersionId pgtype.UUID

+ type CreateGetGroupKeyRunParams struct

+ ID pgtype.UUID

+ Input []byte

+ Requeueafter pgtype.Timestamp

+ Tenantid pgtype.UUID

+ Workflowrunid string

+ type CreateWorkflowConcurrencyParams struct

+ CreatedAt pgtype.Timestamp

+ Getconcurrencygroupid pgtype.UUID

+ ID pgtype.UUID

+ LimitStrategy NullConcurrencyLimitStrategy

+ MaxRuns pgtype.Int4

+ UpdatedAt pgtype.Timestamp

+ Workflowversionid pgtype.UUID

+ type GetGroupKeyRun struct

+ CancelledAt pgtype.Timestamp

+ CancelledError pgtype.Text

+ CancelledReason pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Input []byte

+ Output pgtype.Text

+ RequeueAfter pgtype.Timestamp

+ StartedAt pgtype.Timestamp

+ Status StepRunStatus

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ TimeoutAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ WorkerId pgtype.UUID

+ WorkflowRunId string

type ListWorkflowRunsParams

+ GroupKey pgtype.Text

+ Status NullWorkflowRunStatus

+ WorkflowVersionId pgtype.UUID

+ type NullConcurrencyLimitStrategy struct

+ ConcurrencyLimitStrategy ConcurrencyLimitStrategy

+ Valid bool

+ func (ns *NullConcurrencyLimitStrategy) Scan(value interface{}) error

+ func (ns NullConcurrencyLimitStrategy) Value() (driver.Value, error)

type Queries

+ func (q *Queries) CreateGetGroupKeyRun(ctx context.Context, db DBTX, arg CreateGetGroupKeyRunParams) (*GetGroupKeyRun, error)

+ func (q *Queries) CreateWorkflowConcurrency(ctx context.Context, db DBTX, arg CreateWorkflowConcurrencyParams) (*WorkflowConcurrency, error)

+ func (q *Queries) UpdateGetGroupKeyRun(ctx context.Context, db DBTX, arg UpdateGetGroupKeyRunParams) (*GetGroupKeyRun, error)

+ func (q *Queries) UpdateWorkflowRunGroupKey(ctx context.Context, db DBTX, arg UpdateWorkflowRunGroupKeyParams) (*WorkflowRun, error)

+ type UpdateGetGroupKeyRunParams struct

+ CancelledAt pgtype.Timestamp

+ CancelledReason pgtype.Text

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Input []byte

+ Output pgtype.Text

+ RequeueAfter pgtype.Timestamp

+ StartedAt pgtype.Timestamp

+ Status NullStepRunStatus

+ Tenantid pgtype.UUID

+ type UpdateWorkflowRunGroupKeyParams struct

+ Groupkeyrunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type WorkflowConcurrency struct

+ CreatedAt pgtype.Timestamp

+ GetConcurrencyGroupId pgtype.UUID

+ ID pgtype.UUID

+ LimitStrategy ConcurrencyLimitStrategy

+ MaxRuns int32

+ UpdatedAt pgtype.Timestamp

+ WorkflowVersionId pgtype.UUID

type WorkflowRun

+ ConcurrencyGroupId pgtype.Text

type WorkflowRunStatus

+ const WorkflowRunStatusQUEUED

type WorkflowTriggerCronRef

+ Input []byte

Jan 27, 2024

Changes in this version

+ type APIToken struct

+ CreatedAt pgtype.Timestamp

+ ExpiresAt pgtype.Timestamp

+ ID pgtype.UUID

+ Name pgtype.Text

+ Revoked bool

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

type Action

+ ActionId string

type CreateWorkflowVersionParams

+ Checksum string

type WorkflowVersion

+ Checksum string

Jan 22, 2024

Changes in this version

+ type Action struct

+ Description pgtype.Text

+ ID string

+ TenantId pgtype.UUID

+ type ActionToWorker struct

+ A string

+ B pgtype.UUID

+ type AddStepParentsParams struct

+ ID pgtype.UUID

+ Jobid pgtype.UUID

+ Parents []string

+ type AddWorkflowTagParams struct

+ ID pgtype.UUID

+ Tags pgtype.UUID

+ type CountEventsParams struct

+ Keys []string

+ Search pgtype.Text

+ TenantId pgtype.UUID

+ Workflows []string

+ type CountWorkflowRunsParams struct

+ EventId pgtype.UUID

+ TenantId pgtype.UUID

+ WorkflowId pgtype.UUID

+ type CountWorkflowsParams struct

+ EventKey pgtype.Text

+ TenantId pgtype.UUID

+ type CreateEventParams struct

+ CreatedAt pgtype.Timestamp

+ Data []byte

+ Deletedat pgtype.Timestamp

+ ID pgtype.UUID

+ Key string

+ ReplayedFromId pgtype.UUID

+ Tenantid pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type CreateJobParams struct

+ CreatedAt pgtype.Timestamp

+ Deletedat pgtype.Timestamp

+ Description string

+ ID pgtype.UUID

+ Name string

+ Tenantid pgtype.UUID

+ Timeout string

+ UpdatedAt pgtype.Timestamp

+ Workflowversionid pgtype.UUID

+ type CreateJobRunLookupDataParams struct

+ ID pgtype.UUID

+ Input []byte

+ Jobrunid pgtype.UUID

+ Tenantid pgtype.UUID

+ Triggeredby string

+ type CreateJobRunParams struct

+ ID pgtype.UUID

+ Jobid pgtype.UUID

+ Tenantid pgtype.UUID

+ Workflowrunid string

+ type CreateStepParams struct

+ Actionid string

+ CreatedAt pgtype.Timestamp

+ Deletedat pgtype.Timestamp

+ ID pgtype.UUID

+ Jobid pgtype.UUID

+ Readableid string

+ Tenantid pgtype.UUID

+ Timeout string

+ UpdatedAt pgtype.Timestamp

+ type CreateStepRunParams struct

+ ID pgtype.UUID

+ Jobrunid pgtype.UUID

+ Requeueafter pgtype.Timestamp

+ Scheduletimeoutat pgtype.Timestamp

+ Stepid pgtype.UUID

+ Tenantid pgtype.UUID

+ type CreateWorkflowParams struct

+ CreatedAt pgtype.Timestamp

+ Deletedat pgtype.Timestamp

+ Description string

+ ID pgtype.UUID

+ Name string

+ Tenantid pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type CreateWorkflowRunParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ Workflowversionid pgtype.UUID

+ type CreateWorkflowRunTriggeredByParams struct

+ Cron pgtype.Text

+ CronParentId pgtype.UUID

+ EventId pgtype.UUID

+ ScheduledId pgtype.UUID

+ Tenantid pgtype.UUID

+ Workflowrunid string

+ type CreateWorkflowTriggerCronRefParams struct

+ Crontrigger string

+ Workflowtriggersid pgtype.UUID

+ type CreateWorkflowTriggerEventRefParams struct

+ Eventtrigger string

+ Workflowtriggersid pgtype.UUID

+ type CreateWorkflowTriggerScheduledRefParams struct

+ Scheduledtrigger pgtype.Timestamp

+ Workflowversionid pgtype.UUID

+ type CreateWorkflowTriggersParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ Workflowversionid pgtype.UUID

+ type CreateWorkflowVersionParams struct

+ CreatedAt pgtype.Timestamp

+ Deletedat pgtype.Timestamp

+ ID pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ Version string

+ Workflowid pgtype.UUID

+ type DBTX interface

+ Exec func(context.Context, string, ...interface{}) (pgconn.CommandTag, error)

+ Query func(context.Context, string, ...interface{}) (pgx.Rows, error)

+ QueryRow func(context.Context, string, ...interface{}) pgx.Row

+ type Dispatcher struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ IsActive bool

+ LastHeartbeatAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ type Event struct

+ CreatedAt pgtype.Timestamp

+ Data []byte

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Key string

+ ReplayedFromId pgtype.UUID

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type GetEventsForRangeRow struct

+ EventCount int64

+ EventHour pgtype.Interval

+ type GetStepRunParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ type InviteLinkStatus string

+ const InviteLinkStatusACCEPTED

+ const InviteLinkStatusPENDING

+ const InviteLinkStatusREJECTED

+ func (e *InviteLinkStatus) Scan(src interface{}) error

+ type Job struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ Description pgtype.Text

+ ID pgtype.UUID

+ Name string

+ TenantId pgtype.UUID

+ Timeout pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ WorkflowVersionId pgtype.UUID

+ type JobRun struct

+ CancelledAt pgtype.Timestamp

+ CancelledError pgtype.Text

+ CancelledReason pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ JobId pgtype.UUID

+ Result []byte

+ StartedAt pgtype.Timestamp

+ Status JobRunStatus

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ TimeoutAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ WorkflowRunId string

+ type JobRunLookupData struct

+ CreatedAt pgtype.Timestamp

+ Data []byte

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ JobRunId pgtype.UUID

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type JobRunStatus string

+ const JobRunStatusCANCELLED

+ const JobRunStatusFAILED

+ const JobRunStatusPENDING

+ const JobRunStatusRUNNING

+ const JobRunStatusSUCCEEDED

+ func (e *JobRunStatus) Scan(src interface{}) error

+ type ListActiveDispatchersRow struct

+ Dispatcher Dispatcher

+ type ListActiveTickersRow struct

+ Ticker Ticker

+ type ListDispatchersRow struct

+ Dispatcher Dispatcher

+ type ListEventsParams struct

+ Keys []string

+ Limit interface{}

+ Offset interface{}

+ Orderby interface{}

+ Search pgtype.Text

+ TenantId pgtype.UUID

+ Workflows []string

+ type ListEventsRow struct

+ Event Event

+ Failedruns int64

+ Pendingruns int64

+ Runningruns int64

+ Succeededruns int64

+ type ListNewlyStaleTickersRow struct

+ Ticker Ticker

+ type ListStaleDispatchersRow struct

+ Dispatcher Dispatcher

+ type ListStartableStepRunsParams struct

+ Jobrunid pgtype.UUID

+ Parentsteprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type ListTickersRow struct

+ Ticker Ticker

+ type ListWorkflowRunsParams struct

+ EventId pgtype.UUID

+ Limit interface{}

+ Offset interface{}

+ Orderby interface{}

+ TenantId pgtype.UUID

+ WorkflowId pgtype.UUID

+ type ListWorkflowRunsRow struct

+ CreatedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Key pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ Workflow Workflow

+ WorkflowRun WorkflowRun

+ WorkflowRunTriggeredBy WorkflowRunTriggeredBy

+ WorkflowVersion WorkflowVersion

+ type ListWorkflowsLatestRunsParams struct

+ EventKey pgtype.Text

+ TenantId pgtype.UUID

+ type ListWorkflowsLatestRunsRow struct

+ WorkflowId pgtype.UUID

+ WorkflowRun WorkflowRun

+ type ListWorkflowsParams struct

+ EventKey pgtype.Text

+ Limit interface{}

+ Offset interface{}

+ Orderby interface{}

+ TenantId pgtype.UUID

+ type ListWorkflowsRow struct

+ Workflow Workflow

+ type NullInviteLinkStatus struct

+ InviteLinkStatus InviteLinkStatus

+ Valid bool

+ func (ns *NullInviteLinkStatus) Scan(value interface{}) error

+ func (ns NullInviteLinkStatus) Value() (driver.Value, error)

+ type NullJobRunStatus struct

+ JobRunStatus JobRunStatus

+ Valid bool

+ func (ns *NullJobRunStatus) Scan(value interface{}) error

+ func (ns NullJobRunStatus) Value() (driver.Value, error)

+ type NullStepRunStatus struct

+ StepRunStatus StepRunStatus

+ Valid bool

+ func (ns *NullStepRunStatus) Scan(value interface{}) error

+ func (ns NullStepRunStatus) Value() (driver.Value, error)

+ type NullTenantMemberRole struct

+ TenantMemberRole TenantMemberRole

+ Valid bool

+ func (ns *NullTenantMemberRole) Scan(value interface{}) error

+ func (ns NullTenantMemberRole) Value() (driver.Value, error)

+ type NullWorkerStatus struct

+ Valid bool

+ WorkerStatus WorkerStatus

+ func (ns *NullWorkerStatus) Scan(value interface{}) error

+ func (ns NullWorkerStatus) Value() (driver.Value, error)

+ type NullWorkflowRunStatus struct

+ Valid bool

+ WorkflowRunStatus WorkflowRunStatus

+ func (ns *NullWorkflowRunStatus) Scan(value interface{}) error

+ func (ns NullWorkflowRunStatus) Value() (driver.Value, error)

+ type Queries struct

+ func New() *Queries

+ func (q *Queries) AddStepParents(ctx context.Context, db DBTX, arg AddStepParentsParams) error

+ func (q *Queries) AddWorkflowTag(ctx context.Context, db DBTX, arg AddWorkflowTagParams) error

+ func (q *Queries) CountEvents(ctx context.Context, db DBTX, arg CountEventsParams) (int64, error)

+ func (q *Queries) CountWorkflowRuns(ctx context.Context, db DBTX, arg CountWorkflowRunsParams) (int64, error)

+ func (q *Queries) CountWorkflows(ctx context.Context, db DBTX, arg CountWorkflowsParams) (int64, error)

+ func (q *Queries) CreateEvent(ctx context.Context, db DBTX, arg CreateEventParams) (*Event, error)

+ func (q *Queries) CreateJob(ctx context.Context, db DBTX, arg CreateJobParams) (*Job, error)

+ func (q *Queries) CreateJobRun(ctx context.Context, db DBTX, arg CreateJobRunParams) (*JobRun, error)

+ func (q *Queries) CreateJobRunLookupData(ctx context.Context, db DBTX, arg CreateJobRunLookupDataParams) (*JobRunLookupData, error)

+ func (q *Queries) CreateStep(ctx context.Context, db DBTX, arg CreateStepParams) (*Step, error)

+ func (q *Queries) CreateStepRun(ctx context.Context, db DBTX, arg CreateStepRunParams) (*StepRun, error)

+ func (q *Queries) CreateWorkflow(ctx context.Context, db DBTX, arg CreateWorkflowParams) (*Workflow, error)

+ func (q *Queries) CreateWorkflowRun(ctx context.Context, db DBTX, arg CreateWorkflowRunParams) (*WorkflowRun, error)

+ func (q *Queries) CreateWorkflowRunTriggeredBy(ctx context.Context, db DBTX, arg CreateWorkflowRunTriggeredByParams) (*WorkflowRunTriggeredBy, error)

+ func (q *Queries) CreateWorkflowTriggerCronRef(ctx context.Context, db DBTX, arg CreateWorkflowTriggerCronRefParams) (*WorkflowTriggerCronRef, error)

+ func (q *Queries) CreateWorkflowTriggerEventRef(ctx context.Context, db DBTX, arg CreateWorkflowTriggerEventRefParams) (*WorkflowTriggerEventRef, error)

+ func (q *Queries) CreateWorkflowTriggerScheduledRef(ctx context.Context, db DBTX, arg CreateWorkflowTriggerScheduledRefParams) (*WorkflowTriggerScheduledRef, error)

+ func (q *Queries) CreateWorkflowTriggers(ctx context.Context, db DBTX, arg CreateWorkflowTriggersParams) (*WorkflowTriggers, error)

+ func (q *Queries) CreateWorkflowVersion(ctx context.Context, db DBTX, arg CreateWorkflowVersionParams) (*WorkflowVersion, error)

+ func (q *Queries) GetEventsForRange(ctx context.Context, db DBTX) ([]*GetEventsForRangeRow, error)

+ func (q *Queries) GetStepRun(ctx context.Context, db DBTX, arg GetStepRunParams) (*StepRun, error)

+ func (q *Queries) LinkStepRunParents(ctx context.Context, db DBTX, jobrunid pgtype.UUID) error

+ func (q *Queries) ListActiveDispatchers(ctx context.Context, db DBTX) ([]*ListActiveDispatchersRow, error)

+ func (q *Queries) ListActiveTickers(ctx context.Context, db DBTX) ([]*ListActiveTickersRow, error)

+ func (q *Queries) ListDispatchers(ctx context.Context, db DBTX) ([]*ListDispatchersRow, error)

+ func (q *Queries) ListEvents(ctx context.Context, db DBTX, arg ListEventsParams) ([]*ListEventsRow, error)

+ func (q *Queries) ListNewlyStaleTickers(ctx context.Context, db DBTX) ([]*ListNewlyStaleTickersRow, error)

+ func (q *Queries) ListStaleDispatchers(ctx context.Context, db DBTX) ([]*ListStaleDispatchersRow, error)

+ func (q *Queries) ListStartableStepRuns(ctx context.Context, db DBTX, arg ListStartableStepRunsParams) ([]*StepRun, error)

+ func (q *Queries) ListTickers(ctx context.Context, db DBTX) ([]*ListTickersRow, error)

+ func (q *Queries) ListWorkflowRuns(ctx context.Context, db DBTX, arg ListWorkflowRunsParams) ([]*ListWorkflowRunsRow, error)

+ func (q *Queries) ListWorkflows(ctx context.Context, db DBTX, arg ListWorkflowsParams) ([]*ListWorkflowsRow, error)

+ func (q *Queries) ListWorkflowsLatestRuns(ctx context.Context, db DBTX, arg ListWorkflowsLatestRunsParams) ([]*ListWorkflowsLatestRunsRow, error)

+ func (q *Queries) ResolveJobRunStatus(ctx context.Context, db DBTX, arg ResolveJobRunStatusParams) (*JobRun, error)

+ func (q *Queries) ResolveLaterStepRuns(ctx context.Context, db DBTX, arg ResolveLaterStepRunsParams) ([]*StepRun, error)

+ func (q *Queries) ResolveWorkflowRunStatus(ctx context.Context, db DBTX, arg ResolveWorkflowRunStatusParams) (*WorkflowRun, error)

+ func (q *Queries) SetDispatchersInactive(ctx context.Context, db DBTX, ids []pgtype.UUID) ([]*SetDispatchersInactiveRow, error)

+ func (q *Queries) SetTickersInactive(ctx context.Context, db DBTX, ids []pgtype.UUID) ([]*SetTickersInactiveRow, error)

+ func (q *Queries) UpdateJobRun(ctx context.Context, db DBTX, arg UpdateJobRunParams) (*JobRun, error)

+ func (q *Queries) UpdateJobRunLookupDataWithStepRun(ctx context.Context, db DBTX, arg UpdateJobRunLookupDataWithStepRunParams) error

+ func (q *Queries) UpdateStepRun(ctx context.Context, db DBTX, arg UpdateStepRunParams) (*StepRun, error)

+ func (q *Queries) UpsertAction(ctx context.Context, db DBTX, arg UpsertActionParams) error

+ func (q *Queries) UpsertJobRunLookupData(ctx context.Context, db DBTX, arg UpsertJobRunLookupDataParams) error

+ func (q *Queries) UpsertWorkflowTag(ctx context.Context, db DBTX, arg UpsertWorkflowTagParams) error

+ type ResolveJobRunStatusParams struct

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type ResolveLaterStepRunsParams struct

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type ResolveWorkflowRunStatusParams struct

+ Jobrunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type Service struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ Description pgtype.Text

+ ID pgtype.UUID

+ Name string

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type ServiceToWorker struct

+ A pgtype.UUID

+ B pgtype.UUID

+ type SetDispatchersInactiveRow struct

+ Dispatcher Dispatcher

+ type SetTickersInactiveRow struct

+ Ticker Ticker

+ type Step struct

+ ActionId string

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ JobId pgtype.UUID

+ ReadableId pgtype.Text

+ TenantId pgtype.UUID

+ Timeout pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ type StepOrder struct

+ A pgtype.UUID

+ B pgtype.UUID

+ type StepRun struct

+ CancelledAt pgtype.Timestamp

+ CancelledError pgtype.Text

+ CancelledReason pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Input []byte

+ JobRunId pgtype.UUID

+ Order int16

+ Output []byte

+ RequeueAfter pgtype.Timestamp

+ ScheduleTimeoutAt pgtype.Timestamp

+ StartedAt pgtype.Timestamp

+ Status StepRunStatus

+ StepId pgtype.UUID

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ TimeoutAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ WorkerId pgtype.UUID

+ type StepRunOrder struct

+ A pgtype.UUID

+ B pgtype.UUID

+ type StepRunStatus string

+ const StepRunStatusASSIGNED

+ const StepRunStatusCANCELLED

+ const StepRunStatusFAILED

+ const StepRunStatusPENDING

+ const StepRunStatusPENDINGASSIGNMENT

+ const StepRunStatusRUNNING

+ const StepRunStatusSUCCEEDED

+ func (e *StepRunStatus) Scan(src interface{}) error

+ type Tenant struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Name string

+ Slug string

+ UpdatedAt pgtype.Timestamp

+ type TenantInviteLink struct

+ CreatedAt pgtype.Timestamp

+ Expires pgtype.Timestamp

+ ID pgtype.UUID

+ InviteeEmail string

+ InviterEmail string

+ Role TenantMemberRole

+ Status InviteLinkStatus

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type TenantMember struct

+ CreatedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Role TenantMemberRole

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ UserId pgtype.UUID

+ type TenantMemberRole string

+ const TenantMemberRoleADMIN

+ const TenantMemberRoleMEMBER

+ const TenantMemberRoleOWNER

+ func (e *TenantMemberRole) Scan(src interface{}) error

+ type Ticker struct

+ CreatedAt pgtype.Timestamp

+ ID pgtype.UUID

+ IsActive bool

+ LastHeartbeatAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ type UpdateJobRunLookupDataWithStepRunParams struct

+ Jsondata []byte

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type UpdateJobRunParams struct

+ ID pgtype.UUID

+ Status NullJobRunStatus

+ Tenantid pgtype.UUID

+ type UpdateStepRunParams struct

+ CancelledAt pgtype.Timestamp

+ CancelledReason pgtype.Text

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Input []byte

+ Output []byte

+ RequeueAfter pgtype.Timestamp

+ ScheduleTimeoutAt pgtype.Timestamp

+ StartedAt pgtype.Timestamp

+ Status NullStepRunStatus

+ Tenantid pgtype.UUID

+ type UpsertActionParams struct

+ Action string

+ Tenantid pgtype.UUID

+ type UpsertJobRunLookupDataParams struct

+ Fieldpath []string

+ Jobrunid pgtype.UUID

+ Jsondata []byte

+ Tenantid pgtype.UUID

+ type UpsertWorkflowTagParams struct

+ ID pgtype.UUID

+ TagColor pgtype.Text

+ Tagname string

+ Tenantid pgtype.UUID

+ type User struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ Email string

+ EmailVerified bool

+ ID pgtype.UUID

+ Name pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ type UserOAuth struct

+ AccessToken string

+ CreatedAt pgtype.Timestamp

+ ExpiresAt pgtype.Timestamp

+ ID pgtype.UUID

+ Provider string

+ ProviderUserId string

+ RefreshToken pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ UserId pgtype.UUID

+ type UserPassword struct

+ Hash string

+ UserId pgtype.UUID

+ type UserSession struct

+ CreatedAt pgtype.Timestamp

+ Data []byte

+ ExpiresAt pgtype.Timestamp

+ ID pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ UserId pgtype.UUID

+ type Worker struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ DispatcherId pgtype.UUID

+ ID pgtype.UUID

+ LastHeartbeatAt pgtype.Timestamp

+ Name string

+ Status WorkerStatus

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type WorkerStatus string

+ const WorkerStatusACTIVE

+ const WorkerStatusINACTIVE

+ func (e *WorkerStatus) Scan(src interface{}) error

+ type Workflow struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ Description pgtype.Text

+ ID pgtype.UUID

+ Name string

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type WorkflowRun struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ ID string

+ StartedAt pgtype.Timestamp

+ Status WorkflowRunStatus

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ WorkflowVersionId pgtype.UUID

+ type WorkflowRunStatus string

+ const WorkflowRunStatusFAILED

+ const WorkflowRunStatusPENDING

+ const WorkflowRunStatusRUNNING

+ const WorkflowRunStatusSUCCEEDED

+ func (e *WorkflowRunStatus) Scan(src interface{}) error

+ type WorkflowRunTriggeredBy struct

+ CreatedAt pgtype.Timestamp

+ CronParentId pgtype.UUID

+ CronSchedule pgtype.Text

+ DeletedAt pgtype.Timestamp

+ EventId pgtype.UUID

+ ID pgtype.UUID

+ ParentId string

+ ScheduledId pgtype.UUID

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type WorkflowTag struct

+ Color string

+ CreatedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Name string

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type WorkflowToWorkflowTag struct

+ A pgtype.UUID

+ B pgtype.UUID

+ type WorkflowTriggerCronRef struct

+ Cron string

+ ParentId pgtype.UUID

+ TickerId pgtype.UUID

+ type WorkflowTriggerEventRef struct

+ EventKey string

+ ParentId pgtype.UUID

+ type WorkflowTriggerScheduledRef struct

+ ID pgtype.UUID

+ Input []byte

+ ParentId pgtype.UUID

+ TickerId pgtype.UUID

+ TriggerAt pgtype.Timestamp

+ type WorkflowTriggers struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ WorkflowVersionId pgtype.UUID

+ type WorkflowVersion struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Order int16

+ UpdatedAt pgtype.Timestamp

+ Version string

+ WorkflowId pgtype.UUID