dbsqlc

package
v0.51.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 21, 2024 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

Types

type APIToken 

type APIToken struct {
	ID          pgtype.UUID      `json:"id"`
	CreatedAt   pgtype.Timestamp `json:"createdAt"`
	UpdatedAt   pgtype.Timestamp `json:"updatedAt"`
	ExpiresAt   pgtype.Timestamp `json:"expiresAt"`
	Revoked     bool             `json:"revoked"`
	Name        pgtype.Text      `json:"name"`
	TenantId    pgtype.UUID      `json:"tenantId"`
	NextAlertAt pgtype.Timestamp `json:"nextAlertAt"`
	Internal    bool             `json:"internal"`
}

type AcquireOrExtendLeasesParams added in v0.50.0 

type AcquireOrExtendLeasesParams struct {
	LeaseDuration    pgtype.Interval `json:"leaseDuration"`
	Tenantid         pgtype.UUID     `json:"tenantid"`
	Kind             LeaseKind       `json:"kind"`
	Resourceids      []string        `json:"resourceids"`
	Existingleaseids []int64         `json:"existingleaseids"`
}

type Action 

type Action struct {
	Description pgtype.Text `json:"description"`
	TenantId    pgtype.UUID `json:"tenantId"`
	ActionId    string      `json:"actionId"`
	ID          pgtype.UUID `json:"id"`
}

type ActionToWorker 

type ActionToWorker struct {
	B pgtype.UUID `json:"B"`
	A pgtype.UUID `json:"A"`
}

type AddStepParentsParams 

type AddStepParentsParams struct {
	ID      pgtype.UUID `json:"id"`
	Parents []string    `json:"parents"`
	Jobid   pgtype.UUID `json:"jobid"`
}

type AddWorkflowTagParams 

type AddWorkflowTagParams struct {
	ID   pgtype.UUID `json:"id"`
	Tags pgtype.UUID `json:"tags"`
}

type ArchiveStepRunResultFromStepRunParams 

type ArchiveStepRunResultFromStepRunParams struct {
	ID        pgtype.UUID `json:"id"`
	Error     pgtype.Text `json:"error"`
	Steprunid pgtype.UUID `json:"steprunid"`
	Tenantid  pgtype.UUID `json:"tenantid"`
}

type AssignGetGroupKeyRunToTickerParams 

type AssignGetGroupKeyRunToTickerParams struct {
	Getgroupkeyrunid pgtype.UUID `json:"getgroupkeyrunid"`
	Tenantid         pgtype.UUID `json:"tenantid"`
}

type AssignGetGroupKeyRunToTickerRow 

type AssignGetGroupKeyRunToTickerRow struct {
	ID       pgtype.UUID `json:"id"`
	TickerId pgtype.UUID `json:"tickerId"`
}

type AssignGetGroupKeyRunToWorkerParams 

type AssignGetGroupKeyRunToWorkerParams struct {
	Getgroupkeyrunid pgtype.UUID `json:"getgroupkeyrunid"`
	Tenantid         pgtype.UUID `json:"tenantid"`
}

type AssignGetGroupKeyRunToWorkerRow 

type AssignGetGroupKeyRunToWorkerRow struct {
	ID           pgtype.UUID `json:"id"`
	WorkerId     pgtype.UUID `json:"workerId"`
	DispatcherId pgtype.UUID `json:"dispatcherId"`
}

type BulkCancelStepRunParams added in v0.44.5 

type BulkCancelStepRunParams struct {
	Steprunids       []pgtype.UUID      `json:"steprunids"`
	Finishedats      []pgtype.Timestamp `json:"finishedats"`
	Cancelledats     []pgtype.Timestamp `json:"cancelledats"`
	Cancelledreasons []string           `json:"cancelledreasons"`
	Cancellederrors  []string           `json:"cancellederrors"`
}

type BulkCreateStepRunEventParams added in v0.42.0 

type BulkCreateStepRunEventParams struct {
	Timeseen   []pgtype.Timestamp `json:"timeseen"`
	Steprunids []pgtype.UUID      `json:"steprunids"`
	Reasons    []string           `json:"reasons"`
	Severities []string           `json:"severities"`
	Messages   []string           `json:"messages"`
	Data       [][]byte           `json:"data"`
}

type BulkCreateWorkflowRunEventParams added in v0.45.0 

type BulkCreateWorkflowRunEventParams struct {
	Timeseen       []pgtype.Timestamp `json:"timeseen"`
	Workflowrunids []pgtype.UUID      `json:"workflowrunids"`
	Reasons        []string           `json:"reasons"`
	Severities     []string           `json:"severities"`
	Messages       []string           `json:"messages"`
	Data           [][]byte           `json:"data"`
}

type BulkFailStepRunParams added in v0.44.5 

type BulkFailStepRunParams struct {
	Steprunids  []pgtype.UUID      `json:"steprunids"`
	Finishedats []pgtype.Timestamp `json:"finishedats"`
	Errors      []string           `json:"errors"`
}

type BulkFinishStepRunParams added in v0.44.5 

type BulkFinishStepRunParams struct {
	Steprunids  []pgtype.UUID      `json:"steprunids"`
	Finishedats []pgtype.Timestamp `json:"finishedats"`
	Outputs     [][]byte           `json:"outputs"`
}

type BulkStartStepRunParams added in v0.44.5 

type BulkStartStepRunParams struct {
	Steprunids []pgtype.UUID      `json:"steprunids"`
	Startedats []pgtype.Timestamp `json:"startedats"`
}

type BulkUpdateRateLimitsParams added in v0.42.0 

type BulkUpdateRateLimitsParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Keys     []string    `json:"keys"`
	Units    []int32     `json:"units"`
}

type CheckWorkerParams added in v0.40.0 

type CheckWorkerParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Workerid pgtype.UUID `json:"workerid"`
}

type CleanupInternalQueueItemsParams added in v0.44.0 

type CleanupInternalQueueItemsParams struct {
	Minid    int64       `json:"minid"`
	Maxid    int64       `json:"maxid"`
	Tenantid pgtype.UUID `json:"tenantid"`
}

type CleanupQueueItemsParams added in v0.43.2 

type CleanupQueueItemsParams struct {
	Minid    int64       `json:"minid"`
	Maxid    int64       `json:"maxid"`
	Tenantid pgtype.UUID `json:"tenantid"`
}

type CleanupTimeoutQueueItemsParams added in v0.44.5 

type CleanupTimeoutQueueItemsParams struct {
	Minid    int64       `json:"minid"`
	Maxid    int64       `json:"maxid"`
	Tenantid pgtype.UUID `json:"tenantid"`
}

type ClearEventPayloadDataParams added in v0.39.0 

type ClearEventPayloadDataParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Limit    interface{} `json:"limit"`
}

type ClearJobRunLookupDataParams added in v0.39.0 

type ClearJobRunLookupDataParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Limit    interface{} `json:"limit"`
}

type ClearStepRunPayloadDataParams added in v0.39.0 

type ClearStepRunPayloadDataParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Limit    interface{} `json:"limit"`
}

type ConcurrencyLimitStrategy 

type ConcurrencyLimitStrategy string
const (
	ConcurrencyLimitStrategyCANCELINPROGRESS ConcurrencyLimitStrategy = "CANCEL_IN_PROGRESS"
	ConcurrencyLimitStrategyDROPNEWEST       ConcurrencyLimitStrategy = "DROP_NEWEST"
	ConcurrencyLimitStrategyQUEUENEWEST      ConcurrencyLimitStrategy = "QUEUE_NEWEST"
	ConcurrencyLimitStrategyGROUPROUNDROBIN  ConcurrencyLimitStrategy = "GROUP_ROUND_ROBIN"
)

func (*ConcurrencyLimitStrategy) Scan 

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

type ControllerPartition added in v0.34.2 

type ControllerPartition struct {
	ID            string           `json:"id"`
	CreatedAt     pgtype.Timestamp `json:"createdAt"`
	UpdatedAt     pgtype.Timestamp `json:"updatedAt"`
	LastHeartbeat pgtype.Timestamp `json:"lastHeartbeat"`
	Name          pgtype.Text      `json:"name"`
}

type CountEventsParams 

type CountEventsParams struct {
	TenantId           pgtype.UUID   `json:"tenantId"`
	EventIds           []pgtype.UUID `json:"event_ids"`
	Keys               []string      `json:"keys"`
	AdditionalMetadata []byte        `json:"additionalMetadata"`
	Workflows          []string      `json:"workflows"`
	Search             pgtype.Text   `json:"search"`
	Statuses           []string      `json:"statuses"`
	Orderby            interface{}   `json:"orderby"`
}

type CountLogLinesParams 

type CountLogLinesParams struct {
	Tenantid  pgtype.UUID    `json:"tenantid"`
	StepRunId pgtype.UUID    `json:"stepRunId"`
	Search    pgtype.Text    `json:"search"`
	Levels    []LogLineLevel `json:"levels"`
}

type CountRateLimitsParams added in v0.47.0 

type CountRateLimitsParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Search   pgtype.Text `json:"search"`
	Orderby  interface{} `json:"orderby"`
}

type CountRoundRobinGroupKeysParams 

type CountRoundRobinGroupKeysParams struct {
	Tenantid   pgtype.UUID           `json:"tenantid"`
	Status     NullWorkflowRunStatus `json:"status"`
	Workflowid pgtype.UUID           `json:"workflowid"`
}

type CountScheduledWorkflowsParams added in v0.51.0 

type CountScheduledWorkflowsParams struct {
	Tenantid            pgtype.UUID `json:"tenantid"`
	Scheduleid          pgtype.UUID `json:"scheduleid"`
	Workflowid          pgtype.UUID `json:"workflowid"`
	Parentworkflowrunid pgtype.UUID `json:"parentworkflowrunid"`
	Parentsteprunid     pgtype.UUID `json:"parentsteprunid"`
	AdditionalMetadata  []byte      `json:"additionalMetadata"`
	Statuses            []string    `json:"statuses"`
	Includescheduled    bool        `json:"includescheduled"`
}

type CountWorkflowRunsParams 

type CountWorkflowRunsParams struct {
	TenantId           pgtype.UUID      `json:"tenantId"`
	EventId            pgtype.UUID      `json:"eventId"`
	WorkflowVersionId  pgtype.UUID      `json:"workflowVersionId"`
	Kinds              []string         `json:"kinds"`
	WorkflowId         pgtype.UUID      `json:"workflowId"`
	Ids                []pgtype.UUID    `json:"ids"`
	AdditionalMetadata []byte           `json:"additionalMetadata"`
	ParentId           pgtype.UUID      `json:"parentId"`
	ParentStepRunId    pgtype.UUID      `json:"parentStepRunId"`
	GroupKey           pgtype.Text      `json:"groupKey"`
	Statuses           []string         `json:"statuses"`
	CreatedAfter       pgtype.Timestamp `json:"createdAfter"`
	CreatedBefore      pgtype.Timestamp `json:"createdBefore"`
	FinishedAfter      pgtype.Timestamp `json:"finishedAfter"`
	FinishedBefore     pgtype.Timestamp `json:"finishedBefore"`
	Orderby            interface{}      `json:"orderby"`
}

type CountWorkflowRunsRoundRobinParams 

type CountWorkflowRunsRoundRobinParams struct {
	Tenantid   pgtype.UUID           `json:"tenantid"`
	Status     NullWorkflowRunStatus `json:"status"`
	Workflowid pgtype.UUID           `json:"workflowid"`
	GroupKey   pgtype.Text           `json:"groupKey"`
}

type CountWorkflowsParams 

type CountWorkflowsParams struct {
	TenantId pgtype.UUID `json:"tenantId"`
	EventKey pgtype.Text `json:"eventKey"`
}

type CreateAPITokenParams 

type CreateAPITokenParams struct {
	ID        pgtype.UUID      `json:"id"`
	TenantId  pgtype.UUID      `json:"tenantId"`
	Name      pgtype.Text      `json:"name"`
	Expiresat pgtype.Timestamp `json:"expiresat"`
	Internal  pgtype.Bool      `json:"internal"`
}

type CreateEventKeysParams added in v0.49.3 

type CreateEventKeysParams struct {
	Keys      []string      `json:"keys"`
	Tenantids []pgtype.UUID `json:"tenantids"`
}

type CreateEventParams 

type CreateEventParams struct {
	ID                 pgtype.UUID      `json:"id"`
	CreatedAt          pgtype.Timestamp `json:"createdAt"`
	UpdatedAt          pgtype.Timestamp `json:"updatedAt"`
	Deletedat          pgtype.Timestamp `json:"deletedat"`
	Key                string           `json:"key"`
	Tenantid           pgtype.UUID      `json:"tenantid"`
	ReplayedFromId     pgtype.UUID      `json:"replayedFromId"`
	Data               []byte           `json:"data"`
	Additionalmetadata []byte           `json:"additionalmetadata"`
}

type CreateEventsParams added in v0.46.0 

type CreateEventsParams struct {
	ID                 pgtype.UUID `json:"id"`
	Key                string      `json:"key"`
	TenantId           pgtype.UUID `json:"tenantId"`
	ReplayedFromId     pgtype.UUID `json:"replayedFromId"`
	Data               []byte      `json:"data"`
	AdditionalMetadata []byte      `json:"additionalMetadata"`
	InsertOrder        pgtype.Int4 `json:"insertOrder"`
}

type CreateGetGroupKeyRunParams 

type CreateGetGroupKeyRunParams struct {
	ID                pgtype.UUID      `json:"id"`
	Tenantid          pgtype.UUID      `json:"tenantid"`
	Workflowrunid     pgtype.UUID      `json:"workflowrunid"`
	Input             []byte           `json:"input"`
	Requeueafter      pgtype.Timestamp `json:"requeueafter"`
	Scheduletimeoutat pgtype.Timestamp `json:"scheduletimeoutat"`
}

type CreateGetGroupKeyRunsParams added in v0.50.0 

type CreateGetGroupKeyRunsParams struct {
	ID                pgtype.UUID      `json:"id"`
	TenantId          pgtype.UUID      `json:"tenantId"`
	WorkflowRunId     pgtype.UUID      `json:"workflowRunId"`
	Input             []byte           `json:"input"`
	RequeueAfter      pgtype.Timestamp `json:"requeueAfter"`
	ScheduleTimeoutAt pgtype.Timestamp `json:"scheduleTimeoutAt"`
	Status            StepRunStatus    `json:"status"`
}

type CreateInternalQueueItemsBulkParams added in v0.44.0 

type CreateInternalQueueItemsBulkParams struct {
	Queues    []string      `json:"queues"`
	Datas     [][]byte      `json:"datas"`
	Tenantids []pgtype.UUID `json:"tenantids"`
}

type CreateJobParams 

type CreateJobParams struct {
	ID                pgtype.UUID      `json:"id"`
	CreatedAt         pgtype.Timestamp `json:"createdAt"`
	UpdatedAt         pgtype.Timestamp `json:"updatedAt"`
	Deletedat         pgtype.Timestamp `json:"deletedat"`
	Tenantid          pgtype.UUID      `json:"tenantid"`
	Workflowversionid pgtype.UUID      `json:"workflowversionid"`
	Name              string           `json:"name"`
	Description       string           `json:"description"`
	Timeout           string           `json:"timeout"`
	Kind              NullJobKind      `json:"kind"`
}

type CreateJobRunLookupDataParams 

type CreateJobRunLookupDataParams struct {
	ID          pgtype.UUID `json:"id"`
	Jobrunid    pgtype.UUID `json:"jobrunid"`
	Tenantid    pgtype.UUID `json:"tenantid"`
	Input       []byte      `json:"input"`
	Triggeredby string      `json:"triggeredby"`
}

type CreateJobRunLookupDatasParams added in v0.50.0 

type CreateJobRunLookupDatasParams struct {
	Ids          []pgtype.UUID `json:"ids"`
	Jobrunids    []pgtype.UUID `json:"jobrunids"`
	Tenantids    []pgtype.UUID `json:"tenantids"`
	Triggeredbys []string      `json:"triggeredbys"`
	Inputs       [][]byte      `json:"inputs"`
}

type CreateJobRunsParams 

type CreateJobRunsParams struct {
	Tenantid          pgtype.UUID `json:"tenantid"`
	Workflowrunid     pgtype.UUID `json:"workflowrunid"`
	Workflowversionid pgtype.UUID `json:"workflowversionid"`
}

type CreateLogLineParams 

type CreateLogLineParams struct {
	CreatedAt pgtype.Timestamp `json:"createdAt"`
	Tenantid  pgtype.UUID      `json:"tenantid"`
	Steprunid pgtype.UUID      `json:"steprunid"`
	Message   string           `json:"message"`
	Level     NullLogLineLevel `json:"level"`
	Metadata  []byte           `json:"metadata"`
}

type CreateManyJobRunsParams added in v0.50.0 

type CreateManyJobRunsParams struct {
	Tenantids          []pgtype.UUID `json:"tenantids"`
	Workflowrunids     []pgtype.UUID `json:"workflowrunids"`
	Workflowversionids []pgtype.UUID `json:"workflowversionids"`
}

type CreateManyJobRunsRow added in v0.50.0 

type CreateManyJobRunsRow struct {
	ID            pgtype.UUID `json:"id"`
	WorkflowRunId pgtype.UUID `json:"workflowRunId"`
	TenantId      pgtype.UUID `json:"tenantId"`
}

type CreateMultipleWorkflowRunStickyStatesParams added in v0.50.0 

type CreateMultipleWorkflowRunStickyStatesParams struct {
	Tenantid           []pgtype.UUID `json:"tenantid"`
	Workflowrunids     []pgtype.UUID `json:"workflowrunids"`
	Desiredworkerids   []pgtype.UUID `json:"desiredworkerids"`
	Workflowversionids []pgtype.UUID `json:"workflowversionids"`
}

type CreateQueueItemParams added in v0.42.0 

type CreateQueueItemParams struct {
	StepRunId         pgtype.UUID        `json:"stepRunId"`
	StepId            pgtype.UUID        `json:"stepId"`
	ActionId          pgtype.Text        `json:"actionId"`
	ScheduleTimeoutAt pgtype.Timestamp   `json:"scheduleTimeoutAt"`
	StepTimeout       pgtype.Text        `json:"stepTimeout"`
	Priority          pgtype.Int4        `json:"priority"`
	Tenantid          pgtype.UUID        `json:"tenantid"`
	Queue             string             `json:"queue"`
	Sticky            NullStickyStrategy `json:"sticky"`
	DesiredWorkerId   pgtype.UUID        `json:"desiredWorkerId"`
}

type CreateQueueItemsBulkParams added in v0.50.0 

type CreateQueueItemsBulkParams struct {
	StepRunId         pgtype.UUID        `json:"stepRunId"`
	StepId            pgtype.UUID        `json:"stepId"`
	ActionId          pgtype.Text        `json:"actionId"`
	ScheduleTimeoutAt pgtype.Timestamp   `json:"scheduleTimeoutAt"`
	StepTimeout       pgtype.Text        `json:"stepTimeout"`
	Priority          int32              `json:"priority"`
	IsQueued          bool               `json:"isQueued"`
	TenantId          pgtype.UUID        `json:"tenantId"`
	Queue             string             `json:"queue"`
	Sticky            NullStickyStrategy `json:"sticky"`
	DesiredWorkerId   pgtype.UUID        `json:"desiredWorkerId"`
}

type CreateSchedulesParams 

type CreateSchedulesParams struct {
	Workflowrunid      pgtype.UUID        `json:"workflowrunid"`
	Triggertimes       []pgtype.Timestamp `json:"triggertimes"`
	Input              []byte             `json:"input"`
	Additionalmetadata []byte             `json:"additionalmetadata"`
}

type CreateStepExpressionsParams added in v0.47.0 

type CreateStepExpressionsParams struct {
	Keys        []string    `json:"keys"`
	Stepid      pgtype.UUID `json:"stepid"`
	Expressions []string    `json:"expressions"`
	Kinds       []string    `json:"kinds"`
}

type CreateStepParams 

type CreateStepParams struct {
	ID              pgtype.UUID      `json:"id"`
	CreatedAt       pgtype.Timestamp `json:"createdAt"`
	UpdatedAt       pgtype.Timestamp `json:"updatedAt"`
	Deletedat       pgtype.Timestamp `json:"deletedat"`
	Readableid      string           `json:"readableid"`
	Tenantid        pgtype.UUID      `json:"tenantid"`
	Jobid           pgtype.UUID      `json:"jobid"`
	Actionid        string           `json:"actionid"`
	Timeout         pgtype.Text      `json:"timeout"`
	CustomUserData  []byte           `json:"customUserData"`
	Retries         pgtype.Int4      `json:"retries"`
	ScheduleTimeout pgtype.Text      `json:"scheduleTimeout"`
}

type CreateStepRateLimitParams 

type CreateStepRateLimitParams struct {
	Units        int32             `json:"units"`
	Stepid       pgtype.UUID       `json:"stepid"`
	Ratelimitkey string            `json:"ratelimitkey"`
	Tenantid     pgtype.UUID       `json:"tenantid"`
	Kind         StepRateLimitKind `json:"kind"`
}

type CreateStepRunEventParams 

type CreateStepRunEventParams struct {
	Steprunid pgtype.UUID          `json:"steprunid"`
	Jobrunid  pgtype.UUID          `json:"jobrunid"`
	Reason    StepRunEventReason   `json:"reason"`
	Severity  StepRunEventSeverity `json:"severity"`
	Message   string               `json:"message"`
	Data      []byte               `json:"data"`
}

type CreateStepRunExpressionEvalIntsParams added in v0.47.0 

type CreateStepRunExpressionEvalIntsParams struct {
	Keys      []string    `json:"keys"`
	Steprunid pgtype.UUID `json:"steprunid"`
	Valuesint []int32     `json:"valuesint"`
	Kinds     []string    `json:"kinds"`
}

type CreateStepRunExpressionEvalStrsParams added in v0.47.0 

type CreateStepRunExpressionEvalStrsParams struct {
	Keys      []string    `json:"keys"`
	Steprunid pgtype.UUID `json:"steprunid"`
	Valuesstr []string    `json:"valuesstr"`
	Kinds     []string    `json:"kinds"`
}

type CreateStepRunParams added in v0.42.0 

type CreateStepRunParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Jobrunid pgtype.UUID `json:"jobrunid"`
	Stepid   pgtype.UUID `json:"stepid"`
	Queue    pgtype.Text `json:"queue"`
	Priority pgtype.Int4 `json:"priority"`
}

type CreateStepRunsForJobRunIdsParams added in v0.50.0 

type CreateStepRunsForJobRunIdsParams struct {
	Priority  int32         `json:"priority"`
	Jobrunids []pgtype.UUID `json:"jobrunids"`
}

type CreateStepRunsParams 

type CreateStepRunsParams struct {
	ID           pgtype.UUID      `json:"id"`
	TenantId     pgtype.UUID      `json:"tenantId"`
	JobRunId     pgtype.UUID      `json:"jobRunId"`
	StepId       pgtype.UUID      `json:"stepId"`
	Status       StepRunStatus    `json:"status"`
	RequeueAfter pgtype.Timestamp `json:"requeueAfter"`
	Queue        string           `json:"queue"`
	Priority     pgtype.Int4      `json:"priority"`
}

type CreateStreamEventParams 

type CreateStreamEventParams struct {
	CreatedAt pgtype.Timestamp `json:"createdAt"`
	Tenantid  pgtype.UUID      `json:"tenantid"`
	Steprunid pgtype.UUID      `json:"steprunid"`
	Message   []byte           `json:"message"`
	Metadata  []byte           `json:"metadata"`
}

type CreateTenantParams added in v0.34.2 

type CreateTenantParams struct {
	ID                  pgtype.UUID `json:"id"`
	Name                string      `json:"name"`
	Slug                string      `json:"slug"`
	DataRetentionPeriod pgtype.Text `json:"dataRetentionPeriod"`
}

type CreateTimeoutQueueItemParams added in v0.44.5 

type CreateTimeoutQueueItemParams struct {
	Steprunid  pgtype.UUID      `json:"steprunid"`
	Retrycount int32            `json:"retrycount"`
	Timeoutat  pgtype.Timestamp `json:"timeoutat"`
	Tenantid   pgtype.UUID      `json:"tenantid"`
}

type CreateUniqueInternalQueueItemsBulkParams added in v0.44.0 

type CreateUniqueInternalQueueItemsBulkParams struct {
	Queue      InternalQueue `json:"queue"`
	Tenantid   pgtype.UUID   `json:"tenantid"`
	Datas      [][]byte      `json:"datas"`
	Uniquekeys []string      `json:"uniquekeys"`
}

type CreateWebhookWorkerParams added in v0.42.13 

type CreateWebhookWorkerParams struct {
	Name       string      `json:"name"`
	Secret     string      `json:"secret"`
	Url        string      `json:"url"`
	Tenantid   pgtype.UUID `json:"tenantid"`
	TokenId    pgtype.UUID `json:"tokenId"`
	TokenValue pgtype.Text `json:"tokenValue"`
	Deleted    pgtype.Bool `json:"deleted"`
}

type CreateWorkerAssignEventsParams added in v0.44.0 

type CreateWorkerAssignEventsParams struct {
	Workerids        []pgtype.UUID `json:"workerids"`
	Assignedstepruns [][]byte      `json:"assignedstepruns"`
}

type CreateWorkerParams 

type CreateWorkerParams struct {
	Tenantid        pgtype.UUID    `json:"tenantid"`
	Name            string         `json:"name"`
	Dispatcherid    pgtype.UUID    `json:"dispatcherid"`
	MaxRuns         pgtype.Int4    `json:"maxRuns"`
	WebhookId       pgtype.UUID    `json:"webhookId"`
	Type            NullWorkerType `json:"type"`
	SdkVersion      pgtype.Text    `json:"sdkVersion"`
	Language        NullWorkerSDKS `json:"language"`
	LanguageVersion pgtype.Text    `json:"languageVersion"`
	Os              pgtype.Text    `json:"os"`
	RuntimeExtra    pgtype.Text    `json:"runtimeExtra"`
}

type CreateWorkflowConcurrencyParams 

type CreateWorkflowConcurrencyParams struct {
	CreatedAt                  pgtype.Timestamp             `json:"createdAt"`
	UpdatedAt                  pgtype.Timestamp             `json:"updatedAt"`
	Workflowversionid          pgtype.UUID                  `json:"workflowversionid"`
	GetConcurrencyGroupId      pgtype.UUID                  `json:"getConcurrencyGroupId"`
	MaxRuns                    pgtype.Int4                  `json:"maxRuns"`
	LimitStrategy              NullConcurrencyLimitStrategy `json:"limitStrategy"`
	ConcurrencyGroupExpression pgtype.Text                  `json:"concurrencyGroupExpression"`
}

type CreateWorkflowParams 

type CreateWorkflowParams struct {
	ID          pgtype.UUID      `json:"id"`
	CreatedAt   pgtype.Timestamp `json:"createdAt"`
	UpdatedAt   pgtype.Timestamp `json:"updatedAt"`
	Deletedat   pgtype.Timestamp `json:"deletedat"`
	Tenantid    pgtype.UUID      `json:"tenantid"`
	Name        string           `json:"name"`
	Description string           `json:"description"`
}

type CreateWorkflowRunDedupeParams added in v0.40.0 

type CreateWorkflowRunDedupeParams struct {
	Tenantid          pgtype.UUID `json:"tenantid"`
	Workflowrunid     pgtype.UUID `json:"workflowrunid"`
	Value             pgtype.Text `json:"value"`
	Workflowversionid pgtype.UUID `json:"workflowversionid"`
}

type CreateWorkflowRunParams 

type CreateWorkflowRunParams struct {
	ID                 pgtype.UUID `json:"id"`
	DisplayName        pgtype.Text `json:"displayName"`
	Tenantid           pgtype.UUID `json:"tenantid"`
	Workflowversionid  pgtype.UUID `json:"workflowversionid"`
	ChildIndex         pgtype.Int4 `json:"childIndex"`
	ChildKey           pgtype.Text `json:"childKey"`
	ParentId           pgtype.UUID `json:"parentId"`
	ParentStepRunId    pgtype.UUID `json:"parentStepRunId"`
	Additionalmetadata []byte      `json:"additionalmetadata"`
	Priority           pgtype.Int4 `json:"priority"`
}

type CreateWorkflowRunStickyStateParams added in v0.40.0 

type CreateWorkflowRunStickyStateParams struct {
	Tenantid          pgtype.UUID `json:"tenantid"`
	Workflowrunid     pgtype.UUID `json:"workflowrunid"`
	DesiredWorkerId   pgtype.UUID `json:"desiredWorkerId"`
	Workflowversionid pgtype.UUID `json:"workflowversionid"`
}

type CreateWorkflowRunTriggeredByParams 

type CreateWorkflowRunTriggeredByParams struct {
	Tenantid      pgtype.UUID `json:"tenantid"`
	Workflowrunid pgtype.UUID `json:"workflowrunid"`
	EventId       pgtype.UUID `json:"eventId"`
	CronParentId  pgtype.UUID `json:"cronParentId"`
	Cron          pgtype.Text `json:"cron"`
	ScheduledId   pgtype.UUID `json:"scheduledId"`
}

type CreateWorkflowRunTriggeredBysParams added in v0.50.0 

type CreateWorkflowRunTriggeredBysParams struct {
	ID           pgtype.UUID `json:"id"`
	TenantId     pgtype.UUID `json:"tenantId"`
	ParentId     pgtype.UUID `json:"parentId"`
	EventId      pgtype.UUID `json:"eventId"`
	CronParentId pgtype.UUID `json:"cronParentId"`
	CronSchedule pgtype.Text `json:"cronSchedule"`
	ScheduledId  pgtype.UUID `json:"scheduledId"`
}

type CreateWorkflowRunsParams added in v0.50.0 

type CreateWorkflowRunsParams struct {
	ID                 pgtype.UUID       `json:"id"`
	DisplayName        pgtype.Text       `json:"displayName"`
	TenantId           pgtype.UUID       `json:"tenantId"`
	WorkflowVersionId  pgtype.UUID       `json:"workflowVersionId"`
	Status             WorkflowRunStatus `json:"status"`
	ChildIndex         pgtype.Int4       `json:"childIndex"`
	ChildKey           pgtype.Text       `json:"childKey"`
	ParentId           pgtype.UUID       `json:"parentId"`
	ParentStepRunId    pgtype.UUID       `json:"parentStepRunId"`
	AdditionalMetadata []byte            `json:"additionalMetadata"`
	Priority           pgtype.Int4       `json:"priority"`
	InsertOrder        pgtype.Int4       `json:"insertOrder"`
}

type CreateWorkflowTriggerCronRefParams 

type CreateWorkflowTriggerCronRefParams struct {
	Workflowtriggersid pgtype.UUID `json:"workflowtriggersid"`
	Crontrigger        string      `json:"crontrigger"`
	Input              []byte      `json:"input"`
}

type CreateWorkflowTriggerEventRefParams 

type CreateWorkflowTriggerEventRefParams struct {
	Workflowtriggersid pgtype.UUID `json:"workflowtriggersid"`
	Eventtrigger       string      `json:"eventtrigger"`
}

type CreateWorkflowTriggerScheduledRefParams 

type CreateWorkflowTriggerScheduledRefParams struct {
	Workflowversionid pgtype.UUID      `json:"workflowversionid"`
	Scheduledtrigger  pgtype.Timestamp `json:"scheduledtrigger"`
}

type CreateWorkflowTriggersParams 

type CreateWorkflowTriggersParams struct {
	ID                pgtype.UUID `json:"id"`
	Workflowversionid pgtype.UUID `json:"workflowversionid"`
	Tenantid          pgtype.UUID `json:"tenantid"`
}

type CreateWorkflowVersionParams 

type CreateWorkflowVersionParams struct {
	ID              pgtype.UUID        `json:"id"`
	CreatedAt       pgtype.Timestamp   `json:"createdAt"`
	UpdatedAt       pgtype.Timestamp   `json:"updatedAt"`
	Deletedat       pgtype.Timestamp   `json:"deletedat"`
	Checksum        string             `json:"checksum"`
	Version         pgtype.Text        `json:"version"`
	Workflowid      pgtype.UUID        `json:"workflowid"`
	ScheduleTimeout pgtype.Text        `json:"scheduleTimeout"`
	Sticky          NullStickyStrategy `json:"sticky"`
	Kind            NullWorkflowKind   `json:"kind"`
	DefaultPriority pgtype.Int4        `json:"defaultPriority"`
}

type DBTX 

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
	CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error)
	SendBatch(context.Context, *pgx.Batch) pgx.BatchResults
}

type DeleteOldWorkerAssignEventsParams added in v0.44.3 

type DeleteOldWorkerAssignEventsParams struct {
	Workerid pgtype.UUID `json:"workerid"`
	MaxRuns  int32       `json:"maxRuns"`
	Limit    int32       `json:"limit"`
}

type DeleteOldWorkersParams added in v0.44.0 

type DeleteOldWorkersParams struct {
	Tenantid            pgtype.UUID      `json:"tenantid"`
	Lastheartbeatbefore pgtype.Timestamp `json:"lastheartbeatbefore"`
	Limit               interface{}      `json:"limit"`
}

type Dispatcher 

type Dispatcher struct {
	ID              pgtype.UUID      `json:"id"`
	CreatedAt       pgtype.Timestamp `json:"createdAt"`
	UpdatedAt       pgtype.Timestamp `json:"updatedAt"`
	DeletedAt       pgtype.Timestamp `json:"deletedAt"`
	LastHeartbeatAt pgtype.Timestamp `json:"lastHeartbeatAt"`
	IsActive        bool             `json:"isActive"`
}

type Event 

type Event struct {
	ID                 pgtype.UUID      `json:"id"`
	CreatedAt          pgtype.Timestamp `json:"createdAt"`
	UpdatedAt          pgtype.Timestamp `json:"updatedAt"`
	DeletedAt          pgtype.Timestamp `json:"deletedAt"`
	Key                string           `json:"key"`
	TenantId           pgtype.UUID      `json:"tenantId"`
	ReplayedFromId     pgtype.UUID      `json:"replayedFromId"`
	Data               []byte           `json:"data"`
	AdditionalMetadata []byte           `json:"additionalMetadata"`
	InsertOrder        pgtype.Int4      `json:"insertOrder"`
	IdentityId         pgtype.Int8      `json:"identityId"`
}

type EventKey added in v0.49.3 

type EventKey struct {
	Key      string      `json:"key"`
	TenantId pgtype.UUID `json:"tenantId"`
	ID       int64       `json:"id"`
}

type GetChildWorkflowRunParams 

type GetChildWorkflowRunParams struct {
	Parentid        pgtype.UUID `json:"parentid"`
	Parentsteprunid pgtype.UUID `json:"parentsteprunid"`
	ChildKey        pgtype.Text `json:"childKey"`
	Childindex      pgtype.Int4 `json:"childindex"`
}

type GetChildWorkflowRunsByIndexParams added in v0.50.0 

type GetChildWorkflowRunsByIndexParams struct {
	Parentids        []pgtype.UUID `json:"parentids"`
	Parentsteprunids []pgtype.UUID `json:"parentsteprunids"`
	Childindexes     []int32       `json:"childindexes"`
}

type GetChildWorkflowRunsByKeyParams added in v0.50.0 

type GetChildWorkflowRunsByKeyParams struct {
	Parentids        []pgtype.UUID `json:"parentids"`
	Parentsteprunids []pgtype.UUID `json:"parentsteprunids"`
	Childkeys        []string      `json:"childkeys"`
}

type GetDesiredLabelsRow added in v0.42.0 

type GetDesiredLabelsRow struct {
	Key        string                `json:"key"`
	StrValue   pgtype.Text           `json:"strValue"`
	IntValue   pgtype.Int4           `json:"intValue"`
	Required   bool                  `json:"required"`
	Weight     int32                 `json:"weight"`
	Comparator WorkerLabelComparator `json:"comparator"`
	StepId     pgtype.UUID           `json:"stepId"`
}

type GetEventsForRangeRow 

type GetEventsForRangeRow struct {
	EventHour  pgtype.Interval `json:"event_hour"`
	EventCount int64           `json:"event_count"`
}

type GetFailureDetailsParams added in v0.51.0 

type GetFailureDetailsParams struct {
	Workflowrunid pgtype.UUID `json:"workflowrunid"`
	Tenantid      pgtype.UUID `json:"tenantid"`
}

type GetFailureDetailsRow added in v0.51.0 

type GetFailureDetailsRow struct {
	Status          WorkflowRunStatus `json:"status"`
	ID              pgtype.UUID       `json:"id"`
	JrStatus        JobRunStatus      `json:"jrStatus"`
	SrStatus        StepRunStatus     `json:"srStatus"`
	CancelledReason pgtype.Text       `json:"cancelledReason"`
	Error           pgtype.Text       `json:"error"`
}

type GetFinalizedStepRunsRow added in v0.44.0 

type GetFinalizedStepRunsRow struct {
	ID     pgtype.UUID   `json:"id"`
	Status StepRunStatus `json:"status"`
}

type GetGroupKeyRun 

type GetGroupKeyRun struct {
	ID                pgtype.UUID      `json:"id"`
	CreatedAt         pgtype.Timestamp `json:"createdAt"`
	UpdatedAt         pgtype.Timestamp `json:"updatedAt"`
	DeletedAt         pgtype.Timestamp `json:"deletedAt"`
	TenantId          pgtype.UUID      `json:"tenantId"`
	WorkerId          pgtype.UUID      `json:"workerId"`
	TickerId          pgtype.UUID      `json:"tickerId"`
	Status            StepRunStatus    `json:"status"`
	Input             []byte           `json:"input"`
	Output            pgtype.Text      `json:"output"`
	RequeueAfter      pgtype.Timestamp `json:"requeueAfter"`
	Error             pgtype.Text      `json:"error"`
	StartedAt         pgtype.Timestamp `json:"startedAt"`
	FinishedAt        pgtype.Timestamp `json:"finishedAt"`
	TimeoutAt         pgtype.Timestamp `json:"timeoutAt"`
	CancelledAt       pgtype.Timestamp `json:"cancelledAt"`
	CancelledReason   pgtype.Text      `json:"cancelledReason"`
	CancelledError    pgtype.Text      `json:"cancelledError"`
	WorkflowRunId     pgtype.UUID      `json:"workflowRunId"`
	ScheduleTimeoutAt pgtype.Timestamp `json:"scheduleTimeoutAt"`
}

type GetGroupKeyRunForEngineParams 

type GetGroupKeyRunForEngineParams struct {
	Ids      []pgtype.UUID `json:"ids"`
	Tenantid pgtype.UUID   `json:"tenantid"`
}

type GetGroupKeyRunForEngineRow 

type GetGroupKeyRunForEngineRow struct {
	GetGroupKeyRun    GetGroupKeyRun `json:"get_group_key_run"`
	WorkflowRunId     pgtype.UUID    `json:"workflowRunId"`
	WorkflowVersionId pgtype.UUID    `json:"workflowVersionId"`
	WorkflowId        pgtype.UUID    `json:"workflowId"`
	ActionId          string         `json:"actionId"`
}

type GetJobRunByWorkflowRunIdAndJobIdParams 

type GetJobRunByWorkflowRunIdAndJobIdParams struct {
	Tenantid      pgtype.UUID `json:"tenantid"`
	Workflowrunid pgtype.UUID `json:"workflowrunid"`
	Jobid         pgtype.UUID `json:"jobid"`
}

type GetJobRunByWorkflowRunIdAndJobIdRow 

type GetJobRunByWorkflowRunIdAndJobIdRow struct {
	ID     pgtype.UUID  `json:"id"`
	JobId  pgtype.UUID  `json:"jobId"`
	Status JobRunStatus `json:"status"`
}

type GetJobRunsByWorkflowRunIdParams added in v0.50.0 

type GetJobRunsByWorkflowRunIdParams struct {
	Workflowrunid pgtype.UUID `json:"workflowrunid"`
	Tenantid      pgtype.UUID `json:"tenantid"`
}

type GetJobRunsByWorkflowRunIdRow added in v0.50.0 

type GetJobRunsByWorkflowRunIdRow struct {
	ID     pgtype.UUID  `json:"id"`
	JobId  pgtype.UUID  `json:"jobId"`
	Status JobRunStatus `json:"status"`
}

type GetLatestWorkflowVersionForWorkflowsParams added in v0.50.0 

type GetLatestWorkflowVersionForWorkflowsParams struct {
	Tenantid    pgtype.UUID   `json:"tenantid"`
	Workflowids []pgtype.UUID `json:"workflowids"`
}

type GetLeasesToAcquireParams added in v0.50.0 

type GetLeasesToAcquireParams struct {
	Tenantid    pgtype.UUID `json:"tenantid"`
	Kind        LeaseKind   `json:"kind"`
	Resourceids []string    `json:"resourceids"`
}

type GetMinMaxProcessedInternalQueueItemsRow added in v0.44.0 

type GetMinMaxProcessedInternalQueueItemsRow struct {
	MinId int64 `json:"minId"`
	MaxId int64 `json:"maxId"`
}

type GetMinMaxProcessedQueueItemsRow added in v0.43.2 

type GetMinMaxProcessedQueueItemsRow struct {
	MinId int64 `json:"minId"`
	MaxId int64 `json:"maxId"`
}

type GetMinMaxProcessedTimeoutQueueItemsRow added in v0.44.5 

type GetMinMaxProcessedTimeoutQueueItemsRow struct {
	MinId int64 `json:"minId"`
	MaxId int64 `json:"maxId"`
}

type GetMinUnprocessedQueueItemIdParams added in v0.50.0 

type GetMinUnprocessedQueueItemIdParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Queue    string      `json:"queue"`
}

type GetQueuedCountsRow added in v0.46.1 

type GetQueuedCountsRow struct {
	Queue string `json:"queue"`
	Count int64  `json:"count"`
}

type GetScheduledChildWorkflowRunParams 

type GetScheduledChildWorkflowRunParams struct {
	Parentid        pgtype.UUID `json:"parentid"`
	Parentsteprunid pgtype.UUID `json:"parentsteprunid"`
	ChildKey        pgtype.Text `json:"childKey"`
	Childindex      pgtype.Int4 `json:"childindex"`
}

type GetStepRunBulkDataForEngineParams added in v0.50.0 

type GetStepRunBulkDataForEngineParams struct {
	Tenantid pgtype.UUID   `json:"tenantid"`
	Ids      []pgtype.UUID `json:"ids"`
}

type GetStepRunBulkDataForEngineRow added in v0.50.0 

type GetStepRunBulkDataForEngineRow struct {
	SRID                pgtype.UUID   `json:"SR_id"`
	SRRetryCount        int32         `json:"SR_retryCount"`
	Input               []byte        `json:"input"`
	Output              []byte        `json:"output"`
	Error               pgtype.Text   `json:"error"`
	Status              StepRunStatus `json:"status"`
	JobRunId            pgtype.UUID   `json:"jobRunId"`
	JobRunStatus        JobRunStatus  `json:"jobRunStatus"`
	JobRunStatus_2      JobRunStatus  `json:"jobRunStatus_2"`
	WorkflowRunId       pgtype.UUID   `json:"workflowRunId"`
	JobRunLookupData    []byte        `json:"jobRunLookupData"`
	AdditionalMetadata  []byte        `json:"additionalMetadata"`
	ChildIndex          pgtype.Int4   `json:"childIndex"`
	ChildKey            pgtype.Text   `json:"childKey"`
	ParentId            pgtype.UUID   `json:"parentId"`
	JobRunId_2          pgtype.UUID   `json:"jobRunId_2"`
	StepId              pgtype.UUID   `json:"stepId"`
	StepRetries         int32         `json:"stepRetries"`
	StepTimeout         pgtype.Text   `json:"stepTimeout"`
	StepScheduleTimeout string        `json:"stepScheduleTimeout"`
	StepReadableId      pgtype.Text   `json:"stepReadableId"`
	StepCustomUserData  []byte        `json:"stepCustomUserData"`
	JobName             string        `json:"jobName"`
	JobId               pgtype.UUID   `json:"jobId"`
	JobKind             JobKind       `json:"jobKind"`
	WorkflowVersionId   pgtype.UUID   `json:"workflowVersionId"`
	ActionId            string        `json:"actionId"`
}

type GetStepRunDataForEngineParams added in v0.36.9 

type GetStepRunDataForEngineParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	ID       pgtype.UUID `json:"id"`
}

type GetStepRunDataForEngineRow added in v0.36.9 

type GetStepRunDataForEngineRow struct {
	Input              []byte      `json:"input"`
	Output             []byte      `json:"output"`
	Error              pgtype.Text `json:"error"`
	JobRunLookupData   []byte      `json:"jobRunLookupData"`
	AdditionalMetadata []byte      `json:"additionalMetadata"`
	ChildIndex         pgtype.Int4 `json:"childIndex"`
	ChildKey           pgtype.Text `json:"childKey"`
	ParentId           pgtype.UUID `json:"parentId"`
	ExprCount          int64       `json:"exprCount"`
}

type GetStepRunForEngineParams 

type GetStepRunForEngineParams struct {
	Ids      []pgtype.UUID `json:"ids"`
	TenantId pgtype.UUID   `json:"tenantId"`
}

type GetStepRunForEngineRow 

type GetStepRunForEngineRow struct {
	SRID                pgtype.UUID        `json:"SR_id"`
	SRCreatedAt         pgtype.Timestamp   `json:"SR_createdAt"`
	SRUpdatedAt         pgtype.Timestamp   `json:"SR_updatedAt"`
	SRDeletedAt         pgtype.Timestamp   `json:"SR_deletedAt"`
	SRTenantId          pgtype.UUID        `json:"SR_tenantId"`
	SRQueue             string             `json:"SR_queue"`
	SROrder             int64              `json:"SR_order"`
	SRWorkerId          pgtype.UUID        `json:"SR_workerId"`
	SRTickerId          pgtype.UUID        `json:"SR_tickerId"`
	SRStatus            StepRunStatus      `json:"SR_status"`
	SRRequeueAfter      pgtype.Timestamp   `json:"SR_requeueAfter"`
	SRScheduleTimeoutAt pgtype.Timestamp   `json:"SR_scheduleTimeoutAt"`
	SRStartedAt         pgtype.Timestamp   `json:"SR_startedAt"`
	SRFinishedAt        pgtype.Timestamp   `json:"SR_finishedAt"`
	SRTimeoutAt         pgtype.Timestamp   `json:"SR_timeoutAt"`
	SRCancelledAt       pgtype.Timestamp   `json:"SR_cancelledAt"`
	SRCancelledReason   pgtype.Text        `json:"SR_cancelledReason"`
	SRCancelledError    pgtype.Text        `json:"SR_cancelledError"`
	SRCallerFiles       []byte             `json:"SR_callerFiles"`
	SRGitRepoBranch     pgtype.Text        `json:"SR_gitRepoBranch"`
	SRRetryCount        int32              `json:"SR_retryCount"`
	SRSemaphoreReleased bool               `json:"SR_semaphoreReleased"`
	SRPriority          pgtype.Int4        `json:"SR_priority"`
	SRChildCount        int64              `json:"SR_childCount"`
	JobRunId            pgtype.UUID        `json:"jobRunId"`
	StepId              pgtype.UUID        `json:"stepId"`
	StepRetries         int32              `json:"stepRetries"`
	StepTimeout         pgtype.Text        `json:"stepTimeout"`
	StepScheduleTimeout string             `json:"stepScheduleTimeout"`
	StepReadableId      pgtype.Text        `json:"stepReadableId"`
	StepCustomUserData  []byte             `json:"stepCustomUserData"`
	JobName             string             `json:"jobName"`
	JobId               pgtype.UUID        `json:"jobId"`
	JobKind             JobKind            `json:"jobKind"`
	WorkflowVersionId   pgtype.UUID        `json:"workflowVersionId"`
	JobRunStatus        JobRunStatus       `json:"jobRunStatus"`
	WorkflowRunId       pgtype.UUID        `json:"workflowRunId"`
	ActionId            string             `json:"actionId"`
	StickyStrategy      NullStickyStrategy `json:"stickyStrategy"`
	DesiredWorkerId     pgtype.UUID        `json:"desiredWorkerId"`
}

type GetStepRunMetaParams added in v0.41.0 

type GetStepRunMetaParams struct {
	Steprunid pgtype.UUID `json:"steprunid"`
	Tenantid  pgtype.UUID `json:"tenantid"`
}

type GetStepRunMetaRow added in v0.41.0 

type GetStepRunMetaRow struct {
	WorkflowRunId pgtype.UUID `json:"workflowRunId"`
	RetryCount    int32       `json:"retryCount"`
	Retries       int32       `json:"retries"`
}

type GetStepRunsForJobRunsWithOutputParams added in v0.46.1 

type GetStepRunsForJobRunsWithOutputParams struct {
	Jobids   []pgtype.UUID `json:"jobids"`
	Tenantid pgtype.UUID   `json:"tenantid"`
}

type GetStepRunsForJobRunsWithOutputRow added in v0.46.1 

type GetStepRunsForJobRunsWithOutputRow struct {
	ID              pgtype.UUID      `json:"id"`
	CreatedAt       pgtype.Timestamp `json:"createdAt"`
	UpdatedAt       pgtype.Timestamp `json:"updatedAt"`
	Status          StepRunStatus    `json:"status"`
	JobRunId        pgtype.UUID      `json:"jobRunId"`
	StepId          pgtype.UUID      `json:"stepId"`
	TenantId        pgtype.UUID      `json:"tenantId"`
	StartedAt       pgtype.Timestamp `json:"startedAt"`
	FinishedAt      pgtype.Timestamp `json:"finishedAt"`
	CancelledAt     pgtype.Timestamp `json:"cancelledAt"`
	CancelledError  pgtype.Text      `json:"cancelledError"`
	CancelledReason pgtype.Text      `json:"cancelledReason"`
	TimeoutAt       pgtype.Timestamp `json:"timeoutAt"`
	Error           pgtype.Text      `json:"error"`
	WorkerId        pgtype.UUID      `json:"workerId"`
	Output          []byte           `json:"output"`
}

type GetStepsForJobsParams added in v0.44.8 

type GetStepsForJobsParams struct {
	Jobids   []pgtype.UUID `json:"jobids"`
	Tenantid pgtype.UUID   `json:"tenantid"`
}

type GetStepsForJobsRow added in v0.44.8 

type GetStepsForJobsRow struct {
	JobId   pgtype.UUID   `json:"jobId"`
	Step    Step          `json:"step"`
	Parents []pgtype.UUID `json:"parents"`
}

type GetStreamEventMetaParams added in v0.41.0 

type GetStreamEventMetaParams struct {
	Steprunid pgtype.UUID `json:"steprunid"`
	Tenantid  pgtype.UUID `json:"tenantid"`
}

type GetStreamEventMetaRow added in v0.41.0 

type GetStreamEventMetaRow struct {
	WorkflowRunId pgtype.UUID `json:"workflowRunId"`
	RetryCount    int32       `json:"retryCount"`
	Retries       int32       `json:"retries"`
}

type GetStreamEventParams 

type GetStreamEventParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	ID       int64       `json:"id"`
}

type GetTenantResourceLimitParams 

type GetTenantResourceLimitParams struct {
	Tenantid pgtype.UUID       `json:"tenantid"`
	Resource NullLimitResource `json:"resource"`
}

type GetTenantResourceLimitRow 

type GetTenantResourceLimitRow struct {
	ID               pgtype.UUID      `json:"id"`
	CreatedAt        pgtype.Timestamp `json:"createdAt"`
	UpdatedAt        pgtype.Timestamp `json:"updatedAt"`
	Resource         LimitResource    `json:"resource"`
	TenantId         pgtype.UUID      `json:"tenantId"`
	LimitValue       int32            `json:"limitValue"`
	AlarmValue       pgtype.Int4      `json:"alarmValue"`
	Value            int32            `json:"value"`
	Window           pgtype.Text      `json:"window"`
	LastRefill       pgtype.Timestamp `json:"lastRefill"`
	CustomValueMeter bool             `json:"customValueMeter"`
}

type GetTenantTotalQueueMetricsParams 

type GetTenantTotalQueueMetricsParams struct {
	TenantId           pgtype.UUID   `json:"tenantId"`
	AdditionalMetadata []byte        `json:"additionalMetadata"`
	WorkflowIds        []pgtype.UUID `json:"workflowIds"`
}

type GetTenantTotalQueueMetricsRow 

type GetTenantTotalQueueMetricsRow struct {
	PendingAssignmentCount int64 `json:"pendingAssignmentCount"`
	PendingCount           int64 `json:"pendingCount"`
	RunningCount           int64 `json:"runningCount"`
}

type GetTenantWorkflowQueueMetricsParams 

type GetTenantWorkflowQueueMetricsParams struct {
	TenantId           pgtype.UUID   `json:"tenantId"`
	AdditionalMetadata []byte        `json:"additionalMetadata"`
	WorkflowIds        []pgtype.UUID `json:"workflowIds"`
}

type GetTenantWorkflowQueueMetricsRow 

type GetTenantWorkflowQueueMetricsRow struct {
	WorkflowId             pgtype.UUID `json:"workflowId"`
	PendingAssignmentCount int64       `json:"pendingAssignmentCount"`
	PendingCount           int64       `json:"pendingCount"`
	RunningCount           int64       `json:"runningCount"`
}

type GetWorkerActionsByWorkerIdParams added in v0.42.13 

type GetWorkerActionsByWorkerIdParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Workerid pgtype.UUID `json:"workerid"`
}

type GetWorkerByIdRow added in v0.42.10 

type GetWorkerByIdRow struct {
	Worker         Worker      `json:"worker"`
	WebhookUrl     pgtype.Text `json:"webhookUrl"`
	RemainingSlots int32       `json:"remainingSlots"`
}

type GetWorkerByWebhookIdParams added in v0.42.10 

type GetWorkerByWebhookIdParams struct {
	Webhookid pgtype.UUID `json:"webhookid"`
	Tenantid  pgtype.UUID `json:"tenantid"`
}

type GetWorkerDispatcherActionsParams added in v0.44.0 

type GetWorkerDispatcherActionsParams struct {
	Tenantid  pgtype.UUID `json:"tenantid"`
	Actionids []string    `json:"actionids"`
}

type GetWorkerDispatcherActionsRow added in v0.44.0 

type GetWorkerDispatcherActionsRow struct {
	ID           pgtype.UUID `json:"id"`
	ActionId     string      `json:"actionId"`
	DispatcherId pgtype.UUID `json:"dispatcherId"`
}

type GetWorkerForEngineParams 

type GetWorkerForEngineParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	ID       pgtype.UUID `json:"id"`
}

type GetWorkerForEngineRow 

type GetWorkerForEngineRow struct {
	ID                        pgtype.UUID      `json:"id"`
	TenantId                  pgtype.UUID      `json:"tenantId"`
	DispatcherId              pgtype.UUID      `json:"dispatcherId"`
	DispatcherLastHeartbeatAt pgtype.Timestamp `json:"dispatcherLastHeartbeatAt"`
	IsActive                  bool             `json:"isActive"`
	LastListenerEstablished   pgtype.Timestamp `json:"lastListenerEstablished"`
}

type GetWorkerLabelsRow added in v0.42.0 

type GetWorkerLabelsRow struct {
	Key      string      `json:"key"`
	StrValue pgtype.Text `json:"strValue"`
	IntValue pgtype.Int4 `json:"intValue"`
}

type GetWorkflowByIdRow added in v0.44.8 

type GetWorkflowByIdRow struct {
	Workflow          Workflow    `json:"workflow"`
	WorkflowVersionId pgtype.UUID `json:"workflowVersionId"`
}

type GetWorkflowByNameParams 

type GetWorkflowByNameParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Name     string      `json:"name"`
}

type GetWorkflowRunAdditionalMetaParams added in v0.41.0 

type GetWorkflowRunAdditionalMetaParams struct {
	Workflowrunid pgtype.UUID `json:"workflowrunid"`
	Tenantid      pgtype.UUID `json:"tenantid"`
}

type GetWorkflowRunAdditionalMetaRow added in v0.41.0 

type GetWorkflowRunAdditionalMetaRow struct {
	AdditionalMetadata []byte      `json:"additionalMetadata"`
	ID                 pgtype.UUID `json:"id"`
}

type GetWorkflowRunByIdParams added in v0.44.8 

type GetWorkflowRunByIdParams struct {
	Workflowrunid pgtype.UUID `json:"workflowrunid"`
	Tenantid      pgtype.UUID `json:"tenantid"`
}

type GetWorkflowRunByIdRow added in v0.44.8 

type GetWorkflowRunByIdRow struct {
	CreatedAt              pgtype.Timestamp       `json:"createdAt"`
	UpdatedAt              pgtype.Timestamp       `json:"updatedAt"`
	DeletedAt              pgtype.Timestamp       `json:"deletedAt"`
	TenantId               pgtype.UUID            `json:"tenantId"`
	WorkflowVersionId      pgtype.UUID            `json:"workflowVersionId"`
	Status                 WorkflowRunStatus      `json:"status"`
	Error                  pgtype.Text            `json:"error"`
	StartedAt              pgtype.Timestamp       `json:"startedAt"`
	FinishedAt             pgtype.Timestamp       `json:"finishedAt"`
	ConcurrencyGroupId     pgtype.Text            `json:"concurrencyGroupId"`
	DisplayName            pgtype.Text            `json:"displayName"`
	ID                     pgtype.UUID            `json:"id"`
	ChildIndex             pgtype.Int4            `json:"childIndex"`
	ChildKey               pgtype.Text            `json:"childKey"`
	ParentId               pgtype.UUID            `json:"parentId"`
	ParentStepRunId        pgtype.UUID            `json:"parentStepRunId"`
	AdditionalMetadata     []byte                 `json:"additionalMetadata"`
	Duration               pgtype.Int8            `json:"duration"`
	Priority               pgtype.Int4            `json:"priority"`
	InsertOrder            pgtype.Int4            `json:"insertOrder"`
	IdentityId             pgtype.Int8            `json:"identityId"`
	WorkflowVersion        WorkflowVersion        `json:"workflow_version"`
	Workflow               Workflow               `json:"workflow"`
	WorkflowRunTriggeredBy WorkflowRunTriggeredBy `json:"workflow_run_triggered_by"`
}

type GetWorkflowRunByIdsParams added in v0.50.0 

type GetWorkflowRunByIdsParams struct {
	Workflowrunids []pgtype.UUID `json:"workflowrunids"`
	Tenantid       pgtype.UUID   `json:"tenantid"`
}

type GetWorkflowRunByIdsRow added in v0.50.0 

type GetWorkflowRunByIdsRow struct {
	CreatedAt              pgtype.Timestamp       `json:"createdAt"`
	UpdatedAt              pgtype.Timestamp       `json:"updatedAt"`
	DeletedAt              pgtype.Timestamp       `json:"deletedAt"`
	TenantId               pgtype.UUID            `json:"tenantId"`
	WorkflowVersionId      pgtype.UUID            `json:"workflowVersionId"`
	Status                 WorkflowRunStatus      `json:"status"`
	Error                  pgtype.Text            `json:"error"`
	StartedAt              pgtype.Timestamp       `json:"startedAt"`
	FinishedAt             pgtype.Timestamp       `json:"finishedAt"`
	ConcurrencyGroupId     pgtype.Text            `json:"concurrencyGroupId"`
	DisplayName            pgtype.Text            `json:"displayName"`
	ID                     pgtype.UUID            `json:"id"`
	ChildIndex             pgtype.Int4            `json:"childIndex"`
	ChildKey               pgtype.Text            `json:"childKey"`
	ParentId               pgtype.UUID            `json:"parentId"`
	ParentStepRunId        pgtype.UUID            `json:"parentStepRunId"`
	AdditionalMetadata     []byte                 `json:"additionalMetadata"`
	Duration               pgtype.Int8            `json:"duration"`
	Priority               pgtype.Int4            `json:"priority"`
	InsertOrder            pgtype.Int4            `json:"insertOrder"`
	IdentityId             pgtype.Int8            `json:"identityId"`
	WorkflowVersion        WorkflowVersion        `json:"workflow_version"`
	Workflow               Workflow               `json:"workflow"`
	WorkflowRunTriggeredBy WorkflowRunTriggeredBy `json:"workflow_run_triggered_by"`
}

type GetWorkflowRunParams 

type GetWorkflowRunParams struct {
	Ids      []pgtype.UUID `json:"ids"`
	Tenantid pgtype.UUID   `json:"tenantid"`
}

type GetWorkflowRunRow 

type GetWorkflowRunRow struct {
	WorkflowRun                WorkflowRun                  `json:"workflow_run"`
	WorkflowRunTriggeredBy     WorkflowRunTriggeredBy       `json:"workflow_run_triggered_by"`
	WorkflowVersion            WorkflowVersion              `json:"workflow_version"`
	WorkflowName               pgtype.Text                  `json:"workflowName"`
	ConcurrencyLimitStrategy   NullConcurrencyLimitStrategy `json:"concurrencyLimitStrategy"`
	ConcurrencyMaxRuns         pgtype.Int4                  `json:"concurrencyMaxRuns"`
	IsPaused                   pgtype.Bool                  `json:"isPaused"`
	ConcurrencyGroupExpression pgtype.Text                  `json:"concurrencyGroupExpression"`
	GetGroupKeyRunId           pgtype.UUID                  `json:"getGroupKeyRunId"`
}

type GetWorkflowRunStickyStateForUpdateParams added in v0.40.0 

type GetWorkflowRunStickyStateForUpdateParams struct {
	Workflowrunid pgtype.UUID `json:"workflowrunid"`
	Tenantid      pgtype.UUID `json:"tenantid"`
}

type GetWorkflowRunTriggerParams added in v0.44.8 

type GetWorkflowRunTriggerParams struct {
	Runid    pgtype.UUID `json:"runid"`
	Tenantid pgtype.UUID `json:"tenantid"`
}

type GetWorkflowVersionByIdRow added in v0.44.8 

type GetWorkflowVersionByIdRow struct {
	WorkflowVersion          WorkflowVersion              `json:"workflow_version"`
	Workflow                 Workflow                     `json:"workflow"`
	ConcurrencyId            pgtype.UUID                  `json:"concurrencyId"`
	ConcurrencyMaxRuns       pgtype.Int4                  `json:"concurrencyMaxRuns"`
	ConcurrencyGroupId       pgtype.UUID                  `json:"concurrencyGroupId"`
	ConcurrencyLimitStrategy NullConcurrencyLimitStrategy `json:"concurrencyLimitStrategy"`
}

type GetWorkflowVersionForEngineParams 

type GetWorkflowVersionForEngineParams struct {
	Ids      []pgtype.UUID `json:"ids"`
	Tenantid pgtype.UUID   `json:"tenantid"`
}

type GetWorkflowVersionForEngineRow 

type GetWorkflowVersionForEngineRow struct {
	WorkflowVersion            WorkflowVersion              `json:"workflow_version"`
	WorkflowName               string                       `json:"workflowName"`
	ConcurrencyLimitStrategy   NullConcurrencyLimitStrategy `json:"concurrencyLimitStrategy"`
	ConcurrencyMaxRuns         pgtype.Int4                  `json:"concurrencyMaxRuns"`
	ConcurrencyGroupId         pgtype.UUID                  `json:"concurrencyGroupId"`
	ConcurrencyGroupExpression pgtype.Text                  `json:"concurrencyGroupExpression"`
}

type GetWorkflowWorkerCountParams added in v0.45.2 

type GetWorkflowWorkerCountParams struct {
	Tenantid   pgtype.UUID `json:"tenantid"`
	Workflowid pgtype.UUID `json:"workflowid"`
}

type GetWorkflowWorkerCountRow added in v0.45.2 

type GetWorkflowWorkerCountRow struct {
	Totalslotcount int64 `json:"totalslotcount"`
	Freeslotcount  int32 `json:"freeslotcount"`
}

type GetWorkflowsByNamesParams added in v0.50.0 

type GetWorkflowsByNamesParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Names    []string    `json:"names"`
}

type HandleWorkflowUnpausedParams added in v0.48.0 

type HandleWorkflowUnpausedParams struct {
	Workflowid string      `json:"workflowid"`
	Tenantid   pgtype.UUID `json:"tenantid"`
}

type HardDeleteWebhookWorkerParams added in v0.42.13 

type HardDeleteWebhookWorkerParams struct {
	ID       pgtype.UUID `json:"id"`
	Tenantid pgtype.UUID `json:"tenantid"`
}

type HasActiveWorkersForActionIdParams added in v0.44.8 

type HasActiveWorkersForActionIdParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Actionid string      `json:"actionid"`
}

type InsertWebhookWorkerRequestParams added in v0.42.13 

type InsertWebhookWorkerRequestParams struct {
	Webhookworkerid pgtype.UUID                `json:"webhookworkerid"`
	Method          WebhookWorkerRequestMethod `json:"method"`
	Statuscode      int32                      `json:"statuscode"`
}

type InternalQueue added in v0.44.0 

type InternalQueue string
const (
	InternalQueueWORKERSEMAPHORECOUNT InternalQueue = "WORKER_SEMAPHORE_COUNT"
	InternalQueueSTEPRUNUPDATE        InternalQueue = "STEP_RUN_UPDATE"
	InternalQueueWORKFLOWRUNUPDATE    InternalQueue = "WORKFLOW_RUN_UPDATE"
	InternalQueueWORKFLOWRUNPAUSED    InternalQueue = "WORKFLOW_RUN_PAUSED"
	InternalQueueSTEPRUNUPDATEV2      InternalQueue = "STEP_RUN_UPDATE_V2"
)

func (*InternalQueue) Scan added in v0.44.0 

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

type InternalQueueItem added in v0.44.0 

type InternalQueueItem struct {
	ID        int64         `json:"id"`
	Queue     InternalQueue `json:"queue"`
	IsQueued  bool          `json:"isQueued"`
	Data      []byte        `json:"data"`
	TenantId  pgtype.UUID   `json:"tenantId"`
	Priority  int32         `json:"priority"`
	UniqueKey pgtype.Text   `json:"uniqueKey"`
}

type InviteLinkStatus 

type InviteLinkStatus string
const (
	InviteLinkStatusPENDING  InviteLinkStatus = "PENDING"
	InviteLinkStatusACCEPTED InviteLinkStatus = "ACCEPTED"
	InviteLinkStatusREJECTED InviteLinkStatus = "REJECTED"
)

func (*InviteLinkStatus) Scan 

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

type Job 

type Job struct {
	ID                pgtype.UUID      `json:"id"`
	CreatedAt         pgtype.Timestamp `json:"createdAt"`
	UpdatedAt         pgtype.Timestamp `json:"updatedAt"`
	DeletedAt         pgtype.Timestamp `json:"deletedAt"`
	TenantId          pgtype.UUID      `json:"tenantId"`
	WorkflowVersionId pgtype.UUID      `json:"workflowVersionId"`
	Name              string           `json:"name"`
	Description       pgtype.Text      `json:"description"`
	Timeout           pgtype.Text      `json:"timeout"`
	Kind              JobKind          `json:"kind"`
}

type JobKind 

type JobKind string
const (
	JobKindDEFAULT   JobKind = "DEFAULT"
	JobKindONFAILURE JobKind = "ON_FAILURE"
)

func (*JobKind) Scan 

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

type JobRun 

type JobRun struct {
	ID              pgtype.UUID      `json:"id"`
	CreatedAt       pgtype.Timestamp `json:"createdAt"`
	UpdatedAt       pgtype.Timestamp `json:"updatedAt"`
	DeletedAt       pgtype.Timestamp `json:"deletedAt"`
	TenantId        pgtype.UUID      `json:"tenantId"`
	JobId           pgtype.UUID      `json:"jobId"`
	TickerId        pgtype.UUID      `json:"tickerId"`
	Status          JobRunStatus     `json:"status"`
	Result          []byte           `json:"result"`
	StartedAt       pgtype.Timestamp `json:"startedAt"`
	FinishedAt      pgtype.Timestamp `json:"finishedAt"`
	TimeoutAt       pgtype.Timestamp `json:"timeoutAt"`
	CancelledAt     pgtype.Timestamp `json:"cancelledAt"`
	CancelledReason pgtype.Text      `json:"cancelledReason"`
	CancelledError  pgtype.Text      `json:"cancelledError"`
	WorkflowRunId   pgtype.UUID      `json:"workflowRunId"`
	IdentityId      pgtype.Int8      `json:"identityId"`
}

type JobRunLookupData 

type JobRunLookupData struct {
	ID         pgtype.UUID      `json:"id"`
	CreatedAt  pgtype.Timestamp `json:"createdAt"`
	UpdatedAt  pgtype.Timestamp `json:"updatedAt"`
	DeletedAt  pgtype.Timestamp `json:"deletedAt"`
	JobRunId   pgtype.UUID      `json:"jobRunId"`
	TenantId   pgtype.UUID      `json:"tenantId"`
	Data       []byte           `json:"data"`
	IdentityId pgtype.Int8      `json:"identityId"`
}

type JobRunStatus 

type JobRunStatus string
const (
	JobRunStatusPENDING   JobRunStatus = "PENDING"
	JobRunStatusRUNNING   JobRunStatus = "RUNNING"
	JobRunStatusSUCCEEDED JobRunStatus = "SUCCEEDED"
	JobRunStatusFAILED    JobRunStatus = "FAILED"
	JobRunStatusCANCELLED JobRunStatus = "CANCELLED"
)

func (*JobRunStatus) Scan 

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

type Lease added in v0.50.0 

type Lease struct {
	ID         int64            `json:"id"`
	ExpiresAt  pgtype.Timestamp `json:"expiresAt"`
	TenantId   pgtype.UUID      `json:"tenantId"`
	ResourceId string           `json:"resourceId"`
	Kind       LeaseKind        `json:"kind"`
}

type LeaseKind added in v0.50.0 

type LeaseKind string
const (
	LeaseKindWORKER LeaseKind = "WORKER"
	LeaseKindQUEUE  LeaseKind = "QUEUE"
)

func (*LeaseKind) Scan added in v0.50.0 

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

type LimitResource 

type LimitResource string
const (
	LimitResourceWORKFLOWRUN LimitResource = "WORKFLOW_RUN"
	LimitResourceEVENT       LimitResource = "EVENT"
	LimitResourceWORKER      LimitResource = "WORKER"
	LimitResourceCRON        LimitResource = "CRON"
	LimitResourceSCHEDULE    LimitResource = "SCHEDULE"
)

func (*LimitResource) Scan 

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

type LinkActionsToWorkerParams 

type LinkActionsToWorkerParams struct {
	Actionids []pgtype.UUID `json:"actionids"`
	Workerid  pgtype.UUID   `json:"workerid"`
}

type LinkOnFailureJobParams 

type LinkOnFailureJobParams struct {
	Jobid             pgtype.UUID `json:"jobid"`
	Workflowversionid pgtype.UUID `json:"workflowversionid"`
}

type LinkServicesToWorkerParams 

type LinkServicesToWorkerParams struct {
	Services []pgtype.UUID `json:"services"`
	Workerid pgtype.UUID   `json:"workerid"`
}

type ListActionsForAvailableWorkersRow added in v0.50.0 

type ListActionsForAvailableWorkersRow struct {
	WorkerId pgtype.UUID `json:"workerId"`
	ActionId string      `json:"actionId"`
}

type ListActionsForWorkersParams added in v0.50.0 

type ListActionsForWorkersParams struct {
	Tenantid  pgtype.UUID   `json:"tenantid"`
	Workerids []pgtype.UUID `json:"workerids"`
}

type ListActionsForWorkersRow added in v0.50.0 

type ListActionsForWorkersRow struct {
	WorkerId pgtype.UUID `json:"workerId"`
	ActionId pgtype.Text `json:"actionId"`
}

type ListActiveDispatchersRow 

type ListActiveDispatchersRow struct {
	Dispatcher Dispatcher `json:"dispatcher"`
}

type ListActiveQueuedWorkflowVersionsRow added in v0.36.7 

type ListActiveQueuedWorkflowVersionsRow struct {
	WorkflowVersionId  pgtype.UUID       `json:"workflowVersionId"`
	TenantId           pgtype.UUID       `json:"tenantId"`
	Status             WorkflowRunStatus `json:"status"`
	ID                 pgtype.UUID       `json:"id"`
	ConcurrencyGroupId pgtype.Text       `json:"concurrencyGroupId"`
}

type ListActiveTickersRow 

type ListActiveTickersRow struct {
	Ticker Ticker `json:"ticker"`
}

type ListActiveWorkersRow added in v0.50.0 

type ListActiveWorkersRow struct {
	ID      pgtype.UUID `json:"id"`
	MaxRuns int32       `json:"maxRuns"`
}

type ListAllAvailableSlotsForWorkersRow added in v0.50.0 

type ListAllAvailableSlotsForWorkersRow struct {
	ID             pgtype.UUID `json:"id"`
	AvailableSlots int32       `json:"availableSlots"`
}

type ListAllWorkerActionsParams added in v0.50.0 

type ListAllWorkerActionsParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Workerid pgtype.UUID `json:"workerid"`
}

type ListAvailableSlotsForWorkersParams added in v0.44.7 

type ListAvailableSlotsForWorkersParams struct {
	Tenantid  pgtype.UUID   `json:"tenantid"`
	Workerids []pgtype.UUID `json:"workerids"`
}

type ListAvailableSlotsForWorkersRow added in v0.44.7 

type ListAvailableSlotsForWorkersRow struct {
	ID             pgtype.UUID `json:"id"`
	AvailableSlots int32       `json:"availableSlots"`
}

type ListChildWorkflowRunCountsRow added in v0.44.8 

type ListChildWorkflowRunCountsRow struct {
	ParentStepRunId pgtype.UUID `json:"parentStepRunId"`
	Count           int64       `json:"count"`
}

type ListChildWorkflowRunIdsParams added in v0.44.8 

type ListChildWorkflowRunIdsParams struct {
	Steprun  pgtype.UUID `json:"steprun"`
	Tenantid pgtype.UUID `json:"tenantid"`
}

type ListCronWorkflowsParams added in v0.51.0 

type ListCronWorkflowsParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Orderby  interface{} `json:"orderby"`
	Offset   interface{} `json:"offset"`
	Limit    interface{} `json:"limit"`
}

type ListCronWorkflowsRow added in v0.51.0 

type ListCronWorkflowsRow struct {
	Name                string           `json:"name"`
	WorkflowId          pgtype.UUID      `json:"workflowId"`
	WorkflowVersionId   pgtype.UUID      `json:"workflowVersionId"`
	TenantId            pgtype.UUID      `json:"tenantId"`
	ID                  pgtype.UUID      `json:"id"`
	CreatedAt           pgtype.Timestamp `json:"createdAt"`
	UpdatedAt           pgtype.Timestamp `json:"updatedAt"`
	DeletedAt           pgtype.Timestamp `json:"deletedAt"`
	WorkflowVersionId_2 pgtype.UUID      `json:"workflowVersionId_2"`
	TenantId_2          pgtype.UUID      `json:"tenantId_2"`
	ParentId            pgtype.UUID      `json:"parentId"`
	Cron                string           `json:"cron"`
	TickerId            pgtype.UUID      `json:"tickerId"`
	Input               []byte           `json:"input"`
	Enabled             bool             `json:"enabled"`
	AdditionalMetadata  []byte           `json:"additionalMetadata"`
	CreatedAt_2         pgtype.Timestamp `json:"createdAt_2"`
	DeletedAt_2         pgtype.Timestamp `json:"deletedAt_2"`
	UpdatedAt_2         pgtype.Timestamp `json:"updatedAt_2"`
}

type ListDispatcherIdsForWorkersParams added in v0.50.0 

type ListDispatcherIdsForWorkersParams struct {
	Tenantid  pgtype.UUID   `json:"tenantid"`
	Workerids []pgtype.UUID `json:"workerids"`
}

type ListDispatcherIdsForWorkersRow added in v0.50.0 

type ListDispatcherIdsForWorkersRow struct {
	WorkerId     pgtype.UUID `json:"workerId"`
	DispatcherId pgtype.UUID `json:"dispatcherId"`
}

type ListDispatchersRow 

type ListDispatchersRow struct {
	Dispatcher Dispatcher `json:"dispatcher"`
}

type ListEventsByIDsParams 

type ListEventsByIDsParams struct {
	Tenantid pgtype.UUID   `json:"tenantid"`
	Ids      []pgtype.UUID `json:"ids"`
}

type ListEventsParams 

type ListEventsParams struct {
	TenantId           pgtype.UUID   `json:"tenantId"`
	Orderby            interface{}   `json:"orderby"`
	EventIds           []pgtype.UUID `json:"event_ids"`
	Keys               []string      `json:"keys"`
	AdditionalMetadata []byte        `json:"additionalMetadata"`
	Workflows          []string      `json:"workflows"`
	Search             pgtype.Text   `json:"search"`
	Statuses           []string      `json:"statuses"`
	Offset             interface{}   `json:"offset"`
	Limit              interface{}   `json:"limit"`
}

type ListEventsRow 

type ListEventsRow struct {
	Event         Event `json:"event"`
	Pendingruns   int64 `json:"pendingruns"`
	Queuedruns    int64 `json:"queuedruns"`
	Runningruns   int64 `json:"runningruns"`
	Succeededruns int64 `json:"succeededruns"`
	Failedruns    int64 `json:"failedruns"`
}

type ListInternalQueueItemsParams added in v0.44.0 

type ListInternalQueueItemsParams struct {
	Tenantid pgtype.UUID   `json:"tenantid"`
	Queue    InternalQueue `json:"queue"`
	GtId     pgtype.Int8   `json:"gtId"`
	Limit    pgtype.Int4   `json:"limit"`
}

type ListJobRunsForWorkflowRunFullParams added in v0.44.8 

type ListJobRunsForWorkflowRunFullParams struct {
	Workflowrunid pgtype.UUID `json:"workflowrunid"`
	Tenantid      pgtype.UUID `json:"tenantid"`
}

type ListJobRunsForWorkflowRunFullRow added in v0.44.8 

type ListJobRunsForWorkflowRunFullRow struct {
	ID              pgtype.UUID      `json:"id"`
	CreatedAt       pgtype.Timestamp `json:"createdAt"`
	UpdatedAt       pgtype.Timestamp `json:"updatedAt"`
	DeletedAt       pgtype.Timestamp `json:"deletedAt"`
	TenantId        pgtype.UUID      `json:"tenantId"`
	JobId           pgtype.UUID      `json:"jobId"`
	TickerId        pgtype.UUID      `json:"tickerId"`
	Status          JobRunStatus     `json:"status"`
	Result          []byte           `json:"result"`
	StartedAt       pgtype.Timestamp `json:"startedAt"`
	FinishedAt      pgtype.Timestamp `json:"finishedAt"`
	TimeoutAt       pgtype.Timestamp `json:"timeoutAt"`
	CancelledAt     pgtype.Timestamp `json:"cancelledAt"`
	CancelledReason pgtype.Text      `json:"cancelledReason"`
	CancelledError  pgtype.Text      `json:"cancelledError"`
	WorkflowRunId   pgtype.UUID      `json:"workflowRunId"`
	IdentityId      pgtype.Int8      `json:"identityId"`
	Job             Job              `json:"job"`
}

type ListJobRunsForWorkflowRunRow 

type ListJobRunsForWorkflowRunRow struct {
	ID    pgtype.UUID `json:"id"`
	JobId pgtype.UUID `json:"jobId"`
}

type ListLogLinesParams 

type ListLogLinesParams struct {
	Tenantid  pgtype.UUID    `json:"tenantid"`
	StepRunId pgtype.UUID    `json:"stepRunId"`
	Search    pgtype.Text    `json:"search"`
	Levels    []LogLineLevel `json:"levels"`
	OrderBy   pgtype.Text    `json:"orderBy"`
	Offset    interface{}    `json:"offset"`
	Limit     interface{}    `json:"limit"`
}

type ListManyWorkerLabelsRow added in v0.50.0 

type ListManyWorkerLabelsRow struct {
	ID        int64            `json:"id"`
	Key       string           `json:"key"`
	IntValue  pgtype.Int4      `json:"intValue"`
	StrValue  pgtype.Text      `json:"strValue"`
	CreatedAt pgtype.Timestamp `json:"createdAt"`
	UpdatedAt pgtype.Timestamp `json:"updatedAt"`
	WorkerId  pgtype.UUID      `json:"workerId"`
}

type ListNewlyStaleTickersRow 

type ListNewlyStaleTickersRow struct {
	Ticker Ticker `json:"ticker"`
}

type ListQueueItemsBatchResults added in v0.42.0 

type ListQueueItemsBatchResults struct {
	// contains filtered or unexported fields
}

func (*ListQueueItemsBatchResults) Close added in v0.42.0 

func (b *ListQueueItemsBatchResults) Close() error

func (*ListQueueItemsBatchResults) Query added in v0.42.0 

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

type ListQueueItemsForQueueParams added in v0.50.0 

type ListQueueItemsForQueueParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Queue    string      `json:"queue"`
	GtId     pgtype.Int8 `json:"gtId"`
	Limit    pgtype.Int4 `json:"limit"`
}

type ListQueueItemsForQueueRow added in v0.50.0 

type ListQueueItemsForQueueRow struct {
	QueueItem QueueItem     `json:"queue_item"`
	Status    StepRunStatus `json:"status"`
}

type ListQueueItemsParams added in v0.42.0 

type ListQueueItemsParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Queue    string      `json:"queue"`
	GtId     pgtype.Int8 `json:"gtId"`
	Limit    pgtype.Int4 `json:"limit"`
}

type ListRateLimitsForStepsParams added in v0.42.0 

type ListRateLimitsForStepsParams struct {
	Stepids  []pgtype.UUID `json:"stepids"`
	Tenantid pgtype.UUID   `json:"tenantid"`
}

type ListRateLimitsForTenantNoMutateParams added in v0.47.0 

type ListRateLimitsForTenantNoMutateParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Search   pgtype.Text `json:"search"`
	Orderby  interface{} `json:"orderby"`
	Offset   interface{} `json:"offset"`
	Limit    interface{} `json:"limit"`
}

type ListRateLimitsForTenantNoMutateRow added in v0.47.0 

type ListRateLimitsForTenantNoMutateRow struct {
	TenantId   pgtype.UUID      `json:"tenantId"`
	Key        string           `json:"key"`
	LimitValue int32            `json:"limitValue"`
	Value      int32            `json:"value"`
	Window     string           `json:"window"`
	LastRefill pgtype.Timestamp `json:"lastRefill"`
}

type ListRateLimitsForTenantWithMutateRow added in v0.47.0 

type ListRateLimitsForTenantWithMutateRow struct {
	TenantId     pgtype.UUID      `json:"tenantId"`
	Key          string           `json:"key"`
	LimitValue   int32            `json:"limitValue"`
	Value        int32            `json:"value"`
	Window       string           `json:"window"`
	LastRefill   pgtype.Timestamp `json:"lastRefill"`
	NextRefillAt pgtype.Timestamp `json:"nextRefillAt"`
}

type ListRecentAssignedEventsForWorkerParams added in v0.44.0 

type ListRecentAssignedEventsForWorkerParams struct {
	Workerid pgtype.UUID `json:"workerid"`
	Limit    pgtype.Int4 `json:"limit"`
}

type ListRecentAssignedEventsForWorkerRow added in v0.44.0 

type ListRecentAssignedEventsForWorkerRow struct {
	WorkerId         pgtype.UUID `json:"workerId"`
	AssignedStepRuns []byte      `json:"assignedStepRuns"`
}

type ListScheduledWorkflowsParams added in v0.51.0 

type ListScheduledWorkflowsParams struct {
	Tenantid            pgtype.UUID `json:"tenantid"`
	Scheduleid          pgtype.UUID `json:"scheduleid"`
	Workflowid          pgtype.UUID `json:"workflowid"`
	Parentworkflowrunid pgtype.UUID `json:"parentworkflowrunid"`
	Parentsteprunid     pgtype.UUID `json:"parentsteprunid"`
	AdditionalMetadata  []byte      `json:"additionalMetadata"`
	Statuses            []string    `json:"statuses"`
	Includescheduled    bool        `json:"includescheduled"`
	Orderby             interface{} `json:"orderby"`
	Offset              interface{} `json:"offset"`
	Limit               interface{} `json:"limit"`
}

type ListScheduledWorkflowsRow added in v0.51.0 

type ListScheduledWorkflowsRow struct {
	Name                 string                `json:"name"`
	WorkflowId           pgtype.UUID           `json:"workflowId"`
	WorkflowVersionId    pgtype.UUID           `json:"workflowVersionId"`
	TenantId             pgtype.UUID           `json:"tenantId"`
	ID                   pgtype.UUID           `json:"id"`
	ParentId             pgtype.UUID           `json:"parentId"`
	TriggerAt            pgtype.Timestamp      `json:"triggerAt"`
	TickerId             pgtype.UUID           `json:"tickerId"`
	Input                []byte                `json:"input"`
	ChildIndex           pgtype.Int4           `json:"childIndex"`
	ChildKey             pgtype.Text           `json:"childKey"`
	ParentStepRunId      pgtype.UUID           `json:"parentStepRunId"`
	ParentWorkflowRunId  pgtype.UUID           `json:"parentWorkflowRunId"`
	AdditionalMetadata   []byte                `json:"additionalMetadata"`
	CreatedAt            pgtype.Timestamp      `json:"createdAt"`
	DeletedAt            pgtype.Timestamp      `json:"deletedAt"`
	UpdatedAt            pgtype.Timestamp      `json:"updatedAt"`
	WorkflowRunCreatedAt pgtype.Timestamp      `json:"workflowRunCreatedAt"`
	WorkflowRunStatus    NullWorkflowRunStatus `json:"workflowRunStatus"`
	WorkflowRunId        pgtype.UUID           `json:"workflowRunId"`
	WorkflowRunName      pgtype.Text           `json:"workflowRunName"`
}

type ListSemaphoreSlotsWithStateForWorkerParams added in v0.42.0 

type ListSemaphoreSlotsWithStateForWorkerParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Workerid pgtype.UUID `json:"workerid"`
	Limit    pgtype.Int4 `json:"limit"`
}

type ListSemaphoreSlotsWithStateForWorkerRow added in v0.42.0 

type ListSemaphoreSlotsWithStateForWorkerRow struct {
	StepRunId     pgtype.UUID      `json:"stepRunId"`
	Status        StepRunStatus    `json:"status"`
	ActionId      string           `json:"actionId"`
	TimeoutAt     pgtype.Timestamp `json:"timeoutAt"`
	StartedAt     pgtype.Timestamp `json:"startedAt"`
	WorkflowRunId pgtype.UUID      `json:"workflowRunId"`
}

type ListStaleDispatchersRow 

type ListStaleDispatchersRow struct {
	Dispatcher Dispatcher `json:"dispatcher"`
}

type ListStepRunArchivesParams added in v0.34.2 

type ListStepRunArchivesParams struct {
	Steprunid pgtype.UUID `json:"steprunid"`
	Tenantid  pgtype.UUID `json:"tenantid"`
	Offset    interface{} `json:"offset"`
	Limit     interface{} `json:"limit"`
}

type ListStepRunEventsByWorkflowRunIdParams added in v0.44.8 

type ListStepRunEventsByWorkflowRunIdParams struct {
	Workflowrunid pgtype.UUID `json:"workflowrunid"`
	Tenantid      pgtype.UUID `json:"tenantid"`
	LastId        pgtype.Int8 `json:"lastId"`
}

type ListStepRunEventsParams 

type ListStepRunEventsParams struct {
	Steprunid pgtype.UUID `json:"steprunid"`
	Offset    interface{} `json:"offset"`
	Limit     interface{} `json:"limit"`
}

type ListStepRunsParams 

type ListStepRunsParams struct {
	TenantId       pgtype.UUID       `json:"tenantId"`
	Status         NullStepRunStatus `json:"status"`
	WorkflowRunIds []pgtype.UUID     `json:"workflowRunIds"`
	JobRunId       pgtype.UUID       `json:"jobRunId"`
	TickerId       pgtype.UUID       `json:"tickerId"`
}

type ListStepRunsToCancelParams added in v0.51.2 

type ListStepRunsToCancelParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Jobrunid pgtype.UUID `json:"jobrunid"`
}

type ListStepRunsToReassignParams added in v0.36.5 

type ListStepRunsToReassignParams struct {
	Tenantid              pgtype.UUID `json:"tenantid"`
	Maxinternalretrycount int32       `json:"maxinternalretrycount"`
}

type ListStepRunsToReassignRow added in v0.44.0 

type ListStepRunsToReassignRow struct {
	ID         pgtype.UUID `json:"id"`
	WorkerId   pgtype.UUID `json:"workerId"`
	RetryCount int32       `json:"retryCount"`
	Operation  string      `json:"operation"`
}

type ListStepsForJobRow added in v0.42.0 

type ListStepsForJobRow struct {
	ID       pgtype.UUID `json:"id"`
	ActionId string      `json:"actionId"`
}

type ListTickersParams 

type ListTickersParams struct {
	IsActive           bool             `json:"isActive"`
	LastHeartbeatAfter pgtype.Timestamp `json:"lastHeartbeatAfter"`
}

type ListWorkerLabelsRow added in v0.40.0 

type ListWorkerLabelsRow struct {
	ID        int64            `json:"id"`
	Key       string           `json:"key"`
	IntValue  pgtype.Int4      `json:"intValue"`
	StrValue  pgtype.Text      `json:"strValue"`
	CreatedAt pgtype.Timestamp `json:"createdAt"`
	UpdatedAt pgtype.Timestamp `json:"updatedAt"`
}

type ListWorkersWithSlotCountParams added in v0.44.0 

type ListWorkersWithSlotCountParams struct {
	Tenantid           pgtype.UUID      `json:"tenantid"`
	ActionId           pgtype.Text      `json:"actionId"`
	LastHeartbeatAfter pgtype.Timestamp `json:"lastHeartbeatAfter"`
	Assignable         pgtype.Bool      `json:"assignable"`
}

type ListWorkersWithSlotCountRow added in v0.44.0 

type ListWorkersWithSlotCountRow struct {
	Worker         Worker      `json:"worker"`
	WebhookUrl     pgtype.Text `json:"webhookUrl"`
	WebhookId      pgtype.UUID `json:"webhookId"`
	RemainingSlots int32       `json:"remainingSlots"`
}

type ListWorkflowRunsParams 

type ListWorkflowRunsParams struct {
	TenantId           pgtype.UUID      `json:"tenantId"`
	EventId            pgtype.UUID      `json:"eventId"`
	WorkflowVersionId  pgtype.UUID      `json:"workflowVersionId"`
	Kinds              []string         `json:"kinds"`
	WorkflowId         pgtype.UUID      `json:"workflowId"`
	Ids                []pgtype.UUID    `json:"ids"`
	AdditionalMetadata []byte           `json:"additionalMetadata"`
	ParentId           pgtype.UUID      `json:"parentId"`
	ParentStepRunId    pgtype.UUID      `json:"parentStepRunId"`
	GroupKey           pgtype.Text      `json:"groupKey"`
	Statuses           []string         `json:"statuses"`
	CreatedAfter       pgtype.Timestamp `json:"createdAfter"`
	CreatedBefore      pgtype.Timestamp `json:"createdBefore"`
	FinishedAfter      pgtype.Timestamp `json:"finishedAfter"`
	FinishedBefore     pgtype.Timestamp `json:"finishedBefore"`
	Orderby            interface{}      `json:"orderby"`
	Offset             interface{}      `json:"offset"`
	Limit              interface{}      `json:"limit"`
}

type ListWorkflowRunsRow 

type ListWorkflowRunsRow struct {
	WorkflowRun            WorkflowRun            `json:"workflow_run"`
	Workflow               Workflow               `json:"workflow"`
	WorkflowRunTriggeredBy WorkflowRunTriggeredBy `json:"workflow_run_triggered_by"`
	WorkflowVersion        WorkflowVersion        `json:"workflow_version"`
	ID                     pgtype.UUID            `json:"id"`
	Key                    pgtype.Text            `json:"key"`
	CreatedAt              pgtype.Timestamp       `json:"createdAt"`
	UpdatedAt              pgtype.Timestamp       `json:"updatedAt"`
}

type ListWorkflowsForEventParams 

type ListWorkflowsForEventParams struct {
	Eventkey string      `json:"eventkey"`
	Tenantid pgtype.UUID `json:"tenantid"`
}

type ListWorkflowsLatestRunsParams 

type ListWorkflowsLatestRunsParams struct {
	TenantId pgtype.UUID `json:"tenantId"`
	EventKey pgtype.Text `json:"eventKey"`
}

type ListWorkflowsLatestRunsRow 

type ListWorkflowsLatestRunsRow struct {
	WorkflowRun WorkflowRun `json:"workflow_run"`
	WorkflowId  pgtype.UUID `json:"workflowId"`
}

type ListWorkflowsParams 

type ListWorkflowsParams struct {
	TenantId pgtype.UUID `json:"tenantId"`
	Orderby  interface{} `json:"orderby"`
	Offset   interface{} `json:"offset"`
	Limit    interface{} `json:"limit"`
}

type ListWorkflowsRow 

type ListWorkflowsRow struct {
	Workflow Workflow `json:"workflow"`
}

type LogLine 

type LogLine struct {
	ID        int64            `json:"id"`
	CreatedAt pgtype.Timestamp `json:"createdAt"`
	TenantId  pgtype.UUID      `json:"tenantId"`
	StepRunId pgtype.UUID      `json:"stepRunId"`
	Message   string           `json:"message"`
	Level     LogLineLevel     `json:"level"`
	Metadata  []byte           `json:"metadata"`
}

type LogLineLevel 

type LogLineLevel string
const (
	LogLineLevelDEBUG LogLineLevel = "DEBUG"
	LogLineLevelINFO  LogLineLevel = "INFO"
	LogLineLevelWARN  LogLineLevel = "WARN"
	LogLineLevelERROR LogLineLevel = "ERROR"
)

func (*LogLineLevel) Scan 

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

type ManualReleaseSemaphoreParams added in v0.44.0 

type ManualReleaseSemaphoreParams struct {
	Steprunid pgtype.UUID `json:"steprunid"`
	Tenantid  pgtype.UUID `json:"tenantid"`
}

type MeterTenantResourceParams 

type MeterTenantResourceParams struct {
	Numresources int32             `json:"numresources"`
	Tenantid     pgtype.UUID       `json:"tenantid"`
	Resource     NullLimitResource `json:"resource"`
}

type NullConcurrencyLimitStrategy 

type NullConcurrencyLimitStrategy struct {
	ConcurrencyLimitStrategy ConcurrencyLimitStrategy `json:"ConcurrencyLimitStrategy"`
	Valid                    bool                     `json:"valid"` // Valid is true if ConcurrencyLimitStrategy is not NULL
}

func (*NullConcurrencyLimitStrategy) Scan 

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

Scan implements the Scanner interface.

func (NullConcurrencyLimitStrategy) Value 

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

Value implements the driver Valuer interface.

type NullInternalQueue added in v0.44.0 

type NullInternalQueue struct {
	InternalQueue InternalQueue `json:"InternalQueue"`
	Valid         bool          `json:"valid"` // Valid is true if InternalQueue is not NULL
}

func (*NullInternalQueue) Scan added in v0.44.0 

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

Scan implements the Scanner interface.

func (NullInternalQueue) Value added in v0.44.0 

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

Value implements the driver Valuer interface.

type NullInviteLinkStatus 

type NullInviteLinkStatus struct {
	InviteLinkStatus InviteLinkStatus `json:"InviteLinkStatus"`
	Valid            bool             `json:"valid"` // Valid is true if InviteLinkStatus is not NULL
}

func (*NullInviteLinkStatus) Scan 

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

Scan implements the Scanner interface.

func (NullInviteLinkStatus) Value 

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

Value implements the driver Valuer interface.

type NullJobKind 

type NullJobKind struct {
	JobKind JobKind `json:"JobKind"`
	Valid   bool    `json:"valid"` // Valid is true if JobKind is not NULL
}

func (*NullJobKind) Scan 

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

Scan implements the Scanner interface.

func (NullJobKind) Value 

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

Value implements the driver Valuer interface.

type NullJobRunStatus 

type NullJobRunStatus struct {
	JobRunStatus JobRunStatus `json:"JobRunStatus"`
	Valid        bool         `json:"valid"` // Valid is true if JobRunStatus is not NULL
}

func (*NullJobRunStatus) Scan 

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

Scan implements the Scanner interface.

func (NullJobRunStatus) Value 

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

Value implements the driver Valuer interface.

type NullLeaseKind added in v0.50.0 

type NullLeaseKind struct {
	LeaseKind LeaseKind `json:"LeaseKind"`
	Valid     bool      `json:"valid"` // Valid is true if LeaseKind is not NULL
}

func (*NullLeaseKind) Scan added in v0.50.0 

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

Scan implements the Scanner interface.

func (NullLeaseKind) Value added in v0.50.0 

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

Value implements the driver Valuer interface.

type NullLimitResource 

type NullLimitResource struct {
	LimitResource LimitResource `json:"LimitResource"`
	Valid         bool          `json:"valid"` // Valid is true if LimitResource is not NULL
}

func (*NullLimitResource) Scan 

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

Scan implements the Scanner interface.

func (NullLimitResource) Value 

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

Value implements the driver Valuer interface.

type NullLogLineLevel 

type NullLogLineLevel struct {
	LogLineLevel LogLineLevel `json:"LogLineLevel"`
	Valid        bool         `json:"valid"` // Valid is true if LogLineLevel is not NULL
}

func (*NullLogLineLevel) Scan 

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

Scan implements the Scanner interface.

func (NullLogLineLevel) Value 

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

Value implements the driver Valuer interface.

type NullStepExpressionKind added in v0.47.0 

type NullStepExpressionKind struct {
	StepExpressionKind StepExpressionKind `json:"StepExpressionKind"`
	Valid              bool               `json:"valid"` // Valid is true if StepExpressionKind is not NULL
}

func (*NullStepExpressionKind) Scan added in v0.47.0 

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

Scan implements the Scanner interface.

func (NullStepExpressionKind) Value added in v0.47.0 

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

Value implements the driver Valuer interface.

type NullStepRateLimitKind added in v0.47.0 

type NullStepRateLimitKind struct {
	StepRateLimitKind StepRateLimitKind `json:"StepRateLimitKind"`
	Valid             bool              `json:"valid"` // Valid is true if StepRateLimitKind is not NULL
}

func (*NullStepRateLimitKind) Scan added in v0.47.0 

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

Scan implements the Scanner interface.

func (NullStepRateLimitKind) Value added in v0.47.0 

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

Value implements the driver Valuer interface.

type NullStepRunEventReason 

type NullStepRunEventReason struct {
	StepRunEventReason StepRunEventReason `json:"StepRunEventReason"`
	Valid              bool               `json:"valid"` // Valid is true if StepRunEventReason is not NULL
}

func (*NullStepRunEventReason) Scan 

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

Scan implements the Scanner interface.

func (NullStepRunEventReason) Value 

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

Value implements the driver Valuer interface.

type NullStepRunEventSeverity 

type NullStepRunEventSeverity struct {
	StepRunEventSeverity StepRunEventSeverity `json:"StepRunEventSeverity"`
	Valid                bool                 `json:"valid"` // Valid is true if StepRunEventSeverity is not NULL
}

func (*NullStepRunEventSeverity) Scan 

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

Scan implements the Scanner interface.

func (NullStepRunEventSeverity) Value 

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

Value implements the driver Valuer interface.

type NullStepRunStatus 

type NullStepRunStatus struct {
	StepRunStatus StepRunStatus `json:"StepRunStatus"`
	Valid         bool          `json:"valid"` // Valid is true if StepRunStatus is not NULL
}

func (*NullStepRunStatus) Scan 

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

Scan implements the Scanner interface.

func (NullStepRunStatus) Value 

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

Value implements the driver Valuer interface.

type NullStickyStrategy added in v0.40.0 

type NullStickyStrategy struct {
	StickyStrategy StickyStrategy `json:"StickyStrategy"`
	Valid          bool           `json:"valid"` // Valid is true if StickyStrategy is not NULL
}

func (*NullStickyStrategy) Scan added in v0.40.0 

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

Scan implements the Scanner interface.

func (NullStickyStrategy) Value added in v0.40.0 

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

Value implements the driver Valuer interface.

type NullTenantMemberRole 

type NullTenantMemberRole struct {
	TenantMemberRole TenantMemberRole `json:"TenantMemberRole"`
	Valid            bool             `json:"valid"` // Valid is true if TenantMemberRole is not NULL
}

func (*NullTenantMemberRole) Scan 

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

Scan implements the Scanner interface.

func (NullTenantMemberRole) Value 

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

Value implements the driver Valuer interface.

type NullTenantResourceLimitAlertType 

type NullTenantResourceLimitAlertType struct {
	TenantResourceLimitAlertType TenantResourceLimitAlertType `json:"TenantResourceLimitAlertType"`
	Valid                        bool                         `json:"valid"` // Valid is true if TenantResourceLimitAlertType is not NULL
}

func (*NullTenantResourceLimitAlertType) Scan 

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

Scan implements the Scanner interface.

func (NullTenantResourceLimitAlertType) Value 

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

Value implements the driver Valuer interface.

type NullVcsProvider 

type NullVcsProvider struct {
	VcsProvider VcsProvider `json:"VcsProvider"`
	Valid       bool        `json:"valid"` // Valid is true if VcsProvider is not NULL
}

func (*NullVcsProvider) Scan 

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

Scan implements the Scanner interface.

func (NullVcsProvider) Value 

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

Value implements the driver Valuer interface.

type NullWebhookWorkerRequestMethod added in v0.42.13 

type NullWebhookWorkerRequestMethod struct {
	WebhookWorkerRequestMethod WebhookWorkerRequestMethod `json:"WebhookWorkerRequestMethod"`
	Valid                      bool                       `json:"valid"` // Valid is true if WebhookWorkerRequestMethod is not NULL
}

func (*NullWebhookWorkerRequestMethod) Scan added in v0.42.13 

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

Scan implements the Scanner interface.

func (NullWebhookWorkerRequestMethod) Value added in v0.42.13 

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

Value implements the driver Valuer interface.

type NullWorkerLabelComparator added in v0.40.0 

type NullWorkerLabelComparator struct {
	WorkerLabelComparator WorkerLabelComparator `json:"WorkerLabelComparator"`
	Valid                 bool                  `json:"valid"` // Valid is true if WorkerLabelComparator is not NULL
}

func (*NullWorkerLabelComparator) Scan added in v0.40.0 

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

Scan implements the Scanner interface.

func (NullWorkerLabelComparator) Value added in v0.40.0 

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

Value implements the driver Valuer interface.

type NullWorkerSDKS added in v0.50.4 

type NullWorkerSDKS struct {
	WorkerSDKS WorkerSDKS `json:"WorkerSDKS"`
	Valid      bool       `json:"valid"` // Valid is true if WorkerSDKS is not NULL
}

func (*NullWorkerSDKS) Scan added in v0.50.4 

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

Scan implements the Scanner interface.

func (NullWorkerSDKS) Value added in v0.50.4 

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

Value implements the driver Valuer interface.

type NullWorkerType added in v0.42.10 

type NullWorkerType struct {
	WorkerType WorkerType `json:"WorkerType"`
	Valid      bool       `json:"valid"` // Valid is true if WorkerType is not NULL
}

func (*NullWorkerType) Scan added in v0.42.10 

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

Scan implements the Scanner interface.

func (NullWorkerType) Value added in v0.42.10 

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

Value implements the driver Valuer interface.

type NullWorkflowKind added in v0.41.0 

type NullWorkflowKind struct {
	WorkflowKind WorkflowKind `json:"WorkflowKind"`
	Valid        bool         `json:"valid"` // Valid is true if WorkflowKind is not NULL
}

func (*NullWorkflowKind) Scan added in v0.41.0 

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

Scan implements the Scanner interface.

func (NullWorkflowKind) Value added in v0.41.0 

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

Value implements the driver Valuer interface.

type NullWorkflowRunStatus 

type NullWorkflowRunStatus struct {
	WorkflowRunStatus WorkflowRunStatus `json:"WorkflowRunStatus"`
	Valid             bool              `json:"valid"` // Valid is true if WorkflowRunStatus is not NULL
}

func (*NullWorkflowRunStatus) Scan 

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

Scan implements the Scanner interface.

func (NullWorkflowRunStatus) Value 

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

Value implements the driver Valuer interface.

type PollCronSchedulesRow 

type PollCronSchedulesRow struct {
	ParentId           pgtype.UUID      `json:"parentId"`
	Cron               string           `json:"cron"`
	TickerId           pgtype.UUID      `json:"tickerId"`
	Input              []byte           `json:"input"`
	Enabled            bool             `json:"enabled"`
	AdditionalMetadata []byte           `json:"additionalMetadata"`
	CreatedAt          pgtype.Timestamp `json:"createdAt"`
	DeletedAt          pgtype.Timestamp `json:"deletedAt"`
	UpdatedAt          pgtype.Timestamp `json:"updatedAt"`
	WorkflowVersionId  pgtype.UUID      `json:"workflowVersionId"`
	TenantId           pgtype.UUID      `json:"tenantId"`
}

type PollExpiringTokensRow 

type PollExpiringTokensRow struct {
	ID        pgtype.UUID      `json:"id"`
	Name      pgtype.Text      `json:"name"`
	TenantId  pgtype.UUID      `json:"tenantId"`
	ExpiresAt pgtype.Timestamp `json:"expiresAt"`
}

type PollScheduledWorkflowsRow 

type PollScheduledWorkflowsRow struct {
	ID                  pgtype.UUID      `json:"id"`
	ParentId            pgtype.UUID      `json:"parentId"`
	TriggerAt           pgtype.Timestamp `json:"triggerAt"`
	TickerId            pgtype.UUID      `json:"tickerId"`
	Input               []byte           `json:"input"`
	ChildIndex          pgtype.Int4      `json:"childIndex"`
	ChildKey            pgtype.Text      `json:"childKey"`
	ParentStepRunId     pgtype.UUID      `json:"parentStepRunId"`
	ParentWorkflowRunId pgtype.UUID      `json:"parentWorkflowRunId"`
	AdditionalMetadata  []byte           `json:"additionalMetadata"`
	CreatedAt           pgtype.Timestamp `json:"createdAt"`
	DeletedAt           pgtype.Timestamp `json:"deletedAt"`
	UpdatedAt           pgtype.Timestamp `json:"updatedAt"`
	WorkflowVersionId   pgtype.UUID      `json:"workflowVersionId"`
	TenantId            pgtype.UUID      `json:"tenantId"`
}

type PollTenantAlertsRow 

type PollTenantAlertsRow struct {
	ID                              pgtype.UUID      `json:"id"`
	CreatedAt                       pgtype.Timestamp `json:"createdAt"`
	UpdatedAt                       pgtype.Timestamp `json:"updatedAt"`
	DeletedAt                       pgtype.Timestamp `json:"deletedAt"`
	TenantId                        pgtype.UUID      `json:"tenantId"`
	MaxFrequency                    string           `json:"maxFrequency"`
	LastAlertedAt                   pgtype.Timestamp `json:"lastAlertedAt"`
	TickerId                        pgtype.UUID      `json:"tickerId"`
	EnableExpiringTokenAlerts       bool             `json:"enableExpiringTokenAlerts"`
	EnableWorkflowRunFailureAlerts  bool             `json:"enableWorkflowRunFailureAlerts"`
	EnableTenantResourceLimitAlerts bool             `json:"enableTenantResourceLimitAlerts"`
	PrevLastAlertedAt               pgtype.Timestamp `json:"prevLastAlertedAt"`
}

type PollUnresolvedFailedStepRunsRow added in v0.36.7 

type PollUnresolvedFailedStepRunsRow struct {
	ID       pgtype.UUID `json:"id"`
	TenantId pgtype.UUID `json:"tenantId"`
}

type PopTimeoutQueueItemsParams added in v0.44.5 

type PopTimeoutQueueItemsParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Limit    pgtype.Int4 `json:"limit"`
}

type PopWorkflowRunsRoundRobinParams 

type PopWorkflowRunsRoundRobinParams struct {
	Tenantid   pgtype.UUID `json:"tenantid"`
	Workflowid pgtype.UUID `json:"workflowid"`
	Maxruns    int32       `json:"maxruns"`
}

type Queries 

type Queries struct {
}

func New 

func New() *Queries

func (*Queries) AcquireOrExtendLeases added in v0.50.0 

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

Attempts to acquire leases for a set of resources, and extends the leases if we already have them. Returns the acquired leases. On conflict, acquire the lease if the existing lease has expired.

func (*Queries) AddStepParents 

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

func (*Queries) AddWorkflowTag 

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

func (*Queries) ArchiveStepRunResultFromStepRun 

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

func (*Queries) AssignGetGroupKeyRunToTicker 

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

func (*Queries) AssignGetGroupKeyRunToWorker 

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

func (*Queries) BulkCancelStepRun added in v0.44.5 

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

func (*Queries) BulkCreateStepRunEvent added in v0.42.0 

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

func (*Queries) BulkCreateWorkflowRunEvent added in v0.45.0 

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

func (*Queries) BulkFailStepRun added in v0.44.5 

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

func (*Queries) BulkFinishStepRun added in v0.44.5 

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

func (*Queries) BulkMarkStepRunsAsCancelling added in v0.42.0 

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

func (*Queries) BulkQueueItems added in v0.42.0 

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

func (*Queries) BulkStartStepRun added in v0.44.5 

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

func (*Queries) BulkUpdateRateLimits added in v0.42.0 

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

func (*Queries) CheckWorker added in v0.40.0 

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

func (*Queries) CleanupInternalQueueItems added in v0.44.0 

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

func (*Queries) CleanupQueueItems added in v0.43.2 

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

func (*Queries) CleanupStreamEvents 

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

func (*Queries) CleanupTimeoutQueueItems added in v0.44.5 

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

func (*Queries) ClearEventPayloadData added in v0.39.0 

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

func (*Queries) ClearJobRunLookupData added in v0.39.0 

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

func (*Queries) ClearStepRunPayloadData added in v0.39.0 

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

func (*Queries) ControllerPartitionHeartbeat added in v0.42.0 

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

func (*Queries) CountCronWorkflows added in v0.51.0 

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

func (*Queries) CountEvents 

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

func (*Queries) CountLogLines 

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

func (*Queries) CountRateLimits added in v0.47.0 

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

func (*Queries) CountRoundRobinGroupKeys 

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

func (*Queries) CountScheduledWorkflows added in v0.51.0 

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

func (*Queries) CountStepRunArchives added in v0.34.2 

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

func (*Queries) CountStepRunEvents 

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

func (*Queries) CountTenantWorkers 

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

func (*Queries) CountWorkflowRuns 

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

func (*Queries) CountWorkflowRunsRoundRobin 

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

func (*Queries) CountWorkflows 

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

func (*Queries) CreateAPIToken 

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

func (*Queries) CreateControllerPartition added in v0.34.2 

func (q *Queries) CreateControllerPartition(ctx context.Context, db DBTX, name pgtype.Text) (*ControllerPartition, error)

func (*Queries) CreateDispatcher 

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

func (*Queries) CreateEvent 

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

func (*Queries) CreateEventKeys added in v0.49.3 

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

func (*Queries) CreateEvents added in v0.46.0 

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

func (*Queries) CreateGetGroupKeyRun 

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

func (*Queries) CreateGetGroupKeyRuns added in v0.50.0 

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

func (*Queries) CreateInternalQueueItemsBulk added in v0.44.0 

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

func (*Queries) CreateJob 

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

func (*Queries) CreateJobRunLookupData 

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

func (*Queries) CreateJobRunLookupDatas added in v0.50.0 

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

func (*Queries) CreateJobRuns 

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

func (*Queries) CreateLogLine 

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

func (*Queries) CreateManyJobRuns added in v0.50.0 

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

func (*Queries) CreateMultipleWorkflowRunStickyStates added in v0.50.0 

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

func (*Queries) CreateQueueItem added in v0.42.0 

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

func (*Queries) CreateQueueItemsBulk added in v0.50.0 

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

func (*Queries) CreateSchedulerPartition added in v0.50.0 

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

func (*Queries) CreateSchedules 

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

func (*Queries) CreateStep 

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

func (*Queries) CreateStepExpressions added in v0.47.0 

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

func (*Queries) CreateStepRateLimit 

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

func (*Queries) CreateStepRun added in v0.42.0 

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

func (*Queries) CreateStepRunEvent 

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

func (*Queries) CreateStepRunExpressionEvalInts added in v0.47.0 

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

func (*Queries) CreateStepRunExpressionEvalStrs added in v0.47.0 

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

func (*Queries) CreateStepRuns 

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

func (*Queries) CreateStepRunsForJobRunIds added in v0.50.0 

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

func (*Queries) CreateStreamEvent 

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

func (*Queries) CreateTenant added in v0.34.2 

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

func (*Queries) CreateTenantAlertingSettings added in v0.34.2 

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

func (*Queries) CreateTenantWorkerPartition added in v0.34.2 

func (q *Queries) CreateTenantWorkerPartition(ctx context.Context, db DBTX, name pgtype.Text) (*TenantWorkerPartition, error)

func (*Queries) CreateTicker 

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

func (*Queries) CreateTimeoutQueueItem added in v0.44.5 

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

func (*Queries) CreateUniqueInternalQueueItemsBulk added in v0.44.0 

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

func (*Queries) CreateWebhookWorker added in v0.42.13 

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

func (*Queries) CreateWorker 

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

func (*Queries) CreateWorkerAssignEvents added in v0.44.0 

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

func (*Queries) CreateWorkflow 

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

func (*Queries) CreateWorkflowConcurrency 

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

func (*Queries) CreateWorkflowRun 

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

func (*Queries) CreateWorkflowRunDedupe added in v0.40.0 

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

func (*Queries) CreateWorkflowRunStickyState added in v0.40.0 

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

func (*Queries) CreateWorkflowRunTriggeredBy 

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

func (*Queries) CreateWorkflowRunTriggeredBys added in v0.50.0 

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

func (*Queries) CreateWorkflowRuns added in v0.50.0 

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

func (*Queries) CreateWorkflowTriggerCronRef 

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

func (*Queries) CreateWorkflowTriggerEventRef 

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

func (*Queries) CreateWorkflowTriggerScheduledRef 

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

func (*Queries) CreateWorkflowTriggers 

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

func (*Queries) CreateWorkflowVersion 

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

func (*Queries) DeactivateTicker added in v0.42.0 

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

func (*Queries) DeleteControllerPartition added in v0.34.2 

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

func (*Queries) DeleteDispatcher 

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

func (*Queries) DeleteOldWorkerAssignEvents added in v0.44.3 

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

delete worker assign events outside of the first <maxRuns> events for a worker

func (*Queries) DeleteOldWorkers added in v0.44.0 

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

func (*Queries) DeleteScheduledWorkflow added in v0.51.0 

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

func (*Queries) DeleteSchedulerPartition added in v0.50.0 

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

func (*Queries) DeleteTenantWorkerPartition added in v0.34.2 

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

func (*Queries) DeleteWorker 

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

func (*Queries) GetAPITokenById 

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

func (*Queries) GetChildWorkflowRun 

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

func (*Queries) GetChildWorkflowRunsByIndex added in v0.50.0 

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

func (*Queries) GetChildWorkflowRunsByKey added in v0.50.0 

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

func (*Queries) GetDesiredLabels added in v0.42.0 

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

func (*Queries) GetEmailGroups 

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

func (*Queries) GetEventForEngine 

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

func (*Queries) GetEventsForRange 

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

func (*Queries) GetFailureDetails added in v0.51.0 

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

func (*Queries) GetFinalizedStepRuns added in v0.44.0 

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

func (*Queries) GetGroupKeyRunForEngine 

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

func (*Queries) GetInsertedEvents added in v0.46.0 

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

func (*Queries) GetJobRunByWorkflowRunIdAndJobId 

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

func (*Queries) GetJobRunsByWorkflowRunId added in v0.50.0 

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

func (*Queries) GetLaterStepRuns added in v0.44.0 

func (q *Queries) GetLaterStepRuns(ctx context.Context, db DBTX, steprunid pgtype.UUID) ([]*StepRun, error)

func (*Queries) GetLatestWorkflowVersionForWorkflows added in v0.50.0 

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

func (*Queries) GetLeasesToAcquire added in v0.50.0 

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

func (*Queries) GetMemberEmailGroup 

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

func (*Queries) GetMinMaxProcessedInternalQueueItems added in v0.44.0 

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

func (*Queries) GetMinMaxProcessedQueueItems added in v0.43.2 

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

func (*Queries) GetMinMaxProcessedTimeoutQueueItems added in v0.44.5 

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

func (*Queries) GetMinUnprocessedQueueItemId added in v0.50.0 

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

func (*Queries) GetQueuedCounts added in v0.46.1 

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

func (*Queries) GetScheduledChildWorkflowRun 

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

func (*Queries) GetSecurityCheckIdent added in v0.34.2 

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

func (*Queries) GetSlackWebhooks 

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

func (*Queries) GetStepDesiredWorkerLabels added in v0.40.0 

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

func (*Queries) GetStepExpressions added in v0.47.0 

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

func (*Queries) GetStepRun 

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

func (*Queries) GetStepRunBulkDataForEngine added in v0.50.0 

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

func (*Queries) GetStepRunDataForEngine added in v0.36.9 

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

func (*Queries) GetStepRunForEngine 

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

func (*Queries) GetStepRunMeta added in v0.41.0 

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

func (*Queries) GetStepRunsForJobRunsWithOutput added in v0.46.1 

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

We grab the output for each step run here which could potentially be very large

func (*Queries) GetStepsForJobs added in v0.44.8 

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

func (*Queries) GetStepsForWorkflowVersion added in v0.50.0 

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

func (*Queries) GetStreamEvent 

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

func (*Queries) GetStreamEventMeta added in v0.41.0 

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

func (*Queries) GetTenantAlertingSettings 

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

func (*Queries) GetTenantByID 

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

func (*Queries) GetTenantResourceLimit 

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

func (*Queries) GetTenantTotalQueueMetrics 

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

func (*Queries) GetTenantWorkflowQueueMetrics 

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

func (*Queries) GetWorkerActionsByWorkerId added in v0.42.13 

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

func (*Queries) GetWorkerById added in v0.42.10 

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

func (*Queries) GetWorkerByWebhookId added in v0.42.10 

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

func (*Queries) GetWorkerDispatcherActions added in v0.44.0 

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

func (*Queries) GetWorkerForEngine 

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

func (*Queries) GetWorkerLabels added in v0.42.0 

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

func (*Queries) GetWorkflowById added in v0.44.8 

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

func (*Queries) GetWorkflowByName 

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

func (*Queries) GetWorkflowLatestVersion 

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

func (*Queries) GetWorkflowRun 

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

func (*Queries) GetWorkflowRunAdditionalMeta added in v0.41.0 

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

func (*Queries) GetWorkflowRunById added in v0.44.8 

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

func (*Queries) GetWorkflowRunByIds added in v0.50.0 

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

func (*Queries) GetWorkflowRunInput added in v0.40.0 

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

func (*Queries) GetWorkflowRunStickyStateForUpdate added in v0.40.0 

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

func (*Queries) GetWorkflowRunTrigger added in v0.44.8 

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

func (*Queries) GetWorkflowRunsInsertedInThisTxn added in v0.50.0 

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

func (*Queries) GetWorkflowVersionById added in v0.44.8 

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

func (*Queries) GetWorkflowVersionCronTriggerRefs added in v0.44.8 

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

func (*Queries) GetWorkflowVersionEventTriggerRefs added in v0.44.8 

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

func (*Queries) GetWorkflowVersionForEngine 

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

func (*Queries) GetWorkflowVersionScheduleTriggerRefs added in v0.44.8 

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

func (*Queries) GetWorkflowWorkerCount added in v0.45.2 

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

func (*Queries) GetWorkflowsByNames added in v0.50.0 

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

func (*Queries) HandleWorkflowUnpaused added in v0.48.0 

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

We update all the queue items to have a higher priority so we can unpause them

func (*Queries) HardDeleteWebhookWorker added in v0.42.13 

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

func (*Queries) HasActiveWorkersForActionId added in v0.44.8 

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

func (*Queries) Health 

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

func (*Queries) InsertWebhookWorkerRequest added in v0.42.13 

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

func (*Queries) LinkActionsToWorker 

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

func (*Queries) LinkOnFailureJob 

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

func (*Queries) LinkServicesToWorker 

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

func (*Queries) LinkStepRunParents 

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

func (*Queries) ListActionsForAvailableWorkers added in v0.50.0 

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

func (*Queries) ListActionsForWorkers added in v0.50.0 

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

func (*Queries) ListActiveDispatchers 

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

func (*Queries) ListActiveQueuedWorkflowVersions added in v0.36.7 

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

func (*Queries) ListActiveTickers 

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

func (*Queries) ListActiveWebhookWorkers added in v0.34.0 

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

func (*Queries) ListActiveWorkers added in v0.50.0 

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

func (*Queries) ListAllAvailableSlotsForWorkers added in v0.50.0 

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

subtract the filled slots from the max runs to get the available slots

func (*Queries) ListAllWorkerActions added in v0.50.0 

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

func (*Queries) ListAvailableSlotsForWorkers added in v0.44.7 

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

subtract the filled slots from the max runs to get the available slots

func (*Queries) ListChildWorkflowRunCounts added in v0.44.8 

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

func (*Queries) ListChildWorkflowRunIds added in v0.44.8 

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

func (*Queries) ListCronWorkflows added in v0.51.0 

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

func (*Queries) ListDispatcherIdsForWorkers added in v0.50.0 

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

func (*Queries) ListDispatchers 

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

func (*Queries) ListEventKeys added in v0.49.3 

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

func (*Queries) ListEvents 

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

func (*Queries) ListEventsByIDs 

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

func (*Queries) ListGetGroupKeyRunsToReassign 

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

func (*Queries) ListGetGroupKeyRunsToRequeue 

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

func (*Queries) ListInitialStepRuns added in v0.44.0 

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

func (*Queries) ListInternalQueueItems added in v0.44.0 

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

func (*Queries) ListJobRunsForWorkflowRun 

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

func (*Queries) ListJobRunsForWorkflowRunFull added in v0.44.8 

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

func (*Queries) ListLogLines 

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

func (*Queries) ListManyWorkerLabels added in v0.50.0 

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

func (*Queries) ListNewlyStaleTickers 

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

func (*Queries) ListNonFinalChildStepRuns 

func (q *Queries) ListNonFinalChildStepRuns(ctx context.Context, db DBTX, steprunid pgtype.UUID) ([]*StepRun, error)

Select all child step runs that are not in a final state

func (*Queries) ListPausedWorkflows added in v0.48.0 

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

func (*Queries) ListQueueItems added in v0.42.0 

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

func (*Queries) ListQueueItemsForQueue added in v0.50.0 

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

func (*Queries) ListQueues added in v0.42.0 

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

func (*Queries) ListRateLimitsForSteps added in v0.42.0 

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

func (*Queries) ListRateLimitsForTenantNoMutate added in v0.47.0 

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

Returns the same results as ListRateLimitsForTenantWithMutate but does not update the rate limit values

func (*Queries) ListRateLimitsForTenantWithMutate added in v0.47.0 

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

func (*Queries) ListRecentAssignedEventsForWorker added in v0.44.0 

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

func (*Queries) ListScheduledWorkflows added in v0.51.0 

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

func (*Queries) ListSemaphoreSlotsWithStateForWorker added in v0.42.0 

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

func (*Queries) ListStaleDispatchers 

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

func (*Queries) ListStartableStepRunsManyParents added in v0.49.1 

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

func (*Queries) ListStartableStepRunsSingleParent added in v0.49.1 

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

func (*Queries) ListStepRunArchives added in v0.34.2 

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

func (*Queries) ListStepRunEvents 

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

func (*Queries) ListStepRunEventsByWorkflowRunId added in v0.44.8 

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

func (*Queries) ListStepRunExpressionEvals added in v0.47.0 

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

func (*Queries) ListStepRuns 

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

func (*Queries) ListStepRunsToCancel added in v0.51.2 

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

func (*Queries) ListStepRunsToReassign 

func (q *Queries) ListStepRunsToReassign(ctx context.Context, db DBTX, arg ListStepRunsToReassignParams) ([]*ListStepRunsToReassignRow, error)

func (*Queries) ListStepRunsToTimeout added in v0.36.7 

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

func (*Queries) ListStepsForJob added in v0.42.0 

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

func (*Queries) ListTenantResourceLimits 

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

func (*Queries) ListTenants 

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

func (*Queries) ListTenantsByControllerPartitionId added in v0.34.2 

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

func (*Queries) ListTenantsBySchedulerPartitionId added in v0.50.0 

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

func (*Queries) ListTenantsByTenantWorkerPartitionId added in v0.34.2 

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

func (*Queries) ListTickers 

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

func (*Queries) ListWebhookWorkerRequests added in v0.42.13 

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

func (*Queries) ListWebhookWorkersByPartitionId added in v0.34.2 

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

func (*Queries) ListWorkerLabels added in v0.40.0 

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

func (*Queries) ListWorkersWithSlotCount added in v0.44.0 

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

func (*Queries) ListWorkflowRunEventsByWorkflowRunId added in v0.45.0 

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

func (*Queries) ListWorkflowRuns 

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

func (*Queries) ListWorkflows 

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

func (*Queries) ListWorkflowsForEvent 

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

Get all of the latest workflow versions for the tenant select the workflow versions that have the event trigger

func (*Queries) ListWorkflowsLatestRuns 

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

func (*Queries) ManualReleaseSemaphore added in v0.44.0 

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

func (*Queries) MarkInternalQueueItemsProcessed added in v0.44.0 

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

func (*Queries) MeterTenantResource 

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

func (*Queries) PollCronSchedules 

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

func (*Queries) PollExpiringTokens 

func (q *Queries) PollExpiringTokens(ctx context.Context, db DBTX) ([]*PollExpiringTokensRow, error)

func (*Queries) PollGetGroupKeyRuns 

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

func (*Queries) PollScheduledWorkflows 

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

Finds workflows that are either past their execution time or will be in the next 5 seconds and assigns them to a ticker, or finds workflows that were assigned to a ticker that is no longer active

func (*Queries) PollTenantAlerts 

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

Finds tenant alerts which haven't alerted since their frequency and assigns them to a ticker

func (*Queries) PollTenantResourceLimitAlerts 

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

func (*Queries) PollUnresolvedFailedStepRuns added in v0.36.7 

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

func (*Queries) PopTimeoutQueueItems added in v0.44.5 

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

func (*Queries) PopWorkflowRunsRoundRobin 

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

func (*Queries) QueueStepRun added in v0.44.0 

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

func (*Queries) QueueStepRunBulkNoInput added in v0.50.0 

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

func (*Queries) QueueStepRunBulkWithInput added in v0.50.0 

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

func (*Queries) RebalanceAllControllerPartitions added in v0.34.2 

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

func (*Queries) RebalanceAllSchedulerPartitions added in v0.50.0 

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

func (*Queries) RebalanceAllTenantWorkerPartitions added in v0.34.2 

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

func (*Queries) RebalanceInactiveControllerPartitions added in v0.34.2 

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

func (*Queries) RebalanceInactiveSchedulerPartitions added in v0.50.0 

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

func (*Queries) RebalanceInactiveTenantWorkerPartitions added in v0.34.2 

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

func (*Queries) RefreshTimeoutBy 

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

func (*Queries) ReleaseLeases added in v0.50.0 

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

Releases a set of leases by their IDs. Returns the released leases.

func (*Queries) RemoveTimeoutQueueItem added in v0.44.5 

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

func (*Queries) RemoveTimeoutQueueItems added in v0.50.0 

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

func (*Queries) ReplayStepRunResetJobRun 

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

func (*Queries) ReplayStepRunResetStepRuns added in v0.44.0 

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

func (*Queries) ReplayStepRunResetWorkflowRun 

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

func (*Queries) ReplayWorkflowRunResetGetGroupKeyRun added in v0.44.8 

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

func (*Queries) ReplayWorkflowRunResetJobRun added in v0.39.0 

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

func (*Queries) ResetStepRunsByIds added in v0.39.0 

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

func (*Queries) ResolveAllLimitsIfWindowPassed 

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

func (*Queries) ResolveJobRunStatus 

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

func (*Queries) ResolveLaterStepRuns 

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

func (*Queries) ResolveWorkflowRunStatus 

func (q *Queries) ResolveWorkflowRunStatus(ctx context.Context, db DBTX, arg ResolveWorkflowRunStatusParams) ([]*ResolveWorkflowRunStatusRow, error)

Return distinct workflow run ids in a final state

func (*Queries) SchedulerPartitionHeartbeat added in v0.50.0 

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

func (*Queries) SelectOrInsertTenantResourceLimit 

func (q *Queries) SelectOrInsertTenantResourceLimit(ctx context.Context, db DBTX, arg SelectOrInsertTenantResourceLimitParams) (*SelectOrInsertTenantResourceLimitRow, error)

func (*Queries) SetDispatchersInactive 

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

func (*Queries) SetTickersInactive 

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

func (*Queries) SoftDeleteExpiredEvents added in v0.39.0 

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

func (*Queries) SoftDeleteExpiredWorkflowRunsWithDependencies added in v0.39.0 

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

func (*Queries) SoftDeleteWebhookWorker added in v0.42.13 

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

func (*Queries) SoftDeleteWorkflow added in v0.39.0 

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

func (*Queries) UpdateDispatcher 

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

func (*Queries) UpdateGetGroupKeyRun 

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

func (*Queries) UpdateJobRunLookupDataWithStepRun 

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

func (*Queries) UpdateJobRunStatus 

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

func (*Queries) UpdateManyWorkflowRun 

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

func (*Queries) UpdateScheduledWorkflow added in v0.51.0 

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

func (*Queries) UpdateStepRunInputSchema 

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

func (*Queries) UpdateStepRunOverridesData 

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

func (*Queries) UpdateStepRunUnsetWorkerId added in v0.44.0 

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

func (*Queries) UpdateStepRunUnsetWorkerIdBulk added in v0.50.0 

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

func (*Queries) UpdateStepRunsToAssigned added in v0.44.0 

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

func (*Queries) UpdateTenantAlertingSettings 

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

func (*Queries) UpdateTicker 

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

func (*Queries) UpdateWebhookWorkerToken added in v0.42.13 

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

func (*Queries) UpdateWorker 

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

func (*Queries) UpdateWorkerActiveStatus 

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

func (*Queries) UpdateWorkerHeartbeat added in v0.42.0 

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

func (*Queries) UpdateWorkersByWebhookId added in v0.42.10 

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

func (*Queries) UpdateWorkflow added in v0.48.0 

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

func (*Queries) UpdateWorkflowRun 

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

func (*Queries) UpdateWorkflowRunGroupKeyFromExpr added in v0.45.0 

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

func (*Queries) UpdateWorkflowRunGroupKeyFromRun added in v0.45.0 

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

func (*Queries) UpdateWorkflowRunStickyState added in v0.40.0 

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

func (*Queries) UpsertAction 

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

func (*Queries) UpsertDesiredWorkerLabel added in v0.40.0 

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

func (*Queries) UpsertJobRunLookupData 

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

func (*Queries) UpsertQueue added in v0.42.0 

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

func (*Queries) UpsertRateLimit 

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

func (*Queries) UpsertRateLimitsBulk added in v0.47.0 

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

func (*Queries) UpsertService 

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

func (*Queries) UpsertTenantResourceLimit added in v0.33.2 

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

func (*Queries) UpsertWorkerLabel added in v0.40.0 

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

func (*Queries) UpsertWorkflowTag 

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

func (*Queries) ValidatesAsJson added in v0.51.1 

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

func (*Queries) VerifiedStepRunTenantIds added in v0.50.0 

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

stable ordering as it minimizes the chance of deadlocks

func (*Queries) WorkerPartitionHeartbeat added in v0.43.1 

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

func (*Queries) WorkflowRunsMetricsCount 

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

type Queue added in v0.42.0 

type Queue struct {
	ID         int64            `json:"id"`
	TenantId   pgtype.UUID      `json:"tenantId"`
	Name       string           `json:"name"`
	LastActive pgtype.Timestamp `json:"lastActive"`
}

type QueueItem added in v0.42.0 

type QueueItem struct {
	ID                int64              `json:"id"`
	StepRunId         pgtype.UUID        `json:"stepRunId"`
	StepId            pgtype.UUID        `json:"stepId"`
	ActionId          pgtype.Text        `json:"actionId"`
	ScheduleTimeoutAt pgtype.Timestamp   `json:"scheduleTimeoutAt"`
	StepTimeout       pgtype.Text        `json:"stepTimeout"`
	Priority          int32              `json:"priority"`
	IsQueued          bool               `json:"isQueued"`
	TenantId          pgtype.UUID        `json:"tenantId"`
	Queue             string             `json:"queue"`
	Sticky            NullStickyStrategy `json:"sticky"`
	DesiredWorkerId   pgtype.UUID        `json:"desiredWorkerId"`
}

type QueueStepRunBulkNoInputParams added in v0.50.0 

type QueueStepRunBulkNoInputParams struct {
	Ids         []pgtype.UUID `json:"ids"`
	Retrycounts []int32       `json:"retrycounts"`
}

type QueueStepRunBulkWithInputParams added in v0.50.0 

type QueueStepRunBulkWithInputParams struct {
	Ids         []pgtype.UUID `json:"ids"`
	Inputs      [][]byte      `json:"inputs"`
	Retrycounts []int32       `json:"retrycounts"`
}

type QueueStepRunParams added in v0.44.0 

type QueueStepRunParams struct {
	Input    []byte      `json:"input"`
	IsRetry  pgtype.Bool `json:"isRetry"`
	ID       pgtype.UUID `json:"id"`
	Tenantid pgtype.UUID `json:"tenantid"`
}

type RateLimit 

type RateLimit struct {
	TenantId   pgtype.UUID      `json:"tenantId"`
	Key        string           `json:"key"`
	LimitValue int32            `json:"limitValue"`
	Value      int32            `json:"value"`
	Window     string           `json:"window"`
	LastRefill pgtype.Timestamp `json:"lastRefill"`
}

type RefreshTimeoutByParams 

type RefreshTimeoutByParams struct {
	IncrementTimeoutBy pgtype.Text `json:"incrementTimeoutBy"`
	Steprunid          pgtype.UUID `json:"steprunid"`
	Tenantid           pgtype.UUID `json:"tenantid"`
}

type RemoveTimeoutQueueItemParams added in v0.44.5 

type RemoveTimeoutQueueItemParams struct {
	Steprunid  pgtype.UUID `json:"steprunid"`
	Retrycount int32       `json:"retrycount"`
}

type ReplayStepRunResetStepRunsParams added in v0.44.0 

type ReplayStepRunResetStepRunsParams struct {
	Steprunid pgtype.UUID `json:"steprunid"`
	Input     []byte      `json:"input"`
}

type ResetStepRunsByIdsParams added in v0.39.0 

type ResetStepRunsByIdsParams struct {
	Ids      []pgtype.UUID `json:"ids"`
	Tenantid pgtype.UUID   `json:"tenantid"`
}

type ResolveAllLimitsIfWindowPassedRow 

type ResolveAllLimitsIfWindowPassedRow struct {
	ID               pgtype.UUID      `json:"id"`
	CreatedAt        pgtype.Timestamp `json:"createdAt"`
	UpdatedAt        pgtype.Timestamp `json:"updatedAt"`
	Resource         LimitResource    `json:"resource"`
	TenantId         pgtype.UUID      `json:"tenantId"`
	LimitValue       int32            `json:"limitValue"`
	AlarmValue       pgtype.Int4      `json:"alarmValue"`
	Value            int32            `json:"value"`
	Window           pgtype.Text      `json:"window"`
	LastRefill       pgtype.Timestamp `json:"lastRefill"`
	CustomValueMeter bool             `json:"customValueMeter"`
}

type ResolveLaterStepRunsParams 

type ResolveLaterStepRunsParams struct {
	Status    StepRunStatus `json:"status"`
	Steprunid pgtype.UUID   `json:"steprunid"`
}

type ResolveWorkflowRunStatusParams 

type ResolveWorkflowRunStatusParams struct {
	Jobrunids []pgtype.UUID `json:"jobrunids"`
	Tenantid  pgtype.UUID   `json:"tenantid"`
}

type ResolveWorkflowRunStatusRow added in v0.44.0 

type ResolveWorkflowRunStatusRow struct {
	ID       pgtype.UUID       `json:"id"`
	Status   WorkflowRunStatus `json:"status"`
	TenantId pgtype.UUID       `json:"tenantId"`
}

type SNSIntegration 

type SNSIntegration struct {
	ID        pgtype.UUID      `json:"id"`
	CreatedAt pgtype.Timestamp `json:"createdAt"`
	UpdatedAt pgtype.Timestamp `json:"updatedAt"`
	TenantId  pgtype.UUID      `json:"tenantId"`
	TopicArn  string           `json:"topicArn"`
}

type SchedulerPartition added in v0.50.0 

type SchedulerPartition struct {
	ID            string           `json:"id"`
	CreatedAt     pgtype.Timestamp `json:"createdAt"`
	UpdatedAt     pgtype.Timestamp `json:"updatedAt"`
	LastHeartbeat pgtype.Timestamp `json:"lastHeartbeat"`
	Name          pgtype.Text      `json:"name"`
}

type SecurityCheckIdent added in v0.34.2 

type SecurityCheckIdent struct {
	ID pgtype.UUID `json:"id"`
}

type SelectOrInsertTenantResourceLimitParams 

type SelectOrInsertTenantResourceLimitParams struct {
	Tenantid         pgtype.UUID       `json:"tenantid"`
	Resource         NullLimitResource `json:"resource"`
	LimitValue       pgtype.Int4       `json:"limitValue"`
	AlarmValue       pgtype.Int4       `json:"alarmValue"`
	Window           pgtype.Text       `json:"window"`
	CustomValueMeter pgtype.Bool       `json:"customValueMeter"`
}

type SelectOrInsertTenantResourceLimitRow 

type SelectOrInsertTenantResourceLimitRow struct {
	ID               pgtype.UUID      `json:"id"`
	CreatedAt        pgtype.Timestamp `json:"createdAt"`
	UpdatedAt        pgtype.Timestamp `json:"updatedAt"`
	Resource         LimitResource    `json:"resource"`
	TenantId         pgtype.UUID      `json:"tenantId"`
	LimitValue       int32            `json:"limitValue"`
	AlarmValue       pgtype.Int4      `json:"alarmValue"`
	Value            int32            `json:"value"`
	Window           pgtype.Text      `json:"window"`
	LastRefill       pgtype.Timestamp `json:"lastRefill"`
	CustomValueMeter bool             `json:"customValueMeter"`
}

type SemaphoreQueueItem added in v0.44.7 

type SemaphoreQueueItem struct {
	StepRunId pgtype.UUID `json:"stepRunId"`
	WorkerId  pgtype.UUID `json:"workerId"`
	TenantId  pgtype.UUID `json:"tenantId"`
}

type Service 

type Service struct {
	ID          pgtype.UUID      `json:"id"`
	CreatedAt   pgtype.Timestamp `json:"createdAt"`
	UpdatedAt   pgtype.Timestamp `json:"updatedAt"`
	DeletedAt   pgtype.Timestamp `json:"deletedAt"`
	Name        string           `json:"name"`
	Description pgtype.Text      `json:"description"`
	TenantId    pgtype.UUID      `json:"tenantId"`
}

type ServiceToWorker 

type ServiceToWorker struct {
	A pgtype.UUID `json:"A"`
	B pgtype.UUID `json:"B"`
}

type SetDispatchersInactiveRow 

type SetDispatchersInactiveRow struct {
	Dispatcher Dispatcher `json:"dispatcher"`
}

type SetTickersInactiveRow 

type SetTickersInactiveRow struct {
	Ticker Ticker `json:"ticker"`
}

type SlackAppWebhook 

type SlackAppWebhook struct {
	ID          pgtype.UUID      `json:"id"`
	CreatedAt   pgtype.Timestamp `json:"createdAt"`
	UpdatedAt   pgtype.Timestamp `json:"updatedAt"`
	DeletedAt   pgtype.Timestamp `json:"deletedAt"`
	TenantId    pgtype.UUID      `json:"tenantId"`
	TeamId      string           `json:"teamId"`
	TeamName    string           `json:"teamName"`
	ChannelId   string           `json:"channelId"`
	ChannelName string           `json:"channelName"`
	WebhookURL  []byte           `json:"webhookURL"`
}

type SoftDeleteExpiredEventsParams added in v0.39.0 

type SoftDeleteExpiredEventsParams struct {
	Tenantid      pgtype.UUID      `json:"tenantid"`
	Createdbefore pgtype.Timestamp `json:"createdbefore"`
	Limit         interface{}      `json:"limit"`
}

type SoftDeleteExpiredWorkflowRunsWithDependenciesParams added in v0.39.0 

type SoftDeleteExpiredWorkflowRunsWithDependenciesParams struct {
	Tenantid      pgtype.UUID      `json:"tenantid"`
	Statuses      []string         `json:"statuses"`
	Createdbefore pgtype.Timestamp `json:"createdbefore"`
	Limit         interface{}      `json:"limit"`
}

type SoftDeleteWebhookWorkerParams added in v0.42.13 

type SoftDeleteWebhookWorkerParams struct {
	ID       pgtype.UUID `json:"id"`
	Tenantid pgtype.UUID `json:"tenantid"`
}

type Step 

type Step struct {
	ID              pgtype.UUID      `json:"id"`
	CreatedAt       pgtype.Timestamp `json:"createdAt"`
	UpdatedAt       pgtype.Timestamp `json:"updatedAt"`
	DeletedAt       pgtype.Timestamp `json:"deletedAt"`
	ReadableId      pgtype.Text      `json:"readableId"`
	TenantId        pgtype.UUID      `json:"tenantId"`
	JobId           pgtype.UUID      `json:"jobId"`
	ActionId        string           `json:"actionId"`
	Timeout         pgtype.Text      `json:"timeout"`
	CustomUserData  []byte           `json:"customUserData"`
	Retries         int32            `json:"retries"`
	ScheduleTimeout string           `json:"scheduleTimeout"`
}

type StepDesiredWorkerLabel added in v0.40.0 

type StepDesiredWorkerLabel struct {
	ID         int64                 `json:"id"`
	CreatedAt  pgtype.Timestamp      `json:"createdAt"`
	UpdatedAt  pgtype.Timestamp      `json:"updatedAt"`
	StepId     pgtype.UUID           `json:"stepId"`
	Key        string                `json:"key"`
	StrValue   pgtype.Text           `json:"strValue"`
	IntValue   pgtype.Int4           `json:"intValue"`
	Required   bool                  `json:"required"`
	Comparator WorkerLabelComparator `json:"comparator"`
	Weight     int32                 `json:"weight"`
}

type StepExpression added in v0.47.0 

type StepExpression struct {
	Key        string             `json:"key"`
	StepId     pgtype.UUID        `json:"stepId"`
	Expression string             `json:"expression"`
	Kind       StepExpressionKind `json:"kind"`
}

type StepExpressionKind added in v0.47.0 

type StepExpressionKind string
const (
	StepExpressionKindDYNAMICRATELIMITKEY    StepExpressionKind = "DYNAMIC_RATE_LIMIT_KEY"
	StepExpressionKindDYNAMICRATELIMITVALUE  StepExpressionKind = "DYNAMIC_RATE_LIMIT_VALUE"
	StepExpressionKindDYNAMICRATELIMITUNITS  StepExpressionKind = "DYNAMIC_RATE_LIMIT_UNITS"
	StepExpressionKindDYNAMICRATELIMITWINDOW StepExpressionKind = "DYNAMIC_RATE_LIMIT_WINDOW"
)

func (*StepExpressionKind) Scan added in v0.47.0 

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

type StepOrder 

type StepOrder struct {
	A pgtype.UUID `json:"A"`
	B pgtype.UUID `json:"B"`
}

type StepRateLimit 

type StepRateLimit struct {
	Units        int32             `json:"units"`
	StepId       pgtype.UUID       `json:"stepId"`
	RateLimitKey string            `json:"rateLimitKey"`
	TenantId     pgtype.UUID       `json:"tenantId"`
	Kind         StepRateLimitKind `json:"kind"`
}

type StepRateLimitKind added in v0.47.0 

type StepRateLimitKind string
const (
	StepRateLimitKindSTATIC  StepRateLimitKind = "STATIC"
	StepRateLimitKindDYNAMIC StepRateLimitKind = "DYNAMIC"
)

func (*StepRateLimitKind) Scan added in v0.47.0 

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

type StepRun 

type StepRun struct {
	ID                 pgtype.UUID      `json:"id"`
	CreatedAt          pgtype.Timestamp `json:"createdAt"`
	UpdatedAt          pgtype.Timestamp `json:"updatedAt"`
	DeletedAt          pgtype.Timestamp `json:"deletedAt"`
	TenantId           pgtype.UUID      `json:"tenantId"`
	JobRunId           pgtype.UUID      `json:"jobRunId"`
	StepId             pgtype.UUID      `json:"stepId"`
	Order              int64            `json:"order"`
	WorkerId           pgtype.UUID      `json:"workerId"`
	TickerId           pgtype.UUID      `json:"tickerId"`
	Status             StepRunStatus    `json:"status"`
	Input              []byte           `json:"input"`
	Output             []byte           `json:"output"`
	RequeueAfter       pgtype.Timestamp `json:"requeueAfter"`
	ScheduleTimeoutAt  pgtype.Timestamp `json:"scheduleTimeoutAt"`
	Error              pgtype.Text      `json:"error"`
	StartedAt          pgtype.Timestamp `json:"startedAt"`
	FinishedAt         pgtype.Timestamp `json:"finishedAt"`
	TimeoutAt          pgtype.Timestamp `json:"timeoutAt"`
	CancelledAt        pgtype.Timestamp `json:"cancelledAt"`
	CancelledReason    pgtype.Text      `json:"cancelledReason"`
	CancelledError     pgtype.Text      `json:"cancelledError"`
	InputSchema        []byte           `json:"inputSchema"`
	CallerFiles        []byte           `json:"callerFiles"`
	GitRepoBranch      pgtype.Text      `json:"gitRepoBranch"`
	RetryCount         int32            `json:"retryCount"`
	SemaphoreReleased  bool             `json:"semaphoreReleased"`
	Queue              string           `json:"queue"`
	Priority           pgtype.Int4      `json:"priority"`
	InternalRetryCount int32            `json:"internalRetryCount"`
	IdentityId         int64            `json:"identityId"`
}

type StepRunEvent 

type StepRunEvent struct {
	ID            int64                `json:"id"`
	TimeFirstSeen pgtype.Timestamp     `json:"timeFirstSeen"`
	TimeLastSeen  pgtype.Timestamp     `json:"timeLastSeen"`
	StepRunId     pgtype.UUID          `json:"stepRunId"`
	Reason        StepRunEventReason   `json:"reason"`
	Severity      StepRunEventSeverity `json:"severity"`
	Message       string               `json:"message"`
	Count         int32                `json:"count"`
	Data          []byte               `json:"data"`
	WorkflowRunId pgtype.UUID          `json:"workflowRunId"`
}

type StepRunEventReason 

type StepRunEventReason string
const (
	StepRunEventReasonREQUEUEDNOWORKER             StepRunEventReason = "REQUEUED_NO_WORKER"
	StepRunEventReasonREQUEUEDRATELIMIT            StepRunEventReason = "REQUEUED_RATE_LIMIT"
	StepRunEventReasonSCHEDULINGTIMEDOUT           StepRunEventReason = "SCHEDULING_TIMED_OUT"
	StepRunEventReasonASSIGNED                     StepRunEventReason = "ASSIGNED"
	StepRunEventReasonSTARTED                      StepRunEventReason = "STARTED"
	StepRunEventReasonFINISHED                     StepRunEventReason = "FINISHED"
	StepRunEventReasonFAILED                       StepRunEventReason = "FAILED"
	StepRunEventReasonRETRYING                     StepRunEventReason = "RETRYING"
	StepRunEventReasonCANCELLED                    StepRunEventReason = "CANCELLED"
	StepRunEventReasonTIMEDOUT                     StepRunEventReason = "TIMED_OUT"
	StepRunEventReasonREASSIGNED                   StepRunEventReason = "REASSIGNED"
	StepRunEventReasonSLOTRELEASED                 StepRunEventReason = "SLOT_RELEASED"
	StepRunEventReasonTIMEOUTREFRESHED             StepRunEventReason = "TIMEOUT_REFRESHED"
	StepRunEventReasonRETRIEDBYUSER                StepRunEventReason = "RETRIED_BY_USER"
	StepRunEventReasonSENTTOWORKER                 StepRunEventReason = "SENT_TO_WORKER"
	StepRunEventReasonWORKFLOWRUNGROUPKEYSUCCEEDED StepRunEventReason = "WORKFLOW_RUN_GROUP_KEY_SUCCEEDED"
	StepRunEventReasonWORKFLOWRUNGROUPKEYFAILED    StepRunEventReason = "WORKFLOW_RUN_GROUP_KEY_FAILED"
	StepRunEventReasonRATELIMITERROR               StepRunEventReason = "RATE_LIMIT_ERROR"
	StepRunEventReasonACKNOWLEDGED                 StepRunEventReason = "ACKNOWLEDGED"
)

func (*StepRunEventReason) Scan 

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

type StepRunEventSeverity 

type StepRunEventSeverity string
const (
	StepRunEventSeverityINFO     StepRunEventSeverity = "INFO"
	StepRunEventSeverityWARNING  StepRunEventSeverity = "WARNING"
	StepRunEventSeverityCRITICAL StepRunEventSeverity = "CRITICAL"
)

func (*StepRunEventSeverity) Scan 

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

type StepRunExpressionEval added in v0.47.0 

type StepRunExpressionEval struct {
	Key       string             `json:"key"`
	StepRunId pgtype.UUID        `json:"stepRunId"`
	ValueStr  pgtype.Text        `json:"valueStr"`
	ValueInt  pgtype.Int4        `json:"valueInt"`
	Kind      StepExpressionKind `json:"kind"`
}

type StepRunOrder 

type StepRunOrder struct {
	A pgtype.UUID `json:"A"`
	B pgtype.UUID `json:"B"`
}

type StepRunResultArchive 

type StepRunResultArchive struct {
	ID              pgtype.UUID      `json:"id"`
	CreatedAt       pgtype.Timestamp `json:"createdAt"`
	UpdatedAt       pgtype.Timestamp `json:"updatedAt"`
	DeletedAt       pgtype.Timestamp `json:"deletedAt"`
	StepRunId       pgtype.UUID      `json:"stepRunId"`
	Order           int64            `json:"order"`
	Input           []byte           `json:"input"`
	Output          []byte           `json:"output"`
	Error           pgtype.Text      `json:"error"`
	StartedAt       pgtype.Timestamp `json:"startedAt"`
	FinishedAt      pgtype.Timestamp `json:"finishedAt"`
	TimeoutAt       pgtype.Timestamp `json:"timeoutAt"`
	CancelledAt     pgtype.Timestamp `json:"cancelledAt"`
	CancelledReason pgtype.Text      `json:"cancelledReason"`
	CancelledError  pgtype.Text      `json:"cancelledError"`
	RetryCount      int32            `json:"retryCount"`
}

type StepRunStable added in v0.51.6 

type StepRunStable struct {
	ID                 pgtype.UUID      `json:"id"`
	CreatedAt          pgtype.Timestamp `json:"createdAt"`
	UpdatedAt          pgtype.Timestamp `json:"updatedAt"`
	DeletedAt          pgtype.Timestamp `json:"deletedAt"`
	TenantId           pgtype.UUID      `json:"tenantId"`
	JobRunId           pgtype.UUID      `json:"jobRunId"`
	StepId             pgtype.UUID      `json:"stepId"`
	Order              int64            `json:"order"`
	WorkerId           pgtype.UUID      `json:"workerId"`
	TickerId           pgtype.UUID      `json:"tickerId"`
	Status             StepRunStatus    `json:"status"`
	Input              []byte           `json:"input"`
	Output             []byte           `json:"output"`
	RequeueAfter       pgtype.Timestamp `json:"requeueAfter"`
	ScheduleTimeoutAt  pgtype.Timestamp `json:"scheduleTimeoutAt"`
	Error              pgtype.Text      `json:"error"`
	StartedAt          pgtype.Timestamp `json:"startedAt"`
	FinishedAt         pgtype.Timestamp `json:"finishedAt"`
	TimeoutAt          pgtype.Timestamp `json:"timeoutAt"`
	CancelledAt        pgtype.Timestamp `json:"cancelledAt"`
	CancelledReason    pgtype.Text      `json:"cancelledReason"`
	CancelledError     pgtype.Text      `json:"cancelledError"`
	InputSchema        []byte           `json:"inputSchema"`
	CallerFiles        []byte           `json:"callerFiles"`
	GitRepoBranch      pgtype.Text      `json:"gitRepoBranch"`
	RetryCount         int32            `json:"retryCount"`
	SemaphoreReleased  bool             `json:"semaphoreReleased"`
	Queue              string           `json:"queue"`
	Priority           pgtype.Int4      `json:"priority"`
	InternalRetryCount int32            `json:"internalRetryCount"`
	IdentityId         int64            `json:"identityId"`
}

type StepRunStatus 

type StepRunStatus string
const (
	StepRunStatusPENDING           StepRunStatus = "PENDING"
	StepRunStatusPENDINGASSIGNMENT StepRunStatus = "PENDING_ASSIGNMENT"
	StepRunStatusASSIGNED          StepRunStatus = "ASSIGNED"
	StepRunStatusRUNNING           StepRunStatus = "RUNNING"
	StepRunStatusSUCCEEDED         StepRunStatus = "SUCCEEDED"
	StepRunStatusFAILED            StepRunStatus = "FAILED"
	StepRunStatusCANCELLED         StepRunStatus = "CANCELLED"
	StepRunStatusCANCELLING        StepRunStatus = "CANCELLING"
)

func (*StepRunStatus) Scan 

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

type StepRunVolatile added in v0.51.6 

type StepRunVolatile struct {
	ID                 pgtype.UUID      `json:"id"`
	CreatedAt          pgtype.Timestamp `json:"createdAt"`
	UpdatedAt          pgtype.Timestamp `json:"updatedAt"`
	DeletedAt          pgtype.Timestamp `json:"deletedAt"`
	TenantId           pgtype.UUID      `json:"tenantId"`
	JobRunId           pgtype.UUID      `json:"jobRunId"`
	StepId             pgtype.UUID      `json:"stepId"`
	Order              int64            `json:"order"`
	WorkerId           pgtype.UUID      `json:"workerId"`
	TickerId           pgtype.UUID      `json:"tickerId"`
	Status             StepRunStatus    `json:"status"`
	Input              []byte           `json:"input"`
	Output             []byte           `json:"output"`
	RequeueAfter       pgtype.Timestamp `json:"requeueAfter"`
	ScheduleTimeoutAt  pgtype.Timestamp `json:"scheduleTimeoutAt"`
	Error              pgtype.Text      `json:"error"`
	StartedAt          pgtype.Timestamp `json:"startedAt"`
	FinishedAt         pgtype.Timestamp `json:"finishedAt"`
	TimeoutAt          pgtype.Timestamp `json:"timeoutAt"`
	CancelledAt        pgtype.Timestamp `json:"cancelledAt"`
	CancelledReason    pgtype.Text      `json:"cancelledReason"`
	CancelledError     pgtype.Text      `json:"cancelledError"`
	InputSchema        []byte           `json:"inputSchema"`
	CallerFiles        []byte           `json:"callerFiles"`
	GitRepoBranch      pgtype.Text      `json:"gitRepoBranch"`
	RetryCount         int32            `json:"retryCount"`
	SemaphoreReleased  bool             `json:"semaphoreReleased"`
	Queue              string           `json:"queue"`
	Priority           pgtype.Int4      `json:"priority"`
	InternalRetryCount int32            `json:"internalRetryCount"`
	IdentityId         int64            `json:"identityId"`
}

type StickyStrategy added in v0.40.0 

type StickyStrategy string
const (
	StickyStrategySOFT StickyStrategy = "SOFT"
	StickyStrategyHARD StickyStrategy = "HARD"
)

func (*StickyStrategy) Scan added in v0.40.0 

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

type StreamEvent 

type StreamEvent struct {
	ID        int64            `json:"id"`
	CreatedAt pgtype.Timestamp `json:"createdAt"`
	TenantId  pgtype.UUID      `json:"tenantId"`
	StepRunId pgtype.UUID      `json:"stepRunId"`
	Message   []byte           `json:"message"`
	Metadata  []byte           `json:"metadata"`
}

type Tenant 

type Tenant struct {
	ID                    pgtype.UUID      `json:"id"`
	CreatedAt             pgtype.Timestamp `json:"createdAt"`
	UpdatedAt             pgtype.Timestamp `json:"updatedAt"`
	DeletedAt             pgtype.Timestamp `json:"deletedAt"`
	Name                  string           `json:"name"`
	Slug                  string           `json:"slug"`
	AnalyticsOptOut       bool             `json:"analyticsOptOut"`
	AlertMemberEmails     bool             `json:"alertMemberEmails"`
	ControllerPartitionId pgtype.Text      `json:"controllerPartitionId"`
	WorkerPartitionId     pgtype.Text      `json:"workerPartitionId"`
	DataRetentionPeriod   string           `json:"dataRetentionPeriod"`
	SchedulerPartitionId  pgtype.Text      `json:"schedulerPartitionId"`
}

type TenantAlertEmailGroup 

type TenantAlertEmailGroup struct {
	ID        pgtype.UUID      `json:"id"`
	CreatedAt pgtype.Timestamp `json:"createdAt"`
	UpdatedAt pgtype.Timestamp `json:"updatedAt"`
	DeletedAt pgtype.Timestamp `json:"deletedAt"`
	TenantId  pgtype.UUID      `json:"tenantId"`
	Emails    string           `json:"emails"`
}

type TenantAlertingSettings 

type TenantAlertingSettings struct {
	ID                              pgtype.UUID      `json:"id"`
	CreatedAt                       pgtype.Timestamp `json:"createdAt"`
	UpdatedAt                       pgtype.Timestamp `json:"updatedAt"`
	DeletedAt                       pgtype.Timestamp `json:"deletedAt"`
	TenantId                        pgtype.UUID      `json:"tenantId"`
	MaxFrequency                    string           `json:"maxFrequency"`
	LastAlertedAt                   pgtype.Timestamp `json:"lastAlertedAt"`
	TickerId                        pgtype.UUID      `json:"tickerId"`
	EnableExpiringTokenAlerts       bool             `json:"enableExpiringTokenAlerts"`
	EnableWorkflowRunFailureAlerts  bool             `json:"enableWorkflowRunFailureAlerts"`
	EnableTenantResourceLimitAlerts bool             `json:"enableTenantResourceLimitAlerts"`
}
type TenantInviteLink struct {
	ID           pgtype.UUID      `json:"id"`
	CreatedAt    pgtype.Timestamp `json:"createdAt"`
	UpdatedAt    pgtype.Timestamp `json:"updatedAt"`
	TenantId     pgtype.UUID      `json:"tenantId"`
	InviterEmail string           `json:"inviterEmail"`
	InviteeEmail string           `json:"inviteeEmail"`
	Expires      pgtype.Timestamp `json:"expires"`
	Status       InviteLinkStatus `json:"status"`
	Role         TenantMemberRole `json:"role"`
}

type TenantMember 

type TenantMember struct {
	ID        pgtype.UUID      `json:"id"`
	CreatedAt pgtype.Timestamp `json:"createdAt"`
	UpdatedAt pgtype.Timestamp `json:"updatedAt"`
	TenantId  pgtype.UUID      `json:"tenantId"`
	UserId    pgtype.UUID      `json:"userId"`
	Role      TenantMemberRole `json:"role"`
}

type TenantMemberRole 

type TenantMemberRole string
const (
	TenantMemberRoleOWNER  TenantMemberRole = "OWNER"
	TenantMemberRoleADMIN  TenantMemberRole = "ADMIN"
	TenantMemberRoleMEMBER TenantMemberRole = "MEMBER"
)

func (*TenantMemberRole) Scan 

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

type TenantResourceLimit 

type TenantResourceLimit struct {
	ID               pgtype.UUID      `json:"id"`
	CreatedAt        pgtype.Timestamp `json:"createdAt"`
	UpdatedAt        pgtype.Timestamp `json:"updatedAt"`
	Resource         LimitResource    `json:"resource"`
	TenantId         pgtype.UUID      `json:"tenantId"`
	LimitValue       int32            `json:"limitValue"`
	AlarmValue       pgtype.Int4      `json:"alarmValue"`
	Value            int32            `json:"value"`
	Window           pgtype.Text      `json:"window"`
	LastRefill       pgtype.Timestamp `json:"lastRefill"`
	CustomValueMeter bool             `json:"customValueMeter"`
}

type TenantResourceLimitAlert 

type TenantResourceLimitAlert struct {
	ID              pgtype.UUID                  `json:"id"`
	CreatedAt       pgtype.Timestamp             `json:"createdAt"`
	UpdatedAt       pgtype.Timestamp             `json:"updatedAt"`
	ResourceLimitId pgtype.UUID                  `json:"resourceLimitId"`
	TenantId        pgtype.UUID                  `json:"tenantId"`
	Resource        LimitResource                `json:"resource"`
	AlertType       TenantResourceLimitAlertType `json:"alertType"`
	Value           int32                        `json:"value"`
	Limit           int32                        `json:"limit"`
}

type TenantResourceLimitAlertType 

type TenantResourceLimitAlertType string
const (
	TenantResourceLimitAlertTypeAlarm     TenantResourceLimitAlertType = "Alarm"
	TenantResourceLimitAlertTypeExhausted TenantResourceLimitAlertType = "Exhausted"
)

func (*TenantResourceLimitAlertType) Scan 

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

type TenantVcsProvider 

type TenantVcsProvider struct {
	ID          pgtype.UUID      `json:"id"`
	CreatedAt   pgtype.Timestamp `json:"createdAt"`
	UpdatedAt   pgtype.Timestamp `json:"updatedAt"`
	DeletedAt   pgtype.Timestamp `json:"deletedAt"`
	TenantId    pgtype.UUID      `json:"tenantId"`
	VcsProvider VcsProvider      `json:"vcsProvider"`
	Config      []byte           `json:"config"`
}

type TenantWorkerPartition added in v0.34.2 

type TenantWorkerPartition struct {
	ID            string           `json:"id"`
	CreatedAt     pgtype.Timestamp `json:"createdAt"`
	UpdatedAt     pgtype.Timestamp `json:"updatedAt"`
	LastHeartbeat pgtype.Timestamp `json:"lastHeartbeat"`
	Name          pgtype.Text      `json:"name"`
}

type Ticker 

type Ticker struct {
	ID              pgtype.UUID      `json:"id"`
	CreatedAt       pgtype.Timestamp `json:"createdAt"`
	UpdatedAt       pgtype.Timestamp `json:"updatedAt"`
	LastHeartbeatAt pgtype.Timestamp `json:"lastHeartbeatAt"`
	IsActive        bool             `json:"isActive"`
}

type TimeoutQueueItem added in v0.44.5 

type TimeoutQueueItem struct {
	ID         int64            `json:"id"`
	StepRunId  pgtype.UUID      `json:"stepRunId"`
	RetryCount int32            `json:"retryCount"`
	TimeoutAt  pgtype.Timestamp `json:"timeoutAt"`
	TenantId   pgtype.UUID      `json:"tenantId"`
	IsQueued   bool             `json:"isQueued"`
}

type UpdateDispatcherParams 

type UpdateDispatcherParams struct {
	LastHeartbeatAt pgtype.Timestamp `json:"lastHeartbeatAt"`
	ID              pgtype.UUID      `json:"id"`
}

type UpdateGetGroupKeyRunParams 

type UpdateGetGroupKeyRunParams struct {
	RequeueAfter      pgtype.Timestamp  `json:"requeueAfter"`
	StartedAt         pgtype.Timestamp  `json:"startedAt"`
	FinishedAt        pgtype.Timestamp  `json:"finishedAt"`
	ScheduleTimeoutAt pgtype.Timestamp  `json:"scheduleTimeoutAt"`
	Status            NullStepRunStatus `json:"status"`
	Input             []byte            `json:"input"`
	Output            pgtype.Text       `json:"output"`
	Error             pgtype.Text       `json:"error"`
	CancelledAt       pgtype.Timestamp  `json:"cancelledAt"`
	CancelledReason   pgtype.Text       `json:"cancelledReason"`
	ID                pgtype.UUID       `json:"id"`
	Tenantid          pgtype.UUID       `json:"tenantid"`
}

type UpdateJobRunLookupDataWithStepRunParams 

type UpdateJobRunLookupDataWithStepRunParams struct {
	Jsondata  []byte      `json:"jsondata"`
	Steprunid pgtype.UUID `json:"steprunid"`
	Tenantid  pgtype.UUID `json:"tenantid"`
}

type UpdateJobRunStatusParams 

type UpdateJobRunStatusParams struct {
	Status   JobRunStatus `json:"status"`
	ID       pgtype.UUID  `json:"id"`
	Tenantid pgtype.UUID  `json:"tenantid"`
}

type UpdateManyWorkflowRunParams 

type UpdateManyWorkflowRunParams struct {
	Status     NullWorkflowRunStatus `json:"status"`
	Error      pgtype.Text           `json:"error"`
	StartedAt  pgtype.Timestamp      `json:"startedAt"`
	FinishedAt pgtype.Timestamp      `json:"finishedAt"`
	Tenantid   pgtype.UUID           `json:"tenantid"`
	Ids        []pgtype.UUID         `json:"ids"`
}

type UpdateScheduledWorkflowParams added in v0.51.0 

type UpdateScheduledWorkflowParams struct {
	Triggerat  pgtype.Timestamp `json:"triggerat"`
	Scheduleid pgtype.UUID      `json:"scheduleid"`
}

type UpdateStepRunInputSchemaParams 

type UpdateStepRunInputSchemaParams struct {
	InputSchema []byte      `json:"inputSchema"`
	Tenantid    pgtype.UUID `json:"tenantid"`
	Steprunid   pgtype.UUID `json:"steprunid"`
}

type UpdateStepRunOverridesDataParams 

type UpdateStepRunOverridesDataParams struct {
	Fieldpath    []string    `json:"fieldpath"`
	Jsondata     []byte      `json:"jsondata"`
	Overrideskey []string    `json:"overrideskey"`
	Callerfile   string      `json:"callerfile"`
	Tenantid     pgtype.UUID `json:"tenantid"`
	Steprunid    pgtype.UUID `json:"steprunid"`
}

type UpdateStepRunUnsetWorkerIdParams added in v0.44.0 

type UpdateStepRunUnsetWorkerIdParams struct {
	Steprunid pgtype.UUID `json:"steprunid"`
	Tenantid  pgtype.UUID `json:"tenantid"`
}

type UpdateStepRunUnsetWorkerIdRow added in v0.44.0 

type UpdateStepRunUnsetWorkerIdRow struct {
	WorkerId   pgtype.UUID `json:"workerId"`
	RetryCount int32       `json:"retryCount"`
}

type UpdateStepRunsToAssignedParams added in v0.44.0 

type UpdateStepRunsToAssignedParams struct {
	Steprunids      []pgtype.UUID `json:"steprunids"`
	Stepruntimeouts []string      `json:"stepruntimeouts"`
	Workerids       []pgtype.UUID `json:"workerids"`
	Tenantid        pgtype.UUID   `json:"tenantid"`
}

type UpdateStepRunsToAssignedRow added in v0.44.0 

type UpdateStepRunsToAssignedRow struct {
	StepRunId pgtype.UUID `json:"stepRunId"`
	WorkerId  pgtype.UUID `json:"workerId"`
}

type UpdateTenantAlertingSettingsParams 

type UpdateTenantAlertingSettingsParams struct {
	LastAlertedAt pgtype.Timestamp `json:"lastAlertedAt"`
	TenantId      pgtype.UUID      `json:"tenantId"`
}

type UpdateTickerParams 

type UpdateTickerParams struct {
	LastHeartbeatAt pgtype.Timestamp `json:"lastHeartbeatAt"`
	ID              pgtype.UUID      `json:"id"`
}

type UpdateWebhookWorkerTokenParams added in v0.42.13 

type UpdateWebhookWorkerTokenParams struct {
	TokenValue pgtype.Text `json:"tokenValue"`
	TokenId    pgtype.UUID `json:"tokenId"`
	ID         pgtype.UUID `json:"id"`
	Tenantid   pgtype.UUID `json:"tenantid"`
}

type UpdateWorkerActiveStatusParams 

type UpdateWorkerActiveStatusParams struct {
	Isactive                bool             `json:"isactive"`
	LastListenerEstablished pgtype.Timestamp `json:"lastListenerEstablished"`
	ID                      pgtype.UUID      `json:"id"`
}

type UpdateWorkerHeartbeatParams added in v0.42.0 

type UpdateWorkerHeartbeatParams struct {
	LastHeartbeatAt pgtype.Timestamp `json:"lastHeartbeatAt"`
	ID              pgtype.UUID      `json:"id"`
}

type UpdateWorkerParams 

type UpdateWorkerParams struct {
	DispatcherId    pgtype.UUID      `json:"dispatcherId"`
	MaxRuns         pgtype.Int4      `json:"maxRuns"`
	LastHeartbeatAt pgtype.Timestamp `json:"lastHeartbeatAt"`
	IsActive        pgtype.Bool      `json:"isActive"`
	IsPaused        pgtype.Bool      `json:"isPaused"`
	ID              pgtype.UUID      `json:"id"`
}

type UpdateWorkersByWebhookIdParams added in v0.42.10 

type UpdateWorkersByWebhookIdParams struct {
	Isactive  bool        `json:"isactive"`
	Tenantid  pgtype.UUID `json:"tenantid"`
	Webhookid pgtype.UUID `json:"webhookid"`
}

type UpdateWorkflowParams added in v0.48.0 

type UpdateWorkflowParams struct {
	IsPaused pgtype.Bool `json:"isPaused"`
	ID       pgtype.UUID `json:"id"`
}

type UpdateWorkflowRunGroupKeyFromExprParams added in v0.45.0 

type UpdateWorkflowRunGroupKeyFromExprParams struct {
	Error              pgtype.Text `json:"error"`
	ConcurrencyGroupId pgtype.Text `json:"concurrencyGroupId"`
	Workflowrunid      pgtype.UUID `json:"workflowrunid"`
}

type UpdateWorkflowRunGroupKeyFromRunParams added in v0.45.0 

type UpdateWorkflowRunGroupKeyFromRunParams struct {
	Tenantid      pgtype.UUID `json:"tenantid"`
	Groupkeyrunid pgtype.UUID `json:"groupkeyrunid"`
}

type UpdateWorkflowRunParams 

type UpdateWorkflowRunParams struct {
	Status     NullWorkflowRunStatus `json:"status"`
	Error      pgtype.Text           `json:"error"`
	StartedAt  pgtype.Timestamp      `json:"startedAt"`
	FinishedAt pgtype.Timestamp      `json:"finishedAt"`
	ID         pgtype.UUID           `json:"id"`
	Tenantid   pgtype.UUID           `json:"tenantid"`
}

type UpdateWorkflowRunStickyStateParams added in v0.40.0 

type UpdateWorkflowRunStickyStateParams struct {
	DesiredWorkerId pgtype.UUID `json:"desiredWorkerId"`
	Workflowrunid   pgtype.UUID `json:"workflowrunid"`
	Tenantid        pgtype.UUID `json:"tenantid"`
}

type UpsertActionParams 

type UpsertActionParams struct {
	Action   string      `json:"action"`
	Tenantid pgtype.UUID `json:"tenantid"`
}

type UpsertDesiredWorkerLabelParams added in v0.40.0 

type UpsertDesiredWorkerLabelParams struct {
	Stepid     pgtype.UUID               `json:"stepid"`
	Key        string                    `json:"key"`
	IntValue   pgtype.Int4               `json:"intValue"`
	StrValue   pgtype.Text               `json:"strValue"`
	Required   pgtype.Bool               `json:"required"`
	Weight     pgtype.Int4               `json:"weight"`
	Comparator NullWorkerLabelComparator `json:"comparator"`
}

type UpsertJobRunLookupDataParams 

type UpsertJobRunLookupDataParams struct {
	Jobrunid  pgtype.UUID `json:"jobrunid"`
	Tenantid  pgtype.UUID `json:"tenantid"`
	Fieldpath []string    `json:"fieldpath"`
	Jsondata  []byte      `json:"jsondata"`
}

type UpsertQueueParams added in v0.42.0 

type UpsertQueueParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Name     string      `json:"name"`
}

type UpsertRateLimitParams 

type UpsertRateLimitParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Key      string      `json:"key"`
	Limit    int32       `json:"limit"`
	Window   pgtype.Text `json:"window"`
}

type UpsertRateLimitsBulkParams added in v0.47.0 

type UpsertRateLimitsBulkParams struct {
	Tenantid    pgtype.UUID `json:"tenantid"`
	Keys        []string    `json:"keys"`
	Limitvalues []int32     `json:"limitvalues"`
	Windows     []string    `json:"windows"`
}

type UpsertServiceParams 

type UpsertServiceParams struct {
	Name     string      `json:"name"`
	Tenantid pgtype.UUID `json:"tenantid"`
}

type UpsertTenantResourceLimitParams added in v0.33.2 

type UpsertTenantResourceLimitParams struct {
	Tenantid         pgtype.UUID       `json:"tenantid"`
	Resource         NullLimitResource `json:"resource"`
	LimitValue       pgtype.Int4       `json:"limitValue"`
	AlarmValue       pgtype.Int4       `json:"alarmValue"`
	Window           pgtype.Text       `json:"window"`
	CustomValueMeter pgtype.Bool       `json:"customValueMeter"`
}

type UpsertWorkerLabelParams added in v0.40.0 

type UpsertWorkerLabelParams struct {
	Workerid pgtype.UUID `json:"workerid"`
	Key      string      `json:"key"`
	IntValue pgtype.Int4 `json:"intValue"`
	StrValue pgtype.Text `json:"strValue"`
}

type UpsertWorkflowTagParams 

type UpsertWorkflowTagParams struct {
	ID       pgtype.UUID `json:"id"`
	Tenantid pgtype.UUID `json:"tenantid"`
	Tagname  string      `json:"tagname"`
	TagColor pgtype.Text `json:"tagColor"`
}

type User 

type User struct {
	ID            pgtype.UUID      `json:"id"`
	CreatedAt     pgtype.Timestamp `json:"createdAt"`
	UpdatedAt     pgtype.Timestamp `json:"updatedAt"`
	DeletedAt     pgtype.Timestamp `json:"deletedAt"`
	Email         string           `json:"email"`
	EmailVerified bool             `json:"emailVerified"`
	Name          pgtype.Text      `json:"name"`
}

type UserOAuth 

type UserOAuth struct {
	ID             pgtype.UUID      `json:"id"`
	CreatedAt      pgtype.Timestamp `json:"createdAt"`
	UpdatedAt      pgtype.Timestamp `json:"updatedAt"`
	UserId         pgtype.UUID      `json:"userId"`
	Provider       string           `json:"provider"`
	ProviderUserId string           `json:"providerUserId"`
	ExpiresAt      pgtype.Timestamp `json:"expiresAt"`
	AccessToken    []byte           `json:"accessToken"`
	RefreshToken   []byte           `json:"refreshToken"`
}

type UserPassword 

type UserPassword struct {
	Hash   string      `json:"hash"`
	UserId pgtype.UUID `json:"userId"`
}

type UserSession 

type UserSession struct {
	ID        pgtype.UUID      `json:"id"`
	CreatedAt pgtype.Timestamp `json:"createdAt"`
	UpdatedAt pgtype.Timestamp `json:"updatedAt"`
	UserId    pgtype.UUID      `json:"userId"`
	Data      []byte           `json:"data"`
	ExpiresAt pgtype.Timestamp `json:"expiresAt"`
}

type VcsProvider 

type VcsProvider string
const (
	VcsProviderGITHUB VcsProvider = "GITHUB"
)

func (*VcsProvider) Scan 

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

type VerifiedStepRunTenantIdsParams added in v0.50.0 

type VerifiedStepRunTenantIdsParams struct {
	Steprunids []pgtype.UUID `json:"steprunids"`
	Tenantids  []pgtype.UUID `json:"tenantids"`
}

type WebhookWorker added in v0.34.0 

type WebhookWorker struct {
	ID         pgtype.UUID      `json:"id"`
	CreatedAt  pgtype.Timestamp `json:"createdAt"`
	UpdatedAt  pgtype.Timestamp `json:"updatedAt"`
	Name       string           `json:"name"`
	Secret     string           `json:"secret"`
	Url        string           `json:"url"`
	TokenValue pgtype.Text      `json:"tokenValue"`
	Deleted    bool             `json:"deleted"`
	TokenId    pgtype.UUID      `json:"tokenId"`
	TenantId   pgtype.UUID      `json:"tenantId"`
}

type WebhookWorkerRequest added in v0.42.13 

type WebhookWorkerRequest struct {
	ID              pgtype.UUID                `json:"id"`
	CreatedAt       pgtype.Timestamp           `json:"createdAt"`
	WebhookWorkerId pgtype.UUID                `json:"webhookWorkerId"`
	Method          WebhookWorkerRequestMethod `json:"method"`
	StatusCode      int32                      `json:"statusCode"`
}

type WebhookWorkerRequestMethod added in v0.42.13 

type WebhookWorkerRequestMethod string
const (
	WebhookWorkerRequestMethodGET  WebhookWorkerRequestMethod = "GET"
	WebhookWorkerRequestMethodPOST WebhookWorkerRequestMethod = "POST"
	WebhookWorkerRequestMethodPUT  WebhookWorkerRequestMethod = "PUT"
)

func (*WebhookWorkerRequestMethod) Scan added in v0.42.13 

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

type WebhookWorkerWorkflow added in v0.34.0 

type WebhookWorkerWorkflow struct {
	ID              pgtype.UUID `json:"id"`
	WebhookWorkerId pgtype.UUID `json:"webhookWorkerId"`
	WorkflowId      pgtype.UUID `json:"workflowId"`
}

type Worker 

type Worker struct {
	ID                      pgtype.UUID      `json:"id"`
	CreatedAt               pgtype.Timestamp `json:"createdAt"`
	UpdatedAt               pgtype.Timestamp `json:"updatedAt"`
	DeletedAt               pgtype.Timestamp `json:"deletedAt"`
	TenantId                pgtype.UUID      `json:"tenantId"`
	LastHeartbeatAt         pgtype.Timestamp `json:"lastHeartbeatAt"`
	Name                    string           `json:"name"`
	DispatcherId            pgtype.UUID      `json:"dispatcherId"`
	MaxRuns                 int32            `json:"maxRuns"`
	IsActive                bool             `json:"isActive"`
	LastListenerEstablished pgtype.Timestamp `json:"lastListenerEstablished"`
	IsPaused                bool             `json:"isPaused"`
	Type                    WorkerType       `json:"type"`
	WebhookId               pgtype.UUID      `json:"webhookId"`
	Language                NullWorkerSDKS   `json:"language"`
	LanguageVersion         pgtype.Text      `json:"languageVersion"`
	Os                      pgtype.Text      `json:"os"`
	RuntimeExtra            pgtype.Text      `json:"runtimeExtra"`
	SdkVersion              pgtype.Text      `json:"sdkVersion"`
}

type WorkerAssignEvent added in v0.44.0 

type WorkerAssignEvent struct {
	ID               int64       `json:"id"`
	WorkerId         pgtype.UUID `json:"workerId"`
	AssignedStepRuns []byte      `json:"assignedStepRuns"`
}

type WorkerLabel added in v0.40.0 

type WorkerLabel struct {
	ID        int64            `json:"id"`
	CreatedAt pgtype.Timestamp `json:"createdAt"`
	UpdatedAt pgtype.Timestamp `json:"updatedAt"`
	WorkerId  pgtype.UUID      `json:"workerId"`
	Key       string           `json:"key"`
	StrValue  pgtype.Text      `json:"strValue"`
	IntValue  pgtype.Int4      `json:"intValue"`
}

type WorkerLabelComparator added in v0.40.0 

type WorkerLabelComparator string
const (
	WorkerLabelComparatorEQUAL              WorkerLabelComparator = "EQUAL"
	WorkerLabelComparatorNOTEQUAL           WorkerLabelComparator = "NOT_EQUAL"
	WorkerLabelComparatorGREATERTHAN        WorkerLabelComparator = "GREATER_THAN"
	WorkerLabelComparatorGREATERTHANOREQUAL WorkerLabelComparator = "GREATER_THAN_OR_EQUAL"
	WorkerLabelComparatorLESSTHAN           WorkerLabelComparator = "LESS_THAN"
	WorkerLabelComparatorLESSTHANOREQUAL    WorkerLabelComparator = "LESS_THAN_OR_EQUAL"
)

func (*WorkerLabelComparator) Scan added in v0.40.0 

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

type WorkerSDKS added in v0.50.4 

type WorkerSDKS string
const (
	WorkerSDKSUNKNOWN    WorkerSDKS = "UNKNOWN"
	WorkerSDKSGO         WorkerSDKS = "GO"
	WorkerSDKSPYTHON     WorkerSDKS = "PYTHON"
	WorkerSDKSTYPESCRIPT WorkerSDKS = "TYPESCRIPT"
)

func (*WorkerSDKS) Scan added in v0.50.4 

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

type WorkerType added in v0.42.10 

type WorkerType string
const (
	WorkerTypeWEBHOOK    WorkerType = "WEBHOOK"
	WorkerTypeMANAGED    WorkerType = "MANAGED"
	WorkerTypeSELFHOSTED WorkerType = "SELFHOSTED"
)

func (*WorkerType) Scan added in v0.42.10 

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

type Workflow 

type Workflow struct {
	ID          pgtype.UUID      `json:"id"`
	CreatedAt   pgtype.Timestamp `json:"createdAt"`
	UpdatedAt   pgtype.Timestamp `json:"updatedAt"`
	DeletedAt   pgtype.Timestamp `json:"deletedAt"`
	TenantId    pgtype.UUID      `json:"tenantId"`
	Name        string           `json:"name"`
	Description pgtype.Text      `json:"description"`
	IsPaused    pgtype.Bool      `json:"isPaused"`
}

type WorkflowConcurrency 

type WorkflowConcurrency struct {
	ID                         pgtype.UUID              `json:"id"`
	CreatedAt                  pgtype.Timestamp         `json:"createdAt"`
	UpdatedAt                  pgtype.Timestamp         `json:"updatedAt"`
	WorkflowVersionId          pgtype.UUID              `json:"workflowVersionId"`
	GetConcurrencyGroupId      pgtype.UUID              `json:"getConcurrencyGroupId"`
	MaxRuns                    int32                    `json:"maxRuns"`
	LimitStrategy              ConcurrencyLimitStrategy `json:"limitStrategy"`
	ConcurrencyGroupExpression pgtype.Text              `json:"concurrencyGroupExpression"`
}

type WorkflowKind added in v0.41.0 

type WorkflowKind string
const (
	WorkflowKindFUNCTION WorkflowKind = "FUNCTION"
	WorkflowKindDURABLE  WorkflowKind = "DURABLE"
	WorkflowKindDAG      WorkflowKind = "DAG"
)

func (*WorkflowKind) Scan added in v0.41.0 

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

type WorkflowRun 

type WorkflowRun struct {
	CreatedAt          pgtype.Timestamp  `json:"createdAt"`
	UpdatedAt          pgtype.Timestamp  `json:"updatedAt"`
	DeletedAt          pgtype.Timestamp  `json:"deletedAt"`
	TenantId           pgtype.UUID       `json:"tenantId"`
	WorkflowVersionId  pgtype.UUID       `json:"workflowVersionId"`
	Status             WorkflowRunStatus `json:"status"`
	Error              pgtype.Text       `json:"error"`
	StartedAt          pgtype.Timestamp  `json:"startedAt"`
	FinishedAt         pgtype.Timestamp  `json:"finishedAt"`
	ConcurrencyGroupId pgtype.Text       `json:"concurrencyGroupId"`
	DisplayName        pgtype.Text       `json:"displayName"`
	ID                 pgtype.UUID       `json:"id"`
	ChildIndex         pgtype.Int4       `json:"childIndex"`
	ChildKey           pgtype.Text       `json:"childKey"`
	ParentId           pgtype.UUID       `json:"parentId"`
	ParentStepRunId    pgtype.UUID       `json:"parentStepRunId"`
	AdditionalMetadata []byte            `json:"additionalMetadata"`
	Duration           pgtype.Int8       `json:"duration"`
	Priority           pgtype.Int4       `json:"priority"`
	InsertOrder        pgtype.Int4       `json:"insertOrder"`
	IdentityId         pgtype.Int8       `json:"identityId"`
}

type WorkflowRunDedupe added in v0.40.0 

type WorkflowRunDedupe struct {
	ID            int64            `json:"id"`
	CreatedAt     pgtype.Timestamp `json:"createdAt"`
	UpdatedAt     pgtype.Timestamp `json:"updatedAt"`
	TenantId      pgtype.UUID      `json:"tenantId"`
	WorkflowId    pgtype.UUID      `json:"workflowId"`
	WorkflowRunId pgtype.UUID      `json:"workflowRunId"`
	Value         string           `json:"value"`
}

type WorkflowRunStatus 

type WorkflowRunStatus string
const (
	WorkflowRunStatusPENDING   WorkflowRunStatus = "PENDING"
	WorkflowRunStatusRUNNING   WorkflowRunStatus = "RUNNING"
	WorkflowRunStatusSUCCEEDED WorkflowRunStatus = "SUCCEEDED"
	WorkflowRunStatusFAILED    WorkflowRunStatus = "FAILED"
	WorkflowRunStatusQUEUED    WorkflowRunStatus = "QUEUED"
)

func (*WorkflowRunStatus) Scan 

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

type WorkflowRunStickyState added in v0.40.0 

type WorkflowRunStickyState struct {
	ID              int64            `json:"id"`
	CreatedAt       pgtype.Timestamp `json:"createdAt"`
	UpdatedAt       pgtype.Timestamp `json:"updatedAt"`
	TenantId        pgtype.UUID      `json:"tenantId"`
	WorkflowRunId   pgtype.UUID      `json:"workflowRunId"`
	DesiredWorkerId pgtype.UUID      `json:"desiredWorkerId"`
	Strategy        StickyStrategy   `json:"strategy"`
}

type WorkflowRunTriggeredBy 

type WorkflowRunTriggeredBy struct {
	ID           pgtype.UUID      `json:"id"`
	CreatedAt    pgtype.Timestamp `json:"createdAt"`
	UpdatedAt    pgtype.Timestamp `json:"updatedAt"`
	DeletedAt    pgtype.Timestamp `json:"deletedAt"`
	TenantId     pgtype.UUID      `json:"tenantId"`
	EventId      pgtype.UUID      `json:"eventId"`
	CronParentId pgtype.UUID      `json:"cronParentId"`
	CronSchedule pgtype.Text      `json:"cronSchedule"`
	ScheduledId  pgtype.UUID      `json:"scheduledId"`
	Input        []byte           `json:"input"`
	ParentId     pgtype.UUID      `json:"parentId"`
	IdentityId   pgtype.Int8      `json:"identityId"`
}

type WorkflowRunsMetricsCountParams 

type WorkflowRunsMetricsCountParams struct {
	Tenantid           pgtype.UUID      `json:"tenantid"`
	CreatedAfter       pgtype.Timestamp `json:"createdAfter"`
	CreatedBefore      pgtype.Timestamp `json:"createdBefore"`
	WorkflowId         pgtype.UUID      `json:"workflowId"`
	ParentId           pgtype.UUID      `json:"parentId"`
	ParentStepRunId    pgtype.UUID      `json:"parentStepRunId"`
	AdditionalMetadata []byte           `json:"additionalMetadata"`
	EventId            pgtype.UUID      `json:"eventId"`
}

type WorkflowRunsMetricsCountRow 

type WorkflowRunsMetricsCountRow struct {
	PENDING   int64 `json:"PENDING"`
	RUNNING   int64 `json:"RUNNING"`
	SUCCEEDED int64 `json:"SUCCEEDED"`
	FAILED    int64 `json:"FAILED"`
	QUEUED    int64 `json:"QUEUED"`
}

type WorkflowTag 

type WorkflowTag struct {
	ID        pgtype.UUID      `json:"id"`
	CreatedAt pgtype.Timestamp `json:"createdAt"`
	UpdatedAt pgtype.Timestamp `json:"updatedAt"`
	TenantId  pgtype.UUID      `json:"tenantId"`
	Name      string           `json:"name"`
	Color     string           `json:"color"`
}

type WorkflowToWorkflowTag 

type WorkflowToWorkflowTag struct {
	A pgtype.UUID `json:"A"`
	B pgtype.UUID `json:"B"`
}

type WorkflowTriggerCronRef 

type WorkflowTriggerCronRef struct {
	ParentId           pgtype.UUID      `json:"parentId"`
	Cron               string           `json:"cron"`
	TickerId           pgtype.UUID      `json:"tickerId"`
	Input              []byte           `json:"input"`
	Enabled            bool             `json:"enabled"`
	AdditionalMetadata []byte           `json:"additionalMetadata"`
	CreatedAt          pgtype.Timestamp `json:"createdAt"`
	DeletedAt          pgtype.Timestamp `json:"deletedAt"`
	UpdatedAt          pgtype.Timestamp `json:"updatedAt"`
}

type WorkflowTriggerEventRef 

type WorkflowTriggerEventRef struct {
	ParentId pgtype.UUID `json:"parentId"`
	EventKey string      `json:"eventKey"`
}

type WorkflowTriggerScheduledRef 

type WorkflowTriggerScheduledRef struct {
	ID                  pgtype.UUID      `json:"id"`
	ParentId            pgtype.UUID      `json:"parentId"`
	TriggerAt           pgtype.Timestamp `json:"triggerAt"`
	TickerId            pgtype.UUID      `json:"tickerId"`
	Input               []byte           `json:"input"`
	ChildIndex          pgtype.Int4      `json:"childIndex"`
	ChildKey            pgtype.Text      `json:"childKey"`
	ParentStepRunId     pgtype.UUID      `json:"parentStepRunId"`
	ParentWorkflowRunId pgtype.UUID      `json:"parentWorkflowRunId"`
	AdditionalMetadata  []byte           `json:"additionalMetadata"`
	CreatedAt           pgtype.Timestamp `json:"createdAt"`
	DeletedAt           pgtype.Timestamp `json:"deletedAt"`
	UpdatedAt           pgtype.Timestamp `json:"updatedAt"`
}

type WorkflowTriggers 

type WorkflowTriggers struct {
	ID                pgtype.UUID      `json:"id"`
	CreatedAt         pgtype.Timestamp `json:"createdAt"`
	UpdatedAt         pgtype.Timestamp `json:"updatedAt"`
	DeletedAt         pgtype.Timestamp `json:"deletedAt"`
	WorkflowVersionId pgtype.UUID      `json:"workflowVersionId"`
	TenantId          pgtype.UUID      `json:"tenantId"`
}

type WorkflowVersion 

type WorkflowVersion struct {
	ID              pgtype.UUID        `json:"id"`
	CreatedAt       pgtype.Timestamp   `json:"createdAt"`
	UpdatedAt       pgtype.Timestamp   `json:"updatedAt"`
	DeletedAt       pgtype.Timestamp   `json:"deletedAt"`
	Version         pgtype.Text        `json:"version"`
	Order           int64              `json:"order"`
	WorkflowId      pgtype.UUID        `json:"workflowId"`
	Checksum        string             `json:"checksum"`
	ScheduleTimeout string             `json:"scheduleTimeout"`
	OnFailureJobId  pgtype.UUID        `json:"onFailureJobId"`
	Sticky          NullStickyStrategy `json:"sticky"`
	Kind            WorkflowKind       `json:"kind"`
	DefaultPriority pgtype.Int4        `json:"defaultPriority"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.