job_store

package
v0.12.10 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 1, 2021 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DynamoJobStore

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

func NewDynamoJobStore

func NewDynamoJobStore(session *session.Session, table string) *DynamoJobStore

func (*DynamoJobStore) Clear

func (d *DynamoJobStore) Clear() error

func (*DynamoJobStore) Delete

func (d *DynamoJobStore) Delete(jobID string) error

func (*DynamoJobStore) Init

func (d *DynamoJobStore) Init() error

func (*DynamoJobStore) Insert

func (d *DynamoJobStore) Insert(job *models.Job) error

func (*DynamoJobStore) SelectAll

func (d *DynamoJobStore) SelectAll() ([]*models.Job, error)

func (*DynamoJobStore) SelectByID

func (d *DynamoJobStore) SelectByID(jobID string) (*models.Job, error)

func (*DynamoJobStore) SetJobMeta

func (d *DynamoJobStore) SetJobMeta(jobID string, meta map[string]string) error

func (*DynamoJobStore) UpdateJobStatus

func (d *DynamoJobStore) UpdateJobStatus(jobID string, status types.JobStatus) error

type JobStore

type JobStore interface {
	Init() error
	Delete(string) error
	Insert(*models.Job) error
	SelectAll() ([]*models.Job, error)
	SelectByID(string) (*models.Job, error)
	UpdateJobStatus(string, types.JobStatus) error
	SetJobMeta(string, map[string]string) error
}

type MemoryJobStore

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

func NewMemoryJobStore

func NewMemoryJobStore() *MemoryJobStore

func (*MemoryJobStore) Delete

func (m *MemoryJobStore) Delete(jobID string) error

func (*MemoryJobStore) Init

func (m *MemoryJobStore) Init() error

func (*MemoryJobStore) Insert

func (m *MemoryJobStore) Insert(job *models.Job) error

func (*MemoryJobStore) SelectAll

func (m *MemoryJobStore) SelectAll() ([]*models.Job, error)

func (*MemoryJobStore) SelectByID

func (m *MemoryJobStore) SelectByID(jobID string) (*models.Job, error)

func (*MemoryJobStore) SetJobMeta

func (m *MemoryJobStore) SetJobMeta(jobID string, meta map[string]string) error

func (*MemoryJobStore) UpdateJobStatus

func (m *MemoryJobStore) UpdateJobStatus(jobID string, status types.JobStatus) error

Directories

Path Synopsis
Package mock_job_store is a generated GoMock package.
Package mock_job_store is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL