inmemory

Documentation

Index

• type InMemoryJobStore
  • func NewInMemoryJobStore(options ...Option) *InMemoryJobStore
  • func (d *InMemoryJobStore) Close(_ context.Context) error
  • func (d *InMemoryJobStore) CreateEvaluation(ctx context.Context, eval models.Evaluation) error
  • func (d *InMemoryJobStore) CreateExecution(_ context.Context, execution models.Execution) error
  • func (d *InMemoryJobStore) CreateJob(_ context.Context, job models.Job) error
  • func (d *InMemoryJobStore) DeleteEvaluation(ctx context.Context, id string) error
  • func (d *InMemoryJobStore) DeleteJob(ctx context.Context, jobID string) error
  • func (d *InMemoryJobStore) GetEvaluation(ctx context.Context, id string) (models.Evaluation, error)
  • func (d *InMemoryJobStore) GetExecutions(_ context.Context, jobID string) ([]models.Execution, error)
  • func (d *InMemoryJobStore) GetInProgressJobs(ctx context.Context) ([]models.Job, error)
  • func (d *InMemoryJobStore) GetJob(_ context.Context, id string) (models.Job, error)
  • func (d *InMemoryJobStore) GetJobHistory(_ context.Context, jobID string, options jobstore.JobHistoryFilterOptions) ([]models.JobHistory, error)
  • func (d *InMemoryJobStore) GetJobs(ctx context.Context, query jobstore.JobQuery) ([]models.Job, error)
  • func (d *InMemoryJobStore) UpdateExecution(_ context.Context, request jobstore.UpdateExecutionRequest) error
  • func (d *InMemoryJobStore) UpdateJobState(_ context.Context, request jobstore.UpdateJobStateRequest) error
  • func (d *InMemoryJobStore) Watch(c context.Context, t jobstore.StoreWatcherType, e jobstore.StoreEventType) chan jobstore.WatchEvent
• type Option
  • func WithClock(clock clock.Clock) Option

Types

type InMemoryJobStore

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

func NewInMemoryJobStore

func NewInMemoryJobStore(options ...Option) *InMemoryJobStore

func (*InMemoryJobStore) Close

func (d *InMemoryJobStore) Close(_ context.Context) error

func (*InMemoryJobStore) CreateEvaluation

func (d *InMemoryJobStore) CreateEvaluation(ctx context.Context, eval models.Evaluation) error

CreateEvaluation creates a new evaluation

func (*InMemoryJobStore) CreateExecution

func (d *InMemoryJobStore) CreateExecution(_ context.Context, execution models.Execution) error

func (*InMemoryJobStore) CreateJob

func (d *InMemoryJobStore) CreateJob(_ context.Context, job models.Job) error

func (*InMemoryJobStore) DeleteEvaluation

func (d *InMemoryJobStore) DeleteEvaluation(ctx context.Context, id string) error

DeleteEvaluation deletes the specified evaluation

func (*InMemoryJobStore) DeleteJob

func (d *InMemoryJobStore) DeleteJob(ctx context.Context, jobID string) error

DeleteJob removes a job from storage

func (*InMemoryJobStore) GetEvaluation

func (d *InMemoryJobStore) GetEvaluation(ctx context.Context, id string) (models.Evaluation, error)

GetEvaluation retrieves the specified evaluation

func (*InMemoryJobStore) GetExecutions

func (d *InMemoryJobStore) GetExecutions(_ context.Context, jobID string) ([]models.Execution, error)

func (*InMemoryJobStore) GetInProgressJobs

func (d *InMemoryJobStore) GetInProgressJobs(ctx context.Context) ([]models.Job, error)

func (*InMemoryJobStore) GetJob

func (d *InMemoryJobStore) GetJob(_ context.Context, id string) (models.Job, error)

Gets a job from the datastore.

Errors:

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

func (*InMemoryJobStore) GetJobHistory

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

func (*InMemoryJobStore) GetJobs

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

func (*InMemoryJobStore) UpdateExecution

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

func (*InMemoryJobStore) UpdateJobState

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

func (*InMemoryJobStore) Watch

func (d *InMemoryJobStore) Watch(c context.Context, t jobstore.StoreWatcherType, e jobstore.StoreEventType) chan jobstore.WatchEvent

type Option

type Option func(store *(InMemoryJobStore))

func WithClock

func WithClock(clock clock.Clock) Option