mongo

Documentation

Index

• type Store
  • func New(cfg *mongo.Config, lgr log.Logger) (*Store, error)
  • func (s *Store) EnsureIndexes() error
  • func (s *Store) NewTaskSession() store.TaskSession
• type TaskIterator
  • func (t *TaskIterator) Close() error
  • func (t *TaskIterator) Error() error
  • func (t *TaskIterator) Next(tsk *task.Task) bool
• type TaskSession
  • func (t *TaskSession) CreateTask(ctx context.Context, create *task.TaskCreate) (*task.Task, error)
  • func (t *TaskSession) DeleteTask(ctx context.Context, id string) error
  • func (t *TaskSession) EnsureIndexes() error
  • func (t *TaskSession) GetTask(ctx context.Context, id string) (*task.Task, error)
  • func (t *TaskSession) IteratePending(ctx context.Context) store.TaskIterator
  • func (t *TaskSession) ListTasks(ctx context.Context, filter *task.TaskFilter, pagination *page.Pagination) (task.Tasks, error)
  • func (t *TaskSession) UpdateFromState(ctx context.Context, tsk *task.Task, state string) (*task.Task, error)
  • func (t *TaskSession) UpdateTask(ctx context.Context, id string, update *task.TaskUpdate) (*task.Task, error)

Types

type Store

type Store struct {
	*mongo.Store
}

func New

func New(cfg *mongo.Config, lgr log.Logger) (*Store, error)

func (*Store) EnsureIndexes

func (s *Store) EnsureIndexes() error

func (*Store) NewTaskSession

func (s *Store) NewTaskSession() store.TaskSession

type TaskIterator

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

func (*TaskIterator) Close

func (t *TaskIterator) Close() error

func (*TaskIterator) Error

func (t *TaskIterator) Error() error

func (*TaskIterator) Next

func (t *TaskIterator) Next(tsk *task.Task) bool

type TaskSession

type TaskSession struct {
	*mongo.Session
}

func (*TaskSession) CreateTask

func (t *TaskSession) CreateTask(ctx context.Context, create *task.TaskCreate) (*task.Task, error)

func (*TaskSession) DeleteTask

func (t *TaskSession) DeleteTask(ctx context.Context, id string) error

func (*TaskSession) EnsureIndexes

func (t *TaskSession) EnsureIndexes() error

func (*TaskSession) GetTask

func (t *TaskSession) GetTask(ctx context.Context, id string) (*task.Task, error)

func (*TaskSession) IteratePending

func (t *TaskSession) IteratePending(ctx context.Context) store.TaskIterator

func (*TaskSession) ListTasks

func (t *TaskSession) ListTasks(ctx context.Context, filter *task.TaskFilter, pagination *page.Pagination) (task.Tasks, error)

func (*TaskSession) UpdateFromState

func (t *TaskSession) UpdateFromState(ctx context.Context, tsk *task.Task, state string) (*task.Task, error)

func (*TaskSession) UpdateTask

func (t *TaskSession) UpdateTask(ctx context.Context, id string, update *task.TaskUpdate) (*task.Task, error)