postgres

Documentation

Overview

create way for the rest of our app to interact with postgres

Index

• Variables
• type Config
• type Database
  • func NewDatabase(c Config) (*Database, error)
  • func (d *Database) AddDataSet(ctx context.Context, dataSet *model.DataSet) error
  • func (d *Database) Close() error
  • func (d *Database) GetDataSet(ctx context.Context, dataSetKey string) (*model.DataSet, error)

Variables

var (
	ErrNotExists   = fmt.Errorf("the row does not exist")
	ErrMoreThanOne = fmt.Errorf("there is more than one row")
)

Types

type Config

type Config struct {
	Host     string
	Port     uint16
	Database string
	User     string
	Password string
}

type Database

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

func NewDatabase

func NewDatabase(c Config) (*Database, error)

func (*Database) AddDataSet

func (d *Database) AddDataSet(ctx context.Context, dataSet *model.DataSet) error

AddDataSet - adds a dataset

func (*Database) Close

func (d *Database) Close() error

func (*Database) GetDataSet

func (d *Database) GetDataSet(ctx context.Context, dataSetKey string) (*model.DataSet, error)

GetDataSet - gets a dataset