Package cloud.google.com/go/orchestration/airflow/service/apiv1/servicepb (v1.9.2)

Version latest

• 1.9.2 (latest)
• 1.9.1
• 1.8.5
• 1.7.0
• 1.6.1
• 1.5.0
• 1.4.0
• 1.3.0
• 1.2.0
• 1.1.0
• 1.0.0

Note: To get more information about this package, such as access to older versions, view this package on pkg.go.dev.

Variables

ListWorkloadsResponse_ComposerWorkloadType_name, ListWorkloadsResponse_ComposerWorkloadType_value

var (
	ListWorkloadsResponse_ComposerWorkloadType_name = map[int32]string{
		0: "COMPOSER_WORKLOAD_TYPE_UNSPECIFIED",
		1: "CELERY_WORKER",
		2: "KUBERNETES_WORKER",
		3: "KUBERNETES_OPERATOR_POD",
		4: "SCHEDULER",
		5: "DAG_PROCESSOR",
		6: "TRIGGERER",
		7: "WEB_SERVER",
		8: "REDIS",
	}
	ListWorkloadsResponse_ComposerWorkloadType_value = map[string]int32{
		"COMPOSER_WORKLOAD_TYPE_UNSPECIFIED": 0,
		"CELERY_WORKER":                      1,
		"KUBERNETES_WORKER":                  2,
		"KUBERNETES_OPERATOR_POD":            3,
		"SCHEDULER":                          4,
		"DAG_PROCESSOR":                      5,
		"TRIGGERER":                          6,
		"WEB_SERVER":                         7,
		"REDIS":                              8,
	}
)

Enum value maps for ListWorkloadsResponse_ComposerWorkloadType.

ListWorkloadsResponse_ComposerWorkloadState_name, ListWorkloadsResponse_ComposerWorkloadState_value

var (
	ListWorkloadsResponse_ComposerWorkloadState_name = map[int32]string{
		0: "COMPOSER_WORKLOAD_STATE_UNSPECIFIED",
		1: "PENDING",
		2: "OK",
		3: "WARNING",
		4: "ERROR",
		5: "SUCCEEDED",
		6: "FAILED",
	}
	ListWorkloadsResponse_ComposerWorkloadState_value = map[string]int32{
		"COMPOSER_WORKLOAD_STATE_UNSPECIFIED": 0,
		"PENDING":                             1,
		"OK":                                  2,
		"WARNING":                             3,
		"ERROR":                               4,
		"SUCCEEDED":                           5,
		"FAILED":                              6,
	}
)

Enum value maps for ListWorkloadsResponse_ComposerWorkloadState.

EnvironmentConfig_EnvironmentSize_name, EnvironmentConfig_EnvironmentSize_value

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.

EnvironmentConfig_ResilienceMode_name, EnvironmentConfig_ResilienceMode_value

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.

SoftwareConfig_WebServerPluginsMode_name, SoftwareConfig_WebServerPluginsMode_value

var (
	SoftwareConfig_WebServerPluginsMode_name = map[int32]string{
		0: "WEB_SERVER_PLUGINS_MODE_UNSPECIFIED",
		1: "PLUGINS_DISABLED",
		2: "PLUGINS_ENABLED",
	}
	SoftwareConfig_WebServerPluginsMode_value = map[string]int32{
		"WEB_SERVER_PLUGINS_MODE_UNSPECIFIED": 0,
		"PLUGINS_DISABLED":                    1,
		"PLUGINS_ENABLED":                     2,
	}
)

Enum value maps for SoftwareConfig_WebServerPluginsMode.

NetworkingConfig_ConnectionType_name, NetworkingConfig_ConnectionType_value

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.

Environment_State_name, Environment_State_value

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.

CheckUpgradeResponse_ConflictResult_name, CheckUpgradeResponse_ConflictResult_value

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.

TaskLogsRetentionConfig_TaskLogsStorageMode_name, TaskLogsRetentionConfig_TaskLogsStorageMode_value

var (
	TaskLogsRetentionConfig_TaskLogsStorageMode_name = map[int32]string{
		0: "TASK_LOGS_STORAGE_MODE_UNSPECIFIED",
		1: "CLOUD_LOGGING_AND_CLOUD_STORAGE",
		2: "CLOUD_LOGGING_ONLY",
	}
	TaskLogsRetentionConfig_TaskLogsStorageMode_value = map[string]int32{
		"TASK_LOGS_STORAGE_MODE_UNSPECIFIED": 0,
		"CLOUD_LOGGING_AND_CLOUD_STORAGE":    1,
		"CLOUD_LOGGING_ONLY":                 2,
	}
)

Enum value maps for TaskLogsRetentionConfig_TaskLogsStorageMode.

OperationMetadata_State_name, OperationMetadata_State_value

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.

OperationMetadata_Type_name, OperationMetadata_Type_value

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.

File_google_cloud_orchestration_airflow_service_v1_environments_proto

var File_google_cloud_orchestration_airflow_service_v1_environments_proto protoreflect.FileDescriptor

File_google_cloud_orchestration_airflow_service_v1_image_versions_proto

var File_google_cloud_orchestration_airflow_service_v1_image_versions_proto protoreflect.FileDescriptor

File_google_cloud_orchestration_airflow_service_v1_operations_proto

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)

CheckUpgradeResponse

type CheckUpgradeResponse struct {
	BuildLogUri string `protobuf:"bytes,1,opt,name=build_log_uri,json=buildLogUri,proto3" json:"build_log_uri,omitempty"`

	ContainsPypiModulesConflict CheckUpgradeResponse_ConflictResult "" /* 234 byte string literal not displayed */

	PypiConflictBuildLogExtract string "" /* 148 byte string literal not displayed */

	ImageVersion string `protobuf:"bytes,5,opt,name=image_version,json=imageVersion,proto3" json:"image_version,omitempty"`

	PypiDependencies map[string]string "" /* 197 byte string literal not displayed */

}

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

func (*CheckUpgradeResponse) Descriptor

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

CheckUpgradeResponse_ConflictResult

type CheckUpgradeResponse_ConflictResult int32

Whether there were python modules conflict during image build.

CheckUpgradeResponse_CONFLICT_RESULT_UNSPECIFIED, CheckUpgradeResponse_CONFLICT, CheckUpgradeResponse_NO_CONFLICT

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

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

CloudDataLineageIntegration

type CloudDataLineageIntegration struct {

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

Configuration for Cloud Data Lineage integration.

func (*CloudDataLineageIntegration) Descriptor

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

Deprecated: Use CloudDataLineageIntegration.ProtoReflect.Descriptor instead.

func (*CloudDataLineageIntegration) GetEnabled

func (x *CloudDataLineageIntegration) GetEnabled() bool

func (*CloudDataLineageIntegration) ProtoMessage

func (*CloudDataLineageIntegration) ProtoMessage()

func (*CloudDataLineageIntegration) ProtoReflect

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

func (*CloudDataLineageIntegration) Reset

func (x *CloudDataLineageIntegration) Reset()

func (*CloudDataLineageIntegration) String

func (x *CloudDataLineageIntegration) String() string

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

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

CreateUserWorkloadsConfigMapRequest

type CreateUserWorkloadsConfigMapRequest struct {
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`

	UserWorkloadsConfigMap *UserWorkloadsConfigMap "" /* 131 byte string literal not displayed */

}

Create user workloads ConfigMap request.

func (*CreateUserWorkloadsConfigMapRequest) Descriptor

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

Deprecated: Use CreateUserWorkloadsConfigMapRequest.ProtoReflect.Descriptor instead.

func (*CreateUserWorkloadsConfigMapRequest) GetParent

func (x *CreateUserWorkloadsConfigMapRequest) GetParent() string

func (*CreateUserWorkloadsConfigMapRequest) GetUserWorkloadsConfigMap

func (x *CreateUserWorkloadsConfigMapRequest) GetUserWorkloadsConfigMap() *UserWorkloadsConfigMap

func (*CreateUserWorkloadsConfigMapRequest) ProtoMessage

func (*CreateUserWorkloadsConfigMapRequest) ProtoMessage()

func (*CreateUserWorkloadsConfigMapRequest) ProtoReflect

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

func (*CreateUserWorkloadsConfigMapRequest) Reset

func (x *CreateUserWorkloadsConfigMapRequest) Reset()

func (*CreateUserWorkloadsConfigMapRequest) String

func (x *CreateUserWorkloadsConfigMapRequest) String() string

CreateUserWorkloadsSecretRequest

type CreateUserWorkloadsSecretRequest struct {

	// Required. The environment name to create a Secret for, in the form:
	// "projects/{projectId}/locations/{locationId}/environments/{environmentId}"
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. User workloads Secret to create.
	UserWorkloadsSecret *UserWorkloadsSecret `protobuf:"bytes,2,opt,name=user_workloads_secret,json=userWorkloadsSecret,proto3" json:"user_workloads_secret,omitempty"`
	// contains filtered or unexported fields
}

Create user workloads Secret request.

func (*CreateUserWorkloadsSecretRequest) Descriptor

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

Deprecated: Use CreateUserWorkloadsSecretRequest.ProtoReflect.Descriptor instead.

func (*CreateUserWorkloadsSecretRequest) GetParent

func (x *CreateUserWorkloadsSecretRequest) GetParent() string

func (*CreateUserWorkloadsSecretRequest) GetUserWorkloadsSecret

func (x *CreateUserWorkloadsSecretRequest) GetUserWorkloadsSecret() *UserWorkloadsSecret

func (*CreateUserWorkloadsSecretRequest) ProtoMessage

func (*CreateUserWorkloadsSecretRequest) ProtoMessage()

func (*CreateUserWorkloadsSecretRequest) ProtoReflect

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

func (*CreateUserWorkloadsSecretRequest) Reset

func (x *CreateUserWorkloadsSecretRequest) Reset()

func (*CreateUserWorkloadsSecretRequest) String

func (x *CreateUserWorkloadsSecretRequest) String() string

DataRetentionConfig

type DataRetentionConfig struct {
	TaskLogsRetentionConfig *TaskLogsRetentionConfig "" /* 134 byte string literal not displayed */

}

The configuration setting for Airflow database data retention mechanism.

func (*DataRetentionConfig) Descriptor

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

Deprecated: Use DataRetentionConfig.ProtoReflect.Descriptor instead.

func (*DataRetentionConfig) GetTaskLogsRetentionConfig

func (x *DataRetentionConfig) GetTaskLogsRetentionConfig() *TaskLogsRetentionConfig

func (*DataRetentionConfig) ProtoMessage

func (*DataRetentionConfig) ProtoMessage()

func (*DataRetentionConfig) ProtoReflect

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

func (*DataRetentionConfig) Reset

func (x *DataRetentionConfig) Reset()

func (*DataRetentionConfig) String

func (x *DataRetentionConfig) String() string

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"`
	// Optional. The Compute Engine zone where the Airflow database is created. If
	// zone is provided, it must be in the region selected for the environment. If
	// zone is not provided, a zone is automatically selected. The zone can only
	// be set during environment creation. Supported for Cloud Composer
	// environments in versions composer-2.*.*-airflow-*.*.*.
	Zone string `protobuf:"bytes,2,opt,name=zone,proto3" json:"zone,omitempty"`
	// contains filtered or unexported fields
}

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

func (*DatabaseConfig) Descriptor

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

Deprecated: Use DatabaseConfig.ProtoReflect.Descriptor instead.

func (*DatabaseConfig) GetMachineType

func (x *DatabaseConfig) GetMachineType() string

func (*DatabaseConfig) GetZone

func (x *DatabaseConfig) GetZone() 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

DatabaseFailoverRequest

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

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

Deprecated: Use DatabaseFailoverRequest.ProtoReflect.Descriptor instead.

func (*DatabaseFailoverRequest) GetEnvironment

func (x *DatabaseFailoverRequest) GetEnvironment() string

func (*DatabaseFailoverRequest) ProtoMessage

func (*DatabaseFailoverRequest) ProtoMessage()

func (*DatabaseFailoverRequest) ProtoReflect

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

func (*DatabaseFailoverRequest) Reset

func (x *DatabaseFailoverRequest) Reset()

func (*DatabaseFailoverRequest) String

func (x *DatabaseFailoverRequest) String() string

DatabaseFailoverResponse

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

Response for DatabaseFailoverRequest.

func (*DatabaseFailoverResponse) Descriptor

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

Deprecated: Use DatabaseFailoverResponse.ProtoReflect.Descriptor instead.

func (*DatabaseFailoverResponse) ProtoMessage

func (*DatabaseFailoverResponse) ProtoMessage()

func (*DatabaseFailoverResponse) ProtoReflect

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

func (*DatabaseFailoverResponse) Reset

func (x *DatabaseFailoverResponse) Reset()

func (*DatabaseFailoverResponse) String

func (x *DatabaseFailoverResponse) String() string

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

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

DeleteUserWorkloadsConfigMapRequest

type DeleteUserWorkloadsConfigMapRequest struct {

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

Delete user workloads ConfigMap request.

func (*DeleteUserWorkloadsConfigMapRequest) Descriptor

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

Deprecated: Use DeleteUserWorkloadsConfigMapRequest.ProtoReflect.Descriptor instead.

func (*DeleteUserWorkloadsConfigMapRequest) GetName

func (x *DeleteUserWorkloadsConfigMapRequest) GetName() string

func (*DeleteUserWorkloadsConfigMapRequest) ProtoMessage

func (*DeleteUserWorkloadsConfigMapRequest) ProtoMessage()

func (*DeleteUserWorkloadsConfigMapRequest) ProtoReflect

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

func (*DeleteUserWorkloadsConfigMapRequest) Reset

func (x *DeleteUserWorkloadsConfigMapRequest) Reset()

func (*DeleteUserWorkloadsConfigMapRequest) String

func (x *DeleteUserWorkloadsConfigMapRequest) String() string

DeleteUserWorkloadsSecretRequest

type DeleteUserWorkloadsSecretRequest struct {

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

Delete user workloads Secret request.

func (*DeleteUserWorkloadsSecretRequest) Descriptor

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

Deprecated: Use DeleteUserWorkloadsSecretRequest.ProtoReflect.Descriptor instead.

func (*DeleteUserWorkloadsSecretRequest) GetName

func (x *DeleteUserWorkloadsSecretRequest) GetName() string

func (*DeleteUserWorkloadsSecretRequest) ProtoMessage

func (*DeleteUserWorkloadsSecretRequest) ProtoMessage()

func (*DeleteUserWorkloadsSecretRequest) ProtoReflect

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

func (*DeleteUserWorkloadsSecretRequest) Reset

func (x *DeleteUserWorkloadsSecretRequest) Reset()

func (*DeleteUserWorkloadsSecretRequest) String

func (x *DeleteUserWorkloadsSecretRequest) String() string

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

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

Environment

type Environment struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	Config *EnvironmentConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`

	Uuid string `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"`

	State Environment_State "" /* 133 byte string literal not displayed */

	CreateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`

	Labels map[string]string "" /* 153 byte string literal not displayed */

	SatisfiesPzs bool `protobuf:"varint,8,opt,name=satisfies_pzs,json=satisfiesPzs,proto3" json:"satisfies_pzs,omitempty"`

	StorageConfig *StorageConfig `protobuf:"bytes,9,opt,name=storage_config,json=storageConfig,proto3" json:"storage_config,omitempty"`

}

An environment for running orchestration tasks.

func (*Environment) Descriptor

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

func (x *Environment) GetSatisfiesPzs() bool

func (*Environment) GetState

func (x *Environment) GetState() Environment_State

func (*Environment) GetStorageConfig

func (x *Environment) GetStorageConfig() *StorageConfig

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

EnvironmentConfig

type EnvironmentConfig struct {
	GkeCluster string `protobuf:"bytes,1,opt,name=gke_cluster,json=gkeCluster,proto3" json:"gke_cluster,omitempty"`

	DagGcsPrefix string `protobuf:"bytes,2,opt,name=dag_gcs_prefix,json=dagGcsPrefix,proto3" json:"dag_gcs_prefix,omitempty"`

	NodeCount int32 `protobuf:"varint,3,opt,name=node_count,json=nodeCount,proto3" json:"node_count,omitempty"`

	SoftwareConfig *SoftwareConfig `protobuf:"bytes,4,opt,name=software_config,json=softwareConfig,proto3" json:"software_config,omitempty"`

	NodeConfig *NodeConfig `protobuf:"bytes,5,opt,name=node_config,json=nodeConfig,proto3" json:"node_config,omitempty"`

	PrivateEnvironmentConfig *PrivateEnvironmentConfig "" /* 135 byte string literal not displayed */

	WebServerNetworkAccessControl *WebServerNetworkAccessControl "" /* 154 byte string literal not displayed */

	DatabaseConfig *DatabaseConfig `protobuf:"bytes,9,opt,name=database_config,json=databaseConfig,proto3" json:"database_config,omitempty"`

	WebServerConfig *WebServerConfig `protobuf:"bytes,10,opt,name=web_server_config,json=webServerConfig,proto3" json:"web_server_config,omitempty"`

	EncryptionConfig *EncryptionConfig `protobuf:"bytes,11,opt,name=encryption_config,json=encryptionConfig,proto3" json:"encryption_config,omitempty"`

	MaintenanceWindow *MaintenanceWindow `protobuf:"bytes,12,opt,name=maintenance_window,json=maintenanceWindow,proto3" json:"maintenance_window,omitempty"`

	WorkloadsConfig *WorkloadsConfig `protobuf:"bytes,15,opt,name=workloads_config,json=workloadsConfig,proto3" json:"workloads_config,omitempty"`

	EnvironmentSize EnvironmentConfig_EnvironmentSize "" /* 193 byte string literal not displayed */

	AirflowUri string `protobuf:"bytes,6,opt,name=airflow_uri,json=airflowUri,proto3" json:"airflow_uri,omitempty"`

	AirflowByoidUri string `protobuf:"bytes,20,opt,name=airflow_byoid_uri,json=airflowByoidUri,proto3" json:"airflow_byoid_uri,omitempty"`

	MasterAuthorizedNetworksConfig *MasterAuthorizedNetworksConfig "" /* 156 byte string literal not displayed */

	RecoveryConfig *RecoveryConfig `protobuf:"bytes,18,opt,name=recovery_config,json=recoveryConfig,proto3" json:"recovery_config,omitempty"`

	ResilienceMode EnvironmentConfig_ResilienceMode "" /* 189 byte string literal not displayed */

	DataRetentionConfig *DataRetentionConfig `protobuf:"bytes,21,opt,name=data_retention_config,json=dataRetentionConfig,proto3" json:"data_retention_config,omitempty"`

}

Configuration information for an environment.

func (*EnvironmentConfig) Descriptor

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

Deprecated: Use EnvironmentConfig.ProtoReflect.Descriptor instead.

func (*EnvironmentConfig) GetAirflowByoidUri

func (x *EnvironmentConfig) GetAirflowByoidUri() string

func (*EnvironmentConfig) GetAirflowUri

func (x *EnvironmentConfig) GetAirflowUri() string

func (*EnvironmentConfig) GetDagGcsPrefix

func (x *EnvironmentConfig) GetDagGcsPrefix() string

func (*EnvironmentConfig) GetDataRetentionConfig

func (x *EnvironmentConfig) GetDataRetentionConfig() *DataRetentionConfig

func (*EnvironmentConfig) GetDatabaseConfig

func (x *EnvironmentConfig) GetDatabaseConfig() *DatabaseConfig

func (*EnvironmentConfig) GetEncryptionConfig

func (x *EnvironmentConfig) GetEncryptionConfig() *EncryptionConfig

func (*EnvironmentConfig) GetEnvironmentSize

func (x *EnvironmentConfig) GetEnvironmentSize() EnvironmentConfig_EnvironmentSize

func (*EnvironmentConfig) GetGkeCluster

func (x *EnvironmentConfig) GetGkeCluster() string

func (*EnvironmentConfig) GetMaintenanceWindow

func (x *EnvironmentConfig) GetMaintenanceWindow() *MaintenanceWindow

func (*EnvironmentConfig) GetMasterAuthorizedNetworksConfig

func (x *EnvironmentConfig) GetMasterAuthorizedNetworksConfig() *MasterAuthorizedNetworksConfig

func (*EnvironmentConfig) GetNodeConfig

func (x *EnvironmentConfig) GetNodeConfig() *NodeConfig

func (*EnvironmentConfig) GetNodeCount

func (x *EnvironmentConfig) GetNodeCount() int32

func (*EnvironmentConfig) GetPrivateEnvironmentConfig

func (x *EnvironmentConfig) GetPrivateEnvironmentConfig() *PrivateEnvironmentConfig

func (*EnvironmentConfig) GetRecoveryConfig

func (x *EnvironmentConfig) GetRecoveryConfig() *RecoveryConfig

func (*EnvironmentConfig) GetResilienceMode

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

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

EnvironmentConfig_EnvironmentSize

type EnvironmentConfig_EnvironmentSize int32

The size of the Cloud Composer environment.

EnvironmentConfig_ENVIRONMENT_SIZE_UNSPECIFIED, EnvironmentConfig_ENVIRONMENT_SIZE_SMALL, EnvironmentConfig_ENVIRONMENT_SIZE_MEDIUM, EnvironmentConfig_ENVIRONMENT_SIZE_LARGE

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

func (EnvironmentConfig_EnvironmentSize) Descriptor

func (EnvironmentConfig_EnvironmentSize) Descriptor() protoreflect.EnumDescriptor

func (EnvironmentConfig_EnvironmentSize) Enum

func (x EnvironmentConfig_EnvironmentSize) Enum() *EnvironmentConfig_EnvironmentSize

func (EnvironmentConfig_EnvironmentSize) EnumDescriptor

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

Deprecated: Use EnvironmentConfig_EnvironmentSize.Descriptor instead.

func (EnvironmentConfig_EnvironmentSize) Number

func (x EnvironmentConfig_EnvironmentSize) Number() protoreflect.EnumNumber

func (EnvironmentConfig_EnvironmentSize) String

func (x EnvironmentConfig_EnvironmentSize) String() string

func (EnvironmentConfig_EnvironmentSize) Type

func (EnvironmentConfig_EnvironmentSize) Type() protoreflect.EnumType

EnvironmentConfig_ResilienceMode

type EnvironmentConfig_ResilienceMode int32

Resilience mode of the Cloud Composer Environment.

EnvironmentConfig_RESILIENCE_MODE_UNSPECIFIED, EnvironmentConfig_HIGH_RESILIENCE

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

func (EnvironmentConfig_ResilienceMode) Descriptor() protoreflect.EnumDescriptor

func (EnvironmentConfig_ResilienceMode) Enum

func (x EnvironmentConfig_ResilienceMode) Enum() *EnvironmentConfig_ResilienceMode

func (EnvironmentConfig_ResilienceMode) EnumDescriptor

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

Deprecated: Use EnvironmentConfig_ResilienceMode.Descriptor instead.

func (EnvironmentConfig_ResilienceMode) Number

func (x EnvironmentConfig_ResilienceMode) Number() protoreflect.EnumNumber

func (EnvironmentConfig_ResilienceMode) String

func (x EnvironmentConfig_ResilienceMode) String() string

func (EnvironmentConfig_ResilienceMode) Type

func (EnvironmentConfig_ResilienceMode) Type() protoreflect.EnumType

Environment_State

type Environment_State int32

State of the environment.

Environment_STATE_UNSPECIFIED, Environment_CREATING, Environment_RUNNING, Environment_UPDATING, Environment_DELETING, Environment_ERROR

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

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

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)
	// Lists workloads in a Cloud Composer environment. Workload is a unit that
	// runs a single Composer component.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	ListWorkloads(ctx context.Context, in *ListWorkloadsRequest, opts ...grpc.CallOption) (*ListWorkloadsResponse, error)
	// Creates a user workloads Secret.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	CreateUserWorkloadsSecret(ctx context.Context, in *CreateUserWorkloadsSecretRequest, opts ...grpc.CallOption) (*UserWorkloadsSecret, error)
	// Gets an existing user workloads Secret.
	// Values of the "data" field in the response are cleared.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	GetUserWorkloadsSecret(ctx context.Context, in *GetUserWorkloadsSecretRequest, opts ...grpc.CallOption) (*UserWorkloadsSecret, error)
	// Lists user workloads Secrets.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	ListUserWorkloadsSecrets(ctx context.Context, in *ListUserWorkloadsSecretsRequest, opts ...grpc.CallOption) (*ListUserWorkloadsSecretsResponse, error)
	// Updates a user workloads Secret.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	UpdateUserWorkloadsSecret(ctx context.Context, in *UpdateUserWorkloadsSecretRequest, opts ...grpc.CallOption) (*UserWorkloadsSecret, error)
	// Deletes a user workloads Secret.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	DeleteUserWorkloadsSecret(ctx context.Context, in *DeleteUserWorkloadsSecretRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Creates a user workloads ConfigMap.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	CreateUserWorkloadsConfigMap(ctx context.Context, in *CreateUserWorkloadsConfigMapRequest, opts ...grpc.CallOption) (*UserWorkloadsConfigMap, error)
	// Gets an existing user workloads ConfigMap.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	GetUserWorkloadsConfigMap(ctx context.Context, in *GetUserWorkloadsConfigMapRequest, opts ...grpc.CallOption) (*UserWorkloadsConfigMap, error)
	// Lists user workloads ConfigMaps.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	ListUserWorkloadsConfigMaps(ctx context.Context, in *ListUserWorkloadsConfigMapsRequest, opts ...grpc.CallOption) (*ListUserWorkloadsConfigMapsResponse, error)
	// Updates a user workloads ConfigMap.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	UpdateUserWorkloadsConfigMap(ctx context.Context, in *UpdateUserWorkloadsConfigMapRequest, opts ...grpc.CallOption) (*UserWorkloadsConfigMap, error)
	// Deletes a user workloads ConfigMap.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	DeleteUserWorkloadsConfigMap(ctx context.Context, in *DeleteUserWorkloadsConfigMapRequest, opts ...grpc.CallOption) (*emptypb.Empty, 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

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)
	// Lists workloads in a Cloud Composer environment. Workload is a unit that
	// runs a single Composer component.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	ListWorkloads(context.Context, *ListWorkloadsRequest) (*ListWorkloadsResponse, error)
	// Creates a user workloads Secret.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	CreateUserWorkloadsSecret(context.Context, *CreateUserWorkloadsSecretRequest) (*UserWorkloadsSecret, error)
	// Gets an existing user workloads Secret.
	// Values of the "data" field in the response are cleared.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	GetUserWorkloadsSecret(context.Context, *GetUserWorkloadsSecretRequest) (*UserWorkloadsSecret, error)
	// Lists user workloads Secrets.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	ListUserWorkloadsSecrets(context.Context, *ListUserWorkloadsSecretsRequest) (*ListUserWorkloadsSecretsResponse, error)
	// Updates a user workloads Secret.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	UpdateUserWorkloadsSecret(context.Context, *UpdateUserWorkloadsSecretRequest) (*UserWorkloadsSecret, error)
	// Deletes a user workloads Secret.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	DeleteUserWorkloadsSecret(context.Context, *DeleteUserWorkloadsSecretRequest) (*emptypb.Empty, error)
	// Creates a user workloads ConfigMap.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	CreateUserWorkloadsConfigMap(context.Context, *CreateUserWorkloadsConfigMapRequest) (*UserWorkloadsConfigMap, error)
	// Gets an existing user workloads ConfigMap.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	GetUserWorkloadsConfigMap(context.Context, *GetUserWorkloadsConfigMapRequest) (*UserWorkloadsConfigMap, error)
	// Lists user workloads ConfigMaps.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	ListUserWorkloadsConfigMaps(context.Context, *ListUserWorkloadsConfigMapsRequest) (*ListUserWorkloadsConfigMapsResponse, error)
	// Updates a user workloads ConfigMap.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	UpdateUserWorkloadsConfigMap(context.Context, *UpdateUserWorkloadsConfigMapRequest) (*UserWorkloadsConfigMap, error)
	// Deletes a user workloads ConfigMap.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	DeleteUserWorkloadsConfigMap(context.Context, *DeleteUserWorkloadsConfigMapRequest) (*emptypb.Empty, 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.

ExecuteAirflowCommandRequest

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

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

Deprecated: Use ExecuteAirflowCommandRequest.ProtoReflect.Descriptor instead.

func (*ExecuteAirflowCommandRequest) GetCommand

func (x *ExecuteAirflowCommandRequest) GetCommand() string

func (*ExecuteAirflowCommandRequest) GetEnvironment

func (x *ExecuteAirflowCommandRequest) GetEnvironment() string

func (*ExecuteAirflowCommandRequest) GetParameters

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

func (*ExecuteAirflowCommandRequest) GetSubcommand

func (x *ExecuteAirflowCommandRequest) GetSubcommand() string

func (*ExecuteAirflowCommandRequest) ProtoMessage

func (*ExecuteAirflowCommandRequest) ProtoMessage()

func (*ExecuteAirflowCommandRequest) ProtoReflect

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

func (*ExecuteAirflowCommandRequest) Reset

func (x *ExecuteAirflowCommandRequest) Reset()

func (*ExecuteAirflowCommandRequest) String

func (x *ExecuteAirflowCommandRequest) String() string

ExecuteAirflowCommandResponse

type ExecuteAirflowCommandResponse struct {

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

Response to ExecuteAirflowCommandRequest.

func (*ExecuteAirflowCommandResponse) Descriptor

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

Deprecated: Use ExecuteAirflowCommandResponse.ProtoReflect.Descriptor instead.

func (*ExecuteAirflowCommandResponse) GetError

func (x *ExecuteAirflowCommandResponse) GetError() string

func (*ExecuteAirflowCommandResponse) GetExecutionId

func (x *ExecuteAirflowCommandResponse) GetExecutionId() string

func (*ExecuteAirflowCommandResponse) GetPod

func (x *ExecuteAirflowCommandResponse) GetPod() string

func (*ExecuteAirflowCommandResponse) GetPodNamespace

func (x *ExecuteAirflowCommandResponse) GetPodNamespace() string

func (*ExecuteAirflowCommandResponse) ProtoMessage

func (*ExecuteAirflowCommandResponse) ProtoMessage()

func (*ExecuteAirflowCommandResponse) ProtoReflect

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

func (*ExecuteAirflowCommandResponse) Reset

func (x *ExecuteAirflowCommandResponse) Reset()

func (*ExecuteAirflowCommandResponse) String

func (x *ExecuteAirflowCommandResponse) String() string

FetchDatabasePropertiesRequest

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

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

Deprecated: Use FetchDatabasePropertiesRequest.ProtoReflect.Descriptor instead.

func (*FetchDatabasePropertiesRequest) GetEnvironment

func (x *FetchDatabasePropertiesRequest) GetEnvironment() string

func (*FetchDatabasePropertiesRequest) ProtoMessage

func (*FetchDatabasePropertiesRequest) ProtoMessage()

func (*FetchDatabasePropertiesRequest) ProtoReflect

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

func (*FetchDatabasePropertiesRequest) Reset

func (x *FetchDatabasePropertiesRequest) Reset()

func (*FetchDatabasePropertiesRequest) String

func (x *FetchDatabasePropertiesRequest) String() string

FetchDatabasePropertiesResponse

type FetchDatabasePropertiesResponse struct {
	PrimaryGceZone string `protobuf:"bytes,1,opt,name=primary_gce_zone,json=primaryGceZone,proto3" json:"primary_gce_zone,omitempty"`

	SecondaryGceZone string `protobuf:"bytes,2,opt,name=secondary_gce_zone,json=secondaryGceZone,proto3" json:"secondary_gce_zone,omitempty"`

	IsFailoverReplicaAvailable bool "" /* 144 byte string literal not displayed */

}

Response for FetchDatabasePropertiesRequest.

func (*FetchDatabasePropertiesResponse) Descriptor

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

Deprecated: Use FetchDatabasePropertiesResponse.ProtoReflect.Descriptor instead.

func (*FetchDatabasePropertiesResponse) GetIsFailoverReplicaAvailable

func (x *FetchDatabasePropertiesResponse) GetIsFailoverReplicaAvailable() bool

func (*FetchDatabasePropertiesResponse) GetPrimaryGceZone

func (x *FetchDatabasePropertiesResponse) GetPrimaryGceZone() string

func (*FetchDatabasePropertiesResponse) GetSecondaryGceZone

func (x *FetchDatabasePropertiesResponse) GetSecondaryGceZone() string

func (*FetchDatabasePropertiesResponse) ProtoMessage

func (*FetchDatabasePropertiesResponse) ProtoMessage()

func (*FetchDatabasePropertiesResponse) ProtoReflect

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

func (*FetchDatabasePropertiesResponse) Reset

func (x *FetchDatabasePropertiesResponse) Reset()

func (*FetchDatabasePropertiesResponse) String

func (x *FetchDatabasePropertiesResponse) String() string

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

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

GetUserWorkloadsConfigMapRequest

type GetUserWorkloadsConfigMapRequest struct {

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

Get user workloads ConfigMap request.

func (*GetUserWorkloadsConfigMapRequest) Descriptor

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

Deprecated: Use GetUserWorkloadsConfigMapRequest.ProtoReflect.Descriptor instead.

func (*GetUserWorkloadsConfigMapRequest) GetName

func (x *GetUserWorkloadsConfigMapRequest) GetName() string

func (*GetUserWorkloadsConfigMapRequest) ProtoMessage

func (*GetUserWorkloadsConfigMapRequest) ProtoMessage()

func (*GetUserWorkloadsConfigMapRequest) ProtoReflect

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

func (*GetUserWorkloadsConfigMapRequest) Reset

func (x *GetUserWorkloadsConfigMapRequest) Reset()

func (*GetUserWorkloadsConfigMapRequest) String

func (x *GetUserWorkloadsConfigMapRequest) String() string

GetUserWorkloadsSecretRequest

type GetUserWorkloadsSecretRequest struct {

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

Get user workloads Secret request.

func (*GetUserWorkloadsSecretRequest) Descriptor

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

Deprecated: Use GetUserWorkloadsSecretRequest.ProtoReflect.Descriptor instead.

func (*GetUserWorkloadsSecretRequest) GetName

func (x *GetUserWorkloadsSecretRequest) GetName() string

func (*GetUserWorkloadsSecretRequest) ProtoMessage

func (*GetUserWorkloadsSecretRequest) ProtoMessage()

func (*GetUserWorkloadsSecretRequest) ProtoReflect

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

func (*GetUserWorkloadsSecretRequest) Reset

func (x *GetUserWorkloadsSecretRequest) Reset()

func (*GetUserWorkloadsSecretRequest) String

func (x *GetUserWorkloadsSecretRequest) String() string

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

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

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"`
}

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"`
}

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"`
}

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"`
}

ImageVersion

type ImageVersion struct {
	ImageVersionId string `protobuf:"bytes,1,opt,name=image_version_id,json=imageVersionId,proto3" json:"image_version_id,omitempty"`

	IsDefault bool `protobuf:"varint,2,opt,name=is_default,json=isDefault,proto3" json:"is_default,omitempty"`

	SupportedPythonVersions []string "" /* 132 byte string literal not displayed */

	ReleaseDate *date.Date `protobuf:"bytes,4,opt,name=release_date,json=releaseDate,proto3" json:"release_date,omitempty"`

	CreationDisabled bool `protobuf:"varint,5,opt,name=creation_disabled,json=creationDisabled,proto3" json:"creation_disabled,omitempty"`

	UpgradeDisabled bool `protobuf:"varint,6,opt,name=upgrade_disabled,json=upgradeDisabled,proto3" json:"upgrade_disabled,omitempty"`

}

ImageVersion information

func (*ImageVersion) Descriptor

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

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

ImageVersionsServer

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

ImageVersionsServer is the server API for ImageVersions service.

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

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

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

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

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

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

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

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

ListUserWorkloadsConfigMapsRequest

type ListUserWorkloadsConfigMapsRequest struct {

	// Required. List ConfigMaps in the given environment, in the form:
	// "projects/{projectId}/locations/{locationId}/environments/{environmentId}"
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. The maximum number of ConfigMaps to return.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. 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 user workloads ConfigMaps request.

func (*ListUserWorkloadsConfigMapsRequest) Descriptor

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

Deprecated: Use ListUserWorkloadsConfigMapsRequest.ProtoReflect.Descriptor instead.

func (*ListUserWorkloadsConfigMapsRequest) GetPageSize

func (x *ListUserWorkloadsConfigMapsRequest) GetPageSize() int32

func (*ListUserWorkloadsConfigMapsRequest) GetPageToken

func (x *ListUserWorkloadsConfigMapsRequest) GetPageToken() string

func (*ListUserWorkloadsConfigMapsRequest) GetParent

func (x *ListUserWorkloadsConfigMapsRequest) GetParent() string

func (*ListUserWorkloadsConfigMapsRequest) ProtoMessage

func (*ListUserWorkloadsConfigMapsRequest) ProtoMessage()

func (*ListUserWorkloadsConfigMapsRequest) ProtoReflect

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

func (*ListUserWorkloadsConfigMapsRequest) Reset

func (x *ListUserWorkloadsConfigMapsRequest) Reset()

func (*ListUserWorkloadsConfigMapsRequest) String

func (x *ListUserWorkloadsConfigMapsRequest) String() string

ListUserWorkloadsConfigMapsResponse

type ListUserWorkloadsConfigMapsResponse struct {
	UserWorkloadsConfigMaps []*UserWorkloadsConfigMap "" /* 134 byte string literal not displayed */

	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`

}

The user workloads ConfigMaps for a given environment.

func (*ListUserWorkloadsConfigMapsResponse) Descriptor

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

Deprecated: Use ListUserWorkloadsConfigMapsResponse.ProtoReflect.Descriptor instead.

func (*ListUserWorkloadsConfigMapsResponse) GetNextPageToken

func (x *ListUserWorkloadsConfigMapsResponse) GetNextPageToken() string

func (*ListUserWorkloadsConfigMapsResponse) GetUserWorkloadsConfigMaps

func (x *ListUserWorkloadsConfigMapsResponse) GetUserWorkloadsConfigMaps() []*UserWorkloadsConfigMap

func (*ListUserWorkloadsConfigMapsResponse) ProtoMessage

func (*ListUserWorkloadsConfigMapsResponse) ProtoMessage()

func (*ListUserWorkloadsConfigMapsResponse) ProtoReflect

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

func (*ListUserWorkloadsConfigMapsResponse) Reset

func (x *ListUserWorkloadsConfigMapsResponse) Reset()

func (*ListUserWorkloadsConfigMapsResponse) String

func (x *ListUserWorkloadsConfigMapsResponse) String() string

ListUserWorkloadsSecretsRequest

type ListUserWorkloadsSecretsRequest struct {

	// Required. List Secrets in the given environment, in the form:
	// "projects/{projectId}/locations/{locationId}/environments/{environmentId}"
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. The maximum number of Secrets to return.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. 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 user workloads Secrets request.

func (*ListUserWorkloadsSecretsRequest) Descriptor

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

Deprecated: Use ListUserWorkloadsSecretsRequest.ProtoReflect.Descriptor instead.

func (*ListUserWorkloadsSecretsRequest) GetPageSize

func (x *ListUserWorkloadsSecretsRequest) GetPageSize() int32

func (*ListUserWorkloadsSecretsRequest) GetPageToken

func (x *ListUserWorkloadsSecretsRequest) GetPageToken() string

func (*ListUserWorkloadsSecretsRequest) GetParent

func (x *ListUserWorkloadsSecretsRequest) GetParent() string

func (*ListUserWorkloadsSecretsRequest) ProtoMessage

func (*ListUserWorkloadsSecretsRequest) ProtoMessage()

func (*ListUserWorkloadsSecretsRequest) ProtoReflect

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

func (*ListUserWorkloadsSecretsRequest) Reset

func (x *ListUserWorkloadsSecretsRequest) Reset()

func (*ListUserWorkloadsSecretsRequest) String

func (x *ListUserWorkloadsSecretsRequest) String() string

ListUserWorkloadsSecretsResponse

type ListUserWorkloadsSecretsResponse struct {

	// The list of Secrets returned by a ListUserWorkloadsSecretsRequest.
	UserWorkloadsSecrets []*UserWorkloadsSecret `protobuf:"bytes,1,rep,name=user_workloads_secrets,json=userWorkloadsSecrets,proto3" json:"user_workloads_secrets,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 user workloads Secrets for a given environment.

func (*ListUserWorkloadsSecretsResponse) Descriptor

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

Deprecated: Use ListUserWorkloadsSecretsResponse.ProtoReflect.Descriptor instead.

func (*ListUserWorkloadsSecretsResponse) GetNextPageToken

func (x *ListUserWorkloadsSecretsResponse) GetNextPageToken() string

func (*ListUserWorkloadsSecretsResponse) GetUserWorkloadsSecrets

func (x *ListUserWorkloadsSecretsResponse) GetUserWorkloadsSecrets() []*UserWorkloadsSecret

func (*ListUserWorkloadsSecretsResponse) ProtoMessage

func (*ListUserWorkloadsSecretsResponse) ProtoMessage()

func (*ListUserWorkloadsSecretsResponse) ProtoReflect

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

func (*ListUserWorkloadsSecretsResponse) Reset

func (x *ListUserWorkloadsSecretsResponse) Reset()

func (*ListUserWorkloadsSecretsResponse) String

func (x *ListUserWorkloadsSecretsResponse) String() string

ListWorkloadsRequest

type ListWorkloadsRequest struct {

	// Required. The environment name to get workloads for, in the form:
	// "projects/{projectId}/locations/{locationId}/environments/{environmentId}"
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Optional. The maximum number of environments to return.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. 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"`
	// Optional. The list filter.
	// Currently only supports equality on the type field. The value of a field
	// specified in the filter expression must be one ComposerWorkloadType enum
	// option. It's possible to get multiple types using "OR" operator, e.g.:
	// "type=SCHEDULER OR type=CELERY_WORKER". If not specified, all items are
	// returned.
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

Request for listing workloads in a Cloud Composer environment.

func (*ListWorkloadsRequest) Descriptor

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

Deprecated: Use ListWorkloadsRequest.ProtoReflect.Descriptor instead.

func (*ListWorkloadsRequest) GetFilter

func (x *ListWorkloadsRequest) GetFilter() string

func (*ListWorkloadsRequest) GetPageSize

func (x *ListWorkloadsRequest) GetPageSize() int32

func (*ListWorkloadsRequest) GetPageToken

func (x *ListWorkloadsRequest) GetPageToken() string

func (*ListWorkloadsRequest) GetParent

func (x *ListWorkloadsRequest) GetParent() string

func (*ListWorkloadsRequest) ProtoMessage

func (*ListWorkloadsRequest) ProtoMessage()

func (*ListWorkloadsRequest) ProtoReflect

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

func (*ListWorkloadsRequest) Reset

func (x *ListWorkloadsRequest) Reset()

func (*ListWorkloadsRequest) String

func (x *ListWorkloadsRequest) String() string

ListWorkloadsResponse

type ListWorkloadsResponse struct {

	// The list of environment workloads.
	Workloads []*ListWorkloadsResponse_ComposerWorkload `protobuf:"bytes,1,rep,name=workloads,proto3" json:"workloads,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
}

Response to ListWorkloadsRequest.

func (*ListWorkloadsResponse) Descriptor

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

Deprecated: Use ListWorkloadsResponse.ProtoReflect.Descriptor instead.

func (*ListWorkloadsResponse) GetNextPageToken

func (x *ListWorkloadsResponse) GetNextPageToken() string

func (*ListWorkloadsResponse) GetWorkloads

func (x *ListWorkloadsResponse) GetWorkloads() []*ListWorkloadsResponse_ComposerWorkload

func (*ListWorkloadsResponse) ProtoMessage

func (*ListWorkloadsResponse) ProtoMessage()

func (*ListWorkloadsResponse) ProtoReflect

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

func (*ListWorkloadsResponse) Reset

func (x *ListWorkloadsResponse) Reset()

func (*ListWorkloadsResponse) String

func (x *ListWorkloadsResponse) String() string

ListWorkloadsResponse_ComposerWorkload

type ListWorkloadsResponse_ComposerWorkload struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	Type ListWorkloadsResponse_ComposerWorkloadType "" /* 156 byte string literal not displayed */

	Status *ListWorkloadsResponse_ComposerWorkloadStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`

}

Information about a single workload.

func (*ListWorkloadsResponse_ComposerWorkload) Descriptor

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

Deprecated: Use ListWorkloadsResponse_ComposerWorkload.ProtoReflect.Descriptor instead.

func (*ListWorkloadsResponse_ComposerWorkload) GetName

func (x *ListWorkloadsResponse_ComposerWorkload) GetName() string

func (*ListWorkloadsResponse_ComposerWorkload) GetStatus

func (x *ListWorkloadsResponse_ComposerWorkload) GetStatus() *ListWorkloadsResponse_ComposerWorkloadStatus

func (*ListWorkloadsResponse_ComposerWorkload) GetType

func (x *ListWorkloadsResponse_ComposerWorkload) GetType() ListWorkloadsResponse_ComposerWorkloadType

func (*ListWorkloadsResponse_ComposerWorkload) ProtoMessage

func (*ListWorkloadsResponse_ComposerWorkload) ProtoMessage()

func (*ListWorkloadsResponse_ComposerWorkload) ProtoReflect

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

func (*ListWorkloadsResponse_ComposerWorkload) Reset

func (x *ListWorkloadsResponse_ComposerWorkload) Reset()

func (*ListWorkloadsResponse_ComposerWorkload) String

func (x *ListWorkloadsResponse_ComposerWorkload) String() string

ListWorkloadsResponse_ComposerWorkloadState

type ListWorkloadsResponse_ComposerWorkloadState int32

Workload states.

ListWorkloadsResponse_COMPOSER_WORKLOAD_STATE_UNSPECIFIED, ListWorkloadsResponse_PENDING, ListWorkloadsResponse_OK, ListWorkloadsResponse_WARNING, ListWorkloadsResponse_ERROR, ListWorkloadsResponse_SUCCEEDED, ListWorkloadsResponse_FAILED

const (
	// Not able to determine the status of the workload.
	ListWorkloadsResponse_COMPOSER_WORKLOAD_STATE_UNSPECIFIED ListWorkloadsResponse_ComposerWorkloadState = 0
	// Workload is in pending state and has not yet started.
	ListWorkloadsResponse_PENDING ListWorkloadsResponse_ComposerWorkloadState = 1
	// Workload is running fine.
	ListWorkloadsResponse_OK ListWorkloadsResponse_ComposerWorkloadState = 2
	// Workload is running but there are some non-critical problems.
	ListWorkloadsResponse_WARNING ListWorkloadsResponse_ComposerWorkloadState = 3
	// Workload is not running due to an error.
	ListWorkloadsResponse_ERROR ListWorkloadsResponse_ComposerWorkloadState = 4
	// Workload has finished execution with success.
	ListWorkloadsResponse_SUCCEEDED ListWorkloadsResponse_ComposerWorkloadState = 5
	// Workload has finished execution with failure.
	ListWorkloadsResponse_FAILED ListWorkloadsResponse_ComposerWorkloadState = 6
)

func (ListWorkloadsResponse_ComposerWorkloadState) Descriptor

func (ListWorkloadsResponse_ComposerWorkloadState) Descriptor() protoreflect.EnumDescriptor

func (ListWorkloadsResponse_ComposerWorkloadState) Enum

func (x ListWorkloadsResponse_ComposerWorkloadState) Enum() *ListWorkloadsResponse_ComposerWorkloadState

func (ListWorkloadsResponse_ComposerWorkloadState) EnumDescriptor

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

Deprecated: Use ListWorkloadsResponse_ComposerWorkloadState.Descriptor instead.

func (ListWorkloadsResponse_ComposerWorkloadState) Number

func (x ListWorkloadsResponse_ComposerWorkloadState) Number() protoreflect.EnumNumber

func (ListWorkloadsResponse_ComposerWorkloadState) String

func (x ListWorkloadsResponse_ComposerWorkloadState) String() string

func (ListWorkloadsResponse_ComposerWorkloadState) Type

func (ListWorkloadsResponse_ComposerWorkloadState) Type() protoreflect.EnumType

ListWorkloadsResponse_ComposerWorkloadStatus

type ListWorkloadsResponse_ComposerWorkloadStatus struct {
	State ListWorkloadsResponse_ComposerWorkloadState "" /* 159 byte string literal not displayed */

	StatusMessage string `protobuf:"bytes,2,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`

	DetailedStatusMessage string `protobuf:"bytes,3,opt,name=detailed_status_message,json=detailedStatusMessage,proto3" json:"detailed_status_message,omitempty"`

}

Workload status.

func (*ListWorkloadsResponse_ComposerWorkloadStatus) Descriptor

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

Deprecated: Use ListWorkloadsResponse_ComposerWorkloadStatus.ProtoReflect.Descriptor instead.

func (*ListWorkloadsResponse_ComposerWorkloadStatus) GetDetailedStatusMessage

func (x *ListWorkloadsResponse_ComposerWorkloadStatus) GetDetailedStatusMessage() string

func (*ListWorkloadsResponse_ComposerWorkloadStatus) GetState

func (x *ListWorkloadsResponse_ComposerWorkloadStatus) GetState() ListWorkloadsResponse_ComposerWorkloadState

func (*ListWorkloadsResponse_ComposerWorkloadStatus) GetStatusMessage

func (x *ListWorkloadsResponse_ComposerWorkloadStatus) GetStatusMessage() string

func (*ListWorkloadsResponse_ComposerWorkloadStatus) ProtoMessage

func (*ListWorkloadsResponse_ComposerWorkloadStatus) ProtoMessage()

func (*ListWorkloadsResponse_ComposerWorkloadStatus) ProtoReflect

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

func (*ListWorkloadsResponse_ComposerWorkloadStatus) Reset

func (x *ListWorkloadsResponse_ComposerWorkloadStatus) Reset()

func (*ListWorkloadsResponse_ComposerWorkloadStatus) String

func (x *ListWorkloadsResponse_ComposerWorkloadStatus) String() string

ListWorkloadsResponse_ComposerWorkloadType

type ListWorkloadsResponse_ComposerWorkloadType int32

Supported workload types.

ListWorkloadsResponse_COMPOSER_WORKLOAD_TYPE_UNSPECIFIED, ListWorkloadsResponse_CELERY_WORKER, ListWorkloadsResponse_KUBERNETES_WORKER, ListWorkloadsResponse_KUBERNETES_OPERATOR_POD, ListWorkloadsResponse_SCHEDULER, ListWorkloadsResponse_DAG_PROCESSOR, ListWorkloadsResponse_TRIGGERER, ListWorkloadsResponse_WEB_SERVER, ListWorkloadsResponse_REDIS

const (
	// Not able to determine the type of the workload.
	ListWorkloadsResponse_COMPOSER_WORKLOAD_TYPE_UNSPECIFIED ListWorkloadsResponse_ComposerWorkloadType = 0
	// Celery worker.
	ListWorkloadsResponse_CELERY_WORKER ListWorkloadsResponse_ComposerWorkloadType = 1
	// Kubernetes worker.
	ListWorkloadsResponse_KUBERNETES_WORKER ListWorkloadsResponse_ComposerWorkloadType = 2
	// Workload created by Kubernetes Pod Operator.
	ListWorkloadsResponse_KUBERNETES_OPERATOR_POD ListWorkloadsResponse_ComposerWorkloadType = 3
	// Airflow scheduler.
	ListWorkloadsResponse_SCHEDULER ListWorkloadsResponse_ComposerWorkloadType = 4
	// Airflow Dag processor.
	ListWorkloadsResponse_DAG_PROCESSOR ListWorkloadsResponse_ComposerWorkloadType = 5
	// Airflow triggerer.
	ListWorkloadsResponse_TRIGGERER ListWorkloadsResponse_ComposerWorkloadType = 6
	// Airflow web server UI.
	ListWorkloadsResponse_WEB_SERVER ListWorkloadsResponse_ComposerWorkloadType = 7
	// Redis.
	ListWorkloadsResponse_REDIS ListWorkloadsResponse_ComposerWorkloadType = 8
)

func (ListWorkloadsResponse_ComposerWorkloadType) Descriptor

func (ListWorkloadsResponse_ComposerWorkloadType) Descriptor() protoreflect.EnumDescriptor

func (ListWorkloadsResponse_ComposerWorkloadType) Enum

func (x ListWorkloadsResponse_ComposerWorkloadType) Enum() *ListWorkloadsResponse_ComposerWorkloadType

func (ListWorkloadsResponse_ComposerWorkloadType) EnumDescriptor

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

Deprecated: Use ListWorkloadsResponse_ComposerWorkloadType.Descriptor instead.

func (ListWorkloadsResponse_ComposerWorkloadType) Number

func (x ListWorkloadsResponse_ComposerWorkloadType) Number() protoreflect.EnumNumber

func (ListWorkloadsResponse_ComposerWorkloadType) String

func (x ListWorkloadsResponse_ComposerWorkloadType) String() string

func (ListWorkloadsResponse_ComposerWorkloadType) Type

func (ListWorkloadsResponse_ComposerWorkloadType) Type() protoreflect.EnumType

LoadSnapshotRequest

type LoadSnapshotRequest struct {
	Environment string `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`

	SnapshotPath string `protobuf:"bytes,2,opt,name=snapshot_path,json=snapshotPath,proto3" json:"snapshot_path,omitempty"`

	SkipPypiPackagesInstallation bool "" /* 150 byte string literal not displayed */

	SkipEnvironmentVariablesSetting bool "" /* 159 byte string literal not displayed */

	SkipAirflowOverridesSetting bool "" /* 147 byte string literal not displayed */

	SkipGcsDataCopying bool `protobuf:"varint,6,opt,name=skip_gcs_data_copying,json=skipGcsDataCopying,proto3" json:"skip_gcs_data_copying,omitempty"`

}

Request to load a snapshot into a Cloud Composer environment.

func (*LoadSnapshotRequest) Descriptor

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

Deprecated: Use LoadSnapshotRequest.ProtoReflect.Descriptor instead.

func (*LoadSnapshotRequest) GetEnvironment

func (x *LoadSnapshotRequest) GetEnvironment() string

func (*LoadSnapshotRequest) GetSkipAirflowOverridesSetting

func (x *LoadSnapshotRequest) GetSkipAirflowOverridesSetting() bool

func (*LoadSnapshotRequest) GetSkipEnvironmentVariablesSetting

func (x *LoadSnapshotRequest) GetSkipEnvironmentVariablesSetting() bool

func (*LoadSnapshotRequest) GetSkipGcsDataCopying

func (x *LoadSnapshotRequest) GetSkipGcsDataCopying() bool

func (*LoadSnapshotRequest) GetSkipPypiPackagesInstallation

func (x *LoadSnapshotRequest) GetSkipPypiPackagesInstallation() bool

func (*LoadSnapshotRequest) GetSnapshotPath

func (x *LoadSnapshotRequest) GetSnapshotPath() string

func (*LoadSnapshotRequest) ProtoMessage

func (*LoadSnapshotRequest) ProtoMessage()

func (*LoadSnapshotRequest) ProtoReflect

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

func (*LoadSnapshotRequest) Reset

func (x *LoadSnapshotRequest) Reset()

func (*LoadSnapshotRequest) String

func (x *LoadSnapshotRequest) String() string

LoadSnapshotResponse

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

Response to LoadSnapshotRequest.

func (*LoadSnapshotResponse) Descriptor

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

Deprecated: Use LoadSnapshotResponse.ProtoReflect.Descriptor instead.

func (*LoadSnapshotResponse) ProtoMessage

func (*LoadSnapshotResponse) ProtoMessage()

func (*LoadSnapshotResponse) ProtoReflect

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

func (*LoadSnapshotResponse) Reset

func (x *LoadSnapshotResponse) Reset()

func (*LoadSnapshotResponse) String

func (x *LoadSnapshotResponse) String() string

MaintenanceWindow

type MaintenanceWindow struct {

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

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

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

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

func (*MaintenanceWindow) Descriptor

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

Deprecated: Use MaintenanceWindow.ProtoReflect.Descriptor instead.

func (*MaintenanceWindow) GetEndTime

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

func (*MaintenanceWindow) GetRecurrence

func (x *MaintenanceWindow) GetRecurrence() string

func (*MaintenanceWindow) GetStartTime

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

func (*MaintenanceWindow) ProtoMessage

func (*MaintenanceWindow) ProtoMessage()

func (*MaintenanceWindow) ProtoReflect

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

func (*MaintenanceWindow) Reset

func (x *MaintenanceWindow) Reset()

func (*MaintenanceWindow) String

func (x *MaintenanceWindow) String() string

MasterAuthorizedNetworksConfig

type MasterAuthorizedNetworksConfig struct {

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

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

func (*MasterAuthorizedNetworksConfig) Descriptor

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

Deprecated: Use MasterAuthorizedNetworksConfig.ProtoReflect.Descriptor instead.

func (*MasterAuthorizedNetworksConfig) GetCidrBlocks

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

func (*MasterAuthorizedNetworksConfig) GetEnabled

func (x *MasterAuthorizedNetworksConfig) GetEnabled() bool

func (*MasterAuthorizedNetworksConfig) ProtoMessage

func (*MasterAuthorizedNetworksConfig) ProtoMessage()

func (*MasterAuthorizedNetworksConfig) ProtoReflect

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

func (*MasterAuthorizedNetworksConfig) Reset

func (x *MasterAuthorizedNetworksConfig) Reset()

func (*MasterAuthorizedNetworksConfig) String

func (x *MasterAuthorizedNetworksConfig) String() string

MasterAuthorizedNetworksConfig_CidrBlock

type MasterAuthorizedNetworksConfig_CidrBlock struct {

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

CIDR block with an optional name.

func (*MasterAuthorizedNetworksConfig_CidrBlock) Descriptor

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

Deprecated: Use MasterAuthorizedNetworksConfig_CidrBlock.ProtoReflect.Descriptor instead.

func (*MasterAuthorizedNetworksConfig_CidrBlock) GetCidrBlock

func (x *MasterAuthorizedNetworksConfig_CidrBlock) GetCidrBlock() string

func (*MasterAuthorizedNetworksConfig_CidrBlock) GetDisplayName

func (x *MasterAuthorizedNetworksConfig_CidrBlock) GetDisplayName() string

func (*MasterAuthorizedNetworksConfig_CidrBlock) ProtoMessage

func (*MasterAuthorizedNetworksConfig_CidrBlock) ProtoMessage()

func (*MasterAuthorizedNetworksConfig_CidrBlock) ProtoReflect

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

func (*MasterAuthorizedNetworksConfig_CidrBlock) Reset

func (x *MasterAuthorizedNetworksConfig_CidrBlock) Reset()

func (*MasterAuthorizedNetworksConfig_CidrBlock) String

func (x *MasterAuthorizedNetworksConfig_CidrBlock) String() string

NetworkingConfig

type NetworkingConfig struct {
	ConnectionType NetworkingConfig_ConnectionType "" /* 187 byte string literal not displayed */

}

Configuration options for networking connections in the Composer 2 environment.

func (*NetworkingConfig) Descriptor

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

Deprecated: Use NetworkingConfig.ProtoReflect.Descriptor instead.

func (*NetworkingConfig) GetConnectionType

func (x *NetworkingConfig) GetConnectionType() NetworkingConfig_ConnectionType

func (*NetworkingConfig) ProtoMessage

func (*NetworkingConfig) ProtoMessage()

func (*NetworkingConfig) ProtoReflect

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

func (*NetworkingConfig) Reset

func (x *NetworkingConfig) Reset()

func (*NetworkingConfig) String

func (x *NetworkingConfig) String() string

NetworkingConfig_ConnectionType

type NetworkingConfig_ConnectionType int32

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

NetworkingConfig_CONNECTION_TYPE_UNSPECIFIED, NetworkingConfig_VPC_PEERING, NetworkingConfig_PRIVATE_SERVICE_CONNECT

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

func (NetworkingConfig_ConnectionType) Descriptor

func (NetworkingConfig_ConnectionType) Descriptor() protoreflect.EnumDescriptor

func (NetworkingConfig_ConnectionType) Enum

func (x NetworkingConfig_ConnectionType) Enum() *NetworkingConfig_ConnectionType

func (NetworkingConfig_ConnectionType) EnumDescriptor

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

Deprecated: Use NetworkingConfig_ConnectionType.Descriptor instead.

func (NetworkingConfig_ConnectionType) Number

func (x NetworkingConfig_ConnectionType) Number() protoreflect.EnumNumber

func (NetworkingConfig_ConnectionType) String

func (x NetworkingConfig_ConnectionType) String() string

func (NetworkingConfig_ConnectionType) Type

func (NetworkingConfig_ConnectionType) Type() protoreflect.EnumType

NodeConfig

type NodeConfig struct {
	Location string `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"`

	MachineType string `protobuf:"bytes,2,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"`

	Network string `protobuf:"bytes,3,opt,name=network,proto3" json:"network,omitempty"`

	Subnetwork string `protobuf:"bytes,4,opt,name=subnetwork,proto3" json:"subnetwork,omitempty"`

	DiskSizeGb int32 `protobuf:"varint,5,opt,name=disk_size_gb,json=diskSizeGb,proto3" json:"disk_size_gb,omitempty"`

	OauthScopes []string `protobuf:"bytes,6,rep,name=oauth_scopes,json=oauthScopes,proto3" json:"oauth_scopes,omitempty"`

	ServiceAccount string `protobuf:"bytes,7,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`

	Tags []string `protobuf:"bytes,8,rep,name=tags,proto3" json:"tags,omitempty"`

	IpAllocationPolicy *IPAllocationPolicy `protobuf:"bytes,9,opt,name=ip_allocation_policy,json=ipAllocationPolicy,proto3" json:"ip_allocation_policy,omitempty"`

	EnableIpMasqAgent bool `protobuf:"varint,11,opt,name=enable_ip_masq_agent,json=enableIpMasqAgent,proto3" json:"enable_ip_masq_agent,omitempty"`

	ComposerNetworkAttachment string "" /* 139 byte string literal not displayed */

	ComposerInternalIpv4CidrBlock string "" /* 155 byte string literal not displayed */

}

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

func (*NodeConfig) Descriptor

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

Deprecated: Use NodeConfig.ProtoReflect.Descriptor instead.

func (*NodeConfig) GetComposerInternalIpv4CidrBlock

func (x *NodeConfig) GetComposerInternalIpv4CidrBlock() string

func (*NodeConfig) GetComposerNetworkAttachment

func (x *NodeConfig) GetComposerNetworkAttachment() string

func (*NodeConfig) GetDiskSizeGb

func (x *NodeConfig) GetDiskSizeGb() int32

func (*NodeConfig) GetEnableIpMasqAgent

func (x *NodeConfig) GetEnableIpMasqAgent() bool

func (*NodeConfig) GetIpAllocationPolicy

func (x *NodeConfig) GetIpAllocationPolicy() *IPAllocationPolicy

func (*NodeConfig) GetLocation

func (x *NodeConfig) GetLocation() string

func (*NodeConfig) GetMachineType

func (x *NodeConfig) GetMachineType() string

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

OperationMetadata

type OperationMetadata struct {
	State OperationMetadata_State "" /* 139 byte string literal not displayed */

	OperationType OperationMetadata_Type "" /* 175 byte string literal not displayed */

	Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`

	ResourceUuid string `protobuf:"bytes,4,opt,name=resource_uuid,json=resourceUuid,proto3" json:"resource_uuid,omitempty"`

	CreateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	EndTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`

}

Metadata describing an operation.

func (*OperationMetadata) Descriptor

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

OperationMetadata_State

type OperationMetadata_State int32

An enum describing the overall state of an operation.

OperationMetadata_STATE_UNSPECIFIED, OperationMetadata_PENDING, OperationMetadata_RUNNING, OperationMetadata_SUCCEEDED, OperationMetadata_SUCCESSFUL, OperationMetadata_FAILED

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

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

OperationMetadata_Type

type OperationMetadata_Type int32

Type of longrunning operation.

OperationMetadata_TYPE_UNSPECIFIED, OperationMetadata_CREATE, OperationMetadata_DELETE, OperationMetadata_UPDATE, OperationMetadata_CHECK, OperationMetadata_SAVE_SNAPSHOT, OperationMetadata_LOAD_SNAPSHOT, OperationMetadata_DATABASE_FAILOVER

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

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

PollAirflowCommandRequest

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

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

Deprecated: Use PollAirflowCommandRequest.ProtoReflect.Descriptor instead.

func (*PollAirflowCommandRequest) GetEnvironment

func (x *PollAirflowCommandRequest) GetEnvironment() string

func (*PollAirflowCommandRequest) GetExecutionId

func (x *PollAirflowCommandRequest) GetExecutionId() string

func (*PollAirflowCommandRequest) GetNextLineNumber

func (x *PollAirflowCommandRequest) GetNextLineNumber() int32

func (*PollAirflowCommandRequest) GetPod

func (x *PollAirflowCommandRequest) GetPod() string

func (*PollAirflowCommandRequest) GetPodNamespace

func (x *PollAirflowCommandRequest) GetPodNamespace() string

func (*PollAirflowCommandRequest) ProtoMessage

func (*PollAirflowCommandRequest) ProtoMessage()

func (*PollAirflowCommandRequest) ProtoReflect

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

func (*PollAirflowCommandRequest) Reset

func (x *PollAirflowCommandRequest) Reset()

func (*PollAirflowCommandRequest) String

func (x *PollAirflowCommandRequest) String() string

PollAirflowCommandResponse

type PollAirflowCommandResponse struct {

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

Response to PollAirflowCommandRequest.

func (*PollAirflowCommandResponse) Descriptor

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

Deprecated: Use PollAirflowCommandResponse.ProtoReflect.Descriptor instead.

func (*PollAirflowCommandResponse) GetExitInfo

func (x *PollAirflowCommandResponse) GetExitInfo() *PollAirflowCommandResponse_ExitInfo

func (*PollAirflowCommandResponse) GetOutput

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

func (*PollAirflowCommandResponse) GetOutputEnd

func (x *PollAirflowCommandResponse) GetOutputEnd() bool

func (*PollAirflowCommandResponse) ProtoMessage

func (*PollAirflowCommandResponse) ProtoMessage()

func (*PollAirflowCommandResponse) ProtoReflect

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

func (*PollAirflowCommandResponse) Reset

func (x *PollAirflowCommandResponse) Reset()

func (*PollAirflowCommandResponse) String

func (x *PollAirflowCommandResponse) String() string

PollAirflowCommandResponse_ExitInfo

type PollAirflowCommandResponse_ExitInfo struct {

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

Information about how a command ended.

func (*PollAirflowCommandResponse_ExitInfo) Descriptor

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

Deprecated: Use PollAirflowCommandResponse_ExitInfo.ProtoReflect.Descriptor instead.

func (*PollAirflowCommandResponse_ExitInfo) GetError

func (x *PollAirflowCommandResponse_ExitInfo) GetError() string

func (*PollAirflowCommandResponse_ExitInfo) GetExitCode

func (x *PollAirflowCommandResponse_ExitInfo) GetExitCode() int32

func (*PollAirflowCommandResponse_ExitInfo) ProtoMessage

func (*PollAirflowCommandResponse_ExitInfo) ProtoMessage()

func (*PollAirflowCommandResponse_ExitInfo) ProtoReflect

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

func (*PollAirflowCommandResponse_ExitInfo) Reset

func (x *PollAirflowCommandResponse_ExitInfo) Reset()

func (*PollAirflowCommandResponse_ExitInfo) String

func (x *PollAirflowCommandResponse_ExitInfo) String() string

PollAirflowCommandResponse_Line

type PollAirflowCommandResponse_Line struct {

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

Contains information about a single line from logs.

func (*PollAirflowCommandResponse_Line) Descriptor

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

Deprecated: Use PollAirflowCommandResponse_Line.ProtoReflect.Descriptor instead.

func (*PollAirflowCommandResponse_Line) GetContent

func (x *PollAirflowCommandResponse_Line) GetContent() string

func (*PollAirflowCommandResponse_Line) GetLineNumber

func (x *PollAirflowCommandResponse_Line) GetLineNumber() int32

func (*PollAirflowCommandResponse_Line) ProtoMessage

func (*PollAirflowCommandResponse_Line) ProtoMessage()

func (*PollAirflowCommandResponse_Line) ProtoReflect

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

func (*PollAirflowCommandResponse_Line) Reset

func (x *PollAirflowCommandResponse_Line) Reset()

func (*PollAirflowCommandResponse_Line) String

func (x *PollAirflowCommandResponse_Line) String() string

PrivateClusterConfig

type PrivateClusterConfig struct {
	EnablePrivateEndpoint bool "" /* 127 byte string literal not displayed */

	MasterIpv4CidrBlock string `protobuf:"bytes,2,opt,name=master_ipv4_cidr_block,json=masterIpv4CidrBlock,proto3" json:"master_ipv4_cidr_block,omitempty"`

	MasterIpv4ReservedRange string "" /* 134 byte string literal not displayed */

}

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

func (*PrivateClusterConfig) Descriptor

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

PrivateEnvironmentConfig

type PrivateEnvironmentConfig struct {
	EnablePrivateEnvironment bool "" /* 136 byte string literal not displayed */

	EnablePrivateBuildsOnly bool "" /* 136 byte string literal not displayed */

	PrivateClusterConfig *PrivateClusterConfig `protobuf:"bytes,2,opt,name=private_cluster_config,json=privateClusterConfig,proto3" json:"private_cluster_config,omitempty"`

	WebServerIpv4CidrBlock string "" /* 133 byte string literal not displayed */

	CloudSqlIpv4CidrBlock string "" /* 130 byte string literal not displayed */

	WebServerIpv4ReservedRange string "" /* 145 byte string literal not displayed */

	CloudComposerNetworkIpv4CidrBlock string "" /* 168 byte string literal not displayed */

	CloudComposerNetworkIpv4ReservedRange string "" /* 180 byte string literal not displayed */

	EnablePrivatelyUsedPublicIps bool "" /* 152 byte string literal not displayed */

	CloudComposerConnectionSubnetwork string "" /* 164 byte string literal not displayed */

	NetworkingConfig *NetworkingConfig `protobuf:"bytes,10,opt,name=networking_config,json=networkingConfig,proto3" json:"networking_config,omitempty"`

}

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

func (*PrivateEnvironmentConfig) Descriptor

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

Deprecated: Use PrivateEnvironmentConfig.ProtoReflect.Descriptor instead.

func (*PrivateEnvironmentConfig) GetCloudComposerConnectionSubnetwork

func (x *PrivateEnvironmentConfig) GetCloudComposerConnectionSubnetwork() string

func (*PrivateEnvironmentConfig) GetCloudComposerNetworkIpv4CidrBlock

func (x *PrivateEnvironmentConfig) GetCloudComposerNetworkIpv4CidrBlock() string

func (*PrivateEnvironmentConfig) GetCloudComposerNetworkIpv4ReservedRange

func (x *PrivateEnvironmentConfig) GetCloudComposerNetworkIpv4ReservedRange() string

func (*PrivateEnvironmentConfig) GetCloudSqlIpv4CidrBlock

func (x *PrivateEnvironmentConfig) GetCloudSqlIpv4CidrBlock() string

func (*PrivateEnvironmentConfig) GetEnablePrivateBuildsOnly

func (x *PrivateEnvironmentConfig) GetEnablePrivateBuildsOnly() bool

func (*PrivateEnvironmentConfig) GetEnablePrivateEnvironment

func (x *PrivateEnvironmentConfig) GetEnablePrivateEnvironment() bool

func (*PrivateEnvironmentConfig) GetEnablePrivatelyUsedPublicIps

func (x *PrivateEnvironmentConfig) GetEnablePrivatelyUsedPublicIps() bool

func (*PrivateEnvironmentConfig) GetNetworkingConfig

func (x *PrivateEnvironmentConfig) GetNetworkingConfig() *NetworkingConfig

func (*PrivateEnvironmentConfig) GetPrivateClusterConfig

func (x *PrivateEnvironmentConfig) GetPrivateClusterConfig() *PrivateClusterConfig

func (*PrivateEnvironmentConfig) GetWebServerIpv4CidrBlock

func (x *PrivateEnvironmentConfig) GetWebServerIpv4CidrBlock() string

func (*PrivateEnvironmentConfig) GetWebServerIpv4ReservedRange

func (x *PrivateEnvironmentConfig) GetWebServerIpv4ReservedRange() string

func (*PrivateEnvironmentConfig) ProtoMessage

func (*PrivateEnvironmentConfig) ProtoMessage()

func (*PrivateEnvironmentConfig) ProtoReflect

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

func (*PrivateEnvironmentConfig) Reset

func (x *PrivateEnvironmentConfig) Reset()

func (*PrivateEnvironmentConfig) String

func (x *PrivateEnvironmentConfig) String() string

RecoveryConfig

type RecoveryConfig struct {
	ScheduledSnapshotsConfig *ScheduledSnapshotsConfig "" /* 135 byte string literal not displayed */

}

The Recovery settings of an environment.

func (*RecoveryConfig) Descriptor

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

Deprecated: Use RecoveryConfig.ProtoReflect.Descriptor instead.

func (*RecoveryConfig) GetScheduledSnapshotsConfig

func (x *RecoveryConfig) GetScheduledSnapshotsConfig() *ScheduledSnapshotsConfig

func (*RecoveryConfig) ProtoMessage

func (*RecoveryConfig) ProtoMessage()

func (*RecoveryConfig) ProtoReflect

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

func (*RecoveryConfig) Reset

func (x *RecoveryConfig) Reset()

func (*RecoveryConfig) String

func (x *RecoveryConfig) String() string

SaveSnapshotRequest

type SaveSnapshotRequest struct {

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

Request to create a snapshot of a Cloud Composer environment.

func (*SaveSnapshotRequest) Descriptor

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

Deprecated: Use SaveSnapshotRequest.ProtoReflect.Descriptor instead.

func (*SaveSnapshotRequest) GetEnvironment

func (x *SaveSnapshotRequest) GetEnvironment() string

func (*SaveSnapshotRequest) GetSnapshotLocation

func (x *SaveSnapshotRequest) GetSnapshotLocation() string

func (*SaveSnapshotRequest) ProtoMessage

func (*SaveSnapshotRequest) ProtoMessage()

func (*SaveSnapshotRequest) ProtoReflect

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

func (*SaveSnapshotRequest) Reset

func (x *SaveSnapshotRequest) Reset()

func (*SaveSnapshotRequest) String

func (x *SaveSnapshotRequest) String() string

SaveSnapshotResponse

type SaveSnapshotResponse struct {

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

Response to SaveSnapshotRequest.

func (*SaveSnapshotResponse) Descriptor

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

Deprecated: Use SaveSnapshotResponse.ProtoReflect.Descriptor instead.

func (*SaveSnapshotResponse) GetSnapshotPath

func (x *SaveSnapshotResponse) GetSnapshotPath() string

func (*SaveSnapshotResponse) ProtoMessage

func (*SaveSnapshotResponse) ProtoMessage()

func (*SaveSnapshotResponse) ProtoReflect

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

func (*SaveSnapshotResponse) Reset

func (x *SaveSnapshotResponse) Reset()

func (*SaveSnapshotResponse) String

func (x *SaveSnapshotResponse) String() string

ScheduledSnapshotsConfig

type ScheduledSnapshotsConfig struct {
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`

	SnapshotLocation string `protobuf:"bytes,6,opt,name=snapshot_location,json=snapshotLocation,proto3" json:"snapshot_location,omitempty"`

	SnapshotCreationSchedule string "" /* 135 byte string literal not displayed */

	TimeZone string `protobuf:"bytes,5,opt,name=time_zone,json=timeZone,proto3" json:"time_zone,omitempty"`

}

The configuration for scheduled snapshot creation mechanism.

func (*ScheduledSnapshotsConfig) Descriptor

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

Deprecated: Use ScheduledSnapshotsConfig.ProtoReflect.Descriptor instead.

func (*ScheduledSnapshotsConfig) GetEnabled

func (x *ScheduledSnapshotsConfig) GetEnabled() bool

func (*ScheduledSnapshotsConfig) GetSnapshotCreationSchedule

func (x *ScheduledSnapshotsConfig) GetSnapshotCreationSchedule() string

func (*ScheduledSnapshotsConfig) GetSnapshotLocation

func (x *ScheduledSnapshotsConfig) GetSnapshotLocation() string

func (*ScheduledSnapshotsConfig) GetTimeZone

func (x *ScheduledSnapshotsConfig) GetTimeZone() string

func (*ScheduledSnapshotsConfig) ProtoMessage

func (*ScheduledSnapshotsConfig) ProtoMessage()

func (*ScheduledSnapshotsConfig) ProtoReflect

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

func (*ScheduledSnapshotsConfig) Reset

func (x *ScheduledSnapshotsConfig) Reset()

func (*ScheduledSnapshotsConfig) String

func (x *ScheduledSnapshotsConfig) String() string

SoftwareConfig

type SoftwareConfig struct {
	ImageVersion string `protobuf:"bytes,1,opt,name=image_version,json=imageVersion,proto3" json:"image_version,omitempty"`

	AirflowConfigOverrides map[string]string "" /* 217 byte string literal not displayed */

	PypiPackages map[string]string "" /* 185 byte string literal not displayed */

	EnvVariables map[string]string "" /* 185 byte string literal not displayed */

	PythonVersion string `protobuf:"bytes,6,opt,name=python_version,json=pythonVersion,proto3" json:"python_version,omitempty"`

	SchedulerCount int32 `protobuf:"varint,7,opt,name=scheduler_count,json=schedulerCount,proto3" json:"scheduler_count,omitempty"`

	CloudDataLineageIntegration *CloudDataLineageIntegration "" /* 146 byte string literal not displayed */

	WebServerPluginsMode SoftwareConfig_WebServerPluginsMode "" /* 214 byte string literal not displayed */

}

Specifies the selection and configuration of software inside the environment.

func (*SoftwareConfig) Descriptor

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

Deprecated: Use SoftwareConfig.ProtoReflect.Descriptor instead.

func (*SoftwareConfig) GetAirflowConfigOverrides

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

func (*SoftwareConfig) GetCloudDataLineageIntegration

func (x *SoftwareConfig) GetCloudDataLineageIntegration() *CloudDataLineageIntegration

func (*SoftwareConfig) GetEnvVariables

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

func (*SoftwareConfig) GetImageVersion

func (x *SoftwareConfig) GetImageVersion() string

func (*SoftwareConfig) GetPypiPackages

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

func (*SoftwareConfig) GetPythonVersion

func (x *SoftwareConfig) GetPythonVersion() string

func (*SoftwareConfig) GetSchedulerCount

func (x *SoftwareConfig) GetSchedulerCount() int32

func (*SoftwareConfig) GetWebServerPluginsMode

func (x *SoftwareConfig) GetWebServerPluginsMode() SoftwareConfig_WebServerPluginsMode

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

SoftwareConfig_WebServerPluginsMode

type SoftwareConfig_WebServerPluginsMode int32

Web server plugins mode of the Cloud Composer environment.

SoftwareConfig_WEB_SERVER_PLUGINS_MODE_UNSPECIFIED, SoftwareConfig_PLUGINS_DISABLED, SoftwareConfig_PLUGINS_ENABLED

const (
	// Default mode.
	SoftwareConfig_WEB_SERVER_PLUGINS_MODE_UNSPECIFIED SoftwareConfig_WebServerPluginsMode = 0
	// Web server plugins are not supported.
	SoftwareConfig_PLUGINS_DISABLED SoftwareConfig_WebServerPluginsMode = 1
	// Web server plugins are supported.
	SoftwareConfig_PLUGINS_ENABLED SoftwareConfig_WebServerPluginsMode = 2
)

func (SoftwareConfig_WebServerPluginsMode) Descriptor

func (SoftwareConfig_WebServerPluginsMode) Descriptor() protoreflect.EnumDescriptor

func (SoftwareConfig_WebServerPluginsMode) Enum

func (x SoftwareConfig_WebServerPluginsMode) Enum() *SoftwareConfig_WebServerPluginsMode

func (SoftwareConfig_WebServerPluginsMode) EnumDescriptor

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

Deprecated: Use SoftwareConfig_WebServerPluginsMode.Descriptor instead.

func (SoftwareConfig_WebServerPluginsMode) Number

func (x SoftwareConfig_WebServerPluginsMode) Number() protoreflect.EnumNumber

func (SoftwareConfig_WebServerPluginsMode) String

func (x SoftwareConfig_WebServerPluginsMode) String() string

func (SoftwareConfig_WebServerPluginsMode) Type

func (SoftwareConfig_WebServerPluginsMode) Type() protoreflect.EnumType

StopAirflowCommandRequest

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

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

Deprecated: Use StopAirflowCommandRequest.ProtoReflect.Descriptor instead.

func (*StopAirflowCommandRequest) GetEnvironment

func (x *StopAirflowCommandRequest) GetEnvironment() string

func (*StopAirflowCommandRequest) GetExecutionId

func (x *StopAirflowCommandRequest) GetExecutionId() string

func (*StopAirflowCommandRequest) GetForce

func (x *StopAirflowCommandRequest) GetForce() bool

func (*StopAirflowCommandRequest) GetPod

func (x *StopAirflowCommandRequest) GetPod() string

func (*StopAirflowCommandRequest) GetPodNamespace

func (x *StopAirflowCommandRequest) GetPodNamespace() string

func (*StopAirflowCommandRequest) ProtoMessage

func (*StopAirflowCommandRequest) ProtoMessage()

func (*StopAirflowCommandRequest) ProtoReflect

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

func (*StopAirflowCommandRequest) Reset

func (x *StopAirflowCommandRequest) Reset()

func (*StopAirflowCommandRequest) String

func (x *StopAirflowCommandRequest) String() string

StopAirflowCommandResponse

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

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

Deprecated: Use StopAirflowCommandResponse.ProtoReflect.Descriptor instead.

func (*StopAirflowCommandResponse) GetIsDone

func (x *StopAirflowCommandResponse) GetIsDone() bool

func (*StopAirflowCommandResponse) GetOutput

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

func (*StopAirflowCommandResponse) ProtoMessage

func (*StopAirflowCommandResponse) ProtoMessage()

func (*StopAirflowCommandResponse) ProtoReflect

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

func (*StopAirflowCommandResponse) Reset

func (x *StopAirflowCommandResponse) Reset()

func (*StopAirflowCommandResponse) String

func (x *StopAirflowCommandResponse) String() string

StorageConfig

type StorageConfig struct {

	// Optional. The name of the Cloud Storage bucket used by the environment. No
	// `gs://` prefix.
	Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// contains filtered or unexported fields
}

The configuration for data storage in the environment.

func (*StorageConfig) Descriptor

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

Deprecated: Use StorageConfig.ProtoReflect.Descriptor instead.

func (*StorageConfig) GetBucket

func (x *StorageConfig) GetBucket() string

func (*StorageConfig) ProtoMessage

func (*StorageConfig) ProtoMessage()

func (*StorageConfig) ProtoReflect

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

func (*StorageConfig) Reset

func (x *StorageConfig) Reset()

func (*StorageConfig) String

func (x *StorageConfig) String() string

TaskLogsRetentionConfig

type TaskLogsRetentionConfig struct {
	StorageMode TaskLogsRetentionConfig_TaskLogsStorageMode "" /* 190 byte string literal not displayed */

}

The configuration setting for Task Logs.

func (*TaskLogsRetentionConfig) Descriptor

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

Deprecated: Use TaskLogsRetentionConfig.ProtoReflect.Descriptor instead.

func (*TaskLogsRetentionConfig) GetStorageMode

func (x *TaskLogsRetentionConfig) GetStorageMode() TaskLogsRetentionConfig_TaskLogsStorageMode

func (*TaskLogsRetentionConfig) ProtoMessage

func (*TaskLogsRetentionConfig) ProtoMessage()

func (*TaskLogsRetentionConfig) ProtoReflect

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

func (*TaskLogsRetentionConfig) Reset

func (x *TaskLogsRetentionConfig) Reset()

func (*TaskLogsRetentionConfig) String

func (x *TaskLogsRetentionConfig) String() string

TaskLogsRetentionConfig_TaskLogsStorageMode

type TaskLogsRetentionConfig_TaskLogsStorageMode int32

The definition of task_logs_storage_mode.

TaskLogsRetentionConfig_TASK_LOGS_STORAGE_MODE_UNSPECIFIED, TaskLogsRetentionConfig_CLOUD_LOGGING_AND_CLOUD_STORAGE, TaskLogsRetentionConfig_CLOUD_LOGGING_ONLY

const (
	// This configuration is not specified by the user.
	TaskLogsRetentionConfig_TASK_LOGS_STORAGE_MODE_UNSPECIFIED TaskLogsRetentionConfig_TaskLogsStorageMode = 0
	// Store task logs in Cloud Logging and in the environment's Cloud Storage
	// bucket.
	TaskLogsRetentionConfig_CLOUD_LOGGING_AND_CLOUD_STORAGE TaskLogsRetentionConfig_TaskLogsStorageMode = 1
	// Store task logs in Cloud Logging only.
	TaskLogsRetentionConfig_CLOUD_LOGGING_ONLY TaskLogsRetentionConfig_TaskLogsStorageMode = 2
)

func (TaskLogsRetentionConfig_TaskLogsStorageMode) Descriptor

func (TaskLogsRetentionConfig_TaskLogsStorageMode) Descriptor() protoreflect.EnumDescriptor

func (TaskLogsRetentionConfig_TaskLogsStorageMode) Enum

func (x TaskLogsRetentionConfig_TaskLogsStorageMode) Enum() *TaskLogsRetentionConfig_TaskLogsStorageMode

func (TaskLogsRetentionConfig_TaskLogsStorageMode) EnumDescriptor

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

Deprecated: Use TaskLogsRetentionConfig_TaskLogsStorageMode.Descriptor instead.

func (TaskLogsRetentionConfig_TaskLogsStorageMode) Number

func (x TaskLogsRetentionConfig_TaskLogsStorageMode) Number() protoreflect.EnumNumber

func (TaskLogsRetentionConfig_TaskLogsStorageMode) String

func (x TaskLogsRetentionConfig_TaskLogsStorageMode) String() string

func (TaskLogsRetentionConfig_TaskLogsStorageMode) Type

func (TaskLogsRetentionConfig_TaskLogsStorageMode) Type() protoreflect.EnumType

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

func (*UnimplementedEnvironmentsServer) CreateUserWorkloadsConfigMap(context.Context, *CreateUserWorkloadsConfigMapRequest) (*UserWorkloadsConfigMap, error)

func (*UnimplementedEnvironmentsServer) CreateUserWorkloadsSecret

func (*UnimplementedEnvironmentsServer) CreateUserWorkloadsSecret(context.Context, *CreateUserWorkloadsSecretRequest) (*UserWorkloadsSecret, error)

func (*UnimplementedEnvironmentsServer) DatabaseFailover

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

func (*UnimplementedEnvironmentsServer) DeleteEnvironment

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

func (*UnimplementedEnvironmentsServer) DeleteUserWorkloadsConfigMap

func (*UnimplementedEnvironmentsServer) DeleteUserWorkloadsConfigMap(context.Context, *DeleteUserWorkloadsConfigMapRequest) (*emptypb.Empty, error)

func (*UnimplementedEnvironmentsServer) DeleteUserWorkloadsSecret

func (*UnimplementedEnvironmentsServer) DeleteUserWorkloadsSecret(context.Context, *DeleteUserWorkloadsSecretRequest) (*emptypb.Empty, error)

func (*UnimplementedEnvironmentsServer) ExecuteAirflowCommand

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

func (*UnimplementedEnvironmentsServer) FetchDatabaseProperties

func (*UnimplementedEnvironmentsServer) FetchDatabaseProperties(context.Context, *FetchDatabasePropertiesRequest) (*FetchDatabasePropertiesResponse, error)

func (*UnimplementedEnvironmentsServer) GetEnvironment

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

func (*UnimplementedEnvironmentsServer) GetUserWorkloadsConfigMap

func (*UnimplementedEnvironmentsServer) GetUserWorkloadsConfigMap(context.Context, *GetUserWorkloadsConfigMapRequest) (*UserWorkloadsConfigMap, error)

func (*UnimplementedEnvironmentsServer) GetUserWorkloadsSecret

func (*UnimplementedEnvironmentsServer) GetUserWorkloadsSecret(context.Context, *GetUserWorkloadsSecretRequest) (*UserWorkloadsSecret, error)

func (*UnimplementedEnvironmentsServer) ListEnvironments

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

func (*UnimplementedEnvironmentsServer) ListUserWorkloadsConfigMaps

func (*UnimplementedEnvironmentsServer) ListUserWorkloadsConfigMaps(context.Context, *ListUserWorkloadsConfigMapsRequest) (*ListUserWorkloadsConfigMapsResponse, error)

func (*UnimplementedEnvironmentsServer) ListUserWorkloadsSecrets

func (*UnimplementedEnvironmentsServer) ListUserWorkloadsSecrets(context.Context, *ListUserWorkloadsSecretsRequest) (*ListUserWorkloadsSecretsResponse, error)

func (*UnimplementedEnvironmentsServer) ListWorkloads

func (*UnimplementedEnvironmentsServer) ListWorkloads(context.Context, *ListWorkloadsRequest) (*ListWorkloadsResponse, error)

func (*UnimplementedEnvironmentsServer) LoadSnapshot

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

func (*UnimplementedEnvironmentsServer) PollAirflowCommand

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

func (*UnimplementedEnvironmentsServer) SaveSnapshot

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

func (*UnimplementedEnvironmentsServer) StopAirflowCommand

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

func (*UnimplementedEnvironmentsServer) UpdateEnvironment

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

func (*UnimplementedEnvironmentsServer) UpdateUserWorkloadsConfigMap

func (*UnimplementedEnvironmentsServer) UpdateUserWorkloadsConfigMap(context.Context, *UpdateUserWorkloadsConfigMapRequest) (*UserWorkloadsConfigMap, error)

func (*UnimplementedEnvironmentsServer) UpdateUserWorkloadsSecret

func (*UnimplementedEnvironmentsServer) UpdateUserWorkloadsSecret(context.Context, *UpdateUserWorkloadsSecretRequest) (*UserWorkloadsSecret, error)

UnimplementedImageVersionsServer

type UnimplementedImageVersionsServer struct {
}

UnimplementedImageVersionsServer can be embedded to have forward compatible implementations.

func (*UnimplementedImageVersionsServer) ListImageVersions

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

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

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

UpdateUserWorkloadsConfigMapRequest

type UpdateUserWorkloadsConfigMapRequest struct {
	UserWorkloadsConfigMap *UserWorkloadsConfigMap "" /* 131 byte string literal not displayed */

}

Update user workloads ConfigMap request.

func (*UpdateUserWorkloadsConfigMapRequest) Descriptor

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

Deprecated: Use UpdateUserWorkloadsConfigMapRequest.ProtoReflect.Descriptor instead.

func (*UpdateUserWorkloadsConfigMapRequest) GetUserWorkloadsConfigMap

func (x *UpdateUserWorkloadsConfigMapRequest) GetUserWorkloadsConfigMap() *UserWorkloadsConfigMap

func (*UpdateUserWorkloadsConfigMapRequest) ProtoMessage

func (*UpdateUserWorkloadsConfigMapRequest) ProtoMessage()

func (*UpdateUserWorkloadsConfigMapRequest) ProtoReflect

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

func (*UpdateUserWorkloadsConfigMapRequest) Reset

func (x *UpdateUserWorkloadsConfigMapRequest) Reset()

func (*UpdateUserWorkloadsConfigMapRequest) String

func (x *UpdateUserWorkloadsConfigMapRequest) String() string

UpdateUserWorkloadsSecretRequest

type UpdateUserWorkloadsSecretRequest struct {

	// Optional. User workloads Secret to override.
	UserWorkloadsSecret *UserWorkloadsSecret `protobuf:"bytes,1,opt,name=user_workloads_secret,json=userWorkloadsSecret,proto3" json:"user_workloads_secret,omitempty"`
	// contains filtered or unexported fields
}

Update user workloads Secret request.

func (*UpdateUserWorkloadsSecretRequest) Descriptor

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

Deprecated: Use UpdateUserWorkloadsSecretRequest.ProtoReflect.Descriptor instead.

func (*UpdateUserWorkloadsSecretRequest) GetUserWorkloadsSecret

func (x *UpdateUserWorkloadsSecretRequest) GetUserWorkloadsSecret() *UserWorkloadsSecret

func (*UpdateUserWorkloadsSecretRequest) ProtoMessage

func (*UpdateUserWorkloadsSecretRequest) ProtoMessage()

func (*UpdateUserWorkloadsSecretRequest) ProtoReflect

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

func (*UpdateUserWorkloadsSecretRequest) Reset

func (x *UpdateUserWorkloadsSecretRequest) Reset()

func (*UpdateUserWorkloadsSecretRequest) String

func (x *UpdateUserWorkloadsSecretRequest) String() string

UserWorkloadsConfigMap

type UserWorkloadsConfigMap struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	Data map[string]string "" /* 149 byte string literal not displayed */

}

User workloads ConfigMap used by Airflow tasks that run with Kubernetes executor or KubernetesPodOperator.

func (*UserWorkloadsConfigMap) Descriptor

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

Deprecated: Use UserWorkloadsConfigMap.ProtoReflect.Descriptor instead.

func (*UserWorkloadsConfigMap) GetData

func (x *UserWorkloadsConfigMap) GetData() map[string]string

func (*UserWorkloadsConfigMap) GetName

func (x *UserWorkloadsConfigMap) GetName() string

func (*UserWorkloadsConfigMap) ProtoMessage

func (*UserWorkloadsConfigMap) ProtoMessage()

func (*UserWorkloadsConfigMap) ProtoReflect

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

func (*UserWorkloadsConfigMap) Reset

func (x *UserWorkloadsConfigMap) Reset()

func (*UserWorkloadsConfigMap) String

func (x *UserWorkloadsConfigMap) String() string

UserWorkloadsSecret

type UserWorkloadsSecret struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	Data map[string]string "" /* 149 byte string literal not displayed */

}

User workloads Secret used by Airflow tasks that run with Kubernetes executor or KubernetesPodOperator.

func (*UserWorkloadsSecret) Descriptor

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

Deprecated: Use UserWorkloadsSecret.ProtoReflect.Descriptor instead.

func (*UserWorkloadsSecret) GetData

func (x *UserWorkloadsSecret) GetData() map[string]string

func (*UserWorkloadsSecret) GetName

func (x *UserWorkloadsSecret) GetName() string

func (*UserWorkloadsSecret) ProtoMessage

func (*UserWorkloadsSecret) ProtoMessage()

func (*UserWorkloadsSecret) ProtoReflect

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

func (*UserWorkloadsSecret) Reset

func (x *UserWorkloadsSecret) Reset()

func (*UserWorkloadsSecret) String

func (x *UserWorkloadsSecret) String() string

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

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

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

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

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

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

WorkloadsConfig

type WorkloadsConfig struct {

	// Optional. Resources used by Airflow schedulers.
	Scheduler *WorkloadsConfig_SchedulerResource `protobuf:"bytes,1,opt,name=scheduler,proto3" json:"scheduler,omitempty"`
	// Optional. Resources used by Airflow web server.
	WebServer *WorkloadsConfig_WebServerResource `protobuf:"bytes,2,opt,name=web_server,json=webServer,proto3" json:"web_server,omitempty"`
	// Optional. Resources used by Airflow workers.
	Worker *WorkloadsConfig_WorkerResource `protobuf:"bytes,3,opt,name=worker,proto3" json:"worker,omitempty"`
	// Optional. Resources used by Airflow triggerers.
	Triggerer *WorkloadsConfig_TriggererResource `protobuf:"bytes,4,opt,name=triggerer,proto3" json:"triggerer,omitempty"`
	// Optional. Resources used by Airflow DAG processors.
	//
	// This field is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	DagProcessor *WorkloadsConfig_DagProcessorResource `protobuf:"bytes,5,opt,name=dag_processor,json=dagProcessor,proto3" json:"dag_processor,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

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

Deprecated: Use WorkloadsConfig.ProtoReflect.Descriptor instead.

func (*WorkloadsConfig) GetDagProcessor

func (x *WorkloadsConfig) GetDagProcessor() *WorkloadsConfig_DagProcessorResource

func (*WorkloadsConfig) GetScheduler

func (x *WorkloadsConfig) GetScheduler() *WorkloadsConfig_SchedulerResource

func (*WorkloadsConfig) GetTriggerer

func (x *WorkloadsConfig) GetTriggerer() *WorkloadsConfig_TriggererResource

func (*WorkloadsConfig) GetWebServer

func (x *WorkloadsConfig) GetWebServer() *WorkloadsConfig_WebServerResource

func (*WorkloadsConfig) GetWorker

func (x *WorkloadsConfig) GetWorker() *WorkloadsConfig_WorkerResource

func (*WorkloadsConfig) ProtoMessage

func (*WorkloadsConfig) ProtoMessage()

func (*WorkloadsConfig) ProtoReflect

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

func (*WorkloadsConfig) Reset

func (x *WorkloadsConfig) Reset()

func (*WorkloadsConfig) String

func (x *WorkloadsConfig) String() string

WorkloadsConfig_DagProcessorResource

type WorkloadsConfig_DagProcessorResource struct {

	// Optional. CPU request and limit for a single Airflow DAG processor
	// replica.
	Cpu float32 `protobuf:"fixed32,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
	// Optional. Memory (GB) request and limit for a single Airflow DAG
	// processor 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 DAG
	// processor replica.
	StorageGb float32 `protobuf:"fixed32,3,opt,name=storage_gb,json=storageGb,proto3" json:"storage_gb,omitempty"`
	// Optional. The number of DAG processors. If not provided or set to 0, a
	// single DAG processor instance will be created.
	Count int32 `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

Configuration for resources used by Airflow DAG processors.

func (*WorkloadsConfig_DagProcessorResource) Descriptor

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

Deprecated: Use WorkloadsConfig_DagProcessorResource.ProtoReflect.Descriptor instead.

func (*WorkloadsConfig_DagProcessorResource) GetCount

func (x *WorkloadsConfig_DagProcessorResource) GetCount() int32

func (*WorkloadsConfig_DagProcessorResource) GetCpu

func (x *WorkloadsConfig_DagProcessorResource) GetCpu() float32

func (*WorkloadsConfig_DagProcessorResource) GetMemoryGb

func (x *WorkloadsConfig_DagProcessorResource) GetMemoryGb() float32

func (*WorkloadsConfig_DagProcessorResource) GetStorageGb

func (x *WorkloadsConfig_DagProcessorResource) GetStorageGb() float32

func (*WorkloadsConfig_DagProcessorResource) ProtoMessage

func (*WorkloadsConfig_DagProcessorResource) ProtoMessage()

func (*WorkloadsConfig_DagProcessorResource) ProtoReflect

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

func (*WorkloadsConfig_DagProcessorResource) Reset

func (x *WorkloadsConfig_DagProcessorResource) Reset()

func (*WorkloadsConfig_DagProcessorResource) String

func (x *WorkloadsConfig_DagProcessorResource) String() string

WorkloadsConfig_SchedulerResource

type WorkloadsConfig_SchedulerResource struct {

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

Configuration for resources used by Airflow schedulers.

func (*WorkloadsConfig_SchedulerResource) Descriptor

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

Deprecated: Use WorkloadsConfig_SchedulerResource.ProtoReflect.Descriptor instead.

func (*WorkloadsConfig_SchedulerResource) GetCount

func (x *WorkloadsConfig_SchedulerResource) GetCount() int32

func (*WorkloadsConfig_SchedulerResource) GetCpu

func (x *WorkloadsConfig_SchedulerResource) GetCpu() float32

func (*WorkloadsConfig_SchedulerResource) GetMemoryGb

func (x *WorkloadsConfig_SchedulerResource) GetMemoryGb() float32

func (*WorkloadsConfig_SchedulerResource) GetStorageGb

func (x *WorkloadsConfig_SchedulerResource) GetStorageGb() float32

func (*WorkloadsConfig_SchedulerResource) ProtoMessage

func (*WorkloadsConfig_SchedulerResource) ProtoMessage()

func (*WorkloadsConfig_SchedulerResource) ProtoReflect

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

func (*WorkloadsConfig_SchedulerResource) Reset

func (x *WorkloadsConfig_SchedulerResource) Reset()

func (*WorkloadsConfig_SchedulerResource) String

func (x *WorkloadsConfig_SchedulerResource) String() string

WorkloadsConfig_TriggererResource

type WorkloadsConfig_TriggererResource struct {

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

Configuration for resources used by Airflow triggerers.

func (*WorkloadsConfig_TriggererResource) Descriptor

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

Deprecated: Use WorkloadsConfig_TriggererResource.ProtoReflect.Descriptor instead.

func (*WorkloadsConfig_TriggererResource) GetCount

func (x *WorkloadsConfig_TriggererResource) GetCount() int32

func (*WorkloadsConfig_TriggererResource) GetCpu

func (x *WorkloadsConfig_TriggererResource) GetCpu() float32

func (*WorkloadsConfig_TriggererResource) GetMemoryGb

func (x *WorkloadsConfig_TriggererResource) GetMemoryGb() float32

func (*WorkloadsConfig_TriggererResource) ProtoMessage

func (*WorkloadsConfig_TriggererResource) ProtoMessage()

func (*WorkloadsConfig_TriggererResource) ProtoReflect

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

func (*WorkloadsConfig_TriggererResource) Reset

func (x *WorkloadsConfig_TriggererResource) Reset()

func (*WorkloadsConfig_TriggererResource) String

func (x *WorkloadsConfig_TriggererResource) String() string

WorkloadsConfig_WebServerResource

type WorkloadsConfig_WebServerResource struct {

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

Configuration for resources used by Airflow web server.

func (*WorkloadsConfig_WebServerResource) Descriptor

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

Deprecated: Use WorkloadsConfig_WebServerResource.ProtoReflect.Descriptor instead.

func (*WorkloadsConfig_WebServerResource) GetCpu

func (x *WorkloadsConfig_WebServerResource) GetCpu() float32

func (*WorkloadsConfig_WebServerResource) GetMemoryGb

func (x *WorkloadsConfig_WebServerResource) GetMemoryGb() float32

func (*WorkloadsConfig_WebServerResource) GetStorageGb

func (x *WorkloadsConfig_WebServerResource) GetStorageGb() float32

func (*WorkloadsConfig_WebServerResource) ProtoMessage

func (*WorkloadsConfig_WebServerResource) ProtoMessage()

func (*WorkloadsConfig_WebServerResource) ProtoReflect

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

func (*WorkloadsConfig_WebServerResource) Reset

func (x *WorkloadsConfig_WebServerResource) Reset()

func (*WorkloadsConfig_WebServerResource) String

func (x *WorkloadsConfig_WebServerResource) String() string

WorkloadsConfig_WorkerResource

type WorkloadsConfig_WorkerResource struct {

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

Configuration for resources used by Airflow workers.

func (*WorkloadsConfig_WorkerResource) Descriptor

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

Deprecated: Use WorkloadsConfig_WorkerResource.ProtoReflect.Descriptor instead.

func (*WorkloadsConfig_WorkerResource) GetCpu

func (x *WorkloadsConfig_WorkerResource) GetCpu() float32

func (*WorkloadsConfig_WorkerResource) GetMaxCount

func (x *WorkloadsConfig_WorkerResource) GetMaxCount() int32

func (*WorkloadsConfig_WorkerResource) GetMemoryGb

func (x *WorkloadsConfig_WorkerResource) GetMemoryGb() float32

func (*WorkloadsConfig_WorkerResource) GetMinCount

func (x *WorkloadsConfig_WorkerResource) GetMinCount() int32

func (*WorkloadsConfig_WorkerResource) GetStorageGb

func (x *WorkloadsConfig_WorkerResource) GetStorageGb() float32

func (*WorkloadsConfig_WorkerResource) ProtoMessage

func (*WorkloadsConfig_WorkerResource) ProtoMessage()

func (*WorkloadsConfig_WorkerResource) ProtoReflect

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

func (*WorkloadsConfig_WorkerResource) Reset

func (x *WorkloadsConfig_WorkerResource) Reset()

func (*WorkloadsConfig_WorkerResource) String

func (x *WorkloadsConfig_WorkerResource) String() string