inmemory

Documentation

Index

• Variables
• type Registry
  • func New() *Registry
  • func (r *Registry) Delete(id string) error
  • func (r *Registry) Fetch(id string) (*types.Task, error)
  • func (r *Registry) Register(id string, task *types.Task) error
  • func (r *Registry) Tasks() ([]*types.Task, error)
  • func (r *Registry) Update(id string, t *types.Task) error

Variables

var (
	ErrNotExists = errors.New("task does not exist")
)

Types

type Registry

type Registry struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func New

func New() *Registry

func (*Registry) Delete

func (r *Registry) Delete(id string) error

func (*Registry) Fetch

func (r *Registry) Fetch(id string) (*types.Task, error)

func (*Registry) Register

func (r *Registry) Register(id string, task *types.Task) error

func (*Registry) Tasks

func (r *Registry) Tasks() ([]*types.Task, error)

func (*Registry) Update

func (r *Registry) Update(id string, t *types.Task) error