protocol

Oct 24, 2024

retracted

Changes in this version

type Config

+ PermitShared bool

type Connector

+ func NewDirectConnector(id uint64, address string, config Config, log logging.Func) *Connector

+ func NewLeaderConnector(store NodeStore, config Config, log logging.Func) *Connector

+ type LeaderTracker struct

+ func (lt *LeaderTracker) DonateSharedProtocol(proto *Protocol) (accepted bool)

+ func (lt *LeaderTracker) GetLeaderAddr() string

+ func (lt *LeaderTracker) SetLeaderAddr(address string)

+ func (lt *LeaderTracker) TakeSharedProtocol() (proto *Protocol)

+ func (lt *LeaderTracker) UnsetLeaderAddr()

type Protocol

+ func (p *Protocol) Bad()

Jul 22, 2024

retracted

Changes in this version

+ const MaxConcurrentLeaderConns

type Config

+ ConcurrentLeaderConns int64

May 31, 2023

retracted

Changes in this version

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

+ func EncodeExecSQLV1(request *Message, db uint64, sql string, values NamedValues32)

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

+ func EncodeExecV1(request *Message, db uint32, stmt uint32, values NamedValues32)

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

+ func EncodeQuerySQLV1(request *Message, db uint64, sql string, values NamedValues32)

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

+ func EncodeQueryV1(request *Message, db uint32, stmt uint32, values NamedValues32)

+ type NamedValues32 = []driver.NamedValue

Jun 30, 2020

retracted

Changes in this version

+ const RequestDescribe

+ const RequestDescribeFormatV0

+ const RequestWeight

+ const ResponseMetadata

+ func DecodeMetadata(response *Message) (failureDomain uint64, weight uint64, err error)

+ func EncodeDescribe(request *Message, format uint64)

+ func EncodeWeight(request *Message, weight uint64)

Jun 24, 2020

retracted

Changes in this version

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

Apr 15, 2020

retracted

Changes in this version

+ var TLSCipherSuites = []uint16

Mar 24, 2020

retracted

Changes in this version

type Config

+ BackoffCap time.Duration

+ BackoffFactor time.Duration

+ DialTimeout time.Duration

+ RetryLimit uint

type Protocol

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

Jan 28, 2020

retracted

Changes in this version

+ type Error struct

+ Code int

+ Message string

+ func (e Error) Error() string

Jan 9, 2020

retracted

Changes in this version

+ const ClusterFormatV0

+ const ClusterFormatV1

+ const RequestAdd

+ const RequestAssign

+ const RequestTransfer

+ const Spare

+ const StandBy

+ const Voter

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

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

+ func EncodeTransfer(request *Message, id uint64)

type NodeInfo

+ Role NodeRole

+ type NodeRole int

+ func (r NodeRole) String() string

Dec 4, 2019

retracted

Changes in this version

type Rows

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

Aug 29, 2019

retracted

Changes in this version

+ const Blob

+ const Boolean

+ const Float

+ const ISO8601

+ const Integer

+ const Null

+ const RequestClient

+ const RequestCluster

+ const RequestDump

+ const RequestExec

+ const RequestExecSQL

+ const RequestFinalize

+ const RequestHeartbeat

+ const RequestInterrupt

+ const RequestJoin

+ const RequestLeader

+ const RequestOpen

+ const RequestPrepare

+ const RequestPromote

+ const RequestQuery

+ const RequestQuerySQL

+ const RequestRemove

+ const ResponseDb

+ const ResponseEmpty

+ const ResponseFailure

+ const ResponseFiles

+ const ResponseNode

+ const ResponseNodeLegacy

+ const ResponseNodes

+ const ResponseResult

+ const ResponseRows

+ const ResponseStmt

+ const ResponseWelcome

+ const Text

+ const UnixTime

+ const VersionLegacy

+ const VersionOne

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

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

+ func EncodeCluster(request *Message)

+ 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 EncodeJoin(request *Message, id uint64, address string)

+ func EncodeLeader(request *Message)

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

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

+ func EncodePromote(request *Message, id uint64)

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

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

+ type Config struct

+ AttemptTimeout time.Duration

+ Dial DialFunc

+ RetryStrategies []strategy.Strategy

+ 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 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(staticSize int)

+ func (m *Message) Reset()

+ type NamedValues = []driver.NamedValue

+ type NodeInfo struct

+ Address string

+ ID uint64

+ 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 Connect(ctx context.Context, dial DialFunc, address string, version uint64) (*Protocol, error)

+ func NewProtocol(version uint64, conn net.Conn) *Protocol

+ 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

+ func (p *Protocol) SetContextTimeout(timeout time.Duration)

+ 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) Next(dest []driver.Value) error

Aug 14, 2018

Changes in this version

+ var ErrIntOverflowCommands = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthCommands = fmt.Errorf("proto: negative length found during unmarshaling")

+ func MarshalCommand(command *Command) ([]byte, error)

+ type Begin struct

+ Name string

+ Txid uint64

+ func (*Begin) Descriptor() ([]byte, []int)

+ func (*Begin) ProtoMessage()

+ func (m *Begin) GetName() string

+ func (m *Begin) GetTxid() uint64

+ func (m *Begin) Marshal() (dAtA []byte, err error)

+ func (m *Begin) MarshalTo(dAtA []byte) (int, error)

+ func (m *Begin) Reset()

+ func (m *Begin) Size() (n int)

+ func (m *Begin) String() string

+ func (m *Begin) Unmarshal(dAtA []byte) error

+ type Checkpoint struct

+ Name string

+ func (*Checkpoint) Descriptor() ([]byte, []int)

+ func (*Checkpoint) ProtoMessage()

+ func (m *Checkpoint) GetName() string

+ func (m *Checkpoint) Marshal() (dAtA []byte, err error)

+ func (m *Checkpoint) MarshalTo(dAtA []byte) (int, error)

+ func (m *Checkpoint) Reset()

+ func (m *Checkpoint) Size() (n int)

+ func (m *Checkpoint) String() string

+ func (m *Checkpoint) Unmarshal(dAtA []byte) error

+ type Command struct

+ Payload isCommand_Payload

+ func NewBegin(txid uint64, name string) *Command

+ func NewCheckpoint(name string) *Command

+ func NewEnd(txid uint64) *Command

+ func NewFrames(txid uint64, filename string, list bindings.WalReplicationFrameList) *Command

+ func NewOpen(name string) *Command

+ func NewUndo(txid uint64) *Command

+ func UnmarshalCommand(data []byte) (*Command, error)

+ func (*Command) Descriptor() ([]byte, []int)

+ func (*Command) ProtoMessage()

+ func (*Command) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (c *Command) Name() string

+ func (m *Command) GetBegin() *Begin

+ func (m *Command) GetCheckpoint() *Checkpoint

+ func (m *Command) GetEnd() *End

+ func (m *Command) GetFrames() *Frames

+ func (m *Command) GetOpen() *Open

+ func (m *Command) GetPayload() isCommand_Payload

+ func (m *Command) GetUndo() *Undo

+ func (m *Command) Marshal() (dAtA []byte, err error)

+ func (m *Command) MarshalTo(dAtA []byte) (int, error)

+ func (m *Command) Reset()

+ func (m *Command) Size() (n int)

+ func (m *Command) String() string

+ func (m *Command) Unmarshal(dAtA []byte) error

+ type Command_Begin struct

+ Begin *Begin

+ func (m *Command_Begin) MarshalTo(dAtA []byte) (int, error)

+ func (m *Command_Begin) Size() (n int)

+ type Command_Checkpoint struct

+ Checkpoint *Checkpoint

+ func (m *Command_Checkpoint) MarshalTo(dAtA []byte) (int, error)

+ func (m *Command_Checkpoint) Size() (n int)

+ type Command_End struct

+ End *End

+ func (m *Command_End) MarshalTo(dAtA []byte) (int, error)

+ func (m *Command_End) Size() (n int)

+ type Command_Frames struct

+ Frames *Frames

+ func (m *Command_Frames) MarshalTo(dAtA []byte) (int, error)

+ func (m *Command_Frames) Size() (n int)

+ type Command_Open struct

+ Open *Open

+ func (m *Command_Open) MarshalTo(dAtA []byte) (int, error)

+ func (m *Command_Open) Size() (n int)

+ type Command_Undo struct

+ Undo *Undo

+ func (m *Command_Undo) MarshalTo(dAtA []byte) (int, error)

+ func (m *Command_Undo) Size() (n int)

+ type End struct

+ Txid uint64

+ func (*End) Descriptor() ([]byte, []int)

+ func (*End) ProtoMessage()

+ func (m *End) GetTxid() uint64

+ func (m *End) Marshal() (dAtA []byte, err error)

+ func (m *End) MarshalTo(dAtA []byte) (int, error)

+ func (m *End) Reset()

+ func (m *End) Size() (n int)

+ func (m *End) String() string

+ func (m *End) Unmarshal(dAtA []byte) error

+ type Frames struct

+ Filename string

+ IsCommit int32

+ PageData []byte

+ PageNumbers []uint32

+ PageSize int32

+ Pages []*FramesPage

+ SyncFlags uint32

+ Truncate uint32

+ Txid uint64

+ func (*Frames) Descriptor() ([]byte, []int)

+ func (*Frames) ProtoMessage()

+ func (m *Frames) GetFilename() string

+ func (m *Frames) GetIsCommit() int32

+ func (m *Frames) GetPageData() []byte

+ func (m *Frames) GetPageNumbers() []uint32

+ func (m *Frames) GetPageSize() int32

+ func (m *Frames) GetPages() []*FramesPage

+ func (m *Frames) GetSyncFlags() uint32

+ func (m *Frames) GetTruncate() uint32

+ func (m *Frames) GetTxid() uint64

+ func (m *Frames) Marshal() (dAtA []byte, err error)

+ func (m *Frames) MarshalTo(dAtA []byte) (int, error)

+ func (m *Frames) Reset()

+ func (m *Frames) Size() (n int)

+ func (m *Frames) String() string

+ func (m *Frames) Unmarshal(dAtA []byte) error

+ type FramesPage struct

+ Data []byte

+ Flags uint32

+ Number uint32

+ func (*FramesPage) Descriptor() ([]byte, []int)

+ func (*FramesPage) ProtoMessage()

+ func (m *FramesPage) GetData() []byte

+ func (m *FramesPage) GetFlags() uint32

+ func (m *FramesPage) GetNumber() uint32

+ func (m *FramesPage) Marshal() (dAtA []byte, err error)

+ func (m *FramesPage) MarshalTo(dAtA []byte) (int, error)

+ func (m *FramesPage) Reset()

+ func (m *FramesPage) Size() (n int)

+ func (m *FramesPage) String() string

+ func (m *FramesPage) Unmarshal(dAtA []byte) error

+ type Open struct

+ Name string

+ func (*Open) Descriptor() ([]byte, []int)

+ func (*Open) ProtoMessage()

+ func (m *Open) GetName() string

+ func (m *Open) Marshal() (dAtA []byte, err error)

+ func (m *Open) MarshalTo(dAtA []byte) (int, error)

+ func (m *Open) Reset()

+ func (m *Open) Size() (n int)

+ func (m *Open) String() string

+ func (m *Open) Unmarshal(dAtA []byte) error

+ type Undo struct

+ Txid uint64

+ func (*Undo) Descriptor() ([]byte, []int)

+ func (*Undo) ProtoMessage()

+ func (m *Undo) GetTxid() uint64

+ func (m *Undo) Marshal() (dAtA []byte, err error)

+ func (m *Undo) MarshalTo(dAtA []byte) (int, error)

+ func (m *Undo) Reset()

+ func (m *Undo) Size() (n int)

+ func (m *Undo) String() string

+ func (m *Undo) Unmarshal(dAtA []byte) error