Documentation
¶
Index ¶
- Variables
- type APIToken
- type AcquireOrExtendLeasesParams
- type Action
- type ActionToWorker
- type AddStepParentsParams
- type AddWorkflowTagParams
- type ArchiveStepRunResultFromStepRunParams
- type AssignGetGroupKeyRunToTickerParams
- type AssignGetGroupKeyRunToTickerRow
- type AssignGetGroupKeyRunToWorkerParams
- type AssignGetGroupKeyRunToWorkerRow
- type BulkCancelStepRunParams
- type BulkCreateStepRunEventParams
- type BulkCreateWorkflowRunEventParams
- type BulkFailStepRunParams
- type BulkFinishStepRunParams
- type BulkStartStepRunParams
- type BulkUpdateRateLimitsParams
- type CheckWorkerParams
- type CleanupInternalQueueItemsParams
- type CleanupQueueItemsParams
- type CleanupRetryQueueItemsParams
- type CleanupTimeoutQueueItemsParams
- type ClearEventPayloadDataParams
- type ClearJobRunLookupDataParams
- type ClearStepRunPayloadDataParams
- type ConcurrencyLimitStrategy
- type ControllerPartition
- type CountCronWorkflowsParams
- type CountEventsParams
- type CountLogLinesParams
- type CountRateLimitsParams
- type CountRoundRobinGroupKeysParams
- type CountScheduledWorkflowsParams
- type CountWorkflowRunsParams
- type CountWorkflowRunsRoundRobinParams
- type CountWorkflowsParams
- type CreateAPITokenParams
- type CreateEventKeysParams
- type CreateEventParams
- type CreateEventsParams
- type CreateGetGroupKeyRunParams
- type CreateGetGroupKeyRunsParams
- type CreateInternalQueueItemsBulkParams
- type CreateJobParams
- type CreateJobRunLookupDataParams
- type CreateJobRunLookupDatasParams
- type CreateJobRunsParams
- type CreateLogLineParams
- type CreateManyJobRunsParams
- type CreateManyJobRunsRow
- type CreateMultipleWorkflowRunStickyStatesParams
- type CreateQueueItemParams
- type CreateQueueItemsBulkParams
- type CreateRetryQueueItemParams
- type CreateSchedulesParams
- type CreateStepExpressionsParams
- type CreateStepParams
- type CreateStepRateLimitParams
- type CreateStepRunEventParams
- type CreateStepRunExpressionEvalIntsParams
- type CreateStepRunExpressionEvalStrsParams
- type CreateStepRunParams
- type CreateStepRunsForJobRunIdsParams
- type CreateStepRunsParams
- type CreateStreamEventParams
- type CreateTenantParams
- type CreateTimeoutQueueItemParams
- type CreateUniqueInternalQueueItemsBulkParams
- type CreateWebhookWorkerParams
- type CreateWorkerAssignEventsParams
- type CreateWorkerParams
- type CreateWorkflowConcurrencyParams
- type CreateWorkflowParams
- type CreateWorkflowRunDedupeParams
- type CreateWorkflowRunParams
- type CreateWorkflowRunStickyStateParams
- type CreateWorkflowRunTriggeredByParams
- type CreateWorkflowRunTriggeredBysParams
- type CreateWorkflowRunsParams
- type CreateWorkflowTriggerCronRefForWorkflowParams
- type CreateWorkflowTriggerCronRefParams
- type CreateWorkflowTriggerEventRefParams
- type CreateWorkflowTriggerScheduledRefForWorkflowParams
- type CreateWorkflowTriggerScheduledRefParams
- type CreateWorkflowTriggersParams
- type CreateWorkflowVersionParams
- type DBTX
- type DeleteOldWorkerAssignEventsParams
- type DeleteOldWorkersParams
- type Dispatcher
- type Event
- type EventKey
- type GetChildWorkflowRunParams
- type GetChildWorkflowRunsByIndexParams
- type GetChildWorkflowRunsByKeyParams
- type GetDesiredLabelsRow
- type GetEventsForRangeRow
- type GetFailureDetailsParams
- type GetFailureDetailsRow
- type GetFinalizedStepRunsRow
- type GetGroupKeyRun
- type GetGroupKeyRunForEngineParams
- type GetGroupKeyRunForEngineRow
- type GetJobRunByWorkflowRunIdAndJobIdParams
- type GetJobRunByWorkflowRunIdAndJobIdRow
- type GetJobRunsByWorkflowRunIdParams
- type GetJobRunsByWorkflowRunIdRow
- type GetLatestWorkflowVersionForWorkflowsParams
- type GetLeasesToAcquireParams
- type GetMinMaxProcessedInternalQueueItemsRow
- type GetMinMaxProcessedQueueItemsRow
- type GetMinMaxProcessedRetryQueueItemsRow
- type GetMinMaxProcessedTimeoutQueueItemsRow
- type GetMinUnprocessedQueueItemIdParams
- type GetQueuedCountsRow
- type GetScheduledChildWorkflowRunParams
- type GetStepRunBulkDataForEngineParams
- type GetStepRunBulkDataForEngineRow
- type GetStepRunDataForEngineParams
- type GetStepRunDataForEngineRow
- type GetStepRunForEngineParams
- type GetStepRunForEngineRow
- type GetStepRunMetaParams
- type GetStepRunMetaRow
- type GetStepRunsForJobRunsWithOutputParams
- type GetStepRunsForJobRunsWithOutputRow
- type GetStepsForJobsParams
- type GetStepsForJobsRow
- type GetStreamEventMetaParams
- type GetStreamEventMetaRow
- type GetStreamEventParams
- type GetTenantResourceLimitParams
- type GetTenantResourceLimitRow
- type GetTenantTotalQueueMetricsParams
- type GetTenantTotalQueueMetricsRow
- type GetTenantWorkflowQueueMetricsParams
- type GetTenantWorkflowQueueMetricsRow
- type GetWorkerActionsByWorkerIdParams
- type GetWorkerByIdRow
- type GetWorkerByWebhookIdParams
- type GetWorkerDispatcherActionsParams
- type GetWorkerDispatcherActionsRow
- type GetWorkerForEngineParams
- type GetWorkerForEngineRow
- type GetWorkerLabelsRow
- type GetWorkflowByIdRow
- type GetWorkflowByNameParams
- type GetWorkflowRunAdditionalMetaParams
- type GetWorkflowRunAdditionalMetaRow
- type GetWorkflowRunByIdParams
- type GetWorkflowRunByIdRow
- type GetWorkflowRunByIdsParams
- type GetWorkflowRunByIdsRow
- type GetWorkflowRunParams
- type GetWorkflowRunRow
- type GetWorkflowRunStickyStateForUpdateParams
- type GetWorkflowRunTriggerParams
- type GetWorkflowVersionByIdRow
- type GetWorkflowVersionForEngineParams
- type GetWorkflowVersionForEngineRow
- type GetWorkflowWorkerCountParams
- type GetWorkflowWorkerCountRow
- type GetWorkflowsByNamesParams
- type HandleWorkflowUnpausedParams
- type HardDeleteWebhookWorkerParams
- type HasActiveWorkersForActionIdParams
- type InsertWebhookWorkerRequestParams
- type InternalQueue
- type InternalQueueItem
- type InviteLinkStatus
- type Job
- type JobKind
- type JobRun
- type JobRunLookupData
- type JobRunStatus
- type Lease
- type LeaseKind
- type LimitResource
- type LinkActionsToWorkerParams
- type LinkOnFailureJobParams
- type LinkServicesToWorkerParams
- type ListActionsForAvailableWorkersRow
- type ListActionsForWorkersParams
- type ListActionsForWorkersRow
- type ListActiveDispatchersRow
- type ListActiveQueuedWorkflowVersionsRow
- type ListActiveTickersRow
- type ListActiveWorkersRow
- type ListAllAvailableSlotsForWorkersRow
- type ListAllWorkerActionsParams
- type ListAvailableSlotsForWorkersParams
- type ListAvailableSlotsForWorkersRow
- type ListChildWorkflowRunCountsRow
- type ListChildWorkflowRunIdsParams
- type ListCronWorkflowsParams
- type ListCronWorkflowsRow
- type ListDispatcherIdsForWorkersParams
- type ListDispatcherIdsForWorkersRow
- type ListDispatchersRow
- type ListEventsByIDsParams
- type ListEventsParams
- type ListEventsRow
- type ListInternalQueueItemsParams
- type ListJobRunsForWorkflowRunFullParams
- type ListJobRunsForWorkflowRunFullRow
- type ListJobRunsForWorkflowRunRow
- type ListLogLinesParams
- type ListManyWorkerLabelsRow
- type ListNewlyStaleTickersRow
- type ListQueueItemsBatchResults
- type ListQueueItemsForQueueParams
- type ListQueueItemsForQueueRow
- type ListQueueItemsParams
- type ListRateLimitsForStepsParams
- type ListRateLimitsForTenantNoMutateParams
- type ListRateLimitsForTenantNoMutateRow
- type ListRateLimitsForTenantWithMutateRow
- type ListRecentAssignedEventsForWorkerParams
- type ListRecentAssignedEventsForWorkerRow
- type ListScheduledWorkflowsParams
- type ListScheduledWorkflowsRow
- type ListSemaphoreSlotsWithStateForWorkerParams
- type ListSemaphoreSlotsWithStateForWorkerRow
- type ListStaleDispatchersRow
- type ListStepRunArchivesParams
- type ListStepRunEventsByWorkflowRunIdParams
- type ListStepRunEventsParams
- type ListStepRunsParams
- type ListStepRunsToCancelParams
- type ListStepRunsToReassignParams
- type ListStepRunsToReassignRow
- type ListStepRunsToRetryRow
- type ListStepsForJobRow
- type ListTickersParams
- type ListWorkerLabelsRow
- type ListWorkersWithSlotCountParams
- type ListWorkersWithSlotCountRow
- type ListWorkflowRunsParams
- type ListWorkflowRunsRow
- type ListWorkflowsForEventParams
- type ListWorkflowsLatestRunsParams
- type ListWorkflowsLatestRunsRow
- type ListWorkflowsParams
- type ListWorkflowsRow
- type LogLine
- type LogLineLevel
- type ManualReleaseSemaphoreParams
- type MeterTenantResourceParams
- type MoveCronTriggerToNewWorkflowTriggersParams
- type MoveScheduledTriggerToNewWorkflowTriggersParams
- type NullConcurrencyLimitStrategy
- type NullInternalQueue
- type NullInviteLinkStatus
- type NullJobKind
- type NullJobRunStatus
- type NullLeaseKind
- type NullLimitResource
- type NullLogLineLevel
- type NullStepExpressionKind
- type NullStepRateLimitKind
- type NullStepRunEventReason
- type NullStepRunEventSeverity
- type NullStepRunStatus
- type NullStickyStrategy
- type NullTenantMemberRole
- type NullTenantResourceLimitAlertType
- type NullVcsProvider
- type NullWebhookWorkerRequestMethod
- type NullWorkerLabelComparator
- type NullWorkerSDKS
- type NullWorkerType
- type NullWorkflowKind
- type NullWorkflowRunStatus
- type NullWorkflowTriggerCronRefMethods
- type NullWorkflowTriggerScheduledRefMethods
- type PollCronSchedulesRow
- type PollExpiringTokensRow
- type PollScheduledWorkflowsRow
- type PollTenantAlertsRow
- type PollUnresolvedFailedStepRunsRow
- type PopTimeoutQueueItemsParams
- type PopWorkflowRunsRoundRobinParams
- type Queries
- func (q *Queries) AcquireOrExtendLeases(ctx context.Context, db DBTX, arg AcquireOrExtendLeasesParams) ([]*Lease, 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) BulkCancelStepRun(ctx context.Context, db DBTX, arg BulkCancelStepRunParams) error
- func (q *Queries) BulkCreateStepRunEvent(ctx context.Context, db DBTX, arg BulkCreateStepRunEventParams) error
- func (q *Queries) BulkCreateWorkflowRunEvent(ctx context.Context, db DBTX, arg BulkCreateWorkflowRunEventParams) 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) 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) BulkStartStepRun(ctx context.Context, db DBTX, arg BulkStartStepRunParams) error
- func (q *Queries) BulkUpdateRateLimits(ctx context.Context, db DBTX, arg BulkUpdateRateLimitsParams) ([]*RateLimit, error)
- func (q *Queries) CheckWorker(ctx context.Context, db DBTX, arg CheckWorkerParams) (pgtype.UUID, error)
- func (q *Queries) CleanupInternalQueueItems(ctx context.Context, db DBTX, arg CleanupInternalQueueItemsParams) error
- func (q *Queries) CleanupQueueItems(ctx context.Context, db DBTX, arg CleanupQueueItemsParams) error
- func (q *Queries) CleanupRetryQueueItems(ctx context.Context, db DBTX, arg CleanupRetryQueueItemsParams) error
- func (q *Queries) CleanupStreamEvents(ctx context.Context, db DBTX) error
- func (q *Queries) CleanupTimeoutQueueItems(ctx context.Context, db DBTX, arg CleanupTimeoutQueueItemsParams) error
- 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) ControllerPartitionHeartbeat(ctx context.Context, db DBTX, controllerpartitionid string) (*ControllerPartition, error)
- func (q *Queries) CountCronWorkflows(ctx context.Context, db DBTX, arg CountCronWorkflowsParams) (int64, 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) CountRateLimits(ctx context.Context, db DBTX, arg CountRateLimitsParams) (int64, error)
- func (q *Queries) CountRoundRobinGroupKeys(ctx context.Context, db DBTX, arg CountRoundRobinGroupKeysParams) (int64, error)
- func (q *Queries) CountScheduledWorkflows(ctx context.Context, db DBTX, arg CountScheduledWorkflowsParams) (int64, error)
- func (q *Queries) CountStepRunArchives(ctx context.Context, db DBTX, steprunid pgtype.UUID) (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) CreateControllerPartition(ctx context.Context, db DBTX, name pgtype.Text) (*ControllerPartition, 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) CreateEventKeys(ctx context.Context, db DBTX, arg CreateEventKeysParams) error
- func (q *Queries) CreateEvents(ctx context.Context, db DBTX, arg []CreateEventsParams) (int64, error)
- func (q *Queries) CreateGetGroupKeyRun(ctx context.Context, db DBTX, arg CreateGetGroupKeyRunParams) (*GetGroupKeyRun, error)
- func (q *Queries) CreateGetGroupKeyRuns(ctx context.Context, db DBTX, arg []CreateGetGroupKeyRunsParams) (int64, error)
- func (q *Queries) CreateInternalQueueItemsBulk(ctx context.Context, db DBTX, arg CreateInternalQueueItemsBulkParams) 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) CreateJobRunLookupDatas(ctx context.Context, db DBTX, arg CreateJobRunLookupDatasParams) ([]*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) 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) CreateQueueItem(ctx context.Context, db DBTX, arg CreateQueueItemParams) error
- func (q *Queries) CreateQueueItemsBulk(ctx context.Context, db DBTX, arg []CreateQueueItemsBulkParams) (int64, error)
- func (q *Queries) CreateRetryQueueItem(ctx context.Context, db DBTX, arg CreateRetryQueueItemParams) error
- func (q *Queries) CreateSchedulerPartition(ctx context.Context, db DBTX, name pgtype.Text) (*SchedulerPartition, 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) CreateStepExpressions(ctx context.Context, db DBTX, arg CreateStepExpressionsParams) error
- func (q *Queries) CreateStepRateLimit(ctx context.Context, db DBTX, arg CreateStepRateLimitParams) (*StepRateLimit, error)
- func (q *Queries) CreateStepRun(ctx context.Context, db DBTX, arg CreateStepRunParams) (pgtype.UUID, error)
- func (q *Queries) CreateStepRunEvent(ctx context.Context, db DBTX, arg CreateStepRunEventParams) 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) CreateStepRuns(ctx context.Context, db DBTX, arg []CreateStepRunsParams) (int64, error)
- func (q *Queries) CreateStepRunsForJobRunIds(ctx context.Context, db DBTX, arg CreateStepRunsForJobRunIdsParams) ([]pgtype.UUID, error)
- func (q *Queries) CreateStreamEvent(ctx context.Context, db DBTX, arg CreateStreamEventParams) (*StreamEvent, 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, name pgtype.Text) (*TenantWorkerPartition, error)
- func (q *Queries) CreateTicker(ctx context.Context, db DBTX, id pgtype.UUID) (*Ticker, error)
- func (q *Queries) CreateTimeoutQueueItem(ctx context.Context, db DBTX, arg CreateTimeoutQueueItemParams) error
- func (q *Queries) CreateUniqueInternalQueueItemsBulk(ctx context.Context, db DBTX, arg CreateUniqueInternalQueueItemsBulkParams) error
- func (q *Queries) CreateWebhookWorker(ctx context.Context, db DBTX, arg CreateWebhookWorkerParams) (*WebhookWorker, error)
- func (q *Queries) CreateWorker(ctx context.Context, db DBTX, arg CreateWorkerParams) (*Worker, error)
- func (q *Queries) CreateWorkerAssignEvents(ctx context.Context, db DBTX, arg CreateWorkerAssignEventsParams) 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) 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) CreateWorkflowRunTriggeredBy(ctx context.Context, db DBTX, arg CreateWorkflowRunTriggeredByParams) (*WorkflowRunTriggeredBy, 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) CreateWorkflowTriggerCronRef(ctx context.Context, db DBTX, arg CreateWorkflowTriggerCronRefParams) (*WorkflowTriggerCronRef, error)
- func (q *Queries) CreateWorkflowTriggerCronRefForWorkflow(ctx context.Context, db DBTX, ...) (*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) CreateWorkflowTriggerScheduledRefForWorkflow(ctx context.Context, db DBTX, ...) (*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) DeactivateTicker(ctx context.Context, db DBTX, id pgtype.UUID) (*Ticker, error)
- func (q *Queries) DeleteControllerPartition(ctx context.Context, db DBTX, id string) (*ControllerPartition, error)
- func (q *Queries) DeleteDispatcher(ctx context.Context, db DBTX, id pgtype.UUID) (*Dispatcher, error)
- func (q *Queries) DeleteOldWorkerAssignEvents(ctx context.Context, db DBTX, arg DeleteOldWorkerAssignEventsParams) (bool, error)
- func (q *Queries) DeleteOldWorkers(ctx context.Context, db DBTX, arg DeleteOldWorkersParams) (bool, error)
- func (q *Queries) DeleteScheduledWorkflow(ctx context.Context, db DBTX, scheduleid pgtype.UUID) error
- func (q *Queries) DeleteSchedulerPartition(ctx context.Context, db DBTX, id string) (*SchedulerPartition, error)
- func (q *Queries) DeleteTenantWorkerPartition(ctx context.Context, db DBTX, id string) (*TenantWorkerPartition, error)
- func (q *Queries) DeleteWorker(ctx context.Context, db DBTX, id pgtype.UUID) (*Worker, error)
- func (q *Queries) DeleteWorkflowTriggerCronRef(ctx context.Context, db DBTX, id pgtype.UUID) 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) 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) GetDesiredLabels(ctx context.Context, db DBTX, stepids []pgtype.UUID) ([]*GetDesiredLabelsRow, 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) GetFailureDetails(ctx context.Context, db DBTX, arg GetFailureDetailsParams) ([]*GetFailureDetailsRow, error)
- func (q *Queries) GetFinalizedStepRuns(ctx context.Context, db DBTX, steprunids []pgtype.UUID) ([]*GetFinalizedStepRunsRow, error)
- func (q *Queries) GetGroupKeyRunForEngine(ctx context.Context, db DBTX, arg GetGroupKeyRunForEngineParams) ([]*GetGroupKeyRunForEngineRow, error)
- func (q *Queries) GetInsertedEvents(ctx context.Context, db DBTX, ids []pgtype.UUID) ([]*Event, error)
- func (q *Queries) GetJobRunByWorkflowRunIdAndJobId(ctx context.Context, db DBTX, arg GetJobRunByWorkflowRunIdAndJobIdParams) (*GetJobRunByWorkflowRunIdAndJobIdRow, error)
- func (q *Queries) GetJobRunsByWorkflowRunId(ctx context.Context, db DBTX, arg GetJobRunsByWorkflowRunIdParams) ([]*GetJobRunsByWorkflowRunIdRow, error)
- func (q *Queries) GetLaterStepRuns(ctx context.Context, db DBTX, steprunid pgtype.UUID) ([]*StepRun, 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) GetMemberEmailGroup(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]string, error)
- func (q *Queries) GetMinMaxProcessedInternalQueueItems(ctx context.Context, db DBTX, tenantid pgtype.UUID) (*GetMinMaxProcessedInternalQueueItemsRow, error)
- func (q *Queries) GetMinMaxProcessedQueueItems(ctx context.Context, db DBTX, tenantid pgtype.UUID) (*GetMinMaxProcessedQueueItemsRow, error)
- func (q *Queries) GetMinMaxProcessedRetryQueueItems(ctx context.Context, db DBTX, tenantid pgtype.UUID) (*GetMinMaxProcessedRetryQueueItemsRow, error)
- func (q *Queries) GetMinMaxProcessedTimeoutQueueItems(ctx context.Context, db DBTX, tenantid pgtype.UUID) (*GetMinMaxProcessedTimeoutQueueItemsRow, error)
- func (q *Queries) GetMinUnprocessedQueueItemId(ctx context.Context, db DBTX, arg GetMinUnprocessedQueueItemIdParams) (int64, error)
- func (q *Queries) GetQueuedCounts(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]*GetQueuedCountsRow, error)
- func (q *Queries) GetScheduledChildWorkflowRun(ctx context.Context, db DBTX, arg GetScheduledChildWorkflowRunParams) (*WorkflowTriggerScheduledRef, error)
- func (q *Queries) GetSecurityCheckIdent(ctx context.Context, db DBTX) (pgtype.UUID, error)
- func (q *Queries) GetSlackWebhooks(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]*SlackAppWebhook, error)
- func (q *Queries) GetStepDesiredWorkerLabels(ctx context.Context, db DBTX, stepid pgtype.UUID) ([]byte, error)
- func (q *Queries) GetStepExpressions(ctx context.Context, db DBTX, stepid pgtype.UUID) ([]*StepExpression, error)
- func (q *Queries) GetStepRun(ctx context.Context, db DBTX, id pgtype.UUID) (*StepRun, error)
- func (q *Queries) GetStepRunBulkDataForEngine(ctx context.Context, db DBTX, arg GetStepRunBulkDataForEngineParams) ([]*GetStepRunBulkDataForEngineRow, error)
- func (q *Queries) GetStepRunDataForEngine(ctx context.Context, db DBTX, arg GetStepRunDataForEngineParams) (*GetStepRunDataForEngineRow, error)
- func (q *Queries) GetStepRunForEngine(ctx context.Context, db DBTX, arg GetStepRunForEngineParams) ([]*GetStepRunForEngineRow, error)
- func (q *Queries) GetStepRunMeta(ctx context.Context, db DBTX, arg GetStepRunMetaParams) (*GetStepRunMetaRow, error)
- func (q *Queries) GetStepRunsForJobRunsWithOutput(ctx context.Context, db DBTX, arg GetStepRunsForJobRunsWithOutputParams) ([]*GetStepRunsForJobRunsWithOutputRow, error)
- func (q *Queries) GetStepsForJobs(ctx context.Context, db DBTX, arg GetStepsForJobsParams) ([]*GetStepsForJobsRow, error)
- func (q *Queries) GetStepsForWorkflowVersion(ctx context.Context, db DBTX, workflowversionids []pgtype.UUID) ([]*Step, error)
- func (q *Queries) GetStreamEvent(ctx context.Context, db DBTX, arg GetStreamEventParams) (*StreamEvent, error)
- func (q *Queries) GetStreamEventMeta(ctx context.Context, db DBTX, arg GetStreamEventMetaParams) (*GetStreamEventMetaRow, 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) GetWorkerActionsByWorkerId(ctx context.Context, db DBTX, arg GetWorkerActionsByWorkerIdParams) ([]pgtype.Text, error)
- 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) GetWorkerDispatcherActions(ctx context.Context, db DBTX, arg GetWorkerDispatcherActionsParams) ([]*GetWorkerDispatcherActionsRow, error)
- func (q *Queries) GetWorkerForEngine(ctx context.Context, db DBTX, arg GetWorkerForEngineParams) (*GetWorkerForEngineRow, error)
- func (q *Queries) GetWorkerLabels(ctx context.Context, db DBTX, workerid pgtype.UUID) ([]*GetWorkerLabelsRow, error)
- func (q *Queries) GetWorkflowById(ctx context.Context, db DBTX, id pgtype.UUID) (*GetWorkflowByIdRow, 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) GetWorkflowRunAdditionalMeta(ctx context.Context, db DBTX, arg GetWorkflowRunAdditionalMetaParams) (*GetWorkflowRunAdditionalMetaRow, error)
- func (q *Queries) GetWorkflowRunById(ctx context.Context, db DBTX, arg GetWorkflowRunByIdParams) (*GetWorkflowRunByIdRow, error)
- func (q *Queries) GetWorkflowRunByIds(ctx context.Context, db DBTX, arg GetWorkflowRunByIdsParams) ([]*GetWorkflowRunByIdsRow, 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) GetWorkflowRunTrigger(ctx context.Context, db DBTX, arg GetWorkflowRunTriggerParams) (*WorkflowRunTriggeredBy, error)
- func (q *Queries) GetWorkflowRunsInsertedInThisTxn(ctx context.Context, db DBTX) ([]*WorkflowRun, 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) GetWorkflowVersionForEngine(ctx context.Context, db DBTX, arg GetWorkflowVersionForEngineParams) ([]*GetWorkflowVersionForEngineRow, error)
- func (q *Queries) GetWorkflowVersionScheduleTriggerRefs(ctx context.Context, db DBTX, workflowversionid pgtype.UUID) ([]*WorkflowTriggerScheduledRef, error)
- func (q *Queries) GetWorkflowWorkerCount(ctx context.Context, db DBTX, arg GetWorkflowWorkerCountParams) (*GetWorkflowWorkerCountRow, error)
- func (q *Queries) GetWorkflowsByNames(ctx context.Context, db DBTX, arg GetWorkflowsByNamesParams) ([]*Workflow, error)
- func (q *Queries) HandleWorkflowUnpaused(ctx context.Context, db DBTX, arg HandleWorkflowUnpausedParams) error
- func (q *Queries) HardDeleteWebhookWorker(ctx context.Context, db DBTX, arg HardDeleteWebhookWorkerParams) error
- func (q *Queries) HasActiveWorkersForActionId(ctx context.Context, db DBTX, arg HasActiveWorkersForActionIdParams) (int64, error)
- func (q *Queries) Health(ctx context.Context, db DBTX) ([]pgtype.UUID, error)
- func (q *Queries) InsertWebhookWorkerRequest(ctx context.Context, db DBTX, arg InsertWebhookWorkerRequestParams) 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, steprunids []pgtype.UUID) 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) ListActiveDispatchers(ctx context.Context, db DBTX) ([]*ListActiveDispatchersRow, error)
- func (q *Queries) ListActiveQueuedWorkflowVersions(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]*ListActiveQueuedWorkflowVersionsRow, error)
- func (q *Queries) ListActiveTickers(ctx context.Context, db DBTX) ([]*ListActiveTickersRow, error)
- func (q *Queries) ListActiveWebhookWorkers(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]*WebhookWorker, 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) ListAvailableSlotsForWorkers(ctx context.Context, db DBTX, arg ListAvailableSlotsForWorkersParams) ([]*ListAvailableSlotsForWorkersRow, 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) ListCronWorkflows(ctx context.Context, db DBTX, arg ListCronWorkflowsParams) ([]*ListCronWorkflowsRow, error)
- func (q *Queries) ListDispatcherIdsForWorkers(ctx context.Context, db DBTX, arg ListDispatcherIdsForWorkersParams) ([]*ListDispatcherIdsForWorkersRow, error)
- func (q *Queries) ListDispatchers(ctx context.Context, db DBTX) ([]*ListDispatchersRow, error)
- func (q *Queries) ListEventKeys(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]string, 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) 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) ListJobRunsForWorkflowRun(ctx context.Context, db DBTX, workflowrunid pgtype.UUID) ([]*ListJobRunsForWorkflowRunRow, error)
- func (q *Queries) ListJobRunsForWorkflowRunFull(ctx context.Context, db DBTX, arg ListJobRunsForWorkflowRunFullParams) ([]*ListJobRunsForWorkflowRunFullRow, error)
- func (q *Queries) ListLogLines(ctx context.Context, db DBTX, arg ListLogLinesParams) ([]*LogLine, error)
- func (q *Queries) ListManyWorkerLabels(ctx context.Context, db DBTX, workerids []pgtype.UUID) ([]*ListManyWorkerLabelsRow, error)
- func (q *Queries) ListNewlyStaleTickers(ctx context.Context, db DBTX) ([]*ListNewlyStaleTickersRow, error)
- func (q *Queries) ListNonFinalChildStepRuns(ctx context.Context, db DBTX, steprunid pgtype.UUID) ([]*StepRun, error)
- func (q *Queries) ListPausedWorkflows(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]pgtype.UUID, error)
- func (q *Queries) ListQueueItems(ctx context.Context, db DBTX, arg []ListQueueItemsParams) *ListQueueItemsBatchResults
- func (q *Queries) ListQueueItemsForQueue(ctx context.Context, db DBTX, arg ListQueueItemsForQueueParams) ([]*ListQueueItemsForQueueRow, error)
- 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) 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) ListRecentAssignedEventsForWorker(ctx context.Context, db DBTX, arg ListRecentAssignedEventsForWorkerParams) ([]*ListRecentAssignedEventsForWorkerRow, error)
- func (q *Queries) ListScheduledWorkflows(ctx context.Context, db DBTX, arg ListScheduledWorkflowsParams) ([]*ListScheduledWorkflowsRow, error)
- func (q *Queries) ListSemaphoreSlotsWithStateForWorker(ctx context.Context, db DBTX, arg ListSemaphoreSlotsWithStateForWorkerParams) ([]*ListSemaphoreSlotsWithStateForWorkerRow, error)
- func (q *Queries) ListStaleDispatchers(ctx context.Context, db DBTX) ([]*ListStaleDispatchersRow, error)
- 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)
- func (q *Queries) ListStepRunArchives(ctx context.Context, db DBTX, arg ListStepRunArchivesParams) ([]*StepRunResultArchive, error)
- func (q *Queries) ListStepRunEvents(ctx context.Context, db DBTX, arg ListStepRunEventsParams) ([]*StepRunEvent, error)
- func (q *Queries) ListStepRunEventsByWorkflowRunId(ctx context.Context, db DBTX, arg ListStepRunEventsByWorkflowRunIdParams) ([]*StepRunEvent, error)
- func (q *Queries) ListStepRunExpressionEvals(ctx context.Context, db DBTX, steprunids []pgtype.UUID) ([]*StepRunExpressionEval, error)
- func (q *Queries) ListStepRuns(ctx context.Context, db DBTX, arg ListStepRunsParams) ([]pgtype.UUID, error)
- func (q *Queries) ListStepRunsToCancel(ctx context.Context, db DBTX, arg ListStepRunsToCancelParams) ([]pgtype.UUID, error)
- func (q *Queries) ListStepRunsToReassign(ctx context.Context, db DBTX, arg ListStepRunsToReassignParams) ([]*ListStepRunsToReassignRow, error)
- func (q *Queries) ListStepRunsToRetry(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]*ListStepRunsToRetryRow, error)
- func (q *Queries) ListStepRunsToTimeout(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]pgtype.UUID, error)
- func (q *Queries) ListStepsForJob(ctx context.Context, db DBTX, jobrunid pgtype.UUID) ([]*ListStepsForJobRow, 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) ListTenantsByControllerPartitionId(ctx context.Context, db DBTX, controllerpartitionid string) ([]*Tenant, error)
- func (q *Queries) ListTenantsBySchedulerPartitionId(ctx context.Context, db DBTX, schedulerpartitionid string) ([]*Tenant, error)
- func (q *Queries) ListTenantsByTenantWorkerPartitionId(ctx context.Context, db DBTX, workerpartitionid string) ([]*Tenant, error)
- func (q *Queries) ListTickers(ctx context.Context, db DBTX, arg ListTickersParams) ([]*Ticker, error)
- func (q *Queries) ListWebhookWorkerRequests(ctx context.Context, db DBTX, webhookworkerid pgtype.UUID) ([]*WebhookWorkerRequest, error)
- func (q *Queries) ListWebhookWorkersByPartitionId(ctx context.Context, db DBTX, workerpartitionid string) ([]*WebhookWorker, error)
- func (q *Queries) ListWorkerLabels(ctx context.Context, db DBTX, workerid pgtype.UUID) ([]*ListWorkerLabelsRow, error)
- func (q *Queries) ListWorkersWithSlotCount(ctx context.Context, db DBTX, arg ListWorkersWithSlotCountParams) ([]*ListWorkersWithSlotCountRow, error)
- func (q *Queries) ListWorkflowRunEventsByWorkflowRunId(ctx context.Context, db DBTX, workflowrunid pgtype.UUID) ([]*StepRunEvent, 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) ManualReleaseSemaphore(ctx context.Context, db DBTX, arg ManualReleaseSemaphoreParams) error
- func (q *Queries) MarkInternalQueueItemsProcessed(ctx context.Context, db DBTX, ids []int64) error
- func (q *Queries) MeterTenantResource(ctx context.Context, db DBTX, arg MeterTenantResourceParams) (*TenantResourceLimit, error)
- func (q *Queries) MoveCronTriggerToNewWorkflowTriggers(ctx context.Context, db DBTX, arg MoveCronTriggerToNewWorkflowTriggersParams) error
- func (q *Queries) MoveScheduledTriggerToNewWorkflowTriggers(ctx context.Context, db DBTX, ...) 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) 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) PollUnresolvedFailedStepRuns(ctx context.Context, db DBTX) ([]*PollUnresolvedFailedStepRunsRow, error)
- func (q *Queries) PopTimeoutQueueItems(ctx context.Context, db DBTX, arg PopTimeoutQueueItemsParams) ([]pgtype.UUID, error)
- func (q *Queries) PopWorkflowRunsRoundRobin(ctx context.Context, db DBTX, arg PopWorkflowRunsRoundRobinParams) ([]*WorkflowRun, error)
- func (q *Queries) QueueStepRun(ctx context.Context, db DBTX, arg QueueStepRunParams) 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) RebalanceAllControllerPartitions(ctx context.Context, db DBTX) error
- func (q *Queries) RebalanceAllSchedulerPartitions(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) RebalanceInactiveSchedulerPartitions(ctx context.Context, db DBTX) error
- func (q *Queries) RebalanceInactiveTenantWorkerPartitions(ctx context.Context, db DBTX) error
- func (q *Queries) RefreshTimeoutBy(ctx context.Context, db DBTX, arg RefreshTimeoutByParams) (pgtype.Timestamp, error)
- func (q *Queries) ReleaseLeases(ctx context.Context, db DBTX, leaseids []int64) ([]*Lease, error)
- func (q *Queries) RemoveTimeoutQueueItem(ctx context.Context, db DBTX, arg RemoveTimeoutQueueItemParams) error
- func (q *Queries) RemoveTimeoutQueueItems(ctx context.Context, db DBTX, steprunids []pgtype.UUID) error
- func (q *Queries) ReplayStepRunResetJobRun(ctx context.Context, db DBTX, jobrunid pgtype.UUID) (*JobRun, error)
- func (q *Queries) ReplayStepRunResetStepRuns(ctx context.Context, db DBTX, arg ReplayStepRunResetStepRunsParams) ([]*StepRun, error)
- func (q *Queries) ReplayStepRunResetWorkflowRun(ctx context.Context, db DBTX, workflowrunid pgtype.UUID) (*WorkflowRun, error)
- func (q *Queries) ReplayWorkflowRunResetGetGroupKeyRun(ctx context.Context, db DBTX, workflowrunid pgtype.UUID) (*GetGroupKeyRun, 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) ResolveAllLimitsIfWindowPassed(ctx context.Context, db DBTX) ([]*ResolveAllLimitsIfWindowPassedRow, error)
- func (q *Queries) ResolveJobRunStatus(ctx context.Context, db DBTX, steprunids []pgtype.UUID) ([]pgtype.UUID, error)
- func (q *Queries) ResolveLaterStepRuns(ctx context.Context, db DBTX, arg ResolveLaterStepRunsParams) ([]*StepRun, error)
- func (q *Queries) ResolveWorkflowRunStatus(ctx context.Context, db DBTX, arg ResolveWorkflowRunStatusParams) ([]*ResolveWorkflowRunStatusRow, error)
- func (q *Queries) SchedulerPartitionHeartbeat(ctx context.Context, db DBTX, schedulerpartitionid string) (*SchedulerPartition, 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) SoftDeleteExpiredEvents(ctx context.Context, db DBTX, arg SoftDeleteExpiredEventsParams) (bool, error)
- func (q *Queries) SoftDeleteExpiredWorkflowRunsWithDependencies(ctx context.Context, db DBTX, ...) (bool, error)
- func (q *Queries) SoftDeleteWebhookWorker(ctx context.Context, db DBTX, arg SoftDeleteWebhookWorkerParams) error
- func (q *Queries) SoftDeleteWorkflow(ctx context.Context, db DBTX, id pgtype.UUID) (*Workflow, 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) UpdateScheduledWorkflow(ctx context.Context, db DBTX, arg UpdateScheduledWorkflowParams) 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) UpdateStepRunUnsetWorkerId(ctx context.Context, db DBTX, arg UpdateStepRunUnsetWorkerIdParams) (*UpdateStepRunUnsetWorkerIdRow, error)
- func (q *Queries) UpdateStepRunUnsetWorkerIdBulk(ctx context.Context, db DBTX, steprunids []pgtype.UUID) error
- func (q *Queries) UpdateStepRunsToAssigned(ctx context.Context, db DBTX, arg UpdateStepRunsToAssignedParams) ([]*UpdateStepRunsToAssignedRow, 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) UpdateWebhookWorkerToken(ctx context.Context, db DBTX, arg UpdateWebhookWorkerTokenParams) (*WebhookWorker, 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) UpdateWorkerHeartbeat(ctx context.Context, db DBTX, arg UpdateWorkerHeartbeatParams) (*Worker, error)
- func (q *Queries) UpdateWorkersByWebhookId(ctx context.Context, db DBTX, arg UpdateWorkersByWebhookIdParams) ([]*Worker, error)
- func (q *Queries) UpdateWorkflow(ctx context.Context, db DBTX, arg UpdateWorkflowParams) (*Workflow, error)
- func (q *Queries) UpdateWorkflowRun(ctx context.Context, db DBTX, arg UpdateWorkflowRunParams) (*WorkflowRun, 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)
- func (q *Queries) UpdateWorkflowRunStickyState(ctx context.Context, db DBTX, arg UpdateWorkflowRunStickyStateParams) error
- func (q *Queries) UpsertAction(ctx context.Context, db DBTX, arg UpsertActionParams) (*Action, error)
- func (q *Queries) UpsertDesiredWorkerLabel(ctx context.Context, db DBTX, arg UpsertDesiredWorkerLabelParams) (*StepDesiredWorkerLabel, error)
- func (q *Queries) UpsertJobRunLookupData(ctx context.Context, db DBTX, arg UpsertJobRunLookupDataParams) error
- func (q *Queries) UpsertQueue(ctx context.Context, db DBTX, arg UpsertQueueParams) error
- func (q *Queries) UpsertRateLimit(ctx context.Context, db DBTX, arg UpsertRateLimitParams) (*RateLimit, error)
- func (q *Queries) UpsertRateLimitsBulk(ctx context.Context, db DBTX, arg UpsertRateLimitsBulkParams) error
- func (q *Queries) UpsertService(ctx context.Context, db DBTX, arg UpsertServiceParams) (*Service, error)
- func (q *Queries) UpsertTenantResourceLimit(ctx context.Context, db DBTX, arg UpsertTenantResourceLimitParams) (*TenantResourceLimit, error)
- func (q *Queries) UpsertWorkerLabel(ctx context.Context, db DBTX, arg UpsertWorkerLabelParams) (*WorkerLabel, error)
- func (q *Queries) UpsertWorkflowTag(ctx context.Context, db DBTX, arg UpsertWorkflowTagParams) error
- func (q *Queries) ValidatesAsJson(ctx context.Context, db DBTX, input []byte) error
- func (q *Queries) VerifiedStepRunTenantIds(ctx context.Context, db DBTX, arg VerifiedStepRunTenantIdsParams) ([]pgtype.UUID, error)
- func (q *Queries) WorkerPartitionHeartbeat(ctx context.Context, db DBTX, workerpartitionid string) (*TenantWorkerPartition, error)
- func (q *Queries) WorkflowRunsMetricsCount(ctx context.Context, db DBTX, arg WorkflowRunsMetricsCountParams) (*WorkflowRunsMetricsCountRow, error)
- type Queue
- type QueueItem
- type QueueStepRunBulkNoInputParams
- type QueueStepRunBulkWithInputParams
- type QueueStepRunParams
- type RateLimit
- type RefreshTimeoutByParams
- type RemoveTimeoutQueueItemParams
- type ReplayStepRunResetStepRunsParams
- type ResetStepRunsByIdsParams
- type ResolveAllLimitsIfWindowPassedRow
- type ResolveLaterStepRunsParams
- type ResolveWorkflowRunStatusParams
- type ResolveWorkflowRunStatusRow
- type RetryQueueItem
- type SNSIntegration
- type SchedulerPartition
- type SecurityCheckIdent
- type SelectOrInsertTenantResourceLimitParams
- type SelectOrInsertTenantResourceLimitRow
- type SemaphoreQueueItem
- type Service
- type ServiceToWorker
- type SetDispatchersInactiveRow
- type SetTickersInactiveRow
- type SlackAppWebhook
- type SoftDeleteExpiredEventsParams
- type SoftDeleteExpiredWorkflowRunsWithDependenciesParams
- type SoftDeleteWebhookWorkerParams
- type Step
- type StepDesiredWorkerLabel
- type StepExpression
- type StepExpressionKind
- type StepOrder
- type StepRateLimit
- type StepRateLimitKind
- type StepRun
- type StepRunEvent
- type StepRunEventReason
- type StepRunEventSeverity
- type StepRunExpressionEval
- type StepRunOrder
- type StepRunResultArchive
- type StepRunStatus
- type StickyStrategy
- type StreamEvent
- type Tenant
- type TenantAlertEmailGroup
- type TenantAlertingSettings
- type TenantInviteLink
- type TenantMember
- type TenantMemberRole
- type TenantResourceLimit
- type TenantResourceLimitAlert
- type TenantResourceLimitAlertType
- type TenantVcsProvider
- type TenantWorkerPartition
- type Ticker
- type TimeoutQueueItem
- type UpdateDispatcherParams
- type UpdateGetGroupKeyRunParams
- type UpdateJobRunLookupDataWithStepRunParams
- type UpdateJobRunStatusParams
- type UpdateManyWorkflowRunParams
- type UpdateScheduledWorkflowParams
- type UpdateStepRunInputSchemaParams
- type UpdateStepRunOverridesDataParams
- type UpdateStepRunUnsetWorkerIdParams
- type UpdateStepRunUnsetWorkerIdRow
- type UpdateStepRunsToAssignedParams
- type UpdateStepRunsToAssignedRow
- type UpdateTenantAlertingSettingsParams
- type UpdateTickerParams
- type UpdateWebhookWorkerTokenParams
- type UpdateWorkerActiveStatusParams
- type UpdateWorkerHeartbeatParams
- type UpdateWorkerParams
- type UpdateWorkersByWebhookIdParams
- type UpdateWorkflowParams
- type UpdateWorkflowRunGroupKeyFromExprParams
- type UpdateWorkflowRunGroupKeyFromRunParams
- type UpdateWorkflowRunParams
- type UpdateWorkflowRunStickyStateParams
- type UpsertActionParams
- type UpsertDesiredWorkerLabelParams
- type UpsertJobRunLookupDataParams
- type UpsertQueueParams
- type UpsertRateLimitParams
- type UpsertRateLimitsBulkParams
- type UpsertServiceParams
- type UpsertTenantResourceLimitParams
- type UpsertWorkerLabelParams
- type UpsertWorkflowTagParams
- type User
- type UserOAuth
- type UserPassword
- type UserSession
- type VcsProvider
- type VerifiedStepRunTenantIdsParams
- type WebhookWorker
- type WebhookWorkerRequest
- type WebhookWorkerRequestMethod
- type WebhookWorkerWorkflow
- type Worker
- type WorkerAssignEvent
- type WorkerLabel
- type WorkerLabelComparator
- type WorkerSDKS
- type WorkerType
- type Workflow
- type WorkflowConcurrency
- type WorkflowKind
- type WorkflowRun
- type WorkflowRunDedupe
- type WorkflowRunStatus
- type WorkflowRunStickyState
- type WorkflowRunTriggeredBy
- type WorkflowRunsMetricsCountParams
- type WorkflowRunsMetricsCountRow
- type WorkflowTag
- type WorkflowToWorkflowTag
- type WorkflowTriggerCronRef
- type WorkflowTriggerCronRefMethods
- type WorkflowTriggerEventRef
- type WorkflowTriggerScheduledRef
- type WorkflowTriggerScheduledRefMethods
- type WorkflowTriggers
- type WorkflowVersion
Constants ¶
This section is empty.
Variables ¶
var (
ErrBatchAlreadyClosed = errors.New("batch already closed")
)
Functions ¶
This section is empty.
Types ¶
type APIToken ¶
type APIToken struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
ExpiresAt pgtype.Timestamp `json:"expiresAt"`
Revoked bool `json:"revoked"`
Name pgtype.Text `json:"name"`
TenantId pgtype.UUID `json:"tenantId"`
NextAlertAt pgtype.Timestamp `json:"nextAlertAt"`
Internal bool `json:"internal"`
}
type AcquireOrExtendLeasesParams ¶ added in v0.50.0
type ActionToWorker ¶
type AddStepParentsParams ¶
type AddWorkflowTagParams ¶
type BulkCancelStepRunParams ¶ added in v0.44.5
type BulkCreateStepRunEventParams ¶ added in v0.42.0
type BulkCreateWorkflowRunEventParams ¶ added in v0.45.0
type BulkFailStepRunParams ¶ added in v0.44.5
type BulkFinishStepRunParams ¶ added in v0.44.5
type BulkStartStepRunParams ¶ added in v0.44.5
type BulkUpdateRateLimitsParams ¶ added in v0.42.0
type CheckWorkerParams ¶ added in v0.40.0
type CleanupInternalQueueItemsParams ¶ added in v0.44.0
type CleanupQueueItemsParams ¶ added in v0.43.2
type CleanupRetryQueueItemsParams ¶ added in v0.52.0
type CleanupTimeoutQueueItemsParams ¶ added in v0.44.5
type ClearEventPayloadDataParams ¶ added in v0.39.0
type ClearJobRunLookupDataParams ¶ added in v0.39.0
type ClearStepRunPayloadDataParams ¶ added in v0.39.0
type ConcurrencyLimitStrategy ¶
type ConcurrencyLimitStrategy string
const ( ConcurrencyLimitStrategyCANCELINPROGRESS ConcurrencyLimitStrategy = "CANCEL_IN_PROGRESS" ConcurrencyLimitStrategyDROPNEWEST ConcurrencyLimitStrategy = "DROP_NEWEST" ConcurrencyLimitStrategyQUEUENEWEST ConcurrencyLimitStrategy = "QUEUE_NEWEST" ConcurrencyLimitStrategyGROUPROUNDROBIN ConcurrencyLimitStrategy = "GROUP_ROUND_ROBIN" )
func (*ConcurrencyLimitStrategy) Scan ¶
func (e *ConcurrencyLimitStrategy) Scan(src interface{}) error
type ControllerPartition ¶ added in v0.34.2
type CountCronWorkflowsParams ¶ added in v0.52.0
type CountEventsParams ¶
type CountEventsParams struct {
TenantId pgtype.UUID `json:"tenantId"`
EventIds []pgtype.UUID `json:"event_ids"`
Keys []string `json:"keys"`
AdditionalMetadata []byte `json:"additionalMetadata"`
Workflows []string `json:"workflows"`
Search pgtype.Text `json:"search"`
Statuses []string `json:"statuses"`
Orderby interface{} `json:"orderby"`
}
type CountLogLinesParams ¶
type CountRateLimitsParams ¶ added in v0.47.0
type CountRoundRobinGroupKeysParams ¶
type CountRoundRobinGroupKeysParams struct {
Tenantid pgtype.UUID `json:"tenantid"`
Status NullWorkflowRunStatus `json:"status"`
Workflowid pgtype.UUID `json:"workflowid"`
}
type CountScheduledWorkflowsParams ¶ added in v0.51.0
type CountScheduledWorkflowsParams struct {
Tenantid pgtype.UUID `json:"tenantid"`
Scheduleid pgtype.UUID `json:"scheduleid"`
Workflowid pgtype.UUID `json:"workflowid"`
Parentworkflowrunid pgtype.UUID `json:"parentworkflowrunid"`
Parentsteprunid pgtype.UUID `json:"parentsteprunid"`
AdditionalMetadata []byte `json:"additionalMetadata"`
Statuses []string `json:"statuses"`
Includescheduled bool `json:"includescheduled"`
}
type CountWorkflowRunsParams ¶
type CountWorkflowRunsParams struct {
TenantId pgtype.UUID `json:"tenantId"`
EventId pgtype.UUID `json:"eventId"`
WorkflowVersionId pgtype.UUID `json:"workflowVersionId"`
Kinds []string `json:"kinds"`
WorkflowId pgtype.UUID `json:"workflowId"`
Ids []pgtype.UUID `json:"ids"`
AdditionalMetadata []byte `json:"additionalMetadata"`
ParentId pgtype.UUID `json:"parentId"`
ParentStepRunId pgtype.UUID `json:"parentStepRunId"`
GroupKey pgtype.Text `json:"groupKey"`
Statuses []string `json:"statuses"`
CreatedAfter pgtype.Timestamp `json:"createdAfter"`
CreatedBefore pgtype.Timestamp `json:"createdBefore"`
FinishedAfter pgtype.Timestamp `json:"finishedAfter"`
FinishedBefore pgtype.Timestamp `json:"finishedBefore"`
Orderby interface{} `json:"orderby"`
}
type CountWorkflowsParams ¶
type CreateAPITokenParams ¶
type CreateEventKeysParams ¶ added in v0.49.3
type CreateEventParams ¶
type CreateEventParams struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
Deletedat pgtype.Timestamp `json:"deletedat"`
Key string `json:"key"`
Tenantid pgtype.UUID `json:"tenantid"`
ReplayedFromId pgtype.UUID `json:"replayedFromId"`
Data []byte `json:"data"`
Additionalmetadata []byte `json:"additionalmetadata"`
}
type CreateEventsParams ¶ added in v0.46.0
type CreateEventsParams struct {
ID pgtype.UUID `json:"id"`
Key string `json:"key"`
TenantId pgtype.UUID `json:"tenantId"`
ReplayedFromId pgtype.UUID `json:"replayedFromId"`
Data []byte `json:"data"`
AdditionalMetadata []byte `json:"additionalMetadata"`
InsertOrder pgtype.Int4 `json:"insertOrder"`
}
type CreateGetGroupKeyRunsParams ¶ added in v0.50.0
type CreateGetGroupKeyRunsParams struct {
ID pgtype.UUID `json:"id"`
TenantId pgtype.UUID `json:"tenantId"`
WorkflowRunId pgtype.UUID `json:"workflowRunId"`
Input []byte `json:"input"`
RequeueAfter pgtype.Timestamp `json:"requeueAfter"`
ScheduleTimeoutAt pgtype.Timestamp `json:"scheduleTimeoutAt"`
Status StepRunStatus `json:"status"`
}
type CreateInternalQueueItemsBulkParams ¶ added in v0.44.0
type CreateJobParams ¶
type CreateJobParams struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
Deletedat pgtype.Timestamp `json:"deletedat"`
Tenantid pgtype.UUID `json:"tenantid"`
Workflowversionid pgtype.UUID `json:"workflowversionid"`
Name string `json:"name"`
Description string `json:"description"`
Timeout string `json:"timeout"`
Kind NullJobKind `json:"kind"`
}
type CreateJobRunLookupDatasParams ¶ added in v0.50.0
type CreateJobRunsParams ¶
type CreateLogLineParams ¶
type CreateManyJobRunsParams ¶ added in v0.50.0
type CreateManyJobRunsRow ¶ added in v0.50.0
type CreateMultipleWorkflowRunStickyStatesParams ¶ added in v0.50.0
type CreateQueueItemParams ¶ added in v0.42.0
type CreateQueueItemParams struct {
StepRunId pgtype.UUID `json:"stepRunId"`
StepId pgtype.UUID `json:"stepId"`
ActionId pgtype.Text `json:"actionId"`
ScheduleTimeoutAt pgtype.Timestamp `json:"scheduleTimeoutAt"`
StepTimeout pgtype.Text `json:"stepTimeout"`
Priority pgtype.Int4 `json:"priority"`
Tenantid pgtype.UUID `json:"tenantid"`
Queue string `json:"queue"`
Sticky NullStickyStrategy `json:"sticky"`
DesiredWorkerId pgtype.UUID `json:"desiredWorkerId"`
}
type CreateQueueItemsBulkParams ¶ added in v0.50.0
type CreateQueueItemsBulkParams struct {
StepRunId pgtype.UUID `json:"stepRunId"`
StepId pgtype.UUID `json:"stepId"`
ActionId pgtype.Text `json:"actionId"`
ScheduleTimeoutAt pgtype.Timestamp `json:"scheduleTimeoutAt"`
StepTimeout pgtype.Text `json:"stepTimeout"`
Priority int32 `json:"priority"`
IsQueued bool `json:"isQueued"`
TenantId pgtype.UUID `json:"tenantId"`
Queue string `json:"queue"`
Sticky NullStickyStrategy `json:"sticky"`
DesiredWorkerId pgtype.UUID `json:"desiredWorkerId"`
}
type CreateRetryQueueItemParams ¶ added in v0.52.0
type CreateSchedulesParams ¶
type CreateStepExpressionsParams ¶ added in v0.47.0
type CreateStepParams ¶
type CreateStepParams struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
Deletedat pgtype.Timestamp `json:"deletedat"`
Readableid string `json:"readableid"`
Tenantid pgtype.UUID `json:"tenantid"`
Jobid pgtype.UUID `json:"jobid"`
Actionid string `json:"actionid"`
Timeout pgtype.Text `json:"timeout"`
CustomUserData []byte `json:"customUserData"`
Retries pgtype.Int4 `json:"retries"`
ScheduleTimeout pgtype.Text `json:"scheduleTimeout"`
RetryBackoffFactor pgtype.Float8 `json:"retryBackoffFactor"`
RetryMaxBackoff pgtype.Int4 `json:"retryMaxBackoff"`
}
type CreateStepRunEventParams ¶
type CreateStepRunEventParams struct {
Steprunid pgtype.UUID `json:"steprunid"`
Jobrunid pgtype.UUID `json:"jobrunid"`
Reason StepRunEventReason `json:"reason"`
Severity StepRunEventSeverity `json:"severity"`
Message string `json:"message"`
Data []byte `json:"data"`
}
type CreateStepRunExpressionEvalIntsParams ¶ added in v0.47.0
type CreateStepRunExpressionEvalStrsParams ¶ added in v0.47.0
type CreateStepRunParams ¶ added in v0.42.0
type CreateStepRunsForJobRunIdsParams ¶ added in v0.50.0
type CreateStepRunsParams ¶
type CreateStepRunsParams struct {
ID pgtype.UUID `json:"id"`
TenantId pgtype.UUID `json:"tenantId"`
JobRunId pgtype.UUID `json:"jobRunId"`
StepId pgtype.UUID `json:"stepId"`
Status StepRunStatus `json:"status"`
RequeueAfter pgtype.Timestamp `json:"requeueAfter"`
Queue string `json:"queue"`
Priority pgtype.Int4 `json:"priority"`
}
type CreateStreamEventParams ¶
type CreateTenantParams ¶ added in v0.34.2
type CreateTimeoutQueueItemParams ¶ added in v0.44.5
type CreateUniqueInternalQueueItemsBulkParams ¶ added in v0.44.0
type CreateUniqueInternalQueueItemsBulkParams struct {
Queue InternalQueue `json:"queue"`
Tenantid pgtype.UUID `json:"tenantid"`
Datas [][]byte `json:"datas"`
Uniquekeys []string `json:"uniquekeys"`
}
type CreateWebhookWorkerParams ¶ added in v0.42.13
type CreateWorkerAssignEventsParams ¶ added in v0.44.0
type CreateWorkerParams ¶
type CreateWorkerParams struct {
Tenantid pgtype.UUID `json:"tenantid"`
Name string `json:"name"`
Dispatcherid pgtype.UUID `json:"dispatcherid"`
MaxRuns pgtype.Int4 `json:"maxRuns"`
WebhookId pgtype.UUID `json:"webhookId"`
Type NullWorkerType `json:"type"`
SdkVersion pgtype.Text `json:"sdkVersion"`
Language NullWorkerSDKS `json:"language"`
LanguageVersion pgtype.Text `json:"languageVersion"`
Os pgtype.Text `json:"os"`
RuntimeExtra pgtype.Text `json:"runtimeExtra"`
}
type CreateWorkflowConcurrencyParams ¶
type CreateWorkflowConcurrencyParams struct {
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
Workflowversionid pgtype.UUID `json:"workflowversionid"`
GetConcurrencyGroupId pgtype.UUID `json:"getConcurrencyGroupId"`
MaxRuns pgtype.Int4 `json:"maxRuns"`
LimitStrategy NullConcurrencyLimitStrategy `json:"limitStrategy"`
ConcurrencyGroupExpression pgtype.Text `json:"concurrencyGroupExpression"`
}
type CreateWorkflowParams ¶
type CreateWorkflowParams struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
Deletedat pgtype.Timestamp `json:"deletedat"`
Tenantid pgtype.UUID `json:"tenantid"`
Name string `json:"name"`
Description string `json:"description"`
}
type CreateWorkflowRunDedupeParams ¶ added in v0.40.0
type CreateWorkflowRunParams ¶
type CreateWorkflowRunParams struct {
ID pgtype.UUID `json:"id"`
DisplayName pgtype.Text `json:"displayName"`
Tenantid pgtype.UUID `json:"tenantid"`
Workflowversionid pgtype.UUID `json:"workflowversionid"`
ChildIndex pgtype.Int4 `json:"childIndex"`
ChildKey pgtype.Text `json:"childKey"`
ParentId pgtype.UUID `json:"parentId"`
ParentStepRunId pgtype.UUID `json:"parentStepRunId"`
Additionalmetadata []byte `json:"additionalmetadata"`
Priority pgtype.Int4 `json:"priority"`
}
type CreateWorkflowRunStickyStateParams ¶ added in v0.40.0
type CreateWorkflowRunTriggeredByParams ¶
type CreateWorkflowRunTriggeredByParams struct {
Tenantid pgtype.UUID `json:"tenantid"`
Workflowrunid pgtype.UUID `json:"workflowrunid"`
EventId pgtype.UUID `json:"eventId"`
CronParentId pgtype.UUID `json:"cronParentId"`
CronSchedule pgtype.Text `json:"cronSchedule"`
CronName pgtype.Text `json:"cronName"`
ScheduledId pgtype.UUID `json:"scheduledId"`
}
type CreateWorkflowRunTriggeredBysParams ¶ added in v0.50.0
type CreateWorkflowRunTriggeredBysParams struct {
ID pgtype.UUID `json:"id"`
TenantId pgtype.UUID `json:"tenantId"`
ParentId pgtype.UUID `json:"parentId"`
EventId pgtype.UUID `json:"eventId"`
CronParentId pgtype.UUID `json:"cronParentId"`
CronSchedule pgtype.Text `json:"cronSchedule"`
CronName pgtype.Text `json:"cronName"`
ScheduledId pgtype.UUID `json:"scheduledId"`
}
type CreateWorkflowRunsParams ¶ added in v0.50.0
type CreateWorkflowRunsParams struct {
ID pgtype.UUID `json:"id"`
DisplayName pgtype.Text `json:"displayName"`
TenantId pgtype.UUID `json:"tenantId"`
WorkflowVersionId pgtype.UUID `json:"workflowVersionId"`
Status WorkflowRunStatus `json:"status"`
ChildIndex pgtype.Int4 `json:"childIndex"`
ChildKey pgtype.Text `json:"childKey"`
ParentId pgtype.UUID `json:"parentId"`
ParentStepRunId pgtype.UUID `json:"parentStepRunId"`
AdditionalMetadata []byte `json:"additionalMetadata"`
Priority pgtype.Int4 `json:"priority"`
InsertOrder pgtype.Int4 `json:"insertOrder"`
}
type CreateWorkflowTriggerCronRefForWorkflowParams ¶ added in v0.52.0
type CreateWorkflowTriggerCronRefForWorkflowParams struct {
Crontrigger string `json:"crontrigger"`
Name pgtype.Text `json:"name"`
Input []byte `json:"input"`
AdditionalMetadata []byte `json:"additionalMetadata"`
Method NullWorkflowTriggerCronRefMethods `json:"method"`
Workflowid pgtype.UUID `json:"workflowid"`
}
type CreateWorkflowTriggerCronRefParams ¶
type CreateWorkflowTriggerCronRefParams struct {
Workflowtriggersid pgtype.UUID `json:"workflowtriggersid"`
Crontrigger string `json:"crontrigger"`
Name pgtype.Text `json:"name"`
Input []byte `json:"input"`
AdditionalMetadata []byte `json:"additionalMetadata"`
Method NullWorkflowTriggerCronRefMethods `json:"method"`
}
type CreateWorkflowTriggerScheduledRefForWorkflowParams ¶ added in v0.52.0
type CreateWorkflowTriggerScheduledRefForWorkflowParams struct {
Scheduledtrigger pgtype.Timestamp `json:"scheduledtrigger"`
Input []byte `json:"input"`
Additionalmetadata []byte `json:"additionalmetadata"`
Method NullWorkflowTriggerScheduledRefMethods `json:"method"`
Workflowid pgtype.UUID `json:"workflowid"`
}
type CreateWorkflowVersionParams ¶
type CreateWorkflowVersionParams struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
Deletedat pgtype.Timestamp `json:"deletedat"`
Checksum string `json:"checksum"`
Version pgtype.Text `json:"version"`
Workflowid pgtype.UUID `json:"workflowid"`
ScheduleTimeout pgtype.Text `json:"scheduleTimeout"`
Sticky NullStickyStrategy `json:"sticky"`
Kind NullWorkflowKind `json:"kind"`
DefaultPriority pgtype.Int4 `json:"defaultPriority"`
}
type DBTX ¶
type DBTX interface {
Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
Query(context.Context, string, ...interface{}) (pgx.Rows, error)
QueryRow(context.Context, string, ...interface{}) pgx.Row
CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error)
SendBatch(context.Context, *pgx.Batch) pgx.BatchResults
}
type DeleteOldWorkerAssignEventsParams ¶ added in v0.44.3
type DeleteOldWorkersParams ¶ added in v0.44.0
type Dispatcher ¶
type Event ¶
type Event struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
Key string `json:"key"`
TenantId pgtype.UUID `json:"tenantId"`
ReplayedFromId pgtype.UUID `json:"replayedFromId"`
Data []byte `json:"data"`
AdditionalMetadata []byte `json:"additionalMetadata"`
InsertOrder pgtype.Int4 `json:"insertOrder"`
}
type GetChildWorkflowRunsByIndexParams ¶ added in v0.50.0
type GetChildWorkflowRunsByKeyParams ¶ added in v0.50.0
type GetDesiredLabelsRow ¶ added in v0.42.0
type GetEventsForRangeRow ¶
type GetFailureDetailsParams ¶ added in v0.51.0
type GetFailureDetailsRow ¶ added in v0.51.0
type GetFailureDetailsRow struct {
Status WorkflowRunStatus `json:"status"`
ID pgtype.UUID `json:"id"`
JrStatus JobRunStatus `json:"jrStatus"`
SrStatus StepRunStatus `json:"srStatus"`
CancelledReason pgtype.Text `json:"cancelledReason"`
Error pgtype.Text `json:"error"`
}
type GetFinalizedStepRunsRow ¶ added in v0.44.0
type GetFinalizedStepRunsRow struct {
ID pgtype.UUID `json:"id"`
Status StepRunStatus `json:"status"`
}
type GetGroupKeyRun ¶
type GetGroupKeyRun struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
TenantId pgtype.UUID `json:"tenantId"`
WorkerId pgtype.UUID `json:"workerId"`
TickerId pgtype.UUID `json:"tickerId"`
Status StepRunStatus `json:"status"`
Input []byte `json:"input"`
Output pgtype.Text `json:"output"`
RequeueAfter pgtype.Timestamp `json:"requeueAfter"`
Error pgtype.Text `json:"error"`
StartedAt pgtype.Timestamp `json:"startedAt"`
FinishedAt pgtype.Timestamp `json:"finishedAt"`
TimeoutAt pgtype.Timestamp `json:"timeoutAt"`
CancelledAt pgtype.Timestamp `json:"cancelledAt"`
CancelledReason pgtype.Text `json:"cancelledReason"`
CancelledError pgtype.Text `json:"cancelledError"`
WorkflowRunId pgtype.UUID `json:"workflowRunId"`
ScheduleTimeoutAt pgtype.Timestamp `json:"scheduleTimeoutAt"`
}
type GetJobRunByWorkflowRunIdAndJobIdRow ¶
type GetJobRunByWorkflowRunIdAndJobIdRow struct {
ID pgtype.UUID `json:"id"`
JobId pgtype.UUID `json:"jobId"`
Status JobRunStatus `json:"status"`
}
type GetJobRunsByWorkflowRunIdParams ¶ added in v0.50.0
type GetJobRunsByWorkflowRunIdRow ¶ added in v0.50.0
type GetJobRunsByWorkflowRunIdRow struct {
ID pgtype.UUID `json:"id"`
JobId pgtype.UUID `json:"jobId"`
Status JobRunStatus `json:"status"`
}
type GetLatestWorkflowVersionForWorkflowsParams ¶ added in v0.50.0
type GetLeasesToAcquireParams ¶ added in v0.50.0
type GetMinMaxProcessedInternalQueueItemsRow ¶ added in v0.44.0
type GetMinMaxProcessedQueueItemsRow ¶ added in v0.43.2
type GetMinMaxProcessedRetryQueueItemsRow ¶ added in v0.52.0
type GetMinMaxProcessedTimeoutQueueItemsRow ¶ added in v0.44.5
type GetMinUnprocessedQueueItemIdParams ¶ added in v0.50.0
type GetQueuedCountsRow ¶ added in v0.46.1
type GetStepRunBulkDataForEngineParams ¶ added in v0.50.0
type GetStepRunBulkDataForEngineRow ¶ added in v0.50.0
type GetStepRunBulkDataForEngineRow struct {
SRID pgtype.UUID `json:"SR_id"`
SRRetryCount int32 `json:"SR_retryCount"`
Input []byte `json:"input"`
Output []byte `json:"output"`
Error pgtype.Text `json:"error"`
Status StepRunStatus `json:"status"`
JobRunId pgtype.UUID `json:"jobRunId"`
JobRunStatus JobRunStatus `json:"jobRunStatus"`
JobRunStatus_2 JobRunStatus `json:"jobRunStatus_2"`
WorkflowRunId pgtype.UUID `json:"workflowRunId"`
JobRunLookupData []byte `json:"jobRunLookupData"`
AdditionalMetadata []byte `json:"additionalMetadata"`
ChildIndex pgtype.Int4 `json:"childIndex"`
ChildKey pgtype.Text `json:"childKey"`
ParentId pgtype.UUID `json:"parentId"`
JobRunId_2 pgtype.UUID `json:"jobRunId_2"`
StepId pgtype.UUID `json:"stepId"`
StepRetries int32 `json:"stepRetries"`
StepTimeout pgtype.Text `json:"stepTimeout"`
StepScheduleTimeout string `json:"stepScheduleTimeout"`
StepReadableId pgtype.Text `json:"stepReadableId"`
StepCustomUserData []byte `json:"stepCustomUserData"`
JobName string `json:"jobName"`
JobId pgtype.UUID `json:"jobId"`
JobKind JobKind `json:"jobKind"`
WorkflowVersionId pgtype.UUID `json:"workflowVersionId"`
ActionId string `json:"actionId"`
}
type GetStepRunDataForEngineParams ¶ added in v0.36.9
type GetStepRunDataForEngineRow ¶ added in v0.36.9
type GetStepRunDataForEngineRow struct {
Input []byte `json:"input"`
Output []byte `json:"output"`
Error pgtype.Text `json:"error"`
JobRunLookupData []byte `json:"jobRunLookupData"`
AdditionalMetadata []byte `json:"additionalMetadata"`
ChildIndex pgtype.Int4 `json:"childIndex"`
ChildKey pgtype.Text `json:"childKey"`
ParentId pgtype.UUID `json:"parentId"`
ExprCount int64 `json:"exprCount"`
}
type GetStepRunForEngineRow ¶
type GetStepRunForEngineRow struct {
SRID pgtype.UUID `json:"SR_id"`
SRCreatedAt pgtype.Timestamp `json:"SR_createdAt"`
SRUpdatedAt pgtype.Timestamp `json:"SR_updatedAt"`
SRDeletedAt pgtype.Timestamp `json:"SR_deletedAt"`
SRTenantId pgtype.UUID `json:"SR_tenantId"`
SRQueue string `json:"SR_queue"`
SROrder int64 `json:"SR_order"`
SRWorkerId pgtype.UUID `json:"SR_workerId"`
SRTickerId pgtype.UUID `json:"SR_tickerId"`
SRStatus StepRunStatus `json:"SR_status"`
SRRequeueAfter pgtype.Timestamp `json:"SR_requeueAfter"`
SRScheduleTimeoutAt pgtype.Timestamp `json:"SR_scheduleTimeoutAt"`
SRStartedAt pgtype.Timestamp `json:"SR_startedAt"`
SRFinishedAt pgtype.Timestamp `json:"SR_finishedAt"`
SRTimeoutAt pgtype.Timestamp `json:"SR_timeoutAt"`
SRCancelledAt pgtype.Timestamp `json:"SR_cancelledAt"`
SRCancelledReason pgtype.Text `json:"SR_cancelledReason"`
SRCancelledError pgtype.Text `json:"SR_cancelledError"`
SRCallerFiles []byte `json:"SR_callerFiles"`
SRGitRepoBranch pgtype.Text `json:"SR_gitRepoBranch"`
SRRetryCount int32 `json:"SR_retryCount"`
SRSemaphoreReleased bool `json:"SR_semaphoreReleased"`
SRPriority pgtype.Int4 `json:"SR_priority"`
SRChildCount int64 `json:"SR_childCount"`
JobRunId pgtype.UUID `json:"jobRunId"`
StepId pgtype.UUID `json:"stepId"`
StepRetries int32 `json:"stepRetries"`
StepTimeout pgtype.Text `json:"stepTimeout"`
StepScheduleTimeout string `json:"stepScheduleTimeout"`
StepReadableId pgtype.Text `json:"stepReadableId"`
StepCustomUserData []byte `json:"stepCustomUserData"`
StepRetryBackoffFactor pgtype.Float8 `json:"stepRetryBackoffFactor"`
StepRetryMaxBackoff pgtype.Int4 `json:"stepRetryMaxBackoff"`
JobName string `json:"jobName"`
JobId pgtype.UUID `json:"jobId"`
JobKind JobKind `json:"jobKind"`
WorkflowVersionId pgtype.UUID `json:"workflowVersionId"`
JobRunStatus JobRunStatus `json:"jobRunStatus"`
WorkflowRunId pgtype.UUID `json:"workflowRunId"`
ActionId string `json:"actionId"`
StickyStrategy NullStickyStrategy `json:"stickyStrategy"`
DesiredWorkerId pgtype.UUID `json:"desiredWorkerId"`
}
type GetStepRunMetaParams ¶ added in v0.41.0
type GetStepRunMetaRow ¶ added in v0.41.0
type GetStepRunsForJobRunsWithOutputParams ¶ added in v0.46.1
type GetStepRunsForJobRunsWithOutputRow ¶ added in v0.46.1
type GetStepRunsForJobRunsWithOutputRow struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
Status StepRunStatus `json:"status"`
JobRunId pgtype.UUID `json:"jobRunId"`
StepId pgtype.UUID `json:"stepId"`
TenantId pgtype.UUID `json:"tenantId"`
StartedAt pgtype.Timestamp `json:"startedAt"`
FinishedAt pgtype.Timestamp `json:"finishedAt"`
CancelledAt pgtype.Timestamp `json:"cancelledAt"`
CancelledError pgtype.Text `json:"cancelledError"`
CancelledReason pgtype.Text `json:"cancelledReason"`
TimeoutAt pgtype.Timestamp `json:"timeoutAt"`
Error pgtype.Text `json:"error"`
WorkerId pgtype.UUID `json:"workerId"`
Output []byte `json:"output"`
}
type GetStepsForJobsParams ¶ added in v0.44.8
type GetStepsForJobsRow ¶ added in v0.44.8
type GetStreamEventMetaParams ¶ added in v0.41.0
type GetStreamEventMetaRow ¶ added in v0.41.0
type GetStreamEventParams ¶
type GetTenantResourceLimitParams ¶
type GetTenantResourceLimitParams struct {
Tenantid pgtype.UUID `json:"tenantid"`
Resource NullLimitResource `json:"resource"`
}
type GetTenantResourceLimitRow ¶
type GetTenantResourceLimitRow struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
Resource LimitResource `json:"resource"`
TenantId pgtype.UUID `json:"tenantId"`
LimitValue int32 `json:"limitValue"`
AlarmValue pgtype.Int4 `json:"alarmValue"`
Value int32 `json:"value"`
Window pgtype.Text `json:"window"`
LastRefill pgtype.Timestamp `json:"lastRefill"`
CustomValueMeter bool `json:"customValueMeter"`
}
type GetWorkerActionsByWorkerIdParams ¶ added in v0.42.13
type GetWorkerByIdRow ¶ added in v0.42.10
type GetWorkerByWebhookIdParams ¶ added in v0.42.10
type GetWorkerDispatcherActionsParams ¶ added in v0.44.0
type GetWorkerDispatcherActionsRow ¶ added in v0.44.0
type GetWorkerForEngineRow ¶
type GetWorkerForEngineRow struct {
ID pgtype.UUID `json:"id"`
TenantId pgtype.UUID `json:"tenantId"`
DispatcherId pgtype.UUID `json:"dispatcherId"`
DispatcherLastHeartbeatAt pgtype.Timestamp `json:"dispatcherLastHeartbeatAt"`
IsActive bool `json:"isActive"`
LastListenerEstablished pgtype.Timestamp `json:"lastListenerEstablished"`
}
type GetWorkerLabelsRow ¶ added in v0.42.0
type GetWorkflowByIdRow ¶ added in v0.44.8
type GetWorkflowByNameParams ¶
type GetWorkflowRunAdditionalMetaParams ¶ added in v0.41.0
type GetWorkflowRunAdditionalMetaRow ¶ added in v0.41.0
type GetWorkflowRunByIdParams ¶ added in v0.44.8
type GetWorkflowRunByIdRow ¶ added in v0.44.8
type GetWorkflowRunByIdRow struct {
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
TenantId pgtype.UUID `json:"tenantId"`
WorkflowVersionId pgtype.UUID `json:"workflowVersionId"`
Status WorkflowRunStatus `json:"status"`
Error pgtype.Text `json:"error"`
StartedAt pgtype.Timestamp `json:"startedAt"`
FinishedAt pgtype.Timestamp `json:"finishedAt"`
ConcurrencyGroupId pgtype.Text `json:"concurrencyGroupId"`
DisplayName pgtype.Text `json:"displayName"`
ID pgtype.UUID `json:"id"`
ChildIndex pgtype.Int4 `json:"childIndex"`
ChildKey pgtype.Text `json:"childKey"`
ParentId pgtype.UUID `json:"parentId"`
ParentStepRunId pgtype.UUID `json:"parentStepRunId"`
AdditionalMetadata []byte `json:"additionalMetadata"`
Duration pgtype.Int8 `json:"duration"`
Priority pgtype.Int4 `json:"priority"`
InsertOrder pgtype.Int4 `json:"insertOrder"`
WorkflowVersion WorkflowVersion `json:"workflow_version"`
Workflow Workflow `json:"workflow"`
WorkflowRunTriggeredBy WorkflowRunTriggeredBy `json:"workflow_run_triggered_by"`
}
type GetWorkflowRunByIdsParams ¶ added in v0.50.0
type GetWorkflowRunByIdsRow ¶ added in v0.50.0
type GetWorkflowRunByIdsRow struct {
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
TenantId pgtype.UUID `json:"tenantId"`
WorkflowVersionId pgtype.UUID `json:"workflowVersionId"`
Status WorkflowRunStatus `json:"status"`
Error pgtype.Text `json:"error"`
StartedAt pgtype.Timestamp `json:"startedAt"`
FinishedAt pgtype.Timestamp `json:"finishedAt"`
ConcurrencyGroupId pgtype.Text `json:"concurrencyGroupId"`
DisplayName pgtype.Text `json:"displayName"`
ID pgtype.UUID `json:"id"`
ChildIndex pgtype.Int4 `json:"childIndex"`
ChildKey pgtype.Text `json:"childKey"`
ParentId pgtype.UUID `json:"parentId"`
ParentStepRunId pgtype.UUID `json:"parentStepRunId"`
AdditionalMetadata []byte `json:"additionalMetadata"`
Duration pgtype.Int8 `json:"duration"`
Priority pgtype.Int4 `json:"priority"`
InsertOrder pgtype.Int4 `json:"insertOrder"`
WorkflowVersion WorkflowVersion `json:"workflow_version"`
Workflow Workflow `json:"workflow"`
WorkflowRunTriggeredBy WorkflowRunTriggeredBy `json:"workflow_run_triggered_by"`
}
type GetWorkflowRunParams ¶
type GetWorkflowRunRow ¶
type GetWorkflowRunRow struct {
WorkflowRun WorkflowRun `json:"workflow_run"`
WorkflowRunTriggeredBy WorkflowRunTriggeredBy `json:"workflow_run_triggered_by"`
WorkflowVersion WorkflowVersion `json:"workflow_version"`
WorkflowName pgtype.Text `json:"workflowName"`
ConcurrencyLimitStrategy NullConcurrencyLimitStrategy `json:"concurrencyLimitStrategy"`
ConcurrencyMaxRuns pgtype.Int4 `json:"concurrencyMaxRuns"`
IsPaused pgtype.Bool `json:"isPaused"`
ConcurrencyGroupExpression pgtype.Text `json:"concurrencyGroupExpression"`
GetGroupKeyRunId pgtype.UUID `json:"getGroupKeyRunId"`
}
type GetWorkflowRunStickyStateForUpdateParams ¶ added in v0.40.0
type GetWorkflowRunTriggerParams ¶ added in v0.44.8
type GetWorkflowVersionByIdRow ¶ added in v0.44.8
type GetWorkflowVersionByIdRow struct {
WorkflowVersion WorkflowVersion `json:"workflow_version"`
Workflow Workflow `json:"workflow"`
ConcurrencyId pgtype.UUID `json:"concurrencyId"`
ConcurrencyMaxRuns pgtype.Int4 `json:"concurrencyMaxRuns"`
ConcurrencyGroupId pgtype.UUID `json:"concurrencyGroupId"`
ConcurrencyLimitStrategy NullConcurrencyLimitStrategy `json:"concurrencyLimitStrategy"`
}
type GetWorkflowVersionForEngineRow ¶
type GetWorkflowVersionForEngineRow struct {
WorkflowVersion WorkflowVersion `json:"workflow_version"`
WorkflowName string `json:"workflowName"`
ConcurrencyLimitStrategy NullConcurrencyLimitStrategy `json:"concurrencyLimitStrategy"`
ConcurrencyMaxRuns pgtype.Int4 `json:"concurrencyMaxRuns"`
ConcurrencyGroupId pgtype.UUID `json:"concurrencyGroupId"`
ConcurrencyGroupExpression pgtype.Text `json:"concurrencyGroupExpression"`
}
type GetWorkflowWorkerCountParams ¶ added in v0.45.2
type GetWorkflowWorkerCountRow ¶ added in v0.45.2
type GetWorkflowsByNamesParams ¶ added in v0.50.0
type HandleWorkflowUnpausedParams ¶ added in v0.48.0
type HardDeleteWebhookWorkerParams ¶ added in v0.42.13
type HasActiveWorkersForActionIdParams ¶ added in v0.44.8
type InsertWebhookWorkerRequestParams ¶ added in v0.42.13
type InsertWebhookWorkerRequestParams struct {
Webhookworkerid pgtype.UUID `json:"webhookworkerid"`
Method WebhookWorkerRequestMethod `json:"method"`
Statuscode int32 `json:"statuscode"`
}
type InternalQueue ¶ added in v0.44.0
type InternalQueue string
const ( InternalQueueWORKERSEMAPHORECOUNT InternalQueue = "WORKER_SEMAPHORE_COUNT" InternalQueueSTEPRUNUPDATE InternalQueue = "STEP_RUN_UPDATE" InternalQueueWORKFLOWRUNUPDATE InternalQueue = "WORKFLOW_RUN_UPDATE" InternalQueueWORKFLOWRUNPAUSED InternalQueue = "WORKFLOW_RUN_PAUSED" InternalQueueSTEPRUNUPDATEV2 InternalQueue = "STEP_RUN_UPDATE_V2" )
func (*InternalQueue) Scan ¶ added in v0.44.0
func (e *InternalQueue) Scan(src interface{}) error
type InternalQueueItem ¶ added in v0.44.0
type InviteLinkStatus ¶
type InviteLinkStatus string
const ( InviteLinkStatusPENDING InviteLinkStatus = "PENDING" InviteLinkStatusACCEPTED InviteLinkStatus = "ACCEPTED" InviteLinkStatusREJECTED InviteLinkStatus = "REJECTED" )
func (*InviteLinkStatus) Scan ¶
func (e *InviteLinkStatus) Scan(src interface{}) error
type Job ¶
type Job struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
TenantId pgtype.UUID `json:"tenantId"`
WorkflowVersionId pgtype.UUID `json:"workflowVersionId"`
Name string `json:"name"`
Description pgtype.Text `json:"description"`
Timeout pgtype.Text `json:"timeout"`
Kind JobKind `json:"kind"`
}
type JobRun ¶
type JobRun struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
TenantId pgtype.UUID `json:"tenantId"`
JobId pgtype.UUID `json:"jobId"`
TickerId pgtype.UUID `json:"tickerId"`
Status JobRunStatus `json:"status"`
Result []byte `json:"result"`
StartedAt pgtype.Timestamp `json:"startedAt"`
FinishedAt pgtype.Timestamp `json:"finishedAt"`
TimeoutAt pgtype.Timestamp `json:"timeoutAt"`
CancelledAt pgtype.Timestamp `json:"cancelledAt"`
CancelledReason pgtype.Text `json:"cancelledReason"`
CancelledError pgtype.Text `json:"cancelledError"`
WorkflowRunId pgtype.UUID `json:"workflowRunId"`
}
type JobRunLookupData ¶
type JobRunLookupData struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
JobRunId pgtype.UUID `json:"jobRunId"`
TenantId pgtype.UUID `json:"tenantId"`
Data []byte `json:"data"`
}
type JobRunStatus ¶
type JobRunStatus string
const ( JobRunStatusPENDING JobRunStatus = "PENDING" JobRunStatusRUNNING JobRunStatus = "RUNNING" JobRunStatusSUCCEEDED JobRunStatus = "SUCCEEDED" JobRunStatusFAILED JobRunStatus = "FAILED" JobRunStatusCANCELLED JobRunStatus = "CANCELLED" )
func (*JobRunStatus) Scan ¶
func (e *JobRunStatus) Scan(src interface{}) error
type LimitResource ¶
type LimitResource string
const ( LimitResourceWORKFLOWRUN LimitResource = "WORKFLOW_RUN" LimitResourceEVENT LimitResource = "EVENT" LimitResourceWORKER LimitResource = "WORKER" LimitResourceCRON LimitResource = "CRON" LimitResourceSCHEDULE LimitResource = "SCHEDULE" )
func (*LimitResource) Scan ¶
func (e *LimitResource) Scan(src interface{}) error
type LinkOnFailureJobParams ¶
type ListActionsForAvailableWorkersRow ¶ added in v0.50.0
type ListActionsForWorkersParams ¶ added in v0.50.0
type ListActionsForWorkersRow ¶ added in v0.50.0
type ListActiveDispatchersRow ¶
type ListActiveDispatchersRow struct {
Dispatcher Dispatcher `json:"dispatcher"`
}
type ListActiveQueuedWorkflowVersionsRow ¶ added in v0.36.7
type ListActiveTickersRow ¶
type ListActiveTickersRow struct {
Ticker Ticker `json:"ticker"`
}
type ListActiveWorkersRow ¶ added in v0.50.0
type ListAllAvailableSlotsForWorkersRow ¶ added in v0.50.0
type ListAllWorkerActionsParams ¶ added in v0.50.0
type ListAvailableSlotsForWorkersParams ¶ added in v0.44.7
type ListAvailableSlotsForWorkersRow ¶ added in v0.44.7
type ListChildWorkflowRunCountsRow ¶ added in v0.44.8
type ListChildWorkflowRunIdsParams ¶ added in v0.44.8
type ListCronWorkflowsParams ¶ added in v0.51.0
type ListCronWorkflowsParams struct {
Tenantid pgtype.UUID `json:"tenantid"`
Crontriggerid pgtype.UUID `json:"crontriggerid"`
Workflowid pgtype.UUID `json:"workflowid"`
AdditionalMetadata []byte `json:"additionalMetadata"`
Orderby interface{} `json:"orderby"`
Offset interface{} `json:"offset"`
Limit interface{} `json:"limit"`
}
type ListCronWorkflowsRow ¶ added in v0.51.0
type ListCronWorkflowsRow struct {
WorkflowVersionId pgtype.UUID `json:"workflowVersionId"`
WorkflowName string `json:"workflowName"`
WorkflowId pgtype.UUID `json:"workflowId"`
TenantId pgtype.UUID `json:"tenantId"`
TriggerId pgtype.UUID `json:"triggerId"`
CronId pgtype.UUID `json:"cronId"`
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
WorkflowVersionId_2 pgtype.UUID `json:"workflowVersionId_2"`
TenantId_2 pgtype.UUID `json:"tenantId_2"`
ParentId pgtype.UUID `json:"parentId"`
Cron string `json:"cron"`
TickerId pgtype.UUID `json:"tickerId"`
Input []byte `json:"input"`
Enabled bool `json:"enabled"`
AdditionalMetadata []byte `json:"additionalMetadata"`
CreatedAt_2 pgtype.Timestamp `json:"createdAt_2"`
DeletedAt_2 pgtype.Timestamp `json:"deletedAt_2"`
UpdatedAt_2 pgtype.Timestamp `json:"updatedAt_2"`
Name pgtype.Text `json:"name"`
ID_2 pgtype.UUID `json:"id_2"`
Method WorkflowTriggerCronRefMethods `json:"method"`
}
type ListDispatcherIdsForWorkersParams ¶ added in v0.50.0
type ListDispatcherIdsForWorkersRow ¶ added in v0.50.0
type ListDispatchersRow ¶
type ListDispatchersRow struct {
Dispatcher Dispatcher `json:"dispatcher"`
}
type ListEventsByIDsParams ¶
type ListEventsParams ¶
type ListEventsParams struct {
TenantId pgtype.UUID `json:"tenantId"`
Orderby interface{} `json:"orderby"`
EventIds []pgtype.UUID `json:"event_ids"`
Keys []string `json:"keys"`
AdditionalMetadata []byte `json:"additionalMetadata"`
Workflows []string `json:"workflows"`
Search pgtype.Text `json:"search"`
Statuses []string `json:"statuses"`
Offset interface{} `json:"offset"`
Limit interface{} `json:"limit"`
}
type ListEventsRow ¶
type ListInternalQueueItemsParams ¶ added in v0.44.0
type ListJobRunsForWorkflowRunFullParams ¶ added in v0.44.8
type ListJobRunsForWorkflowRunFullRow ¶ added in v0.44.8
type ListJobRunsForWorkflowRunFullRow struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
TenantId pgtype.UUID `json:"tenantId"`
JobId pgtype.UUID `json:"jobId"`
TickerId pgtype.UUID `json:"tickerId"`
Status JobRunStatus `json:"status"`
Result []byte `json:"result"`
StartedAt pgtype.Timestamp `json:"startedAt"`
FinishedAt pgtype.Timestamp `json:"finishedAt"`
TimeoutAt pgtype.Timestamp `json:"timeoutAt"`
CancelledAt pgtype.Timestamp `json:"cancelledAt"`
CancelledReason pgtype.Text `json:"cancelledReason"`
CancelledError pgtype.Text `json:"cancelledError"`
WorkflowRunId pgtype.UUID `json:"workflowRunId"`
Job Job `json:"job"`
}
type ListLogLinesParams ¶
type ListManyWorkerLabelsRow ¶ added in v0.50.0
type ListNewlyStaleTickersRow ¶
type ListNewlyStaleTickersRow struct {
Ticker Ticker `json:"ticker"`
}
type ListQueueItemsBatchResults ¶ added in v0.42.0
type ListQueueItemsBatchResults struct {
// contains filtered or unexported fields
}
func (*ListQueueItemsBatchResults) Close ¶ added in v0.42.0
func (b *ListQueueItemsBatchResults) Close() error
type ListQueueItemsForQueueParams ¶ added in v0.50.0
type ListQueueItemsForQueueRow ¶ added in v0.50.0
type ListQueueItemsForQueueRow struct {
QueueItem QueueItem `json:"queue_item"`
Status StepRunStatus `json:"status"`
}
type ListQueueItemsParams ¶ added in v0.42.0
type ListRateLimitsForStepsParams ¶ added in v0.42.0
type ListRateLimitsForTenantNoMutateParams ¶ added in v0.47.0
type ListRateLimitsForTenantNoMutateRow ¶ added in v0.47.0
type ListRateLimitsForTenantWithMutateRow ¶ added in v0.47.0
type ListRateLimitsForTenantWithMutateRow struct {
TenantId pgtype.UUID `json:"tenantId"`
Key string `json:"key"`
LimitValue int32 `json:"limitValue"`
Value int32 `json:"value"`
Window string `json:"window"`
LastRefill pgtype.Timestamp `json:"lastRefill"`
NextRefillAt pgtype.Timestamp `json:"nextRefillAt"`
}
type ListRecentAssignedEventsForWorkerParams ¶ added in v0.44.0
type ListRecentAssignedEventsForWorkerRow ¶ added in v0.44.0
type ListScheduledWorkflowsParams ¶ added in v0.51.0
type ListScheduledWorkflowsParams struct {
Tenantid pgtype.UUID `json:"tenantid"`
Scheduleid pgtype.UUID `json:"scheduleid"`
Workflowid pgtype.UUID `json:"workflowid"`
Parentworkflowrunid pgtype.UUID `json:"parentworkflowrunid"`
Parentsteprunid pgtype.UUID `json:"parentsteprunid"`
AdditionalMetadata []byte `json:"additionalMetadata"`
Statuses []string `json:"statuses"`
Includescheduled bool `json:"includescheduled"`
Orderby interface{} `json:"orderby"`
Offset interface{} `json:"offset"`
Limit interface{} `json:"limit"`
}
type ListScheduledWorkflowsRow ¶ added in v0.51.0
type ListScheduledWorkflowsRow struct {
Name string `json:"name"`
WorkflowId pgtype.UUID `json:"workflowId"`
WorkflowVersionId pgtype.UUID `json:"workflowVersionId"`
TenantId pgtype.UUID `json:"tenantId"`
ID pgtype.UUID `json:"id"`
ParentId pgtype.UUID `json:"parentId"`
TriggerAt pgtype.Timestamp `json:"triggerAt"`
TickerId pgtype.UUID `json:"tickerId"`
Input []byte `json:"input"`
ChildIndex pgtype.Int4 `json:"childIndex"`
ChildKey pgtype.Text `json:"childKey"`
ParentStepRunId pgtype.UUID `json:"parentStepRunId"`
ParentWorkflowRunId pgtype.UUID `json:"parentWorkflowRunId"`
AdditionalMetadata []byte `json:"additionalMetadata"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
Method WorkflowTriggerScheduledRefMethods `json:"method"`
WorkflowRunCreatedAt pgtype.Timestamp `json:"workflowRunCreatedAt"`
WorkflowRunStatus NullWorkflowRunStatus `json:"workflowRunStatus"`
WorkflowRunId pgtype.UUID `json:"workflowRunId"`
WorkflowRunName pgtype.Text `json:"workflowRunName"`
}
type ListSemaphoreSlotsWithStateForWorkerParams ¶ added in v0.42.0
type ListSemaphoreSlotsWithStateForWorkerRow ¶ added in v0.42.0
type ListSemaphoreSlotsWithStateForWorkerRow struct {
StepRunId pgtype.UUID `json:"stepRunId"`
Status StepRunStatus `json:"status"`
ActionId string `json:"actionId"`
TimeoutAt pgtype.Timestamp `json:"timeoutAt"`
StartedAt pgtype.Timestamp `json:"startedAt"`
WorkflowRunId pgtype.UUID `json:"workflowRunId"`
}
type ListStaleDispatchersRow ¶
type ListStaleDispatchersRow struct {
Dispatcher Dispatcher `json:"dispatcher"`
}
type ListStepRunArchivesParams ¶ added in v0.34.2
type ListStepRunEventsByWorkflowRunIdParams ¶ added in v0.44.8
type ListStepRunEventsParams ¶
type ListStepRunsParams ¶
type ListStepRunsToCancelParams ¶ added in v0.51.2
type ListStepRunsToReassignParams ¶ added in v0.36.5
type ListStepRunsToReassignRow ¶ added in v0.44.0
type ListStepRunsToRetryRow ¶ added in v0.52.0
type ListStepsForJobRow ¶ added in v0.42.0
type ListTickersParams ¶
type ListWorkerLabelsRow ¶ added in v0.40.0
type ListWorkersWithSlotCountParams ¶ added in v0.44.0
type ListWorkersWithSlotCountRow ¶ added in v0.44.0
type ListWorkflowRunsParams ¶
type ListWorkflowRunsParams struct {
TenantId pgtype.UUID `json:"tenantId"`
EventId pgtype.UUID `json:"eventId"`
WorkflowVersionId pgtype.UUID `json:"workflowVersionId"`
Kinds []string `json:"kinds"`
WorkflowId pgtype.UUID `json:"workflowId"`
Ids []pgtype.UUID `json:"ids"`
AdditionalMetadata []byte `json:"additionalMetadata"`
ParentId pgtype.UUID `json:"parentId"`
ParentStepRunId pgtype.UUID `json:"parentStepRunId"`
GroupKey pgtype.Text `json:"groupKey"`
Statuses []string `json:"statuses"`
CreatedAfter pgtype.Timestamp `json:"createdAfter"`
CreatedBefore pgtype.Timestamp `json:"createdBefore"`
FinishedAfter pgtype.Timestamp `json:"finishedAfter"`
FinishedBefore pgtype.Timestamp `json:"finishedBefore"`
Orderby interface{} `json:"orderby"`
Offset interface{} `json:"offset"`
Limit interface{} `json:"limit"`
}
type ListWorkflowRunsRow ¶
type ListWorkflowRunsRow struct {
WorkflowRun WorkflowRun `json:"workflow_run"`
Workflow Workflow `json:"workflow"`
WorkflowRunTriggeredBy WorkflowRunTriggeredBy `json:"workflow_run_triggered_by"`
WorkflowVersion WorkflowVersion `json:"workflow_version"`
ID pgtype.UUID `json:"id"`
Key pgtype.Text `json:"key"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
}
type ListWorkflowsLatestRunsRow ¶
type ListWorkflowsLatestRunsRow struct {
WorkflowRun WorkflowRun `json:"workflow_run"`
WorkflowId pgtype.UUID `json:"workflowId"`
}
type ListWorkflowsParams ¶
type ListWorkflowsRow ¶
type ListWorkflowsRow struct {
Workflow Workflow `json:"workflow"`
}
type LogLineLevel ¶
type LogLineLevel string
const ( LogLineLevelDEBUG LogLineLevel = "DEBUG" LogLineLevelINFO LogLineLevel = "INFO" LogLineLevelWARN LogLineLevel = "WARN" LogLineLevelERROR LogLineLevel = "ERROR" )
func (*LogLineLevel) Scan ¶
func (e *LogLineLevel) Scan(src interface{}) error
type ManualReleaseSemaphoreParams ¶ added in v0.44.0
type MeterTenantResourceParams ¶
type MeterTenantResourceParams struct {
Numresources int32 `json:"numresources"`
Tenantid pgtype.UUID `json:"tenantid"`
Resource NullLimitResource `json:"resource"`
}
type MoveCronTriggerToNewWorkflowTriggersParams ¶ added in v0.52.0
type MoveScheduledTriggerToNewWorkflowTriggersParams ¶ added in v0.52.0
type NullConcurrencyLimitStrategy ¶
type NullConcurrencyLimitStrategy struct {
ConcurrencyLimitStrategy ConcurrencyLimitStrategy `json:"ConcurrencyLimitStrategy"`
Valid bool `json:"valid"` // Valid is true if ConcurrencyLimitStrategy is not NULL
}
func (*NullConcurrencyLimitStrategy) Scan ¶
func (ns *NullConcurrencyLimitStrategy) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullInternalQueue ¶ added in v0.44.0
type NullInternalQueue struct {
InternalQueue InternalQueue `json:"InternalQueue"`
Valid bool `json:"valid"` // Valid is true if InternalQueue is not NULL
}
func (*NullInternalQueue) Scan ¶ added in v0.44.0
func (ns *NullInternalQueue) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullInviteLinkStatus ¶
type NullInviteLinkStatus struct {
InviteLinkStatus InviteLinkStatus `json:"InviteLinkStatus"`
Valid bool `json:"valid"` // Valid is true if InviteLinkStatus is not NULL
}
func (*NullInviteLinkStatus) Scan ¶
func (ns *NullInviteLinkStatus) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullJobKind ¶
type NullJobKind struct {
JobKind JobKind `json:"JobKind"`
Valid bool `json:"valid"` // Valid is true if JobKind is not NULL
}
func (*NullJobKind) Scan ¶
func (ns *NullJobKind) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullJobRunStatus ¶
type NullJobRunStatus struct {
JobRunStatus JobRunStatus `json:"JobRunStatus"`
Valid bool `json:"valid"` // Valid is true if JobRunStatus is not NULL
}
func (*NullJobRunStatus) Scan ¶
func (ns *NullJobRunStatus) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullLeaseKind ¶ added in v0.50.0
type NullLeaseKind struct {
LeaseKind LeaseKind `json:"LeaseKind"`
Valid bool `json:"valid"` // Valid is true if LeaseKind is not NULL
}
func (*NullLeaseKind) Scan ¶ added in v0.50.0
func (ns *NullLeaseKind) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullLimitResource ¶
type NullLimitResource struct {
LimitResource LimitResource `json:"LimitResource"`
Valid bool `json:"valid"` // Valid is true if LimitResource is not NULL
}
func (*NullLimitResource) Scan ¶
func (ns *NullLimitResource) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullLogLineLevel ¶
type NullLogLineLevel struct {
LogLineLevel LogLineLevel `json:"LogLineLevel"`
Valid bool `json:"valid"` // Valid is true if LogLineLevel is not NULL
}
func (*NullLogLineLevel) Scan ¶
func (ns *NullLogLineLevel) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullStepExpressionKind ¶ added in v0.47.0
type NullStepExpressionKind struct {
StepExpressionKind StepExpressionKind `json:"StepExpressionKind"`
Valid bool `json:"valid"` // Valid is true if StepExpressionKind is not NULL
}
func (*NullStepExpressionKind) Scan ¶ added in v0.47.0
func (ns *NullStepExpressionKind) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullStepRateLimitKind ¶ added in v0.47.0
type NullStepRateLimitKind struct {
StepRateLimitKind StepRateLimitKind `json:"StepRateLimitKind"`
Valid bool `json:"valid"` // Valid is true if StepRateLimitKind is not NULL
}
func (*NullStepRateLimitKind) Scan ¶ added in v0.47.0
func (ns *NullStepRateLimitKind) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullStepRunEventReason ¶
type NullStepRunEventReason struct {
StepRunEventReason StepRunEventReason `json:"StepRunEventReason"`
Valid bool `json:"valid"` // Valid is true if StepRunEventReason is not NULL
}
func (*NullStepRunEventReason) Scan ¶
func (ns *NullStepRunEventReason) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullStepRunEventSeverity ¶
type NullStepRunEventSeverity struct {
StepRunEventSeverity StepRunEventSeverity `json:"StepRunEventSeverity"`
Valid bool `json:"valid"` // Valid is true if StepRunEventSeverity is not NULL
}
func (*NullStepRunEventSeverity) Scan ¶
func (ns *NullStepRunEventSeverity) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullStepRunStatus ¶
type NullStepRunStatus struct {
StepRunStatus StepRunStatus `json:"StepRunStatus"`
Valid bool `json:"valid"` // Valid is true if StepRunStatus is not NULL
}
func (*NullStepRunStatus) Scan ¶
func (ns *NullStepRunStatus) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullStickyStrategy ¶ added in v0.40.0
type NullStickyStrategy struct {
StickyStrategy StickyStrategy `json:"StickyStrategy"`
Valid bool `json:"valid"` // Valid is true if StickyStrategy is not NULL
}
func (*NullStickyStrategy) Scan ¶ added in v0.40.0
func (ns *NullStickyStrategy) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullTenantMemberRole ¶
type NullTenantMemberRole struct {
TenantMemberRole TenantMemberRole `json:"TenantMemberRole"`
Valid bool `json:"valid"` // Valid is true if TenantMemberRole is not NULL
}
func (*NullTenantMemberRole) Scan ¶
func (ns *NullTenantMemberRole) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullTenantResourceLimitAlertType ¶
type NullTenantResourceLimitAlertType struct {
TenantResourceLimitAlertType TenantResourceLimitAlertType `json:"TenantResourceLimitAlertType"`
Valid bool `json:"valid"` // Valid is true if TenantResourceLimitAlertType is not NULL
}
func (*NullTenantResourceLimitAlertType) Scan ¶
func (ns *NullTenantResourceLimitAlertType) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullVcsProvider ¶
type NullVcsProvider struct {
VcsProvider VcsProvider `json:"VcsProvider"`
Valid bool `json:"valid"` // Valid is true if VcsProvider is not NULL
}
func (*NullVcsProvider) Scan ¶
func (ns *NullVcsProvider) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullWebhookWorkerRequestMethod ¶ added in v0.42.13
type NullWebhookWorkerRequestMethod struct {
WebhookWorkerRequestMethod WebhookWorkerRequestMethod `json:"WebhookWorkerRequestMethod"`
Valid bool `json:"valid"` // Valid is true if WebhookWorkerRequestMethod is not NULL
}
func (*NullWebhookWorkerRequestMethod) Scan ¶ added in v0.42.13
func (ns *NullWebhookWorkerRequestMethod) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullWorkerLabelComparator ¶ added in v0.40.0
type NullWorkerLabelComparator struct {
WorkerLabelComparator WorkerLabelComparator `json:"WorkerLabelComparator"`
Valid bool `json:"valid"` // Valid is true if WorkerLabelComparator is not NULL
}
func (*NullWorkerLabelComparator) Scan ¶ added in v0.40.0
func (ns *NullWorkerLabelComparator) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullWorkerSDKS ¶ added in v0.50.4
type NullWorkerSDKS struct {
WorkerSDKS WorkerSDKS `json:"WorkerSDKS"`
Valid bool `json:"valid"` // Valid is true if WorkerSDKS is not NULL
}
func (*NullWorkerSDKS) Scan ¶ added in v0.50.4
func (ns *NullWorkerSDKS) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullWorkerType ¶ added in v0.42.10
type NullWorkerType struct {
WorkerType WorkerType `json:"WorkerType"`
Valid bool `json:"valid"` // Valid is true if WorkerType is not NULL
}
func (*NullWorkerType) Scan ¶ added in v0.42.10
func (ns *NullWorkerType) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullWorkflowKind ¶ added in v0.41.0
type NullWorkflowKind struct {
WorkflowKind WorkflowKind `json:"WorkflowKind"`
Valid bool `json:"valid"` // Valid is true if WorkflowKind is not NULL
}
func (*NullWorkflowKind) Scan ¶ added in v0.41.0
func (ns *NullWorkflowKind) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullWorkflowRunStatus ¶
type NullWorkflowRunStatus struct {
WorkflowRunStatus WorkflowRunStatus `json:"WorkflowRunStatus"`
Valid bool `json:"valid"` // Valid is true if WorkflowRunStatus is not NULL
}
func (*NullWorkflowRunStatus) Scan ¶
func (ns *NullWorkflowRunStatus) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullWorkflowTriggerCronRefMethods ¶ added in v0.52.0
type NullWorkflowTriggerCronRefMethods struct {
WorkflowTriggerCronRefMethods WorkflowTriggerCronRefMethods `json:"WorkflowTriggerCronRefMethods"`
Valid bool `json:"valid"` // Valid is true if WorkflowTriggerCronRefMethods is not NULL
}
func (*NullWorkflowTriggerCronRefMethods) Scan ¶ added in v0.52.0
func (ns *NullWorkflowTriggerCronRefMethods) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullWorkflowTriggerScheduledRefMethods ¶ added in v0.52.0
type NullWorkflowTriggerScheduledRefMethods struct {
WorkflowTriggerScheduledRefMethods WorkflowTriggerScheduledRefMethods `json:"WorkflowTriggerScheduledRefMethods"`
Valid bool `json:"valid"` // Valid is true if WorkflowTriggerScheduledRefMethods is not NULL
}
func (*NullWorkflowTriggerScheduledRefMethods) Scan ¶ added in v0.52.0
func (ns *NullWorkflowTriggerScheduledRefMethods) Scan(value interface{}) error
Scan implements the Scanner interface.
type PollCronSchedulesRow ¶
type PollCronSchedulesRow struct {
ParentId pgtype.UUID `json:"parentId"`
Cron string `json:"cron"`
TickerId pgtype.UUID `json:"tickerId"`
Input []byte `json:"input"`
Enabled bool `json:"enabled"`
AdditionalMetadata []byte `json:"additionalMetadata"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
Name pgtype.Text `json:"name"`
ID pgtype.UUID `json:"id"`
Method WorkflowTriggerCronRefMethods `json:"method"`
WorkflowVersionId pgtype.UUID `json:"workflowVersionId"`
TenantId pgtype.UUID `json:"tenantId"`
}
type PollExpiringTokensRow ¶
type PollScheduledWorkflowsRow ¶
type PollScheduledWorkflowsRow struct {
ID pgtype.UUID `json:"id"`
ParentId pgtype.UUID `json:"parentId"`
TriggerAt pgtype.Timestamp `json:"triggerAt"`
TickerId pgtype.UUID `json:"tickerId"`
Input []byte `json:"input"`
ChildIndex pgtype.Int4 `json:"childIndex"`
ChildKey pgtype.Text `json:"childKey"`
ParentStepRunId pgtype.UUID `json:"parentStepRunId"`
ParentWorkflowRunId pgtype.UUID `json:"parentWorkflowRunId"`
AdditionalMetadata []byte `json:"additionalMetadata"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
Method WorkflowTriggerScheduledRefMethods `json:"method"`
WorkflowVersionId pgtype.UUID `json:"workflowVersionId"`
TenantId pgtype.UUID `json:"tenantId"`
}
type PollTenantAlertsRow ¶
type PollTenantAlertsRow struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
TenantId pgtype.UUID `json:"tenantId"`
MaxFrequency string `json:"maxFrequency"`
LastAlertedAt pgtype.Timestamp `json:"lastAlertedAt"`
TickerId pgtype.UUID `json:"tickerId"`
EnableExpiringTokenAlerts bool `json:"enableExpiringTokenAlerts"`
EnableWorkflowRunFailureAlerts bool `json:"enableWorkflowRunFailureAlerts"`
EnableTenantResourceLimitAlerts bool `json:"enableTenantResourceLimitAlerts"`
PrevLastAlertedAt pgtype.Timestamp `json:"prevLastAlertedAt"`
}
type PollUnresolvedFailedStepRunsRow ¶ added in v0.36.7
type PopTimeoutQueueItemsParams ¶ added in v0.44.5
type Queries ¶
type Queries struct {
}
func (*Queries) AcquireOrExtendLeases ¶ added in v0.50.0
func (q *Queries) AcquireOrExtendLeases(ctx context.Context, db DBTX, arg AcquireOrExtendLeasesParams) ([]*Lease, error)
Attempts to acquire leases for a set of resources, and extends the leases if we already have them. Returns the acquired leases. On conflict, acquire the lease if the existing lease has expired.
func (*Queries) AddStepParents ¶
func (*Queries) AddWorkflowTag ¶
func (*Queries) ArchiveStepRunResultFromStepRun ¶
func (q *Queries) ArchiveStepRunResultFromStepRun(ctx context.Context, db DBTX, arg ArchiveStepRunResultFromStepRunParams) (*StepRunResultArchive, error)
func (*Queries) AssignGetGroupKeyRunToTicker ¶
func (q *Queries) AssignGetGroupKeyRunToTicker(ctx context.Context, db DBTX, arg AssignGetGroupKeyRunToTickerParams) (*AssignGetGroupKeyRunToTickerRow, error)
func (*Queries) AssignGetGroupKeyRunToWorker ¶
func (q *Queries) AssignGetGroupKeyRunToWorker(ctx context.Context, db DBTX, arg AssignGetGroupKeyRunToWorkerParams) (*AssignGetGroupKeyRunToWorkerRow, error)
func (*Queries) BulkCancelStepRun ¶ added in v0.44.5
func (*Queries) BulkCreateStepRunEvent ¶ added in v0.42.0
func (*Queries) BulkCreateWorkflowRunEvent ¶ added in v0.45.0
func (*Queries) BulkFailStepRun ¶ added in v0.44.5
func (*Queries) BulkFinishStepRun ¶ added in v0.44.5
func (*Queries) BulkMarkStepRunsAsCancelling ¶ added in v0.42.0
func (*Queries) BulkQueueItems ¶ added in v0.42.0
func (*Queries) BulkStartStepRun ¶ added in v0.44.5
func (*Queries) BulkUpdateRateLimits ¶ added in v0.42.0
func (*Queries) CheckWorker ¶ added in v0.40.0
func (*Queries) CleanupInternalQueueItems ¶ added in v0.44.0
func (*Queries) CleanupQueueItems ¶ added in v0.43.2
func (*Queries) CleanupRetryQueueItems ¶ added in v0.52.0
func (*Queries) CleanupStreamEvents ¶
func (*Queries) CleanupTimeoutQueueItems ¶ added in v0.44.5
func (*Queries) ClearEventPayloadData ¶ added in v0.39.0
func (*Queries) ClearJobRunLookupData ¶ added in v0.39.0
func (*Queries) ClearStepRunPayloadData ¶ added in v0.39.0
func (*Queries) ControllerPartitionHeartbeat ¶ added in v0.42.0
func (*Queries) CountCronWorkflows ¶ added in v0.51.0
func (q *Queries) CountCronWorkflows(ctx context.Context, db DBTX, arg CountCronWorkflowsParams) (int64, error)
Get all of the latest workflow versions for the tenant
func (*Queries) CountEvents ¶
func (*Queries) CountLogLines ¶
func (*Queries) CountRateLimits ¶ added in v0.47.0
func (*Queries) CountRoundRobinGroupKeys ¶
func (*Queries) CountScheduledWorkflows ¶ added in v0.51.0
func (*Queries) CountStepRunArchives ¶ added in v0.34.2
func (*Queries) CountStepRunEvents ¶
func (*Queries) CountTenantWorkers ¶
func (*Queries) CountWorkflowRuns ¶
func (*Queries) CountWorkflowRunsRoundRobin ¶
func (*Queries) CountWorkflows ¶
func (*Queries) CreateAPIToken ¶
func (*Queries) CreateControllerPartition ¶ added in v0.34.2
func (*Queries) CreateDispatcher ¶
func (*Queries) CreateEvent ¶
func (*Queries) CreateEventKeys ¶ added in v0.49.3
func (*Queries) CreateEvents ¶ added in v0.46.0
func (*Queries) CreateGetGroupKeyRun ¶
func (q *Queries) CreateGetGroupKeyRun(ctx context.Context, db DBTX, arg CreateGetGroupKeyRunParams) (*GetGroupKeyRun, error)
func (*Queries) CreateGetGroupKeyRuns ¶ added in v0.50.0
func (*Queries) CreateInternalQueueItemsBulk ¶ added in v0.44.0
func (*Queries) CreateJobRunLookupData ¶
func (q *Queries) CreateJobRunLookupData(ctx context.Context, db DBTX, arg CreateJobRunLookupDataParams) (*JobRunLookupData, error)
func (*Queries) CreateJobRunLookupDatas ¶ added in v0.50.0
func (q *Queries) CreateJobRunLookupDatas(ctx context.Context, db DBTX, arg CreateJobRunLookupDatasParams) ([]*JobRunLookupData, error)
func (*Queries) CreateJobRuns ¶
func (*Queries) CreateLogLine ¶
func (*Queries) CreateManyJobRuns ¶ added in v0.50.0
func (q *Queries) CreateManyJobRuns(ctx context.Context, db DBTX, arg CreateManyJobRunsParams) ([]*CreateManyJobRunsRow, error)
func (*Queries) CreateMultipleWorkflowRunStickyStates ¶ added in v0.50.0
func (*Queries) CreateQueueItem ¶ added in v0.42.0
func (*Queries) CreateQueueItemsBulk ¶ added in v0.50.0
func (*Queries) CreateRetryQueueItem ¶ added in v0.52.0
func (*Queries) CreateSchedulerPartition ¶ added in v0.50.0
func (*Queries) CreateSchedules ¶
func (q *Queries) CreateSchedules(ctx context.Context, db DBTX, arg CreateSchedulesParams) ([]*WorkflowTriggerScheduledRef, error)
func (*Queries) CreateStep ¶
func (*Queries) CreateStepExpressions ¶ added in v0.47.0
func (*Queries) CreateStepRateLimit ¶
func (q *Queries) CreateStepRateLimit(ctx context.Context, db DBTX, arg CreateStepRateLimitParams) (*StepRateLimit, error)
func (*Queries) CreateStepRun ¶ added in v0.42.0
func (*Queries) CreateStepRunEvent ¶
func (*Queries) CreateStepRunExpressionEvalInts ¶ added in v0.47.0
func (*Queries) CreateStepRunExpressionEvalStrs ¶ added in v0.47.0
func (*Queries) CreateStepRuns ¶
func (*Queries) CreateStepRunsForJobRunIds ¶ added in v0.50.0
func (*Queries) CreateStreamEvent ¶
func (q *Queries) CreateStreamEvent(ctx context.Context, db DBTX, arg CreateStreamEventParams) (*StreamEvent, error)
func (*Queries) CreateTenant ¶ added in v0.34.2
func (*Queries) CreateTenantAlertingSettings ¶ added in v0.34.2
func (*Queries) CreateTenantWorkerPartition ¶ added in v0.34.2
func (*Queries) CreateTicker ¶
func (*Queries) CreateTimeoutQueueItem ¶ added in v0.44.5
func (*Queries) CreateUniqueInternalQueueItemsBulk ¶ added in v0.44.0
func (*Queries) CreateWebhookWorker ¶ added in v0.42.13
func (q *Queries) CreateWebhookWorker(ctx context.Context, db DBTX, arg CreateWebhookWorkerParams) (*WebhookWorker, error)
func (*Queries) CreateWorker ¶
func (*Queries) CreateWorkerAssignEvents ¶ added in v0.44.0
func (*Queries) CreateWorkflow ¶
func (*Queries) CreateWorkflowConcurrency ¶
func (q *Queries) CreateWorkflowConcurrency(ctx context.Context, db DBTX, arg CreateWorkflowConcurrencyParams) (*WorkflowConcurrency, error)
func (*Queries) CreateWorkflowRun ¶
func (q *Queries) CreateWorkflowRun(ctx context.Context, db DBTX, arg CreateWorkflowRunParams) (*WorkflowRun, error)
func (*Queries) CreateWorkflowRunDedupe ¶ added in v0.40.0
func (q *Queries) CreateWorkflowRunDedupe(ctx context.Context, db DBTX, arg CreateWorkflowRunDedupeParams) (*WorkflowRunDedupe, error)
func (*Queries) CreateWorkflowRunStickyState ¶ added in v0.40.0
func (q *Queries) CreateWorkflowRunStickyState(ctx context.Context, db DBTX, arg CreateWorkflowRunStickyStateParams) (*WorkflowRunStickyState, error)
func (*Queries) CreateWorkflowRunTriggeredBy ¶
func (q *Queries) CreateWorkflowRunTriggeredBy(ctx context.Context, db DBTX, arg CreateWorkflowRunTriggeredByParams) (*WorkflowRunTriggeredBy, error)
func (*Queries) CreateWorkflowRunTriggeredBys ¶ added in v0.50.0
func (*Queries) CreateWorkflowRuns ¶ added in v0.50.0
func (*Queries) CreateWorkflowTriggerCronRef ¶
func (q *Queries) CreateWorkflowTriggerCronRef(ctx context.Context, db DBTX, arg CreateWorkflowTriggerCronRefParams) (*WorkflowTriggerCronRef, error)
func (*Queries) CreateWorkflowTriggerCronRefForWorkflow ¶ added in v0.52.0
func (q *Queries) CreateWorkflowTriggerCronRefForWorkflow(ctx context.Context, db DBTX, arg CreateWorkflowTriggerCronRefForWorkflowParams) (*WorkflowTriggerCronRef, error)
func (*Queries) CreateWorkflowTriggerEventRef ¶
func (q *Queries) CreateWorkflowTriggerEventRef(ctx context.Context, db DBTX, arg CreateWorkflowTriggerEventRefParams) (*WorkflowTriggerEventRef, error)
func (*Queries) CreateWorkflowTriggerScheduledRef ¶
func (q *Queries) CreateWorkflowTriggerScheduledRef(ctx context.Context, db DBTX, arg CreateWorkflowTriggerScheduledRefParams) (*WorkflowTriggerScheduledRef, error)
func (*Queries) CreateWorkflowTriggerScheduledRefForWorkflow ¶ added in v0.52.0
func (q *Queries) CreateWorkflowTriggerScheduledRefForWorkflow(ctx context.Context, db DBTX, arg CreateWorkflowTriggerScheduledRefForWorkflowParams) (*WorkflowTriggerScheduledRef, error)
func (*Queries) CreateWorkflowTriggers ¶
func (q *Queries) CreateWorkflowTriggers(ctx context.Context, db DBTX, arg CreateWorkflowTriggersParams) (*WorkflowTriggers, error)
func (*Queries) CreateWorkflowVersion ¶
func (q *Queries) CreateWorkflowVersion(ctx context.Context, db DBTX, arg CreateWorkflowVersionParams) (*WorkflowVersion, error)
func (*Queries) DeactivateTicker ¶ added in v0.42.0
func (*Queries) DeleteControllerPartition ¶ added in v0.34.2
func (*Queries) DeleteDispatcher ¶
func (*Queries) DeleteOldWorkerAssignEvents ¶ added in v0.44.3
func (q *Queries) DeleteOldWorkerAssignEvents(ctx context.Context, db DBTX, arg DeleteOldWorkerAssignEventsParams) (bool, error)
delete worker assign events outside of the first <maxRuns> events for a worker
func (*Queries) DeleteOldWorkers ¶ added in v0.44.0
func (*Queries) DeleteScheduledWorkflow ¶ added in v0.51.0
func (*Queries) DeleteSchedulerPartition ¶ added in v0.50.0
func (*Queries) DeleteTenantWorkerPartition ¶ added in v0.34.2
func (*Queries) DeleteWorker ¶
func (*Queries) DeleteWorkflowTriggerCronRef ¶ added in v0.52.0
func (*Queries) GetAPITokenById ¶
func (*Queries) GetChildWorkflowRun ¶
func (q *Queries) GetChildWorkflowRun(ctx context.Context, db DBTX, arg GetChildWorkflowRunParams) (*WorkflowRun, error)
func (*Queries) GetChildWorkflowRunsByIndex ¶ added in v0.50.0
func (q *Queries) GetChildWorkflowRunsByIndex(ctx context.Context, db DBTX, arg GetChildWorkflowRunsByIndexParams) ([]*WorkflowRun, error)
func (*Queries) GetChildWorkflowRunsByKey ¶ added in v0.50.0
func (q *Queries) GetChildWorkflowRunsByKey(ctx context.Context, db DBTX, arg GetChildWorkflowRunsByKeyParams) ([]*WorkflowRun, error)
func (*Queries) GetDesiredLabels ¶ added in v0.42.0
func (*Queries) GetEmailGroups ¶
func (*Queries) GetEventForEngine ¶
func (*Queries) GetEventsForRange ¶
func (*Queries) GetFailureDetails ¶ added in v0.51.0
func (q *Queries) GetFailureDetails(ctx context.Context, db DBTX, arg GetFailureDetailsParams) ([]*GetFailureDetailsRow, error)
func (*Queries) GetFinalizedStepRuns ¶ added in v0.44.0
func (*Queries) GetGroupKeyRunForEngine ¶
func (q *Queries) GetGroupKeyRunForEngine(ctx context.Context, db DBTX, arg GetGroupKeyRunForEngineParams) ([]*GetGroupKeyRunForEngineRow, error)
func (*Queries) GetInsertedEvents ¶ added in v0.46.0
func (*Queries) GetJobRunByWorkflowRunIdAndJobId ¶
func (q *Queries) GetJobRunByWorkflowRunIdAndJobId(ctx context.Context, db DBTX, arg GetJobRunByWorkflowRunIdAndJobIdParams) (*GetJobRunByWorkflowRunIdAndJobIdRow, error)
func (*Queries) GetJobRunsByWorkflowRunId ¶ added in v0.50.0
func (q *Queries) GetJobRunsByWorkflowRunId(ctx context.Context, db DBTX, arg GetJobRunsByWorkflowRunIdParams) ([]*GetJobRunsByWorkflowRunIdRow, error)
func (*Queries) GetLaterStepRuns ¶ added in v0.44.0
func (*Queries) GetLatestWorkflowVersionForWorkflows ¶ added in v0.50.0
func (*Queries) GetLeasesToAcquire ¶ added in v0.50.0
func (*Queries) GetMemberEmailGroup ¶
func (*Queries) GetMinMaxProcessedInternalQueueItems ¶ added in v0.44.0
func (*Queries) GetMinMaxProcessedQueueItems ¶ added in v0.43.2
func (*Queries) GetMinMaxProcessedRetryQueueItems ¶ added in v0.52.0
func (*Queries) GetMinMaxProcessedTimeoutQueueItems ¶ added in v0.44.5
func (*Queries) GetMinUnprocessedQueueItemId ¶ added in v0.50.0
func (*Queries) GetQueuedCounts ¶ added in v0.46.1
func (*Queries) GetScheduledChildWorkflowRun ¶
func (q *Queries) GetScheduledChildWorkflowRun(ctx context.Context, db DBTX, arg GetScheduledChildWorkflowRunParams) (*WorkflowTriggerScheduledRef, error)
func (*Queries) GetSecurityCheckIdent ¶ added in v0.34.2
func (*Queries) GetSlackWebhooks ¶
func (*Queries) GetStepDesiredWorkerLabels ¶ added in v0.40.0
func (*Queries) GetStepExpressions ¶ added in v0.47.0
func (*Queries) GetStepRun ¶
func (*Queries) GetStepRunBulkDataForEngine ¶ added in v0.50.0
func (q *Queries) GetStepRunBulkDataForEngine(ctx context.Context, db DBTX, arg GetStepRunBulkDataForEngineParams) ([]*GetStepRunBulkDataForEngineRow, error)
func (*Queries) GetStepRunDataForEngine ¶ added in v0.36.9
func (q *Queries) GetStepRunDataForEngine(ctx context.Context, db DBTX, arg GetStepRunDataForEngineParams) (*GetStepRunDataForEngineRow, error)
func (*Queries) GetStepRunForEngine ¶
func (q *Queries) GetStepRunForEngine(ctx context.Context, db DBTX, arg GetStepRunForEngineParams) ([]*GetStepRunForEngineRow, error)
func (*Queries) GetStepRunMeta ¶ added in v0.41.0
func (q *Queries) GetStepRunMeta(ctx context.Context, db DBTX, arg GetStepRunMetaParams) (*GetStepRunMetaRow, error)
func (*Queries) GetStepRunsForJobRunsWithOutput ¶ added in v0.46.1
func (q *Queries) GetStepRunsForJobRunsWithOutput(ctx context.Context, db DBTX, arg GetStepRunsForJobRunsWithOutputParams) ([]*GetStepRunsForJobRunsWithOutputRow, error)
We grab the output for each step run here which could potentially be very large
func (*Queries) GetStepsForJobs ¶ added in v0.44.8
func (q *Queries) GetStepsForJobs(ctx context.Context, db DBTX, arg GetStepsForJobsParams) ([]*GetStepsForJobsRow, error)
func (*Queries) GetStepsForWorkflowVersion ¶ added in v0.50.0
func (*Queries) GetStreamEvent ¶
func (q *Queries) GetStreamEvent(ctx context.Context, db DBTX, arg GetStreamEventParams) (*StreamEvent, error)
func (*Queries) GetStreamEventMeta ¶ added in v0.41.0
func (q *Queries) GetStreamEventMeta(ctx context.Context, db DBTX, arg GetStreamEventMetaParams) (*GetStreamEventMetaRow, error)
func (*Queries) GetTenantAlertingSettings ¶
func (*Queries) GetTenantByID ¶
func (*Queries) GetTenantResourceLimit ¶
func (q *Queries) GetTenantResourceLimit(ctx context.Context, db DBTX, arg GetTenantResourceLimitParams) (*GetTenantResourceLimitRow, error)
func (*Queries) GetTenantTotalQueueMetrics ¶
func (q *Queries) GetTenantTotalQueueMetrics(ctx context.Context, db DBTX, arg GetTenantTotalQueueMetricsParams) (*GetTenantTotalQueueMetricsRow, error)
func (*Queries) GetTenantWorkflowQueueMetrics ¶
func (q *Queries) GetTenantWorkflowQueueMetrics(ctx context.Context, db DBTX, arg GetTenantWorkflowQueueMetricsParams) ([]*GetTenantWorkflowQueueMetricsRow, error)
func (*Queries) GetWorkerActionsByWorkerId ¶ added in v0.42.13
func (*Queries) GetWorkerById ¶ added in v0.42.10
func (*Queries) GetWorkerByWebhookId ¶ added in v0.42.10
func (*Queries) GetWorkerDispatcherActions ¶ added in v0.44.0
func (q *Queries) GetWorkerDispatcherActions(ctx context.Context, db DBTX, arg GetWorkerDispatcherActionsParams) ([]*GetWorkerDispatcherActionsRow, error)
func (*Queries) GetWorkerForEngine ¶
func (q *Queries) GetWorkerForEngine(ctx context.Context, db DBTX, arg GetWorkerForEngineParams) (*GetWorkerForEngineRow, error)
func (*Queries) GetWorkerLabels ¶ added in v0.42.0
func (*Queries) GetWorkflowById ¶ added in v0.44.8
func (*Queries) GetWorkflowByName ¶
func (*Queries) GetWorkflowLatestVersion ¶
func (*Queries) GetWorkflowRun ¶
func (q *Queries) GetWorkflowRun(ctx context.Context, db DBTX, arg GetWorkflowRunParams) ([]*GetWorkflowRunRow, error)
func (*Queries) GetWorkflowRunAdditionalMeta ¶ added in v0.41.0
func (q *Queries) GetWorkflowRunAdditionalMeta(ctx context.Context, db DBTX, arg GetWorkflowRunAdditionalMetaParams) (*GetWorkflowRunAdditionalMetaRow, error)
func (*Queries) GetWorkflowRunById ¶ added in v0.44.8
func (q *Queries) GetWorkflowRunById(ctx context.Context, db DBTX, arg GetWorkflowRunByIdParams) (*GetWorkflowRunByIdRow, error)
func (*Queries) GetWorkflowRunByIds ¶ added in v0.50.0
func (q *Queries) GetWorkflowRunByIds(ctx context.Context, db DBTX, arg GetWorkflowRunByIdsParams) ([]*GetWorkflowRunByIdsRow, error)
func (*Queries) GetWorkflowRunInput ¶ added in v0.40.0
func (*Queries) GetWorkflowRunStickyStateForUpdate ¶ added in v0.40.0
func (q *Queries) GetWorkflowRunStickyStateForUpdate(ctx context.Context, db DBTX, arg GetWorkflowRunStickyStateForUpdateParams) (*WorkflowRunStickyState, error)
func (*Queries) GetWorkflowRunTrigger ¶ added in v0.44.8
func (q *Queries) GetWorkflowRunTrigger(ctx context.Context, db DBTX, arg GetWorkflowRunTriggerParams) (*WorkflowRunTriggeredBy, error)
func (*Queries) GetWorkflowRunsInsertedInThisTxn ¶ added in v0.50.0
func (*Queries) GetWorkflowVersionById ¶ added in v0.44.8
func (*Queries) GetWorkflowVersionCronTriggerRefs ¶ added in v0.44.8
func (*Queries) GetWorkflowVersionEventTriggerRefs ¶ added in v0.44.8
func (*Queries) GetWorkflowVersionForEngine ¶
func (q *Queries) GetWorkflowVersionForEngine(ctx context.Context, db DBTX, arg GetWorkflowVersionForEngineParams) ([]*GetWorkflowVersionForEngineRow, error)
func (*Queries) GetWorkflowVersionScheduleTriggerRefs ¶ added in v0.44.8
func (*Queries) GetWorkflowWorkerCount ¶ added in v0.45.2
func (q *Queries) GetWorkflowWorkerCount(ctx context.Context, db DBTX, arg GetWorkflowWorkerCountParams) (*GetWorkflowWorkerCountRow, error)
func (*Queries) GetWorkflowsByNames ¶ added in v0.50.0
func (*Queries) HandleWorkflowUnpaused ¶ added in v0.48.0
func (q *Queries) HandleWorkflowUnpaused(ctx context.Context, db DBTX, arg HandleWorkflowUnpausedParams) error
We update all the queue items to have a higher priority so we can unpause them
func (*Queries) HardDeleteWebhookWorker ¶ added in v0.42.13
func (*Queries) HasActiveWorkersForActionId ¶ added in v0.44.8
func (*Queries) InsertWebhookWorkerRequest ¶ added in v0.42.13
func (*Queries) LinkActionsToWorker ¶
func (*Queries) LinkOnFailureJob ¶
func (q *Queries) LinkOnFailureJob(ctx context.Context, db DBTX, arg LinkOnFailureJobParams) (*WorkflowVersion, error)
func (*Queries) LinkServicesToWorker ¶
func (*Queries) LinkStepRunParents ¶
func (*Queries) ListActionsForAvailableWorkers ¶ added in v0.50.0
func (*Queries) ListActionsForWorkers ¶ added in v0.50.0
func (q *Queries) ListActionsForWorkers(ctx context.Context, db DBTX, arg ListActionsForWorkersParams) ([]*ListActionsForWorkersRow, error)
func (*Queries) ListActiveDispatchers ¶
func (*Queries) ListActiveQueuedWorkflowVersions ¶ added in v0.36.7
func (*Queries) ListActiveTickers ¶
func (*Queries) ListActiveWebhookWorkers ¶ added in v0.34.0
func (*Queries) ListActiveWorkers ¶ added in v0.50.0
func (*Queries) ListAllAvailableSlotsForWorkers ¶ added in v0.50.0
func (q *Queries) ListAllAvailableSlotsForWorkers(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]*ListAllAvailableSlotsForWorkersRow, error)
subtract the filled slots from the max runs to get the available slots
func (*Queries) ListAllWorkerActions ¶ added in v0.50.0
func (*Queries) ListAvailableSlotsForWorkers ¶ added in v0.44.7
func (q *Queries) ListAvailableSlotsForWorkers(ctx context.Context, db DBTX, arg ListAvailableSlotsForWorkersParams) ([]*ListAvailableSlotsForWorkersRow, error)
subtract the filled slots from the max runs to get the available slots
func (*Queries) ListChildWorkflowRunCounts ¶ added in v0.44.8
func (*Queries) ListChildWorkflowRunIds ¶ added in v0.44.8
func (*Queries) ListCronWorkflows ¶ added in v0.51.0
func (q *Queries) ListCronWorkflows(ctx context.Context, db DBTX, arg ListCronWorkflowsParams) ([]*ListCronWorkflowsRow, error)
Get all of the latest workflow versions for the tenant
func (*Queries) ListDispatcherIdsForWorkers ¶ added in v0.50.0
func (q *Queries) ListDispatcherIdsForWorkers(ctx context.Context, db DBTX, arg ListDispatcherIdsForWorkersParams) ([]*ListDispatcherIdsForWorkersRow, error)
func (*Queries) ListDispatchers ¶
func (*Queries) ListEventKeys ¶ added in v0.49.3
func (*Queries) ListEvents ¶
func (q *Queries) ListEvents(ctx context.Context, db DBTX, arg ListEventsParams) ([]*ListEventsRow, error)
func (*Queries) ListEventsByIDs ¶
func (*Queries) ListGetGroupKeyRunsToReassign ¶
func (*Queries) ListGetGroupKeyRunsToRequeue ¶
func (*Queries) ListInitialStepRuns ¶ added in v0.44.0
func (*Queries) ListInternalQueueItems ¶ added in v0.44.0
func (q *Queries) ListInternalQueueItems(ctx context.Context, db DBTX, arg ListInternalQueueItemsParams) ([]*InternalQueueItem, error)
func (*Queries) ListJobRunsForWorkflowRun ¶
func (*Queries) ListJobRunsForWorkflowRunFull ¶ added in v0.44.8
func (q *Queries) ListJobRunsForWorkflowRunFull(ctx context.Context, db DBTX, arg ListJobRunsForWorkflowRunFullParams) ([]*ListJobRunsForWorkflowRunFullRow, error)
func (*Queries) ListLogLines ¶
func (*Queries) ListManyWorkerLabels ¶ added in v0.50.0
func (*Queries) ListNewlyStaleTickers ¶
func (*Queries) ListNonFinalChildStepRuns ¶
func (q *Queries) ListNonFinalChildStepRuns(ctx context.Context, db DBTX, steprunid pgtype.UUID) ([]*StepRun, error)
Select all child step runs that are not in a final state
func (*Queries) ListPausedWorkflows ¶ added in v0.48.0
func (*Queries) ListQueueItems ¶ added in v0.42.0
func (q *Queries) ListQueueItems(ctx context.Context, db DBTX, arg []ListQueueItemsParams) *ListQueueItemsBatchResults
func (*Queries) ListQueueItemsForQueue ¶ added in v0.50.0
func (q *Queries) ListQueueItemsForQueue(ctx context.Context, db DBTX, arg ListQueueItemsForQueueParams) ([]*ListQueueItemsForQueueRow, error)
func (*Queries) ListQueues ¶ added in v0.42.0
func (*Queries) ListRateLimitsForSteps ¶ added in v0.42.0
func (q *Queries) ListRateLimitsForSteps(ctx context.Context, db DBTX, arg ListRateLimitsForStepsParams) ([]*StepRateLimit, error)
func (*Queries) ListRateLimitsForTenantNoMutate ¶ added in v0.47.0
func (q *Queries) ListRateLimitsForTenantNoMutate(ctx context.Context, db DBTX, arg ListRateLimitsForTenantNoMutateParams) ([]*ListRateLimitsForTenantNoMutateRow, error)
Returns the same results as ListRateLimitsForTenantWithMutate but does not update the rate limit values
func (*Queries) ListRateLimitsForTenantWithMutate ¶ added in v0.47.0
func (*Queries) ListRecentAssignedEventsForWorker ¶ added in v0.44.0
func (q *Queries) ListRecentAssignedEventsForWorker(ctx context.Context, db DBTX, arg ListRecentAssignedEventsForWorkerParams) ([]*ListRecentAssignedEventsForWorkerRow, error)
func (*Queries) ListScheduledWorkflows ¶ added in v0.51.0
func (q *Queries) ListScheduledWorkflows(ctx context.Context, db DBTX, arg ListScheduledWorkflowsParams) ([]*ListScheduledWorkflowsRow, error)
func (*Queries) ListSemaphoreSlotsWithStateForWorker ¶ added in v0.42.0
func (q *Queries) ListSemaphoreSlotsWithStateForWorker(ctx context.Context, db DBTX, arg ListSemaphoreSlotsWithStateForWorkerParams) ([]*ListSemaphoreSlotsWithStateForWorkerRow, error)
func (*Queries) ListStaleDispatchers ¶
func (*Queries) ListStartableStepRunsManyParents ¶ added in v0.49.1
func (*Queries) ListStartableStepRunsSingleParent ¶ added in v0.49.1
func (*Queries) ListStepRunArchives ¶ added in v0.34.2
func (q *Queries) ListStepRunArchives(ctx context.Context, db DBTX, arg ListStepRunArchivesParams) ([]*StepRunResultArchive, error)
func (*Queries) ListStepRunEvents ¶
func (q *Queries) ListStepRunEvents(ctx context.Context, db DBTX, arg ListStepRunEventsParams) ([]*StepRunEvent, error)
func (*Queries) ListStepRunEventsByWorkflowRunId ¶ added in v0.44.8
func (q *Queries) ListStepRunEventsByWorkflowRunId(ctx context.Context, db DBTX, arg ListStepRunEventsByWorkflowRunIdParams) ([]*StepRunEvent, error)
func (*Queries) ListStepRunExpressionEvals ¶ added in v0.47.0
func (*Queries) ListStepRuns ¶
func (*Queries) ListStepRunsToCancel ¶ added in v0.51.2
func (*Queries) ListStepRunsToReassign ¶
func (q *Queries) ListStepRunsToReassign(ctx context.Context, db DBTX, arg ListStepRunsToReassignParams) ([]*ListStepRunsToReassignRow, error)
func (*Queries) ListStepRunsToRetry ¶ added in v0.52.0
func (*Queries) ListStepRunsToTimeout ¶ added in v0.36.7
func (*Queries) ListStepsForJob ¶ added in v0.42.0
func (*Queries) ListTenantResourceLimits ¶
func (*Queries) ListTenants ¶
func (*Queries) ListTenantsByControllerPartitionId ¶ added in v0.34.2
func (*Queries) ListTenantsBySchedulerPartitionId ¶ added in v0.50.0
func (*Queries) ListTenantsByTenantWorkerPartitionId ¶ added in v0.34.2
func (*Queries) ListTickers ¶
func (*Queries) ListWebhookWorkerRequests ¶ added in v0.42.13
func (*Queries) ListWebhookWorkersByPartitionId ¶ added in v0.34.2
func (*Queries) ListWorkerLabels ¶ added in v0.40.0
func (*Queries) ListWorkersWithSlotCount ¶ added in v0.44.0
func (q *Queries) ListWorkersWithSlotCount(ctx context.Context, db DBTX, arg ListWorkersWithSlotCountParams) ([]*ListWorkersWithSlotCountRow, error)
func (*Queries) ListWorkflowRunEventsByWorkflowRunId ¶ added in v0.45.0
func (*Queries) ListWorkflowRuns ¶
func (q *Queries) ListWorkflowRuns(ctx context.Context, db DBTX, arg ListWorkflowRunsParams) ([]*ListWorkflowRunsRow, error)
func (*Queries) ListWorkflows ¶
func (q *Queries) ListWorkflows(ctx context.Context, db DBTX, arg ListWorkflowsParams) ([]*ListWorkflowsRow, error)
func (*Queries) ListWorkflowsForEvent ¶
func (q *Queries) ListWorkflowsForEvent(ctx context.Context, db DBTX, arg ListWorkflowsForEventParams) ([]pgtype.UUID, error)
Get all of the latest workflow versions for the tenant select the workflow versions that have the event trigger
func (*Queries) ListWorkflowsLatestRuns ¶
func (q *Queries) ListWorkflowsLatestRuns(ctx context.Context, db DBTX, arg ListWorkflowsLatestRunsParams) ([]*ListWorkflowsLatestRunsRow, error)
func (*Queries) ManualReleaseSemaphore ¶ added in v0.44.0
func (*Queries) MarkInternalQueueItemsProcessed ¶ added in v0.44.0
func (*Queries) MeterTenantResource ¶
func (q *Queries) MeterTenantResource(ctx context.Context, db DBTX, arg MeterTenantResourceParams) (*TenantResourceLimit, error)
func (*Queries) MoveCronTriggerToNewWorkflowTriggers ¶ added in v0.52.0
func (*Queries) MoveScheduledTriggerToNewWorkflowTriggers ¶ added in v0.52.0
func (*Queries) PollCronSchedules ¶
func (*Queries) PollExpiringTokens ¶
func (*Queries) PollGetGroupKeyRuns ¶
func (*Queries) PollScheduledWorkflows ¶
func (q *Queries) PollScheduledWorkflows(ctx context.Context, db DBTX, tickerid pgtype.UUID) ([]*PollScheduledWorkflowsRow, error)
Finds workflows that are either past their execution time or will be in the next 5 seconds and assigns them to a ticker, or finds workflows that were assigned to a ticker that is no longer active
func (*Queries) PollTenantAlerts ¶
func (q *Queries) PollTenantAlerts(ctx context.Context, db DBTX, tickerid pgtype.UUID) ([]*PollTenantAlertsRow, error)
Finds tenant alerts which haven't alerted since their frequency and assigns them to a ticker
func (*Queries) PollTenantResourceLimitAlerts ¶
func (*Queries) PollUnresolvedFailedStepRuns ¶ added in v0.36.7
func (*Queries) PopTimeoutQueueItems ¶ added in v0.44.5
func (*Queries) PopWorkflowRunsRoundRobin ¶
func (q *Queries) PopWorkflowRunsRoundRobin(ctx context.Context, db DBTX, arg PopWorkflowRunsRoundRobinParams) ([]*WorkflowRun, error)
func (*Queries) QueueStepRun ¶ added in v0.44.0
func (*Queries) QueueStepRunBulkNoInput ¶ added in v0.50.0
func (*Queries) QueueStepRunBulkWithInput ¶ added in v0.50.0
func (*Queries) RebalanceAllControllerPartitions ¶ added in v0.34.2
func (*Queries) RebalanceAllSchedulerPartitions ¶ added in v0.50.0
func (*Queries) RebalanceAllTenantWorkerPartitions ¶ added in v0.34.2
func (*Queries) RebalanceInactiveControllerPartitions ¶ added in v0.34.2
func (*Queries) RebalanceInactiveSchedulerPartitions ¶ added in v0.50.0
func (*Queries) RebalanceInactiveTenantWorkerPartitions ¶ added in v0.34.2
func (*Queries) RefreshTimeoutBy ¶
func (*Queries) ReleaseLeases ¶ added in v0.50.0
Releases a set of leases by their IDs. Returns the released leases.
func (*Queries) RemoveTimeoutQueueItem ¶ added in v0.44.5
func (*Queries) RemoveTimeoutQueueItems ¶ added in v0.50.0
func (*Queries) ReplayStepRunResetJobRun ¶
func (*Queries) ReplayStepRunResetStepRuns ¶ added in v0.44.0
func (*Queries) ReplayStepRunResetWorkflowRun ¶
func (*Queries) ReplayWorkflowRunResetGetGroupKeyRun ¶ added in v0.44.8
func (*Queries) ReplayWorkflowRunResetJobRun ¶ added in v0.39.0
func (*Queries) ResetStepRunsByIds ¶ added in v0.39.0
func (*Queries) ResolveAllLimitsIfWindowPassed ¶
func (*Queries) ResolveJobRunStatus ¶
func (*Queries) ResolveLaterStepRuns ¶
func (*Queries) ResolveWorkflowRunStatus ¶
func (q *Queries) ResolveWorkflowRunStatus(ctx context.Context, db DBTX, arg ResolveWorkflowRunStatusParams) ([]*ResolveWorkflowRunStatusRow, error)
Return distinct workflow run ids in a final state
func (*Queries) SchedulerPartitionHeartbeat ¶ added in v0.50.0
func (*Queries) SelectOrInsertTenantResourceLimit ¶
func (q *Queries) SelectOrInsertTenantResourceLimit(ctx context.Context, db DBTX, arg SelectOrInsertTenantResourceLimitParams) (*SelectOrInsertTenantResourceLimitRow, error)
func (*Queries) SetDispatchersInactive ¶
func (*Queries) SetTickersInactive ¶
func (*Queries) SoftDeleteExpiredEvents ¶ added in v0.39.0
func (*Queries) SoftDeleteExpiredWorkflowRunsWithDependencies ¶ added in v0.39.0
func (*Queries) SoftDeleteWebhookWorker ¶ added in v0.42.13
func (*Queries) SoftDeleteWorkflow ¶ added in v0.39.0
func (*Queries) UpdateDispatcher ¶
func (q *Queries) UpdateDispatcher(ctx context.Context, db DBTX, arg UpdateDispatcherParams) (*Dispatcher, error)
func (*Queries) UpdateGetGroupKeyRun ¶
func (q *Queries) UpdateGetGroupKeyRun(ctx context.Context, db DBTX, arg UpdateGetGroupKeyRunParams) (*GetGroupKeyRun, error)
func (*Queries) UpdateJobRunLookupDataWithStepRun ¶
func (*Queries) UpdateJobRunStatus ¶
func (*Queries) UpdateManyWorkflowRun ¶
func (q *Queries) UpdateManyWorkflowRun(ctx context.Context, db DBTX, arg UpdateManyWorkflowRunParams) ([]*WorkflowRun, error)
func (*Queries) UpdateScheduledWorkflow ¶ added in v0.51.0
func (*Queries) UpdateStepRunInputSchema ¶
func (*Queries) UpdateStepRunOverridesData ¶
func (*Queries) UpdateStepRunUnsetWorkerId ¶ added in v0.44.0
func (q *Queries) UpdateStepRunUnsetWorkerId(ctx context.Context, db DBTX, arg UpdateStepRunUnsetWorkerIdParams) (*UpdateStepRunUnsetWorkerIdRow, error)
func (*Queries) UpdateStepRunUnsetWorkerIdBulk ¶ added in v0.50.0
func (*Queries) UpdateStepRunsToAssigned ¶ added in v0.44.0
func (q *Queries) UpdateStepRunsToAssigned(ctx context.Context, db DBTX, arg UpdateStepRunsToAssignedParams) ([]*UpdateStepRunsToAssignedRow, error)
func (*Queries) UpdateTenantAlertingSettings ¶
func (q *Queries) UpdateTenantAlertingSettings(ctx context.Context, db DBTX, arg UpdateTenantAlertingSettingsParams) (*TenantAlertingSettings, error)
func (*Queries) UpdateTicker ¶
func (*Queries) UpdateWebhookWorkerToken ¶ added in v0.42.13
func (q *Queries) UpdateWebhookWorkerToken(ctx context.Context, db DBTX, arg UpdateWebhookWorkerTokenParams) (*WebhookWorker, error)
func (*Queries) UpdateWorker ¶
func (*Queries) UpdateWorkerActiveStatus ¶
func (*Queries) UpdateWorkerHeartbeat ¶ added in v0.42.0
func (*Queries) UpdateWorkersByWebhookId ¶ added in v0.42.10
func (*Queries) UpdateWorkflow ¶ added in v0.48.0
func (*Queries) UpdateWorkflowRun ¶
func (q *Queries) UpdateWorkflowRun(ctx context.Context, db DBTX, arg UpdateWorkflowRunParams) (*WorkflowRun, error)
func (*Queries) UpdateWorkflowRunGroupKeyFromExpr ¶ added in v0.45.0
func (*Queries) UpdateWorkflowRunGroupKeyFromRun ¶ added in v0.45.0
func (q *Queries) UpdateWorkflowRunGroupKeyFromRun(ctx context.Context, db DBTX, arg UpdateWorkflowRunGroupKeyFromRunParams) (*WorkflowRun, error)
func (*Queries) UpdateWorkflowRunStickyState ¶ added in v0.40.0
func (*Queries) UpsertAction ¶
func (*Queries) UpsertDesiredWorkerLabel ¶ added in v0.40.0
func (q *Queries) UpsertDesiredWorkerLabel(ctx context.Context, db DBTX, arg UpsertDesiredWorkerLabelParams) (*StepDesiredWorkerLabel, error)
func (*Queries) UpsertJobRunLookupData ¶
func (*Queries) UpsertQueue ¶ added in v0.42.0
func (*Queries) UpsertRateLimit ¶
func (*Queries) UpsertRateLimitsBulk ¶ added in v0.47.0
func (*Queries) UpsertService ¶
func (*Queries) UpsertTenantResourceLimit ¶ added in v0.33.2
func (q *Queries) UpsertTenantResourceLimit(ctx context.Context, db DBTX, arg UpsertTenantResourceLimitParams) (*TenantResourceLimit, error)
func (*Queries) UpsertWorkerLabel ¶ added in v0.40.0
func (q *Queries) UpsertWorkerLabel(ctx context.Context, db DBTX, arg UpsertWorkerLabelParams) (*WorkerLabel, error)
func (*Queries) UpsertWorkflowTag ¶
func (*Queries) ValidatesAsJson ¶ added in v0.51.1
func (*Queries) VerifiedStepRunTenantIds ¶ added in v0.50.0
func (q *Queries) VerifiedStepRunTenantIds(ctx context.Context, db DBTX, arg VerifiedStepRunTenantIdsParams) ([]pgtype.UUID, error)
stable ordering as it minimizes the chance of deadlocks
func (*Queries) WorkerPartitionHeartbeat ¶ added in v0.43.1
func (*Queries) WorkflowRunsMetricsCount ¶
func (q *Queries) WorkflowRunsMetricsCount(ctx context.Context, db DBTX, arg WorkflowRunsMetricsCountParams) (*WorkflowRunsMetricsCountRow, error)
type QueueItem ¶ added in v0.42.0
type QueueItem struct {
ID int64 `json:"id"`
StepRunId pgtype.UUID `json:"stepRunId"`
StepId pgtype.UUID `json:"stepId"`
ActionId pgtype.Text `json:"actionId"`
ScheduleTimeoutAt pgtype.Timestamp `json:"scheduleTimeoutAt"`
StepTimeout pgtype.Text `json:"stepTimeout"`
Priority int32 `json:"priority"`
IsQueued bool `json:"isQueued"`
TenantId pgtype.UUID `json:"tenantId"`
Queue string `json:"queue"`
Sticky NullStickyStrategy `json:"sticky"`
DesiredWorkerId pgtype.UUID `json:"desiredWorkerId"`
}
type QueueStepRunBulkNoInputParams ¶ added in v0.50.0
type QueueStepRunBulkWithInputParams ¶ added in v0.50.0
type QueueStepRunParams ¶ added in v0.44.0
type RefreshTimeoutByParams ¶
type RemoveTimeoutQueueItemParams ¶ added in v0.44.5
type ReplayStepRunResetStepRunsParams ¶ added in v0.44.0
type ResetStepRunsByIdsParams ¶ added in v0.39.0
type ResolveAllLimitsIfWindowPassedRow ¶
type ResolveAllLimitsIfWindowPassedRow struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
Resource LimitResource `json:"resource"`
TenantId pgtype.UUID `json:"tenantId"`
LimitValue int32 `json:"limitValue"`
AlarmValue pgtype.Int4 `json:"alarmValue"`
Value int32 `json:"value"`
Window pgtype.Text `json:"window"`
LastRefill pgtype.Timestamp `json:"lastRefill"`
CustomValueMeter bool `json:"customValueMeter"`
}
type ResolveLaterStepRunsParams ¶
type ResolveLaterStepRunsParams struct {
Status StepRunStatus `json:"status"`
Steprunid pgtype.UUID `json:"steprunid"`
}
type ResolveWorkflowRunStatusRow ¶ added in v0.44.0
type ResolveWorkflowRunStatusRow struct {
ID pgtype.UUID `json:"id"`
Status WorkflowRunStatus `json:"status"`
TenantId pgtype.UUID `json:"tenantId"`
}
type RetryQueueItem ¶ added in v0.52.0
type SNSIntegration ¶
type SchedulerPartition ¶ added in v0.50.0
type SecurityCheckIdent ¶ added in v0.34.2
type SelectOrInsertTenantResourceLimitParams ¶
type SelectOrInsertTenantResourceLimitParams struct {
Tenantid pgtype.UUID `json:"tenantid"`
Resource NullLimitResource `json:"resource"`
LimitValue pgtype.Int4 `json:"limitValue"`
AlarmValue pgtype.Int4 `json:"alarmValue"`
Window pgtype.Text `json:"window"`
CustomValueMeter pgtype.Bool `json:"customValueMeter"`
}
type SelectOrInsertTenantResourceLimitRow ¶
type SelectOrInsertTenantResourceLimitRow struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
Resource LimitResource `json:"resource"`
TenantId pgtype.UUID `json:"tenantId"`
LimitValue int32 `json:"limitValue"`
AlarmValue pgtype.Int4 `json:"alarmValue"`
Value int32 `json:"value"`
Window pgtype.Text `json:"window"`
LastRefill pgtype.Timestamp `json:"lastRefill"`
CustomValueMeter bool `json:"customValueMeter"`
}
type SemaphoreQueueItem ¶ added in v0.44.7
type ServiceToWorker ¶
type SetDispatchersInactiveRow ¶
type SetDispatchersInactiveRow struct {
Dispatcher Dispatcher `json:"dispatcher"`
}
type SetTickersInactiveRow ¶
type SetTickersInactiveRow struct {
Ticker Ticker `json:"ticker"`
}
type SlackAppWebhook ¶
type SlackAppWebhook struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
TenantId pgtype.UUID `json:"tenantId"`
TeamId string `json:"teamId"`
TeamName string `json:"teamName"`
ChannelId string `json:"channelId"`
ChannelName string `json:"channelName"`
WebhookURL []byte `json:"webhookURL"`
}
type SoftDeleteExpiredEventsParams ¶ added in v0.39.0
type SoftDeleteExpiredWorkflowRunsWithDependenciesParams ¶ added in v0.39.0
type SoftDeleteWebhookWorkerParams ¶ added in v0.42.13
type Step ¶
type Step struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
ReadableId pgtype.Text `json:"readableId"`
TenantId pgtype.UUID `json:"tenantId"`
JobId pgtype.UUID `json:"jobId"`
ActionId string `json:"actionId"`
Timeout pgtype.Text `json:"timeout"`
CustomUserData []byte `json:"customUserData"`
Retries int32 `json:"retries"`
RetryBackoffFactor pgtype.Float8 `json:"retryBackoffFactor"`
RetryMaxBackoff pgtype.Int4 `json:"retryMaxBackoff"`
ScheduleTimeout string `json:"scheduleTimeout"`
}
type StepDesiredWorkerLabel ¶ added in v0.40.0
type StepDesiredWorkerLabel struct {
ID int64 `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
StepId pgtype.UUID `json:"stepId"`
Key string `json:"key"`
StrValue pgtype.Text `json:"strValue"`
IntValue pgtype.Int4 `json:"intValue"`
Required bool `json:"required"`
Comparator WorkerLabelComparator `json:"comparator"`
Weight int32 `json:"weight"`
}
type StepExpression ¶ added in v0.47.0
type StepExpression struct {
Key string `json:"key"`
StepId pgtype.UUID `json:"stepId"`
Expression string `json:"expression"`
Kind StepExpressionKind `json:"kind"`
}
type StepExpressionKind ¶ added in v0.47.0
type StepExpressionKind string
const ( StepExpressionKindDYNAMICRATELIMITKEY StepExpressionKind = "DYNAMIC_RATE_LIMIT_KEY" StepExpressionKindDYNAMICRATELIMITVALUE StepExpressionKind = "DYNAMIC_RATE_LIMIT_VALUE" StepExpressionKindDYNAMICRATELIMITUNITS StepExpressionKind = "DYNAMIC_RATE_LIMIT_UNITS" StepExpressionKindDYNAMICRATELIMITWINDOW StepExpressionKind = "DYNAMIC_RATE_LIMIT_WINDOW" )
func (*StepExpressionKind) Scan ¶ added in v0.47.0
func (e *StepExpressionKind) Scan(src interface{}) error
type StepRateLimit ¶
type StepRateLimitKind ¶ added in v0.47.0
type StepRateLimitKind string
const ( StepRateLimitKindSTATIC StepRateLimitKind = "STATIC" StepRateLimitKindDYNAMIC StepRateLimitKind = "DYNAMIC" )
func (*StepRateLimitKind) Scan ¶ added in v0.47.0
func (e *StepRateLimitKind) Scan(src interface{}) error
type StepRun ¶
type StepRun struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
TenantId pgtype.UUID `json:"tenantId"`
JobRunId pgtype.UUID `json:"jobRunId"`
StepId pgtype.UUID `json:"stepId"`
Order int64 `json:"order"`
WorkerId pgtype.UUID `json:"workerId"`
TickerId pgtype.UUID `json:"tickerId"`
Status StepRunStatus `json:"status"`
Input []byte `json:"input"`
Output []byte `json:"output"`
RequeueAfter pgtype.Timestamp `json:"requeueAfter"`
ScheduleTimeoutAt pgtype.Timestamp `json:"scheduleTimeoutAt"`
Error pgtype.Text `json:"error"`
StartedAt pgtype.Timestamp `json:"startedAt"`
FinishedAt pgtype.Timestamp `json:"finishedAt"`
TimeoutAt pgtype.Timestamp `json:"timeoutAt"`
CancelledAt pgtype.Timestamp `json:"cancelledAt"`
CancelledReason pgtype.Text `json:"cancelledReason"`
CancelledError pgtype.Text `json:"cancelledError"`
InputSchema []byte `json:"inputSchema"`
CallerFiles []byte `json:"callerFiles"`
GitRepoBranch pgtype.Text `json:"gitRepoBranch"`
RetryCount int32 `json:"retryCount"`
SemaphoreReleased bool `json:"semaphoreReleased"`
Queue string `json:"queue"`
Priority pgtype.Int4 `json:"priority"`
InternalRetryCount int32 `json:"internalRetryCount"`
}
type StepRunEvent ¶
type StepRunEvent struct {
ID int64 `json:"id"`
TimeFirstSeen pgtype.Timestamp `json:"timeFirstSeen"`
TimeLastSeen pgtype.Timestamp `json:"timeLastSeen"`
StepRunId pgtype.UUID `json:"stepRunId"`
Reason StepRunEventReason `json:"reason"`
Severity StepRunEventSeverity `json:"severity"`
Message string `json:"message"`
Count int32 `json:"count"`
Data []byte `json:"data"`
WorkflowRunId pgtype.UUID `json:"workflowRunId"`
}
type StepRunEventReason ¶
type StepRunEventReason string
const ( StepRunEventReasonREQUEUEDNOWORKER StepRunEventReason = "REQUEUED_NO_WORKER" StepRunEventReasonREQUEUEDRATELIMIT StepRunEventReason = "REQUEUED_RATE_LIMIT" StepRunEventReasonSCHEDULINGTIMEDOUT StepRunEventReason = "SCHEDULING_TIMED_OUT" StepRunEventReasonASSIGNED StepRunEventReason = "ASSIGNED" StepRunEventReasonSTARTED StepRunEventReason = "STARTED" StepRunEventReasonFINISHED StepRunEventReason = "FINISHED" StepRunEventReasonFAILED StepRunEventReason = "FAILED" StepRunEventReasonRETRYING StepRunEventReason = "RETRYING" StepRunEventReasonCANCELLED StepRunEventReason = "CANCELLED" StepRunEventReasonTIMEDOUT StepRunEventReason = "TIMED_OUT" StepRunEventReasonREASSIGNED StepRunEventReason = "REASSIGNED" StepRunEventReasonSLOTRELEASED StepRunEventReason = "SLOT_RELEASED" StepRunEventReasonTIMEOUTREFRESHED StepRunEventReason = "TIMEOUT_REFRESHED" StepRunEventReasonRETRIEDBYUSER StepRunEventReason = "RETRIED_BY_USER" StepRunEventReasonSENTTOWORKER StepRunEventReason = "SENT_TO_WORKER" StepRunEventReasonWORKFLOWRUNGROUPKEYSUCCEEDED StepRunEventReason = "WORKFLOW_RUN_GROUP_KEY_SUCCEEDED" StepRunEventReasonWORKFLOWRUNGROUPKEYFAILED StepRunEventReason = "WORKFLOW_RUN_GROUP_KEY_FAILED" StepRunEventReasonRATELIMITERROR StepRunEventReason = "RATE_LIMIT_ERROR" StepRunEventReasonACKNOWLEDGED StepRunEventReason = "ACKNOWLEDGED" )
func (*StepRunEventReason) Scan ¶
func (e *StepRunEventReason) Scan(src interface{}) error
type StepRunEventSeverity ¶
type StepRunEventSeverity string
const ( StepRunEventSeverityINFO StepRunEventSeverity = "INFO" StepRunEventSeverityWARNING StepRunEventSeverity = "WARNING" StepRunEventSeverityCRITICAL StepRunEventSeverity = "CRITICAL" )
func (*StepRunEventSeverity) Scan ¶
func (e *StepRunEventSeverity) Scan(src interface{}) error
type StepRunExpressionEval ¶ added in v0.47.0
type StepRunResultArchive ¶
type StepRunResultArchive struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
StepRunId pgtype.UUID `json:"stepRunId"`
Order int64 `json:"order"`
Input []byte `json:"input"`
Output []byte `json:"output"`
Error pgtype.Text `json:"error"`
StartedAt pgtype.Timestamp `json:"startedAt"`
FinishedAt pgtype.Timestamp `json:"finishedAt"`
TimeoutAt pgtype.Timestamp `json:"timeoutAt"`
CancelledAt pgtype.Timestamp `json:"cancelledAt"`
CancelledReason pgtype.Text `json:"cancelledReason"`
CancelledError pgtype.Text `json:"cancelledError"`
RetryCount int32 `json:"retryCount"`
}
type StepRunStatus ¶
type StepRunStatus string
const ( StepRunStatusPENDING StepRunStatus = "PENDING" StepRunStatusPENDINGASSIGNMENT StepRunStatus = "PENDING_ASSIGNMENT" StepRunStatusASSIGNED StepRunStatus = "ASSIGNED" StepRunStatusRUNNING StepRunStatus = "RUNNING" StepRunStatusSUCCEEDED StepRunStatus = "SUCCEEDED" StepRunStatusFAILED StepRunStatus = "FAILED" StepRunStatusCANCELLED StepRunStatus = "CANCELLED" StepRunStatusCANCELLING StepRunStatus = "CANCELLING" )
func (*StepRunStatus) Scan ¶
func (e *StepRunStatus) Scan(src interface{}) error
type StickyStrategy ¶ added in v0.40.0
type StickyStrategy string
const ( StickyStrategySOFT StickyStrategy = "SOFT" StickyStrategyHARD StickyStrategy = "HARD" )
func (*StickyStrategy) Scan ¶ added in v0.40.0
func (e *StickyStrategy) Scan(src interface{}) error
type StreamEvent ¶
type Tenant ¶
type Tenant struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
Name string `json:"name"`
Slug string `json:"slug"`
AnalyticsOptOut bool `json:"analyticsOptOut"`
AlertMemberEmails bool `json:"alertMemberEmails"`
ControllerPartitionId pgtype.Text `json:"controllerPartitionId"`
WorkerPartitionId pgtype.Text `json:"workerPartitionId"`
DataRetentionPeriod string `json:"dataRetentionPeriod"`
SchedulerPartitionId pgtype.Text `json:"schedulerPartitionId"`
}
type TenantAlertEmailGroup ¶
type TenantAlertingSettings ¶
type TenantAlertingSettings struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
TenantId pgtype.UUID `json:"tenantId"`
MaxFrequency string `json:"maxFrequency"`
LastAlertedAt pgtype.Timestamp `json:"lastAlertedAt"`
TickerId pgtype.UUID `json:"tickerId"`
EnableExpiringTokenAlerts bool `json:"enableExpiringTokenAlerts"`
EnableWorkflowRunFailureAlerts bool `json:"enableWorkflowRunFailureAlerts"`
EnableTenantResourceLimitAlerts bool `json:"enableTenantResourceLimitAlerts"`
}
type TenantInviteLink ¶
type TenantInviteLink struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
TenantId pgtype.UUID `json:"tenantId"`
InviterEmail string `json:"inviterEmail"`
InviteeEmail string `json:"inviteeEmail"`
Expires pgtype.Timestamp `json:"expires"`
Status InviteLinkStatus `json:"status"`
Role TenantMemberRole `json:"role"`
}
type TenantMember ¶
type TenantMemberRole ¶
type TenantMemberRole string
const ( TenantMemberRoleOWNER TenantMemberRole = "OWNER" TenantMemberRoleADMIN TenantMemberRole = "ADMIN" TenantMemberRoleMEMBER TenantMemberRole = "MEMBER" )
func (*TenantMemberRole) Scan ¶
func (e *TenantMemberRole) Scan(src interface{}) error
type TenantResourceLimit ¶
type TenantResourceLimit struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
Resource LimitResource `json:"resource"`
TenantId pgtype.UUID `json:"tenantId"`
LimitValue int32 `json:"limitValue"`
AlarmValue pgtype.Int4 `json:"alarmValue"`
Value int32 `json:"value"`
Window pgtype.Text `json:"window"`
LastRefill pgtype.Timestamp `json:"lastRefill"`
CustomValueMeter bool `json:"customValueMeter"`
}
type TenantResourceLimitAlert ¶
type TenantResourceLimitAlert struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
ResourceLimitId pgtype.UUID `json:"resourceLimitId"`
TenantId pgtype.UUID `json:"tenantId"`
Resource LimitResource `json:"resource"`
AlertType TenantResourceLimitAlertType `json:"alertType"`
Value int32 `json:"value"`
Limit int32 `json:"limit"`
}
type TenantResourceLimitAlertType ¶
type TenantResourceLimitAlertType string
const ( TenantResourceLimitAlertTypeAlarm TenantResourceLimitAlertType = "Alarm" TenantResourceLimitAlertTypeExhausted TenantResourceLimitAlertType = "Exhausted" )
func (*TenantResourceLimitAlertType) Scan ¶
func (e *TenantResourceLimitAlertType) Scan(src interface{}) error
type TenantVcsProvider ¶
type TenantVcsProvider struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
TenantId pgtype.UUID `json:"tenantId"`
VcsProvider VcsProvider `json:"vcsProvider"`
Config []byte `json:"config"`
}
type TenantWorkerPartition ¶ added in v0.34.2
type TimeoutQueueItem ¶ added in v0.44.5
type UpdateDispatcherParams ¶
type UpdateGetGroupKeyRunParams ¶
type UpdateGetGroupKeyRunParams struct {
RequeueAfter pgtype.Timestamp `json:"requeueAfter"`
StartedAt pgtype.Timestamp `json:"startedAt"`
FinishedAt pgtype.Timestamp `json:"finishedAt"`
ScheduleTimeoutAt pgtype.Timestamp `json:"scheduleTimeoutAt"`
Status NullStepRunStatus `json:"status"`
Input []byte `json:"input"`
Output pgtype.Text `json:"output"`
Error pgtype.Text `json:"error"`
CancelledAt pgtype.Timestamp `json:"cancelledAt"`
CancelledReason pgtype.Text `json:"cancelledReason"`
ID pgtype.UUID `json:"id"`
Tenantid pgtype.UUID `json:"tenantid"`
}
type UpdateJobRunStatusParams ¶
type UpdateJobRunStatusParams struct {
Status JobRunStatus `json:"status"`
ID pgtype.UUID `json:"id"`
Tenantid pgtype.UUID `json:"tenantid"`
}
type UpdateScheduledWorkflowParams ¶ added in v0.51.0
type UpdateStepRunUnsetWorkerIdParams ¶ added in v0.44.0
type UpdateStepRunUnsetWorkerIdRow ¶ added in v0.44.0
type UpdateStepRunsToAssignedParams ¶ added in v0.44.0
type UpdateStepRunsToAssignedRow ¶ added in v0.44.0
type UpdateTickerParams ¶
type UpdateWebhookWorkerTokenParams ¶ added in v0.42.13
type UpdateWorkerHeartbeatParams ¶ added in v0.42.0
type UpdateWorkerParams ¶
type UpdateWorkersByWebhookIdParams ¶ added in v0.42.10
type UpdateWorkflowParams ¶ added in v0.48.0
type UpdateWorkflowRunGroupKeyFromExprParams ¶ added in v0.45.0
type UpdateWorkflowRunGroupKeyFromRunParams ¶ added in v0.45.0
type UpdateWorkflowRunParams ¶
type UpdateWorkflowRunStickyStateParams ¶ added in v0.40.0
type UpsertActionParams ¶
type UpsertDesiredWorkerLabelParams ¶ added in v0.40.0
type UpsertDesiredWorkerLabelParams struct {
Stepid pgtype.UUID `json:"stepid"`
Key string `json:"key"`
IntValue pgtype.Int4 `json:"intValue"`
StrValue pgtype.Text `json:"strValue"`
Required pgtype.Bool `json:"required"`
Weight pgtype.Int4 `json:"weight"`
Comparator NullWorkerLabelComparator `json:"comparator"`
}
type UpsertQueueParams ¶ added in v0.42.0
type UpsertRateLimitParams ¶
type UpsertRateLimitsBulkParams ¶ added in v0.47.0
type UpsertServiceParams ¶
type UpsertTenantResourceLimitParams ¶ added in v0.33.2
type UpsertTenantResourceLimitParams struct {
Tenantid pgtype.UUID `json:"tenantid"`
Resource NullLimitResource `json:"resource"`
LimitValue pgtype.Int4 `json:"limitValue"`
AlarmValue pgtype.Int4 `json:"alarmValue"`
Window pgtype.Text `json:"window"`
CustomValueMeter pgtype.Bool `json:"customValueMeter"`
}
type UpsertWorkerLabelParams ¶ added in v0.40.0
type UpsertWorkflowTagParams ¶
type UserOAuth ¶
type UserOAuth struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
UserId pgtype.UUID `json:"userId"`
Provider string `json:"provider"`
ProviderUserId string `json:"providerUserId"`
ExpiresAt pgtype.Timestamp `json:"expiresAt"`
AccessToken []byte `json:"accessToken"`
RefreshToken []byte `json:"refreshToken"`
}
type UserPassword ¶
type UserSession ¶
type VcsProvider ¶
type VcsProvider string
const (
VcsProviderGITHUB VcsProvider = "GITHUB"
)
func (*VcsProvider) Scan ¶
func (e *VcsProvider) Scan(src interface{}) error
type VerifiedStepRunTenantIdsParams ¶ added in v0.50.0
type WebhookWorker ¶ added in v0.34.0
type WebhookWorker struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
Name string `json:"name"`
Secret string `json:"secret"`
Url string `json:"url"`
TokenValue pgtype.Text `json:"tokenValue"`
Deleted bool `json:"deleted"`
TokenId pgtype.UUID `json:"tokenId"`
TenantId pgtype.UUID `json:"tenantId"`
}
type WebhookWorkerRequest ¶ added in v0.42.13
type WebhookWorkerRequestMethod ¶ added in v0.42.13
type WebhookWorkerRequestMethod string
const ( WebhookWorkerRequestMethodGET WebhookWorkerRequestMethod = "GET" WebhookWorkerRequestMethodPOST WebhookWorkerRequestMethod = "POST" WebhookWorkerRequestMethodPUT WebhookWorkerRequestMethod = "PUT" )
func (*WebhookWorkerRequestMethod) Scan ¶ added in v0.42.13
func (e *WebhookWorkerRequestMethod) Scan(src interface{}) error
type WebhookWorkerWorkflow ¶ added in v0.34.0
type Worker ¶
type Worker struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
TenantId pgtype.UUID `json:"tenantId"`
LastHeartbeatAt pgtype.Timestamp `json:"lastHeartbeatAt"`
Name string `json:"name"`
DispatcherId pgtype.UUID `json:"dispatcherId"`
MaxRuns int32 `json:"maxRuns"`
IsActive bool `json:"isActive"`
LastListenerEstablished pgtype.Timestamp `json:"lastListenerEstablished"`
IsPaused bool `json:"isPaused"`
Type WorkerType `json:"type"`
WebhookId pgtype.UUID `json:"webhookId"`
Language NullWorkerSDKS `json:"language"`
LanguageVersion pgtype.Text `json:"languageVersion"`
Os pgtype.Text `json:"os"`
RuntimeExtra pgtype.Text `json:"runtimeExtra"`
SdkVersion pgtype.Text `json:"sdkVersion"`
}
type WorkerAssignEvent ¶ added in v0.44.0
type WorkerLabel ¶ added in v0.40.0
type WorkerLabelComparator ¶ added in v0.40.0
type WorkerLabelComparator string
const ( WorkerLabelComparatorEQUAL WorkerLabelComparator = "EQUAL" WorkerLabelComparatorNOTEQUAL WorkerLabelComparator = "NOT_EQUAL" WorkerLabelComparatorGREATERTHAN WorkerLabelComparator = "GREATER_THAN" WorkerLabelComparatorGREATERTHANOREQUAL WorkerLabelComparator = "GREATER_THAN_OR_EQUAL" WorkerLabelComparatorLESSTHAN WorkerLabelComparator = "LESS_THAN" WorkerLabelComparatorLESSTHANOREQUAL WorkerLabelComparator = "LESS_THAN_OR_EQUAL" )
func (*WorkerLabelComparator) Scan ¶ added in v0.40.0
func (e *WorkerLabelComparator) Scan(src interface{}) error
type WorkerSDKS ¶ added in v0.50.4
type WorkerSDKS string
const ( WorkerSDKSUNKNOWN WorkerSDKS = "UNKNOWN" WorkerSDKSGO WorkerSDKS = "GO" WorkerSDKSPYTHON WorkerSDKS = "PYTHON" WorkerSDKSTYPESCRIPT WorkerSDKS = "TYPESCRIPT" )
func (*WorkerSDKS) Scan ¶ added in v0.50.4
func (e *WorkerSDKS) Scan(src interface{}) error
type WorkerType ¶ added in v0.42.10
type WorkerType string
const ( WorkerTypeWEBHOOK WorkerType = "WEBHOOK" WorkerTypeMANAGED WorkerType = "MANAGED" WorkerTypeSELFHOSTED WorkerType = "SELFHOSTED" )
func (*WorkerType) Scan ¶ added in v0.42.10
func (e *WorkerType) Scan(src interface{}) error
type Workflow ¶
type Workflow struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
TenantId pgtype.UUID `json:"tenantId"`
Name string `json:"name"`
Description pgtype.Text `json:"description"`
IsPaused pgtype.Bool `json:"isPaused"`
}
type WorkflowConcurrency ¶
type WorkflowConcurrency struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
WorkflowVersionId pgtype.UUID `json:"workflowVersionId"`
GetConcurrencyGroupId pgtype.UUID `json:"getConcurrencyGroupId"`
MaxRuns int32 `json:"maxRuns"`
LimitStrategy ConcurrencyLimitStrategy `json:"limitStrategy"`
ConcurrencyGroupExpression pgtype.Text `json:"concurrencyGroupExpression"`
}
type WorkflowKind ¶ added in v0.41.0
type WorkflowKind string
const ( WorkflowKindFUNCTION WorkflowKind = "FUNCTION" WorkflowKindDURABLE WorkflowKind = "DURABLE" WorkflowKindDAG WorkflowKind = "DAG" )
func (*WorkflowKind) Scan ¶ added in v0.41.0
func (e *WorkflowKind) Scan(src interface{}) error
type WorkflowRun ¶
type WorkflowRun struct {
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
TenantId pgtype.UUID `json:"tenantId"`
WorkflowVersionId pgtype.UUID `json:"workflowVersionId"`
Status WorkflowRunStatus `json:"status"`
Error pgtype.Text `json:"error"`
StartedAt pgtype.Timestamp `json:"startedAt"`
FinishedAt pgtype.Timestamp `json:"finishedAt"`
ConcurrencyGroupId pgtype.Text `json:"concurrencyGroupId"`
DisplayName pgtype.Text `json:"displayName"`
ID pgtype.UUID `json:"id"`
ChildIndex pgtype.Int4 `json:"childIndex"`
ChildKey pgtype.Text `json:"childKey"`
ParentId pgtype.UUID `json:"parentId"`
ParentStepRunId pgtype.UUID `json:"parentStepRunId"`
AdditionalMetadata []byte `json:"additionalMetadata"`
Duration pgtype.Int8 `json:"duration"`
Priority pgtype.Int4 `json:"priority"`
InsertOrder pgtype.Int4 `json:"insertOrder"`
}
type WorkflowRunDedupe ¶ added in v0.40.0
type WorkflowRunDedupe struct {
ID int64 `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
TenantId pgtype.UUID `json:"tenantId"`
WorkflowId pgtype.UUID `json:"workflowId"`
WorkflowRunId pgtype.UUID `json:"workflowRunId"`
Value string `json:"value"`
}
type WorkflowRunStatus ¶
type WorkflowRunStatus string
const ( WorkflowRunStatusPENDING WorkflowRunStatus = "PENDING" WorkflowRunStatusRUNNING WorkflowRunStatus = "RUNNING" WorkflowRunStatusSUCCEEDED WorkflowRunStatus = "SUCCEEDED" WorkflowRunStatusFAILED WorkflowRunStatus = "FAILED" WorkflowRunStatusQUEUED WorkflowRunStatus = "QUEUED" )
func (*WorkflowRunStatus) Scan ¶
func (e *WorkflowRunStatus) Scan(src interface{}) error
type WorkflowRunStickyState ¶ added in v0.40.0
type WorkflowRunStickyState struct {
ID int64 `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
TenantId pgtype.UUID `json:"tenantId"`
WorkflowRunId pgtype.UUID `json:"workflowRunId"`
DesiredWorkerId pgtype.UUID `json:"desiredWorkerId"`
Strategy StickyStrategy `json:"strategy"`
}
type WorkflowRunTriggeredBy ¶
type WorkflowRunTriggeredBy struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
TenantId pgtype.UUID `json:"tenantId"`
EventId pgtype.UUID `json:"eventId"`
CronParentId pgtype.UUID `json:"cronParentId"`
CronSchedule pgtype.Text `json:"cronSchedule"`
ScheduledId pgtype.UUID `json:"scheduledId"`
Input []byte `json:"input"`
ParentId pgtype.UUID `json:"parentId"`
CronName pgtype.Text `json:"cronName"`
}
type WorkflowRunsMetricsCountParams ¶
type WorkflowRunsMetricsCountParams struct {
Tenantid pgtype.UUID `json:"tenantid"`
CreatedAfter pgtype.Timestamp `json:"createdAfter"`
CreatedBefore pgtype.Timestamp `json:"createdBefore"`
WorkflowId pgtype.UUID `json:"workflowId"`
ParentId pgtype.UUID `json:"parentId"`
ParentStepRunId pgtype.UUID `json:"parentStepRunId"`
AdditionalMetadata []byte `json:"additionalMetadata"`
EventId pgtype.UUID `json:"eventId"`
}
type WorkflowTag ¶
type WorkflowToWorkflowTag ¶
type WorkflowTriggerCronRef ¶
type WorkflowTriggerCronRef struct {
ParentId pgtype.UUID `json:"parentId"`
Cron string `json:"cron"`
TickerId pgtype.UUID `json:"tickerId"`
Input []byte `json:"input"`
Enabled bool `json:"enabled"`
AdditionalMetadata []byte `json:"additionalMetadata"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
Name pgtype.Text `json:"name"`
ID pgtype.UUID `json:"id"`
Method WorkflowTriggerCronRefMethods `json:"method"`
}
type WorkflowTriggerCronRefMethods ¶ added in v0.52.0
type WorkflowTriggerCronRefMethods string
const ( WorkflowTriggerCronRefMethodsDEFAULT WorkflowTriggerCronRefMethods = "DEFAULT" WorkflowTriggerCronRefMethodsAPI WorkflowTriggerCronRefMethods = "API" )
func (*WorkflowTriggerCronRefMethods) Scan ¶ added in v0.52.0
func (e *WorkflowTriggerCronRefMethods) Scan(src interface{}) error
type WorkflowTriggerEventRef ¶
type WorkflowTriggerScheduledRef ¶
type WorkflowTriggerScheduledRef struct {
ID pgtype.UUID `json:"id"`
ParentId pgtype.UUID `json:"parentId"`
TriggerAt pgtype.Timestamp `json:"triggerAt"`
TickerId pgtype.UUID `json:"tickerId"`
Input []byte `json:"input"`
ChildIndex pgtype.Int4 `json:"childIndex"`
ChildKey pgtype.Text `json:"childKey"`
ParentStepRunId pgtype.UUID `json:"parentStepRunId"`
ParentWorkflowRunId pgtype.UUID `json:"parentWorkflowRunId"`
AdditionalMetadata []byte `json:"additionalMetadata"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
Method WorkflowTriggerScheduledRefMethods `json:"method"`
}
type WorkflowTriggerScheduledRefMethods ¶ added in v0.52.0
type WorkflowTriggerScheduledRefMethods string
const ( WorkflowTriggerScheduledRefMethodsDEFAULT WorkflowTriggerScheduledRefMethods = "DEFAULT" WorkflowTriggerScheduledRefMethodsAPI WorkflowTriggerScheduledRefMethods = "API" )
func (*WorkflowTriggerScheduledRefMethods) Scan ¶ added in v0.52.0
func (e *WorkflowTriggerScheduledRefMethods) Scan(src interface{}) error
type WorkflowTriggers ¶
type WorkflowVersion ¶
type WorkflowVersion struct {
ID pgtype.UUID `json:"id"`
CreatedAt pgtype.Timestamp `json:"createdAt"`
UpdatedAt pgtype.Timestamp `json:"updatedAt"`
DeletedAt pgtype.Timestamp `json:"deletedAt"`
Version pgtype.Text `json:"version"`
Order int64 `json:"order"`
WorkflowId pgtype.UUID `json:"workflowId"`
Checksum string `json:"checksum"`
ScheduleTimeout string `json:"scheduleTimeout"`
OnFailureJobId pgtype.UUID `json:"onFailureJobId"`
Sticky NullStickyStrategy `json:"sticky"`
Kind WorkflowKind `json:"kind"`
DefaultPriority pgtype.Int4 `json:"defaultPriority"`
}
Source Files
¶
- api_tokens.sql.go
- batch.go
- copyfrom.go
- db.go
- dispatchers.sql.go
- events.sql.go
- get_group_key_runs.sql.go
- health.sql.go
- job_runs.sql.go
- lease.sql.go
- logs.sql.go
- models.go
- queue.sql.go
- rate_limits.sql.go
- security_check.sql.go
- step_runs.sql.go
- stream_event.sql.go
- tenant_limits.sql.go
- tenants.sql.go
- tickers.sql.go
- webhook_workers.sql.go
- workers.sql.go
- workflow_runs.sql.go
- workflows.sql.go