...
AWS SDK for Go API Reference
import "github.com/aws/aws-sdk-go/service/emrcontainers"
Overview
Constants

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:

* It is the prefix in the CLI commands for Amazon EMR on EKS. For example,
aws emr-containers start-job-run.

* It is the prefix before IAM policy actions for Amazon EMR on EKS. For
example, "Action": [ "emr-containers:StartJobRun"]. For more information,
see Policy actions for Amazon EMR on EKS (https://docs.aws.amazon.com/emr/latest/EMR-on-EKS-DevelopmentGuide/security_iam_service-with-iam.html#security_iam_service-with-iam-id-based-policies-actions).

* It is the prefix used in Amazon EMR on EKS service endpoints. For example,
emr-containers.us-east-2.amazonaws.com. For more information, see Amazon
EMR on EKS Service Endpoints (https://docs.aws.amazon.com/emr/latest/EMR-on-EKS-DevelopmentGuide/service-quotas.html#service-endpoints).

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

The stub package, emrcontainersiface, can be used to provide alternative implementations of service clients, such as mocking the client for testing.

Types ▾

type EMRContainers
func New(p client.ConfigProvider, cfgs ...*aws.Config) *EMRContainers
func (c *EMRContainers) CancelJobRun(input *CancelJobRunInput) (*CancelJobRunOutput, error)
func (c *EMRContainers) CancelJobRunRequest(input *CancelJobRunInput) (req *request.Request, output *CancelJobRunOutput)
func (c *EMRContainers) CancelJobRunWithContext(ctx aws.Context, input *CancelJobRunInput, opts ...request.Option) (*CancelJobRunOutput, error)
func (c *EMRContainers) CreateManagedEndpoint(input *CreateManagedEndpointInput) (*CreateManagedEndpointOutput, error)
func (c *EMRContainers) CreateManagedEndpointRequest(input *CreateManagedEndpointInput) (req *request.Request, output *CreateManagedEndpointOutput)
func (c *EMRContainers) CreateManagedEndpointWithContext(ctx aws.Context, input *CreateManagedEndpointInput, opts ...request.Option) (*CreateManagedEndpointOutput, error)
func (c *EMRContainers) CreateVirtualCluster(input *CreateVirtualClusterInput) (*CreateVirtualClusterOutput, error)
func (c *EMRContainers) CreateVirtualClusterRequest(input *CreateVirtualClusterInput) (req *request.Request, output *CreateVirtualClusterOutput)
func (c *EMRContainers) CreateVirtualClusterWithContext(ctx aws.Context, input *CreateVirtualClusterInput, opts ...request.Option) (*CreateVirtualClusterOutput, error)
func (c *EMRContainers) DeleteManagedEndpoint(input *DeleteManagedEndpointInput) (*DeleteManagedEndpointOutput, error)
func (c *EMRContainers) DeleteManagedEndpointRequest(input *DeleteManagedEndpointInput) (req *request.Request, output *DeleteManagedEndpointOutput)
func (c *EMRContainers) DeleteManagedEndpointWithContext(ctx aws.Context, input *DeleteManagedEndpointInput, opts ...request.Option) (*DeleteManagedEndpointOutput, error)
func (c *EMRContainers) DeleteVirtualCluster(input *DeleteVirtualClusterInput) (*DeleteVirtualClusterOutput, error)
func (c *EMRContainers) DeleteVirtualClusterRequest(input *DeleteVirtualClusterInput) (req *request.Request, output *DeleteVirtualClusterOutput)
func (c *EMRContainers) DeleteVirtualClusterWithContext(ctx aws.Context, input *DeleteVirtualClusterInput, opts ...request.Option) (*DeleteVirtualClusterOutput, error)
func (c *EMRContainers) DescribeJobRun(input *DescribeJobRunInput) (*DescribeJobRunOutput, error)
func (c *EMRContainers) DescribeJobRunRequest(input *DescribeJobRunInput) (req *request.Request, output *DescribeJobRunOutput)
func (c *EMRContainers) DescribeJobRunWithContext(ctx aws.Context, input *DescribeJobRunInput, opts ...request.Option) (*DescribeJobRunOutput, error)
func (c *EMRContainers) DescribeManagedEndpoint(input *DescribeManagedEndpointInput) (*DescribeManagedEndpointOutput, error)
func (c *EMRContainers) DescribeManagedEndpointRequest(input *DescribeManagedEndpointInput) (req *request.Request, output *DescribeManagedEndpointOutput)
func (c *EMRContainers) DescribeManagedEndpointWithContext(ctx aws.Context, input *DescribeManagedEndpointInput, opts ...request.Option) (*DescribeManagedEndpointOutput, error)
func (c *EMRContainers) DescribeVirtualCluster(input *DescribeVirtualClusterInput) (*DescribeVirtualClusterOutput, error)
func (c *EMRContainers) DescribeVirtualClusterRequest(input *DescribeVirtualClusterInput) (req *request.Request, output *DescribeVirtualClusterOutput)
func (c *EMRContainers) DescribeVirtualClusterWithContext(ctx aws.Context, input *DescribeVirtualClusterInput, opts ...request.Option) (*DescribeVirtualClusterOutput, error)
func (c *EMRContainers) ListJobRuns(input *ListJobRunsInput) (*ListJobRunsOutput, error)
func (c *EMRContainers) ListJobRunsPages(input *ListJobRunsInput, fn func(*ListJobRunsOutput, bool) bool) error
func (c *EMRContainers) ListJobRunsPagesWithContext(ctx aws.Context, input *ListJobRunsInput, fn func(*ListJobRunsOutput, bool) bool, opts ...request.Option) error
func (c *EMRContainers) ListJobRunsRequest(input *ListJobRunsInput) (req *request.Request, output *ListJobRunsOutput)
func (c *EMRContainers) ListJobRunsWithContext(ctx aws.Context, input *ListJobRunsInput, opts ...request.Option) (*ListJobRunsOutput, error)
func (c *EMRContainers) ListManagedEndpoints(input *ListManagedEndpointsInput) (*ListManagedEndpointsOutput, error)
func (c *EMRContainers) ListManagedEndpointsPages(input *ListManagedEndpointsInput, fn func(*ListManagedEndpointsOutput, bool) bool) error
func (c *EMRContainers) ListManagedEndpointsPagesWithContext(ctx aws.Context, input *ListManagedEndpointsInput, fn func(*ListManagedEndpointsOutput, bool) bool, opts ...request.Option) error
func (c *EMRContainers) ListManagedEndpointsRequest(input *ListManagedEndpointsInput) (req *request.Request, output *ListManagedEndpointsOutput)
func (c *EMRContainers) ListManagedEndpointsWithContext(ctx aws.Context, input *ListManagedEndpointsInput, opts ...request.Option) (*ListManagedEndpointsOutput, error)
func (c *EMRContainers) ListTagsForResource(input *ListTagsForResourceInput) (*ListTagsForResourceOutput, error)
func (c *EMRContainers) ListTagsForResourceRequest(input *ListTagsForResourceInput) (req *request.Request, output *ListTagsForResourceOutput)
func (c *EMRContainers) ListTagsForResourceWithContext(ctx aws.Context, input *ListTagsForResourceInput, opts ...request.Option) (*ListTagsForResourceOutput, error)
func (c *EMRContainers) ListVirtualClusters(input *ListVirtualClustersInput) (*ListVirtualClustersOutput, error)
func (c *EMRContainers) ListVirtualClustersPages(input *ListVirtualClustersInput, fn func(*ListVirtualClustersOutput, bool) bool) error
func (c *EMRContainers) ListVirtualClustersPagesWithContext(ctx aws.Context, input *ListVirtualClustersInput, fn func(*ListVirtualClustersOutput, bool) bool, opts ...request.Option) error
func (c *EMRContainers) ListVirtualClustersRequest(input *ListVirtualClustersInput) (req *request.Request, output *ListVirtualClustersOutput)
func (c *EMRContainers) ListVirtualClustersWithContext(ctx aws.Context, input *ListVirtualClustersInput, opts ...request.Option) (*ListVirtualClustersOutput, error)
func (c *EMRContainers) StartJobRun(input *StartJobRunInput) (*StartJobRunOutput, error)
func (c *EMRContainers) StartJobRunRequest(input *StartJobRunInput) (req *request.Request, output *StartJobRunOutput)
func (c *EMRContainers) StartJobRunWithContext(ctx aws.Context, input *StartJobRunInput, opts ...request.Option) (*StartJobRunOutput, error)
func (c *EMRContainers) TagResource(input *TagResourceInput) (*TagResourceOutput, error)
func (c *EMRContainers) TagResourceRequest(input *TagResourceInput) (req *request.Request, output *TagResourceOutput)
func (c *EMRContainers) TagResourceWithContext(ctx aws.Context, input *TagResourceInput, opts ...request.Option) (*TagResourceOutput, error)
func (c *EMRContainers) UntagResource(input *UntagResourceInput) (*UntagResourceOutput, error)
func (c *EMRContainers) UntagResourceRequest(input *UntagResourceInput) (req *request.Request, output *UntagResourceOutput)
func (c *EMRContainers) UntagResourceWithContext(ctx aws.Context, input *UntagResourceInput, opts ...request.Option) (*UntagResourceOutput, error)
func ContainerProviderType_Values() []string
func EndpointState_Values() []string
func FailureReason_Values() []string
func JobRunState_Values() []string
func PersistentAppUI_Values() []string
func VirtualClusterState_Values() []string
type CancelJobRunInput
type CancelJobRunOutput
type Certificate
type CloudWatchMonitoringConfiguration
type Configuration
type ConfigurationOverrides
type ContainerInfo
type ContainerProvider
type CreateManagedEndpointInput
type CreateManagedEndpointOutput
type CreateVirtualClusterInput
type CreateVirtualClusterOutput
type DeleteManagedEndpointInput
type DeleteManagedEndpointOutput
type DeleteVirtualClusterInput
type DeleteVirtualClusterOutput
type DescribeJobRunInput
type DescribeJobRunOutput
type DescribeManagedEndpointInput
type DescribeManagedEndpointOutput
type DescribeVirtualClusterInput
type DescribeVirtualClusterOutput
type EksInfo
type Endpoint
type InternalServerException
type JobDriver
type JobRun
type ListJobRunsInput
type ListJobRunsOutput
type ListManagedEndpointsInput
type ListManagedEndpointsOutput
type ListTagsForResourceInput
type ListTagsForResourceOutput
type ListVirtualClustersInput
type ListVirtualClustersOutput
type MonitoringConfiguration
type ResourceNotFoundException
type S3MonitoringConfiguration
type SparkSubmitJobDriver
type StartJobRunInput
type StartJobRunOutput
type TagResourceInput
type TagResourceOutput
type UntagResourceInput
type UntagResourceOutput
type ValidationException
type VirtualCluster

Constants ▾

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"
)
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"
)
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"
)
const (
    // PersistentAppUIEnabled is a PersistentAppUI enum value
    PersistentAppUIEnabled = "ENABLED"

    // PersistentAppUIDisabled is a PersistentAppUI enum value
    PersistentAppUIDisabled = "DISABLED"
)
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"
)
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"
)
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

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

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

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CancelJobRunInput) SetId

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

SetId sets the Id field's value.

func (*CancelJobRunInput) SetVirtualClusterId

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

SetVirtualClusterId sets the VirtualClusterId field's value.

func (CancelJobRunInput) String

func (s CancelJobRunInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CancelJobRunOutput) SetId

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

SetId sets the Id field's value.

func (*CancelJobRunOutput) SetVirtualClusterId

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

SetVirtualClusterId sets the VirtualClusterId field's value.

func (CancelJobRunOutput) String

func (s CancelJobRunOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type Certificate

type Certificate struct {

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

    // The base64 encoded PEM certificate data generated for managed endpoint.
    CertificateData *string `locationName:"certificateData" type:"string"`
    // contains filtered or unexported fields
}

The entity representing certificate data generated for managed endpoint.

func (Certificate) GoString

func (s Certificate) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*Certificate) SetCertificateArn

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

SetCertificateArn sets the CertificateArn field's value.

func (*Certificate) SetCertificateData

func (s *Certificate) SetCertificateData(v string) *Certificate

SetCertificateData sets the CertificateData field's value.

func (Certificate) String

func (s Certificate) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type CloudWatchMonitoringConfiguration

type CloudWatchMonitoringConfiguration struct {

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

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

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

func (CloudWatchMonitoringConfiguration) GoString

func (s CloudWatchMonitoringConfiguration) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CloudWatchMonitoringConfiguration) SetLogGroupName

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

SetLogGroupName sets the LogGroupName field's value.

func (*CloudWatchMonitoringConfiguration) SetLogStreamNamePrefix

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

SetLogStreamNamePrefix sets the LogStreamNamePrefix field's value.

func (CloudWatchMonitoringConfiguration) String

func (s CloudWatchMonitoringConfiguration) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CloudWatchMonitoringConfiguration) Validate

func (s *CloudWatchMonitoringConfiguration) Validate() error

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

type Configuration

type Configuration struct {

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

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

    // A set of properties specified within a configuration classification.
    //
    // Properties is a sensitive parameter and its value will be
    // replaced with "sensitive" in string returned by Configuration's
    // String and GoString methods.
    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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ContainerProvider) SetId

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

SetId sets the Id field's value.

func (*ContainerProvider) SetInfo

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

SetInfo sets the Info field's value.

func (*ContainerProvider) SetType

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

SetType sets the Type field's value.

func (ContainerProvider) String

func (s ContainerProvider) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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 provided by users for the managed endpoint. This fiedd
    // is under deprecation and will be removed in future releases.
    //
    // Deprecated: Customer provided certificate-arn is deprecated and would be removed in future.
    CertificateArn *string `locationName:"certificateArn" min:"44" deprecated:"true" type:"string"`

    // 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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CreateManagedEndpointInput) SetCertificateArn

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

SetCertificateArn sets the CertificateArn field's value.

func (*CreateManagedEndpointInput) SetClientToken

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

SetClientToken sets the ClientToken field's value.

func (*CreateManagedEndpointInput) SetConfigurationOverrides

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

SetConfigurationOverrides sets the ConfigurationOverrides field's value.

func (*CreateManagedEndpointInput) SetExecutionRoleArn

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

SetExecutionRoleArn sets the ExecutionRoleArn field's value.

func (*CreateManagedEndpointInput) SetName

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

SetName sets the Name field's value.

func (*CreateManagedEndpointInput) SetReleaseLabel

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

SetReleaseLabel sets the ReleaseLabel field's value.

func (*CreateManagedEndpointInput) SetTags

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

SetTags sets the Tags field's value.

func (*CreateManagedEndpointInput) SetType

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

SetType sets the Type field's value.

func (*CreateManagedEndpointInput) SetVirtualClusterId

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

SetVirtualClusterId sets the VirtualClusterId field's value.

func (CreateManagedEndpointInput) String

func (s CreateManagedEndpointInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CreateManagedEndpointOutput) SetArn

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

SetArn sets the Arn field's value.

func (*CreateManagedEndpointOutput) SetId

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

SetId sets the Id field's value.

func (*CreateManagedEndpointOutput) SetName

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

SetName sets the Name field's value.

func (*CreateManagedEndpointOutput) SetVirtualClusterId

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

SetVirtualClusterId sets the VirtualClusterId field's value.

func (CreateManagedEndpointOutput) String

func (s CreateManagedEndpointOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CreateVirtualClusterInput) SetClientToken

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

SetClientToken sets the ClientToken field's value.

func (*CreateVirtualClusterInput) SetContainerProvider

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

SetContainerProvider sets the ContainerProvider field's value.

func (*CreateVirtualClusterInput) SetName

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

SetName sets the Name field's value.

func (*CreateVirtualClusterInput) SetTags

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

SetTags sets the Tags field's value.

func (CreateVirtualClusterInput) String

func (s CreateVirtualClusterInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CreateVirtualClusterOutput) SetArn

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

SetArn sets the Arn field's value.

func (*CreateVirtualClusterOutput) SetId

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

SetId sets the Id field's value.

func (*CreateVirtualClusterOutput) SetName

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

SetName sets the Name field's value.

func (CreateVirtualClusterOutput) String

func (s CreateVirtualClusterOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DeleteManagedEndpointInput) SetId

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

SetId sets the Id field's value.

func (*DeleteManagedEndpointInput) SetVirtualClusterId

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

SetVirtualClusterId sets the VirtualClusterId field's value.

func (DeleteManagedEndpointInput) String

func (s DeleteManagedEndpointInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DeleteManagedEndpointOutput) SetId

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

SetId sets the Id field's value.

func (*DeleteManagedEndpointOutput) SetVirtualClusterId

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

SetVirtualClusterId sets the VirtualClusterId field's value.

func (DeleteManagedEndpointOutput) String

func (s DeleteManagedEndpointOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DeleteVirtualClusterInput) SetId

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

SetId sets the Id field's value.

func (DeleteVirtualClusterInput) String

func (s DeleteVirtualClusterInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DeleteVirtualClusterOutput) SetId

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

SetId sets the Id field's value.

func (DeleteVirtualClusterOutput) String

func (s DeleteVirtualClusterOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DescribeJobRunInput) SetId

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

SetId sets the Id field's value.

func (*DescribeJobRunInput) SetVirtualClusterId

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

SetVirtualClusterId sets the VirtualClusterId field's value.

func (DescribeJobRunInput) String

func (s DescribeJobRunInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DescribeJobRunOutput) SetJobRun

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

SetJobRun sets the JobRun field's value.

func (DescribeJobRunOutput) String

func (s DescribeJobRunOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DescribeManagedEndpointInput) SetId

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

SetId sets the Id field's value.

func (*DescribeManagedEndpointInput) SetVirtualClusterId

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

SetVirtualClusterId sets the VirtualClusterId field's value.

func (DescribeManagedEndpointInput) String

func (s DescribeManagedEndpointInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DescribeManagedEndpointInput) Validate

func (s *DescribeManagedEndpointInput) Validate() error

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

type DescribeManagedEndpointOutput

type DescribeManagedEndpointOutput struct {

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

func (DescribeManagedEndpointOutput) GoString

func (s DescribeManagedEndpointOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DescribeManagedEndpointOutput) SetEndpoint

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

SetEndpoint sets the Endpoint field's value.

func (DescribeManagedEndpointOutput) String

func (s DescribeManagedEndpointOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DescribeVirtualClusterInput) SetId

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

SetId sets the Id field's value.

func (DescribeVirtualClusterInput) String

func (s DescribeVirtualClusterInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DescribeVirtualClusterOutput) SetVirtualCluster

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

SetVirtualCluster sets the VirtualCluster field's value.

func (DescribeVirtualClusterOutput) String

func (s DescribeVirtualClusterOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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. This field is under deprecation and
    // will be removed in future.
    //
    // Deprecated: Customer provided certificate-arn is deprecated and would be removed in future.
    CertificateArn *string `locationName:"certificateArn" min:"44" deprecated:"true" type:"string"`

    // The certificate generated by emr control plane on customer behalf to secure
    // the managed endpoint.
    CertificateAuthority *Certificate `locationName:"certificateAuthority" type:"structure"`

    // 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 reasons why the endpoint has failed.
    FailureReason *string `locationName:"failureReason" type:"string" enum:"FailureReason"`

    // 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"`

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

    // 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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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

func (s *Endpoint) SetCertificateAuthority(v *Certificate) *Endpoint

SetCertificateAuthority sets the CertificateAuthority 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) SetFailureReason

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

SetFailureReason sets the FailureReason 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) SetStateDetails

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

SetStateDetails sets the StateDetails 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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ListManagedEndpointsInput) SetCreatedAfter

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

SetCreatedAfter sets the CreatedAfter field's value.

func (*ListManagedEndpointsInput) SetCreatedBefore

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

SetCreatedBefore sets the CreatedBefore field's value.

func (*ListManagedEndpointsInput) SetMaxResults

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

SetMaxResults sets the MaxResults field's value.

func (*ListManagedEndpointsInput) SetNextToken

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

SetNextToken sets the NextToken field's value.

func (*ListManagedEndpointsInput) SetStates

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

SetStates sets the States field's value.

func (*ListManagedEndpointsInput) SetTypes

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

SetTypes sets the Types field's value.

func (*ListManagedEndpointsInput) SetVirtualClusterId

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

SetVirtualClusterId sets the VirtualClusterId field's value.

func (ListManagedEndpointsInput) String

func (s ListManagedEndpointsInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ListManagedEndpointsOutput) SetEndpoints

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

SetEndpoints sets the Endpoints field's value.

func (*ListManagedEndpointsOutput) SetNextToken

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

SetNextToken sets the NextToken field's value.

func (ListManagedEndpointsOutput) String

func (s ListManagedEndpointsOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ListTagsForResourceInput) SetResourceArn

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

SetResourceArn sets the ResourceArn field's value.

func (ListTagsForResourceInput) String

func (s ListTagsForResourceInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ListTagsForResourceOutput) SetTags

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

SetTags sets the Tags field's value.

func (ListTagsForResourceOutput) String

func (s ListTagsForResourceOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ListVirtualClustersInput) SetContainerProviderId

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

SetContainerProviderId sets the ContainerProviderId field's value.

func (*ListVirtualClustersInput) SetContainerProviderType

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

SetContainerProviderType sets the ContainerProviderType field's value.

func (*ListVirtualClustersInput) SetCreatedAfter

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

SetCreatedAfter sets the CreatedAfter field's value.

func (*ListVirtualClustersInput) SetCreatedBefore

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

SetCreatedBefore sets the CreatedBefore field's value.

func (*ListVirtualClustersInput) SetMaxResults

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

SetMaxResults sets the MaxResults field's value.

func (*ListVirtualClustersInput) SetNextToken

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

SetNextToken sets the NextToken field's value.

func (*ListVirtualClustersInput) SetStates

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

SetStates sets the States field's value.

func (ListVirtualClustersInput) String

func (s ListVirtualClustersInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ListVirtualClustersOutput) SetNextToken

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

SetNextToken sets the NextToken field's value.

func (*ListVirtualClustersOutput) SetVirtualClusters

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

SetVirtualClusters sets the VirtualClusters field's value.

func (ListVirtualClustersOutput) String

func (s ListVirtualClustersOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*MonitoringConfiguration) Validate

func (s *MonitoringConfiguration) Validate() error

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

type ResourceNotFoundException

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

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

The specified resource was not found.

func (*ResourceNotFoundException) Code

func (s *ResourceNotFoundException) Code() string

Code returns the exception type name.

func (*ResourceNotFoundException) Error

func (s *ResourceNotFoundException) Error() string

func (ResourceNotFoundException) GoString

func (s ResourceNotFoundException) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*S3MonitoringConfiguration) SetLogUri

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

SetLogUri sets the LogUri field's value.

func (S3MonitoringConfiguration) String

func (s S3MonitoringConfiguration) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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 sensitive parameter and its value will be
    // replaced with "sensitive" in string returned by SparkSubmitJobDriver's
    // String and GoString methods.
    //
    // 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 is a sensitive parameter and its value will be
    // replaced with "sensitive" in string returned by SparkSubmitJobDriver's
    // String and GoString methods.
    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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*StartJobRunOutput) SetArn

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

SetArn sets the Arn field's value.

func (*StartJobRunOutput) SetId

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

SetId sets the Id field's value.

func (*StartJobRunOutput) SetName

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

SetName sets the Name field's value.

func (*StartJobRunOutput) SetVirtualClusterId

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

SetVirtualClusterId sets the VirtualClusterId field's value.

func (StartJobRunOutput) String

func (s StartJobRunOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (TagResourceOutput) String

func (s TagResourceOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (UntagResourceOutput) String

func (s UntagResourceOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

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.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".