Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Cluster ¶
type Cluster interface { Register(nodeAddresses []string) (*common.Cluster, error) RegisterNodesTo(clusterId string, nodeAddresses []string) error UnRegisterCluster(clusterId string) error UnRegisterNode(nodeId string) error Handshake() error GetClusters() (common.Clusters, error) GetCluster(clusterId string) (*common.Cluster, error) Reserve(size uint64) (*common.ReservationMap, error) Commit(reservationId string, clusterMap map[string]uint64) error Discard(reservationId string) error MoveCluster(sourceClusterId string, targetClusterId string) error BalanceClusters(clusterIds []string) error ChangeState(clusterId string, state common.States) error ChangeStateAll(state common.States) error CreateSnapshot(clusterId string) error DeleteSnapshot(clusterId string, snapshotIndex uint64) error RestoreSnapshot(clusterId string, snapshotIndex uint64) error Map(sha512HexList []string, mapType common.MapType) (map[string][]string, error) Find(sha512Hex string, mapType common.MapType) (string, []string, error) }
Cluster interface contains functions to handle the cluster administration in the dfs farm
type HealthCheck ¶
type HealthCheck interface { Start() Report() (HealthReport, error) }
func NewHealthTracker ¶
type HealthReport ¶
type Node ¶
type Repair ¶
type Repair interface { Start(repairType RepairType) error Status() data.RepairDetail }
type RepairType ¶
type RepairType int
const ( RTFull RepairType = 1 RTStructure RepairType = 2 RTStructureWithIntegrity RepairType = 3 RTIntegrity RepairType = 4 RTIntegrityWithChecksumRebuild RepairType = 5 RTCalculatingMissingChecksum RepairType = 6 RTChecksumRebuild RepairType = 7 )
Click to show internal directories.
Click to hide internal directories.