inmemory

Documentation

Index

• type JobStore
  • func NewJobStore() *JobStore
  • func (d *JobStore) CreateExecution(_ context.Context, execution model.ExecutionState) error
  • func (d *JobStore) CreateJob(_ context.Context, job model.Job) error
  • func (d *JobStore) GetInProgressJobs(ctx context.Context) ([]model.JobWithInfo, error)
  • func (d *JobStore) GetJob(_ context.Context, id string) (model.Job, error)
  • func (d *JobStore) GetJobHistory(_ context.Context, jobID string, options jobstore.JobHistoryFilterOptions) ([]model.JobHistory, error)
  • func (d *JobStore) GetJobState(_ context.Context, jobID string) (model.JobState, error)
  • func (d *JobStore) GetJobs(ctx context.Context, query jobstore.JobQuery) ([]model.Job, error)
  • func (d *JobStore) GetJobsCount(ctx context.Context, query jobstore.JobQuery) (int, error)
  • func (d *JobStore) UpdateExecution(_ context.Context, request jobstore.UpdateExecutionRequest) error
  • func (d *JobStore) UpdateJobState(_ context.Context, request jobstore.UpdateJobStateRequest) error

Types

type JobStore

type JobStore struct {
	// contains filtered or unexported fields
}

func NewJobStore

func NewJobStore() *JobStore

func (*JobStore) CreateExecution

func (d *JobStore) CreateExecution(_ context.Context, execution model.ExecutionState) error

func (*JobStore) CreateJob

func (d *JobStore) CreateJob(_ context.Context, job model.Job) error

func (*JobStore) GetInProgressJobs

func (d *JobStore) GetInProgressJobs(ctx context.Context) ([]model.JobWithInfo, error)

func (*JobStore) GetJob

func (d *JobStore) GetJob(_ context.Context, id string) (model.Job, error)

Gets a job from the datastore.

Errors:

• error-job-not-found -- if the job is not found

func (*JobStore) GetJobHistory

func (d *JobStore) GetJobHistory(_ context.Context, jobID string, options jobstore.JobHistoryFilterOptions) ([]model.JobHistory, error)

func (*JobStore) GetJobState

func (d *JobStore) GetJobState(_ context.Context, jobID string) (model.JobState, error)

func (*JobStore) GetJobs

func (d *JobStore) GetJobs(ctx context.Context, query jobstore.JobQuery) ([]model.Job, error)

func (*JobStore) GetJobsCount

func (d *JobStore) GetJobsCount(ctx context.Context, query jobstore.JobQuery) (int, error)

func (*JobStore) UpdateExecution

func (d *JobStore) UpdateExecution(_ context.Context, request jobstore.UpdateExecutionRequest) error

func (*JobStore) UpdateJobState

func (d *JobStore) UpdateJobState(_ context.Context, request jobstore.UpdateJobStateRequest) error