pgx

package

Go to main page

Versions in this module

v1

v1.7.1

Jan 30, 2016

v1.7.0

Jan 16, 2016

v1.6.1

Jan 15, 2016

v1.6.0

Jan 15, 2016

Changes in this version

+ const CidrArrayOid

+ const InetArrayOid

type ConnConfig

+ RuntimeParams map[string]string

type ConnPool

+ func (p *ConnPool) Reset()

type PreparedStatement

+ SQL string

v1.5.0

Oct 1, 2015

Changes in this version

+ const CidrOid

+ const InetOid

+ const JsonOid

+ const JsonbOid

+ const LogLevelDebug

+ const LogLevelError

+ const LogLevelInfo

+ const LogLevelNone

+ const LogLevelTrace

+ const LogLevelWarn

+ const UuidOid

+ var ErrConnBusy = errors.New("conn is busy")

+ func LogLevelFromString(s string) (int, error)

type Conn

+ func (c *Conn) Unlisten(channel string) error

type ConnConfig

+ FallbackTLSConfig *tls.Config

+ LogLevel int

+ UseFallbackTLS bool

+ func ParseEnvLibpq() (ConnConfig, error)

v1.4.0

May 16, 2015

Changes in this version

+ var ErrTLSRefused = errors.New("server refused TLS connection")

v1.3.3

May 2, 2015

v1.3.2

May 1, 2015

Changes in this version

type ConnConfig

+ Dial DialFunc

+ func ParseDSN(s string) (ConnConfig, error)

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

+ type LargeObject struct

+ func (o *LargeObject) Close() error

+ func (o *LargeObject) Read(p []byte) (int, error)

+ func (o *LargeObject) Seek(offset int64, whence int) (n int64, err error)

+ func (o *LargeObject) Tell() (n int64, err error)

+ func (o *LargeObject) Truncate(size int64) (err error)

+ func (o *LargeObject) Write(p []byte) (int, error)

+ type LargeObjectMode int32

+ const LargeObjectModeRead

+ const LargeObjectModeWrite

+ type LargeObjects struct

+ Has64 bool

+ func (o *LargeObjects) Create(id Oid) (Oid, error)

+ func (o *LargeObjects) Open(oid Oid, mode LargeObjectMode) (*LargeObject, error)

+ func (o *LargeObjects) Unlink(oid Oid) error

type PgError

+ File string

+ InternalPosition int32

+ InternalQuery string

+ Line int32

+ Position int32

+ Routine string

+ Where string

type Tx

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

v1.3.1

Dec 24, 2014

v1.3.0

Dec 24, 2014

Changes in this version

+ const BinaryFormatCode

+ const BoolArrayOid

+ const BoolOid

+ const ByteaOid

+ const DateOid

+ const Float4ArrayOid

+ const Float4Oid

+ const Float8ArrayOid

+ const Float8Oid

+ const Int2ArrayOid

+ const Int2Oid

+ const Int4ArrayOid

+ const Int4Oid

+ const Int8ArrayOid

+ const Int8Oid

+ const OidOid

+ const ReadCommitted

+ const ReadUncommitted

+ const RepeatableRead

+ const Serializable

+ const TextArrayOid

+ const TextFormatCode

+ const TextOid

+ const TimestampArrayOid

+ const TimestampOid

+ const TimestampTzArrayOid

+ const TimestampTzOid

+ const VarcharArrayOid

+ const VarcharOid

+ var DefaultTypeFormats map[string]int16

+ var ErrDeadConn = errors.New("conn is dead")

+ var ErrNoRows = errors.New("no rows in result set")

+ var ErrNotificationTimeout = errors.New("notification timeout")

+ var ErrTxClosed = errors.New("tx is closed")

+ type CommandTag string

+ func (ct CommandTag) RowsAffected() int64

+ type Conn struct

+ PgTypes map[Oid]PgType

+ Pid int32

+ RuntimeParams map[string]string

+ SecretKey int32

+ TxStatus byte

+ func Connect(config ConnConfig) (c *Conn, err error)

+ func (c *Conn) Begin() (*Tx, error)

+ func (c *Conn) BeginIso(isoLevel string) (*Tx, error)

+ func (c *Conn) CauseOfDeath() error

+ func (c *Conn) Close() (err error)

+ func (c *Conn) Deallocate(name string) (err error)

+ func (c *Conn) Exec(sql string, arguments ...interface{}) (commandTag CommandTag, err error)

+ func (c *Conn) IsAlive() bool

+ func (c *Conn) Listen(channel string) (err error)

+ func (c *Conn) Prepare(name, sql string) (ps *PreparedStatement, err error)

+ func (c *Conn) Query(sql string, args ...interface{}) (*Rows, error)

+ func (c *Conn) QueryRow(sql string, args ...interface{}) *Row

+ func (c *Conn) WaitForNotification(timeout time.Duration) (*Notification, error)

+ type ConnConfig struct

+ Database string

+ Host string

+ Logger Logger

+ Password string

+ Port uint16

+ TLSConfig *tls.Config

+ User string

+ func ParseURI(uri string) (ConnConfig, error)

+ type ConnPool struct

+ func NewConnPool(config ConnPoolConfig) (p *ConnPool, err error)

+ func (p *ConnPool) Acquire() (c *Conn, err error)

+ func (p *ConnPool) Begin() (*Tx, error)

+ func (p *ConnPool) BeginIso(iso string) (*Tx, error)

+ func (p *ConnPool) Close()

+ func (p *ConnPool) Exec(sql string, arguments ...interface{}) (commandTag CommandTag, err error)

+ func (p *ConnPool) Query(sql string, args ...interface{}) (*Rows, error)

+ func (p *ConnPool) QueryRow(sql string, args ...interface{}) *Row

+ func (p *ConnPool) Release(conn *Conn)

+ func (p *ConnPool) Stat() (s ConnPoolStat)

+ type ConnPoolConfig struct

+ AfterConnect func(*Conn) error

+ MaxConnections int

+ type ConnPoolStat struct

+ AvailableConnections int

+ CurrentConnections int

+ MaxConnections int

+ type Encoder interface

+ Encode func(w *WriteBuf, oid Oid) error

+ FormatCode func() int16

+ type FieldDescription struct

+ AttributeNumber int16

+ DataType Oid

+ DataTypeName string

+ DataTypeSize int16

+ FormatCode int16

+ Modifier int32

+ Name string

+ Table Oid

+ type Hstore map[string]string

+ func (h *Hstore) Scan(vr *ValueReader) error

+ func (h Hstore) Encode(w *WriteBuf, oid Oid) error

+ func (h Hstore) FormatCode() int16

+ type Logger interface

+ Debug func(msg string, ctx ...interface{})

+ Error func(msg string, ctx ...interface{})

+ Info func(msg string, ctx ...interface{})

+ Warn func(msg string, ctx ...interface{})

+ type Notification struct

+ Channel string

+ Payload string

+ Pid int32

+ type NullBool struct

+ Bool bool

+ Valid bool

+ func (n *NullBool) Scan(vr *ValueReader) error

+ func (n NullBool) Encode(w *WriteBuf, oid Oid) error

+ func (n NullBool) FormatCode() int16

+ type NullFloat32 struct

+ Float32 float32

+ Valid bool

+ func (n *NullFloat32) Scan(vr *ValueReader) error

+ func (n NullFloat32) Encode(w *WriteBuf, oid Oid) error

+ func (n NullFloat32) FormatCode() int16

+ type NullFloat64 struct

+ Float64 float64

+ Valid bool

+ func (n *NullFloat64) Scan(vr *ValueReader) error

+ func (n NullFloat64) Encode(w *WriteBuf, oid Oid) error

+ func (n NullFloat64) FormatCode() int16

+ type NullHstore struct

+ Hstore map[string]NullString

+ Valid bool

+ func (h *NullHstore) Scan(vr *ValueReader) error

+ func (h NullHstore) Encode(w *WriteBuf, oid Oid) error

+ func (h NullHstore) FormatCode() int16

+ type NullInt16 struct

+ Int16 int16

+ Valid bool

+ func (n *NullInt16) Scan(vr *ValueReader) error

+ func (n NullInt16) Encode(w *WriteBuf, oid Oid) error

+ func (n NullInt16) FormatCode() int16

+ type NullInt32 struct

+ Int32 int32

+ Valid bool

+ func (n *NullInt32) Scan(vr *ValueReader) error

+ func (n NullInt32) Encode(w *WriteBuf, oid Oid) error

+ func (n NullInt32) FormatCode() int16

+ type NullInt64 struct

+ Int64 int64

+ Valid bool

+ func (n *NullInt64) Scan(vr *ValueReader) error

+ func (n NullInt64) Encode(w *WriteBuf, oid Oid) error

+ func (n NullInt64) FormatCode() int16

+ type NullString struct

+ String string

+ Valid bool

+ func ParseHstore(s string) (k []string, v []NullString, err error)

+ func (n NullString) FormatCode() int16

+ func (s *NullString) Scan(vr *ValueReader) error

+ func (s NullString) Encode(w *WriteBuf, oid Oid) error

+ type NullTime struct

+ Time time.Time

+ Valid bool

+ func (n *NullTime) Scan(vr *ValueReader) error

+ func (n NullTime) Encode(w *WriteBuf, oid Oid) error

+ func (n NullTime) FormatCode() int16

+ type Oid int32

+ type PgError struct

+ Code string

+ ColumnName string

+ ConstraintName string

+ DataTypeName string

+ Detail string

+ Hint string

+ Message string

+ SchemaName string

+ Severity string

+ TableName string

+ func (self PgError) Error() string

+ type PgType struct

+ DefaultFormat int16

+ Name string

+ type PreparedStatement struct

+ FieldDescriptions []FieldDescription

+ Name string

+ ParameterOids []Oid

+ type ProtocolError string

+ func (e ProtocolError) Error() string

+ type QueryArgs []interface

+ func (qa *QueryArgs) Append(v interface{}) string

+ type Row Rows

+ func (r *Row) Scan(dest ...interface{}) (err error)

+ type Rows struct

+ func (rows *Rows) Close()

+ func (rows *Rows) Err() error

+ func (rows *Rows) Fatal(err error)

+ func (rows *Rows) FieldDescriptions() []FieldDescription

+ func (rows *Rows) Next() bool

+ func (rows *Rows) Scan(dest ...interface{}) (err error)

+ func (rows *Rows) Values() ([]interface{}, error)

+ type Scanner interface

+ Scan func(r *ValueReader) error

+ type SerializationError string

+ func (e SerializationError) Error() string

+ type Tx struct

+ func (tx *Tx) Commit() error

+ func (tx *Tx) Exec(sql string, arguments ...interface{}) (commandTag CommandTag, err error)

+ func (tx *Tx) Query(sql string, args ...interface{}) (*Rows, error)

+ func (tx *Tx) QueryRow(sql string, args ...interface{}) *Row

+ func (tx *Tx) Rollback() error

+ type ValueReader struct

+ func (r *ValueReader) Err() error

+ func (r *ValueReader) Fatal(err error)

+ func (r *ValueReader) Len() int32

+ func (r *ValueReader) ReadByte() byte

+ func (r *ValueReader) ReadBytes(count int32) []byte

+ func (r *ValueReader) ReadInt16() int16

+ func (r *ValueReader) ReadInt32() int32

+ func (r *ValueReader) ReadInt64() int64

+ func (r *ValueReader) ReadOid() Oid

+ func (r *ValueReader) ReadString(count int32) string

+ func (r *ValueReader) Type() *FieldDescription

+ type WriteBuf struct

+ func (wb *WriteBuf) WriteByte(b byte)

+ func (wb *WriteBuf) WriteBytes(b []byte)

+ func (wb *WriteBuf) WriteCString(s string)

+ func (wb *WriteBuf) WriteInt16(n int16)

+ func (wb *WriteBuf) WriteInt32(n int32)

+ func (wb *WriteBuf) WriteInt64(n int64)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL