servicepb

package
v1.8.1 Latest Latest
Warning

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

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

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 (
	EnvironmentConfig_ResilienceMode_name = map[int32]string{
		0: "RESILIENCE_MODE_UNSPECIFIED",
		1: "HIGH_RESILIENCE",
	}
	EnvironmentConfig_ResilienceMode_value = map[string]int32{
		"RESILIENCE_MODE_UNSPECIFIED": 0,
		"HIGH_RESILIENCE":             1,
	}
)

Enum value maps for EnvironmentConfig_ResilienceMode.

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: "SUCCEEDED",

		4: "FAILED",
	}
	OperationMetadata_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"PENDING":           1,
		"RUNNING":           2,
		"SUCCEEDED":         3,
		"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",
		7: "DATABASE_FAILOVER",
	}
	OperationMetadata_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED":  0,
		"CREATE":            1,
		"DELETE":            2,
		"UPDATE":            3,
		"CHECK":             4,
		"SAVE_SNAPSHOT":     5,
		"LOAD_SNAPSHOT":     6,
		"DATABASE_FAILOVER": 7,
	}
)

Enum value maps for OperationMetadata_Type.

View Source 
var File_google_cloud_orchestration_airflow_service_v1_environments_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_orchestration_airflow_service_v1_image_versions_proto protoreflect.FileDescriptor
View Source 
var File_google_cloud_orchestration_airflow_service_v1_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 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 `` /* 234-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 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 DatabaseFailoverRequest added in v1.8.0 

type DatabaseFailoverRequest struct {

	// Target environment:
	// "projects/{projectId}/locations/{locationId}/environments/{environmentId}"
	Environment string `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
	// contains filtered or unexported fields
}

Request to trigger database failover (only for highly resilient environments).

func (*DatabaseFailoverRequest) Descriptor deprecated added in v1.8.0 

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

Deprecated: Use DatabaseFailoverRequest.ProtoReflect.Descriptor instead.

func (*DatabaseFailoverRequest) GetEnvironment added in v1.8.0 

func (x *DatabaseFailoverRequest) GetEnvironment() string

func (*DatabaseFailoverRequest) ProtoMessage added in v1.8.0 

func (*DatabaseFailoverRequest) ProtoMessage()

func (*DatabaseFailoverRequest) ProtoReflect added in v1.8.0 

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

func (*DatabaseFailoverRequest) Reset added in v1.8.0 

func (x *DatabaseFailoverRequest) Reset()

func (*DatabaseFailoverRequest) String added in v1.8.0 

func (x *DatabaseFailoverRequest) String() string

type DatabaseFailoverResponse added in v1.8.0 

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

Response for DatabaseFailoverRequest.

func (*DatabaseFailoverResponse) Descriptor deprecated added in v1.8.0 

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

Deprecated: Use DatabaseFailoverResponse.ProtoReflect.Descriptor instead.

func (*DatabaseFailoverResponse) ProtoMessage added in v1.8.0 

func (*DatabaseFailoverResponse) ProtoMessage()

func (*DatabaseFailoverResponse) ProtoReflect added in v1.8.0 

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

func (*DatabaseFailoverResponse) Reset added in v1.8.0 

func (x *DatabaseFailoverResponse) Reset()

func (*DatabaseFailoverResponse) String added in v1.8.0 

func (x *DatabaseFailoverResponse) 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 `` /* 133-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,9,opt,name=database_config,json=databaseConfig,proto3" json:"database_config,omitempty"`
	// Optional. The configuration settings for the Airflow web server App Engine
	// instance.
	WebServerConfig *WebServerConfig `protobuf:"bytes,10,opt,name=web_server_config,json=webServerConfig,proto3" json:"web_server_config,omitempty"`
	// Optional. The encryption options for the Cloud Composer environment
	// and its dependencies. Cannot be updated.
	EncryptionConfig *EncryptionConfig `protobuf:"bytes,11,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, the default value for maintenance window will be
	// applied. The default value is Saturday and Sunday 00-06 GMT.
	MaintenanceWindow *MaintenanceWindow `protobuf:"bytes,12,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 `` /* 193-byte string literal not displayed */
	// 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"`
	// Output only. The 'bring your own identity' variant of the URI of the Apache
	// Airflow Web UI hosted within this environment, to be accessed with external
	// identities using workforce identity federation (see [Access environments
	// with workforce identity
	// federation](/composer/docs/composer-2/access-environments-with-workforce-identity-federation)).
	AirflowByoidUri string `protobuf:"bytes,20,opt,name=airflow_byoid_uri,json=airflowByoidUri,proto3" json:"airflow_byoid_uri,omitempty"`
	// 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"`
	// Optional. Resilience mode of the Cloud Composer Environment.
	//
	// This field is supported for Cloud Composer environments in versions
	// composer-2.2.0-airflow-*.*.* and newer.
	ResilienceMode EnvironmentConfig_ResilienceMode `` /* 189-byte string literal not displayed */
	// 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) GetAirflowByoidUri added in v1.6.1 

func (x *EnvironmentConfig) GetAirflowByoidUri() string

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 added in v1.5.0 

func (x *EnvironmentConfig) GetEnvironmentSize() EnvironmentConfig_EnvironmentSize

func (*EnvironmentConfig) GetGkeCluster 

func (x *EnvironmentConfig) GetGkeCluster() string

func (*EnvironmentConfig) GetMaintenanceWindow added in v1.5.0 

func (x *EnvironmentConfig) GetMaintenanceWindow() *MaintenanceWindow

func (*EnvironmentConfig) GetMasterAuthorizedNetworksConfig added in v1.5.0 

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 added in v1.5.0 

func (x *EnvironmentConfig) GetRecoveryConfig() *RecoveryConfig

func (*EnvironmentConfig) GetResilienceMode added in v1.8.0 

func (x *EnvironmentConfig) GetResilienceMode() EnvironmentConfig_ResilienceMode

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 added in v1.5.0 

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 added in v1.5.0 

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 added in v1.5.0 

func (EnvironmentConfig_EnvironmentSize) Descriptor() protoreflect.EnumDescriptor

func (EnvironmentConfig_EnvironmentSize) Enum added in v1.5.0 

func (x EnvironmentConfig_EnvironmentSize) Enum() *EnvironmentConfig_EnvironmentSize

func (EnvironmentConfig_EnvironmentSize) EnumDescriptor deprecated added in v1.5.0 

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

Deprecated: Use EnvironmentConfig_EnvironmentSize.Descriptor instead.

func (EnvironmentConfig_EnvironmentSize) Number added in v1.5.0 

func (x EnvironmentConfig_EnvironmentSize) Number() protoreflect.EnumNumber

func (EnvironmentConfig_EnvironmentSize) String added in v1.5.0 

func (x EnvironmentConfig_EnvironmentSize) String() string

func (EnvironmentConfig_EnvironmentSize) Type added in v1.5.0 

func (EnvironmentConfig_EnvironmentSize) Type() protoreflect.EnumType

type EnvironmentConfig_ResilienceMode added in v1.8.0 

type EnvironmentConfig_ResilienceMode int32

Resilience mode of the Cloud Composer Environment. 

const (
	// Default mode doesn't change environment parameters.
	EnvironmentConfig_RESILIENCE_MODE_UNSPECIFIED EnvironmentConfig_ResilienceMode = 0
	// Enabled High Resilience mode, including Cloud SQL HA.
	EnvironmentConfig_HIGH_RESILIENCE EnvironmentConfig_ResilienceMode = 1
)

func (EnvironmentConfig_ResilienceMode) Descriptor added in v1.8.0 

func (EnvironmentConfig_ResilienceMode) Descriptor() protoreflect.EnumDescriptor

func (EnvironmentConfig_ResilienceMode) Enum added in v1.8.0 

func (x EnvironmentConfig_ResilienceMode) Enum() *EnvironmentConfig_ResilienceMode

func (EnvironmentConfig_ResilienceMode) EnumDescriptor deprecated added in v1.8.0 

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

Deprecated: Use EnvironmentConfig_ResilienceMode.Descriptor instead.

func (EnvironmentConfig_ResilienceMode) Number added in v1.8.0 

func (x EnvironmentConfig_ResilienceMode) Number() protoreflect.EnumNumber

func (EnvironmentConfig_ResilienceMode) String added in v1.8.0 

func (x EnvironmentConfig_ResilienceMode) String() string

func (EnvironmentConfig_ResilienceMode) Type added in v1.8.0 

func (EnvironmentConfig_ResilienceMode) 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) (*longrunningpb.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) (*longrunningpb.Operation, error)
	// Delete an environment.
	DeleteEnvironment(ctx context.Context, in *DeleteEnvironmentRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Executes Airflow CLI command.
	ExecuteAirflowCommand(ctx context.Context, in *ExecuteAirflowCommandRequest, opts ...grpc.CallOption) (*ExecuteAirflowCommandResponse, error)
	// Stops Airflow CLI command execution.
	StopAirflowCommand(ctx context.Context, in *StopAirflowCommandRequest, opts ...grpc.CallOption) (*StopAirflowCommandResponse, error)
	// Polls Airflow CLI command execution and fetches logs.
	PollAirflowCommand(ctx context.Context, in *PollAirflowCommandRequest, opts ...grpc.CallOption) (*PollAirflowCommandResponse, 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) (*longrunningpb.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) (*longrunningpb.Operation, error)
	// Triggers database failover (only for highly resilient environments).
	DatabaseFailover(ctx context.Context, in *DatabaseFailoverRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Fetches database properties.
	FetchDatabaseProperties(ctx context.Context, in *FetchDatabasePropertiesRequest, opts ...grpc.CallOption) (*FetchDatabasePropertiesResponse, 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) (*longrunningpb.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) (*longrunningpb.Operation, error)
	// Delete an environment.
	DeleteEnvironment(context.Context, *DeleteEnvironmentRequest) (*longrunningpb.Operation, error)
	// Executes Airflow CLI command.
	ExecuteAirflowCommand(context.Context, *ExecuteAirflowCommandRequest) (*ExecuteAirflowCommandResponse, error)
	// Stops Airflow CLI command execution.
	StopAirflowCommand(context.Context, *StopAirflowCommandRequest) (*StopAirflowCommandResponse, error)
	// Polls Airflow CLI command execution and fetches logs.
	PollAirflowCommand(context.Context, *PollAirflowCommandRequest) (*PollAirflowCommandResponse, 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) (*longrunningpb.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) (*longrunningpb.Operation, error)
	// Triggers database failover (only for highly resilient environments).
	DatabaseFailover(context.Context, *DatabaseFailoverRequest) (*longrunningpb.Operation, error)
	// Fetches database properties.
	FetchDatabaseProperties(context.Context, *FetchDatabasePropertiesRequest) (*FetchDatabasePropertiesResponse, error)
}

EnvironmentsServer is the server API for Environments service.

type ExecuteAirflowCommandRequest added in v1.8.0 

type ExecuteAirflowCommandRequest struct {

	// The resource name of the environment in the form:
	// "projects/{projectId}/locations/{locationId}/environments/{environmentId}".
	Environment string `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
	// Airflow command.
	Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	// Airflow subcommand.
	Subcommand string `protobuf:"bytes,3,opt,name=subcommand,proto3" json:"subcommand,omitempty"`
	// Parameters for the Airflow command/subcommand as an array of arguments.
	// It may contain positional arguments like `["my-dag-id"]`, key-value
	// parameters like `["--foo=bar"]` or `["--foo","bar"]`,
	// or other flags like `["-f"]`.
	Parameters []string `protobuf:"bytes,4,rep,name=parameters,proto3" json:"parameters,omitempty"`
	// contains filtered or unexported fields
}

Execute Airflow Command request.

func (*ExecuteAirflowCommandRequest) Descriptor deprecated added in v1.8.0 

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

Deprecated: Use ExecuteAirflowCommandRequest.ProtoReflect.Descriptor instead.

func (*ExecuteAirflowCommandRequest) GetCommand added in v1.8.0 

func (x *ExecuteAirflowCommandRequest) GetCommand() string

func (*ExecuteAirflowCommandRequest) GetEnvironment added in v1.8.0 

func (x *ExecuteAirflowCommandRequest) GetEnvironment() string

func (*ExecuteAirflowCommandRequest) GetParameters added in v1.8.0 

func (x *ExecuteAirflowCommandRequest) GetParameters() []string

func (*ExecuteAirflowCommandRequest) GetSubcommand added in v1.8.0 

func (x *ExecuteAirflowCommandRequest) GetSubcommand() string

func (*ExecuteAirflowCommandRequest) ProtoMessage added in v1.8.0 

func (*ExecuteAirflowCommandRequest) ProtoMessage()

func (*ExecuteAirflowCommandRequest) ProtoReflect added in v1.8.0 

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

func (*ExecuteAirflowCommandRequest) Reset added in v1.8.0 

func (x *ExecuteAirflowCommandRequest) Reset()

func (*ExecuteAirflowCommandRequest) String added in v1.8.0 

func (x *ExecuteAirflowCommandRequest) String() string

type ExecuteAirflowCommandResponse added in v1.8.0 

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 added in v1.8.0 

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

Deprecated: Use ExecuteAirflowCommandResponse.ProtoReflect.Descriptor instead.

func (*ExecuteAirflowCommandResponse) GetError added in v1.8.0 

func (x *ExecuteAirflowCommandResponse) GetError() string

func (*ExecuteAirflowCommandResponse) GetExecutionId added in v1.8.0 

func (x *ExecuteAirflowCommandResponse) GetExecutionId() string

func (*ExecuteAirflowCommandResponse) GetPod added in v1.8.0 

func (x *ExecuteAirflowCommandResponse) GetPod() string

func (*ExecuteAirflowCommandResponse) GetPodNamespace added in v1.8.0 

func (x *ExecuteAirflowCommandResponse) GetPodNamespace() string

func (*ExecuteAirflowCommandResponse) ProtoMessage added in v1.8.0 

func (*ExecuteAirflowCommandResponse) ProtoMessage()

func (*ExecuteAirflowCommandResponse) ProtoReflect added in v1.8.0 

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

func (*ExecuteAirflowCommandResponse) Reset added in v1.8.0 

func (x *ExecuteAirflowCommandResponse) Reset()

func (*ExecuteAirflowCommandResponse) String added in v1.8.0 

func (x *ExecuteAirflowCommandResponse) String() string

type FetchDatabasePropertiesRequest added in v1.8.0 

type FetchDatabasePropertiesRequest struct {

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

Request to fetch properties of environment's database.

func (*FetchDatabasePropertiesRequest) Descriptor deprecated added in v1.8.0 

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

Deprecated: Use FetchDatabasePropertiesRequest.ProtoReflect.Descriptor instead.

func (*FetchDatabasePropertiesRequest) GetEnvironment added in v1.8.0 

func (x *FetchDatabasePropertiesRequest) GetEnvironment() string

func (*FetchDatabasePropertiesRequest) ProtoMessage added in v1.8.0 

func (*FetchDatabasePropertiesRequest) ProtoMessage()

func (*FetchDatabasePropertiesRequest) ProtoReflect added in v1.8.0 

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

func (*FetchDatabasePropertiesRequest) Reset added in v1.8.0 

func (x *FetchDatabasePropertiesRequest) Reset()

func (*FetchDatabasePropertiesRequest) String added in v1.8.0 

func (x *FetchDatabasePropertiesRequest) String() string

type FetchDatabasePropertiesResponse added in v1.8.0 

type FetchDatabasePropertiesResponse struct {

	// The Compute Engine zone that the instance is currently serving from.
	PrimaryGceZone string `protobuf:"bytes,1,opt,name=primary_gce_zone,json=primaryGceZone,proto3" json:"primary_gce_zone,omitempty"`
	// The Compute Engine zone that the failover instance is currently serving
	// from for a regional Cloud SQL instance.
	SecondaryGceZone string `protobuf:"bytes,2,opt,name=secondary_gce_zone,json=secondaryGceZone,proto3" json:"secondary_gce_zone,omitempty"`
	// The availability status of the failover replica. A false status indicates
	// that the failover replica is out of sync. The primary instance can only
	// fail over to the failover replica when the status is true.
	IsFailoverReplicaAvailable bool `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

Response for FetchDatabasePropertiesRequest.

func (*FetchDatabasePropertiesResponse) Descriptor deprecated added in v1.8.0 

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

Deprecated: Use FetchDatabasePropertiesResponse.ProtoReflect.Descriptor instead.

func (*FetchDatabasePropertiesResponse) GetIsFailoverReplicaAvailable added in v1.8.0 

func (x *FetchDatabasePropertiesResponse) GetIsFailoverReplicaAvailable() bool

func (*FetchDatabasePropertiesResponse) GetPrimaryGceZone added in v1.8.0 

func (x *FetchDatabasePropertiesResponse) GetPrimaryGceZone() string

func (*FetchDatabasePropertiesResponse) GetSecondaryGceZone added in v1.8.0 

func (x *FetchDatabasePropertiesResponse) GetSecondaryGceZone() string

func (*FetchDatabasePropertiesResponse) ProtoMessage added in v1.8.0 

func (*FetchDatabasePropertiesResponse) ProtoMessage()

func (*FetchDatabasePropertiesResponse) ProtoReflect added in v1.8.0 

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

func (*FetchDatabasePropertiesResponse) Reset added in v1.8.0 

func (x *FetchDatabasePropertiesResponse) Reset()

func (*FetchDatabasePropertiesResponse) String added in v1.8.0 

func (x *FetchDatabasePropertiesResponse) 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"`
	// Configuration of allocating IP addresses for pods in the GKE cluster.
	//
	// Types that are assignable to ClusterIpAllocation:
	//	*IPAllocationPolicy_ClusterSecondaryRangeName
	//	*IPAllocationPolicy_ClusterIpv4CidrBlock
	ClusterIpAllocation isIPAllocationPolicy_ClusterIpAllocation `protobuf_oneof:"cluster_ip_allocation"`
	// Configuration of allocating IP addresses for services in the GKE cluster.
	//
	// Types that are assignable to ServicesIpAllocation:
	//	*IPAllocationPolicy_ServicesSecondaryRangeName
	//	*IPAllocationPolicy_ServicesIpv4CidrBlock
	ServicesIpAllocation isIPAllocationPolicy_ServicesIpAllocation `protobuf_oneof:"services_ip_allocation"`
	// contains filtered or unexported fields
}

Configuration for controlling how IPs are allocated in the GKE cluster running the Apache Airflow software.

func (*IPAllocationPolicy) Descriptor deprecated 

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

Deprecated: Use IPAllocationPolicy.ProtoReflect.Descriptor instead.

func (*IPAllocationPolicy) GetClusterIpAllocation 

func (m *IPAllocationPolicy) GetClusterIpAllocation() isIPAllocationPolicy_ClusterIpAllocation

func (*IPAllocationPolicy) GetClusterIpv4CidrBlock 

func (x *IPAllocationPolicy) GetClusterIpv4CidrBlock() string

func (*IPAllocationPolicy) GetClusterSecondaryRangeName 

func (x *IPAllocationPolicy) GetClusterSecondaryRangeName() string

func (*IPAllocationPolicy) GetServicesIpAllocation 

func (m *IPAllocationPolicy) GetServicesIpAllocation() isIPAllocationPolicy_ServicesIpAllocation

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 IPAllocationPolicy_ClusterIpv4CidrBlock 

type IPAllocationPolicy_ClusterIpv4CidrBlock struct {
	// Optional. The IP address range used to allocate IP addresses to pods in
	// the GKE 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.
	ClusterIpv4CidrBlock string `protobuf:"bytes,4,opt,name=cluster_ipv4_cidr_block,json=clusterIpv4CidrBlock,proto3,oneof"`
}

type IPAllocationPolicy_ClusterSecondaryRangeName 

type IPAllocationPolicy_ClusterSecondaryRangeName struct {
	// Optional. The name of the GKE cluster's secondary range used to allocate
	// IP addresses to pods.
	//
	// For Cloud Composer environments in versions composer-1.*.*-airflow-*.*.*,
	// this field is applicable only when `use_ip_aliases` is true.
	ClusterSecondaryRangeName string `protobuf:"bytes,2,opt,name=cluster_secondary_range_name,json=clusterSecondaryRangeName,proto3,oneof"`
}

type IPAllocationPolicy_ServicesIpv4CidrBlock 

type IPAllocationPolicy_ServicesIpv4CidrBlock struct {
	// Optional. The IP address range of the services IP addresses in this
	// GKE 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.
	ServicesIpv4CidrBlock string `protobuf:"bytes,5,opt,name=services_ipv4_cidr_block,json=servicesIpv4CidrBlock,proto3,oneof"`
}

type IPAllocationPolicy_ServicesSecondaryRangeName 

type IPAllocationPolicy_ServicesSecondaryRangeName struct {
	// Optional. The name of the services' secondary range used to allocate
	// IP addresses to the GKE cluster.
	//
	// For Cloud Composer environments in versions composer-1.*.*-airflow-*.*.*,
	// this field is applicable only when `use_ip_aliases` is true.
	ServicesSecondaryRangeName string `protobuf:"bytes,3,opt,name=services_secondary_range_name,json=servicesSecondaryRangeName,proto3,oneof"`
}

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
}

ImageVersion 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 added in v1.5.0 

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 added in v1.5.0 

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

Deprecated: Use LoadSnapshotRequest.ProtoReflect.Descriptor instead.

func (*LoadSnapshotRequest) GetEnvironment added in v1.5.0 

func (x *LoadSnapshotRequest) GetEnvironment() string

func (*LoadSnapshotRequest) GetSkipAirflowOverridesSetting added in v1.5.0 

func (x *LoadSnapshotRequest) GetSkipAirflowOverridesSetting() bool

func (*LoadSnapshotRequest) GetSkipEnvironmentVariablesSetting added in v1.5.0 

func (x *LoadSnapshotRequest) GetSkipEnvironmentVariablesSetting() bool

func (*LoadSnapshotRequest) GetSkipGcsDataCopying added in v1.5.0 

func (x *LoadSnapshotRequest) GetSkipGcsDataCopying() bool

func (*LoadSnapshotRequest) GetSkipPypiPackagesInstallation added in v1.5.0 

func (x *LoadSnapshotRequest) GetSkipPypiPackagesInstallation() bool

func (*LoadSnapshotRequest) GetSnapshotPath added in v1.5.0 

func (x *LoadSnapshotRequest) GetSnapshotPath() string

func (*LoadSnapshotRequest) ProtoMessage added in v1.5.0 

func (*LoadSnapshotRequest) ProtoMessage()

func (*LoadSnapshotRequest) ProtoReflect added in v1.5.0 

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

func (*LoadSnapshotRequest) Reset added in v1.5.0 

func (x *LoadSnapshotRequest) Reset()

func (*LoadSnapshotRequest) String added in v1.5.0 

func (x *LoadSnapshotRequest) String() string

type LoadSnapshotResponse added in v1.5.0 

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

Response to LoadSnapshotRequest.

func (*LoadSnapshotResponse) Descriptor deprecated added in v1.5.0 

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

Deprecated: Use LoadSnapshotResponse.ProtoReflect.Descriptor instead.

func (*LoadSnapshotResponse) ProtoMessage added in v1.5.0 

func (*LoadSnapshotResponse) ProtoMessage()

func (*LoadSnapshotResponse) ProtoReflect added in v1.5.0 

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

func (*LoadSnapshotResponse) Reset added in v1.5.0 

func (x *LoadSnapshotResponse) Reset()

func (*LoadSnapshotResponse) String added in v1.5.0 

func (x *LoadSnapshotResponse) String() string

type MaintenanceWindow added in v1.5.0 

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 added in v1.5.0 

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

Deprecated: Use MaintenanceWindow.ProtoReflect.Descriptor instead.

func (*MaintenanceWindow) GetEndTime added in v1.5.0 

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

func (*MaintenanceWindow) GetRecurrence added in v1.5.0 

func (x *MaintenanceWindow) GetRecurrence() string

func (*MaintenanceWindow) GetStartTime added in v1.5.0 

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

func (*MaintenanceWindow) ProtoMessage added in v1.5.0 

func (*MaintenanceWindow) ProtoMessage()

func (*MaintenanceWindow) ProtoReflect added in v1.5.0 

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

func (*MaintenanceWindow) Reset added in v1.5.0 

func (x *MaintenanceWindow) Reset()

func (*MaintenanceWindow) String added in v1.5.0 

func (x *MaintenanceWindow) String() string

type MasterAuthorizedNetworksConfig added in v1.5.0 

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 added in v1.5.0 

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

Deprecated: Use MasterAuthorizedNetworksConfig.ProtoReflect.Descriptor instead.

func (*MasterAuthorizedNetworksConfig) GetCidrBlocks added in v1.5.0 

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

func (*MasterAuthorizedNetworksConfig) GetEnabled added in v1.5.0 

func (x *MasterAuthorizedNetworksConfig) GetEnabled() bool

func (*MasterAuthorizedNetworksConfig) ProtoMessage added in v1.5.0 

func (*MasterAuthorizedNetworksConfig) ProtoMessage()

func (*MasterAuthorizedNetworksConfig) ProtoReflect added in v1.5.0 

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

func (*MasterAuthorizedNetworksConfig) Reset added in v1.5.0 

func (x *MasterAuthorizedNetworksConfig) Reset()

func (*MasterAuthorizedNetworksConfig) String added in v1.5.0 

func (x *MasterAuthorizedNetworksConfig) String() string

type MasterAuthorizedNetworksConfig_CidrBlock added in v1.5.0 

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 added in v1.5.0 

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

Deprecated: Use MasterAuthorizedNetworksConfig_CidrBlock.ProtoReflect.Descriptor instead.

func (*MasterAuthorizedNetworksConfig_CidrBlock) GetCidrBlock added in v1.5.0 

func (x *MasterAuthorizedNetworksConfig_CidrBlock) GetCidrBlock() string

func (*MasterAuthorizedNetworksConfig_CidrBlock) GetDisplayName added in v1.5.0 

func (x *MasterAuthorizedNetworksConfig_CidrBlock) GetDisplayName() string

func (*MasterAuthorizedNetworksConfig_CidrBlock) ProtoMessage added in v1.5.0 

func (*MasterAuthorizedNetworksConfig_CidrBlock) ProtoMessage()

func (*MasterAuthorizedNetworksConfig_CidrBlock) ProtoReflect added in v1.5.0 

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

func (*MasterAuthorizedNetworksConfig_CidrBlock) Reset added in v1.5.0 

func (x *MasterAuthorizedNetworksConfig_CidrBlock) Reset()

func (*MasterAuthorizedNetworksConfig_CidrBlock) String added in v1.5.0 

func (x *MasterAuthorizedNetworksConfig_CidrBlock) String() string

type NetworkingConfig added in v1.5.0 

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 `` /* 187-byte string literal not displayed */
	// contains filtered or unexported fields
}

Configuration options for networking connections in the Composer 2 environment.

func (*NetworkingConfig) Descriptor deprecated added in v1.5.0 

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

Deprecated: Use NetworkingConfig.ProtoReflect.Descriptor instead.

func (*NetworkingConfig) GetConnectionType added in v1.5.0 

func (x *NetworkingConfig) GetConnectionType() NetworkingConfig_ConnectionType

func (*NetworkingConfig) ProtoMessage added in v1.5.0 

func (*NetworkingConfig) ProtoMessage()

func (*NetworkingConfig) ProtoReflect added in v1.5.0 

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

func (*NetworkingConfig) Reset added in v1.5.0 

func (x *NetworkingConfig) Reset()

func (*NetworkingConfig) String added in v1.5.0 

func (x *NetworkingConfig) String() string

type NetworkingConfig_ConnectionType added in v1.5.0 

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 added in v1.5.0 

func (NetworkingConfig_ConnectionType) Descriptor() protoreflect.EnumDescriptor

func (NetworkingConfig_ConnectionType) Enum added in v1.5.0 

func (x NetworkingConfig_ConnectionType) Enum() *NetworkingConfig_ConnectionType

func (NetworkingConfig_ConnectionType) EnumDescriptor deprecated added in v1.5.0 

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

Deprecated: Use NetworkingConfig_ConnectionType.Descriptor instead.

func (NetworkingConfig_ConnectionType) Number added in v1.5.0 

func (x NetworkingConfig_ConnectionType) Number() protoreflect.EnumNumber

func (NetworkingConfig_ConnectionType) String added in v1.5.0 

func (x NetworkingConfig_ConnectionType) String() string

func (NetworkingConfig_ConnectionType) Type added in v1.5.0 

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 ID 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 node
	// VMs. 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.
	Tags []string `protobuf:"bytes,8,rep,name=tags,proto3" json:"tags,omitempty"`
	// Optional. The configuration for controlling how IPs are allocated in the
	// GKE cluster.
	IpAllocationPolicy *IPAllocationPolicy `protobuf:"bytes,9,opt,name=ip_allocation_policy,json=ipAllocationPolicy,proto3" json:"ip_allocation_policy,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 added in v1.5.0 

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) 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 `` /* 139-byte string literal not displayed */
	// Output only. The type of operation being performed.
	OperationType OperationMetadata_Type `` /* 175-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_SUCCEEDED  OperationMetadata_State = 3
	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
	// Triggers failover of environment's Cloud SQL instance (only for highly
	// resilient environments).
	OperationMetadata_DATABASE_FAILOVER OperationMetadata_Type = 7
)

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 PollAirflowCommandRequest added in v1.8.0 

type PollAirflowCommandRequest struct {

	// The resource name of the environment in the form:
	// "projects/{projectId}/locations/{locationId}/environments/{environmentId}"
	Environment string `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
	// The unique ID of the command execution.
	ExecutionId string `protobuf:"bytes,2,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,3,opt,name=pod,proto3" json:"pod,omitempty"`
	// The namespace of the pod where the command is executed.
	PodNamespace string `protobuf:"bytes,4,opt,name=pod_namespace,json=podNamespace,proto3" json:"pod_namespace,omitempty"`
	// Line number from which new logs should be fetched.
	NextLineNumber int32 `protobuf:"varint,5,opt,name=next_line_number,json=nextLineNumber,proto3" json:"next_line_number,omitempty"`
	// contains filtered or unexported fields
}

Poll Airflow Command request.

func (*PollAirflowCommandRequest) Descriptor deprecated added in v1.8.0 

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

Deprecated: Use PollAirflowCommandRequest.ProtoReflect.Descriptor instead.

func (*PollAirflowCommandRequest) GetEnvironment added in v1.8.0 

func (x *PollAirflowCommandRequest) GetEnvironment() string

func (*PollAirflowCommandRequest) GetExecutionId added in v1.8.0 

func (x *PollAirflowCommandRequest) GetExecutionId() string

func (*PollAirflowCommandRequest) GetNextLineNumber added in v1.8.0 

func (x *PollAirflowCommandRequest) GetNextLineNumber() int32

func (*PollAirflowCommandRequest) GetPod added in v1.8.0 

func (x *PollAirflowCommandRequest) GetPod() string

func (*PollAirflowCommandRequest) GetPodNamespace added in v1.8.0 

func (x *PollAirflowCommandRequest) GetPodNamespace() string

func (*PollAirflowCommandRequest) ProtoMessage added in v1.8.0 

func (*PollAirflowCommandRequest) ProtoMessage()

func (*PollAirflowCommandRequest) ProtoReflect added in v1.8.0 

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

func (*PollAirflowCommandRequest) Reset added in v1.8.0 

func (x *PollAirflowCommandRequest) Reset()

func (*PollAirflowCommandRequest) String added in v1.8.0 

func (x *PollAirflowCommandRequest) String() string

type PollAirflowCommandResponse added in v1.8.0 

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 added in v1.8.0 

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

Deprecated: Use PollAirflowCommandResponse.ProtoReflect.Descriptor instead.

func (*PollAirflowCommandResponse) GetExitInfo added in v1.8.0 

func (x *PollAirflowCommandResponse) GetExitInfo() *PollAirflowCommandResponse_ExitInfo

func (*PollAirflowCommandResponse) GetOutput added in v1.8.0 

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

func (*PollAirflowCommandResponse) GetOutputEnd added in v1.8.0 

func (x *PollAirflowCommandResponse) GetOutputEnd() bool

func (*PollAirflowCommandResponse) ProtoMessage added in v1.8.0 

func (*PollAirflowCommandResponse) ProtoMessage()

func (*PollAirflowCommandResponse) ProtoReflect added in v1.8.0 

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

func (*PollAirflowCommandResponse) Reset added in v1.8.0 

func (x *PollAirflowCommandResponse) Reset()

func (*PollAirflowCommandResponse) String added in v1.8.0 

func (x *PollAirflowCommandResponse) String() string

type PollAirflowCommandResponse_ExitInfo added in v1.8.0 

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 added in v1.8.0 

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

Deprecated: Use PollAirflowCommandResponse_ExitInfo.ProtoReflect.Descriptor instead.

func (*PollAirflowCommandResponse_ExitInfo) GetError added in v1.8.0 

func (x *PollAirflowCommandResponse_ExitInfo) GetError() string

func (*PollAirflowCommandResponse_ExitInfo) GetExitCode added in v1.8.0 

func (x *PollAirflowCommandResponse_ExitInfo) GetExitCode() int32

func (*PollAirflowCommandResponse_ExitInfo) ProtoMessage added in v1.8.0 

func (*PollAirflowCommandResponse_ExitInfo) ProtoMessage()

func (*PollAirflowCommandResponse_ExitInfo) ProtoReflect added in v1.8.0 

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

func (*PollAirflowCommandResponse_ExitInfo) Reset added in v1.8.0 

func (x *PollAirflowCommandResponse_ExitInfo) Reset()

func (*PollAirflowCommandResponse_ExitInfo) String added in v1.8.0 

func (x *PollAirflowCommandResponse_ExitInfo) String() string

type PollAirflowCommandResponse_Line added in v1.8.0 

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 added in v1.8.0 

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

Deprecated: Use PollAirflowCommandResponse_Line.ProtoReflect.Descriptor instead.

func (*PollAirflowCommandResponse_Line) GetContent added in v1.8.0 

func (x *PollAirflowCommandResponse_Line) GetContent() string

func (*PollAirflowCommandResponse_Line) GetLineNumber added in v1.8.0 

func (x *PollAirflowCommandResponse_Line) GetLineNumber() int32

func (*PollAirflowCommandResponse_Line) ProtoMessage added in v1.8.0 

func (*PollAirflowCommandResponse_Line) ProtoMessage()

func (*PollAirflowCommandResponse_Line) ProtoReflect added in v1.8.0 

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

func (*PollAirflowCommandResponse_Line) Reset added in v1.8.0 

func (x *PollAirflowCommandResponse_Line) Reset()

func (*PollAirflowCommandResponse_Line) String added in v1.8.0 

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 GKE
	// 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 added in v1.5.0 

func (x *PrivateEnvironmentConfig) GetCloudComposerConnectionSubnetwork() string

func (*PrivateEnvironmentConfig) GetCloudComposerNetworkIpv4CidrBlock added in v1.5.0 

func (x *PrivateEnvironmentConfig) GetCloudComposerNetworkIpv4CidrBlock() string

func (*PrivateEnvironmentConfig) GetCloudComposerNetworkIpv4ReservedRange added in v1.5.0 

func (x *PrivateEnvironmentConfig) GetCloudComposerNetworkIpv4ReservedRange() string

func (*PrivateEnvironmentConfig) GetCloudSqlIpv4CidrBlock 

func (x *PrivateEnvironmentConfig) GetCloudSqlIpv4CidrBlock() string

func (*PrivateEnvironmentConfig) GetEnablePrivateEnvironment 

func (x *PrivateEnvironmentConfig) GetEnablePrivateEnvironment() bool

func (*PrivateEnvironmentConfig) GetEnablePrivatelyUsedPublicIps added in v1.5.0 

func (x *PrivateEnvironmentConfig) GetEnablePrivatelyUsedPublicIps() bool

func (*PrivateEnvironmentConfig) GetNetworkingConfig added in v1.5.0 

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 added in v1.5.0 

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 added in v1.5.0 

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

Deprecated: Use RecoveryConfig.ProtoReflect.Descriptor instead.

func (*RecoveryConfig) GetScheduledSnapshotsConfig added in v1.5.0 

func (x *RecoveryConfig) GetScheduledSnapshotsConfig() *ScheduledSnapshotsConfig

func (*RecoveryConfig) ProtoMessage added in v1.5.0 

func (*RecoveryConfig) ProtoMessage()

func (*RecoveryConfig) ProtoReflect added in v1.5.0 

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

func (*RecoveryConfig) Reset added in v1.5.0 

func (x *RecoveryConfig) Reset()

func (*RecoveryConfig) String added in v1.5.0 

func (x *RecoveryConfig) String() string

type SaveSnapshotRequest added in v1.5.0 

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 added in v1.5.0 

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

Deprecated: Use SaveSnapshotRequest.ProtoReflect.Descriptor instead.

func (*SaveSnapshotRequest) GetEnvironment added in v1.5.0 

func (x *SaveSnapshotRequest) GetEnvironment() string

func (*SaveSnapshotRequest) GetSnapshotLocation added in v1.5.0 

func (x *SaveSnapshotRequest) GetSnapshotLocation() string

func (*SaveSnapshotRequest) ProtoMessage added in v1.5.0 

func (*SaveSnapshotRequest) ProtoMessage()

func (*SaveSnapshotRequest) ProtoReflect added in v1.5.0 

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

func (*SaveSnapshotRequest) Reset added in v1.5.0 

func (x *SaveSnapshotRequest) Reset()

func (*SaveSnapshotRequest) String added in v1.5.0 

func (x *SaveSnapshotRequest) String() string

type SaveSnapshotResponse added in v1.5.0 

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 added in v1.5.0 

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

Deprecated: Use SaveSnapshotResponse.ProtoReflect.Descriptor instead.

func (*SaveSnapshotResponse) GetSnapshotPath added in v1.5.0 

func (x *SaveSnapshotResponse) GetSnapshotPath() string

func (*SaveSnapshotResponse) ProtoMessage added in v1.5.0 

func (*SaveSnapshotResponse) ProtoMessage()

func (*SaveSnapshotResponse) ProtoReflect added in v1.5.0 

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

func (*SaveSnapshotResponse) Reset added in v1.5.0 

func (x *SaveSnapshotResponse) Reset()

func (*SaveSnapshotResponse) String added in v1.5.0 

func (x *SaveSnapshotResponse) String() string

type ScheduledSnapshotsConfig added in v1.5.0 

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 added in v1.5.0 

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

Deprecated: Use ScheduledSnapshotsConfig.ProtoReflect.Descriptor instead.

func (*ScheduledSnapshotsConfig) GetEnabled added in v1.5.0 

func (x *ScheduledSnapshotsConfig) GetEnabled() bool

func (*ScheduledSnapshotsConfig) GetSnapshotCreationSchedule added in v1.5.0 

func (x *ScheduledSnapshotsConfig) GetSnapshotCreationSchedule() string

func (*ScheduledSnapshotsConfig) GetSnapshotLocation added in v1.5.0 

func (x *ScheduledSnapshotsConfig) GetSnapshotLocation() string

func (*ScheduledSnapshotsConfig) GetTimeZone added in v1.5.0 

func (x *ScheduledSnapshotsConfig) GetTimeZone() string

func (*ScheduledSnapshotsConfig) ProtoMessage added in v1.5.0 

func (*ScheduledSnapshotsConfig) ProtoMessage()

func (*ScheduledSnapshotsConfig) ProtoReflect added in v1.5.0 

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

func (*ScheduledSnapshotsConfig) Reset added in v1.5.0 

func (x *ScheduledSnapshotsConfig) Reset()

func (*ScheduledSnapshotsConfig) String added in v1.5.0 

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"`
	// 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) 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 added in v1.5.0 

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 StopAirflowCommandRequest added in v1.8.0 

type StopAirflowCommandRequest struct {

	// The resource name of the environment in the form:
	// "projects/{projectId}/locations/{locationId}/environments/{environmentId}".
	Environment string `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
	// The unique ID of the command execution.
	ExecutionId string `protobuf:"bytes,2,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,3,opt,name=pod,proto3" json:"pod,omitempty"`
	// The namespace of the pod where the command is executed.
	PodNamespace string `protobuf:"bytes,4,opt,name=pod_namespace,json=podNamespace,proto3" json:"pod_namespace,omitempty"`
	// If true, the execution is terminated forcefully (SIGKILL). If false, the
	// execution is stopped gracefully, giving it time for cleanup.
	Force bool `protobuf:"varint,5,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

Stop Airflow Command request.

func (*StopAirflowCommandRequest) Descriptor deprecated added in v1.8.0 

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

Deprecated: Use StopAirflowCommandRequest.ProtoReflect.Descriptor instead.

func (*StopAirflowCommandRequest) GetEnvironment added in v1.8.0 

func (x *StopAirflowCommandRequest) GetEnvironment() string

func (*StopAirflowCommandRequest) GetExecutionId added in v1.8.0 

func (x *StopAirflowCommandRequest) GetExecutionId() string

func (*StopAirflowCommandRequest) GetForce added in v1.8.0 

func (x *StopAirflowCommandRequest) GetForce() bool

func (*StopAirflowCommandRequest) GetPod added in v1.8.0 

func (x *StopAirflowCommandRequest) GetPod() string

func (*StopAirflowCommandRequest) GetPodNamespace added in v1.8.0 

func (x *StopAirflowCommandRequest) GetPodNamespace() string

func (*StopAirflowCommandRequest) ProtoMessage added in v1.8.0 

func (*StopAirflowCommandRequest) ProtoMessage()

func (*StopAirflowCommandRequest) ProtoReflect added in v1.8.0 

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

func (*StopAirflowCommandRequest) Reset added in v1.8.0 

func (x *StopAirflowCommandRequest) Reset()

func (*StopAirflowCommandRequest) String added in v1.8.0 

func (x *StopAirflowCommandRequest) String() string

type StopAirflowCommandResponse added in v1.8.0 

type StopAirflowCommandResponse struct {

	// Whether the execution is still running.
	IsDone bool `protobuf:"varint,1,opt,name=is_done,json=isDone,proto3" json:"is_done,omitempty"`
	// Output message from stopping execution request.
	Output []string `protobuf:"bytes,2,rep,name=output,proto3" json:"output,omitempty"`
	// contains filtered or unexported fields
}

Response to StopAirflowCommandRequest.

func (*StopAirflowCommandResponse) Descriptor deprecated added in v1.8.0 

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

Deprecated: Use StopAirflowCommandResponse.ProtoReflect.Descriptor instead.

func (*StopAirflowCommandResponse) GetIsDone added in v1.8.0 

func (x *StopAirflowCommandResponse) GetIsDone() bool

func (*StopAirflowCommandResponse) GetOutput added in v1.8.0 

func (x *StopAirflowCommandResponse) GetOutput() []string

func (*StopAirflowCommandResponse) ProtoMessage added in v1.8.0 

func (*StopAirflowCommandResponse) ProtoMessage()

func (*StopAirflowCommandResponse) ProtoReflect added in v1.8.0 

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

func (*StopAirflowCommandResponse) Reset added in v1.8.0 

func (x *StopAirflowCommandResponse) Reset()

func (*StopAirflowCommandResponse) String added in v1.8.0 

func (x *StopAirflowCommandResponse) String() string

type UnimplementedEnvironmentsServer 

type UnimplementedEnvironmentsServer struct {
}

UnimplementedEnvironmentsServer can be embedded to have forward compatible implementations.

func (*UnimplementedEnvironmentsServer) CreateEnvironment 

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

func (*UnimplementedEnvironmentsServer) DatabaseFailover added in v1.8.0 

func (*UnimplementedEnvironmentsServer) DatabaseFailover(context.Context, *DatabaseFailoverRequest) (*longrunningpb.Operation, error)

func (*UnimplementedEnvironmentsServer) DeleteEnvironment 

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

func (*UnimplementedEnvironmentsServer) ExecuteAirflowCommand added in v1.8.0 

func (*UnimplementedEnvironmentsServer) ExecuteAirflowCommand(context.Context, *ExecuteAirflowCommandRequest) (*ExecuteAirflowCommandResponse, error)

func (*UnimplementedEnvironmentsServer) FetchDatabaseProperties added in v1.8.0 

func (*UnimplementedEnvironmentsServer) FetchDatabaseProperties(context.Context, *FetchDatabasePropertiesRequest) (*FetchDatabasePropertiesResponse, 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 added in v1.5.0 

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

func (*UnimplementedEnvironmentsServer) PollAirflowCommand added in v1.8.0 

func (*UnimplementedEnvironmentsServer) PollAirflowCommand(context.Context, *PollAirflowCommandRequest) (*PollAirflowCommandResponse, error)

func (*UnimplementedEnvironmentsServer) SaveSnapshot added in v1.5.0 

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

func (*UnimplementedEnvironmentsServer) StopAirflowCommand added in v1.8.0 

func (*UnimplementedEnvironmentsServer) StopAirflowCommand(context.Context, *StopAirflowCommandRequest) (*StopAirflowCommandResponse, error)

func (*UnimplementedEnvironmentsServer) UpdateEnvironment 

func (*UnimplementedEnvironmentsServer) UpdateEnvironment(context.Context, *UpdateEnvironmentRequest) (*longrunningpb.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
	// numpy, the `updateMask` parameter would include the following two
	// `paths` values: "config.softwareConfig.pypiPackages.scikit-learn" and
	// "config.softwareConfig.pypiPackages.numpy". 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 numpy 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.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.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-*.*.*.
	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 added in v1.5.0 

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"`
	// 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 added in v1.5.0 

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

Deprecated: Use WorkloadsConfig.ProtoReflect.Descriptor instead.

func (*WorkloadsConfig) GetScheduler added in v1.5.0 

func (x *WorkloadsConfig) GetScheduler() *WorkloadsConfig_SchedulerResource

func (*WorkloadsConfig) GetWebServer added in v1.5.0 

func (x *WorkloadsConfig) GetWebServer() *WorkloadsConfig_WebServerResource

func (*WorkloadsConfig) GetWorker added in v1.5.0 

func (x *WorkloadsConfig) GetWorker() *WorkloadsConfig_WorkerResource

func (*WorkloadsConfig) ProtoMessage added in v1.5.0 

func (*WorkloadsConfig) ProtoMessage()

func (*WorkloadsConfig) ProtoReflect added in v1.5.0 

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

func (*WorkloadsConfig) Reset added in v1.5.0 

func (x *WorkloadsConfig) Reset()

func (*WorkloadsConfig) String added in v1.5.0 

func (x *WorkloadsConfig) String() string

type WorkloadsConfig_SchedulerResource added in v1.5.0 

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 added in v1.5.0 

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

Deprecated: Use WorkloadsConfig_SchedulerResource.ProtoReflect.Descriptor instead.

func (*WorkloadsConfig_SchedulerResource) GetCount added in v1.5.0 

func (x *WorkloadsConfig_SchedulerResource) GetCount() int32

func (*WorkloadsConfig_SchedulerResource) GetCpu added in v1.5.0 

func (x *WorkloadsConfig_SchedulerResource) GetCpu() float32

func (*WorkloadsConfig_SchedulerResource) GetMemoryGb added in v1.5.0 

func (x *WorkloadsConfig_SchedulerResource) GetMemoryGb() float32

func (*WorkloadsConfig_SchedulerResource) GetStorageGb added in v1.5.0 

func (x *WorkloadsConfig_SchedulerResource) GetStorageGb() float32

func (*WorkloadsConfig_SchedulerResource) ProtoMessage added in v1.5.0 

func (*WorkloadsConfig_SchedulerResource) ProtoMessage()

func (*WorkloadsConfig_SchedulerResource) ProtoReflect added in v1.5.0 

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

func (*WorkloadsConfig_SchedulerResource) Reset added in v1.5.0 

func (x *WorkloadsConfig_SchedulerResource) Reset()

func (*WorkloadsConfig_SchedulerResource) String added in v1.5.0 

func (x *WorkloadsConfig_SchedulerResource) String() string

type WorkloadsConfig_WebServerResource added in v1.5.0 

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 added in v1.5.0 

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

Deprecated: Use WorkloadsConfig_WebServerResource.ProtoReflect.Descriptor instead.

func (*WorkloadsConfig_WebServerResource) GetCpu added in v1.5.0 

func (x *WorkloadsConfig_WebServerResource) GetCpu() float32

func (*WorkloadsConfig_WebServerResource) GetMemoryGb added in v1.5.0 

func (x *WorkloadsConfig_WebServerResource) GetMemoryGb() float32

func (*WorkloadsConfig_WebServerResource) GetStorageGb added in v1.5.0 

func (x *WorkloadsConfig_WebServerResource) GetStorageGb() float32

func (*WorkloadsConfig_WebServerResource) ProtoMessage added in v1.5.0 

func (*WorkloadsConfig_WebServerResource) ProtoMessage()

func (*WorkloadsConfig_WebServerResource) ProtoReflect added in v1.5.0 

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

func (*WorkloadsConfig_WebServerResource) Reset added in v1.5.0 

func (x *WorkloadsConfig_WebServerResource) Reset()

func (*WorkloadsConfig_WebServerResource) String added in v1.5.0 

func (x *WorkloadsConfig_WebServerResource) String() string

type WorkloadsConfig_WorkerResource added in v1.5.0 

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 added in v1.5.0 

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

Deprecated: Use WorkloadsConfig_WorkerResource.ProtoReflect.Descriptor instead.

func (*WorkloadsConfig_WorkerResource) GetCpu added in v1.5.0 

func (x *WorkloadsConfig_WorkerResource) GetCpu() float32

func (*WorkloadsConfig_WorkerResource) GetMaxCount added in v1.5.0 

func (x *WorkloadsConfig_WorkerResource) GetMaxCount() int32

func (*WorkloadsConfig_WorkerResource) GetMemoryGb added in v1.5.0 

func (x *WorkloadsConfig_WorkerResource) GetMemoryGb() float32

func (*WorkloadsConfig_WorkerResource) GetMinCount added in v1.5.0 

func (x *WorkloadsConfig_WorkerResource) GetMinCount() int32

func (*WorkloadsConfig_WorkerResource) GetStorageGb added in v1.5.0 

func (x *WorkloadsConfig_WorkerResource) GetStorageGb() float32

func (*WorkloadsConfig_WorkerResource) ProtoMessage added in v1.5.0 

func (*WorkloadsConfig_WorkerResource) ProtoMessage()

func (*WorkloadsConfig_WorkerResource) ProtoReflect added in v1.5.0 

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

func (*WorkloadsConfig_WorkerResource) Reset added in v1.5.0 

func (x *WorkloadsConfig_WorkerResource) Reset()

func (*WorkloadsConfig_WorkerResource) String added in v1.5.0 

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.