Versions in this module Expand all Collapse all v0 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