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

protocol

package

Go to main page

Versions in this module

v1

v1.8.4

Oct 7, 2021

v1.8.3

Mar 21, 2021

v1.8.2

Mar 21, 2021

Changes in this version

+ const Blob

+ const Boolean

+ const ClusterFormatV0

+ const ClusterFormatV1

+ const Float

+ const ISO8601

+ const Integer

+ const Null

+ const RequestAdd

+ const RequestAssign

+ const RequestClient

+ const RequestCluster

+ const RequestDescribe

+ const RequestDescribeFormatV0

+ const RequestDump

+ const RequestExec

+ const RequestExecSQL

+ const RequestFinalize

+ const RequestHeartbeat

+ const RequestInterrupt

+ const RequestLeader

+ const RequestOpen

+ const RequestPrepare

+ const RequestQuery

+ const RequestQuerySQL

+ const RequestRemove

+ const RequestTransfer

+ const RequestWeight

+ const ResponseDb

+ const ResponseEmpty

+ const ResponseFailure

+ const ResponseFiles

+ const ResponseMetadata

+ const ResponseNode

+ const ResponseNodeLegacy

+ const ResponseNodes

+ const ResponseResult

+ const ResponseRows

+ const ResponseStmt

+ const ResponseWelcome

+ const Spare

+ const StandBy

+ const Text

+ const UnixTime

+ const VersionLegacy

+ const VersionOne

+ const Voter

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

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

+ var TLSCipherSuites = []uint16

+ 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 DecodeMetadata(response *Message) (failureDomain uint64, weight uint64, err error)

+ func DecodeNode(response *Message) (id uint64, address string, err error)

+ func DecodeNodeCompat(protocol *Protocol, response *Message) (uint64, string, error)

+ func DecodeNodeLegacy(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 Dial(ctx context.Context, address string) (net.Conn, error)

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

+ func EncodeAssign(request *Message, id uint64, role uint64)

+ func EncodeClient(request *Message, id uint64)

+ func EncodeCluster(request *Message, format uint64)

+ func EncodeDescribe(request *Message, format uint64)

+ func EncodeDump(request *Message, name string)

+ 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 EncodeInterrupt(request *Message, db 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 EncodeRemove(request *Message, id uint64)

+ func EncodeTransfer(request *Message, id uint64)

+ func EncodeWeight(request *Message, weight uint64)

+ type Config struct

+ AttemptTimeout time.Duration

+ BackoffCap time.Duration

+ BackoffFactor time.Duration

+ Dial DialFunc

+ DialTimeout time.Duration

+ RetryLimit uint

+ type Connector struct

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

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

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

+ type ErrRequest struct

+ Code uint64

+ Description string

+ func (e ErrRequest) Error() string

+ type Error struct

+ Code int

+ Message string

+ func (e Error) Error() string

+ type Files struct

+ func DecodeFiles(response *Message) (files Files, err error)

+ func (f *Files) Close()

+ func (f *Files) Next() (string, []byte)

+ type InmemNodeStore struct

+ func NewInmemNodeStore() *InmemNodeStore

+ func (i *InmemNodeStore) Get(ctx context.Context) ([]NodeInfo, error)

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

+ type Message struct

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

+ type NamedValues = []driver.NamedValue

+ type NodeInfo struct

+ Address string

+ ID uint64

+ Role NodeRole

+ type NodeRole int

+ func (r NodeRole) String() string

+ type NodeStore interface

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

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

+ type Nodes []NodeInfo

+ func DecodeNodes(response *Message) (servers Nodes, err error)

+ type Protocol struct

+ func Handshake(ctx context.Context, conn net.Conn, version uint64) (*Protocol, error)

+ func (p *Protocol) Call(ctx context.Context, request, response *Message) (err error)

+ func (p *Protocol) Close() error

+ func (p *Protocol) Interrupt(ctx context.Context, request *Message, response *Message) error

+ func (p *Protocol) More(ctx context.Context, response *Message) error

+ 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() error

+ func (r *Rows) ColumnTypes() ([]string, error)

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