repository

Documentation

Index

• func GetConnection() (*gorm.DB, error)
• type Database
  • func GetDatabase() (Database, error)
  • func GetDatabaseForConnection(connection *gorm.DB) Database
• type GaugeRepository
  • func GetGaugeRepository(db *gorm.DB) GaugeRepository
• type MetricRepository
  • func GetMetricRepository(db *gorm.DB) MetricRepository
• type RiverRepository
  • func GetRiverRepository(db *gorm.DB) RiverRepository

Functions

func GetConnection

func GetConnection() (*gorm.DB, error)

Types

type Database

type Database struct {
	Connection *gorm.DB
	RiverRepo  RiverRepository
	GaugeRepo  GaugeRepository
	MetricRepo MetricRepository
}

func GetDatabase

func GetDatabase() (Database, error)

func GetDatabaseForConnection

func GetDatabaseForConnection(connection *gorm.DB) Database

type GaugeRepository

type GaugeRepository interface {
	GetAll() (*[]model.Gauge, error)
	GetRiverGauges(riverId uuid.UUID) (*[]model.Gauge, error)
	Get(uuid.UUID) (*model.Gauge, error)
	Create(river *model.Gauge) error
	Update(river *model.Gauge) error
	Delete(uuid.UUID) error
}

func GetGaugeRepository

func GetGaugeRepository(db *gorm.DB) GaugeRepository

type MetricRepository

type MetricRepository interface {
	GetAll() (*[]model.Metric, error)
	GetGaugeMetrics(gaugeId uuid.UUID) (*[]model.Metric, error)
	Get(uuid.UUID) (*model.Metric, error)
	Create(Metric *model.Metric) error
	Update(Metric *model.Metric) error
	Delete(uuid.UUID) error
	DeleteOldMetrics() error
}

func GetMetricRepository

func GetMetricRepository(db *gorm.DB) MetricRepository

type RiverRepository

type RiverRepository interface {
	GetAll() (*[]model.River, error)
	Get(uuid.UUID) (*model.River, error)
	Create(river *model.River) error
	Update(river *model.River) error
	Delete(uuid.UUID) error
}

func GetRiverRepository

func GetRiverRepository(db *gorm.DB) RiverRepository