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

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.

AirflowMetadataRetentionPolicyConfig_RetentionMode_name, AirflowMetadataRetentionPolicyConfig_RetentionMode_value

var (
	AirflowMetadataRetentionPolicyConfig_RetentionMode_name = map[int32]string{
		0: "RETENTION_MODE_UNSPECIFIED",
		1: "RETENTION_MODE_ENABLED",
		2: "RETENTION_MODE_DISABLED",
	}
	AirflowMetadataRetentionPolicyConfig_RetentionMode_value = map[string]int32{
		"RETENTION_MODE_UNSPECIFIED": 0,
		"RETENTION_MODE_ENABLED":     1,
		"RETENTION_MODE_DISABLED":    2,
	}
)

Enum value maps for AirflowMetadataRetentionPolicyConfig_RetentionMode.

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)

AirflowMetadataRetentionPolicyConfig

type AirflowMetadataRetentionPolicyConfig struct {
	RetentionMode AirflowMetadataRetentionPolicyConfig_RetentionMode "" /* 203 byte string literal not displayed */

	RetentionDays int32 `protobuf:"varint,2,opt,name=retention_days,json=retentionDays,proto3" json:"retention_days,omitempty"`

}

The policy for airflow metadata database retention.

func (*AirflowMetadataRetentionPolicyConfig) Descriptor

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

Deprecated: Use AirflowMetadataRetentionPolicyConfig.ProtoReflect.Descriptor instead.

func (*AirflowMetadataRetentionPolicyConfig) GetRetentionDays

func (x *AirflowMetadataRetentionPolicyConfig) GetRetentionDays() int32

func (*AirflowMetadataRetentionPolicyConfig) GetRetentionMode

func (*AirflowMetadataRetentionPolicyConfig) ProtoMessage

func (*AirflowMetadataRetentionPolicyConfig) ProtoMessage()

func (*AirflowMetadataRetentionPolicyConfig) ProtoReflect

func (*AirflowMetadataRetentionPolicyConfig) Reset

func (*AirflowMetadataRetentionPolicyConfig) String

AirflowMetadataRetentionPolicyConfig_RetentionMode

type AirflowMetadataRetentionPolicyConfig_RetentionMode int32

Describes retention policy.

AirflowMetadataRetentionPolicyConfig_RETENTION_MODE_UNSPECIFIED, AirflowMetadataRetentionPolicyConfig_RETENTION_MODE_ENABLED, AirflowMetadataRetentionPolicyConfig_RETENTION_MODE_DISABLED

const (
	// Default mode doesn't change environment parameters.
	AirflowMetadataRetentionPolicyConfig_RETENTION_MODE_UNSPECIFIED AirflowMetadataRetentionPolicyConfig_RetentionMode = 0
	// Retention policy is enabled.
	AirflowMetadataRetentionPolicyConfig_RETENTION_MODE_ENABLED AirflowMetadataRetentionPolicyConfig_RetentionMode = 1
	// Retention policy is disabled.
	AirflowMetadataRetentionPolicyConfig_RETENTION_MODE_DISABLED AirflowMetadataRetentionPolicyConfig_RetentionMode = 2
)

func (AirflowMetadataRetentionPolicyConfig_RetentionMode) Descriptor

func (AirflowMetadataRetentionPolicyConfig_RetentionMode) Enum

func (AirflowMetadataRetentionPolicyConfig_RetentionMode) EnumDescriptor

Deprecated: Use AirflowMetadataRetentionPolicyConfig_RetentionMode.Descriptor instead.

func (AirflowMetadataRetentionPolicyConfig_RetentionMode) Number

func (AirflowMetadataRetentionPolicyConfig_RetentionMode) String

func (AirflowMetadataRetentionPolicyConfig_RetentionMode) Type

CheckUpgradeRequest

type CheckUpgradeRequest struct {

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

Request to check whether image upgrade will succeed.

func (*CheckUpgradeRequest) Descriptor

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

Deprecated: Use CheckUpgradeRequest.ProtoReflect.Descriptor instead.

func (*CheckUpgradeRequest) GetEnvironment

func (x *CheckUpgradeRequest) GetEnvironment() string

func (*CheckUpgradeRequest) GetImageVersion

func (x *CheckUpgradeRequest) GetImageVersion() string

func (*CheckUpgradeRequest) ProtoMessage

func (*CheckUpgradeRequest) ProtoMessage()

func (*CheckUpgradeRequest) ProtoReflect

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

func (*CheckUpgradeRequest) Reset

func (x *CheckUpgradeRequest) Reset()

func (*CheckUpgradeRequest) String

func (x *CheckUpgradeRequest) String() string

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

func (CheckUpgradeResponse_ConflictResult) EnumDescriptor

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

Deprecated: Use CheckUpgradeResponse_ConflictResult.Descriptor instead.

func (CheckUpgradeResponse_ConflictResult) Number

func (CheckUpgradeResponse_ConflictResult) String

func (CheckUpgradeResponse_ConflictResult) Type

CloudDataLineageIntegration

type CloudDataLineageIntegration struct {

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

Configuration for Cloud Data Lineage integration.

func (*CloudDataLineageIntegration) Descriptor

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 (*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 (*CreateUserWorkloadsConfigMapRequest) GetUserWorkloadsConfigMap

func (x *CreateUserWorkloadsConfigMapRequest) GetUserWorkloadsConfigMap() *UserWorkloadsConfigMap

func (*CreateUserWorkloadsConfigMapRequest) ProtoMessage

func (*CreateUserWorkloadsConfigMapRequest) ProtoMessage()

func (*CreateUserWorkloadsConfigMapRequest) ProtoReflect

func (*CreateUserWorkloadsConfigMapRequest) Reset

func (*CreateUserWorkloadsConfigMapRequest) 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 (*CreateUserWorkloadsSecretRequest) GetUserWorkloadsSecret

func (x *CreateUserWorkloadsSecretRequest) GetUserWorkloadsSecret() *UserWorkloadsSecret

func (*CreateUserWorkloadsSecretRequest) ProtoMessage

func (*CreateUserWorkloadsSecretRequest) ProtoMessage()

func (*CreateUserWorkloadsSecretRequest) ProtoReflect

func (*CreateUserWorkloadsSecretRequest) Reset

func (*CreateUserWorkloadsSecretRequest) String

DataRetentionConfig

type DataRetentionConfig struct {
	AirflowMetadataRetentionConfig *AirflowMetadataRetentionPolicyConfig "" /* 155 byte string literal not displayed */

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

func (x *DataRetentionConfig) GetAirflowMetadataRetentionConfig() *AirflowMetadataRetentionPolicyConfig

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 (*DeleteUserWorkloadsConfigMapRequest) ProtoMessage

func (*DeleteUserWorkloadsConfigMapRequest) ProtoMessage()

func (*DeleteUserWorkloadsConfigMapRequest) ProtoReflect

func (*DeleteUserWorkloadsConfigMapRequest) Reset

func (*DeleteUserWorkloadsConfigMapRequest) 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 (*DeleteUserWorkloadsSecretRequest) ProtoMessage

func (*DeleteUserWorkloadsSecretRequest) ProtoMessage()

func (*DeleteUserWorkloadsSecretRequest) ProtoReflect

func (*DeleteUserWorkloadsSecretRequest) Reset

func (*DeleteUserWorkloadsSecretRequest) 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"`

	SatisfiesPzi bool `protobuf:"varint,10,opt,name=satisfies_pzi,json=satisfiesPzi,proto3" json:"satisfies_pzi,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) GetSatisfiesPzi

func (x *Environment) GetSatisfiesPzi() bool

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

func (EnvironmentConfig_EnvironmentSize) EnumDescriptor

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

Deprecated: Use EnvironmentConfig_EnvironmentSize.Descriptor instead.

func (EnvironmentConfig_EnvironmentSize) Number

func (EnvironmentConfig_EnvironmentSize) String

func (EnvironmentConfig_EnvironmentSize) Type

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

func (EnvironmentConfig_ResilienceMode) EnumDescriptor

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

Deprecated: Use EnvironmentConfig_ResilienceMode.Descriptor instead.

func (EnvironmentConfig_ResilienceMode) Number

func (EnvironmentConfig_ResilienceMode) String

func (EnvironmentConfig_ResilienceMode) Type

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

func (Environment_State) EnumDescriptor

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

Deprecated: Use Environment_State.Descriptor instead.

func (Environment_State) Number

func (Environment_State) String

func (x Environment_State) String() string

func (Environment_State) Type

EnvironmentsClient

type EnvironmentsClient interface {
	// Create a new environment.
	CreateEnvironment(ctx context.Context, in *CreateEnvironmentRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Get an existing environment.
	GetEnvironment(ctx context.Context, in *GetEnvironmentRequest, opts ...grpc.CallOption) (*Environment, error)
	// List environments.
	ListEnvironments(ctx context.Context, in *ListEnvironmentsRequest, opts ...grpc.CallOption) (*ListEnvironmentsResponse, error)
	// Update an environment.
	UpdateEnvironment(ctx context.Context, in *UpdateEnvironmentRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Delete an environment.
	DeleteEnvironment(ctx context.Context, in *DeleteEnvironmentRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Executes Airflow CLI command.
	ExecuteAirflowCommand(ctx context.Context, in *ExecuteAirflowCommandRequest, opts ...grpc.CallOption) (*ExecuteAirflowCommandResponse, error)
	// Stops Airflow CLI command execution.
	StopAirflowCommand(ctx context.Context, in *StopAirflowCommandRequest, opts ...grpc.CallOption) (*StopAirflowCommandResponse, error)
	// Polls Airflow CLI command execution and fetches logs.
	PollAirflowCommand(ctx context.Context, in *PollAirflowCommandRequest, opts ...grpc.CallOption) (*PollAirflowCommandResponse, error)
	// 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-2.*.*-airflow-*.*.* and newer.
	ListWorkloads(ctx context.Context, in *ListWorkloadsRequest, opts ...grpc.CallOption) (*ListWorkloadsResponse, error)
	// Check if an upgrade operation on the environment will succeed.
	//
	// In case of problems detailed info can be found in the returned Operation.
	CheckUpgrade(ctx context.Context, in *CheckUpgradeRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, 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-2.*.*-airflow-*.*.* and newer.
	ListWorkloads(context.Context, *ListWorkloadsRequest) (*ListWorkloadsResponse, error)
	// Check if an upgrade operation on the environment will succeed.
	//
	// In case of problems detailed info can be found in the returned Operation.
	CheckUpgrade(context.Context, *CheckUpgradeRequest) (*longrunningpb.Operation, 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 (*ExecuteAirflowCommandRequest) Reset

func (x *ExecuteAirflowCommandRequest) Reset()

func (*ExecuteAirflowCommandRequest) 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 (*ExecuteAirflowCommandResponse) GetPodNamespace

func (x *ExecuteAirflowCommandResponse) GetPodNamespace() string

func (*ExecuteAirflowCommandResponse) ProtoMessage

func (*ExecuteAirflowCommandResponse) ProtoMessage()

func (*ExecuteAirflowCommandResponse) ProtoReflect

func (*ExecuteAirflowCommandResponse) Reset

func (x *ExecuteAirflowCommandResponse) Reset()

func (*ExecuteAirflowCommandResponse) 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 (*FetchDatabasePropertiesRequest) Reset

func (x *FetchDatabasePropertiesRequest) Reset()

func (*FetchDatabasePropertiesRequest) 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 (*FetchDatabasePropertiesResponse) Reset

func (*FetchDatabasePropertiesResponse) 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 (*GetUserWorkloadsConfigMapRequest) ProtoMessage

func (*GetUserWorkloadsConfigMapRequest) ProtoMessage()

func (*GetUserWorkloadsConfigMapRequest) ProtoReflect

func (*GetUserWorkloadsConfigMapRequest) Reset

func (*GetUserWorkloadsConfigMapRequest) 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 (*GetUserWorkloadsSecretRequest) ProtoMessage

func (*GetUserWorkloadsSecretRequest) ProtoMessage()

func (*GetUserWorkloadsSecretRequest) ProtoReflect

func (*GetUserWorkloadsSecretRequest) Reset

func (x *GetUserWorkloadsSecretRequest) Reset()

func (*GetUserWorkloadsSecretRequest) 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 (*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 (*ListUserWorkloadsConfigMapsRequest) ProtoMessage

func (*ListUserWorkloadsConfigMapsRequest) ProtoMessage()

func (*ListUserWorkloadsConfigMapsRequest) ProtoReflect

func (*ListUserWorkloadsConfigMapsRequest) Reset

func (*ListUserWorkloadsConfigMapsRequest) 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 (*ListUserWorkloadsConfigMapsResponse) Reset

func (*ListUserWorkloadsConfigMapsResponse) 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 (*ListUserWorkloadsSecretsRequest) Reset

func (*ListUserWorkloadsSecretsRequest) 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 (*ListUserWorkloadsSecretsResponse) Reset

func (*ListUserWorkloadsSecretsResponse) 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 (*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 (*ListWorkloadsResponse_ComposerWorkload) GetStatus

func (*ListWorkloadsResponse_ComposerWorkload) GetType

func (*ListWorkloadsResponse_ComposerWorkload) ProtoMessage

func (*ListWorkloadsResponse_ComposerWorkload) ProtoReflect

func (*ListWorkloadsResponse_ComposerWorkload) Reset

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

func (ListWorkloadsResponse_ComposerWorkloadState) EnumDescriptor

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

Deprecated: Use ListWorkloadsResponse_ComposerWorkloadState.Descriptor instead.

func (ListWorkloadsResponse_ComposerWorkloadState) Number

func (ListWorkloadsResponse_ComposerWorkloadState) String

func (ListWorkloadsResponse_ComposerWorkloadState) Type

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

Deprecated: Use ListWorkloadsResponse_ComposerWorkloadStatus.ProtoReflect.Descriptor instead.

func (*ListWorkloadsResponse_ComposerWorkloadStatus) GetDetailedStatusMessage

func (x *ListWorkloadsResponse_ComposerWorkloadStatus) GetDetailedStatusMessage() string

func (*ListWorkloadsResponse_ComposerWorkloadStatus) GetState

func (*ListWorkloadsResponse_ComposerWorkloadStatus) GetStatusMessage

func (*ListWorkloadsResponse_ComposerWorkloadStatus) ProtoMessage

func (*ListWorkloadsResponse_ComposerWorkloadStatus) ProtoReflect

func (*ListWorkloadsResponse_ComposerWorkloadStatus) Reset

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

func (ListWorkloadsResponse_ComposerWorkloadType) EnumDescriptor

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

Deprecated: Use ListWorkloadsResponse_ComposerWorkloadType.Descriptor instead.

func (ListWorkloadsResponse_ComposerWorkloadType) Number

func (ListWorkloadsResponse_ComposerWorkloadType) String

func (ListWorkloadsResponse_ComposerWorkloadType) Type

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 (*MasterAuthorizedNetworksConfig) GetEnabled

func (x *MasterAuthorizedNetworksConfig) GetEnabled() bool

func (*MasterAuthorizedNetworksConfig) ProtoMessage

func (*MasterAuthorizedNetworksConfig) ProtoMessage()

func (*MasterAuthorizedNetworksConfig) ProtoReflect

func (*MasterAuthorizedNetworksConfig) Reset

func (x *MasterAuthorizedNetworksConfig) Reset()

func (*MasterAuthorizedNetworksConfig) 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 (*MasterAuthorizedNetworksConfig_CidrBlock) GetDisplayName

func (*MasterAuthorizedNetworksConfig_CidrBlock) ProtoMessage