cluster

Documentation

Index

• Constants
• func NewClusterCommand(c cli.Interface) *cobra.Command
• func NewCreateCommand(c cli.Interface) *cobra.Command
• func NewListCommand(c cli.Interface) *cobra.Command
• func NewNodeCleanupCommand(c cli.Interface) *cobra.Command
• func NewNodeCommand(c cli.Interface) *cobra.Command
• func NewNodeInspectCommand(c cli.Interface) *cobra.Command
• func NewNodeListCommand(c cli.Interface) *cobra.Command
• func NewRemoveCommand(c cli.Interface) *cobra.Command
• func NewStatusCommand(c cli.Interface) *cobra.Command
• func NewUpdateCommand(c cli.Interface) *cobra.Command
• func RunContainer(c cli.Interface, img string, dockerOpts docker, args []string, ...) error
• type ByRole
  • func (a ByRole) Len() int
  • func (a ByRole) Less(i, j int) bool
  • func (a ByRole) Swap(i, j int)
• type Plugin
  • func NewPlugin(config PluginConfig) (Plugin, error)
• type PluginConfig

Constants

const (
	Local = "local"
	AWS   = "aws"
)

Supported plugin providers used by the factory function `NewPlugin`

Functions

func NewClusterCommand

func NewClusterCommand(c cli.Interface) *cobra.Command

NewClusterCommand returns a new instance of the cluster command.

func NewCreateCommand

func NewCreateCommand(c cli.Interface) *cobra.Command

NewCreateCommand returns a new instance of the create command for bootstrapping an cluster.

func NewListCommand

func NewListCommand(c cli.Interface) *cobra.Command

NewListCommand returns a new instance of the list command for amp clusters.

func NewNodeCleanupCommand

func NewNodeCleanupCommand(c cli.Interface) *cobra.Command

NewNodeCleanupCommand returns a new instance of the cleanup command for amp clusters.

func NewNodeCommand

func NewNodeCommand(c cli.Interface) *cobra.Command

NewNodeCommand returns a new instance of the cluster node command.

func NewNodeInspectCommand

func NewNodeInspectCommand(c cli.Interface) *cobra.Command

NewNodeInspectCommand returns a new instance of the node inspect command for amp clusters.

func NewNodeListCommand

func NewNodeListCommand(c cli.Interface) *cobra.Command

NewNodeListCommand returns a new instance of the list command for amp clusters.

func NewRemoveCommand

func NewRemoveCommand(c cli.Interface) *cobra.Command

NewRemoveCommand returns a new instance of the remove command for destroying a cluster.

func NewStatusCommand

func NewStatusCommand(c cli.Interface) *cobra.Command

NewStatusCommand returns a new instance of the status command for querying the state of amp cluster.

func NewUpdateCommand

func NewUpdateCommand(c cli.Interface) *cobra.Command

NewUpdateCommand returns a new instance of the update command for updating an cluster.

func RunContainer

func RunContainer(c cli.Interface, img string, dockerOpts docker, args []string, env map[string]string, f func(r io.Reader, c chan bool)) error

RunContainer starts a container using the specified image for the cluster plugin. Cluster plugin commands are `init`, `update`, and `destroy` (provided as the single `args` value). Additional arguments are supplied as environment variables in `env`, not `args`. If f is not nil, then your func will be called (as a goroutine) with stdout from the container process; otherwise stdout from the container will be printed to the amp console stdout.

Types

type ByRole

type ByRole []*cluster.NodeReply

ByRole implements sort.Interface for []NodeReply based on the Role field.

func (ByRole) Len

func (a ByRole) Len() int

func (ByRole) Less

func (a ByRole) Less(i, j int) bool

func (ByRole) Swap

func (a ByRole) Swap(i, j int)

type Plugin

type Plugin interface {
	// Provider returns the name of the provider, such as "local" or "aws"
	Provider() string

	// Run executes the plugin with the specified arguments and environment variables
	Run(c cli.Interface, args []string, env map[string]string) error
}

Plugin declares the methods that all plugin providers, such as local and aws, must implement

func NewPlugin

func NewPlugin(config PluginConfig) (Plugin, error)

NewPlugin is a simple factory function to return a new instance of a specific cluster plugin based on the supplied config (config.Provider must be set to a valid provider or this function will return an error).

type PluginConfig

type PluginConfig struct {
	// Provider is the name of the cluster provider, such as "local" or "aws"
	Provider   string
	Options    map[string]string
	DockerOpts docker
}

PluginConfig is used by the factory function `NewClusterPlugin` to create a new plugin instance.