RedQueen

Jan 12, 2024

Changes in this version

+ func NewTLSTransport(addr string, advertise net.Addr, maxPool int, timeout time.Duration, ...) (*raft.NetworkTransport, error)

+ func NewTLSTransportWithGenerator(addr string, advertise net.Addr, config *raft.NetworkTransportConfig) (*raft.NetworkTransport, error)

+ type RaftTLStreamLayer struct

+ func (r RaftTLStreamLayer) Accept() (net.Conn, error)

+ func (r RaftTLStreamLayer) Addr() net.Addr

+ func (r RaftTLStreamLayer) Close() error

+ func (r RaftTLStreamLayer) Dial(addr raft.ServerAddress, timeout time.Duration) (net.Conn, error)

Jan 3, 2024

Changes in this version

type FSM

+ Handlers map[serverpb.RaftLogCommand]FSMHandleFunc

+ Store store.Store

+ Term *uint64

type Raft

+ func (r *Raft) Term() uint64

type Server

+ func (s *Server) RaftSnapshot(_ context.Context, req *serverpb.RaftSnapshotRequest) (*emptypb.Empty, error)

Nov 9, 2023

Changes in this version

+ const Version

Aug 5, 2023

Changes in this version

+ type Internal interface

+ AppendCluster func(context.Context, *serverpb.AppendClusterRequest) (*serverpb.AppendClusterResponse, error)

+ LeaderMonitor func(*serverpb.LeaderMonitorRequest, serverpb.RedQueen_LeaderMonitorServer) error

+ RaftState func(context.Context, *serverpb.RaftStateRequest) (*serverpb.RaftStateResponse, error)

type KV

+ WatchPrefix func(*serverpb.WatchPrefixRequest, serverpb.KV_WatchPrefixServer) error

type Server

+ func (s *Server) ListenAndServe() error

+ func (s *Server) WatchPrefix(req *serverpb.WatchPrefixRequest, stream serverpb.KV_WatchPrefixServer) error

Jul 27, 2023

Changes in this version

+ const MultipleLogPack

+ const SingleLogPack

+ var ErrApplyLogDone = errors.New("raft apply log done")

+ var ErrApplyLogTimeTravelDone = errors.New("raft apply log time-travel done")

+ func GetLogPackHeader(r io.Reader) uint32

+ func LogPackHeader(typ uint32) []byte

+ func NewFSMHandlers(s store.Store) map[serverpb.RaftLogCommand]FSMHandleFunc

+ func RaftLogPayloadKey(m *serverpb.RaftLogPayload) uint64

+ func UnpackLog(r io.Reader) ([]*serverpb.RaftLogPayload, error)

+ type ApplyFunc func(cmd []byte, timeout time.Duration) raft.ApplyFuture

+ type FSMHandlers struct

+ func (h *FSMHandlers) Del(payload *serverpb.RaftLogPayload) error

+ func (h *FSMHandlers) Set(payload *serverpb.RaftLogPayload) error

+ func (h *FSMHandlers) SetWithTTL(payload *serverpb.RaftLogPayload) error

+ func (h *FSMHandlers) TrySet(payload *serverpb.RaftLogPayload) error

+ func (h *FSMHandlers) TrySetWithTTL(payload *serverpb.RaftLogPayload) error

+ type RaftApply interface

+ Apply func(ctx *context.Context, m *serverpb.RaftLogPayload, timeout time.Duration) error

+ func NewRaftMultipleLogApply(ctx context.Context, maxLimit int32, deadline, applyTimeout time.Duration, ...) RaftApply

+ func NewRaftSingeLogApply(af ApplyFunc) RaftApply

Jun 20, 2023

Changes in this version

+ const StoreSuffix

+ func NewLockerBackend(ns store.Namespace, ...) locker.Backend

+ type FSM struct

+ func NewFSM(s store.Store) *FSM

+ func (f *FSM) Apply(log *raft.Log) any

+ func (f *FSM) Restore(rc io.ReadCloser) error

+ func (f *FSM) Snapshot() (raft.FSMSnapshot, error)

+ type FSMHandleFunc func(*serverpb.RaftLogPayload) error

+ type KV interface

+ Delete func(context.Context, *serverpb.DeleteRequest) (*serverpb.DeleteResponse, error)

+ Get func(context.Context, *serverpb.GetRequest) (*serverpb.GetResponse, error)

+ PrefixScan func(context.Context, *serverpb.PrefixScanRequest) (*serverpb.PrefixScanResponse, error)

+ Set func(context.Context, *serverpb.SetRequest) (*serverpb.SetResponse, error)

+ TrySet func(context.Context, *serverpb.SetRequest) (*serverpb.SetResponse, error)

+ Watch func(*serverpb.WatchRequest, serverpb.KV_WatchServer) error

+ type Locker interface

+ Lock func(context.Context, *serverpb.LockRequest) (*serverpb.LockResponse, error)

+ TryLock func(context.Context, *serverpb.TryLockRequest) (*serverpb.TryLockResponse, error)

+ Unlock func(context.Context, *serverpb.UnlockRequest) (*serverpb.UnlockResponse, error)

+ type LockerBackendWrapper struct

+ func (w LockerBackendWrapper) Del(key []byte) error

+ func (w LockerBackendWrapper) Get(key []byte) (*store.Value, error)

+ func (w LockerBackendWrapper) TrySetWithTTL(key, value []byte, ttl uint32) error

+ func (w LockerBackendWrapper) Watch(key []byte) (store.WatcherNotify, error)

+ type Raft struct

+ func NewRaft(cfg RaftConfig) (*Raft, error)

+ func NewRaftWithOptions(opts ...RaftServerOption) (*Raft, error)

+ func (r *Raft) AddCluster(id raft.ServerID, addr raft.ServerAddress) error

+ type RaftConfig struct

+ Addr string

+ Bootstrap bool

+ Clusters []raft.Server

+ DataDir string

+ MaxSnapshots int

+ ServerID string

+ Store store.Store

+ type RaftServerOption func(*Raft) error

+ func RaftWithBoltLogStore(path string) RaftServerOption

+ func RaftWithBootstrap() RaftServerOption

+ func RaftWithClusters(clusters []raft.Server) RaftServerOption

+ func RaftWithConfig(cfg *raft.Config) RaftServerOption

+ func RaftWithEmpty() RaftServerOption

+ func RaftWithFileSnapshotStore(path string, retain int, logOut io.Writer) RaftServerOption

+ func RaftWithStdFSM(store store.Store) RaftServerOption

+ func RaftWithStdStableStore(store store.Store) RaftServerOption

+ func RaftWithTCPTransport(addr string, maxPool int, timeout time.Duration, logOut io.Writer) RaftServerOption

+ type RedQueen interface

+ AppendCluster func(context.Context, *serverpb.AppendClusterRequest) (*serverpb.AppendClusterResponse, error)

+ LeaderMonitor func(*serverpb.LeaderMonitorRequest, serverpb.RedQueen_LeaderMonitorServer) error

+ RaftState func(context.Context, *serverpb.RaftStateRequest) (*serverpb.RaftStateResponse, error)

+ type Server struct

+ func NewServer(cfg *config.Config) (*Server, error)

+ func (s *Server) AppendCluster(_ context.Context, req *serverpb.AppendClusterRequest) (*serverpb.AppendClusterResponse, error)

+ func (s *Server) Close() (err error)

+ func (s *Server) Delete(ctx context.Context, req *serverpb.DeleteRequest) (*serverpb.DeleteResponse, error)

+ func (s *Server) Get(_ context.Context, req *serverpb.GetRequest) (*serverpb.GetResponse, error)

+ func (s *Server) LeaderMonitor(_ *serverpb.LeaderMonitorRequest, stream serverpb.RedQueen_LeaderMonitorServer) error

+ func (s *Server) ListenServer() error

+ func (s *Server) Lock(_ context.Context, req *serverpb.LockRequest) (*serverpb.LockResponse, error)

+ func (s *Server) PrefixScan(_ context.Context, req *serverpb.PrefixScanRequest) (*serverpb.PrefixScanResponse, error)

+ func (s *Server) RaftState(_ context.Context, _ *serverpb.RaftStateRequest) (*serverpb.RaftStateResponse, error)

+ func (s *Server) Set(ctx context.Context, req *serverpb.SetRequest) (*serverpb.SetResponse, error)

+ func (s *Server) TryLock(_ context.Context, req *serverpb.TryLockRequest) (*serverpb.TryLockResponse, error)

+ func (s *Server) TrySet(ctx context.Context, req *serverpb.SetRequest) (*serverpb.SetResponse, error)

+ func (s *Server) Unlock(_ context.Context, req *serverpb.UnlockRequest) (*serverpb.UnlockResponse, error)

+ func (s *Server) Watch(req *serverpb.WatchRequest, stream serverpb.KV_WatchServer) error

+ type Snapshot struct

+ func (s *Snapshot) Persist(sink raft.SnapshotSink) error

+ func (s *Snapshot) Release()

+ type StableStore struct

+ func NewStableStore(s store.Store) (*StableStore, error)

+ func (s *StableStore) Get(key []byte) ([]byte, error)

+ func (s *StableStore) GetUint64(key []byte) (uint64, error)

+ func (s *StableStore) Set(key []byte, val []byte) error

+ func (s *StableStore) SetUint64(key []byte, val uint64) error