Documentation
¶
Index ¶
- Variables
- func RegisterEnvironmentsServer(s *grpc.Server, srv EnvironmentsServer)
- func RegisterImageVersionsServer(s *grpc.Server, srv ImageVersionsServer)
- type CheckUpgradeResponse
- func (*CheckUpgradeResponse) Descriptor() ([]byte, []int)deprecated
- 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
- func (CheckUpgradeResponse_ConflictResult) Descriptor() protoreflect.EnumDescriptor
- func (x CheckUpgradeResponse_ConflictResult) Enum() *CheckUpgradeResponse_ConflictResult
- func (CheckUpgradeResponse_ConflictResult) EnumDescriptor() ([]byte, []int)deprecated
- func (x CheckUpgradeResponse_ConflictResult) Number() protoreflect.EnumNumber
- func (x CheckUpgradeResponse_ConflictResult) String() string
- func (CheckUpgradeResponse_ConflictResult) Type() protoreflect.EnumType
- type CreateEnvironmentRequest
- func (*CreateEnvironmentRequest) Descriptor() ([]byte, []int)deprecated
- 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 DatabaseConfig
- type DeleteEnvironmentRequest
- func (*DeleteEnvironmentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteEnvironmentRequest) GetName() string
- func (*DeleteEnvironmentRequest) ProtoMessage()
- func (x *DeleteEnvironmentRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteEnvironmentRequest) Reset()
- func (x *DeleteEnvironmentRequest) String() string
- type EncryptionConfig
- type Environment
- func (*Environment) Descriptor() ([]byte, []int)deprecated
- 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) GetState() Environment_State
- 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
- func (*EnvironmentConfig) Descriptor() ([]byte, []int)deprecated
- func (x *EnvironmentConfig) GetAirflowUri() string
- func (x *EnvironmentConfig) GetDagGcsPrefix() string
- func (x *EnvironmentConfig) GetDatabaseConfig() *DatabaseConfig
- func (x *EnvironmentConfig) GetEncryptionConfig() *EncryptionConfig
- func (x *EnvironmentConfig) GetGkeCluster() string
- func (x *EnvironmentConfig) GetNodeConfig() *NodeConfig
- func (x *EnvironmentConfig) GetNodeCount() int32
- func (x *EnvironmentConfig) GetPrivateEnvironmentConfig() *PrivateEnvironmentConfig
- func (x *EnvironmentConfig) GetSoftwareConfig() *SoftwareConfig
- func (x *EnvironmentConfig) GetWebServerConfig() *WebServerConfig
- func (x *EnvironmentConfig) GetWebServerNetworkAccessControl() *WebServerNetworkAccessControl
- func (*EnvironmentConfig) ProtoMessage()
- func (x *EnvironmentConfig) ProtoReflect() protoreflect.Message
- func (x *EnvironmentConfig) Reset()
- func (x *EnvironmentConfig) String() string
- type Environment_State
- func (Environment_State) Descriptor() protoreflect.EnumDescriptor
- func (x Environment_State) Enum() *Environment_State
- func (Environment_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x Environment_State) Number() protoreflect.EnumNumber
- func (x Environment_State) String() string
- func (Environment_State) Type() protoreflect.EnumType
- type EnvironmentsClient
- type EnvironmentsServer
- type GetEnvironmentRequest
- func (*GetEnvironmentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetEnvironmentRequest) GetName() string
- func (*GetEnvironmentRequest) ProtoMessage()
- func (x *GetEnvironmentRequest) ProtoReflect() protoreflect.Message
- func (x *GetEnvironmentRequest) Reset()
- func (x *GetEnvironmentRequest) String() string
- type IPAllocationPolicy
- func (*IPAllocationPolicy) Descriptor() ([]byte, []int)deprecated
- func (m *IPAllocationPolicy) GetClusterIpAllocation() isIPAllocationPolicy_ClusterIpAllocation
- func (x *IPAllocationPolicy) GetClusterIpv4CidrBlock() string
- func (x *IPAllocationPolicy) GetClusterSecondaryRangeName() string
- func (m *IPAllocationPolicy) GetServicesIpAllocation() isIPAllocationPolicy_ServicesIpAllocation
- func (x *IPAllocationPolicy) GetServicesIpv4CidrBlock() string
- func (x *IPAllocationPolicy) GetServicesSecondaryRangeName() string
- func (x *IPAllocationPolicy) GetUseIpAliases() bool
- func (*IPAllocationPolicy) ProtoMessage()
- func (x *IPAllocationPolicy) ProtoReflect() protoreflect.Message
- func (x *IPAllocationPolicy) Reset()
- func (x *IPAllocationPolicy) String() string
- type IPAllocationPolicy_ClusterIpv4CidrBlock
- type IPAllocationPolicy_ClusterSecondaryRangeName
- type IPAllocationPolicy_ServicesIpv4CidrBlock
- type IPAllocationPolicy_ServicesSecondaryRangeName
- type ImageVersion
- func (*ImageVersion) Descriptor() ([]byte, []int)deprecated
- func (x *ImageVersion) GetCreationDisabled() bool
- func (x *ImageVersion) GetImageVersionId() string
- func (x *ImageVersion) GetIsDefault() bool
- func (x *ImageVersion) GetReleaseDate() *date.Date
- func (x *ImageVersion) GetSupportedPythonVersions() []string
- func (x *ImageVersion) GetUpgradeDisabled() bool
- func (*ImageVersion) ProtoMessage()
- func (x *ImageVersion) ProtoReflect() protoreflect.Message
- func (x *ImageVersion) Reset()
- func (x *ImageVersion) String() string
- type ImageVersionsClient
- type ImageVersionsServer
- type ListEnvironmentsRequest
- func (*ListEnvironmentsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListEnvironmentsRequest) GetPageSize() int32
- func (x *ListEnvironmentsRequest) GetPageToken() string
- func (x *ListEnvironmentsRequest) GetParent() string
- func (*ListEnvironmentsRequest) ProtoMessage()
- func (x *ListEnvironmentsRequest) ProtoReflect() protoreflect.Message
- func (x *ListEnvironmentsRequest) Reset()
- func (x *ListEnvironmentsRequest) String() string
- type ListEnvironmentsResponse
- func (*ListEnvironmentsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListEnvironmentsResponse) GetEnvironments() []*Environment
- func (x *ListEnvironmentsResponse) GetNextPageToken() string
- func (*ListEnvironmentsResponse) ProtoMessage()
- func (x *ListEnvironmentsResponse) ProtoReflect() protoreflect.Message
- func (x *ListEnvironmentsResponse) Reset()
- func (x *ListEnvironmentsResponse) String() string
- type ListImageVersionsRequest
- func (*ListImageVersionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListImageVersionsRequest) GetIncludePastReleases() bool
- func (x *ListImageVersionsRequest) GetPageSize() int32
- func (x *ListImageVersionsRequest) GetPageToken() string
- func (x *ListImageVersionsRequest) GetParent() string
- func (*ListImageVersionsRequest) ProtoMessage()
- func (x *ListImageVersionsRequest) ProtoReflect() protoreflect.Message
- func (x *ListImageVersionsRequest) Reset()
- func (x *ListImageVersionsRequest) String() string
- type ListImageVersionsResponse
- func (*ListImageVersionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListImageVersionsResponse) GetImageVersions() []*ImageVersion
- func (x *ListImageVersionsResponse) GetNextPageToken() string
- func (*ListImageVersionsResponse) ProtoMessage()
- func (x *ListImageVersionsResponse) ProtoReflect() protoreflect.Message
- func (x *ListImageVersionsResponse) Reset()
- func (x *ListImageVersionsResponse) String() string
- type NodeConfig
- func (*NodeConfig) Descriptor() ([]byte, []int)deprecated
- func (x *NodeConfig) GetDiskSizeGb() int32
- func (x *NodeConfig) GetIpAllocationPolicy() *IPAllocationPolicy
- func (x *NodeConfig) GetLocation() string
- func (x *NodeConfig) GetMachineType() string
- func (x *NodeConfig) GetNetwork() string
- func (x *NodeConfig) GetOauthScopes() []string
- func (x *NodeConfig) GetServiceAccount() string
- func (x *NodeConfig) GetSubnetwork() string
- func (x *NodeConfig) GetTags() []string
- func (*NodeConfig) ProtoMessage()
- func (x *NodeConfig) ProtoReflect() protoreflect.Message
- func (x *NodeConfig) Reset()
- func (x *NodeConfig) String() string
- type OperationMetadata
- func (*OperationMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *OperationMetadata) GetCreateTime() *timestamppb.Timestamp
- func (x *OperationMetadata) GetEndTime() *timestamppb.Timestamp
- func (x *OperationMetadata) GetOperationType() OperationMetadata_Type
- func (x *OperationMetadata) GetResource() string
- func (x *OperationMetadata) GetResourceUuid() string
- func (x *OperationMetadata) GetState() OperationMetadata_State
- func (*OperationMetadata) ProtoMessage()
- func (x *OperationMetadata) ProtoReflect() protoreflect.Message
- func (x *OperationMetadata) Reset()
- func (x *OperationMetadata) String() string
- type OperationMetadata_State
- func (OperationMetadata_State) Descriptor() protoreflect.EnumDescriptor
- func (x OperationMetadata_State) Enum() *OperationMetadata_State
- func (OperationMetadata_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x OperationMetadata_State) Number() protoreflect.EnumNumber
- func (x OperationMetadata_State) String() string
- func (OperationMetadata_State) Type() protoreflect.EnumType
- type OperationMetadata_Type
- func (OperationMetadata_Type) Descriptor() protoreflect.EnumDescriptor
- func (x OperationMetadata_Type) Enum() *OperationMetadata_Type
- func (OperationMetadata_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x OperationMetadata_Type) Number() protoreflect.EnumNumber
- func (x OperationMetadata_Type) String() string
- func (OperationMetadata_Type) Type() protoreflect.EnumType
- type PrivateClusterConfig
- func (*PrivateClusterConfig) Descriptor() ([]byte, []int)deprecated
- func (x *PrivateClusterConfig) GetEnablePrivateEndpoint() bool
- func (x *PrivateClusterConfig) GetMasterIpv4CidrBlock() string
- func (x *PrivateClusterConfig) GetMasterIpv4ReservedRange() string
- func (*PrivateClusterConfig) ProtoMessage()
- func (x *PrivateClusterConfig) ProtoReflect() protoreflect.Message
- func (x *PrivateClusterConfig) Reset()
- func (x *PrivateClusterConfig) String() string
- type PrivateEnvironmentConfig
- func (*PrivateEnvironmentConfig) Descriptor() ([]byte, []int)deprecated
- func (x *PrivateEnvironmentConfig) GetCloudSqlIpv4CidrBlock() string
- func (x *PrivateEnvironmentConfig) GetEnablePrivateEnvironment() bool
- func (x *PrivateEnvironmentConfig) GetPrivateClusterConfig() *PrivateClusterConfig
- func (x *PrivateEnvironmentConfig) GetWebServerIpv4CidrBlock() string
- func (x *PrivateEnvironmentConfig) GetWebServerIpv4ReservedRange() string
- func (*PrivateEnvironmentConfig) ProtoMessage()
- func (x *PrivateEnvironmentConfig) ProtoReflect() protoreflect.Message
- func (x *PrivateEnvironmentConfig) Reset()
- func (x *PrivateEnvironmentConfig) String() string
- type SoftwareConfig
- func (*SoftwareConfig) Descriptor() ([]byte, []int)deprecated
- func (x *SoftwareConfig) GetAirflowConfigOverrides() map[string]string
- func (x *SoftwareConfig) GetEnvVariables() map[string]string
- func (x *SoftwareConfig) GetImageVersion() string
- func (x *SoftwareConfig) GetPypiPackages() map[string]string
- func (x *SoftwareConfig) GetPythonVersion() string
- func (*SoftwareConfig) ProtoMessage()
- func (x *SoftwareConfig) ProtoReflect() protoreflect.Message
- func (x *SoftwareConfig) Reset()
- func (x *SoftwareConfig) String() string
- type UnimplementedEnvironmentsServer
- func (*UnimplementedEnvironmentsServer) CreateEnvironment(context.Context, *CreateEnvironmentRequest) (*longrunning.Operation, error)
- func (*UnimplementedEnvironmentsServer) DeleteEnvironment(context.Context, *DeleteEnvironmentRequest) (*longrunning.Operation, error)
- func (*UnimplementedEnvironmentsServer) GetEnvironment(context.Context, *GetEnvironmentRequest) (*Environment, error)
- func (*UnimplementedEnvironmentsServer) ListEnvironments(context.Context, *ListEnvironmentsRequest) (*ListEnvironmentsResponse, error)
- func (*UnimplementedEnvironmentsServer) UpdateEnvironment(context.Context, *UpdateEnvironmentRequest) (*longrunning.Operation, error)
- type UnimplementedImageVersionsServer
- type UpdateEnvironmentRequest
- func (*UpdateEnvironmentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateEnvironmentRequest) GetEnvironment() *Environment
- func (x *UpdateEnvironmentRequest) GetName() string
- func (x *UpdateEnvironmentRequest) GetUpdateMask() *fieldmaskpb.FieldMask
- func (*UpdateEnvironmentRequest) ProtoMessage()
- func (x *UpdateEnvironmentRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateEnvironmentRequest) Reset()
- func (x *UpdateEnvironmentRequest) String() string
- type WebServerConfig
- type WebServerNetworkAccessControl
- func (*WebServerNetworkAccessControl) Descriptor() ([]byte, []int)deprecated
- func (x *WebServerNetworkAccessControl) GetAllowedIpRanges() []*WebServerNetworkAccessControl_AllowedIpRange
- func (*WebServerNetworkAccessControl) ProtoMessage()
- func (x *WebServerNetworkAccessControl) ProtoReflect() protoreflect.Message
- func (x *WebServerNetworkAccessControl) Reset()
- func (x *WebServerNetworkAccessControl) String() string
- type WebServerNetworkAccessControl_AllowedIpRange
- func (*WebServerNetworkAccessControl_AllowedIpRange) Descriptor() ([]byte, []int)deprecated
- func (x *WebServerNetworkAccessControl_AllowedIpRange) GetDescription() string
- func (x *WebServerNetworkAccessControl_AllowedIpRange) GetValue() string
- func (*WebServerNetworkAccessControl_AllowedIpRange) ProtoMessage()
- func (x *WebServerNetworkAccessControl_AllowedIpRange) ProtoReflect() protoreflect.Message
- func (x *WebServerNetworkAccessControl_AllowedIpRange) Reset()
- func (x *WebServerNetworkAccessControl_AllowedIpRange) String() string
Constants ¶
This section is empty.
Variables ¶
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.
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.
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.
var ( OperationMetadata_Type_name = map[int32]string{ 0: "TYPE_UNSPECIFIED", 1: "CREATE", 2: "DELETE", 3: "UPDATE", 4: "CHECK", } OperationMetadata_Type_value = map[string]int32{ "TYPE_UNSPECIFIED": 0, "CREATE": 1, "DELETE": 2, "UPDATE": 3, "CHECK": 4, } )
Enum value maps for OperationMetadata_Type.
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
Functions ¶
func RegisterEnvironmentsServer ¶
func RegisterEnvironmentsServer(s *grpc.Server, srv EnvironmentsServer)
func RegisterImageVersionsServer ¶
func RegisterImageVersionsServer(s *grpc.Server, srv ImageVersionsServer)
Types ¶
type CheckUpgradeResponse ¶
type CheckUpgradeResponse struct { // Output only. Url for a docker build log of an upgraded image. BuildLogUri string `protobuf:"bytes,1,opt,name=build_log_uri,json=buildLogUri,proto3" json:"build_log_uri,omitempty"` // Output only. Whether build has succeeded or failed on modules conflicts. ContainsPypiModulesConflict CheckUpgradeResponse_ConflictResult `` /* 234-byte string literal not displayed */ // Output only. Extract from a docker image build log containing information about pypi // modules conflicts. PypiConflictBuildLogExtract string `` /* 148-byte string literal not displayed */ // Composer image for which the build was happening. ImageVersion string `protobuf:"bytes,5,opt,name=image_version,json=imageVersion,proto3" json:"image_version,omitempty"` // Pypi dependencies specified in the environment configuration, at the time // when the build was triggered. PypiDependencies map[string]string `` /* 197-byte string literal not displayed */ // contains filtered or unexported fields }
Message containing information about the result of an upgrade check operation.
func (*CheckUpgradeResponse) Descriptor
deprecated
func (*CheckUpgradeResponse) Descriptor() ([]byte, []int)
Deprecated: Use CheckUpgradeResponse.ProtoReflect.Descriptor instead.
func (*CheckUpgradeResponse) GetBuildLogUri ¶
func (x *CheckUpgradeResponse) GetBuildLogUri() string
func (*CheckUpgradeResponse) GetContainsPypiModulesConflict ¶
func (x *CheckUpgradeResponse) GetContainsPypiModulesConflict() CheckUpgradeResponse_ConflictResult
func (*CheckUpgradeResponse) GetImageVersion ¶
func (x *CheckUpgradeResponse) GetImageVersion() string
func (*CheckUpgradeResponse) GetPypiConflictBuildLogExtract ¶
func (x *CheckUpgradeResponse) GetPypiConflictBuildLogExtract() string
func (*CheckUpgradeResponse) GetPypiDependencies ¶
func (x *CheckUpgradeResponse) GetPypiDependencies() map[string]string
func (*CheckUpgradeResponse) ProtoMessage ¶
func (*CheckUpgradeResponse) ProtoMessage()
func (*CheckUpgradeResponse) ProtoReflect ¶
func (x *CheckUpgradeResponse) ProtoReflect() protoreflect.Message
func (*CheckUpgradeResponse) Reset ¶
func (x *CheckUpgradeResponse) Reset()
func (*CheckUpgradeResponse) String ¶
func (x *CheckUpgradeResponse) String() string
type CheckUpgradeResponse_ConflictResult ¶
type CheckUpgradeResponse_ConflictResult int32
Whether there were python modules conflict during image build.
const ( // It is unknown whether build had conflicts or not. CheckUpgradeResponse_CONFLICT_RESULT_UNSPECIFIED CheckUpgradeResponse_ConflictResult = 0 // There were python packages conflicts. CheckUpgradeResponse_CONFLICT CheckUpgradeResponse_ConflictResult = 1 // There were no python packages conflicts. CheckUpgradeResponse_NO_CONFLICT CheckUpgradeResponse_ConflictResult = 2 )
func (CheckUpgradeResponse_ConflictResult) Descriptor ¶
func (CheckUpgradeResponse_ConflictResult) Descriptor() protoreflect.EnumDescriptor
func (CheckUpgradeResponse_ConflictResult) Enum ¶
func (x CheckUpgradeResponse_ConflictResult) Enum() *CheckUpgradeResponse_ConflictResult
func (CheckUpgradeResponse_ConflictResult) EnumDescriptor
deprecated
func (CheckUpgradeResponse_ConflictResult) EnumDescriptor() ([]byte, []int)
Deprecated: Use CheckUpgradeResponse_ConflictResult.Descriptor instead.
func (CheckUpgradeResponse_ConflictResult) Number ¶
func (x CheckUpgradeResponse_ConflictResult) Number() protoreflect.EnumNumber
func (CheckUpgradeResponse_ConflictResult) String ¶
func (x CheckUpgradeResponse_ConflictResult) String() string
func (CheckUpgradeResponse_ConflictResult) Type ¶
func (CheckUpgradeResponse_ConflictResult) Type() protoreflect.EnumType
type CreateEnvironmentRequest ¶
type CreateEnvironmentRequest struct { // The parent must be of the form // "projects/{projectId}/locations/{locationId}". Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` // The environment to create. Environment *Environment `protobuf:"bytes,2,opt,name=environment,proto3" json:"environment,omitempty"` // contains filtered or unexported fields }
Create a new environment.
func (*CreateEnvironmentRequest) Descriptor
deprecated
func (*CreateEnvironmentRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateEnvironmentRequest.ProtoReflect.Descriptor instead.
func (*CreateEnvironmentRequest) GetEnvironment ¶
func (x *CreateEnvironmentRequest) GetEnvironment() *Environment
func (*CreateEnvironmentRequest) GetParent ¶
func (x *CreateEnvironmentRequest) GetParent() string
func (*CreateEnvironmentRequest) ProtoMessage ¶
func (*CreateEnvironmentRequest) ProtoMessage()
func (*CreateEnvironmentRequest) ProtoReflect ¶
func (x *CreateEnvironmentRequest) ProtoReflect() protoreflect.Message
func (*CreateEnvironmentRequest) Reset ¶
func (x *CreateEnvironmentRequest) Reset()
func (*CreateEnvironmentRequest) String ¶
func (x *CreateEnvironmentRequest) String() string
type DatabaseConfig ¶
type DatabaseConfig struct { // Optional. Cloud SQL machine type used by Airflow database. // It has to be one of: db-n1-standard-2, db-n1-standard-4, db-n1-standard-8 // or db-n1-standard-16. If not specified, db-n1-standard-2 will be used. MachineType string `protobuf:"bytes,1,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"` // contains filtered or unexported fields }
The configuration of Cloud SQL instance that is used by the Apache Airflow software.
func (*DatabaseConfig) Descriptor
deprecated
func (*DatabaseConfig) Descriptor() ([]byte, []int)
Deprecated: Use DatabaseConfig.ProtoReflect.Descriptor instead.
func (*DatabaseConfig) GetMachineType ¶
func (x *DatabaseConfig) GetMachineType() string
func (*DatabaseConfig) ProtoMessage ¶
func (*DatabaseConfig) ProtoMessage()
func (*DatabaseConfig) ProtoReflect ¶
func (x *DatabaseConfig) ProtoReflect() protoreflect.Message
func (*DatabaseConfig) Reset ¶
func (x *DatabaseConfig) Reset()
func (*DatabaseConfig) String ¶
func (x *DatabaseConfig) String() string
type DeleteEnvironmentRequest ¶
type DeleteEnvironmentRequest struct { // The environment to delete, in the form: // "projects/{projectId}/locations/{locationId}/environments/{environmentId}" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Delete an environment.
func (*DeleteEnvironmentRequest) Descriptor
deprecated
func (*DeleteEnvironmentRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteEnvironmentRequest.ProtoReflect.Descriptor instead.
func (*DeleteEnvironmentRequest) GetName ¶
func (x *DeleteEnvironmentRequest) GetName() string
func (*DeleteEnvironmentRequest) ProtoMessage ¶
func (*DeleteEnvironmentRequest) ProtoMessage()
func (*DeleteEnvironmentRequest) ProtoReflect ¶
func (x *DeleteEnvironmentRequest) ProtoReflect() protoreflect.Message
func (*DeleteEnvironmentRequest) Reset ¶
func (x *DeleteEnvironmentRequest) Reset()
func (*DeleteEnvironmentRequest) String ¶
func (x *DeleteEnvironmentRequest) String() string
type EncryptionConfig ¶
type EncryptionConfig struct { // Optional. Customer-managed Encryption Key available through Google's Key Management // Service. Cannot be updated. // If not specified, Google-managed key will be used. KmsKeyName string `protobuf:"bytes,1,opt,name=kms_key_name,json=kmsKeyName,proto3" json:"kms_key_name,omitempty"` // contains filtered or unexported fields }
The encryption options for the Cloud Composer environment and its dependencies.
func (*EncryptionConfig) Descriptor
deprecated
func (*EncryptionConfig) Descriptor() ([]byte, []int)
Deprecated: Use EncryptionConfig.ProtoReflect.Descriptor instead.
func (*EncryptionConfig) GetKmsKeyName ¶
func (x *EncryptionConfig) GetKmsKeyName() string
func (*EncryptionConfig) ProtoMessage ¶
func (*EncryptionConfig) ProtoMessage()
func (*EncryptionConfig) ProtoReflect ¶
func (x *EncryptionConfig) ProtoReflect() protoreflect.Message
func (*EncryptionConfig) Reset ¶
func (x *EncryptionConfig) Reset()
func (*EncryptionConfig) String ¶
func (x *EncryptionConfig) String() string
type Environment ¶
type Environment struct { // The resource name of the environment, in the form: // "projects/{projectId}/locations/{locationId}/environments/{environmentId}" // // EnvironmentId must start with a lowercase letter followed by up to 63 // lowercase letters, numbers, or hyphens, and cannot end with a hyphen. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Configuration parameters for this environment. Config *EnvironmentConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"` // Output only. The UUID (Universally Unique IDentifier) associated with this environment. // This value is generated when the environment is created. Uuid string `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"` // The current state of the environment. State Environment_State `` /* 133-byte string literal not displayed */ // Output only. The time at which this environment was created. CreateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // Output only. The time at which this environment was last modified. UpdateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"` // Optional. User-defined labels for this environment. // The labels map can contain no more than 64 entries. Entries of the labels // map are UTF8 strings that comply with the following restrictions: // // * Keys must conform to regexp: [\p{Ll}\p{Lo}][\p{Ll}\p{Lo}\p{N}_-]{0,62} // * Values must conform to regexp: [\p{Ll}\p{Lo}\p{N}_-]{0,63} // * Both keys and values are additionally constrained to be <= 128 bytes in // size. Labels map[string]string `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
An environment for running orchestration tasks.
func (*Environment) Descriptor
deprecated
func (*Environment) Descriptor() ([]byte, []int)
Deprecated: Use Environment.ProtoReflect.Descriptor instead.
func (*Environment) GetConfig ¶
func (x *Environment) GetConfig() *EnvironmentConfig
func (*Environment) GetCreateTime ¶
func (x *Environment) GetCreateTime() *timestamppb.Timestamp
func (*Environment) GetLabels ¶
func (x *Environment) GetLabels() map[string]string
func (*Environment) GetName ¶
func (x *Environment) GetName() string
func (*Environment) GetState ¶
func (x *Environment) GetState() Environment_State
func (*Environment) GetUpdateTime ¶
func (x *Environment) GetUpdateTime() *timestamppb.Timestamp
func (*Environment) GetUuid ¶
func (x *Environment) GetUuid() string
func (*Environment) ProtoMessage ¶
func (*Environment) ProtoMessage()
func (*Environment) ProtoReflect ¶
func (x *Environment) ProtoReflect() protoreflect.Message
func (*Environment) Reset ¶
func (x *Environment) Reset()
func (*Environment) String ¶
func (x *Environment) String() string
type EnvironmentConfig ¶
type EnvironmentConfig struct { // Output only. The Kubernetes Engine cluster used to run this environment. GkeCluster string `protobuf:"bytes,1,opt,name=gke_cluster,json=gkeCluster,proto3" json:"gke_cluster,omitempty"` // Output only. The Cloud Storage prefix of the DAGs for this environment. Although Cloud // Storage objects reside in a flat namespace, a hierarchical file tree // can be simulated using "/"-delimited object name prefixes. DAG objects for // this environment reside in a simulated directory with the given prefix. DagGcsPrefix string `protobuf:"bytes,2,opt,name=dag_gcs_prefix,json=dagGcsPrefix,proto3" json:"dag_gcs_prefix,omitempty"` // The number of nodes in the Kubernetes Engine cluster that will be // used to run this environment. NodeCount int32 `protobuf:"varint,3,opt,name=node_count,json=nodeCount,proto3" json:"node_count,omitempty"` // The configuration settings for software inside the environment. SoftwareConfig *SoftwareConfig `protobuf:"bytes,4,opt,name=software_config,json=softwareConfig,proto3" json:"software_config,omitempty"` // The configuration used for the Kubernetes Engine cluster. NodeConfig *NodeConfig `protobuf:"bytes,5,opt,name=node_config,json=nodeConfig,proto3" json:"node_config,omitempty"` // The configuration used for the Private IP Cloud Composer environment. PrivateEnvironmentConfig *PrivateEnvironmentConfig `` /* 135-byte string literal not displayed */ // Optional. The network-level access control policy for the Airflow web server. If // unspecified, no network-level access restrictions will be applied. WebServerNetworkAccessControl *WebServerNetworkAccessControl `` /* 154-byte string literal not displayed */ // Optional. The configuration settings for Cloud SQL instance used internally by Apache // Airflow software. DatabaseConfig *DatabaseConfig `protobuf:"bytes,9,opt,name=database_config,json=databaseConfig,proto3" json:"database_config,omitempty"` // Optional. The configuration settings for the Airflow web server App Engine instance. WebServerConfig *WebServerConfig `protobuf:"bytes,10,opt,name=web_server_config,json=webServerConfig,proto3" json:"web_server_config,omitempty"` // Optional. The encryption options for the Cloud Composer environment // and its dependencies. Cannot be updated. EncryptionConfig *EncryptionConfig `protobuf:"bytes,11,opt,name=encryption_config,json=encryptionConfig,proto3" json:"encryption_config,omitempty"` // Output only. The URI of the Apache Airflow Web UI hosted within this environment (see // [Airflow web // interface](/composer/docs/how-to/accessing/airflow-web-interface)). AirflowUri string `protobuf:"bytes,6,opt,name=airflow_uri,json=airflowUri,proto3" json:"airflow_uri,omitempty"` // contains filtered or unexported fields }
Configuration information for an environment.
func (*EnvironmentConfig) Descriptor
deprecated
func (*EnvironmentConfig) Descriptor() ([]byte, []int)
Deprecated: Use EnvironmentConfig.ProtoReflect.Descriptor instead.
func (*EnvironmentConfig) GetAirflowUri ¶
func (x *EnvironmentConfig) GetAirflowUri() string
func (*EnvironmentConfig) GetDagGcsPrefix ¶
func (x *EnvironmentConfig) GetDagGcsPrefix() string
func (*EnvironmentConfig) GetDatabaseConfig ¶
func (x *EnvironmentConfig) GetDatabaseConfig() *DatabaseConfig
func (*EnvironmentConfig) GetEncryptionConfig ¶
func (x *EnvironmentConfig) GetEncryptionConfig() *EncryptionConfig
func (*EnvironmentConfig) GetGkeCluster ¶
func (x *EnvironmentConfig) GetGkeCluster() string
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) GetSoftwareConfig ¶
func (x *EnvironmentConfig) GetSoftwareConfig() *SoftwareConfig
func (*EnvironmentConfig) GetWebServerConfig ¶
func (x *EnvironmentConfig) GetWebServerConfig() *WebServerConfig
func (*EnvironmentConfig) GetWebServerNetworkAccessControl ¶
func (x *EnvironmentConfig) GetWebServerNetworkAccessControl() *WebServerNetworkAccessControl
func (*EnvironmentConfig) ProtoMessage ¶
func (*EnvironmentConfig) ProtoMessage()
func (*EnvironmentConfig) ProtoReflect ¶
func (x *EnvironmentConfig) ProtoReflect() protoreflect.Message
func (*EnvironmentConfig) Reset ¶
func (x *EnvironmentConfig) Reset()
func (*EnvironmentConfig) String ¶
func (x *EnvironmentConfig) String() string
type Environment_State ¶
type Environment_State int32
State of the environment.
const ( // The state of the environment is unknown. Environment_STATE_UNSPECIFIED Environment_State = 0 // The environment is in the process of being created. Environment_CREATING Environment_State = 1 // The environment is currently running and healthy. It is ready for use. Environment_RUNNING Environment_State = 2 // The environment is being updated. It remains usable but cannot receive // additional update requests or be deleted at this time. Environment_UPDATING Environment_State = 3 // The environment is undergoing deletion. It cannot be used. Environment_DELETING Environment_State = 4 // The environment has encountered an error and cannot be used. Environment_ERROR Environment_State = 5 )
func (Environment_State) Descriptor ¶
func (Environment_State) Descriptor() protoreflect.EnumDescriptor
func (Environment_State) Enum ¶
func (x Environment_State) Enum() *Environment_State
func (Environment_State) EnumDescriptor
deprecated
func (Environment_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use Environment_State.Descriptor instead.
func (Environment_State) Number ¶
func (x Environment_State) Number() protoreflect.EnumNumber
func (Environment_State) String ¶
func (x Environment_State) String() string
func (Environment_State) Type ¶
func (Environment_State) Type() protoreflect.EnumType
type EnvironmentsClient ¶
type EnvironmentsClient interface { // Create a new environment. CreateEnvironment(ctx context.Context, in *CreateEnvironmentRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) // Get an existing environment. GetEnvironment(ctx context.Context, in *GetEnvironmentRequest, opts ...grpc.CallOption) (*Environment, error) // List environments. ListEnvironments(ctx context.Context, in *ListEnvironmentsRequest, opts ...grpc.CallOption) (*ListEnvironmentsResponse, error) // Update an environment. UpdateEnvironment(ctx context.Context, in *UpdateEnvironmentRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) // Delete an environment. DeleteEnvironment(ctx context.Context, in *DeleteEnvironmentRequest, opts ...grpc.CallOption) (*longrunning.Operation, error) }
EnvironmentsClient is the client API for Environments service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewEnvironmentsClient ¶
func NewEnvironmentsClient(cc grpc.ClientConnInterface) EnvironmentsClient
type EnvironmentsServer ¶
type EnvironmentsServer interface { // Create a new environment. CreateEnvironment(context.Context, *CreateEnvironmentRequest) (*longrunning.Operation, error) // Get an existing environment. GetEnvironment(context.Context, *GetEnvironmentRequest) (*Environment, error) // List environments. ListEnvironments(context.Context, *ListEnvironmentsRequest) (*ListEnvironmentsResponse, error) // Update an environment. UpdateEnvironment(context.Context, *UpdateEnvironmentRequest) (*longrunning.Operation, error) // Delete an environment. DeleteEnvironment(context.Context, *DeleteEnvironmentRequest) (*longrunning.Operation, error) }
EnvironmentsServer is the server API for Environments service.
type GetEnvironmentRequest ¶
type GetEnvironmentRequest struct { // The resource name of the environment to get, in the form: // "projects/{projectId}/locations/{locationId}/environments/{environmentId}" Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Get an environment.
func (*GetEnvironmentRequest) Descriptor
deprecated
func (*GetEnvironmentRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetEnvironmentRequest.ProtoReflect.Descriptor instead.
func (*GetEnvironmentRequest) GetName ¶
func (x *GetEnvironmentRequest) GetName() string
func (*GetEnvironmentRequest) ProtoMessage ¶
func (*GetEnvironmentRequest) ProtoMessage()
func (*GetEnvironmentRequest) ProtoReflect ¶
func (x *GetEnvironmentRequest) ProtoReflect() protoreflect.Message
func (*GetEnvironmentRequest) Reset ¶
func (x *GetEnvironmentRequest) Reset()
func (*GetEnvironmentRequest) String ¶
func (x *GetEnvironmentRequest) String() string
type IPAllocationPolicy ¶
type IPAllocationPolicy struct { // Optional. Whether or not to enable Alias IPs in the GKE cluster. // If `true`, a VPC-native cluster is created. UseIpAliases bool `protobuf:"varint,1,opt,name=use_ip_aliases,json=useIpAliases,proto3" json:"use_ip_aliases,omitempty"` // Configuration of allocating IP addresses for pods in the GKE cluster. // // Types that are assignable to ClusterIpAllocation: // *IPAllocationPolicy_ClusterSecondaryRangeName // *IPAllocationPolicy_ClusterIpv4CidrBlock ClusterIpAllocation isIPAllocationPolicy_ClusterIpAllocation `protobuf_oneof:"cluster_ip_allocation"` // Configuration of allocating IP addresses for services in the GKE cluster. // // Types that are assignable to ServicesIpAllocation: // *IPAllocationPolicy_ServicesSecondaryRangeName // *IPAllocationPolicy_ServicesIpv4CidrBlock ServicesIpAllocation isIPAllocationPolicy_ServicesIpAllocation `protobuf_oneof:"services_ip_allocation"` // contains filtered or unexported fields }
Configuration for controlling how IPs are allocated in the GKE cluster running the Apache Airflow software.
func (*IPAllocationPolicy) Descriptor
deprecated
func (*IPAllocationPolicy) Descriptor() ([]byte, []int)
Deprecated: Use IPAllocationPolicy.ProtoReflect.Descriptor instead.
func (*IPAllocationPolicy) GetClusterIpAllocation ¶
func (m *IPAllocationPolicy) GetClusterIpAllocation() isIPAllocationPolicy_ClusterIpAllocation
func (*IPAllocationPolicy) GetClusterIpv4CidrBlock ¶
func (x *IPAllocationPolicy) GetClusterIpv4CidrBlock() string
func (*IPAllocationPolicy) GetClusterSecondaryRangeName ¶
func (x *IPAllocationPolicy) GetClusterSecondaryRangeName() string
func (*IPAllocationPolicy) GetServicesIpAllocation ¶
func (m *IPAllocationPolicy) GetServicesIpAllocation() isIPAllocationPolicy_ServicesIpAllocation
func (*IPAllocationPolicy) GetServicesIpv4CidrBlock ¶
func (x *IPAllocationPolicy) GetServicesIpv4CidrBlock() string
func (*IPAllocationPolicy) GetServicesSecondaryRangeName ¶
func (x *IPAllocationPolicy) GetServicesSecondaryRangeName() string
func (*IPAllocationPolicy) GetUseIpAliases ¶
func (x *IPAllocationPolicy) GetUseIpAliases() bool
func (*IPAllocationPolicy) ProtoMessage ¶
func (*IPAllocationPolicy) ProtoMessage()
func (*IPAllocationPolicy) ProtoReflect ¶
func (x *IPAllocationPolicy) ProtoReflect() protoreflect.Message
func (*IPAllocationPolicy) Reset ¶
func (x *IPAllocationPolicy) Reset()
func (*IPAllocationPolicy) String ¶
func (x *IPAllocationPolicy) String() string
type IPAllocationPolicy_ClusterIpv4CidrBlock ¶
type IPAllocationPolicy_ClusterIpv4CidrBlock struct { // Optional. The IP address range used to allocate IP addresses to pods in // the GKE cluster. // // 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](http://en.wikipedia.org/wiki/Classless_Inter-Domain_Routing) // notation (e.g. `10.96.0.0/14`) from the RFC-1918 private networks (e.g. // `10.0.0.0/8`, `172.16.0.0/12`, `192.168.0.0/16`) to pick a specific range // to use. ClusterIpv4CidrBlock string `protobuf:"bytes,4,opt,name=cluster_ipv4_cidr_block,json=clusterIpv4CidrBlock,proto3,oneof"` }
type IPAllocationPolicy_ClusterSecondaryRangeName ¶
type IPAllocationPolicy_ClusterSecondaryRangeName struct { // Optional. The name of the GKE cluster's secondary range used to allocate // IP addresses to pods. // // This field is applicable only when `use_ip_aliases` is true. ClusterSecondaryRangeName string `protobuf:"bytes,2,opt,name=cluster_secondary_range_name,json=clusterSecondaryRangeName,proto3,oneof"` }
type IPAllocationPolicy_ServicesIpv4CidrBlock ¶
type IPAllocationPolicy_ServicesIpv4CidrBlock struct { // Optional. The IP address range of the services IP addresses in this // GKE cluster. // // 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](http://en.wikipedia.org/wiki/Classless_Inter-Domain_Routing) // notation (e.g. `10.96.0.0/14`) from the RFC-1918 private networks (e.g. // `10.0.0.0/8`, `172.16.0.0/12`, `192.168.0.0/16`) to pick a specific range // to use. ServicesIpv4CidrBlock string `protobuf:"bytes,5,opt,name=services_ipv4_cidr_block,json=servicesIpv4CidrBlock,proto3,oneof"` }
type IPAllocationPolicy_ServicesSecondaryRangeName ¶
type IPAllocationPolicy_ServicesSecondaryRangeName struct { // Optional. The name of the services' secondary range used to allocate // IP addresses to the GKE cluster. // // This field is applicable only when `use_ip_aliases` is true. ServicesSecondaryRangeName string `protobuf:"bytes,3,opt,name=services_secondary_range_name,json=servicesSecondaryRangeName,proto3,oneof"` }
type ImageVersion ¶
type ImageVersion struct { // The string identifier of the ImageVersion, in the form: // "composer-x.y.z-airflow-a.b(.c)" ImageVersionId string `protobuf:"bytes,1,opt,name=image_version_id,json=imageVersionId,proto3" json:"image_version_id,omitempty"` // Whether this is the default ImageVersion used by Composer during // environment creation if no input ImageVersion is specified. IsDefault bool `protobuf:"varint,2,opt,name=is_default,json=isDefault,proto3" json:"is_default,omitempty"` // supported python versions SupportedPythonVersions []string `` /* 132-byte string literal not displayed */ // The date of the version release. ReleaseDate *date.Date `protobuf:"bytes,4,opt,name=release_date,json=releaseDate,proto3" json:"release_date,omitempty"` // Whether it is impossible to create an environment with the image version. CreationDisabled bool `protobuf:"varint,5,opt,name=creation_disabled,json=creationDisabled,proto3" json:"creation_disabled,omitempty"` // Whether it is impossible to upgrade an environment running with the image // version. UpgradeDisabled bool `protobuf:"varint,6,opt,name=upgrade_disabled,json=upgradeDisabled,proto3" json:"upgrade_disabled,omitempty"` // contains filtered or unexported fields }
ImageVersion information
func (*ImageVersion) Descriptor
deprecated
func (*ImageVersion) Descriptor() ([]byte, []int)
Deprecated: Use ImageVersion.ProtoReflect.Descriptor instead.
func (*ImageVersion) GetCreationDisabled ¶
func (x *ImageVersion) GetCreationDisabled() bool
func (*ImageVersion) GetImageVersionId ¶
func (x *ImageVersion) GetImageVersionId() string
func (*ImageVersion) GetIsDefault ¶
func (x *ImageVersion) GetIsDefault() bool
func (*ImageVersion) GetReleaseDate ¶
func (x *ImageVersion) GetReleaseDate() *date.Date
func (*ImageVersion) GetSupportedPythonVersions ¶
func (x *ImageVersion) GetSupportedPythonVersions() []string
func (*ImageVersion) GetUpgradeDisabled ¶
func (x *ImageVersion) GetUpgradeDisabled() bool
func (*ImageVersion) ProtoMessage ¶
func (*ImageVersion) ProtoMessage()
func (*ImageVersion) ProtoReflect ¶
func (x *ImageVersion) ProtoReflect() protoreflect.Message
func (*ImageVersion) Reset ¶
func (x *ImageVersion) Reset()
func (*ImageVersion) String ¶
func (x *ImageVersion) String() string
type ImageVersionsClient ¶
type ImageVersionsClient interface { // List ImageVersions for provided location. ListImageVersions(ctx context.Context, in *ListImageVersionsRequest, opts ...grpc.CallOption) (*ListImageVersionsResponse, error) }
ImageVersionsClient is the client API for ImageVersions service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewImageVersionsClient ¶
func NewImageVersionsClient(cc grpc.ClientConnInterface) ImageVersionsClient
type ImageVersionsServer ¶
type ImageVersionsServer interface { // List ImageVersions for provided location. ListImageVersions(context.Context, *ListImageVersionsRequest) (*ListImageVersionsResponse, error) }
ImageVersionsServer is the server API for ImageVersions service.
type ListEnvironmentsRequest ¶
type ListEnvironmentsRequest struct { // List environments in the given project and location, in the form: // "projects/{projectId}/locations/{locationId}" Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` // The maximum number of environments to return. PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // The next_page_token value returned from a previous List request, if any. PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // contains filtered or unexported fields }
List environments in a project and location.
func (*ListEnvironmentsRequest) Descriptor
deprecated
func (*ListEnvironmentsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListEnvironmentsRequest.ProtoReflect.Descriptor instead.
func (*ListEnvironmentsRequest) GetPageSize ¶
func (x *ListEnvironmentsRequest) GetPageSize() int32
func (*ListEnvironmentsRequest) GetPageToken ¶
func (x *ListEnvironmentsRequest) GetPageToken() string
func (*ListEnvironmentsRequest) GetParent ¶
func (x *ListEnvironmentsRequest) GetParent() string
func (*ListEnvironmentsRequest) ProtoMessage ¶
func (*ListEnvironmentsRequest) ProtoMessage()
func (*ListEnvironmentsRequest) ProtoReflect ¶
func (x *ListEnvironmentsRequest) ProtoReflect() protoreflect.Message
func (*ListEnvironmentsRequest) Reset ¶
func (x *ListEnvironmentsRequest) Reset()
func (*ListEnvironmentsRequest) String ¶
func (x *ListEnvironmentsRequest) String() string
type ListEnvironmentsResponse ¶
type ListEnvironmentsResponse struct { // The list of environments returned by a ListEnvironmentsRequest. Environments []*Environment `protobuf:"bytes,1,rep,name=environments,proto3" json:"environments,omitempty"` // The page token used to query for the next page if one exists. NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
The environments in a project and location.
func (*ListEnvironmentsResponse) Descriptor
deprecated
func (*ListEnvironmentsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListEnvironmentsResponse.ProtoReflect.Descriptor instead.
func (*ListEnvironmentsResponse) GetEnvironments ¶
func (x *ListEnvironmentsResponse) GetEnvironments() []*Environment
func (*ListEnvironmentsResponse) GetNextPageToken ¶
func (x *ListEnvironmentsResponse) GetNextPageToken() string
func (*ListEnvironmentsResponse) ProtoMessage ¶
func (*ListEnvironmentsResponse) ProtoMessage()
func (*ListEnvironmentsResponse) ProtoReflect ¶
func (x *ListEnvironmentsResponse) ProtoReflect() protoreflect.Message
func (*ListEnvironmentsResponse) Reset ¶
func (x *ListEnvironmentsResponse) Reset()
func (*ListEnvironmentsResponse) String ¶
func (x *ListEnvironmentsResponse) String() string
type ListImageVersionsRequest ¶
type ListImageVersionsRequest struct { // List ImageVersions in the given project and location, in the form: // "projects/{projectId}/locations/{locationId}" Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"` // The maximum number of image_versions to return. PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"` // The next_page_token value returned from a previous List request, if any. PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"` // Whether or not image versions from old releases should be included. IncludePastReleases bool `protobuf:"varint,4,opt,name=include_past_releases,json=includePastReleases,proto3" json:"include_past_releases,omitempty"` // contains filtered or unexported fields }
List ImageVersions in a project and location.
func (*ListImageVersionsRequest) Descriptor
deprecated
func (*ListImageVersionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListImageVersionsRequest.ProtoReflect.Descriptor instead.
func (*ListImageVersionsRequest) GetIncludePastReleases ¶
func (x *ListImageVersionsRequest) GetIncludePastReleases() bool
func (*ListImageVersionsRequest) GetPageSize ¶
func (x *ListImageVersionsRequest) GetPageSize() int32
func (*ListImageVersionsRequest) GetPageToken ¶
func (x *ListImageVersionsRequest) GetPageToken() string
func (*ListImageVersionsRequest) GetParent ¶
func (x *ListImageVersionsRequest) GetParent() string
func (*ListImageVersionsRequest) ProtoMessage ¶
func (*ListImageVersionsRequest) ProtoMessage()
func (*ListImageVersionsRequest) ProtoReflect ¶
func (x *ListImageVersionsRequest) ProtoReflect() protoreflect.Message
func (*ListImageVersionsRequest) Reset ¶
func (x *ListImageVersionsRequest) Reset()
func (*ListImageVersionsRequest) String ¶
func (x *ListImageVersionsRequest) String() string
type ListImageVersionsResponse ¶
type ListImageVersionsResponse struct { // The list of supported ImageVersions in a location. ImageVersions []*ImageVersion `protobuf:"bytes,1,rep,name=image_versions,json=imageVersions,proto3" json:"image_versions,omitempty"` // The page token used to query for the next page if one exists. NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
The ImageVersions in a project and location.
func (*ListImageVersionsResponse) Descriptor
deprecated
func (*ListImageVersionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListImageVersionsResponse.ProtoReflect.Descriptor instead.
func (*ListImageVersionsResponse) GetImageVersions ¶
func (x *ListImageVersionsResponse) GetImageVersions() []*ImageVersion
func (*ListImageVersionsResponse) GetNextPageToken ¶
func (x *ListImageVersionsResponse) GetNextPageToken() string
func (*ListImageVersionsResponse) ProtoMessage ¶
func (*ListImageVersionsResponse) ProtoMessage()
func (*ListImageVersionsResponse) ProtoReflect ¶
func (x *ListImageVersionsResponse) ProtoReflect() protoreflect.Message
func (*ListImageVersionsResponse) Reset ¶
func (x *ListImageVersionsResponse) Reset()
func (*ListImageVersionsResponse) String ¶
func (x *ListImageVersionsResponse) String() string
type NodeConfig ¶
type NodeConfig struct { // Optional. The Compute Engine [zone](/compute/docs/regions-zones) in which // to deploy the VMs used to run the Apache Airflow software, specified as a // [relative resource // name](/apis/design/resource_names#relative_resource_name). For example: // "projects/{projectId}/zones/{zoneId}". // // This `location` must belong to the enclosing environment's project and // location. If both this field and `nodeConfig.machineType` are specified, // `nodeConfig.machineType` must belong to this `location`; if both are // unspecified, the service will pick a zone in the Compute Engine region // corresponding to the Cloud Composer location, and propagate that choice to // both fields. If only one field (`location` or `nodeConfig.machineType`) is // specified, the location information from the specified field will be // propagated to the unspecified field. Location string `protobuf:"bytes,1,opt,name=location,proto3" json:"location,omitempty"` // Optional. The Compute Engine // [machine type](/compute/docs/machine-types) used for cluster instances, // specified as a // [relative resource // name](/apis/design/resource_names#relative_resource_name). For example: // "projects/{projectId}/zones/{zoneId}/machineTypes/{machineTypeId}". // // The `machineType` must belong to the enclosing environment's project and // location. If both this field and `nodeConfig.location` are specified, // this `machineType` must belong to the `nodeConfig.location`; if both are // unspecified, the service will pick a zone in the Compute Engine region // corresponding to the Cloud Composer location, and propagate that choice to // both fields. If exactly one of this field and `nodeConfig.location` is // specified, the location information from the specified field will be // propagated to the unspecified field. // // The `machineTypeId` must not be a [shared-core machine // type](/compute/docs/machine-types#sharedcore). // // If this field is unspecified, the `machineTypeId` defaults // to "n1-standard-1". MachineType string `protobuf:"bytes,2,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"` // Optional. The Compute Engine network to be used for machine // communications, specified as a // [relative resource // name](/apis/design/resource_names#relative_resource_name). For example: // "projects/{projectId}/global/networks/{networkId}". // // If unspecified, the "default" network ID in the environment's project is // used. If a [Custom Subnet Network](/vpc/docs/vpc#vpc_networks_and_subnets) // is provided, `nodeConfig.subnetwork` must also be provided. For // [Shared VPC](/vpc/docs/shared-vpc) subnetwork requirements, see // `nodeConfig.subnetwork`. Network string `protobuf:"bytes,3,opt,name=network,proto3" json:"network,omitempty"` // Optional. The Compute Engine subnetwork to be used for machine // communications, specified as a // [relative resource // name](/apis/design/resource_names#relative_resource_name). For example: // "projects/{projectId}/regions/{regionId}/subnetworks/{subnetworkId}" // // If a subnetwork is provided, `nodeConfig.network` must also be provided, // and the subnetwork must belong to the enclosing environment's project and // location. Subnetwork string `protobuf:"bytes,4,opt,name=subnetwork,proto3" json:"subnetwork,omitempty"` // Optional. The disk size in GB used for node VMs. Minimum size is 20GB. // If unspecified, defaults to 100GB. Cannot be updated. DiskSizeGb int32 `protobuf:"varint,5,opt,name=disk_size_gb,json=diskSizeGb,proto3" json:"disk_size_gb,omitempty"` // Optional. The set of Google API scopes to be made available on all // node VMs. If `oauth_scopes` is empty, defaults to // ["https://www.googleapis.com/auth/cloud-platform"]. Cannot be updated. OauthScopes []string `protobuf:"bytes,6,rep,name=oauth_scopes,json=oauthScopes,proto3" json:"oauth_scopes,omitempty"` // Optional. The Google Cloud Platform Service Account to be used by the node // VMs. If a service account is not specified, the "default" Compute Engine // service account is used. Cannot be updated. ServiceAccount string `protobuf:"bytes,7,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"` // Optional. The list of instance tags applied to all node VMs. Tags are used // to identify valid sources or targets for network firewalls. Each tag within // the list must comply with [RFC1035](https://www.ietf.org/rfc/rfc1035.txt). // Cannot be updated. Tags []string `protobuf:"bytes,8,rep,name=tags,proto3" json:"tags,omitempty"` // Optional. The configuration for controlling how IPs are allocated in the GKE cluster. IpAllocationPolicy *IPAllocationPolicy `protobuf:"bytes,9,opt,name=ip_allocation_policy,json=ipAllocationPolicy,proto3" json:"ip_allocation_policy,omitempty"` // contains filtered or unexported fields }
The configuration information for the Kubernetes Engine nodes running the Apache Airflow software.
func (*NodeConfig) Descriptor
deprecated
func (*NodeConfig) Descriptor() ([]byte, []int)
Deprecated: Use NodeConfig.ProtoReflect.Descriptor instead.
func (*NodeConfig) GetDiskSizeGb ¶
func (x *NodeConfig) GetDiskSizeGb() int32
func (*NodeConfig) GetIpAllocationPolicy ¶
func (x *NodeConfig) GetIpAllocationPolicy() *IPAllocationPolicy
func (*NodeConfig) GetLocation ¶
func (x *NodeConfig) GetLocation() string
func (*NodeConfig) GetMachineType ¶
func (x *NodeConfig) GetMachineType() string
func (*NodeConfig) GetNetwork ¶
func (x *NodeConfig) GetNetwork() string
func (*NodeConfig) GetOauthScopes ¶
func (x *NodeConfig) GetOauthScopes() []string
func (*NodeConfig) GetServiceAccount ¶
func (x *NodeConfig) GetServiceAccount() string
func (*NodeConfig) GetSubnetwork ¶
func (x *NodeConfig) GetSubnetwork() string
func (*NodeConfig) GetTags ¶
func (x *NodeConfig) GetTags() []string
func (*NodeConfig) ProtoMessage ¶
func (*NodeConfig) ProtoMessage()
func (*NodeConfig) ProtoReflect ¶
func (x *NodeConfig) ProtoReflect() protoreflect.Message
func (*NodeConfig) Reset ¶
func (x *NodeConfig) Reset()
func (*NodeConfig) String ¶
func (x *NodeConfig) String() string
type OperationMetadata ¶
type OperationMetadata struct { // Output only. The current operation state. State OperationMetadata_State `` /* 139-byte string literal not displayed */ // Output only. The type of operation being performed. OperationType OperationMetadata_Type `` /* 175-byte string literal not displayed */ // Output only. The resource being operated on, as a [relative resource name]( // /apis/design/resource_names#relative_resource_name). Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"` // Output only. The UUID of the resource being operated on. ResourceUuid string `protobuf:"bytes,4,opt,name=resource_uuid,json=resourceUuid,proto3" json:"resource_uuid,omitempty"` // Output only. The time the operation was submitted to the server. CreateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // Output only. The time when the operation terminated, regardless of its success. // This field is unset if the operation is still ongoing. EndTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` // contains filtered or unexported fields }
Metadata describing an operation.
func (*OperationMetadata) Descriptor
deprecated
func (*OperationMetadata) Descriptor() ([]byte, []int)
Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.
func (*OperationMetadata) GetCreateTime ¶
func (x *OperationMetadata) GetCreateTime() *timestamppb.Timestamp
func (*OperationMetadata) GetEndTime ¶
func (x *OperationMetadata) GetEndTime() *timestamppb.Timestamp
func (*OperationMetadata) GetOperationType ¶
func (x *OperationMetadata) GetOperationType() OperationMetadata_Type
func (*OperationMetadata) GetResource ¶
func (x *OperationMetadata) GetResource() string
func (*OperationMetadata) GetResourceUuid ¶
func (x *OperationMetadata) GetResourceUuid() string
func (*OperationMetadata) GetState ¶
func (x *OperationMetadata) GetState() OperationMetadata_State
func (*OperationMetadata) ProtoMessage ¶
func (*OperationMetadata) ProtoMessage()
func (*OperationMetadata) ProtoReflect ¶
func (x *OperationMetadata) ProtoReflect() protoreflect.Message
func (*OperationMetadata) Reset ¶
func (x *OperationMetadata) Reset()
func (*OperationMetadata) String ¶
func (x *OperationMetadata) String() string
type OperationMetadata_State ¶
type OperationMetadata_State int32
An enum describing the overall state of an operation.
const ( // Unused. OperationMetadata_STATE_UNSPECIFIED OperationMetadata_State = 0 // The operation has been created but is not yet started. OperationMetadata_PENDING OperationMetadata_State = 1 // The operation is underway. OperationMetadata_RUNNING OperationMetadata_State = 2 // The operation completed successfully. OperationMetadata_SUCCEEDED OperationMetadata_State = 3 OperationMetadata_SUCCESSFUL OperationMetadata_State = 3 // The operation is no longer running but did not succeed. OperationMetadata_FAILED OperationMetadata_State = 4 )
func (OperationMetadata_State) Descriptor ¶
func (OperationMetadata_State) Descriptor() protoreflect.EnumDescriptor
func (OperationMetadata_State) Enum ¶
func (x OperationMetadata_State) Enum() *OperationMetadata_State
func (OperationMetadata_State) EnumDescriptor
deprecated
func (OperationMetadata_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use OperationMetadata_State.Descriptor instead.
func (OperationMetadata_State) Number ¶
func (x OperationMetadata_State) Number() protoreflect.EnumNumber
func (OperationMetadata_State) String ¶
func (x OperationMetadata_State) String() string
func (OperationMetadata_State) Type ¶
func (OperationMetadata_State) Type() protoreflect.EnumType
type OperationMetadata_Type ¶
type OperationMetadata_Type int32
Type of longrunning operation.
const ( // Unused. OperationMetadata_TYPE_UNSPECIFIED OperationMetadata_Type = 0 // A resource creation operation. OperationMetadata_CREATE OperationMetadata_Type = 1 // A resource deletion operation. OperationMetadata_DELETE OperationMetadata_Type = 2 // A resource update operation. OperationMetadata_UPDATE OperationMetadata_Type = 3 // A resource check operation. OperationMetadata_CHECK OperationMetadata_Type = 4 )
func (OperationMetadata_Type) Descriptor ¶
func (OperationMetadata_Type) Descriptor() protoreflect.EnumDescriptor
func (OperationMetadata_Type) Enum ¶
func (x OperationMetadata_Type) Enum() *OperationMetadata_Type
func (OperationMetadata_Type) EnumDescriptor
deprecated
func (OperationMetadata_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use OperationMetadata_Type.Descriptor instead.
func (OperationMetadata_Type) Number ¶
func (x OperationMetadata_Type) Number() protoreflect.EnumNumber
func (OperationMetadata_Type) String ¶
func (x OperationMetadata_Type) String() string
func (OperationMetadata_Type) Type ¶
func (OperationMetadata_Type) Type() protoreflect.EnumType
type PrivateClusterConfig ¶
type PrivateClusterConfig struct { // Optional. If `true`, access to the public endpoint of the GKE cluster is // denied. EnablePrivateEndpoint bool `` /* 127-byte string literal not displayed */ // Optional. The CIDR block from which IPv4 range for GKE master will be reserved. If // left blank, the default value of '172.16.0.0/23' is used. MasterIpv4CidrBlock string `protobuf:"bytes,2,opt,name=master_ipv4_cidr_block,json=masterIpv4CidrBlock,proto3" json:"master_ipv4_cidr_block,omitempty"` // Output only. The IP range in CIDR notation to use for the hosted master network. This // range is used for assigning internal IP addresses to the GKE cluster // master or set of masters and to the internal load balancer virtual IP. // This range must not overlap with any other ranges in use // within the cluster's network. MasterIpv4ReservedRange string `` /* 134-byte string literal not displayed */ // contains filtered or unexported fields }
Configuration options for the private GKE cluster in a Cloud Composer environment.
func (*PrivateClusterConfig) Descriptor
deprecated
func (*PrivateClusterConfig) Descriptor() ([]byte, []int)
Deprecated: Use PrivateClusterConfig.ProtoReflect.Descriptor instead.
func (*PrivateClusterConfig) GetEnablePrivateEndpoint ¶
func (x *PrivateClusterConfig) GetEnablePrivateEndpoint() bool
func (*PrivateClusterConfig) GetMasterIpv4CidrBlock ¶
func (x *PrivateClusterConfig) GetMasterIpv4CidrBlock() string
func (*PrivateClusterConfig) GetMasterIpv4ReservedRange ¶
func (x *PrivateClusterConfig) GetMasterIpv4ReservedRange() string
func (*PrivateClusterConfig) ProtoMessage ¶
func (*PrivateClusterConfig) ProtoMessage()
func (*PrivateClusterConfig) ProtoReflect ¶
func (x *PrivateClusterConfig) ProtoReflect() protoreflect.Message
func (*PrivateClusterConfig) Reset ¶
func (x *PrivateClusterConfig) Reset()
func (*PrivateClusterConfig) String ¶
func (x *PrivateClusterConfig) String() string
type PrivateEnvironmentConfig ¶
type PrivateEnvironmentConfig struct { // Optional. If `true`, a Private IP Cloud Composer environment is created. // If this field is set to true, `IPAllocationPolicy.use_ip_aliases` must be // set to true. EnablePrivateEnvironment bool `` /* 136-byte string literal not displayed */ // Optional. Configuration for the private GKE cluster for a Private IP // Cloud Composer environment. PrivateClusterConfig *PrivateClusterConfig `protobuf:"bytes,2,opt,name=private_cluster_config,json=privateClusterConfig,proto3" json:"private_cluster_config,omitempty"` // Optional. The CIDR block from which IP range for web server will be reserved. Needs // to be disjoint from `private_cluster_config.master_ipv4_cidr_block` and // `cloud_sql_ipv4_cidr_block`. WebServerIpv4CidrBlock string `` /* 133-byte string literal not displayed */ // Optional. The CIDR block from which IP range in tenant project will be reserved for // Cloud SQL. Needs to be disjoint from `web_server_ipv4_cidr_block`. CloudSqlIpv4CidrBlock string `` /* 130-byte string literal not displayed */ // Output only. The IP range reserved for the tenant project's App Engine VMs. WebServerIpv4ReservedRange string `` /* 145-byte string literal not displayed */ // contains filtered or unexported fields }
The configuration information for configuring a Private IP Cloud Composer environment.
func (*PrivateEnvironmentConfig) Descriptor
deprecated
func (*PrivateEnvironmentConfig) Descriptor() ([]byte, []int)
Deprecated: Use PrivateEnvironmentConfig.ProtoReflect.Descriptor instead.
func (*PrivateEnvironmentConfig) GetCloudSqlIpv4CidrBlock ¶
func (x *PrivateEnvironmentConfig) GetCloudSqlIpv4CidrBlock() string
func (*PrivateEnvironmentConfig) GetEnablePrivateEnvironment ¶
func (x *PrivateEnvironmentConfig) GetEnablePrivateEnvironment() bool
func (*PrivateEnvironmentConfig) GetPrivateClusterConfig ¶
func (x *PrivateEnvironmentConfig) GetPrivateClusterConfig() *PrivateClusterConfig
func (*PrivateEnvironmentConfig) GetWebServerIpv4CidrBlock ¶
func (x *PrivateEnvironmentConfig) GetWebServerIpv4CidrBlock() string
func (*PrivateEnvironmentConfig) GetWebServerIpv4ReservedRange ¶
func (x *PrivateEnvironmentConfig) GetWebServerIpv4ReservedRange() string
func (*PrivateEnvironmentConfig) ProtoMessage ¶
func (*PrivateEnvironmentConfig) ProtoMessage()
func (*PrivateEnvironmentConfig) ProtoReflect ¶
func (x *PrivateEnvironmentConfig) ProtoReflect() protoreflect.Message
func (*PrivateEnvironmentConfig) Reset ¶
func (x *PrivateEnvironmentConfig) Reset()
func (*PrivateEnvironmentConfig) String ¶
func (x *PrivateEnvironmentConfig) String() string
type SoftwareConfig ¶
type SoftwareConfig struct { // The version of the software running in the environment. // This encapsulates both the version of Cloud Composer functionality and the // version of Apache Airflow. It must match the regular expression // `composer-([0-9]+\.[0-9]+\.[0-9]+|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 version is a // [semantic version](https://semver.org) or `latest`. When the patch version // is omitted, the current Cloud Composer patch version is selected. // When `latest` is provided instead of an explicit version number, // the server replaces `latest` with the current Cloud Composer version // and stores that version number in the same field. // // The portion of the image version that follows *airflow-* is an // official Apache Airflow repository // [release name](https://github.com/apache/incubator-airflow/releases). // // See also [Version // List](/composer/docs/concepts/versioning/composer-versions). ImageVersion string `protobuf:"bytes,1,opt,name=image_version,json=imageVersion,proto3" json:"image_version,omitempty"` // Optional. Apache Airflow configuration properties to override. // // Property keys contain the section and property names, separated by a // hyphen, for example "core-dags_are_paused_at_creation". Section names must // not contain hyphens ("-"), opening square brackets ("["), or closing // square brackets ("]"). The property name must not be empty and must not // contain an equals sign ("=") or semicolon (";"). Section and property names // must not contain a period ("."). Apache Airflow configuration property // names must be written in // [snake_case](https://en.wikipedia.org/wiki/Snake_case). Property values can // contain any character, and can be written in any lower/upper case format. // // Certain Apache Airflow configuration property values are // [blocked](/composer/docs/concepts/airflow-configurations), // and cannot be overridden. AirflowConfigOverrides map[string]string `` /* 217-byte string literal not displayed */ // Optional. Custom Python Package Index (PyPI) packages to be installed in // the environment. // // Keys refer to the lowercase package name such as "numpy" // and values are the lowercase extras and version specifier such as // "==1.12.0", "[devel,gcp_api]", or "[devel]>=1.8.2, <1.9.2". To specify a // package without pinning it to a version specifier, use the empty string as // the value. PypiPackages map[string]string `` /* 185-byte string literal not displayed */ // Optional. Additional environment variables to provide to the Apache Airflow // scheduler, worker, and webserver processes. // // Environment variable names must match the regular expression // `[a-zA-Z_][a-zA-Z0-9_]*`. They cannot specify Apache Airflow // software configuration overrides (they cannot match the regular expression // `AIRFLOW__[A-Z0-9_]+__[A-Z0-9_]+`), and they cannot match any of the // following reserved names: // // * `AIRFLOW_HOME` // * `C_FORCE_ROOT` // * `CONTAINER_NAME` // * `DAGS_FOLDER` // * `GCP_PROJECT` // * `GCS_BUCKET` // * `GKE_CLUSTER_NAME` // * `SQL_DATABASE` // * `SQL_INSTANCE` // * `SQL_PASSWORD` // * `SQL_PROJECT` // * `SQL_REGION` // * `SQL_USER` EnvVariables map[string]string `` /* 185-byte string literal not displayed */ // Optional. The major version of Python used to run the Apache Airflow // scheduler, worker, and webserver processes. // // Can be set to '2' or '3'. If not specified, the default is '3'. Cannot be // updated. PythonVersion string `protobuf:"bytes,6,opt,name=python_version,json=pythonVersion,proto3" json:"python_version,omitempty"` // contains filtered or unexported fields }
Specifies the selection and configuration of software inside the environment.
func (*SoftwareConfig) Descriptor
deprecated
func (*SoftwareConfig) Descriptor() ([]byte, []int)
Deprecated: Use SoftwareConfig.ProtoReflect.Descriptor instead.
func (*SoftwareConfig) GetAirflowConfigOverrides ¶
func (x *SoftwareConfig) GetAirflowConfigOverrides() map[string]string
func (*SoftwareConfig) GetEnvVariables ¶
func (x *SoftwareConfig) GetEnvVariables() map[string]string
func (*SoftwareConfig) GetImageVersion ¶
func (x *SoftwareConfig) GetImageVersion() string
func (*SoftwareConfig) GetPypiPackages ¶
func (x *SoftwareConfig) GetPypiPackages() map[string]string
func (*SoftwareConfig) GetPythonVersion ¶
func (x *SoftwareConfig) GetPythonVersion() string
func (*SoftwareConfig) ProtoMessage ¶
func (*SoftwareConfig) ProtoMessage()
func (*SoftwareConfig) ProtoReflect ¶
func (x *SoftwareConfig) ProtoReflect() protoreflect.Message
func (*SoftwareConfig) Reset ¶
func (x *SoftwareConfig) Reset()
func (*SoftwareConfig) String ¶
func (x *SoftwareConfig) String() string
type UnimplementedEnvironmentsServer ¶
type UnimplementedEnvironmentsServer struct { }
UnimplementedEnvironmentsServer can be embedded to have forward compatible implementations.
func (*UnimplementedEnvironmentsServer) CreateEnvironment ¶
func (*UnimplementedEnvironmentsServer) CreateEnvironment(context.Context, *CreateEnvironmentRequest) (*longrunning.Operation, error)
func (*UnimplementedEnvironmentsServer) DeleteEnvironment ¶
func (*UnimplementedEnvironmentsServer) DeleteEnvironment(context.Context, *DeleteEnvironmentRequest) (*longrunning.Operation, error)
func (*UnimplementedEnvironmentsServer) GetEnvironment ¶
func (*UnimplementedEnvironmentsServer) GetEnvironment(context.Context, *GetEnvironmentRequest) (*Environment, error)
func (*UnimplementedEnvironmentsServer) ListEnvironments ¶
func (*UnimplementedEnvironmentsServer) ListEnvironments(context.Context, *ListEnvironmentsRequest) (*ListEnvironmentsResponse, error)
func (*UnimplementedEnvironmentsServer) UpdateEnvironment ¶
func (*UnimplementedEnvironmentsServer) UpdateEnvironment(context.Context, *UpdateEnvironmentRequest) (*longrunning.Operation, error)
type UnimplementedImageVersionsServer ¶
type UnimplementedImageVersionsServer struct { }
UnimplementedImageVersionsServer can be embedded to have forward compatible implementations.
func (*UnimplementedImageVersionsServer) ListImageVersions ¶
func (*UnimplementedImageVersionsServer) ListImageVersions(context.Context, *ListImageVersionsRequest) (*ListImageVersionsResponse, error)
type UpdateEnvironmentRequest ¶
type UpdateEnvironmentRequest struct { // The relative resource name of the environment to update, in the form: // "projects/{projectId}/locations/{locationId}/environments/{environmentId}" Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // A patch environment. Fields specified by the `updateMask` will be copied // from the patch environment into the environment under update. Environment *Environment `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"` // Required. A comma-separated list of paths, relative to `Environment`, of // fields to update. // For example, to set the version of scikit-learn to install in the // environment to 0.19.0 and to remove an existing installation of // numpy, the `updateMask` parameter would include the following two // `paths` values: "config.softwareConfig.pypiPackages.scikit-learn" and // "config.softwareConfig.pypiPackages.numpy". The included patch // environment would specify the scikit-learn version as follows: // // { // "config":{ // "softwareConfig":{ // "pypiPackages":{ // "scikit-learn":"==0.19.0" // } // } // } // } // // Note that in the above example, any existing PyPI packages // other than scikit-learn and numpy will be unaffected. // // Only one update type may be included in a single request's `updateMask`. // For example, one cannot update both the PyPI packages and // labels in the same request. However, it is possible to update multiple // members of a map field simultaneously in the same request. For example, // to set the labels "label1" and "label2" while clearing "label3" (assuming // it already exists), one can // provide the paths "labels.label1", "labels.label2", and "labels.label3" // and populate the patch environment as follows: // // { // "labels":{ // "label1":"new-label1-value" // "label2":"new-label2-value" // } // } // // Note that in the above example, any existing labels that are not // included in the `updateMask` will be unaffected. // // It is also possible to replace an entire map field by providing the // map field's path in the `updateMask`. The new value of the field will // be that which is provided in the patch environment. For example, to // delete all pre-existing user-specified PyPI packages and // install botocore at version 1.7.14, the `updateMask` would contain // the path "config.softwareConfig.pypiPackages", and // the patch environment would be the following: // // { // "config":{ // "softwareConfig":{ // "pypiPackages":{ // "botocore":"==1.7.14" // } // } // } // } // // **Note:** Only the following fields can be updated: // // * `config.softwareConfig.pypiPackages` // * Replace all custom custom PyPI packages. If a replacement // package map is not included in `environment`, all custom // PyPI packages are cleared. It is an error to provide both // this mask and a mask specifying an individual package. // * `config.softwareConfig.pypiPackages.`packagename // * Update the custom PyPI package *packagename*, // preserving other packages. To delete the package, include it in // `updateMask`, and omit the mapping for it in // `environment.config.softwareConfig.pypiPackages`. It is an error // to provide both a mask of this form and the // `config.softwareConfig.pypiPackages` mask. // * `labels` // * Replace all environment labels. If a replacement labels map is not // included in `environment`, all labels are cleared. It is an error to // provide both this mask and a mask specifying one or more individual // labels. // * `labels.`labelName // * Set the label named *labelName*, while preserving other // labels. To delete the label, include it in `updateMask` and omit its // mapping in `environment.labels`. It is an error to provide both a // mask of this form and the `labels` mask. // * `config.nodeCount` // * Horizontally scale the number of nodes in the environment. An integer // greater than or equal to 3 must be provided in the `config.nodeCount` // field. // * `config.webServerNetworkAccessControl` // * Replace the environment's current `WebServerNetworkAccessControl`. // * `config.databaseConfig` // * Replace the environment's current `DatabaseConfig`. // * `config.webServerConfig` // * Replace the environment's current `WebServerConfig`. // * `config.softwareConfig.airflowConfigOverrides` // * Replace all Apache Airflow config overrides. If a replacement config // overrides map is not included in `environment`, all config overrides // are cleared. // It is an error to provide both this mask and a mask specifying one or // more individual config overrides. // * `config.softwareConfig.airflowConfigOverrides.`section-name // * Override the Apache Airflow config property *name* in the // section named *section*, preserving other properties. To // delete the property override, include it in `updateMask` and omit its // mapping in // `environment.config.softwareConfig.airflowConfigOverrides`. // It is an error to provide both a mask of this form and the // `config.softwareConfig.airflowConfigOverrides` mask. // * `config.softwareConfig.envVariables` // * Replace all environment variables. If a replacement environment // variable map is not included in `environment`, all custom environment // variables are cleared. // It is an error to provide both this mask and a mask specifying one or // more individual environment variables. UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,3,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"` // contains filtered or unexported fields }
Update an environment.
func (*UpdateEnvironmentRequest) Descriptor
deprecated
func (*UpdateEnvironmentRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateEnvironmentRequest.ProtoReflect.Descriptor instead.
func (*UpdateEnvironmentRequest) GetEnvironment ¶
func (x *UpdateEnvironmentRequest) GetEnvironment() *Environment
func (*UpdateEnvironmentRequest) GetName ¶
func (x *UpdateEnvironmentRequest) GetName() string
func (*UpdateEnvironmentRequest) GetUpdateMask ¶
func (x *UpdateEnvironmentRequest) GetUpdateMask() *fieldmaskpb.FieldMask
func (*UpdateEnvironmentRequest) ProtoMessage ¶
func (*UpdateEnvironmentRequest) ProtoMessage()
func (*UpdateEnvironmentRequest) ProtoReflect ¶
func (x *UpdateEnvironmentRequest) ProtoReflect() protoreflect.Message
func (*UpdateEnvironmentRequest) Reset ¶
func (x *UpdateEnvironmentRequest) Reset()
func (*UpdateEnvironmentRequest) String ¶
func (x *UpdateEnvironmentRequest) String() string
type WebServerConfig ¶
type WebServerConfig struct { // Optional. Machine type on which Airflow web server is running. // It has to be one of: composer-n1-webserver-2, composer-n1-webserver-4 or // composer-n1-webserver-8. // If not specified, composer-n1-webserver-2 will be used. // Value custom is returned only in response, if Airflow web server parameters // were manually changed to a non-standard values. MachineType string `protobuf:"bytes,1,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"` // contains filtered or unexported fields }
The configuration settings for the Airflow web server App Engine instance.
func (*WebServerConfig) Descriptor
deprecated
func (*WebServerConfig) Descriptor() ([]byte, []int)
Deprecated: Use WebServerConfig.ProtoReflect.Descriptor instead.
func (*WebServerConfig) GetMachineType ¶
func (x *WebServerConfig) GetMachineType() string
func (*WebServerConfig) ProtoMessage ¶
func (*WebServerConfig) ProtoMessage()
func (*WebServerConfig) ProtoReflect ¶
func (x *WebServerConfig) ProtoReflect() protoreflect.Message
func (*WebServerConfig) Reset ¶
func (x *WebServerConfig) Reset()
func (*WebServerConfig) String ¶
func (x *WebServerConfig) String() string
type WebServerNetworkAccessControl ¶
type WebServerNetworkAccessControl struct { // A collection of allowed IP ranges with descriptions. AllowedIpRanges []*WebServerNetworkAccessControl_AllowedIpRange `protobuf:"bytes,1,rep,name=allowed_ip_ranges,json=allowedIpRanges,proto3" json:"allowed_ip_ranges,omitempty"` // contains filtered or unexported fields }
Network-level access control policy for the Airflow web server.
func (*WebServerNetworkAccessControl) Descriptor
deprecated
func (*WebServerNetworkAccessControl) Descriptor() ([]byte, []int)
Deprecated: Use WebServerNetworkAccessControl.ProtoReflect.Descriptor instead.
func (*WebServerNetworkAccessControl) GetAllowedIpRanges ¶
func (x *WebServerNetworkAccessControl) GetAllowedIpRanges() []*WebServerNetworkAccessControl_AllowedIpRange
func (*WebServerNetworkAccessControl) ProtoMessage ¶
func (*WebServerNetworkAccessControl) ProtoMessage()
func (*WebServerNetworkAccessControl) ProtoReflect ¶
func (x *WebServerNetworkAccessControl) ProtoReflect() protoreflect.Message
func (*WebServerNetworkAccessControl) Reset ¶
func (x *WebServerNetworkAccessControl) Reset()
func (*WebServerNetworkAccessControl) String ¶
func (x *WebServerNetworkAccessControl) String() string
type WebServerNetworkAccessControl_AllowedIpRange ¶
type WebServerNetworkAccessControl_AllowedIpRange struct { // IP address or range, defined using CIDR notation, of requests that this // rule applies to. // Examples: `192.168.1.1` or `192.168.0.0/16` or `2001:db8::/32` // or `2001:0db8:0000:0042:0000:8a2e:0370:7334`. // // IP range prefixes should be properly truncated. For example, // `1.2.3.4/24` should be truncated to `1.2.3.0/24`. Similarly, for IPv6, // `2001:db8::1/32` should be truncated to `2001:db8::/32`. Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // Optional. User-provided description. It must contain at most 300 characters. Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"` // contains filtered or unexported fields }
Allowed IP range with user-provided description.
func (*WebServerNetworkAccessControl_AllowedIpRange) Descriptor
deprecated
func (*WebServerNetworkAccessControl_AllowedIpRange) Descriptor() ([]byte, []int)
Deprecated: Use WebServerNetworkAccessControl_AllowedIpRange.ProtoReflect.Descriptor instead.
func (*WebServerNetworkAccessControl_AllowedIpRange) GetDescription ¶
func (x *WebServerNetworkAccessControl_AllowedIpRange) GetDescription() string
func (*WebServerNetworkAccessControl_AllowedIpRange) GetValue ¶
func (x *WebServerNetworkAccessControl_AllowedIpRange) GetValue() string
func (*WebServerNetworkAccessControl_AllowedIpRange) ProtoMessage ¶
func (*WebServerNetworkAccessControl_AllowedIpRange) ProtoMessage()
func (*WebServerNetworkAccessControl_AllowedIpRange) ProtoReflect ¶
func (x *WebServerNetworkAccessControl_AllowedIpRange) ProtoReflect() protoreflect.Message
func (*WebServerNetworkAccessControl_AllowedIpRange) Reset ¶
func (x *WebServerNetworkAccessControl_AllowedIpRange) Reset()
func (*WebServerNetworkAccessControl_AllowedIpRange) String ¶
func (x *WebServerNetworkAccessControl_AllowedIpRange) String() string