meteringDB

Documentation

Index

• type DBInfo
• type MeteringDB
• type MeteringPg
  • func NewMeteringPg(sqlxdb *sqlx.DB, tn string) MeteringPg
  • func (mpg MeteringPg) Close()
  • func (mpg MeteringPg) Insert(ms metering.Statement) (mid int, err error)
  • func (mpg MeteringPg) Query(projectID int, mType int, typeInfo string) (ms metering.Statement, err error)
  • func (mpg MeteringPg) QueryAll(projectID int, mType int) (mss []metering.Statement, err error)
• type MeteringReadOnlyDB

Types

type DBInfo

type DBInfo struct {
	TheDB     *sqlx.DB
	TableName string
}

type MeteringDB

type MeteringDB interface {
	MeteringReadOnlyDB

	Insert(ms metering.Statement) (mid int, err error)
}

type MeteringPg

type MeteringPg struct {
	DBInfo
}

func NewMeteringPg

func NewMeteringPg(sqlxdb *sqlx.DB, tn string) MeteringPg

func (MeteringPg) Close

func (mpg MeteringPg) Close()

func (MeteringPg) Insert

func (mpg MeteringPg) Insert(ms metering.Statement) (mid int, err error)

func (MeteringPg) Query

func (mpg MeteringPg) Query(projectID int, mType int, typeInfo string) (ms metering.Statement, err error)

func (MeteringPg) QueryAll

func (mpg MeteringPg) QueryAll(projectID int, mType int) (mss []metering.Statement, err error)

type MeteringReadOnlyDB

type MeteringReadOnlyDB interface {
	Query(projectID int, mType int, typeInfo string) (ms metering.Statement, err error)
	QueryAll(projectID int, mType int) (mss []metering.Statement, err error)
	Close()
}