Documentation
¶
Index ¶
Constants ¶
View Source
const (
ColonSeparator = ":"
)
Variables ¶
Functions ¶
func PostToMaster ¶
Types ¶
type MockDataPartition ¶
type MockDataPartition struct {
PartitionID uint64
PersistenceHosts []string
VolName string
Forbidden int32
DpRepairBlockSize uint64
// contains filtered or unexported fields
}
func (*MockDataPartition) GetDpRepairBlockSize ¶ added in v1.34.0
func (md *MockDataPartition) GetDpRepairBlockSize() (size uint64)
func (*MockDataPartition) IsForbidden ¶ added in v1.34.0
func (md *MockDataPartition) IsForbidden() bool
func (*MockDataPartition) SetDpRepairBlockSize ¶ added in v1.34.0
func (md *MockDataPartition) SetDpRepairBlockSize(size uint64)
func (*MockDataPartition) SetForbidden ¶ added in v1.34.0
func (md *MockDataPartition) SetForbidden(status bool)
type MockDataServer ¶
type MockDataServer struct {
TcpAddr string
Zone string
ClusterID string
Total uint64
Used uint64
Available uint64
CreatedPartitionWeights uint64 // dataPartitionCnt*dataPartitionSize
RemainWeightsForCreatePartition uint64 // all-useddataPartitionsWieghts
CreatedPartitionCnt uint64
MaxWeightsForCreatePartition uint64
sync.RWMutex
// contains filtered or unexported fields
}
func NewMockDataServer ¶
func NewMockDataServer(addr string, zoneName string) *MockDataServer
func (*MockDataServer) CheckVolPartition ¶ added in v1.34.0
func (mds *MockDataServer) CheckVolPartition(name string, cond func(*MockDataPartition) bool) bool
func (*MockDataServer) Start ¶
func (mds *MockDataServer) Start()
type MockMetaPartition ¶
type MockMetaPartition struct {
PartitionID uint64
Start uint64
End uint64
Status int8
Cursor uint64
VolName string
Members []proto.Peer
Replicas []*MockMetaReplica
Forbidden int32
EnableAuditLog int32
}
func (*MockMetaPartition) IsEnableAuditLog ¶ added in v1.34.0
func (mm *MockMetaPartition) IsEnableAuditLog() bool
func (*MockMetaPartition) IsForbidden ¶ added in v1.34.0
func (mm *MockMetaPartition) IsForbidden() bool
func (*MockMetaPartition) SetEnableAuditLog ¶ added in v1.34.0
func (mm *MockMetaPartition) SetEnableAuditLog(status bool)
func (*MockMetaPartition) SetForbidden ¶ added in v1.34.0
func (mm *MockMetaPartition) SetForbidden(status bool)
type MockMetaReplica ¶ added in v1.34.0
type MockMetaReplica struct {
Addr string
MaxInodeID uint64
InodeCount uint64
DentryCount uint64
ReportTime int64
Status int8 // unavailable, readOnly, readWrite
IsLeader bool
// contains filtered or unexported fields
}
MockMetaReplica defines the replica of a meta partition
type MockMetaServer ¶
type MockMetaServer struct {
NodeID uint64
TcpAddr string
ZoneName string
sync.RWMutex
// contains filtered or unexported fields
}
func NewMockMetaServer ¶
func NewMockMetaServer(addr string, zoneName string) *MockMetaServer
func (*MockMetaServer) CheckVolPartition ¶ added in v1.34.0
func (mms *MockMetaServer) CheckVolPartition(name string, cond func(*MockMetaPartition) bool) bool
func (*MockMetaServer) Start ¶
func (mms *MockMetaServer) Start()
Click to show internal directories.
Click to hide internal directories.