dbsqlc

package
v0.32.0-alpha.1 Latest Latest
Warning

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

 Go to latest Published: Jun 10, 2024 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 added in v0.7.0 

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

type AcquireWorkerSemaphoreSlotParams added in v0.30.0 

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

type Action 

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

type ActionToWorker 

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

type AddStepParentsParams 

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

type AddWorkflowTagParams 

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

type ArchiveStepRunResultFromStepRunParams added in v0.11.0 

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

type AssignGetGroupKeyRunToTickerParams added in v0.16.0 

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

type AssignGetGroupKeyRunToTickerRow added in v0.16.0 

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

type AssignGetGroupKeyRunToWorkerParams added in v0.16.0 

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

type AssignGetGroupKeyRunToWorkerRow added in v0.16.0 

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

type AssignStepRunToWorkerParams added in v0.16.0 

type AssignStepRunToWorkerParams struct {
	Workerid    pgtype.UUID `json:"workerid"`
	StepTimeout pgtype.Text `json:"stepTimeout"`
	Steprunid   pgtype.UUID `json:"steprunid"`
	Tenantid    pgtype.UUID `json:"tenantid"`
}

type AssignStepRunToWorkerRow added in v0.16.0 

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

type ConcurrencyLimitStrategy added in v0.8.0 

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

func (*ConcurrencyLimitStrategy) Scan added in v0.8.0 

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

type CountEventsParams 

type CountEventsParams struct {
	TenantId  pgtype.UUID `json:"tenantId"`
	Keys      []string    `json:"keys"`
	Workflows []string    `json:"workflows"`
	Search    pgtype.Text `json:"search"`
	Statuses  []string    `json:"statuses"`
}

type CountLogLinesParams added in v0.14.0 

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

type CountRoundRobinGroupKeysParams added in v0.19.3 

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

type CountWorkflowRunsParams 

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

type CountWorkflowRunsRoundRobinParams added in v0.19.3 

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

type CountWorkflowsParams 

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

type CreateAPITokenParams added in v0.17.0 

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

type CreateEventParams 

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

type CreateGetGroupKeyRunParams added in v0.8.0 

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

type CreateJobParams 

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

type CreateJobRunLookupDataParams 

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

type CreateJobRunsParams added in v0.16.0 

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

type CreateLogLineParams added in v0.14.0 

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

type CreateSchedulesParams added in v0.17.0 

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

type CreateStepParams 

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

type CreateStepRateLimitParams added in v0.19.0 

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

type CreateStepRunEventParams added in v0.26.0 

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

type CreateStepRunsParams added in v0.16.0 

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

type CreateStreamEventParams added in v0.19.0 

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

type CreateWorkerParams added in v0.17.0 

type CreateWorkerParams struct {
	Tenantid     pgtype.UUID `json:"tenantid"`
	Name         string      `json:"name"`
	Dispatcherid pgtype.UUID `json:"dispatcherid"`
	MaxRuns      pgtype.Int4 `json:"maxRuns"`
}

type CreateWorkflowConcurrencyParams added in v0.8.0 

type CreateWorkflowConcurrencyParams struct {
	ID                    pgtype.UUID                  `json:"id"`
	CreatedAt             pgtype.Timestamp             `json:"createdAt"`
	UpdatedAt             pgtype.Timestamp             `json:"updatedAt"`
	Workflowversionid     pgtype.UUID                  `json:"workflowversionid"`
	Getconcurrencygroupid pgtype.UUID                  `json:"getconcurrencygroupid"`
	MaxRuns               pgtype.Int4                  `json:"maxRuns"`
	LimitStrategy         NullConcurrencyLimitStrategy `json:"limitStrategy"`
}

type CreateWorkflowParams 

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

type CreateWorkflowRunParams 

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

type CreateWorkflowRunTriggeredByParams 

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

type CreateWorkflowTriggerCronRefParams 

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

type CreateWorkflowTriggerEventRefParams 

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

type CreateWorkflowTriggerScheduledRefParams 

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

type CreateWorkflowTriggersParams 

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

type CreateWorkflowVersionParams 

type CreateWorkflowVersionParams struct {
	ID              pgtype.UUID      `json:"id"`
	CreatedAt       pgtype.Timestamp `json:"createdAt"`
	UpdatedAt       pgtype.Timestamp `json:"updatedAt"`
	Deletedat       pgtype.Timestamp `json:"deletedat"`
	Checksum        string           `json:"checksum"`
	Version         pgtype.Text      `json:"version"`
	Workflowid      pgtype.UUID      `json:"workflowid"`
	ScheduleTimeout pgtype.Text      `json:"scheduleTimeout"`
}

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
}

type Dispatcher 

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

type Event 

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

type GetChildWorkflowRunParams added in v0.18.0 

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

type GetEventsForRangeRow 

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

type GetGroupKeyRun added in v0.8.0 

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

type GetGroupKeyRunForEngineParams added in v0.16.0 

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

type GetGroupKeyRunForEngineRow added in v0.16.0 

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

type GetJobRunByWorkflowRunIdAndJobIdParams added in v0.25.0 

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

type GetJobRunByWorkflowRunIdAndJobIdRow added in v0.25.0 

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

type GetLaterStepRunsForReplayParams added in v0.28.1 

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

type GetScheduledChildWorkflowRunParams added in v0.18.0 

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

type GetStepRunForEngineParams added in v0.16.0 

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

type GetStepRunForEngineRow added in v0.16.0 

type GetStepRunForEngineRow struct {
	StepRun             StepRun     `json:"step_run"`
	JobRunLookupData    []byte      `json:"jobRunLookupData"`
	JobRunId            pgtype.UUID `json:"jobRunId"`
	WorkflowRunId       pgtype.UUID `json:"workflowRunId"`
	StepId              pgtype.UUID `json:"stepId"`
	StepRetries         int32       `json:"stepRetries"`
	StepTimeout         pgtype.Text `json:"stepTimeout"`
	StepScheduleTimeout string      `json:"stepScheduleTimeout"`
	StepReadableId      pgtype.Text `json:"stepReadableId"`
	StepCustomUserData  []byte      `json:"stepCustomUserData"`
	JobName             string      `json:"jobName"`
	JobId               pgtype.UUID `json:"jobId"`
	JobKind             JobKind     `json:"jobKind"`
	WorkflowVersionId   pgtype.UUID `json:"workflowVersionId"`
	WorkflowName        string      `json:"workflowName"`
	WorkflowId          pgtype.UUID `json:"workflowId"`
	ActionId            string      `json:"actionId"`
}

type GetStepRunParams 

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

type GetStreamEventParams added in v0.19.0 

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

type GetTenantResourceLimitParams added in v0.31.0 

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

type GetTenantResourceLimitRow added in v0.31.0 

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 GetWorkerForEngineParams added in v0.16.0 

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

type GetWorkerForEngineRow added in v0.16.0 

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 GetWorkflowByNameParams added in v0.17.0 

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

type GetWorkflowRunParams added in v0.17.0 

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

type GetWorkflowRunRow added in v0.17.0 

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

type GetWorkflowVersionForEngineParams added in v0.16.0 

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

type GetWorkflowVersionForEngineRow added in v0.16.0 

type GetWorkflowVersionForEngineRow struct {
	WorkflowVersion          WorkflowVersion              `json:"workflow_version"`
	WorkflowName             string                       `json:"workflowName"`
	ConcurrencyLimitStrategy NullConcurrencyLimitStrategy `json:"concurrencyLimitStrategy"`
	ConcurrencyMaxRuns       pgtype.Int4                  `json:"concurrencyMaxRuns"`
}

type GithubAppInstallation added in v0.11.0 

type GithubAppInstallation struct {
	ID                      pgtype.UUID      `json:"id"`
	CreatedAt               pgtype.Timestamp `json:"createdAt"`
	UpdatedAt               pgtype.Timestamp `json:"updatedAt"`
	DeletedAt               pgtype.Timestamp `json:"deletedAt"`
	GithubAppOAuthId        pgtype.UUID      `json:"githubAppOAuthId"`
	InstallationId          int32            `json:"installationId"`
	AccountName             string           `json:"accountName"`
	AccountId               int32            `json:"accountId"`
	AccountAvatarURL        pgtype.Text      `json:"accountAvatarURL"`
	InstallationSettingsURL pgtype.Text      `json:"installationSettingsURL"`
	Config                  []byte           `json:"config"`
	TenantId                pgtype.UUID      `json:"tenantId"`
	TenantVcsProviderId     pgtype.UUID      `json:"tenantVcsProviderId"`
}

type GithubAppInstallationToGithubWebhook added in v0.11.0 

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

type GithubAppOAuth added in v0.11.0 

type GithubAppOAuth struct {
	ID           pgtype.UUID      `json:"id"`
	CreatedAt    pgtype.Timestamp `json:"createdAt"`
	UpdatedAt    pgtype.Timestamp `json:"updatedAt"`
	DeletedAt    pgtype.Timestamp `json:"deletedAt"`
	GithubUserID int32            `json:"githubUserID"`
	AccessToken  []byte           `json:"accessToken"`
	RefreshToken []byte           `json:"refreshToken"`
	ExpiresAt    pgtype.Timestamp `json:"expiresAt"`
}

type GithubAppOAuthToUser added in v0.11.0 

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

type GithubPullRequest added in v0.11.0 

type GithubPullRequest 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"`
	RepositoryOwner       string           `json:"repositoryOwner"`
	RepositoryName        string           `json:"repositoryName"`
	PullRequestID         int32            `json:"pullRequestID"`
	PullRequestTitle      string           `json:"pullRequestTitle"`
	PullRequestNumber     int32            `json:"pullRequestNumber"`
	PullRequestHeadBranch string           `json:"pullRequestHeadBranch"`
	PullRequestBaseBranch string           `json:"pullRequestBaseBranch"`
	PullRequestState      string           `json:"pullRequestState"`
}

type GithubPullRequestComment added in v0.11.0 

type GithubPullRequestComment 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"`
	PullRequestID pgtype.UUID      `json:"pullRequestID"`
	ModuleID      string           `json:"moduleID"`
	CommentID     int32            `json:"commentID"`
}

type GithubPullRequestToWorkflowRun added in v0.11.0 

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

type GithubWebhook added in v0.11.0 

type GithubWebhook 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"`
	RepositoryOwner string           `json:"repositoryOwner"`
	RepositoryName  string           `json:"repositoryName"`
	SigningSecret   []byte           `json:"signingSecret"`
}

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

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

func (*JobKind) Scan added in v0.25.0 

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

type JobRun 

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

type JobRunLookupData 

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

type JobRunStatus 

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

func (*JobRunStatus) Scan 

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

type LimitResource added in v0.31.0 

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

func (*LimitResource) Scan added in v0.31.0 

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

type LinkActionsToWorkerParams added in v0.17.0 

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

type LinkOnFailureJobParams added in v0.25.0 

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

type LinkServicesToWorkerParams added in v0.17.0 

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 ListDispatchersRow 

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

type ListEventsByIDsParams added in v0.17.0 

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

type ListEventsParams 

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

type ListEventsRow 

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

type ListJobRunsForWorkflowRunRow added in v0.25.0 

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

type ListLogLinesParams added in v0.14.0 

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

type ListNewlyStaleTickersRow 

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

type ListNonFinalChildStepRunsParams added in v0.28.1 

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

type ListStaleDispatchersRow 

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

type ListStartableStepRunsParams 

type ListStartableStepRunsParams struct {
	Jobrunid        pgtype.UUID `json:"jobrunid"`
	ParentStepRunId pgtype.UUID `json:"parentStepRunId"`
}

type ListStepRunEventsParams added in v0.26.0 

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

type ListStepRunsParams added in v0.17.0 

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

type ListTickersParams added in v0.17.0 

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

type ListWorkersWithStepCountParams added in v0.12.0 

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

type ListWorkersWithStepCountRow added in v0.12.0 

type ListWorkersWithStepCountRow struct {
	Worker          Worker `json:"worker"`
	RunningStepRuns int64  `json:"runningStepRuns"`
	Slots           int64  `json:"slots"`
}

type ListWorkflowRunsParams 

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

type ListWorkflowRunsRow 

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

type ListWorkflowsForEventParams added in v0.16.0 

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

type ListWorkflowsLatestRunsParams 

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

type ListWorkflowsLatestRunsRow 

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

type ListWorkflowsParams 

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

type ListWorkflowsRow 

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

type LogLine added in v0.14.0 

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

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

func (*LogLineLevel) Scan added in v0.14.0 

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

type MeterTenantResourceParams added in v0.31.0 

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

type NullConcurrencyLimitStrategy added in v0.8.0 

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

func (*NullConcurrencyLimitStrategy) Scan added in v0.8.0 

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

Scan implements the Scanner interface.

func (NullConcurrencyLimitStrategy) Value added in v0.8.0 

func (ns NullConcurrencyLimitStrategy) 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 added in v0.25.0 

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

func (*NullJobKind) Scan added in v0.25.0 

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

Scan implements the Scanner interface.

func (NullJobKind) Value added in v0.25.0 

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

Value implements the driver Valuer interface.

type NullJobRunStatus 

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

func (*NullJobRunStatus) Scan 

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

Scan implements the Scanner interface.

func (NullJobRunStatus) Value 

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

Value implements the driver Valuer interface.

type NullLimitResource added in v0.31.0 

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

func (*NullLimitResource) Scan added in v0.31.0 

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

Scan implements the Scanner interface.

func (NullLimitResource) Value added in v0.31.0 

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

Value implements the driver Valuer interface.

type NullLogLineLevel added in v0.14.0 

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

func (*NullLogLineLevel) Scan added in v0.14.0 

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

Scan implements the Scanner interface.

func (NullLogLineLevel) Value added in v0.14.0 

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

Value implements the driver Valuer interface.

type NullStepRunEventReason added in v0.26.0 

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

func (*NullStepRunEventReason) Scan added in v0.26.0 

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

Scan implements the Scanner interface.

func (NullStepRunEventReason) Value added in v0.26.0 

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

Value implements the driver Valuer interface.

type NullStepRunEventSeverity added in v0.26.0 

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

func (*NullStepRunEventSeverity) Scan added in v0.26.0 

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

Scan implements the Scanner interface.

func (NullStepRunEventSeverity) Value added in v0.26.0 

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

Value implements the driver Valuer interface.

type NullStepRunStatus 

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

func (*NullStepRunStatus) Scan 

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

Scan implements the Scanner interface.

func (NullStepRunStatus) Value 

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

Value implements the driver Valuer interface.

type 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 added in v0.31.0 

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

func (*NullTenantResourceLimitAlertType) Scan added in v0.31.0 

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

Scan implements the Scanner interface.

func (NullTenantResourceLimitAlertType) Value added in v0.31.0 

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

Value implements the driver Valuer interface.

type NullVcsProvider added in v0.11.0 

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

func (*NullVcsProvider) Scan added in v0.11.0 

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

Scan implements the Scanner interface.

func (NullVcsProvider) Value added in v0.11.0 

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

Value implements the driver Valuer interface.

type NullWorkflowRunStatus 

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

func (*NullWorkflowRunStatus) Scan 

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

Scan implements the Scanner interface.

func (NullWorkflowRunStatus) Value 

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

Value implements the driver Valuer interface.

type PollCronSchedulesRow added in v0.17.0 

type PollCronSchedulesRow struct {
	ParentId          pgtype.UUID `json:"parentId"`
	Cron              string      `json:"cron"`
	TickerId          pgtype.UUID `json:"tickerId"`
	Input             []byte      `json:"input"`
	Enabled           bool        `json:"enabled"`
	WorkflowVersionId pgtype.UUID `json:"workflowVersionId"`
	TenantId          pgtype.UUID `json:"tenantId"`
}

type PollExpiringTokensRow added in v0.30.0 

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

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

type PollTenantAlertsRow added in v0.25.0 

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 PopWorkflowRunsRoundRobinParams added in v0.12.0 

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

type Queries 

type Queries struct {
}

func New 

func New() *Queries

func (*Queries) AcquireWorkerSemaphoreSlot added in v0.30.0 

func (q *Queries) AcquireWorkerSemaphoreSlot(ctx context.Context, db DBTX, arg AcquireWorkerSemaphoreSlotParams) (*WorkerSemaphoreSlot, error)

func (*Queries) AddStepParents 

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

func (*Queries) AddWorkflowTag 

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

func (*Queries) ArchiveStepRunResultFromStepRun added in v0.11.0 

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

func (*Queries) AssignGetGroupKeyRunToTicker added in v0.16.0 

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

func (*Queries) AssignGetGroupKeyRunToWorker added in v0.16.0 

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

func (*Queries) AssignStepRunToWorker added in v0.16.0 

func (q *Queries) AssignStepRunToWorker(ctx context.Context, db DBTX, arg AssignStepRunToWorkerParams) (*AssignStepRunToWorkerRow, error)

func (*Queries) CleanupStreamEvents added in v0.19.0 

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

func (*Queries) CountEvents 

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

func (*Queries) CountLogLines added in v0.14.0 

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

func (*Queries) CountRoundRobinGroupKeys added in v0.19.3 

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

func (*Queries) CountStepRunEvents added in v0.26.0 

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

func (*Queries) CountTenantWorkers added in v0.31.0 

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

func (*Queries) CountWorkflowRuns 

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

func (*Queries) CountWorkflowRunsRoundRobin added in v0.19.3 

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

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

func (*Queries) CreateDispatcher added in v0.17.0 

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

func (*Queries) CreateEvent 

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

func (*Queries) CreateGetGroupKeyRun added in v0.8.0 

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

func (*Queries) CreateJob 

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

func (*Queries) CreateJobRunLookupData 

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

func (*Queries) CreateJobRuns added in v0.16.0 

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

func (*Queries) CreateLogLine added in v0.14.0 

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

func (*Queries) CreateSchedules added in v0.17.0 

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

func (*Queries) CreateStep 

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

func (*Queries) CreateStepRateLimit added in v0.19.0 

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

func (*Queries) CreateStepRunEvent added in v0.26.0 

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

func (*Queries) CreateStepRuns added in v0.16.0 

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

func (*Queries) CreateStreamEvent added in v0.19.0 

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

func (*Queries) CreateTicker added in v0.17.0 

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

func (*Queries) CreateWorker added in v0.17.0 

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

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

func (*Queries) CreateWorkflowRun 

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

func (*Queries) CreateWorkflowRunTriggeredBy 

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

func (*Queries) CreateWorkflowTriggerCronRef 

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

func (*Queries) CreateWorkflowTriggerEventRef 

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

func (*Queries) CreateWorkflowTriggerScheduledRef 

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

func (*Queries) CreateWorkflowTriggers 

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

func (*Queries) CreateWorkflowVersion 

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

func (*Queries) DeleteDispatcher added in v0.17.0 

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

func (*Queries) DeleteTicker added in v0.17.0 

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

func (*Queries) DeleteWorker added in v0.17.0 

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

func (*Queries) GetAPITokenById added in v0.17.0 

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

func (*Queries) GetChildWorkflowRun added in v0.18.0 

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

func (*Queries) GetEmailGroups added in v0.25.0 

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

func (*Queries) GetEventForEngine added in v0.16.0 

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

func (*Queries) GetEventsForRange 

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

func (*Queries) GetGroupKeyRunForEngine added in v0.16.0 

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

func (*Queries) GetJobRunByWorkflowRunIdAndJobId added in v0.25.0 

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

func (*Queries) GetLaterStepRunsForReplay added in v0.28.1 

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

func (*Queries) GetMemberEmailGroup added in v0.30.0 

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

func (*Queries) GetScheduledChildWorkflowRun added in v0.18.0 

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

func (*Queries) GetSlackWebhooks added in v0.25.0 

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

func (*Queries) GetStepRun 

func (q *Queries) GetStepRun(ctx context.Context, db DBTX, arg GetStepRunParams) (*StepRun, error)

func (*Queries) GetStepRunForEngine added in v0.16.0 

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

func (*Queries) GetStreamEvent added in v0.19.0 

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

func (*Queries) GetTenantAlertingSettings added in v0.25.0 

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

func (*Queries) GetTenantByID added in v0.17.0 

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

func (*Queries) GetTenantResourceLimit added in v0.31.0 

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

func (*Queries) GetWorkerForEngine added in v0.16.0 

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

func (*Queries) GetWorkflowByName added in v0.17.0 

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

func (*Queries) GetWorkflowLatestVersion added in v0.17.0 

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

func (*Queries) GetWorkflowRun added in v0.17.0 

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

func (*Queries) GetWorkflowVersionForEngine added in v0.16.0 

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

func (*Queries) Health added in v0.13.0 

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

func (*Queries) LinkActionsToWorker added in v0.17.0 

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

func (*Queries) LinkOnFailureJob added in v0.25.0 

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

func (*Queries) LinkServicesToWorker added in v0.17.0 

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

func (*Queries) LinkStepRunParents 

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

func (*Queries) ListActiveDispatchers 

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

func (*Queries) ListActiveTickers 

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

func (*Queries) ListDispatchers 

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

func (*Queries) ListEvents 

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

func (*Queries) ListEventsByIDs added in v0.17.0 

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

func (*Queries) ListGetGroupKeyRunsToReassign added in v0.16.0 

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

func (*Queries) ListGetGroupKeyRunsToRequeue added in v0.13.2 

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

func (*Queries) ListJobRunsForWorkflowRun added in v0.17.0 

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

func (*Queries) ListLogLines added in v0.14.0 

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

func (*Queries) ListNewlyStaleTickers 

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

func (*Queries) ListNonFinalChildStepRuns added in v0.28.1 

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

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

func (*Queries) ListStaleDispatchers 

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

func (*Queries) ListStartableStepRuns 

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

func (*Queries) ListStepRunEvents added in v0.26.0 

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

func (*Queries) ListStepRuns added in v0.17.0 

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

func (*Queries) ListStepRunsToReassign added in v0.14.2 

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

Count the total number of slots across all workers

func (*Queries) ListStepRunsToRequeue added in v0.13.0 

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

Count the total number of maxRuns - runningStepRuns across all workers

func (*Queries) ListTenantResourceLimits added in v0.31.0 

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

func (*Queries) ListTenants added in v0.17.0 

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

func (*Queries) ListTickers 

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

func (*Queries) ListWorkersWithStepCount added in v0.12.0 

func (q *Queries) ListWorkersWithStepCount(ctx context.Context, db DBTX, arg ListWorkersWithStepCountParams) ([]*ListWorkersWithStepCountRow, error)

func (*Queries) ListWorkflowRuns 

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

func (*Queries) ListWorkflows 

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

func (*Queries) ListWorkflowsForEvent added in v0.16.0 

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

func (*Queries) ListWorkflowsLatestRuns 

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

func (*Queries) MeterTenantResource added in v0.31.0 

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

func (*Queries) PollCronSchedules added in v0.17.0 

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

func (*Queries) PollExpiringTokens added in v0.30.0 

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

func (*Queries) PollGetGroupKeyRuns added in v0.17.0 

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

func (*Queries) PollScheduledWorkflows added in v0.17.0 

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) PollStepRuns added in v0.17.0 

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

func (*Queries) PollTenantAlerts added in v0.25.0 

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

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

func (*Queries) PopWorkflowRunsRoundRobin added in v0.12.0 

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

func (*Queries) RefreshTimeoutBy added in v0.28.0 

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

func (*Queries) ReleaseWorkerSemaphoreSlot added in v0.30.0 

func (q *Queries) ReleaseWorkerSemaphoreSlot(ctx context.Context, db DBTX, arg ReleaseWorkerSemaphoreSlotParams) (*WorkerSemaphoreSlot, error)

func (*Queries) ReplayStepRunResetJobRun added in v0.28.1 

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

func (*Queries) ReplayStepRunResetLaterStepRuns added in v0.28.1 

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

func (*Queries) ReplayStepRunResetWorkflowRun added in v0.28.1 

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

func (*Queries) ResolveAllLimitsIfWindowPassed added in v0.31.0 

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

func (*Queries) ResolveJobRunStatus 

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

func (*Queries) ResolveLaterStepRuns 

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

func (*Queries) ResolveWorkerSemaphoreSlots added in v0.27.0 

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

func (*Queries) ResolveWorkflowRunStatus 

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

func (*Queries) SelectOrInsertTenantResourceLimit added in v0.31.0 

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

func (*Queries) SetDispatchersInactive 

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

func (*Queries) SetTickersInactive 

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

func (*Queries) StubWorkerSemaphoreSlots added in v0.30.0 

func (q *Queries) StubWorkerSemaphoreSlots(ctx context.Context, db DBTX, arg StubWorkerSemaphoreSlotsParams) error

func (*Queries) UnlinkStepRunFromWorker added in v0.22.4 

func (q *Queries) UnlinkStepRunFromWorker(ctx context.Context, db DBTX, arg UnlinkStepRunFromWorkerParams) (*StepRun, error)

func (*Queries) UpdateDispatcher added in v0.17.0 

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

func (*Queries) UpdateGetGroupKeyRun added in v0.8.0 

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

func (*Queries) UpdateJobRunLookupDataWithStepRun 

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

func (*Queries) UpdateJobRunStatus added in v0.16.0 

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

func (*Queries) UpdateManyWorkflowRun added in v0.12.0 

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

func (*Queries) UpdateStepRateLimits added in v0.19.0 

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

func (*Queries) UpdateStepRun 

func (q *Queries) UpdateStepRun(ctx context.Context, db DBTX, arg UpdateStepRunParams) (*StepRun, error)

func (*Queries) UpdateStepRunInputSchema added in v0.11.0 

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

func (*Queries) UpdateStepRunOverridesData added in v0.11.0 

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

func (*Queries) UpdateTenantAlertingSettings added in v0.25.0 

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

func (*Queries) UpdateTicker added in v0.17.0 

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

func (*Queries) UpdateWorker added in v0.17.0 

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

func (*Queries) UpdateWorkerActiveStatus added in v0.28.3 

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

func (*Queries) UpdateWorkflowRun added in v0.11.0 

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

func (*Queries) UpdateWorkflowRunGroupKey added in v0.8.0 

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

func (*Queries) UpsertAction 

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

func (*Queries) UpsertJobRunLookupData 

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

func (*Queries) UpsertRateLimit added in v0.19.0 

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

func (*Queries) UpsertService added in v0.17.0 

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

func (*Queries) UpsertWorkflowTag 

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

func (*Queries) WorkflowRunsMetricsCount added in v0.22.0 

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

type RateLimit added in v0.19.0 

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

type RefreshTimeoutByParams added in v0.28.0 

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

type ReleaseWorkerSemaphoreSlotParams added in v0.30.0 

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

type ReplayStepRunResetLaterStepRunsParams added in v0.28.1 

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

type ResolveAllLimitsIfWindowPassedRow added in v0.31.0 

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

type ResolveJobRunStatusParams 

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

type ResolveLaterStepRunsParams 

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

type ResolveWorkflowRunStatusParams 

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

type SNSIntegration added in v0.15.0 

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 SelectOrInsertTenantResourceLimitParams added in v0.31.0 

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

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

type Service 

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

type ServiceToWorker 

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

type SetDispatchersInactiveRow 

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

type SetTickersInactiveRow 

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

type SlackAppWebhook added in v0.25.0 

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"`
	ScheduleTimeout string           `json:"scheduleTimeout"`
}

type StepOrder 

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

type StepRateLimit added in v0.19.0 

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

type StepRun 

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

type StepRunEvent added in v0.26.0 

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

type StepRunEventReason added in v0.26.0 

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

func (*StepRunEventReason) Scan added in v0.26.0 

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

type StepRunEventSeverity added in v0.26.0 

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

func (*StepRunEventSeverity) Scan added in v0.26.0 

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

type StepRunOrder 

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

type StepRunResultArchive added in v0.11.0 

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

type StepRunStatus 

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

func (*StepRunStatus) Scan 

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

type StreamEvent added in v0.19.0 

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

type StubWorkerSemaphoreSlotsParams added in v0.30.0 

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

type Tenant 

type Tenant struct {
	ID                pgtype.UUID      `json:"id"`
	CreatedAt         pgtype.Timestamp `json:"createdAt"`
	UpdatedAt         pgtype.Timestamp `json:"updatedAt"`
	DeletedAt         pgtype.Timestamp `json:"deletedAt"`
	Name              string           `json:"name"`
	Slug              string           `json:"slug"`
	AnalyticsOptOut   bool             `json:"analyticsOptOut"`
	AlertMemberEmails bool             `json:"alertMemberEmails"`
}

type TenantAlertEmailGroup added in v0.25.0 

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

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

type TenantMember 

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

type TenantMemberRole 

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

func (*TenantMemberRole) Scan 

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

type TenantResourceLimit added in v0.31.0 

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

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

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

func (*TenantResourceLimitAlertType) Scan added in v0.31.0 

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

type TenantVcsProvider added in v0.11.0 

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 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 UnlinkStepRunFromWorkerParams added in v0.22.4 

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

type UpdateDispatcherParams added in v0.17.0 

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

type UpdateGetGroupKeyRunParams added in v0.8.0 

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

type UpdateJobRunLookupDataWithStepRunParams 

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

type UpdateJobRunStatusParams added in v0.16.0 

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

type UpdateManyWorkflowRunParams added in v0.12.0 

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

type UpdateStepRateLimitsParams added in v0.19.0 

type UpdateStepRateLimitsParams struct {
	Stepid   pgtype.UUID `json:"stepid"`
	Tenantid pgtype.UUID `json:"tenantid"`
}

type UpdateStepRunInputSchemaParams added in v0.11.0 

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

type UpdateStepRunOverridesDataParams added in v0.11.0 

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

type UpdateStepRunParams 

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

type UpdateTenantAlertingSettingsParams added in v0.25.0 

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

type UpdateTickerParams added in v0.17.0 

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

type UpdateWorkerActiveStatusParams added in v0.28.3 

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

type UpdateWorkerParams added in v0.17.0 

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

type UpdateWorkflowRunGroupKeyParams added in v0.8.0 

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

type UpdateWorkflowRunParams added in v0.11.0 

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

type UpsertActionParams 

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

type UpsertJobRunLookupDataParams 

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

type UpsertRateLimitParams added in v0.19.0 

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

type UpsertServiceParams added in v0.17.0 

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

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

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

func (*VcsProvider) Scan added in v0.11.0 

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

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

type WorkerSemaphore added in v0.18.1 

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

type WorkerSemaphoreSlot added in v0.30.0 

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

type Workflow 

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

type WorkflowConcurrency added in v0.8.0 

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

type WorkflowDeploymentConfig added in v0.11.0 

type WorkflowDeploymentConfig struct {
	ID                      pgtype.UUID      `json:"id"`
	CreatedAt               pgtype.Timestamp `json:"createdAt"`
	UpdatedAt               pgtype.Timestamp `json:"updatedAt"`
	DeletedAt               pgtype.Timestamp `json:"deletedAt"`
	WorkflowId              pgtype.UUID      `json:"workflowId"`
	GitRepoName             string           `json:"gitRepoName"`
	GitRepoOwner            string           `json:"gitRepoOwner"`
	GitRepoBranch           string           `json:"gitRepoBranch"`
	GithubAppInstallationId pgtype.UUID      `json:"githubAppInstallationId"`
}

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"`
	GitRepoBranch      pgtype.Text       `json:"gitRepoBranch"`
	ChildIndex         pgtype.Int4       `json:"childIndex"`
	ChildKey           pgtype.Text       `json:"childKey"`
	ParentId           pgtype.UUID       `json:"parentId"`
	ParentStepRunId    pgtype.UUID       `json:"parentStepRunId"`
	AdditionalMetadata []byte            `json:"additionalMetadata"`
}

type WorkflowRunStatus 

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

func (*WorkflowRunStatus) Scan 

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

type WorkflowRunTriggeredBy 

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

type WorkflowRunsMetricsCountParams added in v0.22.0 

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

type WorkflowRunsMetricsCountRow added in v0.22.0 

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

type WorkflowTag 

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

type WorkflowToWorkflowTag 

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

type WorkflowTriggerCronRef 

type WorkflowTriggerCronRef struct {
	ParentId pgtype.UUID `json:"parentId"`
	Cron     string      `json:"cron"`
	TickerId pgtype.UUID `json:"tickerId"`
	Input    []byte      `json:"input"`
	Enabled  bool        `json:"enabled"`
}

type WorkflowTriggerEventRef 

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

type WorkflowTriggerScheduledRef 

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

type WorkflowTriggers 

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

type WorkflowVersion 

type WorkflowVersion struct {
	ID              pgtype.UUID      `json:"id"`
	CreatedAt       pgtype.Timestamp `json:"createdAt"`
	UpdatedAt       pgtype.Timestamp `json:"updatedAt"`
	DeletedAt       pgtype.Timestamp `json:"deletedAt"`
	Version         pgtype.Text      `json:"version"`
	Order           int64            `json:"order"`
	WorkflowId      pgtype.UUID      `json:"workflowId"`
	Checksum        string           `json:"checksum"`
	ScheduleTimeout string           `json:"scheduleTimeout"`
	OnFailureJobId  pgtype.UUID      `json:"onFailureJobId"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.