dbsqlc

package

Go to main page

Versions in this module

v0

v0.73.54

Oct 30, 2025

v0.73.52

Oct 30, 2025

v0.73.51

Oct 30, 2025

v0.73.49

Oct 30, 2025

v0.73.47

Oct 28, 2025

v0.73.46

Oct 28, 2025

v0.73.45-alpha.4

Oct 22, 2025

v0.73.45-alpha.3

Oct 22, 2025

v0.73.45-alpha.2

Oct 22, 2025

v0.73.44

Oct 21, 2025

v0.73.42

Oct 17, 2025

v0.73.42-alpha.0

Oct 16, 2025

v0.73.41

Oct 16, 2025

v0.73.40

Oct 16, 2025

v0.73.40-alpha.1

Oct 15, 2025

v0.73.40-alpha.0

Oct 15, 2025

v0.73.37

Oct 13, 2025

v0.73.35

Oct 8, 2025

Changes in this version

type Queries

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

+ type UpdateCronTriggerParams struct

+ Crontriggerid pgtype.UUID

+ Enabled pgtype.Bool

v0.73.35-alpha.0

Oct 5, 2025

v0.73.34

Oct 3, 2025

v0.73.33

Oct 2, 2025

v0.73.32-alpha.19

Oct 3, 2025

v0.73.32-alpha.18

Oct 3, 2025

v0.73.32-alpha.16

Oct 2, 2025

v0.73.32-alpha.15

Oct 2, 2025

v0.73.32-alpha.13

Oct 2, 2025

v0.73.32-alpha.12

Oct 2, 2025

v0.73.32-alpha.11

Oct 2, 2025

v0.73.32-alpha.10

Oct 2, 2025

v0.73.32-alpha.8

Oct 2, 2025

v0.73.32-alpha.5

Oct 2, 2025

v0.73.32-alpha.4

Oct 1, 2025

v0.73.32-alpha.3

Oct 1, 2025

v0.73.32-alpha.2

Oct 1, 2025

v0.73.32-alpha.0

Sep 30, 2025

v0.73.30

Sep 30, 2025

v0.73.29

Sep 29, 2025

v0.73.28

Sep 29, 2025

v0.73.27-alpha.0

Sep 29, 2025

v0.73.26

Sep 26, 2025

Changes in this version

+ type GetWorkerWorkflowsByWorkerIdParams struct

+ Tenantid pgtype.UUID

+ Workerid pgtype.UUID

type Queries

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

v0.73.23

Sep 26, 2025

v0.73.23-alpha.1

Sep 26, 2025

v0.73.23-alpha.0

Sep 26, 2025

v0.73.21

Sep 25, 2025

Changes in this version

type CountWorkflowsParams

+ Search pgtype.Text

v0.73.20

Sep 24, 2025

v0.73.19

Sep 24, 2025

v0.73.18

Sep 23, 2025

v0.73.15

Sep 23, 2025

v0.73.14

Sep 22, 2025

v0.73.13

Sep 21, 2025

v0.73.12

Sep 19, 2025

v0.73.10

Sep 18, 2025

v0.73.9

Sep 18, 2025

v0.73.8

Sep 18, 2025

v0.73.7

Sep 17, 2025

v0.73.6

Sep 17, 2025

v0.73.4

Sep 16, 2025

v0.73.3-alpha.0

Sep 15, 2025

v0.73.2

Sep 15, 2025

v0.72.7

Sep 11, 2025

v0.72.6

Sep 11, 2025

v0.72.5

Sep 10, 2025

v0.72.3

Sep 9, 2025

v0.72.2

Sep 9, 2025

v0.72.1

Sep 8, 2025

v0.72.0

Sep 5, 2025

v0.71.14

Sep 2, 2025

v0.71.13

Sep 2, 2025

v0.71.11

Aug 29, 2025

v0.71.9

Aug 26, 2025

v0.71.8

Aug 25, 2025

Changes in this version

type CreateTenantParams

+ Environment NullTenantEnvironment

+ OnboardingData []byte

+ type NullTenantEnvironment struct

+ TenantEnvironment TenantEnvironment

+ Valid bool

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

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

type PopulateTenantMembersRow

+ TenantEnvironment NullTenantEnvironment

type Tenant

+ Environment NullTenantEnvironment

+ OnboardingData []byte

+ type TenantEnvironment string

+ const TenantEnvironmentDevelopment

+ const TenantEnvironmentLocal

+ const TenantEnvironmentProduction

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

v0.71.8-alpha.0

Aug 25, 2025

v0.71.7

Aug 22, 2025

v0.71.5

Aug 21, 2025

v0.71.4-alpha.2

Aug 21, 2025

v0.71.4-alpha.1

Aug 20, 2025

v0.71.4-alpha.0

Aug 20, 2025

v0.71.2

Aug 18, 2025

v0.71.1

Aug 15, 2025

v0.71.0

Aug 14, 2025

v0.70.5

Aug 7, 2025

v0.70.4

Aug 6, 2025

v0.70.3

Aug 6, 2025

v0.70.2

Aug 6, 2025

v0.70.2-alpha.0

Aug 5, 2025

v0.70.1

Aug 4, 2025

v0.70.0

Aug 4, 2025

Changes in this version

type LimitResource

+ const LimitResourceINCOMINGWEBHOOK

v0.69.9

Jul 31, 2025

v0.69.7

Jul 29, 2025

v0.69.6

Jul 25, 2025

v0.69.5

Jul 24, 2025

v0.69.4

Jul 22, 2025

v0.69.3

Jul 21, 2025

v0.69.3-alpha.0

Jul 21, 2025

v0.69.2

Jul 21, 2025

v0.69.1

Jul 18, 2025

v0.69.0

Jul 11, 2025

v0.68.10

Jul 18, 2025

v0.68.9

Jul 17, 2025

v0.68.8

Jul 16, 2025

v0.68.7

Jul 15, 2025

v0.68.6

Jul 15, 2025

v0.68.5

Jul 10, 2025

v0.68.4

Jul 9, 2025

v0.68.3

Jul 7, 2025

v0.68.2

Jul 7, 2025

v0.68.1

Jul 4, 2025

v0.68.0

Jul 4, 2025

v0.67.8

Jul 3, 2025

v0.67.8-alpha.0

Jul 2, 2025

v0.67.7

Jul 1, 2025

v0.67.6

Jul 1, 2025

v0.67.5

Jul 1, 2025

v0.67.5-alpha.0

Jul 1, 2025

v0.67.4

Jul 1, 2025

v0.67.3

Jul 1, 2025

v0.67.3-alpha.1

Jun 30, 2025

v0.67.3-alpha.0

Jun 30, 2025

v0.67.2

Jun 30, 2025

v0.67.1

Jun 30, 2025

v0.67.0

Jun 27, 2025

v0.66.8

Jun 25, 2025

v0.66.7

Jun 25, 2025

v0.66.6-alpha.0

Jun 24, 2025

v0.66.5

Jun 23, 2025

v0.66.4

Jun 19, 2025

v0.66.3

Jun 19, 2025

v0.66.2

Jun 13, 2025

v0.66.1

Jun 13, 2025

v0.66.0

Jun 13, 2025

v0.65.4-alpha.0

Jun 13, 2025

v0.65.3

Jun 12, 2025

v0.65.2

Jun 12, 2025

v0.65.1

Jun 12, 2025

v0.65.1-alpha.0

Jun 12, 2025

v0.65.0

Jun 10, 2025

v0.64.14-alpha.0

Jun 9, 2025

v0.64.13

Jun 9, 2025

v0.64.12

Jun 7, 2025

v0.64.12-alpha.3

Jun 8, 2025

v0.64.12-alpha.2

Jun 7, 2025

v0.64.12-alpha.1

Jun 7, 2025

v0.64.12-alpha.0

Jun 5, 2025

v0.64.11

Jun 4, 2025

v0.64.10

Jun 3, 2025

v0.64.9

Jun 3, 2025

v0.64.8

Jun 2, 2025

v0.64.7

May 21, 2025

v0.64.6

May 21, 2025

v0.64.5

May 21, 2025

v0.64.4

May 20, 2025

v0.64.3

May 20, 2025

v0.64.2

May 19, 2025

v0.64.1

May 16, 2025

v0.64.0

May 16, 2025

v0.63.6

May 16, 2025

v0.63.5

May 14, 2025

v0.63.4

May 14, 2025

v0.63.3

May 14, 2025

v0.63.2

May 14, 2025

v0.63.1

May 13, 2025

v0.63.0

May 13, 2025

v0.62.8

May 13, 2025

v0.62.8-alpha.3

May 13, 2025

v0.62.8-alpha.2

May 13, 2025

v0.62.8-alpha.1

May 13, 2025

v0.62.8-alpha.0

May 13, 2025

v0.62.7

May 12, 2025

v0.62.6

May 9, 2025

v0.62.5

May 9, 2025

v0.62.4

May 8, 2025

v0.62.3

May 8, 2025

v0.62.2

May 6, 2025

v0.62.1

May 6, 2025

v0.62.0

May 5, 2025

v0.61.12

May 3, 2025

v0.61.11

May 2, 2025

v0.61.10

May 1, 2025

v0.61.9

Apr 30, 2025

v0.61.8

Apr 30, 2025

v0.61.7

Apr 30, 2025

v0.61.7-alpha.1

Apr 30, 2025

v0.61.7-alpha.0

Apr 30, 2025

v0.61.6

Apr 30, 2025

v0.61.6-alpha.2

Apr 29, 2025

v0.61.5

Apr 29, 2025

v0.61.4

Apr 29, 2025

v0.61.3

Apr 28, 2025

v0.61.2

Apr 26, 2025

v0.61.1

Apr 26, 2025

v0.61.0

Apr 25, 2025

v0.60.5

Apr 23, 2025

v0.60.4

Apr 22, 2025

v0.60.3

Apr 21, 2025

v0.60.2

Apr 21, 2025

v0.60.1

Apr 18, 2025

v0.60.0

Apr 18, 2025

v0.59.5

Apr 15, 2025

v0.59.4

Apr 15, 2025

v0.59.3

Apr 15, 2025

v0.59.2

Apr 15, 2025

v0.59.1

Apr 15, 2025

v0.59.0

Apr 14, 2025

v0.58.11

Apr 14, 2025

v0.58.10

Apr 11, 2025

v0.58.9

Apr 11, 2025

v0.58.8

Apr 8, 2025

v0.58.7

Apr 8, 2025

v0.58.6

Apr 8, 2025

v0.58.5

Apr 7, 2025

v0.58.4

Apr 7, 2025

v0.58.3

Apr 4, 2025

v0.58.3-alpha.0

Apr 5, 2025

v0.58.2

Apr 4, 2025

v0.58.1

Apr 3, 2025

v0.58.1-alpha.2

Apr 3, 2025

v0.58.1-alpha.1

Apr 2, 2025

v0.58.1-alpha.0

Apr 2, 2025

v0.58.0

Apr 1, 2025

v0.57.1

Mar 28, 2025

v0.57.0

Mar 28, 2025

v0.56.4

Mar 27, 2025

v0.56.3

Mar 27, 2025

v0.56.2

Mar 27, 2025

v0.56.1

Mar 27, 2025

v0.56.0

Mar 27, 2025

v0.56.0-alpha.4

Mar 27, 2025

v0.56.0-alpha.3

Mar 27, 2025

v0.56.0-alpha.2

Mar 27, 2025

v0.56.0-alpha.1

Mar 27, 2025

v0.56.0-alpha.0

Mar 27, 2025

v0.55.29

Mar 26, 2025

v0.55.28

Mar 26, 2025

v0.55.27

Mar 26, 2025

v0.55.26

Mar 25, 2025

v0.55.25

Mar 25, 2025

v0.55.24

Mar 24, 2025

v0.55.23

Mar 24, 2025

v0.55.22

Mar 24, 2025

v0.55.21

Mar 21, 2025

v0.55.20

Mar 20, 2025

v0.55.19

Mar 19, 2025

v0.55.18

Mar 19, 2025

v0.55.17

Mar 19, 2025

v0.55.16

Mar 18, 2025

v0.55.15

Mar 18, 2025

v0.55.14

Mar 17, 2025

v0.55.13

Mar 17, 2025

v0.55.12

Mar 17, 2025

v0.55.11

Mar 15, 2025

v0.55.10

Mar 15, 2025

v0.55.9

Mar 15, 2025

v0.55.8

Mar 14, 2025

Changes in this version

+ type BulkUpdateRateLimitsRow struct

+ Key string

+ LastRefill pgtype.Timestamp

+ LimitValue int32

+ TenantId pgtype.UUID

+ Value int32

+ Window string

v0.55.7

Mar 14, 2025

v0.55.6

Mar 14, 2025

v0.55.5

Mar 14, 2025

v0.55.4

Mar 13, 2025

v0.55.3

Mar 12, 2025

v0.55.2

Mar 11, 2025

v0.55.1

Mar 11, 2025

v0.55.0

Mar 11, 2025

Changes in this version

type GetWorkerActionsByWorkerIdParams

+ Workerid pgtype.UUID

v0.55.0-alpha.5

Mar 7, 2025

v0.55.0-alpha.4

Mar 7, 2025

v0.55.0-alpha.3

Mar 7, 2025

v0.55.0-alpha.2

Mar 7, 2025

v0.55.0-alpha.1

Mar 7, 2025

v0.55.0-alpha.0

Mar 7, 2025

v0.1.0-debug.0

Mar 22, 2025

v0.0.1

Aug 4, 2025

v0.0.0

Aug 4, 2025

Changes in this version

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

+ type APIToken struct

+ CreatedAt pgtype.Timestamp

+ ExpiresAt pgtype.Timestamp

+ ID pgtype.UUID

+ Internal bool

+ Name pgtype.Text

+ NextAlertAt pgtype.Timestamp

+ Revoked bool

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type AcquireOrExtendLeasesParams struct

+ Existingleaseids []int64

+ Kind LeaseKind

+ LeaseDuration pgtype.Interval

+ Resourceids []string

+ Tenantid pgtype.UUID

+ type Action struct

+ ActionId string

+ Description pgtype.Text

+ ID pgtype.UUID

+ TenantId pgtype.UUID

+ type ActionToWorker struct

+ A pgtype.UUID

+ B pgtype.UUID

+ type AddMessageParams struct

+ Payload []byte

+ Queueid string

+ type AddStepParentsParams struct

+ ID pgtype.UUID

+ Jobid pgtype.UUID

+ Parents []string

+ type AddWorkflowTagParams struct

+ ID pgtype.UUID

+ Tags pgtype.UUID

+ type ArchiveStepRunResultFromStepRunParams struct

+ Error pgtype.Text

+ ID pgtype.UUID

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type AssignGetGroupKeyRunToTickerParams struct

+ Getgroupkeyrunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type AssignGetGroupKeyRunToTickerRow struct

+ ID pgtype.UUID

+ TickerId pgtype.UUID

+ type AssignGetGroupKeyRunToWorkerParams struct

+ Getgroupkeyrunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type AssignGetGroupKeyRunToWorkerRow struct

+ DispatcherId pgtype.UUID

+ ID pgtype.UUID

+ WorkerId pgtype.UUID

+ type BulkAddMessageParams struct

+ ExpiresAt pgtype.Timestamp

+ Payload []byte

+ QueueId pgtype.Text

+ ReadAfter pgtype.Timestamp

+ type BulkCancelStepRunParams struct

+ Cancelledats []pgtype.Timestamp

+ Cancellederrors []string

+ Cancelledreasons []string

+ Finishedats []pgtype.Timestamp

+ Steprunids []pgtype.UUID

+ type BulkCreateStepRunEventParams struct

+ Data [][]byte

+ Messages []string

+ Reasons []string

+ Severities []string

+ Steprunids []pgtype.UUID

+ Timeseen []pgtype.Timestamp

+ type BulkCreateWorkflowRunEventParams struct

+ Data [][]byte

+ Messages []string

+ Reasons []string

+ Severities []string

+ Timeseen []pgtype.Timestamp

+ Workflowrunids []pgtype.UUID

+ type BulkFailStepRunParams struct

+ Errors []string

+ Finishedats []pgtype.Timestamp

+ Steprunids []pgtype.UUID

+ type BulkFinishStepRunParams struct

+ Finishedats []pgtype.Timestamp

+ Outputs [][]byte

+ Steprunids []pgtype.UUID

+ type BulkStartStepRunParams struct

+ Startedats []pgtype.Timestamp

+ Steprunids []pgtype.UUID

+ type BulkUpdateRateLimitsParams struct

+ Keys []string

+ Tenantid pgtype.UUID

+ Units []int32

+ type CheckWorkerParams struct

+ Tenantid pgtype.UUID

+ Workerid pgtype.UUID

+ type CleanupInternalQueueItemsParams struct

+ Maxid int64

+ Minid int64

+ Tenantid pgtype.UUID

+ type CleanupMessageQueueItemsParams struct

+ Maxid int64

+ Minid int64

+ type CleanupQueueItemsParams struct

+ Maxid int64

+ Minid int64

+ Tenantid pgtype.UUID

+ type CleanupRetryQueueItemsParams struct

+ Maxretryafter pgtype.Timestamp

+ Minretryafter pgtype.Timestamp

+ Tenantid pgtype.UUID

+ type CleanupTimeoutQueueItemsParams struct

+ Maxid int64

+ Minid int64

+ Tenantid pgtype.UUID

+ type ClearEventPayloadDataParams struct

+ Limit interface{}

+ Tenantid pgtype.UUID

+ type ClearJobRunLookupDataParams struct

+ Limit interface{}

+ Tenantid pgtype.UUID

+ type ClearStepRunPayloadDataParams struct

+ Limit interface{}

+ Tenantid pgtype.UUID

+ type ConcurrencyLimitStrategy string

+ const ConcurrencyLimitStrategyCANCELINPROGRESS

+ const ConcurrencyLimitStrategyCANCELNEWEST

+ const ConcurrencyLimitStrategyDROPNEWEST

+ const ConcurrencyLimitStrategyGROUPROUNDROBIN

+ const ConcurrencyLimitStrategyQUEUENEWEST

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

+ type ControllerPartition struct

+ CreatedAt pgtype.Timestamp

+ ID string

+ LastHeartbeat pgtype.Timestamp

+ Name pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ type CountCronWorkflowsParams struct

+ AdditionalMetadata []byte

+ CronName pgtype.Text

+ Crontriggerid pgtype.UUID

+ Tenantid pgtype.UUID

+ WorkflowName pgtype.Text

+ Workflowid pgtype.UUID

+ type CountEventsParams struct

+ AdditionalMetadata []byte

+ EventIds []pgtype.UUID

+ Keys []string

+ Orderby interface{}

+ Search pgtype.Text

+ Statuses []string

+ TenantId pgtype.UUID

+ Workflows []string

+ type CountLogLinesParams struct

+ Levels []LogLineLevel

+ Search pgtype.Text

+ StepRunId pgtype.UUID

+ Tenantid pgtype.UUID

+ type CountRateLimitsParams struct

+ Orderby interface{}

+ Search pgtype.Text

+ Tenantid pgtype.UUID

+ type CountRoundRobinGroupKeysParams struct

+ Status NullWorkflowRunStatus

+ Tenantid pgtype.UUID

+ Workflowid pgtype.UUID

+ type CountScheduledWorkflowsParams struct

+ AdditionalMetadata []byte

+ Includescheduled bool

+ Parentsteprunid pgtype.UUID

+ Parentworkflowrunid pgtype.UUID

+ Scheduleid pgtype.UUID

+ Statuses []string

+ Tenantid pgtype.UUID

+ Workflowid pgtype.UUID

+ type CountWorkflowRunsParams struct

+ AdditionalMetadata []byte

+ CreatedAfter pgtype.Timestamp

+ CreatedBefore pgtype.Timestamp

+ EventId pgtype.UUID

+ FinishedAfter pgtype.Timestamp

+ FinishedBefore pgtype.Timestamp

+ GroupKey pgtype.Text

+ Ids []pgtype.UUID

+ Kinds []string

+ Orderby interface{}

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

+ Statuses []string

+ TenantId pgtype.UUID

+ WorkflowId pgtype.UUID

+ WorkflowVersionId pgtype.UUID

+ type CountWorkflowRunsRoundRobinParams struct

+ GroupKey pgtype.Text

+ Status NullWorkflowRunStatus

+ Tenantid pgtype.UUID

+ Workflowid pgtype.UUID

+ type CountWorkflowsParams struct

+ EventKey pgtype.Text

+ TenantId pgtype.UUID

+ type CreateAPITokenParams struct

+ Expiresat pgtype.Timestamp

+ ID pgtype.UUID

+ Internal pgtype.Bool

+ Name pgtype.Text

+ TenantId pgtype.UUID

+ type CreateEventKeysParams struct

+ Keys []string

+ Tenantids []pgtype.UUID

+ type CreateEventParams struct

+ Additionalmetadata []byte

+ CreatedAt pgtype.Timestamp

+ Data []byte

+ Deletedat pgtype.Timestamp

+ ID pgtype.UUID

+ Key string

+ ReplayedFromId pgtype.UUID

+ Tenantid pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type CreateEventsParams struct

+ AdditionalMetadata []byte

+ Data []byte

+ ID pgtype.UUID

+ InsertOrder pgtype.Int4

+ Key string

+ ReplayedFromId pgtype.UUID

+ TenantId pgtype.UUID

+ type CreateGetGroupKeyRunParams struct

+ ID pgtype.UUID

+ Input []byte

+ Requeueafter pgtype.Timestamp

+ Scheduletimeoutat pgtype.Timestamp

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ type CreateGetGroupKeyRunsParams struct

+ ID pgtype.UUID

+ Input []byte

+ RequeueAfter pgtype.Timestamp

+ ScheduleTimeoutAt pgtype.Timestamp

+ Status StepRunStatus

+ TenantId pgtype.UUID

+ WorkflowRunId pgtype.UUID

+ type CreateInternalQueueItemsBulkParams struct

+ Datas [][]byte

+ Queues []string

+ Tenantids []pgtype.UUID

+ type CreateJobParams struct

+ CreatedAt pgtype.Timestamp

+ Deletedat pgtype.Timestamp

+ Description string

+ ID pgtype.UUID

+ Kind NullJobKind

+ Name string

+ Tenantid pgtype.UUID

+ Timeout string

+ UpdatedAt pgtype.Timestamp

+ Workflowversionid pgtype.UUID

+ type CreateJobRunLookupDataParams struct

+ ID pgtype.UUID

+ Input []byte

+ Jobrunid pgtype.UUID

+ Tenantid pgtype.UUID

+ Triggeredby string

+ type CreateJobRunLookupDatasParams struct

+ Ids []pgtype.UUID

+ Inputs [][]byte

+ Jobrunids []pgtype.UUID

+ Tenantids []pgtype.UUID

+ Triggeredbys []string

+ type CreateJobRunsParams struct

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ Workflowversionid pgtype.UUID

+ type CreateLogLineParams struct

+ CreatedAt pgtype.Timestamp

+ Level NullLogLineLevel

+ Message string

+ Metadata []byte

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type CreateManyJobRunsParams struct

+ Tenantids []pgtype.UUID

+ Workflowrunids []pgtype.UUID

+ Workflowversionids []pgtype.UUID

+ type CreateManyJobRunsRow struct

+ ID pgtype.UUID

+ TenantId pgtype.UUID

+ WorkflowRunId pgtype.UUID

+ type CreateMultipleWorkflowRunStickyStatesParams struct

+ Desiredworkerids []pgtype.UUID

+ Tenantid []pgtype.UUID

+ Workflowrunids []pgtype.UUID

+ Workflowversionids []pgtype.UUID

+ type CreateQueueItemParams struct

+ ActionId pgtype.Text

+ DesiredWorkerId pgtype.UUID

+ Priority pgtype.Int4

+ Queue string

+ ScheduleTimeoutAt pgtype.Timestamp

+ StepId pgtype.UUID

+ StepRunId pgtype.UUID

+ StepTimeout pgtype.Text

+ Sticky NullStickyStrategy

+ Tenantid pgtype.UUID

+ type CreateQueueItemsBulkParams struct

+ ActionId pgtype.Text

+ DesiredWorkerId pgtype.UUID

+ IsQueued bool

+ Priority int32

+ Queue string

+ ScheduleTimeoutAt pgtype.Timestamp

+ StepId pgtype.UUID

+ StepRunId pgtype.UUID

+ StepTimeout pgtype.Text

+ Sticky NullStickyStrategy

+ TenantId pgtype.UUID

+ type CreateRetryQueueItemParams struct

+ Retryafter pgtype.Timestamp

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type CreateSNSIntegrationParams struct

+ Tenantid pgtype.UUID

+ Topicarn string

+ type CreateSchedulesParams struct

+ Additionalmetadata []byte

+ Input []byte

+ Priority pgtype.Int4

+ Triggertimes []pgtype.Timestamp

+ Workflowrunid pgtype.UUID

+ type CreateStepExpressionsParams struct

+ Expressions []string

+ Keys []string

+ Kinds []string

+ Stepid pgtype.UUID

+ type CreateStepParams struct

+ Actionid string

+ CreatedAt pgtype.Timestamp

+ CustomUserData []byte

+ Deletedat pgtype.Timestamp

+ ID pgtype.UUID

+ Jobid pgtype.UUID

+ Readableid string

+ Retries pgtype.Int4

+ RetryBackoffFactor pgtype.Float8

+ RetryMaxBackoff pgtype.Int4

+ ScheduleTimeout pgtype.Text

+ Tenantid pgtype.UUID

+ Timeout pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ type CreateStepRateLimitParams struct

+ Kind StepRateLimitKind

+ Ratelimitkey string

+ Stepid pgtype.UUID

+ Tenantid pgtype.UUID

+ Units int32

+ type CreateStepRunEventParams struct

+ Data []byte

+ Jobrunid pgtype.UUID

+ Message string

+ Reason StepRunEventReason

+ Severity StepRunEventSeverity

+ Steprunid pgtype.UUID

+ type CreateStepRunExpressionEvalIntsParams struct

+ Keys []string

+ Kinds []string

+ Steprunid pgtype.UUID

+ Valuesint []int32

+ type CreateStepRunExpressionEvalStrsParams struct

+ Keys []string

+ Kinds []string

+ Steprunid pgtype.UUID

+ Valuesstr []string

+ type CreateStepRunParams struct

+ Jobrunid pgtype.UUID

+ Priority pgtype.Int4

+ Queue pgtype.Text

+ Stepid pgtype.UUID

+ Tenantid pgtype.UUID

+ type CreateStepRunsForJobRunIdsParams struct

+ Jobrunids []pgtype.UUID

+ Priority int32

+ type CreateStepRunsParams struct

+ ID pgtype.UUID

+ JobRunId pgtype.UUID

+ Priority pgtype.Int4

+ Queue string

+ RequeueAfter pgtype.Timestamp

+ Status StepRunStatus

+ StepId pgtype.UUID

+ TenantId pgtype.UUID

+ type CreateStreamEventParams struct

+ CreatedAt pgtype.Timestamp

+ Message []byte

+ Metadata []byte

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type CreateTenantAlertGroupParams struct

+ Emails string

+ Tenantid pgtype.UUID

+ type CreateTenantInviteParams struct

+ Expires pgtype.Timestamp

+ Inviteeemail string

+ Inviteremail string

+ Role TenantMemberRole

+ Tenantid pgtype.UUID

+ type CreateTenantMemberParams struct

+ Role TenantMemberRole

+ Tenantid pgtype.UUID

+ Userid pgtype.UUID

+ type CreateTenantParams struct

+ DataRetentionPeriod pgtype.Text

+ ID pgtype.UUID

+ Name string

+ Slug string

+ UiVersion NullTenantMajorUIVersion

+ Version NullTenantMajorEngineVersion

+ type CreateTimeoutQueueItemParams struct

+ Retrycount int32

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ Timeoutat pgtype.Timestamp

+ type CreateUniqueInternalQueueItemsBulkParams struct

+ Datas [][]byte

+ Queue InternalQueue

+ Tenantid pgtype.UUID

+ Uniquekeys []string

+ type CreateUserOAuthParams struct

+ Accesstoken []byte

+ ExpiresAt pgtype.Timestamp

+ Provider string

+ Provideruserid string

+ RefreshToken []byte

+ Userid pgtype.UUID

+ type CreateUserParams struct

+ Email string

+ EmailVerified pgtype.Bool

+ ID pgtype.UUID

+ Name pgtype.Text

+ type CreateUserPasswordParams struct

+ Hash string

+ Userid pgtype.UUID

+ type CreateUserSessionParams struct

+ Data []byte

+ Expiresat pgtype.Timestamp

+ ID pgtype.UUID

+ UserId pgtype.UUID

+ type CreateWebhookWorkerParams struct

+ Deleted pgtype.Bool

+ Name string

+ Secret string

+ Tenantid pgtype.UUID

+ TokenId pgtype.UUID

+ TokenValue pgtype.Text

+ Url string

+ type CreateWorkerAssignEventsParams struct

+ Assignedstepruns [][]byte

+ Workerids []pgtype.UUID

+ type CreateWorkerParams struct

+ Dispatcherid pgtype.UUID

+ Language NullWorkerSDKS

+ LanguageVersion pgtype.Text

+ MaxRuns pgtype.Int4

+ Name string

+ Os pgtype.Text

+ RuntimeExtra pgtype.Text

+ SdkVersion pgtype.Text

+ Tenantid pgtype.UUID

+ Type NullWorkerType

+ WebhookId pgtype.UUID

+ type CreateWorkflowConcurrencyParams struct

+ ConcurrencyGroupExpression pgtype.Text

+ CreatedAt pgtype.Timestamp

+ GetConcurrencyGroupId pgtype.UUID

+ LimitStrategy NullConcurrencyLimitStrategy

+ MaxRuns pgtype.Int4

+ UpdatedAt pgtype.Timestamp

+ Workflowversionid pgtype.UUID

+ type CreateWorkflowParams struct

+ CreatedAt pgtype.Timestamp

+ Deletedat pgtype.Timestamp

+ Description string

+ ID pgtype.UUID

+ Name string

+ Tenantid pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type CreateWorkflowRunDedupeParams struct

+ Tenantid pgtype.UUID

+ Value pgtype.Text

+ Workflowrunid pgtype.UUID

+ Workflowversionid pgtype.UUID

+ type CreateWorkflowRunParams struct

+ Additionalmetadata []byte

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ DisplayName pgtype.Text

+ ID pgtype.UUID

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

+ Priority pgtype.Int4

+ Tenantid pgtype.UUID

+ Workflowversionid pgtype.UUID

+ type CreateWorkflowRunStickyStateParams struct

+ DesiredWorkerId pgtype.UUID

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ Workflowversionid pgtype.UUID

+ type CreateWorkflowRunTriggeredByParams struct

+ CronName pgtype.Text

+ CronParentId pgtype.UUID

+ CronSchedule pgtype.Text

+ EventId pgtype.UUID

+ ScheduledId pgtype.UUID

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ type CreateWorkflowRunTriggeredBysParams struct

+ CronName pgtype.Text

+ CronParentId pgtype.UUID

+ CronSchedule pgtype.Text

+ EventId pgtype.UUID

+ ID pgtype.UUID

+ ParentId pgtype.UUID

+ ScheduledId pgtype.UUID

+ TenantId pgtype.UUID

+ type CreateWorkflowRunsParams struct

+ AdditionalMetadata []byte

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ DisplayName pgtype.Text

+ ID pgtype.UUID

+ InsertOrder pgtype.Int4

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

+ Priority pgtype.Int4

+ Status WorkflowRunStatus

+ TenantId pgtype.UUID

+ WorkflowVersionId pgtype.UUID

+ type CreateWorkflowTriggerCronRefForWorkflowParams struct

+ AdditionalMetadata []byte

+ Crontrigger string

+ Input []byte

+ Method NullWorkflowTriggerCronRefMethods

+ Name pgtype.Text

+ Priority pgtype.Int4

+ Workflowid pgtype.UUID

+ type CreateWorkflowTriggerCronRefParams struct

+ AdditionalMetadata []byte

+ Crontrigger string

+ Input []byte

+ Method NullWorkflowTriggerCronRefMethods

+ Name pgtype.Text

+ Priority pgtype.Int4

+ Workflowtriggersid pgtype.UUID

+ type CreateWorkflowTriggerEventRefParams struct

+ Eventtrigger string

+ Workflowtriggersid pgtype.UUID

+ type CreateWorkflowTriggerScheduledRefForWorkflowParams struct

+ Additionalmetadata []byte

+ Input []byte

+ Method NullWorkflowTriggerScheduledRefMethods

+ Priority pgtype.Int4

+ Scheduledtrigger pgtype.Timestamp

+ Workflowid pgtype.UUID

+ type CreateWorkflowTriggerScheduledRefParams struct

+ Additionalmetadata []byte

+ Input []byte

+ Priority pgtype.Int4

+ Scheduledtrigger pgtype.Timestamp

+ Workflowversionid pgtype.UUID

+ type CreateWorkflowTriggersParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ Workflowversionid pgtype.UUID

+ type CreateWorkflowVersionParams struct

+ Checksum string

+ CreatedAt pgtype.Timestamp

+ DefaultPriority pgtype.Int4

+ Deletedat pgtype.Timestamp

+ ID pgtype.UUID

+ Kind NullWorkflowKind

+ ScheduleTimeout pgtype.Text

+ Sticky NullStickyStrategy

+ UpdatedAt pgtype.Timestamp

+ Version pgtype.Text

+ Workflowid pgtype.UUID

+ type DBTX interface

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

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

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

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

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

+ type DeleteAPITokenParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ type DeleteOldWorkerAssignEventsParams struct

+ Limit int32

+ MaxRuns int32

+ Workerid pgtype.UUID

+ type DeleteOldWorkersParams struct

+ Lastheartbeatbefore pgtype.Timestamp

+ Limit interface{}

+ Tenantid pgtype.UUID

+ type DeleteSNSIntegrationParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ type DeleteSlackWebhookParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ type DeleteTenantAlertGroupParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ type Dispatcher struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ IsActive bool

+ LastHeartbeatAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ type Event struct

+ AdditionalMetadata []byte

+ CreatedAt pgtype.Timestamp

+ Data []byte

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ InsertOrder pgtype.Int4

+ Key string

+ ReplayedFromId pgtype.UUID

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type EventKey struct

+ ID int64

+ Key string

+ TenantId pgtype.UUID

+ type GetChildWorkflowRunParams struct

+ ChildKey pgtype.Text

+ Childindex pgtype.Int4

+ Parentid pgtype.UUID

+ Parentsteprunid pgtype.UUID

+ type GetChildWorkflowRunsByIndexParams struct

+ Childindexes []int32

+ Parentids []pgtype.UUID

+ Parentsteprunids []pgtype.UUID

+ type GetChildWorkflowRunsByKeyParams struct

+ Childkeys []string

+ Parentids []pgtype.UUID

+ Parentsteprunids []pgtype.UUID

+ type GetDesiredLabelsRow struct

+ Comparator WorkerLabelComparator

+ IntValue pgtype.Int4

+ Key string

+ Required bool

+ StepId pgtype.UUID

+ StrValue pgtype.Text

+ Weight int32

+ type GetEventsForRangeRow struct

+ EventCount int64

+ EventHour pgtype.Interval

+ type GetExistingInviteParams struct

+ Inviteeemail string

+ Tenantid pgtype.UUID

+ type GetFailureDetailsParams struct

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ type GetFailureDetailsRow struct

+ CancelledReason pgtype.Text

+ Error pgtype.Text

+ ID pgtype.UUID

+ JrStatus JobRunStatus

+ SrStatus StepRunStatus

+ Status WorkflowRunStatus

+ type GetFinalizedStepRunsRow struct

+ ID pgtype.UUID

+ Status StepRunStatus

+ type GetGroupKeyRun struct

+ CancelledAt pgtype.Timestamp

+ CancelledError pgtype.Text

+ CancelledReason pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Input []byte

+ Output pgtype.Text

+ RequeueAfter pgtype.Timestamp

+ ScheduleTimeoutAt pgtype.Timestamp

+ StartedAt pgtype.Timestamp

+ Status StepRunStatus

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ TimeoutAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ WorkerId pgtype.UUID

+ WorkflowRunId pgtype.UUID

+ type GetGroupKeyRunForEngineParams struct

+ Ids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetGroupKeyRunForEngineRow struct

+ ActionId string

+ GetGroupKeyRun GetGroupKeyRun

+ WorkflowId pgtype.UUID

+ WorkflowRunId pgtype.UUID

+ WorkflowVersionId pgtype.UUID

+ type GetJobRunByWorkflowRunIdAndJobIdParams struct

+ Jobid pgtype.UUID

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ type GetJobRunByWorkflowRunIdAndJobIdRow struct

+ ID pgtype.UUID

+ JobId pgtype.UUID

+ Status JobRunStatus

+ type GetJobRunsByWorkflowRunIdParams struct

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ type GetJobRunsByWorkflowRunIdRow struct

+ ID pgtype.UUID

+ JobId pgtype.UUID

+ Status JobRunStatus

+ type GetLatestWorkflowVersionForWorkflowsParams struct

+ Tenantid pgtype.UUID

+ Workflowids []pgtype.UUID

+ type GetLeasesToAcquireParams struct

+ Kind LeaseKind

+ Resourceids []string

+ Tenantid pgtype.UUID

+ type GetMinMaxExpiredMessageQueueItemsRow struct

+ MaxId int64

+ MinId int64

+ type GetMinMaxProcessedInternalQueueItemsRow struct

+ MaxId int64

+ MinId int64

+ type GetMinMaxProcessedQueueItemsRow struct

+ MaxId int64

+ MinId int64

+ type GetMinMaxProcessedRetryQueueItemsRow struct

+ MaxRetryAfter pgtype.Timestamp

+ MinRetryAfter pgtype.Timestamp

+ type GetMinMaxProcessedTimeoutQueueItemsRow struct

+ MaxId int64

+ MinId int64

+ type GetMinUnprocessedQueueItemIdParams struct

+ Queue string

+ Tenantid pgtype.UUID

+ type GetQueuedCountsRow struct

+ Count int64

+ Queue string

+ type GetSNSIntegrationParams struct

+ Tenantid pgtype.UUID

+ Topicarn string

+ type GetScheduledChildWorkflowRunParams struct

+ ChildKey pgtype.Text

+ Childindex pgtype.Int4

+ Parentid pgtype.UUID

+ Parentsteprunid pgtype.UUID

+ type GetStepRunBulkDataForEngineParams struct

+ Ids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetStepRunBulkDataForEngineRow struct

+ ActionId string

+ AdditionalMetadata []byte

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ Error pgtype.Text

+ Input []byte

+ JobId pgtype.UUID

+ JobKind JobKind

+ JobName string

+ JobRunId pgtype.UUID

+ JobRunId_2 pgtype.UUID

+ JobRunLookupData []byte

+ JobRunStatus JobRunStatus

+ JobRunStatus_2 JobRunStatus

+ Output []byte

+ ParentId pgtype.UUID

+ Priority int32

+ SRID pgtype.UUID

+ SRRetryCount int32

+ Status StepRunStatus

+ StepCustomUserData []byte

+ StepId pgtype.UUID

+ StepReadableId pgtype.Text

+ StepRetries int32

+ StepScheduleTimeout string

+ StepTimeout pgtype.Text

+ WorkflowRunId pgtype.UUID

+ WorkflowVersionId pgtype.UUID

+ type GetStepRunDataForEngineParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetStepRunDataForEngineRow struct

+ AdditionalMetadata []byte

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ Error pgtype.Text

+ ExprCount int64

+ Input []byte

+ JobRunLookupData []byte

+ Output []byte

+ ParentId pgtype.UUID

+ type GetStepRunForEngineParams struct

+ Ids []pgtype.UUID

+ TenantId pgtype.UUID

+ type GetStepRunForEngineRow struct

+ ActionId string

+ DesiredWorkerId pgtype.UUID

+ JobId pgtype.UUID

+ JobKind JobKind

+ JobName string

+ JobRunId pgtype.UUID

+ JobRunStatus JobRunStatus

+ SRCallerFiles []byte

+ SRCancelledAt pgtype.Timestamp

+ SRCancelledError pgtype.Text

+ SRCancelledReason pgtype.Text

+ SRChildCount int64

+ SRCreatedAt pgtype.Timestamp

+ SRDeletedAt pgtype.Timestamp

+ SRFinishedAt pgtype.Timestamp

+ SRGitRepoBranch pgtype.Text

+ SRID pgtype.UUID

+ SROrder int64

+ SRPriority pgtype.Int4

+ SRQueue string

+ SRRequeueAfter pgtype.Timestamp

+ SRRetryCount int32

+ SRScheduleTimeoutAt pgtype.Timestamp

+ SRSemaphoreReleased bool

+ SRStartedAt pgtype.Timestamp

+ SRStatus StepRunStatus

+ SRTenantId pgtype.UUID

+ SRTickerId pgtype.UUID

+ SRTimeoutAt pgtype.Timestamp

+ SRUpdatedAt pgtype.Timestamp

+ SRWorkerId pgtype.UUID

+ StepCustomUserData []byte

+ StepId pgtype.UUID

+ StepReadableId pgtype.Text

+ StepRetries int32

+ StepRetryBackoffFactor pgtype.Float8

+ StepRetryMaxBackoff pgtype.Int4

+ StepScheduleTimeout string

+ StepTimeout pgtype.Text

+ StickyStrategy NullStickyStrategy

+ WorkflowRunId pgtype.UUID

+ WorkflowVersionId pgtype.UUID

+ type GetStepRunMetaParams struct

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetStepRunMetaRow struct

+ Retries int32

+ RetryCount int32

+ WorkflowRunId pgtype.UUID

+ type GetStepRunsForJobRunsWithOutputParams struct

+ Jobids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetStepRunsForJobRunsWithOutputRow struct

+ CancelledAt pgtype.Timestamp

+ CancelledError pgtype.Text

+ CancelledReason pgtype.Text

+ CreatedAt pgtype.Timestamp

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ JobRunId pgtype.UUID

+ Output []byte

+ StartedAt pgtype.Timestamp

+ Status StepRunStatus

+ StepId pgtype.UUID

+ TenantId pgtype.UUID

+ TimeoutAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ WorkerId pgtype.UUID

+ type GetStepsForJobsParams struct

+ Jobids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetStepsForJobsRow struct

+ JobId pgtype.UUID

+ Parents []pgtype.UUID

+ Step Step

+ type GetStreamEventMetaParams struct

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetStreamEventMetaRow struct

+ Retries int32

+ RetryCount int32

+ WorkflowRunId pgtype.UUID

+ type GetStreamEventParams struct

+ ID int64

+ Tenantid pgtype.UUID

+ type GetTenantMemberByEmailParams struct

+ Email string

+ Tenantid pgtype.UUID

+ type GetTenantMemberByUserIDParams struct

+ Tenantid pgtype.UUID

+ Userid pgtype.UUID

+ type GetTenantResourceLimitParams struct

+ Resource NullLimitResource

+ Tenantid pgtype.UUID

+ type GetTenantResourceLimitRow struct

+ AlarmValue pgtype.Int4

+ CreatedAt pgtype.Timestamp

+ CustomValueMeter bool

+ ID pgtype.UUID

+ LastRefill pgtype.Timestamp

+ LimitValue int32

+ Resource LimitResource

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ Value int32

+ Window pgtype.Text

+ type GetTenantTotalQueueMetricsParams struct

+ AdditionalMetadata []byte

+ TenantId pgtype.UUID

+ WorkflowIds []pgtype.UUID

+ type GetTenantTotalQueueMetricsRow struct

+ PendingAssignmentCount int64

+ PendingCount int64

+ RunningCount int64

+ type GetTenantWorkflowQueueMetricsParams struct

+ AdditionalMetadata []byte

+ TenantId pgtype.UUID

+ WorkflowIds []pgtype.UUID

+ type GetTenantWorkflowQueueMetricsRow struct

+ PendingAssignmentCount int64

+ PendingCount int64

+ RunningCount int64

+ WorkflowId pgtype.UUID

+ type GetUpstreamErrorsForOnFailureStepRow struct

+ StepReadableId pgtype.Text

+ StepRunError pgtype.Text

+ StepRunId pgtype.UUID

+ type GetWorkerActionsByWorkerIdParams struct

+ Tenantid pgtype.UUID

+ Workerids []pgtype.UUID

+ type GetWorkerActionsByWorkerIdRow struct

+ Actionid pgtype.Text

+ WorkerId pgtype.UUID

+ type GetWorkerByIdRow struct

+ RemainingSlots int32

+ WebhookUrl pgtype.Text

+ Worker Worker

+ type GetWorkerByWebhookIdParams struct

+ Tenantid pgtype.UUID

+ Webhookid pgtype.UUID

+ type GetWorkerDispatcherActionsParams struct

+ Actionids []string

+ Tenantid pgtype.UUID

+ type GetWorkerDispatcherActionsRow struct

+ ActionId string

+ DispatcherId pgtype.UUID

+ ID pgtype.UUID

+ type GetWorkerForEngineParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetWorkerForEngineRow struct

+ DispatcherId pgtype.UUID

+ DispatcherLastHeartbeatAt pgtype.Timestamp

+ ID pgtype.UUID

+ IsActive bool

+ LastListenerEstablished pgtype.Timestamp

+ TenantId pgtype.UUID

+ type GetWorkerLabelsRow struct

+ IntValue pgtype.Int4

+ Key string

+ StrValue pgtype.Text

+ type GetWorkflowByIdRow struct

+ Workflow Workflow

+ WorkflowVersionId pgtype.UUID

+ type GetWorkflowByNameParams struct

+ Name string

+ Tenantid pgtype.UUID

+ type GetWorkflowRunAdditionalMetaParams struct

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ type GetWorkflowRunAdditionalMetaRow struct

+ AdditionalMetadata []byte

+ ID pgtype.UUID

+ type GetWorkflowRunByIdParams struct

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ type GetWorkflowRunByIdRow struct

+ AdditionalMetadata []byte

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ ConcurrencyGroupId pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ DisplayName pgtype.Text

+ Duration pgtype.Int8

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ InsertOrder pgtype.Int4

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

+ Priority pgtype.Int4

+ StartedAt pgtype.Timestamp

+ Status WorkflowRunStatus

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ Workflow Workflow

+ WorkflowRunTriggeredBy WorkflowRunTriggeredBy

+ WorkflowVersion WorkflowVersion

+ WorkflowVersionId pgtype.UUID

+ type GetWorkflowRunByIdsParams struct

+ Tenantid pgtype.UUID

+ Workflowrunids []pgtype.UUID

+ type GetWorkflowRunByIdsRow struct

+ AdditionalMetadata []byte

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ ConcurrencyGroupId pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ DisplayName pgtype.Text

+ Duration pgtype.Int8

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ InsertOrder pgtype.Int4

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

+ Priority pgtype.Int4

+ StartedAt pgtype.Timestamp

+ Status WorkflowRunStatus

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ Workflow Workflow

+ WorkflowRunTriggeredBy WorkflowRunTriggeredBy

+ WorkflowVersion WorkflowVersion

+ WorkflowVersionId pgtype.UUID

+ type GetWorkflowRunParams struct

+ Ids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetWorkflowRunRow struct

+ ConcurrencyGroupExpression pgtype.Text

+ ConcurrencyLimitStrategy NullConcurrencyLimitStrategy

+ ConcurrencyMaxRuns pgtype.Int4

+ GetGroupKeyRunId pgtype.UUID

+ IsPaused pgtype.Bool

+ WorkflowName pgtype.Text

+ WorkflowRun WorkflowRun

+ WorkflowRunTriggeredBy WorkflowRunTriggeredBy

+ WorkflowVersion WorkflowVersion

+ type GetWorkflowRunShapeRow struct

+ Childrenstepids []pgtype.UUID

+ Parentstepid pgtype.UUID

+ Stepname pgtype.Text

+ type GetWorkflowRunStickyStateForUpdateParams struct

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ type GetWorkflowRunTriggerParams struct

+ Runid pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetWorkflowVersionByIdRow struct

+ ConcurrencyGroupId pgtype.UUID

+ ConcurrencyId pgtype.UUID

+ ConcurrencyLimitStrategy NullConcurrencyLimitStrategy

+ ConcurrencyMaxRuns pgtype.Int4

+ Workflow Workflow

+ WorkflowVersion WorkflowVersion

+ type GetWorkflowVersionForEngineParams struct

+ Ids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetWorkflowVersionForEngineRow struct

+ ConcurrencyGroupExpression pgtype.Text

+ ConcurrencyGroupId pgtype.UUID

+ ConcurrencyLimitStrategy NullConcurrencyLimitStrategy

+ ConcurrencyMaxRuns pgtype.Int4

+ WorkflowName string

+ WorkflowVersion WorkflowVersion

+ type GetWorkflowWorkerCountParams struct

+ Tenantid pgtype.UUID

+ Workflowid pgtype.UUID

+ type GetWorkflowWorkerCountRow struct

+ Freeslotcount int32

+ Totalslotcount int64

+ type GetWorkflowsByNamesParams struct

+ Names []string

+ Tenantid pgtype.UUID

+ type HandleWorkflowUnpausedParams struct

+ Tenantid pgtype.UUID

+ Workflowid string

+ type HardDeleteWebhookWorkerParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ type HasActiveWorkersForActionIdParams struct

+ Actionid string

+ Tenantid pgtype.UUID

+ type InsertWebhookWorkerRequestParams struct

+ Method WebhookWorkerRequestMethod

+ Statuscode int32

+ Webhookworkerid pgtype.UUID

+ type InternalQueue string

+ const InternalQueueSTEPRUNUPDATE

+ const InternalQueueSTEPRUNUPDATEV2

+ const InternalQueueWORKERSEMAPHORECOUNT

+ const InternalQueueWORKFLOWRUNPAUSED

+ const InternalQueueWORKFLOWRUNUPDATE

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

+ type InternalQueueItem struct

+ Data []byte

+ ID int64

+ IsQueued bool

+ Priority int32

+ Queue InternalQueue

+ TenantId pgtype.UUID

+ UniqueKey pgtype.Text

+ type InternalRetryStepRunsParams struct

+ Maxinternalretrycount int32

+ Steprunids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type InternalRetryStepRunsRow struct

+ ID pgtype.UUID

+ Operation string

+ RetryCount int32

+ type InviteLinkStatus string

+ const InviteLinkStatusACCEPTED

+ const InviteLinkStatusPENDING

+ const InviteLinkStatusREJECTED

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

+ type Job struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ Description pgtype.Text

+ ID pgtype.UUID

+ Kind JobKind

+ Name string

+ TenantId pgtype.UUID

+ Timeout pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ WorkflowVersionId pgtype.UUID

+ type JobKind string

+ const JobKindDEFAULT

+ const JobKindONFAILURE

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

+ type JobRun struct

+ CancelledAt pgtype.Timestamp

+ CancelledError pgtype.Text

+ CancelledReason pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ JobId pgtype.UUID

+ Result []byte

+ StartedAt pgtype.Timestamp

+ Status JobRunStatus

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ TimeoutAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ WorkflowRunId pgtype.UUID

+ type JobRunLookupData struct

+ CreatedAt pgtype.Timestamp

+ Data []byte

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ JobRunId pgtype.UUID

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type JobRunStatus string

+ const JobRunStatusBACKOFF

+ const JobRunStatusCANCELLED

+ const JobRunStatusFAILED

+ const JobRunStatusPENDING

+ const JobRunStatusRUNNING

+ const JobRunStatusSUCCEEDED

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

+ type Lease struct

+ ExpiresAt pgtype.Timestamp

+ ID int64

+ Kind LeaseKind

+ ResourceId string

+ TenantId pgtype.UUID

+ type LeaseKind string

+ const LeaseKindCONCURRENCYSTRATEGY

+ const LeaseKindQUEUE

+ const LeaseKindWORKER

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

+ type LimitResource string

+ const LimitResourceCRON

+ const LimitResourceEVENT

+ const LimitResourceSCHEDULE

+ const LimitResourceTASKRUN

+ const LimitResourceWORKER

+ const LimitResourceWORKERSLOT

+ const LimitResourceWORKFLOWRUN

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

+ type LinkActionsToWorkerParams struct

+ Actionids []pgtype.UUID

+ Workerid pgtype.UUID

+ type LinkOnFailureJobParams struct

+ Jobid pgtype.UUID

+ Workflowversionid pgtype.UUID

+ type LinkServicesToWorkerParams struct

+ Services []pgtype.UUID

+ Workerid pgtype.UUID

+ type ListActionsForAvailableWorkersRow struct

+ ActionId string

+ WorkerId pgtype.UUID

+ type ListActionsForWorkersParams struct

+ Tenantid pgtype.UUID

+ Workerids []pgtype.UUID

+ type ListActionsForWorkersRow struct

+ ActionId pgtype.Text

+ WorkerId pgtype.UUID

+ type ListActiveDispatchersRow struct

+ Dispatcher Dispatcher

+ type ListActiveQueuedWorkflowVersionsRow struct

+ ConcurrencyGroupId pgtype.Text

+ ID pgtype.UUID

+ Status WorkflowRunStatus

+ TenantId pgtype.UUID

+ WorkflowVersionId pgtype.UUID

+ type ListActiveTickersRow struct

+ Ticker Ticker

+ type ListActiveWorkersRow struct

+ ID pgtype.UUID

+ MaxRuns int32

+ type ListAllAvailableSlotsForWorkersRow struct

+ AvailableSlots int32

+ ID pgtype.UUID

+ type ListAllWorkerActionsParams struct

+ Tenantid pgtype.UUID

+ Workerid pgtype.UUID

+ type ListAvailableSlotsForWorkersParams struct

+ Tenantid pgtype.UUID

+ Workerids []pgtype.UUID

+ type ListAvailableSlotsForWorkersRow struct

+ AvailableSlots int32

+ ID pgtype.UUID

+ type ListChildWorkflowRunCountsRow struct

+ Count int64

+ ParentStepRunId pgtype.UUID

+ type ListChildWorkflowRunIdsParams struct

+ Steprun pgtype.UUID

+ Tenantid pgtype.UUID

+ type ListCronWorkflowsParams struct

+ AdditionalMetadata []byte

+ CronName pgtype.Text

+ Crontriggerid pgtype.UUID

+ Limit interface{}

+ Offset interface{}

+ Orderby interface{}

+ Tenantid pgtype.UUID

+ WorkflowName pgtype.Text

+ Workflowid pgtype.UUID

+ type ListCronWorkflowsRow struct

+ AdditionalMetadata []byte

+ CreatedAt pgtype.Timestamp

+ CreatedAt_2 pgtype.Timestamp

+ Cron string

+ CronId pgtype.UUID

+ DeletedAt pgtype.Timestamp

+ DeletedAt_2 pgtype.Timestamp

+ Enabled bool

+ ID pgtype.UUID

+ ID_2 pgtype.UUID

+ Input []byte

+ Method WorkflowTriggerCronRefMethods

+ Name pgtype.Text

+ ParentId pgtype.UUID

+ Priority int32

+ TenantId pgtype.UUID

+ TenantId_2 pgtype.UUID

+ TickerId pgtype.UUID

+ TriggerId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ UpdatedAt_2 pgtype.Timestamp

+ WorkflowId pgtype.UUID

+ WorkflowName string

+ WorkflowVersionId pgtype.UUID

+ WorkflowVersionId_2 pgtype.UUID

+ type ListDispatcherIdsForWorkersParams struct

+ Tenantid pgtype.UUID

+ Workerids []pgtype.UUID

+ type ListDispatcherIdsForWorkersRow struct

+ DispatcherId pgtype.UUID

+ WorkerId pgtype.UUID

+ type ListDispatchersRow struct

+ Dispatcher Dispatcher

+ type ListEventsByIDsParams struct

+ Ids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type ListEventsParams struct

+ AdditionalMetadata []byte

+ EventIds []pgtype.UUID

+ Keys []string

+ Limit interface{}

+ Offset interface{}

+ Orderby interface{}

+ Search pgtype.Text

+ Statuses []string

+ TenantId pgtype.UUID

+ Workflows []string

+ type ListEventsRow struct

+ Cancelledruns int64

+ Event Event

+ Failedruns int64

+ Pendingruns int64

+ Queuedruns int64

+ Runningruns int64

+ Succeededruns int64

+ type ListInternalQueueItemsParams struct

+ GtId pgtype.Int8

+ Limit pgtype.Int4

+ Queue InternalQueue

+ Tenantid pgtype.UUID

+ type ListInvitesByTenantIdParams struct

+ Expired pgtype.Bool

+ Status NullInviteLinkStatus

+ Tenantid pgtype.UUID

+ type ListJobRunsForWorkflowRunFullParams struct

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ type ListJobRunsForWorkflowRunFullRow struct

+ CancelledAt pgtype.Timestamp

+ CancelledError pgtype.Text

+ CancelledReason pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Job Job

+ JobId pgtype.UUID

+ Result []byte

+ StartedAt pgtype.Timestamp

+ Status JobRunStatus

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ TimeoutAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ WorkflowRunId pgtype.UUID

+ type ListJobRunsForWorkflowRunRow struct

+ ID pgtype.UUID

+ JobId pgtype.UUID

+ type ListLogLinesParams struct

+ Levels []LogLineLevel

+ Limit interface{}

+ Offset interface{}

+ OrderBy pgtype.Text

+ Search pgtype.Text

+ StepRunId pgtype.UUID

+ Tenantid pgtype.UUID

+ type ListManyWorkerLabelsRow struct

+ CreatedAt pgtype.Timestamp

+ ID int64

+ IntValue pgtype.Int4

+ Key string

+ StrValue pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ WorkerId pgtype.UUID

+ type ListNewlyStaleTickersRow struct

+ Ticker Ticker

+ type ListQueueItemsBatchResults struct

+ func (b *ListQueueItemsBatchResults) Close() error

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

+ type ListQueueItemsForQueueParams struct

+ GtId pgtype.Int8

+ Limit pgtype.Int4

+ Queue string

+ Tenantid pgtype.UUID

+ type ListQueueItemsForQueueRow struct

+ QueueItem QueueItem

+ Status StepRunStatus

+ type ListQueueItemsParams struct

+ GtId pgtype.Int8

+ Limit pgtype.Int4

+ Queue string

+ Tenantid pgtype.UUID

+ type ListRateLimitsForStepsParams struct

+ Stepids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type ListRateLimitsForTenantNoMutateParams struct

+ Limit interface{}

+ Offset interface{}

+ Orderby interface{}

+ Search pgtype.Text

+ Tenantid pgtype.UUID

+ type ListRateLimitsForTenantNoMutateRow struct

+ Key string

+ LastRefill pgtype.Timestamp

+ LimitValue int32

+ TenantId pgtype.UUID

+ Value int32

+ Window string

+ type ListRateLimitsForTenantWithMutateRow struct

+ Key string

+ LastRefill pgtype.Timestamp

+ LimitValue int32

+ NextRefillAt pgtype.Timestamp

+ TenantId pgtype.UUID

+ Value int32

+ Window string

+ type ListRecentAssignedEventsForWorkerParams struct

+ Limit pgtype.Int4

+ Workerid pgtype.UUID

+ type ListRecentAssignedEventsForWorkerRow struct

+ AssignedStepRuns []byte

+ WorkerId pgtype.UUID

+ type ListScheduledWorkflowsParams struct

+ AdditionalMetadata []byte

+ Includescheduled bool

+ Limit interface{}

+ Offset interface{}

+ Orderby interface{}

+ Parentsteprunid pgtype.UUID

+ Parentworkflowrunid pgtype.UUID

+ Scheduleid pgtype.UUID

+ Statuses []string

+ Tenantid pgtype.UUID

+ Workflowid pgtype.UUID

+ type ListScheduledWorkflowsRow struct

+ AdditionalMetadata []byte

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Input []byte

+ Method WorkflowTriggerScheduledRefMethods

+ Name string

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

+ ParentWorkflowRunId pgtype.UUID

+ Priority int32

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ TriggerAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ WorkflowId pgtype.UUID

+ WorkflowRunCreatedAt pgtype.Timestamp

+ WorkflowRunId pgtype.UUID

+ WorkflowRunName pgtype.Text

+ WorkflowRunStatus NullWorkflowRunStatus

+ WorkflowVersionId pgtype.UUID

+ type ListSemaphoreSlotsWithStateForWorkerParams struct

+ Limit pgtype.Int4

+ Tenantid pgtype.UUID

+ Workerid pgtype.UUID

+ type ListSemaphoreSlotsWithStateForWorkerRow struct

+ ActionId string

+ StartedAt pgtype.Timestamp

+ Status StepRunStatus

+ StepRunId pgtype.UUID

+ TimeoutAt pgtype.Timestamp

+ WorkflowRunId pgtype.UUID

+ type ListStaleDispatchersRow struct

+ Dispatcher Dispatcher

+ type ListStepRunArchivesParams struct

+ Limit interface{}

+ Offset interface{}

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type ListStepRunEventsByWorkflowRunIdParams struct

+ LastId pgtype.Int8

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ type ListStepRunEventsParams struct

+ Limit interface{}

+ Offset interface{}

+ Steprunid pgtype.UUID

+ type ListStepRunsParams struct

+ JobRunId pgtype.UUID

+ Status NullStepRunStatus

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ WorkflowRunIds []pgtype.UUID

+ type ListStepRunsToCancelParams struct

+ Jobrunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type ListStepRunsToReassignParams struct

+ Maxinternalretrycount int32

+ Tenantid pgtype.UUID

+ type ListStepRunsToReassignRow struct

+ ID pgtype.UUID

+ Operation string

+ RetryCount int32

+ WorkerId pgtype.UUID

+ type ListStepsForJobRow struct

+ ActionId string

+ ID pgtype.UUID

+ type ListTenantInvitesByEmailRow struct

+ CreatedAt pgtype.Timestamp

+ Expires pgtype.Timestamp

+ ID pgtype.UUID

+ InviteeEmail string

+ InviterEmail string

+ Role TenantMemberRole

+ Status InviteLinkStatus

+ TenantId pgtype.UUID

+ TenantName string

+ UpdatedAt pgtype.Timestamp

+ type ListTenantsByControllerPartitionIdParams struct

+ ControllerPartitionId string

+ Majorversion TenantMajorEngineVersion

+ type ListTenantsBySchedulerPartitionIdParams struct

+ Majorversion TenantMajorEngineVersion

+ SchedulerPartitionId string

+ type ListTenantsByTenantWorkerPartitionIdParams struct

+ Majorversion TenantMajorEngineVersion

+ WorkerPartitionId string

+ type ListTickersParams struct

+ IsActive bool

+ LastHeartbeatAfter pgtype.Timestamp

+ type ListWorkerLabelsRow struct

+ CreatedAt pgtype.Timestamp

+ ID int64

+ IntValue pgtype.Int4

+ Key string

+ StrValue pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ type ListWorkersWithSlotCountParams struct

+ ActionId pgtype.Text

+ Assignable pgtype.Bool

+ LastHeartbeatAfter pgtype.Timestamp

+ Tenantid pgtype.UUID

+ type ListWorkersWithSlotCountRow struct

+ RemainingSlots int32

+ WebhookId pgtype.UUID

+ WebhookUrl pgtype.Text

+ Worker Worker

+ type ListWorkflowRunsParams struct

+ AdditionalMetadata []byte

+ CreatedAfter pgtype.Timestamp

+ CreatedBefore pgtype.Timestamp

+ EventId pgtype.UUID

+ FinishedAfter pgtype.Timestamp

+ FinishedBefore pgtype.Timestamp

+ GroupKey pgtype.Text

+ Ids []pgtype.UUID

+ Kinds []string

+ Limit interface{}

+ Offset interface{}

+ Orderby interface{}

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

+ Statuses []string

+ TenantId pgtype.UUID

+ WorkflowId pgtype.UUID

+ WorkflowVersionId pgtype.UUID

+ type ListWorkflowRunsRow struct

+ CreatedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Key pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ Workflow Workflow

+ WorkflowRun WorkflowRun

+ WorkflowRunTriggeredBy WorkflowRunTriggeredBy

+ WorkflowVersion WorkflowVersion

+ type ListWorkflowsForEventParams struct

+ Eventkey string

+ Tenantid pgtype.UUID

+ type ListWorkflowsLatestRunsParams struct

+ EventKey pgtype.Text

+ TenantId pgtype.UUID

+ type ListWorkflowsLatestRunsRow struct

+ WorkflowId pgtype.UUID

+ WorkflowRun WorkflowRun

+ type ListWorkflowsParams struct

+ Limit interface{}

+ Offset interface{}

+ Orderby interface{}

+ Search pgtype.Text

+ Tenantid pgtype.UUID

+ type ListWorkflowsRow struct

+ Workflow Workflow

+ type LockWorkflowRunsForQueueingParams struct

+ Tenantid pgtype.UUID

+ Workflowversionid pgtype.UUID

+ type LogLine struct

+ CreatedAt pgtype.Timestamp

+ ID int64

+ Level LogLineLevel

+ Message string

+ Metadata []byte

+ StepRunId pgtype.UUID

+ TenantId pgtype.UUID

+ type LogLineLevel string

+ const LogLineLevelDEBUG

+ const LogLineLevelERROR

+ const LogLineLevelINFO

+ const LogLineLevelWARN

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

+ type ManualReleaseSemaphoreParams struct

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type MarkWorkflowRunsCancellingParams struct

+ Ids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type MessageQueue struct

+ AutoDeleted bool

+ Durable bool

+ Exclusive bool

+ ExclusiveConsumerId pgtype.UUID

+ LastActive pgtype.Timestamp

+ Name string

+ type MessageQueueItem struct

+ ExpiresAt pgtype.Timestamp

+ ID int64

+ Payload []byte

+ QueueId pgtype.Text

+ ReadAfter pgtype.Timestamp

+ Status MessageQueueItemStatus

+ type MessageQueueItemStatus string

+ const MessageQueueItemStatusASSIGNED

+ const MessageQueueItemStatusPENDING

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

+ type MeterTenantResourceParams struct

+ Numresources int32

+ Resource NullLimitResource

+ Tenantid pgtype.UUID

+ type MoveCronTriggerToNewWorkflowTriggersParams struct

+ Newworkflowtriggerid pgtype.UUID

+ Oldworkflowversionid pgtype.UUID

+ type MoveScheduledTriggerToNewWorkflowTriggersParams struct

+ Newworkflowtriggerid pgtype.UUID

+ Oldworkflowversionid pgtype.UUID

+ type NullConcurrencyLimitStrategy struct

+ ConcurrencyLimitStrategy ConcurrencyLimitStrategy

+ Valid bool

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

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

+ type NullInternalQueue struct

+ InternalQueue InternalQueue

+ Valid bool

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

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

+ type NullInviteLinkStatus struct

+ InviteLinkStatus InviteLinkStatus

+ Valid bool

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

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

+ type NullJobKind struct

+ JobKind JobKind

+ Valid bool

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

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

+ type NullJobRunStatus struct

+ JobRunStatus JobRunStatus

+ Valid bool

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

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

+ type NullLeaseKind struct

+ LeaseKind LeaseKind

+ Valid bool

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

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

+ type NullLimitResource struct

+ LimitResource LimitResource

+ Valid bool

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

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

+ type NullLogLineLevel struct

+ LogLineLevel LogLineLevel

+ Valid bool

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

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

+ type NullMessageQueueItemStatus struct

+ MessageQueueItemStatus MessageQueueItemStatus

+ Valid bool

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

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

+ type NullStepExpressionKind struct

+ StepExpressionKind StepExpressionKind

+ Valid bool

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

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

+ type NullStepRateLimitKind struct

+ StepRateLimitKind StepRateLimitKind

+ Valid bool

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

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

+ type NullStepRunEventReason struct

+ StepRunEventReason StepRunEventReason

+ Valid bool

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

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

+ type NullStepRunEventSeverity struct

+ StepRunEventSeverity StepRunEventSeverity

+ Valid bool

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

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

+ type NullStepRunStatus struct

+ StepRunStatus StepRunStatus

+ Valid bool

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

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

+ type NullStickyStrategy struct

+ StickyStrategy StickyStrategy

+ Valid bool

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

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

+ type NullTenantMajorEngineVersion struct

+ TenantMajorEngineVersion TenantMajorEngineVersion

+ Valid bool

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

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

+ type NullTenantMajorUIVersion struct

+ TenantMajorUIVersion TenantMajorUIVersion

+ Valid bool

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

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

+ type NullTenantMemberRole struct

+ TenantMemberRole TenantMemberRole

+ Valid bool

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

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

+ type NullTenantResourceLimitAlertType struct

+ TenantResourceLimitAlertType TenantResourceLimitAlertType

+ Valid bool

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

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

+ type NullVcsProvider struct

+ Valid bool

+ VcsProvider VcsProvider

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

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

+ type NullWebhookWorkerRequestMethod struct

+ Valid bool

+ WebhookWorkerRequestMethod WebhookWorkerRequestMethod

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

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

+ type NullWorkerLabelComparator struct

+ Valid bool

+ WorkerLabelComparator WorkerLabelComparator

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

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

+ type NullWorkerSDKS struct

+ Valid bool

+ WorkerSDKS WorkerSDKS

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

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

+ type NullWorkerType struct

+ Valid bool

+ WorkerType WorkerType

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

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

+ type NullWorkflowKind struct

+ Valid bool

+ WorkflowKind WorkflowKind

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

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

+ type NullWorkflowRunStatus struct

+ Valid bool

+ WorkflowRunStatus WorkflowRunStatus

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

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

+ type NullWorkflowTriggerCronRefMethods struct

+ Valid bool

+ WorkflowTriggerCronRefMethods WorkflowTriggerCronRefMethods

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

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

+ type NullWorkflowTriggerScheduledRefMethods struct

+ Valid bool

+ WorkflowTriggerScheduledRefMethods WorkflowTriggerScheduledRefMethods

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

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

+ type PollCronSchedulesRow struct

+ AdditionalMetadata []byte

+ CreatedAt pgtype.Timestamp

+ Cron string

+ DeletedAt pgtype.Timestamp

+ Enabled bool

+ ID pgtype.UUID

+ Input []byte

+ Method WorkflowTriggerCronRefMethods

+ Name pgtype.Text

+ ParentId pgtype.UUID

+ Priority int32

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ WorkflowVersionId pgtype.UUID

+ type PollExpiringTokensRow struct

+ ExpiresAt pgtype.Timestamp

+ ID pgtype.UUID

+ Name pgtype.Text

+ TenantId pgtype.UUID

+ type PollScheduledWorkflowsRow struct

+ AdditionalMetadata []byte

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Input []byte

+ Method WorkflowTriggerScheduledRefMethods

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

+ ParentWorkflowRunId pgtype.UUID

+ Priority int32

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ TriggerAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ WorkflowVersionId pgtype.UUID

+ type PollTenantAlertsRow struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ EnableExpiringTokenAlerts bool

+ EnableTenantResourceLimitAlerts bool

+ EnableWorkflowRunFailureAlerts bool

+ ID pgtype.UUID

+ LastAlertedAt pgtype.Timestamp

+ MaxFrequency string

+ PrevLastAlertedAt pgtype.Timestamp

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type PollUnresolvedFailedStepRunsRow struct

+ ID pgtype.UUID

+ TenantId pgtype.UUID

+ type PopTimeoutQueueItemsParams struct

+ Limit pgtype.Int4

+ Tenantid pgtype.UUID

+ type PopWorkflowRunsRoundRobinParams struct

+ Maxruns int32

+ Tenantid pgtype.UUID

+ Workflowversionid pgtype.UUID

+ type PopulateTenantMembersRow struct

+ AlertMemberEmails bool

+ AnalyticsOptOut bool

+ CreatedAt pgtype.Timestamp

+ Email string

+ ID pgtype.UUID

+ Name pgtype.Text

+ Role TenantMemberRole

+ TenantCreatedAt pgtype.Timestamp

+ TenantId pgtype.UUID

+ TenantId_2 pgtype.UUID

+ TenantName string

+ TenantSlug string

+ TenantUiVersion TenantMajorUIVersion

+ TenantUpdatedAt pgtype.Timestamp

+ TenantVersion TenantMajorEngineVersion

+ UpdatedAt pgtype.Timestamp

+ UserId pgtype.UUID

+ type Queries struct

+ func New() *Queries

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

+ func (q *Queries) AddMessage(ctx context.Context, db DBTX, arg AddMessageParams) 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) BulkAckMessages(ctx context.Context, db DBTX, ids []int64) error

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

+ func (q *Queries) BulkBackoffStepRun(ctx context.Context, db DBTX, steprunids []pgtype.UUID) 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) BulkRetryStepRun(ctx context.Context, db DBTX, steprunids []pgtype.UUID) 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) CleanupMessageQueue(ctx context.Context, db DBTX) error

+ func (q *Queries) CleanupMessageQueueItems(ctx context.Context, db DBTX, arg CleanupMessageQueueItemsParams) 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) CountActiveInvites(ctx context.Context, db DBTX, tenantid pgtype.UUID) (int64, 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) CountTenantWorkerSlots(ctx context.Context, db DBTX, tenantid pgtype.UUID) (int32, 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) CreateSNSIntegration(ctx context.Context, db DBTX, arg CreateSNSIntegrationParams) (*SNSIntegration, 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) CreateTenantAlertGroup(ctx context.Context, db DBTX, arg CreateTenantAlertGroupParams) (*TenantAlertEmailGroup, error)

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

+ func (q *Queries) CreateTenantInvite(ctx context.Context, db DBTX, arg CreateTenantInviteParams) (*TenantInviteLink, error)

+ func (q *Queries) CreateTenantMember(ctx context.Context, db DBTX, arg CreateTenantMemberParams) (*TenantMember, 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) CreateUser(ctx context.Context, db DBTX, arg CreateUserParams) (*User, error)

+ func (q *Queries) CreateUserOAuth(ctx context.Context, db DBTX, arg CreateUserOAuthParams) (*UserOAuth, error)

+ func (q *Queries) CreateUserPassword(ctx context.Context, db DBTX, arg CreateUserPasswordParams) (*UserPassword, error)

+ func (q *Queries) CreateUserSession(ctx context.Context, db DBTX, arg CreateUserSessionParams) (*UserSession, 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) DeleteAPIToken(ctx context.Context, db DBTX, arg DeleteAPITokenParams) 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) DeleteExpiredMessages(ctx context.Context, db DBTX) 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) DeleteSNSIntegration(ctx context.Context, db DBTX, arg DeleteSNSIntegrationParams) 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) DeleteSlackWebhook(ctx context.Context, db DBTX, arg DeleteSlackWebhookParams) error

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

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

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

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

+ func (q *Queries) DeleteUserSession(ctx context.Context, db DBTX, id pgtype.UUID) (*UserSession, 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) GetExistingInvite(ctx context.Context, db DBTX, arg GetExistingInviteParams) (*TenantInviteLink, 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) GetInternalTenantForController(ctx context.Context, db DBTX, controllerpartitionid string) (*Tenant, error)

+ func (q *Queries) GetInviteById(ctx context.Context, db DBTX, id pgtype.UUID) (*TenantInviteLink, 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) GetMinMaxExpiredMessageQueueItems(ctx context.Context, db DBTX) (*GetMinMaxExpiredMessageQueueItemsRow, 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) GetSNSIntegration(ctx context.Context, db DBTX, arg GetSNSIntegrationParams) (*SNSIntegration, error)

+ func (q *Queries) GetSNSIntegrationById(ctx context.Context, db DBTX, id pgtype.UUID) (*SNSIntegration, 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) GetSlackWebhookById(ctx context.Context, db DBTX, id pgtype.UUID) (*SlackAppWebhook, 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) GetTenantAlertGroupById(ctx context.Context, db DBTX, id pgtype.UUID) (*TenantAlertEmailGroup, 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) GetTenantBySlug(ctx context.Context, db DBTX, slug string) (*Tenant, error)

+ func (q *Queries) GetTenantMemberByEmail(ctx context.Context, db DBTX, arg GetTenantMemberByEmailParams) (*TenantMember, error)

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

+ func (q *Queries) GetTenantMemberByUserID(ctx context.Context, db DBTX, arg GetTenantMemberByUserIDParams) (*TenantMember, 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) GetUpstreamErrorsForOnFailureStep(ctx context.Context, db DBTX, onfailuresteprunid pgtype.UUID) ([]*GetUpstreamErrorsForOnFailureStepRow, error)

+ func (q *Queries) GetUserByEmail(ctx context.Context, db DBTX, email string) (*User, error)

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

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

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

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

+ func (q *Queries) GetWorkerActionsByWorkerId(ctx context.Context, db DBTX, arg GetWorkerActionsByWorkerIdParams) ([]*GetWorkerActionsByWorkerIdRow, 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) GetWorkflowRunShape(ctx context.Context, db DBTX, workflowversionid pgtype.UUID) ([]*GetWorkflowRunShapeRow, 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) InternalRetryStepRuns(ctx context.Context, db DBTX, arg InternalRetryStepRunsParams) ([]*InternalRetryStepRunsRow, 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) ListAPITokensByTenant(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]*APIToken, 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) ListInvitesByTenantId(ctx context.Context, db DBTX, arg ListInvitesByTenantIdParams) ([]*TenantInviteLink, 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) ListSNSIntegrations(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]*SNSIntegration, 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) ListSlackWebhooks(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]*SlackAppWebhook, 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) 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) ListTenantAlertGroups(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]*TenantAlertEmailGroup, error)

+ func (q *Queries) ListTenantInvitesByEmail(ctx context.Context, db DBTX, inviteeemail string) ([]*ListTenantInvitesByEmailRow, error)

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

+ func (q *Queries) ListTenantMemberships(ctx context.Context, db DBTX, userid pgtype.UUID) ([]*TenantMember, 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, arg ListTenantsByControllerPartitionIdParams) ([]*Tenant, error)

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

+ func (q *Queries) ListTenantsByTenantWorkerPartitionId(ctx context.Context, db DBTX, arg ListTenantsByTenantWorkerPartitionIdParams) ([]*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) LockWorkflowRunsForQueueing(ctx context.Context, db DBTX, arg LockWorkflowRunsForQueueingParams) ([]*WorkflowRun, error)

+ func (q *Queries) LockWorkflowVersion(ctx context.Context, db DBTX, workflowid pgtype.UUID) (pgtype.UUID, 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) MarkWorkflowRunsCancelling(ctx context.Context, db DBTX, arg MarkWorkflowRunsCancellingParams) 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) PopulateTenantMembers(ctx context.Context, db DBTX, ids []pgtype.UUID) ([]*PopulateTenantMembersRow, 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) ReadMessages(ctx context.Context, db DBTX, arg ReadMessagesParams) ([]*ReadMessagesRow, 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) RetryStepRuns(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]*RetryStepRunsRow, error)

+ func (q *Queries) RevokeAPIToken(ctx context.Context, db DBTX, id pgtype.UUID) 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) UpdateMessageQueueActive(ctx context.Context, db DBTX, name string) 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) UpdateTenant(ctx context.Context, db DBTX, arg UpdateTenantParams) (*Tenant, error)

+ func (q *Queries) UpdateTenantAlertGroup(ctx context.Context, db DBTX, arg UpdateTenantAlertGroupParams) (*TenantAlertEmailGroup, error)

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

+ func (q *Queries) UpdateTenantInvite(ctx context.Context, db DBTX, arg UpdateTenantInviteParams) (*TenantInviteLink, error)

+ func (q *Queries) UpdateTenantMember(ctx context.Context, db DBTX, arg UpdateTenantMemberParams) (*TenantMember, error)

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

+ func (q *Queries) UpdateUser(ctx context.Context, db DBTX, arg UpdateUserParams) (*User, error)

+ func (q *Queries) UpdateUserPassword(ctx context.Context, db DBTX, arg UpdateUserPasswordParams) (*UserPassword, error)

+ func (q *Queries) UpdateUserSession(ctx context.Context, db DBTX, arg UpdateUserSessionParams) (*UserSession, 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) UpsertMessageQueue(ctx context.Context, db DBTX, arg UpsertMessageQueueParams) (*MessageQueue, 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) UpsertSlackWebhook(ctx context.Context, db DBTX, arg UpsertSlackWebhookParams) (*SlackAppWebhook, error)

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

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

+ func (q *Queries) UpsertUserOAuth(ctx context.Context, db DBTX, arg UpsertUserOAuthParams) (*UserOAuth, 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 struct

+ ID int64

+ LastActive pgtype.Timestamp

+ Name string

+ TenantId pgtype.UUID

+ type QueueItem struct

+ ActionId pgtype.Text

+ DesiredWorkerId pgtype.UUID

+ ID int64

+ IsQueued bool

+ Priority int32

+ Queue string

+ ScheduleTimeoutAt pgtype.Timestamp

+ StepId pgtype.UUID

+ StepRunId pgtype.UUID

+ StepTimeout pgtype.Text

+ Sticky NullStickyStrategy

+ TenantId pgtype.UUID

+ type QueueStepRunBulkNoInputParams struct

+ Ids []pgtype.UUID

+ Retrycounts []int32

+ type QueueStepRunBulkWithInputParams struct

+ Ids []pgtype.UUID

+ Inputs [][]byte

+ Retrycounts []int32

+ type QueueStepRunParams struct

+ ID pgtype.UUID

+ Input []byte

+ IsRetry pgtype.Bool

+ Tenantid pgtype.UUID

+ type RateLimit struct

+ Key string

+ LastRefill pgtype.Timestamp

+ LimitValue int32

+ TenantId pgtype.UUID

+ Value int32

+ Window string

+ type ReadMessagesParams struct

+ Limit pgtype.Int4

+ Queueid string

+ type ReadMessagesRow struct

+ ExpiresAt pgtype.Timestamp

+ ID int64

+ Payload []byte

+ QueueId pgtype.Text

+ ReadAfter pgtype.Timestamp

+ Status MessageQueueItemStatus

+ type RefreshTimeoutByParams struct

+ IncrementTimeoutBy pgtype.Text

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type RemoveTimeoutQueueItemParams struct

+ Retrycount int32

+ Steprunid pgtype.UUID

+ type ReplayStepRunResetStepRunsParams struct

+ Input []byte

+ Steprunid pgtype.UUID

+ type ResetStepRunsByIdsParams struct

+ Ids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type ResolveAllLimitsIfWindowPassedRow struct

+ AlarmValue pgtype.Int4

+ CreatedAt pgtype.Timestamp

+ CustomValueMeter bool

+ ID pgtype.UUID

+ LastRefill pgtype.Timestamp

+ LimitValue int32

+ Resource LimitResource

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ Value int32

+ Window pgtype.Text

+ type ResolveLaterStepRunsParams struct

+ Status StepRunStatus

+ Steprunid pgtype.UUID

+ type ResolveWorkflowRunStatusParams struct

+ Jobrunids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type ResolveWorkflowRunStatusRow struct

+ ID pgtype.UUID

+ Status WorkflowRunStatus

+ TenantId pgtype.UUID

+ type RetryQueueItem struct

+ ID int64

+ IsQueued bool

+ RetryAfter pgtype.Timestamp

+ StepRunId pgtype.UUID

+ TenantId pgtype.UUID

+ type RetryStepRunsRow struct

+ ID int64

+ IsQueued bool

+ RetryAfter pgtype.Timestamp

+ StepRunId pgtype.UUID

+ TenantId pgtype.UUID

+ type SNSIntegration struct

+ CreatedAt pgtype.Timestamp

+ ID pgtype.UUID

+ TenantId pgtype.UUID

+ TopicArn string

+ UpdatedAt pgtype.Timestamp

+ type SchedulerPartition struct

+ CreatedAt pgtype.Timestamp

+ ID string

+ LastHeartbeat pgtype.Timestamp

+ Name pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ type SecurityCheckIdent struct

+ ID pgtype.UUID

+ type SelectOrInsertTenantResourceLimitParams struct

+ AlarmValue pgtype.Int4

+ CustomValueMeter pgtype.Bool

+ LimitValue pgtype.Int4

+ Resource NullLimitResource

+ Tenantid pgtype.UUID

+ Window pgtype.Text

+ type SelectOrInsertTenantResourceLimitRow struct

+ AlarmValue pgtype.Int4

+ CreatedAt pgtype.Timestamp

+ CustomValueMeter bool

+ ID pgtype.UUID

+ LastRefill pgtype.Timestamp

+ LimitValue int32

+ Resource LimitResource

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ Value int32

+ Window pgtype.Text

+ type SemaphoreQueueItem struct

+ StepRunId pgtype.UUID

+ TenantId pgtype.UUID

+ WorkerId pgtype.UUID

+ type Service struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ Description pgtype.Text

+ ID pgtype.UUID

+ Name string

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type ServiceToWorker struct

+ A pgtype.UUID

+ B pgtype.UUID

+ type SetDispatchersInactiveRow struct

+ Dispatcher Dispatcher

+ type SetTickersInactiveRow struct

+ Ticker Ticker

+ type SlackAppWebhook struct

+ ChannelId string

+ ChannelName string

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ TeamId string

+ TeamName string

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ WebhookURL []byte

+ type SoftDeleteExpiredEventsParams struct

+ Createdbefore pgtype.Timestamp

+ Limit interface{}

+ Tenantid pgtype.UUID

+ type SoftDeleteExpiredWorkflowRunsWithDependenciesParams struct

+ Createdbefore pgtype.Timestamp

+ Limit interface{}

+ Statuses []string

+ Tenantid pgtype.UUID

+ type SoftDeleteWebhookWorkerParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ type Step struct

+ ActionId string

+ CreatedAt pgtype.Timestamp

+ CustomUserData []byte

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ JobId pgtype.UUID

+ ReadableId pgtype.Text

+ Retries int32

+ RetryBackoffFactor pgtype.Float8

+ RetryMaxBackoff pgtype.Int4

+ ScheduleTimeout string

+ TenantId pgtype.UUID

+ Timeout pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ type StepDesiredWorkerLabel struct

+ Comparator WorkerLabelComparator

+ CreatedAt pgtype.Timestamp

+ ID int64

+ IntValue pgtype.Int4

+ Key string

+ Required bool

+ StepId pgtype.UUID

+ StrValue pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ Weight int32

+ type StepExpression struct

+ Expression string

+ Key string

+ Kind StepExpressionKind

+ StepId pgtype.UUID

+ type StepExpressionKind string

+ const StepExpressionKindDYNAMICRATELIMITKEY

+ const StepExpressionKindDYNAMICRATELIMITUNITS

+ const StepExpressionKindDYNAMICRATELIMITVALUE

+ const StepExpressionKindDYNAMICRATELIMITWINDOW

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

+ type StepOrder struct

+ A pgtype.UUID

+ B pgtype.UUID

+ type StepRateLimit struct

+ Kind StepRateLimitKind

+ RateLimitKey string

+ StepId pgtype.UUID

+ TenantId pgtype.UUID

+ Units int32

+ type StepRateLimitKind string

+ const StepRateLimitKindDYNAMIC

+ const StepRateLimitKindSTATIC

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

+ type StepRun struct

+ CallerFiles []byte

+ CancelledAt pgtype.Timestamp

+ CancelledError pgtype.Text

+ CancelledReason pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ GitRepoBranch pgtype.Text

+ ID pgtype.UUID

+ Input []byte

+ InputSchema []byte

+ InternalRetryCount int32

+ JobRunId pgtype.UUID

+ Order int64

+ Output []byte

+ Priority pgtype.Int4

+ Queue string

+ RequeueAfter pgtype.Timestamp

+ RetryCount int32

+ ScheduleTimeoutAt pgtype.Timestamp

+ SemaphoreReleased bool

+ StartedAt pgtype.Timestamp

+ Status StepRunStatus

+ StepId pgtype.UUID

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ TimeoutAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ WorkerId pgtype.UUID

+ type StepRunEvent struct

+ Count int32

+ Data []byte

+ ID int64

+ Message string

+ Reason StepRunEventReason

+ Severity StepRunEventSeverity

+ StepRunId pgtype.UUID

+ TimeFirstSeen pgtype.Timestamp

+ TimeLastSeen pgtype.Timestamp

+ WorkflowRunId pgtype.UUID

+ type StepRunEventReason string

+ const StepRunEventReasonACKNOWLEDGED

+ const StepRunEventReasonASSIGNED

+ const StepRunEventReasonCANCELLED

+ const StepRunEventReasonFAILED

+ const StepRunEventReasonFINISHED

+ const StepRunEventReasonRATELIMITERROR

+ const StepRunEventReasonREASSIGNED

+ const StepRunEventReasonREQUEUEDNOWORKER

+ const StepRunEventReasonREQUEUEDRATELIMIT

+ const StepRunEventReasonRETRIEDBYUSER

+ const StepRunEventReasonRETRYING

+ const StepRunEventReasonSCHEDULINGTIMEDOUT

+ const StepRunEventReasonSENTTOWORKER

+ const StepRunEventReasonSLOTRELEASED

+ const StepRunEventReasonSTARTED

+ const StepRunEventReasonTIMEDOUT

+ const StepRunEventReasonTIMEOUTREFRESHED

+ const StepRunEventReasonWORKFLOWRUNGROUPKEYFAILED

+ const StepRunEventReasonWORKFLOWRUNGROUPKEYSUCCEEDED

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

+ type StepRunEventSeverity string

+ const StepRunEventSeverityCRITICAL

+ const StepRunEventSeverityINFO

+ const StepRunEventSeverityWARNING

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

+ type StepRunExpressionEval struct

+ Key string

+ Kind StepExpressionKind

+ StepRunId pgtype.UUID

+ ValueInt pgtype.Int4

+ ValueStr pgtype.Text

+ type StepRunOrder struct

+ A pgtype.UUID

+ B pgtype.UUID

+ type StepRunResultArchive struct

+ CancelledAt pgtype.Timestamp

+ CancelledError pgtype.Text

+ CancelledReason pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Input []byte

+ Order int64

+ Output []byte

+ RetryCount int32

+ StartedAt pgtype.Timestamp

+ StepRunId pgtype.UUID

+ TimeoutAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ type StepRunStatus string

+ const StepRunStatusASSIGNED

+ const StepRunStatusBACKOFF

+ const StepRunStatusCANCELLED

+ const StepRunStatusCANCELLING

+ const StepRunStatusFAILED

+ const StepRunStatusPENDING

+ const StepRunStatusPENDINGASSIGNMENT

+ const StepRunStatusRUNNING

+ const StepRunStatusSUCCEEDED

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

+ type StickyStrategy string

+ const StickyStrategyHARD

+ const StickyStrategySOFT

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

+ type StreamEvent struct

+ CreatedAt pgtype.Timestamp

+ ID int64

+ Message []byte

+ Metadata []byte

+ StepRunId pgtype.UUID

+ TenantId pgtype.UUID

+ type Tenant struct

+ AlertMemberEmails bool

+ AnalyticsOptOut bool

+ CanUpgradeV1 bool

+ ControllerPartitionId pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DataRetentionPeriod string

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Name string

+ SchedulerPartitionId pgtype.Text

+ Slug string

+ UiVersion TenantMajorUIVersion

+ UpdatedAt pgtype.Timestamp

+ Version TenantMajorEngineVersion

+ WorkerPartitionId pgtype.Text

+ type TenantAlertEmailGroup struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ Emails string

+ ID pgtype.UUID

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type TenantAlertingSettings struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ EnableExpiringTokenAlerts bool

+ EnableTenantResourceLimitAlerts bool

+ EnableWorkflowRunFailureAlerts bool

+ ID pgtype.UUID

+ LastAlertedAt pgtype.Timestamp

+ MaxFrequency string

+ TenantId pgtype.UUID

+ TickerId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type TenantInviteLink struct

+ CreatedAt pgtype.Timestamp

+ Expires pgtype.Timestamp

+ ID pgtype.UUID

+ InviteeEmail string

+ InviterEmail string

+ Role TenantMemberRole

+ Status InviteLinkStatus

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type TenantMajorEngineVersion string

+ const TenantMajorEngineVersionV0

+ const TenantMajorEngineVersionV1

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

+ type TenantMajorUIVersion string

+ const TenantMajorUIVersionV0

+ const TenantMajorUIVersionV1

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

+ type TenantMember struct

+ CreatedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Role TenantMemberRole

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ UserId pgtype.UUID

+ type TenantMemberRole string

+ const TenantMemberRoleADMIN

+ const TenantMemberRoleMEMBER

+ const TenantMemberRoleOWNER

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

+ type TenantResourceLimit struct

+ AlarmValue pgtype.Int4

+ CreatedAt pgtype.Timestamp

+ CustomValueMeter bool

+ ID pgtype.UUID

+ LastRefill pgtype.Timestamp

+ LimitValue int32

+ Resource LimitResource

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ Value int32

+ Window pgtype.Text

+ type TenantResourceLimitAlert struct

+ AlertType TenantResourceLimitAlertType

+ CreatedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Limit int32

+ Resource LimitResource

+ ResourceLimitId pgtype.UUID

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ Value int32

+ type TenantResourceLimitAlertType string

+ const TenantResourceLimitAlertTypeAlarm

+ const TenantResourceLimitAlertTypeExhausted

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

+ type TenantVcsProvider struct

+ Config []byte

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ VcsProvider VcsProvider

+ type TenantWorkerPartition struct

+ CreatedAt pgtype.Timestamp

+ ID string

+ LastHeartbeat pgtype.Timestamp

+ Name pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ type Ticker struct

+ CreatedAt pgtype.Timestamp

+ ID pgtype.UUID

+ IsActive bool

+ LastHeartbeatAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ type TimeoutQueueItem struct

+ ID int64

+ IsQueued bool

+ RetryCount int32

+ StepRunId pgtype.UUID

+ TenantId pgtype.UUID

+ TimeoutAt pgtype.Timestamp

+ type UpdateDispatcherParams struct

+ ID pgtype.UUID

+ LastHeartbeatAt pgtype.Timestamp

+ type UpdateGetGroupKeyRunParams struct

+ CancelledAt pgtype.Timestamp

+ CancelledReason pgtype.Text

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Input []byte

+ Output pgtype.Text

+ RequeueAfter pgtype.Timestamp

+ ScheduleTimeoutAt pgtype.Timestamp

+ StartedAt pgtype.Timestamp

+ Status NullStepRunStatus

+ Tenantid pgtype.UUID

+ type UpdateJobRunLookupDataWithStepRunParams struct

+ Jsondata []byte

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type UpdateJobRunStatusParams struct

+ ID pgtype.UUID

+ Status JobRunStatus

+ Tenantid pgtype.UUID

+ type UpdateManyWorkflowRunParams struct

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ Ids []pgtype.UUID

+ StartedAt pgtype.Timestamp

+ Status NullWorkflowRunStatus

+ Tenantid pgtype.UUID

+ type UpdateScheduledWorkflowParams struct

+ Scheduleid pgtype.UUID

+ Triggerat pgtype.Timestamp

+ type UpdateStepRunInputSchemaParams struct

+ InputSchema []byte

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type UpdateStepRunOverridesDataParams struct

+ Callerfile string

+ Fieldpath []string

+ Jsondata []byte

+ Overrideskey []string

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type UpdateStepRunUnsetWorkerIdParams struct

+ Steprunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type UpdateStepRunUnsetWorkerIdRow struct

+ RetryCount int32

+ WorkerId pgtype.UUID

+ type UpdateStepRunsToAssignedParams struct

+ Steprunids []pgtype.UUID

+ Stepruntimeouts []string

+ Tenantid pgtype.UUID

+ Workerids []pgtype.UUID

+ type UpdateStepRunsToAssignedRow struct

+ StepRunId pgtype.UUID

+ WorkerId pgtype.UUID

+ type UpdateTenantAlertGroupParams struct

+ Emails string

+ ID pgtype.UUID

+ type UpdateTenantAlertingSettingsParams struct

+ LastAlertedAt pgtype.Timestamp

+ TenantId pgtype.UUID

+ type UpdateTenantInviteParams struct

+ ID pgtype.UUID

+ Role NullTenantMemberRole

+ Status NullInviteLinkStatus

+ type UpdateTenantMemberParams struct

+ ID pgtype.UUID

+ Role NullTenantMemberRole

+ type UpdateTenantParams struct

+ AlertMemberEmails pgtype.Bool

+ AnalyticsOptOut pgtype.Bool

+ ID pgtype.UUID

+ Name pgtype.Text

+ UiVersion NullTenantMajorUIVersion

+ Version NullTenantMajorEngineVersion

+ type UpdateTickerParams struct

+ ID pgtype.UUID

+ LastHeartbeatAt pgtype.Timestamp

+ type UpdateUserParams struct

+ EmailVerified pgtype.Bool

+ ID pgtype.UUID

+ Name pgtype.Text

+ type UpdateUserPasswordParams struct

+ Hash string

+ Userid pgtype.UUID

+ type UpdateUserSessionParams struct

+ Data []byte

+ ID pgtype.UUID

+ UserId pgtype.UUID

+ type UpdateWebhookWorkerTokenParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ TokenId pgtype.UUID

+ TokenValue pgtype.Text

+ type UpdateWorkerActiveStatusParams struct

+ ID pgtype.UUID

+ Isactive bool

+ LastListenerEstablished pgtype.Timestamp

+ type UpdateWorkerHeartbeatParams struct

+ ID pgtype.UUID

+ LastHeartbeatAt pgtype.Timestamp

+ type UpdateWorkerParams struct

+ DispatcherId pgtype.UUID

+ ID pgtype.UUID

+ IsActive pgtype.Bool

+ IsPaused pgtype.Bool

+ LastHeartbeatAt pgtype.Timestamp

+ MaxRuns pgtype.Int4

+ type UpdateWorkersByWebhookIdParams struct

+ Isactive bool

+ Tenantid pgtype.UUID

+ Webhookid pgtype.UUID

+ type UpdateWorkflowParams struct

+ ID pgtype.UUID

+ IsPaused pgtype.Bool

+ type UpdateWorkflowRunGroupKeyFromExprParams struct

+ ConcurrencyGroupId pgtype.Text

+ Error pgtype.Text

+ Workflowrunid pgtype.UUID

+ type UpdateWorkflowRunGroupKeyFromRunParams struct

+ Groupkeyrunid pgtype.UUID

+ Tenantid pgtype.UUID

+ type UpdateWorkflowRunParams struct

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ StartedAt pgtype.Timestamp

+ Status NullWorkflowRunStatus

+ Tenantid pgtype.UUID

+ type UpdateWorkflowRunStickyStateParams struct

+ DesiredWorkerId pgtype.UUID

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ type UpsertActionParams struct

+ Action string

+ Tenantid pgtype.UUID

+ type UpsertDesiredWorkerLabelParams struct

+ Comparator NullWorkerLabelComparator

+ IntValue pgtype.Int4

+ Key string

+ Required pgtype.Bool

+ Stepid pgtype.UUID

+ StrValue pgtype.Text

+ Weight pgtype.Int4

+ type UpsertJobRunLookupDataParams struct

+ Fieldpath []string

+ Jobrunid pgtype.UUID

+ Jsondata []byte

+ Tenantid pgtype.UUID

+ type UpsertMessageQueueParams struct

+ Autodeleted bool

+ Durable bool

+ Exclusive bool

+ ExclusiveConsumerId pgtype.UUID

+ Name string

+ type UpsertQueueParams struct

+ Name string

+ Tenantid pgtype.UUID

+ type UpsertRateLimitParams struct

+ Key string

+ Limit int32

+ Tenantid pgtype.UUID

+ Window pgtype.Text

+ type UpsertRateLimitsBulkParams struct

+ Keys []string

+ Limitvalues []int32

+ Tenantid pgtype.UUID

+ Windows []string

+ type UpsertServiceParams struct

+ Name string

+ Tenantid pgtype.UUID

+ type UpsertSlackWebhookParams struct

+ Channelid string

+ Channelname string

+ Teamid string

+ Teamname string

+ Tenantid pgtype.UUID

+ Webhookurl []byte

+ type UpsertTenantAlertingSettingsParams struct

+ EnableExpiringTokenAlerts pgtype.Bool

+ EnableTenantResourceLimitAlerts pgtype.Bool

+ EnableWorkflowRunFailureAlerts pgtype.Bool

+ MaxFrequency pgtype.Text

+ Tenantid pgtype.UUID

+ type UpsertTenantResourceLimitParams struct

+ AlarmValue pgtype.Int4

+ CustomValueMeter pgtype.Bool

+ LimitValue pgtype.Int4

+ Resource NullLimitResource

+ Tenantid pgtype.UUID

+ Window pgtype.Text

+ type UpsertUserOAuthParams struct

+ Accesstoken []byte

+ ExpiresAt pgtype.Timestamp

+ Provider string

+ Provideruserid string

+ RefreshToken []byte

+ Userid pgtype.UUID

+ type UpsertWorkerLabelParams struct

+ IntValue pgtype.Int4

+ Key string

+ StrValue pgtype.Text

+ Workerid pgtype.UUID

+ type UpsertWorkflowTagParams struct

+ ID pgtype.UUID

+ TagColor pgtype.Text

+ Tagname string

+ Tenantid pgtype.UUID

+ type User struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ Email string

+ EmailVerified bool

+ ID pgtype.UUID

+ Name pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ type UserOAuth struct

+ AccessToken []byte

+ CreatedAt pgtype.Timestamp

+ ExpiresAt pgtype.Timestamp

+ ID pgtype.UUID

+ Provider string

+ ProviderUserId string

+ RefreshToken []byte

+ UpdatedAt pgtype.Timestamp

+ UserId pgtype.UUID

+ type UserPassword struct

+ Hash string

+ UserId pgtype.UUID

+ type UserSession struct

+ CreatedAt pgtype.Timestamp

+ Data []byte

+ ExpiresAt pgtype.Timestamp

+ ID pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ UserId pgtype.UUID

+ type VcsProvider string

+ const VcsProviderGITHUB

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

+ type VerifiedStepRunTenantIdsParams struct

+ Steprunids []pgtype.UUID

+ Tenantids []pgtype.UUID

+ type WebhookWorker struct

+ CreatedAt pgtype.Timestamp

+ Deleted bool

+ ID pgtype.UUID

+ Name string

+ Secret string

+ TenantId pgtype.UUID

+ TokenId pgtype.UUID

+ TokenValue pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ Url string

+ type WebhookWorkerRequest struct

+ CreatedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Method WebhookWorkerRequestMethod

+ StatusCode int32

+ WebhookWorkerId pgtype.UUID

+ type WebhookWorkerRequestMethod string

+ const WebhookWorkerRequestMethodGET

+ const WebhookWorkerRequestMethodPOST

+ const WebhookWorkerRequestMethodPUT

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

+ type WebhookWorkerWorkflow struct

+ ID pgtype.UUID

+ WebhookWorkerId pgtype.UUID

+ WorkflowId pgtype.UUID

+ type Worker struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ DispatcherId pgtype.UUID

+ ID pgtype.UUID

+ IsActive bool

+ IsPaused bool

+ Language NullWorkerSDKS

+ LanguageVersion pgtype.Text

+ LastHeartbeatAt pgtype.Timestamp

+ LastListenerEstablished pgtype.Timestamp

+ MaxRuns int32

+ Name string

+ Os pgtype.Text

+ RuntimeExtra pgtype.Text

+ SdkVersion pgtype.Text

+ TenantId pgtype.UUID

+ Type WorkerType

+ UpdatedAt pgtype.Timestamp

+ WebhookId pgtype.UUID

+ type WorkerAssignEvent struct

+ AssignedStepRuns []byte

+ ID int64

+ WorkerId pgtype.UUID

+ type WorkerLabel struct

+ CreatedAt pgtype.Timestamp

+ ID int64

+ IntValue pgtype.Int4

+ Key string

+ StrValue pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ WorkerId pgtype.UUID

+ type WorkerLabelComparator string

+ const WorkerLabelComparatorEQUAL

+ const WorkerLabelComparatorGREATERTHAN

+ const WorkerLabelComparatorGREATERTHANOREQUAL

+ const WorkerLabelComparatorLESSTHAN

+ const WorkerLabelComparatorLESSTHANOREQUAL

+ const WorkerLabelComparatorNOTEQUAL

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

+ type WorkerSDKS string

+ const WorkerSDKSGO

+ const WorkerSDKSPYTHON

+ const WorkerSDKSTYPESCRIPT

+ const WorkerSDKSUNKNOWN

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

+ type WorkerType string

+ const WorkerTypeMANAGED

+ const WorkerTypeSELFHOSTED

+ const WorkerTypeWEBHOOK

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

+ type Workflow struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ Description pgtype.Text

+ ID pgtype.UUID

+ IsPaused pgtype.Bool

+ Name string

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type WorkflowConcurrency struct

+ ConcurrencyGroupExpression pgtype.Text

+ CreatedAt pgtype.Timestamp

+ GetConcurrencyGroupId pgtype.UUID

+ ID pgtype.UUID

+ LimitStrategy ConcurrencyLimitStrategy

+ MaxRuns int32

+ UpdatedAt pgtype.Timestamp

+ WorkflowVersionId pgtype.UUID

+ type WorkflowKind string

+ const WorkflowKindDAG

+ const WorkflowKindDURABLE

+ const WorkflowKindFUNCTION

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

+ type WorkflowRun struct

+ AdditionalMetadata []byte

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ ConcurrencyGroupId pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ DisplayName pgtype.Text

+ Duration pgtype.Int8

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ InsertOrder pgtype.Int4

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

+ Priority pgtype.Int4

+ StartedAt pgtype.Timestamp

+ Status WorkflowRunStatus

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ WorkflowVersionId pgtype.UUID

+ type WorkflowRunDedupe struct

+ CreatedAt pgtype.Timestamp

+ ID int64

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ Value string

+ WorkflowId pgtype.UUID

+ WorkflowRunId pgtype.UUID

+ type WorkflowRunStatus string

+ const WorkflowRunStatusBACKOFF

+ const WorkflowRunStatusCANCELLED

+ const WorkflowRunStatusCANCELLING

+ const WorkflowRunStatusFAILED

+ const WorkflowRunStatusPENDING

+ const WorkflowRunStatusQUEUED

+ const WorkflowRunStatusRUNNING

+ const WorkflowRunStatusSUCCEEDED

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

+ type WorkflowRunStickyState struct

+ CreatedAt pgtype.Timestamp

+ DesiredWorkerId pgtype.UUID

+ ID int64

+ Strategy StickyStrategy

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ WorkflowRunId pgtype.UUID

+ type WorkflowRunTriggeredBy struct

+ CreatedAt pgtype.Timestamp

+ CronName pgtype.Text

+ CronParentId pgtype.UUID

+ CronSchedule pgtype.Text

+ DeletedAt pgtype.Timestamp

+ EventId pgtype.UUID

+ ID pgtype.UUID

+ Input []byte

+ ParentId pgtype.UUID

+ ScheduledId pgtype.UUID

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type WorkflowRunsMetricsCountParams struct

+ AdditionalMetadata []byte

+ CreatedAfter pgtype.Timestamp

+ CreatedBefore pgtype.Timestamp

+ EventId pgtype.UUID

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

+ Tenantid pgtype.UUID

+ WorkflowId pgtype.UUID

+ type WorkflowRunsMetricsCountRow struct

+ CANCELLED int64

+ FAILED int64

+ PENDING int64

+ QUEUED int64

+ RUNNING int64

+ SUCCEEDED int64

+ type WorkflowTag struct

+ Color string

+ CreatedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Name string

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type WorkflowToWorkflowTag struct

+ A pgtype.UUID

+ B pgtype.UUID

+ type WorkflowTriggerCronRef struct

+ AdditionalMetadata []byte

+ CreatedAt pgtype.Timestamp

+ Cron string

+ DeletedAt pgtype.Timestamp

+ Enabled bool

+ ID pgtype.UUID

+ Input []byte

+ Method WorkflowTriggerCronRefMethods

+ Name pgtype.Text

+ ParentId pgtype.UUID

+ Priority int32

+ TickerId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ type WorkflowTriggerCronRefMethods string

+ const WorkflowTriggerCronRefMethodsAPI

+ const WorkflowTriggerCronRefMethodsDEFAULT

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

+ type WorkflowTriggerEventRef struct

+ EventKey string

+ ParentId pgtype.UUID

+ type WorkflowTriggerScheduledRef struct

+ AdditionalMetadata []byte

+ ChildIndex pgtype.Int4

+ ChildKey pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Input []byte

+ Method WorkflowTriggerScheduledRefMethods

+ ParentId pgtype.UUID

+ ParentStepRunId pgtype.UUID

+ ParentWorkflowRunId pgtype.UUID

+ Priority int32

+ TickerId pgtype.UUID

+ TriggerAt pgtype.Timestamp

+ UpdatedAt pgtype.Timestamp

+ type WorkflowTriggerScheduledRefMethods string

+ const WorkflowTriggerScheduledRefMethodsAPI

+ const WorkflowTriggerScheduledRefMethodsDEFAULT

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

+ type WorkflowTriggers struct

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ WorkflowVersionId pgtype.UUID

+ type WorkflowVersion struct

+ Checksum string

+ CreateWorkflowVersionOpts []byte

+ CreatedAt pgtype.Timestamp

+ DefaultPriority pgtype.Int4

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Kind WorkflowKind

+ OnFailureJobId pgtype.UUID

+ Order int64

+ ScheduleTimeout string

+ Sticky NullStickyStrategy

+ UpdatedAt pgtype.Timestamp

+ Version pgtype.Text

+ WorkflowId pgtype.UUID

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL