entgo

func (Database) CheckHealth ¶

func (db Database) CheckHealth(_ context.Context) error

func (Database) CreateJob ¶

func (db Database) CreateJob(ctx context.Context, job *model.Job) (*model.Job, error)

CreateJob persists a new job and sets the job ID field.

func (Database) CreateWorkflow ¶

func (db Database) CreateWorkflow(ctx context.Context, workflow *model.Workflow) (*model.Workflow, error)

CreateWorkflow creates a new workflow.

func (Database) DeleteJob ¶

func (db Database) DeleteJob(ctx context.Context, jobID string) error

func (Database) DeleteWorkflow ¶

func (db Database) DeleteWorkflow(ctx context.Context, name string) error

DeleteWorkflow deletes an existing workflow.

func (Database) GetJob ¶

func (db Database) GetJob(ctx context.Context, jobID string, fetchParams persistence.FetchParams) (*model.Job, error)

func (Database) GetWorkflow ¶

func (db Database) GetWorkflow(ctx context.Context, name string) (*model.Workflow, error)

func (Database) QueryJobs ¶

func (db Database) QueryJobs(ctx context.Context,
	filterParams persistence.FilterParams,
	sortParams persistence.SortParams,
	paginationParams persistence.PaginationParams,
) (*model.PaginatedJobList, error)

QueryJobs returns the jobs matching filterParams.

func (Database) QueryWorkflows ¶

func (db Database) QueryWorkflows(ctx context.Context, paginationParams persistence.PaginationParams) (*model.PaginatedWorkflowList, error)

QueryWorkflows returns multiple workflows (paginated).

func (Database) Shutdown ¶

func (db Database) Shutdown()

func (Database) UpdateJob ¶

func (db Database) UpdateJob(ctx context.Context, job *model.Job, request persistence.JobUpdate) (*model.Job, error)

UpdateJob updates an existing job and its history.