dbsqlc

Documentation

Index

• type Action
• type ActionToWorker
• type CountEventsParams
• type CountWorkflowRunsParams
• type CountWorkflowsParams
• type DBTX
• type Dispatcher
• type Event
• type GetEventsForRangeRow
• type Job
• type JobRun
• type JobRunLookupData
• type JobRunStatus
  • func (e *JobRunStatus) Scan(src interface{}) error
• type ListEventsParams
• type ListEventsRow
• type ListWorkflowRunsParams
• type ListWorkflowRunsRow
• type ListWorkflowsLatestRunsParams
• type ListWorkflowsLatestRunsRow
• type ListWorkflowsParams
• type ListWorkflowsRow
• type NullJobRunStatus
  • func (ns *NullJobRunStatus) Scan(value interface{}) error
  • func (ns NullJobRunStatus) Value() (driver.Value, error)
• type NullStepRunStatus
  • func (ns *NullStepRunStatus) Scan(value interface{}) error
  • func (ns NullStepRunStatus) Value() (driver.Value, error)
• type NullTenantMemberRole
  • func (ns *NullTenantMemberRole) Scan(value interface{}) error
  • func (ns NullTenantMemberRole) Value() (driver.Value, error)
• type NullWorkerStatus
  • func (ns *NullWorkerStatus) Scan(value interface{}) error
  • func (ns NullWorkerStatus) Value() (driver.Value, error)
• type NullWorkflowRunStatus
  • func (ns *NullWorkflowRunStatus) Scan(value interface{}) error
  • func (ns NullWorkflowRunStatus) Value() (driver.Value, error)
• type Queries
  • func New() *Queries
  • func (q *Queries) CountEvents(ctx context.Context, db DBTX, arg CountEventsParams) (int64, error)
  • func (q *Queries) CountWorkflowRuns(ctx context.Context, db DBTX, arg CountWorkflowRunsParams) (int64, error)
  • func (q *Queries) CountWorkflows(ctx context.Context, db DBTX, arg CountWorkflowsParams) (int64, error)
  • func (q *Queries) GetEventsForRange(ctx context.Context, db DBTX) ([]*GetEventsForRangeRow, error)
  • func (q *Queries) ListEvents(ctx context.Context, db DBTX, arg ListEventsParams) ([]*ListEventsRow, error)
  • func (q *Queries) ListWorkflowRuns(ctx context.Context, db DBTX, arg ListWorkflowRunsParams) ([]*ListWorkflowRunsRow, error)
  • func (q *Queries) ListWorkflows(ctx context.Context, db DBTX, arg ListWorkflowsParams) ([]*ListWorkflowsRow, error)
  • func (q *Queries) ListWorkflowsLatestRuns(ctx context.Context, db DBTX, arg ListWorkflowsLatestRunsParams) ([]*ListWorkflowsLatestRunsRow, error)
  • func (q *Queries) ResolveJobRunStatus(ctx context.Context, db DBTX, arg ResolveJobRunStatusParams) (*JobRun, error)
  • func (q *Queries) ResolveLaterStepRuns(ctx context.Context, db DBTX, arg ResolveLaterStepRunsParams) ([]*StepRun, error)
  • func (q *Queries) ResolveWorkflowRunStatus(ctx context.Context, db DBTX, arg ResolveWorkflowRunStatusParams) (*WorkflowRun, error)
  • func (q *Queries) UpdateJobRun(ctx context.Context, db DBTX, arg UpdateJobRunParams) (*JobRun, error)
  • func (q *Queries) UpdateStepRun(ctx context.Context, db DBTX, arg UpdateStepRunParams) (*StepRun, error)
• type ResolveJobRunStatusParams
• type ResolveLaterStepRunsParams
• type ResolveWorkflowRunStatusParams
• type Service
• type ServiceToWorker
• type Step
• type StepRun
• type StepRunStatus
  • func (e *StepRunStatus) Scan(src interface{}) error
• type Tenant
• type TenantMember
• type TenantMemberRole
  • func (e *TenantMemberRole) Scan(src interface{}) error
• type Ticker
• type UpdateJobRunParams
• type UpdateStepRunParams
• type User
• type UserPassword
• type UserSession
• type Worker
• type WorkerStatus
  • func (e *WorkerStatus) Scan(src interface{}) error
• type Workflow
• type WorkflowRun
• type WorkflowRunStatus
  • func (e *WorkflowRunStatus) Scan(src interface{}) error
• type WorkflowRunTriggeredBy
• type WorkflowTag
• type WorkflowToWorkflowTag
• type WorkflowTriggerCronRef
• type WorkflowTriggerEventRef
• type WorkflowTriggers
• type WorkflowVersion

Types

type Action

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

type ActionToWorker

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

type CountEventsParams

type CountEventsParams struct {
	TenantId pgtype.UUID `json:"tenantId"`
	Keys     []string    `json:"keys"`
}

type CountWorkflowRunsParams

type CountWorkflowRunsParams struct {
	TenantId   pgtype.UUID `json:"tenantId"`
	WorkflowId pgtype.UUID `json:"workflowId"`
	EventId    pgtype.UUID `json:"eventId"`
}

type CountWorkflowsParams

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

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

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

type GetEventsForRangeRow

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

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

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"`
	WorkflowRunId   string           `json:"workflowRunId"`
	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"`
}

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 ListEventsParams

type ListEventsParams struct {
	TenantId pgtype.UUID `json:"tenantId"`
	Keys     []string    `json:"keys"`
	Search   pgtype.Text `json:"search"`
	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"`
	Runningruns   int64 `json:"runningruns"`
	Succeededruns int64 `json:"succeededruns"`
	Failedruns    int64 `json:"failedruns"`
}

type ListWorkflowRunsParams

type ListWorkflowRunsParams struct {
	TenantId   pgtype.UUID `json:"tenantId"`
	WorkflowId pgtype.UUID `json:"workflowId"`
	EventId    pgtype.UUID `json:"eventId"`
	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 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 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 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 NullWorkerStatus

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

func (*NullWorkerStatus) Scan

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

Scan implements the Scanner interface.

func (NullWorkerStatus) Value

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

type Queries struct {
}

func New

func New() *Queries

func (*Queries) CountEvents

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

func (*Queries) CountWorkflowRuns

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

func (*Queries) CountWorkflows

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

func (*Queries) GetEventsForRange

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

func (*Queries) ListEvents

func (q *Queries) ListEvents(ctx context.Context, db DBTX, arg ListEventsParams) ([]*ListEventsRow, 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) ListWorkflowsLatestRuns

func (q *Queries) ListWorkflowsLatestRuns(ctx context.Context, db DBTX, arg ListWorkflowsLatestRunsParams) ([]*ListWorkflowsLatestRunsRow, 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) ResolveWorkflowRunStatus

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

func (*Queries) UpdateJobRun

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

func (*Queries) UpdateStepRun

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

type ResolveJobRunStatusParams

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

type ResolveLaterStepRunsParams

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

type ResolveWorkflowRunStatusParams

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

type Service

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

type ServiceToWorker

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

type 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"`
	Inputs     []byte           `json:"inputs"`
	NextId     pgtype.UUID      `json:"nextId"`
}

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"`
	NextId            pgtype.UUID      `json:"nextId"`
	Order             int16            `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"`
}

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

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 Ticker

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

type UpdateJobRunParams

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

type UpdateStepRunParams

type UpdateStepRunParams struct {
	RequeueAfter      pgtype.Timestamp  `json:"requeueAfter"`
	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"`
	ID                pgtype.UUID       `json:"id"`
	Tenantid          pgtype.UUID       `json:"tenantid"`
}

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 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 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"`
	Status          WorkerStatus     `json:"status"`
	DispatcherId    pgtype.UUID      `json:"dispatcherId"`
}

type WorkerStatus

type WorkerStatus string

const (
	WorkerStatusACTIVE   WorkerStatus = "ACTIVE"
	WorkerStatusINACTIVE WorkerStatus = "INACTIVE"
)

func (*WorkerStatus) Scan

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

type Workflow

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

type WorkflowRun

type WorkflowRun struct {
	ID                string            `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"`
	Status            WorkflowRunStatus `json:"status"`
	Input             []byte            `json:"input"`
	Error             pgtype.Text       `json:"error"`
	StartedAt         pgtype.Timestamp  `json:"startedAt"`
	FinishedAt        pgtype.Timestamp  `json:"finishedAt"`
}

type WorkflowRunStatus

type WorkflowRunStatus string

const (
	WorkflowRunStatusPENDING   WorkflowRunStatus = "PENDING"
	WorkflowRunStatusRUNNING   WorkflowRunStatus = "RUNNING"
	WorkflowRunStatusSUCCEEDED WorkflowRunStatus = "SUCCEEDED"
	WorkflowRunStatusFAILED    WorkflowRunStatus = "FAILED"
)

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"`
	ParentId     string           `json:"parentId"`
	EventId      pgtype.UUID      `json:"eventId"`
	CronParentId pgtype.UUID      `json:"cronParentId"`
	CronSchedule pgtype.Text      `json:"cronSchedule"`
}

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

type WorkflowTriggerEventRef

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

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    string           `json:"version"`
	Order      int16            `json:"order"`
	WorkflowId pgtype.UUID      `json:"workflowId"`
}