bindings

package

Go to main page

Versions in this module

v1

v1.5.2

Jun 1, 2020

retracted

v1.5.1

Apr 17, 2020

retracted

v1.5.0

Apr 15, 2020

retracted

v1.4.1

Mar 24, 2020

retracted

v1.4.0

Jan 28, 2020

retracted

Changes in this version

+ func GenerateID(address string) uint64

v1.3.0

Jan 9, 2020

retracted

v1.2.1

Dec 28, 2019

retracted

v1.2.0

Dec 4, 2019

retracted

Changes in this version

+ func ConfigMultiThread() error

+ func ConfigSingleThread() error

v1.1.0

Nov 4, 2019

retracted

Changes in this version

type Node

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

v1.0.0

Aug 29, 2019

retracted

Changes in this version

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

+ type Node C.dqlite_node

+ func NewNode(id uint64, address string, dir string) (*Node, error)

+ func (s *Node) Close()

+ func (s *Node) GetBindAddress() string

+ 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

v0

v0.9.4

Jul 17, 2019

v0.9.3

Jul 12, 2019

Changes in this version

+ const Candidate

+ const Follower

+ const Leader

+ const Unavailable

type Server

+ func (s *Server) SetWatchFunc(watch WatchFunc)

+ type WatchFunc func(int, int)

v0.9.2

Jul 12, 2019

Changes in this version

+ const RequestJoin

+ const RequestPromote

+ const RequestRemove

+ var ErrServerCantBootstrap = fmt.Errorf("server already bootstrapped")

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

+ type LogFunc func(int, string)

type Server

+ func (s *Server) Cluster() ([]ServerInfo, error)

+ func (s *Server) Dump(filename string) ([]byte, error)

+ func (s *Server) Leader() *ServerInfo

+ func (s *Server) SetDialFunc(dial DialFunc)

+ func (s *Server) SetLogFunc(log LogFunc)

v0.9.0

Apr 6, 2019

Changes in this version

type Server

+ func (s *Server) Bootstrap(servers []ServerInfo) error

v0.2.2

Nov 2, 2018

v0.2.1

Aug 16, 2018

Changes in this version

+ const RequestInterrupt

v0.2.0

Aug 14, 2018

Changes in this version

+ const Blob

+ const Boolean

+ const ErrBusy

+ const ErrError

+ const ErrInternal

+ const ErrInterrupt

+ const ErrIoErr

+ const ErrIoErrLeadershipLost

+ const ErrIoErrNotLeader

+ const ErrNoMem

+ const Float

+ const ISO8601

+ const Integer

+ const LogDebug

+ const LogError

+ const LogInfo

+ const LogWarn

+ const Null

+ const OpenCreate

+ const OpenReadOnly

+ const OpenReadWrite

+ const ProtocolVersion

+ const RequestClient

+ const RequestExec

+ const RequestExecSQL

+ const RequestFinalize

+ const RequestHeartbeat

+ const RequestLeader

+ const RequestOpen

+ const RequestPrepare

+ const RequestQuery

+ const RequestQuerySQL

+ const ResponseDb

+ const ResponseEmpty

+ const ResponseFailure

+ const ResponseResult

+ const ResponseRows

+ const ResponseServer

+ const ResponseServers

+ const ResponseStmt

+ const ResponseWelcome

+ const Text

+ const UnixTime

+ const WalCheckpointFull

+ const WalCheckpointPassive

+ const WalCheckpointRestart

+ const WalCheckpointTruncate

+ var ErrServerStopped = fmt.Errorf("server was stopped")

+ func AssertNoMemoryLeaks(t *testing.T)

+ func ErrorCode(err error) int

+ func Init() error

+ func StatusMallocCount(reset bool) (int, int, error)

+ func StatusMemoryUsed(reset bool) (int, int, error)

+ type Cluster C.dqlite_cluster

+ func NewCluster(methods ClusterMethods) (*Cluster, error)

+ func (c *Cluster) Close()

+ type ClusterMethods interface

+ Barrier func() error

+ Checkpoint func(*Conn) error

+ Leader func() string

+ Recover func(token uint64) error

+ Register func(*Conn)

+ Servers func() ([]ServerInfo, error)

+ Unregister func(*Conn)

+ type Conn C.sqlite3

+ func Open(name string, vfs string) (*Conn, error)

+ func (c *Conn) Close() error

+ func (c *Conn) ConfigNoCkptOnClose(flag bool) (bool, error)

+ func (c *Conn) Exec(query string) error

+ func (c *Conn) Filename() string

+ func (c *Conn) Query(query string) (*Rows, error)

+ func (c *Conn) WalCheckpoint(schema string, mode WalCheckpointMode) (int, int, error)

+ func (c *Conn) WalReplicationFollower() error

+ func (c *Conn) WalReplicationFrames(info WalReplicationFrameInfo) error

+ func (c *Conn) WalReplicationLeader(name string) error

+ func (c *Conn) WalReplicationUndo() error

+ type Error struct

+ Code int

+ Message string

+ func (e Error) Error() string

+ type FrameNumber C.unsigned

+ type Logger C.dqlite_logger

+ func NewLogger(f logging.Func) *Logger

+ func (l *Logger) Close()

+ type PageNumber C.unsigned

+ type Rows struct

+ func (r *Rows) Close() error

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

+ type Server C.dqlite_server

+ func NewServer(cluster *Cluster) (*Server, error)

+ func (s *Server) Close()

+ func (s *Server) Handle(conn net.Conn) error

+ func (s *Server) Ready() bool

+ func (s *Server) Run() error

+ func (s *Server) SetLogger(logger *Logger)

+ func (s *Server) SetVfs(name string)

+ func (s *Server) SetWalReplication(name string)

+ func (s *Server) Stop() error

+ type ServerInfo struct

+ Address string

+ ID uint64

+ type Vfs C.sqlite3_vfs

+ func NewVfs(name string, logger *Logger) (*Vfs, error)

+ func (v *Vfs) Close() error

+ func (v *Vfs) Name() string

+ func (v *Vfs) ReadFile(filename string) ([]byte, error)

+ func (v *Vfs) WriteFile(filename string, bytes []byte) error

+ type WalCheckpointMode int

+ type WalReplication C.sqlite3_wal_replication

+ func NewWalReplication(name string, methods WalReplicationMethods) (*WalReplication, error)

+ func (r *WalReplication) Close() error

+ func (r *WalReplication) Name() string

+ type WalReplicationFrameInfo struct

+ func (i *WalReplicationFrameInfo) IsBegin(flag bool)

+ func (i *WalReplicationFrameInfo) IsCommit(flag bool)

+ func (i *WalReplicationFrameInfo) IsCommitGet() bool

+ func (i *WalReplicationFrameInfo) Len(n int)

+ func (i *WalReplicationFrameInfo) PageSize(size int)

+ func (i *WalReplicationFrameInfo) Pages(numbers []PageNumber, data unsafe.Pointer)

+ func (i *WalReplicationFrameInfo) Truncate(truncate uint)

+ type WalReplicationFrameList struct

+ func (l *WalReplicationFrameList) Frame(i int) (unsafe.Pointer, PageNumber, FrameNumber)

+ func (l *WalReplicationFrameList) IsCommit() bool

+ func (l *WalReplicationFrameList) Len() int

+ func (l *WalReplicationFrameList) PageSize() int

+ func (l *WalReplicationFrameList) Truncate() uint

+ type WalReplicationMethods interface

+ Abort func(*Conn) int

+ Begin func(*Conn) int

+ End func(*Conn) int

+ Frames func(*Conn, WalReplicationFrameList) int

+ Undo func(*Conn) int

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