jobdbschema

package

v0.0.113 Latest Latest Go to latest Published: Oct 30, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func Hash() (string, error)

func Register(ctx context.Context, registry jobdb.JobSchemaRegistry, tenantID string) error

func Schema() json.RawMessage

func Selector() (*jobdb.JobSchemaSelector, error)

func SetSubmitJobSchema(job *jobdb.SubmitJob) error

func SetSubmitRestartJobSchema(job *jobdb.SubmitRestartJob) error

type JobSubmitter interface {
	SubmitJob(context.Context, jobdb.SubmitJob) (jobdb.JobHandle, error)
}

type RestartSubmitter interface {
	SubmitRestartJob(context.Context, jobdb.SubmitRestartJobRequest) (jobdb.JobHandle, error)
}

type Submitter struct {
	JobSubmitter
	RestartSubmitter
	Registry jobdb.JobSchemaRegistry
}

func (s Submitter) GetJob(ctx context.Context, key jobdb.JobKey) (jobdb.JobInfo, error)

func (s Submitter) SubmitJob(ctx context.Context, job jobdb.SubmitJob) (jobdb.JobHandle, error)

func (s Submitter) SubmitRestartJob(ctx context.Context, req jobdb.SubmitRestartJobRequest) (jobdb.JobHandle, error)

type WorkflowEngine struct {
	jobworkflow.Engine
	Registry jobdb.JobSchemaRegistry
}

func (e WorkflowEngine) AddGoalCandidate(ctx context.Context, req jobdb.AddGoalCandidateRequest) (jobdb.GoalCandidateInfo, error)

func (e WorkflowEngine) FailGoal(ctx context.Context, req jobdb.FailGoalRequest) (jobdb.GoalInfo, error)

func (e WorkflowEngine) GetDependencyWait(ctx context.Context, key jobdb.DependencyWaitKey) (jobdb.DependencyWaitInfo, error)

func (e WorkflowEngine) GetGoal(ctx context.Context, key jobdb.GoalKey) (jobdb.GoalInfo, error)

func (e WorkflowEngine) ListDependencyWaits(ctx context.Context, req jobdb.ListDependencyWaitsRequest) (jobdb.ListDependencyWaitsResponse, error)

func (e WorkflowEngine) ListGoals(ctx context.Context, req jobdb.ListGoalsRequest) (jobdb.ListGoalsResponse, error)

func (e WorkflowEngine) SubmitJob(ctx context.Context, job jobdb.SubmitJob) (jobdb.JobHandle, error)

func (e WorkflowEngine) SubmitJobRef(ctx context.Context, job jobdb.SubmitJob) (jobref.Ref, error)

SubmitJobRef projects the native SDK handle without another identity read.

func (e WorkflowEngine) SubmitRestartJob(ctx context.Context, req jobdb.SubmitRestartJobRequest) (jobdb.JobHandle, error)

func (e WorkflowEngine) SubmitRestartJobRef(ctx context.Context, req jobdb.SubmitRestartJobRequest) (jobref.Ref, error)