dbsqlc

package
v0.44.5 Latest Latest
Warning

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

 Go to latest Published: Sep 10, 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 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"`
	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 {
	Steprunids []pgtype.UUID `json:"steprunids"`
	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"`
	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 CountRoundRobinGroupKeysParams 

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

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"`
	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 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 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 CreateInternalQueueItemsBulkParams added in v0.44.0 

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

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

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

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"`
}

type CreateStepRunEventParams 

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

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 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 CreateWorkerCountParams added in v0.44.0 

type CreateWorkerCountParams struct {
	Workerid pgtype.UUID `json:"workerid"`
	MaxRuns  pgtype.Int4 `json:"maxRuns"`
}

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"`
}

type CreateWorkflowConcurrencyParams 

type CreateWorkflowConcurrencyParams 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               pgtype.Int4                  `json:"maxRuns"`
	LimitStrategy         NullConcurrencyLimitStrategy `json:"limitStrategy"`
}

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 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
	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"`
}

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 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"`
}

type GetEventsForRangeRow 

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

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 GetLaterStepRunsParams added in v0.44.0 

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

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 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 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"`
}

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"`
	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 GetStepRunParams 

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

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 GetWorkerSemaphoreCountsParams added in v0.44.0 

type GetWorkerSemaphoreCountsParams struct {
	Tenantid  pgtype.UUID   `json:"tenantid"`
	WorkerIds []pgtype.UUID `json:"workerIds"`
}

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 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"`
	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 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"`
}

type HardDeleteWebhookWorkerParams added in v0.42.13 

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

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"
)

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"`
}

type JobRunLookupData 

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

type JobRunStatus 

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

func (*JobRunStatus) Scan 

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

type LimitResource 

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

func (*LimitResource) Scan 

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

type 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 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 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"`
	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 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 ListNewlyStaleTickersRow 

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

type ListNonFinalChildStepRunsParams 

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

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 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 ListRateLimitsForTenantRow added in v0.42.0 

type ListRateLimitsForTenantRow 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 ListSemaphoreSlotsToAssignParams added in v0.42.0 

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

type ListSemaphoreSlotsToAssignRow added in v0.42.0 

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

type ListSemaphoreSlotsWithStateForWorkerParams added in v0.42.0 

type ListSemaphoreSlotsWithStateForWorkerParams struct {
	Workerid pgtype.UUID `json:"workerid"`
	Tenantid pgtype.UUID `json:"tenantid"`
	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 ListStartableStepRunsParams 

type ListStartableStepRunsParams struct {
	Jobrunid                 pgtype.UUID `json:"jobrunid"`
	SucceededParentStepRunId pgtype.UUID `json:"succeededParentStepRunId"`
}

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 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 ListStepRunsToReassignRow added in v0.44.0 

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

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"`
	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 {
	Tenantid pgtype.UUID `json:"tenantid"`
	Eventkey string      `json:"eventkey"`
}

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 {
	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 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 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 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"`
	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"`
	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) 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) 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) 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) CountRoundRobinGroupKeys 

func (q *Queries) CountRoundRobinGroupKeys(ctx context.Context, db DBTX, arg CountRoundRobinGroupKeysParams) (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) CreateGetGroupKeyRun 

func (q *Queries) CreateGetGroupKeyRun(ctx context.Context, db DBTX, arg CreateGetGroupKeyRunParams) (*GetGroupKeyRun, 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) 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) CreateQueueItem added in v0.42.0 

func (q *Queries) CreateQueueItem(ctx context.Context, db DBTX, arg CreateQueueItemParams) 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) 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) error

func (*Queries) CreateStepRunEvent 

func (q *Queries) CreateStepRunEvent(ctx context.Context, db DBTX, arg CreateStepRunEventParams) 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) CreateWorkerCount added in v0.44.0 

func (q *Queries) CreateWorkerCount(ctx context.Context, db DBTX, arg CreateWorkerCountParams) 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) 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) 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) GetDesiredLabels added in v0.42.0 

func (q *Queries) GetDesiredLabels(ctx context.Context, db DBTX, stepid 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) 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) GetJobRunByWorkflowRunIdAndJobId 

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

func (*Queries) GetLaterStepRuns added in v0.44.0 

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

func (*Queries) GetMaxRunsLimit added in v0.36.5 

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

Count the total number of maxRuns - runningStepRuns across all workers

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) 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) GetStepRun 

func (q *Queries) GetStepRun(ctx context.Context, db DBTX, arg GetStepRunParams) (*StepRun, 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) 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) GetWorkerSemaphoreCounts added in v0.44.0 

func (q *Queries) GetWorkerSemaphoreCounts(ctx context.Context, db DBTX, arg GetWorkerSemaphoreCountsParams) ([]*WorkerSemaphoreCount, 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) 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) GetWorkflowVersionForEngine 

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

func (*Queries) HardDeleteWebhookWorker added in v0.42.13 

func (q *Queries) HardDeleteWebhookWorker(ctx context.Context, db DBTX, arg HardDeleteWebhookWorkerParams) 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, jobrunid pgtype.UUID) 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) ([]*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) ListDispatchers 

func (q *Queries) ListDispatchers(ctx context.Context, db DBTX) ([]*ListDispatchersRow, 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) ListLogLines 

func (q *Queries) ListLogLines(ctx context.Context, db DBTX, arg ListLogLinesParams) ([]*LogLine, 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, arg ListNonFinalChildStepRunsParams) ([]*StepRun, error)

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

func (*Queries) ListQueueItems added in v0.42.0 

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

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) ListRateLimitsForTenant added in v0.42.0 

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

func (*Queries) ListRecentAssignedEventsForWorker added in v0.44.0 

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

func (*Queries) ListSemaphoreSlotsToAssign added in v0.42.0 

func (q *Queries) ListSemaphoreSlotsToAssign(ctx context.Context, db DBTX, arg ListSemaphoreSlotsToAssignParams) ([]*ListSemaphoreSlotsToAssignRow, 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) ListStartableStepRuns 

func (q *Queries) ListStartableStepRuns(ctx context.Context, db DBTX, arg ListStartableStepRunsParams) ([]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) ListStepRuns 

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

func (*Queries) ListStepRunsToReassign 

func (q *Queries) ListStepRunsToReassign(ctx context.Context, db DBTX, tenantid pgtype.UUID) ([]*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) 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) 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)

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) RebalanceAllControllerPartitions added in v0.34.2 

func (q *Queries) RebalanceAllControllerPartitions(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) 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) (*StepRun, error)

func (*Queries) RemoveTimeoutQueueItem added in v0.44.5 

func (q *Queries) RemoveTimeoutQueueItem(ctx context.Context, db DBTX, arg RemoveTimeoutQueueItemParams) 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) 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, arg ResolveJobRunStatusParams) ([]pgtype.UUID, error)

func (*Queries) ResolveLaterStepRuns 

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

func (*Queries) ResolveWorkerSemaphoreSlots 

func (q *Queries) ResolveWorkerSemaphoreSlots(ctx context.Context, db DBTX, tenantid pgtype.UUID) (*ResolveWorkerSemaphoreSlotsRow, 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) 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) StubWorkerSemaphoreSlots 

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

return whether old worker id was set

func (*Queries) UpdateStepRunsToAssigned added in v0.44.0 

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

bulk insert into timeout queue items

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) UpdateWorkerSemaphoreCounts added in v0.44.0 

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

func (*Queries) UpdateWorkersByWebhookId added in v0.42.10 

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

func (*Queries) UpdateWorkflowRun 

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

func (*Queries) UpdateWorkflowRunGroupKey 

func (q *Queries) UpdateWorkflowRunGroupKey(ctx context.Context, db DBTX, arg UpdateWorkflowRunGroupKeyParams) (*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) 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) 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"`
}

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 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"`
	Tenantid  pgtype.UUID `json:"tenantid"`
}

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 ResolveJobRunStatusParams 

type ResolveJobRunStatusParams struct {
	Tenantid   pgtype.UUID   `json:"tenantid"`
	Steprunids []pgtype.UUID `json:"steprunids"`
}

type ResolveLaterStepRunsParams 

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

type ResolveWorkerSemaphoreSlotsRow added in v0.39.0 

type ResolveWorkerSemaphoreSlotsRow struct {
	HasResolved bool `json:"hasResolved"`
	HasMore     bool `json:"hasMore"`
}

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"`
}

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 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 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 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"`
}

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"`
}

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"`
}

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"
)

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 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"`
}

type StepRunStatus 

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

func (*StepRunStatus) Scan 

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

type StickyStrategy added in v0.40.0 

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

func (*StickyStrategy) Scan added in v0.40.0 

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

type StreamEvent 

type 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 StubWorkerSemaphoreSlotsParams 

type StubWorkerSemaphoreSlotsParams struct {
	Workerid pgtype.UUID `json:"workerid"`
	MaxRuns  pgtype.Int4 `json:"maxRuns"`
}

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"`
}

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 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"`
}

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 UpdateWorkerSemaphoreCountsParams added in v0.44.0 

type UpdateWorkerSemaphoreCountsParams struct {
	Workerids []pgtype.UUID `json:"workerids"`
	Counts    []int32       `json:"counts"`
}

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 UpdateWorkflowRunGroupKeyParams 

type UpdateWorkflowRunGroupKeyParams 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 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 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"`
}

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 WorkerSemaphore 

type WorkerSemaphore struct {
	WorkerId pgtype.UUID `json:"workerId"`
	Slots    int32       `json:"slots"`
}

type WorkerSemaphoreCount added in v0.44.0 

type WorkerSemaphoreCount struct {
	WorkerId pgtype.UUID `json:"workerId"`
	Count    int32       `json:"count"`
}

type WorkerSemaphoreSlot 

type WorkerSemaphoreSlot struct {
	ID        pgtype.UUID `json:"id"`
	WorkerId  pgtype.UUID `json:"workerId"`
	StepRunId pgtype.UUID `json:"stepRunId"`
}

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"`
}

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"`
}

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.Int4       `json:"duration"`
	Priority           pgtype.Int4       `json:"priority"`
}

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"`
}

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"`
}

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"`
}

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.