node

package

Go to main page

Versions in this module

v0

v0.9.4

Jul 19, 2021

Changes in this version

+ var ErrNotLeader = errors.New("not raft leader")

+ var ErrTransferLeaderSelfErr = errors.New("transfer leader to self not allowed")

+ func EnableSnapBlockingForTest(b bool)

+ func PutSnapBlockingTime(d time.Duration)

type KVNode

+ func (nd *KVNode) IsApplyingSnapshot() bool

+ func (nd *KVNode) TransferLeadership(toRaftID uint64) error

v0.9.3

May 19, 2021

Changes in this version

+ func ChangeSlowRefuseCost(v int64)

+ func HashedKey(pk []byte) int

v0.9.2

Jan 18, 2021

Changes in this version

+ var ErrLocalMagicCodeConflict = errors.New("namespace magic code conflict on local")

+ func LoadMagicCode(fileName string) (int64, error)

+ type CompactAPIRange struct

+ Dryrun bool

+ EndTo []byte

+ StartFrom []byte

type DeleteTableRange

+ NoReplayToRemoteCluster bool

type KVNode

+ func (nd *KVNode) DisableOptimizeDB(disable bool)

+ func (nd *KVNode) OptimizeDBAnyRange(r CompactAPIRange)

+ func (nd *KVNode) OptimizeDBExpire()

type NamespaceMgr

+ func (nsm *NamespaceMgr) DisableOptimizeDB(disable bool)

+ func (nsm *NamespaceMgr) GetDataRoot() string

+ func (nsm *NamespaceMgr) OptimizeDBAnyRange(ns string, r CompactAPIRange)

+ func (nsm *NamespaceMgr) OptimizeDBExpire(ns string)

type StateMachine

+ DisableOptimize func(bool)

+ OptimizeAnyRange func(CompactAPIRange)

+ OptimizeExpire func()

v0.9.1

Nov 26, 2020

Changes in this version

+ func MaybeConflictLogDisabled() bool

+ func SwitchDisableMaybeConflictLog(disable bool)

type NamespaceMgr

+ func (nsm *NamespaceMgr) CheckLocalNamespaces() map[string]int64

+ func (nsm *NamespaceMgr) CleanSharedNsFiles(baseNS string) error

v0.9.0

Sep 3, 2020

Changes in this version

+ func IsMaybeSlowWriteCmd(cmd string) bool

+ func IsSyncerNormalInit() bool

type IRaftPersistStorage

+ LoadNewestAvailable func(walSnaps []walpb.Snapshot) (*raftpb.Snapshot, error)

+ Release func(snap raftpb.Snapshot) error

+ Sync func() error

type KVNode

+ func (nd *KVNode) GetLearnerRole() string

+ func (nd *KVNode) GetRaftConfig() *RaftConfig

+ func (nd *KVNode) PreWaitQueue(ctx context.Context, cmd string, table string) (*SlowWaitDone, error)

type SlowLimiter

+ func (sl *SlowLimiter) PreWaitQueue(ctx context.Context, cmd string, prefix string) (*SlowWaitDone, error)

+ type SlowWaitDone struct

+ func (swd *SlowWaitDone) Done()

v0.8.4

Jun 9, 2020

Changes in this version

type NamespaceMgr

+ func (nsm *NamespaceMgr) ClearTopn(ns string)

+ func (nsm *NamespaceMgr) EnableTopn(ns string, on bool)

type StateMachine

+ ClearTopn func()

+ EnableTopn func(on bool)

v0.8.3

May 13, 2020

Changes in this version

+ var SlowHalfOpenSec = int64(15)

+ var SlowRefuseCostMs = int64(600)

+ func RegisterSlowConfChanged()

v0.8.2

Apr 26, 2020

Changes in this version

+ const SlowHalfOpen

+ const SlowRefuseCost

+ var ErrSlowLimiterRefused = errors.New("refused by slow limiter")

+ func EnableSlowLimiterTest(t bool)

type KVNode

+ func (nd *KVNode) CanPass(ts int64, cmd string, table string) bool

+ func (nd *KVNode) GetFullName() string

+ func (nd *KVNode) MaybeAddSlow(ts int64, cost time.Duration)

type NamespaceMgr

+ func (nsm *NamespaceMgr) HandleSlowLimiterSwitchChanged(v interface{})

+ type SlowLimiter struct

+ func NewSlowLimiter() *SlowLimiter

+ func (sl *SlowLimiter) AddSlow(ts int64)

+ func (sl *SlowLimiter) CanPass(ts int64, cmd string, prefix string) bool

+ func (sl *SlowLimiter) MarkHeavySlow()

+ func (sl *SlowLimiter) MaybeAddSlow(ts int64, cost time.Duration)

+ func (sl *SlowLimiter) RecordSlowCmd(cmd string, prefix string, cost time.Duration)

+ func (sl *SlowLimiter) Start()

+ func (sl *SlowLimiter) Stop()

+ func (sl *SlowLimiter) TurnOff()

+ func (sl *SlowLimiter) TurnOn()

v0.8.1

Apr 21, 2020

Changes in this version

type IBatchOperator

+ AbortBatchForError func(err error)

type KVNode

+ func (nd *KVNode) GetLastSnapIndex() uint64

+ func (nd *KVNode) SetLastSnapIndex(ci uint64)

type KVStore

+ func (s *KVStore) AbortBatch()

v0.8.0

Mar 5, 2020

Changes in this version

+ const RedisV2Req

+ var UseRedisV2 = false

+ type FutureRsp struct

+ func (fr *FutureRsp) WaitRsp() (interface{}, error)

type KVNode

+ func (nd *KVNode) GetWriteHandler(cmd string) (common.WriteCommandFunc, bool)

+ func (nd *KVNode) ProposeRawAndWaitFromSyncer(reqList *BatchInternalRaftRequest, term uint64, index uint64, raftTs int64) error

+ func (nd *KVNode) ProposeRawAsyncFromSyncer(buffer []byte, reqList *BatchInternalRaftRequest, term uint64, index uint64, ...) (*FutureRsp, *BatchInternalRaftRequest, error)

+ func (nd *KVNode) RedisPropose(buf []byte) (interface{}, error)

+ func (nd *KVNode) RedisProposeAsync(buf []byte) (*FutureRsp, error)

+ func (nd *KVNode) RedisV2ProposeAsync(buf []byte) (*FutureRsp, error)

+ func (nd *KVNode) UpdateWriteStats(vSize int64, latencyUs int64)

type KVOptions

+ DataVersion common.DataVersionT

type NamespaceConfig

+ DataVersion string

type NamespaceMgr

+ func (nsm *NamespaceMgr) GetNamespaceNodeWithPrimaryKeySum(nsBaseName string, pk []byte, pkSum int) (*NamespaceNode, error)

v0.7.2

Jan 3, 2020

v0.7.1

Dec 25, 2019

Changes in this version

+ func CopyFileForHardLink(src, dst string) error

type BatchInternalRaftRequest

+ func (m *BatchInternalRaftRequest) XXX_DiscardUnknown()

+ func (m *BatchInternalRaftRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BatchInternalRaftRequest) XXX_Merge(src proto.Message)

+ func (m *BatchInternalRaftRequest) XXX_Size() int

+ func (m *BatchInternalRaftRequest) XXX_Unmarshal(b []byte) error

type DataStorage

+ UpdateSnapshotState func(term uint64, index uint64)

type InternalRaftRequest

+ func (m *InternalRaftRequest) XXX_DiscardUnknown()

+ func (m *InternalRaftRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *InternalRaftRequest) XXX_Merge(src proto.Message)

+ func (m *InternalRaftRequest) XXX_Size() int

+ func (m *InternalRaftRequest) XXX_Unmarshal(b []byte) error

type KVNode

+ func (nd *KVNode) ProposeInternal(ctx context.Context, irr InternalRaftRequest, cancel context.CancelFunc, ...) (*waitReqHeaders, error)

+ func (nd *KVNode) SetMaxBackgroundOptions(maxCompact int, maxBackJobs int) error

+ func (nd *KVNode) UpdateSnapshotState(term uint64, index uint64)

type NamespaceMgr

+ func (nsm *NamespaceMgr) SetDBOptions(key string, value string) error

+ func (nsm *NamespaceMgr) SetMaxBackgroundOptions(maxCompact int, maxBackJobs int) error

+ func (nsm *NamespaceMgr) SetRateLimiterBytesPerSec(bytesPerSec int64)

type RequestHeader

+ func (m *RequestHeader) XXX_DiscardUnknown()

+ func (m *RequestHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RequestHeader) XXX_Merge(src proto.Message)

+ func (m *RequestHeader) XXX_Size() int

+ func (m *RequestHeader) XXX_Unmarshal(b []byte) error

type SchemaChange

+ func (m *SchemaChange) XXX_DiscardUnknown()

+ func (m *SchemaChange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SchemaChange) XXX_Merge(src proto.Message)

+ func (m *SchemaChange) XXX_Size() int

+ func (m *SchemaChange) XXX_Unmarshal(b []byte) error

type StateMachine

+ UpdateSnapshotState func(term uint64, index uint64)

v0.7.0

Oct 7, 2019

Changes in this version

+ type IBatchOperator interface

+ AddBatchKey func(string)

+ AddBatchRsp func(uint64, interface{})

+ BeginBatch func() error

+ CommitBatch func()

+ IsBatchable func(string, string) bool

+ IsBatched func() bool

+ SetBatched func(bool)

+ type RequestResultCode int

+ const ReqCancelled

+ const ReqComplete

+ const ReqTimeouted

type StateMachine

+ GetBatchOperator func() IBatchOperator

v0.6.3

Jul 30, 2019

Changes in this version

+ var ErrReadIndexTimeout = errors.New("wait read index timeout")

+ func EnableSnapForTest(transfer bool, save bool, apply bool, restore bool)

type DataStorage

+ PrepareSnapshot func(raftpb.Snapshot) error

type KVNode

+ func (nd *KVNode) GetAppliedIndex() uint64

+ func (nd *KVNode) PrepareSnapshot(raftSnapshot raftpb.Snapshot) error

+ func (nd *KVNode) SetAppliedIndex(ci uint64)

type StateMachine

+ PrepareSnapshot func(raftSnapshot raftpb.Snapshot, stop chan struct{}) error

v0.6.2

Jun 27, 2019

Changes in this version

type KVNode

+ func (nd *KVNode) IsStopping() bool

+ func (nd *KVNode) SetDynamicInfo(dync NamespaceDynamicConf)

type NamespaceDynamicConf

+ Replicator int

v0.6.0

Apr 29, 2019

Changes in this version

+ var ErrNamespaceAlreadyStarting = errors.New("namespace is starting")

type KVNode

+ func (nd *KVNode) GetWALDBInternalStats() map[string]interface{}

type MachineConfig

+ SharedRocksWAL bool

+ UseRocksWAL bool

+ WALRocksDBOpts engine.RockOptions

+ WALRocksDBSharedConfig *engine.SharedRockConfig

type NamespaceMgr

+ func (nsm *NamespaceMgr) GetWALDBStats(leaderOnly bool) map[string]map[string]interface{}

type RaftConfig

+ RaftStorageDir string

+ func (rc *RaftConfig) SetEng(eng *engine.RockEng)

v0.5.3

Mar 13, 2019

v0.5.2

Jan 24, 2019

Changes in this version

+ const Conflict

+ const MaybeConflict

+ const NoConflict

+ type ConflictState int

type KVNode

+ func (nd *KVNode) BackupDB()

type KVOptions

+ KeepBackup int

type MachineConfig

+ KeepBackup int

type NamespaceMgr

+ func (nsm *NamespaceMgr) BackupDB(ns string)

v0.4.3

Jul 21, 2018

Changes in this version

+ func GetSyncedOnlyChangedTs() int64

v0.4.0

May 23, 2018

Changes in this version

+ func GetLogLatencyStats() (*common.WriteStats, *common.WriteStats)

type KVNode

+ func (nd *KVNode) GetLogSyncStatsInSyncLearner() (*common.LogSyncStats, *common.LogSyncStats)

type NamespaceMgr

+ func (nsm *NamespaceMgr) GetLogSyncStatsInSyncer() ([]common.LogSyncStats, []common.LogSyncStats)

type SyncedState

+ Timestamp int64

+ func (ss *SyncedState) IsSame(other *SyncedState) bool

v0.3.2

May 10, 2018

Changes in this version

+ const ProposeOp_DeleteTable

+ func GetPerfLevel() int

+ func IsPerfEnabled() bool

+ func SetPerfLevel(level int)

+ type DeleteTableRange struct

+ DeleteAll bool

+ Dryrun bool

+ EndTo []byte

+ StartFrom []byte

+ Table string

+ func (dtr DeleteTableRange) CheckValid() error

type KVNode

+ func (nd *KVNode) DeleteRange(drange DeleteTableRange) error

type KVOptions

+ SharedConfig *rockredis.SharedRockConfig

type MachineConfig

+ RocksDBSharedConfig *rockredis.SharedRockConfig

type NamespaceMgr

+ func (nsm *NamespaceMgr) DeleteRange(ns string, dtr DeleteTableRange) error

v0.3.0

Apr 8, 2018

Changes in this version

+ const ApplySnapApplying

+ const ApplySnapBegin

+ const ApplySnapDone

+ const ApplySnapFailed

+ const ApplySnapTransferred

+ const ApplySnapTransferring

+ const ApplySnapUnknown

+ const CustomReq

+ const DefaultSnapCount

+ const HealthInterval

+ const ProposeOp_ApplyRemoteSnap

+ const ProposeOp_ApplySkippedRemoteSnap

+ const ProposeOp_Backup

+ const ProposeOp_RemoteConfChange

+ const ProposeOp_TransferRemoteSnap

+ const RADIUS_COORDS

+ const RADIUS_MEMBER

+ const RedisReq

+ const SORT_ASC

+ const SORT_DESC

+ const SORT_NONE

+ const SchemaChangeReq

+ var ErrExpiredBatchedBuffFull = errors.New("the expired data batched buffer is full now")

+ var ErrIntOverflowRaftInternal = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthRaftInternal = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrNamespaceAlreadyExist = errors.New("namespace already exist")

+ var ErrNamespaceNotFound = errors.New("ERR_CLUSTER_CHANGED: namespace is not found")

+ var ErrNamespaceNotLeader = errors.New("ERR_CLUSTER_CHANGED: partition of the namespace is not leader on the node")

+ var ErrNamespacePartitionNotFound = errors.New("ERR_CLUSTER_CHANGED: partition of the namespace is not found")

+ var ErrNodeNoLeader = errors.New("ERR_CLUSTER_CHANGED: partition of the node has no leader")

+ var ErrProposalCanceled = errors.New("ERR_CLUSTER_CHANGED: raft proposal " + context.Canceled.Error())

+ var ErrRaftConfMismatch = errors.New("raft config mismatch")

+ var ErrRaftGroupNotReady = errors.New("ERR_CLUSTER_CHANGED: raft group not ready")

+ var ErrRaftIDMismatch = errors.New("raft id mismatch")

+ var ReqSourceType_name = map[int32]string

+ var ReqSourceType_value = map[string]int32

+ var SchemaChangeType_name = map[int32]string

+ var SchemaChangeType_value = map[string]int32

+ func EnableForTest()

+ func GetHashedPartitionID(pk []byte, pnum int) int

+ func GetValidBackupInfo(machineConfig MachineConfig, clusterInfo common.IClusterInfo, fullNS string, ...) (string, string)

+ func IsSyncerOnly() bool

+ func NewConflictRouter() *conflictRouter

+ func NewKVStoreSM(opts *KVOptions, machineConfig MachineConfig, localID uint64, ns string, ...) (*kvStoreSM, error)

+ func NewLogSyncerSM(opts *KVOptions, machineConfig MachineConfig, localID uint64, fullNS string, ...) (*logSyncerSM, error)

+ func SetLogLevel(level int)

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

+ func SetSyncerNormalInit()

+ func SetSyncerOnly(enable bool)

+ type BatchInternalRaftRequest struct

+ OrigCluster string

+ OrigIndex uint64

+ OrigTerm uint64

+ ReqId uint64

+ ReqNum int32

+ Reqs []*InternalRaftRequest

+ Timestamp int64

+ Type ReqSourceType

+ func (*BatchInternalRaftRequest) Descriptor() ([]byte, []int)

+ func (*BatchInternalRaftRequest) ProtoMessage()

+ func (m *BatchInternalRaftRequest) Marshal() (dAtA []byte, err error)

+ func (m *BatchInternalRaftRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *BatchInternalRaftRequest) Reset()

+ func (m *BatchInternalRaftRequest) Size() (n int)

+ func (m *BatchInternalRaftRequest) String() string

+ func (m *BatchInternalRaftRequest) Unmarshal(dAtA []byte) error

+ type ConflictCheckFunc func(redcon.Command, int64) bool

+ type DataStorage interface

+ CleanData func() error

+ GetSnapshot func(term uint64, index uint64) (Snapshot, error)

+ RestoreFromSnapshot func(bool, raftpb.Snapshot) error

+ Stop func()

+ type ExpireHandler struct

+ func NewExpireHandler(node *KVNode) *ExpireHandler

+ func (exp *ExpireHandler) LeaderChanged()

+ func (exp *ExpireHandler) Start()

+ func (exp *ExpireHandler) Stop()

+ type HindexSearchResults struct

+ Rets []common.HIndexRespWithValues

+ Table string

+ type IRaftPersistStorage interface

+ Close func() error

+ Load func() (*raftpb.Snapshot, string, error)

+ Save func(st raftpb.HardState, ents []raftpb.Entry) error

+ SaveSnap func(snap raftpb.Snapshot) error

+ func NewRaftPersistStorage(w *wal.WAL, s *snap.Snapshotter) IRaftPersistStorage

+ type InternalRaftRequest struct

+ Data []byte

+ Header *RequestHeader

+ func (*InternalRaftRequest) Descriptor() ([]byte, []int)

+ func (*InternalRaftRequest) ProtoMessage()

+ func (m *InternalRaftRequest) Marshal() (dAtA []byte, err error)

+ func (m *InternalRaftRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *InternalRaftRequest) Reset()

+ func (m *InternalRaftRequest) Size() (n int)

+ func (m *InternalRaftRequest) String() string

+ func (m *InternalRaftRequest) Unmarshal(dAtA []byte) error

+ type KVNode struct

+ func NewKVNode(kvopts *KVOptions, machineConfig *MachineConfig, config *RaftConfig, ...) (*KVNode, error)

+ func (nd *KVNode) ApplyRemoteSnapshot(skip bool, name string, term uint64, index uint64) error

+ func (nd *KVNode) BeginTransferRemoteSnap(name string, term uint64, index uint64, syncAddr string, syncPath string) error

+ func (nd *KVNode) CheckLocalBackup(snapData []byte) (bool, error)

+ func (nd *KVNode) CleanData() error

+ func (nd *KVNode) CustomPropose(buf []byte) (interface{}, error)

+ func (nd *KVNode) FillMyMemberInfo(m *common.MemberInfo)

+ func (nd *KVNode) GetApplyRemoteSnapStatus(name string) (*SnapApplyStatus, bool)

+ func (nd *KVNode) GetCommittedIndex() uint64

+ func (nd *KVNode) GetDBInternalStats() string

+ func (nd *KVNode) GetHandler(cmd string) (common.CommandFunc, bool, bool)

+ func (nd *KVNode) GetIndexSchema(table string) (map[string]*common.IndexSchema, error)

+ func (nd *KVNode) GetLastLeaderChangedTime() int64

+ func (nd *KVNode) GetLeadMember() *common.MemberInfo

+ func (nd *KVNode) GetLearners() []*common.MemberInfo

+ func (nd *KVNode) GetLocalMemberInfo() *common.MemberInfo

+ func (nd *KVNode) GetMembers() []*common.MemberInfo

+ func (nd *KVNode) GetMergeHandler(cmd string) (common.MergeCommandFunc, bool, bool)

+ func (nd *KVNode) GetRaftStatus() raft.Status

+ func (nd *KVNode) GetRemoteClusterSyncedRaft(name string) (uint64, uint64)

+ func (nd *KVNode) GetSnapshot(term uint64, index uint64) (Snapshot, error)

+ func (nd *KVNode) GetStats() common.NamespaceStats

+ func (nd *KVNode) IsLead() bool

+ func (nd *KVNode) IsPeerRemoved(peerID uint64) bool

+ func (nd *KVNode) IsRaftSynced(checkCommitIndex bool) bool

+ func (nd *KVNode) IsReplicaRaftReady(raftID uint64) bool

+ func (nd *KVNode) IsWriteReady() bool

+ func (nd *KVNode) Lookup(key []byte) ([]byte, error)

+ func (nd *KVNode) OnRaftLeaderChanged()

+ func (nd *KVNode) OptimizeDB()

+ func (nd *KVNode) Process(ctx context.Context, m raftpb.Message) error

+ func (nd *KVNode) Propose(buf []byte) (interface{}, error)

+ func (nd *KVNode) ProposeAddLearner(m common.MemberInfo) error

+ func (nd *KVNode) ProposeAddMember(m common.MemberInfo) error

+ func (nd *KVNode) ProposeChangeTableSchema(table string, sc *SchemaChange) error

+ func (nd *KVNode) ProposeRawAndWait(buffer []byte, term uint64, index uint64, raftTs int64) error

+ func (nd *KVNode) ProposeRemoveMember(m common.MemberInfo) error

+ func (nd *KVNode) ProposeUpdateMember(m common.MemberInfo) error

+ func (nd *KVNode) ReportMeLeaderToCluster()

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

+ func (nd *KVNode) ReportUnreachable(id uint64, group raftpb.Group)

+ func (nd *KVNode) RestoreFromSnapshot(startup bool, raftSnapshot raftpb.Snapshot) error

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

+ func (nd *KVNode) SetCommittedIndex(ci uint64)

+ func (nd *KVNode) SetRemoteClusterSyncedRaft(name string, term uint64, index uint64)

+ func (nd *KVNode) Start(standalone bool) error

+ func (nd *KVNode) Stop()

+ func (nd *KVNode) StopRaft()

+ func (nd *KVNode) Tick()

+ type KVOptions struct

+ DataDir string

+ EngType string

+ ExpirationPolicy common.ExpirationPolicy

+ RockOpts rockredis.RockOptions

+ type KVSnapInfo struct

+ BackupMeta []byte

+ LeaderInfo *common.MemberInfo

+ Learners []*common.MemberInfo

+ Members []*common.MemberInfo

+ RemoteSyncedStates map[string]SyncedState

+ Ver int

+ func (si *KVSnapInfo) GetData() ([]byte, error)

+ type KVStore struct

+ func NewKVStore(kvopts *KVOptions) (*KVStore, error)

+ func (s *KVStore) BeginBatchWrite() error

+ func (s *KVStore) CheckExpiredData(buffer common.ExpiredDataBuffer, stop chan struct{}) error

+ func (s *KVStore) CleanData() error

+ func (s *KVStore) CommitBatchWrite() error

+ func (s *KVStore) Destroy() error

+ func (s *KVStore) IsBatchableWrite(cmdName string) bool

+ func (s *KVStore) LocalDelete(key []byte) (int64, error)

+ func (s *KVStore) LocalLookup(key []byte) ([]byte, error)

+ func (s *KVStore) LocalPut(ts int64, key []byte, value []byte) error

+ func (s *KVStore) LocalWriteBatch(cmd ...common.WriteCmd) error

+ type MachineConfig struct

+ BroadcastAddr string

+ DataRootDir string

+ ElectionTick int

+ HttpAPIPort int

+ KeepWAL int

+ LearnerRole string

+ LocalRaftAddr string

+ NodeID uint64

+ RemoteSyncCluster string

+ RocksDBOpts rockredis.RockOptions

+ StateMachineType string

+ TickMs int

+ type NamespaceConfig struct

+ BaseName string

+ EngType string

+ ExpirationPolicy string

+ Name string

+ OptimizedFsync bool

+ PartitionNum int

+ RaftGroupConf RaftGroupConfig

+ Replicator int

+ SnapCatchup int

+ SnapCount int

+ func NewNSConfig() *NamespaceConfig

+ type NamespaceDynamicConf struct

+ type NamespaceMeta struct

+ PartitionNum int

+ type NamespaceMgr struct

+ func NewNamespaceMgr(transport *rafthttp.Transport, conf *MachineConfig) *NamespaceMgr

+ func (nsm *NamespaceMgr) CheckMagicCode(ns string, magic int64, fix bool) error

+ func (nsm *NamespaceMgr) GetDBStats(leaderOnly bool) map[string]string

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

+ func (nsm *NamespaceMgr) GetNamespaceNode(ns string) *NamespaceNode

+ func (nsm *NamespaceMgr) GetNamespaceNodeFromGID(gid uint64) *NamespaceNode

+ func (nsm *NamespaceMgr) GetNamespaceNodeWithPrimaryKey(nsBaseName string, pk []byte) (*NamespaceNode, error)

+ func (nsm *NamespaceMgr) GetNamespaceNodes(nsBaseName string, leaderOnly bool) (map[string]*NamespaceNode, error)

+ func (nsm *NamespaceMgr) GetNamespaces() map[string]*NamespaceNode

+ func (nsm *NamespaceMgr) GetStats(leaderOnly bool) []common.NamespaceStats

+ func (nsm *NamespaceMgr) InitNamespaceNode(conf *NamespaceConfig, raftID uint64, join bool) (*NamespaceNode, error)

+ func (nsm *NamespaceMgr) IsAllRecoveryDone() bool

+ func (nsm *NamespaceMgr) LoadMachineRegID() (uint64, error)

+ func (nsm *NamespaceMgr) OptimizeDB()

+ func (nsm *NamespaceMgr) SaveMachineRegID(regID uint64) error

+ func (nsm *NamespaceMgr) SetIClusterInfo(clusterInfo common.IClusterInfo)

+ func (nsm *NamespaceMgr) SetNamespaceMagicCode(node *NamespaceNode, magic int64) error

+ func (nsm *NamespaceMgr) Start()

+ func (nsm *NamespaceMgr) Stop()

+ type NamespaceNode struct

+ Node *KVNode

+ func (nn *NamespaceNode) CheckRaftConf(raftID uint64, conf *NamespaceConfig) error

+ func (nn *NamespaceNode) Close()

+ func (nn *NamespaceNode) Destroy() error

+ func (nn *NamespaceNode) FullName() string

+ func (nn *NamespaceNode) GetLastLeaderChangedTime() int64

+ func (nn *NamespaceNode) GetLearners() []*common.MemberInfo

+ func (nn *NamespaceNode) GetMembers() []*common.MemberInfo

+ func (nn *NamespaceNode) GetRaftID() uint64

+ func (nn *NamespaceNode) IsDataNeedFix() bool

+ func (nn *NamespaceNode) IsNsNodeFullReady(checkCommitIndex bool) bool

+ func (nn *NamespaceNode) IsReady() bool

+ func (nn *NamespaceNode) SetDataFixState(needFix bool)

+ func (nn *NamespaceNode) SetDynamicInfo(dync NamespaceDynamicConf)

+ func (nn *NamespaceNode) SetMagicCode(magic int64) error

+ func (nn *NamespaceNode) Start(forceStandaloneCluster bool) error

+ func (nn *NamespaceNode) SwitchForLearnerLeader(isLearnerLeader bool)

+ func (nn *NamespaceNode) TransferMyLeader(to uint64, toRaftID uint64) error

+ type RaftConfig struct

+ DataDir string

+ GroupID uint64

+ GroupName string

+ ID uint64

+ KeepWAL int

+ OptimizedFsync bool

+ RaftAddr string

+ RaftPeers map[uint64]ReplicaInfo

+ Replicator int

+ SnapCatchup int

+ SnapCount int

+ SnapDir string

+ WALDir string

+ type RaftGroupConfig struct

+ GroupID uint64

+ SeedNodes []ReplicaInfo

+ type RaftRpcFunc func() error

+ type RemoteLogSender struct

+ func NewRemoteLogSender(localCluster string, fullName string, remoteCluster string) (*RemoteLogSender, error)

+ func (s *RemoteLogSender) GetStats() interface{}

+ func (s *RemoteLogSender) Stop()

+ type ReplicaInfo struct

+ NodeID uint64

+ RaftAddr string

+ ReplicaID uint64

+ type ReqSourceType int32

+ const FromAPI

+ const FromClusterSyncer

+ func (ReqSourceType) EnumDescriptor() ([]byte, []int)

+ func (x ReqSourceType) String() string

+ type RequestHeader struct

+ DataType int32

+ ID uint64

+ Timestamp int64

+ func (*RequestHeader) Descriptor() ([]byte, []int)

+ func (*RequestHeader) ProtoMessage()

+ func (m *RequestHeader) Marshal() (dAtA []byte, err error)

+ func (m *RequestHeader) MarshalTo(dAtA []byte) (int, error)

+ func (m *RequestHeader) Reset()

+ func (m *RequestHeader) Size() (n int)

+ func (m *RequestHeader) String() string

+ func (m *RequestHeader) Unmarshal(dAtA []byte) error

+ type SchemaChange struct

+ SchemaData []byte

+ Table string

+ Type SchemaChangeType

+ func (*SchemaChange) Descriptor() ([]byte, []int)

+ func (*SchemaChange) ProtoMessage()

+ func (m *SchemaChange) Marshal() (dAtA []byte, err error)

+ func (m *SchemaChange) MarshalTo(dAtA []byte) (int, error)

+ func (m *SchemaChange) Reset()

+ func (m *SchemaChange) Size() (n int)

+ func (m *SchemaChange) String() string

+ func (m *SchemaChange) Unmarshal(dAtA []byte) error

+ type SchemaChangeType int32

+ const SchemaChangeAddHsetIndex

+ const SchemaChangeDeleteHsetIndex

+ const SchemaChangeUpdateHsetIndex

+ func (SchemaChangeType) EnumDescriptor() ([]byte, []int)

+ func (x SchemaChangeType) String() string

+ type SnapApplyStatus struct

+ SS SyncedState

+ Status string

+ StatusCode int

+ UpdatedTime time.Time

+ type Snapshot interface

+ GetData func() ([]byte, error)

+ type StateMachine interface

+ ApplyRaftConfRequest func(req raftpb.ConfChange, term uint64, index uint64, stop chan struct{}) error

+ ApplyRaftRequest func(isReplaying bool, req BatchInternalRaftRequest, term uint64, index uint64, ...) (bool, error)

+ CheckExpiredData func(buffer common.ExpiredDataBuffer, stop chan struct{}) error

+ CleanData func() error

+ Close func()

+ Destroy func()

+ GetSnapshot func(term uint64, index uint64) (*KVSnapInfo, error)

+ GetStats func() common.NamespaceStats

+ Optimize func()

+ RestoreFromSnapshot func(startup bool, raftSnapshot raftpb.Snapshot, stop chan struct{}) error

+ Start func() error

+ func NewStateMachine(opts *KVOptions, machineConfig MachineConfig, localID uint64, fullNS string, ...) (StateMachine, error)

+ type SyncedState struct

+ SyncedIndex uint64

+ SyncedTerm uint64

+ func (ss *SyncedState) IsNewer(other *SyncedState) bool

+ func (ss *SyncedState) IsNewer2(term uint64, index uint64) bool

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