README
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddNodes ¶
func AddNodes(cluster string, deploy deployment.Deployment, nodeNames []string) error
AddNodes implements the add-node command.
func RemoveNode ¶
func RemoveNode(cluster string, deploy deployment.Deployment, metaList string, node string) error
Types ¶
type Downgrader ¶
type Downgrader interface {
Downgrade(node *util.PegasusNode) error
}
Downgrader safely and gracefully downgrades all replicas on this node.
NOTE: It adds a level of abstraction between rolling-update/remove_node and MetaServer, so that we can mock this step, without mocking Meta.
type Updater ¶
type Updater struct {
// contains filtered or unexported fields
}
func PrepareRollingUpdate ¶
func PrepareRollingUpdate(cluster string, deploy deployment.Deployment) (*Updater, error)
func (*Updater) FindAndUpdateNode ¶
func (u *Updater) FindAndUpdateNode(nodeName string, jobType deployment.JobType) error
func (*Updater) UpdateNode ¶
func (u *Updater) UpdateNode(node *deployment.Node) error
rolling-update a single node.
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.