datanode

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

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

type DataPartition interface {
	ID() uint32
	Path() string
	IsLeader() bool
	ReplicaHosts() []string
	Disk() *Disk

	Size() int
	Used() int
	Available() int

	Status() int
	ChangeStatus(status int)

	GetExtentStore() *storage.ExtentStore
	GetBlobStore() *storage.BlobStore

	GetObjects(blobfileID uint32, startOid, lastOid uint64) (objects []*storage.Object)
	PackObject(dataBuf []byte, o *storage.Object, blobfileID uint32) (err error)
	DelObjects(blobfileId uint32, deleteBuf []byte) (err error)

	LaunchRepair()
	MergeExtentStoreRepair(metas *MembersFileMetas)
	MergeBlobStoreRepair(metas *MembersFileMetas)
	FlushDelete() error

	AddWriteMetrics(latency uint64)
	AddReadMetrics(latency uint64)

	Stop()
}

type DataPartitionMetrics struct {
	WriteCnt        uint64
	ReadCnt         uint64
	SumWriteLatency uint64
	SumReadLatency  uint64
	WriteLatency    float64
	ReadLatency     float64
	// contains filtered or unexported fields
}

type Disk struct {
	sync.RWMutex
	Path        string
	ReadErrs    uint64
	WriteErrs   uint64
	Total       uint64
	Used        uint64
	Available   uint64
	Unallocated uint64
	Allocated   uint64
	MaxErrs     int
	Status      int
	RestSize    uint64
	// contains filtered or unexported fields
}

type DiskMetrics struct {
	Status               int32
	ReadErrs             int32
	WriteErrs            int32
	MaxDiskErrs          int32
	MinRestWeight        int64
	TotalWeight          int64
	RealAvailWeight      int64
	PartitionAvailWeight int64
	Path                 string
}

type DiskUsage struct {
	Total       uint64
	Used        uint64
	Available   uint64
	Unallocated uint64
	Allocated   uint64
}

type MembersFileMetas struct {
	NeedDeleteExtentsTasks   []*storage.FileInfo //generator delete extent file task
	NeedAddExtentsTasks      []*storage.FileInfo //generator add extent file task
	NeedFixExtentSizeTasks   []*storage.FileInfo //generator fixSize file task
	NeedDeleteObjectsTasks   map[int][]byte      //generator deleteObject on blob file task
	NeedFixBlobFileSizeTasks []*storage.FileInfo
	// contains filtered or unexported fields
}

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

type Packet struct {
	proto.Packet
	NextConn      *net.TCPConn
	NextAddr      string
	IsReturn      bool
	DataPartition DataPartition
	// contains filtered or unexported fields
}

type PartitionVisitor func(dp DataPartition)

type RepairBlobFileTask struct {
	BlobFileId int
	StartObj   uint64
	EndObj     uint64
}

type SpaceManager interface {
	LoadDisk(path string, restSize uint64, maxErrs int) (err error)
	GetDisk(path string) (d *Disk, err error)
	GetPartition(partitionId uint32) (dp DataPartition)
	Stats() *Stats
	GetDisks() []*Disk
	CreatePartition(volId string, partitionId uint32, storeSize int, storeType string) (DataPartition, error)
	DeletePartition(partitionId uint32)
	RangePartitions(f func(partition DataPartition) bool)
	Stop()
}

type Stats struct {
	Zone                            string
	CurrentConns                    int64
	ClusterID                       string
	TcpAddr                         string
	Start                           time.Time
	Total                           uint64
	Used                            uint64
	Available                       uint64
	CreatedPartitionWeights         uint64 //dataPartitionCnt*dataPartitionSize
	RemainWeightsForCreatePartition uint64 //all-useddataPartitionsWieghts
	CreatedPartitionCnt             uint64
	MaxWeightsForCreatePartition    uint64

	sync.Mutex
	// contains filtered or unexported fields
}