data

Documentation

Index

• Variables
• type Data
  • func New(configPath string) *Data
  • func (d *Data) Close() error
  • func (d *Data) Delete(key string) error
  • func (d *Data) DeleteKeys(keys ...string) error
  • func (d *Data) Exec(sql string, args ...interface{}) (sql.Result, error)
  • func (d *Data) Get(key string) ([]byte, error)
  • func (d *Data) NewSessionStore() *session.Store
  • func (d *Data) Prepare(sql string) *sql.Stmt
  • func (d *Data) Reset() error
  • func (d *Data) Select(sql string, args ...interface{}) (*sql.Rows, error)
  • func (d *Data) SelectRow(sql string, args ...interface{}) *sql.Row
  • func (d *Data) Set(key string, value []byte, expiration time.Duration) error
• type Prepare
• type PrepareCallback
• type PrepareQueue
  • func NewPrepareQueue() *PrepareQueue
  • func (p *PrepareQueue) Add(stmt **sql.Stmt, q string)

Variables

var PrepareQueuer = NewPrepareQueue()

PrepareQueuer global to allow queuing

Types

type Data

type Data struct {
	Config *config.Config
	// contains filtered or unexported fields
}

Data struct

func New

func New(configPath string) *Data

New initializes and returns Data struct

Also inits klog

func (*Data) Close

func (d *Data) Close() error

Close redis store

func (*Data) Delete

func (d *Data) Delete(key string) error

Delete deletes a key from redis store

func (*Data) DeleteKeys

func (d *Data) DeleteKeys(keys ...string) error

Delete deletes keys from redis store

func (*Data) Exec

func (d *Data) Exec(sql string, args ...interface{}) (sql.Result, error)

Exec is a Exec wrapper

func (*Data) Get

func (d *Data) Get(key string) ([]byte, error)

Get retrieves values from redis store Default returns nil, nil

func (*Data) NewSessionStore

func (d *Data) NewSessionStore() *session.Store

NewSessionStore initializes the Session handler

func (*Data) Prepare

func (d *Data) Prepare(sql string) *sql.Stmt

Prepare prepares a query and returns the stmt Logs own errors

func (*Data) Reset

func (d *Data) Reset() error

Reset redis store

func (*Data) Select

func (d *Data) Select(sql string, args ...interface{}) (*sql.Rows, error)

Select is a query wrapper

func (*Data) SelectRow

func (d *Data) SelectRow(sql string, args ...interface{}) *sql.Row

SelectRow is a queryRow wrapper

func (*Data) Set

func (d *Data) Set(key string, value []byte, expiration time.Duration) error

Set stores values in redis store

type Prepare

type Prepare = func(sql string) *sql.Stmt

Prepare defines a function to prepare a sql statement

type PrepareCallback

type PrepareCallback = func(Prepare)

type PrepareQueue

type PrepareQueue struct {
	Prepared bool
	// contains filtered or unexported fields
}

PrepareQueue adds easy tools to queue sql for prepare in the init() function or any time Before the database is ready

func NewPrepareQueue

func NewPrepareQueue() *PrepareQueue

NewPrepareQueue

func (*PrepareQueue) Add

func (p *PrepareQueue) Add(stmt **sql.Stmt, q string)

Add stmt pointer and query to queue

Must not be called after prepareAll