storage

package
v1.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 8, 2022 License: MIT Imports: 16 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ImplementationTest

func ImplementationTest(t *testing.T, storage task.Storage)

func NewMemory

func NewMemory() task.Storage

func NewMongo

func NewMongo(cfg StorageMongoConfig) (task.Storage, error)

Types

type StorageMock

type StorageMock struct {
	First   chan task.Task
	Created chan task.Task
	Updated chan task.Task
}

func NewMock

func NewMock() *StorageMock

func (*StorageMock) Close

func (m *StorageMock) Close() error

func (*StorageMock) Create

func (m *StorageMock) Create(t task.Task) error

func (*StorageMock) FillFirst

func (m *StorageMock) FillFirst(tasks []task.Task)

func (*StorageMock) FirstToExecute

func (m *StorageMock) FirstToExecute() (*task.Task, error)

func (*StorageMock) Update

func (m *StorageMock) Update(t task.Task) error

func (*StorageMock) Watch

func (m *StorageMock) Watch() (task.Notificator, error)

type StorageMongoConfig

type StorageMongoConfig struct {
	ConnectURL string // mongodb connect url
	DBName     string // used db, default: task
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL