awsu

Documentation

Index

• type AwsUptime
  • func Fake() (a *AwsUptime)
  • func (a *AwsUptime) Insertable() InsertParams
• type AwsUptimeTracker
• type DBTX
• type InsertParams
• type Queries
  • func New(db DBTX) *Queries
  • func Prepare(ctx context.Context, db DBTX) (*Queries, error)
  • func (q *Queries) Close() error
  • func (q *Queries) Count(ctx context.Context) (int64, error)
  • func (q *Queries) Insert(ctx context.Context, arg InsertParams) (int, error)
  • func (q *Queries) Oldest(ctx context.Context) (string, error)
  • func (q *Queries) Track(ctx context.Context, runDate string) error
  • func (q *Queries) WithTx(tx *sql.Tx) *Queries
  • func (q *Queries) Youngest(ctx context.Context) (string, error)

Types

type AwsUptime

type AwsUptime struct {
	ID      int     `json:"id"`
	Ts      string  `json:"ts"`
	Unit    string  `json:"unit"`
	Average float64 `json:"average"`
	Date    string  `json:"date"`
}

func Fake

func Fake() (a *AwsUptime)

func (*AwsUptime) Insertable

func (a *AwsUptime) Insertable() InsertParams

type AwsUptimeTracker

type AwsUptimeTracker struct {
	ID      int    `json:"id"`
	RunDate string `json:"run_date"`
}

type DBTX

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type InsertParams

type InsertParams struct {
	Ts      string  `json:"ts"`
	Unit    string  `json:"unit"`
	Date    string  `json:"date"`
	Average float64 `json:"average"`
}

type Queries

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

func New

func New(db DBTX) *Queries

func Prepare

func Prepare(ctx context.Context, db DBTX) (*Queries, error)

func (*Queries) Close

func (q *Queries) Close() error

func (*Queries) Count

func (q *Queries) Count(ctx context.Context) (int64, error)

func (*Queries) Insert

func (q *Queries) Insert(ctx context.Context, arg InsertParams) (int, error)

func (*Queries) Oldest

func (q *Queries) Oldest(ctx context.Context) (string, error)

func (*Queries) Track

func (q *Queries) Track(ctx context.Context, runDate string) error

func (*Queries) WithTx

func (q *Queries) WithTx(tx *sql.Tx) *Queries

func (*Queries) Youngest

func (q *Queries) Youngest(ctx context.Context) (string, error)