emr

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 31, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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) AddInstanceFleet 

func (a *Activities) AddInstanceFleet(ctx context.Context, input *emr.AddInstanceFleetInput) (*emr.AddInstanceFleetOutput, error)

func (*Activities) AddInstanceGroups 

func (a *Activities) AddInstanceGroups(ctx context.Context, input *emr.AddInstanceGroupsInput) (*emr.AddInstanceGroupsOutput, error)

func (*Activities) AddJobFlowSteps 

func (a *Activities) AddJobFlowSteps(ctx context.Context, input *emr.AddJobFlowStepsInput) (*emr.AddJobFlowStepsOutput, error)

func (*Activities) AddTags 

func (a *Activities) AddTags(ctx context.Context, input *emr.AddTagsInput) (*emr.AddTagsOutput, error)

func (*Activities) CancelSteps 

func (a *Activities) CancelSteps(ctx context.Context, input *emr.CancelStepsInput) (*emr.CancelStepsOutput, error)

func (*Activities) CreateSecurityConfiguration 

func (a *Activities) CreateSecurityConfiguration(ctx context.Context, input *emr.CreateSecurityConfigurationInput) (*emr.CreateSecurityConfigurationOutput, error)

func (*Activities) CreateStudio 

func (a *Activities) CreateStudio(ctx context.Context, input *emr.CreateStudioInput) (*emr.CreateStudioOutput, error)

func (*Activities) CreateStudioSessionMapping 

func (a *Activities) CreateStudioSessionMapping(ctx context.Context, input *emr.CreateStudioSessionMappingInput) (*emr.CreateStudioSessionMappingOutput, error)

func (*Activities) DeleteSecurityConfiguration 

func (a *Activities) DeleteSecurityConfiguration(ctx context.Context, input *emr.DeleteSecurityConfigurationInput) (*emr.DeleteSecurityConfigurationOutput, error)

func (*Activities) DeleteStudio 

func (a *Activities) DeleteStudio(ctx context.Context, input *emr.DeleteStudioInput) (*emr.DeleteStudioOutput, error)

func (*Activities) DeleteStudioSessionMapping 

func (a *Activities) DeleteStudioSessionMapping(ctx context.Context, input *emr.DeleteStudioSessionMappingInput) (*emr.DeleteStudioSessionMappingOutput, error)

func (*Activities) DescribeCluster 

func (a *Activities) DescribeCluster(ctx context.Context, input *emr.DescribeClusterInput) (*emr.DescribeClusterOutput, error)

func (*Activities) DescribeJobFlows 

func (a *Activities) DescribeJobFlows(ctx context.Context, input *emr.DescribeJobFlowsInput) (*emr.DescribeJobFlowsOutput, error)

func (*Activities) DescribeNotebookExecution 

func (a *Activities) DescribeNotebookExecution(ctx context.Context, input *emr.DescribeNotebookExecutionInput) (*emr.DescribeNotebookExecutionOutput, error)

func (*Activities) DescribeSecurityConfiguration 

func (a *Activities) DescribeSecurityConfiguration(ctx context.Context, input *emr.DescribeSecurityConfigurationInput) (*emr.DescribeSecurityConfigurationOutput, error)

func (*Activities) DescribeStep 

func (a *Activities) DescribeStep(ctx context.Context, input *emr.DescribeStepInput) (*emr.DescribeStepOutput, error)

func (*Activities) DescribeStudio 

func (a *Activities) DescribeStudio(ctx context.Context, input *emr.DescribeStudioInput) (*emr.DescribeStudioOutput, error)

func (*Activities) GetBlockPublicAccessConfiguration 

func (a *Activities) GetBlockPublicAccessConfiguration(ctx context.Context, input *emr.GetBlockPublicAccessConfigurationInput) (*emr.GetBlockPublicAccessConfigurationOutput, error)

func (*Activities) GetManagedScalingPolicy 

func (a *Activities) GetManagedScalingPolicy(ctx context.Context, input *emr.GetManagedScalingPolicyInput) (*emr.GetManagedScalingPolicyOutput, error)

func (*Activities) GetStudioSessionMapping 

func (a *Activities) GetStudioSessionMapping(ctx context.Context, input *emr.GetStudioSessionMappingInput) (*emr.GetStudioSessionMappingOutput, error)

func (*Activities) ListBootstrapActions 

func (a *Activities) ListBootstrapActions(ctx context.Context, input *emr.ListBootstrapActionsInput) (*emr.ListBootstrapActionsOutput, error)

func (*Activities) ListClusters 

func (a *Activities) ListClusters(ctx context.Context, input *emr.ListClustersInput) (*emr.ListClustersOutput, error)

func (*Activities) ListInstanceFleets 

func (a *Activities) ListInstanceFleets(ctx context.Context, input *emr.ListInstanceFleetsInput) (*emr.ListInstanceFleetsOutput, error)

func (*Activities) ListInstanceGroups 

func (a *Activities) ListInstanceGroups(ctx context.Context, input *emr.ListInstanceGroupsInput) (*emr.ListInstanceGroupsOutput, error)

func (*Activities) ListInstances 

func (a *Activities) ListInstances(ctx context.Context, input *emr.ListInstancesInput) (*emr.ListInstancesOutput, error)

func (*Activities) ListNotebookExecutions 

func (a *Activities) ListNotebookExecutions(ctx context.Context, input *emr.ListNotebookExecutionsInput) (*emr.ListNotebookExecutionsOutput, error)

func (*Activities) ListSecurityConfigurations 

func (a *Activities) ListSecurityConfigurations(ctx context.Context, input *emr.ListSecurityConfigurationsInput) (*emr.ListSecurityConfigurationsOutput, error)

func (*Activities) ListSteps 

func (a *Activities) ListSteps(ctx context.Context, input *emr.ListStepsInput) (*emr.ListStepsOutput, error)

func (*Activities) ListStudioSessionMappings 

func (a *Activities) ListStudioSessionMappings(ctx context.Context, input *emr.ListStudioSessionMappingsInput) (*emr.ListStudioSessionMappingsOutput, error)

func (*Activities) ListStudios 

func (a *Activities) ListStudios(ctx context.Context, input *emr.ListStudiosInput) (*emr.ListStudiosOutput, error)

func (*Activities) ModifyCluster 

func (a *Activities) ModifyCluster(ctx context.Context, input *emr.ModifyClusterInput) (*emr.ModifyClusterOutput, error)

func (*Activities) ModifyInstanceFleet 

func (a *Activities) ModifyInstanceFleet(ctx context.Context, input *emr.ModifyInstanceFleetInput) (*emr.ModifyInstanceFleetOutput, error)

func (*Activities) ModifyInstanceGroups 

func (a *Activities) ModifyInstanceGroups(ctx context.Context, input *emr.ModifyInstanceGroupsInput) (*emr.ModifyInstanceGroupsOutput, error)

func (*Activities) PutAutoScalingPolicy 

func (a *Activities) PutAutoScalingPolicy(ctx context.Context, input *emr.PutAutoScalingPolicyInput) (*emr.PutAutoScalingPolicyOutput, error)

func (*Activities) PutBlockPublicAccessConfiguration 

func (a *Activities) PutBlockPublicAccessConfiguration(ctx context.Context, input *emr.PutBlockPublicAccessConfigurationInput) (*emr.PutBlockPublicAccessConfigurationOutput, error)

func (*Activities) PutManagedScalingPolicy 

func (a *Activities) PutManagedScalingPolicy(ctx context.Context, input *emr.PutManagedScalingPolicyInput) (*emr.PutManagedScalingPolicyOutput, error)

func (*Activities) RemoveAutoScalingPolicy 

func (a *Activities) RemoveAutoScalingPolicy(ctx context.Context, input *emr.RemoveAutoScalingPolicyInput) (*emr.RemoveAutoScalingPolicyOutput, error)

func (*Activities) RemoveManagedScalingPolicy 

func (a *Activities) RemoveManagedScalingPolicy(ctx context.Context, input *emr.RemoveManagedScalingPolicyInput) (*emr.RemoveManagedScalingPolicyOutput, error)

func (*Activities) RemoveTags 

func (a *Activities) RemoveTags(ctx context.Context, input *emr.RemoveTagsInput) (*emr.RemoveTagsOutput, error)

func (*Activities) RunJobFlow 

func (a *Activities) RunJobFlow(ctx context.Context, input *emr.RunJobFlowInput) (*emr.RunJobFlowOutput, error)

func (*Activities) SetTerminationProtection 

func (a *Activities) SetTerminationProtection(ctx context.Context, input *emr.SetTerminationProtectionInput) (*emr.SetTerminationProtectionOutput, error)

func (*Activities) SetVisibleToAllUsers 

func (a *Activities) SetVisibleToAllUsers(ctx context.Context, input *emr.SetVisibleToAllUsersInput) (*emr.SetVisibleToAllUsersOutput, error)

func (*Activities) StartNotebookExecution 

func (a *Activities) StartNotebookExecution(ctx context.Context, input *emr.StartNotebookExecutionInput) (*emr.StartNotebookExecutionOutput, error)

func (*Activities) StopNotebookExecution 

func (a *Activities) StopNotebookExecution(ctx context.Context, input *emr.StopNotebookExecutionInput) (*emr.StopNotebookExecutionOutput, error)

func (*Activities) TerminateJobFlows 

func (a *Activities) TerminateJobFlows(ctx context.Context, input *emr.TerminateJobFlowsInput) (*emr.TerminateJobFlowsOutput, error)

func (*Activities) UpdateStudioSessionMapping 

func (a *Activities) UpdateStudioSessionMapping(ctx context.Context, input *emr.UpdateStudioSessionMappingInput) (*emr.UpdateStudioSessionMappingOutput, error)

func (*Activities) WaitUntilClusterRunning 

func (a *Activities) WaitUntilClusterRunning(ctx context.Context, input *emr.DescribeClusterInput) error

func (*Activities) WaitUntilClusterTerminated 

func (a *Activities) WaitUntilClusterTerminated(ctx context.Context, input *emr.DescribeClusterInput) error

func (*Activities) WaitUntilStepComplete 

func (a *Activities) WaitUntilStepComplete(ctx context.Context, input *emr.DescribeStepInput) error

type SessionFactory 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.