client

package

Go to main page

Versions in this module

v0

v0.9.4

Jul 17, 2019

v0.9.3

Jul 12, 2019

v0.9.2

Jul 12, 2019

Changes in this version

+ func EncodeJoin(request *Message, id uint64, address string)

+ func EncodePromote(request *Message, id uint64)

+ func EncodeRemove(request *Message, id uint64)

v0.9.0

Apr 6, 2019

v0.2.2

Nov 2, 2018

Changes in this version

+ var ErrNoAvailableLeader = fmt.Errorf("no available dqlite leader server found")

type Client

+ func (c *Client) SetContextTimeout(timeout time.Duration)

v0.2.1

Aug 16, 2018

Changes in this version

+ func EncodeInterrupt(request *Message, db uint64)

type Client

+ func (c *Client) Interrupt(ctx context.Context, request *Message, response *Message) error

v0.2.0

Aug 14, 2018

Changes in this version

+ var ErrRowsPart = fmt.Errorf("not all rows were returned in this response")

+ func DecodeDb(response *Message) (id uint32, err error)

+ func DecodeEmpty(response *Message) (err error)

+ func DecodeFailure(response *Message) (code uint64, message string, err error)

+ func DecodeServer(response *Message) (address string, err error)

+ func DecodeStmt(response *Message) (db uint32, id uint32, params uint64, err error)

+ func DecodeWelcome(response *Message) (heartbeatTimeout uint64, err error)

+ func EncodeClient(request *Message, id uint64)

+ func EncodeExec(request *Message, db uint32, stmt uint32, values NamedValues)

+ func EncodeExecSQL(request *Message, db uint64, sql string, values NamedValues)

+ func EncodeFinalize(request *Message, db uint32, stmt uint32)

+ func EncodeHeartbeat(request *Message, timestamp uint64)

+ func EncodeLeader(request *Message)

+ func EncodeOpen(request *Message, name string, flags uint64, vfs string)

+ func EncodePrepare(request *Message, db uint64, sql string)

+ func EncodeQuery(request *Message, db uint32, stmt uint32, values NamedValues)

+ func EncodeQuerySQL(request *Message, db uint64, sql string, values NamedValues)

+ func TCPDial(ctx context.Context, address string) (net.Conn, error)

+ func UnixDial(ctx context.Context, address string) (net.Conn, error)

+ type Client struct

+ func (c *Client) Call(ctx context.Context, request, response *Message) error

+ func (c *Client) Close() error

+ func (c *Client) More(ctx context.Context, response *Message) error

+ type Config struct

+ AttemptTimeout time.Duration

+ Dial DialFunc

+ RetryStrategies []strategy.Strategy

+ type Connector struct

+ func NewConnector(id uint64, store ServerStore, config Config, log logging.Func) *Connector

+ func (c *Connector) Connect(ctx context.Context) (*Client, error)

+ type DialFunc func(context.Context, string) (net.Conn, error)

+ type ErrRequest struct

+ Code uint64

+ Description string

+ func (e ErrRequest) Error() string

+ type InmemServerStore struct

+ func NewInmemServerStore() *InmemServerStore

+ func (i *InmemServerStore) Get(ctx context.Context) ([]ServerInfo, error)

+ func (i *InmemServerStore) Set(ctx context.Context, servers []ServerInfo) error

+ type Message struct

+ func (m *Message) Init(staticSize int)

+ func (m *Message) Reset()

+ type NamedValues = []driver.NamedValue

+ type Result struct

+ LastInsertID uint64

+ RowsAffected uint64

+ func DecodeResult(response *Message) (result Result, err error)

+ type Rows struct

+ Columns []string

+ func DecodeRows(response *Message) (rows Rows, err error)

+ func (r *Rows) Close()

+ func (r *Rows) Next(dest []driver.Value) error

+ type ServerInfo = bindings.ServerInfo

+ type ServerStore interface

+ Get func(context.Context) ([]ServerInfo, error)

+ Set func(context.Context, []ServerInfo) error

+ type Servers []bindings.ServerInfo

+ func DecodeServers(response *Message) (servers Servers, err error)

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