Documentation

Overview

    Package emrcontainers provides the API client, operations, and parameter types for 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).

    Index

    Constants

    View Source
    const ServiceAPIVersion = "2020-10-01"
    View Source
    const ServiceID = "EMR containers"

    Variables

    This section is empty.

    Functions

    func NewDefaultEndpointResolver

    func NewDefaultEndpointResolver() *internalendpoints.Resolver

      NewDefaultEndpointResolver constructs a new service endpoint resolver

      func WithAPIOptions

      func WithAPIOptions(optFns ...func(*middleware.Stack) error) func(*Options)

        WithAPIOptions returns a functional option for setting the Client's APIOptions option.

        func WithEndpointResolver

        func WithEndpointResolver(v EndpointResolver) func(*Options)

          WithEndpointResolver returns a functional option for setting the Client's EndpointResolver option.

          Types

          type CancelJobRunInput

          type CancelJobRunInput struct {
          
          	// The ID of the job run to cancel.
          	//
          	// This member is required.
          	Id *string
          
          	// The ID of the virtual cluster for which the job run will be canceled.
          	//
          	// This member is required.
          	VirtualClusterId *string
          }

          type CancelJobRunOutput

          type CancelJobRunOutput struct {
          
          	// The output contains the ID of the cancelled job run.
          	Id *string
          
          	// The output contains the virtual cluster ID for which the job run is cancelled.
          	VirtualClusterId *string
          
          	// Metadata pertaining to the operation's result.
          	ResultMetadata middleware.Metadata
          }

          type Client

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

            Client provides the API client to make operations call for Amazon EMR Containers.

            func New

            func New(options Options, optFns ...func(*Options)) *Client

              New returns an initialized Client based on the functional options. Provide additional functional options to further configure the behavior of the client, such as changing the client's endpoint or adding custom middleware behavior.

              func NewFromConfig

              func NewFromConfig(cfg aws.Config, optFns ...func(*Options)) *Client

                NewFromConfig returns a new client from the provided config.

                func (*Client) CancelJobRun

                func (c *Client) CancelJobRun(ctx context.Context, params *CancelJobRunInput, optFns ...func(*Options)) (*CancelJobRunOutput, error)

                  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.

                  func (*Client) CreateManagedEndpoint

                  func (c *Client) CreateManagedEndpoint(ctx context.Context, params *CreateManagedEndpointInput, optFns ...func(*Options)) (*CreateManagedEndpointOutput, error)

                    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.

                    func (*Client) CreateVirtualCluster

                    func (c *Client) CreateVirtualCluster(ctx context.Context, params *CreateVirtualClusterInput, optFns ...func(*Options)) (*CreateVirtualClusterOutput, error)

                      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.

                      func (*Client) DeleteManagedEndpoint

                      func (c *Client) DeleteManagedEndpoint(ctx context.Context, params *DeleteManagedEndpointInput, optFns ...func(*Options)) (*DeleteManagedEndpointOutput, error)

                        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.

                        func (*Client) DeleteVirtualCluster

                        func (c *Client) DeleteVirtualCluster(ctx context.Context, params *DeleteVirtualClusterInput, optFns ...func(*Options)) (*DeleteVirtualClusterOutput, error)

                          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.

                          func (*Client) DescribeJobRun

                          func (c *Client) DescribeJobRun(ctx context.Context, params *DescribeJobRunInput, optFns ...func(*Options)) (*DescribeJobRunOutput, error)

                            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.

                            func (*Client) DescribeManagedEndpoint

                            func (c *Client) DescribeManagedEndpoint(ctx context.Context, params *DescribeManagedEndpointInput, optFns ...func(*Options)) (*DescribeManagedEndpointOutput, error)

                              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.

                              func (*Client) DescribeVirtualCluster

                              func (c *Client) DescribeVirtualCluster(ctx context.Context, params *DescribeVirtualClusterInput, optFns ...func(*Options)) (*DescribeVirtualClusterOutput, error)

                                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.

                                func (*Client) ListJobRuns

                                func (c *Client) ListJobRuns(ctx context.Context, params *ListJobRunsInput, optFns ...func(*Options)) (*ListJobRunsOutput, error)

                                  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.

                                  func (*Client) ListManagedEndpoints

                                  func (c *Client) ListManagedEndpoints(ctx context.Context, params *ListManagedEndpointsInput, optFns ...func(*Options)) (*ListManagedEndpointsOutput, error)

                                    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.

                                    func (*Client) ListTagsForResource

                                    func (c *Client) ListTagsForResource(ctx context.Context, params *ListTagsForResourceInput, optFns ...func(*Options)) (*ListTagsForResourceOutput, error)

                                      Lists the tags assigned to the resources.

                                      func (*Client) ListVirtualClusters

                                      func (c *Client) ListVirtualClusters(ctx context.Context, params *ListVirtualClustersInput, optFns ...func(*Options)) (*ListVirtualClustersOutput, error)

                                        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.

                                        func (*Client) StartJobRun

                                        func (c *Client) StartJobRun(ctx context.Context, params *StartJobRunInput, optFns ...func(*Options)) (*StartJobRunOutput, error)

                                          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.

                                          func (*Client) TagResource

                                          func (c *Client) TagResource(ctx context.Context, params *TagResourceInput, optFns ...func(*Options)) (*TagResourceOutput, error)

                                            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.

                                            func (*Client) UntagResource

                                            func (c *Client) UntagResource(ctx context.Context, params *UntagResourceInput, optFns ...func(*Options)) (*UntagResourceOutput, error)

                                              Removes tags from resources.

                                              type CreateManagedEndpointInput

                                              type CreateManagedEndpointInput struct {
                                              
                                              	// The certificate ARN of the managed endpoint.
                                              	//
                                              	// This member is required.
                                              	CertificateArn *string
                                              
                                              	// The client idempotency token for this create call.
                                              	//
                                              	// This member is required.
                                              	ClientToken *string
                                              
                                              	// The ARN of the execution role.
                                              	//
                                              	// This member is required.
                                              	ExecutionRoleArn *string
                                              
                                              	// The name of the managed endpoint.
                                              	//
                                              	// This member is required.
                                              	Name *string
                                              
                                              	// The Amazon EMR release version.
                                              	//
                                              	// This member is required.
                                              	ReleaseLabel *string
                                              
                                              	// The type of the managed endpoint.
                                              	//
                                              	// This member is required.
                                              	Type *string
                                              
                                              	// The ID of the virtual cluster for which a managed endpoint is created.
                                              	//
                                              	// This member is required.
                                              	VirtualClusterId *string
                                              
                                              	// The configuration settings that will be used to override existing
                                              	// configurations.
                                              	ConfigurationOverrides *types.ConfigurationOverrides
                                              
                                              	// The tags of the managed endpoint.
                                              	Tags map[string]string
                                              }

                                              type CreateManagedEndpointOutput

                                              type CreateManagedEndpointOutput struct {
                                              
                                              	// The output contains the ARN of the managed endpoint.
                                              	Arn *string
                                              
                                              	// The output contains the ID of the managed endpoint.
                                              	Id *string
                                              
                                              	// The output contains the name of the managed endpoint.
                                              	Name *string
                                              
                                              	// The output contains the ID of the virtual cluster.
                                              	VirtualClusterId *string
                                              
                                              	// Metadata pertaining to the operation's result.
                                              	ResultMetadata middleware.Metadata
                                              }

                                              type CreateVirtualClusterInput

                                              type CreateVirtualClusterInput struct {
                                              
                                              	// The client token of the virtual cluster.
                                              	//
                                              	// This member is required.
                                              	ClientToken *string
                                              
                                              	// The container provider of the virtual cluster.
                                              	//
                                              	// This member is required.
                                              	ContainerProvider *types.ContainerProvider
                                              
                                              	// The specified name of the virtual cluster.
                                              	//
                                              	// This member is required.
                                              	Name *string
                                              
                                              	// The tags assigned to the virtual cluster.
                                              	Tags map[string]string
                                              }

                                              type CreateVirtualClusterOutput

                                              type CreateVirtualClusterOutput struct {
                                              
                                              	// This output contains the ARN of virtual cluster.
                                              	Arn *string
                                              
                                              	// This output contains the virtual cluster ID.
                                              	Id *string
                                              
                                              	// This output contains the name of the virtual cluster.
                                              	Name *string
                                              
                                              	// Metadata pertaining to the operation's result.
                                              	ResultMetadata middleware.Metadata
                                              }

                                              type DeleteManagedEndpointInput

                                              type DeleteManagedEndpointInput struct {
                                              
                                              	// The ID of the managed endpoint.
                                              	//
                                              	// This member is required.
                                              	Id *string
                                              
                                              	// The ID of the endpoint's virtual cluster.
                                              	//
                                              	// This member is required.
                                              	VirtualClusterId *string
                                              }

                                              type DeleteManagedEndpointOutput

                                              type DeleteManagedEndpointOutput struct {
                                              
                                              	// The output displays the ID of the managed endpoint.
                                              	Id *string
                                              
                                              	// The output displays the ID of the endpoint's virtual cluster.
                                              	VirtualClusterId *string
                                              
                                              	// Metadata pertaining to the operation's result.
                                              	ResultMetadata middleware.Metadata
                                              }

                                              type DeleteVirtualClusterInput

                                              type DeleteVirtualClusterInput struct {
                                              
                                              	// The ID of the virtual cluster that will be deleted.
                                              	//
                                              	// This member is required.
                                              	Id *string
                                              }

                                              type DeleteVirtualClusterOutput

                                              type DeleteVirtualClusterOutput struct {
                                              
                                              	// This output contains the ID of the virtual cluster that will be deleted.
                                              	Id *string
                                              
                                              	// Metadata pertaining to the operation's result.
                                              	ResultMetadata middleware.Metadata
                                              }

                                              type DescribeJobRunInput

                                              type DescribeJobRunInput struct {
                                              
                                              	// The ID of the job run request.
                                              	//
                                              	// This member is required.
                                              	Id *string
                                              
                                              	// The ID of the virtual cluster for which the job run is submitted.
                                              	//
                                              	// This member is required.
                                              	VirtualClusterId *string
                                              }

                                              type DescribeJobRunOutput

                                              type DescribeJobRunOutput struct {
                                              
                                              	// The output displays information about a job run.
                                              	JobRun *types.JobRun
                                              
                                              	// Metadata pertaining to the operation's result.
                                              	ResultMetadata middleware.Metadata
                                              }

                                              type DescribeManagedEndpointInput

                                              type DescribeManagedEndpointInput struct {
                                              
                                              	// This output displays ID of the managed endpoint.
                                              	//
                                              	// This member is required.
                                              	Id *string
                                              
                                              	// The ID of the endpoint's virtual cluster.
                                              	//
                                              	// This member is required.
                                              	VirtualClusterId *string
                                              }

                                              type DescribeManagedEndpointOutput

                                              type DescribeManagedEndpointOutput struct {
                                              
                                              	// This output displays information about a managed endpoint.
                                              	Endpoint *types.Endpoint
                                              
                                              	// Metadata pertaining to the operation's result.
                                              	ResultMetadata middleware.Metadata
                                              }

                                              type DescribeVirtualClusterInput

                                              type DescribeVirtualClusterInput struct {
                                              
                                              	// The ID of the virtual cluster that will be described.
                                              	//
                                              	// This member is required.
                                              	Id *string
                                              }

                                              type DescribeVirtualClusterOutput

                                              type DescribeVirtualClusterOutput struct {
                                              
                                              	// This output displays information about the specified virtual cluster.
                                              	VirtualCluster *types.VirtualCluster
                                              
                                              	// Metadata pertaining to the operation's result.
                                              	ResultMetadata middleware.Metadata
                                              }

                                              type EndpointResolver

                                              type EndpointResolver interface {
                                              	ResolveEndpoint(region string, options EndpointResolverOptions) (aws.Endpoint, error)
                                              }

                                                EndpointResolver interface for resolving service endpoints.

                                                func EndpointResolverFromURL

                                                func EndpointResolverFromURL(url string, optFns ...func(*aws.Endpoint)) EndpointResolver

                                                  EndpointResolverFromURL returns an EndpointResolver configured using the provided endpoint url. By default, the resolved endpoint resolver uses the client region as signing region, and the endpoint source is set to EndpointSourceCustom.You can provide functional options to configure endpoint values for the resolved endpoint.

                                                  type EndpointResolverFunc

                                                  type EndpointResolverFunc func(region string, options EndpointResolverOptions) (aws.Endpoint, error)

                                                    EndpointResolverFunc is a helper utility that wraps a function so it satisfies the EndpointResolver interface. This is useful when you want to add additional endpoint resolving logic, or stub out specific endpoints with custom values.

                                                    func (EndpointResolverFunc) ResolveEndpoint

                                                    func (fn EndpointResolverFunc) ResolveEndpoint(region string, options EndpointResolverOptions) (endpoint aws.Endpoint, err error)

                                                    type EndpointResolverOptions

                                                    type EndpointResolverOptions = internalendpoints.Options

                                                      EndpointResolverOptions is the service endpoint resolver options

                                                      type HTTPClient

                                                      type HTTPClient interface {
                                                      	Do(*http.Request) (*http.Response, error)
                                                      }

                                                      type HTTPSignerV4

                                                      type HTTPSignerV4 interface {
                                                      	SignHTTP(ctx context.Context, credentials aws.Credentials, r *http.Request, payloadHash string, service string, region string, signingTime time.Time, optFns ...func(*v4.SignerOptions)) error
                                                      }

                                                      type IdempotencyTokenProvider

                                                      type IdempotencyTokenProvider interface {
                                                      	GetIdempotencyToken() (string, error)
                                                      }

                                                        IdempotencyTokenProvider interface for providing idempotency token

                                                        type ListJobRunsAPIClient

                                                        type ListJobRunsAPIClient interface {
                                                        	ListJobRuns(context.Context, *ListJobRunsInput, ...func(*Options)) (*ListJobRunsOutput, error)
                                                        }

                                                          ListJobRunsAPIClient is a client that implements the ListJobRuns operation.

                                                          type ListJobRunsInput

                                                          type ListJobRunsInput struct {
                                                          
                                                          	// The ID of the virtual cluster for which to list the job run.
                                                          	//
                                                          	// This member is required.
                                                          	VirtualClusterId *string
                                                          
                                                          	// The date and time after which the job runs were submitted.
                                                          	CreatedAfter *time.Time
                                                          
                                                          	// The date and time before which the job runs were submitted.
                                                          	CreatedBefore *time.Time
                                                          
                                                          	// The maximum number of job runs that can be listed.
                                                          	MaxResults *int32
                                                          
                                                          	// The name of the job run.
                                                          	Name *string
                                                          
                                                          	// The token for the next set of job runs to return.
                                                          	NextToken *string
                                                          
                                                          	// The states of the job run.
                                                          	States []types.JobRunState
                                                          }

                                                          type ListJobRunsOutput

                                                          type ListJobRunsOutput struct {
                                                          
                                                          	// This output lists information about the specified job runs.
                                                          	JobRuns []types.JobRun
                                                          
                                                          	// This output displays the token for the next set of job runs.
                                                          	NextToken *string
                                                          
                                                          	// Metadata pertaining to the operation's result.
                                                          	ResultMetadata middleware.Metadata
                                                          }

                                                          type ListJobRunsPaginator

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

                                                            ListJobRunsPaginator is a paginator for ListJobRuns

                                                            func NewListJobRunsPaginator

                                                            func NewListJobRunsPaginator(client ListJobRunsAPIClient, params *ListJobRunsInput, optFns ...func(*ListJobRunsPaginatorOptions)) *ListJobRunsPaginator

                                                              NewListJobRunsPaginator returns a new ListJobRunsPaginator

                                                              func (*ListJobRunsPaginator) HasMorePages

                                                              func (p *ListJobRunsPaginator) HasMorePages() bool

                                                                HasMorePages returns a boolean indicating whether more pages are available

                                                                func (*ListJobRunsPaginator) NextPage

                                                                func (p *ListJobRunsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*ListJobRunsOutput, error)

                                                                  NextPage retrieves the next ListJobRuns page.

                                                                  type ListJobRunsPaginatorOptions

                                                                  type ListJobRunsPaginatorOptions struct {
                                                                  	// The maximum number of job runs that can be listed.
                                                                  	Limit int32
                                                                  
                                                                  	// Set to true if pagination should stop if the service returns a pagination token
                                                                  	// that matches the most recent token provided to the service.
                                                                  	StopOnDuplicateToken bool
                                                                  }

                                                                    ListJobRunsPaginatorOptions is the paginator options for ListJobRuns

                                                                    type ListManagedEndpointsAPIClient

                                                                    type ListManagedEndpointsAPIClient interface {
                                                                    	ListManagedEndpoints(context.Context, *ListManagedEndpointsInput, ...func(*Options)) (*ListManagedEndpointsOutput, error)
                                                                    }

                                                                      ListManagedEndpointsAPIClient is a client that implements the ListManagedEndpoints operation.

                                                                      type ListManagedEndpointsInput

                                                                      type ListManagedEndpointsInput struct {
                                                                      
                                                                      	// The ID of the virtual cluster.
                                                                      	//
                                                                      	// This member is required.
                                                                      	VirtualClusterId *string
                                                                      
                                                                      	// The date and time after which the endpoints are created.
                                                                      	CreatedAfter *time.Time
                                                                      
                                                                      	// The date and time before which the endpoints are created.
                                                                      	CreatedBefore *time.Time
                                                                      
                                                                      	// The maximum number of managed endpoints that can be listed.
                                                                      	MaxResults *int32
                                                                      
                                                                      	// The token for the next set of managed endpoints to return.
                                                                      	NextToken *string
                                                                      
                                                                      	// The states of the managed endpoints.
                                                                      	States []types.EndpointState
                                                                      
                                                                      	// The types of the managed endpoints.
                                                                      	Types []string
                                                                      }

                                                                      type ListManagedEndpointsOutput

                                                                      type ListManagedEndpointsOutput struct {
                                                                      
                                                                      	// The managed endpoints to be listed.
                                                                      	Endpoints []types.Endpoint
                                                                      
                                                                      	// The token for the next set of endpoints to return.
                                                                      	NextToken *string
                                                                      
                                                                      	// Metadata pertaining to the operation's result.
                                                                      	ResultMetadata middleware.Metadata
                                                                      }

                                                                      type ListManagedEndpointsPaginator

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

                                                                        ListManagedEndpointsPaginator is a paginator for ListManagedEndpoints

                                                                        func NewListManagedEndpointsPaginator

                                                                          NewListManagedEndpointsPaginator returns a new ListManagedEndpointsPaginator

                                                                          func (*ListManagedEndpointsPaginator) HasMorePages

                                                                          func (p *ListManagedEndpointsPaginator) HasMorePages() bool

                                                                            HasMorePages returns a boolean indicating whether more pages are available

                                                                            func (*ListManagedEndpointsPaginator) NextPage

                                                                              NextPage retrieves the next ListManagedEndpoints page.

                                                                              type ListManagedEndpointsPaginatorOptions

                                                                              type ListManagedEndpointsPaginatorOptions struct {
                                                                              	// The maximum number of managed endpoints that can be listed.
                                                                              	Limit int32
                                                                              
                                                                              	// Set to true if pagination should stop if the service returns a pagination token
                                                                              	// that matches the most recent token provided to the service.
                                                                              	StopOnDuplicateToken bool
                                                                              }

                                                                                ListManagedEndpointsPaginatorOptions is the paginator options for ListManagedEndpoints

                                                                                type ListTagsForResourceInput

                                                                                type ListTagsForResourceInput struct {
                                                                                
                                                                                	// The ARN of tagged resources.
                                                                                	//
                                                                                	// This member is required.
                                                                                	ResourceArn *string
                                                                                }

                                                                                type ListTagsForResourceOutput

                                                                                type ListTagsForResourceOutput struct {
                                                                                
                                                                                	// The tags assigned to resources.
                                                                                	Tags map[string]string
                                                                                
                                                                                	// Metadata pertaining to the operation's result.
                                                                                	ResultMetadata middleware.Metadata
                                                                                }

                                                                                type ListVirtualClustersAPIClient

                                                                                type ListVirtualClustersAPIClient interface {
                                                                                	ListVirtualClusters(context.Context, *ListVirtualClustersInput, ...func(*Options)) (*ListVirtualClustersOutput, error)
                                                                                }

                                                                                  ListVirtualClustersAPIClient is a client that implements the ListVirtualClusters operation.

                                                                                  type ListVirtualClustersInput

                                                                                  type ListVirtualClustersInput struct {
                                                                                  
                                                                                  	// The container provider ID of the virtual cluster.
                                                                                  	ContainerProviderId *string
                                                                                  
                                                                                  	// The container provider type of the virtual cluster. EKS is the only supported
                                                                                  	// type as of now.
                                                                                  	ContainerProviderType types.ContainerProviderType
                                                                                  
                                                                                  	// The date and time after which the virtual clusters are created.
                                                                                  	CreatedAfter *time.Time
                                                                                  
                                                                                  	// The date and time before which the virtual clusters are created.
                                                                                  	CreatedBefore *time.Time
                                                                                  
                                                                                  	// The maximum number of virtual clusters that can be listed.
                                                                                  	MaxResults *int32
                                                                                  
                                                                                  	// The token for the next set of virtual clusters to return.
                                                                                  	NextToken *string
                                                                                  
                                                                                  	// The states of the requested virtual clusters.
                                                                                  	States []types.VirtualClusterState
                                                                                  }

                                                                                  type ListVirtualClustersOutput

                                                                                  type ListVirtualClustersOutput struct {
                                                                                  
                                                                                  	// This output displays the token for the next set of virtual clusters.
                                                                                  	NextToken *string
                                                                                  
                                                                                  	// This output lists the specified virtual clusters.
                                                                                  	VirtualClusters []types.VirtualCluster
                                                                                  
                                                                                  	// Metadata pertaining to the operation's result.
                                                                                  	ResultMetadata middleware.Metadata
                                                                                  }

                                                                                  type ListVirtualClustersPaginator

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

                                                                                    ListVirtualClustersPaginator is a paginator for ListVirtualClusters

                                                                                    func NewListVirtualClustersPaginator

                                                                                    func NewListVirtualClustersPaginator(client ListVirtualClustersAPIClient, params *ListVirtualClustersInput, optFns ...func(*ListVirtualClustersPaginatorOptions)) *ListVirtualClustersPaginator

                                                                                      NewListVirtualClustersPaginator returns a new ListVirtualClustersPaginator

                                                                                      func (*ListVirtualClustersPaginator) HasMorePages

                                                                                      func (p *ListVirtualClustersPaginator) HasMorePages() bool

                                                                                        HasMorePages returns a boolean indicating whether more pages are available

                                                                                        func (*ListVirtualClustersPaginator) NextPage

                                                                                        func (p *ListVirtualClustersPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*ListVirtualClustersOutput, error)

                                                                                          NextPage retrieves the next ListVirtualClusters page.

                                                                                          type ListVirtualClustersPaginatorOptions

                                                                                          type ListVirtualClustersPaginatorOptions struct {
                                                                                          	// The maximum number of virtual clusters that can be listed.
                                                                                          	Limit int32
                                                                                          
                                                                                          	// Set to true if pagination should stop if the service returns a pagination token
                                                                                          	// that matches the most recent token provided to the service.
                                                                                          	StopOnDuplicateToken bool
                                                                                          }

                                                                                            ListVirtualClustersPaginatorOptions is the paginator options for ListVirtualClusters

                                                                                            type Options

                                                                                            type Options struct {
                                                                                            	// Set of options to modify how an operation is invoked. These apply to all
                                                                                            	// operations invoked for this client. Use functional options on operation call to
                                                                                            	// modify this list for per operation behavior.
                                                                                            	APIOptions []func(*middleware.Stack) error
                                                                                            
                                                                                            	// Configures the events that will be sent to the configured logger.
                                                                                            	ClientLogMode aws.ClientLogMode
                                                                                            
                                                                                            	// The credentials object to use when signing requests.
                                                                                            	Credentials aws.CredentialsProvider
                                                                                            
                                                                                            	// The endpoint options to be used when attempting to resolve an endpoint.
                                                                                            	EndpointOptions EndpointResolverOptions
                                                                                            
                                                                                            	// The service endpoint resolver.
                                                                                            	EndpointResolver EndpointResolver
                                                                                            
                                                                                            	// Signature Version 4 (SigV4) Signer
                                                                                            	HTTPSignerV4 HTTPSignerV4
                                                                                            
                                                                                            	// Provides idempotency tokens values that will be automatically populated into
                                                                                            	// idempotent API operations.
                                                                                            	IdempotencyTokenProvider IdempotencyTokenProvider
                                                                                            
                                                                                            	// The logger writer interface to write logging messages to.
                                                                                            	Logger logging.Logger
                                                                                            
                                                                                            	// The region to send requests to. (Required)
                                                                                            	Region string
                                                                                            
                                                                                            	// Retryer guides how HTTP requests should be retried in case of recoverable
                                                                                            	// failures. When nil the API client will use a default retryer.
                                                                                            	Retryer aws.Retryer
                                                                                            
                                                                                            	// The HTTP client to invoke API calls with. Defaults to client's default HTTP
                                                                                            	// implementation if nil.
                                                                                            	HTTPClient HTTPClient
                                                                                            }

                                                                                            func (Options) Copy

                                                                                            func (o Options) Copy() Options

                                                                                              Copy creates a clone where the APIOptions list is deep copied.

                                                                                              type ResolveEndpoint

                                                                                              type ResolveEndpoint struct {
                                                                                              	Resolver EndpointResolver
                                                                                              	Options  EndpointResolverOptions
                                                                                              }

                                                                                              func (*ResolveEndpoint) HandleSerialize

                                                                                              func (*ResolveEndpoint) ID

                                                                                              func (*ResolveEndpoint) ID() string

                                                                                              type StartJobRunInput

                                                                                              type StartJobRunInput struct {
                                                                                              
                                                                                              	// The client idempotency token of the job run request.
                                                                                              	//
                                                                                              	// This member is required.
                                                                                              	ClientToken *string
                                                                                              
                                                                                              	// The execution role ARN for the job run.
                                                                                              	//
                                                                                              	// This member is required.
                                                                                              	ExecutionRoleArn *string
                                                                                              
                                                                                              	// The job driver for the job run.
                                                                                              	//
                                                                                              	// This member is required.
                                                                                              	JobDriver *types.JobDriver
                                                                                              
                                                                                              	// The Amazon EMR release version to use for the job run.
                                                                                              	//
                                                                                              	// This member is required.
                                                                                              	ReleaseLabel *string
                                                                                              
                                                                                              	// The virtual cluster ID for which the job run request is submitted.
                                                                                              	//
                                                                                              	// This member is required.
                                                                                              	VirtualClusterId *string
                                                                                              
                                                                                              	// The configuration overrides for the job run.
                                                                                              	ConfigurationOverrides *types.ConfigurationOverrides
                                                                                              
                                                                                              	// The name of the job run.
                                                                                              	Name *string
                                                                                              
                                                                                              	// The tags assigned to job runs.
                                                                                              	Tags map[string]string
                                                                                              }

                                                                                              type StartJobRunOutput

                                                                                              type StartJobRunOutput struct {
                                                                                              
                                                                                              	// This output lists the ARN of job run.
                                                                                              	Arn *string
                                                                                              
                                                                                              	// This output displays the started job run ID.
                                                                                              	Id *string
                                                                                              
                                                                                              	// This output displays the name of the started job run.
                                                                                              	Name *string
                                                                                              
                                                                                              	// This output displays the virtual cluster ID for which the job run was submitted.
                                                                                              	VirtualClusterId *string
                                                                                              
                                                                                              	// Metadata pertaining to the operation's result.
                                                                                              	ResultMetadata middleware.Metadata
                                                                                              }

                                                                                              type TagResourceInput

                                                                                              type TagResourceInput struct {
                                                                                              
                                                                                              	// The ARN of resources.
                                                                                              	//
                                                                                              	// This member is required.
                                                                                              	ResourceArn *string
                                                                                              
                                                                                              	// The tags assigned to resources.
                                                                                              	//
                                                                                              	// This member is required.
                                                                                              	Tags map[string]string
                                                                                              }

                                                                                              type TagResourceOutput

                                                                                              type TagResourceOutput struct {
                                                                                              	// Metadata pertaining to the operation's result.
                                                                                              	ResultMetadata middleware.Metadata
                                                                                              }

                                                                                              type UntagResourceInput

                                                                                              type UntagResourceInput struct {
                                                                                              
                                                                                              	// The ARN of resources.
                                                                                              	//
                                                                                              	// This member is required.
                                                                                              	ResourceArn *string
                                                                                              
                                                                                              	// The tag keys of the resources.
                                                                                              	//
                                                                                              	// This member is required.
                                                                                              	TagKeys []string
                                                                                              }

                                                                                              type UntagResourceOutput

                                                                                              type UntagResourceOutput struct {
                                                                                              	// Metadata pertaining to the operation's result.
                                                                                              	ResultMetadata middleware.Metadata
                                                                                              }

                                                                                              Directories

                                                                                              Path Synopsis
                                                                                              internal