repository

Documentation

Index

• func NewAreaFromHistory(events []storage.AreaEvent) *domain.Area
• func NewFarmFromHistory(events []storage.FarmEvent) *domain.Farm
• func NewMaterialFromHistory(events []storage.MaterialEvent) *domain.Material
• func NewReservoirFromHistory(events []storage.ReservoirEvent) *domain.Reservoir
• type AreaEventRepository
• type AreaReadRepository
• type FarmEventRepository
• type FarmReadRepository
• type MaterialEventRepository
• type MaterialEventTypeWrapper
  • func (w MaterialEventTypeWrapper) Code() string
• type MaterialReadRepository
• type RepositoryResult
• type ReservoirEventRepository
• type ReservoirReadRepository

Functions

func NewAreaFromHistory

func NewAreaFromHistory(events []storage.AreaEvent) *domain.Area

func NewFarmFromHistory

func NewFarmFromHistory(events []storage.FarmEvent) *domain.Farm

func NewMaterialFromHistory

func NewMaterialFromHistory(events []storage.MaterialEvent) *domain.Material

func NewReservoirFromHistory

func NewReservoirFromHistory(events []storage.ReservoirEvent) *domain.Reservoir

Types

type AreaEventRepository

type AreaEventRepository interface {
	Save(uid uuid.UUID, latestVersion int, events []interface{}) <-chan error
}

type AreaReadRepository

type AreaReadRepository interface {
	Save(areaRead *storage.AreaRead) <-chan error
}

type FarmEventRepository

type FarmEventRepository interface {
	Save(uid uuid.UUID, latestVersion int, events []interface{}) <-chan error
}

type FarmReadRepository

type FarmReadRepository interface {
	Save(farmRead *storage.FarmRead) <-chan error
}

type MaterialEventRepository

type MaterialEventRepository interface {
	Save(uid uuid.UUID, latestVersion int, events []interface{}) <-chan error
}

type MaterialEventTypeWrapper

type MaterialEventTypeWrapper struct {
	Type string
	Data interface{}
}

func (MaterialEventTypeWrapper) Code

func (w MaterialEventTypeWrapper) Code() string

type MaterialReadRepository

type MaterialReadRepository interface {
	Save(materialRead *storage.MaterialRead) <-chan error
}

type RepositoryResult

type RepositoryResult struct {
	Result interface{}
	Error  error
}

RepositoryResult is a struct to wrap repository result so its easy to use it in channel

type ReservoirEventRepository

type ReservoirEventRepository interface {
	Save(uid uuid.UUID, latestVersion int, events []interface{}) <-chan error
}

type ReservoirReadRepository

type ReservoirReadRepository interface {
	Save(reservoirRead *storage.ReservoirRead) <-chan error
}