master

type AdminTaskManager struct {
	TaskMap map[string]*proto.AdminTask
	sync.RWMutex
	// contains filtered or unexported fields
}

type Cluster struct {
	Name string

	BadDataPartitionIds *sync.Map
	BadMetaPartitionIds *sync.Map
	DisableAutoAllocate bool

	MasterSecretKey []byte
	// contains filtered or unexported fields
}

type DataNode struct {
	Total          uint64 `json:"TotalWeight"`
	Used           uint64 `json:"UsedWeight"`
	AvailableSpace uint64
	ID             uint64
	ZoneName       string `json:"Zone"`
	Addr           string
	ReportTime     time.Time

	sync.RWMutex
	UsageRatio                float64 // used / total space
	SelectedTimes             uint64  // number times that this datanode has been selected as the location for a data partition.
	Carry                     float64 // carry is a factor used in cacluate the node's weight
	TaskManager               *AdminTaskManager
	DataPartitionReports      []*proto.PartitionReport
	DataPartitionCount        uint32
	NodeSetID                 uint64
	PersistenceDataPartitions []uint64
	BadDisks                  []string
	// contains filtered or unexported fields
}

type DataPartition struct {
	PartitionID    uint64
	LastLoadedTime int64
	ReplicaNum     uint8
	Status         int8

	Replicas []*DataReplica
	Hosts    []string // host addresses
	Peers    []proto.Peer
	sync.RWMutex

	MissingNodes map[string]int64 // key: address of the missing node, value: when the node is missing
	VolName      string
	VolID        uint64

	FileInCoreMap           map[string]*FileInCore
	FilesWithMissingReplica map[string]int64 // key: file name, value: last time when a missing replica is found
	// contains filtered or unexported fields
}

type DataPartitionMap struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type DataReplica struct {
	proto.DataReplica
	// contains filtered or unexported fields
}

type FileCrc struct {
	// contains filtered or unexported fields
}

type FileInCore struct {
	proto.FileInCore
	MetadataArray []*FileMetadata
}

type FileMetadata struct {
	proto.FileMetadata
	// contains filtered or unexported fields
}

type GetCarryNodes func(maxTotal uint64, excludeHosts []string, nodes *sync.Map) (weightedNodes SortedWeightedNodes, availCount int)

type GetMaxTotal func(nodes *sync.Map) (maxTotal uint64)

type IDAllocator struct {
	// contains filtered or unexported fields
}

type LeaderInfo struct {
	// contains filtered or unexported fields
}

type MetaNode struct {
	ID                uint64
	Addr              string
	IsActive          bool
	Sender            *AdminTaskManager
	ZoneName          string `json:"Zone"`
	MaxMemAvailWeight uint64 `json:"MaxMemAvailWeight"`
	Total             uint64 `json:"TotalWeight"`
	Used              uint64 `json:"UsedWeight"`
	Ratio             float64
	SelectCount       uint64
	Carry             float64
	Threshold         float32
	ReportTime        time.Time

	MetaPartitionCount int
	NodeSetID          uint64
	sync.RWMutex
	PersistenceMetaPartitions []uint64
	// contains filtered or unexported fields
}

type MetaPartition struct {
	PartitionID uint64
	Start       uint64
	End         uint64
	MaxInodeID  uint64
	Replicas    []*MetaReplica
	ReplicaNum  uint8
	Status      int8
	IsRecover   bool

	Hosts        []string
	Peers        []proto.Peer
	MissNodes    map[string]int64
	LoadResponse []*proto.MetaPartitionLoadResponse
	sync.RWMutex
	// contains filtered or unexported fields
}

type MetaReplica struct {
	Addr string

	MaxInodeID uint64
	ReportTime int64
	Status     int8 // unavailable, readOnly, readWrite
	IsLeader   bool
	// contains filtered or unexported fields
}

type MetadataFsm struct {
	// contains filtered or unexported fields
}

type MetadataSnapshot struct {
	// contains filtered or unexported fields
}

type Node interface {
	SetCarry(carry float64)
	SelectNodeForWrite()
	GetID() uint64
	GetAddr() string
}

type NodeView struct {
	Addr       string
	Status     bool
	ID         uint64
	IsWritable bool
}

type RaftCmd struct {
	Op uint32 `json:"op"`
	K  string `json:"k"`
	V  []byte `json:"v"`
}

type Server struct {
	// contains filtered or unexported fields
}

type SortedWeightedNodes []*weightedNode

type TokenValue struct {
	VolName   string
	Value     string
	TokenType int8
}

type TopologyView struct {
	Zones []*ZoneView
}

type User struct {
	AKStore sync.Map //K: ak, V: userID

	AKStoreMutex sync.RWMutex
	// contains filtered or unexported fields
}

type Vol struct {
	ID           uint64
	Name         string
	Owner        string
	OSSAccessKey string
	OSSSecretKey string

	Status uint8

	Capacity           uint64 // GB
	NeedToLowerReplica bool
	FollowerRead       bool

	MetaPartitions map[uint64]*MetaPartition

	sync.RWMutex
	// contains filtered or unexported fields
}

type Zone struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type ZoneView struct {
	Name    string
	Status  string
	NodeSet map[uint64]*nodeSetView
}