infra

Documentation

Index

• Variables
• func CloseDatabase()
• func GetDatabase() *pgx.Pool
• func InitDatabase(connectionString string, log *zap.Logger) error
• type GroupingDatasource
  • func (g *GroupingDatasource) AddGroup(id string, value string) error
  • func (g *GroupingDatasource) GetGroup(id string) (*PersistedGroup, error)
• type PersistedGroup

Variables

var ConnectionPool *pgx.Pool

Functions

func CloseDatabase

func CloseDatabase()

func GetDatabase

func GetDatabase() *pgx.Pool

func InitDatabase

func InitDatabase(connectionString string, log *zap.Logger) error

Types

type GroupingDatasource

type GroupingDatasource struct {
	DB *pgx.Pool
}

func (*GroupingDatasource) AddGroup

func (g *GroupingDatasource) AddGroup(id string, value string) error

func (*GroupingDatasource) GetGroup

func (g *GroupingDatasource) GetGroup(id string) (*PersistedGroup, error)

type PersistedGroup

type PersistedGroup struct {
	Id    string
	Value string
}