Help us shape the future of Go! Take the 2026 Go Developer Survey

dbsqlc

package
v0.73.112 Latest Latest
Warning

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

Go to latest
Published: Dec 31, 2025 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 BulkAddMessageParams

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

type BulkDeleteScheduledWorkflowsParams added in v0.73.106

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

type BulkUpdateRateLimitsParams

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

type BulkUpdateScheduledWorkflowsParams added in v0.73.106

type BulkUpdateScheduledWorkflowsParams struct {
	Tenantid   pgtype.UUID        `json:"tenantid"`
	Ids        []pgtype.UUID      `json:"ids"`
	Triggerats []pgtype.Timestamp `json:"triggerats"`
}

type CheckWorkerParams

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

type CleanupMessageQueueItemsParams

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

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"`
	CronName           pgtype.Text `json:"cronName"`
	WorkflowName       pgtype.Text `json:"workflowName"`
}

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 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"`
	Search   pgtype.Text `json:"search"`
}

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

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 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 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"`
	Version             NullTenantMajorEngineVersion `json:"version"`
	OnboardingData      []byte                       `json:"onboardingData"`
	Environment         NullTenantEnvironment        `json:"environment"`
}

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

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

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

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

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

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

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

type GetScheduledWorkflowMetaByIdsParams added in v0.73.106

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

type GetScheduledWorkflowMetaByIdsRow added in v0.73.106

type GetScheduledWorkflowMetaByIdsRow struct {
	ID              pgtype.UUID                        `json:"id"`
	Method          WorkflowTriggerScheduledRefMethods `json:"method"`
	HasTriggeredRun bool                               `json:"hasTriggeredRun"`
}

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

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

type GetWorkerActionsByWorkerIdRow

type GetWorkerActionsByWorkerIdRow struct {
	WorkerId pgtype.UUID `json:"workerId"`
	Actionid pgtype.Text `json:"actionid"`
}

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 GetWorkerWorkflowsByWorkerIdParams added in v0.73.25

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

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 GetWorkflowRunShapeRow

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

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 HasActiveWorkersForActionIdParams

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

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 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"
	LimitResourceTASKRUN         LimitResource = "TASK_RUN"
	LimitResourceEVENT           LimitResource = "EVENT"
	LimitResourceWORKER          LimitResource = "WORKER"
	LimitResourceWORKERSLOT      LimitResource = "WORKER_SLOT"
	LimitResourceCRON            LimitResource = "CRON"
	LimitResourceSCHEDULE        LimitResource = "SCHEDULE"
	LimitResourceINCOMINGWEBHOOK LimitResource = "INCOMING_WEBHOOK"
)

func (*LimitResource) Scan

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

type LinkActionsToWorkerParams

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

type LinkOnFailureJobParams

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

type LinkServicesToWorkerParams

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

type ListActiveDispatchersRow

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

type ListActiveTickersRow

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

type ListCronWorkflowsParams

type ListCronWorkflowsParams struct {
	Tenantid           pgtype.UUID `json:"tenantid"`
	Crontriggerid      pgtype.UUID `json:"crontriggerid"`
	Workflowid         pgtype.UUID `json:"workflowid"`
	AdditionalMetadata []byte      `json:"additionalMetadata"`
	CronName           pgtype.Text `json:"cronName"`
	WorkflowName       pgtype.Text `json:"workflowName"`
	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"`
	Priority            int32                         `json:"priority"`
}

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 ListInvitesByTenantIdParams

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

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 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"`
	Priority             int32                              `json:"priority"`
	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 ListStepsForJobRow

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

type ListTenantInvitesByEmailRow

type ListTenantInvitesByEmailRow 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"`
	TenantName   string           `json:"tenantName"`
}

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

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

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

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 NullTenantEnvironment added in v0.71.8

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

func (*NullTenantEnvironment) Scan added in v0.71.8

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

Scan implements the Scanner interface.

func (NullTenantEnvironment) Value added in v0.71.8

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

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

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

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

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

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

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"`
	Priority           int32                         `json:"priority"`
	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"`
	Priority            int32                              `json:"priority"`
	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 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"`
	TenantEnvironment NullTenantEnvironment    `json:"tenantEnvironment"`
}

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) 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) BulkDeleteScheduledWorkflows added in v0.73.106

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

func (*Queries) BulkUpdateRateLimits

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

func (*Queries) BulkUpdateScheduledWorkflows added in v0.73.106

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

func (*Queries) CheckWorker

func (q *Queries) CheckWorker(ctx context.Context, db DBTX, arg CheckWorkerParams) (pgtype.UUID, 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) 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) 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) CountTenantWorkerSlots

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

func (*Queries) CountTenantWorkers

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

func (q *Queries) CreateJob(ctx context.Context, db DBTX, arg CreateJobParams) (*Job, 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) 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) 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) 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) CreateWorker

func (q *Queries) CreateWorker(ctx context.Context, db DBTX, arg CreateWorkerParams) (*Worker, 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) 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) 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) 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) 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) GetExistingInvite

func (q *Queries) GetExistingInvite(ctx context.Context, db DBTX, arg GetExistingInviteParams) (*TenantInviteLink, 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) 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) 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) GetScheduledWorkflowMetaByIds added in v0.73.106

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

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

func (q *Queries) GetWorkerActionsByWorkerId(ctx context.Context, db DBTX, arg GetWorkerActionsByWorkerIdParams) ([]*GetWorkerActionsByWorkerIdRow, 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) GetWorkerWorkflowsByWorkerId added in v0.73.25

func (q *Queries) GetWorkerWorkflowsByWorkerId(ctx context.Context, db DBTX, arg GetWorkerWorkflowsByWorkerIdParams) ([]*Workflow, 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) GetWorkflowRunShape

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

func (*Queries) GetWorkflowRunTrigger

func (q *Queries) GetWorkflowRunTrigger(ctx context.Context, db DBTX, arg GetWorkflowRunTriggerParams) (*WorkflowRunTriggeredBy, 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) 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) 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) ListAPITokensByTenant

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

func (*Queries) ListActiveDispatchers

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

func (*Queries) ListActiveTickers

func (q *Queries) ListActiveTickers(ctx context.Context, db DBTX) ([]*ListActiveTickersRow, 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) ListInvitesByTenantId

func (q *Queries) ListInvitesByTenantId(ctx context.Context, db DBTX, arg ListInvitesByTenantIdParams) ([]*TenantInviteLink, 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) ListPausedWorkflows

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

func (q *Queries) ListStepRunExpressionEvals(ctx context.Context, db DBTX, steprunids []pgtype.UUID) ([]*StepRunExpressionEval, 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) ([]*ListTenantInvitesByEmailRow, 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) 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) 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) LockWorkflowVersion

func (q *Queries) LockWorkflowVersion(ctx context.Context, db DBTX, workflowid pgtype.UUID) (pgtype.UUID, 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) PopulateTenantMembers

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

func (q *Queries) ResolveAllLimitsIfWindowPassed(ctx context.Context, db DBTX) ([]*ResolveAllLimitsIfWindowPassedRow, 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) 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) SoftDeleteWorkflow

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

func (*Queries) UpdateCronTrigger added in v0.73.35

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

func (*Queries) UpdateDispatcher

func (q *Queries) UpdateDispatcher(ctx context.Context, db DBTX, arg UpdateDispatcherParams) (*Dispatcher, 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) 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) 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) 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) UpsertMessageQueue

func (q *Queries) UpsertMessageQueue(ctx context.Context, db DBTX, arg UpsertMessageQueueParams) (*MessageQueue, 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) WorkerPartitionHeartbeat

func (q *Queries) WorkerPartitionHeartbeat(ctx context.Context, db DBTX, workerpartitionid string) (*TenantWorkerPartition, 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 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 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 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 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 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"`
	CanUpgradeV1          bool                     `json:"canUpgradeV1"`
	OnboardingData        []byte                   `json:"onboardingData"`
	Environment           NullTenantEnvironment    `json:"environment"`
}

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 TenantEnvironment added in v0.71.8

type TenantEnvironment string
const (
	TenantEnvironmentLocal       TenantEnvironment = "local"
	TenantEnvironmentDevelopment TenantEnvironment = "development"
	TenantEnvironmentProduction  TenantEnvironment = "production"
)

func (*TenantEnvironment) Scan added in v0.71.8

func (e *TenantEnvironment) Scan(src interface{}) error
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 UpdateCronTriggerParams added in v0.73.35

type UpdateCronTriggerParams struct {
	Enabled       pgtype.Bool `json:"enabled"`
	Crontriggerid pgtype.UUID `json:"crontriggerid"`
}

type UpdateDispatcherParams

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

type UpdateScheduledWorkflowParams

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

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 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 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 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 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 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 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"`
	Priority           int32                         `json:"priority"`
}

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"`
	Priority            int32                              `json:"priority"`
}

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"`
	CreateWorkflowVersionOpts []byte             `json:"createWorkflowVersionOpts"`
}

Jump to

Keyboard shortcuts

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