repository

Documentation

Overview

Package repository implements domain services with repository.

Index

• type Task
  • func (tr *Task) Cancel(ctx context.Context, identity task.Identity) error
  • func (tr *Task) Create(ctx context.Context, value task.Value) (task.Entity, error)
  • func (tr *Task) Find(ctx context.Context) []task.Entity
  • func (tr *Task) FindByID(ctx context.Context, identity task.Identity) (task.Entity, error)
  • func (tr *Task) Finish(ctx context.Context, identity task.Identity) error
  • func (tr *Task) FinishExpired(_ context.Context) error
  • func (tr *Task) TaskCreator() task.Creator
  • func (tr *Task) TaskFinder() task.Finder
  • func (tr *Task) TaskFinisher() task.Finisher
  • func (tr *Task) TaskUpdater() task.Updater
  • func (tr *Task) Update(_ context.Context, identity task.Identity, value task.Value) error

Types

type Task

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

Task is an in-memory task repository.

func (*Task) Cancel

func (tr *Task) Cancel(ctx context.Context, identity task.Identity) error

Cancel closes task as canceled.

func (*Task) Create

func (tr *Task) Create(ctx context.Context, value task.Value) (task.Entity, error)

Create creates a new task.

func (*Task) Find

func (tr *Task) Find(ctx context.Context) []task.Entity

Find finds all tasks.

func (*Task) FindByID

func (tr *Task) FindByID(ctx context.Context, identity task.Identity) (task.Entity, error)

FindByID finds task by identity.

func (*Task) Finish

func (tr *Task) Finish(ctx context.Context, identity task.Identity) error

Finish closes task as done.

func (*Task) FinishExpired

func (tr *Task) FinishExpired(_ context.Context) error

FinishExpired closes expired tasks.

func (*Task) TaskCreator

func (tr *Task) TaskCreator() task.Creator

TaskCreator is a service provider.

func (*Task) TaskFinder

func (tr *Task) TaskFinder() task.Finder

TaskFinder is a service provider.

func (*Task) TaskFinisher

func (tr *Task) TaskFinisher() task.Finisher

TaskFinisher is a service provider.

func (*Task) TaskUpdater

func (tr *Task) TaskUpdater() task.Updater

TaskUpdater is a service provider.

func (*Task) Update

func (tr *Task) Update(_ context.Context, identity task.Identity, value task.Value) error

Update updates task value by identity.