state

Documentation

Index

• type FileStore
  • func NewFileStore(location string) (*FileStore, error)
  • func (f FileStore) CreateTasks(tasks []*datatypes.Task) error
  • func (f FileStore) PendingMapTasks(*datatypes.Job) ([]*datatypes.Task, error)
  • func (f FileStore) PendingReduceTasks(*datatypes.Job) ([]*datatypes.Task, error)
  • func (f FileStore) SaveJob(job *datatypes.Job) error
  • func (f FileStore) SaveTask(task *datatypes.Task) error
  • func (f FileStore) WaitUntilTasksComplete(id string, kind datatypes.TaskKind) error
• type State
  • func New() (State, error)

Types

type FileStore

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

FileStore implementation

func NewFileStore

func NewFileStore(location string) (*FileStore, error)

NewFileStore returns a new file backed state store

func (FileStore) CreateTasks

func (f FileStore) CreateTasks(tasks []*datatypes.Task) error

CreateTasks implementation

func (FileStore) PendingMapTasks

func (f FileStore) PendingMapTasks(*datatypes.Job) ([]*datatypes.Task, error)

PendingMapTasks implementation

func (FileStore) PendingReduceTasks

func (f FileStore) PendingReduceTasks(*datatypes.Job) ([]*datatypes.Task, error)

PendingReduceTasks implementation

func (FileStore) SaveJob

func (f FileStore) SaveJob(job *datatypes.Job) error

SaveJob implementation

func (FileStore) SaveTask

func (f FileStore) SaveTask(task *datatypes.Task) error

SaveTask implementation

func (FileStore) WaitUntilTasksComplete

func (f FileStore) WaitUntilTasksComplete(id string, kind datatypes.TaskKind) error

WaitUntilTasksComplete implementation

type State

type State interface {
	SaveJob(*datatypes.Job) error
	SaveTask(*datatypes.Task) error
	CreateTasks([]*datatypes.Task) error
	WaitUntilTasksComplete(string, datatypes.TaskKind) error
}

State defintion

func New

func New() (State, error)

New returns state