master

Jan 20, 2020

Changes in this version

type Cluster

+ BadMetaPartitionIds *sync.Map

type MetaPartition

+ IsRecover bool

type MetaReplica

+ MaxInodeID uint64

Jan 8, 2020

Changes in this version

+ const DefaultCellName

+ const SecretKey

+ type Cell struct

+ type CellView struct

+ DataNodes []NodeView

+ Name string

type Cluster

+ MasterSecretKey []byte

type DataNode

+ CellName string

type DataPartition

+ func (partition *DataPartition) ToProto() *proto.DataPartitionInfo

type FileInCore

+ func (fc FileInCore) ToProto() proto.FileInCore

type MetaNode

+ CellName string

type Vol

+ OSSAccessKey string

+ OSSSecretKey string

Nov 13, 2019

Changes in this version

+ const DefaultRackName

+ const MetricDataNodesInactive

+ const MetricDiskError

+ const MetricMetaNodesInactive

type DataNode

+ BadDisks []string

+ DataPartitionReports []*proto.PartitionReport

+ PersistenceDataPartitions []uint64

type MetaNode

+ PersistenceMetaPartitions []uint64

type MetaPartition

+ MaxInodeID uint64

type Vol

+ FollowerRead bool

+ NeedToLowerReplica bool

Apr 2, 2019

Changes in this version

+ const CfgRetainLogs

+ const ClusterName

+ const DefaultRetainLogs

+ const EmptyCrcValue

+ const GroupID

+ const ID

+ const IP

+ const LRUCacheSize

+ const LogLevel

+ const MaxTaskNum

+ const MetricDataNodesCount

+ const MetricDataNodesIncreasedGB

+ const MetricDataNodesTotalGB

+ const MetricDataNodesUsedGB

+ const MetricMetaNodesCount

+ const MetricMetaNodesIncreasedGB

+ const MetricMetaNodesTotalGB

+ const MetricMetaNodesUsedGB

+ const MetricVolCount

+ const MetricVolTotalGB

+ const MetricVolUsageGB

+ const MetricVolUsedGB

+ const ModuleName

+ const NumberOfDataPartitionsToLoad

+ const Port

+ const StatPeriod

+ const StoreDir

+ const TaskWorkerInterval

+ const WalDir

+ const WriteBufferSize

+ var AddrDatabase = make(map[uint64]string)

+ func Warn(clusterID, msg string)

+ func WarnBySpecialKey(key, msg string)

+ type AdminTaskManager struct

+ TaskMap map[string]*proto.AdminTask

+ func (sender *AdminTaskManager) AddTask(t *proto.AdminTask)

+ func (sender *AdminTaskManager) DelTask(t *proto.AdminTask)

+ type Cluster struct

+ BadDataPartitionIds *sync.Map

+ DisableAutoAllocate bool

+ Name string

+ type ClusterView struct

+ Applied uint64

+ BadPartitionIDs []badPartitionView

+ DataNodeStatInfo *nodeStatInfo

+ DataNodes []NodeView

+ DisableAutoAlloc bool

+ LeaderAddr string

+ MaxDataPartitionID uint64

+ MaxMetaNodeID uint64

+ MaxMetaPartitionID uint64

+ MetaNodeStatInfo *nodeStatInfo

+ MetaNodeThreshold float32

+ MetaNodes []NodeView

+ Name string

+ VolStatInfo []*volStatInfo

+ type DataNode struct

+ Addr string

+ AvailableSpace uint64

+ Carry float64

+ DataPartitionCount uint32

+ ID uint64

+ NodeSetID uint64

+ RackName string

+ ReportTime time.Time

+ SelectedTimes uint64

+ TaskManager *AdminTaskManager

+ Total uint64

+ UsageRatio float64

+ Used uint64

+ func (dataNode *DataNode) SelectNodeForWrite()

+ func (dataNode *DataNode) SetCarry(carry float64)

+ type DataPartition struct

+ FileInCoreMap map[string]*FileInCore

+ FilesWithMissingReplica map[string]int64

+ Hosts []string

+ LastLoadedTime int64

+ MissingNodes map[string]int64

+ PartitionID uint64

+ Peers []proto.Peer

+ ReplicaNum uint8

+ Replicas []*DataReplica

+ Status int8

+ VolID uint64

+ VolName string

+ type DataPartitionMap struct

+ type DataReplica struct

+ Addr string

+ DiskPath string

+ FileCount uint32

+ HasLoadResponse bool

+ IsLeader bool

+ NeedsToCompare bool

+ ReportTime int64

+ Status int8

+ Total uint64

+ Used uint64

+ type FileCrc struct

+ type FileInCore struct

+ LastModify int64

+ MetadataArray []*FileMetadata

+ Name string

+ type FileMetadata struct

+ Crc uint32

+ LocAddr string

+ Size uint32

+ func (fm *FileMetadata) String() (msg string)

+ type IDAllocator struct

+ type LeaderInfo struct

+ type MetaNode struct

+ Addr string

+ Carry float64

+ ID uint64

+ IsActive bool

+ MaxMemAvailWeight uint64

+ MetaPartitionCount int

+ NodeSetID uint64

+ RackName string

+ Ratio float64

+ ReportTime time.Time

+ SelectCount uint64

+ Sender *AdminTaskManager

+ Threshold float32

+ Total uint64

+ Used uint64

+ func (metaNode *MetaNode) SelectNodeForWrite()

+ func (metaNode *MetaNode) SetCarry(carry float64)

+ type MetaPartition struct

+ End uint64

+ Hosts []string

+ LoadResponse []*proto.MetaPartitionLoadResponse

+ MaxNodeID uint64

+ MissNodes map[string]int64

+ PartitionID uint64

+ Peers []proto.Peer

+ ReplicaNum uint8

+ Replicas []*MetaReplica

+ Start uint64

+ Status int8

+ type MetaReplica struct

+ Addr string

+ IsLeader bool

+ ReportTime int64

+ Status int8

+ type MetadataFsm struct

+ func (mf *MetadataFsm) Apply(command []byte, index uint64) (resp interface{}, err error)

+ func (mf *MetadataFsm) ApplyMemberChange(confChange *proto.ConfChange, index uint64) (interface{}, error)

+ func (mf *MetadataFsm) ApplySnapshot(peers []proto.Peer, iterator proto.SnapIterator) (err error)

+ func (mf *MetadataFsm) Del(key interface{}) (interface{}, error)

+ func (mf *MetadataFsm) Get(key interface{}) (interface{}, error)

+ func (mf *MetadataFsm) HandleFatalEvent(err *raft.FatalError)

+ func (mf *MetadataFsm) HandleLeaderChange(leader uint64)

+ func (mf *MetadataFsm) Put(key, val interface{}) (interface{}, error)

+ func (mf *MetadataFsm) Snapshot() (proto.Snapshot, error)

+ type MetadataSnapshot struct

+ func (ms *MetadataSnapshot) ApplyIndex() uint64

+ func (ms *MetadataSnapshot) Close()

+ func (ms *MetadataSnapshot) Next() (data []byte, err error)

+ type Node interface

+ SelectNodeForWrite func()

+ SetCarry func(carry float64)

+ type NodeView struct

+ Addr string

+ ID uint64

+ IsWritable bool

+ Status bool

+ type Rack struct

+ type RackView struct

+ DataNodes []NodeView

+ Name string

+ type RaftCmd struct

+ K string

+ Op uint32

+ V []byte

+ func (m *RaftCmd) Marshal() ([]byte, error)

+ func (m *RaftCmd) Unmarshal(data []byte) (err error)

+ type Server struct

+ func NewServer() *Server

+ func (m *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (m *Server) Shutdown()

+ func (m *Server) Start(cfg *config.Config) (err error)

+ func (m *Server) Sync()

+ type SortedWeightedNodes []*weightedNode

+ func (nodes SortedWeightedNodes) Len() int

+ func (nodes SortedWeightedNodes) Less(i, j int) bool

+ func (nodes SortedWeightedNodes) Swap(i, j int)

+ type TopologyView struct

+ NodeSet map[uint64]*nodeSetView

+ type Vol struct

+ Capacity uint64

+ ID uint64

+ MetaPartitions map[uint64]*MetaPartition

+ Name string

+ Owner string

+ Status uint8

+ func (vol *Vol) String() string

+ type VolStatView struct

+ Increased uint64

+ Name string

+ Total uint64

+ Used uint64