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

Version 1.3.0

• 1.9.1 (latest)
• 1.9.0
• 1.8.5

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

Variables

Environment_State_name, Environment_State_value

var (
	Environment_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "CREATING",
		2: "RUNNING",
		3: "UPDATING",
		4: "DELETING",
		5: "ERROR",
	}
	Environment_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"CREATING":          1,
		"RUNNING":           2,
		"UPDATING":          3,
		"DELETING":          4,
		"ERROR":             5,
	}
)

Enum value maps for Environment_State.

CheckUpgradeResponse_ConflictResult_name, CheckUpgradeResponse_ConflictResult_value

var (
	CheckUpgradeResponse_ConflictResult_name = map[int32]string{
		0: "CONFLICT_RESULT_UNSPECIFIED",
		1: "CONFLICT",
		2: "NO_CONFLICT",
	}
	CheckUpgradeResponse_ConflictResult_value = map[string]int32{
		"CONFLICT_RESULT_UNSPECIFIED": 0,
		"CONFLICT":                    1,
		"NO_CONFLICT":                 2,
	}
)

Enum value maps for CheckUpgradeResponse_ConflictResult.

OperationMetadata_State_name, OperationMetadata_State_value

var (
	OperationMetadata_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "PENDING",
		2: "RUNNING",
		3: "SUCCEEDED",

		4: "FAILED",
	}
	OperationMetadata_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"PENDING":           1,
		"RUNNING":           2,
		"SUCCEEDED":         3,
		"SUCCESSFUL":        3,
		"FAILED":            4,
	}
)

Enum value maps for OperationMetadata_State.

OperationMetadata_Type_name, OperationMetadata_Type_value

var (
	OperationMetadata_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "CREATE",
		2: "DELETE",
		3: "UPDATE",
		4: "CHECK",
	}
	OperationMetadata_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"CREATE":           1,
		"DELETE":           2,
		"UPDATE":           3,
		"CHECK":            4,
	}
)

Enum value maps for OperationMetadata_Type.

File_google_cloud_orchestration_airflow_service_v1_environments_proto

var File_google_cloud_orchestration_airflow_service_v1_environments_proto protoreflect.FileDescriptor

File_google_cloud_orchestration_airflow_service_v1_image_versions_proto

var File_google_cloud_orchestration_airflow_service_v1_image_versions_proto protoreflect.FileDescriptor

File_google_cloud_orchestration_airflow_service_v1_operations_proto

var File_google_cloud_orchestration_airflow_service_v1_operations_proto protoreflect.FileDescriptor

Functions

func RegisterEnvironmentsServer

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

func RegisterImageVersionsServer

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

CheckUpgradeResponse

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

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

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

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

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

}

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

func (*CheckUpgradeResponse) Descriptor

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

Deprecated: Use CheckUpgradeResponse.ProtoReflect.Descriptor instead.

func (*CheckUpgradeResponse) GetBuildLogUri

func (x *CheckUpgradeResponse) GetBuildLogUri() string

func (*CheckUpgradeResponse) GetContainsPypiModulesConflict

func (x *CheckUpgradeResponse) GetContainsPypiModulesConflict() CheckUpgradeResponse_ConflictResult

func (*CheckUpgradeResponse) GetImageVersion

func (x *CheckUpgradeResponse) GetImageVersion() string

func (*CheckUpgradeResponse) GetPypiConflictBuildLogExtract

func (x *CheckUpgradeResponse) GetPypiConflictBuildLogExtract() string

func (*CheckUpgradeResponse) GetPypiDependencies

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

func (*CheckUpgradeResponse) ProtoMessage

func (*CheckUpgradeResponse) ProtoMessage()

func (*CheckUpgradeResponse) ProtoReflect

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

func (*CheckUpgradeResponse) Reset

func (x *CheckUpgradeResponse) Reset()

func (*CheckUpgradeResponse) String

func (x *CheckUpgradeResponse) String() string

CheckUpgradeResponse_ConflictResult

type CheckUpgradeResponse_ConflictResult int32

Whether there were python modules conflict during image build.

CheckUpgradeResponse_CONFLICT_RESULT_UNSPECIFIED, CheckUpgradeResponse_CONFLICT, CheckUpgradeResponse_NO_CONFLICT

const (
	// It is unknown whether build had conflicts or not.
	CheckUpgradeResponse_CONFLICT_RESULT_UNSPECIFIED CheckUpgradeResponse_ConflictResult = 0
	// There were python packages conflicts.
	CheckUpgradeResponse_CONFLICT CheckUpgradeResponse_ConflictResult = 1
	// There were no python packages conflicts.
	CheckUpgradeResponse_NO_CONFLICT CheckUpgradeResponse_ConflictResult = 2
)

func (CheckUpgradeResponse_ConflictResult) Descriptor

func (CheckUpgradeResponse_ConflictResult) Descriptor() protoreflect.EnumDescriptor

func (CheckUpgradeResponse_ConflictResult) Enum

func (x CheckUpgradeResponse_ConflictResult) Enum() *CheckUpgradeResponse_ConflictResult

func (CheckUpgradeResponse_ConflictResult) EnumDescriptor

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

Deprecated: Use CheckUpgradeResponse_ConflictResult.Descriptor instead.

func (CheckUpgradeResponse_ConflictResult) Number

func (x CheckUpgradeResponse_ConflictResult) Number() protoreflect.EnumNumber

func (CheckUpgradeResponse_ConflictResult) String

func (x CheckUpgradeResponse_ConflictResult) String() string

func (CheckUpgradeResponse_ConflictResult) Type

func (CheckUpgradeResponse_ConflictResult) Type() protoreflect.EnumType

CreateEnvironmentRequest

type CreateEnvironmentRequest struct {

	// The parent must be of the form
	// "projects/{projectId}/locations/{locationId}".
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// The environment to create.
	Environment *Environment `protobuf:"bytes,2,opt,name=environment,proto3" json:"environment,omitempty"`
	// contains filtered or unexported fields
}

Create a new environment.

func (*CreateEnvironmentRequest) Descriptor

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

Deprecated: Use CreateEnvironmentRequest.ProtoReflect.Descriptor instead.

func (*CreateEnvironmentRequest) GetEnvironment

func (x *CreateEnvironmentRequest) GetEnvironment() *Environment

func (*CreateEnvironmentRequest) GetParent

func (x *CreateEnvironmentRequest) GetParent() string

func (*CreateEnvironmentRequest) ProtoMessage

func (*CreateEnvironmentRequest) ProtoMessage()

func (*CreateEnvironmentRequest) ProtoReflect

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

func (*CreateEnvironmentRequest) Reset

func (x *CreateEnvironmentRequest) Reset()

func (*CreateEnvironmentRequest) String

func (x *CreateEnvironmentRequest) String() string

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

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

DeleteEnvironmentRequest

type DeleteEnvironmentRequest struct {

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

Delete an environment.

func (*DeleteEnvironmentRequest) Descriptor

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

Deprecated: Use DeleteEnvironmentRequest.ProtoReflect.Descriptor instead.

func (*DeleteEnvironmentRequest) GetName

func (x *DeleteEnvironmentRequest) GetName() string

func (*DeleteEnvironmentRequest) ProtoMessage

func (*DeleteEnvironmentRequest) ProtoMessage()

func (*DeleteEnvironmentRequest) ProtoReflect

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

func (*DeleteEnvironmentRequest) Reset

func (x *DeleteEnvironmentRequest) Reset()

func (*DeleteEnvironmentRequest) String

func (x *DeleteEnvironmentRequest) String() string

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

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

Deprecated: Use EncryptionConfig.ProtoReflect.Descriptor instead.

func (*EncryptionConfig) GetKmsKeyName

func (x *EncryptionConfig) GetKmsKeyName() string

func (*EncryptionConfig) ProtoMessage

func (*EncryptionConfig) ProtoMessage()

func (*EncryptionConfig) ProtoReflect

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

func (*EncryptionConfig) Reset

func (x *EncryptionConfig) Reset()

func (*EncryptionConfig) String

func (x *EncryptionConfig) String() string

Environment

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

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

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

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

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

	UpdateTime *timestamp.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 */

}

An environment for running orchestration tasks.

func (*Environment) Descriptor

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

Deprecated: Use Environment.ProtoReflect.Descriptor instead.

func (*Environment) GetConfig

func (x *Environment) GetConfig() *EnvironmentConfig

func (*Environment) GetCreateTime

func (x *Environment) GetCreateTime() *timestamp.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() *timestamp.Timestamp

func (*Environment) GetUuid

func (x *Environment) GetUuid() string

func (*Environment) ProtoMessage

func (*Environment) ProtoMessage()

func (*Environment) ProtoReflect

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

func (*Environment) Reset

func (x *Environment) Reset()

func (*Environment) String

func (x *Environment) String() string

EnvironmentConfig

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

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

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

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

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

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

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

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

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

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

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

}

Configuration information for an environment.

func (*EnvironmentConfig) Descriptor

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

Environment_State

type Environment_State int32

State of the environment.

Environment_STATE_UNSPECIFIED, Environment_CREATING, Environment_RUNNING, Environment_UPDATING, Environment_DELETING, Environment_ERROR

const (
	// The state of the environment is unknown.
	Environment_STATE_UNSPECIFIED Environment_State = 0
	// The environment is in the process of being created.
	Environment_CREATING Environment_State = 1
	// The environment is currently running and healthy. It is ready for use.
	Environment_RUNNING Environment_State = 2
	// The environment is being updated. It remains usable but cannot receive
	// additional update requests or be deleted at this time.
	Environment_UPDATING Environment_State = 3
	// The environment is undergoing deletion. It cannot be used.
	Environment_DELETING Environment_State = 4
	// The environment has encountered an error and cannot be used.
	Environment_ERROR Environment_State = 5
)

func (Environment_State) Descriptor

func (Environment_State) Descriptor() protoreflect.EnumDescriptor

func (Environment_State) Enum

func (x Environment_State) Enum() *Environment_State

func (Environment_State) EnumDescriptor

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

Deprecated: Use Environment_State.Descriptor instead.

func (Environment_State) Number

func (x Environment_State) Number() protoreflect.EnumNumber

func (Environment_State) String

func (x Environment_State) String() string

func (Environment_State) Type

func (Environment_State) Type() protoreflect.EnumType

EnvironmentsClient

type EnvironmentsClient interface {
	// Create a new environment.
	CreateEnvironment(ctx context.Context, in *CreateEnvironmentRequest, opts ...grpc.CallOption) (*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

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.

GetEnvironmentRequest

type GetEnvironmentRequest struct {

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

Get an environment.

func (*GetEnvironmentRequest) Descriptor

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

Deprecated: Use GetEnvironmentRequest.ProtoReflect.Descriptor instead.

func (*GetEnvironmentRequest) GetName

func (x *GetEnvironmentRequest) GetName() string

func (*GetEnvironmentRequest) ProtoMessage

func (*GetEnvironmentRequest) ProtoMessage()

func (*GetEnvironmentRequest) ProtoReflect

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

func (*GetEnvironmentRequest) Reset

func (x *GetEnvironmentRequest) Reset()

func (*GetEnvironmentRequest) String

func (x *GetEnvironmentRequest) String() string

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

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

Deprecated: Use IPAllocationPolicy.ProtoReflect.Descriptor instead.

func (*IPAllocationPolicy) GetClusterIpAllocation

func (m *IPAllocationPolicy) GetClusterIpAllocation() isIPAllocationPolicy_ClusterIpAllocation

func (*IPAllocationPolicy) GetClusterIpv4CidrBlock

func (x *IPAllocationPolicy) GetClusterIpv4CidrBlock() string

func (*IPAllocationPolicy) GetClusterSecondaryRangeName

func (x *IPAllocationPolicy) GetClusterSecondaryRangeName() string

func (*IPAllocationPolicy) GetServicesIpAllocation

func (m *IPAllocationPolicy) GetServicesIpAllocation() isIPAllocationPolicy_ServicesIpAllocation

func (*IPAllocationPolicy) GetServicesIpv4CidrBlock

func (x *IPAllocationPolicy) GetServicesIpv4CidrBlock() string

func (*IPAllocationPolicy) GetServicesSecondaryRangeName

func (x *IPAllocationPolicy) GetServicesSecondaryRangeName() string

func (*IPAllocationPolicy) GetUseIpAliases

func (x *IPAllocationPolicy) GetUseIpAliases() bool

func (*IPAllocationPolicy) ProtoMessage

func (*IPAllocationPolicy) ProtoMessage()

func (*IPAllocationPolicy) ProtoReflect

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

func (*IPAllocationPolicy) Reset

func (x *IPAllocationPolicy) Reset()

func (*IPAllocationPolicy) String

func (x *IPAllocationPolicy) String() string

IPAllocationPolicy_ClusterIpv4CidrBlock

type IPAllocationPolicy_ClusterIpv4CidrBlock struct {
	// Optional. The IP address range used to allocate IP addresses to pods in
	// the GKE cluster.
	//
	// 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"`
}

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

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

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

ImageVersion

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

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

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

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

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

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

}

ImageVersion information

func (*ImageVersion) Descriptor

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

Deprecated: Use ImageVersion.ProtoReflect.Descriptor instead.

func (*ImageVersion) GetCreationDisabled

func (x *ImageVersion) GetCreationDisabled() bool

func (*ImageVersion) GetImageVersionId

func (x *ImageVersion) GetImageVersionId() string

func (*ImageVersion) GetIsDefault

func (x *ImageVersion) GetIsDefault() bool

func (*ImageVersion) GetReleaseDate

func (x *ImageVersion) GetReleaseDate() *date.Date

func (*ImageVersion) GetSupportedPythonVersions

func (x *ImageVersion) GetSupportedPythonVersions() []string

func (*ImageVersion) GetUpgradeDisabled

func (x *ImageVersion) GetUpgradeDisabled() bool

func (*ImageVersion) ProtoMessage

func (*ImageVersion) ProtoMessage()

func (*ImageVersion) ProtoReflect

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

func (*ImageVersion) Reset

func (x *ImageVersion) Reset()

func (*ImageVersion) String

func (x *ImageVersion) String() string

ImageVersionsClient

type ImageVersionsClient interface {
	// List ImageVersions for provided location.
	ListImageVersions(ctx context.Context, in *ListImageVersionsRequest, opts ...grpc.CallOption) (*ListImageVersionsResponse, error)
}

ImageVersionsClient is the client API for ImageVersions service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewImageVersionsClient

func NewImageVersionsClient(cc grpc.ClientConnInterface) ImageVersionsClient

ImageVersionsServer

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

ImageVersionsServer is the server API for ImageVersions service.

ListEnvironmentsRequest

type ListEnvironmentsRequest struct {

	// List environments in the given project and location, in the form:
	// "projects/{projectId}/locations/{locationId}"
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// The maximum number of environments to return.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// The next_page_token value returned from a previous List request, if any.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

List environments in a project and location.

func (*ListEnvironmentsRequest) Descriptor

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

Deprecated: Use ListEnvironmentsRequest.ProtoReflect.Descriptor instead.

func (*ListEnvironmentsRequest) GetPageSize

func (x *ListEnvironmentsRequest) GetPageSize() int32

func (*ListEnvironmentsRequest) GetPageToken

func (x *ListEnvironmentsRequest) GetPageToken() string

func (*ListEnvironmentsRequest) GetParent

func (x *ListEnvironmentsRequest) GetParent() string

func (*ListEnvironmentsRequest) ProtoMessage

func (*ListEnvironmentsRequest) ProtoMessage()

func (*ListEnvironmentsRequest) ProtoReflect

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

func (*ListEnvironmentsRequest) Reset

func (x *ListEnvironmentsRequest) Reset()

func (*ListEnvironmentsRequest) String

func (x *ListEnvironmentsRequest) String() string

ListEnvironmentsResponse

type ListEnvironmentsResponse struct {

	// The list of environments returned by a ListEnvironmentsRequest.
	Environments []*Environment `protobuf:"bytes,1,rep,name=environments,proto3" json:"environments,omitempty"`
	// The page token used to query for the next page if one exists.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

The environments in a project and location.

func (*ListEnvironmentsResponse) Descriptor

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

Deprecated: Use ListEnvironmentsResponse.ProtoReflect.Descriptor instead.

func (*ListEnvironmentsResponse) GetEnvironments

func (x *ListEnvironmentsResponse) GetEnvironments() []*Environment

func (*ListEnvironmentsResponse) GetNextPageToken

func (x *ListEnvironmentsResponse) GetNextPageToken() string

func (*ListEnvironmentsResponse) ProtoMessage

func (*ListEnvironmentsResponse) ProtoMessage()

func (*ListEnvironmentsResponse) ProtoReflect

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

func (*ListEnvironmentsResponse) Reset

func (x *ListEnvironmentsResponse) Reset()

func (*ListEnvironmentsResponse) String

func (x *ListEnvironmentsResponse) String() string

ListImageVersionsRequest

type ListImageVersionsRequest struct {

	// List ImageVersions in the given project and location, in the form:
	// "projects/{projectId}/locations/{locationId}"
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// The maximum number of image_versions to return.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// The next_page_token value returned from a previous List request, if any.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Whether or not image versions from old releases should be included.
	IncludePastReleases bool `protobuf:"varint,4,opt,name=include_past_releases,json=includePastReleases,proto3" json:"include_past_releases,omitempty"`
	// contains filtered or unexported fields
}

List ImageVersions in a project and location.

func (*ListImageVersionsRequest) Descriptor

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

Deprecated: Use ListImageVersionsRequest.ProtoReflect.Descriptor instead.

func (*ListImageVersionsRequest) GetIncludePastReleases

func (x *ListImageVersionsRequest) GetIncludePastReleases() bool

func (*ListImageVersionsRequest) GetPageSize

func (x *ListImageVersionsRequest) GetPageSize() int32

func (*ListImageVersionsRequest) GetPageToken

func (x *ListImageVersionsRequest) GetPageToken() string

func (*ListImageVersionsRequest) GetParent

func (x *ListImageVersionsRequest) GetParent() string

func (*ListImageVersionsRequest) ProtoMessage

func (*ListImageVersionsRequest) ProtoMessage()

func (*ListImageVersionsRequest) ProtoReflect

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

func (*ListImageVersionsRequest) Reset

func (x *ListImageVersionsRequest) Reset()

func (*ListImageVersionsRequest) String

func (x *ListImageVersionsRequest) String() string

ListImageVersionsResponse

type ListImageVersionsResponse struct {

	// The list of supported ImageVersions in a location.
	ImageVersions []*ImageVersion `protobuf:"bytes,1,rep,name=image_versions,json=imageVersions,proto3" json:"image_versions,omitempty"`
	// The page token used to query for the next page if one exists.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

The ImageVersions in a project and location.

func (*ListImageVersionsResponse) Descriptor

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

Deprecated: Use ListImageVersionsResponse.ProtoReflect.Descriptor instead.

func (*ListImageVersionsResponse) GetImageVersions

func (x *ListImageVersionsResponse) GetImageVersions() []*ImageVersion

func (*ListImageVersionsResponse) GetNextPageToken

func (x *ListImageVersionsResponse) GetNextPageToken() string

func (*ListImageVersionsResponse) ProtoMessage

func (*ListImageVersionsResponse) ProtoMessage()

func (*ListImageVersionsResponse) ProtoReflect

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

func (*ListImageVersionsResponse) Reset

func (x *ListImageVersionsResponse) Reset()

func (*ListImageVersionsResponse) String

func (x *ListImageVersionsResponse) String() string

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

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

OperationMetadata

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

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

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

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

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

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

}

Metadata describing an operation.

func (*OperationMetadata) Descriptor

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

Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.

func (*OperationMetadata) GetCreateTime

func (x *OperationMetadata) GetCreateTime() *timestamp.Timestamp

func (*OperationMetadata) GetEndTime

func (x *OperationMetadata) GetEndTime() *timestamp.Timestamp

func (*OperationMetadata) GetOperationType

func (x *OperationMetadata) GetOperationType() OperationMetadata_Type

func (*OperationMetadata) GetResource

func (x *OperationMetadata) GetResource() string

func (*OperationMetadata) GetResourceUuid

func (x *OperationMetadata) GetResourceUuid() string

func (*OperationMetadata) GetState

func (x *OperationMetadata) GetState() OperationMetadata_State

func (*OperationMetadata) ProtoMessage

func (*OperationMetadata) ProtoMessage()

func (*OperationMetadata) ProtoReflect

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

func (*OperationMetadata) Reset

func (x *OperationMetadata) Reset()

func (*OperationMetadata) String

func (x *OperationMetadata) String() string

OperationMetadata_State

type OperationMetadata_State int32

An enum describing the overall state of an operation.

OperationMetadata_STATE_UNSPECIFIED, OperationMetadata_PENDING, OperationMetadata_RUNNING, OperationMetadata_SUCCEEDED, OperationMetadata_SUCCESSFUL, OperationMetadata_FAILED

const (
	// Unused.
	OperationMetadata_STATE_UNSPECIFIED OperationMetadata_State = 0
	// The operation has been created but is not yet started.
	OperationMetadata_PENDING OperationMetadata_State = 1
	// The operation is underway.
	OperationMetadata_RUNNING OperationMetadata_State = 2
	// The operation completed successfully.
	OperationMetadata_SUCCEEDED  OperationMetadata_State = 3
	OperationMetadata_SUCCESSFUL OperationMetadata_State = 3
	// The operation is no longer running but did not succeed.
	OperationMetadata_FAILED OperationMetadata_State = 4
)

func (OperationMetadata_State) Descriptor

func (OperationMetadata_State) Descriptor() protoreflect.EnumDescriptor

func (OperationMetadata_State) Enum

func (x OperationMetadata_State) Enum() *OperationMetadata_State

func (OperationMetadata_State) EnumDescriptor

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

Deprecated: Use OperationMetadata_State.Descriptor instead.

func (OperationMetadata_State) Number

func (x OperationMetadata_State) Number() protoreflect.EnumNumber

func (OperationMetadata_State) String

func (x OperationMetadata_State) String() string

func (OperationMetadata_State) Type

func (OperationMetadata_State) Type() protoreflect.EnumType

OperationMetadata_Type

type OperationMetadata_Type int32

Type of longrunning operation.

OperationMetadata_TYPE_UNSPECIFIED, OperationMetadata_CREATE, OperationMetadata_DELETE, OperationMetadata_UPDATE, OperationMetadata_CHECK

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

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

PrivateClusterConfig

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

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

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

}

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

func (*PrivateClusterConfig) Descriptor

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

Deprecated: Use PrivateClusterConfig.ProtoReflect.Descriptor instead.

func (*PrivateClusterConfig) GetEnablePrivateEndpoint

func (x *PrivateClusterConfig) GetEnablePrivateEndpoint() bool

func (*PrivateClusterConfig) GetMasterIpv4CidrBlock

func (x *PrivateClusterConfig) GetMasterIpv4CidrBlock() string

func (*PrivateClusterConfig) GetMasterIpv4ReservedRange

func (x *PrivateClusterConfig) GetMasterIpv4ReservedRange() string

func (*PrivateClusterConfig) ProtoMessage

func (*PrivateClusterConfig) ProtoMessage()

func (*PrivateClusterConfig) ProtoReflect

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

func (*PrivateClusterConfig) Reset

func (x *PrivateClusterConfig) Reset()

func (*PrivateClusterConfig) String

func (x *PrivateClusterConfig) String() string

PrivateEnvironmentConfig

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

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

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

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

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

}

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

func (*PrivateEnvironmentConfig) Descriptor

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

Deprecated: Use PrivateEnvironmentConfig.ProtoReflect.Descriptor instead.

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

SoftwareConfig

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

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

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

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

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

}

Specifies the selection and configuration of software inside the environment.

func (*SoftwareConfig) Descriptor

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

Deprecated: Use SoftwareConfig.ProtoReflect.Descriptor instead.

func (*SoftwareConfig) GetAirflowConfigOverrides

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

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

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)

UnimplementedImageVersionsServer

type UnimplementedImageVersionsServer struct {
}

UnimplementedImageVersionsServer can be embedded to have forward compatible implementations.

func (*UnimplementedImageVersionsServer) ListImageVersions

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

UpdateEnvironmentRequest

type UpdateEnvironmentRequest struct {

	// The relative resource name of the environment to update, in the form:
	// "projects/{projectId}/locations/{locationId}/environments/{environmentId}"
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// A patch environment. Fields specified by the `updateMask` will be copied
	// from the patch environment into the environment under update.
	Environment *Environment `protobuf:"bytes,1,opt,name=environment,proto3" json:"environment,omitempty"`
	// Required. A comma-separated list of paths, relative to `Environment`, of
	// fields to update.
	// For example, to set the version of scikit-learn to install in the
	// environment to 0.19.0 and to remove an existing installation of
	// numpy, the `updateMask` parameter would include the following two
	// `paths` values: "config.softwareConfig.pypiPackages.scikit-learn" and
	// "config.softwareConfig.pypiPackages.numpy". The included patch
	// environment would specify the scikit-learn version as follows:
	//
	//	{
	//	  "config":{
	//	    "softwareConfig":{
	//	      "pypiPackages":{
	//	        "scikit-learn":"==0.19.0"
	//	      }
	//	    }
	//	  }
	//	}
	//
	// Note that in the above example, any existing PyPI packages
	// other than scikit-learn and numpy will be unaffected.
	//
	// Only one update type may be included in a single request's `updateMask`.
	// For example, one cannot update both the PyPI packages and
	// labels in the same request. However, it is possible to update multiple
	// members of a map field simultaneously in the same request. For example,
	// to set the labels "label1" and "label2" while clearing "label3" (assuming
	// it already exists), one can
	// provide the paths "labels.label1", "labels.label2", and "labels.label3"
	// and populate the patch environment as follows:
	//
	//	{
	//	  "labels":{
	//	    "label1":"new-label1-value"
	//	    "label2":"new-label2-value"
	//	  }
	//	}
	//
	// Note that in the above example, any existing labels that are not
	// included in the `updateMask` will be unaffected.
	//
	// It is also possible to replace an entire map field by providing the
	// map field's path in the `updateMask`. The new value of the field will
	// be that which is provided in the patch environment. For example, to
	// delete all pre-existing user-specified PyPI packages and
	// install botocore at version 1.7.14, the `updateMask` would contain
	// the path "config.softwareConfig.pypiPackages", and
	// the patch environment would be the following:
	//
	//	{
	//	  "config":{
	//	    "softwareConfig":{
	//	      "pypiPackages":{
	//	        "botocore":"==1.7.14"
	//	      }
	//	    }
	//	  }
	//	}
	//
	// **Note:** Only the following fields can be updated:
	//
	// * `config.softwareConfig.pypiPackages`
	//   - Replace all custom custom PyPI packages. If a replacement
	//     package map is not included in `environment`, all custom
	//     PyPI packages are cleared. It is an error to provide both
	//     this mask and a mask specifying an individual package.
	//
	// * `config.softwareConfig.pypiPackages.`packagename
	//   - Update the custom PyPI package *packagename*,
	//     preserving other packages. To delete the package, include it in
	//     `updateMask`, and omit the mapping for it in
	//     `environment.config.softwareConfig.pypiPackages`. It is an error
	//     to provide both a mask of this form and the
	//     `config.softwareConfig.pypiPackages` mask.
	//
	// * `labels`
	//   - Replace all environment labels. If a replacement labels map is not
	//     included in `environment`, all labels are cleared. It is an error to
	//     provide both this mask and a mask specifying one or more individual
	//     labels.
	//
	// * `labels.`labelName
	//   - Set the label named *labelName*, while preserving other
	//     labels. To delete the label, include it in `updateMask` and omit its
	//     mapping in `environment.labels`. It is an error to provide both a
	//     mask of this form and the `labels` mask.
	//
	// * `config.nodeCount`
	//   - Horizontally scale the number of nodes in the environment. An integer
	//     greater than or equal to 3 must be provided in the `config.nodeCount`
	//     field.
	//
	// * `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 *field_mask.FieldMask `protobuf:"bytes,3,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

Update an environment.

func (*UpdateEnvironmentRequest) Descriptor

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

Deprecated: Use UpdateEnvironmentRequest.ProtoReflect.Descriptor instead.

func (*UpdateEnvironmentRequest) GetEnvironment

func (x *UpdateEnvironmentRequest) GetEnvironment() *Environment

func (*UpdateEnvironmentRequest) GetName

func (x *UpdateEnvironmentRequest) GetName() string

func (*UpdateEnvironmentRequest) GetUpdateMask

func (x *UpdateEnvironmentRequest) GetUpdateMask() *field_mask.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

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

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

Deprecated: Use WebServerConfig.ProtoReflect.Descriptor instead.

func (*WebServerConfig) GetMachineType

func (x *WebServerConfig) GetMachineType() string

func (*WebServerConfig) ProtoMessage

func (*WebServerConfig) ProtoMessage()

func (*WebServerConfig) ProtoReflect

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

func (*WebServerConfig) Reset

func (x *WebServerConfig) Reset()

func (*WebServerConfig) String

func (x *WebServerConfig) String() string

WebServerNetworkAccessControl

type WebServerNetworkAccessControl struct {

	// A collection of allowed IP ranges with descriptions.
	AllowedIpRanges []*WebServerNetworkAccessControl_AllowedIpRange `protobuf:"bytes,1,rep,name=allowed_ip_ranges,json=allowedIpRanges,proto3" json:"allowed_ip_ranges,omitempty"`
	// contains filtered or unexported fields
}

Network-level access control policy for the Airflow web server.

func (*WebServerNetworkAccessControl) Descriptor

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

Deprecated: Use WebServerNetworkAccessControl.ProtoReflect.Descriptor instead.

func (*WebServerNetworkAccessControl) GetAllowedIpRanges

func (x *WebServerNetworkAccessControl) GetAllowedIpRanges() []*WebServerNetworkAccessControl_AllowedIpRange

func (*WebServerNetworkAccessControl) ProtoMessage

func (*WebServerNetworkAccessControl) ProtoMessage()

func (*WebServerNetworkAccessControl) ProtoReflect

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

func (*WebServerNetworkAccessControl) Reset

func (x *WebServerNetworkAccessControl) Reset()

func (*WebServerNetworkAccessControl) String

func (x *WebServerNetworkAccessControl) String() string

WebServerNetworkAccessControl_AllowedIpRange

type WebServerNetworkAccessControl_AllowedIpRange struct {

	// IP address or range, defined using CIDR notation, of requests that this
	// rule applies to.
	// Examples: `192.168.1.1` or `192.168.0.0/16` or `2001:db8::/32`
	//
	//	or `2001:0db8:0000:0042:0000:8a2e:0370:7334`.
	//
	// IP range prefixes should be properly truncated. For example,
	// `1.2.3.4/24` should be truncated to `1.2.3.0/24`. Similarly, for IPv6,
	// `2001:db8::1/32` should be truncated to `2001:db8::/32`.
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Optional. User-provided description. It must contain at most 300 characters.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

Allowed IP range with user-provided description.

func (*WebServerNetworkAccessControl_AllowedIpRange) Descriptor

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

Deprecated: Use WebServerNetworkAccessControl_AllowedIpRange.ProtoReflect.Descriptor instead.

func (*WebServerNetworkAccessControl_AllowedIpRange) GetDescription

func (x *WebServerNetworkAccessControl_AllowedIpRange) GetDescription() string

func (*WebServerNetworkAccessControl_AllowedIpRange) GetValue

func (x *WebServerNetworkAccessControl_AllowedIpRange) GetValue() string

func (*WebServerNetworkAccessControl_AllowedIpRange) ProtoMessage

func (*WebServerNetworkAccessControl_AllowedIpRange) ProtoMessage()

func (*WebServerNetworkAccessControl_AllowedIpRange) ProtoReflect

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

func (*WebServerNetworkAccessControl_AllowedIpRange) Reset

func (x *WebServerNetworkAccessControl_AllowedIpRange) Reset()

func (*WebServerNetworkAccessControl_AllowedIpRange) String

func (x *WebServerNetworkAccessControl_AllowedIpRange) String() string