Documentation ¶
Overview ¶
Package emrcontainers provides the client and types for making API requests to Amazon EMR Containers.
Amazon EMR on EKS provides a deployment option for Amazon EMR that allows you to run open-source big data frameworks on Amazon Elastic Kubernetes Service (Amazon EKS). With this deployment option, you can focus on running analytics workloads while Amazon EMR on EKS builds, configures, and manages containers for open-source applications. For more information about Amazon EMR on EKS concepts and tasks, see What is Amazon EMR on EKS (https://docs.aws.amazon.com/emr/latest/EMR-on-EKS-DevelopmentGuide/emr-eks.html).
Amazon EMR containers is the API name for Amazon EMR on EKS. The emr-containers prefix is used in the following scenarios:
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
Index ¶
- Constants
- func ContainerProviderType_Values() []string
- func EndpointState_Values() []string
- func FailureReason_Values() []string
- func JobRunState_Values() []string
- func PersistentAppUI_Values() []string
- func TemplateParameterDataType_Values() []string
- func VirtualClusterState_Values() []string
- type CancelJobRunInput
- type CancelJobRunOutput
- type Certificate
- type CloudWatchMonitoringConfiguration
- func (s CloudWatchMonitoringConfiguration) GoString() string
- func (s *CloudWatchMonitoringConfiguration) SetLogGroupName(v string) *CloudWatchMonitoringConfiguration
- func (s *CloudWatchMonitoringConfiguration) SetLogStreamNamePrefix(v string) *CloudWatchMonitoringConfiguration
- func (s CloudWatchMonitoringConfiguration) String() string
- func (s *CloudWatchMonitoringConfiguration) Validate() error
- type Configuration
- func (s Configuration) GoString() string
- func (s *Configuration) SetClassification(v string) *Configuration
- func (s *Configuration) SetConfigurations(v []*Configuration) *Configuration
- func (s *Configuration) SetProperties(v map[string]*string) *Configuration
- func (s Configuration) String() string
- func (s *Configuration) Validate() error
- type ConfigurationOverrides
- func (s ConfigurationOverrides) GoString() string
- func (s *ConfigurationOverrides) SetApplicationConfiguration(v []*Configuration) *ConfigurationOverrides
- func (s *ConfigurationOverrides) SetMonitoringConfiguration(v *MonitoringConfiguration) *ConfigurationOverrides
- func (s ConfigurationOverrides) String() string
- func (s *ConfigurationOverrides) Validate() error
- type ContainerInfo
- type ContainerProvider
- func (s ContainerProvider) GoString() string
- func (s *ContainerProvider) SetId(v string) *ContainerProvider
- func (s *ContainerProvider) SetInfo(v *ContainerInfo) *ContainerProvider
- func (s *ContainerProvider) SetType(v string) *ContainerProvider
- func (s ContainerProvider) String() string
- func (s *ContainerProvider) Validate() error
- type CreateJobTemplateInput
- func (s CreateJobTemplateInput) GoString() string
- func (s *CreateJobTemplateInput) SetClientToken(v string) *CreateJobTemplateInput
- func (s *CreateJobTemplateInput) SetJobTemplateData(v *JobTemplateData) *CreateJobTemplateInput
- func (s *CreateJobTemplateInput) SetKmsKeyArn(v string) *CreateJobTemplateInput
- func (s *CreateJobTemplateInput) SetName(v string) *CreateJobTemplateInput
- func (s *CreateJobTemplateInput) SetTags(v map[string]*string) *CreateJobTemplateInput
- func (s CreateJobTemplateInput) String() string
- func (s *CreateJobTemplateInput) Validate() error
- type CreateJobTemplateOutput
- func (s CreateJobTemplateOutput) GoString() string
- func (s *CreateJobTemplateOutput) SetArn(v string) *CreateJobTemplateOutput
- func (s *CreateJobTemplateOutput) SetCreatedAt(v time.Time) *CreateJobTemplateOutput
- func (s *CreateJobTemplateOutput) SetId(v string) *CreateJobTemplateOutput
- func (s *CreateJobTemplateOutput) SetName(v string) *CreateJobTemplateOutput
- func (s CreateJobTemplateOutput) String() string
- type CreateManagedEndpointInput
- func (s CreateManagedEndpointInput) GoString() string
- func (s *CreateManagedEndpointInput) SetCertificateArn(v string) *CreateManagedEndpointInput
- func (s *CreateManagedEndpointInput) SetClientToken(v string) *CreateManagedEndpointInput
- func (s *CreateManagedEndpointInput) SetConfigurationOverrides(v *ConfigurationOverrides) *CreateManagedEndpointInput
- func (s *CreateManagedEndpointInput) SetExecutionRoleArn(v string) *CreateManagedEndpointInput
- func (s *CreateManagedEndpointInput) SetName(v string) *CreateManagedEndpointInput
- func (s *CreateManagedEndpointInput) SetReleaseLabel(v string) *CreateManagedEndpointInput
- func (s *CreateManagedEndpointInput) SetTags(v map[string]*string) *CreateManagedEndpointInput
- func (s *CreateManagedEndpointInput) SetType(v string) *CreateManagedEndpointInput
- func (s *CreateManagedEndpointInput) SetVirtualClusterId(v string) *CreateManagedEndpointInput
- func (s CreateManagedEndpointInput) String() string
- func (s *CreateManagedEndpointInput) Validate() error
- type CreateManagedEndpointOutput
- func (s CreateManagedEndpointOutput) GoString() string
- func (s *CreateManagedEndpointOutput) SetArn(v string) *CreateManagedEndpointOutput
- func (s *CreateManagedEndpointOutput) SetId(v string) *CreateManagedEndpointOutput
- func (s *CreateManagedEndpointOutput) SetName(v string) *CreateManagedEndpointOutput
- func (s *CreateManagedEndpointOutput) SetVirtualClusterId(v string) *CreateManagedEndpointOutput
- func (s CreateManagedEndpointOutput) String() string
- type CreateVirtualClusterInput
- func (s CreateVirtualClusterInput) GoString() string
- func (s *CreateVirtualClusterInput) SetClientToken(v string) *CreateVirtualClusterInput
- func (s *CreateVirtualClusterInput) SetContainerProvider(v *ContainerProvider) *CreateVirtualClusterInput
- func (s *CreateVirtualClusterInput) SetName(v string) *CreateVirtualClusterInput
- func (s *CreateVirtualClusterInput) SetTags(v map[string]*string) *CreateVirtualClusterInput
- func (s CreateVirtualClusterInput) String() string
- func (s *CreateVirtualClusterInput) Validate() error
- type CreateVirtualClusterOutput
- func (s CreateVirtualClusterOutput) GoString() string
- func (s *CreateVirtualClusterOutput) SetArn(v string) *CreateVirtualClusterOutput
- func (s *CreateVirtualClusterOutput) SetId(v string) *CreateVirtualClusterOutput
- func (s *CreateVirtualClusterOutput) SetName(v string) *CreateVirtualClusterOutput
- func (s CreateVirtualClusterOutput) String() string
- type DeleteJobTemplateInput
- type DeleteJobTemplateOutput
- type DeleteManagedEndpointInput
- func (s DeleteManagedEndpointInput) GoString() string
- func (s *DeleteManagedEndpointInput) SetId(v string) *DeleteManagedEndpointInput
- func (s *DeleteManagedEndpointInput) SetVirtualClusterId(v string) *DeleteManagedEndpointInput
- func (s DeleteManagedEndpointInput) String() string
- func (s *DeleteManagedEndpointInput) Validate() error
- type DeleteManagedEndpointOutput
- type DeleteVirtualClusterInput
- type DeleteVirtualClusterOutput
- type DescribeJobRunInput
- type DescribeJobRunOutput
- type DescribeJobTemplateInput
- type DescribeJobTemplateOutput
- type DescribeManagedEndpointInput
- func (s DescribeManagedEndpointInput) GoString() string
- func (s *DescribeManagedEndpointInput) SetId(v string) *DescribeManagedEndpointInput
- func (s *DescribeManagedEndpointInput) SetVirtualClusterId(v string) *DescribeManagedEndpointInput
- func (s DescribeManagedEndpointInput) String() string
- func (s *DescribeManagedEndpointInput) Validate() error
- type DescribeManagedEndpointOutput
- type DescribeVirtualClusterInput
- type DescribeVirtualClusterOutput
- type 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) CreateJobTemplate(input *CreateJobTemplateInput) (*CreateJobTemplateOutput, error)
- func (c *EMRContainers) CreateJobTemplateRequest(input *CreateJobTemplateInput) (req *request.Request, output *CreateJobTemplateOutput)
- func (c *EMRContainers) CreateJobTemplateWithContext(ctx aws.Context, input *CreateJobTemplateInput, opts ...request.Option) (*CreateJobTemplateOutput, 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) DeleteJobTemplate(input *DeleteJobTemplateInput) (*DeleteJobTemplateOutput, error)
- func (c *EMRContainers) DeleteJobTemplateRequest(input *DeleteJobTemplateInput) (req *request.Request, output *DeleteJobTemplateOutput)
- func (c *EMRContainers) DeleteJobTemplateWithContext(ctx aws.Context, input *DeleteJobTemplateInput, opts ...request.Option) (*DeleteJobTemplateOutput, 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) DescribeJobTemplate(input *DescribeJobTemplateInput) (*DescribeJobTemplateOutput, error)
- func (c *EMRContainers) DescribeJobTemplateRequest(input *DescribeJobTemplateInput) (req *request.Request, output *DescribeJobTemplateOutput)
- func (c *EMRContainers) DescribeJobTemplateWithContext(ctx aws.Context, input *DescribeJobTemplateInput, opts ...request.Option) (*DescribeJobTemplateOutput, 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, ...) 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) ListJobTemplates(input *ListJobTemplatesInput) (*ListJobTemplatesOutput, error)
- func (c *EMRContainers) ListJobTemplatesPages(input *ListJobTemplatesInput, fn func(*ListJobTemplatesOutput, bool) bool) error
- func (c *EMRContainers) ListJobTemplatesPagesWithContext(ctx aws.Context, input *ListJobTemplatesInput, ...) error
- func (c *EMRContainers) ListJobTemplatesRequest(input *ListJobTemplatesInput) (req *request.Request, output *ListJobTemplatesOutput)
- func (c *EMRContainers) ListJobTemplatesWithContext(ctx aws.Context, input *ListJobTemplatesInput, opts ...request.Option) (*ListJobTemplatesOutput, error)
- func (c *EMRContainers) ListManagedEndpoints(input *ListManagedEndpointsInput) (*ListManagedEndpointsOutput, error)
- func (c *EMRContainers) ListManagedEndpointsPages(input *ListManagedEndpointsInput, ...) error
- func (c *EMRContainers) ListManagedEndpointsPagesWithContext(ctx aws.Context, input *ListManagedEndpointsInput, ...) 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, ...) error
- func (c *EMRContainers) ListVirtualClustersPagesWithContext(ctx aws.Context, input *ListVirtualClustersInput, ...) 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)
- type EksInfo
- type Endpoint
- func (s Endpoint) GoString() string
- func (s *Endpoint) SetArn(v string) *Endpoint
- func (s *Endpoint) SetCertificateArn(v string) *Endpoint
- func (s *Endpoint) SetCertificateAuthority(v *Certificate) *Endpoint
- func (s *Endpoint) SetConfigurationOverrides(v *ConfigurationOverrides) *Endpoint
- func (s *Endpoint) SetCreatedAt(v time.Time) *Endpoint
- func (s *Endpoint) SetExecutionRoleArn(v string) *Endpoint
- func (s *Endpoint) SetFailureReason(v string) *Endpoint
- func (s *Endpoint) SetId(v string) *Endpoint
- func (s *Endpoint) SetName(v string) *Endpoint
- func (s *Endpoint) SetReleaseLabel(v string) *Endpoint
- func (s *Endpoint) SetSecurityGroup(v string) *Endpoint
- func (s *Endpoint) SetServerUrl(v string) *Endpoint
- func (s *Endpoint) SetState(v string) *Endpoint
- func (s *Endpoint) SetStateDetails(v string) *Endpoint
- func (s *Endpoint) SetSubnetIds(v []*string) *Endpoint
- func (s *Endpoint) SetTags(v map[string]*string) *Endpoint
- func (s *Endpoint) SetType(v string) *Endpoint
- func (s *Endpoint) SetVirtualClusterId(v string) *Endpoint
- func (s Endpoint) String() string
- type InternalServerException
- func (s *InternalServerException) Code() string
- func (s *InternalServerException) Error() string
- func (s InternalServerException) GoString() string
- func (s *InternalServerException) Message() string
- func (s *InternalServerException) OrigErr() error
- func (s *InternalServerException) RequestID() string
- func (s *InternalServerException) StatusCode() int
- func (s InternalServerException) String() string
- type JobDriver
- type JobRun
- func (s JobRun) GoString() string
- func (s *JobRun) SetArn(v string) *JobRun
- func (s *JobRun) SetClientToken(v string) *JobRun
- func (s *JobRun) SetConfigurationOverrides(v *ConfigurationOverrides) *JobRun
- func (s *JobRun) SetCreatedAt(v time.Time) *JobRun
- func (s *JobRun) SetCreatedBy(v string) *JobRun
- func (s *JobRun) SetExecutionRoleArn(v string) *JobRun
- func (s *JobRun) SetFailureReason(v string) *JobRun
- func (s *JobRun) SetFinishedAt(v time.Time) *JobRun
- func (s *JobRun) SetId(v string) *JobRun
- func (s *JobRun) SetJobDriver(v *JobDriver) *JobRun
- func (s *JobRun) SetName(v string) *JobRun
- func (s *JobRun) SetReleaseLabel(v string) *JobRun
- func (s *JobRun) SetState(v string) *JobRun
- func (s *JobRun) SetStateDetails(v string) *JobRun
- func (s *JobRun) SetTags(v map[string]*string) *JobRun
- func (s *JobRun) SetVirtualClusterId(v string) *JobRun
- func (s JobRun) String() string
- type JobTemplate
- func (s JobTemplate) GoString() string
- func (s *JobTemplate) SetArn(v string) *JobTemplate
- func (s *JobTemplate) SetCreatedAt(v time.Time) *JobTemplate
- func (s *JobTemplate) SetCreatedBy(v string) *JobTemplate
- func (s *JobTemplate) SetDecryptionError(v string) *JobTemplate
- func (s *JobTemplate) SetId(v string) *JobTemplate
- func (s *JobTemplate) SetJobTemplateData(v *JobTemplateData) *JobTemplate
- func (s *JobTemplate) SetKmsKeyArn(v string) *JobTemplate
- func (s *JobTemplate) SetName(v string) *JobTemplate
- func (s *JobTemplate) SetTags(v map[string]*string) *JobTemplate
- func (s JobTemplate) String() string
- type JobTemplateData
- func (s JobTemplateData) GoString() string
- func (s *JobTemplateData) SetConfigurationOverrides(v *ParametricConfigurationOverrides) *JobTemplateData
- func (s *JobTemplateData) SetExecutionRoleArn(v string) *JobTemplateData
- func (s *JobTemplateData) SetJobDriver(v *JobDriver) *JobTemplateData
- func (s *JobTemplateData) SetJobTags(v map[string]*string) *JobTemplateData
- func (s *JobTemplateData) SetParameterConfiguration(v map[string]*TemplateParameterConfiguration) *JobTemplateData
- func (s *JobTemplateData) SetReleaseLabel(v string) *JobTemplateData
- func (s JobTemplateData) String() string
- func (s *JobTemplateData) Validate() error
- type ListJobRunsInput
- func (s ListJobRunsInput) GoString() string
- func (s *ListJobRunsInput) SetCreatedAfter(v time.Time) *ListJobRunsInput
- func (s *ListJobRunsInput) SetCreatedBefore(v time.Time) *ListJobRunsInput
- func (s *ListJobRunsInput) SetMaxResults(v int64) *ListJobRunsInput
- func (s *ListJobRunsInput) SetName(v string) *ListJobRunsInput
- func (s *ListJobRunsInput) SetNextToken(v string) *ListJobRunsInput
- func (s *ListJobRunsInput) SetStates(v []*string) *ListJobRunsInput
- func (s *ListJobRunsInput) SetVirtualClusterId(v string) *ListJobRunsInput
- func (s ListJobRunsInput) String() string
- func (s *ListJobRunsInput) Validate() error
- type ListJobRunsOutput
- type ListJobTemplatesInput
- func (s ListJobTemplatesInput) GoString() string
- func (s *ListJobTemplatesInput) SetCreatedAfter(v time.Time) *ListJobTemplatesInput
- func (s *ListJobTemplatesInput) SetCreatedBefore(v time.Time) *ListJobTemplatesInput
- func (s *ListJobTemplatesInput) SetMaxResults(v int64) *ListJobTemplatesInput
- func (s *ListJobTemplatesInput) SetNextToken(v string) *ListJobTemplatesInput
- func (s ListJobTemplatesInput) String() string
- func (s *ListJobTemplatesInput) Validate() error
- type ListJobTemplatesOutput
- type ListManagedEndpointsInput
- func (s ListManagedEndpointsInput) GoString() string
- func (s *ListManagedEndpointsInput) SetCreatedAfter(v time.Time) *ListManagedEndpointsInput
- func (s *ListManagedEndpointsInput) SetCreatedBefore(v time.Time) *ListManagedEndpointsInput
- func (s *ListManagedEndpointsInput) SetMaxResults(v int64) *ListManagedEndpointsInput
- func (s *ListManagedEndpointsInput) SetNextToken(v string) *ListManagedEndpointsInput
- func (s *ListManagedEndpointsInput) SetStates(v []*string) *ListManagedEndpointsInput
- func (s *ListManagedEndpointsInput) SetTypes(v []*string) *ListManagedEndpointsInput
- func (s *ListManagedEndpointsInput) SetVirtualClusterId(v string) *ListManagedEndpointsInput
- func (s ListManagedEndpointsInput) String() string
- func (s *ListManagedEndpointsInput) Validate() error
- type ListManagedEndpointsOutput
- type ListTagsForResourceInput
- type ListTagsForResourceOutput
- type ListVirtualClustersInput
- func (s ListVirtualClustersInput) GoString() string
- func (s *ListVirtualClustersInput) SetContainerProviderId(v string) *ListVirtualClustersInput
- func (s *ListVirtualClustersInput) SetContainerProviderType(v string) *ListVirtualClustersInput
- func (s *ListVirtualClustersInput) SetCreatedAfter(v time.Time) *ListVirtualClustersInput
- func (s *ListVirtualClustersInput) SetCreatedBefore(v time.Time) *ListVirtualClustersInput
- func (s *ListVirtualClustersInput) SetMaxResults(v int64) *ListVirtualClustersInput
- func (s *ListVirtualClustersInput) SetNextToken(v string) *ListVirtualClustersInput
- func (s *ListVirtualClustersInput) SetStates(v []*string) *ListVirtualClustersInput
- func (s ListVirtualClustersInput) String() string
- func (s *ListVirtualClustersInput) Validate() error
- type ListVirtualClustersOutput
- type MonitoringConfiguration
- func (s MonitoringConfiguration) GoString() string
- func (s *MonitoringConfiguration) SetCloudWatchMonitoringConfiguration(v *CloudWatchMonitoringConfiguration) *MonitoringConfiguration
- func (s *MonitoringConfiguration) SetPersistentAppUI(v string) *MonitoringConfiguration
- func (s *MonitoringConfiguration) SetS3MonitoringConfiguration(v *S3MonitoringConfiguration) *MonitoringConfiguration
- func (s MonitoringConfiguration) String() string
- func (s *MonitoringConfiguration) Validate() error
- type ParametricCloudWatchMonitoringConfiguration
- func (s ParametricCloudWatchMonitoringConfiguration) GoString() string
- func (s *ParametricCloudWatchMonitoringConfiguration) SetLogGroupName(v string) *ParametricCloudWatchMonitoringConfiguration
- func (s *ParametricCloudWatchMonitoringConfiguration) SetLogStreamNamePrefix(v string) *ParametricCloudWatchMonitoringConfiguration
- func (s ParametricCloudWatchMonitoringConfiguration) String() string
- func (s *ParametricCloudWatchMonitoringConfiguration) Validate() error
- type ParametricConfigurationOverrides
- func (s ParametricConfigurationOverrides) GoString() string
- func (s *ParametricConfigurationOverrides) SetApplicationConfiguration(v []*Configuration) *ParametricConfigurationOverrides
- func (s *ParametricConfigurationOverrides) SetMonitoringConfiguration(v *ParametricMonitoringConfiguration) *ParametricConfigurationOverrides
- func (s ParametricConfigurationOverrides) String() string
- func (s *ParametricConfigurationOverrides) Validate() error
- type ParametricMonitoringConfiguration
- func (s ParametricMonitoringConfiguration) GoString() string
- func (s *ParametricMonitoringConfiguration) SetCloudWatchMonitoringConfiguration(v *ParametricCloudWatchMonitoringConfiguration) *ParametricMonitoringConfiguration
- func (s *ParametricMonitoringConfiguration) SetPersistentAppUI(v string) *ParametricMonitoringConfiguration
- func (s *ParametricMonitoringConfiguration) SetS3MonitoringConfiguration(v *ParametricS3MonitoringConfiguration) *ParametricMonitoringConfiguration
- func (s ParametricMonitoringConfiguration) String() string
- func (s *ParametricMonitoringConfiguration) Validate() error
- type ParametricS3MonitoringConfiguration
- type ResourceNotFoundException
- func (s *ResourceNotFoundException) Code() string
- func (s *ResourceNotFoundException) Error() string
- func (s ResourceNotFoundException) GoString() string
- func (s *ResourceNotFoundException) Message() string
- func (s *ResourceNotFoundException) OrigErr() error
- func (s *ResourceNotFoundException) RequestID() string
- func (s *ResourceNotFoundException) StatusCode() int
- func (s ResourceNotFoundException) String() string
- type S3MonitoringConfiguration
- type SparkSqlJobDriver
- type SparkSubmitJobDriver
- func (s SparkSubmitJobDriver) GoString() string
- func (s *SparkSubmitJobDriver) SetEntryPoint(v string) *SparkSubmitJobDriver
- func (s *SparkSubmitJobDriver) SetEntryPointArguments(v []*string) *SparkSubmitJobDriver
- func (s *SparkSubmitJobDriver) SetSparkSubmitParameters(v string) *SparkSubmitJobDriver
- func (s SparkSubmitJobDriver) String() string
- func (s *SparkSubmitJobDriver) Validate() error
- type StartJobRunInput
- func (s StartJobRunInput) GoString() string
- func (s *StartJobRunInput) SetClientToken(v string) *StartJobRunInput
- func (s *StartJobRunInput) SetConfigurationOverrides(v *ConfigurationOverrides) *StartJobRunInput
- func (s *StartJobRunInput) SetExecutionRoleArn(v string) *StartJobRunInput
- func (s *StartJobRunInput) SetJobDriver(v *JobDriver) *StartJobRunInput
- func (s *StartJobRunInput) SetJobTemplateId(v string) *StartJobRunInput
- func (s *StartJobRunInput) SetJobTemplateParameters(v map[string]*string) *StartJobRunInput
- func (s *StartJobRunInput) SetName(v string) *StartJobRunInput
- func (s *StartJobRunInput) SetReleaseLabel(v string) *StartJobRunInput
- func (s *StartJobRunInput) SetTags(v map[string]*string) *StartJobRunInput
- func (s *StartJobRunInput) SetVirtualClusterId(v string) *StartJobRunInput
- func (s StartJobRunInput) String() string
- func (s *StartJobRunInput) Validate() error
- type StartJobRunOutput
- func (s StartJobRunOutput) GoString() string
- func (s *StartJobRunOutput) SetArn(v string) *StartJobRunOutput
- func (s *StartJobRunOutput) SetId(v string) *StartJobRunOutput
- func (s *StartJobRunOutput) SetName(v string) *StartJobRunOutput
- func (s *StartJobRunOutput) SetVirtualClusterId(v string) *StartJobRunOutput
- func (s StartJobRunOutput) String() string
- type TagResourceInput
- type TagResourceOutput
- type TemplateParameterConfiguration
- func (s TemplateParameterConfiguration) GoString() string
- func (s *TemplateParameterConfiguration) SetDefaultValue(v string) *TemplateParameterConfiguration
- func (s *TemplateParameterConfiguration) SetType(v string) *TemplateParameterConfiguration
- func (s TemplateParameterConfiguration) String() string
- func (s *TemplateParameterConfiguration) Validate() error
- type UntagResourceInput
- type UntagResourceOutput
- type ValidationException
- func (s *ValidationException) Code() string
- func (s *ValidationException) Error() string
- func (s ValidationException) GoString() string
- func (s *ValidationException) Message() string
- func (s *ValidationException) OrigErr() error
- func (s *ValidationException) RequestID() string
- func (s *ValidationException) StatusCode() int
- func (s ValidationException) String() string
- type VirtualCluster
- func (s VirtualCluster) GoString() string
- func (s *VirtualCluster) SetArn(v string) *VirtualCluster
- func (s *VirtualCluster) SetContainerProvider(v *ContainerProvider) *VirtualCluster
- func (s *VirtualCluster) SetCreatedAt(v time.Time) *VirtualCluster
- func (s *VirtualCluster) SetId(v string) *VirtualCluster
- func (s *VirtualCluster) SetName(v string) *VirtualCluster
- func (s *VirtualCluster) SetState(v string) *VirtualCluster
- func (s *VirtualCluster) SetTags(v map[string]*string) *VirtualCluster
- func (s VirtualCluster) String() string
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 = "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 ( // TemplateParameterDataTypeNumber is a TemplateParameterDataType enum value TemplateParameterDataTypeNumber = "NUMBER" // TemplateParameterDataTypeString is a TemplateParameterDataType enum value TemplateParameterDataTypeString = "STRING" )
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"
)
Variables ¶
This section is empty.
Functions ¶
func ContainerProviderType_Values ¶
func ContainerProviderType_Values() []string
ContainerProviderType_Values returns all elements of the ContainerProviderType enum
func EndpointState_Values ¶
func EndpointState_Values() []string
EndpointState_Values returns all elements of the EndpointState enum
func FailureReason_Values ¶
func FailureReason_Values() []string
FailureReason_Values returns all elements of the FailureReason enum
func JobRunState_Values ¶
func JobRunState_Values() []string
JobRunState_Values returns all elements of the JobRunState enum
func PersistentAppUI_Values ¶
func PersistentAppUI_Values() []string
PersistentAppUI_Values returns all elements of the PersistentAppUI enum
func TemplateParameterDataType_Values ¶ added in v1.44.131
func TemplateParameterDataType_Values() []string
TemplateParameterDataType_Values returns all elements of the TemplateParameterDataType enum
func VirtualClusterState_Values ¶
func VirtualClusterState_Values() []string
VirtualClusterState_Values returns all elements of the VirtualClusterState enum
Types ¶
type CancelJobRunInput ¶
type CancelJobRunInput struct { // The ID of the job run to cancel. // // Id is a required field Id *string `location:"uri" locationName:"jobRunId" min:"1" type:"string" required:"true"` // The ID of the virtual cluster for which the job run will be canceled. // // VirtualClusterId is a required field VirtualClusterId *string `location:"uri" locationName:"virtualClusterId" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
func (CancelJobRunInput) GoString ¶
func (s CancelJobRunInput) GoString() string
GoString returns the string representation.
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 ¶ added in v1.41.11
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 ¶ added in v1.41.11
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 ¶ added in v1.41.11
func (s *Certificate) SetCertificateArn(v string) *Certificate
SetCertificateArn sets the CertificateArn field's value.
func (*Certificate) SetCertificateData ¶ added in v1.41.11
func (s *Certificate) SetCertificateData(v string) *Certificate
SetCertificateData sets the CertificateData field's value.
func (Certificate) String ¶ added in v1.41.11
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 CreateJobTemplateInput ¶ added in v1.44.131
type CreateJobTemplateInput struct { // The client token of the job template. ClientToken *string `locationName:"clientToken" min:"1" type:"string" idempotencyToken:"true"` // The job template data which holds values of StartJobRun API request. // // JobTemplateData is a required field JobTemplateData *JobTemplateData `locationName:"jobTemplateData" type:"structure" required:"true"` // The KMS key ARN used to encrypt the job template. KmsKeyArn *string `locationName:"kmsKeyArn" min:"3" type:"string"` // The specified name of the job template. // // Name is a required field Name *string `locationName:"name" min:"1" type:"string" required:"true"` // The tags that are associated with the job template. Tags map[string]*string `locationName:"tags" type:"map"` // contains filtered or unexported fields }
func (CreateJobTemplateInput) GoString ¶ added in v1.44.131
func (s CreateJobTemplateInput) 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 (*CreateJobTemplateInput) SetClientToken ¶ added in v1.44.131
func (s *CreateJobTemplateInput) SetClientToken(v string) *CreateJobTemplateInput
SetClientToken sets the ClientToken field's value.
func (*CreateJobTemplateInput) SetJobTemplateData ¶ added in v1.44.131
func (s *CreateJobTemplateInput) SetJobTemplateData(v *JobTemplateData) *CreateJobTemplateInput
SetJobTemplateData sets the JobTemplateData field's value.
func (*CreateJobTemplateInput) SetKmsKeyArn ¶ added in v1.44.131
func (s *CreateJobTemplateInput) SetKmsKeyArn(v string) *CreateJobTemplateInput
SetKmsKeyArn sets the KmsKeyArn field's value.
func (*CreateJobTemplateInput) SetName ¶ added in v1.44.131
func (s *CreateJobTemplateInput) SetName(v string) *CreateJobTemplateInput
SetName sets the Name field's value.
func (*CreateJobTemplateInput) SetTags ¶ added in v1.44.131
func (s *CreateJobTemplateInput) SetTags(v map[string]*string) *CreateJobTemplateInput
SetTags sets the Tags field's value.
func (CreateJobTemplateInput) String ¶ added in v1.44.131
func (s CreateJobTemplateInput) 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 (*CreateJobTemplateInput) Validate ¶ added in v1.44.131
func (s *CreateJobTemplateInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CreateJobTemplateOutput ¶ added in v1.44.131
type CreateJobTemplateOutput struct { // This output display the ARN of the created job template. Arn *string `locationName:"arn" min:"60" type:"string"` // This output displays the date and time when the job template was created. CreatedAt *time.Time `locationName:"createdAt" type:"timestamp" timestampFormat:"iso8601"` // This output display the created job template ID. Id *string `locationName:"id" min:"1" type:"string"` // This output displays the name of the created job template. Name *string `locationName:"name" min:"1" type:"string"` // contains filtered or unexported fields }
func (CreateJobTemplateOutput) GoString ¶ added in v1.44.131
func (s CreateJobTemplateOutput) 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 (*CreateJobTemplateOutput) SetArn ¶ added in v1.44.131
func (s *CreateJobTemplateOutput) SetArn(v string) *CreateJobTemplateOutput
SetArn sets the Arn field's value.
func (*CreateJobTemplateOutput) SetCreatedAt ¶ added in v1.44.131
func (s *CreateJobTemplateOutput) SetCreatedAt(v time.Time) *CreateJobTemplateOutput
SetCreatedAt sets the CreatedAt field's value.
func (*CreateJobTemplateOutput) SetId ¶ added in v1.44.131
func (s *CreateJobTemplateOutput) SetId(v string) *CreateJobTemplateOutput
SetId sets the Id field's value.
func (*CreateJobTemplateOutput) SetName ¶ added in v1.44.131
func (s *CreateJobTemplateOutput) SetName(v string) *CreateJobTemplateOutput
SetName sets the Name field's value.
func (CreateJobTemplateOutput) String ¶ added in v1.44.131
func (s CreateJobTemplateOutput) 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 CreateManagedEndpointInput ¶
type CreateManagedEndpointInput struct { // The certificate ARN provided by users for the managed endpoint. This field // 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 DeleteJobTemplateInput ¶ added in v1.44.131
type DeleteJobTemplateInput struct { // The ID of the job template that will be deleted. // // Id is a required field Id *string `location:"uri" locationName:"templateId" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
func (DeleteJobTemplateInput) GoString ¶ added in v1.44.131
func (s DeleteJobTemplateInput) 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 (*DeleteJobTemplateInput) SetId ¶ added in v1.44.131
func (s *DeleteJobTemplateInput) SetId(v string) *DeleteJobTemplateInput
SetId sets the Id field's value.
func (DeleteJobTemplateInput) String ¶ added in v1.44.131
func (s DeleteJobTemplateInput) 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 (*DeleteJobTemplateInput) Validate ¶ added in v1.44.131
func (s *DeleteJobTemplateInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DeleteJobTemplateOutput ¶ added in v1.44.131
type DeleteJobTemplateOutput struct { // This output contains the ID of the job template that was deleted. Id *string `locationName:"id" min:"1" type:"string"` // contains filtered or unexported fields }
func (DeleteJobTemplateOutput) GoString ¶ added in v1.44.131
func (s DeleteJobTemplateOutput) 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 (*DeleteJobTemplateOutput) SetId ¶ added in v1.44.131
func (s *DeleteJobTemplateOutput) SetId(v string) *DeleteJobTemplateOutput
SetId sets the Id field's value.
func (DeleteJobTemplateOutput) String ¶ added in v1.44.131
func (s DeleteJobTemplateOutput) 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 DescribeJobTemplateInput ¶ added in v1.44.131
type DescribeJobTemplateInput struct { // The ID of the job template that will be described. // // Id is a required field Id *string `location:"uri" locationName:"templateId" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
func (DescribeJobTemplateInput) GoString ¶ added in v1.44.131
func (s DescribeJobTemplateInput) 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 (*DescribeJobTemplateInput) SetId ¶ added in v1.44.131
func (s *DescribeJobTemplateInput) SetId(v string) *DescribeJobTemplateInput
SetId sets the Id field's value.
func (DescribeJobTemplateInput) String ¶ added in v1.44.131
func (s DescribeJobTemplateInput) 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 (*DescribeJobTemplateInput) Validate ¶ added in v1.44.131
func (s *DescribeJobTemplateInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DescribeJobTemplateOutput ¶ added in v1.44.131
type DescribeJobTemplateOutput struct { // This output displays information about the specified job template. JobTemplate *JobTemplate `locationName:"jobTemplate" type:"structure"` // contains filtered or unexported fields }
func (DescribeJobTemplateOutput) GoString ¶ added in v1.44.131
func (s DescribeJobTemplateOutput) 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 (*DescribeJobTemplateOutput) SetJobTemplate ¶ added in v1.44.131
func (s *DescribeJobTemplateOutput) SetJobTemplate(v *JobTemplate) *DescribeJobTemplateOutput
SetJobTemplate sets the JobTemplate field's value.
func (DescribeJobTemplateOutput) String ¶ added in v1.44.131
func (s DescribeJobTemplateOutput) 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 ¶
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) CreateJobTemplate ¶ added in v1.44.131
func (c *EMRContainers) CreateJobTemplate(input *CreateJobTemplateInput) (*CreateJobTemplateOutput, error)
CreateJobTemplate API operation for Amazon EMR Containers.
Creates a job template. Job template stores values of StartJobRun API request in a template and can be used to start a job run. Job template allows two use cases: avoid repeating recurring StartJobRun API request values, enforcing certain values in StartJobRun API request.
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 CreateJobTemplate 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/CreateJobTemplate
func (*EMRContainers) CreateJobTemplateRequest ¶ added in v1.44.131
func (c *EMRContainers) CreateJobTemplateRequest(input *CreateJobTemplateInput) (req *request.Request, output *CreateJobTemplateOutput)
CreateJobTemplateRequest generates a "aws/request.Request" representing the client's request for the CreateJobTemplate 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 CreateJobTemplate for more information on using the CreateJobTemplate 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 CreateJobTemplateRequest method. req, resp := client.CreateJobTemplateRequest(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/CreateJobTemplate
func (*EMRContainers) CreateJobTemplateWithContext ¶ added in v1.44.131
func (c *EMRContainers) CreateJobTemplateWithContext(ctx aws.Context, input *CreateJobTemplateInput, opts ...request.Option) (*CreateJobTemplateOutput, error)
CreateJobTemplateWithContext is the same as CreateJobTemplate with the addition of the ability to pass a context and additional request options.
See CreateJobTemplate 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) DeleteJobTemplate ¶ added in v1.44.131
func (c *EMRContainers) DeleteJobTemplate(input *DeleteJobTemplateInput) (*DeleteJobTemplateOutput, error)
DeleteJobTemplate API operation for Amazon EMR Containers.
Deletes a job template. Job template stores values of StartJobRun API request in a template and can be used to start a job run. Job template allows two use cases: avoid repeating recurring StartJobRun API request values, enforcing certain values in StartJobRun API request.
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 DeleteJobTemplate 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/DeleteJobTemplate
func (*EMRContainers) DeleteJobTemplateRequest ¶ added in v1.44.131
func (c *EMRContainers) DeleteJobTemplateRequest(input *DeleteJobTemplateInput) (req *request.Request, output *DeleteJobTemplateOutput)
DeleteJobTemplateRequest generates a "aws/request.Request" representing the client's request for the DeleteJobTemplate 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 DeleteJobTemplate for more information on using the DeleteJobTemplate 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 DeleteJobTemplateRequest method. req, resp := client.DeleteJobTemplateRequest(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/DeleteJobTemplate
func (*EMRContainers) DeleteJobTemplateWithContext ¶ added in v1.44.131
func (c *EMRContainers) DeleteJobTemplateWithContext(ctx aws.Context, input *DeleteJobTemplateInput, opts ...request.Option) (*DeleteJobTemplateOutput, error)
DeleteJobTemplateWithContext is the same as DeleteJobTemplate with the addition of the ability to pass a context and additional request options.
See DeleteJobTemplate 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) DescribeJobTemplate ¶ added in v1.44.131
func (c *EMRContainers) DescribeJobTemplate(input *DescribeJobTemplateInput) (*DescribeJobTemplateOutput, error)
DescribeJobTemplate API operation for Amazon EMR Containers.
Displays detailed information about a specified job template. Job template stores values of StartJobRun API request in a template and can be used to start a job run. Job template allows two use cases: avoid repeating recurring StartJobRun API request values, enforcing certain values in StartJobRun API request.
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 DescribeJobTemplate 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/DescribeJobTemplate
func (*EMRContainers) DescribeJobTemplateRequest ¶ added in v1.44.131
func (c *EMRContainers) DescribeJobTemplateRequest(input *DescribeJobTemplateInput) (req *request.Request, output *DescribeJobTemplateOutput)
DescribeJobTemplateRequest generates a "aws/request.Request" representing the client's request for the DescribeJobTemplate 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 DescribeJobTemplate for more information on using the DescribeJobTemplate 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 DescribeJobTemplateRequest method. req, resp := client.DescribeJobTemplateRequest(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/DescribeJobTemplate
func (*EMRContainers) DescribeJobTemplateWithContext ¶ added in v1.44.131
func (c *EMRContainers) DescribeJobTemplateWithContext(ctx aws.Context, input *DescribeJobTemplateInput, opts ...request.Option) (*DescribeJobTemplateOutput, error)
DescribeJobTemplateWithContext is the same as DescribeJobTemplate with the addition of the ability to pass a context and additional request options.
See DescribeJobTemplate 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) ListJobTemplates ¶ added in v1.44.131
func (c *EMRContainers) ListJobTemplates(input *ListJobTemplatesInput) (*ListJobTemplatesOutput, error)
ListJobTemplates API operation for Amazon EMR Containers.
Lists job templates based on a set of parameters. Job template stores values of StartJobRun API request in a template and can be used to start a job run. Job template allows two use cases: avoid repeating recurring StartJobRun API request values, enforcing certain values in StartJobRun API request.
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 ListJobTemplates 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/ListJobTemplates
func (*EMRContainers) ListJobTemplatesPages ¶ added in v1.44.131
func (c *EMRContainers) ListJobTemplatesPages(input *ListJobTemplatesInput, fn func(*ListJobTemplatesOutput, bool) bool) error
ListJobTemplatesPages iterates over the pages of a ListJobTemplates operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.
See ListJobTemplates 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 ListJobTemplates operation. pageNum := 0 err := client.ListJobTemplatesPages(params, func(page *emrcontainers.ListJobTemplatesOutput, lastPage bool) bool { pageNum++ fmt.Println(page) return pageNum <= 3 })
func (*EMRContainers) ListJobTemplatesPagesWithContext ¶ added in v1.44.131
func (c *EMRContainers) ListJobTemplatesPagesWithContext(ctx aws.Context, input *ListJobTemplatesInput, fn func(*ListJobTemplatesOutput, bool) bool, opts ...request.Option) error
ListJobTemplatesPagesWithContext same as ListJobTemplatesPages 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) ListJobTemplatesRequest ¶ added in v1.44.131
func (c *EMRContainers) ListJobTemplatesRequest(input *ListJobTemplatesInput) (req *request.Request, output *ListJobTemplatesOutput)
ListJobTemplatesRequest generates a "aws/request.Request" representing the client's request for the ListJobTemplates 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 ListJobTemplates for more information on using the ListJobTemplates 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 ListJobTemplatesRequest method. req, resp := client.ListJobTemplatesRequest(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/ListJobTemplates
func (*EMRContainers) ListJobTemplatesWithContext ¶ added in v1.44.131
func (c *EMRContainers) ListJobTemplatesWithContext(ctx aws.Context, input *ListJobTemplatesInput, opts ...request.Option) (*ListJobTemplatesOutput, error)
ListJobTemplatesWithContext is the same as ListJobTemplates with the addition of the ability to pass a context and additional request options.
See ListJobTemplates 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 ¶
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 ¶
SetNamespace sets the Namespace field's value.
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 ¶
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) SetCertificateArn ¶
SetCertificateArn sets the CertificateArn field's value.
func (*Endpoint) SetCertificateAuthority ¶ added in v1.41.11
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 ¶
SetCreatedAt sets the CreatedAt field's value.
func (*Endpoint) SetExecutionRoleArn ¶
SetExecutionRoleArn sets the ExecutionRoleArn field's value.
func (*Endpoint) SetFailureReason ¶ added in v1.40.3
SetFailureReason sets the FailureReason field's value.
func (*Endpoint) SetReleaseLabel ¶
SetReleaseLabel sets the ReleaseLabel field's value.
func (*Endpoint) SetSecurityGroup ¶
SetSecurityGroup sets the SecurityGroup field's value.
func (*Endpoint) SetServerUrl ¶
SetServerUrl sets the ServerUrl field's value.
func (*Endpoint) SetStateDetails ¶ added in v1.40.3
SetStateDetails sets the StateDetails field's value.
func (*Endpoint) SetSubnetIds ¶
SetSubnetIds sets the SubnetIds field's value.
func (*Endpoint) SetVirtualClusterId ¶
SetVirtualClusterId sets the VirtualClusterId field's value.
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 for job type. SparkSqlJobDriver *SparkSqlJobDriver `locationName:"sparkSqlJobDriver" type:"structure"` // 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. Exactly one of the two available job drivers is required, either sparkSqlJobDriver or sparkSubmitJobDriver.
func (JobDriver) GoString ¶
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) SetSparkSqlJobDriver ¶ added in v1.44.94
func (s *JobDriver) SetSparkSqlJobDriver(v *SparkSqlJobDriver) *JobDriver
SetSparkSqlJobDriver sets the SparkSqlJobDriver field's value.
func (*JobDriver) SetSparkSubmitJobDriver ¶
func (s *JobDriver) SetSparkSubmitJobDriver(v *SparkSubmitJobDriver) *JobDriver
SetSparkSubmitJobDriver sets the SparkSubmitJobDriver field's value.
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 ¶
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) SetClientToken ¶
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 ¶
SetCreatedAt sets the CreatedAt field's value.
func (*JobRun) SetCreatedBy ¶
SetCreatedBy sets the CreatedBy field's value.
func (*JobRun) SetExecutionRoleArn ¶
SetExecutionRoleArn sets the ExecutionRoleArn field's value.
func (*JobRun) SetFailureReason ¶
SetFailureReason sets the FailureReason field's value.
func (*JobRun) SetFinishedAt ¶
SetFinishedAt sets the FinishedAt field's value.
func (*JobRun) SetJobDriver ¶
SetJobDriver sets the JobDriver field's value.
func (*JobRun) SetReleaseLabel ¶
SetReleaseLabel sets the ReleaseLabel field's value.
func (*JobRun) SetStateDetails ¶
SetStateDetails sets the StateDetails field's value.
func (*JobRun) SetVirtualClusterId ¶
SetVirtualClusterId sets the VirtualClusterId field's value.
type JobTemplate ¶ added in v1.44.131
type JobTemplate struct { // The ARN of the job template. Arn *string `locationName:"arn" min:"60" type:"string"` // The date and time when the job template was created. CreatedAt *time.Time `locationName:"createdAt" type:"timestamp" timestampFormat:"iso8601"` // The user who created the job template. CreatedBy *string `locationName:"createdBy" min:"20" type:"string"` // The error message in case the decryption of job template fails. DecryptionError *string `locationName:"decryptionError" min:"1" type:"string"` // The ID of the job template. Id *string `locationName:"id" min:"1" type:"string"` // The job template data which holds values of StartJobRun API request. // // JobTemplateData is a required field JobTemplateData *JobTemplateData `locationName:"jobTemplateData" type:"structure" required:"true"` // The KMS key ARN used to encrypt the job template. KmsKeyArn *string `locationName:"kmsKeyArn" min:"3" type:"string"` // The name of the job template. Name *string `locationName:"name" min:"1" type:"string"` // The tags assigned to the job template. Tags map[string]*string `locationName:"tags" type:"map"` // contains filtered or unexported fields }
This entity describes a job template. Job template stores values of StartJobRun API request in a template and can be used to start a job run. Job template allows two use cases: avoid repeating recurring StartJobRun API request values, enforcing certain values in StartJobRun API request.
func (JobTemplate) GoString ¶ added in v1.44.131
func (s JobTemplate) 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 (*JobTemplate) SetArn ¶ added in v1.44.131
func (s *JobTemplate) SetArn(v string) *JobTemplate
SetArn sets the Arn field's value.
func (*JobTemplate) SetCreatedAt ¶ added in v1.44.131
func (s *JobTemplate) SetCreatedAt(v time.Time) *JobTemplate
SetCreatedAt sets the CreatedAt field's value.
func (*JobTemplate) SetCreatedBy ¶ added in v1.44.131
func (s *JobTemplate) SetCreatedBy(v string) *JobTemplate
SetCreatedBy sets the CreatedBy field's value.
func (*JobTemplate) SetDecryptionError ¶ added in v1.44.131
func (s *JobTemplate) SetDecryptionError(v string) *JobTemplate
SetDecryptionError sets the DecryptionError field's value.
func (*JobTemplate) SetId ¶ added in v1.44.131
func (s *JobTemplate) SetId(v string) *JobTemplate
SetId sets the Id field's value.
func (*JobTemplate) SetJobTemplateData ¶ added in v1.44.131
func (s *JobTemplate) SetJobTemplateData(v *JobTemplateData) *JobTemplate
SetJobTemplateData sets the JobTemplateData field's value.
func (*JobTemplate) SetKmsKeyArn ¶ added in v1.44.131
func (s *JobTemplate) SetKmsKeyArn(v string) *JobTemplate
SetKmsKeyArn sets the KmsKeyArn field's value.
func (*JobTemplate) SetName ¶ added in v1.44.131
func (s *JobTemplate) SetName(v string) *JobTemplate
SetName sets the Name field's value.
func (*JobTemplate) SetTags ¶ added in v1.44.131
func (s *JobTemplate) SetTags(v map[string]*string) *JobTemplate
SetTags sets the Tags field's value.
func (JobTemplate) String ¶ added in v1.44.131
func (s JobTemplate) 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 JobTemplateData ¶ added in v1.44.131
type JobTemplateData struct { // The configuration settings that are used to override defaults configuration. ConfigurationOverrides *ParametricConfigurationOverrides `locationName:"configurationOverrides" type:"structure"` // The execution role ARN of the job run. // // ExecutionRoleArn is a required field ExecutionRoleArn *string `locationName:"executionRoleArn" min:"4" type:"string" required:"true"` // Specify the driver that the job runs on. Exactly one of the two available // job drivers is required, either sparkSqlJobDriver or sparkSubmitJobDriver. // // JobDriver is a required field JobDriver *JobDriver `locationName:"jobDriver" type:"structure" required:"true"` // The tags assigned to jobs started using the job template. JobTags map[string]*string `locationName:"jobTags" type:"map"` // The configuration of parameters existing in the job template. ParameterConfiguration map[string]*TemplateParameterConfiguration `locationName:"parameterConfiguration" type:"map"` // The release version of Amazon EMR. // // ReleaseLabel is a required field ReleaseLabel *string `locationName:"releaseLabel" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
The values of StartJobRun API requests used in job runs started using the job template.
func (JobTemplateData) GoString ¶ added in v1.44.131
func (s JobTemplateData) 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 (*JobTemplateData) SetConfigurationOverrides ¶ added in v1.44.131
func (s *JobTemplateData) SetConfigurationOverrides(v *ParametricConfigurationOverrides) *JobTemplateData
SetConfigurationOverrides sets the ConfigurationOverrides field's value.
func (*JobTemplateData) SetExecutionRoleArn ¶ added in v1.44.131
func (s *JobTemplateData) SetExecutionRoleArn(v string) *JobTemplateData
SetExecutionRoleArn sets the ExecutionRoleArn field's value.
func (*JobTemplateData) SetJobDriver ¶ added in v1.44.131
func (s *JobTemplateData) SetJobDriver(v *JobDriver) *JobTemplateData
SetJobDriver sets the JobDriver field's value.
func (*JobTemplateData) SetJobTags ¶ added in v1.44.131
func (s *JobTemplateData) SetJobTags(v map[string]*string) *JobTemplateData
SetJobTags sets the JobTags field's value.
func (*JobTemplateData) SetParameterConfiguration ¶ added in v1.44.131
func (s *JobTemplateData) SetParameterConfiguration(v map[string]*TemplateParameterConfiguration) *JobTemplateData
SetParameterConfiguration sets the ParameterConfiguration field's value.
func (*JobTemplateData) SetReleaseLabel ¶ added in v1.44.131
func (s *JobTemplateData) SetReleaseLabel(v string) *JobTemplateData
SetReleaseLabel sets the ReleaseLabel field's value.
func (JobTemplateData) String ¶ added in v1.44.131
func (s JobTemplateData) 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 (*JobTemplateData) Validate ¶ added in v1.44.131
func (s *JobTemplateData) Validate() error
Validate inspects the fields of the type to determine if they are valid.
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" enum:"JobRunState"` // 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 ListJobTemplatesInput ¶ added in v1.44.131
type ListJobTemplatesInput struct { // The date and time after which the job templates were created. CreatedAfter *time.Time `location:"querystring" locationName:"createdAfter" type:"timestamp" timestampFormat:"iso8601"` // The date and time before which the job templates were created. CreatedBefore *time.Time `location:"querystring" locationName:"createdBefore" type:"timestamp" timestampFormat:"iso8601"` // The maximum number of job templates that can be listed. MaxResults *int64 `location:"querystring" locationName:"maxResults" type:"integer"` // The token for the next set of job templates to return. NextToken *string `location:"querystring" locationName:"nextToken" min:"1" type:"string"` // contains filtered or unexported fields }
func (ListJobTemplatesInput) GoString ¶ added in v1.44.131
func (s ListJobTemplatesInput) 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 (*ListJobTemplatesInput) SetCreatedAfter ¶ added in v1.44.131
func (s *ListJobTemplatesInput) SetCreatedAfter(v time.Time) *ListJobTemplatesInput
SetCreatedAfter sets the CreatedAfter field's value.
func (*ListJobTemplatesInput) SetCreatedBefore ¶ added in v1.44.131
func (s *ListJobTemplatesInput) SetCreatedBefore(v time.Time) *ListJobTemplatesInput
SetCreatedBefore sets the CreatedBefore field's value.
func (*ListJobTemplatesInput) SetMaxResults ¶ added in v1.44.131
func (s *ListJobTemplatesInput) SetMaxResults(v int64) *ListJobTemplatesInput
SetMaxResults sets the MaxResults field's value.
func (*ListJobTemplatesInput) SetNextToken ¶ added in v1.44.131
func (s *ListJobTemplatesInput) SetNextToken(v string) *ListJobTemplatesInput
SetNextToken sets the NextToken field's value.
func (ListJobTemplatesInput) String ¶ added in v1.44.131
func (s ListJobTemplatesInput) 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 (*ListJobTemplatesInput) Validate ¶ added in v1.44.131
func (s *ListJobTemplatesInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListJobTemplatesOutput ¶ added in v1.44.131
type ListJobTemplatesOutput struct { // This output displays the token for the next set of job templates. NextToken *string `locationName:"nextToken" min:"1" type:"string"` // This output lists information about the specified job templates. Templates []*JobTemplate `locationName:"templates" type:"list"` // contains filtered or unexported fields }
func (ListJobTemplatesOutput) GoString ¶ added in v1.44.131
func (s ListJobTemplatesOutput) 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 (*ListJobTemplatesOutput) SetNextToken ¶ added in v1.44.131
func (s *ListJobTemplatesOutput) SetNextToken(v string) *ListJobTemplatesOutput
SetNextToken sets the NextToken field's value.
func (*ListJobTemplatesOutput) SetTemplates ¶ added in v1.44.131
func (s *ListJobTemplatesOutput) SetTemplates(v []*JobTemplate) *ListJobTemplatesOutput
SetTemplates sets the Templates field's value.
func (ListJobTemplatesOutput) String ¶ added in v1.44.131
func (s ListJobTemplatesOutput) 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" enum:"EndpointState"` // 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" enum:"VirtualClusterState"` // 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 ParametricCloudWatchMonitoringConfiguration ¶ added in v1.44.131
type ParametricCloudWatchMonitoringConfiguration struct { // The name of the log group for log publishing. LogGroupName *string `locationName:"logGroupName" min:"1" type:"string"` // 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. This data type allows job template parameters to be specified within.
func (ParametricCloudWatchMonitoringConfiguration) GoString ¶ added in v1.44.131
func (s ParametricCloudWatchMonitoringConfiguration) 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 (*ParametricCloudWatchMonitoringConfiguration) SetLogGroupName ¶ added in v1.44.131
func (s *ParametricCloudWatchMonitoringConfiguration) SetLogGroupName(v string) *ParametricCloudWatchMonitoringConfiguration
SetLogGroupName sets the LogGroupName field's value.
func (*ParametricCloudWatchMonitoringConfiguration) SetLogStreamNamePrefix ¶ added in v1.44.131
func (s *ParametricCloudWatchMonitoringConfiguration) SetLogStreamNamePrefix(v string) *ParametricCloudWatchMonitoringConfiguration
SetLogStreamNamePrefix sets the LogStreamNamePrefix field's value.
func (ParametricCloudWatchMonitoringConfiguration) String ¶ added in v1.44.131
func (s ParametricCloudWatchMonitoringConfiguration) 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 (*ParametricCloudWatchMonitoringConfiguration) Validate ¶ added in v1.44.131
func (s *ParametricCloudWatchMonitoringConfiguration) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ParametricConfigurationOverrides ¶ added in v1.44.131
type ParametricConfigurationOverrides struct { // The configurations for the application running by the job run. ApplicationConfiguration []*Configuration `locationName:"applicationConfiguration" type:"list"` // The configurations for monitoring. MonitoringConfiguration *ParametricMonitoringConfiguration `locationName:"monitoringConfiguration" type:"structure"` // contains filtered or unexported fields }
A configuration specification to be used to override existing configurations. This data type allows job template parameters to be specified within.
func (ParametricConfigurationOverrides) GoString ¶ added in v1.44.131
func (s ParametricConfigurationOverrides) 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 (*ParametricConfigurationOverrides) SetApplicationConfiguration ¶ added in v1.44.131
func (s *ParametricConfigurationOverrides) SetApplicationConfiguration(v []*Configuration) *ParametricConfigurationOverrides
SetApplicationConfiguration sets the ApplicationConfiguration field's value.
func (*ParametricConfigurationOverrides) SetMonitoringConfiguration ¶ added in v1.44.131
func (s *ParametricConfigurationOverrides) SetMonitoringConfiguration(v *ParametricMonitoringConfiguration) *ParametricConfigurationOverrides
SetMonitoringConfiguration sets the MonitoringConfiguration field's value.
func (ParametricConfigurationOverrides) String ¶ added in v1.44.131
func (s ParametricConfigurationOverrides) 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 (*ParametricConfigurationOverrides) Validate ¶ added in v1.44.131
func (s *ParametricConfigurationOverrides) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ParametricMonitoringConfiguration ¶ added in v1.44.131
type ParametricMonitoringConfiguration struct { // Monitoring configurations for CloudWatch. CloudWatchMonitoringConfiguration *ParametricCloudWatchMonitoringConfiguration `locationName:"cloudWatchMonitoringConfiguration" type:"structure"` // Monitoring configurations for the persistent application UI. PersistentAppUI *string `locationName:"persistentAppUI" min:"1" type:"string"` // Amazon S3 configuration for monitoring log publishing. S3MonitoringConfiguration *ParametricS3MonitoringConfiguration `locationName:"s3MonitoringConfiguration" type:"structure"` // contains filtered or unexported fields }
Configuration setting for monitoring. This data type allows job template parameters to be specified within.
func (ParametricMonitoringConfiguration) GoString ¶ added in v1.44.131
func (s ParametricMonitoringConfiguration) 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 (*ParametricMonitoringConfiguration) SetCloudWatchMonitoringConfiguration ¶ added in v1.44.131
func (s *ParametricMonitoringConfiguration) SetCloudWatchMonitoringConfiguration(v *ParametricCloudWatchMonitoringConfiguration) *ParametricMonitoringConfiguration
SetCloudWatchMonitoringConfiguration sets the CloudWatchMonitoringConfiguration field's value.
func (*ParametricMonitoringConfiguration) SetPersistentAppUI ¶ added in v1.44.131
func (s *ParametricMonitoringConfiguration) SetPersistentAppUI(v string) *ParametricMonitoringConfiguration
SetPersistentAppUI sets the PersistentAppUI field's value.
func (*ParametricMonitoringConfiguration) SetS3MonitoringConfiguration ¶ added in v1.44.131
func (s *ParametricMonitoringConfiguration) SetS3MonitoringConfiguration(v *ParametricS3MonitoringConfiguration) *ParametricMonitoringConfiguration
SetS3MonitoringConfiguration sets the S3MonitoringConfiguration field's value.
func (ParametricMonitoringConfiguration) String ¶ added in v1.44.131
func (s ParametricMonitoringConfiguration) 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 (*ParametricMonitoringConfiguration) Validate ¶ added in v1.44.131
func (s *ParametricMonitoringConfiguration) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ParametricS3MonitoringConfiguration ¶ added in v1.44.131
type ParametricS3MonitoringConfiguration struct { // Amazon S3 destination URI for log publishing. LogUri *string `locationName:"logUri" min:"1" type:"string"` // contains filtered or unexported fields }
Amazon S3 configuration for monitoring log publishing. You can configure your jobs to send log information to Amazon S3. This data type allows job template parameters to be specified within.
func (ParametricS3MonitoringConfiguration) GoString ¶ added in v1.44.131
func (s ParametricS3MonitoringConfiguration) 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 (*ParametricS3MonitoringConfiguration) SetLogUri ¶ added in v1.44.131
func (s *ParametricS3MonitoringConfiguration) SetLogUri(v string) *ParametricS3MonitoringConfiguration
SetLogUri sets the LogUri field's value.
func (ParametricS3MonitoringConfiguration) String ¶ added in v1.44.131
func (s ParametricS3MonitoringConfiguration) 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 (*ParametricS3MonitoringConfiguration) Validate ¶ added in v1.44.131
func (s *ParametricS3MonitoringConfiguration) 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 SparkSqlJobDriver ¶ added in v1.44.94
type SparkSqlJobDriver struct { // The SQL file to be executed. // // EntryPoint is a sensitive parameter and its value will be // replaced with "sensitive" in string returned by SparkSqlJobDriver's // String and GoString methods. EntryPoint *string `locationName:"entryPoint" min:"1" type:"string" sensitive:"true"` // The Spark parameters to be included in the Spark SQL command. // // SparkSqlParameters is a sensitive parameter and its value will be // replaced with "sensitive" in string returned by SparkSqlJobDriver's // String and GoString methods. SparkSqlParameters *string `locationName:"sparkSqlParameters" min:"1" type:"string" sensitive:"true"` // contains filtered or unexported fields }
The job driver for job type.
func (SparkSqlJobDriver) GoString ¶ added in v1.44.94
func (s SparkSqlJobDriver) 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 (*SparkSqlJobDriver) SetEntryPoint ¶ added in v1.44.94
func (s *SparkSqlJobDriver) SetEntryPoint(v string) *SparkSqlJobDriver
SetEntryPoint sets the EntryPoint field's value.
func (*SparkSqlJobDriver) SetSparkSqlParameters ¶ added in v1.44.94
func (s *SparkSqlJobDriver) SetSparkSqlParameters(v string) *SparkSqlJobDriver
SetSparkSqlParameters sets the SparkSqlParameters field's value.
func (SparkSqlJobDriver) String ¶ added in v1.44.94
func (s SparkSqlJobDriver) 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 (*SparkSqlJobDriver) Validate ¶ added in v1.44.94
func (s *SparkSqlJobDriver) 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 *string `locationName:"executionRoleArn" min:"20" type:"string"` // The job driver for the job run. JobDriver *JobDriver `locationName:"jobDriver" type:"structure"` // The job template ID to be used to start the job run. JobTemplateId *string `locationName:"jobTemplateId" min:"1" type:"string"` // The values of job template parameters to start a job run. JobTemplateParameters map[string]*string `locationName:"jobTemplateParameters" type:"map"` // 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 *string `locationName:"releaseLabel" min:"1" type:"string"` // 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) SetJobTemplateId ¶ added in v1.44.131
func (s *StartJobRunInput) SetJobTemplateId(v string) *StartJobRunInput
SetJobTemplateId sets the JobTemplateId field's value.
func (*StartJobRunInput) SetJobTemplateParameters ¶ added in v1.44.131
func (s *StartJobRunInput) SetJobTemplateParameters(v map[string]*string) *StartJobRunInput
SetJobTemplateParameters sets the JobTemplateParameters 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 TemplateParameterConfiguration ¶ added in v1.44.131
type TemplateParameterConfiguration struct { // The default value for the job template parameter. DefaultValue *string `locationName:"defaultValue" min:"1" type:"string"` // The type of the job template parameter. Allowed values are: ‘String’, // ‘Number’. Type *string `locationName:"type" type:"string" enum:"TemplateParameterDataType"` // contains filtered or unexported fields }
The configuration of a job template parameter.
func (TemplateParameterConfiguration) GoString ¶ added in v1.44.131
func (s TemplateParameterConfiguration) 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 (*TemplateParameterConfiguration) SetDefaultValue ¶ added in v1.44.131
func (s *TemplateParameterConfiguration) SetDefaultValue(v string) *TemplateParameterConfiguration
SetDefaultValue sets the DefaultValue field's value.
func (*TemplateParameterConfiguration) SetType ¶ added in v1.44.131
func (s *TemplateParameterConfiguration) SetType(v string) *TemplateParameterConfiguration
SetType sets the Type field's value.
func (TemplateParameterConfiguration) String ¶ added in v1.44.131
func (s TemplateParameterConfiguration) 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 (*TemplateParameterConfiguration) Validate ¶ added in v1.44.131
func (s *TemplateParameterConfiguration) Validate() error
Validate inspects the fields of the type to determine if they are valid.
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".
Directories ¶
Path | Synopsis |
---|---|
Package emrcontainersiface provides an interface to enable mocking the Amazon EMR Containers service client for testing your code.
|
Package emrcontainersiface provides an interface to enable mocking the Amazon EMR Containers service client for testing your code. |