service

type AutofailoverManager interface {
	// returns HealthInfo if the service considers itself overall
	// healthy and error otherwise
	HealthCheck() (*HealthInfo, error)
	// returns nil if the auto failover is safe from the service
	// perspective for the NodeID's passed, and error otherwise
	IsSafe(nodeUUIDs []NodeID) error
}

type Cancel <-chan struct{}

type CancelTaskReq struct {
	ID  string   `json:"id"`
	Rev Revision `json:"rev,omitempty"`
}

type DefragmentedUtilizationInfo map[string]map[string]interface{}

type DefragmentedUtilizationReply struct {
	Info *DefragmentedUtilizationInfo
}

type GetCurrentTopologyReq struct {
	Rev     Revision `json:"rev,omitempty"`
	Timeout int64    `json:"timeout,omitempty"`
}

type GetTaskListReq struct {
	Rev     Revision `json:"rev,omitempty"`
	Timeout int64    `json:"timeout,omitempty"`
}

type HealthInfo struct {
	// number of the disk failures encountered since the
	// start of the service executable
	DiskFailures int `json:"diskFailures"`
}

type Manager interface {
	GetNodeInfo() (*NodeInfo, error)
	Shutdown() error

	GetTaskList(rev Revision, cancel Cancel) (*TaskList, error)
	CancelTask(id string, rev Revision) error

	GetCurrentTopology(rev Revision, cancel Cancel) (*Topology, error)

	PrepareTopologyChange(change TopologyChange) error
	StartTopologyChange(change TopologyChange) error
}

type NodeID string

type NodeInfo struct {
	NodeID   NodeID      `json:"nodeId"`
	Priority Priority    `json:"priority"`
	Opaque   interface{} `json:"opaque"`
}

type Priority int64

type RecoveryType string

type Revision []byte

type ServerlessManager interface {
	// returns projected utilization stats if the service would
	// be defragmented
	GetDefragmentedUtilization() (*DefragmentedUtilizationInfo, error)
}

type Task struct {
	Rev Revision `json:"rev"`

	ID           string     `json:"id"`
	Type         TaskType   `json:"type"`
	Status       TaskStatus `json:"status"`
	IsCancelable bool       `json:"isCancelable"`

	Progress         float64            `json:"progress"`
	DetailedProgress map[NodeID]float64 `json:"detailedProgress,omitempty"`

	Description  string `json:"description,omitempty"`
	ErrorMessage string `json:"errorMessage,omitempty"`

	Extra map[string]interface{} `json:"extra"`
}

type TaskList struct {
	Rev   Revision `json:"rev"`
	Tasks []Task   `json:"tasks"`
}

type TaskStatus string

type TaskType string

type Topology struct {
	Rev   Revision `json:"rev"`
	Nodes []NodeID `json:"nodes"`

	IsBalanced bool     `json:"isBalanced"`
	Messages   []string `json:"messages,omitempty"`
}

type TopologyChange struct {
	ID                 string   `json:"id"`
	CurrentTopologyRev Revision `json:"currentTopologyRev"`

	Type TopologyChangeType `json:"type"`

	KeepNodes []struct {
		NodeInfo     NodeInfo     `json:"nodeInfo"`
		RecoveryType RecoveryType `json:"recoveryType"`
	} `json:"keepNodes"`

	EjectNodes []NodeInfo `json:"ejectNodes"`
}

type TopologyChangeType string

type Void *struct{}