v1alpha1

package
v0.41.0 Latest Latest
Warning

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

 Go to latest Published: Jun 16, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// ConnectionDetailsCLITokenKey for cli token
	ConnectionDetailsCLITokenKey string = "cliToken"
	// ConnectionDetailsWebTokenKey for web token
	ConnectionDetailsWebTokenKey string = "webToken"
	// ConnectionDetailsWebServerURL for web server URL
	ConnectionDetailsWebServerURL string = "webServerURL"
)
View Source 
const (
	CRDGroup   = "mwaa.aws.crossplane.io"
	CRDVersion = "v1alpha1"
)

Package type metadata.

Variables

View Source 
var (
	EnvironmentKind             = "Environment"
	EnvironmentGroupKind        = schema.GroupKind{Group: CRDGroup, Kind: EnvironmentKind}.String()
	EnvironmentKindAPIVersion   = EnvironmentKind + "." + GroupVersion.String()
	EnvironmentGroupVersionKind = GroupVersion.WithKind(EnvironmentKind)
)

Repository type metadata.

View Source 
var (
	// GroupVersion is the API Group Version used to register the objects
	GroupVersion = schema.GroupVersion{Group: CRDGroup, Version: CRDVersion}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

This section is empty.

Types

type CustomEnvironmentParameters 

type CustomEnvironmentParameters struct {
	// 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).
	//
	// This field or KMSKeyRef or KMSKeySelector is required.
	// +optional
	// +immutable
	// +crossplane:generate:reference:type=github.com/crossplane-contrib/provider-aws/apis/kms/v1alpha1.Key
	KMSKey *string `json:"kmsKey,omitempty"`

	// KMSKeyRef is a reference to the KMSKey used to set.
	// the SubnetIDs.
	// +optional
	KMSKeyRef *xpv1.Reference `json:"kmsKeyRef,omitempty"`

	// KMSKeySelector selects the reference to the KMSKey.
	// +optional
	KMSKeySelector *xpv1.Selector `json:"kmsKeySelector,omitempty"`

	// 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).
	//
	// This field or SourceBucketARNRef or SourceBucketARNSelector is required.
	// +optional
	// +crossplane:generate:reference:type=github.com/crossplane-contrib/provider-aws/apis/s3/v1beta1.Bucket
	// +crossplane:generate:reference:extractor=github.com/crossplane-contrib/provider-aws/apis/s3/v1beta1.BucketARN()
	SourceBucketARN *string `json:"sourceBucketARN"`

	// SourceBucketARNRef is a reference to the SourceBucketARN used to set.
	// the SubnetIDs.
	// +optional
	SourceBucketARNRef *xpv1.Reference `json:"sourceBucketARNRef,omitempty"`

	// SourceBucketARNSelector selects the reference to the SourceBucketARN.
	// +optional
	SourceBucketARNSelector *xpv1.Selector `json:"sourceBucketARNSelector,omitempty"`

	// 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).
	//
	// This field or SourceBucketARNRef or SourceBucketARNSelector is required.
	// +optional
	// +crossplane:generate:reference:type=github.com/crossplane-contrib/provider-aws/apis/iam/v1beta1.Role
	// +crossplane:generate:reference:extractor=github.com/crossplane-contrib/provider-aws/apis/iam/v1beta1.RoleARN()
	ExecutionRoleARN *string `json:"executionRoleARN"`

	// ExecutionRoleARNRef is a reference to the ExecutionRoleARN used to set.
	// the SubnetIDs.
	// +optional
	ExecutionRoleARNRef *xpv1.Reference `json:"executionRoleARNRef,omitempty"`

	// ExecutionRoleARNSelector selects the reference to the ExecutionRoleARN.
	// +optional
	ExecutionRoleARNSelector *xpv1.Selector `json:"executionRoleARNSelector,omitempty"`

	// 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).
	// +kubebuilder:validation:Required
	NetworkConfiguration CustomNetworkConfiguration `json:"networkConfiguration"`
}

CustomEnvironmentParameters for an Environment.

func (*CustomEnvironmentParameters) DeepCopy 

func (in *CustomEnvironmentParameters) DeepCopy() *CustomEnvironmentParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomEnvironmentParameters.

func (*CustomEnvironmentParameters) DeepCopyInto 

func (in *CustomEnvironmentParameters) DeepCopyInto(out *CustomEnvironmentParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CustomNetworkConfiguration 

type CustomNetworkConfiguration struct {
	// SecurityGroupIDs is the list of IDs for the SecurityGroups.
	// +crossplane:generate:reference:type=github.com/crossplane-contrib/provider-aws/apis/ec2/v1beta1.SecurityGroup
	// +crossplane:generate:reference:refFieldName=SecurityGroupIDRefs
	// +crossplane:generate:reference:selectorFieldName=SecurityGroupIDSelector
	SecurityGroupIDs []string `json:"securityGroupIds,omitempty"`

	// SecurityGroupIDRefs is a list of references to SecurityGroups used to set
	// the SecurityGroupIDs.
	// +optional
	SecurityGroupIDRefs []xpv1.Reference `json:"securityGroupIdRefs,omitempty"`

	// SecurityGroupIDsSelector selects references to SecurityGroupID used
	// to set the SecurityGroupIDs.
	// +optional
	SecurityGroupIDSelector *xpv1.Selector `json:"securityGroupIdSelector,omitempty"`

	// SecurityGroupIDs is the list of IDs for the SecurityGroups.
	// +immutable
	// +crossplane:generate:reference:type=github.com/crossplane-contrib/provider-aws/apis/ec2/v1beta1.Subnet
	// +crossplane:generate:reference:refFieldName=SubnetIDRefs
	// +crossplane:generate:reference:selectorFieldName=SubnetIDSelector
	SubnetIDs []string `json:"subnetIds,omitempty"`

	// SubnetIDRefs is a list of references to Subnets used to set
	// the SubnetIDs.
	// +optional
	SubnetIDRefs []xpv1.Reference `json:"subnetIdRefs,omitempty"`

	// SubnetIDsSelector selects references to Subnets used
	// to set the SubnetIDs.
	// +optional
	SubnetIDSelector *xpv1.Selector `json:"subnetIdSelector,omitempty"`
}

CustomNetworkConfiguration for an Environment.

func (*CustomNetworkConfiguration) DeepCopy 

func (in *CustomNetworkConfiguration) DeepCopy() *CustomNetworkConfiguration

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CustomNetworkConfiguration.

func (*CustomNetworkConfiguration) DeepCopyInto 

func (in *CustomNetworkConfiguration) DeepCopyInto(out *CustomNetworkConfiguration)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Environment 

type Environment struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              EnvironmentSpec   `json:"spec"`
	Status            EnvironmentStatus `json:"status,omitempty"`
}

Environment is the Schema for the Environments API +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:storageversion +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}

func (*Environment) DeepCopy 

func (in *Environment) DeepCopy() *Environment

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Environment.

func (*Environment) DeepCopyInto 

func (in *Environment) DeepCopyInto(out *Environment)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Environment) DeepCopyObject 

func (in *Environment) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Environment) GetCondition 

func (mg *Environment) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this Environment.

func (*Environment) GetDeletionPolicy 

func (mg *Environment) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this Environment.

func (*Environment) GetProviderConfigReference 

func (mg *Environment) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this Environment.

func (*Environment) GetProviderReference 

func (mg *Environment) GetProviderReference() *xpv1.Reference

GetProviderReference of this Environment. Deprecated: Use GetProviderConfigReference.

func (*Environment) GetPublishConnectionDetailsTo 

func (mg *Environment) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this Environment.

func (*Environment) GetWriteConnectionSecretToReference 

func (mg *Environment) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this Environment.

func (*Environment) ResolveReferences 

func (mg *Environment) ResolveReferences(ctx context.Context, c client.Reader) error

ResolveReferences of this Environment.

func (*Environment) SetConditions 

func (mg *Environment) SetConditions(c ...xpv1.Condition)

SetConditions of this Environment.

func (*Environment) SetDeletionPolicy 

func (mg *Environment) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this Environment.

func (*Environment) SetProviderConfigReference 

func (mg *Environment) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this Environment.

func (*Environment) SetProviderReference 

func (mg *Environment) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this Environment. Deprecated: Use SetProviderConfigReference.

func (*Environment) SetPublishConnectionDetailsTo 

func (mg *Environment) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this Environment.

func (*Environment) SetWriteConnectionSecretToReference 

func (mg *Environment) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this Environment.

type EnvironmentList 

type EnvironmentList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Environment `json:"items"`
}

EnvironmentList contains a list of Environments

func (*EnvironmentList) DeepCopy 

func (in *EnvironmentList) DeepCopy() *EnvironmentList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EnvironmentList.

func (*EnvironmentList) DeepCopyInto 

func (in *EnvironmentList) DeepCopyInto(out *EnvironmentList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*EnvironmentList) DeepCopyObject 

func (in *EnvironmentList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*EnvironmentList) GetItems 

func (l *EnvironmentList) GetItems() []resource.Managed

GetItems of this EnvironmentList.

type EnvironmentObservation 

type EnvironmentObservation struct {
	// The Amazon Resource Name (ARN) returned in the response for the environment.
	ARN *string `json:"arn,omitempty"`
	// The status of the last update on the environment.
	LastUpdate *LastUpdate `json:"lastUpdate,omitempty"`
	// 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 `json:"status,omitempty"`
}

EnvironmentObservation defines the observed state of Environment

func (*EnvironmentObservation) DeepCopy 

func (in *EnvironmentObservation) DeepCopy() *EnvironmentObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EnvironmentObservation.

func (*EnvironmentObservation) DeepCopyInto 

func (in *EnvironmentObservation) DeepCopyInto(out *EnvironmentObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EnvironmentParameters 

type EnvironmentParameters struct {
	// Region is which region the Environment will be created.
	// +kubebuilder:validation:Required
	Region string `json:"region"`
	// 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 map[string]*string `json:"airflowConfigurationOptions,omitempty"`
	// The Apache Airflow version for your environment. If no value is specified,
	// it defaults to the latest version. Valid values: 1.10.12, 2.0.2, 2.2.2, and
	// 2.4.3. For more information, see Apache Airflow versions on Amazon Managed
	// Workflows for Apache Airflow (MWAA) (https://docs.aws.amazon.com/mwaa/latest/userguide/airflow-versions.html).
	AirflowVersion *string `json:"airflowVersion,omitempty"`
	// 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).
	// +kubebuilder:validation:Required
	DagS3Path *string `json:"dagS3Path"`
	// 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 `json:"environmentClass,omitempty"`
	// Defines the Apache Airflow logs to send to CloudWatch Logs.
	LoggingConfiguration *LoggingConfigurationInput `json:"loggingConfiguration,omitempty"`
	// 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 `json:"maxWorkers,omitempty"`
	// 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 `json:"minWorkers,omitempty"`
	// 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 `json:"pluginsS3ObjectVersion,omitempty"`
	// 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 `json:"pluginsS3Path,omitempty"`
	// 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 `json:"requirementsS3ObjectVersion,omitempty"`
	// 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 `json:"requirementsS3Path,omitempty"`
	// The number of Apache Airflow schedulers to run in your environment. Valid
	// values:
	//
	//    * v2 - Accepts between 2 to 5. Defaults to 2.
	//
	//    * v1 - Accepts 1.
	Schedulers *int64 `json:"schedulers,omitempty"`
	// The key-value tag pairs you want to associate to your environment. For example,
	// "Environment": "Staging". To learn more, see Tagging Amazon Web Services
	// resources (https://docs.aws.amazon.com/general/latest/gr/aws_tagging.html).
	Tags map[string]*string `json:"tags,omitempty"`
	// 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 `json:"webserverAccessMode,omitempty"`
	// The day and time of the week in Coordinated Universal Time (UTC) 24-hour
	// standard time 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.
	WeeklyMaintenanceWindowStart *string `json:"weeklyMaintenanceWindowStart,omitempty"`
	CustomEnvironmentParameters  `json:",inline"`
}

EnvironmentParameters defines the desired state of Environment

func (*EnvironmentParameters) DeepCopy 

func (in *EnvironmentParameters) DeepCopy() *EnvironmentParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EnvironmentParameters.

func (*EnvironmentParameters) DeepCopyInto 

func (in *EnvironmentParameters) DeepCopyInto(out *EnvironmentParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EnvironmentSpec 

type EnvironmentSpec struct {
	xpv1.ResourceSpec `json:",inline"`
	ForProvider       EnvironmentParameters `json:"forProvider"`
}

EnvironmentSpec defines the desired state of Environment

func (*EnvironmentSpec) DeepCopy 

func (in *EnvironmentSpec) DeepCopy() *EnvironmentSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EnvironmentSpec.

func (*EnvironmentSpec) DeepCopyInto 

func (in *EnvironmentSpec) DeepCopyInto(out *EnvironmentSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EnvironmentStatus 

type EnvironmentStatus struct {
	xpv1.ResourceStatus `json:",inline"`
	AtProvider          EnvironmentObservation `json:"atProvider,omitempty"`
}

EnvironmentStatus defines the observed state of Environment.

func (*EnvironmentStatus) DeepCopy 

func (in *EnvironmentStatus) DeepCopy() *EnvironmentStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EnvironmentStatus.

func (*EnvironmentStatus) DeepCopyInto 

func (in *EnvironmentStatus) DeepCopyInto(out *EnvironmentStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EnvironmentStatus_SDK 

type EnvironmentStatus_SDK string
const (
	EnvironmentStatus_SDK_CREATING      EnvironmentStatus_SDK = "CREATING"
	EnvironmentStatus_SDK_CREATE_FAILED EnvironmentStatus_SDK = "CREATE_FAILED"
	EnvironmentStatus_SDK_AVAILABLE     EnvironmentStatus_SDK = "AVAILABLE"
	EnvironmentStatus_SDK_UPDATING      EnvironmentStatus_SDK = "UPDATING"
	EnvironmentStatus_SDK_DELETING      EnvironmentStatus_SDK = "DELETING"
	EnvironmentStatus_SDK_DELETED       EnvironmentStatus_SDK = "DELETED"
	EnvironmentStatus_SDK_UNAVAILABLE   EnvironmentStatus_SDK = "UNAVAILABLE"
	EnvironmentStatus_SDK_UPDATE_FAILED EnvironmentStatus_SDK = "UPDATE_FAILED"
)

type Environment_SDK 

type Environment_SDK struct {
	AirflowConfigurationOptions map[string]*string `json:"airflowConfigurationOptions,omitempty"`

	AirflowVersion *string `json:"airflowVersion,omitempty"`

	ARN *string `json:"arn,omitempty"`

	CreatedAt *metav1.Time `json:"createdAt,omitempty"`

	DagS3Path *string `json:"dagS3Path,omitempty"`

	EnvironmentClass *string `json:"environmentClass,omitempty"`

	ExecutionRoleARN *string `json:"executionRoleARN,omitempty"`

	KMSKey *string `json:"kmsKey,omitempty"`
	// Describes the status of the last update on the environment, and any errors
	// that were encountered.
	LastUpdate *LastUpdate `json:"lastUpdate,omitempty"`
	// Describes the Apache Airflow log types that are published to CloudWatch Logs.
	LoggingConfiguration *LoggingConfiguration `json:"loggingConfiguration,omitempty"`

	MaxWorkers *int64 `json:"maxWorkers,omitempty"`

	MinWorkers *int64 `json:"minWorkers,omitempty"`

	Name *string `json:"name,omitempty"`

	PluginsS3ObjectVersion *string `json:"pluginsS3ObjectVersion,omitempty"`

	PluginsS3Path *string `json:"pluginsS3Path,omitempty"`

	RequirementsS3ObjectVersion *string `json:"requirementsS3ObjectVersion,omitempty"`

	RequirementsS3Path *string `json:"requirementsS3Path,omitempty"`

	Schedulers *int64 `json:"schedulers,omitempty"`

	ServiceRoleARN *string `json:"serviceRoleARN,omitempty"`

	SourceBucketARN *string `json:"sourceBucketARN,omitempty"`

	Status *string `json:"status,omitempty"`

	Tags map[string]*string `json:"tags,omitempty"`

	WebserverAccessMode *string `json:"webserverAccessMode,omitempty"`

	WebserverURL *string `json:"webserverURL,omitempty"`

	WeeklyMaintenanceWindowStart *string `json:"weeklyMaintenanceWindowStart,omitempty"`
}

+kubebuilder:skipversion

func (*Environment_SDK) DeepCopy 

func (in *Environment_SDK) DeepCopy() *Environment_SDK

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Environment_SDK.

func (*Environment_SDK) DeepCopyInto 

func (in *Environment_SDK) DeepCopyInto(out *Environment_SDK)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type LastUpdate 

type LastUpdate struct {
	// Describes the error(s) encountered with the last update of the environment.
	Error *UpdateError `json:"error,omitempty"`

	Source *string `json:"source,omitempty"`

	Status *string `json:"status,omitempty"`
}

+kubebuilder:skipversion

func (*LastUpdate) DeepCopy 

func (in *LastUpdate) DeepCopy() *LastUpdate

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LastUpdate.

func (*LastUpdate) DeepCopyInto 

func (in *LastUpdate) DeepCopyInto(out *LastUpdate)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type LoggingConfiguration 

type LoggingConfiguration struct {
	// Describes the Apache Airflow log details for the log type (e.g. DagProcessingLogs).
	DagProcessingLogs *ModuleLoggingConfiguration `json:"dagProcessingLogs,omitempty"`
	// Describes the Apache Airflow log details for the log type (e.g. DagProcessingLogs).
	SchedulerLogs *ModuleLoggingConfiguration `json:"schedulerLogs,omitempty"`
	// Describes the Apache Airflow log details for the log type (e.g. DagProcessingLogs).
	TaskLogs *ModuleLoggingConfiguration `json:"taskLogs,omitempty"`
	// Describes the Apache Airflow log details for the log type (e.g. DagProcessingLogs).
	WebserverLogs *ModuleLoggingConfiguration `json:"webserverLogs,omitempty"`
	// Describes the Apache Airflow log details for the log type (e.g. DagProcessingLogs).
	WorkerLogs *ModuleLoggingConfiguration `json:"workerLogs,omitempty"`
}

+kubebuilder:skipversion

func (*LoggingConfiguration) DeepCopy 

func (in *LoggingConfiguration) DeepCopy() *LoggingConfiguration

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LoggingConfiguration.

func (*LoggingConfiguration) DeepCopyInto 

func (in *LoggingConfiguration) DeepCopyInto(out *LoggingConfiguration)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type LoggingConfigurationInput 

type LoggingConfigurationInput struct {
	// Enables the Apache Airflow log type (e.g. DagProcessingLogs) and defines
	// the log level to send to CloudWatch Logs (e.g. INFO).
	DagProcessingLogs *ModuleLoggingConfigurationInput `json:"dagProcessingLogs,omitempty"`
	// Enables the Apache Airflow log type (e.g. DagProcessingLogs) and defines
	// the log level to send to CloudWatch Logs (e.g. INFO).
	SchedulerLogs *ModuleLoggingConfigurationInput `json:"schedulerLogs,omitempty"`
	// Enables the Apache Airflow log type (e.g. DagProcessingLogs) and defines
	// the log level to send to CloudWatch Logs (e.g. INFO).
	TaskLogs *ModuleLoggingConfigurationInput `json:"taskLogs,omitempty"`
	// Enables the Apache Airflow log type (e.g. DagProcessingLogs) and defines
	// the log level to send to CloudWatch Logs (e.g. INFO).
	WebserverLogs *ModuleLoggingConfigurationInput `json:"webserverLogs,omitempty"`
	// Enables the Apache Airflow log type (e.g. DagProcessingLogs) and defines
	// the log level to send to CloudWatch Logs (e.g. INFO).
	WorkerLogs *ModuleLoggingConfigurationInput `json:"workerLogs,omitempty"`
}

+kubebuilder:skipversion

func (*LoggingConfigurationInput) DeepCopy 

func (in *LoggingConfigurationInput) DeepCopy() *LoggingConfigurationInput

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LoggingConfigurationInput.

func (*LoggingConfigurationInput) DeepCopyInto 

func (in *LoggingConfigurationInput) DeepCopyInto(out *LoggingConfigurationInput)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type LoggingLevel 

type LoggingLevel string
const (
	LoggingLevel_CRITICAL LoggingLevel = "CRITICAL"
	LoggingLevel_ERROR    LoggingLevel = "ERROR"
	LoggingLevel_WARNING  LoggingLevel = "WARNING"
	LoggingLevel_INFO     LoggingLevel = "INFO"
	LoggingLevel_DEBUG    LoggingLevel = "DEBUG"
)

type ModuleLoggingConfiguration 

type ModuleLoggingConfiguration struct {
	CloudWatchLogGroupARN *string `json:"cloudWatchLogGroupARN,omitempty"`

	Enabled *bool `json:"enabled,omitempty"`

	LogLevel *string `json:"logLevel,omitempty"`
}

+kubebuilder:skipversion

func (*ModuleLoggingConfiguration) DeepCopy 

func (in *ModuleLoggingConfiguration) DeepCopy() *ModuleLoggingConfiguration

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ModuleLoggingConfiguration.

func (*ModuleLoggingConfiguration) DeepCopyInto 

func (in *ModuleLoggingConfiguration) DeepCopyInto(out *ModuleLoggingConfiguration)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ModuleLoggingConfigurationInput 

type ModuleLoggingConfigurationInput struct {
	Enabled *bool `json:"enabled,omitempty"`

	LogLevel *string `json:"logLevel,omitempty"`
}

+kubebuilder:skipversion

func (*ModuleLoggingConfigurationInput) DeepCopy 

func (in *ModuleLoggingConfigurationInput) DeepCopy() *ModuleLoggingConfigurationInput

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ModuleLoggingConfigurationInput.

func (*ModuleLoggingConfigurationInput) DeepCopyInto 

func (in *ModuleLoggingConfigurationInput) DeepCopyInto(out *ModuleLoggingConfigurationInput)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Unit 

type Unit string
const (
	Unit_Seconds          Unit = "Seconds"
	Unit_Microseconds     Unit = "Microseconds"
	Unit_Milliseconds     Unit = "Milliseconds"
	Unit_Bytes            Unit = "Bytes"
	Unit_Kilobytes        Unit = "Kilobytes"
	Unit_Megabytes        Unit = "Megabytes"
	Unit_Gigabytes        Unit = "Gigabytes"
	Unit_Terabytes        Unit = "Terabytes"
	Unit_Bits             Unit = "Bits"
	Unit_Kilobits         Unit = "Kilobits"
	Unit_Megabits         Unit = "Megabits"
	Unit_Gigabits         Unit = "Gigabits"
	Unit_Terabits         Unit = "Terabits"
	Unit_Percent          Unit = "Percent"
	Unit_Count            Unit = "Count"
	Unit_Bytes_Second     Unit = "Bytes/Second"
	Unit_Kilobytes_Second Unit = "Kilobytes/Second"
	Unit_Megabytes_Second Unit = "Megabytes/Second"
	Unit_Gigabytes_Second Unit = "Gigabytes/Second"
	Unit_Terabytes_Second Unit = "Terabytes/Second"
	Unit_Bits_Second      Unit = "Bits/Second"
	Unit_Kilobits_Second  Unit = "Kilobits/Second"
	Unit_Megabits_Second  Unit = "Megabits/Second"
	Unit_Gigabits_Second  Unit = "Gigabits/Second"
	Unit_Terabits_Second  Unit = "Terabits/Second"
	Unit_Count_Second     Unit = "Count/Second"
	Unit_None             Unit = "None"
)

type UpdateError 

type UpdateError struct {
	ErrorCode *string `json:"errorCode,omitempty"`

	ErrorMessage *string `json:"errorMessage,omitempty"`
}

+kubebuilder:skipversion

func (*UpdateError) DeepCopy 

func (in *UpdateError) DeepCopy() *UpdateError

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new UpdateError.

func (*UpdateError) DeepCopyInto 

func (in *UpdateError) DeepCopyInto(out *UpdateError)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type UpdateStatus 

type UpdateStatus string
const (
	UpdateStatus_SUCCESS UpdateStatus = "SUCCESS"
	UpdateStatus_PENDING UpdateStatus = "PENDING"
	UpdateStatus_FAILED  UpdateStatus = "FAILED"
)

type WebserverAccessMode 

type WebserverAccessMode string
const (
	WebserverAccessMode_PRIVATE_ONLY WebserverAccessMode = "PRIVATE_ONLY"
	WebserverAccessMode_PUBLIC_ONLY  WebserverAccessMode = "PUBLIC_ONLY"
)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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