provider

README

provider

-- import "github.com/Zemanta/mrgob/runner/provider"

Usage

var (
	ErrClusterNotFound  = fmt.Errorf("EMR cluster not found")
	ErrInstanceNotFound = fmt.Errorf("EMR instance not found")
)

type EmrProvider

type EmrProvider struct {
}

func NewEmrProvider

func NewEmrProvider(clusterName string, sshConfig *ssh.ClientConfig, awsConfig *aws.Config) *EmrProvider

func (*EmrProvider) GetMasterHost

func (e *EmrProvider) GetMasterHost() (master string, err error)

func (*EmrProvider) GetMasterSSHClient

func (e *EmrProvider) GetMasterSSHClient() (*ssh.Client, error)

func (*EmrProvider) GetNextSSHClient

func (e *EmrProvider) GetNextSSHClient() (*ssh.Client, error)

type HadoopProvider

type HadoopProvider interface {
	GetMasterHost() (string, error)
	GetMasterSSHClient() (*ssh.Client, error)
	GetNextSSHClient() (*ssh.Client, error)
}

Documentation

Index

• Variables
• type EmrProvider
  • func NewEmrProvider(clusterName string, sshConfig *ssh.ClientConfig, awsConfig *aws.Config) *EmrProvider
  • func (e *EmrProvider) GetMasterHost() (master string, err error)
  • func (e *EmrProvider) GetMasterSSHClient() (*ssh.Client, error)
• type HadoopProvider

Variables

var (
	ErrClusterNotFound  = fmt.Errorf("EMR cluster not found")
	ErrInstanceNotFound = fmt.Errorf("EMR instance not found")
)

Types

type EmrProvider

type EmrProvider struct {
	// contains filtered or unexported fields
}

func NewEmrProvider

func NewEmrProvider(clusterName string, sshConfig *ssh.ClientConfig, awsConfig *aws.Config) *EmrProvider

func (*EmrProvider) GetMasterHost

func (e *EmrProvider) GetMasterHost() (master string, err error)

func (*EmrProvider) GetMasterSSHClient

func (e *EmrProvider) GetMasterSSHClient() (*ssh.Client, error)

type HadoopProvider

type HadoopProvider interface {
	GetMasterHost() (string, error)
	GetMasterSSHClient() (*ssh.Client, error)
}