Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

voltdbclient

package

Go to main page

Versions in this module

v1

v1.0.1

May 31, 2018

Changes in this version

+ var ErrMissingServerArgument = errors.New("voltdbclient: missing voltdb connection string")

type Conn

+ func (c *Conn) DumpConn()

v1.0.0

Apr 3, 2018

Changes in this version

+ const AsyncTopoHandle

+ const BinArrayFormat

+ const BlockDuration

+ const DefaultQueryTimeout

+ const Elastic

+ const JSONFormat

+ const MPInitPID

+ const OutTXNsLimit

+ const PartitionIDBits

+ const PartitionIDMaxValue

+ const PingHandle

+ var ProtocolVersion = 1

+ func EncodePI(e *wire.Encoder, pi *procedureInvocation) error

+ func SearchToken2Partitions(a []token2Partition, token int) (partition int)

+ type AsyncResponseConsumer interface

+ ConsumeError func(error)

+ ConsumeResult func(driver.Result)

+ ConsumeRows func(driver.Rows)

+ type Conn struct

+ func OpenConn(ci string) (*Conn, error)

+ func OpenConnWithLatencyTarget(ci string, latencyTarget int32) (*Conn, error)

+ func OpenConnWithMaxOutstandingTxns(ci string, maxOutTxns int) (*Conn, error)

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

+ func (c *Conn) Close() error

+ func (c *Conn) Drain()

+ func (c *Conn) Exec(query string, args []driver.Value) (driver.Result, error)

+ func (c *Conn) ExecAsync(resCons AsyncResponseConsumer, query string, args []driver.Value)

+ func (c *Conn) ExecAsyncTimeout(resCons AsyncResponseConsumer, query string, args []driver.Value, ...)

+ func (c *Conn) ExecTimeout(query string, args []driver.Value, timeout time.Duration) (driver.Result, error)

+ func (c *Conn) Prepare(query string) (driver.Stmt, error)

+ func (c *Conn) Query(query string, args []driver.Value) (driver.Rows, error)

+ func (c *Conn) QueryAsync(rowsCons AsyncResponseConsumer, query string, args []driver.Value)

+ func (c *Conn) QueryAsyncTimeout(rowsCons AsyncResponseConsumer, query string, args []driver.Value, ...)

+ func (c *Conn) QueryTimeout(query string, args []driver.Value, timeout time.Duration) (driver.Rows, error)

+ type ResponseStatus int8

+ const ConnectionLost

+ const ConnectionTimeout

+ const GracefulFailure

+ const OperationalFailure

+ const ResponseUnknown

+ const ServerUnavailable

+ const Success

+ const TXNRestart

+ const UnexpectedFailure

+ const UninitializedAppStatusCode

+ const UserAbort

+ func (rs ResponseStatus) String() string

+ type Token2PartitionSlice []token2Partition

+ func (s Token2PartitionSlice) Len() int

+ func (s Token2PartitionSlice) Less(i, j int) bool

+ func (s Token2PartitionSlice) Sort()

+ func (s Token2PartitionSlice) Swap(i, j int)

+ type VoltDriver struct

+ func NewVoltDriver() *VoltDriver

+ func (vd *VoltDriver) Open(hostAndPort string) (driver.Conn, error)

+ type VoltError struct

+ type VoltResult struct

+ func (vr *VoltResult) AdvanceTable() bool

+ func (vr *VoltResult) AdvanceToTable(ti int) bool

+ func (vr VoltResult) LastInsertId() (int64, error)

+ func (vr VoltResult) RowsAffected() (int64, error)

+ type VoltRows struct

+ func (vr *VoltRows) AdvanceTable() bool

+ func (vr *VoltRows) AdvanceToTable(tableIndex int16) bool

+ func (vr VoltRows) AdvanceRow() bool

+ func (vr VoltRows) AdvanceToRow(rowIndex int32) bool

+ func (vr VoltRows) Close() error

+ func (vr VoltRows) ColumnCount() int

+ func (vr VoltRows) ColumnTypes() []int8

+ func (vr VoltRows) Columns() []string

+ func (vr VoltRows) GetBigInt(colIndex int16) (interface{}, error)

+ func (vr VoltRows) GetBigIntByName(cn string) (interface{}, error)

+ func (vr VoltRows) GetDecimal(colIndex int16) (interface{}, error)

+ func (vr VoltRows) GetDecimalByName(cn string) (interface{}, error)

+ func (vr VoltRows) GetFloat(colIndex int16) (interface{}, error)

+ func (vr VoltRows) GetFloatByName(cn string) (interface{}, error)

+ func (vr VoltRows) GetInteger(colIndex int16) (interface{}, error)

+ func (vr VoltRows) GetIntegerByName(cn string) (interface{}, error)

+ func (vr VoltRows) GetSmallInt(colIndex int16) (interface{}, error)

+ func (vr VoltRows) GetSmallIntByName(cn string) (interface{}, error)

+ func (vr VoltRows) GetString(colIndex int16) (interface{}, error)

+ func (vr VoltRows) GetStringByName(cn string) (interface{}, error)

+ func (vr VoltRows) GetTimestamp(colIndex int16) (interface{}, error)

+ func (vr VoltRows) GetTimestampByName(cn string) (interface{}, error)

+ func (vr VoltRows) GetTinyInt(colIndex int16) (interface{}, error)

+ func (vr VoltRows) GetTinyIntByName(cn string) (interface{}, error)

+ func (vr VoltRows) GetVarbinary(colIndex int16) (interface{}, error)

+ func (vr VoltRows) GetVarbinaryByName(cn string) (interface{}, error)

+ func (vr VoltRows) Next(dest []driver.Value) (err error)

+ type VoltStatement struct

+ func (vs VoltStatement) Close() error

+ func (vs VoltStatement) Exec(args []driver.Value) (driver.Result, error)

+ func (vs VoltStatement) ExecAsync(resCons AsyncResponseConsumer, args []driver.Value)

+ func (vs VoltStatement) ExecAsyncTimeout(resCons AsyncResponseConsumer, args []driver.Value, timeout time.Duration)

+ func (vs VoltStatement) ExecTimeout(args []driver.Value, timeout time.Duration) (driver.Result, error)

+ func (vs VoltStatement) NumInput() int

+ func (vs VoltStatement) Query(args []driver.Value) (driver.Rows, error)

+ func (vs VoltStatement) QueryAsync(rowsCons AsyncResponseConsumer, args []driver.Value)

+ func (vs VoltStatement) QueryAsyncTimeout(rowsCons AsyncResponseConsumer, args []driver.Value, timeout time.Duration)

+ func (vs VoltStatement) QueryTimeout(args []driver.Value, timeout time.Duration) (driver.Rows, error)