emr

Documentation

Index

• type AwsClient
• type Cluster
  • func NewCluster(client AwsClient, cluster *types.Cluster) Cluster
  • func (e Cluster) GetName() string
  • func (e Cluster) GetTagValue(tag string) string
  • func (e Cluster) GetTags() map[string]string
• type ClusterList
• type EmrRepository
  • func NewEmrRepository(ctx context.Context, client AwsClient) *EmrRepository
  • func (r *EmrRepository) DescribeCluster(clusterId *string) (*Cluster, error)
  • func (r *EmrRepository) GetRegion() ptypes.AwsRegion
  • func (r *EmrRepository) ListClustersAll() ([]Cluster, error)
  • func (r *EmrRepository) ListClustersByInput(query *emr.ListClustersInput) ([]Cluster, error)
  • func (r *EmrRepository) ListClustersLatest(createdAfter *time.Time) ([]Cluster, error)

Types

type AwsClient

type AwsClient interface {
	GetRegion() ptypes.AwsRegion
	GetAccountID() ptypes.AwsAccountID
	EMR() *emr.Client
}

type Cluster

type Cluster struct {
	service.AbstractResource
	*types.Cluster
}

func NewCluster

func NewCluster(client AwsClient, cluster *types.Cluster) Cluster

func (Cluster) GetName

func (e Cluster) GetName() string

func (Cluster) GetTagValue

func (e Cluster) GetTagValue(tag string) string

func (Cluster) GetTags

func (e Cluster) GetTags() map[string]string

type ClusterList

type ClusterList struct {
	Items []Cluster
}

type EmrRepository

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

func NewEmrRepository

func NewEmrRepository(ctx context.Context, client AwsClient) *EmrRepository

func (*EmrRepository) DescribeCluster

func (r *EmrRepository) DescribeCluster(clusterId *string) (*Cluster, error)

func (*EmrRepository) GetRegion

func (r *EmrRepository) GetRegion() ptypes.AwsRegion

func (*EmrRepository) ListClustersAll

func (r *EmrRepository) ListClustersAll() ([]Cluster, error)

func (*EmrRepository) ListClustersByInput

func (r *EmrRepository) ListClustersByInput(query *emr.ListClustersInput) ([]Cluster, error)

func (*EmrRepository) ListClustersLatest

func (r *EmrRepository) ListClustersLatest(createdAfter *time.Time) ([]Cluster, error)