emrcontainers

Documentation

Index

• type Activities
  • func NewActivities(sess *session.Session, config ...*aws.Config) *Activities
  • func NewActivitiesWithSessionFactory(sessionFactory SessionFactory) *Activities
  • func (a *Activities) CancelJobRun(ctx context.Context, input *emrcontainers.CancelJobRunInput) (*emrcontainers.CancelJobRunOutput, error)
  • func (a *Activities) CreateManagedEndpoint(ctx context.Context, input *emrcontainers.CreateManagedEndpointInput) (*emrcontainers.CreateManagedEndpointOutput, error)
  • func (a *Activities) CreateVirtualCluster(ctx context.Context, input *emrcontainers.CreateVirtualClusterInput) (*emrcontainers.CreateVirtualClusterOutput, error)
  • func (a *Activities) DeleteManagedEndpoint(ctx context.Context, input *emrcontainers.DeleteManagedEndpointInput) (*emrcontainers.DeleteManagedEndpointOutput, error)
  • func (a *Activities) DeleteVirtualCluster(ctx context.Context, input *emrcontainers.DeleteVirtualClusterInput) (*emrcontainers.DeleteVirtualClusterOutput, error)
  • func (a *Activities) DescribeJobRun(ctx context.Context, input *emrcontainers.DescribeJobRunInput) (*emrcontainers.DescribeJobRunOutput, error)
  • func (a *Activities) DescribeManagedEndpoint(ctx context.Context, input *emrcontainers.DescribeManagedEndpointInput) (*emrcontainers.DescribeManagedEndpointOutput, error)
  • func (a *Activities) DescribeVirtualCluster(ctx context.Context, input *emrcontainers.DescribeVirtualClusterInput) (*emrcontainers.DescribeVirtualClusterOutput, error)
  • func (a *Activities) ListJobRuns(ctx context.Context, input *emrcontainers.ListJobRunsInput) (*emrcontainers.ListJobRunsOutput, error)
  • func (a *Activities) ListManagedEndpoints(ctx context.Context, input *emrcontainers.ListManagedEndpointsInput) (*emrcontainers.ListManagedEndpointsOutput, error)
  • func (a *Activities) ListTagsForResource(ctx context.Context, input *emrcontainers.ListTagsForResourceInput) (*emrcontainers.ListTagsForResourceOutput, error)
  • func (a *Activities) ListVirtualClusters(ctx context.Context, input *emrcontainers.ListVirtualClustersInput) (*emrcontainers.ListVirtualClustersOutput, error)
  • func (a *Activities) StartJobRun(ctx context.Context, input *emrcontainers.StartJobRunInput) (*emrcontainers.StartJobRunOutput, error)
  • func (a *Activities) TagResource(ctx context.Context, input *emrcontainers.TagResourceInput) (*emrcontainers.TagResourceOutput, error)
  • func (a *Activities) UntagResource(ctx context.Context, input *emrcontainers.UntagResourceInput) (*emrcontainers.UntagResourceOutput, error)
• type SessionFactory

Types

type Activities

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

func NewActivities

func NewActivities(sess *session.Session, config ...*aws.Config) *Activities

func NewActivitiesWithSessionFactory

func NewActivitiesWithSessionFactory(sessionFactory SessionFactory) *Activities

func (*Activities) CancelJobRun

func (a *Activities) CancelJobRun(ctx context.Context, input *emrcontainers.CancelJobRunInput) (*emrcontainers.CancelJobRunOutput, error)

func (*Activities) CreateManagedEndpoint

func (a *Activities) CreateManagedEndpoint(ctx context.Context, input *emrcontainers.CreateManagedEndpointInput) (*emrcontainers.CreateManagedEndpointOutput, error)

func (*Activities) CreateVirtualCluster

func (a *Activities) CreateVirtualCluster(ctx context.Context, input *emrcontainers.CreateVirtualClusterInput) (*emrcontainers.CreateVirtualClusterOutput, error)

func (*Activities) DeleteManagedEndpoint

func (a *Activities) DeleteManagedEndpoint(ctx context.Context, input *emrcontainers.DeleteManagedEndpointInput) (*emrcontainers.DeleteManagedEndpointOutput, error)

func (*Activities) DeleteVirtualCluster

func (a *Activities) DeleteVirtualCluster(ctx context.Context, input *emrcontainers.DeleteVirtualClusterInput) (*emrcontainers.DeleteVirtualClusterOutput, error)

func (*Activities) DescribeJobRun

func (a *Activities) DescribeJobRun(ctx context.Context, input *emrcontainers.DescribeJobRunInput) (*emrcontainers.DescribeJobRunOutput, error)

func (*Activities) DescribeManagedEndpoint

func (a *Activities) DescribeManagedEndpoint(ctx context.Context, input *emrcontainers.DescribeManagedEndpointInput) (*emrcontainers.DescribeManagedEndpointOutput, error)

func (*Activities) DescribeVirtualCluster

func (a *Activities) DescribeVirtualCluster(ctx context.Context, input *emrcontainers.DescribeVirtualClusterInput) (*emrcontainers.DescribeVirtualClusterOutput, error)

func (*Activities) ListJobRuns

func (a *Activities) ListJobRuns(ctx context.Context, input *emrcontainers.ListJobRunsInput) (*emrcontainers.ListJobRunsOutput, error)

func (*Activities) ListManagedEndpoints

func (a *Activities) ListManagedEndpoints(ctx context.Context, input *emrcontainers.ListManagedEndpointsInput) (*emrcontainers.ListManagedEndpointsOutput, error)

func (*Activities) ListTagsForResource

func (a *Activities) ListTagsForResource(ctx context.Context, input *emrcontainers.ListTagsForResourceInput) (*emrcontainers.ListTagsForResourceOutput, error)

func (*Activities) ListVirtualClusters

func (a *Activities) ListVirtualClusters(ctx context.Context, input *emrcontainers.ListVirtualClustersInput) (*emrcontainers.ListVirtualClustersOutput, error)

func (*Activities) StartJobRun

func (a *Activities) StartJobRun(ctx context.Context, input *emrcontainers.StartJobRunInput) (*emrcontainers.StartJobRunOutput, error)

func (*Activities) TagResource

func (a *Activities) TagResource(ctx context.Context, input *emrcontainers.TagResourceInput) (*emrcontainers.TagResourceOutput, error)

func (*Activities) UntagResource

func (a *Activities) UntagResource(ctx context.Context, input *emrcontainers.UntagResourceInput) (*emrcontainers.UntagResourceOutput, error)

type SessionFactory

type SessionFactory interface {
	Session(ctx context.Context) (*session.Session, error)
}

SessionFactory returns an aws.Session based on the activity context.