dqlite

Jan 28, 2020

retracted

Changes in this version

+ const BootstrapID

+ func GenerateID(address string) uint64

Dec 4, 2019

retracted

Changes in this version

+ func ConfigMultiThread() error

Nov 4, 2019

retracted

Changes in this version

type Node

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

Aug 29, 2019

retracted

Changes in this version

+ type Node struct

+ func New(id uint64, address string, dir string, options ...Option) (*Node, error)

+ func (s *Node) BindAddress() string

+ func (s *Node) Close() error

+ func (s *Node) Start() error

+ type NodeInfo = client.NodeInfo

+ type Option func(*options)

+ func WithBindAddress(address string) Option

+ func WithNetworkLatency(latency time.Duration) Option

Jul 12, 2019

Changes in this version

+ const Candidate

+ const Follower

+ const Leader

+ const Unavailable

type ServerOption

+ func WithServerWatchFunc(watch WatchFunc) ServerOption

+ type WatchFunc = bindings.WatchFunc

Jul 12, 2019

Changes in this version

+ var ErrServerCantBootstrap = bindings.ErrServerCantBootstrap

+ func Leave(ctx context.Context, id uint64, store ServerStore, dial DialFunc) error

type Server

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

+ func (s *Server) Join(ctx context.Context, store ServerStore, dial DialFunc) error

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

type ServerOption

+ func WithServerDialFunc(dial DialFunc) ServerOption

Apr 6, 2019

Changes in this version

type Server

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

+ func (s *Server) Start() error

Nov 2, 2018

Changes in this version

+ var ErrNoAvailableLeader = client.ErrNoAvailableLeader

type Driver

+ func (d *Driver) SetContextTimeout(timeout time.Duration)

type DriverOption

+ func WithContextTimeout(timeout time.Duration) DriverOption

Aug 14, 2018

Changes in this version

+ const LogDebug

+ const LogError

+ const LogInfo

+ const LogWarn

+ var NewInmemServerStore = client.NewInmemServerStore

+ func NewFSM(r *Registry) raft.FSM

+ type Conn struct

+ func (c *Conn) Begin() (driver.Tx, error)

+ func (c *Conn) BeginTx(ctx context.Context, opts driver.TxOptions) (driver.Tx, error)

+ func (c *Conn) Close() error

+ func (c *Conn) Exec(query string, args []driver.Value) (driver.Result, error)

+ func (c *Conn) ExecContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Result, error)

+ func (c *Conn) Prepare(query string) (driver.Stmt, error)

+ func (c *Conn) PrepareContext(ctx context.Context, query string) (driver.Stmt, error)

+ func (c *Conn) Query(query string, args []driver.Value) (driver.Rows, error)

+ func (c *Conn) QueryContext(ctx context.Context, query string, args []driver.NamedValue) (driver.Rows, error)

+ type DatabaseServerStore struct

+ func DefaultServerStore(filename string) (*DatabaseServerStore, error)

+ func NewServerStore(db *sql.DB, schema, table, column string) *DatabaseServerStore

+ func (d *DatabaseServerStore) Get(ctx context.Context) ([]ServerInfo, error)

+ func (d *DatabaseServerStore) Set(ctx context.Context, servers []ServerInfo) error

+ type DialFunc client.DialFunc

+ type Driver struct

+ func NewDriver(store ServerStore, options ...DriverOption) (*Driver, error)

+ func (d *Driver) Open(uri string) (driver.Conn, error)

+ type DriverError = bindings.Error

+ type DriverOption func(*driverOptions)

+ func WithConnectionBackoffCap(cap time.Duration) DriverOption

+ func WithConnectionBackoffFactor(factor time.Duration) DriverOption

+ func WithConnectionTimeout(timeout time.Duration) DriverOption

+ func WithContext(context context.Context) DriverOption

+ func WithDialFunc(dial DialFunc) DriverOption

+ func WithLogFunc(log LogFunc) DriverOption

+ type InmemServerStore = client.InmemServerStore

+ type LogFunc = logging.Func

+ type LogLevel = logging.Level

+ type Registry struct

+ func NewRegistry(id string) *Registry

+ func NewRegistryWithLogger(id string, log LogFunc) *Registry

+ func (r *Registry) Close()

+ type Result struct

+ func (r *Result) LastInsertId() (int64, error)

+ func (r *Result) RowsAffected() (int64, error)

+ type Rows struct

+ func (r *Rows) Close() error

+ func (r *Rows) ColumnTypeDatabaseTypeName(i int) string

+ func (r *Rows) ColumnTypeScanType(i int) reflect.Type

+ func (r *Rows) Columns() []string

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

+ type Server struct

+ func NewServer(raft *raft.Raft, registry *Registry, listener net.Listener, ...) (*Server, error)

+ func (s *Server) Close() error

+ func (s *Server) Dump(name string, dir string) error

+ type ServerInfo = client.ServerInfo

+ type ServerOption func(*serverOptions)

+ func WithServerAddressProvider(provider raft.ServerAddressProvider) ServerOption

+ func WithServerLogFunc(log LogFunc) ServerOption

+ type ServerStore = client.ServerStore

+ type Stmt struct

+ func (s *Stmt) Close() error

+ func (s *Stmt) Exec(args []driver.Value) (driver.Result, error)

+ func (s *Stmt) ExecContext(ctx context.Context, args []driver.NamedValue) (driver.Result, error)

+ func (s *Stmt) NumInput() int

+ func (s *Stmt) Query(args []driver.Value) (driver.Rows, error)

+ func (s *Stmt) QueryContext(ctx context.Context, args []driver.NamedValue) (driver.Rows, error)

+ type Tx struct

+ func (tx *Tx) Commit() error

+ func (tx *Tx) Rollback() error