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

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

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

GoString returns the string representation

func (*CloudWatchMonitoringConfiguration) SetLogGroupName

SetLogGroupName sets the LogGroupName field's value.

func (*CloudWatchMonitoringConfiguration) SetLogStreamNamePrefix

SetLogStreamNamePrefix sets the LogStreamNamePrefix field's value.

func (CloudWatchMonitoringConfiguration) String

String returns the string representation

func (*CloudWatchMonitoringConfiguration) Validate

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

SetId sets the Id field's value.

func (*ContainerProvider) SetInfo

SetInfo sets the Info field's value.

func (*ContainerProvider) SetType

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

SetCertificateArn sets the CertificateArn field's value.

func (*CreateManagedEndpointInput) SetClientToken

SetClientToken sets the ClientToken field's value.

func (*CreateManagedEndpointInput) SetConfigurationOverrides

SetConfigurationOverrides sets the ConfigurationOverrides field's value.

func (*CreateManagedEndpointInput) SetExecutionRoleArn

SetExecutionRoleArn sets the ExecutionRoleArn field's value.

func (*CreateManagedEndpointInput) SetName

SetName sets the Name field's value.

func (*CreateManagedEndpointInput) SetReleaseLabel

SetReleaseLabel sets the ReleaseLabel field's value.

func (*CreateManagedEndpointInput) SetTags

SetTags sets the Tags field's value.

func (*CreateManagedEndpointInput) SetType

SetType sets the Type field's value.

func (*CreateManagedEndpointInput) SetVirtualClusterId

SetVirtualClusterId sets the VirtualClusterId field's value.

func (CreateManagedEndpointInput) 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

SetArn sets the Arn field's value.

func (*CreateManagedEndpointOutput) SetId

SetId sets the Id field's value.

func (*CreateManagedEndpointOutput) SetName

SetName sets the Name field's value.

func (*CreateManagedEndpointOutput) SetVirtualClusterId

SetVirtualClusterId sets the VirtualClusterId field's value.

func (CreateManagedEndpointOutput) 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

SetClientToken sets the ClientToken field's value.

func (*CreateVirtualClusterInput) SetContainerProvider

SetContainerProvider sets the ContainerProvider field's value.

func (*CreateVirtualClusterInput) SetName

SetName sets the Name field's value.

func (*CreateVirtualClusterInput) SetTags

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

SetArn sets the Arn field's value.

func (*CreateVirtualClusterOutput) SetId

SetId sets the Id field's value.

func (*CreateVirtualClusterOutput) SetName

SetName sets the Name field's value.

func (CreateVirtualClusterOutput) 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

SetId sets the Id field's value.

func (*DeleteManagedEndpointInput) SetVirtualClusterId

SetVirtualClusterId sets the VirtualClusterId field's value.

func (DeleteManagedEndpointInput) 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

SetId sets the Id field's value.

func (*DeleteManagedEndpointOutput) SetVirtualClusterId

SetVirtualClusterId sets the VirtualClusterId field's value.

func (DeleteManagedEndpointOutput) 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

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

SetId sets the Id field's value.

func (DeleteVirtualClusterOutput) 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

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

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

SetId sets the Id field's value.

func (*DescribeManagedEndpointInput) SetVirtualClusterId

SetVirtualClusterId sets the VirtualClusterId field's value.

func (DescribeManagedEndpointInput) 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

GoString returns the string representation

func (*DescribeManagedEndpointOutput) SetEndpoint

SetEndpoint sets the Endpoint field's value.

func (DescribeManagedEndpointOutput) 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

SetId sets the Id field's value.

func (DescribeVirtualClusterInput) 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

SetVirtualCluster sets the VirtualCluster field's value.

func (DescribeVirtualClusterOutput) 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

SetCreatedAfter sets the CreatedAfter field's value.

func (*ListManagedEndpointsInput) SetCreatedBefore

SetCreatedBefore sets the CreatedBefore field's value.

func (*ListManagedEndpointsInput) SetMaxResults

SetMaxResults sets the MaxResults field's value.

func (*ListManagedEndpointsInput) SetNextToken

SetNextToken sets the NextToken field's value.

func (*ListManagedEndpointsInput) SetStates

SetStates sets the States field's value.

func (*ListManagedEndpointsInput) SetTypes

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

SetEndpoints sets the Endpoints field's value.

func (*ListManagedEndpointsOutput) SetNextToken

SetNextToken sets the NextToken field's value.

func (ListManagedEndpointsOutput) 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

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

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

SetCreatedAfter sets the CreatedAfter field's value.

func (*ListVirtualClustersInput) SetCreatedBefore

SetCreatedBefore sets the CreatedBefore field's value.

func (*ListVirtualClustersInput) SetMaxResults

SetMaxResults sets the MaxResults field's value.

func (*ListVirtualClustersInput) SetNextToken

SetNextToken sets the NextToken field's value.

func (*ListVirtualClustersInput) SetStates

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

SetNextToken sets the NextToken field's value.

func (*ListVirtualClustersOutput) SetVirtualClusters

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

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

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

SetArn sets the Arn field's value.

func (*StartJobRunOutput) SetId

SetId sets the Id field's value.

func (*StartJobRunOutput) SetName

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

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