mwaa

package
v1.41.3 Latest Latest
Warning

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

Go to latest
Published: Oct 12, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

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"

	// EnvironmentStatusUnavailable is a EnvironmentStatus enum value
	EnvironmentStatusUnavailable = "UNAVAILABLE"

	// EnvironmentStatusUpdateFailed is a EnvironmentStatus enum value
	EnvironmentStatusUpdateFailed = "UPDATE_FAILED"
)
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.

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

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

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

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

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

func (*CreateCliTokenInput) SetName

SetName sets the Name field's value.

func (CreateCliTokenInput) String

func (s CreateCliTokenInput) String() string

String returns the string representation.

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

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

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

func (*CreateCliTokenOutput) SetCliToken

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.

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

type CreateEnvironmentInput

type CreateEnvironmentInput struct {

	// A list of key-value pairs containing the Apache Airflow configuration options
	// you want to attach to your environment. To learn more, see Apache Airflow
	// configuration options (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-env-variables.html).
	//
	// AirflowConfigurationOptions is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by CreateEnvironmentInput's
	// String and GoString methods.
	AirflowConfigurationOptions map[string]*string `type:"map" sensitive:"true"`

	// The Apache Airflow version for your environment. For example, v1.10.12. If
	// no value is specified, defaults to the latest version. Valid values: v1.10.12.
	AirflowVersion *string `min:"1" type:"string"`

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

	// The environment class type. Valid values: mw1.small, mw1.medium, mw1.large.
	// To learn more, see Amazon MWAA environment class (https://docs.aws.amazon.com/mwaa/latest/userguide/environment-class.html).
	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.
	// To learn more, see Amazon MWAA Execution role (https://docs.aws.amazon.com/mwaa/latest/userguide/mwaa-create-role.html).
	//
	// ExecutionRoleArn is a required field
	ExecutionRoleArn *string `min:"1" type:"string" required:"true"`

	// The AWS Key Management Service (KMS) key to encrypt the data in your environment.
	// You can use an AWS owned CMK, or a Customer managed CMK (advanced). To learn
	// more, see Get started with Amazon Managed Workflows for Apache Airflow (https://docs.aws.amazon.com/mwaa/latest/userguide/get-started.html).
	KmsKey *string `min:"1" type:"string"`

	// Defines the Apache Airflow logs to send to CloudWatch Logs: DagProcessingLogs,
	// SchedulerLogs, TaskLogs, WebserverLogs, WorkerLogs.
	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 up to the number you specify
	// in the MaxWorkers field. For example, 20. When there are no more tasks running,
	// and no more in the queue, MWAA disposes of the extra workers leaving the
	// one worker that is included with your environment, or the number you specify
	// in MinWorkers.
	MaxWorkers *int64 `min:"1" type:"integer"`

	// The minimum number of workers that you want to run in your environment. MWAA
	// scales the number of Apache Airflow workers up to the number you specify
	// in the MaxWorkers field. When there are no more tasks running, and no more
	// in the queue, MWAA disposes of the extra workers leaving the worker count
	// you specify in the MinWorkers field. For example, 2.
	MinWorkers *int64 `min:"1" type:"integer"`

	// The name of the Amazon MWAA environment. For example, MyMWAAEnvironment.
	//
	// Name is a required field
	Name *string `location:"uri" locationName:"Name" min:"1" type:"string" required:"true"`

	// The VPC networking components used to secure and enable network traffic between
	// the AWS resources for your environment. To learn more, see About networking
	// on Amazon MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/networking-about.html).
	//
	// NetworkConfiguration is a required field
	NetworkConfiguration *NetworkConfiguration `type:"structure" required:"true"`

	// The version of the plugins.zip file on your Amazon S3 bucket. A version must
	// be specified each time a plugins.zip file is updated. To learn more, see
	// How S3 Versioning works (https://docs.aws.amazon.com/AmazonS3/latest/userguide/versioning-workflows.html).
	PluginsS3ObjectVersion *string `min:"1" type:"string"`

	// The relative path to the plugins.zip file on your Amazon S3 bucket. For example,
	// plugins.zip. If specified, then the plugins.zip version is required. To learn
	// more, see Installing custom plugins (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-dag-import-plugins.html).
	PluginsS3Path *string `min:"1" type:"string"`

	// The version of the requirements.txt file on your Amazon S3 bucket. A version
	// must be specified each time a requirements.txt file is updated. To learn
	// more, see How S3 Versioning works (https://docs.aws.amazon.com/AmazonS3/latest/userguide/versioning-workflows.html).
	RequirementsS3ObjectVersion *string `min:"1" type:"string"`

	// The relative path to the requirements.txt file on your Amazon S3 bucket.
	// For example, requirements.txt. If specified, then a file version is required.
	// To learn more, see Installing Python dependencies (https://docs.aws.amazon.com/mwaa/latest/userguide/working-dags-dependencies.html).
	RequirementsS3Path *string `min:"1" type:"string"`

	// The number of Apache Airflow schedulers to run in your environment.
	Schedulers *int64 `type:"integer"`

	// The Amazon Resource Name (ARN) of the Amazon S3 bucket where your DAG code
	// and supporting files are stored. For example, arn:aws:s3:::my-airflow-bucket-unique-name.
	// To learn more, see Create an Amazon S3 bucket for Amazon MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/mwaa-s3-bucket.html).
	//
	// SourceBucketArn is a required field
	SourceBucketArn *string `min:"1" type:"string" required:"true"`

	// The key-value tag pairs you want to associate to your environment. For example,
	// "Environment": "Staging". To learn more, see Tagging AWS resources (https://docs.aws.amazon.com/general/latest/gr/aws_tagging.html).
	Tags map[string]*string `min:"1" type:"map"`

	// The Apache Airflow Web server access mode. To learn more, see Apache Airflow
	// access modes (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-networking.html).
	WebserverAccessMode *string `type:"string" enum:"WebserverAccessMode"`

	// The day and time of the week to start weekly maintenance updates of your
	// environment in the following format: DAY:HH:MM. For example: TUE:03:30. You
	// can specify a start time in 30 minute increments only. Supported input includes
	// the following:
	//
	//    * MON|TUE|WED|THU|FRI|SAT|SUN:([01]\\d|2[0-3]):(00|30)
	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.

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

func (*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

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

SetKmsKey sets the KmsKey field's value.

func (*CreateEnvironmentInput) SetLoggingConfiguration

SetLoggingConfiguration sets the LoggingConfiguration field's value.

func (*CreateEnvironmentInput) SetMaxWorkers

SetMaxWorkers sets the MaxWorkers field's value.

func (*CreateEnvironmentInput) SetMinWorkers

SetMinWorkers sets the MinWorkers field's value.

func (*CreateEnvironmentInput) SetName

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

SetSchedulers sets the Schedulers field's value.

func (*CreateEnvironmentInput) SetSourceBucketArn

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

SetSourceBucketArn sets the SourceBucketArn field's value.

func (*CreateEnvironmentInput) SetTags

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.

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

func (*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 Amazon Resource Name (ARN) returned in the response for the environment.
	Arn *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

func (CreateEnvironmentOutput) GoString

func (s CreateEnvironmentOutput) GoString() string

GoString returns the string representation.

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

func (*CreateEnvironmentOutput) SetArn

SetArn sets the Arn field's value.

func (CreateEnvironmentOutput) String

func (s CreateEnvironmentOutput) String() string

String returns the string representation.

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

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

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

func (*CreateWebLoginTokenInput) SetName

SetName sets the Name field's value.

func (CreateWebLoginTokenInput) String

func (s CreateWebLoginTokenInput) String() string

String returns the string representation.

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

func (*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 is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by CreateWebLoginTokenOutput's
	// String and GoString methods.
	WebToken *string `type:"string" sensitive:"true"`
	// contains filtered or unexported fields
}

func (CreateWebLoginTokenOutput) GoString

func (s CreateWebLoginTokenOutput) GoString() string

GoString returns the string representation.

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

func (*CreateWebLoginTokenOutput) SetWebServerHostname

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

SetWebServerHostname sets the WebServerHostname field's value.

func (*CreateWebLoginTokenOutput) SetWebToken

SetWebToken sets the WebToken field's value.

func (CreateWebLoginTokenOutput) String

func (s CreateWebLoginTokenOutput) String() string

String returns the string representation.

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

type DeleteEnvironmentInput

type DeleteEnvironmentInput struct {

	// The name of the Amazon MWAA environment. For example, MyMWAAEnvironment.
	//
	// 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.

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

func (*DeleteEnvironmentInput) SetName

SetName sets the Name field's value.

func (DeleteEnvironmentInput) String

func (s DeleteEnvironmentInput) String() string

String returns the string representation.

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

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

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

func (DeleteEnvironmentOutput) String

func (s DeleteEnvironmentOutput) String() string

String returns the string representation.

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

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

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

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

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

func (*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 {

	// A list of key-value pairs containing the Apache Airflow configuration options
	// attached to your environment. To learn more, see Apache Airflow configuration
	// options (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-env-variables.html).
	AirflowConfigurationOptions map[string]*string `type:"map"`

	// The Apache Airflow version on your environment. For example, v1.10.12.
	AirflowVersion *string `min:"1" type:"string"`

	// The Amazon Resource Name (ARN) of the Amazon MWAA environment.
	Arn *string `min:"1" type:"string"`

	// The day and time the environment was created.
	CreatedAt *time.Time `type:"timestamp"`

	// The relative path to the DAGs folder on your Amazon S3 bucket. For example,
	// dags. To learn more, see Adding or updating DAGs (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-dag-folder.html).
	DagS3Path *string `min:"1" type:"string"`

	// The environment class type. Valid values: mw1.small, mw1.medium, mw1.large.
	// To learn more, see Amazon MWAA environment class (https://docs.aws.amazon.com/mwaa/latest/userguide/environment-class.html).
	EnvironmentClass *string `min:"1" type:"string"`

	// The Amazon Resource Name (ARN) of the execution role in IAM that allows MWAA
	// to access AWS resources in your environment. For example, arn:aws:iam::123456789:role/my-execution-role.
	// To learn more, see Amazon MWAA Execution role (https://docs.aws.amazon.com/mwaa/latest/userguide/mwaa-create-role.html).
	ExecutionRoleArn *string `min:"1" type:"string"`

	// The Key Management Service (KMS) encryption key used to encrypt the data
	// in your environment.
	KmsKey *string `min:"1" type:"string"`

	// The status of the last update on the environment, and any errors that were
	// encountered.
	LastUpdate *LastUpdate `type:"structure"`

	// The Apache Airflow logs being sent to CloudWatch Logs: DagProcessingLogs,
	// SchedulerLogs, TaskLogs, WebserverLogs, WorkerLogs.
	LoggingConfiguration *LoggingConfiguration `type:"structure"`

	// The maximum number of workers that run in your environment. For example,
	// 20.
	MaxWorkers *int64 `min:"1" type:"integer"`

	// The minimum number of workers that run in your environment. For example,
	// 2.
	MinWorkers *int64 `min:"1" type:"integer"`

	// The name of the Amazon MWAA environment. For example, MyMWAAEnvironment.
	Name *string `min:"1" type:"string"`

	// The VPC networking components used to secure and enable network traffic between
	// the AWS resources for your environment. To learn more, see About networking
	// on Amazon MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/networking-about.html).
	NetworkConfiguration *NetworkConfiguration `type:"structure"`

	// The version of the plugins.zip file on your Amazon S3 bucket. To learn more,
	// see Installing custom plugins (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-dag-import-plugins.html).
	PluginsS3ObjectVersion *string `min:"1" type:"string"`

	// The relative path to the plugins.zip file on your Amazon S3 bucket. For example,
	// plugins.zip. To learn more, see Installing custom plugins (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-dag-import-plugins.html).
	PluginsS3Path *string `min:"1" type:"string"`

	// The version of the requirements.txt file on your Amazon S3 bucket. To learn
	// more, see Installing Python dependencies (https://docs.aws.amazon.com/mwaa/latest/userguide/working-dags-dependencies.html).
	RequirementsS3ObjectVersion *string `min:"1" type:"string"`

	// The relative path to the requirements.txt file on your Amazon S3 bucket.
	// For example, requirements.txt. To learn more, see Installing Python dependencies
	// (https://docs.aws.amazon.com/mwaa/latest/userguide/working-dags-dependencies.html).
	RequirementsS3Path *string `min:"1" type:"string"`

	// The number of Apache Airflow schedulers that run in your Amazon MWAA environment.
	Schedulers *int64 `type:"integer"`

	// The Amazon Resource Name (ARN) for the service-linked role of the environment.
	// To learn more, see Amazon MWAA Service-linked role (https://docs.aws.amazon.com/mwaa/latest/userguide/mwaa-slr.html).
	ServiceRoleArn *string `min:"1" type:"string"`

	// The Amazon Resource Name (ARN) of the Amazon S3 bucket where your DAG code
	// and supporting files are stored. For example, arn:aws:s3:::my-airflow-bucket-unique-name.
	// To learn more, see Create an Amazon S3 bucket for Amazon MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/mwaa-s3-bucket.html).
	SourceBucketArn *string `min:"1" type:"string"`

	// The status of the Amazon MWAA environment. Valid values:
	//
	//    * CREATING - Indicates the request to create the environment is in progress.
	//
	//    * CREATE_FAILED - Indicates the request to create the environment failed,
	//    and the environment could not be created.
	//
	//    * AVAILABLE - Indicates the request was successful and the environment
	//    is ready to use.
	//
	//    * UPDATING - Indicates the request to update the environment is in progress.
	//
	//    * DELETING - Indicates the request to delete the environment is in progress.
	//
	//    * DELETED - Indicates the request to delete the environment is complete,
	//    and the environment has been deleted.
	//
	//    * UNAVAILABLE - Indicates the request failed, but the environment was
	//    unable to rollback and is not in a stable state.
	//
	//    * UPDATE_FAILED - Indicates the request to update the environment failed,
	//    and the environment has rolled back successfully and is ready to use.
	//
	// We recommend reviewing our troubleshooting guide for a list of common errors
	// and their solutions. To learn more, see Amazon MWAA troubleshooting (https://docs.aws.amazon.com/mwaa/latest/userguide/troubleshooting.html).
	Status *string `type:"string" enum:"EnvironmentStatus"`

	// The key-value tag pairs associated to your environment. For example, "Environment":
	// "Staging". To learn more, see Tagging AWS resources (https://docs.aws.amazon.com/general/latest/gr/aws_tagging.html).
	Tags map[string]*string `min:"1" type:"map"`

	// The Apache Airflow Web server access mode. To learn more, see Apache Airflow
	// access modes (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-networking.html).
	WebserverAccessMode *string `type:"string" enum:"WebserverAccessMode"`

	// The Apache Airflow Web server host name for the Amazon MWAA environment.
	// To learn more, see Accessing the Apache Airflow UI (https://docs.aws.amazon.com/mwaa/latest/userguide/access-airflow-ui.html).
	WebserverUrl *string `min:"1" type:"string"`

	// The day and time of the week that weekly maintenance updates are scheduled.
	// For example: TUE:03:30.
	WeeklyMaintenanceWindowStart *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

The Amazon Managed Workflows for Apache Airflow (MWAA) environment.

func (Environment) GoString

func (s Environment) GoString() string

GoString returns the string representation.

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

func (*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) SetMinWorkers

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

SetMinWorkers sets the MinWorkers 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) SetSchedulers

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

SetSchedulers sets the Schedulers 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.

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

type GetEnvironmentInput

type GetEnvironmentInput struct {

	// The name of the Amazon MWAA environment. For example, MyMWAAEnvironment.
	//
	// 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.

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

func (*GetEnvironmentInput) SetName

SetName sets the Name field's value.

func (GetEnvironmentInput) String

func (s GetEnvironmentInput) String() string

String returns the string representation.

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

func (*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 {

	// An object containing all available details about the environment.
	Environment *Environment `type:"structure"`
	// contains filtered or unexported fields
}

func (GetEnvironmentOutput) GoString

func (s GetEnvironmentOutput) GoString() string

GoString returns the string representation.

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

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

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

type InternalServerException

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

	Message_ *string `locationName:"message" 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.

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

func (*InternalServerException) Message

func (s *InternalServerException) Message() string

Message returns the exception's message.

func (*InternalServerException) OrigErr

func (s *InternalServerException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*InternalServerException) RequestID

func (s *InternalServerException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*InternalServerException) StatusCode

func (s *InternalServerException) StatusCode() int

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

func (InternalServerException) String

func (s InternalServerException) String() string

String returns the string representation.

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

type LastUpdate

type LastUpdate struct {

	// The day and time of the last update on the environment.
	CreatedAt *time.Time `type:"timestamp"`

	// The error that was encountered during the last update of the environment.
	Error *UpdateError `type:"structure"`

	// The status of the last update on the environment. Valid values: SUCCESS,
	// PENDING, FAILED.
	Status *string `type:"string" enum:"UpdateStatus"`
	// contains filtered or unexported fields
}

The status of the last update on the environment, and any errors that were encountered.

func (LastUpdate) GoString

func (s LastUpdate) GoString() string

GoString returns the string representation.

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

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

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

type ListEnvironmentsInput

type ListEnvironmentsInput struct {

	// The maximum number of results to retrieve per page. For example, 5 environments
	// per page.
	MaxResults *int64 `location:"querystring" locationName:"MaxResults" min:"1" type:"integer"`

	// Retrieves the next page of the results.
	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.

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

func (*ListEnvironmentsInput) SetMaxResults

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

SetMaxResults sets the MaxResults field's value.

func (*ListEnvironmentsInput) SetNextToken

SetNextToken sets the NextToken field's value.

func (ListEnvironmentsInput) String

func (s ListEnvironmentsInput) String() string

String returns the string representation.

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

func (*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 {

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

	// Retrieves the next page of the results.
	NextToken *string `type:"string"`
	// contains filtered or unexported fields
}

func (ListEnvironmentsOutput) GoString

func (s ListEnvironmentsOutput) GoString() string

GoString returns the string representation.

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

func (*ListEnvironmentsOutput) SetEnvironments

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

SetEnvironments sets the Environments field's value.

func (*ListEnvironmentsOutput) SetNextToken

SetNextToken sets the NextToken field's value.

func (ListEnvironmentsOutput) String

func (s ListEnvironmentsOutput) String() string

String returns the string representation.

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

type ListTagsForResourceInput

type ListTagsForResourceInput struct {

	// The Amazon Resource Name (ARN) of the Amazon MWAA environment. For example,
	// arn:aws:airflow:us-east-1:123456789012:environment/MyMWAAEnvironment.
	//
	// 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.

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

func (*ListTagsForResourceInput) SetResourceArn

SetResourceArn sets the ResourceArn field's value.

func (ListTagsForResourceInput) String

func (s ListTagsForResourceInput) String() string

String returns the string representation.

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

func (*ListTagsForResourceInput) Validate

func (s *ListTagsForResourceInput) Validate() error

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

type ListTagsForResourceOutput

type ListTagsForResourceOutput struct {

	// The key-value tag pairs associated to your environment. To learn more, see
	// Tagging AWS resources (https://docs.aws.amazon.com/general/latest/gr/aws_tagging.html).
	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.

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

func (*ListTagsForResourceOutput) SetTags

SetTags sets the Tags field's value.

func (ListTagsForResourceOutput) String

func (s ListTagsForResourceOutput) String() string

String returns the string representation.

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

type LoggingConfiguration

type LoggingConfiguration struct {

	// Defines the type of logs to send for the Apache Airflow log type (e.g. DagProcessingLogs).
	// Valid values: CloudWatchLogGroupArn, Enabled, LogLevel.
	DagProcessingLogs *ModuleLoggingConfiguration `type:"structure"`

	// Defines the type of logs to send for the Apache Airflow log type (e.g. DagProcessingLogs).
	// Valid values: CloudWatchLogGroupArn, Enabled, LogLevel.
	SchedulerLogs *ModuleLoggingConfiguration `type:"structure"`

	// Defines the type of logs to send for the Apache Airflow log type (e.g. DagProcessingLogs).
	// Valid values: CloudWatchLogGroupArn, Enabled, LogLevel.
	TaskLogs *ModuleLoggingConfiguration `type:"structure"`

	// Defines the type of logs to send for the Apache Airflow log type (e.g. DagProcessingLogs).
	// Valid values: CloudWatchLogGroupArn, Enabled, LogLevel.
	WebserverLogs *ModuleLoggingConfiguration `type:"structure"`

	// Defines the type of logs to send for the Apache Airflow log type (e.g. DagProcessingLogs).
	// Valid values: CloudWatchLogGroupArn, Enabled, LogLevel.
	WorkerLogs *ModuleLoggingConfiguration `type:"structure"`
	// contains filtered or unexported fields
}

Defines the Apache Airflow logs to send to CloudWatch Logs: DagProcessingLogs, SchedulerLogs, TaskLogs, WebserverLogs, WorkerLogs.

func (LoggingConfiguration) GoString

func (s LoggingConfiguration) GoString() string

GoString returns the string representation.

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

func (*LoggingConfiguration) SetDagProcessingLogs

SetDagProcessingLogs sets the DagProcessingLogs field's value.

func (*LoggingConfiguration) SetSchedulerLogs

SetSchedulerLogs sets the SchedulerLogs field's value.

func (*LoggingConfiguration) SetTaskLogs

SetTaskLogs sets the TaskLogs field's value.

func (*LoggingConfiguration) SetWebserverLogs

SetWebserverLogs sets the WebserverLogs field's value.

func (*LoggingConfiguration) SetWorkerLogs

SetWorkerLogs sets the WorkerLogs field's value.

func (LoggingConfiguration) String

func (s LoggingConfiguration) String() string

String returns the string representation.

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

type LoggingConfigurationInput

type LoggingConfigurationInput struct {

	// Defines the type of logs to send for the Apache Airflow log type (e.g. DagProcessingLogs).
	// Valid values: CloudWatchLogGroupArn, Enabled, LogLevel.
	DagProcessingLogs *ModuleLoggingConfigurationInput `type:"structure"`

	// Defines the type of logs to send for the Apache Airflow log type (e.g. DagProcessingLogs).
	// Valid values: CloudWatchLogGroupArn, Enabled, LogLevel.
	SchedulerLogs *ModuleLoggingConfigurationInput `type:"structure"`

	// Defines the type of logs to send for the Apache Airflow log type (e.g. DagProcessingLogs).
	// Valid values: CloudWatchLogGroupArn, Enabled, LogLevel.
	TaskLogs *ModuleLoggingConfigurationInput `type:"structure"`

	// Defines the type of logs to send for the Apache Airflow log type (e.g. DagProcessingLogs).
	// Valid values: CloudWatchLogGroupArn, Enabled, LogLevel.
	WebserverLogs *ModuleLoggingConfigurationInput `type:"structure"`

	// Defines the type of logs to send for the Apache Airflow log type (e.g. DagProcessingLogs).
	// Valid values: CloudWatchLogGroupArn, Enabled, LogLevel.
	WorkerLogs *ModuleLoggingConfigurationInput `type:"structure"`
	// contains filtered or unexported fields
}

Defines the Apache Airflow logs to send to CloudWatch Logs: DagProcessingLogs, SchedulerLogs, TaskLogs, WebserverLogs, WorkerLogs.

func (LoggingConfigurationInput) GoString

func (s LoggingConfigurationInput) GoString() string

GoString returns the string representation.

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

func (*LoggingConfigurationInput) SetDagProcessingLogs

SetDagProcessingLogs sets the DagProcessingLogs field's value.

func (*LoggingConfigurationInput) SetSchedulerLogs

SetSchedulerLogs sets the SchedulerLogs field's value.

func (*LoggingConfigurationInput) SetTaskLogs

SetTaskLogs sets the TaskLogs field's value.

func (*LoggingConfigurationInput) SetWebserverLogs

SetWebserverLogs sets the WebserverLogs field's value.

func (*LoggingConfigurationInput) SetWorkerLogs

SetWorkerLogs sets the WorkerLogs field's value.

func (LoggingConfigurationInput) String

func (s LoggingConfigurationInput) String() string

String returns the string representation.

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

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

Creates an Amazon Managed Workflows for Apache Airflow (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 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.

Deletes an Amazon Managed Workflows for Apache Airflow (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 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.

Retrieves the details of an Amazon Managed Workflows for Apache Airflow (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 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.

Lists the Amazon Managed Workflows for Apache Airflow (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.

Lists the key-value tag pairs associated to the Amazon Managed Workflows for Apache Airflow (MWAA) environment. For example, "Environment": "Staging".

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.

Associates key-value tag pairs to your Amazon Managed Workflows for Apache Airflow (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 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.

Removes key-value tag pairs associated to your Amazon Managed Workflows for Apache Airflow (MWAA) environment. For example, "Environment": "Staging".

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.

Updates an Amazon Managed Workflows for Apache Airflow (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.

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

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

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

func (*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 {

	// The Amazon Resource Name (ARN) for the CloudWatch Logs group where the Apache
	// Airflow log type (e.g. DagProcessingLogs) is published. For example, arn:aws:logs:us-east-1:123456789012:log-group:airflow-MyMWAAEnvironment-MwaaEnvironment-DAGProcessing:*.
	CloudWatchLogGroupArn *string `min:"1" type:"string"`

	// Indicates whether to enable the Apache Airflow log type (e.g. DagProcessingLogs)
	// in CloudWatch Logs.
	Enabled *bool `type:"boolean"`

	// Defines the Apache Airflow logs to send for the log type (e.g. DagProcessingLogs)
	// to CloudWatch Logs. Valid values: CRITICAL, ERROR, WARNING, INFO.
	LogLevel *string `type:"string" enum:"LoggingLevel"`
	// contains filtered or unexported fields
}

Defines the type of logs to send for the Apache Airflow log type (e.g. DagProcessingLogs). Valid values: CloudWatchLogGroupArn, Enabled, LogLevel.

func (ModuleLoggingConfiguration) GoString

func (s ModuleLoggingConfiguration) GoString() string

GoString returns the string representation.

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

func (*ModuleLoggingConfiguration) SetCloudWatchLogGroupArn

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

SetCloudWatchLogGroupArn sets the CloudWatchLogGroupArn field's value.

func (*ModuleLoggingConfiguration) SetEnabled

SetEnabled sets the Enabled field's value.

func (*ModuleLoggingConfiguration) SetLogLevel

SetLogLevel sets the LogLevel field's value.

func (ModuleLoggingConfiguration) String

String returns the string representation.

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

type ModuleLoggingConfigurationInput

type ModuleLoggingConfigurationInput struct {

	// Indicates whether to enable the Apache Airflow log type (e.g. DagProcessingLogs)
	// in CloudWatch Logs.
	//
	// Enabled is a required field
	Enabled *bool `type:"boolean" required:"true"`

	// Defines the Apache Airflow logs to send for the log type (e.g. DagProcessingLogs)
	// to CloudWatch Logs. Valid values: CRITICAL, ERROR, WARNING, INFO.
	//
	// LogLevel is a required field
	LogLevel *string `type:"string" required:"true" enum:"LoggingLevel"`
	// contains filtered or unexported fields
}

Defines the type of logs to send for the Apache Airflow log type (e.g. DagProcessingLogs). Valid values: CloudWatchLogGroupArn, Enabled, LogLevel.

func (ModuleLoggingConfigurationInput) GoString

GoString returns the string representation.

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

func (*ModuleLoggingConfigurationInput) SetEnabled

SetEnabled sets the Enabled field's value.

func (*ModuleLoggingConfigurationInput) SetLogLevel

SetLogLevel sets the LogLevel field's value.

func (ModuleLoggingConfigurationInput) String

String returns the string representation.

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

func (*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 list of 1 or more security group IDs. Accepts up to 5 security group IDs.
	// A security group must be attached to the same VPC as the subnets. To learn
	// more, see Security in your VPC on Amazon MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/vpc-security.html).
	SecurityGroupIds []*string `min:"1" type:"list"`

	// A list of 2 subnet IDs. Required to create an environment. Must be private
	// subnets in two different availability zones. A subnet must be attached to
	// the same VPC as the security group.
	SubnetIds []*string `min:"2" type:"list"`
	// contains filtered or unexported fields
}

The VPC networking components used to secure and enable network traffic between the AWS resources for your environment. To learn more, see About networking on Amazon MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/networking-about.html).

func (NetworkConfiguration) GoString

func (s NetworkConfiguration) GoString() string

GoString returns the string representation.

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

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

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

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

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

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

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

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

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

func (PublishMetricsOutput) String

func (s PublishMetricsOutput) String() string

String returns the string representation.

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

type 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

Code returns the exception type name.

func (*ResourceNotFoundException) Error

func (s *ResourceNotFoundException) Error() string

func (ResourceNotFoundException) GoString

func (s ResourceNotFoundException) GoString() string

GoString returns the string representation.

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

func (*ResourceNotFoundException) Message

func (s *ResourceNotFoundException) Message() string

Message returns the exception's message.

func (*ResourceNotFoundException) OrigErr

func (s *ResourceNotFoundException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ResourceNotFoundException) RequestID

func (s *ResourceNotFoundException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ResourceNotFoundException) StatusCode

func (s *ResourceNotFoundException) StatusCode() int

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

func (ResourceNotFoundException) String

func (s ResourceNotFoundException) String() string

String returns the string representation.

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

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

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

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

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

type TagResourceInput

type TagResourceInput struct {

	// The Amazon Resource Name (ARN) of the Amazon MWAA environment. For example,
	// arn:aws:airflow:us-east-1:123456789012:environment/MyMWAAEnvironment.
	//
	// ResourceArn is a required field
	ResourceArn *string `location:"uri" locationName:"ResourceArn" min:"1" type:"string" required:"true"`

	// The key-value tag pairs you want to associate to your environment. For example,
	// "Environment": "Staging". To learn more, see Tagging AWS resources (https://docs.aws.amazon.com/general/latest/gr/aws_tagging.html).
	//
	// 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.

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

func (*TagResourceInput) SetResourceArn

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

SetResourceArn sets the ResourceArn field's value.

func (*TagResourceInput) SetTags

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

SetTags sets the Tags field's value.

func (TagResourceInput) String

func (s TagResourceInput) String() string

String returns the string representation.

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

func (*TagResourceInput) Validate

func (s *TagResourceInput) Validate() error

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

type TagResourceOutput

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

func (TagResourceOutput) GoString

func (s TagResourceOutput) GoString() string

GoString returns the string representation.

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

func (TagResourceOutput) String

func (s TagResourceOutput) String() string

String returns the string representation.

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

type UntagResourceInput

type UntagResourceInput struct {

	// The Amazon Resource Name (ARN) of the Amazon MWAA environment. For example,
	// arn:aws:airflow:us-east-1:123456789012:environment/MyMWAAEnvironment.
	//
	// ResourceArn is a required field
	ResourceArn *string `location:"uri" locationName:"ResourceArn" min:"1" type:"string" required:"true"`

	// The key-value tag pair you want to remove. For example, "Environment": "Staging".
	//
	// TagKeys is a required field
	TagKeys []*string `location:"querystring" locationName:"tagKeys" type:"list" required:"true"`
	// contains filtered or unexported fields
}

func (UntagResourceInput) GoString

func (s UntagResourceInput) GoString() string

GoString returns the string representation.

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

func (*UntagResourceInput) SetResourceArn

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

SetResourceArn sets the ResourceArn field's value.

func (*UntagResourceInput) SetTagKeys

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

SetTagKeys sets the TagKeys field's value.

func (UntagResourceInput) String

func (s UntagResourceInput) String() string

String returns the string representation.

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

func (*UntagResourceInput) Validate

func (s *UntagResourceInput) Validate() error

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

type UntagResourceOutput

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

func (UntagResourceOutput) GoString

func (s UntagResourceOutput) GoString() string

GoString returns the string representation.

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

func (UntagResourceOutput) String

func (s UntagResourceOutput) String() string

String returns the string representation.

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

type UpdateEnvironmentInput

type UpdateEnvironmentInput struct {

	// A list of key-value pairs containing the Apache Airflow configuration options
	// you want to attach to your environment. To learn more, see Apache Airflow
	// configuration options (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-env-variables.html).
	//
	// AirflowConfigurationOptions is a sensitive parameter and its value will be
	// replaced with "sensitive" in string returned by UpdateEnvironmentInput's
	// String and GoString methods.
	AirflowConfigurationOptions map[string]*string `type:"map" sensitive:"true"`

	// The Apache Airflow version for your environment. For example, v1.10.12. If
	// no value is specified, defaults to the latest version. Valid values: v1.10.12.
	AirflowVersion *string `min:"1" type:"string"`

	// The relative path to the DAGs folder on your Amazon S3 bucket. For example,
	// dags. To learn more, see Adding or updating DAGs (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-dag-folder.html).
	DagS3Path *string `min:"1" type:"string"`

	// The environment class type. Valid values: mw1.small, mw1.medium, mw1.large.
	// To learn more, see Amazon MWAA environment class (https://docs.aws.amazon.com/mwaa/latest/userguide/environment-class.html).
	EnvironmentClass *string `min:"1" type:"string"`

	// The Amazon Resource Name (ARN) of the execution role in IAM that allows MWAA
	// to access AWS resources in your environment. For example, arn:aws:iam::123456789:role/my-execution-role.
	// To learn more, see Amazon MWAA Execution role (https://docs.aws.amazon.com/mwaa/latest/userguide/mwaa-create-role.html).
	ExecutionRoleArn *string `min:"1" type:"string"`

	// Defines the Apache Airflow logs to send to CloudWatch Logs: DagProcessingLogs,
	// SchedulerLogs, TaskLogs, WebserverLogs, WorkerLogs.
	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 up to the number you specify
	// in the MaxWorkers field. For example, 20. When there are no more tasks running,
	// and no more in the queue, MWAA disposes of the extra workers leaving the
	// one worker that is included with your environment, or the number you specify
	// in MinWorkers.
	MaxWorkers *int64 `min:"1" type:"integer"`

	// The minimum number of workers that you want to run in your environment. MWAA
	// scales the number of Apache Airflow workers up to the number you specify
	// in the MaxWorkers field. When there are no more tasks running, and no more
	// in the queue, MWAA disposes of the extra workers leaving the worker count
	// you specify in the MinWorkers field. For example, 2.
	MinWorkers *int64 `min:"1" type:"integer"`

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

	// The VPC networking components used to secure and enable network traffic between
	// the AWS resources for your environment. To learn more, see About networking
	// on Amazon MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/networking-about.html).
	NetworkConfiguration *UpdateNetworkConfigurationInput `type:"structure"`

	// The version of the plugins.zip file on your Amazon S3 bucket. A version must
	// be specified each time a plugins.zip file is updated. To learn more, see
	// How S3 Versioning works (https://docs.aws.amazon.com/AmazonS3/latest/userguide/versioning-workflows.html).
	PluginsS3ObjectVersion *string `min:"1" type:"string"`

	// The relative path to the plugins.zip file on your Amazon S3 bucket. For example,
	// plugins.zip. If specified, then the plugins.zip version is required. To learn
	// more, see Installing custom plugins (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-dag-import-plugins.html).
	PluginsS3Path *string `min:"1" type:"string"`

	// The version of the requirements.txt file on your Amazon S3 bucket. A version
	// must be specified each time a requirements.txt file is updated. To learn
	// more, see How S3 Versioning works (https://docs.aws.amazon.com/AmazonS3/latest/userguide/versioning-workflows.html).
	RequirementsS3ObjectVersion *string `min:"1" type:"string"`

	// The relative path to the requirements.txt file on your Amazon S3 bucket.
	// For example, requirements.txt. If specified, then a file version is required.
	// To learn more, see Installing Python dependencies (https://docs.aws.amazon.com/mwaa/latest/userguide/working-dags-dependencies.html).
	RequirementsS3Path *string `min:"1" type:"string"`

	// The number of Apache Airflow schedulers to run in your Amazon MWAA environment.
	Schedulers *int64 `type:"integer"`

	// The Amazon Resource Name (ARN) of the Amazon S3 bucket where your DAG code
	// and supporting files are stored. For example, arn:aws:s3:::my-airflow-bucket-unique-name.
	// To learn more, see Create an Amazon S3 bucket for Amazon MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/mwaa-s3-bucket.html).
	SourceBucketArn *string `min:"1" type:"string"`

	// The Apache Airflow Web server access mode. To learn more, see Apache Airflow
	// access modes (https://docs.aws.amazon.com/mwaa/latest/userguide/configuring-networking.html).
	WebserverAccessMode *string `type:"string" enum:"WebserverAccessMode"`

	// The day and time of the week to start weekly maintenance updates of your
	// environment in the following format: DAY:HH:MM. For example: TUE:03:30. You
	// can specify a start time in 30 minute increments only. Supported input includes
	// the following:
	//
	//    * MON|TUE|WED|THU|FRI|SAT|SUN:([01]\\d|2[0-3]):(00|30)
	WeeklyMaintenanceWindowStart *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

func (UpdateEnvironmentInput) GoString

func (s UpdateEnvironmentInput) GoString() string

GoString returns the string representation.

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

func (*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

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

SetLoggingConfiguration sets the LoggingConfiguration field's value.

func (*UpdateEnvironmentInput) SetMaxWorkers

SetMaxWorkers sets the MaxWorkers field's value.

func (*UpdateEnvironmentInput) SetMinWorkers

SetMinWorkers sets the MinWorkers field's value.

func (*UpdateEnvironmentInput) SetName

SetName sets the Name field's value.

func (*UpdateEnvironmentInput) SetNetworkConfiguration

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

SetSchedulers sets the Schedulers 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.

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

func (*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 Amazon Resource Name (ARN) of the Amazon MWAA environment. For example,
	// arn:aws:airflow:us-east-1:123456789012:environment/MyMWAAEnvironment.
	Arn *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

func (UpdateEnvironmentOutput) GoString

func (s UpdateEnvironmentOutput) GoString() string

GoString returns the string representation.

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

func (*UpdateEnvironmentOutput) SetArn

SetArn sets the Arn field's value.

func (UpdateEnvironmentOutput) String

func (s UpdateEnvironmentOutput) String() string

String returns the string representation.

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

type UpdateError

type UpdateError struct {

	// The error code that corresponds to the error with the last update.
	ErrorCode *string `type:"string"`

	// The error message that corresponds to the error code.
	ErrorMessage *string `min:"1" type:"string"`
	// contains filtered or unexported fields
}

An object containing the error encountered with the last update: ErrorCode, ErrorMessage.

func (UpdateError) GoString

func (s UpdateError) GoString() string

GoString returns the string representation.

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

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

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

type UpdateNetworkConfigurationInput

type UpdateNetworkConfigurationInput struct {

	// A list of 1 or more security group IDs. Accepts up to 5 security group IDs.
	// A security group must be attached to the same VPC as the subnets. To learn
	// more, see Security in your VPC on Amazon MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/vpc-security.html).
	//
	// SecurityGroupIds is a required field
	SecurityGroupIds []*string `min:"1" type:"list" required:"true"`
	// contains filtered or unexported fields
}

The VPC networking components used to secure and enable network traffic between the AWS resources for your environment. To learn more, see About networking on Amazon MWAA (https://docs.aws.amazon.com/mwaa/latest/userguide/networking-about.html).

func (UpdateNetworkConfigurationInput) GoString

GoString returns the string representation.

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

func (*UpdateNetworkConfigurationInput) SetSecurityGroupIds

SetSecurityGroupIds sets the SecurityGroupIds field's value.

func (UpdateNetworkConfigurationInput) String

String returns the string representation.

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

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

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

func (*ValidationException) Message

func (s *ValidationException) Message() string

Message returns the exception's message.

func (*ValidationException) OrigErr

func (s *ValidationException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ValidationException) RequestID

func (s *ValidationException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ValidationException) StatusCode

func (s *ValidationException) StatusCode() int

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

func (ValidationException) String

func (s ValidationException) String() string

String returns the string representation.

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

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