bindings

Documentation

Index

• Variables
• func ConfigMultiThread() error
• func ConfigSingleThread() error
• func GenerateID(address string) uint64
• type Node
  • func NewNode(id uint64, address string, dir string) (*Node, error)
  • func (s *Node) Close()
  • func (s *Node) GetBindAddress() string
  • func (s *Node) Recover(cluster []protocol.NodeInfo) error
  • func (s *Node) SetBindAddress(address string) error
  • func (s *Node) SetDialFunc(dial protocol.DialFunc) error
  • func (s *Node) SetNetworkLatency(nanoseconds uint64) error
  • func (s *Node) Start() error
  • func (s *Node) Stop() error

Variables

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 C.dqlite_node

func NewNode

func NewNode(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) GetBindAddress

func (s *Node) GetBindAddress() string

func (*Node) Recover

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

func (*Node) SetBindAddress

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

func (*Node) SetDialFunc

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

func (*Node) SetNetworkLatency

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

func (*Node) Start

func (s *Node) Start() error

func (*Node) Stop

func (s *Node) Stop() error