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

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,
	}
)

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,
	}
)

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,
	}
)

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,
	}
)

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,
	}
)

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,
	}
)

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,
	}
)

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,
	}
)

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,
	}
)

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,
	}
)

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,
	}
)

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,
	}
)

var File_google_cloud_orchestration_airflow_service_v1_environments_proto protoreflect.FileDescriptor

var File_google_cloud_orchestration_airflow_service_v1_image_versions_proto protoreflect.FileDescriptor

var File_google_cloud_orchestration_airflow_service_v1_operations_proto protoreflect.FileDescriptor

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

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

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

}

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

func (x *AirflowMetadataRetentionPolicyConfig) GetRetentionDays() int32

func (x *AirflowMetadataRetentionPolicyConfig) GetRetentionMode() AirflowMetadataRetentionPolicyConfig_RetentionMode

func (*AirflowMetadataRetentionPolicyConfig) ProtoMessage()

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

func (x *AirflowMetadataRetentionPolicyConfig) Reset()

func (x *AirflowMetadataRetentionPolicyConfig) String() string

type AirflowMetadataRetentionPolicyConfig_RetentionMode int32

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() protoreflect.EnumDescriptor

func (x AirflowMetadataRetentionPolicyConfig_RetentionMode) Enum() *AirflowMetadataRetentionPolicyConfig_RetentionMode

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

func (x AirflowMetadataRetentionPolicyConfig_RetentionMode) Number() protoreflect.EnumNumber

func (x AirflowMetadataRetentionPolicyConfig_RetentionMode) String() string

func (AirflowMetadataRetentionPolicyConfig_RetentionMode) Type() protoreflect.EnumType

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
}

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

func (x *CheckUpgradeRequest) GetEnvironment() string

func (x *CheckUpgradeRequest) GetImageVersion() string

func (*CheckUpgradeRequest) ProtoMessage()

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

func (x *CheckUpgradeRequest) Reset()

func (x *CheckUpgradeRequest) String() string

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 */

}

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

func (x *CheckUpgradeResponse) GetBuildLogUri() string

func (x *CheckUpgradeResponse) GetContainsPypiModulesConflict() CheckUpgradeResponse_ConflictResult

func (x *CheckUpgradeResponse) GetImageVersion() string

func (x *CheckUpgradeResponse) GetPypiConflictBuildLogExtract() string

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

func (*CheckUpgradeResponse) ProtoMessage()

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

func (x *CheckUpgradeResponse) Reset()

func (x *CheckUpgradeResponse) String() string

type CheckUpgradeResponse_ConflictResult int32

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() protoreflect.EnumDescriptor

func (x CheckUpgradeResponse_ConflictResult) Enum() *CheckUpgradeResponse_ConflictResult

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

func (x CheckUpgradeResponse_ConflictResult) Number() protoreflect.EnumNumber

func (x CheckUpgradeResponse_ConflictResult) String() string

func (CheckUpgradeResponse_ConflictResult) Type() protoreflect.EnumType

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
}

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

func (x *CloudDataLineageIntegration) GetEnabled() bool

func (*CloudDataLineageIntegration) ProtoMessage()

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

func (x *CloudDataLineageIntegration) Reset()

func (x *CloudDataLineageIntegration) String() string

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
}

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

func (x *CreateEnvironmentRequest) GetEnvironment() *Environment

func (x *CreateEnvironmentRequest) GetParent() string

func (*CreateEnvironmentRequest) ProtoMessage()

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

func (x *CreateEnvironmentRequest) Reset()

func (x *CreateEnvironmentRequest) String() string

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

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

}

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

func (x *CreateUserWorkloadsConfigMapRequest) GetParent() string

func (x *CreateUserWorkloadsConfigMapRequest) GetUserWorkloadsConfigMap() *UserWorkloadsConfigMap

func (*CreateUserWorkloadsConfigMapRequest) ProtoMessage()

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

func (x *CreateUserWorkloadsConfigMapRequest) Reset()

func (x *CreateUserWorkloadsConfigMapRequest) String() string

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
}

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

func (x *CreateUserWorkloadsSecretRequest) GetParent() string

func (x *CreateUserWorkloadsSecretRequest) GetUserWorkloadsSecret() *UserWorkloadsSecret

func (*CreateUserWorkloadsSecretRequest) ProtoMessage()

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

func (x *CreateUserWorkloadsSecretRequest) Reset()

func (x *CreateUserWorkloadsSecretRequest) String() string

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

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

}

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

func (x *DataRetentionConfig) GetAirflowMetadataRetentionConfig() *AirflowMetadataRetentionPolicyConfig

func (x *DataRetentionConfig) GetTaskLogsRetentionConfig() *TaskLogsRetentionConfig

func (*DataRetentionConfig) ProtoMessage()

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

func (x *DataRetentionConfig) Reset()

func (x *DataRetentionConfig) String() string

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
}

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

func (x *DatabaseConfig) GetMachineType() string

func (x *DatabaseConfig) GetZone() string

func (*DatabaseConfig) ProtoMessage()

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

func (x *DatabaseConfig) Reset()

func (x *DatabaseConfig) String() string

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
}

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

func (x *DatabaseFailoverRequest) GetEnvironment() string

func (*DatabaseFailoverRequest) ProtoMessage()

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

func (x *DatabaseFailoverRequest) Reset()

func (x *DatabaseFailoverRequest) String() string

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

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

func (*DatabaseFailoverResponse) ProtoMessage()

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

func (x *DatabaseFailoverResponse) Reset()

func (x *DatabaseFailoverResponse) String() string

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
}

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

func (x *DeleteEnvironmentRequest) GetName() string

func (*DeleteEnvironmentRequest) ProtoMessage()

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

func (x *DeleteEnvironmentRequest) Reset()

func (x *DeleteEnvironmentRequest) String() string

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
}

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

func (x *DeleteUserWorkloadsConfigMapRequest) GetName() string

func (*DeleteUserWorkloadsConfigMapRequest) ProtoMessage()

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

func (x *DeleteUserWorkloadsConfigMapRequest) Reset()

func (x *DeleteUserWorkloadsConfigMapRequest) String() string

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
}

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

func (x *DeleteUserWorkloadsSecretRequest) GetName() string

func (*DeleteUserWorkloadsSecretRequest) ProtoMessage()

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

func (x *DeleteUserWorkloadsSecretRequest) Reset()

func (x *DeleteUserWorkloadsSecretRequest) String() string

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
}

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

func (x *EncryptionConfig) GetKmsKeyName() string

func (*EncryptionConfig) ProtoMessage()

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

func (x *EncryptionConfig) Reset()

func (x *EncryptionConfig) String() string

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

}

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

func (x *Environment) GetConfig() *EnvironmentConfig

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

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

func (x *Environment) GetName() string

func (x *Environment) GetSatisfiesPzi() bool

func (x *Environment) GetSatisfiesPzs() bool

func (x *Environment) GetState() Environment_State

func (x *Environment) GetStorageConfig() *StorageConfig

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

func (x *Environment) GetUuid() string

func (*Environment) ProtoMessage()

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

func (x *Environment) Reset()

func (x *Environment) String() string

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

}

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

func (x *EnvironmentConfig) GetAirflowByoidUri() string

func (x *EnvironmentConfig) GetAirflowUri() string

func (x *EnvironmentConfig) GetDagGcsPrefix() string

func (x *EnvironmentConfig) GetDataRetentionConfig() *DataRetentionConfig

func (x *EnvironmentConfig) GetDatabaseConfig() *DatabaseConfig

func (x *EnvironmentConfig) GetEncryptionConfig() *EncryptionConfig

func (x *EnvironmentConfig) GetEnvironmentSize() EnvironmentConfig_EnvironmentSize

func (x *EnvironmentConfig) GetGkeCluster() string

func (x *EnvironmentConfig) GetMaintenanceWindow() *MaintenanceWindow

func (x *EnvironmentConfig) GetMasterAuthorizedNetworksConfig() *MasterAuthorizedNetworksConfig

func (x *EnvironmentConfig) GetNodeConfig() *NodeConfig

func (x *EnvironmentConfig) GetNodeCount() int32

func (x *EnvironmentConfig) GetPrivateEnvironmentConfig() *PrivateEnvironmentConfig

func (x *EnvironmentConfig) GetRecoveryConfig() *RecoveryConfig

func (x *EnvironmentConfig) GetResilienceMode() EnvironmentConfig_ResilienceMode

func (x *EnvironmentConfig) GetSoftwareConfig() *SoftwareConfig

func (x *EnvironmentConfig) GetWebServerConfig() *WebServerConfig

func (x *EnvironmentConfig) GetWebServerNetworkAccessControl() *WebServerNetworkAccessControl

func (x *EnvironmentConfig) GetWorkloadsConfig() *WorkloadsConfig

func (*EnvironmentConfig) ProtoMessage()

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

func (x *EnvironmentConfig) Reset()

func (x *EnvironmentConfig) String() string

type EnvironmentConfig_EnvironmentSize int32

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() protoreflect.EnumDescriptor

func (x EnvironmentConfig_EnvironmentSize) Enum() *EnvironmentConfig_EnvironmentSize

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

func (x EnvironmentConfig_EnvironmentSize) Number() protoreflect.EnumNumber

func (x EnvironmentConfig_EnvironmentSize) String() string

func (EnvironmentConfig_EnvironmentSize) Type() protoreflect.EnumType

type EnvironmentConfig_ResilienceMode int32

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() protoreflect.EnumDescriptor

func (x EnvironmentConfig_ResilienceMode) Enum() *EnvironmentConfig_ResilienceMode

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

func (x EnvironmentConfig_ResilienceMode) Number() protoreflect.EnumNumber

func (x EnvironmentConfig_ResilienceMode) String() string

func (EnvironmentConfig_ResilienceMode) Type() protoreflect.EnumType

type Environment_State int32

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() protoreflect.EnumDescriptor

func (x Environment_State) Enum() *Environment_State

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

func (x Environment_State) Number() protoreflect.EnumNumber

func (x Environment_State) String() string

func (Environment_State) Type() protoreflect.EnumType

type EnvironmentsClient interface {
	// Create a new environment.
	CreateEnvironment(ctx context.Context, in *CreateEnvironmentRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Get an existing environment.
	GetEnvironment(ctx context.Context, in *GetEnvironmentRequest, opts ...grpc.CallOption) (*Environment, error)
	// List environments.
	ListEnvironments(ctx context.Context, in *ListEnvironmentsRequest, opts ...grpc.CallOption) (*ListEnvironmentsResponse, error)
	// Update an environment.
	UpdateEnvironment(ctx context.Context, in *UpdateEnvironmentRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Delete an environment.
	DeleteEnvironment(ctx context.Context, in *DeleteEnvironmentRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Executes Airflow CLI command.
	ExecuteAirflowCommand(ctx context.Context, in *ExecuteAirflowCommandRequest, opts ...grpc.CallOption) (*ExecuteAirflowCommandResponse, error)
	// Stops Airflow CLI command execution.
	StopAirflowCommand(ctx context.Context, in *StopAirflowCommandRequest, opts ...grpc.CallOption) (*StopAirflowCommandResponse, error)
	// Polls Airflow CLI command execution and fetches logs.
	PollAirflowCommand(ctx context.Context, in *PollAirflowCommandRequest, opts ...grpc.CallOption) (*PollAirflowCommandResponse, error)
	// Lists workloads in a Cloud Composer environment. Workload is a unit that
	// runs a single Composer component.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	ListWorkloads(ctx context.Context, in *ListWorkloadsRequest, opts ...grpc.CallOption) (*ListWorkloadsResponse, error)
	// 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)
}

func NewEnvironmentsClient(cc grpc.ClientConnInterface) EnvironmentsClient

type EnvironmentsServer interface {
	// Create a new environment.
	CreateEnvironment(context.Context, *CreateEnvironmentRequest) (*longrunningpb.Operation, error)
	// Get an existing environment.
	GetEnvironment(context.Context, *GetEnvironmentRequest) (*Environment, error)
	// List environments.
	ListEnvironments(context.Context, *ListEnvironmentsRequest) (*ListEnvironmentsResponse, error)
	// Update an environment.
	UpdateEnvironment(context.Context, *UpdateEnvironmentRequest) (*longrunningpb.Operation, error)
	// Delete an environment.
	DeleteEnvironment(context.Context, *DeleteEnvironmentRequest) (*longrunningpb.Operation, error)
	// Executes Airflow CLI command.
	ExecuteAirflowCommand(context.Context, *ExecuteAirflowCommandRequest) (*ExecuteAirflowCommandResponse, error)
	// Stops Airflow CLI command execution.
	StopAirflowCommand(context.Context, *StopAirflowCommandRequest) (*StopAirflowCommandResponse, error)
	// Polls Airflow CLI command execution and fetches logs.
	PollAirflowCommand(context.Context, *PollAirflowCommandRequest) (*PollAirflowCommandResponse, error)
	// Lists workloads in a Cloud Composer environment. Workload is a unit that
	// runs a single Composer component.
	//
	// This method is supported for Cloud Composer environments in versions
	// composer-3.*.*-airflow-*.*.* and newer.
	ListWorkloads(context.Context, *ListWorkloadsRequest) (*ListWorkloadsResponse, error)
	// 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)
}