mock

Documentation

Index

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

Types

type DataStore

type DataStore struct {
	mock.Mock
}

DataStore is a mocked data storage service

func NewDataStore

func NewDataStore() *DataStore

NewDataStore initializes a DataStore mock object

func (*DataStore) GetAllJobs

func (db *DataStore) GetAllJobs(
	ctx context.Context,
	page int64,
	perPage int64,
) ([]model.Job, int64, error)

func (*DataStore) GetJobByID

func (db *DataStore) GetJobByID(ctx context.Context,
	ID string) (*model.Job, error)

GetJobByID get a job by ID

func (*DataStore) GetJobByNameAndID

func (db *DataStore) GetJobByNameAndID(ctx context.Context,
	name, ID string) (*model.Job, error)

GetJobByNameAndID get the task execution status for a job status bu Name and ID

func (*DataStore) GetWorkflowByName

func (db *DataStore) GetWorkflowByName(ctx context.Context,
	workflowName string, version string) (*model.Workflow, error)

GetWorkflowByName returns a workflow by name

func (*DataStore) GetWorkflows

func (db *DataStore) GetWorkflows(ctx context.Context) []model.Workflow

GetWorkflows returns the list of workflows

func (*DataStore) InsertWorkflows

func (db *DataStore) InsertWorkflows(ctx context.Context,
	workflows ...model.Workflow) (int, error)

InsertWorkflows inserts one or multiple workflows

func (*DataStore) LoadWorkflows

func (db *DataStore) LoadWorkflows(ctx context.Context, l *log.Logger) error

LoadWorkflows from filesystem if the workflowsPath setting is provided

func (*DataStore) Ping

func (db *DataStore) Ping(ctx context.Context) error

func (*DataStore) UpdateJobAddResult

func (db *DataStore) UpdateJobAddResult(ctx context.Context,
	job *model.Job, result *model.TaskResult) error

UpdateJobAddResult add a task execution result to a job status

func (*DataStore) UpdateJobStatus

func (db *DataStore) UpdateJobStatus(ctx context.Context, job *model.Job,
	status int32) error

UpdateJobStatus set the task execution status for a job status

func (*DataStore) UpsertJob

func (db *DataStore) UpsertJob(ctx context.Context, job *model.Job) (*model.Job, error)

UpsertJob inserts the job in the queue