Versions in this module Expand all Collapse all v0 v0.12.0 Mar 29, 2021 v0.11.0 Jun 1, 2020 Changes in this version + var ErrDeleteChannel = errors.New("delete channel from db error") + var ErrDeleteConnection = errors.New("unmarshal json error") + var ErrDeleteDb = errors.New("delete thing from db error") + var ErrHasThing = errors.New("check thing-channel connection in database error") + var ErrMarshalThing = errors.New("marshal to json error") + var ErrSaveChannel = errors.New("save channel to db error") + var ErrSaveDb = errors.New("save thing to db error") + var ErrScan = errors.New("database scanner error") + var ErrSelectChannel = errors.New("select channel from db error") + var ErrSelectDb = errors.New("select thing from db error") + var ErrUnmarshalThing = errors.New("unmarshal json error") + var ErrUpdateChannel = errors.New("update channel to db error") + var ErrUpdateDb = errors.New("update thing in db error") + var ErrValue = errors.New("database valuer error") + func Connect(cfg Config) (*sqlx.DB, error) + func NewChannelRepository(db Database) things.ChannelRepository + func NewThingRepository(db Database) things.ThingRepository + type Config struct + Host string + Name string + Pass string + Port string + SSLCert string + SSLKey string + SSLMode string + SSLRootCert string + User string + type Database interface + BeginTxx func(context.Context, *sql.TxOptions) (*sqlx.Tx, error) + GetContext func(context.Context, interface{}, string, ...interface{}) error + NamedExecContext func(context.Context, string, interface{}) (sql.Result, error) + NamedQueryContext func(context.Context, string, interface{}) (*sqlx.Rows, error) + QueryRowxContext func(context.Context, string, ...interface{}) *sqlx.Row + func NewDatabase(db *sqlx.DB) Database