storage

Documentation

Index

• type Configuration
• type Storage
  • func NewStorage(configuration Configuration) (Storage, error)

Types

type Configuration

type Configuration struct {
	Host     string
	Port     int
	User     string
	Password string
	Database string
	InMemory bool
	Log      *logrus.Entry
}

type Storage

type Storage interface {
	GetAllPumps(ctx context.Context) ([]models.Pump, error)
	GetLastPumpState(ctx context.Context, pumpId int) (pio.State, error)
	PersistPumpState(ctx context.Context, pumpId int, state pio.State, timestamp time.Time) error
	GetCyclesToNotify(ctx context.Context) ([]models.Cycle, error)
	SetCyclesNotified(ctx context.Context, cycleIds []int) error

	Close() error
}

func NewStorage

func NewStorage(configuration Configuration) (Storage, error)