pg

Jan 16, 2017

Changes in this version

type Options

+ func ParseURL(sURL string) (*Options, error)

Jan 3, 2017

Changes in this version

type Options

+ MaxAge time.Duration

Nov 19, 2016

Changes in this version

type DB

+ func (db *DB) String() string

Nov 9, 2016

Changes in this version

type DB

+ func (db *DB) WithParam(param string, value interface{}) *DB

Oct 26, 2016

Changes in this version

type Listener

+ func (ln *Listener) Channel() <-chan *Notification

+ type Notification struct

+ Channel string

+ Payload string

Oct 18, 2016

Changes in this version

+ var Discard orm.Discard

+ var ErrMultiRows = internal.ErrMultiRows

+ var ErrNoRows = internal.ErrNoRows

+ func Array(v interface{}) *types.Array

+ func F(field string) types.ValueAppender

+ func Hstore(v interface{}) *types.Hstore

+ func In(slice interface{}) types.ValueAppender

+ func Model(model ...interface{}) *orm.Query

+ func Q(query string, params ...interface{}) orm.FormatAppender

+ func Scan(values ...interface{}) orm.ColumnScanner

+ func SetLogger(logger *log.Logger)

+ func SetQueryLogger(logger *log.Logger)

+ type DB struct

+ func Connect(opt *Options) *DB

+ func (db *DB) Begin() (*Tx, error)

+ func (db *DB) Close() error

+ func (db *DB) CopyFrom(reader io.Reader, query interface{}, params ...interface{}) (*types.Result, error)

+ func (db *DB) CopyTo(writer io.Writer, query interface{}, params ...interface{}) (*types.Result, error)

+ func (db *DB) CreateTable(model interface{}, opt *orm.CreateTableOptions) error

+ func (db *DB) Delete(model interface{}) error

+ func (db *DB) Exec(query interface{}, params ...interface{}) (res *types.Result, err error)

+ func (db *DB) ExecOne(query interface{}, params ...interface{}) (*types.Result, error)

+ func (db *DB) FormatQuery(dst []byte, query string, params ...interface{}) []byte

+ func (db *DB) Insert(model ...interface{}) error

+ func (db *DB) Listen(channels ...string) (*Listener, error)

+ func (db *DB) Model(model ...interface{}) *orm.Query

+ func (db *DB) Options() *Options

+ func (db *DB) Prepare(q string) (*Stmt, error)

+ func (db *DB) Query(model, query interface{}, params ...interface{}) (res *types.Result, err error)

+ func (db *DB) QueryOne(model, query interface{}, params ...interface{}) (*types.Result, error)

+ func (db *DB) RunInTransaction(fn func(*Tx) error) error

+ func (db *DB) Select(model interface{}) error

+ func (db *DB) Update(model interface{}) error

+ func (db *DB) WithTimeout(d time.Duration) *DB

+ type Error interface

+ Field func(byte) string

+ IntegrityViolation func() bool

+ type IntSet map[int64]struct

+ func (IntSet) AddModel(_ orm.ColumnScanner) error

+ func (IntSet) AfterDelete(_ orm.DB) error

+ func (IntSet) AfterInsert(_ orm.DB) error

+ func (IntSet) AfterQuery(_ orm.DB) error

+ func (IntSet) AfterSelect(_ orm.DB) error

+ func (IntSet) AfterUpdate(_ orm.DB) error

+ func (IntSet) BeforeDelete(_ orm.DB) error

+ func (IntSet) BeforeInsert(_ orm.DB) error

+ func (IntSet) BeforeUpdate(_ orm.DB) error

+ func (set *IntSet) NewModel() orm.ColumnScanner

+ func (set *IntSet) Reset() error

+ func (setptr *IntSet) ScanColumn(colIdx int, colName string, b []byte) error

+ type Ints []int64

+ func (Ints) AddModel(_ orm.ColumnScanner) error

+ func (Ints) AfterDelete(_ orm.DB) error

+ func (Ints) AfterInsert(_ orm.DB) error

+ func (Ints) AfterQuery(_ orm.DB) error

+ func (Ints) AfterSelect(_ orm.DB) error

+ func (Ints) AfterUpdate(_ orm.DB) error

+ func (Ints) BeforeDelete(_ orm.DB) error

+ func (Ints) BeforeInsert(_ orm.DB) error

+ func (Ints) BeforeUpdate(_ orm.DB) error

+ func (ints *Ints) NewModel() orm.ColumnScanner

+ func (ints *Ints) Reset() error

+ func (ints *Ints) ScanColumn(colIdx int, colName string, b []byte) error

+ func (ints Ints) AppendValue(dst []byte, quote int) ([]byte, error)

+ type Listener struct

+ func (l *Listener) Close() error

+ func (l *Listener) Listen(channels ...string) error

+ func (l *Listener) Receive() (channel string, payload string, err error)

+ func (l *Listener) ReceiveTimeout(readTimeout time.Duration) (channel, payload string, err error)

+ type NullTime struct

+ func (tm *NullTime) Scan(b interface{}) error

+ func (tm *NullTime) UnmarshalJSON(b []byte) error

+ func (tm NullTime) AppendValue(b []byte, quote int) ([]byte, error)

+ func (tm NullTime) MarshalJSON() ([]byte, error)

+ type Options struct

+ Addr string

+ Database string

+ DialTimeout time.Duration

+ Dialer func(network, addr string) (net.Conn, error)

+ DisableTransaction bool

+ IdleCheckFrequency time.Duration

+ IdleTimeout time.Duration

+ MaxRetries int

+ Network string

+ Password string

+ PoolSize int

+ PoolTimeout time.Duration

+ ReadTimeout time.Duration

+ RetryStatementTimeout bool

+ TLSConfig *tls.Config

+ User string

+ WriteTimeout time.Duration

+ type Stmt struct

+ func (stmt *Stmt) Close() error

+ func (stmt *Stmt) Exec(params ...interface{}) (res *types.Result, err error)

+ func (stmt *Stmt) ExecOne(params ...interface{}) (*types.Result, error)

+ func (stmt *Stmt) Query(model interface{}, params ...interface{}) (res *types.Result, err error)

+ func (stmt *Stmt) QueryOne(model interface{}, params ...interface{}) (*types.Result, error)

+ type Strings []string

+ func (Strings) AddModel(_ orm.ColumnScanner) error

+ func (Strings) AfterDelete(_ orm.DB) error

+ func (Strings) AfterInsert(_ orm.DB) error

+ func (Strings) AfterQuery(_ orm.DB) error

+ func (Strings) AfterSelect(_ orm.DB) error

+ func (Strings) AfterUpdate(_ orm.DB) error

+ func (Strings) BeforeDelete(_ orm.DB) error

+ func (Strings) BeforeInsert(_ orm.DB) error

+ func (Strings) BeforeUpdate(_ orm.DB) error

+ func (strings *Strings) NewModel() orm.ColumnScanner

+ func (strings *Strings) Reset() error

+ func (strings *Strings) ScanColumn(colIdx int, _ string, b []byte) error

+ func (strings Strings) AppendValue(dst []byte, quote int) ([]byte, error)

+ type Tx struct

+ func (tx *Tx) Begin() (*Tx, error)

+ func (tx *Tx) Commit() error

+ func (tx *Tx) CopyFrom(r io.Reader, query string, params ...interface{}) (*types.Result, error)

+ func (tx *Tx) CreateTable(model interface{}, opt *orm.CreateTableOptions) error

+ func (tx *Tx) Delete(model interface{}) error

+ func (tx *Tx) Exec(query interface{}, params ...interface{}) (*types.Result, error)

+ func (tx *Tx) ExecOne(query interface{}, params ...interface{}) (*types.Result, error)

+ func (tx *Tx) FormatQuery(dst []byte, query string, params ...interface{}) []byte

+ func (tx *Tx) Insert(model ...interface{}) error

+ func (tx *Tx) Model(model ...interface{}) *orm.Query

+ func (tx *Tx) Prepare(q string) (*Stmt, error)

+ func (tx *Tx) Query(model interface{}, query interface{}, params ...interface{}) (*types.Result, error)

+ func (tx *Tx) QueryOne(model interface{}, query interface{}, params ...interface{}) (*types.Result, error)

+ func (tx *Tx) Rollback() error

+ func (tx *Tx) RunInTransaction(fn func(*Tx) error) error

+ func (tx *Tx) Select(model interface{}) error

+ func (tx *Tx) Stmt(stmt *Stmt) *Stmt

+ func (tx *Tx) Update(model interface{}) error