store

Documentation

Index

• Variables
• type DataStore

Variables

var (
	ErrWorkflowNotFound      = errors.New("Workflow not found")
	ErrWorkflowMissingName   = errors.New("Workflow missing name")
	ErrWorkflowAlreadyExists = errors.New("Workflow already exists")
)

Error messages

Types

type DataStore

type DataStore interface {
	Ping(ctx context.Context) error
	InsertWorkflows(ctx context.Context, workflow ...model.Workflow) (int, error)
	GetWorkflowByName(
		ctx context.Context,
		workflowName string,
		version string,
	) (*model.Workflow, error)
	GetWorkflows(ctx context.Context) []model.Workflow
	LoadWorkflows(ctx context.Context, l *log.Logger) error
	UpsertJob(ctx context.Context, job *model.Job) (*model.Job, error)
	GetAllJobs(ctx context.Context, page int64, perPage int64) ([]model.Job, int64, error)
	UpdateJobAddResult(ctx context.Context, job *model.Job, result *model.TaskResult) error
	UpdateJobStatus(ctx context.Context, job *model.Job, status int32) error
	GetJobByNameAndID(ctx context.Context, name string, ID string) (*model.Job, error)
	GetJobByID(ctx context.Context, ID string) (*model.Job, error)
}

DataStore interface for DataStore services