aws

type Commands struct {
	MasterBinPath string
	SlaveBinPath  string
	ConfPath      string
	RegPath       string
	S3            string
	// contains filtered or unexported fields
}

type Config struct {
	PemFile       string
	Regions       []string
	MasterTimeOut int
	SSHUser       string
	TargetSystem  string
	TargetArch    string
	CopyBinFiles  bool
	ConfTimeout   int
}

type Instance struct {
	// EC2 ID
	ID *string
	// IP Visible to the outside world
	PublicIP *string
	// State: running, pending, stopped
	State *string
	//EC2 Instance region
	Region string
	// EC2 Instance TAG
	Tag string

	Nodes []*lib.Node
}

type Manager interface {
	// Instances lists available instances in any state
	Instances() []Instance
	// RefreshInstances populates the instance list and updates instances status
	RefreshInstances() ([]Instance, error)
	// StartInstances starts all available instances and populates the instance list,
	// blocks until all instances are in "running" state
	StartInstances() error
	// StopInstances stops all available instances
	StopInstances() error
}

type MasterCommands struct {
	Commands
}

type NodeController interface {
	// CopyFiles copies files to equivalent location on a remote host
	// for example "/tmp/aws.csv" from localhost will be placed in
	// "/tmp/aws.csv" on the remote host
	CopyFiles(files ...string) error
	// Run runs command on a remote node, for example Run("ls -l") and blocks until completion
	Run(command string, pw *io.PipeWriter) error
	// Run starts command on a remote node
	Start(command string) error

	// Init inits connection to the remote node
	Init() error
	// Close
	Close()
}

type SlaveCommands struct {
	Commands
	SameBinary   bool
	SyncBasePort int
}