job_store

Documentation

Index

• type DynamoJobStore
  • func NewDynamoJobStore(session *session.Session, table string) *DynamoJobStore
  • func (d *DynamoJobStore) Clear() error
  • func (d *DynamoJobStore) Delete(jobID string) error
  • func (d *DynamoJobStore) Init() error
  • func (d *DynamoJobStore) Insert(job *models.Job) error
  • func (d *DynamoJobStore) SelectAll() ([]*models.Job, error)
  • func (d *DynamoJobStore) SelectByID(jobID string) (*models.Job, error)
  • func (d *DynamoJobStore) SetJobMeta(jobID string, meta map[string]string) error
  • func (d *DynamoJobStore) UpdateJobStatus(jobID string, status types.JobStatus) error
• type JobStore
• type MemoryJobStore
  • func NewMemoryJobStore() *MemoryJobStore
  • func (m *MemoryJobStore) Delete(jobID string) error
  • func (m *MemoryJobStore) Init() error
  • func (m *MemoryJobStore) Insert(job *models.Job) error
  • func (m *MemoryJobStore) SelectAll() ([]*models.Job, error)
  • func (m *MemoryJobStore) SelectByID(jobID string) (*models.Job, error)
  • func (m *MemoryJobStore) SetJobMeta(jobID string, meta map[string]string) error
  • func (m *MemoryJobStore) UpdateJobStatus(jobID string, status types.JobStatus) error

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