bindings

Documentation

Index

• Constants
• Variables
• func ConfigMultiThread() error
• func ConfigSingleThread() error
• func GenerateID(address string) uint64
• type Node
  • func NewNode(ctx context.Context, id uint64, address string, dir string) (*Node, error)
  • func (s *Node) Close()
  • func (s *Node) DescribeLastEntry() (uint64, uint64, error)
  • func (s *Node) EnableDiskMode() error
  • func (s *Node) GetBindAddress() string
  • func (s *Node) Recover(cluster []protocol.NodeInfo) error
  • func (s *Node) RecoverExt(cluster []protocol.NodeInfo) error
  • func (s *Node) SetAutoRecovery(on bool) error
  • func (s *Node) SetBindAddress(address string) error
  • func (s *Node) SetBlockSize(size uint) error
  • func (s *Node) SetBusyTimeout(milliseconds uint64) error
  • func (s *Node) SetDialFunc(dial protocol.DialFunc) error
  • func (s *Node) SetFailureDomain(code uint64) error
  • func (s *Node) SetNetworkLatency(nanoseconds uint64) error
  • func (s *Node) SetSnapshotParams(params SnapshotParams) error
  • func (s *Node) Start() error
  • func (s *Node) Stop() error
• type SnapshotParams
• type TrailingStrategy

Constants

const DqliteMinSupportedVersion = 1_17_00

required dqlite version

Variables

var DqliteVersion = int(C.dqlite_version_number())

var ErrNodeStopped = fmt.Errorf("server was stopped")

ErrNodeStopped is returned by Node.Handle() is the server was stopped.

Functions

func ConfigMultiThread

func ConfigMultiThread() error

func ConfigSingleThread

func ConfigSingleThread() error

func GenerateID

func GenerateID(address string) uint64

GenerateID generates a unique ID for a server.

Types

type Node

type Node struct {
	// contains filtered or unexported fields
}

func NewNode

func NewNode(ctx context.Context, id uint64, address string, dir string) (*Node, error)

NewNode creates a new Node instance.

func (*Node) Close

func (s *Node) Close()

Close the server releasing all used resources.

func (*Node) DescribeLastEntry

func (s *Node) DescribeLastEntry() (uint64, uint64, error)

func (*Node) EnableDiskMode

func (s *Node) EnableDiskMode() error

func (*Node) GetBindAddress

func (s *Node) GetBindAddress() string

func (*Node) Recover

func (s *Node) Recover(cluster []protocol.NodeInfo) error

Remark that Recover doesn't take the node role into account

func (*Node) RecoverExt

func (s *Node) RecoverExt(cluster []protocol.NodeInfo) error

RecoverExt has a similar purpose as `Recover` but takes the node role into account

func (*Node) SetAutoRecovery

func (s *Node) SetAutoRecovery(on bool) error

func (*Node) SetBindAddress

func (s *Node) SetBindAddress(address string) error

func (*Node) SetBlockSize

func (s *Node) SetBlockSize(size uint) error

func (*Node) SetBusyTimeout

func (s *Node) SetBusyTimeout(milliseconds uint64) error

func (*Node) SetDialFunc

func (s *Node) SetDialFunc(dial protocol.DialFunc) error

func (*Node) SetFailureDomain

func (s *Node) SetFailureDomain(code uint64) error

func (*Node) SetNetworkLatency

func (s *Node) SetNetworkLatency(nanoseconds uint64) error

func (*Node) SetSnapshotParams

func (s *Node) SetSnapshotParams(params SnapshotParams) error

func (*Node) Start

func (s *Node) Start() error

func (*Node) Stop

func (s *Node) Stop() error

type SnapshotParams

type SnapshotParams struct {
	Threshold uint64
	Trailing  uint64
	Strategy  TrailingStrategy
}

type TrailingStrategy

type TrailingStrategy int

const (
	TrailingStrategyStatic  TrailingStrategy = C.DQLITE_SNAPSHOT_TRAILING_STATIC
	TrailingStrategyDynamic TrailingStrategy = C.DQLITE_SNAPSHOT_TRAILING_DYNAMIC
)