jobdbschema

package

v0.0.49 Latest Latest Go to latest Published: Jul 2, 2026 License: Apache-2.0 Imports: 8 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.JobKey, error)
}

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

type Submitter struct {
	JobSubmitter
	RestartSubmitter
	Registry jobdb.JobSchemaRegistry
}

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

func (s Submitter) SubmitRestartJob(ctx context.Context, job jobdb.SubmitRestartJob) (jobdb.JobKey, error)

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

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

func (e WorkflowEngine) SubmitRestartJob(ctx context.Context, job jobdb.SubmitRestartJob) (jobdb.JobKey, error)