repository

Documentation

Index

• Variables
• type Config
• type Connector
• type Database
• type Repo
• type Repository
  • func NewRepository(ctx context.Context, cfg *Config) *Repository
  • func (r *Repository) Close()
  • func (r *Repository) Connect(address, login, pass string, port uint) (err error)
  • func (r *Repository) InsertLog(dtime time.Time, optype string, data json.RawMessage) error
  • func (r *Repository) InsertReceipt(dtime time.Time, optype string, data json.RawMessage) error

Variables

var DefaultConfig = Config{
	Login:    "postgres",
	Password: "",
	Address:  "localhost",
	Port:     5432,
}

Types

type Config

type Config struct {
	Login    string `yaml:"login"`
	Password string `yaml:"password"`
	Address  string `yaml:"address"`
	Port     uint   `yaml:"port"`
}

type Connector

type Connector interface {
	Connect(address, login, pass string, port uint) (err error)
	Close()
}

type Database

type Database interface {
	InsertLog(dtime time.Time, optype string, data json.RawMessage) (err error)
	InsertReceipt(dtime time.Time, optype string, data json.RawMessage) (err error)
}

type Repo

type Repo interface {
	Connector
	Database
}

type Repository

type Repository struct {
	// contains filtered or unexported fields
}

func NewRepository

func NewRepository(ctx context.Context, cfg *Config) *Repository

func (*Repository) Close

func (r *Repository) Close()

func (*Repository) Connect

func (r *Repository) Connect(address, login, pass string, port uint) (err error)

func (*Repository) InsertLog

func (r *Repository) InsertLog(dtime time.Time, optype string, data json.RawMessage) error

func (*Repository) InsertReceipt

func (r *Repository) InsertReceipt(dtime time.Time, optype string, data json.RawMessage) error