service

package
v0.0.0-...-796eee8 Latest Latest
Warning

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

 Go to latest Published: Oct 15, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	EnvironmentConfig_EnvironmentSize_name = map[int32]string{
		0: "ENVIRONMENT_SIZE_UNSPECIFIED",
		1: "ENVIRONMENT_SIZE_SMALL",
		2: "ENVIRONMENT_SIZE_MEDIUM",
		3: "ENVIRONMENT_SIZE_LARGE",
	}
	EnvironmentConfig_EnvironmentSize_value = map[string]int32{
		"ENVIRONMENT_SIZE_UNSPECIFIED": 0,
		"ENVIRONMENT_SIZE_SMALL":       1,
		"ENVIRONMENT_SIZE_MEDIUM":      2,
		"ENVIRONMENT_SIZE_LARGE":       3,
	}
)

Enum value maps for EnvironmentConfig_EnvironmentSize.

View Source 
var (
	NetworkingConfig_ConnectionType_name = map[int32]string{
		0: "CONNECTION_TYPE_UNSPECIFIED",
		1: "VPC_PEERING",
		2: "PRIVATE_SERVICE_CONNECT",
	}
	NetworkingConfig_ConnectionType_value = map[string]int32{
		"CONNECTION_TYPE_UNSPECIFIED": 0,
		"VPC_PEERING":                 1,
		"PRIVATE_SERVICE_CONNECT":     2,
	}
)

Enum value maps for NetworkingConfig_ConnectionType.

View Source 
var (
	Environment_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "CREATING",
		2: "RUNNING",
		3: "UPDATING",
		4: "DELETING",
		5: "ERROR",
	}
	Environment_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"CREATING":          1,
		"RUNNING":           2,
		"UPDATING":          3,
		"DELETING":          4,
		"ERROR":             5,
	}
)

Enum value maps for Environment_State.

View Source 
var (
	CheckUpgradeResponse_ConflictResult_name = map[int32]string{
		0: "CONFLICT_RESULT_UNSPECIFIED",
		1: "CONFLICT",
		2: "NO_CONFLICT",
	}
	CheckUpgradeResponse_ConflictResult_value = map[string]int32{
		"CONFLICT_RESULT_UNSPECIFIED": 0,
		"CONFLICT":                    1,
		"NO_CONFLICT":                 2,
	}
)

Enum value maps for CheckUpgradeResponse_ConflictResult.

View Source 
var (
	OperationMetadata_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "PENDING",
		2: "RUNNING",
		3: "SUCCESSFUL",
		4: "FAILED",
	}
	OperationMetadata_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"PENDING":           1,
		"RUNNING":           2,
		"SUCCESSFUL":        3,
		"FAILED":            4,
	}
)

Enum value maps for OperationMetadata_State.

View Source 
var (
	OperationMetadata_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "CREATE",
		2: "DELETE",
		3: "UPDATE",
		4: "CHECK",
		5: "SAVE_SNAPSHOT",
		6: "LOAD_SNAPSHOT",
	}
	OperationMetadata_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"CREATE":           1,
		"DELETE":           2,
		"UPDATE":           3,
		"CHECK":            4,
		"SAVE_SNAPSHOT":    5,
		"LOAD_SNAPSHOT":    6,
	}
)

Enum value maps for OperationMetadata_Type.

View Source 
var File_google_cloud_orchestration_airflow_service_v1beta1_environments_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_orchestration_airflow_service_v1beta1_image_versions_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_orchestration_airflow_service_v1beta1_operations_proto protoreflect.FileDescriptor

Functions

func RegisterEnvironmentsServer 

func RegisterEnvironmentsServer(s *grpc.Server, srv EnvironmentsServer)

func RegisterImageVersionsServer 

func RegisterImageVersionsServer(s *grpc.Server, srv ImageVersionsServer)

Types

type CheckUpgradeRequest 

type CheckUpgradeRequest struct {

	// The resource name of the environment to check upgrade for, in the
	// form:
	// "projects/{projectId}/locations/{locationId}/environments/{environmentId}"
	Environment string `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
	// The version of the software running in the environment.
	// This encapsulates both the version of Cloud Composer functionality and the
	// version of Apache Airflow. It must match the regular expression
	// `composer-([0-9]+(\.[0-9]+\.[0-9]+(-preview\.[0-9]+)?)?|latest)-airflow-([0-9]+(\.[0-9]+(\.[0-9]+)?)?)`.
	// When used as input, the server also checks if the provided version is
	// supported and denies the request for an unsupported version.
	//
	// The Cloud Composer portion of the image version is a full
	// [semantic version](https://semver.org), or an alias in the form of major
	// version number or `latest`. When an alias is provided, the server replaces
	// it with the current Cloud Composer version that satisfies the alias.
	//
	// The Apache Airflow portion of the image version is a full semantic version
	// that points to one of the supported Apache Airflow versions, or an alias in
	// the form of only major or major.minor versions specified. When an alias is
	// provided, the server replaces it with the latest Apache Airflow version
	// that satisfies the alias and is supported in the given Cloud Composer
	// version.
	//
	// In all cases, the resolved image version is stored in the same field.
	//
	// See also [version
	// list](/composer/docs/concepts/versioning/composer-versions) and [versioning
	// overview](/composer/docs/concepts/versioning/composer-versioning-overview).
	ImageVersion string `protobuf:"bytes,2,opt,name=image_version,json=imageVersion,proto3" json:"image_version,omitempty"`
	// contains filtered or unexported fields
}

Request to check whether image upgrade will succeed.

func (*CheckUpgradeRequest) Descriptor deprecated 

func (*CheckUpgradeRequest) Descriptor() ([]byte, []int)

Deprecated: Use CheckUpgradeRequest.ProtoReflect.Descriptor instead.

func (*CheckUpgradeRequest) GetEnvironment 

func (x *CheckUpgradeRequest) GetEnvironment() string

func (*CheckUpgradeRequest) GetImageVersion 

func (x *CheckUpgradeRequest) GetImageVersion() string

func (*CheckUpgradeRequest) ProtoMessage 

func (*CheckUpgradeRequest) ProtoMessage()

func (*CheckUpgradeRequest) ProtoReflect 

func (x *CheckUpgradeRequest) ProtoReflect() protoreflect.Message

func (*CheckUpgradeRequest) Reset 

func (x *CheckUpgradeRequest) Reset()

func (*CheckUpgradeRequest) String 

func (x *CheckUpgradeRequest) String() string

type CheckUpgradeResponse 

type CheckUpgradeResponse struct {

	// Output only. Url for a docker build log of an upgraded image.
	BuildLogUri string `protobuf:"bytes,1,opt,name=build_log_uri,json=buildLogUri,proto3" json:"build_log_uri,omitempty"`
	// Output only. Whether build has succeeded or failed on modules conflicts.
	ContainsPypiModulesConflict CheckUpgradeResponse_ConflictResult `` /* 239-byte string literal not displayed */
	// Output only. Extract from a docker image build log containing information
	// about pypi modules conflicts.
	PypiConflictBuildLogExtract string `` /* 148-byte string literal not displayed */
	// Composer image for which the build was happening.
	ImageVersion string `protobuf:"bytes,5,opt,name=image_version,json=imageVersion,proto3" json:"image_version,omitempty"`
	// Pypi dependencies specified in the environment configuration, at the time
	// when the build was triggered.
	PypiDependencies map[string]string `` /* 197-byte string literal not displayed */
	// contains filtered or unexported fields
}

Message containing information about the result of an upgrade check operation.

func (*CheckUpgradeResponse) Descriptor deprecated 

func (*CheckUpgradeResponse) Descriptor() ([]byte, []int)

Deprecated: Use CheckUpgradeResponse.ProtoReflect.Descriptor instead.

func (*CheckUpgradeResponse) GetBuildLogUri 

func (x *CheckUpgradeResponse) GetBuildLogUri() string

func (*CheckUpgradeResponse) GetContainsPypiModulesConflict 

func (x *CheckUpgradeResponse) GetContainsPypiModulesConflict() CheckUpgradeResponse_ConflictResult

func (*CheckUpgradeResponse) GetImageVersion 

func (x *CheckUpgradeResponse) GetImageVersion() string

func (*CheckUpgradeResponse) GetPypiConflictBuildLogExtract 

func (x *CheckUpgradeResponse) GetPypiConflictBuildLogExtract() string

func (*CheckUpgradeResponse) GetPypiDependencies 

func (x *CheckUpgradeResponse) GetPypiDependencies() map[string]string

func (*CheckUpgradeResponse) ProtoMessage 

func (*CheckUpgradeResponse) ProtoMessage()

func (*CheckUpgradeResponse) ProtoReflect 

func (x *CheckUpgradeResponse) ProtoReflect() protoreflect.Message

func (*CheckUpgradeResponse) Reset 

func (x *CheckUpgradeResponse) Reset()

func (*CheckUpgradeResponse) String 

func (x *CheckUpgradeResponse) String() string

type CheckUpgradeResponse_ConflictResult 

type CheckUpgradeResponse_ConflictResult int32

Whether there were python modules conflict during image build. 

const (
	// It is unknown whether build had conflicts or not.
	CheckUpgradeResponse_CONFLICT_RESULT_UNSPECIFIED CheckUpgradeResponse_ConflictResult = 0
	// There were python packages conflicts.
	CheckUpgradeResponse_CONFLICT CheckUpgradeResponse_ConflictResult = 1
	// There were no python packages conflicts.
	CheckUpgradeResponse_NO_CONFLICT CheckUpgradeResponse_ConflictResult = 2
)

func (CheckUpgradeResponse_ConflictResult) Descriptor 

func (CheckUpgradeResponse_ConflictResult) Descriptor() protoreflect.EnumDescriptor

func (CheckUpgradeResponse_ConflictResult) Enum 

func (x CheckUpgradeResponse_ConflictResult) Enum() *CheckUpgradeResponse_ConflictResult

func (CheckUpgradeResponse_ConflictResult) EnumDescriptor deprecated 

func (CheckUpgradeResponse_ConflictResult) EnumDescriptor() ([]byte, []int)

Deprecated: Use CheckUpgradeResponse_ConflictResult.Descriptor instead.

func (CheckUpgradeResponse_ConflictResult) Number 

func (x CheckUpgradeResponse_ConflictResult) Number() protoreflect.EnumNumber

func (CheckUpgradeResponse_ConflictResult) String 

func (x CheckUpgradeResponse_ConflictResult) String() string

func (CheckUpgradeResponse_ConflictResult) Type 

func (CheckUpgradeResponse_ConflictResult) Type() protoreflect.EnumType

type CloudDataLineageIntegration 

type CloudDataLineageIntegration struct {

	// Optional. Whether or not Cloud Data Lineage integration is enabled.
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// contains filtered or unexported fields
}

Configuration for Cloud Data Lineage integration.

func (*CloudDataLineageIntegration) Descriptor deprecated 

func (*CloudDataLineageIntegration) Descriptor() ([]byte, []int)

Deprecated: Use CloudDataLineageIntegration.ProtoReflect.Descriptor instead.

func (*CloudDataLineageIntegration) GetEnabled 

func (x *CloudDataLineageIntegration) GetEnabled() bool

func (*CloudDataLineageIntegration) ProtoMessage 

func (*CloudDataLineageIntegration) ProtoMessage()

func (*CloudDataLineageIntegration) ProtoReflect 

func (x *CloudDataLineageIntegration) ProtoReflect() protoreflect.Message

func (*CloudDataLineageIntegration) Reset 

func (x *CloudDataLineageIntegration) Reset()

func (*CloudDataLineageIntegration) String 

func (x *CloudDataLineageIntegration) String() string

type CreateEnvironmentRequest 

type CreateEnvironmentRequest struct {

	// The parent must be of the form
	// "projects/{projectId}/locations/{locationId}".
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// The environment to create.
	Environment *Environment `protobuf:"bytes,2,opt,name=environment,proto3" json:"environment,omitempty"`
	// contains filtered or unexported fields
}

Create a new environment.

func (*CreateEnvironmentRequest) Descriptor deprecated 

func (*CreateEnvironmentRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateEnvironmentRequest.ProtoReflect.Descriptor instead.

func (*CreateEnvironmentRequest) GetEnvironment 

func (x *CreateEnvironmentRequest) GetEnvironment() *Environment

func (*CreateEnvironmentRequest) GetParent 

func (x *CreateEnvironmentRequest) GetParent() string

func (*CreateEnvironmentRequest) ProtoMessage 

func (*CreateEnvironmentRequest) ProtoMessage()

func (*CreateEnvironmentRequest) ProtoReflect 

func (x *CreateEnvironmentRequest) ProtoReflect() protoreflect.Message

func (*CreateEnvironmentRequest) Reset 

func (x *CreateEnvironmentRequest) Reset()

func (*CreateEnvironmentRequest) String 

func (x *CreateEnvironmentRequest) String() string

type DatabaseConfig 

type DatabaseConfig struct {

	// Optional. Cloud SQL machine type used by Airflow database.
	// It has to be one of: db-n1-standard-2, db-n1-standard-4, db-n1-standard-8
	// or db-n1-standard-16. If not specified, db-n1-standard-2 will be used.
	// Supported for Cloud Composer environments in versions
	// composer-1.*.*-airflow-*.*.*.
	MachineType string `protobuf:"bytes,1,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"`
	// contains filtered or unexported fields
}

The configuration of Cloud SQL instance that is used by the Apache Airflow software.

func (*DatabaseConfig) Descriptor deprecated 

func (*DatabaseConfig) Descriptor() ([]byte, []int)

Deprecated: Use DatabaseConfig.ProtoReflect.Descriptor instead.

func (*DatabaseConfig) GetMachineType 

func (x *DatabaseConfig) GetMachineType() string

func (*DatabaseConfig) ProtoMessage 

func (*DatabaseConfig) ProtoMessage()

func (*DatabaseConfig) ProtoReflect 

func (x *DatabaseConfig) ProtoReflect() protoreflect.Message

func (*DatabaseConfig) Reset 

func (x *DatabaseConfig) Reset()

func (*DatabaseConfig) String 

func (x *DatabaseConfig) String() string

type DeleteEnvironmentRequest 

type DeleteEnvironmentRequest struct {

	// The environment to delete, in the form:
	// "projects/{projectId}/locations/{locationId}/environments/{environmentId}"
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Delete an environment.

func (*DeleteEnvironmentRequest) Descriptor deprecated 

func (*DeleteEnvironmentRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteEnvironmentRequest.ProtoReflect.Descriptor instead.

func (*DeleteEnvironmentRequest) GetName 

func (x *DeleteEnvironmentRequest) GetName() string

func (*DeleteEnvironmentRequest) ProtoMessage 

func (*DeleteEnvironmentRequest) ProtoMessage()

func (*DeleteEnvironmentRequest) ProtoReflect 

func (x *DeleteEnvironmentRequest) ProtoReflect() protoreflect.Message

func (*DeleteEnvironmentRequest) Reset 

func (x *DeleteEnvironmentRequest) Reset()

func (*DeleteEnvironmentRequest) String 

func (x *DeleteEnvironmentRequest) String() string

type EncryptionConfig 

type EncryptionConfig struct {

	// Optional. Customer-managed Encryption Key available through Google's Key
	// Management Service. Cannot be updated. If not specified, Google-managed key
	// will be used.
	KmsKeyName string `protobuf:"bytes,1,opt,name=kms_key_name,json=kmsKeyName,proto3" json:"kms_key_name,omitempty"`
	// contains filtered or unexported fields
}

The encryption options for the Cloud Composer environment and its dependencies. Supported for Cloud Composer environments in versions composer-1.*.*-airflow-*.*.*.

func (*EncryptionConfig) Descriptor deprecated 

func (*EncryptionConfig) Descriptor() ([]byte, []int)

Deprecated: Use EncryptionConfig.ProtoReflect.Descriptor instead.

func (*EncryptionConfig) GetKmsKeyName 

func (x *EncryptionConfig) GetKmsKeyName() string

func (*EncryptionConfig) ProtoMessage 

func (*EncryptionConfig) ProtoMessage()

func (*EncryptionConfig) ProtoReflect 

func (x *EncryptionConfig) ProtoReflect() protoreflect.Message

func (*EncryptionConfig) Reset 

func (x *EncryptionConfig) Reset()

func (*EncryptionConfig) String 

func (x *EncryptionConfig) String() string

type Environment 

type Environment struct {

	// The resource name of the environment, in the form:
	// "projects/{projectId}/locations/{locationId}/environments/{environmentId}"
	//
	// EnvironmentId must start with a lowercase letter followed by up to 63
	// lowercase letters, numbers, or hyphens, and cannot end with a hyphen.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Configuration parameters for this environment.
	Config *EnvironmentConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// Output only. The UUID (Universally Unique IDentifier) associated with this
	// environment. This value is generated when the environment is created.
	Uuid string `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// The current state of the environment.
	State Environment_State `` /* 138-byte string literal not displayed */
	// Output only. The time at which this environment was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The time at which this environment was last modified.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Optional. User-defined labels for this environment.
	// The labels map can contain no more than 64 entries. Entries of the labels
	// map are UTF8 strings that comply with the following restrictions:
	//
	// * Keys must conform to regexp: [\p{Ll}\p{Lo}][\p{Ll}\p{Lo}\p{N}_-]{0,62}
	// * Values must conform to regexp:  [\p{Ll}\p{Lo}\p{N}_-]{0,63}
	// * Both keys and values are additionally constrained to be <= 128 bytes in
	// size.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

An environment for running orchestration tasks.

func (*Environment) Descriptor deprecated 

func (*Environment) Descriptor() ([]byte, []int)

Deprecated: Use Environment.ProtoReflect.Descriptor instead.

func (*Environment) GetConfig 

func (x *Environment) GetConfig() *EnvironmentConfig

func (*Environment) GetCreateTime 

func (x *Environment) GetCreateTime() *timestamppb.Timestamp

func (*Environment) GetLabels 

func (x *Environment) GetLabels() map[string]string

func (*Environment) GetName 

func (x *Environment) GetName() string

func (*Environment) GetState 

func (x *Environment) GetState() Environment_State

func (*Environment) GetUpdateTime 

func (x *Environment) GetUpdateTime() *timestamppb.Timestamp

func (*Environment) GetUuid 

func (x *Environment) GetUuid() string

func (*Environment) ProtoMessage 

func (*Environment) ProtoMessage()

func (*Environment) ProtoReflect 

func (x *Environment) ProtoReflect() protoreflect.Message

func (*Environment) Reset 

func (x *Environment) Reset()

func (*Environment) String 

func (x *Environment) String() string

type EnvironmentConfig 

type EnvironmentConfig struct {

	// Output only. The Kubernetes Engine cluster used to run this environment.
	GkeCluster string `protobuf:"bytes,1,opt,name=gke_cluster,json=gkeCluster,proto3" json:"gke_cluster,omitempty"`
	// Output only. The Cloud Storage prefix of the DAGs for this environment.
	// Although Cloud Storage objects reside in a flat namespace, a hierarchical
	// file tree can be simulated using "/"-delimited object name prefixes. DAG
	// objects for this environment reside in a simulated directory with the given
	// prefix.
	DagGcsPrefix string `protobuf:"bytes,2,opt,name=dag_gcs_prefix,json=dagGcsPrefix,proto3" json:"dag_gcs_prefix,omitempty"`
	// The number of nodes in the Kubernetes Engine cluster that will be
	// used to run this environment.
	//
	// This field is supported for Cloud Composer environments in versions
	// composer-1.*.*-airflow-*.*.*.
	NodeCount int32 `protobuf:"varint,3,opt,name=node_count,json=nodeCount,proto3" json:"node_count,omitempty"`
	// The configuration settings for software inside the environment.
	SoftwareConfig *SoftwareConfig `protobuf:"bytes,4,opt,name=software_config,json=softwareConfig,proto3" json:"software_config,omitempty"`
	// The configuration used for the Kubernetes Engine cluster.
	NodeConfig *NodeConfig `protobuf:"bytes,5,opt,name=node_config,json=nodeConfig,proto3" json:"node_config,omitempty"`
	// The configuration used for the Private IP Cloud Composer environment.
	PrivateEnvironmentConfig *PrivateEnvironmentConfig `` /* 135-byte string literal not displayed */
	// Optional. The network-level access control policy for the Airflow web
	// server. If unspecified, no network-level access restrictions will be
	// applied.
	WebServerNetworkAccessControl *WebServerNetworkAccessControl `` /* 154-byte string literal not displayed */
	// Optional. The configuration settings for Cloud SQL instance used internally
	// by Apache Airflow software.
	DatabaseConfig *DatabaseConfig `protobuf:"bytes,10,opt,name=database_config,json=databaseConfig,proto3" json:"database_config,omitempty"`
	// Optional. The configuration settings for the Airflow web server App Engine
	// instance.
	//
	// This field is supported for Cloud Composer environments in versions
	// composer-1.*.*-airflow-*.*.*.
	WebServerConfig *WebServerConfig `protobuf:"bytes,11,opt,name=web_server_config,json=webServerConfig,proto3" json:"web_server_config,omitempty"`
	// Output only. The URI of the Apache Airflow Web UI hosted within this
	// environment (see [Airflow web
	// interface](/composer/docs/how-to/accessing/airflow-web-interface)).
	AirflowUri string `protobuf:"bytes,6,opt,name=airflow_uri,json=airflowUri,proto3" json:"airflow_uri,omitempty"`
	// Optional. The encryption options for the Cloud Composer environment and its
	// dependencies. Cannot be updated.
	EncryptionConfig *EncryptionConfig `protobuf:"bytes,12,opt,name=encryption_config,json=encryptionConfig,proto3" json:"encryption_config,omitempty"`
	// Optional. The maintenance window is the period when Cloud Composer
	// components may undergo maintenance. It is defined so that maintenance is
	// not executed during peak hours or critical time periods.
	//
	// The system will not be under maintenance for every occurrence of this
	// window, but when maintenance is planned, it will be scheduled
	// during the window.
	//
	// The maintenance window period must encompass at least 12 hours per week.
	// This may be split into multiple chunks, each with a size of
	// at least 4 hours.
	//
	// If this value is omitted, Cloud Composer components may be subject to
	// maintenance at any time.
	MaintenanceWindow *MaintenanceWindow `protobuf:"bytes,13,opt,name=maintenance_window,json=maintenanceWindow,proto3" json:"maintenance_window,omitempty"`
	// Optional. The workloads configuration settings for the GKE cluster
	// associated with the Cloud Composer environment. The GKE cluster runs
	// Airflow scheduler, web server and workers workloads.
	//
	// This field is supported for Cloud Composer environments in versions
	// composer-2.*.*-airflow-*.*.* and newer.
	WorkloadsConfig *WorkloadsConfig `protobuf:"bytes,15,opt,name=workloads_config,json=workloadsConfig,proto3" json:"workloads_config,omitempty"`
	// Optional. The size of the Cloud Composer environment.
	//
	// This field is supported for Cloud Composer environments in versions
	// composer-2.*.*-airflow-*.*.* and newer.
	EnvironmentSize EnvironmentConfig_EnvironmentSize `` /* 198-byte string literal not displayed */
	// Optional. The configuration options for GKE cluster master authorized
	// networks. By default master authorized networks feature is:
	// - in case of private environment: enabled with no external networks
	// allowlisted.
	// - in case of public environment: disabled.
	MasterAuthorizedNetworksConfig *MasterAuthorizedNetworksConfig `` /* 156-byte string literal not displayed */
	// Optional. The Recovery settings configuration of an environment.
	//
	// This field is supported for Cloud Composer environments in versions
	// composer-2.*.*-airflow-*.*.* and newer.
	RecoveryConfig *RecoveryConfig `protobuf:"bytes,18,opt,name=recovery_config,json=recoveryConfig,proto3" json:"recovery_config,omitempty"`
	// contains filtered or unexported fields
}

Configuration information for an environment.

func (*EnvironmentConfig) Descriptor deprecated 

func (*EnvironmentConfig) Descriptor() ([]byte, []int)

Deprecated: Use EnvironmentConfig.ProtoReflect.Descriptor instead.

func (*EnvironmentConfig) GetAirflowUri 

func (x *EnvironmentConfig) GetAirflowUri() string

func (*EnvironmentConfig) GetDagGcsPrefix 

func (x *EnvironmentConfig) GetDagGcsPrefix() string

func (*EnvironmentConfig) GetDatabaseConfig 

func (x *EnvironmentConfig) GetDatabaseConfig() *DatabaseConfig

func (*EnvironmentConfig) GetEncryptionConfig 

func (x *EnvironmentConfig) GetEncryptionConfig() *EncryptionConfig

func (*EnvironmentConfig) GetEnvironmentSize 

func (x *EnvironmentConfig) GetEnvironmentSize() EnvironmentConfig_EnvironmentSize

func (*EnvironmentConfig) GetGkeCluster 

func (x *EnvironmentConfig) GetGkeCluster() string

func (*EnvironmentConfig) GetMaintenanceWindow 

func (x *EnvironmentConfig) GetMaintenanceWindow() *MaintenanceWindow

func (*EnvironmentConfig) GetMasterAuthorizedNetworksConfig 

func (x *EnvironmentConfig) GetMasterAuthorizedNetworksConfig() *MasterAuthorizedNetworksConfig

func (*EnvironmentConfig) GetNodeConfig 

func (x *EnvironmentConfig) GetNodeConfig() *NodeConfig

func (*EnvironmentConfig) GetNodeCount 

func (x *EnvironmentConfig) GetNodeCount() int32

func (*EnvironmentConfig) GetPrivateEnvironmentConfig 

func (x *EnvironmentConfig) GetPrivateEnvironmentConfig() *PrivateEnvironmentConfig

func (*EnvironmentConfig) GetRecoveryConfig 

func (x *EnvironmentConfig) GetRecoveryConfig() *RecoveryConfig

func (*EnvironmentConfig) GetSoftwareConfig 

func (x *EnvironmentConfig) GetSoftwareConfig() *SoftwareConfig

func (*EnvironmentConfig) GetWebServerConfig 

func (x *EnvironmentConfig) GetWebServerConfig() *WebServerConfig

func (*EnvironmentConfig) GetWebServerNetworkAccessControl 

func (x *EnvironmentConfig) GetWebServerNetworkAccessControl() *WebServerNetworkAccessControl

func (*EnvironmentConfig) GetWorkloadsConfig 

func (x *EnvironmentConfig) GetWorkloadsConfig() *WorkloadsConfig

func (*EnvironmentConfig) ProtoMessage 

func (*EnvironmentConfig) ProtoMessage()

func (*EnvironmentConfig) ProtoReflect 

func (x *EnvironmentConfig) ProtoReflect() protoreflect.Message

func (*EnvironmentConfig) Reset 

func (x *EnvironmentConfig) Reset()

func (*EnvironmentConfig) String 

func (x *EnvironmentConfig) String() string

type EnvironmentConfig_EnvironmentSize 

type EnvironmentConfig_EnvironmentSize int32

The size of the Cloud Composer environment. 

const (
	// The size of the environment is unspecified.
	EnvironmentConfig_ENVIRONMENT_SIZE_UNSPECIFIED EnvironmentConfig_EnvironmentSize = 0
	// The environment size is small.
	EnvironmentConfig_ENVIRONMENT_SIZE_SMALL EnvironmentConfig_EnvironmentSize = 1
	// The environment size is medium.
	EnvironmentConfig_ENVIRONMENT_SIZE_MEDIUM EnvironmentConfig_EnvironmentSize = 2
	// The environment size is large.
	EnvironmentConfig_ENVIRONMENT_SIZE_LARGE EnvironmentConfig_EnvironmentSize = 3
)

func (EnvironmentConfig_EnvironmentSize) Descriptor 

func (EnvironmentConfig_EnvironmentSize) Descriptor() protoreflect.EnumDescriptor

func (EnvironmentConfig_EnvironmentSize) Enum 

func (x EnvironmentConfig_EnvironmentSize) Enum() *EnvironmentConfig_EnvironmentSize

func (EnvironmentConfig_EnvironmentSize) EnumDescriptor deprecated 

func (EnvironmentConfig_EnvironmentSize) EnumDescriptor() ([]byte, []int)

Deprecated: Use EnvironmentConfig_EnvironmentSize.Descriptor instead.

func (EnvironmentConfig_EnvironmentSize) Number 

func (x EnvironmentConfig_EnvironmentSize) Number() protoreflect.EnumNumber

func (EnvironmentConfig_EnvironmentSize) String 

func (x EnvironmentConfig_EnvironmentSize) String() string

func (EnvironmentConfig_EnvironmentSize) Type 

func (EnvironmentConfig_EnvironmentSize) Type() protoreflect.EnumType

type Environment_State 

type Environment_State int32

State of the environment. 

const (
	// The state of the environment is unknown.
	Environment_STATE_UNSPECIFIED Environment_State = 0
	// The environment is in the process of being created.
	Environment_CREATING Environment_State = 1
	// The environment is currently running and healthy. It is ready for use.
	Environment_RUNNING Environment_State = 2
	// The environment is being updated. It remains usable but cannot receive
	// additional update requests or be deleted at this time.
	Environment_UPDATING Environment_State = 3
	// The environment is undergoing deletion. It cannot be used.
	Environment_DELETING Environment_State = 4
	// The environment has encountered an error and cannot be used.
	Environment_ERROR Environment_State = 5
)

func (Environment_State) Descriptor 

func (Environment_State) Descriptor() protoreflect.EnumDescriptor

func (Environment_State) Enum 

func (x Environment_State) Enum() *Environment_State

func (Environment_State) EnumDescriptor deprecated 

func (Environment_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use Environment_State.Descriptor instead.

func (Environment_State) Number 

func (x Environment_State) Number() protoreflect.EnumNumber

func (Environment_State) String 

func (x Environment_State) String() string

func (Environment_State) Type 

func (Environment_State) Type() protoreflect.EnumType

type EnvironmentsClient 

type EnvironmentsClient interface {
	// Create a new environment.
	CreateEnvironment(ctx context.Context, in *CreateEnvironmentRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Get an existing environment.
	GetEnvironment(ctx context.Context, in *GetEnvironmentRequest, opts ...grpc.CallOption) (*Environment, error)
	// List environments.
	ListEnvironments(ctx context.Context, in *ListEnvironmentsRequest, opts ...grpc.CallOption) (*ListEnvironmentsResponse, error)
	// Update an environment.
	UpdateEnvironment(ctx context.Context, in *UpdateEnvironmentRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Delete an environment.
	DeleteEnvironment(ctx context.Context, in *DeleteEnvironmentRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Restart Airflow web server.
	RestartWebServer(ctx context.Context, in *RestartWebServerRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Check if an upgrade operation on the environment will succeed.
	//
	// In case of problems detailed info can be found in the returned Operation.
	CheckUpgrade(ctx context.Context, in *CheckUpgradeRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Creates a snapshots of a Cloud Composer environment.
	//
	// As a result of this operation, snapshot of environment's state is stored
	// in a location specified in the SaveSnapshotRequest.
	SaveSnapshot(ctx context.Context, in *SaveSnapshotRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Loads a snapshot of a Cloud Composer environment.
	//
	// As a result of this operation, a snapshot of environment's specified in
	// LoadSnapshotRequest is loaded into the environment.
	LoadSnapshot(ctx context.Context, in *LoadSnapshotRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
}

EnvironmentsClient is the client API for Environments service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewEnvironmentsClient 

func NewEnvironmentsClient(cc grpc.ClientConnInterface) EnvironmentsClient

type EnvironmentsServer 

type EnvironmentsServer interface {
	// Create a new environment.
	CreateEnvironment(context.Context, *CreateEnvironmentRequest) (*longrunning.Operation, error)
	// Get an existing environment.
	GetEnvironment(context.Context, *GetEnvironmentRequest) (*Environment, error)
	// List environments.
	ListEnvironments(context.Context, *ListEnvironmentsRequest) (*ListEnvironmentsResponse, error)
	// Update an environment.
	UpdateEnvironment(context.Context, *UpdateEnvironmentRequest) (*longrunning.Operation, error)
	// Delete an environment.
	DeleteEnvironment(context.Context, *DeleteEnvironmentRequest) (*longrunning.Operation, error)
	// Restart Airflow web server.
	RestartWebServer(context.Context, *RestartWebServerRequest) (*longrunning.Operation, error)
	// Check if an upgrade operation on the environment will succeed.
	//
	// In case of problems detailed info can be found in the returned Operation.
	CheckUpgrade(context.Context, *CheckUpgradeRequest) (*longrunning.Operation, error)
	// Creates a snapshots of a Cloud Composer environment.
	//
	// As a result of this operation, snapshot of environment's state is stored
	// in a location specified in the SaveSnapshotRequest.
	SaveSnapshot(context.Context, *SaveSnapshotRequest) (*longrunning.Operation, error)
	// Loads a snapshot of a Cloud Composer environment.
	//
	// As a result of this operation, a snapshot of environment's specified in
	// LoadSnapshotRequest is loaded into the environment.
	LoadSnapshot(context.Context, *LoadSnapshotRequest) (*longrunning.Operation, error)
}

EnvironmentsServer is the server API for Environments service.

type ExecuteAirflowCommandResponse 

type ExecuteAirflowCommandResponse struct {

	// The unique ID of the command execution for polling.
	ExecutionId string `protobuf:"bytes,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	// The name of the pod where the command is executed.
	Pod string `protobuf:"bytes,2,opt,name=pod,proto3" json:"pod,omitempty"`
	// The namespace of the pod where the command is executed.
	PodNamespace string `protobuf:"bytes,3,opt,name=pod_namespace,json=podNamespace,proto3" json:"pod_namespace,omitempty"`
	// Error message. Empty if there was no error.
	Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

Response to ExecuteAirflowCommandRequest.

func (*ExecuteAirflowCommandResponse) Descriptor deprecated 

func (*ExecuteAirflowCommandResponse) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteAirflowCommandResponse.ProtoReflect.Descriptor instead.

func (*ExecuteAirflowCommandResponse) GetError 

func (x *ExecuteAirflowCommandResponse) GetError() string

func (*ExecuteAirflowCommandResponse) GetExecutionId 

func (x *ExecuteAirflowCommandResponse) GetExecutionId() string

func (*ExecuteAirflowCommandResponse) GetPod 

func (x *ExecuteAirflowCommandResponse) GetPod() string

func (*ExecuteAirflowCommandResponse) GetPodNamespace 

func (x *ExecuteAirflowCommandResponse) GetPodNamespace() string

func (*ExecuteAirflowCommandResponse) ProtoMessage 

func (*ExecuteAirflowCommandResponse) ProtoMessage()

func (*ExecuteAirflowCommandResponse) ProtoReflect 

func (x *ExecuteAirflowCommandResponse) ProtoReflect() protoreflect.Message

func (*ExecuteAirflowCommandResponse) Reset 

func (x *ExecuteAirflowCommandResponse) Reset()

func (*ExecuteAirflowCommandResponse) String 

func (x *ExecuteAirflowCommandResponse) String() string

type GetEnvironmentRequest 

type GetEnvironmentRequest struct {

	// The resource name of the environment to get, in the form:
	// "projects/{projectId}/locations/{locationId}/environments/{environmentId}"
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Get an environment.

func (*GetEnvironmentRequest) Descriptor deprecated 

func (*GetEnvironmentRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetEnvironmentRequest.ProtoReflect.Descriptor instead.

func (*GetEnvironmentRequest) GetName 

func (x *GetEnvironmentRequest) GetName() string

func (*GetEnvironmentRequest) ProtoMessage 

func (*GetEnvironmentRequest) ProtoMessage()

func (*GetEnvironmentRequest) ProtoReflect 

func (x *GetEnvironmentRequest) ProtoReflect() protoreflect.Message

func (*GetEnvironmentRequest) Reset 

func (x *GetEnvironmentRequest) Reset()

func (*GetEnvironmentRequest) String 

func (x *GetEnvironmentRequest) String() string

type IPAllocationPolicy 

type IPAllocationPolicy struct {

	// Optional. Whether or not to enable Alias IPs in the GKE cluster.
	// If `true`, a VPC-native cluster is created.
	//
	// This field is only supported for Cloud Composer environments in versions
	// composer-1.*.*-airflow-*.*.*. Environments in newer versions always use
	// VPC-native GKE clusters.
	UseIpAliases bool `protobuf:"varint,1,opt,name=use_ip_aliases,json=useIpAliases,proto3" json:"use_ip_aliases,omitempty"`
	// Optional. The name of the cluster's secondary range used to allocate
	// IP addresses to pods. Specify either `cluster_secondary_range_name`
	// or `cluster_ipv4_cidr_block` but not both.
	//
	// For Cloud Composer environments in versions composer-1.*.*-airflow-*.*.*,
	// this field is applicable only when `use_ip_aliases` is true.
	ClusterSecondaryRangeName string `` /* 140-byte string literal not displayed */
	// Optional. The name of the services' secondary range used to allocate
	// IP addresses to the cluster. Specify either `services_secondary_range_name`
	// or `services_ipv4_cidr_block` but not both.
	//
	// For Cloud Composer environments in versions composer-1.*.*-airflow-*.*.*,
	// this field is applicable only when `use_ip_aliases` is true.
	ServicesSecondaryRangeName string `` /* 143-byte string literal not displayed */
	// Optional. The IP address range used to allocate IP addresses to pods in
	// the cluster.
	//
	// For Cloud Composer environments in versions composer-1.*.*-airflow-*.*.*,
	// this field is applicable only when `use_ip_aliases` is true.
	//
	// Set to blank to have GKE choose a range with the default size.
	//
	// Set to /netmask (e.g. `/14`) to have GKE choose a range with a specific
	// netmask.
	//
	// Set to a
	// [CIDR](https://en.wikipedia.org/wiki/Classless_Inter-Domain_Routing)
	// notation (e.g. `10.96.0.0/14`) from the RFC-1918 private networks (e.g.
	// `10.0.0.0/8`, `172.16.0.0/12`, `192.168.0.0/16`) to pick a specific range
	// to use.
	// Specify `cluster_secondary_range_name` or `cluster_ipv4_cidr_block`
	// but not both.
	ClusterIpv4CidrBlock string `protobuf:"bytes,4,opt,name=cluster_ipv4_cidr_block,json=clusterIpv4CidrBlock,proto3" json:"cluster_ipv4_cidr_block,omitempty"`
	// Optional. The IP address range of the services IP addresses in this
	// cluster.
	//
	// For Cloud Composer environments in versions composer-1.*.*-airflow-*.*.*,
	// this field is applicable only when `use_ip_aliases` is true.
	//
	// Set to blank to have GKE choose a range with the default size.
	//
	// Set to /netmask (e.g. `/14`) to have GKE choose a range with a specific
	// netmask.
	//
	// Set to a
	// [CIDR](https://en.wikipedia.org/wiki/Classless_Inter-Domain_Routing)
	// notation (e.g. `10.96.0.0/14`) from the RFC-1918 private networks (e.g.
	// `10.0.0.0/8`, `172.16.0.0/12`, `192.168.0.0/16`) to pick a specific range
	// to use.
	// Specify `services_secondary_range_name` or `services_ipv4_cidr_block`
	// but not both.
	ServicesIpv4CidrBlock string `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

Configuration for controlling how IPs are allocated in the GKE cluster.

func (*IPAllocationPolicy) Descriptor deprecated 

func (*IPAllocationPolicy) Descriptor() ([]byte, []int)

Deprecated: Use IPAllocationPolicy.ProtoReflect.Descriptor instead.

func (*IPAllocationPolicy) GetClusterIpv4CidrBlock 

func (x *IPAllocationPolicy) GetClusterIpv4CidrBlock() string

func (*IPAllocationPolicy) GetClusterSecondaryRangeName 

func (x *IPAllocationPolicy) GetClusterSecondaryRangeName() string

func (*IPAllocationPolicy) GetServicesIpv4CidrBlock 

func (x *IPAllocationPolicy) GetServicesIpv4CidrBlock() string

func (*IPAllocationPolicy) GetServicesSecondaryRangeName 

func (x *IPAllocationPolicy) GetServicesSecondaryRangeName() string

func (*IPAllocationPolicy) GetUseIpAliases 

func (x *IPAllocationPolicy) GetUseIpAliases() bool

func (*IPAllocationPolicy) ProtoMessage 

func (*IPAllocationPolicy) ProtoMessage()

func (*IPAllocationPolicy) ProtoReflect 

func (x *IPAllocationPolicy) ProtoReflect() protoreflect.Message

func (*IPAllocationPolicy) Reset 

func (x *IPAllocationPolicy) Reset()

func (*IPAllocationPolicy) String 

func (x *IPAllocationPolicy) String() string

type ImageVersion 

type ImageVersion struct {

	// The string identifier of the ImageVersion, in the form:
	// "composer-x.y.z-airflow-a.b.c"
	ImageVersionId string `protobuf:"bytes,1,opt,name=image_version_id,json=imageVersionId,proto3" json:"image_version_id,omitempty"`
	// Whether this is the default ImageVersion used by Composer during
	// environment creation if no input ImageVersion is specified.
	IsDefault bool `protobuf:"varint,2,opt,name=is_default,json=isDefault,proto3" json:"is_default,omitempty"`
	// supported python versions
	SupportedPythonVersions []string `` /* 132-byte string literal not displayed */
	// The date of the version release.
	ReleaseDate *date.Date `protobuf:"bytes,4,opt,name=release_date,json=releaseDate,proto3" json:"release_date,omitempty"`
	// Whether it is impossible to create an environment with the image version.
	CreationDisabled bool `protobuf:"varint,5,opt,name=creation_disabled,json=creationDisabled,proto3" json:"creation_disabled,omitempty"`
	// Whether it is impossible to upgrade an environment running with the image
	// version.
	UpgradeDisabled bool `protobuf:"varint,6,opt,name=upgrade_disabled,json=upgradeDisabled,proto3" json:"upgrade_disabled,omitempty"`
	// contains filtered or unexported fields
}

Image Version information

func (*ImageVersion) Descriptor deprecated 

func (*ImageVersion) Descriptor() ([]byte, []int)

Deprecated: Use ImageVersion.ProtoReflect.Descriptor instead.

func (*ImageVersion) GetCreationDisabled 

func (x *ImageVersion) GetCreationDisabled() bool

func (*ImageVersion) GetImageVersionId 

func (x *ImageVersion) GetImageVersionId() string

func (*ImageVersion) GetIsDefault 

func (x *ImageVersion) GetIsDefault() bool

func (*ImageVersion) GetReleaseDate 

func (x *ImageVersion) GetReleaseDate() *date.Date

func (*ImageVersion) GetSupportedPythonVersions 

func (x *ImageVersion) GetSupportedPythonVersions() []string

func (*ImageVersion) GetUpgradeDisabled 

func (x *ImageVersion) GetUpgradeDisabled() bool

func (*ImageVersion) ProtoMessage 

func (*ImageVersion) ProtoMessage()

func (*ImageVersion) ProtoReflect 

func (x *ImageVersion) ProtoReflect() protoreflect.Message

func (*ImageVersion) Reset 

func (x *ImageVersion) Reset()

func (*ImageVersion) String 

func (x *ImageVersion) String() string

type ImageVersionsClient 

type ImageVersionsClient interface {
	// List ImageVersions for provided location.
	ListImageVersions(ctx context.Context, in *ListImageVersionsRequest, opts ...grpc.CallOption) (*ListImageVersionsResponse, error)
}

ImageVersionsClient is the client API for ImageVersions service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewImageVersionsClient 

func NewImageVersionsClient(cc grpc.ClientConnInterface) ImageVersionsClient

type ImageVersionsServer 

type ImageVersionsServer interface {
	// List ImageVersions for provided location.
	ListImageVersions(context.Context, *ListImageVersionsRequest) (*ListImageVersionsResponse, error)
}

ImageVersionsServer is the server API for ImageVersions service.

type ListEnvironmentsRequest 

type ListEnvironmentsRequest struct {

	// List environments in the given project and location, in the form:
	// "projects/{projectId}/locations/{locationId}"
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// The maximum number of environments to return.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// The next_page_token value returned from a previous List request, if any.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

List environments in a project and location.

func (*ListEnvironmentsRequest) Descriptor deprecated 

func (*ListEnvironmentsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListEnvironmentsRequest.ProtoReflect.Descriptor instead.

func (*ListEnvironmentsRequest) GetPageSize 

func (x *ListEnvironmentsRequest) GetPageSize() int32

func (*ListEnvironmentsRequest) GetPageToken 

func (x *ListEnvironmentsRequest) GetPageToken() string

func (*ListEnvironmentsRequest) GetParent 

func (x *ListEnvironmentsRequest) GetParent() string

func (*ListEnvironmentsRequest) ProtoMessage 

func (*ListEnvironmentsRequest) ProtoMessage()

func (*ListEnvironmentsRequest) ProtoReflect 

func (x *ListEnvironmentsRequest) ProtoReflect() protoreflect.Message

func (*ListEnvironmentsRequest) Reset 

func (x *ListEnvironmentsRequest) Reset()

func (*ListEnvironmentsRequest) String 

func (x *ListEnvironmentsRequest) String() string

type ListEnvironmentsResponse 

type ListEnvironmentsResponse struct {

	// The list of environments returned by a ListEnvironmentsRequest.
	Environments []*Environment `protobuf:"bytes,1,rep,name=environments,proto3" json:"environments,omitempty"`
	// The page token used to query for the next page if one exists.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

The environments in a project and location.

func (*ListEnvironmentsResponse) Descriptor deprecated 

func (*ListEnvironmentsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListEnvironmentsResponse.ProtoReflect.Descriptor instead.

func (*ListEnvironmentsResponse) GetEnvironments 

func (x *ListEnvironmentsResponse) GetEnvironments() []*Environment

func (*ListEnvironmentsResponse) GetNextPageToken 

func (x *ListEnvironmentsResponse) GetNextPageToken() string

func (*ListEnvironmentsResponse) ProtoMessage 

func (*ListEnvironmentsResponse) ProtoMessage()

func (*ListEnvironmentsResponse) ProtoReflect 

func (x *ListEnvironmentsResponse) ProtoReflect() protoreflect.Message

func (*ListEnvironmentsResponse) Reset 

func (x *ListEnvironmentsResponse) Reset()

func (*ListEnvironmentsResponse) String 

func (x *ListEnvironmentsResponse) String() string

type ListImageVersionsRequest 

type ListImageVersionsRequest struct {

	// List ImageVersions in the given project and location, in the form:
	// "projects/{projectId}/locations/{locationId}"
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// The maximum number of image_versions to return.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// The next_page_token value returned from a previous List request, if any.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Whether or not image versions from old releases should be included.
	IncludePastReleases bool `protobuf:"varint,4,opt,name=include_past_releases,json=includePastReleases,proto3" json:"include_past_releases,omitempty"`
	// contains filtered or unexported fields
}

List ImageVersions in a project and location.

func (*ListImageVersionsRequest) Descriptor deprecated 

func (*ListImageVersionsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListImageVersionsRequest.ProtoReflect.Descriptor instead.

func (*ListImageVersionsRequest) GetIncludePastReleases 

func (x *ListImageVersionsRequest) GetIncludePastReleases() bool

func (*ListImageVersionsRequest) GetPageSize 

func (x *ListImageVersionsRequest) GetPageSize() int32

func (*ListImageVersionsRequest) GetPageToken 

func (x *ListImageVersionsRequest) GetPageToken() string

func (*ListImageVersionsRequest) GetParent 

func (x *ListImageVersionsRequest) GetParent() string

func (*ListImageVersionsRequest) ProtoMessage 

func (*ListImageVersionsRequest) ProtoMessage()

func (*ListImageVersionsRequest) ProtoReflect 

func (x *ListImageVersionsRequest) ProtoReflect() protoreflect.Message

func (*ListImageVersionsRequest) Reset 

func (x *ListImageVersionsRequest) Reset()

func (*ListImageVersionsRequest) String 

func (x *ListImageVersionsRequest) String() string

type ListImageVersionsResponse 

type ListImageVersionsResponse struct {

	// The list of supported ImageVersions in a location.
	ImageVersions []*ImageVersion `protobuf:"bytes,1,rep,name=image_versions,json=imageVersions,proto3" json:"image_versions,omitempty"`
	// The page token used to query for the next page if one exists.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

The ImageVersions in a project and location.

func (*ListImageVersionsResponse) Descriptor deprecated 

func (*ListImageVersionsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListImageVersionsResponse.ProtoReflect.Descriptor instead.

func (*ListImageVersionsResponse) GetImageVersions 

func (x *ListImageVersionsResponse) GetImageVersions() []*ImageVersion

func (*ListImageVersionsResponse) GetNextPageToken 

func (x *ListImageVersionsResponse) GetNextPageToken() string

func (*ListImageVersionsResponse) ProtoMessage 

func (*ListImageVersionsResponse) ProtoMessage()

func (*ListImageVersionsResponse) ProtoReflect 

func (x *ListImageVersionsResponse) ProtoReflect() protoreflect.Message

func (*ListImageVersionsResponse) Reset 

func (x *ListImageVersionsResponse) Reset()

func (*ListImageVersionsResponse) String 

func (x *ListImageVersionsResponse) String() string

type LoadSnapshotRequest 

type LoadSnapshotRequest struct {

	// The resource name of the target environment in the form:
	// "projects/{projectId}/locations/{locationId}/environments/{environmentId}"
	Environment string `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
	// A Cloud Storage path to a snapshot to load, e.g.:
	// "gs://my-bucket/snapshots/project_location_environment_timestamp".
	SnapshotPath string `protobuf:"bytes,2,opt,name=snapshot_path,json=snapshotPath,proto3" json:"snapshot_path,omitempty"`
	// Whether or not to skip installing Pypi packages when loading the
	// environment's state.
	SkipPypiPackagesInstallation bool `` /* 150-byte string literal not displayed */
	// Whether or not to skip setting environment variables when loading the
	// environment's state.
	SkipEnvironmentVariablesSetting bool `` /* 159-byte string literal not displayed */
	// Whether or not to skip setting Airflow overrides when loading the
	// environment's state.
	SkipAirflowOverridesSetting bool `` /* 147-byte string literal not displayed */
	// Whether or not to skip copying Cloud Storage data when loading the
	// environment's state.
	SkipGcsDataCopying bool `protobuf:"varint,6,opt,name=skip_gcs_data_copying,json=skipGcsDataCopying,proto3" json:"skip_gcs_data_copying,omitempty"`
	// contains filtered or unexported fields
}

Request to load a snapshot into a Cloud Composer environment.

func (*LoadSnapshotRequest) Descriptor deprecated 

func (*LoadSnapshotRequest) Descriptor() ([]byte, []int)

Deprecated: Use LoadSnapshotRequest.ProtoReflect.Descriptor instead.

func (*LoadSnapshotRequest) GetEnvironment 

func (x *LoadSnapshotRequest) GetEnvironment() string

func (*LoadSnapshotRequest) GetSkipAirflowOverridesSetting 

func (x *LoadSnapshotRequest) GetSkipAirflowOverridesSetting() bool

func (*LoadSnapshotRequest) GetSkipEnvironmentVariablesSetting 

func (x *LoadSnapshotRequest) GetSkipEnvironmentVariablesSetting() bool

func (*LoadSnapshotRequest) GetSkipGcsDataCopying 

func (x *LoadSnapshotRequest) GetSkipGcsDataCopying() bool

func (*LoadSnapshotRequest) GetSkipPypiPackagesInstallation 

func (x *LoadSnapshotRequest) GetSkipPypiPackagesInstallation() bool

func (*LoadSnapshotRequest) GetSnapshotPath 

func (x *LoadSnapshotRequest) GetSnapshotPath() string

func (*LoadSnapshotRequest) ProtoMessage 

func (*LoadSnapshotRequest) ProtoMessage()

func (*LoadSnapshotRequest) ProtoReflect 

func (x *LoadSnapshotRequest) ProtoReflect() protoreflect.Message

func (*LoadSnapshotRequest) Reset 

func (x *LoadSnapshotRequest) Reset()

func (*LoadSnapshotRequest) String 

func (x *LoadSnapshotRequest) String() string

type LoadSnapshotResponse 

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

Response to LoadSnapshotRequest.

func (*LoadSnapshotResponse) Descriptor deprecated 

func (*LoadSnapshotResponse) Descriptor() ([]byte, []int)

Deprecated: Use LoadSnapshotResponse.ProtoReflect.Descriptor instead.

func (*LoadSnapshotResponse) ProtoMessage 

func (*LoadSnapshotResponse) ProtoMessage()

func (*LoadSnapshotResponse) ProtoReflect 

func (x *LoadSnapshotResponse) ProtoReflect() protoreflect.Message

func (*LoadSnapshotResponse) Reset 

func (x *LoadSnapshotResponse) Reset()

func (*LoadSnapshotResponse) String 

func (x *LoadSnapshotResponse) String() string

type MaintenanceWindow 

type MaintenanceWindow struct {

	// Required. Start time of the first recurrence of the maintenance window.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Required. Maintenance window end time. It is used only to calculate the
	// duration of the maintenance window. The value for end_time must be in the
	// future, relative to `start_time`.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Required. Maintenance window recurrence. Format is a subset of
	// [RFC-5545](https://tools.ietf.org/html/rfc5545) `RRULE`. The only allowed
	// values for `FREQ` field are `FREQ=DAILY` and `FREQ=WEEKLY;BYDAY=...`
	// Example values: `FREQ=WEEKLY;BYDAY=TU,WE`, `FREQ=DAILY`.
	Recurrence string `protobuf:"bytes,3,opt,name=recurrence,proto3" json:"recurrence,omitempty"`
	// contains filtered or unexported fields
}

The configuration settings for Cloud Composer maintenance window. The following example:

``` 

{
  "startTime":"2019-08-01T01:00:00Z"
  "endTime":"2019-08-01T07:00:00Z"
  "recurrence":"FREQ=WEEKLY;BYDAY=TU,WE"
}

```

would define a maintenance window between 01 and 07 hours UTC during each Tuesday and Wednesday.

func (*MaintenanceWindow) Descriptor deprecated 

func (*MaintenanceWindow) Descriptor() ([]byte, []int)

Deprecated: Use MaintenanceWindow.ProtoReflect.Descriptor instead.

func (*MaintenanceWindow) GetEndTime 

func (x *MaintenanceWindow) GetEndTime() *timestamppb.Timestamp

func (*MaintenanceWindow) GetRecurrence 

func (x *MaintenanceWindow) GetRecurrence() string

func (*MaintenanceWindow) GetStartTime 

func (x *MaintenanceWindow) GetStartTime() *timestamppb.Timestamp

func (*MaintenanceWindow) ProtoMessage 

func (*MaintenanceWindow) ProtoMessage()

func (*MaintenanceWindow) ProtoReflect 

func (x *MaintenanceWindow) ProtoReflect() protoreflect.Message

func (*MaintenanceWindow) Reset 

func (x *MaintenanceWindow) Reset()

func (*MaintenanceWindow) String 

func (x *MaintenanceWindow) String() string

type MasterAuthorizedNetworksConfig 

type MasterAuthorizedNetworksConfig struct {

	// Whether or not master authorized networks feature is enabled.
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// Up to 50 external networks that could access Kubernetes master through
	// HTTPS.
	CidrBlocks []*MasterAuthorizedNetworksConfig_CidrBlock `protobuf:"bytes,2,rep,name=cidr_blocks,json=cidrBlocks,proto3" json:"cidr_blocks,omitempty"`
	// contains filtered or unexported fields
}

Configuration options for the master authorized networks feature. Enabled master authorized networks will disallow all external traffic to access Kubernetes master through HTTPS except traffic from the given CIDR blocks, Google Compute Engine Public IPs and Google Prod IPs.

func (*MasterAuthorizedNetworksConfig) Descriptor deprecated 

func (*MasterAuthorizedNetworksConfig) Descriptor() ([]byte, []int)

Deprecated: Use MasterAuthorizedNetworksConfig.ProtoReflect.Descriptor instead.

func (*MasterAuthorizedNetworksConfig) GetCidrBlocks 

func (x *MasterAuthorizedNetworksConfig) GetCidrBlocks() []*MasterAuthorizedNetworksConfig_CidrBlock

func (*MasterAuthorizedNetworksConfig) GetEnabled 

func (x *MasterAuthorizedNetworksConfig) GetEnabled() bool

func (*MasterAuthorizedNetworksConfig) ProtoMessage 

func (*MasterAuthorizedNetworksConfig) ProtoMessage()

func (*MasterAuthorizedNetworksConfig) ProtoReflect 

func (x *MasterAuthorizedNetworksConfig) ProtoReflect() protoreflect.Message

func (*MasterAuthorizedNetworksConfig) Reset 

func (x *MasterAuthorizedNetworksConfig) Reset()

func (*MasterAuthorizedNetworksConfig) String 

func (x *MasterAuthorizedNetworksConfig) String() string

type MasterAuthorizedNetworksConfig_CidrBlock 

type MasterAuthorizedNetworksConfig_CidrBlock struct {

	// User-defined name that identifies the CIDR block.
	DisplayName string `protobuf:"bytes,1,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// CIDR block that must be specified in CIDR notation.
	CidrBlock string `protobuf:"bytes,2,opt,name=cidr_block,json=cidrBlock,proto3" json:"cidr_block,omitempty"`
	// contains filtered or unexported fields
}

CIDR block with an optional name.

func (*MasterAuthorizedNetworksConfig_CidrBlock) Descriptor deprecated 

func (*MasterAuthorizedNetworksConfig_CidrBlock) Descriptor() ([]byte, []int)

Deprecated: Use MasterAuthorizedNetworksConfig_CidrBlock.ProtoReflect.Descriptor instead.

func (*MasterAuthorizedNetworksConfig_CidrBlock) GetCidrBlock 

func (x *MasterAuthorizedNetworksConfig_CidrBlock) GetCidrBlock() string

func (*MasterAuthorizedNetworksConfig_CidrBlock) GetDisplayName 

func (x *MasterAuthorizedNetworksConfig_CidrBlock) GetDisplayName() string

func (*MasterAuthorizedNetworksConfig_CidrBlock) ProtoMessage 

func (*MasterAuthorizedNetworksConfig_CidrBlock) ProtoMessage()

func (*MasterAuthorizedNetworksConfig_CidrBlock) ProtoReflect 

func (x *MasterAuthorizedNetworksConfig_CidrBlock) ProtoReflect() protoreflect.Message

func (*MasterAuthorizedNetworksConfig_CidrBlock) Reset 

func (x *MasterAuthorizedNetworksConfig_CidrBlock) Reset()

func (*MasterAuthorizedNetworksConfig_CidrBlock) String 

func (x *MasterAuthorizedNetworksConfig_CidrBlock) String() string

type NetworkingConfig 

type NetworkingConfig struct {

	// Optional. Indicates the user requested specifc connection type between
	// Tenant and Customer projects. You cannot set networking connection type in
	// public IP environment.
	ConnectionType NetworkingConfig_ConnectionType `` /* 192-byte string literal not displayed */
	// contains filtered or unexported fields
}

Configuration options for networking connections in the Composer 2 environment.

func (*NetworkingConfig) Descriptor deprecated 

func (*NetworkingConfig) Descriptor() ([]byte, []int)

Deprecated: Use NetworkingConfig.ProtoReflect.Descriptor instead.

func (*NetworkingConfig) GetConnectionType 

func (x *NetworkingConfig) GetConnectionType() NetworkingConfig_ConnectionType

func (*NetworkingConfig) ProtoMessage 

func (*NetworkingConfig) ProtoMessage()

func (*NetworkingConfig) ProtoReflect 

func (x *NetworkingConfig) ProtoReflect() protoreflect.Message

func (*NetworkingConfig) Reset 

func (x *NetworkingConfig) Reset()

func (*NetworkingConfig) String 

func (x *NetworkingConfig) String() string

type NetworkingConfig_ConnectionType 

type NetworkingConfig_ConnectionType int32

Represents connection type between Composer environment in Customer Project and the corresponding Tenant project, from a predefined list of available connection modes. 

const (
	// No specific connection type was requested, so the environment uses
	// the default value corresponding to the rest of its configuration.
	NetworkingConfig_CONNECTION_TYPE_UNSPECIFIED NetworkingConfig_ConnectionType = 0
	// Requests the use of VPC peerings for connecting the Customer and Tenant
	// projects.
	NetworkingConfig_VPC_PEERING NetworkingConfig_ConnectionType = 1
	// Requests the use of Private Service Connect for connecting the Customer
	// and Tenant projects.
	NetworkingConfig_PRIVATE_SERVICE_CONNECT NetworkingConfig_ConnectionType = 2
)

func (NetworkingConfig_ConnectionType) Descriptor 

func (NetworkingConfig_ConnectionType) Descriptor() protoreflect.EnumDescriptor

func (NetworkingConfig_ConnectionType) Enum 

func (x NetworkingConfig_ConnectionType) Enum() *NetworkingConfig_ConnectionType

func (NetworkingConfig_ConnectionType) EnumDescriptor deprecated 

func (NetworkingConfig_ConnectionType) EnumDescriptor() ([]byte, []int)

Deprecated: Use NetworkingConfig_ConnectionType.Descriptor instead.

func (NetworkingConfig_ConnectionType) Number 

func (x NetworkingConfig_ConnectionType) Number() protoreflect.EnumNumber

func (NetworkingConfig_ConnectionType) String 

func (x NetworkingConfig_ConnectionType) String() string

func (NetworkingConfig_ConnectionType) Type 

func (NetworkingConfig_ConnectionType) Type() protoreflect.EnumType

type NodeConfig 

type NodeConfig struct {

	// Optional. The Compute Engine [zone](/compute/docs/regions-zones) in which
	// to deploy the VMs used to run the Apache Airflow software, specified as a
	// [relative resource
	// name](/apis/design/resource_names#relative_resource_name). For example:
	// "projects/{projectId}/zones/{zoneId}".
	//
	// This `location` must belong to the enclosing environment's project and
	// location. If both this field and `nodeConfig.machineType` are specified,
	// `nodeConfig.machineType` must belong to this `location`; if both are
	// unspecified, the service will pick a zone in the Compute Engine region
	// corresponding to the Cloud Composer location, and propagate that choice to
	// both fields. If only one field (`location` or `nodeConfig.machineType`) is
	// specified, the location information from the specified field will be
	// propagated to the unspecified field.
	//
	// This field is supported for Cloud Composer environments in versions
	// composer-1.*.*-airflow-*.*.*.
	Location string `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`
	// Optional. The Compute Engine
	// [machine type](/compute/docs/machine-types) used for cluster instances,
	// specified as a
	// [relative resource
	// name](/apis/design/resource_names#relative_resource_name). For example:
	// "projects/{projectId}/zones/{zoneId}/machineTypes/{machineTypeId}".
	//
	// The `machineType` must belong to the enclosing environment's project and
	// location. If both this field and `nodeConfig.location` are specified,
	// this `machineType` must belong to the `nodeConfig.location`; if both are
	// unspecified, the service will pick a zone in the Compute Engine region
	// corresponding to the Cloud Composer location, and propagate that choice to
	// both fields. If exactly one of this field and `nodeConfig.location` is
	// specified, the location information from the specified field will be
	// propagated to the unspecified field.
	//
	// The `machineTypeId` must not be a [shared-core machine
	// type](/compute/docs/machine-types#sharedcore).
	//
	// If this field is unspecified, the `machineTypeId` defaults
	// to "n1-standard-1".
	//
	// This field is supported for Cloud Composer environments in versions
	// composer-1.*.*-airflow-*.*.*.
	MachineType string `protobuf:"bytes,2,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"`
	// Optional. The Compute Engine network to be used for machine
	// communications, specified as a
	// [relative resource
	// name](/apis/design/resource_names#relative_resource_name). For example:
	// "projects/{projectId}/global/networks/{networkId}".
	//
	// If unspecified, the default network in the environment's project is used.
	// If a [Custom Subnet Network](/vpc/docs/vpc#vpc_networks_and_subnets)
	// is provided, `nodeConfig.subnetwork` must also be provided. For
	// [Shared VPC](/vpc/docs/shared-vpc) subnetwork requirements, see
	// `nodeConfig.subnetwork`.
	Network string `protobuf:"bytes,3,opt,name=network,proto3" json:"network,omitempty"`
	// Optional. The Compute Engine subnetwork to be used for machine
	// communications, specified as a
	// [relative resource
	// name](/apis/design/resource_names#relative_resource_name). For example:
	// "projects/{projectId}/regions/{regionId}/subnetworks/{subnetworkId}"
	//
	// If a subnetwork is provided, `nodeConfig.network` must also be provided,
	// and the subnetwork must belong to the enclosing environment's project and
	// location.
	Subnetwork string `protobuf:"bytes,4,opt,name=subnetwork,proto3" json:"subnetwork,omitempty"`
	// Optional. The disk size in GB used for node VMs. Minimum size is 30GB.
	// If unspecified, defaults to 100GB. Cannot be updated.
	//
	// This field is supported for Cloud Composer environments in versions
	// composer-1.*.*-airflow-*.*.*.
	DiskSizeGb int32 `protobuf:"varint,5,opt,name=disk_size_gb,json=diskSizeGb,proto3" json:"disk_size_gb,omitempty"`
	// Optional. The set of Google API scopes to be made available on all
	// node VMs. If `oauth_scopes` is empty, defaults to
	// ["https://www.googleapis.com/auth/cloud-platform"]. Cannot be updated.
	//
	// This field is supported for Cloud Composer environments in versions
	// composer-1.*.*-airflow-*.*.*.
	OauthScopes []string `protobuf:"bytes,6,rep,name=oauth_scopes,json=oauthScopes,proto3" json:"oauth_scopes,omitempty"`
	// Optional. The Google Cloud Platform Service Account to be used by the
	// workloads. If a service account is not specified, the "default" Compute
	// Engine service account is used. Cannot be updated.
	ServiceAccount string `protobuf:"bytes,7,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
	// Optional. The list of instance tags applied to all node VMs. Tags are used
	// to identify valid sources or targets for network firewalls. Each tag within
	// the list must comply with [RFC1035](https://www.ietf.org/rfc/rfc1035.txt).
	// Cannot be updated.
	//
	// This field is supported for Cloud Composer environments in versions
	// composer-1.*.*-airflow-*.*.*.
	Tags []string `protobuf:"bytes,8,rep,name=tags,proto3" json:"tags,omitempty"`
	// Optional. The IPAllocationPolicy fields for the GKE cluster.
	IpAllocationPolicy *IPAllocationPolicy `protobuf:"bytes,9,opt,name=ip_allocation_policy,json=ipAllocationPolicy,proto3" json:"ip_allocation_policy,omitempty"`
	// Optional. The maximum number of pods per node in the Cloud Composer GKE
	// cluster. The value must be between 8 and 110 and it can be set only if the
	// environment is VPC-native. The default value is 32. Values of this field
	// will be propagated both to the `default-pool` node pool of the newly
	// created GKE cluster, and to the default "Maximum Pods per Node" value which
	// is used for newly created node pools if their value is not explicitly set
	// during node pool creation. For more information, see [Optimizing IP address
	// allocation]
	// (https://cloud.google.com/kubernetes-engine/docs/how-to/flexible-pod-cidr).
	// Cannot be updated.
	//
	// This field is supported for Cloud Composer environments in versions
	// composer-1.*.*-airflow-*.*.*.
	MaxPodsPerNode int32 `protobuf:"varint,10,opt,name=max_pods_per_node,json=maxPodsPerNode,proto3" json:"max_pods_per_node,omitempty"`
	// Optional. Deploys 'ip-masq-agent' daemon set in the GKE cluster and defines
	// nonMasqueradeCIDRs equals to pod IP range so IP masquerading is used for
	// all destination addresses, except between pods traffic.
	//
	// See:
	// https://cloud.google.com/kubernetes-engine/docs/how-to/ip-masquerade-agent
	EnableIpMasqAgent bool `protobuf:"varint,11,opt,name=enable_ip_masq_agent,json=enableIpMasqAgent,proto3" json:"enable_ip_masq_agent,omitempty"`
	// contains filtered or unexported fields
}

The configuration information for the Kubernetes Engine nodes running the Apache Airflow software.

func (*NodeConfig) Descriptor deprecated 

func (*NodeConfig) Descriptor() ([]byte, []int)

Deprecated: Use NodeConfig.ProtoReflect.Descriptor instead.

func (*NodeConfig) GetDiskSizeGb 

func (x *NodeConfig) GetDiskSizeGb() int32

func (*NodeConfig) GetEnableIpMasqAgent 

func (x *NodeConfig) GetEnableIpMasqAgent() bool

func (*NodeConfig) GetIpAllocationPolicy 

func (x *NodeConfig) GetIpAllocationPolicy() *IPAllocationPolicy

func (*NodeConfig) GetLocation 

func (x *NodeConfig) GetLocation() string

func (*NodeConfig) GetMachineType 

func (x *NodeConfig) GetMachineType() string

func (*NodeConfig) GetMaxPodsPerNode 

func (x *NodeConfig) GetMaxPodsPerNode() int32

func (*NodeConfig) GetNetwork 

func (x *NodeConfig) GetNetwork() string

func (*NodeConfig) GetOauthScopes 

func (x *NodeConfig) GetOauthScopes() []string

func (*NodeConfig) GetServiceAccount 

func (x *NodeConfig) GetServiceAccount() string

func (*NodeConfig) GetSubnetwork 

func (x *NodeConfig) GetSubnetwork() string

func (*NodeConfig) GetTags 

func (x *NodeConfig) GetTags() []string

func (*NodeConfig) ProtoMessage 

func (*NodeConfig) ProtoMessage()

func (*NodeConfig) ProtoReflect 

func (x *NodeConfig) ProtoReflect() protoreflect.Message

func (*NodeConfig) Reset 

func (x *NodeConfig) Reset()

func (*NodeConfig) String 

func (x *NodeConfig) String() string

type OperationMetadata 

type OperationMetadata struct {

	// Output only. The current operation state.
	State OperationMetadata_State `` /* 144-byte string literal not displayed */
	// Output only. The type of operation being performed.
	OperationType OperationMetadata_Type `` /* 180-byte string literal not displayed */
	// Output only. The resource being operated on, as a [relative resource name](
	// /apis/design/resource_names#relative_resource_name).
	Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
	// Output only. The UUID of the resource being operated on.
	ResourceUuid string `protobuf:"bytes,4,opt,name=resource_uuid,json=resourceUuid,proto3" json:"resource_uuid,omitempty"`
	// Output only. The time the operation was submitted to the server.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The time when the operation terminated, regardless of its
	// success. This field is unset if the operation is still ongoing.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// contains filtered or unexported fields
}

Metadata describing an operation.

func (*OperationMetadata) Descriptor deprecated 

func (*OperationMetadata) Descriptor() ([]byte, []int)

Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.

func (*OperationMetadata) GetCreateTime 

func (x *OperationMetadata) GetCreateTime() *timestamppb.Timestamp

func (*OperationMetadata) GetEndTime 

func (x *OperationMetadata) GetEndTime() *timestamppb.Timestamp

func (*OperationMetadata) GetOperationType 

func (x *OperationMetadata) GetOperationType() OperationMetadata_Type

func (*OperationMetadata) GetResource 

func (x *OperationMetadata) GetResource() string

func (*OperationMetadata) GetResourceUuid 

func (x *OperationMetadata) GetResourceUuid() string

func (*OperationMetadata) GetState 

func (x *OperationMetadata) GetState() OperationMetadata_State

func (*OperationMetadata) ProtoMessage 

func (*OperationMetadata) ProtoMessage()

func (*OperationMetadata) ProtoReflect 

func (x *OperationMetadata) ProtoReflect() protoreflect.Message

func (*OperationMetadata) Reset 

func (x *OperationMetadata) Reset()

func (*OperationMetadata) String 

func (x *OperationMetadata) String() string

type OperationMetadata_State 

type OperationMetadata_State int32

An enum describing the overall state of an operation. 

const (
	// Unused.
	OperationMetadata_STATE_UNSPECIFIED OperationMetadata_State = 0
	// The operation has been created but is not yet started.
	OperationMetadata_PENDING OperationMetadata_State = 1
	// The operation is underway.
	OperationMetadata_RUNNING OperationMetadata_State = 2
	// The operation completed successfully.
	OperationMetadata_SUCCESSFUL OperationMetadata_State = 3
	// The operation is no longer running but did not succeed.
	OperationMetadata_FAILED OperationMetadata_State = 4
)

func (OperationMetadata_State) Descriptor 

func (OperationMetadata_State) Descriptor() protoreflect.EnumDescriptor

func (OperationMetadata_State) Enum 

func (x OperationMetadata_State) Enum() *OperationMetadata_State

func (OperationMetadata_State) EnumDescriptor deprecated 

func (OperationMetadata_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use OperationMetadata_State.Descriptor instead.

func (OperationMetadata_State) Number 

func (x OperationMetadata_State) Number() protoreflect.EnumNumber

func (OperationMetadata_State) String 

func (x OperationMetadata_State) String() string

func (OperationMetadata_State) Type 

func (OperationMetadata_State) Type() protoreflect.EnumType

type OperationMetadata_Type 

type OperationMetadata_Type int32

Type of longrunning operation. 

const (
	// Unused.
	OperationMetadata_TYPE_UNSPECIFIED OperationMetadata_Type = 0
	// A resource creation operation.
	OperationMetadata_CREATE OperationMetadata_Type = 1
	// A resource deletion operation.
	OperationMetadata_DELETE OperationMetadata_Type = 2
	// A resource update operation.
	OperationMetadata_UPDATE OperationMetadata_Type = 3
	// A resource check operation.
	OperationMetadata_CHECK OperationMetadata_Type = 4
	// Saves snapshot of the resource operation.
	OperationMetadata_SAVE_SNAPSHOT OperationMetadata_Type = 5
	// Loads snapshot of the resource operation.
	OperationMetadata_LOAD_SNAPSHOT OperationMetadata_Type = 6
)

func (OperationMetadata_Type) Descriptor 

func (OperationMetadata_Type) Descriptor() protoreflect.EnumDescriptor

func (OperationMetadata_Type) Enum 

func (x OperationMetadata_Type) Enum() *OperationMetadata_Type

func (OperationMetadata_Type) EnumDescriptor deprecated 

func (OperationMetadata_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use OperationMetadata_Type.Descriptor instead.

func (OperationMetadata_Type) Number 

func (x OperationMetadata_Type) Number() protoreflect.EnumNumber

func (OperationMetadata_Type) String 

func (x OperationMetadata_Type) String() string

func (OperationMetadata_Type) Type 

func (OperationMetadata_Type) Type() protoreflect.EnumType

type PollAirflowCommandResponse 

type PollAirflowCommandResponse struct {

	// Output from the command execution. It may not contain the full output
	// and the caller may need to poll for more lines.
	Output []*PollAirflowCommandResponse_Line `protobuf:"bytes,1,rep,name=output,proto3" json:"output,omitempty"`
	// Whether the command execution has finished and there is no more output.
	OutputEnd bool `protobuf:"varint,2,opt,name=output_end,json=outputEnd,proto3" json:"output_end,omitempty"`
	// The result exit status of the command.
	ExitInfo *PollAirflowCommandResponse_ExitInfo `protobuf:"bytes,3,opt,name=exit_info,json=exitInfo,proto3" json:"exit_info,omitempty"`
	// contains filtered or unexported fields
}

Response to PollAirflowCommandRequest.

func (*PollAirflowCommandResponse) Descriptor deprecated 

func (*PollAirflowCommandResponse) Descriptor() ([]byte, []int)

Deprecated: Use PollAirflowCommandResponse.ProtoReflect.Descriptor instead.

func (*PollAirflowCommandResponse) GetExitInfo 

func (x *PollAirflowCommandResponse) GetExitInfo() *PollAirflowCommandResponse_ExitInfo

func (*PollAirflowCommandResponse) GetOutput 

func (x *PollAirflowCommandResponse) GetOutput() []*PollAirflowCommandResponse_Line

func (*PollAirflowCommandResponse) GetOutputEnd 

func (x *PollAirflowCommandResponse) GetOutputEnd() bool

func (*PollAirflowCommandResponse) ProtoMessage 

func (*PollAirflowCommandResponse) ProtoMessage()

func (*PollAirflowCommandResponse) ProtoReflect 

func (x *PollAirflowCommandResponse) ProtoReflect() protoreflect.Message

func (*PollAirflowCommandResponse) Reset 

func (x *PollAirflowCommandResponse) Reset()

func (*PollAirflowCommandResponse) String 

func (x *PollAirflowCommandResponse) String() string

type PollAirflowCommandResponse_ExitInfo 

type PollAirflowCommandResponse_ExitInfo struct {

	// The exit code from the command execution.
	ExitCode int32 `protobuf:"varint,1,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	// Error message. Empty if there was no error.
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

Information about how a command ended.

func (*PollAirflowCommandResponse_ExitInfo) Descriptor deprecated 

func (*PollAirflowCommandResponse_ExitInfo) Descriptor() ([]byte, []int)

Deprecated: Use PollAirflowCommandResponse_ExitInfo.ProtoReflect.Descriptor instead.

func (*PollAirflowCommandResponse_ExitInfo) GetError 

func (x *PollAirflowCommandResponse_ExitInfo) GetError() string

func (*PollAirflowCommandResponse_ExitInfo) GetExitCode 

func (x *PollAirflowCommandResponse_ExitInfo) GetExitCode() int32

func (*PollAirflowCommandResponse_ExitInfo) ProtoMessage 

func (*PollAirflowCommandResponse_ExitInfo) ProtoMessage()

func (*PollAirflowCommandResponse_ExitInfo) ProtoReflect 

func (x *PollAirflowCommandResponse_ExitInfo) ProtoReflect() protoreflect.Message

func (*PollAirflowCommandResponse_ExitInfo) Reset 

func (x *PollAirflowCommandResponse_ExitInfo) Reset()

func (*PollAirflowCommandResponse_ExitInfo) String 

func (x *PollAirflowCommandResponse_ExitInfo) String() string

type PollAirflowCommandResponse_Line 

type PollAirflowCommandResponse_Line struct {

	// Number of the line.
	LineNumber int32 `protobuf:"varint,1,opt,name=line_number,json=lineNumber,proto3" json:"line_number,omitempty"`
	// Text content of the log line.
	Content string `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

Contains information about a single line from logs.

func (*PollAirflowCommandResponse_Line) Descriptor deprecated 

func (*PollAirflowCommandResponse_Line) Descriptor() ([]byte, []int)

Deprecated: Use PollAirflowCommandResponse_Line.ProtoReflect.Descriptor instead.

func (*PollAirflowCommandResponse_Line) GetContent 

func (x *PollAirflowCommandResponse_Line) GetContent() string

func (*PollAirflowCommandResponse_Line) GetLineNumber 

func (x *PollAirflowCommandResponse_Line) GetLineNumber() int32

func (*PollAirflowCommandResponse_Line) ProtoMessage 

func (*PollAirflowCommandResponse_Line) ProtoMessage()

func (*PollAirflowCommandResponse_Line) ProtoReflect 

func (x *PollAirflowCommandResponse_Line) ProtoReflect() protoreflect.Message

func (*PollAirflowCommandResponse_Line) Reset 

func (x *PollAirflowCommandResponse_Line) Reset()

func (*PollAirflowCommandResponse_Line) String 

func (x *PollAirflowCommandResponse_Line) String() string

type PrivateClusterConfig 

type PrivateClusterConfig struct {

	// Optional. If `true`, access to the public endpoint of the GKE cluster is
	// denied.
	EnablePrivateEndpoint bool `` /* 127-byte string literal not displayed */
	// Optional. The CIDR block from which IPv4 range for GKE master will be
	// reserved. If left blank, the default value of '172.16.0.0/23' is used.
	MasterIpv4CidrBlock string `protobuf:"bytes,2,opt,name=master_ipv4_cidr_block,json=masterIpv4CidrBlock,proto3" json:"master_ipv4_cidr_block,omitempty"`
	// Output only. The IP range in CIDR notation to use for the hosted master
	// network. This range is used for assigning internal IP addresses to the
	// cluster master or set of masters and to the internal load balancer virtual
	// IP. This range must not overlap with any other ranges in use within the
	// cluster's network.
	MasterIpv4ReservedRange string `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

Configuration options for the private GKE cluster in a Cloud Composer environment.

func (*PrivateClusterConfig) Descriptor deprecated 

func (*PrivateClusterConfig) Descriptor() ([]byte, []int)

Deprecated: Use PrivateClusterConfig.ProtoReflect.Descriptor instead.

func (*PrivateClusterConfig) GetEnablePrivateEndpoint 

func (x *PrivateClusterConfig) GetEnablePrivateEndpoint() bool

func (*PrivateClusterConfig) GetMasterIpv4CidrBlock 

func (x *PrivateClusterConfig) GetMasterIpv4CidrBlock() string

func (*PrivateClusterConfig) GetMasterIpv4ReservedRange 

func (x *PrivateClusterConfig) GetMasterIpv4ReservedRange() string

func (*PrivateClusterConfig) ProtoMessage 

func (*PrivateClusterConfig) ProtoMessage()

func (*PrivateClusterConfig) ProtoReflect 

func (x *PrivateClusterConfig) ProtoReflect() protoreflect.Message

func (*PrivateClusterConfig) Reset 

func (x *PrivateClusterConfig) Reset()

func (*PrivateClusterConfig) String 

func (x *PrivateClusterConfig) String() string

type PrivateEnvironmentConfig 

type PrivateEnvironmentConfig struct {

	// Optional. If `true`, a Private IP Cloud Composer environment is created.
	// If this field is set to true, `IPAllocationPolicy.use_ip_aliases` must be
	// set to true for Cloud Composer environments in versions
	// composer-1.*.*-airflow-*.*.*.
	EnablePrivateEnvironment bool `` /* 136-byte string literal not displayed */
	// Optional. Configuration for the private GKE cluster for a Private IP
	// Cloud Composer environment.
	PrivateClusterConfig *PrivateClusterConfig `protobuf:"bytes,2,opt,name=private_cluster_config,json=privateClusterConfig,proto3" json:"private_cluster_config,omitempty"`
	// Optional. The CIDR block from which IP range for web server will be
	// reserved. Needs to be disjoint from
	// private_cluster_config.master_ipv4_cidr_block and
	// cloud_sql_ipv4_cidr_block.
	//
	// This field is supported for Cloud Composer environments in versions
	// composer-1.*.*-airflow-*.*.*.
	WebServerIpv4CidrBlock string `` /* 133-byte string literal not displayed */
	// Optional. The CIDR block from which IP range in tenant project will be
	// reserved for Cloud SQL. Needs to be disjoint from
	// web_server_ipv4_cidr_block
	CloudSqlIpv4CidrBlock string `` /* 130-byte string literal not displayed */
	// Output only. The IP range reserved for the tenant project's App Engine VMs.
	//
	// This field is supported for Cloud Composer environments in versions
	// composer-1.*.*-airflow-*.*.*.
	WebServerIpv4ReservedRange string `` /* 145-byte string literal not displayed */
	// Optional. The CIDR block from which IP range for Cloud Composer Network in
	// tenant project will be reserved. Needs to be disjoint from
	// private_cluster_config.master_ipv4_cidr_block and
	// cloud_sql_ipv4_cidr_block.
	//
	// This field is supported for Cloud Composer environments in versions
	// composer-2.*.*-airflow-*.*.* and newer.
	CloudComposerNetworkIpv4CidrBlock string `` /* 168-byte string literal not displayed */
	// Output only. The IP range reserved for the tenant project's Cloud Composer
	// network.
	//
	// This field is supported for Cloud Composer environments in versions
	// composer-2.*.*-airflow-*.*.* and newer.
	CloudComposerNetworkIpv4ReservedRange string `` /* 180-byte string literal not displayed */
	// Optional. When enabled, IPs from public (non-RFC1918) ranges can be used
	// for `IPAllocationPolicy.cluster_ipv4_cidr_block` and
	// `IPAllocationPolicy.service_ipv4_cidr_block`.
	EnablePrivatelyUsedPublicIps bool `` /* 152-byte string literal not displayed */
	// Optional. When specified, the environment will use Private Service Connect
	// instead of VPC peerings to connect to Cloud SQL in the Tenant Project,
	// and the PSC endpoint in the Customer Project will use an IP address from
	// this subnetwork.
	CloudComposerConnectionSubnetwork string `` /* 164-byte string literal not displayed */
	// Optional. Configuration for the network connections configuration in the
	// environment.
	NetworkingConfig *NetworkingConfig `protobuf:"bytes,10,opt,name=networking_config,json=networkingConfig,proto3" json:"networking_config,omitempty"`
	// contains filtered or unexported fields
}

The configuration information for configuring a Private IP Cloud Composer environment.

func (*PrivateEnvironmentConfig) Descriptor deprecated 

func (*PrivateEnvironmentConfig) Descriptor() ([]byte, []int)

Deprecated: Use PrivateEnvironmentConfig.ProtoReflect.Descriptor instead.

func (*PrivateEnvironmentConfig) GetCloudComposerConnectionSubnetwork 

func (x *PrivateEnvironmentConfig) GetCloudComposerConnectionSubnetwork() string

func (*PrivateEnvironmentConfig) GetCloudComposerNetworkIpv4CidrBlock 

func (x *PrivateEnvironmentConfig) GetCloudComposerNetworkIpv4CidrBlock() string

func (*PrivateEnvironmentConfig) GetCloudComposerNetworkIpv4ReservedRange 

func (x *PrivateEnvironmentConfig) GetCloudComposerNetworkIpv4ReservedRange() string

func (*PrivateEnvironmentConfig) GetCloudSqlIpv4CidrBlock 

func (x *PrivateEnvironmentConfig) GetCloudSqlIpv4CidrBlock() string

func (*PrivateEnvironmentConfig) GetEnablePrivateEnvironment 

func (x *PrivateEnvironmentConfig) GetEnablePrivateEnvironment() bool

func (*PrivateEnvironmentConfig) GetEnablePrivatelyUsedPublicIps 

func (x *PrivateEnvironmentConfig) GetEnablePrivatelyUsedPublicIps() bool

func (*PrivateEnvironmentConfig) GetNetworkingConfig 

func (x *PrivateEnvironmentConfig) GetNetworkingConfig() *NetworkingConfig

func (*PrivateEnvironmentConfig) GetPrivateClusterConfig 

func (x *PrivateEnvironmentConfig) GetPrivateClusterConfig() *PrivateClusterConfig

func (*PrivateEnvironmentConfig) GetWebServerIpv4CidrBlock 

func (x *PrivateEnvironmentConfig) GetWebServerIpv4CidrBlock() string

func (*PrivateEnvironmentConfig) GetWebServerIpv4ReservedRange 

func (x *PrivateEnvironmentConfig) GetWebServerIpv4ReservedRange() string

func (*PrivateEnvironmentConfig) ProtoMessage 

func (*PrivateEnvironmentConfig) ProtoMessage()

func (*PrivateEnvironmentConfig) ProtoReflect 

func (x *PrivateEnvironmentConfig) ProtoReflect() protoreflect.Message

func (*PrivateEnvironmentConfig) Reset 

func (x *PrivateEnvironmentConfig) Reset()

func (*PrivateEnvironmentConfig) String 

func (x *PrivateEnvironmentConfig) String() string

type RecoveryConfig 

type RecoveryConfig struct {

	// Optional. The configuration for scheduled snapshot creation mechanism.
	ScheduledSnapshotsConfig *ScheduledSnapshotsConfig `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

The Recovery settings of an environment.

func (*RecoveryConfig) Descriptor deprecated 

func (*RecoveryConfig) Descriptor() ([]byte, []int)

Deprecated: Use RecoveryConfig.ProtoReflect.Descriptor instead.

func (*RecoveryConfig) GetScheduledSnapshotsConfig 

func (x *RecoveryConfig) GetScheduledSnapshotsConfig() *ScheduledSnapshotsConfig

func (*RecoveryConfig) ProtoMessage 

func (*RecoveryConfig) ProtoMessage()

func (*RecoveryConfig) ProtoReflect 

func (x *RecoveryConfig) ProtoReflect() protoreflect.Message

func (*RecoveryConfig) Reset 

func (x *RecoveryConfig) Reset()

func (*RecoveryConfig) String 

func (x *RecoveryConfig) String() string

type RestartWebServerRequest 

type RestartWebServerRequest struct {

	// The resource name of the environment to restart the web server for, in the
	// form:
	// "projects/{projectId}/locations/{locationId}/environments/{environmentId}"
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Restart Airflow web server.

func (*RestartWebServerRequest) Descriptor deprecated 

func (*RestartWebServerRequest) Descriptor() ([]byte, []int)

Deprecated: Use RestartWebServerRequest.ProtoReflect.Descriptor instead.

func (*RestartWebServerRequest) GetName 

func (x *RestartWebServerRequest) GetName() string

func (*RestartWebServerRequest) ProtoMessage 

func (*RestartWebServerRequest) ProtoMessage()

func (*RestartWebServerRequest) ProtoReflect 

func (x *RestartWebServerRequest) ProtoReflect() protoreflect.Message

func (*RestartWebServerRequest) Reset 

func (x *RestartWebServerRequest) Reset()

func (*RestartWebServerRequest) String 

func (x *RestartWebServerRequest) String() string

type SaveSnapshotRequest 

type SaveSnapshotRequest struct {

	// The resource name of the source environment in the form:
	// "projects/{projectId}/locations/{locationId}/environments/{environmentId}"
	Environment string `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
	// Location in a Cloud Storage where the snapshot is going to be stored, e.g.:
	// "gs://my-bucket/snapshots".
	SnapshotLocation string `protobuf:"bytes,2,opt,name=snapshot_location,json=snapshotLocation,proto3" json:"snapshot_location,omitempty"`
	// contains filtered or unexported fields
}

Request to create a snapshot of a Cloud Composer environment.

func (*SaveSnapshotRequest) Descriptor deprecated 

func (*SaveSnapshotRequest) Descriptor() ([]byte, []int)

Deprecated: Use SaveSnapshotRequest.ProtoReflect.Descriptor instead.

func (*SaveSnapshotRequest) GetEnvironment 

func (x *SaveSnapshotRequest) GetEnvironment() string

func (*SaveSnapshotRequest) GetSnapshotLocation 

func (x *SaveSnapshotRequest) GetSnapshotLocation() string

func (*SaveSnapshotRequest) ProtoMessage 

func (*SaveSnapshotRequest) ProtoMessage()

func (*SaveSnapshotRequest) ProtoReflect 

func (x *SaveSnapshotRequest) ProtoReflect() protoreflect.Message

func (*SaveSnapshotRequest) Reset 

func (x *SaveSnapshotRequest) Reset()

func (*SaveSnapshotRequest) String 

func (x *SaveSnapshotRequest) String() string

type SaveSnapshotResponse 

type SaveSnapshotResponse struct {

	// The fully-resolved Cloud Storage path of the created snapshot,
	// e.g.:
	// "gs://my-bucket/snapshots/project_location_environment_timestamp".
	// This field is populated only if the snapshot creation was successful.
	SnapshotPath string `protobuf:"bytes,1,opt,name=snapshot_path,json=snapshotPath,proto3" json:"snapshot_path,omitempty"`
	// contains filtered or unexported fields
}

Response to SaveSnapshotRequest.

func (*SaveSnapshotResponse) Descriptor deprecated 

func (*SaveSnapshotResponse) Descriptor() ([]byte, []int)

Deprecated: Use SaveSnapshotResponse.ProtoReflect.Descriptor instead.

func (*SaveSnapshotResponse) GetSnapshotPath 

func (x *SaveSnapshotResponse) GetSnapshotPath() string

func (*SaveSnapshotResponse) ProtoMessage 

func (*SaveSnapshotResponse) ProtoMessage()

func (*SaveSnapshotResponse) ProtoReflect 

func (x *SaveSnapshotResponse) ProtoReflect() protoreflect.Message

func (*SaveSnapshotResponse) Reset 

func (x *SaveSnapshotResponse) Reset()

func (*SaveSnapshotResponse) String 

func (x *SaveSnapshotResponse) String() string

type ScheduledSnapshotsConfig 

type ScheduledSnapshotsConfig struct {

	// Optional. Whether scheduled snapshots creation is enabled.
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// Optional. The Cloud Storage location for storing automatically created
	// snapshots.
	SnapshotLocation string `protobuf:"bytes,6,opt,name=snapshot_location,json=snapshotLocation,proto3" json:"snapshot_location,omitempty"`
	// Optional. The cron expression representing the time when snapshots creation
	// mechanism runs. This field is subject to additional validation around
	// frequency of execution.
	SnapshotCreationSchedule string `` /* 135-byte string literal not displayed */
	// Optional. Time zone that sets the context to interpret
	// snapshot_creation_schedule.
	TimeZone string `protobuf:"bytes,5,opt,name=time_zone,json=timeZone,proto3" json:"time_zone,omitempty"`
	// contains filtered or unexported fields
}

The configuration for scheduled snapshot creation mechanism.

func (*ScheduledSnapshotsConfig) Descriptor deprecated 

func (*ScheduledSnapshotsConfig) Descriptor() ([]byte, []int)

Deprecated: Use ScheduledSnapshotsConfig.ProtoReflect.Descriptor instead.

func (*ScheduledSnapshotsConfig) GetEnabled 

func (x *ScheduledSnapshotsConfig) GetEnabled() bool

func (*ScheduledSnapshotsConfig) GetSnapshotCreationSchedule 

func (x *ScheduledSnapshotsConfig) GetSnapshotCreationSchedule() string

func (*ScheduledSnapshotsConfig) GetSnapshotLocation 

func (x *ScheduledSnapshotsConfig) GetSnapshotLocation() string

func (*ScheduledSnapshotsConfig) GetTimeZone 

func (x *ScheduledSnapshotsConfig) GetTimeZone() string

func (*ScheduledSnapshotsConfig) ProtoMessage 

func (*ScheduledSnapshotsConfig) ProtoMessage()

func (*ScheduledSnapshotsConfig) ProtoReflect 

func (x *ScheduledSnapshotsConfig) ProtoReflect() protoreflect.Message

func (*ScheduledSnapshotsConfig) Reset 

func (x *ScheduledSnapshotsConfig) Reset()

func (*ScheduledSnapshotsConfig) String 

func (x *ScheduledSnapshotsConfig) String() string

type SoftwareConfig 

type SoftwareConfig struct {

	// The version of the software running in the environment.
	// This encapsulates both the version of Cloud Composer functionality and the
	// version of Apache Airflow. It must match the regular expression
	// `composer-([0-9]+(\.[0-9]+\.[0-9]+(-preview\.[0-9]+)?)?|latest)-airflow-([0-9]+(\.[0-9]+(\.[0-9]+)?)?)`.
	// When used as input, the server also checks if the provided version is
	// supported and denies the request for an unsupported version.
	//
	// The Cloud Composer portion of the image version is a full
	// [semantic version](https://semver.org), or an alias in the form of major
	// version number or `latest`. When an alias is provided, the server replaces
	// it with the current Cloud Composer version that satisfies the alias.
	//
	// The Apache Airflow portion of the image version is a full semantic version
	// that points to one of the supported Apache Airflow versions, or an alias in
	// the form of only major or major.minor versions specified. When an alias is
	// provided, the server replaces it with the latest Apache Airflow version
	// that satisfies the alias and is supported in the given Cloud Composer
	// version.
	//
	// In all cases, the resolved image version is stored in the same field.
	//
	// See also [version
	// list](/composer/docs/concepts/versioning/composer-versions) and [versioning
	// overview](/composer/docs/concepts/versioning/composer-versioning-overview).
	ImageVersion string `protobuf:"bytes,1,opt,name=image_version,json=imageVersion,proto3" json:"image_version,omitempty"`
	// Optional. Apache Airflow configuration properties to override.
	//
	// Property keys contain the section and property names, separated by a
	// hyphen, for example "core-dags_are_paused_at_creation". Section names must
	// not contain hyphens ("-"), opening square brackets ("["),  or closing
	// square brackets ("]"). The property name must not be empty and must not
	// contain an equals sign ("=") or semicolon (";"). Section and property names
	// must not contain a period ("."). Apache Airflow configuration property
	// names must be written in
	// [snake_case](https://en.wikipedia.org/wiki/Snake_case). Property values can
	// contain any character, and can be written in any lower/upper case format.
	//
	// Certain Apache Airflow configuration property values are
	// [blocked](/composer/docs/concepts/airflow-configurations),
	// and cannot be overridden.
	AirflowConfigOverrides map[string]string `` /* 217-byte string literal not displayed */
	// Optional. Custom Python Package Index (PyPI) packages to be installed in
	// the environment.
	//
	// Keys refer to the lowercase package name such as "numpy"
	// and values are the lowercase extras and version specifier such as
	// "==1.12.0", "[devel,gcp_api]", or "[devel]>=1.8.2, <1.9.2". To specify a
	// package without pinning it to a version specifier, use the empty string as
	// the value.
	PypiPackages map[string]string `` /* 185-byte string literal not displayed */
	// Optional. Additional environment variables to provide to the Apache Airflow
	// scheduler, worker, and webserver processes.
	//
	// Environment variable names must match the regular expression
	// `[a-zA-Z_][a-zA-Z0-9_]*`. They cannot specify Apache Airflow
	// software configuration overrides (they cannot match the regular expression
	// `AIRFLOW__[A-Z0-9_]+__[A-Z0-9_]+`), and they cannot match any of the
	// following reserved names:
	//
	// * `AIRFLOW_HOME`
	// * `C_FORCE_ROOT`
	// * `CONTAINER_NAME`
	// * `DAGS_FOLDER`
	// * `GCP_PROJECT`
	// * `GCS_BUCKET`
	// * `GKE_CLUSTER_NAME`
	// * `SQL_DATABASE`
	// * `SQL_INSTANCE`
	// * `SQL_PASSWORD`
	// * `SQL_PROJECT`
	// * `SQL_REGION`
	// * `SQL_USER`
	EnvVariables map[string]string `` /* 185-byte string literal not displayed */
	// Optional. The major version of Python used to run the Apache Airflow
	// scheduler, worker, and webserver processes.
	//
	// Can be set to '2' or '3'. If not specified, the default is '3'. Cannot be
	// updated.
	//
	// This field is only supported for Cloud Composer environments in versions
	// composer-1.*.*-airflow-*.*.*. Environments in newer versions always use
	// Python major version 3.
	PythonVersion string `protobuf:"bytes,6,opt,name=python_version,json=pythonVersion,proto3" json:"python_version,omitempty"`
	// Optional. The number of schedulers for Airflow.
	//
	// This field is supported for Cloud Composer environments in versions
	// composer-1.*.*-airflow-2.*.*.
	SchedulerCount int32 `protobuf:"varint,7,opt,name=scheduler_count,json=schedulerCount,proto3" json:"scheduler_count,omitempty"`
	// Optional. The configuration for Cloud Data Lineage integration.
	CloudDataLineageIntegration *CloudDataLineageIntegration `` /* 146-byte string literal not displayed */
	// contains filtered or unexported fields
}

Specifies the selection and configuration of software inside the environment.

func (*SoftwareConfig) Descriptor deprecated 

func (*SoftwareConfig) Descriptor() ([]byte, []int)

Deprecated: Use SoftwareConfig.ProtoReflect.Descriptor instead.

func (*SoftwareConfig) GetAirflowConfigOverrides 

func (x *SoftwareConfig) GetAirflowConfigOverrides() map[string]string

func (*SoftwareConfig) GetCloudDataLineageIntegration 

func (x *SoftwareConfig) GetCloudDataLineageIntegration() *CloudDataLineageIntegration

func (*SoftwareConfig) GetEnvVariables 

func (x *SoftwareConfig) GetEnvVariables() map[string]string

func (*SoftwareConfig) GetImageVersion 

func (x *SoftwareConfig) GetImageVersion() string

func (*SoftwareConfig) GetPypiPackages 

func (x *SoftwareConfig) GetPypiPackages() map[string]string

func (*SoftwareConfig) GetPythonVersion 

func (x *SoftwareConfig) GetPythonVersion() string

func (*SoftwareConfig) GetSchedulerCount 

func (x *SoftwareConfig) GetSchedulerCount() int32

func (*SoftwareConfig) ProtoMessage 

func (*SoftwareConfig) ProtoMessage()

func (*SoftwareConfig) ProtoReflect 

func (x *SoftwareConfig) ProtoReflect() protoreflect.Message

func (*SoftwareConfig) Reset 

func (x *SoftwareConfig) Reset()

func (*SoftwareConfig) String 

func (x *SoftwareConfig) String() string

type UnimplementedEnvironmentsServer 

type UnimplementedEnvironmentsServer struct {
}

UnimplementedEnvironmentsServer can be embedded to have forward compatible implementations.

func (*UnimplementedEnvironmentsServer) CheckUpgrade 

func (*UnimplementedEnvironmentsServer) CheckUpgrade(context.Context, *CheckUpgradeRequest) (*longrunning.Operation, error)

func (*UnimplementedEnvironmentsServer) CreateEnvironment 

func (*UnimplementedEnvironmentsServer) CreateEnvironment(context.Context, *CreateEnvironmentRequest) (*longrunning.Operation, error)

func (*UnimplementedEnvironmentsServer) DeleteEnvironment 

func (*UnimplementedEnvironmentsServer) DeleteEnvironment(context.Context, *DeleteEnvironmentRequest) (*longrunning.Operation, error)

func (*UnimplementedEnvironmentsServer) GetEnvironment 

func (*UnimplementedEnvironmentsServer) GetEnvironment(context.Context, *GetEnvironmentRequest) (*Environment, error)

func (*UnimplementedEnvironmentsServer) ListEnvironments 

func (*UnimplementedEnvironmentsServer) ListEnvironments(context.Context, *ListEnvironmentsRequest) (*ListEnvironmentsResponse, error)

func (*UnimplementedEnvironmentsServer) LoadSnapshot 

func (*UnimplementedEnvironmentsServer) LoadSnapshot(context.Context, *LoadSnapshotRequest) (*longrunning.Operation, error)

func (*UnimplementedEnvironmentsServer) RestartWebServer 

func (*UnimplementedEnvironmentsServer) RestartWebServer(context.Context, *RestartWebServerRequest) (*longrunning.Operation, error)

func (*UnimplementedEnvironmentsServer) SaveSnapshot 

func (*UnimplementedEnvironmentsServer) SaveSnapshot(context.Context, *SaveSnapshotRequest) (*longrunning.Operation, error)

func (*UnimplementedEnvironmentsServer) UpdateEnvironment 

func (*UnimplementedEnvironmentsServer) UpdateEnvironment(context.Context, *UpdateEnvironmentRequest) (*longrunning.Operation, error)

type UnimplementedImageVersionsServer 

type UnimplementedImageVersionsServer struct {
}

UnimplementedImageVersionsServer can be embedded to have forward compatible implementations.

func (*UnimplementedImageVersionsServer) ListImageVersions 

func (*UnimplementedImageVersionsServer) ListImageVersions(context.Context, *ListImageVersionsRequest) (*ListImageVersionsResponse, error)

type UpdateEnvironmentRequest 

type UpdateEnvironmentRequest struct {

	// The relative resource name of the environment to update, in the form:
	// "projects/{projectId}/locations/{locationId}/environments/{environmentId}"
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// A patch environment. Fields specified by the `updateMask` will be copied
	// from the patch environment into the environment under update.
	Environment *Environment `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
	// Required. A comma-separated list of paths, relative to `Environment`, of
	// fields to update.
	// For example, to set the version of scikit-learn to install in the
	// environment to 0.19.0 and to remove an existing installation of
	// argparse, the `updateMask` parameter would include the following two
	// `paths` values: "config.softwareConfig.pypiPackages.scikit-learn" and
	// "config.softwareConfig.pypiPackages.argparse". The included patch
	// environment would specify the scikit-learn version as follows:
	//
	//	{
	//	  "config":{
	//	    "softwareConfig":{
	//	      "pypiPackages":{
	//	        "scikit-learn":"==0.19.0"
	//	      }
	//	    }
	//	  }
	//	}
	//
	// Note that in the above example, any existing PyPI packages
	// other than scikit-learn and argparse will be unaffected.
	//
	// Only one update type may be included in a single request's `updateMask`.
	// For example, one cannot update both the PyPI packages and
	// labels in the same request. However, it is possible to update multiple
	// members of a map field simultaneously in the same request. For example,
	// to set the labels "label1" and "label2" while clearing "label3" (assuming
	// it already exists), one can
	// provide the paths "labels.label1", "labels.label2", and "labels.label3"
	// and populate the patch environment as follows:
	//
	//	{
	//	  "labels":{
	//	    "label1":"new-label1-value"
	//	    "label2":"new-label2-value"
	//	  }
	//	}
	//
	// Note that in the above example, any existing labels that are not
	// included in the `updateMask` will be unaffected.
	//
	// It is also possible to replace an entire map field by providing the
	// map field's path in the `updateMask`. The new value of the field will
	// be that which is provided in the patch environment. For example, to
	// delete all pre-existing user-specified PyPI packages and
	// install botocore at version 1.7.14, the `updateMask` would contain
	// the path "config.softwareConfig.pypiPackages", and
	// the patch environment would be the following:
	//
	//	{
	//	  "config":{
	//	    "softwareConfig":{
	//	      "pypiPackages":{
	//	        "botocore":"==1.7.14"
	//	      }
	//	    }
	//	  }
	//	}
	//
	// **Note:** Only the following fields can be updated:
	//
	// * `config.softwareConfig.pypiPackages`
	//   - Replace all custom custom PyPI packages. If a replacement
	//     package map is not included in `environment`, all custom
	//     PyPI packages are cleared. It is an error to provide both
	//     this mask and a mask specifying an individual package.
	//
	// * `config.softwareConfig.pypiPackages.`packagename
	//   - Update the custom PyPI package *packagename*,
	//     preserving other packages. To delete the package, include it in
	//     `updateMask`, and omit the mapping for it in
	//     `environment.config.softwareConfig.pypiPackages`. It is an error
	//     to provide both a mask of this form and the
	//     `config.softwareConfig.pypiPackages` mask.
	//
	// * `labels`
	//   - Replace all environment labels. If a replacement labels map is not
	//     included in `environment`, all labels are cleared. It is an error to
	//     provide both this mask and a mask specifying one or more individual
	//     labels.
	//
	// * `labels.`labelName
	//   - Set the label named *labelName*, while preserving other
	//     labels. To delete the label, include it in `updateMask` and omit its
	//     mapping in `environment.labels`. It is an error to provide both a
	//     mask of this form and the `labels` mask.
	//
	// * `config.nodeCount`
	//   - Horizontally scale the number of nodes in the environment. An integer
	//     greater than or equal to 3 must be provided in the `config.nodeCount`
	//     field. Supported for Cloud Composer environments in versions
	//     composer-1.*.*-airflow-*.*.*.
	//
	// * `config.webServerNetworkAccessControl`
	//   - Replace the environment's current WebServerNetworkAccessControl.
	//
	// * `config.softwareConfig.airflowConfigOverrides`
	//   - Replace all Apache Airflow config overrides. If a replacement config
	//     overrides map is not included in `environment`, all config overrides
	//     are cleared.
	//     It is an error to provide both this mask and a mask specifying one or
	//     more individual config overrides.
	//
	// * `config.softwareConfig.airflowConfigOverrides.`section-name
	//   - Override the Apache Airflow config property *name* in the
	//     section named *section*, preserving other properties. To
	//     delete the property override, include it in `updateMask` and omit its
	//     mapping in
	//     `environment.config.softwareConfig.airflowConfigOverrides`.
	//     It is an error to provide both a mask of this form and the
	//     `config.softwareConfig.airflowConfigOverrides` mask.
	//
	// * `config.softwareConfig.envVariables`
	//   - Replace all environment variables. If a replacement environment
	//     variable map is not included in `environment`, all custom environment
	//     variables are cleared.
	//
	// * `config.softwareConfig.imageVersion`
	//   - Upgrade the version of the environment in-place. Refer to
	//     `SoftwareConfig.image_version` for information on how to format the
	//     new image version. Additionally, the new image version cannot effect
	//     a version downgrade, and must match the current image version's
	//     Composer and Airflow major versions. Consult the [Cloud Composer
	//     version list](/composer/docs/concepts/versioning/composer-versions)
	//     for valid values.
	//
	// * `config.softwareConfig.schedulerCount`
	//   - Horizontally scale the number of schedulers in Airflow. A positive
	//     integer not greater than the number of nodes must be provided in the
	//     `config.softwareConfig.schedulerCount` field. Supported for Cloud
	//     Composer environments in versions composer-1.*.*-airflow-2.*.*.
	//
	// * `config.softwareConfig.cloudDataLineageIntegration`
	//   - Configuration for Cloud Data Lineage integration.
	//
	// * `config.databaseConfig.machineType`
	//   - Cloud SQL machine type used by Airflow database.
	//     It has to be one of: db-n1-standard-2, db-n1-standard-4,
	//     db-n1-standard-8 or db-n1-standard-16. Supported for Cloud Composer
	//     environments in versions composer-1.*.*-airflow-*.*.*.
	//
	// * `config.webServerConfig.machineType`
	//   - Machine type on which Airflow web server is running.
	//     It has to be one of: composer-n1-webserver-2, composer-n1-webserver-4
	//     or composer-n1-webserver-8. Supported for Cloud Composer environments
	//     in versions composer-1.*.*-airflow-*.*.*.
	//
	// * `config.maintenanceWindow`
	//   - Maintenance window during which Cloud Composer components may be
	//     under maintenance.
	//
	// * `config.workloadsConfig`
	//   - The workloads configuration settings for the GKE cluster associated
	//     with the Cloud Composer environment. Supported for Cloud Composer
	//     environments in versions composer-2.*.*-airflow-*.*.* and newer.
	//
	// * `config.environmentSize`
	//   - The size of the Cloud Composer environment. Supported for Cloud
	//     Composer environments in versions composer-2.*.*-airflow-*.*.* and
	//     newer.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,3,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

Update an environment.

func (*UpdateEnvironmentRequest) Descriptor deprecated 

func (*UpdateEnvironmentRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateEnvironmentRequest.ProtoReflect.Descriptor instead.

func (*UpdateEnvironmentRequest) GetEnvironment 

func (x *UpdateEnvironmentRequest) GetEnvironment() *Environment

func (*UpdateEnvironmentRequest) GetName 

func (x *UpdateEnvironmentRequest) GetName() string

func (*UpdateEnvironmentRequest) GetUpdateMask 

func (x *UpdateEnvironmentRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateEnvironmentRequest) ProtoMessage 

func (*UpdateEnvironmentRequest) ProtoMessage()

func (*UpdateEnvironmentRequest) ProtoReflect 

func (x *UpdateEnvironmentRequest) ProtoReflect() protoreflect.Message

func (*UpdateEnvironmentRequest) Reset 

func (x *UpdateEnvironmentRequest) Reset()

func (*UpdateEnvironmentRequest) String 

func (x *UpdateEnvironmentRequest) String() string

type WebServerConfig 

type WebServerConfig struct {

	// Optional. Machine type on which Airflow web server is running.
	// It has to be one of: composer-n1-webserver-2, composer-n1-webserver-4 or
	// composer-n1-webserver-8.
	// If not specified, composer-n1-webserver-2 will be used.
	// Value custom is returned only in response, if Airflow web server parameters
	// were manually changed to a non-standard values.
	MachineType string `protobuf:"bytes,1,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"`
	// contains filtered or unexported fields
}

The configuration settings for the Airflow web server App Engine instance. Supported for Cloud Composer environments in versions composer-1.*.*-airflow-*.*.*.

func (*WebServerConfig) Descriptor deprecated 

func (*WebServerConfig) Descriptor() ([]byte, []int)

Deprecated: Use WebServerConfig.ProtoReflect.Descriptor instead.

func (*WebServerConfig) GetMachineType 

func (x *WebServerConfig) GetMachineType() string

func (*WebServerConfig) ProtoMessage 

func (*WebServerConfig) ProtoMessage()

func (*WebServerConfig) ProtoReflect 

func (x *WebServerConfig) ProtoReflect() protoreflect.Message

func (*WebServerConfig) Reset 

func (x *WebServerConfig) Reset()

func (*WebServerConfig) String 

func (x *WebServerConfig) String() string

type WebServerNetworkAccessControl 

type WebServerNetworkAccessControl struct {

	// A collection of allowed IP ranges with descriptions.
	AllowedIpRanges []*WebServerNetworkAccessControl_AllowedIpRange `protobuf:"bytes,1,rep,name=allowed_ip_ranges,json=allowedIpRanges,proto3" json:"allowed_ip_ranges,omitempty"`
	// contains filtered or unexported fields
}

Network-level access control policy for the Airflow web server.

func (*WebServerNetworkAccessControl) Descriptor deprecated 

func (*WebServerNetworkAccessControl) Descriptor() ([]byte, []int)

Deprecated: Use WebServerNetworkAccessControl.ProtoReflect.Descriptor instead.

func (*WebServerNetworkAccessControl) GetAllowedIpRanges 

func (x *WebServerNetworkAccessControl) GetAllowedIpRanges() []*WebServerNetworkAccessControl_AllowedIpRange

func (*WebServerNetworkAccessControl) ProtoMessage 

func (*WebServerNetworkAccessControl) ProtoMessage()

func (*WebServerNetworkAccessControl) ProtoReflect 

func (x *WebServerNetworkAccessControl) ProtoReflect() protoreflect.Message

func (*WebServerNetworkAccessControl) Reset 

func (x *WebServerNetworkAccessControl) Reset()

func (*WebServerNetworkAccessControl) String 

func (x *WebServerNetworkAccessControl) String() string

type WebServerNetworkAccessControl_AllowedIpRange 

type WebServerNetworkAccessControl_AllowedIpRange struct {

	// IP address or range, defined using CIDR notation, of requests that this
	// rule applies to.
	// Examples: `192.168.1.1` or `192.168.0.0/16` or `2001:db8::/32`
	//
	//	or `2001:0db8:0000:0042:0000:8a2e:0370:7334`.
	//
	// IP range prefixes should be properly truncated. For example,
	// `1.2.3.4/24` should be truncated to `1.2.3.0/24`. Similarly, for IPv6,
	// `2001:db8::1/32` should be truncated to `2001:db8::/32`.
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Optional. User-provided description. It must contain at most 300
	// characters.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

Allowed IP range with user-provided description.

func (*WebServerNetworkAccessControl_AllowedIpRange) Descriptor deprecated 

func (*WebServerNetworkAccessControl_AllowedIpRange) Descriptor() ([]byte, []int)

Deprecated: Use WebServerNetworkAccessControl_AllowedIpRange.ProtoReflect.Descriptor instead.

func (*WebServerNetworkAccessControl_AllowedIpRange) GetDescription 

func (x *WebServerNetworkAccessControl_AllowedIpRange) GetDescription() string

func (*WebServerNetworkAccessControl_AllowedIpRange) GetValue 

func (x *WebServerNetworkAccessControl_AllowedIpRange) GetValue() string

func (*WebServerNetworkAccessControl_AllowedIpRange) ProtoMessage 

func (*WebServerNetworkAccessControl_AllowedIpRange) ProtoMessage()

func (*WebServerNetworkAccessControl_AllowedIpRange) ProtoReflect 

func (x *WebServerNetworkAccessControl_AllowedIpRange) ProtoReflect() protoreflect.Message

func (*WebServerNetworkAccessControl_AllowedIpRange) Reset 

func (x *WebServerNetworkAccessControl_AllowedIpRange) Reset()

func (*WebServerNetworkAccessControl_AllowedIpRange) String 

func (x *WebServerNetworkAccessControl_AllowedIpRange) String() string

type WorkloadsConfig 

type WorkloadsConfig struct {

	// Optional. Resources used by Airflow schedulers.
	Scheduler *WorkloadsConfig_SchedulerResource `protobuf:"bytes,1,opt,name=scheduler,proto3" json:"scheduler,omitempty"`
	// Optional. Resources used by Airflow web server.
	WebServer *WorkloadsConfig_WebServerResource `protobuf:"bytes,2,opt,name=web_server,json=webServer,proto3" json:"web_server,omitempty"`
	// Optional. Resources used by Airflow workers.
	Worker *WorkloadsConfig_WorkerResource `protobuf:"bytes,3,opt,name=worker,proto3" json:"worker,omitempty"`
	// Optional. Resources used by Airflow triggerers.
	Triggerer *WorkloadsConfig_TriggererResource `protobuf:"bytes,4,opt,name=triggerer,proto3" json:"triggerer,omitempty"`
	// contains filtered or unexported fields
}

The Kubernetes workloads configuration for GKE cluster associated with the Cloud Composer environment. Supported for Cloud Composer environments in versions composer-2.*.*-airflow-*.*.* and newer.

func (*WorkloadsConfig) Descriptor deprecated 

func (*WorkloadsConfig) Descriptor() ([]byte, []int)

Deprecated: Use WorkloadsConfig.ProtoReflect.Descriptor instead.

func (*WorkloadsConfig) GetScheduler 

func (x *WorkloadsConfig) GetScheduler() *WorkloadsConfig_SchedulerResource

func (*WorkloadsConfig) GetTriggerer 

func (x *WorkloadsConfig) GetTriggerer() *WorkloadsConfig_TriggererResource

func (*WorkloadsConfig) GetWebServer 

func (x *WorkloadsConfig) GetWebServer() *WorkloadsConfig_WebServerResource

func (*WorkloadsConfig) GetWorker 

func (x *WorkloadsConfig) GetWorker() *WorkloadsConfig_WorkerResource

func (*WorkloadsConfig) ProtoMessage 

func (*WorkloadsConfig) ProtoMessage()

func (*WorkloadsConfig) ProtoReflect 

func (x *WorkloadsConfig) ProtoReflect() protoreflect.Message

func (*WorkloadsConfig) Reset 

func (x *WorkloadsConfig) Reset()

func (*WorkloadsConfig) String 

func (x *WorkloadsConfig) String() string

type WorkloadsConfig_SchedulerResource 

type WorkloadsConfig_SchedulerResource struct {

	// Optional. CPU request and limit for a single Airflow scheduler replica.
	Cpu float32 `protobuf:"fixed32,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
	// Optional. Memory (GB) request and limit for a single Airflow scheduler
	// replica.
	MemoryGb float32 `protobuf:"fixed32,2,opt,name=memory_gb,json=memoryGb,proto3" json:"memory_gb,omitempty"`
	// Optional. Storage (GB) request and limit for a single Airflow scheduler
	// replica.
	StorageGb float32 `protobuf:"fixed32,3,opt,name=storage_gb,json=storageGb,proto3" json:"storage_gb,omitempty"`
	// Optional. The number of schedulers.
	Count int32 `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

Configuration for resources used by Airflow schedulers.

func (*WorkloadsConfig_SchedulerResource) Descriptor deprecated 

func (*WorkloadsConfig_SchedulerResource) Descriptor() ([]byte, []int)

Deprecated: Use WorkloadsConfig_SchedulerResource.ProtoReflect.Descriptor instead.

func (*WorkloadsConfig_SchedulerResource) GetCount 

func (x *WorkloadsConfig_SchedulerResource) GetCount() int32

func (*WorkloadsConfig_SchedulerResource) GetCpu 

func (x *WorkloadsConfig_SchedulerResource) GetCpu() float32

func (*WorkloadsConfig_SchedulerResource) GetMemoryGb 

func (x *WorkloadsConfig_SchedulerResource) GetMemoryGb() float32

func (*WorkloadsConfig_SchedulerResource) GetStorageGb 

func (x *WorkloadsConfig_SchedulerResource) GetStorageGb() float32

func (*WorkloadsConfig_SchedulerResource) ProtoMessage 

func (*WorkloadsConfig_SchedulerResource) ProtoMessage()

func (*WorkloadsConfig_SchedulerResource) ProtoReflect 

func (x *WorkloadsConfig_SchedulerResource) ProtoReflect() protoreflect.Message

func (*WorkloadsConfig_SchedulerResource) Reset 

func (x *WorkloadsConfig_SchedulerResource) Reset()

func (*WorkloadsConfig_SchedulerResource) String 

func (x *WorkloadsConfig_SchedulerResource) String() string

type WorkloadsConfig_TriggererResource 

type WorkloadsConfig_TriggererResource struct {

	// Optional. The number of triggerers.
	Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// Optional. CPU request and limit for a single Airflow triggerer replica.
	Cpu float32 `protobuf:"fixed32,2,opt,name=cpu,proto3" json:"cpu,omitempty"`
	// Optional. Memory (GB) request and limit for a single Airflow triggerer
	// replica.
	MemoryGb float32 `protobuf:"fixed32,3,opt,name=memory_gb,json=memoryGb,proto3" json:"memory_gb,omitempty"`
	// contains filtered or unexported fields
}

Configuration for resources used by Airflow triggerers.

func (*WorkloadsConfig_TriggererResource) Descriptor deprecated 

func (*WorkloadsConfig_TriggererResource) Descriptor() ([]byte, []int)

Deprecated: Use WorkloadsConfig_TriggererResource.ProtoReflect.Descriptor instead.

func (*WorkloadsConfig_TriggererResource) GetCount 

func (x *WorkloadsConfig_TriggererResource) GetCount() int32

func (*WorkloadsConfig_TriggererResource) GetCpu 

func (x *WorkloadsConfig_TriggererResource) GetCpu() float32

func (*WorkloadsConfig_TriggererResource) GetMemoryGb 

func (x *WorkloadsConfig_TriggererResource) GetMemoryGb() float32

func (*WorkloadsConfig_TriggererResource) ProtoMessage 

func (*WorkloadsConfig_TriggererResource) ProtoMessage()

func (*WorkloadsConfig_TriggererResource) ProtoReflect 

func (x *WorkloadsConfig_TriggererResource) ProtoReflect() protoreflect.Message

func (*WorkloadsConfig_TriggererResource) Reset 

func (x *WorkloadsConfig_TriggererResource) Reset()

func (*WorkloadsConfig_TriggererResource) String 

func (x *WorkloadsConfig_TriggererResource) String() string

type WorkloadsConfig_WebServerResource 

type WorkloadsConfig_WebServerResource struct {

	// Optional. CPU request and limit for Airflow web server.
	Cpu float32 `protobuf:"fixed32,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
	// Optional. Memory (GB) request and limit for Airflow web server.
	MemoryGb float32 `protobuf:"fixed32,2,opt,name=memory_gb,json=memoryGb,proto3" json:"memory_gb,omitempty"`
	// Optional. Storage (GB) request and limit for Airflow web server.
	StorageGb float32 `protobuf:"fixed32,3,opt,name=storage_gb,json=storageGb,proto3" json:"storage_gb,omitempty"`
	// contains filtered or unexported fields
}

Configuration for resources used by Airflow web server.

func (*WorkloadsConfig_WebServerResource) Descriptor deprecated 

func (*WorkloadsConfig_WebServerResource) Descriptor() ([]byte, []int)

Deprecated: Use WorkloadsConfig_WebServerResource.ProtoReflect.Descriptor instead.

func (*WorkloadsConfig_WebServerResource) GetCpu 

func (x *WorkloadsConfig_WebServerResource) GetCpu() float32

func (*WorkloadsConfig_WebServerResource) GetMemoryGb 

func (x *WorkloadsConfig_WebServerResource) GetMemoryGb() float32

func (*WorkloadsConfig_WebServerResource) GetStorageGb 

func (x *WorkloadsConfig_WebServerResource) GetStorageGb() float32

func (*WorkloadsConfig_WebServerResource) ProtoMessage 

func (*WorkloadsConfig_WebServerResource) ProtoMessage()

func (*WorkloadsConfig_WebServerResource) ProtoReflect 

func (x *WorkloadsConfig_WebServerResource) ProtoReflect() protoreflect.Message

func (*WorkloadsConfig_WebServerResource) Reset 

func (x *WorkloadsConfig_WebServerResource) Reset()

func (*WorkloadsConfig_WebServerResource) String 

func (x *WorkloadsConfig_WebServerResource) String() string

type WorkloadsConfig_WorkerResource 

type WorkloadsConfig_WorkerResource struct {

	// Optional. CPU request and limit for a single Airflow worker replica.
	Cpu float32 `protobuf:"fixed32,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
	// Optional. Memory (GB) request and limit for a single Airflow worker
	// replica.
	MemoryGb float32 `protobuf:"fixed32,2,opt,name=memory_gb,json=memoryGb,proto3" json:"memory_gb,omitempty"`
	// Optional. Storage (GB) request and limit for a single Airflow worker
	// replica.
	StorageGb float32 `protobuf:"fixed32,3,opt,name=storage_gb,json=storageGb,proto3" json:"storage_gb,omitempty"`
	// Optional. Minimum number of workers for autoscaling.
	MinCount int32 `protobuf:"varint,4,opt,name=min_count,json=minCount,proto3" json:"min_count,omitempty"`
	// Optional. Maximum number of workers for autoscaling.
	MaxCount int32 `protobuf:"varint,5,opt,name=max_count,json=maxCount,proto3" json:"max_count,omitempty"`
	// contains filtered or unexported fields
}

Configuration for resources used by Airflow workers.

func (*WorkloadsConfig_WorkerResource) Descriptor deprecated 

func (*WorkloadsConfig_WorkerResource) Descriptor() ([]byte, []int)

Deprecated: Use WorkloadsConfig_WorkerResource.ProtoReflect.Descriptor instead.

func (*WorkloadsConfig_WorkerResource) GetCpu 

func (x *WorkloadsConfig_WorkerResource) GetCpu() float32

func (*WorkloadsConfig_WorkerResource) GetMaxCount 

func (x *WorkloadsConfig_WorkerResource) GetMaxCount() int32

func (*WorkloadsConfig_WorkerResource) GetMemoryGb 

func (x *WorkloadsConfig_WorkerResource) GetMemoryGb() float32

func (*WorkloadsConfig_WorkerResource) GetMinCount 

func (x *WorkloadsConfig_WorkerResource) GetMinCount() int32

func (*WorkloadsConfig_WorkerResource) GetStorageGb 

func (x *WorkloadsConfig_WorkerResource) GetStorageGb() float32

func (*WorkloadsConfig_WorkerResource) ProtoMessage 

func (*WorkloadsConfig_WorkerResource) ProtoMessage()

func (*WorkloadsConfig_WorkerResource) ProtoReflect 

func (x *WorkloadsConfig_WorkerResource) ProtoReflect() protoreflect.Message

func (*WorkloadsConfig_WorkerResource) Reset 

func (x *WorkloadsConfig_WorkerResource) Reset()

func (*WorkloadsConfig_WorkerResource) String 

func (x *WorkloadsConfig_WorkerResource) String() string

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.