dbsqlc

package
v0.55.0-alpha.0 Latest Latest
Warning

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

 Go to latest Published: Mar 7, 2025 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

Types

type APIToken 

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

type AcquireOrExtendLeasesParams 

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

type Action 

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

type ActionToWorker 

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

type AddMessageParams 

type AddMessageParams struct {
	Payload []byte `json:"payload"`
	Queueid string `json:"queueid"`
}

type AddStepParentsParams 

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

type AddWorkflowTagParams 

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

type ArchiveStepRunResultFromStepRunParams 

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

type AssignGetGroupKeyRunToTickerParams 

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

type AssignGetGroupKeyRunToTickerRow 

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

type AssignGetGroupKeyRunToWorkerParams 

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

type AssignGetGroupKeyRunToWorkerRow 

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

type BulkAddMessageParams 

type BulkAddMessageParams struct {
	Payload   []byte           `json:"payload"`
	QueueId   pgtype.Text      `json:"queueId"`
	ReadAfter pgtype.Timestamp `json:"readAfter"`
	ExpiresAt pgtype.Timestamp `json:"expiresAt"`
}

type BulkCancelStepRunParams 

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 

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

type BulkCreateWorkflowRunEventParams 

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

type BulkFailStepRunParams 

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

type BulkFinishStepRunParams 

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

type BulkStartStepRunParams 

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

type BulkUpdateRateLimitsParams 

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

type CheckWorkerParams 

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

type CleanupInternalQueueItemsParams 

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

type CleanupMessageQueueItemsParams 

type CleanupMessageQueueItemsParams struct {
	Minid int64 `json:"minid"`
	Maxid int64 `json:"maxid"`
}

type CleanupQueueItemsParams 

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

type CleanupRetryQueueItemsParams 

type CleanupRetryQueueItemsParams struct {
	Minretryafter pgtype.Timestamp `json:"minretryafter"`
	Maxretryafter pgtype.Timestamp `json:"maxretryafter"`
	Tenantid      pgtype.UUID      `json:"tenantid"`
}

type CleanupTimeoutQueueItemsParams 

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

type ClearEventPayloadDataParams 

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

type ClearJobRunLookupDataParams 

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

type ClearStepRunPayloadDataParams 

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"
	ConcurrencyLimitStrategyCANCELNEWEST     ConcurrencyLimitStrategy = "CANCEL_NEWEST"
)

func (*ConcurrencyLimitStrategy) Scan 

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

type ControllerPartition 

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 CountCronWorkflowsParams 

type CountCronWorkflowsParams struct {
	Tenantid           pgtype.UUID `json:"tenantid"`
	Crontriggerid      pgtype.UUID `json:"crontriggerid"`
	Workflowid         pgtype.UUID `json:"workflowid"`
	AdditionalMetadata []byte      `json:"additionalMetadata"`
}

type CountEventsParams 

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

type CountLogLinesParams 

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

type CountRateLimitsParams 

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

type CountRoundRobinGroupKeysParams 

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

type CountScheduledWorkflowsParams 

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

type CountWorkflowRunsParams 

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

type CountWorkflowRunsRoundRobinParams 

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

type CountWorkflowsParams 

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

type CreateAPITokenParams 

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

type CreateEventKeysParams 

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

type CreateEventParams 

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

type CreateEventsParams 

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

type CreateGetGroupKeyRunParams 

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

type CreateGetGroupKeyRunsParams 

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

type CreateInternalQueueItemsBulkParams 

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

type CreateJobParams 

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

type CreateJobRunLookupDataParams 

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

type CreateJobRunLookupDatasParams 

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

type CreateJobRunsParams 

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

type CreateLogLineParams 

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

type CreateManyJobRunsParams 

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

type CreateManyJobRunsRow 

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

type CreateMultipleWorkflowRunStickyStatesParams 

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

type CreateQueueItemParams 

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

type CreateQueueItemsBulkParams 

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

type CreateRetryQueueItemParams 

type CreateRetryQueueItemParams struct {
	Steprunid  pgtype.UUID      `json:"steprunid"`
	Retryafter pgtype.Timestamp `json:"retryafter"`
	Tenantid   pgtype.UUID      `json:"tenantid"`
}

type CreateSNSIntegrationParams 

type CreateSNSIntegrationParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Topicarn string      `json:"topicarn"`
}

type CreateSchedulesParams 

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

type CreateStepExpressionsParams 

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

type CreateStepParams 

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

type CreateStepRateLimitParams 

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

type CreateStepRunEventParams 

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

type CreateStepRunExpressionEvalIntsParams 

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

type CreateStepRunExpressionEvalStrsParams 

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

type CreateStepRunParams 

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

type CreateStepRunsForJobRunIdsParams 

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

type CreateStepRunsParams 

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

type CreateStreamEventParams 

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

type CreateTenantAlertGroupParams 

type CreateTenantAlertGroupParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Emails   string      `json:"emails"`
}

type CreateTenantInviteParams 

type CreateTenantInviteParams struct {
	Tenantid     pgtype.UUID      `json:"tenantid"`
	Inviteremail string           `json:"inviteremail"`
	Inviteeemail string           `json:"inviteeemail"`
	Expires      pgtype.Timestamp `json:"expires"`
	Role         TenantMemberRole `json:"role"`
}

type CreateTenantMemberParams 

type CreateTenantMemberParams struct {
	Tenantid pgtype.UUID      `json:"tenantid"`
	Userid   pgtype.UUID      `json:"userid"`
	Role     TenantMemberRole `json:"role"`
}

type CreateTenantParams 

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

type CreateTimeoutQueueItemParams 

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

type CreateUniqueInternalQueueItemsBulkParams 

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

type CreateUserOAuthParams 

type CreateUserOAuthParams struct {
	Userid         pgtype.UUID      `json:"userid"`
	Provider       string           `json:"provider"`
	Provideruserid string           `json:"provideruserid"`
	Accesstoken    []byte           `json:"accesstoken"`
	RefreshToken   []byte           `json:"refreshToken"`
	ExpiresAt      pgtype.Timestamp `json:"expiresAt"`
}

type CreateUserParams 

type CreateUserParams struct {
	ID            pgtype.UUID `json:"id"`
	Email         string      `json:"email"`
	EmailVerified pgtype.Bool `json:"emailVerified"`
	Name          pgtype.Text `json:"name"`
}

type CreateUserPasswordParams 

type CreateUserPasswordParams struct {
	Userid pgtype.UUID `json:"userid"`
	Hash   string      `json:"hash"`
}

type CreateUserSessionParams 

type CreateUserSessionParams struct {
	ID        pgtype.UUID      `json:"id"`
	Expiresat pgtype.Timestamp `json:"expiresat"`
	UserId    pgtype.UUID      `json:"userId"`
	Data      []byte           `json:"data"`
}

type CreateWebhookWorkerParams 

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 

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

type CreateWorkerParams 

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

type CreateWorkflowConcurrencyParams 

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

type CreateWorkflowParams 

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

type CreateWorkflowRunDedupeParams 

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 

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"`
	CronSchedule  pgtype.Text `json:"cronSchedule"`
	CronName      pgtype.Text `json:"cronName"`
	ScheduledId   pgtype.UUID `json:"scheduledId"`
}

type CreateWorkflowRunTriggeredBysParams 

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

type CreateWorkflowRunsParams 

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

type CreateWorkflowTriggerCronRefForWorkflowParams 

type CreateWorkflowTriggerCronRefForWorkflowParams struct {
	Crontrigger        string                            `json:"crontrigger"`
	Name               pgtype.Text                       `json:"name"`
	Input              []byte                            `json:"input"`
	AdditionalMetadata []byte                            `json:"additionalMetadata"`
	Method             NullWorkflowTriggerCronRefMethods `json:"method"`
	Workflowid         pgtype.UUID                       `json:"workflowid"`
}

type CreateWorkflowTriggerCronRefParams 

type CreateWorkflowTriggerCronRefParams struct {
	Workflowtriggersid pgtype.UUID                       `json:"workflowtriggersid"`
	Crontrigger        string                            `json:"crontrigger"`
	Name               pgtype.Text                       `json:"name"`
	Input              []byte                            `json:"input"`
	AdditionalMetadata []byte                            `json:"additionalMetadata"`
	Method             NullWorkflowTriggerCronRefMethods `json:"method"`
}

type CreateWorkflowTriggerEventRefParams 

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

type CreateWorkflowTriggerScheduledRefForWorkflowParams 

type CreateWorkflowTriggerScheduledRefForWorkflowParams struct {
	Scheduledtrigger   pgtype.Timestamp                       `json:"scheduledtrigger"`
	Input              []byte                                 `json:"input"`
	Additionalmetadata []byte                                 `json:"additionalmetadata"`
	Method             NullWorkflowTriggerScheduledRefMethods `json:"method"`
	Workflowid         pgtype.UUID                            `json:"workflowid"`
}

type CreateWorkflowTriggerScheduledRefParams 

type CreateWorkflowTriggerScheduledRefParams struct {
	Workflowversionid  pgtype.UUID      `json:"workflowversionid"`
	Scheduledtrigger   pgtype.Timestamp `json:"scheduledtrigger"`
	Input              []byte           `json:"input"`
	Additionalmetadata []byte           `json:"additionalmetadata"`
}

type CreateWorkflowTriggersParams 

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

type CreateWorkflowVersionParams 

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

type DBTX 

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

type DeleteAPITokenParams 

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

type DeleteOldWorkerAssignEventsParams 

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

type DeleteOldWorkersParams 

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

type DeleteSNSIntegrationParams 

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

type DeleteSlackWebhookParams 

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

type DeleteTenantAlertGroupParams 

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

type Dispatcher 

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

type Event 

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

type EventKey 

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

type GetChildWorkflowRunParams 

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

type GetChildWorkflowRunsByIndexParams 

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

type GetChildWorkflowRunsByKeyParams 

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

type GetDesiredLabelsRow 

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

type GetEventsForRangeRow 

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

type GetExistingInviteParams 

type GetExistingInviteParams struct {
	Inviteeemail string      `json:"inviteeemail"`
	Tenantid     pgtype.UUID `json:"tenantid"`
}

type GetFailureDetailsParams 

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

type GetFailureDetailsRow 

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

type GetFinalizedStepRunsRow 

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

type GetGroupKeyRun 

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

type GetGroupKeyRunForEngineParams 

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

type GetGroupKeyRunForEngineRow 

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

type GetJobRunByWorkflowRunIdAndJobIdParams 

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

type GetJobRunByWorkflowRunIdAndJobIdRow 

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

type GetJobRunsByWorkflowRunIdParams 

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

type GetJobRunsByWorkflowRunIdRow 

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

type GetLatestWorkflowVersionForWorkflowsParams 

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

type GetLeasesToAcquireParams 

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

type GetMinMaxExpiredMessageQueueItemsRow 

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

type GetMinMaxProcessedInternalQueueItemsRow 

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

type GetMinMaxProcessedQueueItemsRow 

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

type GetMinMaxProcessedRetryQueueItemsRow 

type GetMinMaxProcessedRetryQueueItemsRow struct {
	MinRetryAfter pgtype.Timestamp `json:"minRetryAfter"`
	MaxRetryAfter pgtype.Timestamp `json:"maxRetryAfter"`
}

type GetMinMaxProcessedTimeoutQueueItemsRow 

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

type GetMinUnprocessedQueueItemIdParams 

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

type GetQueuedCountsRow 

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

type GetSNSIntegrationParams 

type GetSNSIntegrationParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Topicarn string      `json:"topicarn"`
}

type GetScheduledChildWorkflowRunParams 

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

type GetStepRunBulkDataForEngineParams 

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

type GetStepRunBulkDataForEngineRow 

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

type GetStepRunDataForEngineParams 

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

type GetStepRunDataForEngineRow 

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

type GetStepRunForEngineParams 

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

type GetStepRunForEngineRow 

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

type GetStepRunMetaParams 

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

type GetStepRunMetaRow 

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

type GetStepRunsForJobRunsWithOutputParams 

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

type GetStepRunsForJobRunsWithOutputRow 

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

type GetStepsForJobsParams 

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

type GetStepsForJobsRow 

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

type GetStreamEventMetaParams 

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

type GetStreamEventMetaRow 

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 GetTenantMemberByEmailParams 

type GetTenantMemberByEmailParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Email    string      `json:"email"`
}

type GetTenantMemberByUserIDParams 

type GetTenantMemberByUserIDParams struct {
	Tenantid pgtype.UUID `json:"tenantid"`
	Userid   pgtype.UUID `json:"userid"`
}

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 GetUpstreamErrorsForOnFailureStepRow 

type GetUpstreamErrorsForOnFailureStepRow struct {
	StepRunId      pgtype.UUID `json:"stepRunId"`
	StepReadableId pgtype.Text `json:"stepReadableId"`
	StepRunError   pgtype.Text `json:"stepRunError"`
}

type GetWorkerActionsByWorkerIdParams 

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

type GetWorkerByIdRow 

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

type GetWorkerByWebhookIdParams 

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

type GetWorkerDispatcherActionsParams 

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

type GetWorkerDispatcherActionsRow 

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 

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

type GetWorkflowByIdRow 

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

type GetWorkflowByNameParams 

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

type GetWorkflowRunAdditionalMetaParams 

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

type GetWorkflowRunAdditionalMetaRow 

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

type GetWorkflowRunByIdParams 

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

type GetWorkflowRunByIdRow 

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

type GetWorkflowRunByIdsParams 

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

type GetWorkflowRunByIdsRow 

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

type GetWorkflowRunParams 

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

type GetWorkflowRunRow 

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

type GetWorkflowRunShapeRow 

type GetWorkflowRunShapeRow struct {
	Parentstepid    pgtype.UUID   `json:"parentstepid"`
	Stepname        pgtype.Text   `json:"stepname"`
	Childrenstepids []pgtype.UUID `json:"childrenstepids"`
}

type GetWorkflowRunStickyStateForUpdateParams 

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

type GetWorkflowRunTriggerParams 

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

type GetWorkflowVersionByIdRow 

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

type GetWorkflowVersionForEngineParams 

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

type GetWorkflowVersionForEngineRow 

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

type GetWorkflowWorkerCountParams 

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

type GetWorkflowWorkerCountRow 

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

type GetWorkflowsByNamesParams 

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

type HandleWorkflowUnpausedParams 

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

type HardDeleteWebhookWorkerParams 

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

type HasActiveWorkersForActionIdParams 

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

type InsertWebhookWorkerRequestParams 

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

type InternalQueue 

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

func (*InternalQueue) Scan 

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

type InternalQueueItem 

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 InternalRetryStepRunsParams 

type InternalRetryStepRunsParams struct {
	Tenantid              pgtype.UUID   `json:"tenantid"`
	Steprunids            []pgtype.UUID `json:"steprunids"`
	Maxinternalretrycount int32         `json:"maxinternalretrycount"`
}

type InternalRetryStepRunsRow 

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

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"
	JobRunStatusBACKOFF   JobRunStatus = "BACKOFF"
)

func (*JobRunStatus) Scan 

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

type Lease 

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

type LeaseKind 

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

func (*LeaseKind) Scan 

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

type LimitResource 

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

func (*LimitResource) Scan 

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

type LinkActionsToWorkerParams 

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

type LinkOnFailureJobParams 

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

type LinkServicesToWorkerParams 

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

type ListActionsForAvailableWorkersRow 

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

type ListActionsForWorkersParams 

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

type ListActionsForWorkersRow 

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

type ListActiveDispatchersRow 

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

type ListActiveQueuedWorkflowVersionsRow 

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

type ListActiveTickersRow 

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

type ListActiveWorkersRow 

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

type ListAllAvailableSlotsForWorkersRow 

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

type ListAllWorkerActionsParams 

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

type ListAvailableSlotsForWorkersParams 

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

type ListAvailableSlotsForWorkersRow 

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

type ListChildWorkflowRunCountsRow 

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

type ListChildWorkflowRunIdsParams 

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

type ListCronWorkflowsParams 

type ListCronWorkflowsParams struct {
	Tenantid           pgtype.UUID `json:"tenantid"`
	Crontriggerid      pgtype.UUID `json:"crontriggerid"`
	Workflowid         pgtype.UUID `json:"workflowid"`
	AdditionalMetadata []byte      `json:"additionalMetadata"`
	Orderby            interface{} `json:"orderby"`
	Offset             interface{} `json:"offset"`
	Limit              interface{} `json:"limit"`
}

type ListCronWorkflowsRow 

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

type ListDispatcherIdsForWorkersParams 

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

type ListDispatcherIdsForWorkersRow 

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

type ListDispatchersRow 

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

type ListEventsByIDsParams 

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

type ListEventsParams 

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

type ListEventsRow 

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

type ListInternalQueueItemsParams 

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

type ListInvitesByTenantIdParams 

type ListInvitesByTenantIdParams struct {
	Tenantid pgtype.UUID          `json:"tenantid"`
	Status   NullInviteLinkStatus `json:"status"`
	Expired  pgtype.Bool          `json:"expired"`
}

type ListJobRunsForWorkflowRunFullParams 

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

type ListJobRunsForWorkflowRunFullRow 

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

type ListJobRunsForWorkflowRunRow 

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

type ListLogLinesParams 

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

type ListManyWorkerLabelsRow 

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

type ListNewlyStaleTickersRow 

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

type ListQueueItemsBatchResults 

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

func (*ListQueueItemsBatchResults) Close 

func (b *ListQueueItemsBatchResults) Close() error

func (*ListQueueItemsBatchResults) Query 

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

type ListQueueItemsForQueueParams 

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

type ListQueueItemsForQueueRow 

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

type ListQueueItemsParams 

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

type ListRateLimitsForStepsParams 

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

type ListRateLimitsForTenantNoMutateParams 

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

type ListRateLimitsForTenantNoMutateRow 

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

type ListRateLimitsForTenantWithMutateRow 

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

type ListRecentAssignedEventsForWorkerParams 

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

type ListRecentAssignedEventsForWorkerRow 

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

type ListScheduledWorkflowsParams 

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

type ListScheduledWorkflowsRow 

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

type ListSemaphoreSlotsWithStateForWorkerParams 

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

type ListSemaphoreSlotsWithStateForWorkerRow 

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

type ListStaleDispatchersRow 

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

type ListStepRunArchivesParams 

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

type ListStepRunEventsByWorkflowRunIdParams 

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

type ListStepRunEventsParams 

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

type ListStepRunsParams 

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

type ListStepRunsToCancelParams 

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

type ListStepRunsToReassignParams 

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

type ListStepRunsToReassignRow 

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

type ListStepsForJobRow 

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

type ListTenantsByControllerPartitionIdParams 

type ListTenantsByControllerPartitionIdParams struct {
	ControllerPartitionId string                   `json:"controllerPartitionId"`
	Majorversion          TenantMajorEngineVersion `json:"majorversion"`
}

type ListTenantsBySchedulerPartitionIdParams 

type ListTenantsBySchedulerPartitionIdParams struct {
	SchedulerPartitionId string                   `json:"schedulerPartitionId"`
	Majorversion         TenantMajorEngineVersion `json:"majorversion"`
}

type ListTenantsByTenantWorkerPartitionIdParams 

type ListTenantsByTenantWorkerPartitionIdParams struct {
	WorkerPartitionId string                   `json:"workerPartitionId"`
	Majorversion      TenantMajorEngineVersion `json:"majorversion"`
}

type ListTickersParams 

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

type ListWorkerLabelsRow 

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 

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 

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

type ListWorkflowRunsParams 

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

type ListWorkflowRunsRow 

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

type ListWorkflowsForEventParams 

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

type ListWorkflowsLatestRunsParams 

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

type ListWorkflowsLatestRunsRow 

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

type ListWorkflowsParams 

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

type ListWorkflowsRow 

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

type LockWorkflowRunsForQueueingParams 

type LockWorkflowRunsForQueueingParams struct {
	Tenantid          pgtype.UUID `json:"tenantid"`
	Workflowversionid pgtype.UUID `json:"workflowversionid"`
}

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 

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

type MarkWorkflowRunsCancellingParams 

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

type MessageQueue 

type MessageQueue struct {
	Name                string           `json:"name"`
	LastActive          pgtype.Timestamp `json:"lastActive"`
	Durable             bool             `json:"durable"`
	AutoDeleted         bool             `json:"autoDeleted"`
	Exclusive           bool             `json:"exclusive"`
	ExclusiveConsumerId pgtype.UUID      `json:"exclusiveConsumerId"`
}

type MessageQueueItem 

type MessageQueueItem struct {
	ID        int64                  `json:"id"`
	Payload   []byte                 `json:"payload"`
	ReadAfter pgtype.Timestamp       `json:"readAfter"`
	ExpiresAt pgtype.Timestamp       `json:"expiresAt"`
	QueueId   pgtype.Text            `json:"queueId"`
	Status    MessageQueueItemStatus `json:"status"`
}

type MessageQueueItemStatus 

type MessageQueueItemStatus string
const (
	MessageQueueItemStatusPENDING  MessageQueueItemStatus = "PENDING"
	MessageQueueItemStatusASSIGNED MessageQueueItemStatus = "ASSIGNED"
)

func (*MessageQueueItemStatus) Scan 

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

type MeterTenantResourceParams 

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

type MoveCronTriggerToNewWorkflowTriggersParams 

type MoveCronTriggerToNewWorkflowTriggersParams struct {
	Newworkflowtriggerid pgtype.UUID `json:"newworkflowtriggerid"`
	Oldworkflowversionid pgtype.UUID `json:"oldworkflowversionid"`
}

type MoveScheduledTriggerToNewWorkflowTriggersParams 

type MoveScheduledTriggerToNewWorkflowTriggersParams struct {
	Newworkflowtriggerid pgtype.UUID `json:"newworkflowtriggerid"`
	Oldworkflowversionid pgtype.UUID `json:"oldworkflowversionid"`
}

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 

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

func (*NullInternalQueue) Scan 

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

Scan implements the Scanner interface.

func (NullInternalQueue) Value 

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

Value implements the driver Valuer interface.

type NullInviteLinkStatus 

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

func (*NullInviteLinkStatus) Scan 

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

Scan implements the Scanner interface.

func (NullInviteLinkStatus) Value 

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

Value implements the driver Valuer interface.

type NullJobKind 

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

func (*NullJobKind) Scan 

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

Scan implements the Scanner interface.

func (NullJobKind) Value 

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

Value implements the driver Valuer interface.

type NullJobRunStatus 

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

func (*NullJobRunStatus) Scan 

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

Scan implements the Scanner interface.

func (NullJobRunStatus) Value 

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

Value implements the driver Valuer interface.

type NullLeaseKind 

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

func (*NullLeaseKind) Scan 

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

Scan implements the Scanner interface.

func (NullLeaseKind) Value 

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

Value implements the driver Valuer interface.

type NullLimitResource 

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

func (*NullLimitResource) Scan 

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

Scan implements the Scanner interface.

func (NullLimitResource) Value 

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

Value implements the driver Valuer interface.

type NullLogLineLevel 

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

func (*NullLogLineLevel) Scan 

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

Scan implements the Scanner interface.

func (NullLogLineLevel) Value 

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

Value implements the driver Valuer interface.

type NullMessageQueueItemStatus 

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

func (*NullMessageQueueItemStatus) Scan 

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

Scan implements the Scanner interface.

func (NullMessageQueueItemStatus) Value 

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

Value implements the driver Valuer interface.

type NullStepExpressionKind 

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

func (*NullStepExpressionKind) Scan 

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

Scan implements the Scanner interface.

func (NullStepExpressionKind) Value 

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

Value implements the driver Valuer interface.

type NullStepRateLimitKind 

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

func (*NullStepRateLimitKind) Scan 

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

Scan implements the Scanner interface.

func (NullStepRateLimitKind) Value 

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

Value implements the driver Valuer interface.

type NullStepRunEventReason 

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

func (*NullStepRunEventReason) Scan 

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

Scan implements the Scanner interface.

func (NullStepRunEventReason) Value 

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

Value implements the driver Valuer interface.

type NullStepRunEventSeverity 

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

func (*NullStepRunEventSeverity) Scan 

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

Scan implements the Scanner interface.

func (NullStepRunEventSeverity) Value 

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

Value implements the driver Valuer interface.

type NullStepRunStatus 

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

func (*NullStepRunStatus) Scan 

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

Scan implements the Scanner interface.

func (NullStepRunStatus) Value 

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

Value implements the driver Valuer interface.

type NullStickyStrategy 

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

func (*NullStickyStrategy) Scan 

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

Scan implements the Scanner interface.

func (NullStickyStrategy) Value 

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

Value implements the driver Valuer interface.

type NullTenantMajorEngineVersion 

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

func (*NullTenantMajorEngineVersion) Scan 

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

Scan implements the Scanner interface.

func (NullTenantMajorEngineVersion) Value 

func (ns NullTenantMajorEngineVersion) 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 

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

func (*NullWebhookWorkerRequestMethod) Scan 

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

Scan implements the Scanner interface.

func (NullWebhookWorkerRequestMethod) Value 

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

Value implements the driver Valuer interface.

type NullWorkerLabelComparator 

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

func (*NullWorkerLabelComparator) Scan 

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

Scan implements the Scanner interface.

func (NullWorkerLabelComparator) Value 

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

Value implements the driver Valuer interface.

type NullWorkerSDKS 

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

func (*NullWorkerSDKS) Scan 

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

Scan implements the Scanner interface.

func (NullWorkerSDKS) Value 

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

Value implements the driver Valuer interface.

type NullWorkerType 

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

func (*NullWorkerType) Scan 

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

Scan implements the Scanner interface.

func (NullWorkerType) Value 

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

Value implements the driver Valuer interface.

type NullWorkflowKind 

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

func (*NullWorkflowKind) Scan 

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

Scan implements the Scanner interface.

func (NullWorkflowKind) Value 

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 NullWorkflowTriggerCronRefMethods 

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

func (*NullWorkflowTriggerCronRefMethods) Scan 

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

Scan implements the Scanner interface.

func (NullWorkflowTriggerCronRefMethods) Value 

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

Value implements the driver Valuer interface.

type NullWorkflowTriggerScheduledRefMethods 

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

func (*NullWorkflowTriggerScheduledRefMethods) Scan 

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

Scan implements the Scanner interface.

func (NullWorkflowTriggerScheduledRefMethods) Value 

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

Value implements the driver Valuer interface.

type PollCronSchedulesRow 

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

type PollExpiringTokensRow 

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

type PollScheduledWorkflowsRow 

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

type PollTenantAlertsRow 

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

type PollUnresolvedFailedStepRunsRow 

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

type PopTimeoutQueueItemsParams 

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

type PopWorkflowRunsRoundRobinParams 

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

type PopulateTenantMembersRow 

type PopulateTenantMembersRow 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"`
	Email             string                   `json:"email"`
	Name              pgtype.Text              `json:"name"`
	TenantId_2        pgtype.UUID              `json:"tenantId_2"`
	TenantCreatedAt   pgtype.Timestamp         `json:"tenantCreatedAt"`
	TenantUpdatedAt   pgtype.Timestamp         `json:"tenantUpdatedAt"`
	TenantName        string                   `json:"tenantName"`
	TenantSlug        string                   `json:"tenantSlug"`
	AlertMemberEmails bool                     `json:"alertMemberEmails"`
	AnalyticsOptOut   bool                     `json:"analyticsOptOut"`
	TenantVersion     TenantMajorEngineVersion `json:"tenantVersion"`
}

type Queries 

type Queries struct {
}

func New 

func New() *Queries

func (*Queries) AcquireOrExtendLeases 

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

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

func (*Queries) AddMessage 

func (q *Queries) AddMessage(ctx context.Context, db DBTX, arg AddMessageParams) error

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

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

func (*Queries) BulkAddMessage 

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

func (*Queries) BulkBackoffStepRun 

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

func (*Queries) BulkCancelStepRun 

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

func (*Queries) BulkCreateStepRunEvent 

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

func (*Queries) BulkCreateWorkflowRunEvent 

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

func (*Queries) BulkFailStepRun 

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

func (*Queries) BulkFinishStepRun 

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

func (*Queries) BulkMarkStepRunsAsCancelling 

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

func (*Queries) BulkQueueItems 

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

func (*Queries) BulkRetryStepRun 

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

func (*Queries) BulkStartStepRun 

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

func (*Queries) BulkUpdateRateLimits 

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

func (*Queries) CheckWorker 

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

func (*Queries) CleanupInternalQueueItems 

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

func (*Queries) CleanupMessageQueue 

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

func (*Queries) CleanupMessageQueueItems 

func (q *Queries) CleanupMessageQueueItems(ctx context.Context, db DBTX, arg CleanupMessageQueueItemsParams) error

func (*Queries) CleanupQueueItems 

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

func (*Queries) CleanupRetryQueueItems 

func (q *Queries) CleanupRetryQueueItems(ctx context.Context, db DBTX, arg CleanupRetryQueueItemsParams) error

func (*Queries) CleanupStreamEvents 

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

func (*Queries) CleanupTimeoutQueueItems 

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

func (*Queries) ClearEventPayloadData 

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

func (*Queries) ClearJobRunLookupData 

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

func (*Queries) ClearStepRunPayloadData 

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

func (*Queries) ControllerPartitionHeartbeat 

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

func (*Queries) CountActiveInvites 

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

func (*Queries) CountCronWorkflows 

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

Get all of the latest workflow versions for the tenant

func (*Queries) CountEvents 

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

func (*Queries) CountLogLines 

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

func (*Queries) CountRateLimits 

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

func (*Queries) CountRoundRobinGroupKeys 

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

func (*Queries) CountScheduledWorkflows 

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

func (*Queries) CountStepRunArchives 

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 

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

func (*Queries) CreateDispatcher 

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

func (*Queries) CreateEvent 

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

func (*Queries) CreateEventKeys 

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

func (*Queries) CreateEvents 

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

func (*Queries) CreateGetGroupKeyRun 

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

func (*Queries) CreateGetGroupKeyRuns 

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

func (*Queries) CreateInternalQueueItemsBulk 

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

func (*Queries) CreateJob 

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

func (*Queries) CreateJobRunLookupData 

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

func (*Queries) CreateJobRunLookupDatas 

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

func (*Queries) CreateJobRuns 

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

func (*Queries) CreateLogLine 

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

func (*Queries) CreateManyJobRuns 

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

func (*Queries) CreateMultipleWorkflowRunStickyStates 

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

func (*Queries) CreateQueueItem 

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

func (*Queries) CreateQueueItemsBulk 

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

func (*Queries) CreateRetryQueueItem 

func (q *Queries) CreateRetryQueueItem(ctx context.Context, db DBTX, arg CreateRetryQueueItemParams) error

func (*Queries) CreateSNSIntegration 

func (q *Queries) CreateSNSIntegration(ctx context.Context, db DBTX, arg CreateSNSIntegrationParams) (*SNSIntegration, error)

func (*Queries) CreateSchedulerPartition 

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

func (*Queries) CreateSchedules 

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

func (*Queries) CreateStep 

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

func (*Queries) CreateStepExpressions 

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

func (*Queries) CreateStepRateLimit 

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

func (*Queries) CreateStepRun 

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

func (*Queries) CreateStepRunEvent 

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

func (*Queries) CreateStepRunExpressionEvalInts 

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

func (*Queries) CreateStepRunExpressionEvalStrs 

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

func (*Queries) CreateStepRuns 

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

func (*Queries) CreateStepRunsForJobRunIds 

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

func (*Queries) CreateStreamEvent 

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

func (*Queries) CreateTenant 

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

func (*Queries) CreateTenantAlertGroup 

func (q *Queries) CreateTenantAlertGroup(ctx context.Context, db DBTX, arg CreateTenantAlertGroupParams) (*TenantAlertEmailGroup, error)

func (*Queries) CreateTenantAlertingSettings 

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

func (*Queries) CreateTenantInvite 

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

func (*Queries) CreateTenantMember 

func (q *Queries) CreateTenantMember(ctx context.Context, db DBTX, arg CreateTenantMemberParams) (*TenantMember, error)

func (*Queries) CreateTenantWorkerPartition 

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 

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

func (*Queries) CreateUniqueInternalQueueItemsBulk 

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

func (*Queries) CreateUser 

func (q *Queries) CreateUser(ctx context.Context, db DBTX, arg CreateUserParams) (*User, error)

func (*Queries) CreateUserOAuth 

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

func (*Queries) CreateUserPassword 

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

func (*Queries) CreateUserSession 

func (q *Queries) CreateUserSession(ctx context.Context, db DBTX, arg CreateUserSessionParams) (*UserSession, error)

func (*Queries) CreateWebhookWorker 

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 

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

func (*Queries) CreateWorkflow 

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

func (*Queries) CreateWorkflowConcurrency 

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

func (*Queries) CreateWorkflowRun 

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

func (*Queries) CreateWorkflowRunDedupe 

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

func (*Queries) CreateWorkflowRunStickyState 

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

func (*Queries) CreateWorkflowRunTriggeredBy 

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

func (*Queries) CreateWorkflowRunTriggeredBys 

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

func (*Queries) CreateWorkflowRuns 

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

func (*Queries) CreateWorkflowTriggerCronRef 

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

func (*Queries) CreateWorkflowTriggerCronRefForWorkflow 

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

func (*Queries) CreateWorkflowTriggerEventRef 

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

func (*Queries) CreateWorkflowTriggerScheduledRef 

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

func (*Queries) CreateWorkflowTriggerScheduledRefForWorkflow 

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

func (*Queries) CreateWorkflowTriggers 

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

func (*Queries) CreateWorkflowVersion 

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

func (*Queries) DeactivateTicker 

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

func (*Queries) DeleteAPIToken 

func (q *Queries) DeleteAPIToken(ctx context.Context, db DBTX, arg DeleteAPITokenParams) error

func (*Queries) DeleteControllerPartition 

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

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

func (*Queries) DeleteOldWorkerAssignEvents 

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 

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

func (*Queries) DeleteSNSIntegration 

func (q *Queries) DeleteSNSIntegration(ctx context.Context, db DBTX, arg DeleteSNSIntegrationParams) error

func (*Queries) DeleteScheduledWorkflow 

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

func (*Queries) DeleteSchedulerPartition 

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

func (*Queries) DeleteSlackWebhook 

func (q *Queries) DeleteSlackWebhook(ctx context.Context, db DBTX, arg DeleteSlackWebhookParams) error

func (*Queries) DeleteTenantAlertGroup 

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

func (*Queries) DeleteTenantInvite 

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

func (*Queries) DeleteTenantMember 

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

func (*Queries) DeleteTenantWorkerPartition 

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

func (*Queries) DeleteUserSession 

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

func (*Queries) DeleteWorker 

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

func (*Queries) DeleteWorkflowTriggerCronRef 

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

func (*Queries) GetAPITokenById 

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

func (*Queries) GetChildWorkflowRun 

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

func (*Queries) GetChildWorkflowRunsByIndex 

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

func (*Queries) GetChildWorkflowRunsByKey 

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

func (*Queries) GetDesiredLabels 

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

func (*Queries) GetEmailGroups 

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

func (*Queries) GetEventForEngine 

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

func (*Queries) GetEventsForRange 

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

func (*Queries) GetExistingInvite 

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

func (*Queries) GetFailureDetails 

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

func (*Queries) GetFinalizedStepRuns 

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

func (*Queries) GetGroupKeyRunForEngine 

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

func (*Queries) GetInsertedEvents 

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

func (*Queries) GetInternalTenantForController 

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

func (*Queries) GetInviteById 

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

func (*Queries) GetJobRunByWorkflowRunIdAndJobId 

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

func (*Queries) GetJobRunsByWorkflowRunId 

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

func (*Queries) GetLaterStepRuns 

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

func (*Queries) GetLatestWorkflowVersionForWorkflows 

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

func (*Queries) GetLeasesToAcquire 

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

func (*Queries) GetMemberEmailGroup 

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

func (*Queries) GetMinMaxExpiredMessageQueueItems 

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

func (*Queries) GetMinMaxProcessedInternalQueueItems 

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

func (*Queries) GetMinMaxProcessedQueueItems 

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

func (*Queries) GetMinMaxProcessedRetryQueueItems 

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

func (*Queries) GetMinMaxProcessedTimeoutQueueItems 

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

func (*Queries) GetMinUnprocessedQueueItemId 

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

func (*Queries) GetQueuedCounts 

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

func (*Queries) GetSNSIntegration 

func (q *Queries) GetSNSIntegration(ctx context.Context, db DBTX, arg GetSNSIntegrationParams) (*SNSIntegration, error)

func (*Queries) GetSNSIntegrationById 

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

func (*Queries) GetScheduledChildWorkflowRun 

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

func (*Queries) GetSecurityCheckIdent 

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

func (*Queries) GetSlackWebhookById 

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

func (*Queries) GetSlackWebhooks 

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

func (*Queries) GetStepDesiredWorkerLabels 

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

func (*Queries) GetStepExpressions 

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

func (*Queries) GetStepRun 

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

func (*Queries) GetStepRunBulkDataForEngine 

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

func (*Queries) GetStepRunDataForEngine 

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 

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

func (*Queries) GetStepRunsForJobRunsWithOutput 

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

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

func (*Queries) GetStepsForJobs 

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

func (*Queries) GetStepsForWorkflowVersion 

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

func (*Queries) GetStreamEvent 

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

func (*Queries) GetStreamEventMeta 

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

func (*Queries) GetTenantAlertGroupById 

func (q *Queries) GetTenantAlertGroupById(ctx context.Context, db DBTX, id pgtype.UUID) (*TenantAlertEmailGroup, 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) GetTenantBySlug 

func (q *Queries) GetTenantBySlug(ctx context.Context, db DBTX, slug string) (*Tenant, error)

func (*Queries) GetTenantMemberByEmail 

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

func (*Queries) GetTenantMemberByID 

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

func (*Queries) GetTenantMemberByUserID 

func (q *Queries) GetTenantMemberByUserID(ctx context.Context, db DBTX, arg GetTenantMemberByUserIDParams) (*TenantMember, 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) GetUpstreamErrorsForOnFailureStep 

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

func (*Queries) GetUserByEmail 

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

func (*Queries) GetUserByID 

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

func (*Queries) GetUserPassword 

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

func (*Queries) GetUserSession 

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

func (*Queries) GetWebhookWorkerByID 

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

func (*Queries) GetWorkerActionsByWorkerId 

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

func (*Queries) GetWorkerById 

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

func (*Queries) GetWorkerByWebhookId 

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

func (*Queries) GetWorkerDispatcherActions 

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 

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

func (*Queries) GetWorkflowById 

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

func (*Queries) GetWorkflowByName 

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

func (*Queries) GetWorkflowLatestVersion 

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

func (*Queries) GetWorkflowRun 

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

func (*Queries) GetWorkflowRunAdditionalMeta 

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

func (*Queries) GetWorkflowRunById 

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

func (*Queries) GetWorkflowRunByIds 

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

func (*Queries) GetWorkflowRunInput 

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

func (*Queries) GetWorkflowRunShape 

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

func (*Queries) GetWorkflowRunStickyStateForUpdate 

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

func (*Queries) GetWorkflowRunTrigger 

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

func (*Queries) GetWorkflowRunsInsertedInThisTxn 

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

func (*Queries) GetWorkflowVersionById 

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

func (*Queries) GetWorkflowVersionCronTriggerRefs 

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

func (*Queries) GetWorkflowVersionEventTriggerRefs 

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

func (*Queries) GetWorkflowVersionForEngine 

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

func (*Queries) GetWorkflowVersionScheduleTriggerRefs 

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

func (*Queries) GetWorkflowWorkerCount 

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

func (*Queries) GetWorkflowsByNames 

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

func (*Queries) HandleWorkflowUnpaused 

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

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

func (*Queries) HardDeleteWebhookWorker 

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

func (*Queries) HasActiveWorkersForActionId 

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

func (*Queries) Health 

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

func (*Queries) InsertWebhookWorkerRequest 

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

func (*Queries) InternalRetryStepRuns 

func (q *Queries) InternalRetryStepRuns(ctx context.Context, db DBTX, arg InternalRetryStepRunsParams) ([]*InternalRetryStepRunsRow, error)

func (*Queries) LinkActionsToWorker 

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

func (*Queries) LinkOnFailureJob 

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

func (*Queries) LinkServicesToWorker 

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

func (*Queries) LinkStepRunParents 

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

func (*Queries) ListAPITokensByTenant 

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

func (*Queries) ListActionsForAvailableWorkers 

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

func (*Queries) ListActionsForWorkers 

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

func (*Queries) ListActiveDispatchers 

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

func (*Queries) ListActiveQueuedWorkflowVersions 

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

func (*Queries) ListActiveTickers 

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

func (*Queries) ListActiveWebhookWorkers 

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

func (*Queries) ListActiveWorkers 

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

func (*Queries) ListAllAvailableSlotsForWorkers 

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

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

func (*Queries) ListAllWorkerActions 

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

func (*Queries) ListAvailableSlotsForWorkers 

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

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

func (*Queries) ListChildWorkflowRunCounts 

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

func (*Queries) ListChildWorkflowRunIds 

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

func (*Queries) ListCronWorkflows 

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

Get all of the latest workflow versions for the tenant

func (*Queries) ListDispatcherIdsForWorkers 

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

func (*Queries) ListDispatchers 

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

func (*Queries) ListEventKeys 

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

func (*Queries) ListEvents 

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

func (*Queries) ListEventsByIDs 

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

func (*Queries) ListGetGroupKeyRunsToReassign 

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

func (*Queries) ListGetGroupKeyRunsToRequeue 

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

func (*Queries) ListInitialStepRuns 

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

func (*Queries) ListInternalQueueItems 

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

func (*Queries) ListInvitesByTenantId 

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

func (*Queries) ListJobRunsForWorkflowRun 

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

func (*Queries) ListJobRunsForWorkflowRunFull 

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

func (*Queries) ListLogLines 

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

func (*Queries) ListManyWorkerLabels 

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

func (*Queries) ListNewlyStaleTickers 

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

func (*Queries) ListNonFinalChildStepRuns 

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

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

func (*Queries) ListPausedWorkflows 

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

func (*Queries) ListQueueItems 

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

func (*Queries) ListQueueItemsForQueue 

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

func (*Queries) ListQueues 

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

func (*Queries) ListRateLimitsForSteps 

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

func (*Queries) ListRateLimitsForTenantNoMutate 

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

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

func (*Queries) ListRateLimitsForTenantWithMutate 

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

func (*Queries) ListRecentAssignedEventsForWorker 

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

func (*Queries) ListSNSIntegrations 

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

func (*Queries) ListScheduledWorkflows 

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

func (*Queries) ListSemaphoreSlotsWithStateForWorker 

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

func (*Queries) ListSlackWebhooks 

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

func (*Queries) ListStaleDispatchers 

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

func (*Queries) ListStartableStepRunsManyParents 

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

func (*Queries) ListStartableStepRunsSingleParent 

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

func (*Queries) ListStepRunArchives 

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

func (*Queries) ListStepRunEvents 

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

func (*Queries) ListStepRunEventsByWorkflowRunId 

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

func (*Queries) ListStepRunExpressionEvals 

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

func (*Queries) ListStepRuns 

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

func (*Queries) ListStepRunsToCancel 

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

func (*Queries) ListStepRunsToReassign 

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

func (*Queries) ListStepRunsToTimeout 

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

func (*Queries) ListStepsForJob 

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

func (*Queries) ListTenantAlertGroups 

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

func (*Queries) ListTenantInvitesByEmail 

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

func (*Queries) ListTenantMembers 

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

func (*Queries) ListTenantMemberships 

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

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

func (*Queries) ListTenantsBySchedulerPartitionId 

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

func (*Queries) ListTenantsByTenantWorkerPartitionId 

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

func (*Queries) ListTickers 

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

func (*Queries) ListWebhookWorkerRequests 

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

func (*Queries) ListWebhookWorkersByPartitionId 

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

func (*Queries) ListWorkerLabels 

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

func (*Queries) ListWorkersWithSlotCount 

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

func (*Queries) ListWorkflowRunEventsByWorkflowRunId 

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

func (*Queries) ListWorkflowRuns 

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

func (*Queries) ListWorkflows 

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

func (*Queries) ListWorkflowsForEvent 

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

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

func (*Queries) ListWorkflowsLatestRuns 

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

func (*Queries) LockWorkflowRunsForQueueing 

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

Locks any workflow runs which are in a RUNNING or QUEUED state, and have a matching concurrencyGroupId in a QUEUED state

func (*Queries) ManualReleaseSemaphore 

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

func (*Queries) MarkInternalQueueItemsProcessed 

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

func (*Queries) MarkWorkflowRunsCancelling 

func (q *Queries) MarkWorkflowRunsCancelling(ctx context.Context, db DBTX, arg MarkWorkflowRunsCancellingParams) error

func (*Queries) MeterTenantResource 

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

func (*Queries) MoveCronTriggerToNewWorkflowTriggers 

func (q *Queries) MoveCronTriggerToNewWorkflowTriggers(ctx context.Context, db DBTX, arg MoveCronTriggerToNewWorkflowTriggersParams) error

func (*Queries) MoveScheduledTriggerToNewWorkflowTriggers 

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

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

func (*Queries) PopTimeoutQueueItems 

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

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

func (*Queries) QueueStepRun 

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

func (*Queries) QueueStepRunBulkNoInput 

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

func (*Queries) QueueStepRunBulkWithInput 

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

func (*Queries) ReadMessages 

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

func (*Queries) RebalanceAllControllerPartitions 

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

func (*Queries) RebalanceAllSchedulerPartitions 

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

func (*Queries) RebalanceAllTenantWorkerPartitions 

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

func (*Queries) RebalanceInactiveControllerPartitions 

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

func (*Queries) RebalanceInactiveSchedulerPartitions 

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

func (*Queries) RebalanceInactiveTenantWorkerPartitions 

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

func (*Queries) RefreshTimeoutBy 

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

func (*Queries) ReleaseLeases 

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

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

func (*Queries) RemoveTimeoutQueueItem 

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

func (*Queries) RemoveTimeoutQueueItems 

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

func (*Queries) ReplayStepRunResetJobRun 

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

func (*Queries) ReplayStepRunResetStepRuns 

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

func (*Queries) ReplayStepRunResetWorkflowRun 

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

func (*Queries) ReplayWorkflowRunResetGetGroupKeyRun 

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

func (*Queries) ReplayWorkflowRunResetJobRun 

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

func (*Queries) ResetStepRunsByIds 

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

func (*Queries) ResolveAllLimitsIfWindowPassed 

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

func (*Queries) ResolveJobRunStatus 

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

func (*Queries) ResolveLaterStepRuns 

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

func (*Queries) ResolveWorkflowRunStatus 

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

Return distinct workflow run ids in a final state

func (*Queries) RetryStepRuns 

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

func (*Queries) RevokeAPIToken 

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

func (*Queries) SchedulerPartitionHeartbeat 

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

func (*Queries) SelectOrInsertTenantResourceLimit 

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

func (*Queries) SetDispatchersInactive 

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

func (*Queries) SetTickersInactive 

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

func (*Queries) SoftDeleteExpiredEvents 

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

func (*Queries) SoftDeleteExpiredWorkflowRunsWithDependencies 

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

func (*Queries) SoftDeleteWebhookWorker 

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

func (*Queries) SoftDeleteWorkflow 

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

func (*Queries) UpdateDispatcher 

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

func (*Queries) UpdateGetGroupKeyRun 

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

func (*Queries) UpdateJobRunLookupDataWithStepRun 

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

func (*Queries) UpdateJobRunStatus 

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

func (*Queries) UpdateManyWorkflowRun 

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

func (*Queries) UpdateMessageQueueActive 

func (q *Queries) UpdateMessageQueueActive(ctx context.Context, db DBTX, name string) error

func (*Queries) UpdateScheduledWorkflow 

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

func (*Queries) UpdateStepRunInputSchema 

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

func (*Queries) UpdateStepRunOverridesData 

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

func (*Queries) UpdateStepRunUnsetWorkerId 

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

func (*Queries) UpdateStepRunUnsetWorkerIdBulk 

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

func (*Queries) UpdateStepRunsToAssigned 

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

func (*Queries) UpdateTenant 

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

func (*Queries) UpdateTenantAlertGroup 

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

func (*Queries) UpdateTenantAlertingSettings 

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

func (*Queries) UpdateTenantInvite 

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

func (*Queries) UpdateTenantMember 

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

func (*Queries) UpdateTicker 

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

func (*Queries) UpdateUser 

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

func (*Queries) UpdateUserPassword 

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

func (*Queries) UpdateUserSession 

func (q *Queries) UpdateUserSession(ctx context.Context, db DBTX, arg UpdateUserSessionParams) (*UserSession, error)

func (*Queries) UpdateWebhookWorkerToken 

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 

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

func (*Queries) UpdateWorkersByWebhookId 

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

func (*Queries) UpdateWorkflow 

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

func (*Queries) UpdateWorkflowRun 

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

func (*Queries) UpdateWorkflowRunGroupKeyFromExpr 

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

func (*Queries) UpdateWorkflowRunGroupKeyFromRun 

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

func (*Queries) UpdateWorkflowRunStickyState 

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 

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

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

func (*Queries) UpsertQueue 

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

func (*Queries) UpsertRateLimit 

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

func (*Queries) UpsertRateLimitsBulk 

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

func (*Queries) UpsertService 

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

func (*Queries) UpsertSlackWebhook 

func (q *Queries) UpsertSlackWebhook(ctx context.Context, db DBTX, arg UpsertSlackWebhookParams) (*SlackAppWebhook, error)

func (*Queries) UpsertTenantAlertingSettings 

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

func (*Queries) UpsertTenantResourceLimit 

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

func (*Queries) UpsertUserOAuth 

func (q *Queries) UpsertUserOAuth(ctx context.Context, db DBTX, arg UpsertUserOAuthParams) (*UserOAuth, error)

func (*Queries) UpsertWorkerLabel 

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

func (*Queries) UpsertWorkflowTag 

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

func (*Queries) ValidatesAsJson 

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

func (*Queries) VerifiedStepRunTenantIds 

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

stable ordering as it minimizes the chance of deadlocks

func (*Queries) WorkerPartitionHeartbeat 

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 

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

type QueueItem 

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

type QueueStepRunBulkNoInputParams 

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

type QueueStepRunBulkWithInputParams 

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

type QueueStepRunParams 

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 ReadMessagesParams 

type ReadMessagesParams struct {
	Queueid string      `json:"queueid"`
	Limit   pgtype.Int4 `json:"limit"`
}

type ReadMessagesRow 

type ReadMessagesRow struct {
	ID        int64                  `json:"id"`
	Payload   []byte                 `json:"payload"`
	ReadAfter pgtype.Timestamp       `json:"readAfter"`
	ExpiresAt pgtype.Timestamp       `json:"expiresAt"`
	QueueId   pgtype.Text            `json:"queueId"`
	Status    MessageQueueItemStatus `json:"status"`
}

type RefreshTimeoutByParams 

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

type RemoveTimeoutQueueItemParams 

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

type ReplayStepRunResetStepRunsParams 

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

type ResetStepRunsByIdsParams 

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

type ResolveAllLimitsIfWindowPassedRow 

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

type ResolveLaterStepRunsParams 

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

type ResolveWorkflowRunStatusParams 

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

type ResolveWorkflowRunStatusRow 

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

type RetryQueueItem 

type RetryQueueItem struct {
	ID         int64            `json:"id"`
	RetryAfter pgtype.Timestamp `json:"retryAfter"`
	StepRunId  pgtype.UUID      `json:"stepRunId"`
	TenantId   pgtype.UUID      `json:"tenantId"`
	IsQueued   bool             `json:"isQueued"`
}

type RetryStepRunsRow 

type RetryStepRunsRow struct {
	ID         int64            `json:"id"`
	RetryAfter pgtype.Timestamp `json:"retryAfter"`
	StepRunId  pgtype.UUID      `json:"stepRunId"`
	TenantId   pgtype.UUID      `json:"tenantId"`
	IsQueued   bool             `json:"isQueued"`
}

type SNSIntegration 

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

type SchedulerPartition 

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

type SecurityCheckIdent 

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

type SelectOrInsertTenantResourceLimitParams 

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

type SelectOrInsertTenantResourceLimitRow 

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

type SemaphoreQueueItem 

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

type Service 

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

type ServiceToWorker 

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

type SetDispatchersInactiveRow 

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

type SetTickersInactiveRow 

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

type SlackAppWebhook 

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

type SoftDeleteExpiredEventsParams 

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

type SoftDeleteExpiredWorkflowRunsWithDependenciesParams 

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

type SoftDeleteWebhookWorkerParams 

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"`
	RetryBackoffFactor pgtype.Float8    `json:"retryBackoffFactor"`
	RetryMaxBackoff    pgtype.Int4      `json:"retryMaxBackoff"`
	ScheduleTimeout    string           `json:"scheduleTimeout"`
}

type StepDesiredWorkerLabel 

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

type StepExpression 

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

type StepExpressionKind 

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

func (*StepExpressionKind) Scan 

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

type StepOrder 

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

type StepRateLimit 

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

type StepRateLimitKind 

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

func (*StepRateLimitKind) Scan 

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

type StepRun 

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

type StepRunEvent 

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

type StepRunEventReason 

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

func (*StepRunEventReason) Scan 

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

type StepRunEventSeverity 

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

func (*StepRunEventSeverity) Scan 

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

type StepRunExpressionEval 

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

type StepRunOrder 

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

type StepRunResultArchive 

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

type 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"
	StepRunStatusBACKOFF           StepRunStatus = "BACKOFF"
)

func (*StepRunStatus) Scan 

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

type StickyStrategy 

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

func (*StickyStrategy) Scan 

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

type StreamEvent 

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

type Tenant 

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

type TenantAlertEmailGroup 

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

type TenantAlertingSettings 

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

type TenantMajorEngineVersion 

type TenantMajorEngineVersion string
const (
	TenantMajorEngineVersionV0 TenantMajorEngineVersion = "V0"
	TenantMajorEngineVersionV1 TenantMajorEngineVersion = "V1"
)

func (*TenantMajorEngineVersion) Scan 

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

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 

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 

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

type UpdateDispatcherParams 

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

type UpdateGetGroupKeyRunParams 

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

type UpdateJobRunLookupDataWithStepRunParams 

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

type UpdateJobRunStatusParams 

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

type UpdateManyWorkflowRunParams 

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

type UpdateScheduledWorkflowParams 

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

type UpdateStepRunInputSchemaParams 

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

type UpdateStepRunOverridesDataParams 

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

type UpdateStepRunUnsetWorkerIdParams 

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

type UpdateStepRunUnsetWorkerIdRow 

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

type UpdateStepRunsToAssignedParams 

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

type UpdateStepRunsToAssignedRow 

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

type UpdateTenantAlertGroupParams 

type UpdateTenantAlertGroupParams struct {
	Emails string      `json:"emails"`
	ID     pgtype.UUID `json:"id"`
}

type UpdateTenantAlertingSettingsParams 

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

type UpdateTenantInviteParams 

type UpdateTenantInviteParams struct {
	Status NullInviteLinkStatus `json:"status"`
	Role   NullTenantMemberRole `json:"role"`
	ID     pgtype.UUID          `json:"id"`
}

type UpdateTenantMemberParams 

type UpdateTenantMemberParams struct {
	Role NullTenantMemberRole `json:"role"`
	ID   pgtype.UUID          `json:"id"`
}

type UpdateTenantParams 

type UpdateTenantParams struct {
	Name              pgtype.Text                  `json:"name"`
	AnalyticsOptOut   pgtype.Bool                  `json:"analyticsOptOut"`
	AlertMemberEmails pgtype.Bool                  `json:"alertMemberEmails"`
	Version           NullTenantMajorEngineVersion `json:"version"`
	ID                pgtype.UUID                  `json:"id"`
}

type UpdateTickerParams 

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

type UpdateUserParams 

type UpdateUserParams struct {
	EmailVerified pgtype.Bool `json:"emailVerified"`
	Name          pgtype.Text `json:"name"`
	ID            pgtype.UUID `json:"id"`
}

type UpdateUserPasswordParams 

type UpdateUserPasswordParams struct {
	Hash   string      `json:"hash"`
	Userid pgtype.UUID `json:"userid"`
}

type UpdateUserSessionParams 

type UpdateUserSessionParams struct {
	UserId pgtype.UUID `json:"userId"`
	Data   []byte      `json:"data"`
	ID     pgtype.UUID `json:"id"`
}

type UpdateWebhookWorkerTokenParams 

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 

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

type UpdateWorkerParams 

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

type UpdateWorkersByWebhookIdParams 

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

type UpdateWorkflowParams 

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

type UpdateWorkflowRunGroupKeyFromExprParams 

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

type UpdateWorkflowRunGroupKeyFromRunParams 

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

type UpdateWorkflowRunParams 

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

type UpdateWorkflowRunStickyStateParams 

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 

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 UpsertMessageQueueParams 

type UpsertMessageQueueParams struct {
	Name                string      `json:"name"`
	Durable             bool        `json:"durable"`
	Autodeleted         bool        `json:"autodeleted"`
	Exclusive           bool        `json:"exclusive"`
	ExclusiveConsumerId pgtype.UUID `json:"exclusiveConsumerId"`
}

type UpsertQueueParams 

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

type UpsertRateLimitParams 

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

type UpsertRateLimitsBulkParams 

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

type UpsertServiceParams 

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

type UpsertSlackWebhookParams 

type UpsertSlackWebhookParams struct {
	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 UpsertTenantAlertingSettingsParams 

type UpsertTenantAlertingSettingsParams struct {
	Tenantid                        pgtype.UUID `json:"tenantid"`
	MaxFrequency                    pgtype.Text `json:"maxFrequency"`
	EnableExpiringTokenAlerts       pgtype.Bool `json:"enableExpiringTokenAlerts"`
	EnableWorkflowRunFailureAlerts  pgtype.Bool `json:"enableWorkflowRunFailureAlerts"`
	EnableTenantResourceLimitAlerts pgtype.Bool `json:"enableTenantResourceLimitAlerts"`
}

type UpsertTenantResourceLimitParams 

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 UpsertUserOAuthParams 

type UpsertUserOAuthParams struct {
	Userid         pgtype.UUID      `json:"userid"`
	Provider       string           `json:"provider"`
	Provideruserid string           `json:"provideruserid"`
	Accesstoken    []byte           `json:"accesstoken"`
	RefreshToken   []byte           `json:"refreshToken"`
	ExpiresAt      pgtype.Timestamp `json:"expiresAt"`
}

type UpsertWorkerLabelParams 

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

type UpsertWorkflowTagParams 

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

type User 

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

type UserOAuth 

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

type UserPassword 

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

type UserSession 

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

type VcsProvider 

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

func (*VcsProvider) Scan 

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

type VerifiedStepRunTenantIdsParams 

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

type WebhookWorker 

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 

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 

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

func (*WebhookWorkerRequestMethod) Scan 

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

type WebhookWorkerWorkflow 

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

type Worker 

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

type WorkerAssignEvent 

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

type WorkerLabel 

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 

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 

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

type WorkerSDKS 

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

func (*WorkerSDKS) Scan 

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

type WorkerType 

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

func (*WorkerType) Scan 

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

type Workflow 

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

type WorkflowConcurrency 

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

type WorkflowKind 

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

func (*WorkflowKind) Scan 

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

type WorkflowRun 

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

type WorkflowRunDedupe 

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"
	WorkflowRunStatusCANCELLING WorkflowRunStatus = "CANCELLING"
	WorkflowRunStatusCANCELLED  WorkflowRunStatus = "CANCELLED"
	WorkflowRunStatusBACKOFF    WorkflowRunStatus = "BACKOFF"
)

func (*WorkflowRunStatus) Scan 

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

type WorkflowRunStickyState 

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

type WorkflowRunTriggeredBy 

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

type WorkflowRunsMetricsCountParams 

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

type WorkflowRunsMetricsCountRow 

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

type WorkflowTag 

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

type WorkflowToWorkflowTag 

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

type WorkflowTriggerCronRef 

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

type WorkflowTriggerCronRefMethods 

type WorkflowTriggerCronRefMethods string
const (
	WorkflowTriggerCronRefMethodsDEFAULT WorkflowTriggerCronRefMethods = "DEFAULT"
	WorkflowTriggerCronRefMethodsAPI     WorkflowTriggerCronRefMethods = "API"
)

func (*WorkflowTriggerCronRefMethods) Scan 

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

type WorkflowTriggerEventRef 

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

type WorkflowTriggerScheduledRef 

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

type WorkflowTriggerScheduledRefMethods 

type WorkflowTriggerScheduledRefMethods string
const (
	WorkflowTriggerScheduledRefMethodsDEFAULT WorkflowTriggerScheduledRefMethods = "DEFAULT"
	WorkflowTriggerScheduledRefMethodsAPI     WorkflowTriggerScheduledRefMethods = "API"
)

func (*WorkflowTriggerScheduledRefMethods) Scan 

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

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.