inmemory

Documentation

Index

• func NewAreaQueryInMemory(s *storage.AreaReadStorage) query.AreaQuery
• func NewCropQueryInMemory(s *storage.CropReadStorage) query.CropQuery
• func NewMaterialQueryInMemory(s *assetsstorage.MaterialReadStorage) query.MaterialQuery
• func NewReservoirQueryInMemory(s *storage.ReservoirReadStorage) query.ReservoirQuery
• func NewTaskEventQueryInMemory(s *storage.TaskEventStorage) query.TaskEventQuery
• func NewTaskReadQueryInMemory(s *storage.TaskReadStorage) query.TaskReadQuery
• type AreaQueryInMemory
  • func (s AreaQueryInMemory) FindByID(uid uuid.UUID) <-chan query.QueryResult
• type CropQueryInMemory
  • func (s CropQueryInMemory) FindCropByID(uid uuid.UUID) <-chan query.QueryResult
• type MaterialQueryInMemory
  • func (s MaterialQueryInMemory) FindMaterialByID(inventoryUID uuid.UUID) <-chan query.QueryResult
• type ReservoirQueryInMemory
  • func (s ReservoirQueryInMemory) FindReservoirByID(reservoirUID uuid.UUID) <-chan query.QueryResult
• type TaskEventQueryInMemory
  • func (f *TaskEventQueryInMemory) FindAllByTaskID(uid uuid.UUID) <-chan query.QueryResult
• type TaskReadQueryInMemory
  • func (q TaskReadQueryInMemory) CountAll() <-chan query.QueryResult
  • func (s TaskReadQueryInMemory) CountTasksWithFilter(params map[string]string) <-chan query.QueryResult
  • func (r TaskReadQueryInMemory) FindAll(page, limit int) <-chan query.QueryResult
  • func (r TaskReadQueryInMemory) FindByID(uid uuid.UUID) <-chan query.QueryResult
  • func (s TaskReadQueryInMemory) FindTasksWithFilter(params map[string]string, page, limit int) <-chan query.QueryResult

Functions

func NewAreaQueryInMemory

func NewAreaQueryInMemory(s *storage.AreaReadStorage) query.AreaQuery

func NewCropQueryInMemory

func NewCropQueryInMemory(s *storage.CropReadStorage) query.CropQuery

func NewMaterialQueryInMemory

func NewMaterialQueryInMemory(s *assetsstorage.MaterialReadStorage) query.MaterialQuery

func NewReservoirQueryInMemory

func NewReservoirQueryInMemory(s *storage.ReservoirReadStorage) query.ReservoirQuery

func NewTaskEventQueryInMemory

func NewTaskEventQueryInMemory(s *storage.TaskEventStorage) query.TaskEventQuery

func NewTaskReadQueryInMemory

func NewTaskReadQueryInMemory(s *storage.TaskReadStorage) query.TaskReadQuery

Types

type AreaQueryInMemory

type AreaQueryInMemory struct {
	Storage *storage.AreaReadStorage
}

func (AreaQueryInMemory) FindByID

func (s AreaQueryInMemory) FindByID(uid uuid.UUID) <-chan query.QueryResult

type CropQueryInMemory

type CropQueryInMemory struct {
	Storage *storage.CropReadStorage
}

func (CropQueryInMemory) FindCropByID

func (s CropQueryInMemory) FindCropByID(uid uuid.UUID) <-chan query.QueryResult

type MaterialQueryInMemory

type MaterialQueryInMemory struct {
	Storage *assetsstorage.MaterialReadStorage
}

func (MaterialQueryInMemory) FindMaterialByID

func (s MaterialQueryInMemory) FindMaterialByID(inventoryUID uuid.UUID) <-chan query.QueryResult

type ReservoirQueryInMemory

type ReservoirQueryInMemory struct {
	Storage *storage.ReservoirReadStorage
}

func (ReservoirQueryInMemory) FindReservoirByID

func (s ReservoirQueryInMemory) FindReservoirByID(reservoirUID uuid.UUID) <-chan query.QueryResult

type TaskEventQueryInMemory

type TaskEventQueryInMemory struct {
	Storage *storage.TaskEventStorage
}

func (*TaskEventQueryInMemory) FindAllByTaskID

func (f *TaskEventQueryInMemory) FindAllByTaskID(uid uuid.UUID) <-chan query.QueryResult

type TaskReadQueryInMemory

type TaskReadQueryInMemory struct {
	Storage *storage.TaskReadStorage
}

func (TaskReadQueryInMemory) CountAll

func (q TaskReadQueryInMemory) CountAll() <-chan query.QueryResult

func (TaskReadQueryInMemory) CountTasksWithFilter

func (s TaskReadQueryInMemory) CountTasksWithFilter(params map[string]string) <-chan query.QueryResult

func (TaskReadQueryInMemory) FindAll

func (r TaskReadQueryInMemory) FindAll(page, limit int) <-chan query.QueryResult

func (TaskReadQueryInMemory) FindByID

func (r TaskReadQueryInMemory) FindByID(uid uuid.UUID) <-chan query.QueryResult

FindByID is to find by ID

func (TaskReadQueryInMemory) FindTasksWithFilter

func (s TaskReadQueryInMemory) FindTasksWithFilter(params map[string]string, page, limit int) <-chan query.QueryResult