dbsqlc

Nov 21, 2024

Changes in this version

+ type CleanupRetryQueueItemsParams struct

+ Maxretryafter pgtype.Timestamp

+ Minretryafter pgtype.Timestamp

+ Tenantid pgtype.UUID

+ type CountCronWorkflowsParams struct

+ AdditionalMetadata []byte

+ Crontriggerid pgtype.UUID

+ Tenantid pgtype.UUID

+ Workflowid pgtype.UUID

+ type CreateRetryQueueItemParams struct

+ Retryafter pgtype.Timestamp

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

type CreateStepParams

+ RetryBackoffFactor pgtype.Float8

+ RetryMaxBackoff pgtype.Int4

type CreateWorkflowRunTriggeredByParams

+ CronName pgtype.Text

+ CronSchedule pgtype.Text

type CreateWorkflowRunTriggeredBysParams

+ CronName pgtype.Text

+ type CreateWorkflowTriggerCronRefForWorkflowParams struct

+ AdditionalMetadata []byte

+ Crontrigger string

+ Input []byte

+ Method NullWorkflowTriggerCronRefMethods

+ Name pgtype.Text

+ Workflowid pgtype.UUID

type CreateWorkflowTriggerCronRefParams

+ AdditionalMetadata []byte

+ Method NullWorkflowTriggerCronRefMethods

+ Name pgtype.Text

+ type CreateWorkflowTriggerScheduledRefForWorkflowParams struct

+ Additionalmetadata []byte

+ Input []byte

+ Method NullWorkflowTriggerScheduledRefMethods

+ Scheduledtrigger pgtype.Timestamp

+ Workflowid pgtype.UUID

type CreateWorkflowTriggerScheduledRefParams

+ Additionalmetadata []byte

+ Input []byte

+ type GetMinMaxProcessedRetryQueueItemsRow struct

+ MaxRetryAfter pgtype.Timestamp

+ MinRetryAfter pgtype.Timestamp

type GetStepRunForEngineRow

+ StepRetryBackoffFactor pgtype.Float8

+ StepRetryMaxBackoff pgtype.Int4

type ListCronWorkflowsParams

+ AdditionalMetadata []byte

+ Crontriggerid pgtype.UUID

+ Workflowid pgtype.UUID

type ListCronWorkflowsRow

+ CronId pgtype.UUID

+ ID_2 pgtype.UUID

+ Method WorkflowTriggerCronRefMethods

+ TriggerId pgtype.UUID

+ WorkflowName string

type ListScheduledWorkflowsRow

+ Method WorkflowTriggerScheduledRefMethods

+ type ListStepRunsToRetryRow struct

+ ID int64

+ IsQueued bool

+ RetryAfter pgtype.Timestamp

+ StepRunId pgtype.UUID

+ TenantId pgtype.UUID

+ type MoveCronTriggerToNewWorkflowTriggersParams struct

+ Newworkflowtriggerid pgtype.UUID

+ Oldworkflowversionid pgtype.UUID

+ type MoveScheduledTriggerToNewWorkflowTriggersParams struct

+ Newworkflowtriggerid pgtype.UUID

+ Oldworkflowversionid pgtype.UUID

+ type NullWorkflowTriggerCronRefMethods struct

+ Valid bool

+ WorkflowTriggerCronRefMethods WorkflowTriggerCronRefMethods

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

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

+ type NullWorkflowTriggerScheduledRefMethods struct

+ Valid bool

+ WorkflowTriggerScheduledRefMethods WorkflowTriggerScheduledRefMethods

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

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

type PollCronSchedulesRow

+ ID pgtype.UUID

+ Method WorkflowTriggerCronRefMethods

+ Name pgtype.Text

type PollScheduledWorkflowsRow

+ Method WorkflowTriggerScheduledRefMethods

type Queries

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

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

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

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

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

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

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

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

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

+ type RetryQueueItem struct

+ ID int64

+ IsQueued bool

+ RetryAfter pgtype.Timestamp

+ StepRunId pgtype.UUID

+ TenantId pgtype.UUID

type Step

+ RetryBackoffFactor pgtype.Float8

+ RetryMaxBackoff pgtype.Int4

type WorkflowRunTriggeredBy

+ CronName pgtype.Text

type WorkflowTriggerCronRef

+ ID pgtype.UUID

+ Method WorkflowTriggerCronRefMethods

+ Name pgtype.Text

+ type WorkflowTriggerCronRefMethods string

+ const WorkflowTriggerCronRefMethodsAPI

+ const WorkflowTriggerCronRefMethodsDEFAULT

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

type WorkflowTriggerScheduledRef

+ Method WorkflowTriggerScheduledRefMethods

+ type WorkflowTriggerScheduledRefMethods string

+ const WorkflowTriggerScheduledRefMethodsAPI

+ const WorkflowTriggerScheduledRefMethodsDEFAULT

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

Nov 21, 2024

Changes in this version

type Event

+ IdentityId pgtype.Int8

type GetWorkflowRunByIdRow

+ IdentityId pgtype.Int8

type GetWorkflowRunByIdsRow

+ IdentityId pgtype.Int8

type JobRun

+ IdentityId pgtype.Int8

type JobRunLookupData

+ IdentityId pgtype.Int8

type ListJobRunsForWorkflowRunFullRow

+ IdentityId pgtype.Int8

type StepRun

+ IdentityId int64

+ type StepRunStable struct

+ CallerFiles []byte

+ CancelledAt pgtype.Timestamp

+ CancelledError pgtype.Text

+ CancelledReason pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ GitRepoBranch pgtype.Text

+ ID pgtype.UUID

+ IdentityId int64

+ Input []byte

+ InputSchema []byte

+ InternalRetryCount int32

+ JobRunId pgtype.UUID

+ Order int64

+ Output []byte

+ Priority pgtype.Int4

+ Queue string

+ RequeueAfter pgtype.Timestamp

+ RetryCount int32

+ ScheduleTimeoutAt pgtype.Timestamp

+ SemaphoreReleased bool

+ StartedAt pgtype.Timestamp

+ Status StepRunStatus

+ StepId pgtype.UUID

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ TimeoutAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ WorkerId pgtype.UUID

+ type StepRunVolatile struct

+ CallerFiles []byte

+ CancelledAt pgtype.Timestamp

+ CancelledError pgtype.Text

+ CancelledReason pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ GitRepoBranch pgtype.Text

+ ID pgtype.UUID

+ IdentityId int64

+ Input []byte

+ InputSchema []byte

+ InternalRetryCount int32

+ JobRunId pgtype.UUID

+ Order int64

+ Output []byte

+ Priority pgtype.Int4

+ Queue string

+ RequeueAfter pgtype.Timestamp

+ RetryCount int32

+ ScheduleTimeoutAt pgtype.Timestamp

+ SemaphoreReleased bool

+ StartedAt pgtype.Timestamp

+ Status StepRunStatus

+ StepId pgtype.UUID

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ TimeoutAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ WorkerId pgtype.UUID

type WorkflowRun

+ IdentityId pgtype.Int8

type WorkflowRunTriggeredBy

+ IdentityId pgtype.Int8

Nov 15, 2024

Changes in this version

type ListStepRunsToReassignParams

+ Maxinternalretrycount int32

Nov 7, 2024

Changes in this version

+ type ListStepRunsToCancelParams struct

+ Jobrunid pgtype.UUID

+ Tenantid pgtype.UUID

type ListStepRunsToReassignRow

+ Operation string

type Queries

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

type StepRun

+ InternalRetryCount int32

Nov 6, 2024

Changes in this version

type Queries

+ func (q *Queries) ValidatesAsJson(ctx context.Context, db DBTX, input []byte) error

Nov 5, 2024

Changes in this version

+ type CountScheduledWorkflowsParams struct

+ AdditionalMetadata []byte

+ Includescheduled bool

+ Parentsteprunid pgtype.UUID

+ Parentworkflowrunid pgtype.UUID

+ Scheduleid pgtype.UUID

+ Statuses []string

+ Tenantid pgtype.UUID

+ Workflowid pgtype.UUID

type CreateSchedulesParams

+ Additionalmetadata []byte

+ type GetFailureDetailsParams struct

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ type GetFailureDetailsRow struct

+ CancelledReason pgtype.Text

+ Error pgtype.Text

+ ID pgtype.UUID

+ JrStatus JobRunStatus

+ SrStatus StepRunStatus

+ Status WorkflowRunStatus

+ type ListCronWorkflowsParams struct

+ Limit interface{}

+ Offset interface{}

+ Orderby interface{}

+ Tenantid pgtype.UUID

+ type ListCronWorkflowsRow struct

+ AdditionalMetadata []byte

+ CreatedAt pgtype.Timestamp

+ CreatedAt_2 pgtype.Timestamp

+ Cron string

+ DeletedAt pgtype.Timestamp

+ DeletedAt_2 pgtype.Timestamp

+ Enabled bool

+ ID pgtype.UUID

+ Input []byte

+ Name string

+ ParentId pgtype.UUID

+ TenantId pgtype.UUID

+ TenantId_2 pgtype.UUID

+ TickerId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ UpdatedAt_2 pgtype.Timestamp

+ WorkflowId pgtype.UUID

+ WorkflowVersionId pgtype.UUID

+ WorkflowVersionId_2 pgtype.UUID

+ type ListScheduledWorkflowsParams struct

+ AdditionalMetadata []byte

+ Includescheduled bool

+ Limit interface{}

+ Offset interface{}

+ Orderby interface{}

+ Parentsteprunid pgtype.UUID

+ Parentworkflowrunid pgtype.UUID

+ Scheduleid pgtype.UUID

+ Statuses []string

+ Tenantid pgtype.UUID

+ Workflowid pgtype.UUID

+ type ListScheduledWorkflowsRow struct

+ AdditionalMetadata []byte

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Input []byte

+ Name string

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

+ ParentWorkflowRunId pgtype.UUID

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ TriggerAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ WorkflowId pgtype.UUID

+ WorkflowRunCreatedAt pgtype.Timestamp

+ WorkflowRunId pgtype.UUID

+ WorkflowRunName pgtype.Text

+ WorkflowRunStatus NullWorkflowRunStatus

+ WorkflowVersionId pgtype.UUID

type PollCronSchedulesRow

+ AdditionalMetadata []byte

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

type PollScheduledWorkflowsRow

+ AdditionalMetadata []byte

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

type Queries

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

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

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

+ func (q *Queries) GetFailureDetails(ctx context.Context, db DBTX, arg GetFailureDetailsParams) ([]*GetFailureDetailsRow, error)

+ func (q *Queries) ListCronWorkflows(ctx context.Context, db DBTX, arg ListCronWorkflowsParams) ([]*ListCronWorkflowsRow, error)

+ func (q *Queries) ListScheduledWorkflows(ctx context.Context, db DBTX, arg ListScheduledWorkflowsParams) ([]*ListScheduledWorkflowsRow, error)

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

+ type UpdateScheduledWorkflowParams struct

+ Scheduleid pgtype.UUID

+ Triggerat pgtype.Timestamp

type WorkflowTriggerCronRef

+ AdditionalMetadata []byte

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

type WorkflowTriggerScheduledRef

+ AdditionalMetadata []byte

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

Oct 30, 2024

Changes in this version

type CreateWorkerParams

+ Language NullWorkerSDKS

+ LanguageVersion pgtype.Text

+ Os pgtype.Text

+ RuntimeExtra pgtype.Text

+ SdkVersion pgtype.Text

+ type NullWorkerSDKS struct

+ Valid bool

+ WorkerSDKS WorkerSDKS

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

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

type Worker

+ Language NullWorkerSDKS

+ LanguageVersion pgtype.Text

+ Os pgtype.Text

+ RuntimeExtra pgtype.Text

+ SdkVersion pgtype.Text

+ type WorkerSDKS string

+ const WorkerSDKSGO

+ const WorkerSDKSPYTHON

+ const WorkerSDKSTYPESCRIPT

+ const WorkerSDKSUNKNOWN

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

Oct 25, 2024

Changes in this version

type UpdateStepRunsToAssignedRow

+ StepRunId pgtype.UUID

Oct 23, 2024

Changes in this version

+ type AcquireOrExtendLeasesParams struct

+ Existingleaseids []int64

+ Kind LeaseKind

+ LeaseDuration pgtype.Interval

+ Resourceids []string

+ Tenantid pgtype.UUID

+ type CreateGetGroupKeyRunsParams struct

+ ID pgtype.UUID

+ Input []byte

+ RequeueAfter pgtype.Timestamp

+ ScheduleTimeoutAt pgtype.Timestamp

+ Status StepRunStatus

+ TenantId pgtype.UUID

+ WorkflowRunId pgtype.UUID

+ type CreateJobRunLookupDatasParams struct

+ Ids []pgtype.UUID

+ Inputs [][]byte

+ Jobrunids []pgtype.UUID

+ Tenantids []pgtype.UUID

+ Triggeredbys []string

+ type CreateManyJobRunsParams struct

+ Tenantids []pgtype.UUID

+ Workflowrunids []pgtype.UUID

+ Workflowversionids []pgtype.UUID

+ type CreateManyJobRunsRow struct

+ ID pgtype.UUID

+ TenantId pgtype.UUID

+ WorkflowRunId pgtype.UUID

+ type CreateMultipleWorkflowRunStickyStatesParams struct

+ Desiredworkerids []pgtype.UUID

+ Tenantid []pgtype.UUID

+ Workflowrunids []pgtype.UUID

+ Workflowversionids []pgtype.UUID

+ type CreateQueueItemsBulkParams struct

+ ActionId pgtype.Text

+ DesiredWorkerId pgtype.UUID

+ IsQueued bool

+ Priority int32

+ Queue string

+ ScheduleTimeoutAt pgtype.Timestamp

+ StepId pgtype.UUID

+ StepRunId pgtype.UUID

+ StepTimeout pgtype.Text

+ Sticky NullStickyStrategy

+ TenantId pgtype.UUID

+ type CreateStepRunsForJobRunIdsParams struct

+ Jobrunids []pgtype.UUID

+ Priority int32

type CreateStepRunsParams

+ ID pgtype.UUID

+ JobRunId pgtype.UUID

+ Priority pgtype.Int4

+ Queue string

+ RequeueAfter pgtype.Timestamp

+ Status StepRunStatus

+ StepId pgtype.UUID

+ TenantId pgtype.UUID

+ type CreateWorkflowRunTriggeredBysParams struct

+ CronParentId pgtype.UUID

+ CronSchedule pgtype.Text

+ EventId pgtype.UUID

+ ID pgtype.UUID

+ ParentId pgtype.UUID

+ ScheduledId pgtype.UUID

+ TenantId pgtype.UUID

+ type CreateWorkflowRunsParams struct

+ AdditionalMetadata []byte

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ DisplayName pgtype.Text

+ ID pgtype.UUID

+ InsertOrder pgtype.Int4

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

+ Priority pgtype.Int4

+ Status WorkflowRunStatus

+ TenantId pgtype.UUID

+ WorkflowVersionId pgtype.UUID

+ type GetChildWorkflowRunsByIndexParams struct

+ Childindexes []int32

+ Parentids []pgtype.UUID

+ Parentsteprunids []pgtype.UUID

+ type GetChildWorkflowRunsByKeyParams struct

+ Childkeys []string

+ Parentids []pgtype.UUID

+ Parentsteprunids []pgtype.UUID

+ type GetJobRunsByWorkflowRunIdParams struct

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ type GetJobRunsByWorkflowRunIdRow struct

+ ID pgtype.UUID

+ JobId pgtype.UUID

+ Status JobRunStatus

+ type GetLatestWorkflowVersionForWorkflowsParams struct

+ Tenantid pgtype.UUID

+ Workflowids []pgtype.UUID

+ type GetLeasesToAcquireParams struct

+ Kind LeaseKind

+ Resourceids []string

+ Tenantid pgtype.UUID

+ type GetMinUnprocessedQueueItemIdParams struct

+ Queue string

+ Tenantid pgtype.UUID

+ type GetStepRunBulkDataForEngineParams struct

+ Ids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetStepRunBulkDataForEngineRow struct

+ ActionId string

+ AdditionalMetadata []byte

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ Error pgtype.Text

+ Input []byte

+ JobId pgtype.UUID

+ JobKind JobKind

+ JobName string

+ JobRunId pgtype.UUID

+ JobRunId_2 pgtype.UUID

+ JobRunLookupData []byte

+ JobRunStatus JobRunStatus

+ JobRunStatus_2 JobRunStatus

+ Output []byte

+ ParentId pgtype.UUID

+ SRID pgtype.UUID

+ SRRetryCount int32

+ Status StepRunStatus

+ StepCustomUserData []byte

+ StepId pgtype.UUID

+ StepReadableId pgtype.Text

+ StepRetries int32

+ StepScheduleTimeout string

+ StepTimeout pgtype.Text

+ WorkflowRunId pgtype.UUID

+ WorkflowVersionId pgtype.UUID

type GetWorkflowRunByIdRow

+ InsertOrder pgtype.Int4

+ type GetWorkflowRunByIdsParams struct

+ Tenantid pgtype.UUID

+ Workflowrunids []pgtype.UUID

+ type GetWorkflowRunByIdsRow struct

+ AdditionalMetadata []byte

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ ConcurrencyGroupId pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ DisplayName pgtype.Text

+ Duration pgtype.Int8

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ InsertOrder pgtype.Int4

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

+ Priority pgtype.Int4

+ StartedAt pgtype.Timestamp

+ Status WorkflowRunStatus

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ Workflow Workflow

+ WorkflowRunTriggeredBy WorkflowRunTriggeredBy

+ WorkflowVersion WorkflowVersion

+ WorkflowVersionId pgtype.UUID

+ type GetWorkflowsByNamesParams struct

+ Names []string

+ Tenantid pgtype.UUID

+ type Lease struct

+ ExpiresAt pgtype.Timestamp

+ ID int64

+ Kind LeaseKind

+ ResourceId string

+ TenantId pgtype.UUID

+ type LeaseKind string

+ const LeaseKindQUEUE

+ const LeaseKindWORKER

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

+ type ListActionsForAvailableWorkersRow struct

+ ActionId string

+ WorkerId pgtype.UUID

+ type ListActionsForWorkersParams struct

+ Tenantid pgtype.UUID

+ Workerids []pgtype.UUID

+ type ListActionsForWorkersRow struct

+ ActionId pgtype.Text

+ WorkerId pgtype.UUID

+ type ListActiveWorkersRow struct

+ ID pgtype.UUID

+ MaxRuns int32

+ type ListAllAvailableSlotsForWorkersRow struct

+ AvailableSlots int32

+ ID pgtype.UUID

+ type ListAllWorkerActionsParams struct

+ Tenantid pgtype.UUID

+ Workerid pgtype.UUID

+ type ListDispatcherIdsForWorkersParams struct

+ Tenantid pgtype.UUID

+ Workerids []pgtype.UUID

+ type ListDispatcherIdsForWorkersRow struct

+ DispatcherId pgtype.UUID

+ WorkerId pgtype.UUID

+ type ListManyWorkerLabelsRow struct

+ CreatedAt pgtype.Timestamp

+ ID int64

+ IntValue pgtype.Int4

+ Key string

+ StrValue pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ WorkerId pgtype.UUID

+ type ListQueueItemsForQueueParams struct

+ GtId pgtype.Int8

+ Limit pgtype.Int4

+ Queue string

+ Tenantid pgtype.UUID

+ type ListQueueItemsForQueueRow struct

+ QueueItem QueueItem

+ Status StepRunStatus

+ type NullLeaseKind struct

+ LeaseKind LeaseKind

+ Valid bool

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

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

type Queries

+ func (q *Queries) AcquireOrExtendLeases(ctx context.Context, db DBTX, arg AcquireOrExtendLeasesParams) ([]*Lease, error)

+ func (q *Queries) CreateGetGroupKeyRuns(ctx context.Context, db DBTX, arg []CreateGetGroupKeyRunsParams) (int64, error)

+ func (q *Queries) CreateJobRunLookupDatas(ctx context.Context, db DBTX, arg CreateJobRunLookupDatasParams) ([]*JobRunLookupData, error)

+ func (q *Queries) CreateManyJobRuns(ctx context.Context, db DBTX, arg CreateManyJobRunsParams) ([]*CreateManyJobRunsRow, error)

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

+ func (q *Queries) CreateQueueItemsBulk(ctx context.Context, db DBTX, arg []CreateQueueItemsBulkParams) (int64, error)

+ func (q *Queries) CreateSchedulerPartition(ctx context.Context, db DBTX, name pgtype.Text) (*SchedulerPartition, error)

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

+ func (q *Queries) CreateWorkflowRunTriggeredBys(ctx context.Context, db DBTX, arg []CreateWorkflowRunTriggeredBysParams) (int64, error)

+ func (q *Queries) CreateWorkflowRuns(ctx context.Context, db DBTX, arg []CreateWorkflowRunsParams) (int64, error)

+ func (q *Queries) DeleteSchedulerPartition(ctx context.Context, db DBTX, id string) (*SchedulerPartition, error)

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

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

+ func (q *Queries) GetJobRunsByWorkflowRunId(ctx context.Context, db DBTX, arg GetJobRunsByWorkflowRunIdParams) ([]*GetJobRunsByWorkflowRunIdRow, error)

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

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

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

+ func (q *Queries) GetStepRunBulkDataForEngine(ctx context.Context, db DBTX, arg GetStepRunBulkDataForEngineParams) ([]*GetStepRunBulkDataForEngineRow, error)

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

+ func (q *Queries) GetWorkflowRunByIds(ctx context.Context, db DBTX, arg GetWorkflowRunByIdsParams) ([]*GetWorkflowRunByIdsRow, error)

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

+ func (q *Queries) GetWorkflowsByNames(ctx context.Context, db DBTX, arg GetWorkflowsByNamesParams) ([]*Workflow, error)

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

+ func (q *Queries) ListActionsForWorkers(ctx context.Context, db DBTX, arg ListActionsForWorkersParams) ([]*ListActionsForWorkersRow, error)

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

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

+ func (q *Queries) ListAllWorkerActions(ctx context.Context, db DBTX, arg ListAllWorkerActionsParams) ([]pgtype.Text, error)

+ func (q *Queries) ListDispatcherIdsForWorkers(ctx context.Context, db DBTX, arg ListDispatcherIdsForWorkersParams) ([]*ListDispatcherIdsForWorkersRow, error)

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

+ func (q *Queries) ListQueueItemsForQueue(ctx context.Context, db DBTX, arg ListQueueItemsForQueueParams) ([]*ListQueueItemsForQueueRow, error)

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

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

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

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

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

+ func (q *Queries) ReleaseLeases(ctx context.Context, db DBTX, leaseids []int64) ([]*Lease, error)

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

+ func (q *Queries) SchedulerPartitionHeartbeat(ctx context.Context, db DBTX, schedulerpartitionid string) (*SchedulerPartition, error)

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

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

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

type Queue

+ LastActive pgtype.Timestamp

+ type QueueStepRunBulkNoInputParams struct

+ Ids []pgtype.UUID

+ Retrycounts []int32

+ type QueueStepRunBulkWithInputParams struct

+ Ids []pgtype.UUID

+ Inputs [][]byte

+ Retrycounts []int32

+ type SchedulerPartition struct

+ CreatedAt pgtype.Timestamp

+ ID string

+ LastHeartbeat pgtype.Timestamp

+ Name pgtype.Text

+ UpdatedAt pgtype.Timestamp

type StepRunEventReason

+ const StepRunEventReasonACKNOWLEDGED

type Tenant

+ SchedulerPartitionId pgtype.Text

+ type UpsertQueuesParams struct

+ Names []string

+ Tenantids []pgtype.UUID

+ type VerifiedStepRunTenantIdsParams struct

+ Steprunids []pgtype.UUID

+ Tenantids []pgtype.UUID

type WorkflowRun

+ InsertOrder pgtype.Int4

Oct 11, 2024

Changes in this version

type EventKey

+ ID int64

Oct 10, 2024

Changes in this version

+ type CreateEventKeysParams struct

+ Keys []string

+ Tenantids []pgtype.UUID

+ type EventKey struct

+ Key string

+ TenantId pgtype.UUID

type Queries

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

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

Oct 7, 2024

Changes in this version

type CreateEventsParams

+ InsertOrder pgtype.Int4

type CreateInternalQueueItemsBulkParams

+ Queues []string

+ Tenantids []pgtype.UUID

type Event

+ InsertOrder pgtype.Int4

type InternalQueue

+ const InternalQueueSTEPRUNUPDATEV2

type Queries

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

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

Sep 29, 2024

Changes in this version

type GetWorkflowRunRow

+ IsPaused pgtype.Bool

+ type HandleWorkflowUnpausedParams struct

+ Tenantid pgtype.UUID

+ Workflowid string

type InternalQueue

+ const InternalQueueWORKFLOWRUNPAUSED

type Queries

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

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

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

+ type UpdateWorkflowParams struct

+ ID pgtype.UUID

+ IsPaused pgtype.Bool

type Workflow

+ IsPaused pgtype.Bool

Sep 27, 2024

Changes in this version

+ type CountRateLimitsParams struct

+ Orderby interface{}

+ Search pgtype.Text

+ Tenantid pgtype.UUID

type CountWorkflowRunsParams

+ FinishedBefore pgtype.Timestamp

+ type CreateStepExpressionsParams struct

+ Expressions []string

+ Keys []string

+ Kinds []string

+ Stepid pgtype.UUID

type CreateStepRateLimitParams

+ Kind StepRateLimitKind

+ type CreateStepRunExpressionEvalIntsParams struct

+ Keys []string

+ Kinds []string

+ Steprunid pgtype.UUID

+ Valuesint []int32

+ type CreateStepRunExpressionEvalStrsParams struct

+ Keys []string

+ Kinds []string

+ Steprunid pgtype.UUID

+ Valuesstr []string

type GetStepRunDataForEngineRow

+ ExprCount int64

+ type ListRateLimitsForTenantNoMutateParams struct

+ Limit interface{}

+ Offset interface{}

+ Orderby interface{}

+ Search pgtype.Text

+ Tenantid pgtype.UUID

+ type ListRateLimitsForTenantNoMutateRow struct

+ Key string

+ LastRefill pgtype.Timestamp

+ LimitValue int32

+ TenantId pgtype.UUID

+ Value int32

+ Window string

+ type ListRateLimitsForTenantWithMutateRow struct

+ Key string

+ LastRefill pgtype.Timestamp

+ LimitValue int32

+ NextRefillAt pgtype.Timestamp

+ TenantId pgtype.UUID

+ Value int32

+ Window string

type ListWorkflowRunsParams

+ FinishedBefore pgtype.Timestamp

+ type NullStepExpressionKind struct

+ StepExpressionKind StepExpressionKind

+ Valid bool

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

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

+ type NullStepRateLimitKind struct

+ StepRateLimitKind StepRateLimitKind

+ Valid bool

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

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

type Queries

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

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

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

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

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

+ func (q *Queries) ListRateLimitsForTenantNoMutate(ctx context.Context, db DBTX, arg ListRateLimitsForTenantNoMutateParams) ([]*ListRateLimitsForTenantNoMutateRow, error)

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

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

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

type ResolveWorkflowRunStatusRow

+ TenantId pgtype.UUID

+ type StepExpression struct

+ Expression string

+ Key string

+ Kind StepExpressionKind

+ StepId pgtype.UUID

+ type StepExpressionKind string

+ const StepExpressionKindDYNAMICRATELIMITKEY

+ const StepExpressionKindDYNAMICRATELIMITUNITS

+ const StepExpressionKindDYNAMICRATELIMITVALUE

+ const StepExpressionKindDYNAMICRATELIMITWINDOW

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

type StepRateLimit

+ Kind StepRateLimitKind

+ type StepRateLimitKind string

+ const StepRateLimitKindDYNAMIC

+ const StepRateLimitKindSTATIC

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

type StepRunEventReason

+ const StepRunEventReasonRATELIMITERROR

+ type StepRunExpressionEval struct

+ Key string

+ Kind StepExpressionKind

+ StepRunId pgtype.UUID

+ ValueInt pgtype.Int4

+ ValueStr pgtype.Text

+ type UpsertRateLimitsBulkParams struct

+ Keys []string

+ Limitvalues []int32

+ Tenantid pgtype.UUID

+ Windows []string

Sep 24, 2024

Changes in this version

+ type GetQueuedCountsRow struct

+ Count int64

+ Queue string

+ type GetStepRunsForJobRunsWithOutputParams struct

+ Jobids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetStepRunsForJobRunsWithOutputRow struct

+ CancelledAt pgtype.Timestamp

+ CancelledError pgtype.Text

+ CancelledReason pgtype.Text

+ CreatedAt pgtype.Timestamp

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ JobRunId pgtype.UUID

+ Output []byte

+ StartedAt pgtype.Timestamp

+ Status StepRunStatus

+ StepId pgtype.UUID

+ TenantId pgtype.UUID

+ TimeoutAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ WorkerId pgtype.UUID

type Queries

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

+ func (q *Queries) GetStepRunsForJobRunsWithOutput(ctx context.Context, db DBTX, arg GetStepRunsForJobRunsWithOutputParams) ([]*GetStepRunsForJobRunsWithOutputRow, error)

Sep 23, 2024

Changes in this version

+ type CreateEventsParams struct

+ AdditionalMetadata []byte

+ Data []byte

+ ID pgtype.UUID

+ Key string

+ ReplayedFromId pgtype.UUID

+ TenantId pgtype.UUID

type DBTX

+ CopyFrom func(ctx context.Context, tableName pgx.Identifier, columnNames []string, ...) (int64, error)

type MeterTenantResourceParams

+ Numresources int32

type Queries

+ func (q *Queries) CreateEvents(ctx context.Context, db DBTX, arg []CreateEventsParams) (int64, error)

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

Sep 19, 2024

Changes in this version

+ type GetWorkflowWorkerCountParams struct

+ Tenantid pgtype.UUID

+ Workflowid pgtype.UUID

+ type GetWorkflowWorkerCountRow struct

+ Freeslotcount int32

+ Totalslotcount int64

type Queries

+ func (q *Queries) GetWorkflowWorkerCount(ctx context.Context, db DBTX, arg GetWorkflowWorkerCountParams) (*GetWorkflowWorkerCountRow, error)

Sep 19, 2024

Changes in this version

+ type BulkCreateWorkflowRunEventParams struct

+ Data [][]byte

+ Messages []string

+ Reasons []string

+ Severities []string

+ Timeseen []pgtype.Timestamp

+ Workflowrunids []pgtype.UUID

type CreateWorkflowConcurrencyParams

+ ConcurrencyGroupExpression pgtype.Text

+ GetConcurrencyGroupId pgtype.UUID

type GetWorkflowRunRow

+ ConcurrencyGroupExpression pgtype.Text

type GetWorkflowVersionForEngineRow

+ ConcurrencyGroupExpression pgtype.Text

+ ConcurrencyGroupId pgtype.UUID

type InternalQueue

+ const InternalQueueWORKFLOWRUNUPDATE

type Queries

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

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

+ func (q *Queries) UpdateWorkflowRunGroupKeyFromExpr(ctx context.Context, db DBTX, arg UpdateWorkflowRunGroupKeyFromExprParams) (pgtype.UUID, error)

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

type StepRunEvent

+ WorkflowRunId pgtype.UUID

type StepRunEventReason

+ const StepRunEventReasonWORKFLOWRUNGROUPKEYFAILED

+ const StepRunEventReasonWORKFLOWRUNGROUPKEYSUCCEEDED

+ type UpdateWorkflowRunGroupKeyFromExprParams struct

+ ConcurrencyGroupId pgtype.Text

+ Error pgtype.Text

+ Workflowrunid pgtype.UUID

+ type UpdateWorkflowRunGroupKeyFromRunParams struct

+ Groupkeyrunid pgtype.UUID

+ Tenantid pgtype.UUID

type WorkflowConcurrency

+ ConcurrencyGroupExpression pgtype.Text

Sep 16, 2024

Changes in this version

type ArchiveStepRunResultFromStepRunParams

+ Error pgtype.Text

type BulkCreateStepRunEventParams

+ Timeseen []pgtype.Timestamp

type CountEventsParams

+ EventIds []pgtype.UUID

type CreateStepRunEventParams

+ Jobrunid pgtype.UUID

type GetDesiredLabelsRow

+ StepId pgtype.UUID

type GetStepRunForEngineRow

+ SRChildCount int64

+ type GetStepRunsForJobRunsParams struct

+ Jobids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetStepRunsForJobRunsRow struct

+ CancelledAt pgtype.Timestamp

+ CancelledError pgtype.Text

+ CancelledReason pgtype.Text

+ CreatedAt pgtype.Timestamp

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ JobRunId pgtype.UUID

+ StartedAt pgtype.Timestamp

+ Status StepRunStatus

+ StepId pgtype.UUID

+ TenantId pgtype.UUID

+ TimeoutAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ WorkerId pgtype.UUID

+ type GetStepsForJobsParams struct

+ Jobids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetStepsForJobsRow struct

+ JobId pgtype.UUID

+ Parents []pgtype.UUID

+ Step Step

+ type GetWorkflowByIdRow struct

+ Workflow Workflow

+ WorkflowVersionId pgtype.UUID

+ type GetWorkflowRunByIdParams struct

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ type GetWorkflowRunByIdRow struct

+ AdditionalMetadata []byte

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ ConcurrencyGroupId pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ DisplayName pgtype.Text

+ Duration pgtype.Int4

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

+ Priority pgtype.Int4

+ StartedAt pgtype.Timestamp

+ Status WorkflowRunStatus

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ Workflow Workflow

+ WorkflowRunTriggeredBy WorkflowRunTriggeredBy

+ WorkflowVersion WorkflowVersion

+ WorkflowVersionId pgtype.UUID

+ type GetWorkflowRunTriggerParams struct

+ Runid pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetWorkflowVersionByIdRow struct

+ ConcurrencyGroupId pgtype.UUID

+ ConcurrencyId pgtype.UUID

+ ConcurrencyLimitStrategy NullConcurrencyLimitStrategy

+ ConcurrencyMaxRuns pgtype.Int4

+ Workflow Workflow

+ WorkflowVersion WorkflowVersion

+ type HasActiveWorkersForActionIdParams struct

+ Actionid string

+ Tenantid pgtype.UUID

+ type ListChildWorkflowRunCountsRow struct

+ Count int64

+ ParentStepRunId pgtype.UUID

+ type ListChildWorkflowRunIdsParams struct

+ Steprun pgtype.UUID

+ Tenantid pgtype.UUID

type ListEventsParams

+ EventIds []pgtype.UUID

+ type ListJobRunsForWorkflowRunFullParams struct

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ type ListJobRunsForWorkflowRunFullRow struct

+ CancelledAt pgtype.Timestamp

+ CancelledError pgtype.Text

+ CancelledReason pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Job Job

+ JobId pgtype.UUID

+ Result []byte

+ StartedAt pgtype.Timestamp

+ Status JobRunStatus

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ TimeoutAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ WorkflowRunId pgtype.UUID

+ type ListStepRunEventsByWorkflowRunIdParams struct

+ LastId pgtype.Int8

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

type Queries

+ func (q *Queries) GetStepRunsForJobRuns(ctx context.Context, db DBTX, arg GetStepRunsForJobRunsParams) ([]*GetStepRunsForJobRunsRow, error)

+ func (q *Queries) GetStepsForJobs(ctx context.Context, db DBTX, arg GetStepsForJobsParams) ([]*GetStepsForJobsRow, error)

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

+ func (q *Queries) GetWorkflowRunById(ctx context.Context, db DBTX, arg GetWorkflowRunByIdParams) (*GetWorkflowRunByIdRow, error)

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

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

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

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

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

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

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

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

+ func (q *Queries) ListJobRunsForWorkflowRunFull(ctx context.Context, db DBTX, arg ListJobRunsForWorkflowRunFullParams) ([]*ListJobRunsForWorkflowRunFullRow, error)

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

+ func (q *Queries) ReplayWorkflowRunResetGetGroupKeyRun(ctx context.Context, db DBTX, workflowrunid pgtype.UUID) (*GetGroupKeyRun, error)

type StepRunResultArchive

+ RetryCount int32

type UpdateStepRunsToAssignedParams

+ Tenantid pgtype.UUID

Sep 12, 2024

Changes in this version

+ type BulkReleaseSemaphoreQueueItemsParams struct

+ Steprunids []pgtype.UUID

+ Workerids []pgtype.UUID

+ type CreateSemaphoreQueueItemsBulkParams struct

+ Steprunids []pgtype.UUID

+ Tenantid pgtype.UUID

+ Workerids []pgtype.UUID

+ type ListAvailableSlotsForWorkersParams struct

+ Tenantid pgtype.UUID

+ Workerids []pgtype.UUID

+ type ListAvailableSlotsForWorkersRow struct

+ AvailableSlots int32

+ ID pgtype.UUID

type Queries

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

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

+ func (q *Queries) ListAvailableSlotsForWorkers(ctx context.Context, db DBTX, arg ListAvailableSlotsForWorkersParams) ([]*ListAvailableSlotsForWorkersRow, error)

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

+ type RemoveSemaphoreQueueItemParams struct

+ Steprunid pgtype.UUID

+ Workerid pgtype.UUID

+ type SemaphoreQueueItem struct

+ ID int64

+ StepRunId pgtype.UUID

+ TenantId pgtype.UUID

+ WorkerId pgtype.UUID

Sep 10, 2024

Changes in this version

+ type BulkCancelStepRunParams struct

+ Cancelledats []pgtype.Timestamp

+ Cancellederrors []string

+ Cancelledreasons []string

+ Finishedats []pgtype.Timestamp

+ Steprunids []pgtype.UUID

+ type BulkFailStepRunParams struct

+ Errors []string

+ Finishedats []pgtype.Timestamp

+ Steprunids []pgtype.UUID

+ type BulkFinishStepRunParams struct

+ Finishedats []pgtype.Timestamp

+ Outputs [][]byte

+ Steprunids []pgtype.UUID

+ type BulkStartStepRunParams struct

+ Startedats []pgtype.Timestamp

+ Steprunids []pgtype.UUID

+ type CleanupTimeoutQueueItemsParams struct

+ Maxid int64

+ Minid int64

+ Tenantid pgtype.UUID

+ type CreateTimeoutQueueItemParams struct

+ Retrycount int32

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ Timeoutat pgtype.Timestamp

+ type GetMinMaxProcessedTimeoutQueueItemsRow struct

+ MaxId int64

+ MinId int64

+ type PopTimeoutQueueItemsParams struct

+ Limit pgtype.Int4

+ Tenantid pgtype.UUID

type Queries

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

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

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

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

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

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

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

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

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

+ type RemoveTimeoutQueueItemParams struct

+ Retrycount int32

+ Steprunid pgtype.UUID

+ type TimeoutQueueItem struct

+ ID int64

+ IsQueued bool

+ RetryCount int32

+ StepRunId pgtype.UUID

+ TenantId pgtype.UUID

+ TimeoutAt pgtype.Timestamp

Sep 9, 2024

Changes in this version

+ type DeleteOldWorkerAssignEventsParams struct

+ Limit int32

+ MaxRuns int32

+ Workerid pgtype.UUID

type GetWorkerByIdRow

+ RemainingSlots int32

type ListSemaphoreSlotsWithStateForWorkerParams

+ Limit pgtype.Int4

type Queries

+ func (q *Queries) DeleteOldWorkerAssignEvents(ctx context.Context, db DBTX, arg DeleteOldWorkerAssignEventsParams) (bool, error)

Sep 6, 2024

Changes in this version

+ type CleanupInternalQueueItemsParams struct

+ Maxid int64

+ Minid int64

+ Tenantid pgtype.UUID

+ type CreateInternalQueueItemsBulkParams struct

+ Datas [][]byte

+ Queue InternalQueue

+ Tenantid pgtype.UUID

+ type CreateUniqueInternalQueueItemsBulkParams struct

+ Datas [][]byte

+ Queue InternalQueue

+ Tenantid pgtype.UUID

+ Uniquekeys []string

+ type CreateWorkerAssignEventsParams struct

+ Assignedstepruns [][]byte

+ Workerids []pgtype.UUID

+ type CreateWorkerCountParams struct

+ MaxRuns pgtype.Int4

+ Workerid pgtype.UUID

+ type DeleteOldWorkersParams struct

+ Lastheartbeatbefore pgtype.Timestamp

+ Limit interface{}

+ Tenantid pgtype.UUID

+ type GetFinalizedStepRunsRow struct

+ ID pgtype.UUID

+ Status StepRunStatus

+ type GetLaterStepRunsParams struct

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetMinMaxProcessedInternalQueueItemsRow struct

+ MaxId int64

+ MinId int64

+ type GetWorkerDispatcherActionsParams struct

+ Actionids []string

+ Tenantid pgtype.UUID

+ type GetWorkerDispatcherActionsRow struct

+ ActionId string

+ DispatcherId pgtype.UUID

+ ID pgtype.UUID

+ type GetWorkerSemaphoreCountsParams struct

+ Tenantid pgtype.UUID

+ WorkerIds []pgtype.UUID

+ type InternalQueue string

+ const InternalQueueSTEPRUNUPDATE

+ const InternalQueueWORKERSEMAPHORECOUNT

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

+ type InternalQueueItem struct

+ Data []byte

+ ID int64

+ IsQueued bool

+ Priority int32

+ Queue InternalQueue

+ TenantId pgtype.UUID

+ UniqueKey pgtype.Text

+ type ListInternalQueueItemsParams struct

+ GtId pgtype.Int8

+ Limit pgtype.Int4

+ Queue InternalQueue

+ Tenantid pgtype.UUID

+ type ListRecentAssignedEventsForWorkerParams struct

+ Limit pgtype.Int4

+ Workerid pgtype.UUID

+ type ListRecentAssignedEventsForWorkerRow struct

+ AssignedStepRuns []byte

+ WorkerId pgtype.UUID

type ListStartableStepRunsParams

+ SucceededParentStepRunId pgtype.UUID

+ type ListStepRunsToReassignRow struct

+ ID pgtype.UUID

+ RetryCount int32

+ WorkerId pgtype.UUID

+ type ListWorkersWithSlotCountParams struct

+ ActionId pgtype.Text

+ Assignable pgtype.Bool

+ LastHeartbeatAfter pgtype.Timestamp

+ Tenantid pgtype.UUID

+ type ListWorkersWithSlotCountRow struct

+ RemainingSlots int32

+ WebhookId pgtype.UUID

+ WebhookUrl pgtype.Text

+ Worker Worker

+ type ManualReleaseSemaphoreParams struct

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type NullInternalQueue struct

+ InternalQueue InternalQueue

+ Valid bool

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

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

type Queries

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

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

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

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

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

+ func (q *Queries) DeleteOldWorkers(ctx context.Context, db DBTX, arg DeleteOldWorkersParams) (bool, error)

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

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

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

+ func (q *Queries) GetWorkerDispatcherActions(ctx context.Context, db DBTX, arg GetWorkerDispatcherActionsParams) ([]*GetWorkerDispatcherActionsRow, error)

+ func (q *Queries) GetWorkerSemaphoreCounts(ctx context.Context, db DBTX, arg GetWorkerSemaphoreCountsParams) ([]*WorkerSemaphoreCount, error)

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

+ func (q *Queries) ListInternalQueueItems(ctx context.Context, db DBTX, arg ListInternalQueueItemsParams) ([]*InternalQueueItem, error)

+ func (q *Queries) ListRecentAssignedEventsForWorker(ctx context.Context, db DBTX, arg ListRecentAssignedEventsForWorkerParams) ([]*ListRecentAssignedEventsForWorkerRow, error)

+ func (q *Queries) ListWorkersWithSlotCount(ctx context.Context, db DBTX, arg ListWorkersWithSlotCountParams) ([]*ListWorkersWithSlotCountRow, error)

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

+ func (q *Queries) MarkInternalQueueItemsProcessed(ctx context.Context, db DBTX, ids []int64) error

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

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

+ func (q *Queries) UpdateStepRunBatch(ctx context.Context, db DBTX, arg []UpdateStepRunBatchParams) *UpdateStepRunBatchBatchResults

+ func (q *Queries) UpdateStepRunUnsetWorkerId(ctx context.Context, db DBTX, arg UpdateStepRunUnsetWorkerIdParams) (*UpdateStepRunUnsetWorkerIdRow, error)

+ func (q *Queries) UpdateStepRunsToAssigned(ctx context.Context, db DBTX, arg UpdateStepRunsToAssignedParams) ([]*UpdateStepRunsToAssignedRow, error)

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

+ type QueueStepRunParams struct

+ ID pgtype.UUID

+ Input []byte

+ IsRetry pgtype.Bool

+ Tenantid pgtype.UUID

+ type ReplayStepRunResetStepRunsParams struct

+ Input []byte

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

type ResolveJobRunStatusParams

+ Steprunids []pgtype.UUID

type ResolveLaterStepRunsParams

+ Status StepRunStatus

type ResolveWorkflowRunStatusParams

+ Jobrunids []pgtype.UUID

+ type ResolveWorkflowRunStatusRow struct

+ ID pgtype.UUID

+ Status WorkflowRunStatus

+ type UpdateStepRunBatchBatchResults struct

+ func (b *UpdateStepRunBatchBatchResults) Close() error

+ func (b *UpdateStepRunBatchBatchResults) Exec(f func(int, error))

+ type UpdateStepRunBatchParams struct

+ CancelledAt pgtype.Timestamp

+ CancelledReason pgtype.Text

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Output []byte

+ StartedAt pgtype.Timestamp

+ Status NullStepRunStatus

+ Tenantid pgtype.UUID

+ type UpdateStepRunUnsetWorkerIdParams struct

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type UpdateStepRunUnsetWorkerIdRow struct

+ RetryCount int32

+ WorkerId pgtype.UUID

+ type UpdateStepRunsToAssignedParams struct

+ Steprunids []pgtype.UUID

+ Stepruntimeouts []string

+ Workerids []pgtype.UUID

+ type UpdateStepRunsToAssignedRow struct

+ ID interface{}

+ WorkerId interface{}

+ type UpdateWorkerSemaphoreCountsParams struct

+ Counts []int32

+ Workerids []pgtype.UUID

+ type WorkerAssignEvent struct

+ AssignedStepRuns []byte

+ ID int64

+ WorkerId pgtype.UUID

+ type WorkerSemaphoreCount struct

+ Count int32

+ WorkerId pgtype.UUID

Aug 29, 2024

Changes in this version

+ type CleanupQueueItemsParams struct

+ Maxid int64

+ Minid int64

+ Tenantid pgtype.UUID

type ControllerPartition

+ Name pgtype.Text

+ type GetMinMaxProcessedQueueItemsRow struct

+ MaxId int64

+ MinId int64

type Queries

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

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

type TenantWorkerPartition

+ Name pgtype.Text

Aug 28, 2024

Changes in this version

type Queries

+ func (q *Queries) WorkerPartitionHeartbeat(ctx context.Context, db DBTX, workerpartitionid string) (*TenantWorkerPartition, error)

Aug 26, 2024

Changes in this version

type CreateStepRunParams

+ Priority pgtype.Int4

type CreateWorkflowRunParams

+ Priority pgtype.Int4

type CreateWorkflowVersionParams

+ DefaultPriority pgtype.Int4

type GetStepRunForEngineRow

+ SRPriority pgtype.Int4

type StepRun

+ Priority pgtype.Int4

type WorkflowRun

+ Priority pgtype.Int4

type WorkflowVersion

+ DefaultPriority pgtype.Int4

Aug 23, 2024

Changes in this version

+ type CreateWebhookWorkerParams struct

+ Deleted pgtype.Bool

+ Name string

+ Secret string

+ Tenantid pgtype.UUID

+ TokenId pgtype.UUID

+ TokenValue pgtype.Text

+ Url string

+ type GetWorkerActionsByWorkerIdParams struct

+ Tenantid pgtype.UUID

+ Workerid pgtype.UUID

type GetWorkerByIdRow

+ FilledSlots int64

+ type HardDeleteWebhookWorkerParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ type InsertWebhookWorkerRequestParams struct

+ Method WebhookWorkerRequestMethod

+ Statuscode int32

+ Webhookworkerid pgtype.UUID

type ListWorkersWithStepCountRow

+ WebhookId pgtype.UUID

+ type NullWebhookWorkerRequestMethod struct

+ Valid bool

+ WebhookWorkerRequestMethod WebhookWorkerRequestMethod

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

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

type Queries

+ func (q *Queries) CreateWebhookWorker(ctx context.Context, db DBTX, arg CreateWebhookWorkerParams) (*WebhookWorker, error)

+ func (q *Queries) GetWorkerActionsByWorkerId(ctx context.Context, db DBTX, arg GetWorkerActionsByWorkerIdParams) ([]pgtype.Text, error)

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

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

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

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

+ func (q *Queries) UpdateWebhookWorkerToken(ctx context.Context, db DBTX, arg UpdateWebhookWorkerTokenParams) (*WebhookWorker, error)

+ type SoftDeleteWebhookWorkerParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ type UpdateWebhookWorkerTokenParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ TokenId pgtype.UUID

+ TokenValue pgtype.Text

+ type WebhookWorkerRequest struct

+ CreatedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Method WebhookWorkerRequestMethod

+ StatusCode int32

+ WebhookWorkerId pgtype.UUID

+ type WebhookWorkerRequestMethod string

+ const WebhookWorkerRequestMethodGET

+ const WebhookWorkerRequestMethodPOST

+ const WebhookWorkerRequestMethodPUT

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

Aug 22, 2024

Changes in this version

+ type BulkAssignStepRunsToWorkersRow struct

+ UpdatedStepRunsID pgtype.UUID

+ UpdatedStepRunsWorkerId pgtype.UUID

type Queries

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

Aug 21, 2024

Changes in this version

type CreateWorkerParams

+ Type NullWorkerType

+ WebhookId pgtype.UUID

+ type GetWorkerByIdRow struct

+ WebhookUrl pgtype.Text

+ Worker Worker

+ type GetWorkerByWebhookIdParams struct

+ Tenantid pgtype.UUID

+ Webhookid pgtype.UUID

type ListWorkersWithStepCountRow

+ WebhookUrl pgtype.Text

+ type NullWorkerType struct

+ Valid bool

+ WorkerType WorkerType

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

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

type Queries

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

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

+ func (q *Queries) UpdateWorkersByWebhookId(ctx context.Context, db DBTX, arg UpdateWorkersByWebhookIdParams) ([]*Worker, error)

+ type UpdateWorkersByWebhookIdParams struct

+ Isactive bool

+ Tenantid pgtype.UUID

+ Webhookid pgtype.UUID

type Worker

+ Type WorkerType

+ WebhookId pgtype.UUID

+ type WorkerType string

+ const WorkerTypeMANAGED

+ const WorkerTypeSELFHOSTED

+ const WorkerTypeWEBHOOK

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

Aug 20, 2024

Changes in this version

type CountWorkflowRunsParams

+ CreatedBefore pgtype.Timestamp

type ListWorkflowRunsParams

+ CreatedBefore pgtype.Timestamp

type WorkflowRunsMetricsCountParams

+ CreatedAfter pgtype.Timestamp

+ CreatedBefore pgtype.Timestamp

Aug 12, 2024

Changes in this version

+ var ErrBatchAlreadyClosed = errors.New("batch already closed")

+ type BulkAssignStepRunsToWorkersParams struct

+ Slotids []pgtype.UUID

+ Steprunids []pgtype.UUID

+ Stepruntimeouts []string

+ Workerids []pgtype.UUID

+ type BulkCreateStepRunEventParams struct

+ Data [][]byte

+ Messages []string

+ Reasons []string

+ Severities []string

+ Steprunids []pgtype.UUID

+ type BulkUpdateRateLimitsParams struct

+ Keys []string

+ Tenantid pgtype.UUID

+ Units []int32

+ type CreateQueueItemParams struct

+ ActionId pgtype.Text

+ DesiredWorkerId pgtype.UUID

+ Priority pgtype.Int4

+ Queue string

+ ScheduleTimeoutAt pgtype.Timestamp

+ StepId pgtype.UUID

+ StepRunId pgtype.UUID

+ StepTimeout pgtype.Text

+ Sticky NullStickyStrategy

+ Tenantid pgtype.UUID

+ type CreateStepRunParams struct

+ Jobrunid pgtype.UUID

+ Queue pgtype.Text

+ Stepid pgtype.UUID

+ Tenantid pgtype.UUID

type DBTX

+ SendBatch func(context.Context, *pgx.Batch) pgx.BatchResults

+ type GetDesiredLabelsRow struct

+ Comparator WorkerLabelComparator

+ IntValue pgtype.Int4

+ Key string

+ Required bool

+ StrValue pgtype.Text

+ Weight int32

type GetStepRunForEngineRow

+ DesiredWorkerId pgtype.UUID

+ JobRunStatus JobRunStatus

+ SRQueue string

+ type GetWorkerLabelsRow struct

+ IntValue pgtype.Int4

+ Key string

+ StrValue pgtype.Text

+ type ListQueueItemsBatchResults struct

+ func (b *ListQueueItemsBatchResults) Close() error

+ func (b *ListQueueItemsBatchResults) Query(f func(int, []*QueueItem, error))

+ type ListQueueItemsParams struct

+ GtId pgtype.Int8

+ Limit pgtype.Int4

+ Queue string

+ Tenantid pgtype.UUID

+ type ListRateLimitsForStepsParams struct

+ Stepids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type ListRateLimitsForTenantRow struct

+ Key string

+ LastRefill pgtype.Timestamp

+ LimitValue int32

+ NextRefillAt pgtype.Timestamp

+ TenantId pgtype.UUID

+ Value int32

+ Window string

+ type ListRecentStepRunsForWorkerParams struct

+ Statuses []string

+ Tenantid pgtype.UUID

+ Workerid pgtype.UUID

+ type ListRecentStepRunsForWorkerRow struct

+ ActionId string

+ CancelledAt pgtype.Timestamp

+ CreatedAt pgtype.Timestamp

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ StartedAt pgtype.Timestamp

+ Status StepRunStatus

+ TimeoutAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ WorkflowRunId pgtype.UUID

+ type ListSemaphoreSlotsToAssignParams struct

+ Actionids []string

+ Tenantid pgtype.UUID

+ type ListSemaphoreSlotsToAssignRow struct

+ ActionId string

+ DispatcherId pgtype.UUID

+ ID pgtype.UUID

+ WorkerId pgtype.UUID

+ type ListSemaphoreSlotsWithStateForWorkerParams struct

+ Tenantid pgtype.UUID

+ Workerid pgtype.UUID

+ type ListSemaphoreSlotsWithStateForWorkerRow struct

+ ActionId pgtype.Text

+ Slot pgtype.UUID

+ StartedAt pgtype.Timestamp

+ Status NullStepRunStatus

+ StepRunId pgtype.UUID

+ TimeoutAt pgtype.Timestamp

+ WorkflowRunId pgtype.UUID

+ type ListStepsForJobRow struct

+ ActionId string

+ ID pgtype.UUID

type Queries

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

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

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

+ func (q *Queries) BulkQueueItems(ctx context.Context, db DBTX, ids []int64) error

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

+ func (q *Queries) ControllerPartitionHeartbeat(ctx context.Context, db DBTX, controllerpartitionid string) (*ControllerPartition, error)

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

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

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

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

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

+ func (q *Queries) ListQueueItems(ctx context.Context, db DBTX, arg []ListQueueItemsParams) *ListQueueItemsBatchResults

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

+ func (q *Queries) ListRateLimitsForSteps(ctx context.Context, db DBTX, arg ListRateLimitsForStepsParams) ([]*StepRateLimit, error)

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

+ func (q *Queries) ListRecentStepRunsForWorker(ctx context.Context, db DBTX, arg ListRecentStepRunsForWorkerParams) ([]*ListRecentStepRunsForWorkerRow, error)

+ func (q *Queries) ListSemaphoreSlotsToAssign(ctx context.Context, db DBTX, arg ListSemaphoreSlotsToAssignParams) ([]*ListSemaphoreSlotsToAssignRow, error)

+ func (q *Queries) ListSemaphoreSlotsWithStateForWorker(ctx context.Context, db DBTX, arg ListSemaphoreSlotsWithStateForWorkerParams) ([]*ListSemaphoreSlotsWithStateForWorkerRow, error)

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

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

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

+ type Queue struct

+ ID int64

+ Name string

+ TenantId pgtype.UUID

+ type QueueItem struct

+ ActionId pgtype.Text

+ DesiredWorkerId pgtype.UUID

+ ID int64

+ IsQueued bool

+ Priority int32

+ Queue string

+ ScheduleTimeoutAt pgtype.Timestamp

+ StepId pgtype.UUID

+ StepRunId pgtype.UUID

+ StepTimeout pgtype.Text

+ Sticky NullStickyStrategy

+ TenantId pgtype.UUID

type StepRun

+ Queue string

type StepRunEventReason

+ const StepRunEventReasonSENTTOWORKER

type StepRunStatus

+ const StepRunStatusCANCELLING

+ type UpdateWorkerHeartbeatParams struct

+ ID pgtype.UUID

+ LastHeartbeatAt pgtype.Timestamp

+ type UpsertQueueParams struct

+ Name string

+ Tenantid pgtype.UUID

Jul 29, 2024

Changes in this version

type CountWorkflowRunsParams

+ Kinds []string

type CreateWorkflowVersionParams

+ Kind NullWorkflowKind

+ type GetStepRunMetaParams struct

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetStepRunMetaRow struct

+ Retries int32

+ RetryCount int32

+ WorkflowRunId pgtype.UUID

+ type GetStreamEventMetaParams struct

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetStreamEventMetaRow struct

+ Retries int32

+ RetryCount int32

+ WorkflowRunId pgtype.UUID

+ type GetWorkflowRunAdditionalMetaParams struct

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ type GetWorkflowRunAdditionalMetaRow struct

+ AdditionalMetadata []byte

+ ID pgtype.UUID

type ListWorkflowRunsParams

+ Kinds []string

+ type NullWorkflowKind struct

+ Valid bool

+ WorkflowKind WorkflowKind

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

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

type Queries

+ func (q *Queries) GetStepRunMeta(ctx context.Context, db DBTX, arg GetStepRunMetaParams) (*GetStepRunMetaRow, error)

+ func (q *Queries) GetStreamEventMeta(ctx context.Context, db DBTX, arg GetStreamEventMetaParams) (*GetStreamEventMetaRow, error)

+ func (q *Queries) GetWorkflowRunAdditionalMeta(ctx context.Context, db DBTX, arg GetWorkflowRunAdditionalMetaParams) (*GetWorkflowRunAdditionalMetaRow, error)

+ type WorkflowKind string

+ const WorkflowKindDAG

+ const WorkflowKindDURABLE

+ const WorkflowKindFUNCTION

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

type WorkflowVersion

+ Kind WorkflowKind

Jul 26, 2024

Changes in this version

type AcquireWorkerSemaphoreSlotAndAssignParams

+ WorkerId pgtype.UUID

type AcquireWorkerSemaphoreSlotAndAssignRow

+ DesiredLabels []byte

+ WorkerLabels []byte

+ type CheckWorkerParams struct

+ Tenantid pgtype.UUID

+ Workerid pgtype.UUID

+ type CreateWorkflowRunDedupeParams struct

+ Tenantid pgtype.UUID

+ Value pgtype.Text

+ Workflowrunid pgtype.UUID

+ Workflowversionid pgtype.UUID

+ type CreateWorkflowRunStickyStateParams struct

+ DesiredWorkerId pgtype.UUID

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ Workflowversionid pgtype.UUID

type CreateWorkflowVersionParams

+ Sticky NullStickyStrategy

type GetStepRunDataForEngineRow

+ AdditionalMetadata []byte

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ ParentId pgtype.UUID

type GetStepRunForEngineRow

+ StickyStrategy NullStickyStrategy

+ type GetWorkflowRunStickyStateForUpdateParams struct

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ type ListWorkerLabelsRow struct

+ CreatedAt pgtype.Timestamp

+ ID int64

+ IntValue pgtype.Int4

+ Key string

+ StrValue pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ type NullStickyStrategy struct

+ StickyStrategy StickyStrategy

+ Valid bool

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

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

+ type NullWorkerLabelComparator struct

+ Valid bool

+ WorkerLabelComparator WorkerLabelComparator

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

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

type Queries

+ func (q *Queries) CheckWorker(ctx context.Context, db DBTX, arg CheckWorkerParams) (pgtype.UUID, error)

+ func (q *Queries) CreateWorkflowRunDedupe(ctx context.Context, db DBTX, arg CreateWorkflowRunDedupeParams) (*WorkflowRunDedupe, error)

+ func (q *Queries) CreateWorkflowRunStickyState(ctx context.Context, db DBTX, arg CreateWorkflowRunStickyStateParams) (*WorkflowRunStickyState, error)

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

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

+ func (q *Queries) GetWorkflowRunStickyStateForUpdate(ctx context.Context, db DBTX, arg GetWorkflowRunStickyStateForUpdateParams) (*WorkflowRunStickyState, error)

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

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

+ func (q *Queries) UpsertDesiredWorkerLabel(ctx context.Context, db DBTX, arg UpsertDesiredWorkerLabelParams) (*StepDesiredWorkerLabel, error)

+ func (q *Queries) UpsertWorkerLabel(ctx context.Context, db DBTX, arg UpsertWorkerLabelParams) (*WorkerLabel, error)

+ type StepDesiredWorkerLabel struct

+ Comparator WorkerLabelComparator

+ CreatedAt pgtype.Timestamp

+ ID int64

+ IntValue pgtype.Int4

+ Key string

+ Required bool

+ StepId pgtype.UUID

+ StrValue pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ Weight int32

+ type StickyStrategy string

+ const StickyStrategyHARD

+ const StickyStrategySOFT

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

+ type UpdateWorkflowRunStickyStateParams struct

+ DesiredWorkerId pgtype.UUID

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ type UpsertDesiredWorkerLabelParams struct

+ Comparator NullWorkerLabelComparator

+ IntValue pgtype.Int4

+ Key string

+ Required pgtype.Bool

+ Stepid pgtype.UUID

+ StrValue pgtype.Text

+ Weight pgtype.Int4

+ type UpsertWorkerLabelParams struct

+ IntValue pgtype.Int4

+ Key string

+ StrValue pgtype.Text

+ Workerid pgtype.UUID

+ type WorkerLabel struct

+ CreatedAt pgtype.Timestamp

+ ID int64

+ IntValue pgtype.Int4

+ Key string

+ StrValue pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ WorkerId pgtype.UUID

+ type WorkerLabelComparator string

+ const WorkerLabelComparatorEQUAL

+ const WorkerLabelComparatorGREATERTHAN

+ const WorkerLabelComparatorGREATERTHANOREQUAL

+ const WorkerLabelComparatorLESSTHAN

+ const WorkerLabelComparatorLESSTHANOREQUAL

+ const WorkerLabelComparatorNOTEQUAL

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

+ type WorkflowRunDedupe struct

+ CreatedAt pgtype.Timestamp

+ ID int64

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ Value string

+ WorkflowId pgtype.UUID

+ WorkflowRunId pgtype.UUID

+ type WorkflowRunStickyState struct

+ CreatedAt pgtype.Timestamp

+ DesiredWorkerId pgtype.UUID

+ ID int64

+ Strategy StickyStrategy

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ WorkflowRunId pgtype.UUID

type WorkflowVersion

+ Sticky NullStickyStrategy

Jul 18, 2024

Changes in this version

+ type ClearEventPayloadDataParams struct

+ Limit interface{}

+ Tenantid pgtype.UUID

+ type ClearJobRunLookupDataParams struct

+ Limit interface{}

+ Tenantid pgtype.UUID

+ type ClearStepRunPayloadDataParams struct

+ Limit interface{}

+ Tenantid pgtype.UUID

type Queries

+ func (q *Queries) ClearEventPayloadData(ctx context.Context, db DBTX, arg ClearEventPayloadDataParams) (bool, error)

+ func (q *Queries) ClearJobRunLookupData(ctx context.Context, db DBTX, arg ClearJobRunLookupDataParams) (bool, error)

+ func (q *Queries) ClearStepRunPayloadData(ctx context.Context, db DBTX, arg ClearStepRunPayloadDataParams) (bool, error)

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

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

+ func (q *Queries) SoftDeleteExpiredEvents(ctx context.Context, db DBTX, arg SoftDeleteExpiredEventsParams) (bool, error)

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

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

+ type ResetStepRunsByIdsParams struct

+ Ids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type ResolveWorkerSemaphoreSlotsRow struct

+ HasMore bool

+ HasResolved bool

+ type SoftDeleteExpiredEventsParams struct

+ Createdbefore pgtype.Timestamp

+ Limit interface{}

+ Tenantid pgtype.UUID

+ type SoftDeleteExpiredWorkflowRunsWithDependenciesParams struct

+ Createdbefore pgtype.Timestamp

+ Limit interface{}

+ Statuses []string

+ Tenantid pgtype.UUID

Jul 16, 2024

Changes in this version

type APIToken

+ Internal bool

type CreateAPITokenParams

+ Internal pgtype.Bool

Jul 15, 2024

Changes in this version

type WorkflowRun

+ Duration pgtype.Int4

Jul 15, 2024

Changes in this version

type GetStepRunDataForEngineRow

+ JobRunLookupData []byte

Jul 14, 2024

Changes in this version

+ type GetStepRunDataForEngineParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetStepRunDataForEngineRow struct

+ Error pgtype.Text

+ Input []byte

+ Output []byte

type GetStepRunForEngineRow

+ SRCallerFiles []byte

+ SRCancelledAt pgtype.Timestamp

+ SRCancelledError pgtype.Text

+ SRCancelledReason pgtype.Text

+ SRCreatedAt pgtype.Timestamp

+ SRDeletedAt pgtype.Timestamp

+ SRFinishedAt pgtype.Timestamp

+ SRGitRepoBranch pgtype.Text

+ SRID pgtype.UUID

+ SROrder int64

+ SRRequeueAfter pgtype.Timestamp

+ SRRetryCount int32

+ SRScheduleTimeoutAt pgtype.Timestamp

+ SRSemaphoreReleased bool

+ SRStartedAt pgtype.Timestamp

+ SRStatus StepRunStatus

+ SRTenantId pgtype.UUID

+ SRTickerId pgtype.UUID

+ SRTimeoutAt pgtype.Timestamp

+ SRUpdatedAt pgtype.Timestamp

+ SRWorkerId pgtype.UUID

type Queries

+ func (q *Queries) GetStepRunDataForEngine(ctx context.Context, db DBTX, arg GetStepRunDataForEngineParams) (*GetStepRunDataForEngineRow, error)

Jul 12, 2024

Changes in this version

+ type ListActiveQueuedWorkflowVersionsRow struct

+ ConcurrencyGroupId pgtype.Text

+ ID pgtype.UUID

+ Status WorkflowRunStatus

+ TenantId pgtype.UUID

+ WorkflowVersionId pgtype.UUID

+ type PollUnresolvedFailedStepRunsRow struct

+ ID pgtype.UUID

+ TenantId pgtype.UUID

type Queries

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

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

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

Jul 10, 2024

Changes in this version

+ type ListStepRunsToReassignParams struct

+ Limit int32

+ Tenantid pgtype.UUID

+ type ListStepRunsToRequeueParams struct

+ Limit int32

+ Tenantid pgtype.UUID

type Queries

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

Jul 10, 2024

Changes in this version

+ type AcquireWorkerSemaphoreSlotAndAssignParams struct

+ Actionid string

+ StepTimeout pgtype.Text

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type AcquireWorkerSemaphoreSlotAndAssignRow struct

+ DispatcherId pgtype.UUID

+ ExhaustedRateLimitCount int32

+ RemainingSlots int32

+ StepRunId pgtype.UUID

+ WorkerId pgtype.UUID

type Queries

+ func (q *Queries) AcquireWorkerSemaphoreSlotAndAssign(ctx context.Context, db DBTX, arg AcquireWorkerSemaphoreSlotAndAssignParams) (*AcquireWorkerSemaphoreSlotAndAssignRow, error)

Jul 10, 2024

Changes in this version

type CountEventsParams

+ AdditionalMetadata []byte

+ Orderby interface{}

type CountWorkflowRunsParams

+ Orderby interface{}

Jul 6, 2024

Changes in this version

type CreateTenantParams

+ DataRetentionPeriod pgtype.Text

+ type DeleteExpiredEventsParams struct

+ Createdbefore pgtype.Timestamp

+ Limit int32

+ Tenantid pgtype.UUID

+ type DeleteExpiredEventsRow struct

+ Deleted int64

+ Remaining int32

+ Total int64

+ type DeleteExpiredWorkflowRunsParams struct

+ Createdbefore pgtype.Timestamp

+ Limit int32

+ Statuses []string

+ Tenantid pgtype.UUID

+ type DeleteExpiredWorkflowRunsRow struct

+ Deleted int64

+ Remaining int32

+ Total int64

type Queries

+ func (q *Queries) DeleteExpiredEvents(ctx context.Context, db DBTX, arg DeleteExpiredEventsParams) (*DeleteExpiredEventsRow, error)

+ func (q *Queries) DeleteExpiredWorkflowRuns(ctx context.Context, db DBTX, arg DeleteExpiredWorkflowRunsParams) (*DeleteExpiredWorkflowRunsRow, error)

type Tenant

+ DataRetentionPeriod string

Jul 1, 2024

Changes in this version

type UpdateWorkerParams

+ IsPaused pgtype.Bool

type Worker

+ IsPaused bool

Jun 26, 2024

Changes in this version

+ type ControllerPartition struct

+ CreatedAt pgtype.Timestamp

+ ID string

+ LastHeartbeat pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ type CreateTenantParams struct

+ ID pgtype.UUID

+ Name string

+ Slug string

+ type ListStepRunArchivesParams struct

+ Limit interface{}

+ Offset interface{}

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

type Queries

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

+ func (q *Queries) CreateControllerPartition(ctx context.Context, db DBTX, id string) (*ControllerPartition, error)

+ func (q *Queries) CreateTenant(ctx context.Context, db DBTX, arg CreateTenantParams) (*Tenant, error)

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

+ func (q *Queries) CreateTenantWorkerPartition(ctx context.Context, db DBTX, id string) (*TenantWorkerPartition, error)

+ func (q *Queries) DeleteControllerPartition(ctx context.Context, db DBTX, id string) (*ControllerPartition, error)

+ func (q *Queries) DeleteTenantWorkerPartition(ctx context.Context, db DBTX, id string) (*TenantWorkerPartition, error)

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

+ func (q *Queries) ListStepRunArchives(ctx context.Context, db DBTX, arg ListStepRunArchivesParams) ([]*StepRunResultArchive, error)

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

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

+ func (q *Queries) ListWebhookWorkersByPartitionId(ctx context.Context, db DBTX, workerpartitionid string) ([]*WebhookWorker, error)

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

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

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

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

+ type SecurityCheckIdent struct

+ ID pgtype.UUID

type Tenant

+ ControllerPartitionId pgtype.Text

+ WorkerPartitionId pgtype.Text

+ type TenantWorkerPartition struct

+ CreatedAt pgtype.Timestamp

+ ID string

+ LastHeartbeat pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

Jun 26, 2024

Changes in this version

type UpsertWebhookWorkerParams

+ Deleted pgtype.Bool

Jun 25, 2024

Changes in this version

+ type DeleteWebhookWorkerParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

type Queries

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

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

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

+ func (q *Queries) UpdateWorkersByName(ctx context.Context, db DBTX, arg UpdateWorkersByNameParams) ([]*Worker, error)

+ func (q *Queries) UpsertWebhookWorker(ctx context.Context, db DBTX, arg UpsertWebhookWorkerParams) (*WebhookWorker, error)

+ type UpdateWorkersByNameParams struct

+ Isactive bool

+ Name string

+ Tenantid pgtype.UUID

+ type UpsertWebhookWorkerParams struct

+ Name pgtype.Text

+ Secret pgtype.Text

+ Tenantid pgtype.UUID

+ TokenId pgtype.UUID

+ TokenValue pgtype.Text

+ Url pgtype.Text

+ type WebhookWorker struct

+ CreatedAt pgtype.Timestamp

+ Deleted bool

+ ID pgtype.UUID

+ Name string

+ Secret string

+ TenantId pgtype.UUID

+ TokenId pgtype.UUID

+ TokenValue pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ Url string

+ type WebhookWorkerWorkflow struct

+ ID pgtype.UUID

+ WebhookWorkerId pgtype.UUID

+ WorkflowId pgtype.UUID

Jun 25, 2024

Changes in this version

type Queries

+ func (q *Queries) UpsertTenantResourceLimit(ctx context.Context, db DBTX, arg UpsertTenantResourceLimitParams) (*TenantResourceLimit, error)

+ type UpsertTenantResourceLimitParams struct

+ AlarmValue pgtype.Int4

+ CustomValueMeter pgtype.Bool

+ LimitValue pgtype.Int4

+ Resource NullLimitResource

+ Tenantid pgtype.UUID

+ Window pgtype.Text

Jun 19, 2024

Changes in this version

+ type APIToken struct

+ CreatedAt pgtype.Timestamp

+ ExpiresAt pgtype.Timestamp

+ ID pgtype.UUID

+ Name pgtype.Text

+ NextAlertAt pgtype.Timestamp

+ Revoked bool

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type AcquireWorkerSemaphoreSlotParams struct

+ Actionid string

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type Action struct

+ ActionId string

+ Description pgtype.Text

+ ID pgtype.UUID

+ TenantId pgtype.UUID

+ type ActionToWorker struct

+ A pgtype.UUID

+ B pgtype.UUID

+ type AddStepParentsParams struct

+ ID pgtype.UUID

+ Jobid pgtype.UUID

+ Parents []string

+ type AddWorkflowTagParams struct

+ ID pgtype.UUID

+ Tags pgtype.UUID

+ type ArchiveStepRunResultFromStepRunParams struct

+ ID pgtype.UUID

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

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

+ StepTimeout pgtype.Text

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ Workerid pgtype.UUID

+ type AssignStepRunToWorkerRow struct

+ DispatcherId pgtype.UUID

+ ID pgtype.UUID

+ WorkerId pgtype.UUID

+ type ConcurrencyLimitStrategy string

+ const ConcurrencyLimitStrategyCANCELINPROGRESS

+ const ConcurrencyLimitStrategyDROPNEWEST

+ const ConcurrencyLimitStrategyGROUPROUNDROBIN

+ const ConcurrencyLimitStrategyQUEUENEWEST

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

+ type CountEventsParams struct

+ Keys []string

+ Search pgtype.Text

+ Statuses []string

+ TenantId pgtype.UUID

+ Workflows []string

+ type CountLogLinesParams struct

+ Levels []LogLineLevel

+ Search pgtype.Text

+ StepRunId pgtype.UUID

+ Tenantid pgtype.UUID

+ type CountRoundRobinGroupKeysParams struct

+ Status NullWorkflowRunStatus

+ Tenantid pgtype.UUID

+ Workflowid pgtype.UUID

+ type CountWorkflowRunsParams struct

+ AdditionalMetadata []byte

+ CreatedAfter pgtype.Timestamp

+ EventId pgtype.UUID

+ FinishedAfter pgtype.Timestamp

+ GroupKey pgtype.Text

+ Ids []pgtype.UUID

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

+ Statuses []string

+ TenantId pgtype.UUID

+ WorkflowId pgtype.UUID

+ WorkflowVersionId pgtype.UUID

+ type CountWorkflowRunsRoundRobinParams struct

+ GroupKey pgtype.Text

+ Status NullWorkflowRunStatus

+ Tenantid pgtype.UUID

+ Workflowid pgtype.UUID

+ type CountWorkflowsParams struct

+ EventKey pgtype.Text

+ TenantId pgtype.UUID

+ type CreateAPITokenParams struct

+ Expiresat pgtype.Timestamp

+ ID pgtype.UUID

+ Name pgtype.Text

+ TenantId pgtype.UUID

+ type CreateEventParams struct

+ Additionalmetadata []byte

+ CreatedAt pgtype.Timestamp

+ Data []byte

+ Deletedat pgtype.Timestamp

+ ID pgtype.UUID

+ Key string

+ ReplayedFromId pgtype.UUID

+ Tenantid pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type CreateGetGroupKeyRunParams struct

+ ID pgtype.UUID

+ Input []byte

+ Requeueafter pgtype.Timestamp

+ Scheduletimeoutat pgtype.Timestamp

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ type CreateJobParams struct

+ CreatedAt pgtype.Timestamp

+ Deletedat pgtype.Timestamp

+ Description string

+ ID pgtype.UUID

+ Kind NullJobKind

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

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ Workflowversionid pgtype.UUID

+ type CreateLogLineParams struct

+ CreatedAt pgtype.Timestamp

+ Level NullLogLineLevel

+ Message string

+ Metadata []byte

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type CreateSchedulesParams struct

+ Input []byte

+ Triggertimes []pgtype.Timestamp

+ Workflowrunid pgtype.UUID

+ type CreateStepParams struct

+ Actionid string

+ CreatedAt pgtype.Timestamp

+ CustomUserData []byte

+ Deletedat pgtype.Timestamp

+ ID pgtype.UUID

+ Jobid pgtype.UUID

+ Readableid string

+ Retries pgtype.Int4

+ ScheduleTimeout pgtype.Text

+ Tenantid pgtype.UUID

+ Timeout pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ type CreateStepRateLimitParams struct

+ Ratelimitkey string

+ Stepid pgtype.UUID

+ Tenantid pgtype.UUID

+ Units int32

+ type CreateStepRunEventParams struct

+ Data []byte

+ Message string

+ Reason StepRunEventReason

+ Severity StepRunEventSeverity

+ Steprunid pgtype.UUID

+ type CreateStepRunsParams struct

+ Jobrunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type CreateStreamEventParams struct

+ CreatedAt pgtype.Timestamp

+ Message []byte

+ Metadata []byte

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type CreateWorkerParams struct

+ Dispatcherid pgtype.UUID

+ MaxRuns pgtype.Int4

+ Name string

+ Tenantid pgtype.UUID

+ type CreateWorkflowConcurrencyParams struct

+ CreatedAt pgtype.Timestamp

+ Getconcurrencygroupid pgtype.UUID

+ ID pgtype.UUID

+ LimitStrategy NullConcurrencyLimitStrategy

+ MaxRuns pgtype.Int4

+ UpdatedAt pgtype.Timestamp

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

+ Additionalmetadata []byte

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ DisplayName pgtype.Text

+ ID pgtype.UUID

+ ParentId pgtype.UUID

+ ParentStepRunId 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 pgtype.UUID

+ type CreateWorkflowTriggerCronRefParams struct

+ Crontrigger string

+ Input []byte

+ 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

+ Checksum string

+ CreatedAt pgtype.Timestamp

+ Deletedat pgtype.Timestamp

+ ID pgtype.UUID

+ ScheduleTimeout pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ Version pgtype.Text

+ 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

+ AdditionalMetadata []byte

+ CreatedAt pgtype.Timestamp

+ Data []byte

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Key string

+ ReplayedFromId pgtype.UUID

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type GetChildWorkflowRunParams struct

+ ChildKey pgtype.Text

+ Childindex pgtype.Int4

+ Parentid pgtype.UUID

+ Parentsteprunid pgtype.UUID

+ type GetEventsForRangeRow struct

+ EventCount int64

+ EventHour pgtype.Interval

+ 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

+ ScheduleTimeoutAt pgtype.Timestamp

+ StartedAt pgtype.Timestamp

+ Status StepRunStatus

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ TimeoutAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ WorkerId pgtype.UUID

+ WorkflowRunId 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 GetJobRunByWorkflowRunIdAndJobIdParams struct

+ Jobid pgtype.UUID

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ type GetJobRunByWorkflowRunIdAndJobIdRow struct

+ ID pgtype.UUID

+ JobId pgtype.UUID

+ Status JobRunStatus

+ type GetLaterStepRunsForReplayParams struct

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetScheduledChildWorkflowRunParams struct

+ ChildKey pgtype.Text

+ Childindex pgtype.Int4

+ Parentid pgtype.UUID

+ Parentsteprunid pgtype.UUID

+ type GetStepRunForEngineParams struct

+ Ids []pgtype.UUID

+ TenantId pgtype.UUID

+ type GetStepRunForEngineRow struct

+ ActionId string

+ JobId pgtype.UUID

+ JobKind JobKind

+ JobName string

+ JobRunId pgtype.UUID

+ JobRunLookupData []byte

+ StepCustomUserData []byte

+ StepId pgtype.UUID

+ StepReadableId pgtype.Text

+ StepRetries int32

+ StepRun StepRun

+ StepScheduleTimeout string

+ StepTimeout pgtype.Text

+ WorkflowId pgtype.UUID

+ WorkflowName string

+ WorkflowRunId pgtype.UUID

+ WorkflowVersionId pgtype.UUID

+ type GetStepRunParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetStreamEventParams struct

+ ID int64

+ Tenantid pgtype.UUID

+ type GetTenantResourceLimitParams struct

+ Resource NullLimitResource

+ Tenantid pgtype.UUID

+ type GetTenantResourceLimitRow struct

+ AlarmValue pgtype.Int4

+ CreatedAt pgtype.Timestamp

+ CustomValueMeter bool

+ ID pgtype.UUID

+ LastRefill pgtype.Timestamp

+ LimitValue int32

+ Resource LimitResource

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ Value int32

+ Window pgtype.Text

+ type GetTenantTotalQueueMetricsParams struct

+ AdditionalMetadata []byte

+ TenantId pgtype.UUID

+ WorkflowIds []pgtype.UUID

+ type GetTenantTotalQueueMetricsRow struct

+ PendingAssignmentCount int64

+ PendingCount int64

+ RunningCount int64

+ type GetTenantWorkflowQueueMetricsParams struct

+ AdditionalMetadata []byte

+ TenantId pgtype.UUID

+ WorkflowIds []pgtype.UUID

+ type GetTenantWorkflowQueueMetricsRow struct

+ PendingAssignmentCount int64

+ PendingCount int64

+ RunningCount int64

+ WorkflowId pgtype.UUID

+ type GetWorkerForEngineParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetWorkerForEngineRow struct

+ DispatcherId pgtype.UUID

+ DispatcherLastHeartbeatAt pgtype.Timestamp

+ ID pgtype.UUID

+ IsActive bool

+ LastListenerEstablished pgtype.Timestamp

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

+ Ids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetWorkflowVersionForEngineRow struct

+ ConcurrencyLimitStrategy NullConcurrencyLimitStrategy

+ ConcurrencyMaxRuns pgtype.Int4

+ WorkflowName string

+ WorkflowVersion WorkflowVersion

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

+ Kind JobKind

+ Name string

+ TenantId pgtype.UUID

+ Timeout pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ WorkflowVersionId pgtype.UUID

+ type JobKind string

+ const JobKindDEFAULT

+ const JobKindONFAILURE

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

+ 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 pgtype.UUID

+ 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 LimitResource string

+ const LimitResourceCRON

+ const LimitResourceEVENT

+ const LimitResourceSCHEDULE

+ const LimitResourceWORKER

+ const LimitResourceWORKFLOWRUN

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

+ type LinkActionsToWorkerParams struct

+ Actionids []pgtype.UUID

+ Workerid pgtype.UUID

+ type LinkOnFailureJobParams struct

+ Jobid pgtype.UUID

+ Workflowversionid pgtype.UUID

+ type LinkServicesToWorkerParams struct

+ Services []pgtype.UUID

+ Workerid pgtype.UUID

+ type ListActiveDispatchersRow struct

+ Dispatcher Dispatcher

+ type ListActiveTickersRow struct

+ Ticker Ticker

+ type ListDispatchersRow struct

+ Dispatcher Dispatcher

+ type ListEventsByIDsParams struct

+ Ids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type ListEventsParams struct

+ AdditionalMetadata []byte

+ Keys []string

+ Limit interface{}

+ Offset interface{}

+ Orderby interface{}

+ Search pgtype.Text

+ Statuses []string

+ TenantId pgtype.UUID

+ Workflows []string

+ type ListEventsRow struct

+ Event Event

+ Failedruns int64

+ Pendingruns int64

+ Queuedruns int64

+ Runningruns int64

+ Succeededruns int64

+ type ListJobRunsForWorkflowRunRow struct

+ ID pgtype.UUID

+ JobId pgtype.UUID

+ type ListLogLinesParams struct

+ Levels []LogLineLevel

+ Limit interface{}

+ Offset interface{}

+ OrderBy pgtype.Text

+ Search pgtype.Text

+ StepRunId pgtype.UUID

+ Tenantid pgtype.UUID

+ type ListNewlyStaleTickersRow struct

+ Ticker Ticker

+ type ListNonFinalChildStepRunsParams struct

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type ListStaleDispatchersRow struct

+ Dispatcher Dispatcher

+ type ListStartableStepRunsParams struct

+ Jobrunid pgtype.UUID

+ ParentStepRunId pgtype.UUID

+ type ListStepRunEventsParams struct

+ Limit interface{}

+ Offset interface{}

+ Steprunid pgtype.UUID

+ type ListStepRunsParams struct

+ JobRunId pgtype.UUID

+ Status NullStepRunStatus

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ WorkflowRunIds []pgtype.UUID

+ type ListTickersParams struct

+ IsActive bool

+ LastHeartbeatAfter pgtype.Timestamp

+ type ListWorkersWithStepCountParams struct

+ ActionId pgtype.Text

+ Assignable pgtype.Bool

+ LastHeartbeatAfter pgtype.Timestamp

+ Tenantid pgtype.UUID

+ type ListWorkersWithStepCountRow struct

+ RunningStepRuns int64

+ Slots int64

+ Worker Worker

+ type ListWorkflowRunsParams struct

+ AdditionalMetadata []byte

+ CreatedAfter pgtype.Timestamp

+ EventId pgtype.UUID

+ FinishedAfter pgtype.Timestamp

+ GroupKey pgtype.Text

+ Ids []pgtype.UUID

+ Limit interface{}

+ Offset interface{}

+ Orderby interface{}

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

+ Statuses []string

+ TenantId pgtype.UUID

+ WorkflowId pgtype.UUID

+ WorkflowVersionId 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 ListWorkflowsForEventParams struct

+ Eventkey string

+ Tenantid pgtype.UUID

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

+ Resource NullLimitResource

+ Tenantid pgtype.UUID

+ type NullConcurrencyLimitStrategy struct

+ ConcurrencyLimitStrategy ConcurrencyLimitStrategy

+ Valid bool

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

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

+ type NullInviteLinkStatus struct

+ InviteLinkStatus InviteLinkStatus

+ Valid bool

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

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

+ type NullJobKind struct

+ JobKind JobKind

+ Valid bool

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

+ func (ns NullJobKind) 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 NullLimitResource struct

+ LimitResource LimitResource

+ Valid bool

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

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

+ type NullLogLineLevel struct

+ LogLineLevel LogLineLevel

+ Valid bool

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

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

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

+ TenantResourceLimitAlertType TenantResourceLimitAlertType

+ Valid bool

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

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

+ type NullVcsProvider struct

+ Valid bool

+ VcsProvider VcsProvider

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

+ func (ns NullVcsProvider) 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 PollCronSchedulesRow struct

+ Cron string

+ Enabled bool

+ Input []byte

+ ParentId pgtype.UUID

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ WorkflowVersionId pgtype.UUID

+ type PollExpiringTokensRow struct

+ ExpiresAt pgtype.Timestamp

+ ID pgtype.UUID

+ Name pgtype.Text

+ TenantId pgtype.UUID

+ type PollScheduledWorkflowsRow struct

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ ID pgtype.UUID

+ Input []byte

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

+ ParentWorkflowRunId pgtype.UUID

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ TriggerAt pgtype.Timestamp

+ WorkflowVersionId pgtype.UUID

+ type PollTenantAlertsRow struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ EnableExpiringTokenAlerts bool

+ EnableTenantResourceLimitAlerts bool

+ EnableWorkflowRunFailureAlerts bool

+ ID pgtype.UUID

+ LastAlertedAt pgtype.Timestamp

+ MaxFrequency string

+ PrevLastAlertedAt pgtype.Timestamp

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type PopWorkflowRunsRoundRobinParams struct

+ Maxruns int32

+ Tenantid pgtype.UUID

+ Workflowid pgtype.UUID

+ type Queries struct

+ func New() *Queries

+ func (q *Queries) AcquireWorkerSemaphoreSlot(ctx context.Context, db DBTX, arg AcquireWorkerSemaphoreSlotParams) (*WorkerSemaphoreSlot, error)

+ 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) ArchiveStepRunResultFromStepRun(ctx context.Context, db DBTX, arg ArchiveStepRunResultFromStepRunParams) (*StepRunResultArchive, error)

+ 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) AssignStepRunToWorker(ctx context.Context, db DBTX, arg AssignStepRunToWorkerParams) (*AssignStepRunToWorkerRow, error)

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

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

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

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

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

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

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

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

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

+ 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) CreateEvent(ctx context.Context, db DBTX, arg CreateEventParams) (*Event, error)

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

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

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

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

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

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

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

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

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

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

+ func (q *Queries) CreateStreamEvent(ctx context.Context, db DBTX, arg CreateStreamEventParams) (*StreamEvent, 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) CreateWorkflow(ctx context.Context, db DBTX, arg CreateWorkflowParams) (*Workflow, error)

+ func (q *Queries) CreateWorkflowConcurrency(ctx context.Context, db DBTX, arg CreateWorkflowConcurrencyParams) (*WorkflowConcurrency, 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) 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) GetChildWorkflowRun(ctx context.Context, db DBTX, arg GetChildWorkflowRunParams) (*WorkflowRun, error)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (q *Queries) GetTenantResourceLimit(ctx context.Context, db DBTX, arg GetTenantResourceLimitParams) (*GetTenantResourceLimitRow, error)

+ func (q *Queries) GetTenantTotalQueueMetrics(ctx context.Context, db DBTX, arg GetTenantTotalQueueMetricsParams) (*GetTenantTotalQueueMetricsRow, error)

+ func (q *Queries) GetTenantWorkflowQueueMetrics(ctx context.Context, db DBTX, arg GetTenantWorkflowQueueMetricsParams) ([]*GetTenantWorkflowQueueMetricsRow, error)

+ func (q *Queries) GetWorkerForEngine(ctx context.Context, db DBTX, arg GetWorkerForEngineParams) (*GetWorkerForEngineRow, 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) GetWorkflowVersionForEngine(ctx context.Context, db DBTX, arg GetWorkflowVersionForEngineParams) ([]*GetWorkflowVersionForEngineRow, error)

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

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

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

+ func (q *Queries) LinkServicesToWorker(ctx context.Context, db DBTX, arg LinkServicesToWorkerParams) 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) ListEventsByIDs(ctx context.Context, db DBTX, arg ListEventsByIDsParams) ([]*Event, error)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (q *Queries) ListWorkersWithStepCount(ctx context.Context, db DBTX, arg ListWorkersWithStepCountParams) ([]*ListWorkersWithStepCountRow, 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) ListWorkflowsForEvent(ctx context.Context, db DBTX, arg ListWorkflowsForEventParams) ([]pgtype.UUID, error)

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

+ func (q *Queries) MeterTenantResource(ctx context.Context, db DBTX, arg MeterTenantResourceParams) (*TenantResourceLimit, error)

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

+ func (q *Queries) PollExpiringTokens(ctx context.Context, db DBTX) ([]*PollExpiringTokensRow, 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) PollTenantAlerts(ctx context.Context, db DBTX, tickerid pgtype.UUID) ([]*PollTenantAlertsRow, error)

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

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

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

+ func (q *Queries) ReleaseWorkerSemaphoreSlot(ctx context.Context, db DBTX, arg ReleaseWorkerSemaphoreSlotParams) (*WorkerSemaphoreSlot, 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)

+ func (q *Queries) ResolveAllLimitsIfWindowPassed(ctx context.Context, db DBTX) ([]*ResolveAllLimitsIfWindowPassedRow, 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) ResolveWorkerSemaphoreSlots(ctx context.Context, db DBTX) (int64, error)

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

+ func (q *Queries) SelectOrInsertTenantResourceLimit(ctx context.Context, db DBTX, arg SelectOrInsertTenantResourceLimitParams) (*SelectOrInsertTenantResourceLimitRow, 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) StubWorkerSemaphoreSlots(ctx context.Context, db DBTX, arg StubWorkerSemaphoreSlotsParams) error

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

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

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

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

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

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

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

+ func (q *Queries) UpdateStepRun(ctx context.Context, db DBTX, arg UpdateStepRunParams) (*StepRun, 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) UpdateTenantAlertingSettings(ctx context.Context, db DBTX, arg UpdateTenantAlertingSettingsParams) (*TenantAlertingSettings, 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) UpdateWorkerActiveStatus(ctx context.Context, db DBTX, arg UpdateWorkerActiveStatusParams) (*Worker, error)

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

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

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

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

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

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

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

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

+ type RateLimit struct

+ Key string

+ LastRefill pgtype.Timestamp

+ LimitValue int32

+ TenantId pgtype.UUID

+ Value int32

+ Window string

+ type RefreshTimeoutByParams struct

+ IncrementTimeoutBy pgtype.Text

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type ReleaseWorkerSemaphoreSlotParams struct

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type ReplayStepRunResetLaterStepRunsParams struct

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type ResolveAllLimitsIfWindowPassedRow struct

+ AlarmValue pgtype.Int4

+ CreatedAt pgtype.Timestamp

+ CustomValueMeter bool

+ ID pgtype.UUID

+ LastRefill pgtype.Timestamp

+ LimitValue int32

+ Resource LimitResource

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ Value int32

+ Window pgtype.Text

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

+ CreatedAt pgtype.Timestamp

+ ID pgtype.UUID

+ TenantId pgtype.UUID

+ TopicArn string

+ UpdatedAt pgtype.Timestamp

+ type SelectOrInsertTenantResourceLimitParams struct

+ AlarmValue pgtype.Int4

+ CustomValueMeter pgtype.Bool

+ LimitValue pgtype.Int4

+ Resource NullLimitResource

+ Tenantid pgtype.UUID

+ Window pgtype.Text

+ type SelectOrInsertTenantResourceLimitRow struct

+ AlarmValue pgtype.Int4

+ CreatedAt pgtype.Timestamp

+ CustomValueMeter bool

+ ID pgtype.UUID

+ LastRefill pgtype.Timestamp

+ LimitValue int32

+ Resource LimitResource

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ Value int32

+ Window pgtype.Text

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

+ ActionId string

+ CreatedAt pgtype.Timestamp

+ CustomUserData []byte

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ JobId pgtype.UUID

+ ReadableId pgtype.Text

+ Retries int32

+ ScheduleTimeout string

+ TenantId pgtype.UUID

+ Timeout pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ type StepOrder struct

+ A pgtype.UUID

+ B pgtype.UUID

+ type StepRateLimit struct

+ RateLimitKey string

+ StepId pgtype.UUID

+ TenantId pgtype.UUID

+ Units int32

+ type StepRun struct

+ CallerFiles []byte

+ CancelledAt pgtype.Timestamp

+ CancelledError pgtype.Text

+ CancelledReason pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ GitRepoBranch pgtype.Text

+ ID pgtype.UUID

+ Input []byte

+ InputSchema []byte

+ JobRunId pgtype.UUID

+ Order int64

+ Output []byte

+ RequeueAfter pgtype.Timestamp

+ RetryCount int32

+ ScheduleTimeoutAt pgtype.Timestamp

+ SemaphoreReleased bool

+ StartedAt pgtype.Timestamp

+ Status StepRunStatus

+ StepId pgtype.UUID

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ TimeoutAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ WorkerId pgtype.UUID

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

+ const StepRunEventReasonREQUEUEDNOWORKER

+ const StepRunEventReasonREQUEUEDRATELIMIT

+ const StepRunEventReasonRETRIEDBYUSER

+ const StepRunEventReasonRETRYING

+ const StepRunEventReasonSCHEDULINGTIMEDOUT

+ const StepRunEventReasonSLOTRELEASED

+ const StepRunEventReasonSTARTED

+ const StepRunEventReasonTIMEDOUT

+ const StepRunEventReasonTIMEOUTREFRESHED

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

+ type StepRunEventSeverity string

+ const StepRunEventSeverityCRITICAL

+ const StepRunEventSeverityINFO

+ const StepRunEventSeverityWARNING

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

+ type StepRunOrder struct

+ A pgtype.UUID

+ B pgtype.UUID

+ 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 StepRunStatus string

+ const StepRunStatusASSIGNED

+ const StepRunStatusCANCELLED

+ const StepRunStatusFAILED

+ const StepRunStatusPENDING

+ const StepRunStatusPENDINGASSIGNMENT

+ const StepRunStatusRUNNING

+ const StepRunStatusSUCCEEDED

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

+ type StreamEvent struct

+ CreatedAt pgtype.Timestamp

+ ID int64

+ Message []byte

+ Metadata []byte

+ StepRunId pgtype.UUID

+ TenantId pgtype.UUID

+ type StubWorkerSemaphoreSlotsParams struct

+ MaxRuns pgtype.Int4

+ Workerid pgtype.UUID

+ type Tenant struct

+ AlertMemberEmails bool

+ AnalyticsOptOut bool

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Name string

+ Slug string

+ UpdatedAt pgtype.Timestamp

+ 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

+ EnableExpiringTokenAlerts bool

+ EnableTenantResourceLimitAlerts bool

+ EnableWorkflowRunFailureAlerts bool

+ ID pgtype.UUID

+ LastAlertedAt pgtype.Timestamp

+ MaxFrequency string

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

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

+ AlarmValue pgtype.Int4

+ CreatedAt pgtype.Timestamp

+ CustomValueMeter bool

+ ID pgtype.UUID

+ LastRefill pgtype.Timestamp

+ LimitValue int32

+ Resource LimitResource

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ Value int32

+ Window pgtype.Text

+ type TenantResourceLimitAlert struct

+ AlertType TenantResourceLimitAlertType

+ CreatedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Limit int32

+ Resource LimitResource

+ ResourceLimitId pgtype.UUID

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ Value int32

+ type TenantResourceLimitAlertType string

+ const TenantResourceLimitAlertTypeAlarm

+ const TenantResourceLimitAlertTypeExhausted

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

+ type TenantVcsProvider struct

+ Config []byte

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ VcsProvider VcsProvider

+ type Ticker struct

+ CreatedAt pgtype.Timestamp

+ ID pgtype.UUID

+ IsActive bool

+ LastHeartbeatAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ type UnlinkStepRunFromWorkerParams struct

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type UpdateDispatcherParams struct

+ ID pgtype.UUID

+ LastHeartbeatAt pgtype.Timestamp

+ 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

+ ScheduleTimeoutAt pgtype.Timestamp

+ StartedAt pgtype.Timestamp

+ Status NullStepRunStatus

+ Tenantid pgtype.UUID

+ type UpdateJobRunLookupDataWithStepRunParams struct

+ Jsondata []byte

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type UpdateJobRunStatusParams struct

+ ID pgtype.UUID

+ Status JobRunStatus

+ Tenantid pgtype.UUID

+ type UpdateManyWorkflowRunParams struct

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ Ids []pgtype.UUID

+ StartedAt pgtype.Timestamp

+ Status NullWorkflowRunStatus

+ Tenantid pgtype.UUID

+ type UpdateStepRateLimitsParams struct

+ Stepid pgtype.UUID

+ Tenantid pgtype.UUID

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

+ CancelledAt pgtype.Timestamp

+ CancelledReason pgtype.Text

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Input []byte

+ Output []byte

+ RequeueAfter pgtype.Timestamp

+ Rerun pgtype.Bool

+ RetryCount pgtype.Int4

+ ScheduleTimeoutAt pgtype.Timestamp

+ SemaphoreReleased pgtype.Bool

+ StartedAt pgtype.Timestamp

+ Status NullStepRunStatus

+ Tenantid pgtype.UUID

+ type UpdateTenantAlertingSettingsParams struct

+ LastAlertedAt pgtype.Timestamp

+ TenantId pgtype.UUID

+ type UpdateTickerParams struct

+ ID pgtype.UUID

+ LastHeartbeatAt pgtype.Timestamp

+ type UpdateWorkerActiveStatusParams struct

+ ID pgtype.UUID

+ Isactive bool

+ LastListenerEstablished pgtype.Timestamp

+ type UpdateWorkerParams struct

+ DispatcherId pgtype.UUID

+ ID pgtype.UUID

+ IsActive pgtype.Bool

+ LastHeartbeatAt pgtype.Timestamp

+ MaxRuns pgtype.Int4

+ type UpdateWorkflowRunGroupKeyParams struct

+ Groupkeyrunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type UpdateWorkflowRunParams struct

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ StartedAt pgtype.Timestamp

+ Status NullWorkflowRunStatus

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

+ Key string

+ Limit int32

+ Tenantid pgtype.UUID

+ Window pgtype.Text

+ type UpsertServiceParams struct

+ Name string

+ 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 []byte

+ CreatedAt pgtype.Timestamp

+ ExpiresAt pgtype.Timestamp

+ ID pgtype.UUID

+ Provider string

+ ProviderUserId string

+ RefreshToken []byte

+ 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 VcsProvider string

+ const VcsProviderGITHUB

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

+ type Worker struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ DispatcherId pgtype.UUID

+ ID pgtype.UUID

+ IsActive bool

+ LastHeartbeatAt pgtype.Timestamp

+ LastListenerEstablished pgtype.Timestamp

+ MaxRuns int32

+ Name string

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type WorkerSemaphore struct

+ Slots int32

+ WorkerId pgtype.UUID

+ type WorkerSemaphoreSlot struct

+ ID pgtype.UUID

+ StepRunId pgtype.UUID

+ WorkerId pgtype.UUID

+ type Workflow struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ Description pgtype.Text

+ ID pgtype.UUID

+ Name string

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type WorkflowConcurrency struct

+ CreatedAt pgtype.Timestamp

+ GetConcurrencyGroupId pgtype.UUID

+ ID pgtype.UUID

+ LimitStrategy ConcurrencyLimitStrategy

+ MaxRuns int32

+ UpdatedAt pgtype.Timestamp

+ WorkflowVersionId pgtype.UUID

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

+ AdditionalMetadata []byte

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ ConcurrencyGroupId pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ DisplayName pgtype.Text

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ GitRepoBranch pgtype.Text

+ ID pgtype.UUID

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

+ StartedAt pgtype.Timestamp

+ Status WorkflowRunStatus

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ WorkflowVersionId pgtype.UUID

+ type WorkflowRunStatus string

+ const WorkflowRunStatusFAILED

+ const WorkflowRunStatusPENDING

+ const WorkflowRunStatusQUEUED

+ 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

+ Input []byte

+ ParentId pgtype.UUID

+ ScheduledId pgtype.UUID

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type WorkflowRunsMetricsCountParams struct

+ AdditionalMetadata []byte

+ 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

+ 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

+ Enabled bool

+ Input []byte

+ ParentId pgtype.UUID

+ TickerId pgtype.UUID

+ type WorkflowTriggerEventRef struct

+ EventKey string

+ ParentId pgtype.UUID

+ type WorkflowTriggerScheduledRef struct

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ ID pgtype.UUID

+ Input []byte

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

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

+ Checksum string

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ OnFailureJobId pgtype.UUID

+ Order int64

+ ScheduleTimeout string

+ UpdatedAt pgtype.Timestamp

+ Version pgtype.Text

+ WorkflowId pgtype.UUID