deployment

type Deployment interface {

	// Start a Pegasus node on the specified machine. A possible implementation may
	// login to the machine, download the binary package and config, and launch the
	// process.
	StartNode(Node) error

	// Stop a Pegasus node on the specified machine. A possible implementation may
	// login to the machine, and kill the process (via supervisord).
	StopNode(Node) error

	// Rolling-update a Pegasus node on the specified machine. A possible implementation
	// may login to the machine, re-download the binary package and config and restart the process.
	RollingUpdate(Node) error

	// Retrieves all nodes information in the Pegasus cluster.
	ListAllNodes() ([]Node, error)

	// Name returns a simple name identifies the deployment system.
	Name() string
}

type JobType int

type Node struct {
	Job JobType `json:"job"`

	// Node's name should be unique within the cluster.
	// There's no strict rule on the naming of a node.
	// It could be some ID like "1", "2" ..., or a hostname, UUID, TCP address, etc.
	Name string `json:"name"`

	IPPort string `json:"ip_port"`

	Hostname string `json:"hostname"`

	// Attrs contains the additional attributes that are provided by the specific Deployment.
	// This field is optional, can be left empty.
	// A typical use-case could be giving a "Status" that represents the node running status:
	//   Attrs : map[string]interface{"Status" : "Running"}
	// It will be useful to check if the node behaves normal after start/stop/rolling-update.
	Attrs map[string]interface{} `json:"attributes,omitempty"`
}