databases

Documentation

Index

• type IntTaskID
  • func (s *IntTaskID) String() string
• type MemTask
  • func (t *MemTask) SpecData() []byte
  • func (t *MemTask) String() string
• type MemTaskDB
  • func NewMemTaskDB() *MemTaskDB
  • func (db *MemTaskDB) Cancel(id models.TaskID) error
  • func (db *MemTaskDB) Consume(fn models.TaskConsumer) error
  • func (db *MemTaskDB) Create(task models.Task) (models.TaskID, error)
  • func (db *MemTaskDB) Delete(id models.TaskID) error
  • func (db *MemTaskDB) Inspect(id models.TaskID) (models.TaskDetail, error)
  • func (db *MemTaskDB) List() ([]models.TaskDetail, error)
  • func (db *MemTaskDB) Wait(id models.TaskID, ctx context.Context) error
• type MemTaskDetail
  • func (d *MemTaskDetail) Result() models.TaskResult
  • func (d *MemTaskDetail) State() string
  • func (d *MemTaskDetail) String() string
  • func (d *MemTaskDetail) TaskID() models.TaskID
• type MemTaskResult
  • func (r *MemTaskResult) AfterResult() models.ScriptResult
  • func (r *MemTaskResult) BeforeResult() models.ScriptResult
  • func (r *MemTaskResult) Error() error
  • func (r *MemTaskResult) ScriptResult() models.ScriptResult
  • func (r *MemTaskResult) String() string
• type StringTaskID
  • func (s *StringTaskID) String() string

Types

type IntTaskID

type IntTaskID struct {
	ID int
}

func (*IntTaskID) String

func (s *IntTaskID) String() string

type MemTask

type MemTask struct {
	Spec []byte
}

func (*MemTask) SpecData

func (t *MemTask) SpecData() []byte

func (*MemTask) String

func (t *MemTask) String() string

type MemTaskDB

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

func NewMemTaskDB

func NewMemTaskDB() *MemTaskDB

func (*MemTaskDB) Cancel

func (db *MemTaskDB) Cancel(id models.TaskID) error

func (*MemTaskDB) Consume

func (db *MemTaskDB) Consume(fn models.TaskConsumer) error

func (*MemTaskDB) Create

func (db *MemTaskDB) Create(task models.Task) (models.TaskID, error)

func (*MemTaskDB) Delete

func (db *MemTaskDB) Delete(id models.TaskID) error

func (*MemTaskDB) Inspect

func (db *MemTaskDB) Inspect(id models.TaskID) (models.TaskDetail, error)

func (*MemTaskDB) List

func (db *MemTaskDB) List() ([]models.TaskDetail, error)

func (*MemTaskDB) Wait

func (db *MemTaskDB) Wait(id models.TaskID, ctx context.Context) error

type MemTaskDetail

type MemTaskDetail struct {
	ID models.TaskID
	DB *MemTaskDB
}

func (*MemTaskDetail) Result

func (d *MemTaskDetail) Result() models.TaskResult

func (*MemTaskDetail) State

func (d *MemTaskDetail) State() string

func (*MemTaskDetail) String

func (d *MemTaskDetail) String() string

func (*MemTaskDetail) TaskID

func (d *MemTaskDetail) TaskID() models.TaskID

type MemTaskResult

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

func (*MemTaskResult) AfterResult

func (r *MemTaskResult) AfterResult() models.ScriptResult

func (*MemTaskResult) BeforeResult

func (r *MemTaskResult) BeforeResult() models.ScriptResult

func (*MemTaskResult) Error

func (r *MemTaskResult) Error() error

func (*MemTaskResult) ScriptResult

func (r *MemTaskResult) ScriptResult() models.ScriptResult

func (*MemTaskResult) String

func (r *MemTaskResult) String() string

type StringTaskID

type StringTaskID struct {
	ID string
}

func (*StringTaskID) String

func (s *StringTaskID) String() string