sqlcv1

package

Go to main page

Versions in this module

v0

v0.78.14

Feb 6, 2026

v0.78.13

Feb 6, 2026

v0.78.12

Feb 5, 2026

v0.78.11

Feb 5, 2026

v0.78.10

Feb 5, 2026

v0.78.9

Feb 4, 2026

v0.78.8

Feb 4, 2026

v0.78.7

Feb 4, 2026

Changes in this version

type CreateWebhookParams

+ ScopeExpression pgtype.Text

+ StaticPayload []byte

type UpdateWebhookExpressionParams

+ EventKeyExpression pgtype.Text

+ ScopeExpression pgtype.Text

+ StaticPayload []byte

type V1IncomingWebhook

+ ScopeExpression pgtype.Text

+ StaticPayload []byte

v0.78.6

Feb 4, 2026

v0.78.5

Feb 4, 2026

v0.78.4

Feb 4, 2026

v0.78.3

Feb 3, 2026

v0.78.2

Feb 3, 2026

v0.78.1

Feb 3, 2026

v0.78.0

Feb 3, 2026

Changes in this version

+ type BulkCreateEventsOLAPParams struct

+ Additionalmetadatas [][]byte

+ Externalids []uuid.UUID

+ Keys []string

+ Payloads [][]byte

+ Scopes []pgtype.Text

+ Seenats []pgtype.Timestamptz

+ Tenantids []uuid.UUID

+ TriggeringWebhookNames []pgtype.Text

type CountCronWorkflowsParams

+ CronTriggerId *uuid.UUID

+ WorkflowId *uuid.UUID

type CountScheduledWorkflowsParams

+ ParentStepRunId *uuid.UUID

+ ParentWorkflowRunId *uuid.UUID

+ ScheduleId *uuid.UUID

+ WorkflowId *uuid.UUID

+ type CreateEventToRunsParams struct

+ Eventids []int64

+ Eventseenats []pgtype.Timestamptz

+ Filterids []uuid.UUID

+ Runexternalids []uuid.UUID

type ListCronWorkflowsParams

+ CronTriggerId *uuid.UUID

+ WorkflowId *uuid.UUID

+ type ListQueueItemsForTasksParams struct

+ Retrycounts []int32

+ Taskids []int64

+ Taskinsertedats []pgtype.Timestamptz

+ Tenantid uuid.UUID

type ListScheduledWorkflowsParams

+ ParentStepRunId *uuid.UUID

+ ParentWorkflowRunId *uuid.UUID

+ ScheduleId *uuid.UUID

+ WorkflowId *uuid.UUID

type Queries

+ func (q *Queries) BulkCreateEventsOLAP(ctx context.Context, db DBTX, arg BulkCreateEventsOLAPParams) ([]*V1EventsOlap, error)

+ func (q *Queries) CreateEventToRuns(ctx context.Context, db DBTX, arg CreateEventToRunsParams) ([]*V1EventToRun, error)

+ func (q *Queries) ListQueueItemsForTasks(ctx context.Context, db DBTX, arg ListQueueItemsForTasksParams) ([]*V1QueueItem, error)

+ func (q *Queries) ReactivateInactiveQueuesWithItems(ctx context.Context, db DBTX) (pgconn.CommandTag, error)

+ type V1Event struct

+ AdditionalMetadata []byte

+ ExternalID uuid.UUID

+ ID int64

+ Key string

+ Scope pgtype.Text

+ SeenAt pgtype.Timestamptz

+ TenantID uuid.UUID

+ TriggeringWebhookName pgtype.Text

+ type V1EventLookupTable struct

+ EventID int64

+ EventSeenAt pgtype.Timestamptz

+ ExternalID uuid.UUID

+ TenantID uuid.UUID

+ type V1EventToRun struct

+ EventID int64

+ EventSeenAt pgtype.Timestamptz

+ FilterID *uuid.UUID

+ RunExternalID uuid.UUID

type V1PayloadType

+ const V1PayloadTypeUSEREVENTINPUT

v0.77.38-alpha.1

Jan 30, 2026

v0.77.37

Jan 30, 2026

Changes in this version

type ListLogLinesParams

+ Attempt pgtype.Int4

v0.77.36

Jan 29, 2026

v0.77.35

Jan 29, 2026

v0.77.34

Jan 29, 2026

v0.77.33

Jan 29, 2026

Changes in this version

type CreateWorkflowVersionParams

+ InputJsonSchema []byte

type WorkflowVersion

+ InputJsonSchema []byte

v0.77.32

Jan 28, 2026

v0.77.31

Jan 27, 2026

v0.77.30

Jan 27, 2026

v0.77.29

Jan 27, 2026

v0.77.28

Jan 27, 2026

Changes in this version

type GetTaskPointMetricsRow

+ MinuteBucket pgtype.Timestamptz

v0.77.27

Jan 27, 2026

v0.77.26

Jan 27, 2026

v0.77.25

Jan 26, 2026

v0.77.24

Jan 26, 2026

Changes in this version

type GetTaskPointMetricsRow

+ Bucket pgtype.Timestamptz

v0.77.23

Jan 26, 2026

v0.77.22

Jan 26, 2026

Changes in this version

+ type GetTenantUsageDataRow struct

+ TenantMembersCount int64

+ UsedWorkerSlotsCount int32

+ WorkerCount int64

type ListLogLinesParams

+ Orderbydirection string

type Queries

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

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

v0.77.21

Jan 23, 2026

v0.77.20

Jan 23, 2026

v0.77.19

Jan 22, 2026

v0.77.18

Jan 22, 2026

v0.77.17

Jan 22, 2026

v0.77.17-migration.9

Jan 24, 2026

v0.77.17-migration.8

Jan 24, 2026

v0.77.17-migration.7

Jan 24, 2026

v0.77.17-migration.6

Jan 24, 2026

v0.77.17-migration.5

Jan 23, 2026

v0.77.17-migration.4

Jan 22, 2026

v0.77.17-migration.3

Jan 22, 2026

v0.77.17-migration.2

Jan 22, 2026

v0.77.17-migration.1

Jan 22, 2026

v0.77.16

Jan 21, 2026

v0.77.15

Jan 21, 2026

v0.77.14

Jan 21, 2026

v0.77.13

Jan 21, 2026

v0.77.12-alpha.1

Jan 21, 2026

v0.77.11

Jan 21, 2026

Changes in this version

type ListLogLinesParams

+ Levels []V1LogLineLevel

v0.77.10

Jan 21, 2026

v0.77.9

Jan 21, 2026

v0.77.8

Jan 21, 2026

v0.77.7

Jan 21, 2026

v0.77.6

Jan 21, 2026

v0.77.5

Jan 20, 2026

v0.77.4

Jan 20, 2026

v0.77.3

Jan 20, 2026

v0.77.2-alpha.5

Jan 20, 2026

v0.77.2-alpha.4

Jan 20, 2026

v0.77.2-alpha.3

Jan 20, 2026

v0.77.2-alpha.2

Jan 20, 2026

v0.77.2-alpha.1

Jan 19, 2026

v0.77.1

Jan 19, 2026

v0.77.0

Jan 19, 2026

v0.76.0-alpha.4

Jan 15, 2026

v0.76.0-alpha.3

Jan 15, 2026

v0.76.0-alpha.2

Jan 14, 2026

v0.76.0-alpha.1

Jan 14, 2026

v0.76.0-alpha.0

Jan 14, 2026

v0.75.4

Jan 18, 2026

v0.75.3

Jan 16, 2026

v0.75.2

Jan 16, 2026

v0.75.1

Jan 15, 2026

v0.75.0

Jan 13, 2026

v0.74.14

Jan 12, 2026

Changes in this version

type GetWorkflowVersionByIdRow

+ ConcurrencyExpression pgtype.Text

+ type ListConcurrencyStrategiesByWorkflowVersionIdParams struct

+ Tenantid pgtype.UUID

+ Workflowid pgtype.UUID

+ Workflowversionid pgtype.UUID

+ type ListConcurrencyStrategiesByWorkflowVersionIdRow struct

+ Expression string

+ ID int64

+ IsActive bool

+ MaxConcurrency int32

+ ParentStrategyID pgtype.Int8

+ StepID pgtype.UUID

+ StepReadableID pgtype.Text

+ Strategy V1ConcurrencyStrategy

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

+ WorkflowVersionID pgtype.UUID

type Queries

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

v0.74.13

Jan 12, 2026

v0.74.12

Jan 11, 2026

v0.74.11

Jan 10, 2026

v0.74.10

Jan 9, 2026

v0.74.9

Jan 8, 2026

Changes in this version

type FlattenExternalIdsRow

+ StepReadableID string

+ type ListTaskRunningStatusesParams struct

+ Taskids []int64

+ Taskinsertedats []pgtype.Timestamptz

+ Taskretrycounts []int32

+ Tenantid pgtype.UUID

+ type ListTaskRunningStatusesRow struct

+ ExternalID pgtype.UUID

+ IsRunning bool

type Queries

+ func (q *Queries) ListTaskRunningStatuses(ctx context.Context, db DBTX, arg ListTaskRunningStatusesParams) ([]*ListTaskRunningStatusesRow, error)

v0.74.8

Jan 8, 2026

v0.74.7

Jan 7, 2026

v0.74.6

Jan 7, 2026

Changes in this version

type CountWorkflowRunsParams

+ ParentTaskExternalId pgtype.UUID

type CutoverOLAPPayloadToInsert

+ Location V1PayloadLocationOlap

type CutoverPayloadToInsert

+ Location V1PayloadLocation

v0.74.5

Jan 6, 2026

Changes in this version

+ type NullTenantMajorUIVersion struct

+ TenantMajorUIVersion TenantMajorUIVersion

+ Valid bool

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

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

type Tenant

+ UiVersion TenantMajorUIVersion

+ type TenantMajorUIVersion string

+ const TenantMajorUIVersionV0

+ const TenantMajorUIVersionV1

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

v0.74.4

Jan 6, 2026

v0.74.3

Jan 6, 2026

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

+ Key pgtype.Date

+ Lastid int64

+ Lastinsertedat pgtype.Timestamptz

+ Lasttenantid pgtype.UUID

+ Lasttype V1PayloadType

+ Leaseexpiresat pgtype.Timestamptz

+ Leaseprocessid pgtype.UUID

+ type AcquireOrExtendLeasesParams struct

+ Existingleaseids []int64

+ Kind LeaseKind

+ LeaseDuration pgtype.Interval

+ Resourceids []string

+ Tenantid pgtype.UUID

+ type AcquireOrExtendOLAPCutoverJobLeaseParams struct

+ Key pgtype.Date

+ Lastexternalid pgtype.UUID

+ Lastinsertedat pgtype.Timestamptz

+ Lasttenantid pgtype.UUID

+ Leaseexpiresat pgtype.Timestamptz

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

+ ExpiresAt pgtype.Timestamp

+ Payload []byte

+ QueueId pgtype.Text

+ ReadAfter pgtype.Timestamp

+ type BulkCreateEventTriggersParams struct

+ EventID int64

+ EventSeenAt pgtype.Timestamptz

+ FilterID pgtype.UUID

+ RunID int64

+ RunInsertedAt pgtype.Timestamptz

+ type BulkCreateEventsParams struct

+ Additionalmetadatas [][]byte

+ Externalids []pgtype.UUID

+ Keys []string

+ Payloads [][]byte

+ Scopes []pgtype.Text

+ Seenats []pgtype.Timestamptz

+ Tenantids []pgtype.UUID

+ TriggeringWebhookNames []pgtype.Text

+ type BulkDeleteScheduledWorkflowsParams struct

+ Ids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type BulkInsertDeclarativeFiltersParams struct

+ Expressions []string

+ Payloads [][]byte

+ Scopes []string

+ Tenantid pgtype.UUID

+ Workflowid pgtype.UUID

+ type BulkUpdateRateLimitsParams struct

+ Keys []string

+ Tenantid pgtype.UUID

+ Units []int32

+ type BulkUpdateScheduledWorkflowsParams struct

+ Ids []pgtype.UUID

+ Tenantid pgtype.UUID

+ Triggerats []pgtype.Timestamp

+ type CanCreateWebhookParams struct

+ Tenantid pgtype.UUID

+ Webhooklimit int32

+ type CheckBloatRow struct

+ DeadPct pgtype.Numeric

+ DeadTuples pgtype.Int8

+ LastAnalyze pgtype.Timestamptz

+ LastAutovacuum pgtype.Timestamptz

+ LastVacuum pgtype.Timestamptz

+ LiveTuples pgtype.Int8

+ Schemaname pgtype.Text

+ TableSize string

+ Tablename pgtype.Text

+ TotalSize string

+ type CheckLastAutovacuumForPartitionedTablesCoreDBRow struct

+ LastAutovacuum pgtype.Timestamptz

+ Schemaname pgtype.Text

+ SecondsSinceLastAutovacuum pgtype.Numeric

+ Tablename pgtype.Text

+ type CheckLastAutovacuumForPartitionedTablesRow struct

+ LastAutovacuum pgtype.Timestamptz

+ Schemaname pgtype.Text

+ SecondsSinceLastAutovacuum pgtype.Numeric

+ Tablename pgtype.Text

+ type CheckLongRunningQueriesRow struct

+ ApplicationName pgtype.Text

+ ClientAddr *netip.Addr

+ Duration int32

+ Pid pgtype.Int4

+ Query pgtype.Text

+ State pgtype.Text

+ Usename pgtype.Text

+ type CheckQueryCachesRow struct

+ CacheHitRatioPct float64

+ HeapBlksHit pgtype.Int8

+ HeapBlksRead pgtype.Int8

+ Schemaname pgtype.Text

+ Tablename pgtype.Text

+ TotalReads int32

+ TotalSize string

+ type CheckStrategyActiveParams struct

+ Strategyid int64

+ Tenantid pgtype.UUID

+ Workflowid pgtype.UUID

+ Workflowversionid pgtype.UUID

+ type ClaimIdempotencyKeysParams struct

+ Claimedbyexternalids []pgtype.UUID

+ Keys []string

+ Tenantid pgtype.UUID

+ type ClaimIdempotencyKeysRow struct

+ ClaimedByExternalID pgtype.UUID

+ ExpiresAt pgtype.Timestamptz

+ Key string

+ WasSuccessfullyClaimed bool

+ type CleanupMessageQueueItemsParams struct

+ Maxid int64

+ Minid int64

+ type CleanupWorkflowConcurrencySlotsAfterInsertParams struct

+ Concurrencyparentstrategyids []int64

+ Workflowrunids []pgtype.UUID

+ Workflowversionids []pgtype.UUID

+ type ComputeOLAPPayloadBatchSizeParams struct

+ Batchsize int32

+ Lastexternalid pgtype.UUID

+ Lastinsertedat pgtype.Timestamptz

+ Lasttenantid pgtype.UUID

+ Partitiondate pgtype.Date

+ type ComputePayloadBatchSizeParams struct

+ Batchsize int32

+ Lastid int64

+ Lastinsertedat pgtype.Timestamptz

+ Lasttenantid pgtype.UUID

+ Lasttype V1PayloadType

+ Partitiondate pgtype.Date

+ 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

+ Scopes []string

+ Since pgtype.Timestamptz

+ Statuses []string

+ Tenantid pgtype.UUID

+ Until pgtype.Timestamptz

+ WorkflowIds []pgtype.UUID

+ type CountFiltersParams struct

+ Scopes []string

+ Tenantid pgtype.UUID

+ WorkflowIds []pgtype.UUID

+ type CountRateLimitsParams struct

+ Orderby interface{}

+ Search pgtype.Text

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

+ Keys []string

+ Since pgtype.Timestamptz

+ Statuses []string

+ Tenantid pgtype.UUID

+ TriggeringEventExternalId pgtype.UUID

+ Until pgtype.Timestamptz

+ Values []string

+ WorkerId pgtype.UUID

+ WorkflowIds []pgtype.UUID

+ type CountWorkflowRunsParams struct

+ Keys []string

+ Since pgtype.Timestamptz

+ Statuses []string

+ Tenantid pgtype.UUID

+ TriggeringEventExternalId pgtype.UUID

+ Until pgtype.Timestamptz

+ Values []string

+ WorkflowIds []pgtype.UUID

+ type CountWorkflowsParams struct

+ EventKey pgtype.Text

+ Search pgtype.Text

+ TenantId pgtype.UUID

+ type CreateAPITokenParams struct

+ Expiresat pgtype.Timestamp

+ ID pgtype.UUID

+ Internal pgtype.Bool

+ Name pgtype.Text

+ TenantId pgtype.UUID

+ type CreateDAGDataParams struct

+ AdditionalMetadata []byte

+ DagID int64

+ DagInsertedAt pgtype.Timestamptz

+ Input []byte

+ type CreateDAGsOLAPParams struct

+ AdditionalMetadata []byte

+ DisplayName string

+ ExternalID pgtype.UUID

+ ID int64

+ Input []byte

+ InsertedAt pgtype.Timestamptz

+ ParentTaskExternalID pgtype.UUID

+ TenantID pgtype.UUID

+ TotalTasks int32

+ WorkflowID pgtype.UUID

+ WorkflowVersionID pgtype.UUID

+ type CreateDAGsParams struct

+ Displaynames []string

+ Externalids []pgtype.UUID

+ Parenttaskexternalids []pgtype.UUID

+ Tenantids []pgtype.UUID

+ Workflowids []pgtype.UUID

+ Workflowversionids []pgtype.UUID

+ type CreateDurableSleepParams struct

+ SleepDurations []string

+ TenantID pgtype.UUID

+ type CreateFilterParams struct

+ Expression string

+ Payload []byte

+ Scope string

+ Tenantid pgtype.UUID

+ Workflowid pgtype.UUID

+ type CreateIdempotencyKeyParams struct

+ Expiresat pgtype.Timestamptz

+ Key string

+ Tenantid pgtype.UUID

+ type CreateIncomingWebhookValidationFailureLogsParams struct

+ Errors []string

+ Incomingwebhooknames []string

+ Tenantid pgtype.UUID

+ type CreateJobParams struct

+ CreatedAt pgtype.Timestamp

+ Deletedat pgtype.Timestamp

+ Description string

+ ID pgtype.UUID

+ Kind NullJobKind

+ Name string

+ Tenantid pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ Workflowversionid pgtype.UUID

+ type CreateMatchConditionsParams struct

+ Action V1MatchConditionAction

+ Data []byte

+ EventKey string

+ EventResourceHint pgtype.Text

+ EventType V1EventType

+ Expression pgtype.Text

+ IsSatisfied bool

+ OrGroupID pgtype.UUID

+ ReadableDataKey string

+ TenantID pgtype.UUID

+ V1MatchID int64

+ type CreateMatchesForDAGTriggersParams struct

+ ExistingDatas [][]byte

+ Kinds []string

+ Tenantids []pgtype.UUID

+ TriggerChildIndex []pgtype.Int8

+ TriggerChildKey []pgtype.Text

+ TriggerParentTaskExternalIds []pgtype.UUID

+ TriggerParentTaskIds []pgtype.Int8

+ TriggerParentTaskInsertedAt []pgtype.Timestamptz

+ TriggerPriorities []pgtype.Int4

+ Triggerdagids []int64

+ Triggerdaginsertedats []pgtype.Timestamptz

+ Triggerexistingtaskids []pgtype.Int8

+ Triggerexistingtaskinsertedat []pgtype.Timestamptz

+ Triggerexternalids []pgtype.UUID

+ Triggerstepids []pgtype.UUID

+ Triggerstepindex []int64

+ Triggerworkflowrunids []pgtype.UUID

+ type CreateMatchesForSignalTriggersParams struct

+ Kinds []string

+ Signalexternalids []pgtype.UUID

+ Signalkeys []string

+ Signaltaskids []int64

+ Signaltaskinsertedats []pgtype.Timestamptz

+ Tenantids []pgtype.UUID

+ type CreateOLAPPartitionsParams struct

+ Date pgtype.Date

+ Partitions int32

+ type CreateOLAPPayloadRangeChunksParams struct

+ Chunksize int32

+ Lastexternalid pgtype.UUID

+ Lastinsertedat pgtype.Timestamptz

+ Lasttenantid pgtype.UUID

+ Partitiondate pgtype.Date

+ Windowsize int32

+ type CreateOLAPPayloadRangeChunksRow struct

+ LowerExternalID pgtype.UUID

+ LowerInsertedAt pgtype.Timestamptz

+ LowerTenantID pgtype.UUID

+ UpperExternalID pgtype.UUID

+ UpperInsertedAt pgtype.Timestamptz

+ UpperTenantID pgtype.UUID

+ type CreatePayloadRangeChunksParams struct

+ Chunksize int32

+ Lastid int64

+ Lastinsertedat pgtype.Timestamptz

+ Lasttenantid pgtype.UUID

+ Lasttype V1PayloadType

+ Partitiondate pgtype.Date

+ Windowsize int32

+ type CreatePayloadRangeChunksRow struct

+ LowerID int64

+ LowerInsertedAt pgtype.Timestamptz

+ LowerTenantID pgtype.UUID

+ LowerType V1PayloadType

+ UpperID int64

+ UpperInsertedAt pgtype.Timestamptz

+ UpperTenantID pgtype.UUID

+ UpperType V1PayloadType

+ type CreateSNSIntegrationParams struct

+ Tenantid pgtype.UUID

+ Topicarn string

+ type CreateStepConcurrencyParams struct

+ Expression string

+ Maxconcurrency int32

+ Stepid pgtype.UUID

+ Strategy V1ConcurrencyStrategy

+ Tenantid pgtype.UUID

+ Workflowid pgtype.UUID

+ Workflowversionid pgtype.UUID

+ type CreateStepExpressionsParams struct

+ Expressions []string

+ Keys []string

+ Kinds []string

+ Stepid pgtype.UUID

+ type CreateStepMatchConditionParams struct

+ Action V1MatchConditionAction

+ EventKey pgtype.Text

+ Expression pgtype.Text

+ Kind V1StepMatchConditionKind

+ Orgroupid pgtype.UUID

+ ParentReadableId pgtype.Text

+ Readabledatakey string

+ SleepDuration pgtype.Text

+ Stepid pgtype.UUID

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

+ AdditionalEventData pgtype.Text

+ AdditionalEventMessage pgtype.Text

+ ErrorMessage pgtype.Text

+ EventTimestamp pgtype.Timestamptz

+ EventType V1EventTypeOlap

+ ExternalID pgtype.UUID

+ Output []byte

+ ReadableStatus V1ReadableStatusOlap

+ RetryCount int32

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ TenantID pgtype.UUID

+ WorkerID pgtype.UUID

+ WorkflowID pgtype.UUID

+ type CreateTaskEventsOLAPTmpParams struct

+ EventType V1EventTypeOlap

+ ReadableStatus V1ReadableStatusOlap

+ RetryCount int32

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ TenantID pgtype.UUID

+ WorkerID pgtype.UUID

+ type CreateTaskEventsParams struct

+ Datas [][]byte

+ Eventkeys []pgtype.Text

+ Eventtypes []string

+ Externalids []pgtype.UUID

+ Retrycounts []int32

+ Taskids []int64

+ Taskinsertedats []pgtype.Timestamptz

+ Tenantid pgtype.UUID

+ type CreateTaskExpressionEvalsParams struct

+ Keys []string

+ Kinds []string

+ Taskids []int64

+ Taskinsertedats []pgtype.Timestamptz

+ Valuesint []pgtype.Int4

+ Valuesstr []pgtype.Text

+ type CreateTasksOLAPParams struct

+ ActionID string

+ AdditionalMetadata []byte

+ DagID pgtype.Int8

+ DagInsertedAt pgtype.Timestamptz

+ DesiredWorkerID pgtype.UUID

+ DisplayName string

+ ExternalID pgtype.UUID

+ ID int64

+ Input []byte

+ InsertedAt pgtype.Timestamptz

+ ParentTaskExternalID pgtype.UUID

+ Priority pgtype.Int4

+ Queue string

+ ScheduleTimeout string

+ StepID pgtype.UUID

+ StepTimeout pgtype.Text

+ Sticky V1StickyStrategyOlap

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

+ WorkflowRunID pgtype.UUID

+ WorkflowVersionID pgtype.UUID

+ type CreateTasksParams struct

+ Actionids []string

+ Additionalmetadatas [][]byte

+ ChildIndex []pgtype.Int8

+ ChildKey []pgtype.Text

+ ConcurrencyKeys [][]string

+ ConcurrencyStrategyIds [][]int64

+ Concurrencyparentstrategyids [][]pgtype.Int8

+ Dagids []pgtype.Int8

+ Daginsertedats []pgtype.Timestamptz

+ Desiredworkerids []pgtype.UUID

+ Displaynames []string

+ Externalids []pgtype.UUID

+ InitialStateReasons []pgtype.Text

+ InitialStates []string

+ Inputs [][]byte

+ ParentTaskExternalIds []pgtype.UUID

+ ParentTaskIds []pgtype.Int8

+ ParentTaskInsertedAts []pgtype.Timestamptz

+ Priorities []int32

+ Queues []string

+ RetryBackoffFactor []pgtype.Float8

+ RetryMaxBackoff []pgtype.Int4

+ Retrycounts []int32

+ Scheduletimeouts []string

+ StepIndex []int64

+ Stepids []pgtype.UUID

+ Stepreadableids []string

+ Steptimeouts []string

+ Stickies []string

+ Tenantids []pgtype.UUID

+ WorkflowRunIds []pgtype.UUID

+ WorkflowVersionIds []pgtype.UUID

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

+ Environment NullTenantEnvironment

+ ID pgtype.UUID

+ Name string

+ OnboardingData []byte

+ Slug string

+ Version NullTenantMajorEngineVersion

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

+ AuthApiKeyHeaderName pgtype.Text

+ AuthBasicUsername pgtype.Text

+ AuthHmacAlgorithm NullV1IncomingWebhookHmacAlgorithm

+ AuthHmacEncoding NullV1IncomingWebhookHmacEncoding

+ AuthHmacSignatureHeaderName pgtype.Text

+ Authapikeykey []byte

+ Authbasicpassword []byte

+ Authhmacwebhooksigningsecret []byte

+ Authmethod V1IncomingWebhookAuthType

+ Eventkeyexpression string

+ Name string

+ Sourcename V1IncomingWebhookSourceName

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

+ Expression string

+ Limitstrategy V1ConcurrencyStrategy

+ MaxRuns pgtype.Int4

+ Tenantid pgtype.UUID

+ Workflowid pgtype.UUID

+ Workflowversionid pgtype.UUID

+ type CreateWorkflowConcurrencyV1Row struct

+ ChildStrategyIds []int64

+ ID int64

+ type CreateWorkflowParams struct

+ CreatedAt pgtype.Timestamp

+ Deletedat pgtype.Timestamp

+ Description string

+ ID pgtype.UUID

+ Name string

+ Tenantid pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ 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

+ OldWorkflowVersionId pgtype.UUID

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

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ Workflowversionid pgtype.UUID

+ type CreateWorkflowVersionParams struct

+ Checksum string

+ CreateWorkflowVersionOpts []byte

+ CreatedAt pgtype.Timestamp

+ DefaultPriority pgtype.Int4

+ Deletedat pgtype.Timestamp

+ ID pgtype.UUID

+ Kind NullWorkflowKind

+ Sticky NullStickyStrategy

+ UpdatedAt pgtype.Timestamp

+ Version pgtype.Text

+ Workflowid pgtype.UUID

+ type CutoverOLAPPayloadToInsert struct

+ ExternalID pgtype.UUID

+ ExternalLocationKey string

+ InlineContent []byte

+ InsertedAt pgtype.Timestamptz

+ TenantID pgtype.UUID

+ type CutoverPayloadToInsert struct

+ ExternalID pgtype.UUID

+ ExternalLocationKey string

+ ID int64

+ InlineContent []byte

+ InsertedAt pgtype.Timestamptz

+ TenantID pgtype.UUID

+ Type V1PayloadType

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

+ Activesince pgtype.Timestamptz

+ Tenantid pgtype.UUID

+ type DeleteAPITokenParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ type DeleteExistingDeclarativeFiltersForOverwriteParams struct

+ Tenantid pgtype.UUID

+ Workflowid pgtype.UUID

+ type DeleteFilterParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ type DeleteMatchingSignalEventsParams struct

+ Eventkeys []string

+ Eventtype V1TaskEventType

+ Taskids []int64

+ Taskinsertedats []pgtype.Timestamptz

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

+ Retrycounts []int32

+ Taskids []int64

+ type DeleteTenantAlertGroupParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ type DeleteWebhookParams struct

+ Name string

+ Tenantid pgtype.UUID

+ type DiffOLAPPayloadSourceAndTargetPartitionsRow struct

+ ExternalID pgtype.UUID

+ ExternalLocationKey string

+ InlineContent []byte

+ InsertedAt pgtype.Timestamptz

+ Location V1PayloadLocationOlap

+ TenantID pgtype.UUID

+ UpdatedAt pgtype.Timestamptz

+ type DiffPayloadSourceAndTargetPartitionsRow struct

+ ExternalID pgtype.UUID

+ ExternalLocationKey string

+ ID int64

+ InlineContent []byte

+ InsertedAt pgtype.Timestamptz

+ Location V1PayloadLocation

+ TenantID pgtype.UUID

+ Type V1PayloadType

+ UpdatedAt pgtype.Timestamptz

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

+ Isnonretryables []bool

+ Taskids []int64

+ Taskinsertedats []pgtype.Timestamptz

+ Taskretrycounts []int32

+ Tenantid pgtype.UUID

+ type FailTaskAppFailureRow struct

+ AppRetryCount int32

+ ID int64

+ InsertedAt pgtype.Timestamptz

+ RetryBackoffFactor pgtype.Float8

+ RetryCount int32

+ RetryMaxBackoff pgtype.Int4

+ type FailTaskInternalFailureParams struct

+ Maxinternalretries int32

+ Taskids []int64

+ Taskinsertedats []pgtype.Timestamptz

+ Taskretrycounts []int32

+ Tenantid pgtype.UUID

+ type FailTaskInternalFailureRow struct

+ ID int64

+ InsertedAt pgtype.Timestamptz

+ RetryCount int32

+ type FetchWorkflowRunIdsParams struct

+ Keys []string

+ Listworkflowrunslimit int32

+ Listworkflowrunsoffset int32

+ ParentTaskExternalId pgtype.UUID

+ Since pgtype.Timestamptz

+ Statuses []string

+ Tenantid pgtype.UUID

+ TriggeringEventExternalId pgtype.UUID

+ Until pgtype.Timestamptz

+ Values []string

+ WorkflowIds []pgtype.UUID

+ type FetchWorkflowRunIdsRow struct

+ ExternalID pgtype.UUID

+ ID int64

+ InsertedAt pgtype.Timestamptz

+ Kind V1RunKind

+ type FindMinInsertedAtForDAGStatusUpdatesParams struct

+ Eventlimit int32

+ Partitionnumber int32

+ Tenantids []pgtype.UUID

+ type FindMinInsertedAtForTaskStatusUpdatesParams struct

+ Eventlimit int32

+ Partitionnumber int32

+ Tenantids []pgtype.UUID

+ type FindV1OLAPPayloadPartitionsBeforeDateRow struct

+ PartitionDate pgtype.Date

+ PartitionName string

+ type FindV1PayloadPartitionsBeforeDateRow struct

+ PartitionDate pgtype.Date

+ PartitionName string

+ type FlattenExternalIdsParams struct

+ Externalids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type FlattenExternalIdsRow struct

+ AdditionalMetadata []byte

+ ChildIndex pgtype.Int8

+ ChildKey pgtype.Text

+ DagID pgtype.Int8

+ DagInsertedAt pgtype.Timestamptz

+ ExternalID pgtype.UUID

+ ID int64

+ InsertedAt pgtype.Timestamptz

+ ParentTaskID pgtype.Int8

+ RetryCount int32

+ WorkflowRunExternalID pgtype.UUID

+ WorkflowRunID pgtype.UUID

+ type FlattenTasksByExternalIdsParams struct

+ Externalids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type FlattenTasksByExternalIdsRow struct

+ ExternalID pgtype.UUID

+ ID int64

+ InsertedAt pgtype.Timestamptz

+ RetryCount int32

+ TenantID pgtype.UUID

+ type GetDAGDataParams struct

+ Dagids []int64

+ Daginsertedats []pgtype.Timestamptz

+ type GetDAGDataRow struct

+ AdditionalMetadata []byte

+ DagID int64

+ DagID_2 interface{}

+ DagInsertedAt pgtype.Timestamptz

+ DagInsertedAt_2 interface{}

+ Input []byte

+ type GetDagDurationsParams struct

+ Externalids []pgtype.UUID

+ Mininsertedat pgtype.Timestamptz

+ Tenantid pgtype.UUID

+ type GetDagDurationsRow struct

+ ExternalID pgtype.UUID

+ FinishedAt pgtype.Timestamptz

+ StartedAt pgtype.Timestamptz

+ type GetDesiredLabelsRow struct

+ Comparator WorkerLabelComparator

+ IntValue pgtype.Int4

+ Key string

+ Required bool

+ StepId pgtype.UUID

+ StrValue pgtype.Text

+ Weight int32

+ type GetEventByExternalIdUsingTenantIdParams struct

+ Eventexternalid pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetExistingInviteParams struct

+ Inviteeemail string

+ Tenantid pgtype.UUID

+ type GetFilterParams struct

+ ID pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetGroupKeyRun struct

+ CancelledAt pgtype.Timestamp

+ CancelledError pgtype.Text

+ CancelledReason pgtype.Text

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ Error pgtype.Text

+ FinishedAt pgtype.Timestamp

+ ID pgtype.UUID

+ Input []byte

+ Output pgtype.Text

+ RequeueAfter pgtype.Timestamp

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

+ Queue string

+ Tenantid pgtype.UUID

+ type GetQueuedCountsRow struct

+ Count int64

+ Queue string

+ type GetRunsListRecursiveParams struct

+ Createdafter pgtype.Timestamptz

+ Depth int32

+ Taskexternalids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetRunsListRecursiveRow struct

+ Depth int32

+ ExternalID pgtype.UUID

+ ID int64

+ InsertedAt pgtype.Timestamptz

+ ParentTaskExternalID pgtype.UUID

+ TenantID pgtype.UUID

+ type GetSNSIntegrationParams struct

+ Tenantid pgtype.UUID

+ Topicarn string

+ type GetSatisfiedMatchConditionsParams struct

+ Conditionids []int64

+ Datas [][]byte

+ Matchids []int64

+ type GetScheduledWorkflowMetaByIdsParams struct

+ Ids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetScheduledWorkflowMetaByIdsRow struct

+ HasTriggeredRun bool

+ ID pgtype.UUID

+ Method WorkflowTriggerScheduledRefMethods

+ type GetStepsForJobsParams struct

+ Jobids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type GetStepsForJobsRow struct

+ JobId pgtype.UUID

+ Parents []pgtype.UUID

+ Step Step

+ type GetTaskDurationsByTaskIdsParams struct

+ Readablestatuses []V1ReadableStatusOlap

+ Taskids []int64

+ Taskinsertedats []pgtype.Timestamptz

+ Tenantid pgtype.UUID

+ type GetTaskDurationsByTaskIdsRow struct

+ FinishedAt pgtype.Timestamptz

+ StartedAt pgtype.Timestamptz

+ type GetTaskPointMetricsParams struct

+ Createdafter pgtype.Timestamptz

+ Createdbefore pgtype.Timestamptz

+ Interval pgtype.Interval

+ Tenantid pgtype.UUID

+ type GetTaskPointMetricsRow struct

+ Bucket2 pgtype.Timestamptz

+ CompletedCount int64

+ FailedCount int64

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

+ AdditionalMetaKeys []string

+ AdditionalMetaValues []string

+ CreatedBefore pgtype.Timestamptz

+ Createdafter pgtype.Timestamptz

+ ParentTaskExternalId pgtype.UUID

+ Tenantid pgtype.UUID

+ TriggeringEventExternalId pgtype.UUID

+ WorkflowIds []pgtype.UUID

+ type GetTenantStatusMetricsRow struct

+ TenantID pgtype.UUID

+ TotalCancelled int64

+ TotalCompleted int64

+ TotalFailed int64

+ TotalQueued int64

+ TotalRunning int64

+ type GetTenantTaskStatsRow struct

+ Count int64

+ Expression pgtype.Text

+ Key pgtype.Text

+ Oldest pgtype.Timestamptz

+ Queue string

+ StepReadableID string

+ Strategy pgtype.Text

+ TaskStatus string

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

+ Name string

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

+ Tenantid pgtype.UUID

+ Workerid pgtype.UUID

+ type GetWorkflowByIdRow struct

+ Workflow Workflow

+ WorkflowVersionId pgtype.UUID

+ type GetWorkflowByNameParams struct

+ Name string

+ Tenantid pgtype.UUID

+ type GetWorkflowConcurrencyQueueCountsRow struct

+ Count int64

+ Key string

+ WorkflowName string

+ type GetWorkflowRunIdFromDagIdInsertedAtParams struct

+ Dagid int64

+ Daginsertedat pgtype.Timestamptz

+ type GetWorkflowShapeRow struct

+ Childrenstepids []pgtype.UUID

+ Parentstepid pgtype.UUID

+ Stepname pgtype.Text

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

+ ExternalId pgtype.UUID

+ InsertedAt pgtype.Timestamptz

+ TenantId pgtype.UUID

+ func InsertCutOverOLAPPayloadsIntoTempTable(ctx context.Context, tx DBTX, tableName string, ...) (*InsertCutOverOLAPPayloadsIntoTempTableRow, error)

+ type InsertCutOverPayloadsIntoTempTableRow struct

+ ID int64

+ InsertedAt pgtype.Timestamptz

+ TenantId pgtype.UUID

+ Type V1PayloadType

+ func InsertCutOverPayloadsIntoTempTable(ctx context.Context, tx DBTX, tableName string, ...) (*InsertCutOverPayloadsIntoTempTableRow, error)

+ type InsertLogLineParams struct

+ Level V1LogLineLevel

+ Message string

+ Metadata []byte

+ RetryCount int32

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ TenantID 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 InviteLinkStatus string

+ const InviteLinkStatusACCEPTED

+ const InviteLinkStatusPENDING

+ const InviteLinkStatusREJECTED

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

+ type IsTenantAlertActiveRow struct

+ IsActive bool

+ LastAlertedAt pgtype.Timestamp

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

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

+ Tenantid pgtype.UUID

+ Workerids []pgtype.UUID

+ type ListActionsForWorkersRow struct

+ ActionId pgtype.Text

+ WorkerId pgtype.UUID

+ type ListActiveDispatchersRow struct

+ Dispatcher Dispatcher

+ type ListActiveSDKsPerTenantRow struct

+ Count int64

+ Language string

+ LanguageVersion string

+ Os string

+ SdkVersion string

+ TenantId pgtype.UUID

+ type ListActiveTickersRow struct

+ Ticker Ticker

+ type ListActiveWorkersPerTenantRow struct

+ Count int64

+ TenantId pgtype.UUID

+ type ListActiveWorkersRow struct

+ ID pgtype.UUID

+ MaxRuns int32

+ Name string

+ type ListAllTasksInDagsParams struct

+ Dagids []int64

+ Tenantid pgtype.UUID

+ type ListAllTasksInDagsRow struct

+ DagID pgtype.Int8

+ DagInsertedAt pgtype.Timestamptz

+ ExternalID pgtype.UUID

+ ID int64

+ InsertedAt pgtype.Timestamptz

+ RetryCount int32

+ StepID pgtype.UUID

+ StepReadableID string

+ WorkflowID pgtype.UUID

+ type ListAvailableSlotsForWorkersParams struct

+ Tenantid pgtype.UUID

+ Workerids []pgtype.UUID

+ type ListAvailableSlotsForWorkersRow struct

+ AvailableSlots int32

+ ID pgtype.UUID

+ type ListConcurrencyStrategiesByStepIdParams struct

+ Stepids []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 ListEventsParams struct

+ AdditionalMetadata []byte

+ EventIds []pgtype.UUID

+ Keys []string

+ Limit pgtype.Int8

+ Offset pgtype.Int8

+ Scopes []string

+ Since pgtype.Timestamptz

+ Statuses []string

+ Tenantid pgtype.UUID

+ Until pgtype.Timestamptz

+ WorkflowIds []pgtype.UUID

+ type ListFilterCountsForWorkflowsParams struct

+ Tenantid pgtype.UUID

+ Workflowids []pgtype.UUID

+ type ListFilterCountsForWorkflowsRow struct

+ Count int64

+ WorkflowID pgtype.UUID

+ type ListFiltersForEventTriggersParams struct

+ FilterLimit pgtype.Int8

+ FilterOffset pgtype.Int8

+ Scopes []string

+ Tenantid pgtype.UUID

+ Workflowids []pgtype.UUID

+ type ListFiltersParams struct

+ Filterlimit int64

+ Filteroffset int64

+ Scopes []string

+ Tenantid pgtype.UUID

+ WorkflowIds []pgtype.UUID

+ type ListInvitesByTenantIdParams struct

+ Expired pgtype.Bool

+ Status NullInviteLinkStatus

+ Tenantid pgtype.UUID

+ type ListLogLinesParams struct

+ Limit interface{}

+ Offset interface{}

+ Search pgtype.Text

+ Since pgtype.Timestamptz

+ Taskid int64

+ Taskinsertedat pgtype.Timestamptz

+ Tenantid pgtype.UUID

+ Until pgtype.Timestamptz

+ type ListManyWorkerLabelsRow struct

+ CreatedAt pgtype.Timestamp

+ ID int64

+ IntValue pgtype.Int4

+ Key string

+ StrValue pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ WorkerId pgtype.UUID

+ type ListMatchConditionsForEventRow struct

+ EventKey string

+ EventResourceHint pgtype.Text

+ EventType V1EventType

+ Expression pgtype.Text

+ ID int64

+ ReadableDataKey string

+ RegisteredAt pgtype.Timestamptz

+ V1MatchID int64

+ type ListMatchConditionsForEventWithHintParams struct

+ Eventkeys []string

+ Eventresourcehints []string

+ Eventtype V1EventType

+ Tenantid pgtype.UUID

+ type ListMatchConditionsForEventWithoutHintParams struct

+ Eventkeys []string

+ Eventtype V1EventType

+ Tenantid pgtype.UUID

+ type ListMatchingSignalEventsParams struct

+ Eventkeys []string

+ Eventtype V1TaskEventType

+ Taskids []int64

+ Taskinsertedats []pgtype.Timestamptz

+ Tenantid pgtype.UUID

+ type ListMatchingTaskEventsParams struct

+ Eventtypes [][]string

+ Taskexternalids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type ListMatchingTaskEventsRow struct

+ CreatedAt pgtype.Timestamp

+ Data []byte

+ EventKey pgtype.Text

+ EventType V1TaskEventType

+ ExternalID pgtype.UUID

+ ExternalID_2 pgtype.UUID

+ ID int64

+ InsertedAt pgtype.Timestamptz

+ RetryCount int32

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ TenantID pgtype.UUID

+ type ListNewlyStaleTickersRow struct

+ Ticker Ticker

+ type ListOLAPPartitionsBeforeDateParams struct

+ Date pgtype.Date

+ Shouldpartitioneventstables bool

+ type ListOLAPPartitionsBeforeDateRow struct

+ ParentTable string

+ PartitionName string

+ type ListPaginatedOLAPPayloadsForOffloadParams struct

+ Batchsize int32

+ Lastexternalid pgtype.UUID

+ Lastinsertedat pgtype.Timestamptz

+ Lasttenantid pgtype.UUID

+ Nextexternalid pgtype.UUID

+ Nextinsertedat pgtype.Timestamptz

+ Nexttenantid pgtype.UUID

+ Partitiondate pgtype.Date

+ type ListPaginatedOLAPPayloadsForOffloadRow struct

+ ExternalID pgtype.UUID

+ ExternalLocationKey string

+ InlineContent []byte

+ InsertedAt pgtype.Timestamptz

+ Location V1PayloadLocationOlap

+ TenantID pgtype.UUID

+ UpdatedAt pgtype.Timestamptz

+ type ListPaginatedPayloadsForOffloadParams struct

+ Batchsize int32

+ Lastid int64

+ Lastinsertedat pgtype.Timestamptz

+ Lasttenantid pgtype.UUID

+ Lasttype V1PayloadType

+ Nextid int64

+ Nextinsertedat pgtype.Timestamptz

+ Nexttenantid pgtype.UUID

+ Nexttype V1PayloadType

+ Partitiondate pgtype.Date

+ type ListPaginatedPayloadsForOffloadRow struct

+ ExternalID pgtype.UUID

+ ExternalLocationKey string

+ ID int64

+ InlineContent []byte

+ InsertedAt pgtype.Timestamptz

+ Location V1PayloadLocation

+ TenantID pgtype.UUID

+ Type V1PayloadType

+ UpdatedAt pgtype.Timestamptz

+ type ListPartitionsBeforeDateRow struct

+ ParentTable string

+ PartitionName string

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

+ AdditionalMetadata []byte

+ AppRetryCount int32

+ ChildIndex pgtype.Int8

+ ChildKey pgtype.Text

+ ConcurrencyKeys []string

+ ConcurrencyParentStrategyIds []pgtype.Int8

+ ConcurrencyStrategyIds []int64

+ DagID pgtype.Int8

+ DagInsertedAt pgtype.Timestamptz

+ DesiredWorkerID pgtype.UUID

+ DisplayName string

+ ExternalID pgtype.UUID

+ ID int64

+ InitialState V1TaskInitialState

+ InitialStateReason pgtype.Text

+ Input []byte

+ InsertedAt pgtype.Timestamptz

+ InternalRetryCount int32

+ ParentTaskExternalID pgtype.UUID

+ ParentTaskID pgtype.Int8

+ ParentTaskInsertedAt pgtype.Timestamptz

+ Priority pgtype.Int4

+ Queue string

+ RetryBackoffFactor pgtype.Float8

+ RetryCount int32

+ RetryCount_2 int32

+ RetryMaxBackoff pgtype.Int4

+ ScheduleTimeout string

+ StepID pgtype.UUID

+ StepIndex int64

+ StepReadableID string

+ StepTimeout pgtype.Text

+ Sticky V1StickyStrategy

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ TenantID pgtype.UUID

+ TenantID_2 pgtype.UUID

+ TimeoutAt pgtype.Timestamp

+ WorkerID pgtype.UUID

+ WorkflowID pgtype.UUID

+ WorkflowRunID pgtype.UUID

+ WorkflowVersionID pgtype.UUID

+ type ListStaleDispatchersRow struct

+ Dispatcher Dispatcher

+ type ListStepMatchConditionsParams struct

+ Stepids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type ListStepsByIdsParams struct

+ Ids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type ListStepsByIdsRow struct

+ ActionId string

+ ConcurrencyCount int64

+ CreatedAt pgtype.Timestamp

+ CustomUserData []byte

+ DefaultPriority int32

+ DeletedAt pgtype.Timestamp

+ ExprCount int64

+ 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

+ WorkflowId pgtype.UUID

+ WorkflowName string

+ WorkflowVersionId pgtype.UUID

+ WorkflowVersionSticky NullStickyStrategy

+ type ListStepsByWorkflowVersionIdsParams struct

+ Ids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type ListStepsByWorkflowVersionIdsRow struct

+ ActionId string

+ CreatedAt pgtype.Timestamp

+ CustomUserData []byte

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ JobId pgtype.UUID

+ JobKind JobKind

+ MatchConditionCount int64

+ Parents []pgtype.UUID

+ ReadableId pgtype.Text

+ Retries int32

+ RetryBackoffFactor pgtype.Float8

+ RetryMaxBackoff pgtype.Int4

+ ScheduleTimeout string

+ TenantId pgtype.UUID

+ Timeout pgtype.Text

+ UpdatedAt pgtype.Timestamp

+ WorkflowId pgtype.UUID

+ WorkflowName string

+ WorkflowVersionId pgtype.UUID

+ type ListTaskEventsForWorkflowRunParams struct

+ Tenantid pgtype.UUID

+ Workflowrunid pgtype.UUID

+ type ListTaskEventsForWorkflowRunRow struct

+ AdditionalEventData pgtype.Text

+ AdditionalEventMessage pgtype.Text

+ Count int64

+ DisplayName string

+ ErrorMessage pgtype.Text

+ EventExternalID pgtype.UUID

+ EventTimestamp pgtype.Timestamptz

+ EventType V1EventTypeOlap

+ ID int64

+ Output []byte

+ ReadableStatus V1ReadableStatusOlap

+ RetryCount int32

+ TaskExternalID pgtype.UUID

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ TenantID pgtype.UUID

+ TimeFirstSeen pgtype.Timestamptz

+ TimeLastSeen pgtype.Timestamptz

+ WorkerID pgtype.UUID

+ type ListTaskEventsParams struct

+ Taskid int64

+ Taskinsertedat pgtype.Timestamptz

+ Tenantid pgtype.UUID

+ type ListTaskEventsRow struct

+ AdditionalEventData pgtype.Text

+ AdditionalEventMessage pgtype.Text

+ Count int64

+ ErrorMessage pgtype.Text

+ EventExternalID pgtype.UUID

+ EventTimestamp pgtype.Timestamptz

+ EventType V1EventTypeOlap

+ ID int64

+ Output []byte

+ ReadableStatus V1ReadableStatusOlap

+ RetryCount int32

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ TenantID pgtype.UUID

+ TimeFirstSeen interface{}

+ TimeLastSeen interface{}

+ WorkerID pgtype.UUID

+ type ListTaskExpressionEvalsParams struct

+ Taskids []int64

+ Taskinsertedats []pgtype.Timestamptz

+ type ListTaskMetasParams struct

+ Ids []int64

+ TenantID pgtype.UUID

+ type ListTaskMetasRow struct

+ ExternalID pgtype.UUID

+ ID int64

+ InsertedAt pgtype.Timestamptz

+ RetryCount int32

+ WorkflowID pgtype.UUID

+ WorkflowRunID pgtype.UUID

+ type ListTaskParentOutputsParams struct

+ Taskids []int64

+ Taskinsertedats []pgtype.Timestamptz

+ Tenantid pgtype.UUID

+ type ListTaskParentOutputsRow struct

+ Output []byte

+ TaskEventID int64

+ TaskEventInsertedAt pgtype.Timestamptz

+ WorkflowRunID pgtype.UUID

+ type ListTasksByDAGIdsParams struct

+ Dagids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type ListTasksByDAGIdsRow struct

+ DagExternalID pgtype.UUID

+ DagID int64

+ DagInsertedAt pgtype.Timestamptz

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ type ListTasksByExternalIdsParams struct

+ Externalids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type ListTasksByExternalIdsRow struct

+ InsertedAt pgtype.Timestamptz

+ TaskID pgtype.Int8

+ TenantID pgtype.UUID

+ type ListTasksForReplayParams struct

+ Taskids []int64

+ Taskinsertedats []pgtype.Timestamptz

+ Tenantid pgtype.UUID

+ type ListTasksForReplayRow struct

+ AdditionalMetadata []byte

+ ChildIndex pgtype.Int8

+ ChildKey pgtype.Text

+ DagID pgtype.Int8

+ DagInsertedAt pgtype.Timestamptz

+ ExternalID pgtype.UUID

+ ID int64

+ Input []byte

+ InsertedAt pgtype.Timestamptz

+ JobKind JobKind

+ ParentTaskExternalID pgtype.UUID

+ ParentTaskID pgtype.Int8

+ ParentTaskInsertedAt pgtype.Timestamptz

+ Parents []pgtype.UUID

+ RetryCount int32

+ StepID pgtype.UUID

+ StepIndex int64

+ StepReadableID string

+ WorkflowID pgtype.UUID

+ type ListTasksOlapParams struct

+ Keys []string

+ Since pgtype.Timestamptz

+ Statuses []string

+ Tasklimit int32

+ Taskoffset int32

+ Tenantid pgtype.UUID

+ TriggeringEventExternalId pgtype.UUID

+ Until pgtype.Timestamptz

+ Values []string

+ WorkerId pgtype.UUID

+ WorkflowIds []pgtype.UUID

+ type ListTasksOlapRow struct

+ ID int64

+ InsertedAt pgtype.Timestamptz

+ type ListTasksParams struct

+ Ids []int64

+ TenantID pgtype.UUID

+ type ListTasksToReassignParams struct

+ Limit pgtype.Int4

+ Tenantid pgtype.UUID

+ type ListTasksToReassignRow struct

+ ID int64

+ InsertedAt pgtype.Timestamptz

+ RetryCount int32

+ type ListTasksToTimeoutParams struct

+ Limit pgtype.Int4

+ Tenantid pgtype.UUID

+ type ListTasksToTimeoutRow struct

+ AppRetryCount int32

+ ExternalID pgtype.UUID

+ ID int64

+ InsertedAt pgtype.Timestamptz

+ RetryBackoffFactor pgtype.Float8

+ RetryCount int32

+ RetryMaxBackoff pgtype.Int4

+ StepID pgtype.UUID

+ StepTimeout pgtype.Text

+ WorkerID pgtype.UUID

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

+ TenantId pgtype.UUID

+ TotalActiveSlots int64

+ type ListWebhooksParams struct

+ Sourcenames []V1IncomingWebhookSourceName

+ Tenantid pgtype.UUID

+ WebhookLimit pgtype.Int8

+ WebhookOffset pgtype.Int8

+ Webhooknames []string

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

+ ID pgtype.UUID

+ Name string

+ type ListWorkflowRunDisplayNamesParams struct

+ Externalids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type ListWorkflowRunDisplayNamesRow struct

+ DisplayName string

+ ExternalID pgtype.UUID

+ InsertedAt pgtype.Timestamptz

+ type ListWorkflowRunExternalIdsParams struct

+ AdditionalMetaKeys []string

+ AdditionalMetaValues []string

+ Since pgtype.Timestamptz

+ Statuses []string

+ Tenantid pgtype.UUID

+ Until pgtype.Timestamptz

+ WorkflowIds []pgtype.UUID

+ type ListWorkflowsByNamesParams struct

+ Tenantid pgtype.UUID

+ Workflownames []string

+ type ListWorkflowsByNamesRow struct

+ WorkflowId pgtype.UUID

+ WorkflowName string

+ WorkflowVersionId pgtype.UUID

+ type ListWorkflowsForEventsParams struct

+ Eventkeys []string

+ Tenantid pgtype.UUID

+ type ListWorkflowsForEventsRow struct

+ IncomingEventKey string

+ WorkflowId pgtype.UUID

+ WorkflowName string

+ WorkflowTriggeringEventKeyPattern string

+ WorkflowVersionId pgtype.UUID

+ type ListWorkflowsParams struct

+ Limit interface{}

+ Offset interface{}

+ Orderby interface{}

+ Search pgtype.Text

+ Tenantid pgtype.UUID

+ type ListWorkflowsRow struct

+ Workflow Workflow

+ type ListYesterdayRunCountsByStatusRow struct

+ Count int64

+ ReadableStatus V1ReadableStatusOlap

+ type LockDAGsForReplayParams struct

+ Dagids []int64

+ Tenantid pgtype.UUID

+ type LockSignalCreatedEventsParams struct

+ Eventkeys []string

+ Taskids []int64

+ Taskinsertedats []pgtype.Timestamptz

+ Tenantid pgtype.UUID

+ type LockSignalCreatedEventsRow struct

+ Data []byte

+ EventKey pgtype.Text

+ ID int64

+ InsertedAt pgtype.Timestamptz

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

+ ElapsedTime int32

+ EstimatedTimeRemaining pgtype.Interval

+ IndexVacuumCount pgtype.Int8

+ PctScanned pgtype.Numeric

+ Phase pgtype.Text

+ Pid pgtype.Int4

+ Query pgtype.Text

+ ScannedBlocks pgtype.Int8

+ TableName interface{}

+ TableSize string

+ TotalBlocks pgtype.Int8

+ VacuumedBlocks pgtype.Int8

+ WaitEvent pgtype.Text

+ WaitEventType pgtype.Text

+ type LookupExternalIdsParams struct

+ Externalids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type ManualSlotReleaseParams struct

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

+ Ids []int64

+ Requeueafter []pgtype.Timestamptz

+ type MoveRateLimitedQueueItemsRow struct

+ RetryCount int32

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

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

+ TenantEnvironment TenantEnvironment

+ Valid bool

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

+ func (ns NullTenantEnvironment) 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 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 NullV1CelEvaluationFailureSource struct

+ V1CelEvaluationFailureSource V1CelEvaluationFailureSource

+ Valid bool

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

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

+ type NullV1ConcurrencyStrategy struct

+ V1ConcurrencyStrategy V1ConcurrencyStrategy

+ Valid bool

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

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

+ type NullV1EventType struct

+ V1EventType V1EventType

+ Valid bool

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

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

+ type NullV1EventTypeOlap struct

+ V1EventTypeOlap V1EventTypeOlap

+ Valid bool

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

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

+ type NullV1IncomingWebhookAuthType struct

+ V1IncomingWebhookAuthType V1IncomingWebhookAuthType

+ Valid bool

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

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

+ type NullV1IncomingWebhookHmacAlgorithm struct

+ V1IncomingWebhookHmacAlgorithm V1IncomingWebhookHmacAlgorithm

+ Valid bool

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

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

+ type NullV1IncomingWebhookHmacEncoding struct

+ V1IncomingWebhookHmacEncoding V1IncomingWebhookHmacEncoding

+ Valid bool

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

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

+ type NullV1IncomingWebhookSourceName struct

+ V1IncomingWebhookSourceName V1IncomingWebhookSourceName

+ Valid bool

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

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

+ type NullV1LogLineLevel struct

+ V1LogLineLevel V1LogLineLevel

+ Valid bool

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

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

+ type NullV1MatchConditionAction struct

+ V1MatchConditionAction V1MatchConditionAction

+ Valid bool

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

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

+ type NullV1MatchKind struct

+ V1MatchKind V1MatchKind

+ Valid bool

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

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

+ type NullV1PayloadLocation struct

+ V1PayloadLocation V1PayloadLocation

+ Valid bool

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

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

+ type NullV1PayloadLocationOlap struct

+ V1PayloadLocationOlap V1PayloadLocationOlap

+ Valid bool

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

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

+ type NullV1PayloadType struct

+ V1PayloadType V1PayloadType

+ Valid bool

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

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

+ type NullV1ReadableStatusOlap struct

+ V1ReadableStatusOlap V1ReadableStatusOlap

+ Valid bool

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

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

+ type NullV1RunKind struct

+ V1RunKind V1RunKind

+ Valid bool

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

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

+ type NullV1StatusKind struct

+ V1StatusKind V1StatusKind

+ Valid bool

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

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

+ type NullV1StepMatchConditionKind struct

+ V1StepMatchConditionKind V1StepMatchConditionKind

+ Valid bool

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

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

+ type NullV1StickyStrategy struct

+ V1StickyStrategy V1StickyStrategy

+ Valid bool

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

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

+ type NullV1StickyStrategyOlap struct

+ V1StickyStrategyOlap V1StickyStrategyOlap

+ Valid bool

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

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

+ type NullV1TaskEventType struct

+ V1TaskEventType V1TaskEventType

+ Valid bool

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

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

+ type NullV1TaskInitialState struct

+ V1TaskInitialState V1TaskInitialState

+ Valid bool

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

+ func (ns NullV1TaskInitialState) 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 OffloadPayloadsParams struct

+ Externalids []pgtype.UUID

+ Externallocationkeys []string

+ Tenantids []pgtype.UUID

+ type PartitionRowCounts struct

+ SourcePartitionCount int64

+ TempPartitionCount int64

+ func ComparePartitionRowCounts(ctx context.Context, tx DBTX, tempPartitionName, sourcePartitionName string) (*PartitionRowCounts, error)

+ type PgAvailableExtensions struct

+ Comment pgtype.Text

+ DefaultVersion pgtype.Text

+ InstalledVersion pgtype.Text

+ Name pgtype.Text

+ type PgStatActivity struct

+ ApplicationName pgtype.Text

+ ClientAddr *netip.Addr

+ Pid pgtype.Int4

+ Query pgtype.Text

+ QueryStart pgtype.Timestamptz

+ State pgtype.Text

+ Usename pgtype.Text

+ WaitEvent pgtype.Text

+ WaitEventType pgtype.Text

+ type PgStatProgressVacuum struct

+ Datid pgtype.Uint32

+ Datname pgtype.Text

+ HeapBlksFrozen pgtype.Int8

+ HeapBlksScanned pgtype.Int8

+ HeapBlksTotal pgtype.Int8

+ HeapBlksVacuumed pgtype.Int8

+ IndexVacuumCount pgtype.Int8

+ MaxDeadTuples pgtype.Int8

+ NumDeadTuples pgtype.Int8

+ Phase pgtype.Text

+ Pid pgtype.Int4

+ Relid pgtype.Uint32

+ type PgStatStatements struct

+ BlkReadTime pgtype.Float8

+ BlkWriteTime pgtype.Float8

+ Calls pgtype.Int8

+ Dbid pgtype.Uint32

+ LocalBlksDirtied pgtype.Int8

+ LocalBlksHit pgtype.Int8

+ LocalBlksRead pgtype.Int8

+ LocalBlksWritten pgtype.Int8

+ Query pgtype.Text

+ Queryid pgtype.Int8

+ Rows pgtype.Int8

+ SharedBlksDirtied pgtype.Int8

+ SharedBlksHit pgtype.Int8

+ SharedBlksRead pgtype.Int8

+ SharedBlksWritten pgtype.Int8

+ TempBlksRead pgtype.Int8

+ TempBlksWritten pgtype.Int8

+ TotalExecTime pgtype.Float8

+ Userid pgtype.Uint32

+ type PgStatUserTables struct

+ AnalyzeCount pgtype.Int8

+ AutoanalyzeCount pgtype.Int8

+ AutovacuumCount pgtype.Int8

+ IdxScan pgtype.Int8

+ IdxTupFetch pgtype.Int8

+ LastAnalyze pgtype.Timestamptz

+ LastAutoanalyze pgtype.Timestamptz

+ LastAutovacuum pgtype.Timestamptz

+ LastVacuum pgtype.Timestamptz

+ NDeadTup pgtype.Int8

+ NInsSinceVacuum pgtype.Int8

+ NLiveTup pgtype.Int8

+ NModSinceAnalyze pgtype.Int8

+ NTupDel pgtype.Int8

+ NTupHotUpd pgtype.Int8

+ NTupIns pgtype.Int8

+ NTupUpd pgtype.Int8

+ Relid pgtype.Uint32

+ Relname pgtype.Text

+ Schemaname pgtype.Text

+ SeqScan pgtype.Int8

+ SeqTupRead pgtype.Int8

+ VacuumCount pgtype.Int8

+ type PgStatioUserTables struct

+ HeapBlksHit pgtype.Int8

+ HeapBlksRead pgtype.Int8

+ IdxBlksHit pgtype.Int8

+ IdxBlksRead pgtype.Int8

+ Relid pgtype.Uint32

+ Relname pgtype.Text

+ Schemaname pgtype.Text

+ TidxBlksHit pgtype.Int8

+ TidxBlksRead pgtype.Int8

+ ToastBlksHit pgtype.Int8

+ ToastBlksRead pgtype.Int8

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

+ Limit pgtype.Int4

+ TenantID pgtype.UUID

+ type PopulateDAGMetadataParams struct

+ Ids []int64

+ Includepayloads bool

+ Insertedats []pgtype.Timestamptz

+ Tenantid pgtype.UUID

+ type PopulateDAGMetadataRow struct

+ AdditionalMetadata []byte

+ CreatedAt pgtype.Timestamptz

+ DagID int64

+ DisplayName string

+ ErrorMessage pgtype.Text

+ ExternalID pgtype.UUID

+ FinishedAt pgtype.Timestamptz

+ Input []byte

+ InsertedAt pgtype.Timestamptz

+ Kind V1RunKind

+ Output []byte

+ OutputEventExternalID pgtype.UUID

+ ParentTaskExternalID pgtype.UUID

+ ReadableStatus V1ReadableStatusOlap

+ RetryCount int32

+ RunID int64

+ StartedAt pgtype.Timestamptz

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

+ WorkflowVersionID pgtype.UUID

+ type PopulateEventDataParams struct

+ Eventexternalids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type PopulateEventDataRow struct

+ CancelledCount int64

+ CompletedCount int64

+ ExternalID pgtype.UUID

+ FailedCount int64

+ QueuedCount int64

+ RunningCount int64

+ TriggeredRuns []byte

+ type PopulateSingleTaskRunDataParams struct

+ RetryCount pgtype.Int4

+ Taskid int64

+ Taskinsertedat pgtype.Timestamptz

+ Tenantid pgtype.UUID

+ type PopulateSingleTaskRunDataRow struct

+ ActionID string

+ AdditionalMetadata []byte

+ DagID pgtype.Int8

+ DagInsertedAt pgtype.Timestamptz

+ DesiredWorkerID pgtype.UUID

+ DisplayName string

+ ErrorMessage pgtype.Text

+ ExternalID pgtype.UUID

+ FinishedAt pgtype.Timestamptz

+ ID int64

+ Input []byte

+ InsertedAt pgtype.Timestamptz

+ LatestRetryCount int32

+ LatestWorkerID pgtype.UUID

+ Output []byte

+ OutputEventExternalID pgtype.UUID

+ ParentTaskExternalID pgtype.UUID

+ Priority pgtype.Int4

+ Queue string

+ QueuedAt pgtype.Timestamptz

+ ReadableStatus V1ReadableStatusOlap

+ RetryCount int32

+ ScheduleTimeout string

+ SpawnedChildren pgtype.Int8

+ StartedAt pgtype.Timestamptz

+ Status V1ReadableStatusOlap

+ StepID pgtype.UUID

+ StepTimeout pgtype.Text

+ Sticky V1StickyStrategyOlap

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

+ WorkflowRunID pgtype.UUID

+ WorkflowVersionID pgtype.UUID

+ type PopulateTaskRunDataParams struct

+ Includepayloads bool

+ Taskids []int64

+ Taskinsertedats []pgtype.Timestamptz

+ Tenantid pgtype.UUID

+ type PopulateTaskRunDataRow struct

+ ActionID string

+ AdditionalMetadata []byte

+ DisplayName string

+ ErrorMessage pgtype.Text

+ ExternalID pgtype.UUID

+ FinishedAt pgtype.Timestamptz

+ ID int64

+ Input []byte

+ InsertedAt pgtype.Timestamptz

+ Output []byte

+ OutputEventExternalID pgtype.UUID

+ ParentTaskExternalID pgtype.UUID

+ Priority pgtype.Int4

+ Queue string

+ QueuedAt pgtype.Timestamptz

+ RetryCount int32

+ ScheduleTimeout string

+ StartedAt pgtype.Timestamptz

+ Status V1ReadableStatusOlap

+ StepID pgtype.UUID

+ StepTimeout pgtype.Text

+ Sticky V1StickyStrategyOlap

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

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

+ TenantEnvironment NullTenantEnvironment

+ TenantId pgtype.UUID

+ TenantId_2 pgtype.UUID

+ TenantName string

+ TenantSlug string

+ TenantUpdatedAt pgtype.Timestamp

+ TenantVersion TenantMajorEngineVersion

+ UpdatedAt pgtype.Timestamp

+ UserId pgtype.UUID

+ type PreflightCheckDAGsForReplayParams struct

+ Dagids []int64

+ Tenantid pgtype.UUID

+ type PreflightCheckDAGsForReplayRow struct

+ ExternalID pgtype.UUID

+ ID int64

+ InsertedAt pgtype.Timestamptz

+ StepCount int64

+ TaskCount int64

+ type PreflightCheckTasksForReplayParams struct

+ Mininsertedat pgtype.Timestamptz

+ Taskids []int64

+ Taskinsertedats []pgtype.Timestamptz

+ Tenantid pgtype.UUID

+ type PreflightCheckTasksForReplayRow struct

+ DagID pgtype.Int8

+ ID int64

+ type ProcessRetryQueueItemsParams struct

+ Limit pgtype.Int4

+ Tenantid pgtype.UUID

+ type PutPayloadsParams struct

+ Externalids []pgtype.UUID

+ Externallocationkeys []string

+ Insertedats []pgtype.Timestamptz

+ Locations []string

+ Payloads [][]byte

+ Tenantids []pgtype.UUID

+ type Queries struct

+ func New() *Queries

+ func (q *Queries) AcquireOrExtendCutoverJobLease(ctx context.Context, db DBTX, arg AcquireOrExtendCutoverJobLeaseParams) (*V1PayloadCutoverJobOffset, error)

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

+ func (q *Queries) AcquireOrExtendOLAPCutoverJobLease(ctx context.Context, db DBTX, arg AcquireOrExtendOLAPCutoverJobLeaseParams) (*V1PayloadsOlapCutoverJobOffset, 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) AdvisoryLock(ctx context.Context, db DBTX, key int64) error

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

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

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

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

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

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

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

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

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

+ func (q *Queries) AnalyzeV1TasksOLAP(ctx context.Context, db DBTX) 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) BulkCreateEventTriggers(ctx context.Context, db DBTX, arg []BulkCreateEventTriggersParams) (int64, error)

+ func (q *Queries) BulkCreateEvents(ctx context.Context, db DBTX, arg BulkCreateEventsParams) ([]*V1EventsOlap, error)

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (q *Queries) ClaimIdempotencyKeys(ctx context.Context, db DBTX, arg ClaimIdempotencyKeysParams) ([]*ClaimIdempotencyKeysRow, error)

+ func (q *Queries) CleanUpCutoverJobOffsets(ctx context.Context, db DBTX, keystokeep []pgtype.Date) error

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

+ func (q *Queries) CleanUpOLAPCutoverJobOffsets(ctx context.Context, db DBTX, keystokeep []pgtype.Date) error

+ func (q *Queries) CleanupMatchWithMatchConditions(ctx context.Context, db DBTX, date pgtype.Date) 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) CleanupV1ConcurrencySlot(ctx context.Context, db DBTX, batchsize int32) (pgconn.CommandTag, error)

+ func (q *Queries) CleanupV1QueueItem(ctx context.Context, db DBTX, batchsize int32) (pgconn.CommandTag, error)

+ func (q *Queries) CleanupV1RateLimitedQueueItem(ctx context.Context, db DBTX, batchsize int32) (pgconn.CommandTag, error)

+ func (q *Queries) CleanupV1RetryQueueItem(ctx context.Context, db DBTX, batchsize int32) (pgconn.CommandTag, error)

+ func (q *Queries) CleanupV1TaskRuntime(ctx context.Context, db DBTX, batchsize int32) (pgconn.CommandTag, error)

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

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

+ func (q *Queries) ComputePayloadBatchSize(ctx context.Context, db DBTX, arg ComputePayloadBatchSizeParams) (int64, 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) CountFilters(ctx context.Context, db DBTX, arg CountFiltersParams) (int64, error)

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

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

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

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

+ func (q *Queries) CountTasks(ctx context.Context, db DBTX, arg CountTasksParams) (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) 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) CreateDAGData(ctx context.Context, db DBTX, arg []CreateDAGDataParams) (int64, error)

+ func (q *Queries) CreateDAGs(ctx context.Context, db DBTX, arg CreateDAGsParams) ([]*V1Dag, error)

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

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

+ func (q *Queries) CreateDurableSleep(ctx context.Context, db DBTX, arg CreateDurableSleepParams) ([]*V1DurableSleep, error)

+ func (q *Queries) CreateFilter(ctx context.Context, db DBTX, arg CreateFilterParams) (*V1Filter, error)

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

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

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

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

+ func (q *Queries) CreateMatchesForDAGTriggers(ctx context.Context, db DBTX, arg CreateMatchesForDAGTriggersParams) ([]*V1Match, error)

+ func (q *Queries) CreateMatchesForSignalTriggers(ctx context.Context, db DBTX, arg CreateMatchesForSignalTriggersParams) ([]*V1Match, error)

+ func (q *Queries) CreateOLAPEventPartitions(ctx context.Context, db DBTX, date pgtype.Date) error

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

+ func (q *Queries) CreateOLAPPayloadRangeChunks(ctx context.Context, db DBTX, arg CreateOLAPPayloadRangeChunksParams) ([]*CreateOLAPPayloadRangeChunksRow, error)

+ func (q *Queries) CreatePartitions(ctx context.Context, db DBTX, date pgtype.Date) error

+ func (q *Queries) CreatePayloadRangeChunks(ctx context.Context, db DBTX, arg CreatePayloadRangeChunksParams) ([]*CreatePayloadRangeChunksRow, 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) CreateStep(ctx context.Context, db DBTX, arg CreateStepParams) (*Step, error)

+ func (q *Queries) CreateStepConcurrency(ctx context.Context, db DBTX, arg CreateStepConcurrencyParams) (*V1StepConcurrency, error)

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

+ func (q *Queries) CreateStepMatchCondition(ctx context.Context, db DBTX, arg CreateStepMatchConditionParams) (*V1StepMatchCondition, error)

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

+ func (q *Queries) CreateTaskEvents(ctx context.Context, db DBTX, arg CreateTaskEventsParams) ([]*V1TaskEvent, error)

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

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

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

+ func (q *Queries) CreateTasks(ctx context.Context, db DBTX, arg CreateTasksParams) ([]*V1Task, error)

+ func (q *Queries) CreateTasksOLAP(ctx context.Context, db DBTX, arg []CreateTasksOLAPParams) (int64, 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) 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) CreateV1PayloadCutoverTemporaryTable(ctx context.Context, db DBTX, date pgtype.Date) error

+ func (q *Queries) CreateV1PayloadOLAPCutoverTemporaryTable(ctx context.Context, db DBTX, date pgtype.Date) error

+ func (q *Queries) CreateWebhook(ctx context.Context, db DBTX, arg CreateWebhookParams) (*V1IncomingWebhook, error)

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

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

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

+ func (q *Queries) CreateWorkflowConcurrencyV1(ctx context.Context, db DBTX, arg CreateWorkflowConcurrencyV1Params) (*CreateWorkflowConcurrencyV1Row, 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) 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) DefaultTaskActivityGauge(ctx context.Context, db DBTX, arg DefaultTaskActivityGaugeParams) (int64, 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) DeleteExistingDeclarativeFiltersForOverwrite(ctx context.Context, db DBTX, ...) error

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

+ func (q *Queries) DeleteFilter(ctx context.Context, db DBTX, arg DeleteFilterParams) (*V1Filter, error)

+ func (q *Queries) DeleteMatchingSignalEvents(ctx context.Context, db DBTX, arg DeleteMatchingSignalEventsParams) 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) DeleteTasksFromQueue(ctx context.Context, db DBTX, arg DeleteTasksFromQueueParams) 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) DeleteWebhook(ctx context.Context, db DBTX, arg DeleteWebhookParams) (*V1IncomingWebhook, 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) DiffOLAPPayloadSourceAndTargetPartitions(ctx context.Context, db DBTX, partitiondate pgtype.Date) ([]*DiffOLAPPayloadSourceAndTargetPartitionsRow, error)

+ func (q *Queries) DiffPayloadSourceAndTargetPartitions(ctx context.Context, db DBTX, partitiondate pgtype.Date) ([]*DiffPayloadSourceAndTargetPartitionsRow, error)

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

+ func (q *Queries) FailTaskAppFailure(ctx context.Context, db DBTX, arg FailTaskAppFailureParams) ([]*FailTaskAppFailureRow, error)

+ func (q *Queries) FailTaskInternalFailure(ctx context.Context, db DBTX, arg FailTaskInternalFailureParams) ([]*FailTaskInternalFailureRow, error)

+ func (q *Queries) FetchWorkflowRunIds(ctx context.Context, db DBTX, arg FetchWorkflowRunIdsParams) ([]*FetchWorkflowRunIdsRow, error)

+ func (q *Queries) FindMinInsertedAtForDAGStatusUpdates(ctx context.Context, db DBTX, arg FindMinInsertedAtForDAGStatusUpdatesParams) (pgtype.Timestamptz, error)

+ func (q *Queries) FindMinInsertedAtForTaskStatusUpdates(ctx context.Context, db DBTX, arg FindMinInsertedAtForTaskStatusUpdatesParams) (pgtype.Timestamptz, error)

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

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

+ func (q *Queries) FindV1OLAPPayloadPartitionsBeforeDate(ctx context.Context, db DBTX, maxPartitionsToProcess int32, date pgtype.Date) ([]*FindV1OLAPPayloadPartitionsBeforeDateRow, error)

+ func (q *Queries) FindV1PayloadPartitionsBeforeDate(ctx context.Context, db DBTX, maxPartitionsToProcess int32, date pgtype.Date) ([]*FindV1PayloadPartitionsBeforeDateRow, error)

+ func (q *Queries) FlattenExternalIds(ctx context.Context, db DBTX, arg FlattenExternalIdsParams) ([]*FlattenExternalIdsRow, error)

+ func (q *Queries) FlattenTasksByExternalIds(ctx context.Context, db DBTX, arg FlattenTasksByExternalIdsParams) ([]*FlattenTasksByExternalIdsRow, error)

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

+ func (q *Queries) GetDAGData(ctx context.Context, db DBTX, arg GetDAGDataParams) ([]*GetDAGDataRow, error)

+ func (q *Queries) GetDagDurations(ctx context.Context, db DBTX, arg GetDagDurationsParams) ([]*GetDagDurationsRow, 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) GetEventByExternalId(ctx context.Context, db DBTX, eventexternalid pgtype.UUID) (*V1EventsOlap, error)

+ func (q *Queries) GetEventByExternalIdUsingTenantId(ctx context.Context, db DBTX, arg GetEventByExternalIdUsingTenantIdParams) (*V1EventsOlap, error)

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

+ func (q *Queries) GetFilter(ctx context.Context, db DBTX, arg GetFilterParams) (*V1Filter, 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) 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) 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) GetRunsListRecursive(ctx context.Context, db DBTX, arg GetRunsListRecursiveParams) ([]*GetRunsListRecursiveRow, 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) GetSatisfiedMatchConditions(ctx context.Context, db DBTX, arg GetSatisfiedMatchConditionsParams) ([]int64, error)

+ func (q *Queries) GetScheduledWorkflowMetaByIds(ctx context.Context, db DBTX, arg GetScheduledWorkflowMetaByIdsParams) ([]*GetScheduledWorkflowMetaByIdsRow, 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) GetStepsForJobs(ctx context.Context, db DBTX, arg GetStepsForJobsParams) ([]*GetStepsForJobsRow, error)

+ func (q *Queries) GetTaskDurationsByTaskIds(ctx context.Context, db DBTX, arg GetTaskDurationsByTaskIdsParams) ([]*GetTaskDurationsByTaskIdsRow, error)

+ func (q *Queries) GetTaskPointMetrics(ctx context.Context, db DBTX, arg GetTaskPointMetricsParams) ([]*GetTaskPointMetricsRow, 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) GetTenantStatusMetrics(ctx context.Context, db DBTX, arg GetTenantStatusMetricsParams) (*GetTenantStatusMetricsRow, error)

+ func (q *Queries) GetTenantTaskStats(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]*GetTenantTaskStatsRow, 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) 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) GetWebhook(ctx context.Context, db DBTX, arg GetWebhookParams) (*V1IncomingWebhook, 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) GetWorkerForEngine(ctx context.Context, db DBTX, arg GetWorkerForEngineParams) (*GetWorkerForEngineRow, error)

+ func (q *Queries) GetWorkerWorkflowsByWorkerId(ctx context.Context, db DBTX, arg GetWorkerWorkflowsByWorkerIdParams) ([]*Workflow, 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) GetWorkflowConcurrencyQueueCounts(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]*GetWorkflowConcurrencyQueueCountsRow, error)

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

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

+ func (q *Queries) GetWorkflowShape(ctx context.Context, db DBTX, workflowversionid pgtype.UUID) ([]*GetWorkflowShapeRow, 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) Health(ctx context.Context, db DBTX) ([]pgtype.UUID, error)

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

+ func (q *Queries) IsTenantAlertActive(ctx context.Context, db DBTX, tenantid pgtype.UUID) (*IsTenantAlertActiveRow, 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) ListAPITokensByTenant(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]*APIToken, error)

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

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

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

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

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

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

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

+ func (q *Queries) ListAllTasksInDags(ctx context.Context, db DBTX, arg ListAllTasksInDagsParams) ([]*ListAllTasksInDagsRow, error)

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

+ func (q *Queries) ListConcurrencyStrategiesByStepId(ctx context.Context, db DBTX, arg ListConcurrencyStrategiesByStepIdParams) ([]*V1StepConcurrency, 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) ([]*V1EventsOlap, error)

+ func (q *Queries) ListFilterCountsForWorkflows(ctx context.Context, db DBTX, arg ListFilterCountsForWorkflowsParams) ([]*ListFilterCountsForWorkflowsRow, error)

+ func (q *Queries) ListFilters(ctx context.Context, db DBTX, arg ListFiltersParams) ([]*V1Filter, error)

+ func (q *Queries) ListFiltersForEventTriggers(ctx context.Context, db DBTX, arg ListFiltersForEventTriggersParams) ([]*V1Filter, error)

+ func (q *Queries) ListIntervalsByOperationId(ctx context.Context, db DBTX, operationid string) ([]*V1OperationIntervalSettings, error)

+ func (q *Queries) ListInvitesByTenantId(ctx context.Context, db DBTX, arg ListInvitesByTenantIdParams) ([]*TenantInviteLink, error)

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

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

+ func (q *Queries) ListMatchConditionsForEventWithHint(ctx context.Context, db DBTX, arg ListMatchConditionsForEventWithHintParams) ([]*ListMatchConditionsForEventRow, error)

+ func (q *Queries) ListMatchConditionsForEventWithoutHint(ctx context.Context, db DBTX, arg ListMatchConditionsForEventWithoutHintParams) ([]*ListMatchConditionsForEventRow, error)

+ func (q *Queries) ListMatchingSignalEvents(ctx context.Context, db DBTX, arg ListMatchingSignalEventsParams) ([]*V1TaskEvent, error)

+ func (q *Queries) ListMatchingTaskEvents(ctx context.Context, db DBTX, arg ListMatchingTaskEventsParams) ([]*ListMatchingTaskEventsRow, error)

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

+ func (q *Queries) ListOLAPPartitionsBeforeDate(ctx context.Context, db DBTX, arg ListOLAPPartitionsBeforeDateParams) ([]*ListOLAPPartitionsBeforeDateRow, error)

+ func (q *Queries) ListPaginatedOLAPPayloadsForOffload(ctx context.Context, db DBTX, arg ListPaginatedOLAPPayloadsForOffloadParams) ([]*ListPaginatedOLAPPayloadsForOffloadRow, error)

+ func (q *Queries) ListPaginatedPayloadsForOffload(ctx context.Context, db DBTX, arg ListPaginatedPayloadsForOffloadParams) ([]*ListPaginatedPayloadsForOffloadRow, error)

+ func (q *Queries) ListPartitionsBeforeDate(ctx context.Context, db DBTX, date pgtype.Date) ([]*ListPartitionsBeforeDateRow, error)

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

+ func (q *Queries) ListQueues(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]*V1Queue, 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) 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) ListStepExpressions(ctx context.Context, db DBTX, stepids []pgtype.UUID) ([]*StepExpression, error)

+ func (q *Queries) ListStepMatchConditions(ctx context.Context, db DBTX, arg ListStepMatchConditionsParams) ([]*V1StepMatchCondition, error)

+ func (q *Queries) ListStepsByIds(ctx context.Context, db DBTX, arg ListStepsByIdsParams) ([]*ListStepsByIdsRow, error)

+ func (q *Queries) ListStepsByWorkflowVersionIds(ctx context.Context, db DBTX, arg ListStepsByWorkflowVersionIdsParams) ([]*ListStepsByWorkflowVersionIdsRow, error)

+ func (q *Queries) ListTaskEvents(ctx context.Context, db DBTX, arg ListTaskEventsParams) ([]*ListTaskEventsRow, error)

+ func (q *Queries) ListTaskEventsForWorkflowRun(ctx context.Context, db DBTX, arg ListTaskEventsForWorkflowRunParams) ([]*ListTaskEventsForWorkflowRunRow, error)

+ func (q *Queries) ListTaskExpressionEvals(ctx context.Context, db DBTX, arg ListTaskExpressionEvalsParams) ([]*V1TaskExpressionEval, error)

+ func (q *Queries) ListTaskMetas(ctx context.Context, db DBTX, arg ListTaskMetasParams) ([]*ListTaskMetasRow, error)

+ func (q *Queries) ListTaskParentOutputs(ctx context.Context, db DBTX, arg ListTaskParentOutputsParams) ([]*ListTaskParentOutputsRow, error)

+ func (q *Queries) ListTasks(ctx context.Context, db DBTX, arg ListTasksParams) ([]*V1Task, error)

+ func (q *Queries) ListTasksByDAGIds(ctx context.Context, db DBTX, arg ListTasksByDAGIdsParams) ([]*ListTasksByDAGIdsRow, error)

+ func (q *Queries) ListTasksByExternalIds(ctx context.Context, db DBTX, arg ListTasksByExternalIdsParams) ([]*ListTasksByExternalIdsRow, error)

+ func (q *Queries) ListTasksForReplay(ctx context.Context, db DBTX, arg ListTasksForReplayParams) ([]*ListTasksForReplayRow, error)

+ func (q *Queries) ListTasksOlap(ctx context.Context, db DBTX, arg ListTasksOlapParams) ([]*ListTasksOlapRow, error)

+ func (q *Queries) ListTasksToReassign(ctx context.Context, db DBTX, arg ListTasksToReassignParams) ([]*ListTasksToReassignRow, error)

+ func (q *Queries) ListTasksToTimeout(ctx context.Context, db DBTX, arg ListTasksToTimeoutParams) ([]*ListTasksToTimeoutRow, 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) ListTotalActiveSlotsPerTenant(ctx context.Context, db DBTX) ([]*ListTotalActiveSlotsPerTenantRow, error)

+ func (q *Queries) ListWebhooks(ctx context.Context, db DBTX, arg ListWebhooksParams) ([]*V1IncomingWebhook, 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) ListWorkflowNamesByIds(ctx context.Context, db DBTX, ids []pgtype.UUID) ([]*ListWorkflowNamesByIdsRow, error)

+ func (q *Queries) ListWorkflowRunDisplayNames(ctx context.Context, db DBTX, arg ListWorkflowRunDisplayNamesParams) ([]*ListWorkflowRunDisplayNamesRow, error)

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

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

+ func (q *Queries) ListWorkflowsByNames(ctx context.Context, db DBTX, arg ListWorkflowsByNamesParams) ([]*ListWorkflowsByNamesRow, error)

+ func (q *Queries) ListWorkflowsForEvents(ctx context.Context, db DBTX, arg ListWorkflowsForEventsParams) ([]*ListWorkflowsForEventsRow, error)

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

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

+ func (q *Queries) LockSignalCreatedEvents(ctx context.Context, db DBTX, arg LockSignalCreatedEventsParams) ([]*LockSignalCreatedEventsRow, error)

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

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

+ func (q *Queries) LookupExternalIds(ctx context.Context, db DBTX, arg LookupExternalIdsParams) ([]*V1LookupTable, error)

+ func (q *Queries) ManualSlotRelease(ctx context.Context, db DBTX, arg ManualSlotReleaseParams) (*V1TaskRuntime, error)

+ func (q *Queries) MarkCutoverJobAsCompleted(ctx context.Context, db DBTX, key pgtype.Date) error

+ func (q *Queries) MarkOLAPCutoverJobAsCompleted(ctx context.Context, db DBTX, key pgtype.Date) 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) MoveRateLimitedQueueItems(ctx context.Context, db DBTX, arg MoveRateLimitedQueueItemsParams) ([]*MoveRateLimitedQueueItemsRow, error)

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

+ func (q *Queries) OffloadPayloads(ctx context.Context, db DBTX, arg OffloadPayloadsParams) 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) 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) PopDurableSleep(ctx context.Context, db DBTX, arg PopDurableSleepParams) ([]*V1DurableSleep, error)

+ func (q *Queries) PopulateDAGMetadata(ctx context.Context, db DBTX, arg PopulateDAGMetadataParams) ([]*PopulateDAGMetadataRow, error)

+ func (q *Queries) PopulateEventData(ctx context.Context, db DBTX, arg PopulateEventDataParams) ([]*PopulateEventDataRow, error)

+ func (q *Queries) PopulateSingleTaskRunData(ctx context.Context, db DBTX, arg PopulateSingleTaskRunDataParams) (*PopulateSingleTaskRunDataRow, error)

+ func (q *Queries) PopulateTaskRunData(ctx context.Context, db DBTX, arg PopulateTaskRunDataParams) ([]*PopulateTaskRunDataRow, error)

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

+ func (q *Queries) PreflightCheckDAGsForReplay(ctx context.Context, db DBTX, arg PreflightCheckDAGsForReplayParams) ([]*PreflightCheckDAGsForReplayRow, error)

+ func (q *Queries) PreflightCheckTasksForReplay(ctx context.Context, db DBTX, arg PreflightCheckTasksForReplayParams) ([]*PreflightCheckTasksForReplayRow, error)

+ func (q *Queries) ProcessRetryQueueItems(ctx context.Context, db DBTX, arg ProcessRetryQueueItemsParams) ([]*V1RetryQueueItem, error)

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

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

+ func (q *Queries) ReadInterval(ctx context.Context, db DBTX, arg ReadIntervalParams) (*V1OperationIntervalSettings, error)

+ func (q *Queries) ReadMessages(ctx context.Context, db DBTX, arg ReadMessagesParams) ([]*ReadMessagesRow, error)

+ func (q *Queries) ReadPayloads(ctx context.Context, db DBTX, arg ReadPayloadsParams) ([]*V1Payload, error)

+ func (q *Queries) ReadPayloadsOLAP(ctx context.Context, db DBTX, arg ReadPayloadsOLAPParams) ([]*V1PayloadsOlap, error)

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

+ func (q *Queries) ReadWorkflowRunByExternalId(ctx context.Context, db DBTX, workflowrunexternalid pgtype.UUID) (*ReadWorkflowRunByExternalIdRow, 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) (*V1TaskRuntime, error)

+ func (q *Queries) RegisterBatch(ctx context.Context, db DBTX, id []int64) *RegisterBatchBatchResults

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

+ func (q *Queries) ReleaseTasks(ctx context.Context, db DBTX, arg ReleaseTasksParams) ([]*ReleaseTasksRow, error)

+ func (q *Queries) ReplayTasks(ctx context.Context, db DBTX, arg ReplayTasksParams) ([]*V1Task, error)

+ func (q *Queries) RequeueRateLimitedQueueItems(ctx context.Context, db DBTX, arg RequeueRateLimitedQueueItemsParams) ([]*RequeueRateLimitedQueueItemsRow, error)

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

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

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

+ func (q *Queries) RunCancelInProgress(ctx context.Context, db DBTX, arg RunCancelInProgressParams) ([]*RunCancelInProgressRow, error)

+ func (q *Queries) RunCancelNewest(ctx context.Context, db DBTX, arg RunCancelNewestParams) ([]*RunCancelNewestRow, error)

+ func (q *Queries) RunChildCancelInProgress(ctx context.Context, db DBTX, arg RunChildCancelInProgressParams) ([]*RunChildCancelInProgressRow, error)

+ func (q *Queries) RunChildCancelNewest(ctx context.Context, db DBTX, arg RunChildCancelNewestParams) ([]*RunChildCancelNewestRow, error)

+ func (q *Queries) RunChildGroupRoundRobin(ctx context.Context, db DBTX, arg RunChildGroupRoundRobinParams) ([]*RunChildGroupRoundRobinRow, error)

+ func (q *Queries) RunGroupRoundRobin(ctx context.Context, db DBTX, arg RunGroupRoundRobinParams) ([]*RunGroupRoundRobinRow, error)

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

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

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

+ func (q *Queries) SaveSatisfiedMatchConditions(ctx context.Context, db DBTX, matchids []int64) ([]*SaveSatisfiedMatchConditionsRow, 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) SetConcurrencyStrategyInactive(ctx context.Context, db DBTX, arg SetConcurrencyStrategyInactiveParams) 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) SoftDeleteWorkflow(ctx context.Context, db DBTX, id pgtype.UUID) (*Workflow, error)

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

+ func (q *Queries) SwapV1PayloadOLAPPartitionWithTemp(ctx context.Context, db DBTX, date pgtype.Date) error

+ func (q *Queries) SwapV1PayloadPartitionWithTemp(ctx context.Context, db DBTX, date pgtype.Date) error

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

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

+ func (q *Queries) UpdateDAGStatuses(ctx context.Context, db DBTX, arg UpdateDAGStatusesParams) ([]*UpdateDAGStatusesRow, error)

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

+ func (q *Queries) UpdateFilter(ctx context.Context, db DBTX, arg UpdateFilterParams) (*V1Filter, 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) UpdateTaskStatuses(ctx context.Context, db DBTX, arg UpdateTaskStatusesParams) ([]*UpdateTaskStatusesRow, error)

+ func (q *Queries) UpdateTasksToAssigned(ctx context.Context, db DBTX, arg UpdateTasksToAssignedParams) ([]*UpdateTasksToAssignedRow, 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) UpdateWebhookExpression(ctx context.Context, db DBTX, arg UpdateWebhookExpressionParams) (*V1IncomingWebhook, 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) UpdateWorkflow(ctx context.Context, db DBTX, arg UpdateWorkflowParams) (*Workflow, error)

+ func (q *Queries) UpdateWorkflowConcurrencyWithChildStrategyIds(ctx context.Context, db DBTX, ...) 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) UpsertInterval(ctx context.Context, db DBTX, arg UpsertIntervalParams) (*V1OperationIntervalSettings, error)

+ func (q *Queries) UpsertMessageQueue(ctx context.Context, db DBTX, arg UpsertMessageQueueParams) (*MessageQueue, error)

+ func (q *Queries) UpsertQueues(ctx context.Context, db DBTX, arg UpsertQueuesParams) 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) WorkerPartitionHeartbeat(ctx context.Context, db DBTX, workerpartitionid string) (*TenantWorkerPartition, error)

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

+ Key string

+ LastRefill pgtype.Timestamp

+ LimitValue int32

+ TenantId pgtype.UUID

+ Value int32

+ Window string

+ type ReadIntervalParams struct

+ Operationid string

+ Tenantid pgtype.UUID

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

+ Externalids []pgtype.UUID

+ Tenantid pgtype.UUID

+ type ReadPayloadsParams struct

+ Ids []int64

+ Insertedats []pgtype.Timestamptz

+ Tenantids []pgtype.UUID

+ Types []string

+ type ReadTaskByExternalIDRow struct

+ ActionID string

+ AdditionalMetadata []byte

+ DagID pgtype.Int8

+ DagInsertedAt pgtype.Timestamptz

+ DesiredWorkerID pgtype.UUID

+ DisplayName string

+ ErrorMessage pgtype.Text

+ EventExternalID pgtype.UUID

+ ExternalID pgtype.UUID

+ ID int64

+ Input []byte

+ InsertedAt pgtype.Timestamptz

+ LatestRetryCount int32

+ LatestWorkerID pgtype.UUID

+ Output []byte

+ ParentTaskExternalID pgtype.UUID

+ Priority pgtype.Int4

+ Queue string

+ ReadableStatus V1ReadableStatusOlap

+ ScheduleTimeout string

+ StepID pgtype.UUID

+ StepTimeout pgtype.Text

+ Sticky V1StickyStrategyOlap

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

+ WorkflowRunID pgtype.UUID

+ WorkflowVersionID pgtype.UUID

+ type ReadWorkflowRunByExternalIdRow struct

+ AdditionalMetadata []byte

+ CreatedAt pgtype.Timestamptz

+ DagID pgtype.Int8

+ DisplayName string

+ ErrorMessage pgtype.Text

+ ExternalID pgtype.UUID

+ FinishedAt pgtype.Timestamptz

+ ID int64

+ Input []byte

+ InsertedAt pgtype.Timestamptz

+ Kind V1RunKind

+ ParentTaskExternalID pgtype.UUID

+ ReadableStatus V1ReadableStatusOlap

+ StartedAt pgtype.Timestamptz

+ TaskID pgtype.Int8

+ TaskMetadata []byte

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

+ WorkflowVersionID pgtype.UUID

+ type RefreshTimeoutByParams struct

+ Externalid pgtype.UUID

+ IncrementTimeoutBy pgtype.Text

+ Tenantid pgtype.UUID

+ type RegisterBatchBatchResults struct

+ func (b *RegisterBatchBatchResults) Close() error

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

+ type ReleaseTasksParams struct

+ Retrycounts []int32

+ Taskids []int64

+ Taskinsertedats []pgtype.Timestamptz

+ type ReleaseTasksRow struct

+ ConcurrencyStrategyIds []int64

+ ExternalID pgtype.UUID

+ ID int64

+ InsertedAt pgtype.Timestamptz

+ IsCurrentRetry bool

+ Queue string

+ RetryCount int32

+ StepReadableID string

+ WorkerID pgtype.UUID

+ WorkflowRunID pgtype.UUID

+ type ReplayTasksParams struct

+ Concurrencykeys [][]string

+ InitialStateReasons []pgtype.Text

+ InitialStates []string

+ Inputs [][]byte

+ Taskids []int64

+ Taskinsertedats []pgtype.Timestamptz

+ type RequeueRateLimitedQueueItemsParams struct

+ Queue string

+ Tenantid pgtype.UUID

+ type RequeueRateLimitedQueueItemsRow struct

+ ID int64

+ RetryCount int32

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ TenantID pgtype.UUID

+ type ResetMatchConditionsParams struct

+ Conditionids []int64

+ Datas [][]byte

+ Matchids []int64

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

+ ID int64

+ IsQueued bool

+ RetryAfter pgtype.Timestamp

+ StepRunId pgtype.UUID

+ TenantId pgtype.UUID

+ type RunCancelInProgressParams struct

+ Maxruns int32

+ Strategyid int64

+ Tenantid pgtype.UUID

+ type RunCancelInProgressRow struct

+ ExternalID pgtype.UUID

+ NextStrategyIds []int64

+ Operation string

+ QueueToNotify string

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ TaskRetryCount int32

+ TenantID pgtype.UUID

+ WorkflowRunID pgtype.UUID

+ type RunCancelNewestParams struct

+ Maxruns int32

+ Strategyid int64

+ Tenantid pgtype.UUID

+ type RunCancelNewestRow struct

+ ExternalID pgtype.UUID

+ NextStrategyIds []int64

+ Operation string

+ QueueToNotify string

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ TaskRetryCount int32

+ TenantID pgtype.UUID

+ WorkflowRunID pgtype.UUID

+ type RunChildCancelInProgressParams struct

+ Maxruns int32

+ Strategyid int64

+ Tenantid pgtype.UUID

+ type RunChildCancelInProgressRow struct

+ ExternalID pgtype.UUID

+ IsFilled bool

+ Key string

+ NextKeys []string

+ NextParentStrategyIds []pgtype.Int8

+ NextStrategyIds []int64

+ Operation string

+ ParentStrategyID pgtype.Int8

+ Priority int32

+ QueueToNotify string

+ ScheduleTimeoutAt pgtype.Timestamp

+ SortID pgtype.Int8

+ StrategyID int64

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ TaskRetryCount int32

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

+ WorkflowRunID pgtype.UUID

+ WorkflowVersionID pgtype.UUID

+ type RunChildCancelNewestParams struct

+ Maxruns int32

+ Strategyid int64

+ Tenantid pgtype.UUID

+ type RunChildCancelNewestRow struct

+ ExternalID pgtype.UUID

+ IsFilled bool

+ Key string

+ NextKeys []string

+ NextParentStrategyIds []pgtype.Int8

+ NextStrategyIds []int64

+ Operation string

+ ParentStrategyID pgtype.Int8

+ Priority int32

+ QueueToNotify string

+ ScheduleTimeoutAt pgtype.Timestamp

+ SortID pgtype.Int8

+ StrategyID int64

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ TaskRetryCount int32

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

+ WorkflowRunID pgtype.UUID

+ WorkflowVersionID pgtype.UUID

+ type RunChildGroupRoundRobinParams struct

+ Parentstrategyid int64

+ Strategyid int64

+ Tenantid pgtype.UUID

+ type RunChildGroupRoundRobinRow struct

+ ExternalID pgtype.UUID

+ IsFilled bool

+ Key string

+ NextKeys []string

+ NextParentStrategyIds []pgtype.Int8

+ NextStrategyIds []int64

+ Operation string

+ ParentStrategyID pgtype.Int8

+ Priority int32

+ QueueToNotify string

+ ScheduleTimeoutAt pgtype.Timestamp

+ SortID pgtype.Int8

+ StrategyID int64

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ TaskRetryCount int32

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

+ WorkflowRunID pgtype.UUID

+ WorkflowVersionID pgtype.UUID

+ type RunGroupRoundRobinParams struct

+ Maxruns int32

+ Strategyid int64

+ Tenantid pgtype.UUID

+ type RunGroupRoundRobinRow struct

+ ExternalID pgtype.UUID

+ NextStrategyIds []int64

+ Operation string

+ QueueToNotify string

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ TaskRetryCount int32

+ TenantID pgtype.UUID

+ WorkflowRunID pgtype.UUID

+ type RunParentCancelInProgressParams struct

+ Maxruns int32

+ Strategyid int64

+ Tenantid pgtype.UUID

+ type RunParentCancelNewestParams struct

+ Maxruns int32

+ Strategyid int64

+ Tenantid pgtype.UUID

+ type RunParentGroupRoundRobinParams struct

+ Maxruns int32

+ Strategyid int64

+ Tenantid pgtype.UUID

+ type SNSIntegration struct

+ CreatedAt pgtype.Timestamp

+ ID pgtype.UUID

+ TenantId pgtype.UUID

+ TopicArn string

+ UpdatedAt pgtype.Timestamp

+ type SaveSatisfiedMatchConditionsRow struct

+ Action V1MatchConditionAction

+ ExistingData []byte

+ ID int64

+ IsSatisfied bool

+ Kind V1MatchKind

+ McAggregatedData []byte

+ SignalExternalID pgtype.UUID

+ SignalKey pgtype.Text

+ SignalTaskID pgtype.Int8

+ SignalTaskInsertedAt pgtype.Timestamptz

+ TenantID pgtype.UUID

+ TriggerChildIndex pgtype.Int8

+ TriggerChildKey pgtype.Text

+ TriggerDagID pgtype.Int8

+ TriggerDagInsertedAt pgtype.Timestamptz

+ TriggerExistingTaskID pgtype.Int8

+ TriggerExistingTaskInsertedAt pgtype.Timestamptz

+ TriggerExternalID pgtype.UUID

+ TriggerParentTaskExternalID pgtype.UUID

+ TriggerParentTaskID pgtype.Int8

+ TriggerParentTaskInsertedAt pgtype.Timestamptz

+ TriggerPriority pgtype.Int4

+ TriggerStepID pgtype.UUID

+ TriggerStepIndex pgtype.Int8

+ TriggerWorkflowRunID pgtype.UUID

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

+ Stepid pgtype.UUID

+ Strategyid int64

+ Workflowid pgtype.UUID

+ Workflowversionid pgtype.UUID

+ type SetDispatchersInactiveRow struct

+ Dispatcher Dispatcher

+ type SetTickersInactiveRow struct

+ Ticker Ticker

+ type SlackAppWebhook struct

+ ChannelId string

+ ChannelName string

+ CreatedAt pgtype.Timestamp

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ TeamId string

+ TeamName string

+ TenantId pgtype.UUID

+ UpdatedAt pgtype.Timestamp

+ WebhookURL []byte

+ type Step struct

+ ActionId string

+ CreatedAt pgtype.Timestamp

+ CustomUserData []byte

+ DeletedAt pgtype.Timestamp

+ ID pgtype.UUID

+ JobId pgtype.UUID

+ ReadableId pgtype.Text

+ Retries int32

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

+ Errors []string

+ Sources []string

+ Tenantid pgtype.UUID

+ 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

+ Environment NullTenantEnvironment

+ ID pgtype.UUID

+ Name string

+ OnboardingData []byte

+ SchedulerPartitionId pgtype.Text

+ Slug string

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

+ const TenantEnvironmentDevelopment

+ const TenantEnvironmentLocal

+ const TenantEnvironmentProduction

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

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

+ ChildStrategyIds []int64

+ CompletedChildStrategyIds []int64

+ IsFilled bool

+ Key string

+ Priority int32

+ SortID int64

+ StrategyID int64

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

+ WorkflowRunID pgtype.UUID

+ WorkflowVersionID pgtype.UUID

+ type UpdateCronTriggerParams struct

+ Crontriggerid pgtype.UUID

+ Enabled pgtype.Bool

+ type UpdateDAGStatusesParams struct

+ Eventlimit int32

+ Mininsertedat pgtype.Timestamptz

+ Partitionnumber int32

+ Tenantids []pgtype.UUID

+ type UpdateDAGStatusesRow struct

+ Count int64

+ ExternalID pgtype.UUID

+ ID int64

+ InsertedAt pgtype.Timestamptz

+ ReadableStatus V1ReadableStatusOlap

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

+ type UpdateDispatcherParams struct

+ ID pgtype.UUID

+ LastHeartbeatAt pgtype.Timestamp

+ type UpdateFilterParams struct

+ Expression pgtype.Text

+ ID pgtype.UUID

+ Payload []byte

+ Scope pgtype.Text

+ Tenantid pgtype.UUID

+ type UpdateScheduledWorkflowParams struct

+ Scheduleid pgtype.UUID

+ Triggerat pgtype.Timestamp

+ type UpdateTaskStatusesParams struct

+ Eventlimit int32

+ Mininsertedat pgtype.Timestamptz

+ Partitionnumber int32

+ Tenantids []pgtype.UUID

+ type UpdateTaskStatusesRow struct

+ Count int64

+ ExternalID pgtype.UUID

+ ID int64

+ InsertedAt pgtype.Timestamptz

+ IsDagTask bool

+ LatestWorkerID pgtype.UUID

+ ReadableStatus V1ReadableStatusOlap

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

+ type UpdateTasksToAssignedParams struct

+ Mintaskinsertedat pgtype.Timestamptz

+ Taskids []int64

+ Taskinsertedats []pgtype.Timestamptz

+ Tenantid pgtype.UUID

+ Workerids []pgtype.UUID

+ type UpdateTasksToAssignedRow struct

+ TaskID int64

+ 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

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

+ Eventkeyexpression string

+ Tenantid pgtype.UUID

+ Webhookname string

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

+ Childstrategyids []int64

+ Workflowconcurrencyid int64

+ Workflowid pgtype.UUID

+ Workflowversionid pgtype.UUID

+ type UpdateWorkflowParams struct

+ ID pgtype.UUID

+ IsPaused pgtype.Bool

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

+ Intervalnanoseconds int64

+ Operationid string

+ Tenantid pgtype.UUID

+ type UpsertMessageQueueParams struct

+ Autodeleted bool

+ Durable bool

+ Exclusive bool

+ ExclusiveConsumerId pgtype.UUID

+ Name string

+ type UpsertQueuesParams struct

+ Names []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 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 V1CelEvaluationFailureSource string

+ const V1CelEvaluationFailureSourceFILTER

+ const V1CelEvaluationFailureSourceWEBHOOK

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

+ type V1CelEvaluationFailuresOlap struct

+ Error string

+ ID int64

+ InsertedAt pgtype.Timestamptz

+ Source V1CelEvaluationFailureSource

+ TenantID pgtype.UUID

+ UpdatedAt pgtype.Timestamptz

+ type V1ConcurrencySlot struct

+ ExternalID pgtype.UUID

+ IsFilled bool

+ Key string

+ NextKeys []string

+ NextParentStrategyIds []int64

+ NextStrategyIds []int64

+ ParentStrategyID pgtype.Int8

+ Priority int32

+ QueueToNotify string

+ ScheduleTimeoutAt pgtype.Timestamp

+ SortID pgtype.Int8

+ StrategyID int64

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ TaskRetryCount int32

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

+ WorkflowRunID pgtype.UUID

+ WorkflowVersionID pgtype.UUID

+ type V1ConcurrencyStrategy string

+ const V1ConcurrencyStrategyCANCELINPROGRESS

+ const V1ConcurrencyStrategyCANCELNEWEST

+ const V1ConcurrencyStrategyGROUPROUNDROBIN

+ const V1ConcurrencyStrategyNONE

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

+ type V1Dag struct

+ DisplayName string

+ ExternalID pgtype.UUID

+ ID int64

+ InsertedAt pgtype.Timestamptz

+ ParentTaskExternalID pgtype.UUID

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

+ WorkflowVersionID pgtype.UUID

+ type V1DagData struct

+ AdditionalMetadata []byte

+ DagID int64

+ DagInsertedAt pgtype.Timestamptz

+ Input []byte

+ type V1DagToTask struct

+ DagID int64

+ DagInsertedAt pgtype.Timestamptz

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ type V1DagToTaskOlap struct

+ DagID int64

+ DagInsertedAt pgtype.Timestamptz

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ type V1DagsOlap struct

+ AdditionalMetadata []byte

+ DisplayName string

+ ExternalID pgtype.UUID

+ ID int64

+ Input []byte

+ InsertedAt pgtype.Timestamptz

+ ParentTaskExternalID pgtype.UUID

+ ReadableStatus V1ReadableStatusOlap

+ TenantID pgtype.UUID

+ TotalTasks int32

+ WorkflowID pgtype.UUID

+ WorkflowVersionID pgtype.UUID

+ type V1DurableSleep struct

+ ID int64

+ SleepDuration string

+ SleepUntil pgtype.Timestamptz

+ TenantID pgtype.UUID

+ type V1EventLookupTableOlap struct

+ EventID int64

+ EventSeenAt pgtype.Timestamptz

+ ExternalID pgtype.UUID

+ TenantID pgtype.UUID

+ type V1EventToRunOlap struct

+ EventID int64

+ EventSeenAt pgtype.Timestamptz

+ FilterID pgtype.UUID

+ RunID int64

+ RunInsertedAt pgtype.Timestamptz

+ type V1EventType string

+ const V1EventTypeINTERNAL

+ const V1EventTypeUSER

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

+ type V1EventTypeOlap string

+ const V1EventTypeOlapACKNOWLEDGED

+ const V1EventTypeOlapASSIGNED

+ const V1EventTypeOlapCANCELLED

+ const V1EventTypeOlapCOULDNOTSENDTOWORKER

+ const V1EventTypeOlapCREATED

+ const V1EventTypeOlapFAILED

+ const V1EventTypeOlapFINISHED

+ const V1EventTypeOlapQUEUED

+ const V1EventTypeOlapRATELIMITERROR

+ const V1EventTypeOlapREASSIGNED

+ const V1EventTypeOlapREQUEUEDNOWORKER

+ const V1EventTypeOlapREQUEUEDRATELIMIT

+ const V1EventTypeOlapRETRIEDBYUSER

+ const V1EventTypeOlapRETRYING

+ const V1EventTypeOlapSCHEDULINGTIMEDOUT

+ const V1EventTypeOlapSENTTOWORKER

+ const V1EventTypeOlapSKIPPED

+ const V1EventTypeOlapSLOTRELEASED

+ const V1EventTypeOlapSTARTED

+ const V1EventTypeOlapTIMEDOUT

+ const V1EventTypeOlapTIMEOUTREFRESHED

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

+ type V1EventsOlap struct

+ AdditionalMetadata []byte

+ ExternalID pgtype.UUID

+ ID int64

+ Key string

+ Payload []byte

+ Scope pgtype.Text

+ SeenAt pgtype.Timestamptz

+ TenantID pgtype.UUID

+ TriggeringWebhookName pgtype.Text

+ type V1Filter struct

+ Expression string

+ ID pgtype.UUID

+ InsertedAt pgtype.Timestamptz

+ IsDeclarative bool

+ Payload []byte

+ PayloadHash pgtype.Text

+ Scope string

+ TenantID pgtype.UUID

+ UpdatedAt pgtype.Timestamptz

+ WorkflowID pgtype.UUID

+ type V1IdempotencyKey struct

+ ClaimedByExternalID pgtype.UUID

+ ExpiresAt pgtype.Timestamptz

+ InsertedAt pgtype.Timestamptz

+ Key string

+ TenantID pgtype.UUID

+ UpdatedAt pgtype.Timestamptz

+ type V1IncomingWebhook struct

+ AuthApiKeyHeaderName pgtype.Text

+ AuthApiKeyKey []byte

+ AuthBasicPassword []byte

+ AuthBasicUsername pgtype.Text

+ AuthHmacAlgorithm NullV1IncomingWebhookHmacAlgorithm

+ AuthHmacEncoding NullV1IncomingWebhookHmacEncoding

+ AuthHmacSignatureHeaderName pgtype.Text

+ AuthHmacWebhookSigningSecret []byte

+ AuthMethod V1IncomingWebhookAuthType

+ EventKeyExpression string

+ InsertedAt pgtype.Timestamptz

+ Name string

+ SourceName V1IncomingWebhookSourceName

+ TenantID pgtype.UUID

+ UpdatedAt pgtype.Timestamptz

+ type V1IncomingWebhookAuthType string

+ const V1IncomingWebhookAuthTypeAPIKEY

+ const V1IncomingWebhookAuthTypeBASIC

+ const V1IncomingWebhookAuthTypeHMAC

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

+ type V1IncomingWebhookHmacAlgorithm string

+ const V1IncomingWebhookHmacAlgorithmMD5

+ const V1IncomingWebhookHmacAlgorithmSHA1

+ const V1IncomingWebhookHmacAlgorithmSHA256

+ const V1IncomingWebhookHmacAlgorithmSHA512

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

+ type V1IncomingWebhookHmacEncoding string

+ const V1IncomingWebhookHmacEncodingBASE64

+ const V1IncomingWebhookHmacEncodingBASE64URL

+ const V1IncomingWebhookHmacEncodingHEX

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

+ type V1IncomingWebhookSourceName string

+ const V1IncomingWebhookSourceNameGENERIC

+ const V1IncomingWebhookSourceNameGITHUB

+ const V1IncomingWebhookSourceNameLINEAR

+ const V1IncomingWebhookSourceNameSLACK

+ const V1IncomingWebhookSourceNameSTRIPE

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

+ type V1IncomingWebhookValidationFailuresOlap struct

+ Error string

+ ID int64

+ IncomingWebhookName string

+ InsertedAt pgtype.Timestamptz

+ TenantID pgtype.UUID

+ UpdatedAt pgtype.Timestamptz

+ type V1LogLine struct

+ CreatedAt pgtype.Timestamptz

+ ID int64

+ Level V1LogLineLevel

+ Message string

+ Metadata []byte

+ RetryCount int32

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ TenantID pgtype.UUID

+ type V1LogLineLevel string

+ const V1LogLineLevelDEBUG

+ const V1LogLineLevelERROR

+ const V1LogLineLevelINFO

+ const V1LogLineLevelWARN

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

+ type V1LookupTable struct

+ DagID pgtype.Int8

+ ExternalID pgtype.UUID

+ InsertedAt pgtype.Timestamptz

+ TaskID pgtype.Int8

+ TenantID pgtype.UUID

+ type V1LookupTableOlap struct

+ DagID pgtype.Int8

+ ExternalID pgtype.UUID

+ InsertedAt pgtype.Timestamptz

+ TaskID pgtype.Int8

+ TenantID pgtype.UUID

+ type V1Match struct

+ ExistingData []byte

+ ID int64

+ IsSatisfied bool

+ Kind V1MatchKind

+ SignalExternalID pgtype.UUID

+ SignalKey pgtype.Text

+ SignalTaskID pgtype.Int8

+ SignalTaskInsertedAt pgtype.Timestamptz

+ TenantID pgtype.UUID

+ TriggerChildIndex pgtype.Int8

+ TriggerChildKey pgtype.Text

+ TriggerDagID pgtype.Int8

+ TriggerDagInsertedAt pgtype.Timestamptz

+ TriggerExistingTaskID pgtype.Int8

+ TriggerExistingTaskInsertedAt pgtype.Timestamptz

+ TriggerExternalID pgtype.UUID

+ TriggerParentTaskExternalID pgtype.UUID

+ TriggerParentTaskID pgtype.Int8

+ TriggerParentTaskInsertedAt pgtype.Timestamptz

+ TriggerPriority pgtype.Int4

+ TriggerStepID pgtype.UUID

+ TriggerStepIndex pgtype.Int8

+ TriggerWorkflowRunID pgtype.UUID

+ type V1MatchCondition struct

+ Action V1MatchConditionAction

+ Data []byte

+ EventKey string

+ EventResourceHint pgtype.Text

+ EventType V1EventType

+ Expression pgtype.Text

+ ID int64

+ IsSatisfied bool

+ OrGroupID pgtype.UUID

+ ReadableDataKey string

+ RegisteredAt pgtype.Timestamptz

+ TenantID pgtype.UUID

+ V1MatchID int64

+ type V1MatchConditionAction string

+ const V1MatchConditionActionCANCEL

+ const V1MatchConditionActionCREATE

+ const V1MatchConditionActionCREATEMATCH

+ const V1MatchConditionActionQUEUE

+ const V1MatchConditionActionSKIP

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

+ type V1MatchKind string

+ const V1MatchKindSIGNAL

+ const V1MatchKindTRIGGER

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

+ type V1OperationIntervalSettings struct

+ IntervalNanoseconds int64

+ OperationID string

+ TenantID pgtype.UUID

+ type V1Payload struct

+ ExternalID pgtype.UUID

+ ExternalLocationKey pgtype.Text

+ ID int64

+ InlineContent []byte

+ InsertedAt pgtype.Timestamptz

+ Location V1PayloadLocation

+ TenantID pgtype.UUID

+ Type V1PayloadType

+ UpdatedAt pgtype.Timestamptz

+ type V1PayloadCutoverJobOffset struct

+ IsCompleted bool

+ Key pgtype.Date

+ LastID int64

+ LastInsertedAt pgtype.Timestamptz

+ LastTenantID pgtype.UUID

+ LastType V1PayloadType

+ LeaseExpiresAt pgtype.Timestamptz

+ LeaseProcessID pgtype.UUID

+ type V1PayloadLocation string

+ const V1PayloadLocationEXTERNAL

+ const V1PayloadLocationINLINE

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

+ type V1PayloadLocationOlap string

+ const V1PayloadLocationOlapEXTERNAL

+ const V1PayloadLocationOlapINLINE

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

+ type V1PayloadType string

+ const V1PayloadTypeDAGINPUT

+ const V1PayloadTypeTASKEVENTDATA

+ const V1PayloadTypeTASKINPUT

+ const V1PayloadTypeTASKOUTPUT

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

+ type V1PayloadsOlap struct

+ ExternalID pgtype.UUID

+ ExternalLocationKey pgtype.Text

+ InlineContent []byte

+ InsertedAt pgtype.Timestamptz

+ Location V1PayloadLocationOlap

+ TenantID pgtype.UUID

+ UpdatedAt pgtype.Timestamptz

+ type V1PayloadsOlapCutoverJobOffset struct

+ IsCompleted bool

+ Key pgtype.Date

+ LastExternalID pgtype.UUID

+ LastInsertedAt pgtype.Timestamptz

+ LastTenantID pgtype.UUID

+ LeaseExpiresAt pgtype.Timestamptz

+ LeaseProcessID pgtype.UUID

+ type V1Queue struct

+ LastActive pgtype.Timestamp

+ Name string

+ TenantID pgtype.UUID

+ type V1QueueItem struct

+ ActionID string

+ DesiredWorkerID pgtype.UUID

+ ExternalID pgtype.UUID

+ ID int64

+ Priority int32

+ Queue string

+ RetryCount int32

+ ScheduleTimeoutAt pgtype.Timestamp

+ StepID pgtype.UUID

+ StepTimeout pgtype.Text

+ Sticky V1StickyStrategy

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

+ WorkflowRunID pgtype.UUID

+ type V1RateLimitedQueueItems struct

+ ActionID string

+ DesiredWorkerID pgtype.UUID

+ ExternalID pgtype.UUID

+ Priority int32

+ Queue string

+ RequeueAfter pgtype.Timestamptz

+ RetryCount int32

+ ScheduleTimeoutAt pgtype.Timestamp

+ StepID pgtype.UUID

+ StepTimeout pgtype.Text

+ Sticky V1StickyStrategy

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

+ WorkflowRunID pgtype.UUID

+ type V1ReadableStatusOlap string

+ const V1ReadableStatusOlapCANCELLED

+ const V1ReadableStatusOlapCOMPLETED

+ const V1ReadableStatusOlapFAILED

+ const V1ReadableStatusOlapQUEUED

+ const V1ReadableStatusOlapRUNNING

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

+ type V1RetryQueueItem struct

+ RetryAfter pgtype.Timestamptz

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ TaskRetryCount int32

+ TenantID pgtype.UUID

+ type V1RunKind string

+ const V1RunKindDAG

+ const V1RunKindTASK

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

+ type V1RunsOlap struct

+ AdditionalMetadata []byte

+ ExternalID pgtype.UUID

+ ID int64

+ InsertedAt pgtype.Timestamptz

+ Kind V1RunKind

+ ParentTaskExternalID pgtype.UUID

+ ReadableStatus V1ReadableStatusOlap

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

+ WorkflowVersionID pgtype.UUID

+ type V1StatusKind string

+ const V1StatusKindDAG

+ const V1StatusKindTASK

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

+ type V1StatusesOlap struct

+ ExternalID pgtype.UUID

+ InsertedAt pgtype.Timestamptz

+ Kind V1RunKind

+ ReadableStatus V1ReadableStatusOlap

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

+ type V1StepConcurrency struct

+ Expression string

+ ID int64

+ IsActive bool

+ MaxConcurrency int32

+ ParentStrategyID pgtype.Int8

+ StepID pgtype.UUID

+ Strategy V1ConcurrencyStrategy

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

+ WorkflowVersionID pgtype.UUID

+ type V1StepMatchCondition struct

+ Action V1MatchConditionAction

+ EventKey pgtype.Text

+ Expression pgtype.Text

+ ID int64

+ Kind V1StepMatchConditionKind

+ OrGroupID pgtype.UUID

+ ParentReadableID pgtype.Text

+ ReadableDataKey string

+ SleepDuration pgtype.Text

+ StepID pgtype.UUID

+ TenantID pgtype.UUID

+ type V1StepMatchConditionKind string

+ const V1StepMatchConditionKindPARENTOVERRIDE

+ const V1StepMatchConditionKindSLEEP

+ const V1StepMatchConditionKindUSEREVENT

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

+ type V1StickyStrategy string

+ const V1StickyStrategyHARD

+ const V1StickyStrategyNONE

+ const V1StickyStrategySOFT

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

+ type V1StickyStrategyOlap string

+ const V1StickyStrategyOlapHARD

+ const V1StickyStrategyOlapNONE

+ const V1StickyStrategyOlapSOFT

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

+ type V1Task struct

+ ActionID string

+ AdditionalMetadata []byte

+ AppRetryCount int32

+ ChildIndex pgtype.Int8

+ ChildKey pgtype.Text

+ ConcurrencyKeys []string

+ ConcurrencyParentStrategyIds []pgtype.Int8

+ ConcurrencyStrategyIds []int64

+ DagID pgtype.Int8

+ DagInsertedAt pgtype.Timestamptz

+ DesiredWorkerID pgtype.UUID

+ DisplayName string

+ ExternalID pgtype.UUID

+ ID int64

+ InitialState V1TaskInitialState

+ InitialStateReason pgtype.Text

+ Input []byte

+ InsertedAt pgtype.Timestamptz

+ InternalRetryCount int32

+ ParentTaskExternalID pgtype.UUID

+ ParentTaskID pgtype.Int8

+ ParentTaskInsertedAt pgtype.Timestamptz

+ Priority pgtype.Int4

+ Queue string

+ RetryBackoffFactor pgtype.Float8

+ RetryCount int32

+ RetryMaxBackoff pgtype.Int4

+ ScheduleTimeout string

+ StepID pgtype.UUID

+ StepIndex int64

+ StepReadableID string

+ StepTimeout pgtype.Text

+ Sticky V1StickyStrategy

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

+ WorkflowRunID pgtype.UUID

+ WorkflowVersionID pgtype.UUID

+ type V1TaskEvent struct

+ CreatedAt pgtype.Timestamp

+ Data []byte

+ EventKey pgtype.Text

+ EventType V1TaskEventType

+ ExternalID pgtype.UUID

+ ID int64

+ InsertedAt pgtype.Timestamptz

+ RetryCount int32

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ TenantID pgtype.UUID

+ type V1TaskEventType string

+ const V1TaskEventTypeCANCELLED

+ const V1TaskEventTypeCOMPLETED

+ const V1TaskEventTypeFAILED

+ const V1TaskEventTypeSIGNALCOMPLETED

+ const V1TaskEventTypeSIGNALCREATED

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

+ type V1TaskEventsOlap struct

+ AdditionalEventData pgtype.Text

+ AdditionalEventMessage pgtype.Text

+ ErrorMessage pgtype.Text

+ EventTimestamp pgtype.Timestamptz

+ EventType V1EventTypeOlap

+ ExternalID pgtype.UUID

+ ID int64

+ InsertedAt pgtype.Timestamptz

+ Output []byte

+ ReadableStatus V1ReadableStatusOlap

+ RetryCount int32

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ TenantID pgtype.UUID

+ WorkerID pgtype.UUID

+ WorkflowID pgtype.UUID

+ type V1TaskEventsOlapTmp struct

+ EventType V1EventTypeOlap

+ ID int64

+ ReadableStatus V1ReadableStatusOlap

+ RequeueAfter pgtype.Timestamptz

+ RequeueRetries int32

+ RetryCount int32

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ TenantID pgtype.UUID

+ WorkerID pgtype.UUID

+ type V1TaskExpressionEval struct

+ Key string

+ Kind StepExpressionKind

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ ValueInt pgtype.Int4

+ ValueStr pgtype.Text

+ type V1TaskInitialState string

+ const V1TaskInitialStateCANCELLED

+ const V1TaskInitialStateFAILED

+ const V1TaskInitialStateQUEUED

+ const V1TaskInitialStateSKIPPED

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

+ type V1TaskRuntime struct

+ RetryCount int32

+ TaskID int64

+ TaskInsertedAt pgtype.Timestamptz

+ TenantID pgtype.UUID

+ TimeoutAt pgtype.Timestamp

+ WorkerID pgtype.UUID

+ type V1TaskStatusUpdatesTmp struct

+ DagID int64

+ DagInsertedAt pgtype.Timestamptz

+ ID int64

+ RequeueAfter pgtype.Timestamptz

+ RequeueRetries int32

+ TenantID pgtype.UUID

+ type V1TasksOlap struct

+ ActionID string

+ AdditionalMetadata []byte

+ DagID pgtype.Int8

+ DagInsertedAt pgtype.Timestamptz

+ DesiredWorkerID pgtype.UUID

+ DisplayName string

+ ExternalID pgtype.UUID

+ ID int64

+ Input []byte

+ InsertedAt pgtype.Timestamptz

+ LatestRetryCount int32

+ LatestWorkerID pgtype.UUID

+ ParentTaskExternalID pgtype.UUID

+ Priority pgtype.Int4

+ Queue string

+ ReadableStatus V1ReadableStatusOlap

+ ScheduleTimeout string

+ StepID pgtype.UUID

+ StepTimeout pgtype.Text

+ Sticky V1StickyStrategyOlap

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

+ WorkflowRunID pgtype.UUID

+ WorkflowVersionID pgtype.UUID

+ type V1WorkflowConcurrency struct

+ ChildStrategyIds []int64

+ Expression string

+ ID int64

+ IsActive bool

+ MaxConcurrency int32

+ Strategy V1ConcurrencyStrategy

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

+ WorkflowVersionID pgtype.UUID

+ type V1WorkflowConcurrencySlot struct

+ ChildStrategyIds []int64

+ CompletedChildStrategyIds []int64

+ IsFilled bool

+ Key string

+ Priority int32

+ SortID int64

+ StrategyID int64

+ TenantID pgtype.UUID

+ WorkflowID pgtype.UUID

+ WorkflowRunID pgtype.UUID

+ WorkflowVersionID pgtype.UUID

+ type VcsProvider string

+ const VcsProviderGITHUB

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

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

+ type WritePayloadsParams struct

+ Externalids []pgtype.UUID

+ Externallocationkeys []string

+ Ids []int64

+ Inlinecontents [][]byte

+ Insertedats []pgtype.Timestamptz

+ Locations []string

+ Tenantids []pgtype.UUID

+ Types []string

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