mysql

Documentation

Index

• func NewAreaEventRepositoryMysql(db *sql.DB) repository.AreaEvent
• func NewAreaReadRepositoryMysql(db *sql.DB) repository.AreaRead
• func NewFarmEventRepositoryMysql(db *sql.DB) repository.FarmEvent
• func NewFarmReadRepositoryMysql(db *sql.DB) repository.FarmRead
• func NewMaterialEventRepositoryMysql(db *sql.DB) repository.MaterialEvent
• func NewMaterialReadRepositoryMysql(db *sql.DB) repository.MaterialRead
• func NewReservoirEventRepositoryMysql(db *sql.DB) repository.ReservoirEvent
• func NewReservoirReadRepositoryMysql(db *sql.DB) repository.ReservoirRead
• type AreaEventRepositoryMysql
  • func (f *AreaEventRepositoryMysql) Save(uid uuid.UUID, latestVersion int, events []interface{}) <-chan error
• type AreaReadRepositoryMysql
  • func (f *AreaReadRepositoryMysql) Save(areaRead *storage.AreaRead) <-chan error
• type FarmEventRepositoryMysql
  • func (f *FarmEventRepositoryMysql) Save(uid uuid.UUID, latestVersion int, events []interface{}) <-chan error
• type FarmReadRepositoryMysql
  • func (f *FarmReadRepositoryMysql) Save(farmRead *storage.FarmRead) <-chan error
• type MaterialEventRepositoryMysql
  • func (f *MaterialEventRepositoryMysql) Save(uid uuid.UUID, latestVersion int, events []interface{}) <-chan error
• type MaterialReadRepositoryMysql
  • func (f *MaterialReadRepositoryMysql) Save(materialRead *storage.MaterialRead) <-chan error
• type ReservoirEventRepositoryMysql
  • func (f *ReservoirEventRepositoryMysql) Save(uid uuid.UUID, latestVersion int, events []interface{}) <-chan error
• type ReservoirReadRepositoryMysql
  • func (f *ReservoirReadRepositoryMysql) Save(reservoirRead *storage.ReservoirRead) <-chan error

Functions

func NewAreaEventRepositoryMysql

func NewAreaEventRepositoryMysql(db *sql.DB) repository.AreaEvent

func NewAreaReadRepositoryMysql

func NewAreaReadRepositoryMysql(db *sql.DB) repository.AreaRead

func NewFarmEventRepositoryMysql

func NewFarmEventRepositoryMysql(db *sql.DB) repository.FarmEvent

func NewFarmReadRepositoryMysql

func NewFarmReadRepositoryMysql(db *sql.DB) repository.FarmRead

func NewMaterialEventRepositoryMysql

func NewMaterialEventRepositoryMysql(db *sql.DB) repository.MaterialEvent

func NewMaterialReadRepositoryMysql

func NewMaterialReadRepositoryMysql(db *sql.DB) repository.MaterialRead

func NewReservoirEventRepositoryMysql

func NewReservoirEventRepositoryMysql(db *sql.DB) repository.ReservoirEvent

func NewReservoirReadRepositoryMysql

func NewReservoirReadRepositoryMysql(db *sql.DB) repository.ReservoirRead

Types

type AreaEventRepositoryMysql

type AreaEventRepositoryMysql struct {
	DB *sql.DB
}

func (*AreaEventRepositoryMysql) Save

func (f *AreaEventRepositoryMysql) Save(uid uuid.UUID, latestVersion int, events []interface{}) <-chan error

type AreaReadRepositoryMysql

type AreaReadRepositoryMysql struct {
	DB *sql.DB
}

func (*AreaReadRepositoryMysql) Save

func (f *AreaReadRepositoryMysql) Save(areaRead *storage.AreaRead) <-chan error

type FarmEventRepositoryMysql

type FarmEventRepositoryMysql struct {
	DB *sql.DB
}

func (*FarmEventRepositoryMysql) Save

func (f *FarmEventRepositoryMysql) Save(uid uuid.UUID, latestVersion int, events []interface{}) <-chan error

type FarmReadRepositoryMysql

type FarmReadRepositoryMysql struct {
	DB *sql.DB
}

func (*FarmReadRepositoryMysql) Save

func (f *FarmReadRepositoryMysql) Save(farmRead *storage.FarmRead) <-chan error

type MaterialEventRepositoryMysql

type MaterialEventRepositoryMysql struct {
	DB *sql.DB
}

func (*MaterialEventRepositoryMysql) Save

func (f *MaterialEventRepositoryMysql) Save(uid uuid.UUID, latestVersion int, events []interface{}) <-chan error

type MaterialReadRepositoryMysql

type MaterialReadRepositoryMysql struct {
	DB *sql.DB
}

func (*MaterialReadRepositoryMysql) Save

func (f *MaterialReadRepositoryMysql) Save(materialRead *storage.MaterialRead) <-chan error

type ReservoirEventRepositoryMysql

type ReservoirEventRepositoryMysql struct {
	DB *sql.DB
}

func (*ReservoirEventRepositoryMysql) Save

func (f *ReservoirEventRepositoryMysql) Save(uid uuid.UUID, latestVersion int, events []interface{}) <-chan error

type ReservoirReadRepositoryMysql

type ReservoirReadRepositoryMysql struct {
	DB *sql.DB
}

func (*ReservoirReadRepositoryMysql) Save

func (f *ReservoirReadRepositoryMysql) Save(reservoirRead *storage.ReservoirRead) <-chan error