server

May 19, 2021

Changes in this version

type ServerConfig

+ SlowLimiterRefuseCostMs int64

Jan 18, 2021

Changes in this version

type ServerConfig

+ MetricAddr string

Sep 3, 2020

Changes in this version

type ServerConfig

+ RemoteLogAddr string

Apr 26, 2020

Changes in this version

+ func GetPKAndHashSum(cmdName string, cmd redcon.Command) (string, []byte, int, error)

Apr 21, 2020

Changes in this version

type ServerConfig

+ LogDir string

Mar 5, 2020

Changes in this version

type Server

+ func (s *Server) GetHandleNode(ns string, pk []byte, pkSum int, cmdName string, cmd redcon.Command) (*node.KVNode, error)

+ func (s *Server) GetPKAndHashSum(cmdName string, cmd redcon.Command) (string, []byte, int, error)

+ func (s *Server) GetWriteHandler(cmdName string, cmd redcon.Command, kvn *node.KVNode) (common.WriteCommandFunc, redcon.Command, error)

type ServerConfig

+ UseRedisV2 bool

Jul 30, 2019

Changes in this version

type Server

+ func (s *Server) GetNsMgr() *node.NamespaceMgr

Apr 29, 2019

Changes in this version

type Server

+ func (s *Server) GetWALDBStats(leaderOnly bool) map[string]map[string]interface{}

type ServerConfig

+ SharedRocksWAL bool

+ UseRocksWAL bool

+ WALRocksDBOpts engine.RockOptions

Jan 24, 2019

Changes in this version

type ServerConfig

+ DefaultSnapCatchup int

+ DefaultSnapCount int

+ KeepBackup int

+ KeepWAL int

Jul 21, 2018

Changes in this version

+ type CustomRaftStatus struct

+ Applied uint64

+ Commit uint64

+ ID uint64

+ Lead uint64

+ LeadTransferee uint64

+ Progress map[uint64]RaftProgress

+ RaftState string

+ Term uint64

+ Vote uint64

+ func (crs *CustomRaftStatus) Init(s raft.Status)

+ type RaftProgress struct

+ Match uint64

+ Next uint64

+ State string

type Server

+ func (s *Server) GetTableStats(leaderOnly bool, table string) map[string]common.TableStats

type ServerConfig

+ RsyncLimit int64

May 23, 2018

Changes in this version

type Server

+ func (s *Server) GetLogSyncStatsInSyncLearner() ([]common.LogSyncStats, []common.LogSyncStats)

May 10, 2018

Changes in this version

type Server

+ func (s *Server) DeleteRange(ns string, dtr node.DeleteTableRange) error

Apr 8, 2018

Changes in this version

+ var ErrDisabled = errors.New("disabled")

+ var ErrUnknownCommand = errors.New("unknown command")

+ var ErrWrongNumberOfArguments = errors.New("wrong number of arguments")

+ func GetIPv4ForInterfaceName(ifname string) string

+ func SLogger() *common.LevelLogger

+ func SetLogger(level int32, logger common.Logger)

+ type ConfigFile struct

+ ServerConf ServerConfig

+ type NamespaceNodeConfig struct

+ LocalReplicaID uint64

+ Name string

+ type RaftStatus struct

+ LeaderInfo *common.MemberInfo

+ Learners []*common.MemberInfo

+ Members []*common.MemberInfo

+ RaftStat raft.Status

+ type Server struct

+ func NewServer(conf ServerConfig) *Server

+ func (s *Server) ApplyRaftReqs(ctx context.Context, reqs *syncerpb.RaftReqs) (*syncerpb.RpcErr, error)

+ func (s *Server) GetApplySnapStatus(ctx context.Context, req *syncerpb.RaftApplySnapStatusReq) (*syncerpb.RaftApplySnapStatusRsp, error)

+ func (s *Server) GetCoord() *datanode_coord.DataCoordinator

+ func (s *Server) GetDBStats(leaderOnly bool) map[string]string

+ func (s *Server) GetHandler(cmdName string, cmd redcon.Command) (bool, common.CommandFunc, redcon.Command, error)

+ func (s *Server) GetLogSyncStats(leaderOnly bool, srcClusterName string) []common.LogSyncStats

+ func (s *Server) GetMergeHandlers(cmd redcon.Command) ([]common.MergeCommandFunc, []redcon.Command, bool, error)

+ func (s *Server) GetNamespace(ns string, pk []byte) (*node.NamespaceNode, error)

+ func (s *Server) GetNamespaceFromFullName(ns string) *node.NamespaceNode

+ func (s *Server) GetStats(leaderOnly bool) common.ServerStats

+ func (s *Server) GetSyncedRaft(ctx context.Context, req *syncerpb.SyncedRaftReq) (*syncerpb.SyncedRaftRsp, error)

+ func (s *Server) InitKVNamespace(id uint64, conf *node.NamespaceConfig, join bool) (*node.NamespaceNode, error)

+ func (s *Server) IsPeerRemoved(peerID uint64) bool

+ func (s *Server) NotifyApplySnap(ctx context.Context, req *syncerpb.RaftApplySnapReq) (*syncerpb.RpcErr, error)

+ func (s *Server) NotifyTransferSnap(ctx context.Context, req *syncerpb.RaftApplySnapReq) (*syncerpb.RpcErr, error)

+ func (s *Server) OptimizeDB()

+ func (s *Server) Process(ctx context.Context, m raftpb.Message) error

+ func (s *Server) ReportSnapshot(id uint64, gp raftpb.Group, status raft.SnapshotStatus)

+ func (s *Server) ReportUnreachable(id uint64, group raftpb.Group)

+ func (s *Server) RestartAsStandalone(fullNamespace string) error

+ func (s *Server) SaveDBFrom(r io.Reader, msg raftpb.Message) (int64, error)

+ func (s *Server) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ func (s *Server) Start()

+ func (s *Server) Stop()

+ type ServerConfig struct

+ BroadcastAddr string

+ BroadcastInterface string

+ ClusterID string

+ DataDir string

+ DataRsyncModule string

+ ElectionTick int

+ EtcdClusterAddresses string

+ GrpcAPIPort int

+ HttpAPIPort int

+ LearnerRole string

+ LocalRaftAddr string

+ MaxScanJob int32

+ Namespaces []NamespaceNodeConfig

+ ProfilePort int

+ RedisAPIPort int

+ RemoteSyncCluster string

+ RocksDBOpts rockredis.RockOptions

+ StateMachineType string

+ SyncerNormalInit bool

+ SyncerWriteOnly bool

+ Tags map[string]string

+ TickMs int