emrcontainers

package
v1.38.26-0...-e443fa6 Latest Latest
Warning

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

 Go to latest Published: Apr 26, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

Package emrcontainers provides the client and types for making API requests to Amazon EMR Containers.

Amazon EMR on EKS provides a deployment option for Amazon EMR that allows you to run open-source big data frameworks on Amazon Elastic Kubernetes Service (Amazon EKS). With this deployment option, you can focus on running analytics workloads while Amazon EMR on EKS builds, configures, and manages containers for open-source applications. For more information about Amazon EMR on EKS concepts and tasks, see What is Amazon EMR on EKS (https://docs.aws.amazon.com/emr/latest/EMR-on-EKS-DevelopmentGuide/emr-eks.html).

Amazon EMR containers is the API name for Amazon EMR on EKS. The emr-containers prefix is used in the following scenarios:

See https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01 for more information on this service.

See emrcontainers package documentation for more information. https://docs.aws.amazon.com/sdk-for-go/api/service/emrcontainers/

Using the Client

To contact Amazon EMR Containers with the SDK use the New function to create a new service client. With that client you can make API requests to the service. These clients are safe to use concurrently.

See the SDK's documentation for more information on how to use the SDK. https://docs.aws.amazon.com/sdk-for-go/api/

See aws.Config documentation for more information on configuring SDK clients. https://docs.aws.amazon.com/sdk-for-go/api/aws/#Config

See the Amazon EMR Containers client EMRContainers for more information on creating client for this service. https://docs.aws.amazon.com/sdk-for-go/api/service/emrcontainers/#New

Index

Constants

View Source 
const (
	// EndpointStateCreating is a EndpointState enum value
	EndpointStateCreating = "CREATING"

	// EndpointStateActive is a EndpointState enum value
	EndpointStateActive = "ACTIVE"

	// EndpointStateTerminating is a EndpointState enum value
	EndpointStateTerminating = "TERMINATING"

	// EndpointStateTerminated is a EndpointState enum value
	EndpointStateTerminated = "TERMINATED"

	// EndpointStateTerminatedWithErrors is a EndpointState enum value
	EndpointStateTerminatedWithErrors = "TERMINATED_WITH_ERRORS"
)
View Source 
const (
	// FailureReasonInternalError is a FailureReason enum value
	FailureReasonInternalError = "INTERNAL_ERROR"

	// FailureReasonUserError is a FailureReason enum value
	FailureReasonUserError = "USER_ERROR"

	// FailureReasonValidationError is a FailureReason enum value
	FailureReasonValidationError = "VALIDATION_ERROR"

	// FailureReasonClusterUnavailable is a FailureReason enum value
	FailureReasonClusterUnavailable = "CLUSTER_UNAVAILABLE"
)
View Source 
const (
	// JobRunStatePending is a JobRunState enum value
	JobRunStatePending = "PENDING"

	// JobRunStateSubmitted is a JobRunState enum value
	JobRunStateSubmitted = "SUBMITTED"

	// JobRunStateRunning is a JobRunState enum value
	JobRunStateRunning = "RUNNING"

	// JobRunStateFailed is a JobRunState enum value
	JobRunStateFailed = "FAILED"

	// JobRunStateCancelled is a JobRunState enum value
	JobRunStateCancelled = "CANCELLED"

	// JobRunStateCancelPending is a JobRunState enum value
	JobRunStateCancelPending = "CANCEL_PENDING"

	// JobRunStateCompleted is a JobRunState enum value
	JobRunStateCompleted = "COMPLETED"
)
View Source 
const (
	// PersistentAppUIEnabled is a PersistentAppUI enum value
	PersistentAppUIEnabled = "ENABLED"

	// PersistentAppUIDisabled is a PersistentAppUI enum value
	PersistentAppUIDisabled = "DISABLED"
)
View Source 
const (
	// VirtualClusterStateRunning is a VirtualClusterState enum value
	VirtualClusterStateRunning = "RUNNING"

	// VirtualClusterStateTerminating is a VirtualClusterState enum value
	VirtualClusterStateTerminating = "TERMINATING"

	// VirtualClusterStateTerminated is a VirtualClusterState enum value
	VirtualClusterStateTerminated = "TERMINATED"

	// VirtualClusterStateArrested is a VirtualClusterState enum value
	VirtualClusterStateArrested = "ARRESTED"
)
View Source 
const (

	// ErrCodeInternalServerException for service response error code
	// "InternalServerException".
	//
	// This is an internal server exception.
	ErrCodeInternalServerException = "InternalServerException"

	// ErrCodeResourceNotFoundException for service response error code
	// "ResourceNotFoundException".
	//
	// The specified resource was not found.
	ErrCodeResourceNotFoundException = "ResourceNotFoundException"

	// ErrCodeValidationException for service response error code
	// "ValidationException".
	//
	// There are invalid parameters in the client request.
	ErrCodeValidationException = "ValidationException"
)
View Source 
const (
	ServiceName = "EMR containers" // Name of service.
	EndpointsID = "emr-containers" // ID to lookup a service endpoint with.
	ServiceID   = "EMR containers" // ServiceID is a unique identifier of a specific service.
)

Service information constants

View Source 
const (
	// ContainerProviderTypeEks is a ContainerProviderType enum value
	ContainerProviderTypeEks = "EKS"
)

Variables

This section is empty.

Functions

func ContainerProviderType_Values 

func ContainerProviderType_Values() []string

ContainerProviderType_Values returns all elements of the ContainerProviderType enum

func EndpointState_Values 

func EndpointState_Values() []string

EndpointState_Values returns all elements of the EndpointState enum

func FailureReason_Values 

func FailureReason_Values() []string

FailureReason_Values returns all elements of the FailureReason enum

func JobRunState_Values 

func JobRunState_Values() []string

JobRunState_Values returns all elements of the JobRunState enum

func PersistentAppUI_Values 

func PersistentAppUI_Values() []string

PersistentAppUI_Values returns all elements of the PersistentAppUI enum

func VirtualClusterState_Values 

func VirtualClusterState_Values() []string

VirtualClusterState_Values returns all elements of the VirtualClusterState enum

Types

type CancelJobRunInput 

type CancelJobRunInput struct {

	// The ID of the job run to cancel.
	//
	// Id is a required field
	Id *string `location:"uri" locationName:"jobRunId" min:"1" type:"string" required:"true"`

	// The ID of the virtual cluster for which the job run will be canceled.
	//
	// VirtualClusterId is a required field
	VirtualClusterId *string `location:"uri" locationName:"virtualClusterId" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (CancelJobRunInput) GoString 

func (s CancelJobRunInput) GoString() string

GoString returns the string representation

func (*CancelJobRunInput) SetId 

func (s *CancelJobRunInput) SetId(v string) *CancelJobRunInput

SetId sets the Id field's value.

func (*CancelJobRunInput) SetVirtualClusterId 

func (s *CancelJobRunInput) SetVirtualClusterId(v string) *CancelJobRunInput

SetVirtualClusterId sets the VirtualClusterId field's value.

func (CancelJobRunInput) String 

func (s CancelJobRunInput) String() string

String returns the string representation

func (*CancelJobRunInput) Validate 

func (s *CancelJobRunInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type CancelJobRunOutput 

type CancelJobRunOutput struct {

	// The output contains the ID of the cancelled job run.
	Id *string `locationName:"id" min:"1" type:"string"`

	// The output contains the virtual cluster ID for which the job run is cancelled.
	VirtualClusterId *string `locationName:"virtualClusterId" min:"1" type:"string"`
	// contains filtered or unexported fields
}

func (CancelJobRunOutput) GoString 

func (s CancelJobRunOutput) GoString() string

GoString returns the string representation

func (*CancelJobRunOutput) SetId 

func (s *CancelJobRunOutput) SetId(v string) *CancelJobRunOutput

SetId sets the Id field's value.

func (*CancelJobRunOutput) SetVirtualClusterId 

func (s *CancelJobRunOutput) SetVirtualClusterId(v string) *CancelJobRunOutput

SetVirtualClusterId sets the VirtualClusterId field's value.

func (CancelJobRunOutput) String 

func (s CancelJobRunOutput) String() string

String returns the string representation

type CloudWatchMonitoringConfiguration 

type CloudWatchMonitoringConfiguration struct {

	// The name of the log group for log publishing.
	//
	// LogGroupName is a required field
	LogGroupName *string `locationName:"logGroupName" min:"1" type:"string" required:"true"`

	// The specified name prefix for log streams.
	LogStreamNamePrefix *string `locationName:"logStreamNamePrefix" min:"1" type:"string"`
	// contains filtered or unexported fields
}

A configuration for CloudWatch monitoring. You can configure your jobs to send log information to CloudWatch Logs.

func (CloudWatchMonitoringConfiguration) GoString 

func (s CloudWatchMonitoringConfiguration) GoString() string

GoString returns the string representation

func (*CloudWatchMonitoringConfiguration) SetLogGroupName 

func (s *CloudWatchMonitoringConfiguration) SetLogGroupName(v string) *CloudWatchMonitoringConfiguration

SetLogGroupName sets the LogGroupName field's value.

func (*CloudWatchMonitoringConfiguration) SetLogStreamNamePrefix 

func (s *CloudWatchMonitoringConfiguration) SetLogStreamNamePrefix(v string) *CloudWatchMonitoringConfiguration

SetLogStreamNamePrefix sets the LogStreamNamePrefix field's value.

func (CloudWatchMonitoringConfiguration) String 

func (s CloudWatchMonitoringConfiguration) String() string

String returns the string representation

func (*CloudWatchMonitoringConfiguration) Validate 

func (s *CloudWatchMonitoringConfiguration) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type Configuration 

type Configuration struct {

	// The classification within a configuration.
	//
	// Classification is a required field
	Classification *string `locationName:"classification" min:"1" type:"string" required:"true"`

	// A list of additional configurations to apply within a configuration object.
	Configurations []*Configuration `locationName:"configurations" type:"list"`

	// A set of properties specified within a configuration classification.
	Properties map[string]*string `locationName:"properties" type:"map" sensitive:"true"`
	// contains filtered or unexported fields
}

A configuration specification to be used when provisioning virtual clusters, which can include configurations for applications and software bundled with Amazon EMR on EKS. A configuration consists of a classification, properties, and optional nested configurations. A classification refers to an application-specific configuration file. Properties are the settings you want to change in that file.

func (Configuration) GoString 

func (s Configuration) GoString() string

GoString returns the string representation

func (*Configuration) SetClassification 

func (s *Configuration) SetClassification(v string) *Configuration

SetClassification sets the Classification field's value.

func (*Configuration) SetConfigurations 

func (s *Configuration) SetConfigurations(v []*Configuration) *Configuration

SetConfigurations sets the Configurations field's value.

func (*Configuration) SetProperties 

func (s *Configuration) SetProperties(v map[string]*string) *Configuration

SetProperties sets the Properties field's value.

func (Configuration) String 

func (s Configuration) String() string

String returns the string representation

func (*Configuration) Validate 

func (s *Configuration) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ConfigurationOverrides 

type ConfigurationOverrides struct {

	// The configurations for the application running by the job run.
	ApplicationConfiguration []*Configuration `locationName:"applicationConfiguration" type:"list"`

	// The configurations for monitoring.
	MonitoringConfiguration *MonitoringConfiguration `locationName:"monitoringConfiguration" type:"structure"`
	// contains filtered or unexported fields
}

A configuration specification to be used to override existing configurations.

func (ConfigurationOverrides) GoString 

func (s ConfigurationOverrides) GoString() string

GoString returns the string representation

func (*ConfigurationOverrides) SetApplicationConfiguration 

func (s *ConfigurationOverrides) SetApplicationConfiguration(v []*Configuration) *ConfigurationOverrides

SetApplicationConfiguration sets the ApplicationConfiguration field's value.

func (*ConfigurationOverrides) SetMonitoringConfiguration 

func (s *ConfigurationOverrides) SetMonitoringConfiguration(v *MonitoringConfiguration) *ConfigurationOverrides

SetMonitoringConfiguration sets the MonitoringConfiguration field's value.

func (ConfigurationOverrides) String 

func (s ConfigurationOverrides) String() string

String returns the string representation

func (*ConfigurationOverrides) Validate 

func (s *ConfigurationOverrides) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ContainerInfo 

type ContainerInfo struct {

	// The information about the EKS cluster.
	EksInfo *EksInfo `locationName:"eksInfo" type:"structure"`
	// contains filtered or unexported fields
}

The information about the container used for a job run or a managed endpoint.

func (ContainerInfo) GoString 

func (s ContainerInfo) GoString() string

GoString returns the string representation

func (*ContainerInfo) SetEksInfo 

func (s *ContainerInfo) SetEksInfo(v *EksInfo) *ContainerInfo

SetEksInfo sets the EksInfo field's value.

func (ContainerInfo) String 

func (s ContainerInfo) String() string

String returns the string representation

func (*ContainerInfo) Validate 

func (s *ContainerInfo) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ContainerProvider 

type ContainerProvider struct {

	// The ID of the container cluster.
	//
	// Id is a required field
	Id *string `locationName:"id" min:"1" type:"string" required:"true"`

	// The information about the container cluster.
	Info *ContainerInfo `locationName:"info" type:"structure"`

	// The type of the container provider. EKS is the only supported type as of
	// now.
	//
	// Type is a required field
	Type *string `locationName:"type" type:"string" required:"true" enum:"ContainerProviderType"`
	// contains filtered or unexported fields
}

The information about the container provider.

func (ContainerProvider) GoString 

func (s ContainerProvider) GoString() string

GoString returns the string representation

func (*ContainerProvider) SetId 

func (s *ContainerProvider) SetId(v string) *ContainerProvider

SetId sets the Id field's value.

func (*ContainerProvider) SetInfo 

func (s *ContainerProvider) SetInfo(v *ContainerInfo) *ContainerProvider

SetInfo sets the Info field's value.

func (*ContainerProvider) SetType 

func (s *ContainerProvider) SetType(v string) *ContainerProvider

SetType sets the Type field's value.

func (ContainerProvider) String 

func (s ContainerProvider) String() string

String returns the string representation

func (*ContainerProvider) Validate 

func (s *ContainerProvider) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type CreateManagedEndpointInput 

type CreateManagedEndpointInput struct {

	// The certificate ARN of the managed endpoint.
	//
	// CertificateArn is a required field
	CertificateArn *string `locationName:"certificateArn" min:"44" type:"string" required:"true"`

	// The client idempotency token for this create call.
	ClientToken *string `locationName:"clientToken" min:"1" type:"string" idempotencyToken:"true"`

	// The configuration settings that will be used to override existing configurations.
	ConfigurationOverrides *ConfigurationOverrides `locationName:"configurationOverrides" type:"structure"`

	// The ARN of the execution role.
	//
	// ExecutionRoleArn is a required field
	ExecutionRoleArn *string `locationName:"executionRoleArn" min:"20" type:"string" required:"true"`

	// The name of the managed endpoint.
	//
	// Name is a required field
	Name *string `locationName:"name" min:"1" type:"string" required:"true"`

	// The Amazon EMR release version.
	//
	// ReleaseLabel is a required field
	ReleaseLabel *string `locationName:"releaseLabel" min:"1" type:"string" required:"true"`

	// The tags of the managed endpoint.
	Tags map[string]*string `locationName:"tags" type:"map"`

	// The type of the managed endpoint.
	//
	// Type is a required field
	Type *string `locationName:"type" min:"1" type:"string" required:"true"`

	// The ID of the virtual cluster for which a managed endpoint is created.
	//
	// VirtualClusterId is a required field
	VirtualClusterId *string `location:"uri" locationName:"virtualClusterId" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (CreateManagedEndpointInput) GoString 

func (s CreateManagedEndpointInput) GoString() string

GoString returns the string representation

func (*CreateManagedEndpointInput) SetCertificateArn 

func (s *CreateManagedEndpointInput) SetCertificateArn(v string) *CreateManagedEndpointInput

SetCertificateArn sets the CertificateArn field's value.

func (*CreateManagedEndpointInput) SetClientToken 

func (s *CreateManagedEndpointInput) SetClientToken(v string) *CreateManagedEndpointInput

SetClientToken sets the ClientToken field's value.

func (*CreateManagedEndpointInput) SetConfigurationOverrides 

func (s *CreateManagedEndpointInput) SetConfigurationOverrides(v *ConfigurationOverrides) *CreateManagedEndpointInput

SetConfigurationOverrides sets the ConfigurationOverrides field's value.

func (*CreateManagedEndpointInput) SetExecutionRoleArn 

func (s *CreateManagedEndpointInput) SetExecutionRoleArn(v string) *CreateManagedEndpointInput

SetExecutionRoleArn sets the ExecutionRoleArn field's value.

func (*CreateManagedEndpointInput) SetName 

func (s *CreateManagedEndpointInput) SetName(v string) *CreateManagedEndpointInput

SetName sets the Name field's value.

func (*CreateManagedEndpointInput) SetReleaseLabel 

func (s *CreateManagedEndpointInput) SetReleaseLabel(v string) *CreateManagedEndpointInput

SetReleaseLabel sets the ReleaseLabel field's value.

func (*CreateManagedEndpointInput) SetTags 

func (s *CreateManagedEndpointInput) SetTags(v map[string]*string) *CreateManagedEndpointInput

SetTags sets the Tags field's value.

func (*CreateManagedEndpointInput) SetType 

func (s *CreateManagedEndpointInput) SetType(v string) *CreateManagedEndpointInput

SetType sets the Type field's value.

func (*CreateManagedEndpointInput) SetVirtualClusterId 

func (s *CreateManagedEndpointInput) SetVirtualClusterId(v string) *CreateManagedEndpointInput

SetVirtualClusterId sets the VirtualClusterId field's value.

func (CreateManagedEndpointInput) String 

func (s CreateManagedEndpointInput) String() string

String returns the string representation

func (*CreateManagedEndpointInput) Validate 

func (s *CreateManagedEndpointInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type CreateManagedEndpointOutput 

type CreateManagedEndpointOutput struct {

	// The output contains the ARN of the managed endpoint.
	Arn *string `locationName:"arn" min:"60" type:"string"`

	// The output contains the ID of the managed endpoint.
	Id *string `locationName:"id" min:"1" type:"string"`

	// The output contains the name of the managed endpoint.
	Name *string `locationName:"name" min:"1" type:"string"`

	// The output contains the ID of the virtual cluster.
	VirtualClusterId *string `locationName:"virtualClusterId" min:"1" type:"string"`
	// contains filtered or unexported fields
}

func (CreateManagedEndpointOutput) GoString 

func (s CreateManagedEndpointOutput) GoString() string

GoString returns the string representation

func (*CreateManagedEndpointOutput) SetArn 

func (s *CreateManagedEndpointOutput) SetArn(v string) *CreateManagedEndpointOutput

SetArn sets the Arn field's value.

func (*CreateManagedEndpointOutput) SetId 

func (s *CreateManagedEndpointOutput) SetId(v string) *CreateManagedEndpointOutput

SetId sets the Id field's value.

func (*CreateManagedEndpointOutput) SetName 

func (s *CreateManagedEndpointOutput) SetName(v string) *CreateManagedEndpointOutput

SetName sets the Name field's value.

func (*CreateManagedEndpointOutput) SetVirtualClusterId 

func (s *CreateManagedEndpointOutput) SetVirtualClusterId(v string) *CreateManagedEndpointOutput

SetVirtualClusterId sets the VirtualClusterId field's value.

func (CreateManagedEndpointOutput) String 

func (s CreateManagedEndpointOutput) String() string

String returns the string representation

type CreateVirtualClusterInput 

type CreateVirtualClusterInput struct {

	// The client token of the virtual cluster.
	ClientToken *string `locationName:"clientToken" min:"1" type:"string" idempotencyToken:"true"`

	// The container provider of the virtual cluster.
	//
	// ContainerProvider is a required field
	ContainerProvider *ContainerProvider `locationName:"containerProvider" type:"structure" required:"true"`

	// The specified name of the virtual cluster.
	//
	// Name is a required field
	Name *string `locationName:"name" min:"1" type:"string" required:"true"`

	// The tags assigned to the virtual cluster.
	Tags map[string]*string `locationName:"tags" type:"map"`
	// contains filtered or unexported fields
}

func (CreateVirtualClusterInput) GoString 

func (s CreateVirtualClusterInput) GoString() string

GoString returns the string representation

func (*CreateVirtualClusterInput) SetClientToken 

func (s *CreateVirtualClusterInput) SetClientToken(v string) *CreateVirtualClusterInput

SetClientToken sets the ClientToken field's value.

func (*CreateVirtualClusterInput) SetContainerProvider 

func (s *CreateVirtualClusterInput) SetContainerProvider(v *ContainerProvider) *CreateVirtualClusterInput

SetContainerProvider sets the ContainerProvider field's value.

func (*CreateVirtualClusterInput) SetName 

func (s *CreateVirtualClusterInput) SetName(v string) *CreateVirtualClusterInput

SetName sets the Name field's value.

func (*CreateVirtualClusterInput) SetTags 

func (s *CreateVirtualClusterInput) SetTags(v map[string]*string) *CreateVirtualClusterInput

SetTags sets the Tags field's value.

func (CreateVirtualClusterInput) String 

func (s CreateVirtualClusterInput) String() string

String returns the string representation

func (*CreateVirtualClusterInput) Validate 

func (s *CreateVirtualClusterInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type CreateVirtualClusterOutput 

type CreateVirtualClusterOutput struct {

	// This output contains the ARN of virtual cluster.
	Arn *string `locationName:"arn" min:"60" type:"string"`

	// This output contains the virtual cluster ID.
	Id *string `locationName:"id" min:"1" type:"string"`

	// This output contains the name of the virtual cluster.
	Name *string `locationName:"name" min:"1" type:"string"`
	// contains filtered or unexported fields
}

func (CreateVirtualClusterOutput) GoString 

func (s CreateVirtualClusterOutput) GoString() string

GoString returns the string representation

func (*CreateVirtualClusterOutput) SetArn 

func (s *CreateVirtualClusterOutput) SetArn(v string) *CreateVirtualClusterOutput

SetArn sets the Arn field's value.

func (*CreateVirtualClusterOutput) SetId 

func (s *CreateVirtualClusterOutput) SetId(v string) *CreateVirtualClusterOutput

SetId sets the Id field's value.

func (*CreateVirtualClusterOutput) SetName 

func (s *CreateVirtualClusterOutput) SetName(v string) *CreateVirtualClusterOutput

SetName sets the Name field's value.

func (CreateVirtualClusterOutput) String 

func (s CreateVirtualClusterOutput) String() string

String returns the string representation

type DeleteManagedEndpointInput 

type DeleteManagedEndpointInput struct {

	// The ID of the managed endpoint.
	//
	// Id is a required field
	Id *string `location:"uri" locationName:"endpointId" min:"1" type:"string" required:"true"`

	// The ID of the endpoint's virtual cluster.
	//
	// VirtualClusterId is a required field
	VirtualClusterId *string `location:"uri" locationName:"virtualClusterId" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (DeleteManagedEndpointInput) GoString 

func (s DeleteManagedEndpointInput) GoString() string

GoString returns the string representation

func (*DeleteManagedEndpointInput) SetId 

func (s *DeleteManagedEndpointInput) SetId(v string) *DeleteManagedEndpointInput

SetId sets the Id field's value.

func (*DeleteManagedEndpointInput) SetVirtualClusterId 

func (s *DeleteManagedEndpointInput) SetVirtualClusterId(v string) *DeleteManagedEndpointInput

SetVirtualClusterId sets the VirtualClusterId field's value.

func (DeleteManagedEndpointInput) String 

func (s DeleteManagedEndpointInput) String() string

String returns the string representation

func (*DeleteManagedEndpointInput) Validate 

func (s *DeleteManagedEndpointInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DeleteManagedEndpointOutput 

type DeleteManagedEndpointOutput struct {

	// The output displays the ID of the managed endpoint.
	Id *string `locationName:"id" min:"1" type:"string"`

	// The output displays the ID of the endpoint's virtual cluster.
	VirtualClusterId *string `locationName:"virtualClusterId" min:"1" type:"string"`
	// contains filtered or unexported fields
}

func (DeleteManagedEndpointOutput) GoString 

func (s DeleteManagedEndpointOutput) GoString() string

GoString returns the string representation

func (*DeleteManagedEndpointOutput) SetId 

func (s *DeleteManagedEndpointOutput) SetId(v string) *DeleteManagedEndpointOutput

SetId sets the Id field's value.

func (*DeleteManagedEndpointOutput) SetVirtualClusterId 

func (s *DeleteManagedEndpointOutput) SetVirtualClusterId(v string) *DeleteManagedEndpointOutput

SetVirtualClusterId sets the VirtualClusterId field's value.

func (DeleteManagedEndpointOutput) String 

func (s DeleteManagedEndpointOutput) String() string

String returns the string representation

type DeleteVirtualClusterInput 

type DeleteVirtualClusterInput struct {

	// The ID of the virtual cluster that will be deleted.
	//
	// Id is a required field
	Id *string `location:"uri" locationName:"virtualClusterId" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (DeleteVirtualClusterInput) GoString 

func (s DeleteVirtualClusterInput) GoString() string

GoString returns the string representation

func (*DeleteVirtualClusterInput) SetId 

func (s *DeleteVirtualClusterInput) SetId(v string) *DeleteVirtualClusterInput

SetId sets the Id field's value.

func (DeleteVirtualClusterInput) String 

func (s DeleteVirtualClusterInput) String() string

String returns the string representation

func (*DeleteVirtualClusterInput) Validate 

func (s *DeleteVirtualClusterInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DeleteVirtualClusterOutput 

type DeleteVirtualClusterOutput struct {

	// This output contains the ID of the virtual cluster that will be deleted.
	Id *string `locationName:"id" min:"1" type:"string"`
	// contains filtered or unexported fields
}

func (DeleteVirtualClusterOutput) GoString 

func (s DeleteVirtualClusterOutput) GoString() string

GoString returns the string representation

func (*DeleteVirtualClusterOutput) SetId 

func (s *DeleteVirtualClusterOutput) SetId(v string) *DeleteVirtualClusterOutput

SetId sets the Id field's value.

func (DeleteVirtualClusterOutput) String 

func (s DeleteVirtualClusterOutput) String() string

String returns the string representation

type DescribeJobRunInput 

type DescribeJobRunInput struct {

	// The ID of the job run request.
	//
	// Id is a required field
	Id *string `location:"uri" locationName:"jobRunId" min:"1" type:"string" required:"true"`

	// The ID of the virtual cluster for which the job run is submitted.
	//
	// VirtualClusterId is a required field
	VirtualClusterId *string `location:"uri" locationName:"virtualClusterId" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (DescribeJobRunInput) GoString 

func (s DescribeJobRunInput) GoString() string

GoString returns the string representation

func (*DescribeJobRunInput) SetId 

func (s *DescribeJobRunInput) SetId(v string) *DescribeJobRunInput

SetId sets the Id field's value.

func (*DescribeJobRunInput) SetVirtualClusterId 

func (s *DescribeJobRunInput) SetVirtualClusterId(v string) *DescribeJobRunInput

SetVirtualClusterId sets the VirtualClusterId field's value.

func (DescribeJobRunInput) String 

func (s DescribeJobRunInput) String() string

String returns the string representation

func (*DescribeJobRunInput) Validate 

func (s *DescribeJobRunInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DescribeJobRunOutput 

type DescribeJobRunOutput struct {

	// The output displays information about a job run.
	JobRun *JobRun `locationName:"jobRun" type:"structure"`
	// contains filtered or unexported fields
}

func (DescribeJobRunOutput) GoString 

func (s DescribeJobRunOutput) GoString() string

GoString returns the string representation

func (*DescribeJobRunOutput) SetJobRun 

func (s *DescribeJobRunOutput) SetJobRun(v *JobRun) *DescribeJobRunOutput

SetJobRun sets the JobRun field's value.

func (DescribeJobRunOutput) String 

func (s DescribeJobRunOutput) String() string

String returns the string representation

type DescribeManagedEndpointInput 

type DescribeManagedEndpointInput struct {

	// This output displays ID of the managed endpoint.
	//
	// Id is a required field
	Id *string `location:"uri" locationName:"endpointId" min:"1" type:"string" required:"true"`

	// The ID of the endpoint's virtual cluster.
	//
	// VirtualClusterId is a required field
	VirtualClusterId *string `location:"uri" locationName:"virtualClusterId" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (DescribeManagedEndpointInput) GoString 

func (s DescribeManagedEndpointInput) GoString() string

GoString returns the string representation

func (*DescribeManagedEndpointInput) SetId 

func (s *DescribeManagedEndpointInput) SetId(v string) *DescribeManagedEndpointInput

SetId sets the Id field's value.

func (*DescribeManagedEndpointInput) SetVirtualClusterId 

func (s *DescribeManagedEndpointInput) SetVirtualClusterId(v string) *DescribeManagedEndpointInput

SetVirtualClusterId sets the VirtualClusterId field's value.

func (DescribeManagedEndpointInput) String 

func (s DescribeManagedEndpointInput) String() string

String returns the string representation

func (*DescribeManagedEndpointInput) Validate 

func (s *DescribeManagedEndpointInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DescribeManagedEndpointOutput 

type DescribeManagedEndpointOutput struct {

	// This output displays information about a managed endpoint.
	Endpoint *Endpoint `locationName:"endpoint" type:"structure"`
	// contains filtered or unexported fields
}

func (DescribeManagedEndpointOutput) GoString 

func (s DescribeManagedEndpointOutput) GoString() string

GoString returns the string representation

func (*DescribeManagedEndpointOutput) SetEndpoint 

func (s *DescribeManagedEndpointOutput) SetEndpoint(v *Endpoint) *DescribeManagedEndpointOutput

SetEndpoint sets the Endpoint field's value.

func (DescribeManagedEndpointOutput) String 

func (s DescribeManagedEndpointOutput) String() string

String returns the string representation

type DescribeVirtualClusterInput 

type DescribeVirtualClusterInput struct {

	// The ID of the virtual cluster that will be described.
	//
	// Id is a required field
	Id *string `location:"uri" locationName:"virtualClusterId" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (DescribeVirtualClusterInput) GoString 

func (s DescribeVirtualClusterInput) GoString() string

GoString returns the string representation

func (*DescribeVirtualClusterInput) SetId 

func (s *DescribeVirtualClusterInput) SetId(v string) *DescribeVirtualClusterInput

SetId sets the Id field's value.

func (DescribeVirtualClusterInput) String 

func (s DescribeVirtualClusterInput) String() string

String returns the string representation

func (*DescribeVirtualClusterInput) Validate 

func (s *DescribeVirtualClusterInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DescribeVirtualClusterOutput 

type DescribeVirtualClusterOutput struct {

	// This output displays information about the specified virtual cluster.
	VirtualCluster *VirtualCluster `locationName:"virtualCluster" type:"structure"`
	// contains filtered or unexported fields
}

func (DescribeVirtualClusterOutput) GoString 

func (s DescribeVirtualClusterOutput) GoString() string

GoString returns the string representation

func (*DescribeVirtualClusterOutput) SetVirtualCluster 

func (s *DescribeVirtualClusterOutput) SetVirtualCluster(v *VirtualCluster) *DescribeVirtualClusterOutput

SetVirtualCluster sets the VirtualCluster field's value.

func (DescribeVirtualClusterOutput) String 

func (s DescribeVirtualClusterOutput) String() string

String returns the string representation

type EMRContainers 

type EMRContainers struct {
	*client.Client
}

EMRContainers provides the API operation methods for making requests to Amazon EMR Containers. See this package's package overview docs for details on the service.

EMRContainers methods are safe to use concurrently. It is not safe to modify mutate any of the struct's properties though.

func New 

func New(p client.ConfigProvider, cfgs ...*aws.Config) *EMRContainers

New creates a new instance of the EMRContainers client with a session. If additional configuration is needed for the client instance use the optional aws.Config parameter to add your extra config.

Example: 

mySession := session.Must(session.NewSession())

// Create a EMRContainers client from just a session.
svc := emrcontainers.New(mySession)

// Create a EMRContainers client with additional configuration
svc := emrcontainers.New(mySession, aws.NewConfig().WithRegion("us-west-2"))

func (*EMRContainers) CancelJobRun 

func (c *EMRContainers) CancelJobRun(input *CancelJobRunInput) (*CancelJobRunOutput, error)

CancelJobRun API operation for Amazon EMR Containers.

Cancels a job run. A job run is a unit of work, such as a Spark jar, PySpark script, or SparkSQL query, that you submit to Amazon EMR on EKS.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EMR Containers's API operation CancelJobRun for usage and error information.

Returned Error Types:

  • ValidationException There are invalid parameters in the client request.

  • InternalServerException This is an internal server exception.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/CancelJobRun

func (*EMRContainers) CancelJobRunRequest 

func (c *EMRContainers) CancelJobRunRequest(input *CancelJobRunInput) (req *request.Request, output *CancelJobRunOutput)

CancelJobRunRequest generates a "aws/request.Request" representing the client's request for the CancelJobRun operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See CancelJobRun for more information on using the CancelJobRun API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the CancelJobRunRequest method.
req, resp := client.CancelJobRunRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/CancelJobRun

func (*EMRContainers) CancelJobRunWithContext 

func (c *EMRContainers) CancelJobRunWithContext(ctx aws.Context, input *CancelJobRunInput, opts ...request.Option) (*CancelJobRunOutput, error)

CancelJobRunWithContext is the same as CancelJobRun with the addition of the ability to pass a context and additional request options.

See CancelJobRun for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRContainers) CreateManagedEndpoint 

func (c *EMRContainers) CreateManagedEndpoint(input *CreateManagedEndpointInput) (*CreateManagedEndpointOutput, error)

CreateManagedEndpoint API operation for Amazon EMR Containers.

Creates a managed endpoint. A managed endpoint is a gateway that connects EMR Studio to Amazon EMR on EKS so that EMR Studio can communicate with your virtual cluster.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EMR Containers's API operation CreateManagedEndpoint for usage and error information.

Returned Error Types:

  • ValidationException There are invalid parameters in the client request.

  • ResourceNotFoundException The specified resource was not found.

  • InternalServerException This is an internal server exception.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/CreateManagedEndpoint

func (*EMRContainers) CreateManagedEndpointRequest 

func (c *EMRContainers) CreateManagedEndpointRequest(input *CreateManagedEndpointInput) (req *request.Request, output *CreateManagedEndpointOutput)

CreateManagedEndpointRequest generates a "aws/request.Request" representing the client's request for the CreateManagedEndpoint operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See CreateManagedEndpoint for more information on using the CreateManagedEndpoint API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the CreateManagedEndpointRequest method.
req, resp := client.CreateManagedEndpointRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/CreateManagedEndpoint

func (*EMRContainers) CreateManagedEndpointWithContext 

func (c *EMRContainers) CreateManagedEndpointWithContext(ctx aws.Context, input *CreateManagedEndpointInput, opts ...request.Option) (*CreateManagedEndpointOutput, error)

CreateManagedEndpointWithContext is the same as CreateManagedEndpoint with the addition of the ability to pass a context and additional request options.

See CreateManagedEndpoint for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRContainers) CreateVirtualCluster 

func (c *EMRContainers) CreateVirtualCluster(input *CreateVirtualClusterInput) (*CreateVirtualClusterOutput, error)

CreateVirtualCluster API operation for Amazon EMR Containers.

Creates a virtual cluster. Virtual cluster is a managed entity on Amazon EMR on EKS. You can create, describe, list and delete virtual clusters. They do not consume any additional resource in your system. A single virtual cluster maps to a single Kubernetes namespace. Given this relationship, you can model virtual clusters the same way you model Kubernetes namespaces to meet your requirements.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EMR Containers's API operation CreateVirtualCluster for usage and error information.

Returned Error Types:

  • ValidationException There are invalid parameters in the client request.

  • ResourceNotFoundException The specified resource was not found.

  • InternalServerException This is an internal server exception.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/CreateVirtualCluster

func (*EMRContainers) CreateVirtualClusterRequest 

func (c *EMRContainers) CreateVirtualClusterRequest(input *CreateVirtualClusterInput) (req *request.Request, output *CreateVirtualClusterOutput)

CreateVirtualClusterRequest generates a "aws/request.Request" representing the client's request for the CreateVirtualCluster operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See CreateVirtualCluster for more information on using the CreateVirtualCluster API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the CreateVirtualClusterRequest method.
req, resp := client.CreateVirtualClusterRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/CreateVirtualCluster

func (*EMRContainers) CreateVirtualClusterWithContext 

func (c *EMRContainers) CreateVirtualClusterWithContext(ctx aws.Context, input *CreateVirtualClusterInput, opts ...request.Option) (*CreateVirtualClusterOutput, error)

CreateVirtualClusterWithContext is the same as CreateVirtualCluster with the addition of the ability to pass a context and additional request options.

See CreateVirtualCluster for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRContainers) DeleteManagedEndpoint 

func (c *EMRContainers) DeleteManagedEndpoint(input *DeleteManagedEndpointInput) (*DeleteManagedEndpointOutput, error)

DeleteManagedEndpoint API operation for Amazon EMR Containers.

Deletes a managed endpoint. A managed endpoint is a gateway that connects EMR Studio to Amazon EMR on EKS so that EMR Studio can communicate with your virtual cluster.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EMR Containers's API operation DeleteManagedEndpoint for usage and error information.

Returned Error Types:

  • ValidationException There are invalid parameters in the client request.

  • InternalServerException This is an internal server exception.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/DeleteManagedEndpoint

func (*EMRContainers) DeleteManagedEndpointRequest 

func (c *EMRContainers) DeleteManagedEndpointRequest(input *DeleteManagedEndpointInput) (req *request.Request, output *DeleteManagedEndpointOutput)

DeleteManagedEndpointRequest generates a "aws/request.Request" representing the client's request for the DeleteManagedEndpoint operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See DeleteManagedEndpoint for more information on using the DeleteManagedEndpoint API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the DeleteManagedEndpointRequest method.
req, resp := client.DeleteManagedEndpointRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/DeleteManagedEndpoint

func (*EMRContainers) DeleteManagedEndpointWithContext 

func (c *EMRContainers) DeleteManagedEndpointWithContext(ctx aws.Context, input *DeleteManagedEndpointInput, opts ...request.Option) (*DeleteManagedEndpointOutput, error)

DeleteManagedEndpointWithContext is the same as DeleteManagedEndpoint with the addition of the ability to pass a context and additional request options.

See DeleteManagedEndpoint for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRContainers) DeleteVirtualCluster 

func (c *EMRContainers) DeleteVirtualCluster(input *DeleteVirtualClusterInput) (*DeleteVirtualClusterOutput, error)

DeleteVirtualCluster API operation for Amazon EMR Containers.

Deletes a virtual cluster. Virtual cluster is a managed entity on Amazon EMR on EKS. You can create, describe, list and delete virtual clusters. They do not consume any additional resource in your system. A single virtual cluster maps to a single Kubernetes namespace. Given this relationship, you can model virtual clusters the same way you model Kubernetes namespaces to meet your requirements.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EMR Containers's API operation DeleteVirtualCluster for usage and error information.

Returned Error Types:

  • ValidationException There are invalid parameters in the client request.

  • InternalServerException This is an internal server exception.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/DeleteVirtualCluster

func (*EMRContainers) DeleteVirtualClusterRequest 

func (c *EMRContainers) DeleteVirtualClusterRequest(input *DeleteVirtualClusterInput) (req *request.Request, output *DeleteVirtualClusterOutput)

DeleteVirtualClusterRequest generates a "aws/request.Request" representing the client's request for the DeleteVirtualCluster operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See DeleteVirtualCluster for more information on using the DeleteVirtualCluster API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the DeleteVirtualClusterRequest method.
req, resp := client.DeleteVirtualClusterRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/DeleteVirtualCluster

func (*EMRContainers) DeleteVirtualClusterWithContext 

func (c *EMRContainers) DeleteVirtualClusterWithContext(ctx aws.Context, input *DeleteVirtualClusterInput, opts ...request.Option) (*DeleteVirtualClusterOutput, error)

DeleteVirtualClusterWithContext is the same as DeleteVirtualCluster with the addition of the ability to pass a context and additional request options.

See DeleteVirtualCluster for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRContainers) DescribeJobRun 

func (c *EMRContainers) DescribeJobRun(input *DescribeJobRunInput) (*DescribeJobRunOutput, error)

DescribeJobRun API operation for Amazon EMR Containers.

Displays detailed information about a job run. A job run is a unit of work, such as a Spark jar, PySpark script, or SparkSQL query, that you submit to Amazon EMR on EKS.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EMR Containers's API operation DescribeJobRun for usage and error information.

Returned Error Types:

  • ValidationException There are invalid parameters in the client request.

  • ResourceNotFoundException The specified resource was not found.

  • InternalServerException This is an internal server exception.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/DescribeJobRun

func (*EMRContainers) DescribeJobRunRequest 

func (c *EMRContainers) DescribeJobRunRequest(input *DescribeJobRunInput) (req *request.Request, output *DescribeJobRunOutput)

DescribeJobRunRequest generates a "aws/request.Request" representing the client's request for the DescribeJobRun operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See DescribeJobRun for more information on using the DescribeJobRun API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the DescribeJobRunRequest method.
req, resp := client.DescribeJobRunRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/DescribeJobRun

func (*EMRContainers) DescribeJobRunWithContext 

func (c *EMRContainers) DescribeJobRunWithContext(ctx aws.Context, input *DescribeJobRunInput, opts ...request.Option) (*DescribeJobRunOutput, error)

DescribeJobRunWithContext is the same as DescribeJobRun with the addition of the ability to pass a context and additional request options.

See DescribeJobRun for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRContainers) DescribeManagedEndpoint 

func (c *EMRContainers) DescribeManagedEndpoint(input *DescribeManagedEndpointInput) (*DescribeManagedEndpointOutput, error)

DescribeManagedEndpoint API operation for Amazon EMR Containers.

Displays detailed information about a managed endpoint. A managed endpoint is a gateway that connects EMR Studio to Amazon EMR on EKS so that EMR Studio can communicate with your virtual cluster.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EMR Containers's API operation DescribeManagedEndpoint for usage and error information.

Returned Error Types:

  • ValidationException There are invalid parameters in the client request.

  • ResourceNotFoundException The specified resource was not found.

  • InternalServerException This is an internal server exception.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/DescribeManagedEndpoint

func (*EMRContainers) DescribeManagedEndpointRequest 

func (c *EMRContainers) DescribeManagedEndpointRequest(input *DescribeManagedEndpointInput) (req *request.Request, output *DescribeManagedEndpointOutput)

DescribeManagedEndpointRequest generates a "aws/request.Request" representing the client's request for the DescribeManagedEndpoint operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See DescribeManagedEndpoint for more information on using the DescribeManagedEndpoint API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the DescribeManagedEndpointRequest method.
req, resp := client.DescribeManagedEndpointRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/DescribeManagedEndpoint

func (*EMRContainers) DescribeManagedEndpointWithContext 

func (c *EMRContainers) DescribeManagedEndpointWithContext(ctx aws.Context, input *DescribeManagedEndpointInput, opts ...request.Option) (*DescribeManagedEndpointOutput, error)

DescribeManagedEndpointWithContext is the same as DescribeManagedEndpoint with the addition of the ability to pass a context and additional request options.

See DescribeManagedEndpoint for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRContainers) DescribeVirtualCluster 

func (c *EMRContainers) DescribeVirtualCluster(input *DescribeVirtualClusterInput) (*DescribeVirtualClusterOutput, error)

DescribeVirtualCluster API operation for Amazon EMR Containers.

Displays detailed information about a specified virtual cluster. Virtual cluster is a managed entity on Amazon EMR on EKS. You can create, describe, list and delete virtual clusters. They do not consume any additional resource in your system. A single virtual cluster maps to a single Kubernetes namespace. Given this relationship, you can model virtual clusters the same way you model Kubernetes namespaces to meet your requirements.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EMR Containers's API operation DescribeVirtualCluster for usage and error information.

Returned Error Types:

  • ValidationException There are invalid parameters in the client request.

  • ResourceNotFoundException The specified resource was not found.

  • InternalServerException This is an internal server exception.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/DescribeVirtualCluster

func (*EMRContainers) DescribeVirtualClusterRequest 

func (c *EMRContainers) DescribeVirtualClusterRequest(input *DescribeVirtualClusterInput) (req *request.Request, output *DescribeVirtualClusterOutput)

DescribeVirtualClusterRequest generates a "aws/request.Request" representing the client's request for the DescribeVirtualCluster operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See DescribeVirtualCluster for more information on using the DescribeVirtualCluster API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the DescribeVirtualClusterRequest method.
req, resp := client.DescribeVirtualClusterRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/DescribeVirtualCluster

func (*EMRContainers) DescribeVirtualClusterWithContext 

func (c *EMRContainers) DescribeVirtualClusterWithContext(ctx aws.Context, input *DescribeVirtualClusterInput, opts ...request.Option) (*DescribeVirtualClusterOutput, error)

DescribeVirtualClusterWithContext is the same as DescribeVirtualCluster with the addition of the ability to pass a context and additional request options.

See DescribeVirtualCluster for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRContainers) ListJobRuns 

func (c *EMRContainers) ListJobRuns(input *ListJobRunsInput) (*ListJobRunsOutput, error)

ListJobRuns API operation for Amazon EMR Containers.

Lists job runs based on a set of parameters. A job run is a unit of work, such as a Spark jar, PySpark script, or SparkSQL query, that you submit to Amazon EMR on EKS.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EMR Containers's API operation ListJobRuns for usage and error information.

Returned Error Types:

  • ValidationException There are invalid parameters in the client request.

  • InternalServerException This is an internal server exception.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/ListJobRuns

func (*EMRContainers) ListJobRunsPages 

func (c *EMRContainers) ListJobRunsPages(input *ListJobRunsInput, fn func(*ListJobRunsOutput, bool) bool) error

ListJobRunsPages iterates over the pages of a ListJobRuns operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See ListJobRuns method for more information on how to use this operation.

Note: This operation can generate multiple requests to a service. 

// Example iterating over at most 3 pages of a ListJobRuns operation.
pageNum := 0
err := client.ListJobRunsPages(params,
    func(page *emrcontainers.ListJobRunsOutput, lastPage bool) bool {
        pageNum++
        fmt.Println(page)
        return pageNum <= 3
    })

func (*EMRContainers) ListJobRunsPagesWithContext 

func (c *EMRContainers) ListJobRunsPagesWithContext(ctx aws.Context, input *ListJobRunsInput, fn func(*ListJobRunsOutput, bool) bool, opts ...request.Option) error

ListJobRunsPagesWithContext same as ListJobRunsPages except it takes a Context and allows setting request options on the pages.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRContainers) ListJobRunsRequest 

func (c *EMRContainers) ListJobRunsRequest(input *ListJobRunsInput) (req *request.Request, output *ListJobRunsOutput)

ListJobRunsRequest generates a "aws/request.Request" representing the client's request for the ListJobRuns operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See ListJobRuns for more information on using the ListJobRuns API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the ListJobRunsRequest method.
req, resp := client.ListJobRunsRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/ListJobRuns

func (*EMRContainers) ListJobRunsWithContext 

func (c *EMRContainers) ListJobRunsWithContext(ctx aws.Context, input *ListJobRunsInput, opts ...request.Option) (*ListJobRunsOutput, error)

ListJobRunsWithContext is the same as ListJobRuns with the addition of the ability to pass a context and additional request options.

See ListJobRuns for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRContainers) ListManagedEndpoints 

func (c *EMRContainers) ListManagedEndpoints(input *ListManagedEndpointsInput) (*ListManagedEndpointsOutput, error)

ListManagedEndpoints API operation for Amazon EMR Containers.

Lists managed endpoints based on a set of parameters. A managed endpoint is a gateway that connects EMR Studio to Amazon EMR on EKS so that EMR Studio can communicate with your virtual cluster.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EMR Containers's API operation ListManagedEndpoints for usage and error information.

Returned Error Types:

  • ValidationException There are invalid parameters in the client request.

  • InternalServerException This is an internal server exception.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/ListManagedEndpoints

func (*EMRContainers) ListManagedEndpointsPages 

func (c *EMRContainers) ListManagedEndpointsPages(input *ListManagedEndpointsInput, fn func(*ListManagedEndpointsOutput, bool) bool) error

ListManagedEndpointsPages iterates over the pages of a ListManagedEndpoints operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See ListManagedEndpoints method for more information on how to use this operation.

Note: This operation can generate multiple requests to a service. 

// Example iterating over at most 3 pages of a ListManagedEndpoints operation.
pageNum := 0
err := client.ListManagedEndpointsPages(params,
    func(page *emrcontainers.ListManagedEndpointsOutput, lastPage bool) bool {
        pageNum++
        fmt.Println(page)
        return pageNum <= 3
    })

func (*EMRContainers) ListManagedEndpointsPagesWithContext 

func (c *EMRContainers) ListManagedEndpointsPagesWithContext(ctx aws.Context, input *ListManagedEndpointsInput, fn func(*ListManagedEndpointsOutput, bool) bool, opts ...request.Option) error

ListManagedEndpointsPagesWithContext same as ListManagedEndpointsPages except it takes a Context and allows setting request options on the pages.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRContainers) ListManagedEndpointsRequest 

func (c *EMRContainers) ListManagedEndpointsRequest(input *ListManagedEndpointsInput) (req *request.Request, output *ListManagedEndpointsOutput)

ListManagedEndpointsRequest generates a "aws/request.Request" representing the client's request for the ListManagedEndpoints operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See ListManagedEndpoints for more information on using the ListManagedEndpoints API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the ListManagedEndpointsRequest method.
req, resp := client.ListManagedEndpointsRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/ListManagedEndpoints

func (*EMRContainers) ListManagedEndpointsWithContext 

func (c *EMRContainers) ListManagedEndpointsWithContext(ctx aws.Context, input *ListManagedEndpointsInput, opts ...request.Option) (*ListManagedEndpointsOutput, error)

ListManagedEndpointsWithContext is the same as ListManagedEndpoints with the addition of the ability to pass a context and additional request options.

See ListManagedEndpoints for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRContainers) ListTagsForResource 

func (c *EMRContainers) ListTagsForResource(input *ListTagsForResourceInput) (*ListTagsForResourceOutput, error)

ListTagsForResource API operation for Amazon EMR Containers.

Lists the tags assigned to the resources.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EMR Containers's API operation ListTagsForResource for usage and error information.

Returned Error Types:

  • InternalServerException This is an internal server exception.

  • ValidationException There are invalid parameters in the client request.

  • ResourceNotFoundException The specified resource was not found.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/ListTagsForResource

func (*EMRContainers) ListTagsForResourceRequest 

func (c *EMRContainers) ListTagsForResourceRequest(input *ListTagsForResourceInput) (req *request.Request, output *ListTagsForResourceOutput)

ListTagsForResourceRequest generates a "aws/request.Request" representing the client's request for the ListTagsForResource operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See ListTagsForResource for more information on using the ListTagsForResource API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the ListTagsForResourceRequest method.
req, resp := client.ListTagsForResourceRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/ListTagsForResource

func (*EMRContainers) ListTagsForResourceWithContext 

func (c *EMRContainers) ListTagsForResourceWithContext(ctx aws.Context, input *ListTagsForResourceInput, opts ...request.Option) (*ListTagsForResourceOutput, error)

ListTagsForResourceWithContext is the same as ListTagsForResource with the addition of the ability to pass a context and additional request options.

See ListTagsForResource for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRContainers) ListVirtualClusters 

func (c *EMRContainers) ListVirtualClusters(input *ListVirtualClustersInput) (*ListVirtualClustersOutput, error)

ListVirtualClusters API operation for Amazon EMR Containers.

Lists information about the specified virtual cluster. Virtual cluster is a managed entity on Amazon EMR on EKS. You can create, describe, list and delete virtual clusters. They do not consume any additional resource in your system. A single virtual cluster maps to a single Kubernetes namespace. Given this relationship, you can model virtual clusters the same way you model Kubernetes namespaces to meet your requirements.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EMR Containers's API operation ListVirtualClusters for usage and error information.

Returned Error Types:

  • ValidationException There are invalid parameters in the client request.

  • InternalServerException This is an internal server exception.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/ListVirtualClusters

func (*EMRContainers) ListVirtualClustersPages 

func (c *EMRContainers) ListVirtualClustersPages(input *ListVirtualClustersInput, fn func(*ListVirtualClustersOutput, bool) bool) error

ListVirtualClustersPages iterates over the pages of a ListVirtualClusters operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.

See ListVirtualClusters method for more information on how to use this operation.

Note: This operation can generate multiple requests to a service. 

// Example iterating over at most 3 pages of a ListVirtualClusters operation.
pageNum := 0
err := client.ListVirtualClustersPages(params,
    func(page *emrcontainers.ListVirtualClustersOutput, lastPage bool) bool {
        pageNum++
        fmt.Println(page)
        return pageNum <= 3
    })

func (*EMRContainers) ListVirtualClustersPagesWithContext 

func (c *EMRContainers) ListVirtualClustersPagesWithContext(ctx aws.Context, input *ListVirtualClustersInput, fn func(*ListVirtualClustersOutput, bool) bool, opts ...request.Option) error

ListVirtualClustersPagesWithContext same as ListVirtualClustersPages except it takes a Context and allows setting request options on the pages.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRContainers) ListVirtualClustersRequest 

func (c *EMRContainers) ListVirtualClustersRequest(input *ListVirtualClustersInput) (req *request.Request, output *ListVirtualClustersOutput)

ListVirtualClustersRequest generates a "aws/request.Request" representing the client's request for the ListVirtualClusters operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See ListVirtualClusters for more information on using the ListVirtualClusters API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the ListVirtualClustersRequest method.
req, resp := client.ListVirtualClustersRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/ListVirtualClusters

func (*EMRContainers) ListVirtualClustersWithContext 

func (c *EMRContainers) ListVirtualClustersWithContext(ctx aws.Context, input *ListVirtualClustersInput, opts ...request.Option) (*ListVirtualClustersOutput, error)

ListVirtualClustersWithContext is the same as ListVirtualClusters with the addition of the ability to pass a context and additional request options.

See ListVirtualClusters for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRContainers) StartJobRun 

func (c *EMRContainers) StartJobRun(input *StartJobRunInput) (*StartJobRunOutput, error)

StartJobRun API operation for Amazon EMR Containers.

Starts a job run. A job run is a unit of work, such as a Spark jar, PySpark script, or SparkSQL query, that you submit to Amazon EMR on EKS.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EMR Containers's API operation StartJobRun for usage and error information.

Returned Error Types:

  • ValidationException There are invalid parameters in the client request.

  • ResourceNotFoundException The specified resource was not found.

  • InternalServerException This is an internal server exception.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/StartJobRun

func (*EMRContainers) StartJobRunRequest 

func (c *EMRContainers) StartJobRunRequest(input *StartJobRunInput) (req *request.Request, output *StartJobRunOutput)

StartJobRunRequest generates a "aws/request.Request" representing the client's request for the StartJobRun operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See StartJobRun for more information on using the StartJobRun API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the StartJobRunRequest method.
req, resp := client.StartJobRunRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/StartJobRun

func (*EMRContainers) StartJobRunWithContext 

func (c *EMRContainers) StartJobRunWithContext(ctx aws.Context, input *StartJobRunInput, opts ...request.Option) (*StartJobRunOutput, error)

StartJobRunWithContext is the same as StartJobRun with the addition of the ability to pass a context and additional request options.

See StartJobRun for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRContainers) TagResource 

func (c *EMRContainers) TagResource(input *TagResourceInput) (*TagResourceOutput, error)

TagResource API operation for Amazon EMR Containers.

Assigns tags to resources. A tag is a label that you assign to an AWS resource. Each tag consists of a key and an optional value, both of which you define. Tags enable you to categorize your AWS resources by attributes such as purpose, owner, or environment. When you have many resources of the same type, you can quickly identify a specific resource based on the tags you've assigned to it. For example, you can define a set of tags for your Amazon EMR on EKS clusters to help you track each cluster's owner and stack level. We recommend that you devise a consistent set of tag keys for each resource type. You can then search and filter the resources based on the tags that you add.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EMR Containers's API operation TagResource for usage and error information.

Returned Error Types:

  • InternalServerException This is an internal server exception.

  • ValidationException There are invalid parameters in the client request.

  • ResourceNotFoundException The specified resource was not found.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/TagResource

func (*EMRContainers) TagResourceRequest 

func (c *EMRContainers) TagResourceRequest(input *TagResourceInput) (req *request.Request, output *TagResourceOutput)

TagResourceRequest generates a "aws/request.Request" representing the client's request for the TagResource operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See TagResource for more information on using the TagResource API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the TagResourceRequest method.
req, resp := client.TagResourceRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/TagResource

func (*EMRContainers) TagResourceWithContext 

func (c *EMRContainers) TagResourceWithContext(ctx aws.Context, input *TagResourceInput, opts ...request.Option) (*TagResourceOutput, error)

TagResourceWithContext is the same as TagResource with the addition of the ability to pass a context and additional request options.

See TagResource for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

func (*EMRContainers) UntagResource 

func (c *EMRContainers) UntagResource(input *UntagResourceInput) (*UntagResourceOutput, error)

UntagResource API operation for Amazon EMR Containers.

Removes tags from resources.

Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.

See the AWS API reference guide for Amazon EMR Containers's API operation UntagResource for usage and error information.

Returned Error Types:

  • InternalServerException This is an internal server exception.

  • ValidationException There are invalid parameters in the client request.

  • ResourceNotFoundException The specified resource was not found.

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/UntagResource

func (*EMRContainers) UntagResourceRequest 

func (c *EMRContainers) UntagResourceRequest(input *UntagResourceInput) (req *request.Request, output *UntagResourceOutput)

UntagResourceRequest generates a "aws/request.Request" representing the client's request for the UntagResource operation. The "output" return value will be populated with the request's response once the request completes successfully.

Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.

See UntagResource for more information on using the UntagResource API call, and error handling.

This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic. 

// Example sending a request using the UntagResourceRequest method.
req, resp := client.UntagResourceRequest(params)

err := req.Send()
if err == nil { // resp is now filled
    fmt.Println(resp)
}

See also, https://docs.aws.amazon.com/goto/WebAPI/emr-containers-2020-10-01/UntagResource

func (*EMRContainers) UntagResourceWithContext 

func (c *EMRContainers) UntagResourceWithContext(ctx aws.Context, input *UntagResourceInput, opts ...request.Option) (*UntagResourceOutput, error)

UntagResourceWithContext is the same as UntagResource with the addition of the ability to pass a context and additional request options.

See UntagResource for details on how to use this API operation.

The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.

type EksInfo 

type EksInfo struct {

	// The namespaces of the EKS cluster.
	Namespace *string `locationName:"namespace" min:"1" type:"string"`
	// contains filtered or unexported fields
}

The information about the EKS cluster.

func (EksInfo) GoString 

func (s EksInfo) GoString() string

GoString returns the string representation

func (*EksInfo) SetNamespace 

func (s *EksInfo) SetNamespace(v string) *EksInfo

SetNamespace sets the Namespace field's value.

func (EksInfo) String 

func (s EksInfo) String() string

String returns the string representation

func (*EksInfo) Validate 

func (s *EksInfo) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type Endpoint 

type Endpoint struct {

	// The ARN of the endpoint.
	Arn *string `locationName:"arn" min:"60" type:"string"`

	// The certificate ARN of the endpoint.
	CertificateArn *string `locationName:"certificateArn" min:"44" type:"string"`

	// The configuration settings that are used to override existing configurations
	// for endpoints.
	ConfigurationOverrides *ConfigurationOverrides `locationName:"configurationOverrides" type:"structure"`

	// The date and time when the endpoint was created.
	CreatedAt *time.Time `locationName:"createdAt" type:"timestamp" timestampFormat:"iso8601"`

	// The execution role ARN of the endpoint.
	ExecutionRoleArn *string `locationName:"executionRoleArn" min:"20" type:"string"`

	// The ID of the endpoint.
	Id *string `locationName:"id" min:"1" type:"string"`

	// The name of the endpoint.
	Name *string `locationName:"name" min:"1" type:"string"`

	// The EMR release version to be used for the endpoint.
	ReleaseLabel *string `locationName:"releaseLabel" min:"1" type:"string"`

	// The security group configuration of the endpoint.
	SecurityGroup *string `locationName:"securityGroup" min:"1" type:"string"`

	// The server URL of the endpoint.
	ServerUrl *string `locationName:"serverUrl" min:"1" type:"string"`

	// The state of the endpoint.
	State *string `locationName:"state" type:"string" enum:"EndpointState"`

	// The subnet IDs of the endpoint.
	SubnetIds []*string `locationName:"subnetIds" type:"list"`

	// The tags of the endpoint.
	Tags map[string]*string `locationName:"tags" type:"map"`

	// The type of the endpoint.
	Type *string `locationName:"type" min:"1" type:"string"`

	// The ID of the endpoint's virtual cluster.
	VirtualClusterId *string `locationName:"virtualClusterId" min:"1" type:"string"`
	// contains filtered or unexported fields
}

This entity represents the endpoint that is managed by Amazon EMR on EKS.

func (Endpoint) GoString 

func (s Endpoint) GoString() string

GoString returns the string representation

func (*Endpoint) SetArn 

func (s *Endpoint) SetArn(v string) *Endpoint

SetArn sets the Arn field's value.

func (*Endpoint) SetCertificateArn 

func (s *Endpoint) SetCertificateArn(v string) *Endpoint

SetCertificateArn sets the CertificateArn field's value.

func (*Endpoint) SetConfigurationOverrides 

func (s *Endpoint) SetConfigurationOverrides(v *ConfigurationOverrides) *Endpoint

SetConfigurationOverrides sets the ConfigurationOverrides field's value.

func (*Endpoint) SetCreatedAt 

func (s *Endpoint) SetCreatedAt(v time.Time) *Endpoint

SetCreatedAt sets the CreatedAt field's value.

func (*Endpoint) SetExecutionRoleArn 

func (s *Endpoint) SetExecutionRoleArn(v string) *Endpoint

SetExecutionRoleArn sets the ExecutionRoleArn field's value.

func (*Endpoint) SetId 

func (s *Endpoint) SetId(v string) *Endpoint

SetId sets the Id field's value.

func (*Endpoint) SetName 

func (s *Endpoint) SetName(v string) *Endpoint

SetName sets the Name field's value.

func (*Endpoint) SetReleaseLabel 

func (s *Endpoint) SetReleaseLabel(v string) *Endpoint

SetReleaseLabel sets the ReleaseLabel field's value.

func (*Endpoint) SetSecurityGroup 

func (s *Endpoint) SetSecurityGroup(v string) *Endpoint

SetSecurityGroup sets the SecurityGroup field's value.

func (*Endpoint) SetServerUrl 

func (s *Endpoint) SetServerUrl(v string) *Endpoint

SetServerUrl sets the ServerUrl field's value.

func (*Endpoint) SetState 

func (s *Endpoint) SetState(v string) *Endpoint

SetState sets the State field's value.

func (*Endpoint) SetSubnetIds 

func (s *Endpoint) SetSubnetIds(v []*string) *Endpoint

SetSubnetIds sets the SubnetIds field's value.

func (*Endpoint) SetTags 

func (s *Endpoint) SetTags(v map[string]*string) *Endpoint

SetTags sets the Tags field's value.

func (*Endpoint) SetType 

func (s *Endpoint) SetType(v string) *Endpoint

SetType sets the Type field's value.

func (*Endpoint) SetVirtualClusterId 

func (s *Endpoint) SetVirtualClusterId(v string) *Endpoint

SetVirtualClusterId sets the VirtualClusterId field's value.

func (Endpoint) String 

func (s Endpoint) String() string

String returns the string representation

type InternalServerException 

type InternalServerException struct {
	RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`

	Message_ *string `locationName:"message" min:"1" type:"string"`
	// contains filtered or unexported fields
}

This is an internal server exception.

func (*InternalServerException) Code 

func (s *InternalServerException) Code() string

Code returns the exception type name.

func (*InternalServerException) Error 

func (s *InternalServerException) Error() string

func (InternalServerException) GoString 

func (s InternalServerException) GoString() string

GoString returns the string representation

func (*InternalServerException) Message 

func (s *InternalServerException) Message() string

Message returns the exception's message.

func (*InternalServerException) OrigErr 

func (s *InternalServerException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*InternalServerException) RequestID 

func (s *InternalServerException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*InternalServerException) StatusCode 

func (s *InternalServerException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (InternalServerException) String 

func (s InternalServerException) String() string

String returns the string representation

type JobDriver 

type JobDriver struct {

	// The job driver parameters specified for spark submit.
	SparkSubmitJobDriver *SparkSubmitJobDriver `locationName:"sparkSubmitJobDriver" type:"structure"`
	// contains filtered or unexported fields
}

Specify the driver that the job runs on.

func (JobDriver) GoString 

func (s JobDriver) GoString() string

GoString returns the string representation

func (*JobDriver) SetSparkSubmitJobDriver 

func (s *JobDriver) SetSparkSubmitJobDriver(v *SparkSubmitJobDriver) *JobDriver

SetSparkSubmitJobDriver sets the SparkSubmitJobDriver field's value.

func (JobDriver) String 

func (s JobDriver) String() string

String returns the string representation

func (*JobDriver) Validate 

func (s *JobDriver) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type JobRun 

type JobRun struct {

	// The ARN of job run.
	Arn *string `locationName:"arn" min:"60" type:"string"`

	// The client token used to start a job run.
	ClientToken *string `locationName:"clientToken" min:"1" type:"string"`

	// The configuration settings that are used to override default configuration.
	ConfigurationOverrides *ConfigurationOverrides `locationName:"configurationOverrides" type:"structure"`

	// The date and time when the job run was created.
	CreatedAt *time.Time `locationName:"createdAt" type:"timestamp" timestampFormat:"iso8601"`

	// The user who created the job run.
	CreatedBy *string `locationName:"createdBy" min:"20" type:"string"`

	// The execution role ARN of the job run.
	ExecutionRoleArn *string `locationName:"executionRoleArn" min:"20" type:"string"`

	// The reasons why the job run has failed.
	FailureReason *string `locationName:"failureReason" type:"string" enum:"FailureReason"`

	// The date and time when the job run has finished.
	FinishedAt *time.Time `locationName:"finishedAt" type:"timestamp" timestampFormat:"iso8601"`

	// The ID of the job run.
	Id *string `locationName:"id" min:"1" type:"string"`

	// Parameters of job driver for the job run.
	JobDriver *JobDriver `locationName:"jobDriver" type:"structure"`

	// The name of the job run.
	Name *string `locationName:"name" min:"1" type:"string"`

	// The release version of Amazon EMR.
	ReleaseLabel *string `locationName:"releaseLabel" min:"1" type:"string"`

	// The state of the job run.
	State *string `locationName:"state" type:"string" enum:"JobRunState"`

	// Additional details of the job run state.
	StateDetails *string `locationName:"stateDetails" min:"1" type:"string"`

	// The assigned tags of the job run.
	Tags map[string]*string `locationName:"tags" type:"map"`

	// The ID of the job run's virtual cluster.
	VirtualClusterId *string `locationName:"virtualClusterId" min:"1" type:"string"`
	// contains filtered or unexported fields
}

This entity describes a job run. A job run is a unit of work, such as a Spark jar, PySpark script, or SparkSQL query, that you submit to Amazon EMR on EKS.

func (JobRun) GoString 

func (s JobRun) GoString() string

GoString returns the string representation

func (*JobRun) SetArn 

func (s *JobRun) SetArn(v string) *JobRun

SetArn sets the Arn field's value.

func (*JobRun) SetClientToken 

func (s *JobRun) SetClientToken(v string) *JobRun

SetClientToken sets the ClientToken field's value.

func (*JobRun) SetConfigurationOverrides 

func (s *JobRun) SetConfigurationOverrides(v *ConfigurationOverrides) *JobRun

SetConfigurationOverrides sets the ConfigurationOverrides field's value.

func (*JobRun) SetCreatedAt 

func (s *JobRun) SetCreatedAt(v time.Time) *JobRun

SetCreatedAt sets the CreatedAt field's value.

func (*JobRun) SetCreatedBy 

func (s *JobRun) SetCreatedBy(v string) *JobRun

SetCreatedBy sets the CreatedBy field's value.

func (*JobRun) SetExecutionRoleArn 

func (s *JobRun) SetExecutionRoleArn(v string) *JobRun

SetExecutionRoleArn sets the ExecutionRoleArn field's value.

func (*JobRun) SetFailureReason 

func (s *JobRun) SetFailureReason(v string) *JobRun

SetFailureReason sets the FailureReason field's value.

func (*JobRun) SetFinishedAt 

func (s *JobRun) SetFinishedAt(v time.Time) *JobRun

SetFinishedAt sets the FinishedAt field's value.

func (*JobRun) SetId 

func (s *JobRun) SetId(v string) *JobRun

SetId sets the Id field's value.

func (*JobRun) SetJobDriver 

func (s *JobRun) SetJobDriver(v *JobDriver) *JobRun

SetJobDriver sets the JobDriver field's value.

func (*JobRun) SetName 

func (s *JobRun) SetName(v string) *JobRun

SetName sets the Name field's value.

func (*JobRun) SetReleaseLabel 

func (s *JobRun) SetReleaseLabel(v string) *JobRun

SetReleaseLabel sets the ReleaseLabel field's value.

func (*JobRun) SetState 

func (s *JobRun) SetState(v string) *JobRun

SetState sets the State field's value.

func (*JobRun) SetStateDetails 

func (s *JobRun) SetStateDetails(v string) *JobRun

SetStateDetails sets the StateDetails field's value.

func (*JobRun) SetTags 

func (s *JobRun) SetTags(v map[string]*string) *JobRun

SetTags sets the Tags field's value.

func (*JobRun) SetVirtualClusterId 

func (s *JobRun) SetVirtualClusterId(v string) *JobRun

SetVirtualClusterId sets the VirtualClusterId field's value.

func (JobRun) String 

func (s JobRun) String() string

String returns the string representation

type ListJobRunsInput 

type ListJobRunsInput struct {

	// The date and time after which the job runs were submitted.
	CreatedAfter *time.Time `location:"querystring" locationName:"createdAfter" type:"timestamp" timestampFormat:"iso8601"`

	// The date and time before which the job runs were submitted.
	CreatedBefore *time.Time `location:"querystring" locationName:"createdBefore" type:"timestamp" timestampFormat:"iso8601"`

	// The maximum number of job runs that can be listed.
	MaxResults *int64 `location:"querystring" locationName:"maxResults" type:"integer"`

	// The name of the job run.
	Name *string `location:"querystring" locationName:"name" min:"1" type:"string"`

	// The token for the next set of job runs to return.
	NextToken *string `location:"querystring" locationName:"nextToken" min:"1" type:"string"`

	// The states of the job run.
	States []*string `location:"querystring" locationName:"states" type:"list"`

	// The ID of the virtual cluster for which to list the job run.
	//
	// VirtualClusterId is a required field
	VirtualClusterId *string `location:"uri" locationName:"virtualClusterId" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (ListJobRunsInput) GoString 

func (s ListJobRunsInput) GoString() string

GoString returns the string representation

func (*ListJobRunsInput) SetCreatedAfter 

func (s *ListJobRunsInput) SetCreatedAfter(v time.Time) *ListJobRunsInput

SetCreatedAfter sets the CreatedAfter field's value.

func (*ListJobRunsInput) SetCreatedBefore 

func (s *ListJobRunsInput) SetCreatedBefore(v time.Time) *ListJobRunsInput

SetCreatedBefore sets the CreatedBefore field's value.

func (*ListJobRunsInput) SetMaxResults 

func (s *ListJobRunsInput) SetMaxResults(v int64) *ListJobRunsInput

SetMaxResults sets the MaxResults field's value.

func (*ListJobRunsInput) SetName 

func (s *ListJobRunsInput) SetName(v string) *ListJobRunsInput

SetName sets the Name field's value.

func (*ListJobRunsInput) SetNextToken 

func (s *ListJobRunsInput) SetNextToken(v string) *ListJobRunsInput

SetNextToken sets the NextToken field's value.

func (*ListJobRunsInput) SetStates 

func (s *ListJobRunsInput) SetStates(v []*string) *ListJobRunsInput

SetStates sets the States field's value.

func (*ListJobRunsInput) SetVirtualClusterId 

func (s *ListJobRunsInput) SetVirtualClusterId(v string) *ListJobRunsInput

SetVirtualClusterId sets the VirtualClusterId field's value.

func (ListJobRunsInput) String 

func (s ListJobRunsInput) String() string

String returns the string representation

func (*ListJobRunsInput) Validate 

func (s *ListJobRunsInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ListJobRunsOutput 

type ListJobRunsOutput struct {

	// This output lists information about the specified job runs.
	JobRuns []*JobRun `locationName:"jobRuns" type:"list"`

	// This output displays the token for the next set of job runs.
	NextToken *string `locationName:"nextToken" min:"1" type:"string"`
	// contains filtered or unexported fields
}

func (ListJobRunsOutput) GoString 

func (s ListJobRunsOutput) GoString() string

GoString returns the string representation

func (*ListJobRunsOutput) SetJobRuns 

func (s *ListJobRunsOutput) SetJobRuns(v []*JobRun) *ListJobRunsOutput

SetJobRuns sets the JobRuns field's value.

func (*ListJobRunsOutput) SetNextToken 

func (s *ListJobRunsOutput) SetNextToken(v string) *ListJobRunsOutput

SetNextToken sets the NextToken field's value.

func (ListJobRunsOutput) String 

func (s ListJobRunsOutput) String() string

String returns the string representation

type ListManagedEndpointsInput 

type ListManagedEndpointsInput struct {

	// The date and time after which the endpoints are created.
	CreatedAfter *time.Time `location:"querystring" locationName:"createdAfter" type:"timestamp" timestampFormat:"iso8601"`

	// The date and time before which the endpoints are created.
	CreatedBefore *time.Time `location:"querystring" locationName:"createdBefore" type:"timestamp" timestampFormat:"iso8601"`

	// The maximum number of managed endpoints that can be listed.
	MaxResults *int64 `location:"querystring" locationName:"maxResults" type:"integer"`

	// The token for the next set of managed endpoints to return.
	NextToken *string `location:"querystring" locationName:"nextToken" min:"1" type:"string"`

	// The states of the managed endpoints.
	States []*string `location:"querystring" locationName:"states" type:"list"`

	// The types of the managed endpoints.
	Types []*string `location:"querystring" locationName:"types" type:"list"`

	// The ID of the virtual cluster.
	//
	// VirtualClusterId is a required field
	VirtualClusterId *string `location:"uri" locationName:"virtualClusterId" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (ListManagedEndpointsInput) GoString 

func (s ListManagedEndpointsInput) GoString() string

GoString returns the string representation

func (*ListManagedEndpointsInput) SetCreatedAfter 

func (s *ListManagedEndpointsInput) SetCreatedAfter(v time.Time) *ListManagedEndpointsInput

SetCreatedAfter sets the CreatedAfter field's value.

func (*ListManagedEndpointsInput) SetCreatedBefore 

func (s *ListManagedEndpointsInput) SetCreatedBefore(v time.Time) *ListManagedEndpointsInput

SetCreatedBefore sets the CreatedBefore field's value.

func (*ListManagedEndpointsInput) SetMaxResults 

func (s *ListManagedEndpointsInput) SetMaxResults(v int64) *ListManagedEndpointsInput

SetMaxResults sets the MaxResults field's value.

func (*ListManagedEndpointsInput) SetNextToken 

func (s *ListManagedEndpointsInput) SetNextToken(v string) *ListManagedEndpointsInput

SetNextToken sets the NextToken field's value.

func (*ListManagedEndpointsInput) SetStates 

func (s *ListManagedEndpointsInput) SetStates(v []*string) *ListManagedEndpointsInput

SetStates sets the States field's value.

func (*ListManagedEndpointsInput) SetTypes 

func (s *ListManagedEndpointsInput) SetTypes(v []*string) *ListManagedEndpointsInput

SetTypes sets the Types field's value.

func (*ListManagedEndpointsInput) SetVirtualClusterId 

func (s *ListManagedEndpointsInput) SetVirtualClusterId(v string) *ListManagedEndpointsInput

SetVirtualClusterId sets the VirtualClusterId field's value.

func (ListManagedEndpointsInput) String 

func (s ListManagedEndpointsInput) String() string

String returns the string representation

func (*ListManagedEndpointsInput) Validate 

func (s *ListManagedEndpointsInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ListManagedEndpointsOutput 

type ListManagedEndpointsOutput struct {

	// The managed endpoints to be listed.
	Endpoints []*Endpoint `locationName:"endpoints" type:"list"`

	// The token for the next set of endpoints to return.
	NextToken *string `locationName:"nextToken" min:"1" type:"string"`
	// contains filtered or unexported fields
}

func (ListManagedEndpointsOutput) GoString 

func (s ListManagedEndpointsOutput) GoString() string

GoString returns the string representation

func (*ListManagedEndpointsOutput) SetEndpoints 

func (s *ListManagedEndpointsOutput) SetEndpoints(v []*Endpoint) *ListManagedEndpointsOutput

SetEndpoints sets the Endpoints field's value.

func (*ListManagedEndpointsOutput) SetNextToken 

func (s *ListManagedEndpointsOutput) SetNextToken(v string) *ListManagedEndpointsOutput

SetNextToken sets the NextToken field's value.

func (ListManagedEndpointsOutput) String 

func (s ListManagedEndpointsOutput) String() string

String returns the string representation

type ListTagsForResourceInput 

type ListTagsForResourceInput struct {

	// The ARN of tagged resources.
	//
	// ResourceArn is a required field
	ResourceArn *string `location:"uri" locationName:"resourceArn" min:"60" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (ListTagsForResourceInput) GoString 

func (s ListTagsForResourceInput) GoString() string

GoString returns the string representation

func (*ListTagsForResourceInput) SetResourceArn 

func (s *ListTagsForResourceInput) SetResourceArn(v string) *ListTagsForResourceInput

SetResourceArn sets the ResourceArn field's value.

func (ListTagsForResourceInput) String 

func (s ListTagsForResourceInput) String() string

String returns the string representation

func (*ListTagsForResourceInput) Validate 

func (s *ListTagsForResourceInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ListTagsForResourceOutput 

type ListTagsForResourceOutput struct {

	// The tags assigned to resources.
	Tags map[string]*string `locationName:"tags" type:"map"`
	// contains filtered or unexported fields
}

func (ListTagsForResourceOutput) GoString 

func (s ListTagsForResourceOutput) GoString() string

GoString returns the string representation

func (*ListTagsForResourceOutput) SetTags 

func (s *ListTagsForResourceOutput) SetTags(v map[string]*string) *ListTagsForResourceOutput

SetTags sets the Tags field's value.

func (ListTagsForResourceOutput) String 

func (s ListTagsForResourceOutput) String() string

String returns the string representation

type ListVirtualClustersInput 

type ListVirtualClustersInput struct {

	// The container provider ID of the virtual cluster.
	ContainerProviderId *string `location:"querystring" locationName:"containerProviderId" min:"1" type:"string"`

	// The container provider type of the virtual cluster. EKS is the only supported
	// type as of now.
	ContainerProviderType *string `location:"querystring" locationName:"containerProviderType" type:"string" enum:"ContainerProviderType"`

	// The date and time after which the virtual clusters are created.
	CreatedAfter *time.Time `location:"querystring" locationName:"createdAfter" type:"timestamp" timestampFormat:"iso8601"`

	// The date and time before which the virtual clusters are created.
	CreatedBefore *time.Time `location:"querystring" locationName:"createdBefore" type:"timestamp" timestampFormat:"iso8601"`

	// The maximum number of virtual clusters that can be listed.
	MaxResults *int64 `location:"querystring" locationName:"maxResults" type:"integer"`

	// The token for the next set of virtual clusters to return.
	NextToken *string `location:"querystring" locationName:"nextToken" min:"1" type:"string"`

	// The states of the requested virtual clusters.
	States []*string `location:"querystring" locationName:"states" type:"list"`
	// contains filtered or unexported fields
}

func (ListVirtualClustersInput) GoString 

func (s ListVirtualClustersInput) GoString() string

GoString returns the string representation

func (*ListVirtualClustersInput) SetContainerProviderId 

func (s *ListVirtualClustersInput) SetContainerProviderId(v string) *ListVirtualClustersInput

SetContainerProviderId sets the ContainerProviderId field's value.

func (*ListVirtualClustersInput) SetContainerProviderType 

func (s *ListVirtualClustersInput) SetContainerProviderType(v string) *ListVirtualClustersInput

SetContainerProviderType sets the ContainerProviderType field's value.

func (*ListVirtualClustersInput) SetCreatedAfter 

func (s *ListVirtualClustersInput) SetCreatedAfter(v time.Time) *ListVirtualClustersInput

SetCreatedAfter sets the CreatedAfter field's value.

func (*ListVirtualClustersInput) SetCreatedBefore 

func (s *ListVirtualClustersInput) SetCreatedBefore(v time.Time) *ListVirtualClustersInput

SetCreatedBefore sets the CreatedBefore field's value.

func (*ListVirtualClustersInput) SetMaxResults 

func (s *ListVirtualClustersInput) SetMaxResults(v int64) *ListVirtualClustersInput

SetMaxResults sets the MaxResults field's value.

func (*ListVirtualClustersInput) SetNextToken 

func (s *ListVirtualClustersInput) SetNextToken(v string) *ListVirtualClustersInput

SetNextToken sets the NextToken field's value.

func (*ListVirtualClustersInput) SetStates 

func (s *ListVirtualClustersInput) SetStates(v []*string) *ListVirtualClustersInput

SetStates sets the States field's value.

func (ListVirtualClustersInput) String 

func (s ListVirtualClustersInput) String() string

String returns the string representation

func (*ListVirtualClustersInput) Validate 

func (s *ListVirtualClustersInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ListVirtualClustersOutput 

type ListVirtualClustersOutput struct {

	// This output displays the token for the next set of virtual clusters.
	NextToken *string `locationName:"nextToken" min:"1" type:"string"`

	// This output lists the specified virtual clusters.
	VirtualClusters []*VirtualCluster `locationName:"virtualClusters" type:"list"`
	// contains filtered or unexported fields
}

func (ListVirtualClustersOutput) GoString 

func (s ListVirtualClustersOutput) GoString() string

GoString returns the string representation

func (*ListVirtualClustersOutput) SetNextToken 

func (s *ListVirtualClustersOutput) SetNextToken(v string) *ListVirtualClustersOutput

SetNextToken sets the NextToken field's value.

func (*ListVirtualClustersOutput) SetVirtualClusters 

func (s *ListVirtualClustersOutput) SetVirtualClusters(v []*VirtualCluster) *ListVirtualClustersOutput

SetVirtualClusters sets the VirtualClusters field's value.

func (ListVirtualClustersOutput) String 

func (s ListVirtualClustersOutput) String() string

String returns the string representation

type MonitoringConfiguration 

type MonitoringConfiguration struct {

	// Monitoring configurations for CloudWatch.
	CloudWatchMonitoringConfiguration *CloudWatchMonitoringConfiguration `locationName:"cloudWatchMonitoringConfiguration" type:"structure"`

	// Monitoring configurations for the persistent application UI.
	PersistentAppUI *string `locationName:"persistentAppUI" type:"string" enum:"PersistentAppUI"`

	// Amazon S3 configuration for monitoring log publishing.
	S3MonitoringConfiguration *S3MonitoringConfiguration `locationName:"s3MonitoringConfiguration" type:"structure"`
	// contains filtered or unexported fields
}

Configuration setting for monitoring.

func (MonitoringConfiguration) GoString 

func (s MonitoringConfiguration) GoString() string

GoString returns the string representation

func (*MonitoringConfiguration) SetCloudWatchMonitoringConfiguration 

func (s *MonitoringConfiguration) SetCloudWatchMonitoringConfiguration(v *CloudWatchMonitoringConfiguration) *MonitoringConfiguration

SetCloudWatchMonitoringConfiguration sets the CloudWatchMonitoringConfiguration field's value.

func (*MonitoringConfiguration) SetPersistentAppUI 

func (s *MonitoringConfiguration) SetPersistentAppUI(v string) *MonitoringConfiguration

SetPersistentAppUI sets the PersistentAppUI field's value.

func (*MonitoringConfiguration) SetS3MonitoringConfiguration 

func (s *MonitoringConfiguration) SetS3MonitoringConfiguration(v *S3MonitoringConfiguration) *MonitoringConfiguration

SetS3MonitoringConfiguration sets the S3MonitoringConfiguration field's value.

func (MonitoringConfiguration) String 

func (s MonitoringConfiguration) String() string

String returns the string representation

func (*MonitoringConfiguration) Validate 

func (s *MonitoringConfiguration) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ResourceNotFoundException 

type ResourceNotFoundException struct {
	RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`

	Message_ *string `locationName:"message" min:"1" type:"string"`
	// contains filtered or unexported fields
}

The specified resource was not found.

func (*ResourceNotFoundException) Code 

func (s *ResourceNotFoundException) Code() string

Code returns the exception type name.

func (*ResourceNotFoundException) Error 

func (s *ResourceNotFoundException) Error() string

func (ResourceNotFoundException) GoString 

func (s ResourceNotFoundException) GoString() string

GoString returns the string representation

func (*ResourceNotFoundException) Message 

func (s *ResourceNotFoundException) Message() string

Message returns the exception's message.

func (*ResourceNotFoundException) OrigErr 

func (s *ResourceNotFoundException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ResourceNotFoundException) RequestID 

func (s *ResourceNotFoundException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ResourceNotFoundException) StatusCode 

func (s *ResourceNotFoundException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (ResourceNotFoundException) String 

func (s ResourceNotFoundException) String() string

String returns the string representation

type S3MonitoringConfiguration 

type S3MonitoringConfiguration struct {

	// Amazon S3 destination URI for log publishing.
	//
	// LogUri is a required field
	LogUri *string `locationName:"logUri" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

Amazon S3 configuration for monitoring log publishing. You can configure your jobs to send log information to Amazon S3.

func (S3MonitoringConfiguration) GoString 

func (s S3MonitoringConfiguration) GoString() string

GoString returns the string representation

func (*S3MonitoringConfiguration) SetLogUri 

func (s *S3MonitoringConfiguration) SetLogUri(v string) *S3MonitoringConfiguration

SetLogUri sets the LogUri field's value.

func (S3MonitoringConfiguration) String 

func (s S3MonitoringConfiguration) String() string

String returns the string representation

func (*S3MonitoringConfiguration) Validate 

func (s *S3MonitoringConfiguration) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type SparkSubmitJobDriver 

type SparkSubmitJobDriver struct {

	// The entry point of job application.
	//
	// EntryPoint is a required field
	EntryPoint *string `locationName:"entryPoint" min:"1" type:"string" required:"true" sensitive:"true"`

	// The arguments for job application.
	EntryPointArguments []*string `locationName:"entryPointArguments" type:"list"`

	// The Spark submit parameters that are used for job runs.
	SparkSubmitParameters *string `locationName:"sparkSubmitParameters" min:"1" type:"string" sensitive:"true"`
	// contains filtered or unexported fields
}

The information about job driver for Spark submit.

func (SparkSubmitJobDriver) GoString 

func (s SparkSubmitJobDriver) GoString() string

GoString returns the string representation

func (*SparkSubmitJobDriver) SetEntryPoint 

func (s *SparkSubmitJobDriver) SetEntryPoint(v string) *SparkSubmitJobDriver

SetEntryPoint sets the EntryPoint field's value.

func (*SparkSubmitJobDriver) SetEntryPointArguments 

func (s *SparkSubmitJobDriver) SetEntryPointArguments(v []*string) *SparkSubmitJobDriver

SetEntryPointArguments sets the EntryPointArguments field's value.

func (*SparkSubmitJobDriver) SetSparkSubmitParameters 

func (s *SparkSubmitJobDriver) SetSparkSubmitParameters(v string) *SparkSubmitJobDriver

SetSparkSubmitParameters sets the SparkSubmitParameters field's value.

func (SparkSubmitJobDriver) String 

func (s SparkSubmitJobDriver) String() string

String returns the string representation

func (*SparkSubmitJobDriver) Validate 

func (s *SparkSubmitJobDriver) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type StartJobRunInput 

type StartJobRunInput struct {

	// The client idempotency token of the job run request.
	ClientToken *string `locationName:"clientToken" min:"1" type:"string" idempotencyToken:"true"`

	// The configuration overrides for the job run.
	ConfigurationOverrides *ConfigurationOverrides `locationName:"configurationOverrides" type:"structure"`

	// The execution role ARN for the job run.
	//
	// ExecutionRoleArn is a required field
	ExecutionRoleArn *string `locationName:"executionRoleArn" min:"20" type:"string" required:"true"`

	// The job driver for the job run.
	//
	// JobDriver is a required field
	JobDriver *JobDriver `locationName:"jobDriver" type:"structure" required:"true"`

	// The name of the job run.
	Name *string `locationName:"name" min:"1" type:"string"`

	// The Amazon EMR release version to use for the job run.
	//
	// ReleaseLabel is a required field
	ReleaseLabel *string `locationName:"releaseLabel" min:"1" type:"string" required:"true"`

	// The tags assigned to job runs.
	Tags map[string]*string `locationName:"tags" type:"map"`

	// The virtual cluster ID for which the job run request is submitted.
	//
	// VirtualClusterId is a required field
	VirtualClusterId *string `location:"uri" locationName:"virtualClusterId" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (StartJobRunInput) GoString 

func (s StartJobRunInput) GoString() string

GoString returns the string representation

func (*StartJobRunInput) SetClientToken 

func (s *StartJobRunInput) SetClientToken(v string) *StartJobRunInput

SetClientToken sets the ClientToken field's value.

func (*StartJobRunInput) SetConfigurationOverrides 

func (s *StartJobRunInput) SetConfigurationOverrides(v *ConfigurationOverrides) *StartJobRunInput

SetConfigurationOverrides sets the ConfigurationOverrides field's value.

func (*StartJobRunInput) SetExecutionRoleArn 

func (s *StartJobRunInput) SetExecutionRoleArn(v string) *StartJobRunInput

SetExecutionRoleArn sets the ExecutionRoleArn field's value.

func (*StartJobRunInput) SetJobDriver 

func (s *StartJobRunInput) SetJobDriver(v *JobDriver) *StartJobRunInput

SetJobDriver sets the JobDriver field's value.

func (*StartJobRunInput) SetName 

func (s *StartJobRunInput) SetName(v string) *StartJobRunInput

SetName sets the Name field's value.

func (*StartJobRunInput) SetReleaseLabel 

func (s *StartJobRunInput) SetReleaseLabel(v string) *StartJobRunInput

SetReleaseLabel sets the ReleaseLabel field's value.

func (*StartJobRunInput) SetTags 

func (s *StartJobRunInput) SetTags(v map[string]*string) *StartJobRunInput

SetTags sets the Tags field's value.

func (*StartJobRunInput) SetVirtualClusterId 

func (s *StartJobRunInput) SetVirtualClusterId(v string) *StartJobRunInput

SetVirtualClusterId sets the VirtualClusterId field's value.

func (StartJobRunInput) String 

func (s StartJobRunInput) String() string

String returns the string representation

func (*StartJobRunInput) Validate 

func (s *StartJobRunInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type StartJobRunOutput 

type StartJobRunOutput struct {

	// This output lists the ARN of job run.
	Arn *string `locationName:"arn" min:"60" type:"string"`

	// This output displays the started job run ID.
	Id *string `locationName:"id" min:"1" type:"string"`

	// This output displays the name of the started job run.
	Name *string `locationName:"name" min:"1" type:"string"`

	// This output displays the virtual cluster ID for which the job run was submitted.
	VirtualClusterId *string `locationName:"virtualClusterId" min:"1" type:"string"`
	// contains filtered or unexported fields
}

func (StartJobRunOutput) GoString 

func (s StartJobRunOutput) GoString() string

GoString returns the string representation

func (*StartJobRunOutput) SetArn 

func (s *StartJobRunOutput) SetArn(v string) *StartJobRunOutput

SetArn sets the Arn field's value.

func (*StartJobRunOutput) SetId 

func (s *StartJobRunOutput) SetId(v string) *StartJobRunOutput

SetId sets the Id field's value.

func (*StartJobRunOutput) SetName 

func (s *StartJobRunOutput) SetName(v string) *StartJobRunOutput

SetName sets the Name field's value.

func (*StartJobRunOutput) SetVirtualClusterId 

func (s *StartJobRunOutput) SetVirtualClusterId(v string) *StartJobRunOutput

SetVirtualClusterId sets the VirtualClusterId field's value.

func (StartJobRunOutput) String 

func (s StartJobRunOutput) String() string

String returns the string representation

type TagResourceInput 

type TagResourceInput struct {

	// The ARN of resources.
	//
	// ResourceArn is a required field
	ResourceArn *string `location:"uri" locationName:"resourceArn" min:"60" type:"string" required:"true"`

	// The tags assigned to resources.
	//
	// Tags is a required field
	Tags map[string]*string `locationName:"tags" type:"map" required:"true"`
	// contains filtered or unexported fields
}

func (TagResourceInput) GoString 

func (s TagResourceInput) GoString() string

GoString returns the string representation

func (*TagResourceInput) SetResourceArn 

func (s *TagResourceInput) SetResourceArn(v string) *TagResourceInput

SetResourceArn sets the ResourceArn field's value.

func (*TagResourceInput) SetTags 

func (s *TagResourceInput) SetTags(v map[string]*string) *TagResourceInput

SetTags sets the Tags field's value.

func (TagResourceInput) String 

func (s TagResourceInput) String() string

String returns the string representation

func (*TagResourceInput) Validate 

func (s *TagResourceInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type TagResourceOutput 

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

func (TagResourceOutput) GoString 

func (s TagResourceOutput) GoString() string

GoString returns the string representation

func (TagResourceOutput) String 

func (s TagResourceOutput) String() string

String returns the string representation

type UntagResourceInput 

type UntagResourceInput struct {

	// The ARN of resources.
	//
	// ResourceArn is a required field
	ResourceArn *string `location:"uri" locationName:"resourceArn" min:"60" type:"string" required:"true"`

	// The tag keys of the resources.
	//
	// TagKeys is a required field
	TagKeys []*string `location:"querystring" locationName:"tagKeys" type:"list" required:"true"`
	// contains filtered or unexported fields
}

func (UntagResourceInput) GoString 

func (s UntagResourceInput) GoString() string

GoString returns the string representation

func (*UntagResourceInput) SetResourceArn 

func (s *UntagResourceInput) SetResourceArn(v string) *UntagResourceInput

SetResourceArn sets the ResourceArn field's value.

func (*UntagResourceInput) SetTagKeys 

func (s *UntagResourceInput) SetTagKeys(v []*string) *UntagResourceInput

SetTagKeys sets the TagKeys field's value.

func (UntagResourceInput) String 

func (s UntagResourceInput) String() string

String returns the string representation

func (*UntagResourceInput) Validate 

func (s *UntagResourceInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type UntagResourceOutput 

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

func (UntagResourceOutput) GoString 

func (s UntagResourceOutput) GoString() string

GoString returns the string representation

func (UntagResourceOutput) String 

func (s UntagResourceOutput) String() string

String returns the string representation

type ValidationException 

type ValidationException struct {
	RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`

	Message_ *string `locationName:"message" min:"1" type:"string"`
	// contains filtered or unexported fields
}

There are invalid parameters in the client request.

func (*ValidationException) Code 

func (s *ValidationException) Code() string

Code returns the exception type name.

func (*ValidationException) Error 

func (s *ValidationException) Error() string

func (ValidationException) GoString 

func (s ValidationException) GoString() string

GoString returns the string representation

func (*ValidationException) Message 

func (s *ValidationException) Message() string

Message returns the exception's message.

func (*ValidationException) OrigErr 

func (s *ValidationException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ValidationException) RequestID 

func (s *ValidationException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ValidationException) StatusCode 

func (s *ValidationException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (ValidationException) String 

func (s ValidationException) String() string

String returns the string representation

type VirtualCluster 

type VirtualCluster struct {

	// The ARN of the virtual cluster.
	Arn *string `locationName:"arn" min:"60" type:"string"`

	// The container provider of the virtual cluster.
	ContainerProvider *ContainerProvider `locationName:"containerProvider" type:"structure"`

	// The date and time when the virtual cluster is created.
	CreatedAt *time.Time `locationName:"createdAt" type:"timestamp" timestampFormat:"iso8601"`

	// The ID of the virtual cluster.
	Id *string `locationName:"id" min:"1" type:"string"`

	// The name of the virtual cluster.
	Name *string `locationName:"name" min:"1" type:"string"`

	// The state of the virtual cluster.
	State *string `locationName:"state" type:"string" enum:"VirtualClusterState"`

	// The assigned tags of the virtual cluster.
	Tags map[string]*string `locationName:"tags" type:"map"`
	// contains filtered or unexported fields
}

This entity describes a virtual cluster. A virtual cluster is a Kubernetes namespace that Amazon EMR is registered with. Amazon EMR uses virtual clusters to run jobs and host endpoints. Multiple virtual clusters can be backed by the same physical cluster. However, each virtual cluster maps to one namespace on an EKS cluster. Virtual clusters do not create any active resources that contribute to your bill or that require lifecycle management outside the service.

func (VirtualCluster) GoString 

func (s VirtualCluster) GoString() string

GoString returns the string representation

func (*VirtualCluster) SetArn 

func (s *VirtualCluster) SetArn(v string) *VirtualCluster

SetArn sets the Arn field's value.

func (*VirtualCluster) SetContainerProvider 

func (s *VirtualCluster) SetContainerProvider(v *ContainerProvider) *VirtualCluster

SetContainerProvider sets the ContainerProvider field's value.

func (*VirtualCluster) SetCreatedAt 

func (s *VirtualCluster) SetCreatedAt(v time.Time) *VirtualCluster

SetCreatedAt sets the CreatedAt field's value.

func (*VirtualCluster) SetId 

func (s *VirtualCluster) SetId(v string) *VirtualCluster

SetId sets the Id field's value.

func (*VirtualCluster) SetName 

func (s *VirtualCluster) SetName(v string) *VirtualCluster

SetName sets the Name field's value.

func (*VirtualCluster) SetState 

func (s *VirtualCluster) SetState(v string) *VirtualCluster

SetState sets the State field's value.

func (*VirtualCluster) SetTags 

func (s *VirtualCluster) SetTags(v map[string]*string) *VirtualCluster

SetTags sets the Tags field's value.

func (VirtualCluster) String 

func (s VirtualCluster) String() string

String returns the string representation

Source Files

View all Source files

Directories

Path Synopsis
Package emrcontainersiface provides an interface to enable mocking the Amazon EMR Containers service client for testing your code.
 Package emrcontainersiface provides an interface to enable mocking the Amazon EMR Containers service client for testing your code.

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.