mwaa

package
v1.37.5 Latest Latest
Warning

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

 Go to latest Published: Feb 4, 2021 License: Apache-2.0 Imports: 10 Imported by: 17

Documentation

Overview

Package mwaa provides the client and types for making API requests to AmazonMWAA.

This section contains the Amazon Managed Workflows for Apache Airflow (MWAA) API reference documentation. For more information, see What Is Amazon MWAA? (https://docs.aws.amazon.com/mwaa/latest/userguide/what-is-mwaa.html).

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

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

Using the Client

To contact AmazonMWAA 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 AmazonMWAA client MWAA for more information on creating client for this service. https://docs.aws.amazon.com/sdk-for-go/api/service/mwaa/#New

Index

Constants

View Source 
const (
	// EnvironmentStatusCreating is a EnvironmentStatus enum value
	EnvironmentStatusCreating = "CREATING"

	// EnvironmentStatusCreateFailed is a EnvironmentStatus enum value
	EnvironmentStatusCreateFailed = "CREATE_FAILED"

	// EnvironmentStatusAvailable is a EnvironmentStatus enum value
	EnvironmentStatusAvailable = "AVAILABLE"

	// EnvironmentStatusUpdating is a EnvironmentStatus enum value
	EnvironmentStatusUpdating = "UPDATING"

	// EnvironmentStatusDeleting is a EnvironmentStatus enum value
	EnvironmentStatusDeleting = "DELETING"

	// EnvironmentStatusDeleted is a EnvironmentStatus enum value
	EnvironmentStatusDeleted = "DELETED"
)
View Source 
const (
	// LoggingLevelCritical is a LoggingLevel enum value
	LoggingLevelCritical = "CRITICAL"

	// LoggingLevelError is a LoggingLevel enum value
	LoggingLevelError = "ERROR"

	// LoggingLevelWarning is a LoggingLevel enum value
	LoggingLevelWarning = "WARNING"

	// LoggingLevelInfo is a LoggingLevel enum value
	LoggingLevelInfo = "INFO"

	// LoggingLevelDebug is a LoggingLevel enum value
	LoggingLevelDebug = "DEBUG"
)
View Source 
const (
	// UnitSeconds is a Unit enum value
	UnitSeconds = "Seconds"

	// UnitMicroseconds is a Unit enum value
	UnitMicroseconds = "Microseconds"

	// UnitMilliseconds is a Unit enum value
	UnitMilliseconds = "Milliseconds"

	// UnitBytes is a Unit enum value
	UnitBytes = "Bytes"

	// UnitKilobytes is a Unit enum value
	UnitKilobytes = "Kilobytes"

	// UnitMegabytes is a Unit enum value
	UnitMegabytes = "Megabytes"

	// UnitGigabytes is a Unit enum value
	UnitGigabytes = "Gigabytes"

	// UnitTerabytes is a Unit enum value
	UnitTerabytes = "Terabytes"

	// UnitBits is a Unit enum value
	UnitBits = "Bits"

	// UnitKilobits is a Unit enum value
	UnitKilobits = "Kilobits"

	// UnitMegabits is a Unit enum value
	UnitMegabits = "Megabits"

	// UnitGigabits is a Unit enum value
	UnitGigabits = "Gigabits"

	// UnitTerabits is a Unit enum value
	UnitTerabits = "Terabits"

	// UnitPercent is a Unit enum value
	UnitPercent = "Percent"

	// UnitCount is a Unit enum value
	UnitCount = "Count"

	// UnitBytesSecond is a Unit enum value
	UnitBytesSecond = "Bytes/Second"

	// UnitKilobytesSecond is a Unit enum value
	UnitKilobytesSecond = "Kilobytes/Second"

	// UnitMegabytesSecond is a Unit enum value
	UnitMegabytesSecond = "Megabytes/Second"

	// UnitGigabytesSecond is a Unit enum value
	UnitGigabytesSecond = "Gigabytes/Second"

	// UnitTerabytesSecond is a Unit enum value
	UnitTerabytesSecond = "Terabytes/Second"

	// UnitBitsSecond is a Unit enum value
	UnitBitsSecond = "Bits/Second"

	// UnitKilobitsSecond is a Unit enum value
	UnitKilobitsSecond = "Kilobits/Second"

	// UnitMegabitsSecond is a Unit enum value
	UnitMegabitsSecond = "Megabits/Second"

	// UnitGigabitsSecond is a Unit enum value
	UnitGigabitsSecond = "Gigabits/Second"

	// UnitTerabitsSecond is a Unit enum value
	UnitTerabitsSecond = "Terabits/Second"

	// UnitCountSecond is a Unit enum value
	UnitCountSecond = "Count/Second"

	// UnitNone is a Unit enum value
	UnitNone = "None"
)

Unit

View Source 
const (
	// UpdateStatusSuccess is a UpdateStatus enum value
	UpdateStatusSuccess = "SUCCESS"

	// UpdateStatusPending is a UpdateStatus enum value
	UpdateStatusPending = "PENDING"

	// UpdateStatusFailed is a UpdateStatus enum value
	UpdateStatusFailed = "FAILED"
)
View Source 
const (
	// WebserverAccessModePrivateOnly is a WebserverAccessMode enum value
	WebserverAccessModePrivateOnly = "PRIVATE_ONLY"

	// WebserverAccessModePublicOnly is a WebserverAccessMode enum value
	WebserverAccessModePublicOnly = "PUBLIC_ONLY"
)
View Source 
const (

	// ErrCodeAccessDeniedException for service response error code
	// "AccessDeniedException".
	//
	// Access to the Airflow Web UI or CLI has been Denied. Please follow the MWAA
	// user guide to setup permissions to access the Web UI and CLI functionality.
	ErrCodeAccessDeniedException = "AccessDeniedException"

	// ErrCodeInternalServerException for service response error code
	// "InternalServerException".
	//
	// InternalServerException: An internal error has occurred.
	ErrCodeInternalServerException = "InternalServerException"

	// ErrCodeResourceNotFoundException for service response error code
	// "ResourceNotFoundException".
	//
	// ResourceNotFoundException: The resource is not available.
	ErrCodeResourceNotFoundException = "ResourceNotFoundException"

	// ErrCodeValidationException for service response error code
	// "ValidationException".
	//
	// ValidationException: The provided input is not valid.
	ErrCodeValidationException = "ValidationException"
)
View Source 
const (
	ServiceName = "MWAA"    // Name of service.
	EndpointsID = "airflow" // ID to lookup a service endpoint with.
	ServiceID   = "MWAA"    // ServiceID is a unique identifier of a specific service.
)

Service information constants

Variables

This section is empty.

Functions

func EnvironmentStatus_Values 

func EnvironmentStatus_Values() []string

EnvironmentStatus_Values returns all elements of the EnvironmentStatus enum

func LoggingLevel_Values 

func LoggingLevel_Values() []string

LoggingLevel_Values returns all elements of the LoggingLevel enum

func Unit_Values 

func Unit_Values() []string

Unit_Values returns all elements of the Unit enum

func UpdateStatus_Values 

func UpdateStatus_Values() []string

UpdateStatus_Values returns all elements of the UpdateStatus enum

func WebserverAccessMode_Values 

func WebserverAccessMode_Values() []string

WebserverAccessMode_Values returns all elements of the WebserverAccessMode enum

Types

type AccessDeniedException 

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

	Message_ *string `locationName:"Message" type:"string"`
	// contains filtered or unexported fields
}

Access to the Airflow Web UI or CLI has been Denied. Please follow the MWAA user guide to setup permissions to access the Web UI and CLI functionality.

func (*AccessDeniedException) Code 

func (s *AccessDeniedException) Code() string

Code returns the exception type name.

func (*AccessDeniedException) Error 

func (s *AccessDeniedException) Error() string

func (AccessDeniedException) GoString 

func (s AccessDeniedException) GoString() string

GoString returns the string representation

func (*AccessDeniedException) Message 

func (s *AccessDeniedException) Message() string

Message returns the exception's message.

func (*AccessDeniedException) OrigErr 

func (s *AccessDeniedException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*AccessDeniedException) RequestID 

func (s *AccessDeniedException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*AccessDeniedException) StatusCode 

func (s *AccessDeniedException) StatusCode() int

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

func (AccessDeniedException) String 

func (s AccessDeniedException) String() string

String returns the string representation

type CreateCliTokenInput 

type CreateCliTokenInput struct {

	// Create a CLI token request for a MWAA environment.
	//
	// Name is a required field
	Name *string `location:"uri" locationName:"Name" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (CreateCliTokenInput) GoString 

func (s CreateCliTokenInput) GoString() string

GoString returns the string representation

func (*CreateCliTokenInput) SetName 

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

SetName sets the Name field's value.

func (CreateCliTokenInput) String 

func (s CreateCliTokenInput) String() string

String returns the string representation

func (*CreateCliTokenInput) Validate 

func (s *CreateCliTokenInput) Validate() error

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

type CreateCliTokenOutput 

type CreateCliTokenOutput struct {

	// Create an Airflow CLI login token response for the provided JWT token.
	CliToken *string `type:"string" sensitive:"true"`

	// Create an Airflow CLI login token response for the provided webserver hostname.
	WebServerHostname *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

func (CreateCliTokenOutput) GoString 

func (s CreateCliTokenOutput) GoString() string

GoString returns the string representation

func (*CreateCliTokenOutput) SetCliToken 

func (s *CreateCliTokenOutput) SetCliToken(v string) *CreateCliTokenOutput

SetCliToken sets the CliToken field's value.

func (*CreateCliTokenOutput) SetWebServerHostname 

func (s *CreateCliTokenOutput) SetWebServerHostname(v string) *CreateCliTokenOutput

SetWebServerHostname sets the WebServerHostname field's value.

func (CreateCliTokenOutput) String 

func (s CreateCliTokenOutput) String() string

String returns the string representation

type CreateEnvironmentInput 

type CreateEnvironmentInput struct {

	// The Apache Airflow configuration setting you want to override in your environment.
	// For more information, see Environment configuration (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-env-variables.html).
	AirflowConfigurationOptions map[string]*string `type:"map" sensitive:"true"`

	// The Apache Airflow version you want to use for your environment.
	AirflowVersion *string `min:"1" type:"string"`

	// The relative path to the DAG folder on your Amazon S3 storage bucket. For
	// example, dags. For more information, see Importing DAGs on Amazon MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-dag-import.html).
	//
	// DagS3Path is a required field
	DagS3Path *string `min:"1" type:"string" required:"true"`

	// The environment class you want to use for your environment. The environment
	// class determines the size of the containers and database used for your Apache
	// Airflow services.
	EnvironmentClass *string `min:"1" type:"string"`

	// The Amazon Resource Name (ARN) of the execution role for your environment.
	// An execution role is an AWS Identity and Access Management (IAM) role that
	// grants MWAA permission to access AWS services and resources used by your
	// environment. For example, arn:aws:iam::123456789:role/my-execution-role.
	// For more information, see Managing access to Amazon Managed Workflows for
	// Apache Airflow (https://docs.aws.amazon.com/mwaa/latest/userguide/manage-access.html).
	//
	// ExecutionRoleArn is a required field
	ExecutionRoleArn *string `min:"1" type:"string" required:"true"`

	// The AWS Key Management Service (KMS) key to encrypt and decrypt the data
	// in your environment. You can use an AWS KMS key managed by MWAA, or a custom
	// KMS key (advanced). For more information, see Customer master keys (CMKs)
	// (https://docs.aws.amazon.com/kms/latest/developerguide/concepts.html?icmpid=docs_console_unmapped#master_keys)
	// in the AWS KMS developer guide.
	KmsKey *string `min:"1" type:"string"`

	// The Apache Airflow logs you want to send to Amazon CloudWatch Logs.
	LoggingConfiguration *LoggingConfigurationInput `type:"structure"`

	// The maximum number of workers that you want to run in your environment. MWAA
	// scales the number of Apache Airflow workers and the Fargate containers that
	// run your tasks up to the number you specify in this field. When there are
	// no more tasks running, and no more in the queue, MWAA disposes of the extra
	// containers leaving the one worker that is included with your environment.
	MaxWorkers *int64 `min:"1" type:"integer"`

	// The name of your MWAA environment.
	//
	// Name is a required field
	Name *string `location:"uri" locationName:"Name" min:"1" type:"string" required:"true"`

	// The VPC networking components you want to use for your environment. At least
	// two private subnet identifiers and one VPC security group identifier are
	// required to create an environment. For more information, see Creating the
	// VPC network for a MWAA environment (https://docs.aws.amazon.com/mwaa/latest/userguide/vpc-mwaa.html).
	//
	// NetworkConfiguration is a required field
	NetworkConfiguration *NetworkConfiguration `type:"structure" required:"true"`

	// The plugins.zip file version you want to use.
	PluginsS3ObjectVersion *string `min:"1" type:"string"`

	// The relative path to the plugins.zip file on your Amazon S3 storage bucket.
	// For example, plugins.zip. If a relative path is provided in the request,
	// then PluginsS3ObjectVersion is required. For more information, see Importing
	// DAGs on Amazon MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-dag-import.html).
	PluginsS3Path *string `min:"1" type:"string"`

	// The requirements.txt file version you want to use.
	RequirementsS3ObjectVersion *string `min:"1" type:"string"`

	// The relative path to the requirements.txt file on your Amazon S3 storage
	// bucket. For example, requirements.txt. If a relative path is provided in
	// the request, then RequirementsS3ObjectVersion is required. For more information,
	// see Importing DAGs on Amazon MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-dag-import.html).
	RequirementsS3Path *string `min:"1" type:"string"`

	// The Amazon Resource Name (ARN) of your Amazon S3 storage bucket. For example,
	// arn:aws:s3:::airflow-mybucketname.
	//
	// SourceBucketArn is a required field
	SourceBucketArn *string `min:"1" type:"string" required:"true"`

	// The metadata tags you want to attach to your environment. For more information,
	// see Tagging AWS resources (https://docs.aws.amazon.com/general/latest/gr/aws_tagging.html).
	Tags map[string]*string `min:"1" type:"map"`

	// The networking access of your Apache Airflow web server. A public network
	// allows your Airflow UI to be accessed over the Internet by users granted
	// access in your IAM policy. A private network limits access of your Airflow
	// UI to users within your VPC. For more information, see Creating the VPC network
	// for a MWAA environment (https://docs.aws.amazon.com/mwaa/latest/userguide/vpc-mwaa.html).
	WebserverAccessMode *string `type:"string" enum:"WebserverAccessMode"`

	// The day and time you want MWAA to start weekly maintenance updates on your
	// environment.
	WeeklyMaintenanceWindowStart *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

This section contains the Amazon Managed Workflows for Apache Airflow (MWAA) API reference documentation to create an environment. For more information, see Get started with Amazon Managed Workflows for Apache Airflow (https://docs.aws.amazon.com/mwaa/latest/userguide/get-started.html).

func (CreateEnvironmentInput) GoString 

func (s CreateEnvironmentInput) GoString() string

GoString returns the string representation

func (*CreateEnvironmentInput) SetAirflowConfigurationOptions 

func (s *CreateEnvironmentInput) SetAirflowConfigurationOptions(v map[string]*string) *CreateEnvironmentInput

SetAirflowConfigurationOptions sets the AirflowConfigurationOptions field's value.

func (*CreateEnvironmentInput) SetAirflowVersion 

func (s *CreateEnvironmentInput) SetAirflowVersion(v string) *CreateEnvironmentInput

SetAirflowVersion sets the AirflowVersion field's value.

func (*CreateEnvironmentInput) SetDagS3Path 

func (s *CreateEnvironmentInput) SetDagS3Path(v string) *CreateEnvironmentInput

SetDagS3Path sets the DagS3Path field's value.

func (*CreateEnvironmentInput) SetEnvironmentClass 

func (s *CreateEnvironmentInput) SetEnvironmentClass(v string) *CreateEnvironmentInput

SetEnvironmentClass sets the EnvironmentClass field's value.

func (*CreateEnvironmentInput) SetExecutionRoleArn 

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

SetExecutionRoleArn sets the ExecutionRoleArn field's value.

func (*CreateEnvironmentInput) SetKmsKey 

func (s *CreateEnvironmentInput) SetKmsKey(v string) *CreateEnvironmentInput

SetKmsKey sets the KmsKey field's value.

func (*CreateEnvironmentInput) SetLoggingConfiguration 

func (s *CreateEnvironmentInput) SetLoggingConfiguration(v *LoggingConfigurationInput) *CreateEnvironmentInput

SetLoggingConfiguration sets the LoggingConfiguration field's value.

func (*CreateEnvironmentInput) SetMaxWorkers 

func (s *CreateEnvironmentInput) SetMaxWorkers(v int64) *CreateEnvironmentInput

SetMaxWorkers sets the MaxWorkers field's value.

func (*CreateEnvironmentInput) SetName 

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

SetName sets the Name field's value.

func (*CreateEnvironmentInput) SetNetworkConfiguration 

func (s *CreateEnvironmentInput) SetNetworkConfiguration(v *NetworkConfiguration) *CreateEnvironmentInput

SetNetworkConfiguration sets the NetworkConfiguration field's value.

func (*CreateEnvironmentInput) SetPluginsS3ObjectVersion 

func (s *CreateEnvironmentInput) SetPluginsS3ObjectVersion(v string) *CreateEnvironmentInput

SetPluginsS3ObjectVersion sets the PluginsS3ObjectVersion field's value.

func (*CreateEnvironmentInput) SetPluginsS3Path 

func (s *CreateEnvironmentInput) SetPluginsS3Path(v string) *CreateEnvironmentInput

SetPluginsS3Path sets the PluginsS3Path field's value.

func (*CreateEnvironmentInput) SetRequirementsS3ObjectVersion 

func (s *CreateEnvironmentInput) SetRequirementsS3ObjectVersion(v string) *CreateEnvironmentInput

SetRequirementsS3ObjectVersion sets the RequirementsS3ObjectVersion field's value.

func (*CreateEnvironmentInput) SetRequirementsS3Path 

func (s *CreateEnvironmentInput) SetRequirementsS3Path(v string) *CreateEnvironmentInput

SetRequirementsS3Path sets the RequirementsS3Path field's value.

func (*CreateEnvironmentInput) SetSourceBucketArn 

func (s *CreateEnvironmentInput) SetSourceBucketArn(v string) *CreateEnvironmentInput

SetSourceBucketArn sets the SourceBucketArn field's value.

func (*CreateEnvironmentInput) SetTags 

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

SetTags sets the Tags field's value.

func (*CreateEnvironmentInput) SetWebserverAccessMode 

func (s *CreateEnvironmentInput) SetWebserverAccessMode(v string) *CreateEnvironmentInput

SetWebserverAccessMode sets the WebserverAccessMode field's value.

func (*CreateEnvironmentInput) SetWeeklyMaintenanceWindowStart 

func (s *CreateEnvironmentInput) SetWeeklyMaintenanceWindowStart(v string) *CreateEnvironmentInput

SetWeeklyMaintenanceWindowStart sets the WeeklyMaintenanceWindowStart field's value.

func (CreateEnvironmentInput) String 

func (s CreateEnvironmentInput) String() string

String returns the string representation

func (*CreateEnvironmentInput) Validate 

func (s *CreateEnvironmentInput) Validate() error

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

type CreateEnvironmentOutput 

type CreateEnvironmentOutput struct {

	// The resulting Amazon MWAA envirnonment ARN.
	Arn *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

func (CreateEnvironmentOutput) GoString 

func (s CreateEnvironmentOutput) GoString() string

GoString returns the string representation

func (*CreateEnvironmentOutput) SetArn 

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

SetArn sets the Arn field's value.

func (CreateEnvironmentOutput) String 

func (s CreateEnvironmentOutput) String() string

String returns the string representation

type CreateWebLoginTokenInput 

type CreateWebLoginTokenInput struct {

	// Create an Airflow Web UI login token request for a MWAA environment.
	//
	// Name is a required field
	Name *string `location:"uri" locationName:"Name" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (CreateWebLoginTokenInput) GoString 

func (s CreateWebLoginTokenInput) GoString() string

GoString returns the string representation

func (*CreateWebLoginTokenInput) SetName 

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

SetName sets the Name field's value.

func (CreateWebLoginTokenInput) String 

func (s CreateWebLoginTokenInput) String() string

String returns the string representation

func (*CreateWebLoginTokenInput) Validate 

func (s *CreateWebLoginTokenInput) Validate() error

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

type CreateWebLoginTokenOutput 

type CreateWebLoginTokenOutput struct {

	// Create an Airflow Web UI login token response for the provided webserver
	// hostname.
	WebServerHostname *string `min:"1" type:"string"`

	// Create an Airflow Web UI login token response for the provided JWT token.
	WebToken *string `type:"string" sensitive:"true"`
	// contains filtered or unexported fields
}

func (CreateWebLoginTokenOutput) GoString 

func (s CreateWebLoginTokenOutput) GoString() string

GoString returns the string representation

func (*CreateWebLoginTokenOutput) SetWebServerHostname 

func (s *CreateWebLoginTokenOutput) SetWebServerHostname(v string) *CreateWebLoginTokenOutput

SetWebServerHostname sets the WebServerHostname field's value.

func (*CreateWebLoginTokenOutput) SetWebToken 

func (s *CreateWebLoginTokenOutput) SetWebToken(v string) *CreateWebLoginTokenOutput

SetWebToken sets the WebToken field's value.

func (CreateWebLoginTokenOutput) String 

func (s CreateWebLoginTokenOutput) String() string

String returns the string representation

type DeleteEnvironmentInput 

type DeleteEnvironmentInput struct {

	// The name of the environment to delete.
	//
	// Name is a required field
	Name *string `location:"uri" locationName:"Name" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (DeleteEnvironmentInput) GoString 

func (s DeleteEnvironmentInput) GoString() string

GoString returns the string representation

func (*DeleteEnvironmentInput) SetName 

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

SetName sets the Name field's value.

func (DeleteEnvironmentInput) String 

func (s DeleteEnvironmentInput) String() string

String returns the string representation

func (*DeleteEnvironmentInput) Validate 

func (s *DeleteEnvironmentInput) Validate() error

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

type DeleteEnvironmentOutput 

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

func (DeleteEnvironmentOutput) GoString 

func (s DeleteEnvironmentOutput) GoString() string

GoString returns the string representation

func (DeleteEnvironmentOutput) String 

func (s DeleteEnvironmentOutput) String() string

String returns the string representation

type Dimension 

type Dimension struct {

	// Internal only API.
	//
	// Name is a required field
	Name *string `type:"string" required:"true"`

	// Internal only API.
	//
	// Value is a required field
	Value *string `type:"string" required:"true"`
	// contains filtered or unexported fields
}

Internal only API.

func (Dimension) GoString 

func (s Dimension) GoString() string

GoString returns the string representation

func (*Dimension) SetName 

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

SetName sets the Name field's value.

func (*Dimension) SetValue 

func (s *Dimension) SetValue(v string) *Dimension

SetValue sets the Value field's value.

func (Dimension) String 

func (s Dimension) String() string

String returns the string representation

func (*Dimension) Validate 

func (s *Dimension) Validate() error

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

type Environment 

type Environment struct {

	// The Airflow Configuration Options of the Amazon MWAA Environment.
	AirflowConfigurationOptions map[string]*string `type:"map"`

	// The AirflowV ersion of the Amazon MWAA Environment.
	AirflowVersion *string `min:"1" type:"string"`

	// The ARN of the Amazon MWAA Environment.
	Arn *string `min:"1" type:"string"`

	// The Created At date of the Amazon MWAA Environment.
	CreatedAt *time.Time `type:"timestamp"`

	// The Dags S3 Path of the Amazon MWAA Environment.
	DagS3Path *string `min:"1" type:"string"`

	// The Environment Class (size) of the Amazon MWAA Environment.
	EnvironmentClass *string `min:"1" type:"string"`

	// The Execution Role ARN of the Amazon MWAA Environment.
	ExecutionRoleArn *string `min:"1" type:"string"`

	// The Kms Key of the Amazon MWAA Environment.
	KmsKey *string `min:"1" type:"string"`

	// Last update information for the environment.
	LastUpdate *LastUpdate `type:"structure"`

	// The Logging Configuration of the Amazon MWAA Environment.
	LoggingConfiguration *LoggingConfiguration `type:"structure"`

	// The Maximum Workers of the Amazon MWAA Environment.
	MaxWorkers *int64 `min:"1" type:"integer"`

	// The name of the Amazon MWAA Environment.
	Name *string `min:"1" type:"string"`

	// Provide the security group and subnet IDs for the workers and scheduler.
	NetworkConfiguration *NetworkConfiguration `type:"structure"`

	// The Plugins.zip S3 Object Version of the Amazon MWAA Environment.
	PluginsS3ObjectVersion *string `min:"1" type:"string"`

	// The Plugins.zip S3 Path of the Amazon MWAA Environment.
	PluginsS3Path *string `min:"1" type:"string"`

	// The Requirements.txt file S3 Object Version of the Amazon MWAA Environment.
	RequirementsS3ObjectVersion *string `min:"1" type:"string"`

	// The Requirement.txt S3 Path of the Amazon MWAA Environment.
	RequirementsS3Path *string `min:"1" type:"string"`

	// The Service Role ARN of the Amazon MWAA Environment.
	ServiceRoleArn *string `min:"1" type:"string"`

	// The Source S3 Bucket ARN of the Amazon MWAA Environment.
	SourceBucketArn *string `min:"1" type:"string"`

	// The status of the Amazon MWAA Environment.
	Status *string `type:"string" enum:"EnvironmentStatus"`

	// The Tags of the Amazon MWAA Environment.
	Tags map[string]*string `min:"1" type:"map"`

	// The Webserver Access Mode of the Amazon MWAA Environment (public or private
	// only).
	WebserverAccessMode *string `type:"string" enum:"WebserverAccessMode"`

	// The Webserver URL of the Amazon MWAA Environment.
	WebserverUrl *string `min:"1" type:"string"`

	// The Weekly Maintenance Window Start of the Amazon MWAA Environment.
	WeeklyMaintenanceWindowStart *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

An Amazon MWAA environment.

func (Environment) GoString 

func (s Environment) GoString() string

GoString returns the string representation

func (*Environment) SetAirflowConfigurationOptions 

func (s *Environment) SetAirflowConfigurationOptions(v map[string]*string) *Environment

SetAirflowConfigurationOptions sets the AirflowConfigurationOptions field's value.

func (*Environment) SetAirflowVersion 

func (s *Environment) SetAirflowVersion(v string) *Environment

SetAirflowVersion sets the AirflowVersion field's value.

func (*Environment) SetArn 

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

SetArn sets the Arn field's value.

func (*Environment) SetCreatedAt 

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

SetCreatedAt sets the CreatedAt field's value.

func (*Environment) SetDagS3Path 

func (s *Environment) SetDagS3Path(v string) *Environment

SetDagS3Path sets the DagS3Path field's value.

func (*Environment) SetEnvironmentClass 

func (s *Environment) SetEnvironmentClass(v string) *Environment

SetEnvironmentClass sets the EnvironmentClass field's value.

func (*Environment) SetExecutionRoleArn 

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

SetExecutionRoleArn sets the ExecutionRoleArn field's value.

func (*Environment) SetKmsKey 

func (s *Environment) SetKmsKey(v string) *Environment

SetKmsKey sets the KmsKey field's value.

func (*Environment) SetLastUpdate 

func (s *Environment) SetLastUpdate(v *LastUpdate) *Environment

SetLastUpdate sets the LastUpdate field's value.

func (*Environment) SetLoggingConfiguration 

func (s *Environment) SetLoggingConfiguration(v *LoggingConfiguration) *Environment

SetLoggingConfiguration sets the LoggingConfiguration field's value.

func (*Environment) SetMaxWorkers 

func (s *Environment) SetMaxWorkers(v int64) *Environment

SetMaxWorkers sets the MaxWorkers field's value.

func (*Environment) SetName 

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

SetName sets the Name field's value.

func (*Environment) SetNetworkConfiguration 

func (s *Environment) SetNetworkConfiguration(v *NetworkConfiguration) *Environment

SetNetworkConfiguration sets the NetworkConfiguration field's value.

func (*Environment) SetPluginsS3ObjectVersion 

func (s *Environment) SetPluginsS3ObjectVersion(v string) *Environment

SetPluginsS3ObjectVersion sets the PluginsS3ObjectVersion field's value.

func (*Environment) SetPluginsS3Path 

func (s *Environment) SetPluginsS3Path(v string) *Environment

SetPluginsS3Path sets the PluginsS3Path field's value.

func (*Environment) SetRequirementsS3ObjectVersion 

func (s *Environment) SetRequirementsS3ObjectVersion(v string) *Environment

SetRequirementsS3ObjectVersion sets the RequirementsS3ObjectVersion field's value.

func (*Environment) SetRequirementsS3Path 

func (s *Environment) SetRequirementsS3Path(v string) *Environment

SetRequirementsS3Path sets the RequirementsS3Path field's value.

func (*Environment) SetServiceRoleArn 

func (s *Environment) SetServiceRoleArn(v string) *Environment

SetServiceRoleArn sets the ServiceRoleArn field's value.

func (*Environment) SetSourceBucketArn 

func (s *Environment) SetSourceBucketArn(v string) *Environment

SetSourceBucketArn sets the SourceBucketArn field's value.

func (*Environment) SetStatus 

func (s *Environment) SetStatus(v string) *Environment

SetStatus sets the Status field's value.

func (*Environment) SetTags 

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

SetTags sets the Tags field's value.

func (*Environment) SetWebserverAccessMode 

func (s *Environment) SetWebserverAccessMode(v string) *Environment

SetWebserverAccessMode sets the WebserverAccessMode field's value.

func (*Environment) SetWebserverUrl 

func (s *Environment) SetWebserverUrl(v string) *Environment

SetWebserverUrl sets the WebserverUrl field's value.

func (*Environment) SetWeeklyMaintenanceWindowStart 

func (s *Environment) SetWeeklyMaintenanceWindowStart(v string) *Environment

SetWeeklyMaintenanceWindowStart sets the WeeklyMaintenanceWindowStart field's value.

func (Environment) String 

func (s Environment) String() string

String returns the string representation

type GetEnvironmentInput 

type GetEnvironmentInput struct {

	// The name of the environment to retrieve.
	//
	// Name is a required field
	Name *string `location:"uri" locationName:"Name" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (GetEnvironmentInput) GoString 

func (s GetEnvironmentInput) GoString() string

GoString returns the string representation

func (*GetEnvironmentInput) SetName 

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

SetName sets the Name field's value.

func (GetEnvironmentInput) String 

func (s GetEnvironmentInput) String() string

String returns the string representation

func (*GetEnvironmentInput) Validate 

func (s *GetEnvironmentInput) Validate() error

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

type GetEnvironmentOutput 

type GetEnvironmentOutput struct {

	// A JSON blob with environment details.
	Environment *Environment `type:"structure"`
	// contains filtered or unexported fields
}

func (GetEnvironmentOutput) GoString 

func (s GetEnvironmentOutput) GoString() string

GoString returns the string representation

func (*GetEnvironmentOutput) SetEnvironment 

func (s *GetEnvironmentOutput) SetEnvironment(v *Environment) *GetEnvironmentOutput

SetEnvironment sets the Environment field's value.

func (GetEnvironmentOutput) String 

func (s GetEnvironmentOutput) String() string

String returns the string representation

type InternalServerException 

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

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

InternalServerException: An internal error has occurred.

func (*InternalServerException) Code 

func (s *InternalServerException) Code() string

Code returns the exception type name.

func (*InternalServerException) Error 

func (s *InternalServerException) Error() string

func (InternalServerException) GoString 

func (s InternalServerException) GoString() string

GoString returns the string representation

func (*InternalServerException) Message 

func (s *InternalServerException) Message() string

Message returns the exception's message.

func (*InternalServerException) OrigErr 

func (s *InternalServerException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*InternalServerException) RequestID 

func (s *InternalServerException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*InternalServerException) StatusCode 

func (s *InternalServerException) StatusCode() int

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

func (InternalServerException) String 

func (s InternalServerException) String() string

String returns the string representation

type LastUpdate 

type LastUpdate struct {

	// Time that last update occurred.
	CreatedAt *time.Time `type:"timestamp"`

	// Error string of last update, if applicable.
	Error *UpdateError `type:"structure"`

	// Status of last update of SUCCESS, FAILED, CREATING, DELETING.
	Status *string `type:"string" enum:"UpdateStatus"`
	// contains filtered or unexported fields
}

Last update information for the environment.

func (LastUpdate) GoString 

func (s LastUpdate) GoString() string

GoString returns the string representation

func (*LastUpdate) SetCreatedAt 

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

SetCreatedAt sets the CreatedAt field's value.

func (*LastUpdate) SetError 

func (s *LastUpdate) SetError(v *UpdateError) *LastUpdate

SetError sets the Error field's value.

func (*LastUpdate) SetStatus 

func (s *LastUpdate) SetStatus(v string) *LastUpdate

SetStatus sets the Status field's value.

func (LastUpdate) String 

func (s LastUpdate) String() string

String returns the string representation

type ListEnvironmentsInput 

type ListEnvironmentsInput struct {

	// The maximum results when listing MWAA environments.
	MaxResults *int64 `location:"querystring" locationName:"MaxResults" min:"1" type:"integer"`

	// The Next Token when listing MWAA environments.
	NextToken *string `location:"querystring" locationName:"NextToken" type:"string"`
	// contains filtered or unexported fields
}

func (ListEnvironmentsInput) GoString 

func (s ListEnvironmentsInput) GoString() string

GoString returns the string representation

func (*ListEnvironmentsInput) SetMaxResults 

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

SetMaxResults sets the MaxResults field's value.

func (*ListEnvironmentsInput) SetNextToken 

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

SetNextToken sets the NextToken field's value.

func (ListEnvironmentsInput) String 

func (s ListEnvironmentsInput) String() string

String returns the string representation

func (*ListEnvironmentsInput) Validate 

func (s *ListEnvironmentsInput) Validate() error

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

type ListEnvironmentsOutput 

type ListEnvironmentsOutput struct {

	// The list of Amazon MWAA Environments.
	//
	// Environments is a required field
	Environments []*string `type:"list" required:"true"`

	// The Next Token when listing MWAA environments.
	NextToken *string `type:"string"`
	// contains filtered or unexported fields
}

func (ListEnvironmentsOutput) GoString 

func (s ListEnvironmentsOutput) GoString() string

GoString returns the string representation

func (*ListEnvironmentsOutput) SetEnvironments 

func (s *ListEnvironmentsOutput) SetEnvironments(v []*string) *ListEnvironmentsOutput

SetEnvironments sets the Environments field's value.

func (*ListEnvironmentsOutput) SetNextToken 

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

SetNextToken sets the NextToken field's value.

func (ListEnvironmentsOutput) String 

func (s ListEnvironmentsOutput) String() string

String returns the string representation

type ListTagsForResourceInput 

type ListTagsForResourceInput struct {

	// The ARN of the MWAA environment.
	//
	// ResourceArn is a required field
	ResourceArn *string `location:"uri" locationName:"ResourceArn" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (ListTagsForResourceInput) GoString 

func (s ListTagsForResourceInput) GoString() string

GoString returns the string representation

func (*ListTagsForResourceInput) SetResourceArn 

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

SetResourceArn sets the ResourceArn field's value.

func (ListTagsForResourceInput) String 

func (s ListTagsForResourceInput) String() string

String returns the string representation

func (*ListTagsForResourceInput) Validate 

func (s *ListTagsForResourceInput) Validate() error

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

type ListTagsForResourceOutput 

type ListTagsForResourceOutput struct {

	// The tags of the MWAA environments.
	Tags map[string]*string `min:"1" type:"map"`
	// contains filtered or unexported fields
}

func (ListTagsForResourceOutput) GoString 

func (s ListTagsForResourceOutput) GoString() string

GoString returns the string representation

func (*ListTagsForResourceOutput) SetTags 

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

SetTags sets the Tags field's value.

func (ListTagsForResourceOutput) String 

func (s ListTagsForResourceOutput) String() string

String returns the string representation

type LoggingConfiguration 

type LoggingConfiguration struct {

	// A JSON blob that provides configuration to use for logging with respect to
	// the various Apache Airflow services: DagProcessingLogs, SchedulerLogs, TaskLogs,
	// WebserverLogs, and WorkerLogs.
	DagProcessingLogs *ModuleLoggingConfiguration `type:"structure"`

	// A JSON blob that provides configuration to use for logging with respect to
	// the various Apache Airflow services: DagProcessingLogs, SchedulerLogs, TaskLogs,
	// WebserverLogs, and WorkerLogs.
	SchedulerLogs *ModuleLoggingConfiguration `type:"structure"`

	// A JSON blob that provides configuration to use for logging with respect to
	// the various Apache Airflow services: DagProcessingLogs, SchedulerLogs, TaskLogs,
	// WebserverLogs, and WorkerLogs.
	TaskLogs *ModuleLoggingConfiguration `type:"structure"`

	// A JSON blob that provides configuration to use for logging with respect to
	// the various Apache Airflow services: DagProcessingLogs, SchedulerLogs, TaskLogs,
	// WebserverLogs, and WorkerLogs.
	WebserverLogs *ModuleLoggingConfiguration `type:"structure"`

	// A JSON blob that provides configuration to use for logging with respect to
	// the various Apache Airflow services: DagProcessingLogs, SchedulerLogs, TaskLogs,
	// WebserverLogs, and WorkerLogs.
	WorkerLogs *ModuleLoggingConfiguration `type:"structure"`
	// contains filtered or unexported fields
}

The Logging Configuration of your Amazon MWAA environment.

func (LoggingConfiguration) GoString 

func (s LoggingConfiguration) GoString() string

GoString returns the string representation

func (*LoggingConfiguration) SetDagProcessingLogs 

func (s *LoggingConfiguration) SetDagProcessingLogs(v *ModuleLoggingConfiguration) *LoggingConfiguration

SetDagProcessingLogs sets the DagProcessingLogs field's value.

func (*LoggingConfiguration) SetSchedulerLogs 

func (s *LoggingConfiguration) SetSchedulerLogs(v *ModuleLoggingConfiguration) *LoggingConfiguration

SetSchedulerLogs sets the SchedulerLogs field's value.

func (*LoggingConfiguration) SetTaskLogs 

func (s *LoggingConfiguration) SetTaskLogs(v *ModuleLoggingConfiguration) *LoggingConfiguration

SetTaskLogs sets the TaskLogs field's value.

func (*LoggingConfiguration) SetWebserverLogs 

func (s *LoggingConfiguration) SetWebserverLogs(v *ModuleLoggingConfiguration) *LoggingConfiguration

SetWebserverLogs sets the WebserverLogs field's value.

func (*LoggingConfiguration) SetWorkerLogs 

func (s *LoggingConfiguration) SetWorkerLogs(v *ModuleLoggingConfiguration) *LoggingConfiguration

SetWorkerLogs sets the WorkerLogs field's value.

func (LoggingConfiguration) String 

func (s LoggingConfiguration) String() string

String returns the string representation

type LoggingConfigurationInput 

type LoggingConfigurationInput struct {

	// A JSON blob that provides configuration to use for logging with respect to
	// the various Apache Airflow services: DagProcessingLogs, SchedulerLogs, TaskLogs,
	// WebserverLogs, and WorkerLogs.
	DagProcessingLogs *ModuleLoggingConfigurationInput `type:"structure"`

	// A JSON blob that provides configuration to use for logging with respect to
	// the various Apache Airflow services: DagProcessingLogs, SchedulerLogs, TaskLogs,
	// WebserverLogs, and WorkerLogs.
	SchedulerLogs *ModuleLoggingConfigurationInput `type:"structure"`

	// A JSON blob that provides configuration to use for logging with respect to
	// the various Apache Airflow services: DagProcessingLogs, SchedulerLogs, TaskLogs,
	// WebserverLogs, and WorkerLogs.
	TaskLogs *ModuleLoggingConfigurationInput `type:"structure"`

	// A JSON blob that provides configuration to use for logging with respect to
	// the various Apache Airflow services: DagProcessingLogs, SchedulerLogs, TaskLogs,
	// WebserverLogs, and WorkerLogs.
	WebserverLogs *ModuleLoggingConfigurationInput `type:"structure"`

	// A JSON blob that provides configuration to use for logging with respect to
	// the various Apache Airflow services: DagProcessingLogs, SchedulerLogs, TaskLogs,
	// WebserverLogs, and WorkerLogs.
	WorkerLogs *ModuleLoggingConfigurationInput `type:"structure"`
	// contains filtered or unexported fields
}

The Logging Configuration of your Amazon MWAA environment.

func (LoggingConfigurationInput) GoString 

func (s LoggingConfigurationInput) GoString() string

GoString returns the string representation

func (*LoggingConfigurationInput) SetDagProcessingLogs 

func (s *LoggingConfigurationInput) SetDagProcessingLogs(v *ModuleLoggingConfigurationInput) *LoggingConfigurationInput

SetDagProcessingLogs sets the DagProcessingLogs field's value.

func (*LoggingConfigurationInput) SetSchedulerLogs 

func (s *LoggingConfigurationInput) SetSchedulerLogs(v *ModuleLoggingConfigurationInput) *LoggingConfigurationInput

SetSchedulerLogs sets the SchedulerLogs field's value.

func (*LoggingConfigurationInput) SetTaskLogs 

func (s *LoggingConfigurationInput) SetTaskLogs(v *ModuleLoggingConfigurationInput) *LoggingConfigurationInput

SetTaskLogs sets the TaskLogs field's value.

func (*LoggingConfigurationInput) SetWebserverLogs 

func (s *LoggingConfigurationInput) SetWebserverLogs(v *ModuleLoggingConfigurationInput) *LoggingConfigurationInput

SetWebserverLogs sets the WebserverLogs field's value.

func (*LoggingConfigurationInput) SetWorkerLogs 

func (s *LoggingConfigurationInput) SetWorkerLogs(v *ModuleLoggingConfigurationInput) *LoggingConfigurationInput

SetWorkerLogs sets the WorkerLogs field's value.

func (LoggingConfigurationInput) String 

func (s LoggingConfigurationInput) String() string

String returns the string representation

func (*LoggingConfigurationInput) Validate 

func (s *LoggingConfigurationInput) Validate() error

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

type MWAA 

type MWAA struct {
	*client.Client
}

MWAA provides the API operation methods for making requests to AmazonMWAA. See this package's package overview docs for details on the service.

MWAA 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) *MWAA

New creates a new instance of the MWAA 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 MWAA client from just a session.
svc := mwaa.New(mySession)

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

func (*MWAA) CreateCliToken 

func (c *MWAA) CreateCliToken(input *CreateCliTokenInput) (*CreateCliTokenOutput, error)

CreateCliToken API operation for AmazonMWAA.

Create a CLI token to use Airflow CLI.

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 AmazonMWAA's API operation CreateCliToken for usage and error information.

Returned Error Types:

  • ResourceNotFoundException ResourceNotFoundException: The resource is not available.

See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/CreateCliToken

func (*MWAA) CreateCliTokenRequest 

func (c *MWAA) CreateCliTokenRequest(input *CreateCliTokenInput) (req *request.Request, output *CreateCliTokenOutput)

CreateCliTokenRequest generates a "aws/request.Request" representing the client's request for the CreateCliToken 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 CreateCliToken for more information on using the CreateCliToken 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 CreateCliTokenRequest method.
req, resp := client.CreateCliTokenRequest(params)

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

See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/CreateCliToken

func (*MWAA) CreateCliTokenWithContext 

func (c *MWAA) CreateCliTokenWithContext(ctx aws.Context, input *CreateCliTokenInput, opts ...request.Option) (*CreateCliTokenOutput, error)

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

See CreateCliToken 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 (*MWAA) CreateEnvironment 

func (c *MWAA) CreateEnvironment(input *CreateEnvironmentInput) (*CreateEnvironmentOutput, error)

CreateEnvironment API operation for AmazonMWAA.

JSON blob that describes the environment to create.

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 AmazonMWAA's API operation CreateEnvironment for usage and error information.

Returned Error Types:

  • ValidationException ValidationException: The provided input is not valid.

  • InternalServerException InternalServerException: An internal error has occurred.

See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/CreateEnvironment

func (*MWAA) CreateEnvironmentRequest 

func (c *MWAA) CreateEnvironmentRequest(input *CreateEnvironmentInput) (req *request.Request, output *CreateEnvironmentOutput)

CreateEnvironmentRequest generates a "aws/request.Request" representing the client's request for the CreateEnvironment 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 CreateEnvironment for more information on using the CreateEnvironment 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 CreateEnvironmentRequest method.
req, resp := client.CreateEnvironmentRequest(params)

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

See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/CreateEnvironment

func (*MWAA) CreateEnvironmentWithContext 

func (c *MWAA) CreateEnvironmentWithContext(ctx aws.Context, input *CreateEnvironmentInput, opts ...request.Option) (*CreateEnvironmentOutput, error)

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

See CreateEnvironment 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 (*MWAA) CreateWebLoginToken 

func (c *MWAA) CreateWebLoginToken(input *CreateWebLoginTokenInput) (*CreateWebLoginTokenOutput, error)

CreateWebLoginToken API operation for AmazonMWAA.

Create a JWT token to be used to login to Airflow Web UI with claims based Authentication.

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 AmazonMWAA's API operation CreateWebLoginToken for usage and error information.

Returned Error Types:

  • AccessDeniedException Access to the Airflow Web UI or CLI has been Denied. Please follow the MWAA user guide to setup permissions to access the Web UI and CLI functionality.

  • ResourceNotFoundException ResourceNotFoundException: The resource is not available.

  • ValidationException ValidationException: The provided input is not valid.

  • InternalServerException InternalServerException: An internal error has occurred.

See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/CreateWebLoginToken

func (*MWAA) CreateWebLoginTokenRequest 

func (c *MWAA) CreateWebLoginTokenRequest(input *CreateWebLoginTokenInput) (req *request.Request, output *CreateWebLoginTokenOutput)

CreateWebLoginTokenRequest generates a "aws/request.Request" representing the client's request for the CreateWebLoginToken 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 CreateWebLoginToken for more information on using the CreateWebLoginToken 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 CreateWebLoginTokenRequest method.
req, resp := client.CreateWebLoginTokenRequest(params)

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

See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/CreateWebLoginToken

func (*MWAA) CreateWebLoginTokenWithContext 

func (c *MWAA) CreateWebLoginTokenWithContext(ctx aws.Context, input *CreateWebLoginTokenInput, opts ...request.Option) (*CreateWebLoginTokenOutput, error)

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

See CreateWebLoginToken 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 (*MWAA) DeleteEnvironment 

func (c *MWAA) DeleteEnvironment(input *DeleteEnvironmentInput) (*DeleteEnvironmentOutput, error)

DeleteEnvironment API operation for AmazonMWAA.

Delete an existing environment.

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 AmazonMWAA's API operation DeleteEnvironment for usage and error information.

Returned Error Types:

  • ResourceNotFoundException ResourceNotFoundException: The resource is not available.

  • ValidationException ValidationException: The provided input is not valid.

  • InternalServerException InternalServerException: An internal error has occurred.

See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/DeleteEnvironment

func (*MWAA) DeleteEnvironmentRequest 

func (c *MWAA) DeleteEnvironmentRequest(input *DeleteEnvironmentInput) (req *request.Request, output *DeleteEnvironmentOutput)

DeleteEnvironmentRequest generates a "aws/request.Request" representing the client's request for the DeleteEnvironment 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 DeleteEnvironment for more information on using the DeleteEnvironment 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 DeleteEnvironmentRequest method.
req, resp := client.DeleteEnvironmentRequest(params)

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

See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/DeleteEnvironment

func (*MWAA) DeleteEnvironmentWithContext 

func (c *MWAA) DeleteEnvironmentWithContext(ctx aws.Context, input *DeleteEnvironmentInput, opts ...request.Option) (*DeleteEnvironmentOutput, error)

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

See DeleteEnvironment 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 (*MWAA) GetEnvironment 

func (c *MWAA) GetEnvironment(input *GetEnvironmentInput) (*GetEnvironmentOutput, error)

GetEnvironment API operation for AmazonMWAA.

Get details of an existing environment.

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 AmazonMWAA's API operation GetEnvironment for usage and error information.

Returned Error Types:

  • ResourceNotFoundException ResourceNotFoundException: The resource is not available.

  • ValidationException ValidationException: The provided input is not valid.

  • InternalServerException InternalServerException: An internal error has occurred.

See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/GetEnvironment

func (*MWAA) GetEnvironmentRequest 

func (c *MWAA) GetEnvironmentRequest(input *GetEnvironmentInput) (req *request.Request, output *GetEnvironmentOutput)

GetEnvironmentRequest generates a "aws/request.Request" representing the client's request for the GetEnvironment 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 GetEnvironment for more information on using the GetEnvironment 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 GetEnvironmentRequest method.
req, resp := client.GetEnvironmentRequest(params)

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

See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/GetEnvironment

func (*MWAA) GetEnvironmentWithContext 

func (c *MWAA) GetEnvironmentWithContext(ctx aws.Context, input *GetEnvironmentInput, opts ...request.Option) (*GetEnvironmentOutput, error)

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

See GetEnvironment 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 (*MWAA) ListEnvironments 

func (c *MWAA) ListEnvironments(input *ListEnvironmentsInput) (*ListEnvironmentsOutput, error)

ListEnvironments API operation for AmazonMWAA.

List Amazon MWAA Environments.

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 AmazonMWAA's API operation ListEnvironments for usage and error information.

Returned Error Types:

  • ValidationException ValidationException: The provided input is not valid.

  • InternalServerException InternalServerException: An internal error has occurred.

See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/ListEnvironments

func (*MWAA) ListEnvironmentsPages 

func (c *MWAA) ListEnvironmentsPages(input *ListEnvironmentsInput, fn func(*ListEnvironmentsOutput, bool) bool) error

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

See ListEnvironments 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 ListEnvironments operation.
pageNum := 0
err := client.ListEnvironmentsPages(params,
    func(page *mwaa.ListEnvironmentsOutput, lastPage bool) bool {
        pageNum++
        fmt.Println(page)
        return pageNum <= 3
    })

func (*MWAA) ListEnvironmentsPagesWithContext 

func (c *MWAA) ListEnvironmentsPagesWithContext(ctx aws.Context, input *ListEnvironmentsInput, fn func(*ListEnvironmentsOutput, bool) bool, opts ...request.Option) error

ListEnvironmentsPagesWithContext same as ListEnvironmentsPages 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 (*MWAA) ListEnvironmentsRequest 

func (c *MWAA) ListEnvironmentsRequest(input *ListEnvironmentsInput) (req *request.Request, output *ListEnvironmentsOutput)

ListEnvironmentsRequest generates a "aws/request.Request" representing the client's request for the ListEnvironments 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 ListEnvironments for more information on using the ListEnvironments 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 ListEnvironmentsRequest method.
req, resp := client.ListEnvironmentsRequest(params)

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

See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/ListEnvironments

func (*MWAA) ListEnvironmentsWithContext 

func (c *MWAA) ListEnvironmentsWithContext(ctx aws.Context, input *ListEnvironmentsInput, opts ...request.Option) (*ListEnvironmentsOutput, error)

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

See ListEnvironments 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 (*MWAA) ListTagsForResource 

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

ListTagsForResource API operation for AmazonMWAA.

List the tags for MWAA environments.

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 AmazonMWAA's API operation ListTagsForResource for usage and error information.

Returned Error Types:

  • ResourceNotFoundException ResourceNotFoundException: The resource is not available.

  • ValidationException ValidationException: The provided input is not valid.

  • InternalServerException InternalServerException: An internal error has occurred.

See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/ListTagsForResource

func (*MWAA) ListTagsForResourceRequest 

func (c *MWAA) 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/mwaa-2020-07-01/ListTagsForResource

func (*MWAA) ListTagsForResourceWithContext 

func (c *MWAA) 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 (*MWAA) PublishMetrics 

func (c *MWAA) PublishMetrics(input *PublishMetricsInput) (*PublishMetricsOutput, error)

PublishMetrics API operation for AmazonMWAA.

An operation for publishing metrics from the customers to the Ops plane.

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 AmazonMWAA's API operation PublishMetrics for usage and error information.

Returned Error Types:

  • ValidationException ValidationException: The provided input is not valid.

  • InternalServerException InternalServerException: An internal error has occurred.

See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/PublishMetrics

func (*MWAA) PublishMetricsRequest 

func (c *MWAA) PublishMetricsRequest(input *PublishMetricsInput) (req *request.Request, output *PublishMetricsOutput)

PublishMetricsRequest generates a "aws/request.Request" representing the client's request for the PublishMetrics 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 PublishMetrics for more information on using the PublishMetrics 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 PublishMetricsRequest method.
req, resp := client.PublishMetricsRequest(params)

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

See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/PublishMetrics

func (*MWAA) PublishMetricsWithContext 

func (c *MWAA) PublishMetricsWithContext(ctx aws.Context, input *PublishMetricsInput, opts ...request.Option) (*PublishMetricsOutput, error)

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

See PublishMetrics 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 (*MWAA) TagResource 

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

TagResource API operation for AmazonMWAA.

Add tag to the MWAA environments.

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 AmazonMWAA's API operation TagResource for usage and error information.

Returned Error Types:

  • ResourceNotFoundException ResourceNotFoundException: The resource is not available.

  • ValidationException ValidationException: The provided input is not valid.

  • InternalServerException InternalServerException: An internal error has occurred.

See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/TagResource

func (*MWAA) TagResourceRequest 

func (c *MWAA) 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/mwaa-2020-07-01/TagResource

func (*MWAA) TagResourceWithContext 

func (c *MWAA) 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 (*MWAA) UntagResource 

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

UntagResource API operation for AmazonMWAA.

Remove a tag from the MWAA environments.

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 AmazonMWAA's API operation UntagResource for usage and error information.

Returned Error Types:

  • ResourceNotFoundException ResourceNotFoundException: The resource is not available.

  • ValidationException ValidationException: The provided input is not valid.

  • InternalServerException InternalServerException: An internal error has occurred.

See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/UntagResource

func (*MWAA) UntagResourceRequest 

func (c *MWAA) 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/mwaa-2020-07-01/UntagResource

func (*MWAA) UntagResourceWithContext 

func (c *MWAA) 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.

func (*MWAA) UpdateEnvironment 

func (c *MWAA) UpdateEnvironment(input *UpdateEnvironmentInput) (*UpdateEnvironmentOutput, error)

UpdateEnvironment API operation for AmazonMWAA.

Update an MWAA environment.

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 AmazonMWAA's API operation UpdateEnvironment for usage and error information.

Returned Error Types:

  • ResourceNotFoundException ResourceNotFoundException: The resource is not available.

  • ValidationException ValidationException: The provided input is not valid.

  • InternalServerException InternalServerException: An internal error has occurred.

See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/UpdateEnvironment

func (*MWAA) UpdateEnvironmentRequest 

func (c *MWAA) UpdateEnvironmentRequest(input *UpdateEnvironmentInput) (req *request.Request, output *UpdateEnvironmentOutput)

UpdateEnvironmentRequest generates a "aws/request.Request" representing the client's request for the UpdateEnvironment 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 UpdateEnvironment for more information on using the UpdateEnvironment 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 UpdateEnvironmentRequest method.
req, resp := client.UpdateEnvironmentRequest(params)

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

See also, https://docs.aws.amazon.com/goto/WebAPI/mwaa-2020-07-01/UpdateEnvironment

func (*MWAA) UpdateEnvironmentWithContext 

func (c *MWAA) UpdateEnvironmentWithContext(ctx aws.Context, input *UpdateEnvironmentInput, opts ...request.Option) (*UpdateEnvironmentOutput, error)

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

See UpdateEnvironment 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 MetricDatum 

type MetricDatum struct {

	// Internal only API.
	Dimensions []*Dimension `type:"list"`

	// Internal only API.
	//
	// MetricName is a required field
	MetricName *string `type:"string" required:"true"`

	// Internal only API.
	StatisticValues *StatisticSet `type:"structure"`

	// Internal only API.
	//
	// Timestamp is a required field
	Timestamp *time.Time `type:"timestamp" required:"true"`

	// Unit
	Unit *string `type:"string" enum:"Unit"`

	// Internal only API.
	Value *float64 `type:"double"`
	// contains filtered or unexported fields
}

Internal only API.

func (MetricDatum) GoString 

func (s MetricDatum) GoString() string

GoString returns the string representation

func (*MetricDatum) SetDimensions 

func (s *MetricDatum) SetDimensions(v []*Dimension) *MetricDatum

SetDimensions sets the Dimensions field's value.

func (*MetricDatum) SetMetricName 

func (s *MetricDatum) SetMetricName(v string) *MetricDatum

SetMetricName sets the MetricName field's value.

func (*MetricDatum) SetStatisticValues 

func (s *MetricDatum) SetStatisticValues(v *StatisticSet) *MetricDatum

SetStatisticValues sets the StatisticValues field's value.

func (*MetricDatum) SetTimestamp 

func (s *MetricDatum) SetTimestamp(v time.Time) *MetricDatum

SetTimestamp sets the Timestamp field's value.

func (*MetricDatum) SetUnit 

func (s *MetricDatum) SetUnit(v string) *MetricDatum

SetUnit sets the Unit field's value.

func (*MetricDatum) SetValue 

func (s *MetricDatum) SetValue(v float64) *MetricDatum

SetValue sets the Value field's value.

func (MetricDatum) String 

func (s MetricDatum) String() string

String returns the string representation

func (*MetricDatum) Validate 

func (s *MetricDatum) Validate() error

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

type ModuleLoggingConfiguration 

type ModuleLoggingConfiguration struct {

	// Provides the ARN for the CloudWatch group where the logs will be published.
	CloudWatchLogGroupArn *string `min:"1" type:"string"`

	// Defines that the logging module is enabled.
	Enabled *bool `type:"boolean"`

	// Defines the log level, which can be CRITICAL, ERROR, WARNING, or INFO.
	LogLevel *string `type:"string" enum:"LoggingLevel"`
	// contains filtered or unexported fields
}

A JSON blob that provides configuration to use for logging with respect to the various Apache Airflow services: DagProcessingLogs, SchedulerLogs, TaskLogs, WebserverLogs, and WorkerLogs.

func (ModuleLoggingConfiguration) GoString 

func (s ModuleLoggingConfiguration) GoString() string

GoString returns the string representation

func (*ModuleLoggingConfiguration) SetCloudWatchLogGroupArn 

func (s *ModuleLoggingConfiguration) SetCloudWatchLogGroupArn(v string) *ModuleLoggingConfiguration

SetCloudWatchLogGroupArn sets the CloudWatchLogGroupArn field's value.

func (*ModuleLoggingConfiguration) SetEnabled 

func (s *ModuleLoggingConfiguration) SetEnabled(v bool) *ModuleLoggingConfiguration

SetEnabled sets the Enabled field's value.

func (*ModuleLoggingConfiguration) SetLogLevel 

func (s *ModuleLoggingConfiguration) SetLogLevel(v string) *ModuleLoggingConfiguration

SetLogLevel sets the LogLevel field's value.

func (ModuleLoggingConfiguration) String 

func (s ModuleLoggingConfiguration) String() string

String returns the string representation

type ModuleLoggingConfigurationInput 

type ModuleLoggingConfigurationInput struct {

	// Defines that the logging module is enabled.
	//
	// Enabled is a required field
	Enabled *bool `type:"boolean" required:"true"`

	// Defines the log level, which can be CRITICAL, ERROR, WARNING, or INFO.
	//
	// LogLevel is a required field
	LogLevel *string `type:"string" required:"true" enum:"LoggingLevel"`
	// contains filtered or unexported fields
}

A JSON blob that provides configuration to use for logging with respect to the various Apache Airflow services: DagProcessingLogs, SchedulerLogs, TaskLogs, WebserverLogs, and WorkerLogs.

func (ModuleLoggingConfigurationInput) GoString 

func (s ModuleLoggingConfigurationInput) GoString() string

GoString returns the string representation

func (*ModuleLoggingConfigurationInput) SetEnabled 

func (s *ModuleLoggingConfigurationInput) SetEnabled(v bool) *ModuleLoggingConfigurationInput

SetEnabled sets the Enabled field's value.

func (*ModuleLoggingConfigurationInput) SetLogLevel 

func (s *ModuleLoggingConfigurationInput) SetLogLevel(v string) *ModuleLoggingConfigurationInput

SetLogLevel sets the LogLevel field's value.

func (ModuleLoggingConfigurationInput) String 

func (s ModuleLoggingConfigurationInput) String() string

String returns the string representation

func (*ModuleLoggingConfigurationInput) Validate 

func (s *ModuleLoggingConfigurationInput) Validate() error

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

type NetworkConfiguration 

type NetworkConfiguration struct {

	// A JSON list of 1 or more security groups IDs by name, in the same VPC as
	// the subnets.
	SecurityGroupIds []*string `min:"1" type:"list"`

	// Provide a JSON list of 2 subnet IDs by name. These must be private subnets,
	// in the same VPC, in two different availability zones.
	SubnetIds []*string `min:"2" type:"list"`
	// contains filtered or unexported fields
}

Provide the security group and subnet IDs for the workers and scheduler.

func (NetworkConfiguration) GoString 

func (s NetworkConfiguration) GoString() string

GoString returns the string representation

func (*NetworkConfiguration) SetSecurityGroupIds 

func (s *NetworkConfiguration) SetSecurityGroupIds(v []*string) *NetworkConfiguration

SetSecurityGroupIds sets the SecurityGroupIds field's value.

func (*NetworkConfiguration) SetSubnetIds 

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

SetSubnetIds sets the SubnetIds field's value.

func (NetworkConfiguration) String 

func (s NetworkConfiguration) String() string

String returns the string representation

func (*NetworkConfiguration) Validate 

func (s *NetworkConfiguration) Validate() error

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

type PublishMetricsInput 

type PublishMetricsInput struct {

	// Publishes environment metric data to Amazon CloudWatch.
	//
	// EnvironmentName is a required field
	EnvironmentName *string `location:"uri" locationName:"EnvironmentName" min:"1" type:"string" required:"true"`

	// Publishes metric data points to Amazon CloudWatch. CloudWatch associates
	// the data points with the specified metrica.
	//
	// MetricData is a required field
	MetricData []*MetricDatum `type:"list" required:"true"`
	// contains filtered or unexported fields
}

func (PublishMetricsInput) GoString 

func (s PublishMetricsInput) GoString() string

GoString returns the string representation

func (*PublishMetricsInput) SetEnvironmentName 

func (s *PublishMetricsInput) SetEnvironmentName(v string) *PublishMetricsInput

SetEnvironmentName sets the EnvironmentName field's value.

func (*PublishMetricsInput) SetMetricData 

func (s *PublishMetricsInput) SetMetricData(v []*MetricDatum) *PublishMetricsInput

SetMetricData sets the MetricData field's value.

func (PublishMetricsInput) String 

func (s PublishMetricsInput) String() string

String returns the string representation

func (*PublishMetricsInput) Validate 

func (s *PublishMetricsInput) Validate() error

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

type PublishMetricsOutput 

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

func (PublishMetricsOutput) GoString 

func (s PublishMetricsOutput) GoString() string

GoString returns the string representation

func (PublishMetricsOutput) String 

func (s PublishMetricsOutput) String() string

String returns the string representation

type ResourceNotFoundException 

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

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

ResourceNotFoundException: The resource is not available.

func (*ResourceNotFoundException) Code 

func (s *ResourceNotFoundException) Code() string

Code returns the exception type name.

func (*ResourceNotFoundException) Error 

func (s *ResourceNotFoundException) Error() string

func (ResourceNotFoundException) GoString 

func (s ResourceNotFoundException) GoString() string

GoString returns the string representation

func (*ResourceNotFoundException) Message 

func (s *ResourceNotFoundException) Message() string

Message returns the exception's message.

func (*ResourceNotFoundException) OrigErr 

func (s *ResourceNotFoundException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ResourceNotFoundException) RequestID 

func (s *ResourceNotFoundException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ResourceNotFoundException) StatusCode 

func (s *ResourceNotFoundException) StatusCode() int

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

func (ResourceNotFoundException) String 

func (s ResourceNotFoundException) String() string

String returns the string representation

type StatisticSet 

type StatisticSet struct {

	// Internal only API.
	Maximum *float64 `type:"double"`

	// Internal only API.
	Minimum *float64 `type:"double"`

	// Internal only API.
	SampleCount *int64 `type:"integer"`

	// Internal only API.
	Sum *float64 `type:"double"`
	// contains filtered or unexported fields
}

Internal only API.

func (StatisticSet) GoString 

func (s StatisticSet) GoString() string

GoString returns the string representation

func (*StatisticSet) SetMaximum 

func (s *StatisticSet) SetMaximum(v float64) *StatisticSet

SetMaximum sets the Maximum field's value.

func (*StatisticSet) SetMinimum 

func (s *StatisticSet) SetMinimum(v float64) *StatisticSet

SetMinimum sets the Minimum field's value.

func (*StatisticSet) SetSampleCount 

func (s *StatisticSet) SetSampleCount(v int64) *StatisticSet

SetSampleCount sets the SampleCount field's value.

func (*StatisticSet) SetSum 

func (s *StatisticSet) SetSum(v float64) *StatisticSet

SetSum sets the Sum field's value.

func (StatisticSet) String 

func (s StatisticSet) String() string

String returns the string representation

type TagResourceInput 

type TagResourceInput struct {

	// The tag resource ARN of the MWAA environments.
	//
	// ResourceArn is a required field
	ResourceArn *string `location:"uri" locationName:"ResourceArn" min:"1" type:"string" required:"true"`

	// The tag resource tag of the MWAA environments.
	//
	// Tags is a required field
	Tags map[string]*string `min:"1" type:"map" required:"true"`
	// contains filtered or unexported fields
}

func (TagResourceInput) GoString 

func (s TagResourceInput) GoString() string

GoString returns the string representation

func (*TagResourceInput) SetResourceArn 

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

SetResourceArn sets the ResourceArn field's value.

func (*TagResourceInput) SetTags 

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

SetTags sets the Tags field's value.

func (TagResourceInput) String 

func (s TagResourceInput) String() string

String returns the string representation

func (*TagResourceInput) Validate 

func (s *TagResourceInput) Validate() error

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

type TagResourceOutput 

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

func (TagResourceOutput) GoString 

func (s TagResourceOutput) GoString() string

GoString returns the string representation

func (TagResourceOutput) String 

func (s TagResourceOutput) String() string

String returns the string representation

type UntagResourceInput 

type UntagResourceInput struct {

	// The tag resource ARN of the MWAA environments.
	//
	// ResourceArn is a required field
	ResourceArn *string `location:"uri" locationName:"ResourceArn" min:"1" type:"string" required:"true"`

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

func (UntagResourceInput) GoString 

func (s UntagResourceInput) GoString() string

GoString returns the string representation

func (*UntagResourceInput) SetResourceArn 

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

SetResourceArn sets the ResourceArn field's value.

func (*UntagResourceInput) SetTagKeys 

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

SetTagKeys sets the TagKeys field's value.

func (UntagResourceInput) String 

func (s UntagResourceInput) String() string

String returns the string representation

func (*UntagResourceInput) Validate 

func (s *UntagResourceInput) Validate() error

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

type UntagResourceOutput 

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

func (UntagResourceOutput) GoString 

func (s UntagResourceOutput) GoString() string

GoString returns the string representation

func (UntagResourceOutput) String 

func (s UntagResourceOutput) String() string

String returns the string representation

type UpdateEnvironmentInput 

type UpdateEnvironmentInput struct {

	// The Airflow Configuration Options to update of your Amazon MWAA environment.
	AirflowConfigurationOptions map[string]*string `type:"map" sensitive:"true"`

	// The Airflow Version to update of your Amazon MWAA environment.
	AirflowVersion *string `min:"1" type:"string"`

	// The Dags folder S3 Path to update of your Amazon MWAA environment.
	DagS3Path *string `min:"1" type:"string"`

	// The Environment Class to update of your Amazon MWAA environment.
	EnvironmentClass *string `min:"1" type:"string"`

	// The Executio Role ARN to update of your Amazon MWAA environment.
	ExecutionRoleArn *string `min:"1" type:"string"`

	// The Logging Configuration to update of your Amazon MWAA environment.
	LoggingConfiguration *LoggingConfigurationInput `type:"structure"`

	// The Maximum Workers to update of your Amazon MWAA environment.
	MaxWorkers *int64 `min:"1" type:"integer"`

	// The name of your Amazon MWAA environment that you wish to update.
	//
	// Name is a required field
	Name *string `location:"uri" locationName:"Name" min:"1" type:"string" required:"true"`

	// The Network Configuration to update of your Amazon MWAA environment.
	NetworkConfiguration *UpdateNetworkConfigurationInput `type:"structure"`

	// The Plugins.zip S3 Object Version to update of your Amazon MWAA environment.
	PluginsS3ObjectVersion *string `min:"1" type:"string"`

	// The Plugins.zip S3 Path to update of your Amazon MWAA environment.
	PluginsS3Path *string `min:"1" type:"string"`

	// The Requirements.txt S3 ObjectV ersion to update of your Amazon MWAA environment.
	RequirementsS3ObjectVersion *string `min:"1" type:"string"`

	// The Requirements.txt S3 Path to update of your Amazon MWAA environment.
	RequirementsS3Path *string `min:"1" type:"string"`

	// The S3 Source Bucket ARN to update of your Amazon MWAA environment.
	SourceBucketArn *string `min:"1" type:"string"`

	// The Webserver Access Mode to update of your Amazon MWAA environment.
	WebserverAccessMode *string `type:"string" enum:"WebserverAccessMode"`

	// The Weekly Maintenance Window Start to update of your Amazon MWAA environment.
	WeeklyMaintenanceWindowStart *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

func (UpdateEnvironmentInput) GoString 

func (s UpdateEnvironmentInput) GoString() string

GoString returns the string representation

func (*UpdateEnvironmentInput) SetAirflowConfigurationOptions 

func (s *UpdateEnvironmentInput) SetAirflowConfigurationOptions(v map[string]*string) *UpdateEnvironmentInput

SetAirflowConfigurationOptions sets the AirflowConfigurationOptions field's value.

func (*UpdateEnvironmentInput) SetAirflowVersion 

func (s *UpdateEnvironmentInput) SetAirflowVersion(v string) *UpdateEnvironmentInput

SetAirflowVersion sets the AirflowVersion field's value.

func (*UpdateEnvironmentInput) SetDagS3Path 

func (s *UpdateEnvironmentInput) SetDagS3Path(v string) *UpdateEnvironmentInput

SetDagS3Path sets the DagS3Path field's value.

func (*UpdateEnvironmentInput) SetEnvironmentClass 

func (s *UpdateEnvironmentInput) SetEnvironmentClass(v string) *UpdateEnvironmentInput

SetEnvironmentClass sets the EnvironmentClass field's value.

func (*UpdateEnvironmentInput) SetExecutionRoleArn 

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

SetExecutionRoleArn sets the ExecutionRoleArn field's value.

func (*UpdateEnvironmentInput) SetLoggingConfiguration 

func (s *UpdateEnvironmentInput) SetLoggingConfiguration(v *LoggingConfigurationInput) *UpdateEnvironmentInput

SetLoggingConfiguration sets the LoggingConfiguration field's value.

func (*UpdateEnvironmentInput) SetMaxWorkers 

func (s *UpdateEnvironmentInput) SetMaxWorkers(v int64) *UpdateEnvironmentInput

SetMaxWorkers sets the MaxWorkers field's value.

func (*UpdateEnvironmentInput) SetName 

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

SetName sets the Name field's value.

func (*UpdateEnvironmentInput) SetNetworkConfiguration 

func (s *UpdateEnvironmentInput) SetNetworkConfiguration(v *UpdateNetworkConfigurationInput) *UpdateEnvironmentInput

SetNetworkConfiguration sets the NetworkConfiguration field's value.

func (*UpdateEnvironmentInput) SetPluginsS3ObjectVersion 

func (s *UpdateEnvironmentInput) SetPluginsS3ObjectVersion(v string) *UpdateEnvironmentInput

SetPluginsS3ObjectVersion sets the PluginsS3ObjectVersion field's value.

func (*UpdateEnvironmentInput) SetPluginsS3Path 

func (s *UpdateEnvironmentInput) SetPluginsS3Path(v string) *UpdateEnvironmentInput

SetPluginsS3Path sets the PluginsS3Path field's value.

func (*UpdateEnvironmentInput) SetRequirementsS3ObjectVersion 

func (s *UpdateEnvironmentInput) SetRequirementsS3ObjectVersion(v string) *UpdateEnvironmentInput

SetRequirementsS3ObjectVersion sets the RequirementsS3ObjectVersion field's value.

func (*UpdateEnvironmentInput) SetRequirementsS3Path 

func (s *UpdateEnvironmentInput) SetRequirementsS3Path(v string) *UpdateEnvironmentInput

SetRequirementsS3Path sets the RequirementsS3Path field's value.

func (*UpdateEnvironmentInput) SetSourceBucketArn 

func (s *UpdateEnvironmentInput) SetSourceBucketArn(v string) *UpdateEnvironmentInput

SetSourceBucketArn sets the SourceBucketArn field's value.

func (*UpdateEnvironmentInput) SetWebserverAccessMode 

func (s *UpdateEnvironmentInput) SetWebserverAccessMode(v string) *UpdateEnvironmentInput

SetWebserverAccessMode sets the WebserverAccessMode field's value.

func (*UpdateEnvironmentInput) SetWeeklyMaintenanceWindowStart 

func (s *UpdateEnvironmentInput) SetWeeklyMaintenanceWindowStart(v string) *UpdateEnvironmentInput

SetWeeklyMaintenanceWindowStart sets the WeeklyMaintenanceWindowStart field's value.

func (UpdateEnvironmentInput) String 

func (s UpdateEnvironmentInput) String() string

String returns the string representation

func (*UpdateEnvironmentInput) Validate 

func (s *UpdateEnvironmentInput) Validate() error

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

type UpdateEnvironmentOutput 

type UpdateEnvironmentOutput struct {

	// The ARN to update of your Amazon MWAA environment.
	Arn *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

func (UpdateEnvironmentOutput) GoString 

func (s UpdateEnvironmentOutput) GoString() string

GoString returns the string representation

func (*UpdateEnvironmentOutput) SetArn 

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

SetArn sets the Arn field's value.

func (UpdateEnvironmentOutput) String 

func (s UpdateEnvironmentOutput) String() string

String returns the string representation

type UpdateError 

type UpdateError struct {

	// Error code of update.
	ErrorCode *string `type:"string"`

	// Error message of update.
	ErrorMessage *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

Error information of update, if applicable.

func (UpdateError) GoString 

func (s UpdateError) GoString() string

GoString returns the string representation

func (*UpdateError) SetErrorCode 

func (s *UpdateError) SetErrorCode(v string) *UpdateError

SetErrorCode sets the ErrorCode field's value.

func (*UpdateError) SetErrorMessage 

func (s *UpdateError) SetErrorMessage(v string) *UpdateError

SetErrorMessage sets the ErrorMessage field's value.

func (UpdateError) String 

func (s UpdateError) String() string

String returns the string representation

type UpdateNetworkConfigurationInput 

type UpdateNetworkConfigurationInput struct {

	// Provide a JSON list of 1 or more security groups IDs by name, in the same
	// VPC as the subnets.
	//
	// SecurityGroupIds is a required field
	SecurityGroupIds []*string `min:"1" type:"list" required:"true"`
	// contains filtered or unexported fields
}

Provide the security group and subnet IDs for the workers and scheduler.

func (UpdateNetworkConfigurationInput) GoString 

func (s UpdateNetworkConfigurationInput) GoString() string

GoString returns the string representation

func (*UpdateNetworkConfigurationInput) SetSecurityGroupIds 

func (s *UpdateNetworkConfigurationInput) SetSecurityGroupIds(v []*string) *UpdateNetworkConfigurationInput

SetSecurityGroupIds sets the SecurityGroupIds field's value.

func (UpdateNetworkConfigurationInput) String 

func (s UpdateNetworkConfigurationInput) String() string

String returns the string representation

func (*UpdateNetworkConfigurationInput) Validate 

func (s *UpdateNetworkConfigurationInput) Validate() error

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

type ValidationException 

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

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

ValidationException: The provided input is not valid.

func (*ValidationException) Code 

func (s *ValidationException) Code() string

Code returns the exception type name.

func (*ValidationException) Error 

func (s *ValidationException) Error() string

func (ValidationException) GoString 

func (s ValidationException) GoString() string

GoString returns the string representation

func (*ValidationException) Message 

func (s *ValidationException) Message() string

Message returns the exception's message.

func (*ValidationException) OrigErr 

func (s *ValidationException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ValidationException) RequestID 

func (s *ValidationException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ValidationException) StatusCode 

func (s *ValidationException) StatusCode() int

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

func (ValidationException) String 

func (s ValidationException) String() string

String returns the string representation

Source Files

View all Source files

Directories

Path Synopsis
Package mwaaiface provides an interface to enable mocking the AmazonMWAA service client for testing your code.
 Package mwaaiface provides an interface to enable mocking the AmazonMWAA service client for testing your code.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.