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

Version 1.6.1

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

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

Variables

EnvironmentConfig_EnvironmentSize_name, EnvironmentConfig_EnvironmentSize_value

var (
	EnvironmentConfig_EnvironmentSize_name = map[int32]string{
		0: "ENVIRONMENT_SIZE_UNSPECIFIED",
		1: "ENVIRONMENT_SIZE_SMALL",
		2: "ENVIRONMENT_SIZE_MEDIUM",
		3: "ENVIRONMENT_SIZE_LARGE",
	}
	EnvironmentConfig_EnvironmentSize_value = map[string]int32{
		"ENVIRONMENT_SIZE_UNSPECIFIED": 0,
		"ENVIRONMENT_SIZE_SMALL":       1,
		"ENVIRONMENT_SIZE_MEDIUM":      2,
		"ENVIRONMENT_SIZE_LARGE":       3,
	}
)

Enum value maps for EnvironmentConfig_EnvironmentSize.

NetworkingConfig_ConnectionType_name, NetworkingConfig_ConnectionType_value

var (
	NetworkingConfig_ConnectionType_name = map[int32]string{
		0: "CONNECTION_TYPE_UNSPECIFIED",
		1: "VPC_PEERING",
		2: "PRIVATE_SERVICE_CONNECT",
	}
	NetworkingConfig_ConnectionType_value = map[string]int32{
		"CONNECTION_TYPE_UNSPECIFIED": 0,
		"VPC_PEERING":                 1,
		"PRIVATE_SERVICE_CONNECT":     2,
	}
)

Enum value maps for NetworkingConfig_ConnectionType.

Environment_State_name, Environment_State_value

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

Enum value maps for Environment_State.

CheckUpgradeResponse_ConflictResult_name, CheckUpgradeResponse_ConflictResult_value

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

Enum value maps for CheckUpgradeResponse_ConflictResult.

OperationMetadata_State_name, OperationMetadata_State_value

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

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

Enum value maps for OperationMetadata_State.

OperationMetadata_Type_name, OperationMetadata_Type_value

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

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.
	// Supported for Cloud Composer environments in versions
	// composer-1.*.*-airflow-*.*.*.
	MachineType string `protobuf:"bytes,1,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"`
	// 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.Supported for Cloud Composer environments in versions composer-1..-airflow-..*.

func (*EncryptionConfig) Descriptor

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

Deprecated: Use EncryptionConfig.ProtoReflect.Descriptor instead.

func (*EncryptionConfig) GetKmsKeyName

func (x *EncryptionConfig) GetKmsKeyName() string

func (*EncryptionConfig) ProtoMessage

func (*EncryptionConfig) ProtoMessage()

func (*EncryptionConfig) ProtoReflect

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

func (*EncryptionConfig) Reset

func (x *EncryptionConfig) Reset()

func (*EncryptionConfig) String

func (x *EncryptionConfig) String() string

Environment

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

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

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

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

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

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

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

}

An environment for running orchestration tasks.

func (*Environment) Descriptor

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

Deprecated: Use Environment.ProtoReflect.Descriptor instead.

func (*Environment) GetConfig

func (x *Environment) GetConfig() *EnvironmentConfig

func (*Environment) GetCreateTime

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

func (*Environment) GetLabels

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

func (*Environment) GetName

func (x *Environment) GetName() string

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

EnvironmentConfig

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

}

Configuration information for an environment.

func (*EnvironmentConfig) Descriptor

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

Deprecated: Use EnvironmentConfig.ProtoReflect.Descriptor instead.

func (*EnvironmentConfig) GetAirflowByoidUri

func (x *EnvironmentConfig) GetAirflowByoidUri() string

func (*EnvironmentConfig) GetAirflowUri

func (x *EnvironmentConfig) GetAirflowUri() string

func (*EnvironmentConfig) GetDagGcsPrefix

func (x *EnvironmentConfig) GetDagGcsPrefix() string

func (*EnvironmentConfig) GetDatabaseConfig

func (x *EnvironmentConfig) GetDatabaseConfig() *DatabaseConfig

func (*EnvironmentConfig) GetEncryptionConfig

func (x *EnvironmentConfig) GetEncryptionConfig() *EncryptionConfig

func (*EnvironmentConfig) GetEnvironmentSize

func (x *EnvironmentConfig) GetEnvironmentSize() EnvironmentConfig_EnvironmentSize

func (*EnvironmentConfig) GetGkeCluster

func (x *EnvironmentConfig) GetGkeCluster() string

func (*EnvironmentConfig) GetMaintenanceWindow

func (x *EnvironmentConfig) GetMaintenanceWindow() *MaintenanceWindow

func (*EnvironmentConfig) GetMasterAuthorizedNetworksConfig

func (x *EnvironmentConfig) GetMasterAuthorizedNetworksConfig() *MasterAuthorizedNetworksConfig

func (*EnvironmentConfig) GetNodeConfig

func (x *EnvironmentConfig) GetNodeConfig() *NodeConfig

func (*EnvironmentConfig) GetNodeCount

func (x *EnvironmentConfig) GetNodeCount() int32

func (*EnvironmentConfig) GetPrivateEnvironmentConfig

func (x *EnvironmentConfig) GetPrivateEnvironmentConfig() *PrivateEnvironmentConfig

func (*EnvironmentConfig) GetRecoveryConfig

func (x *EnvironmentConfig) GetRecoveryConfig() *RecoveryConfig

func (*EnvironmentConfig) GetSoftwareConfig

func (x *EnvironmentConfig) GetSoftwareConfig() *SoftwareConfig

func (*EnvironmentConfig) GetWebServerConfig

func (x *EnvironmentConfig) GetWebServerConfig() *WebServerConfig

func (*EnvironmentConfig) GetWebServerNetworkAccessControl

func (x *EnvironmentConfig) GetWebServerNetworkAccessControl() *WebServerNetworkAccessControl

func (*EnvironmentConfig) GetWorkloadsConfig

func (x *EnvironmentConfig) GetWorkloadsConfig() *WorkloadsConfig

func (*EnvironmentConfig) ProtoMessage

func (*EnvironmentConfig) ProtoMessage()

func (*EnvironmentConfig) ProtoReflect

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

func (*EnvironmentConfig) Reset

func (x *EnvironmentConfig) Reset()

func (*EnvironmentConfig) String

func (x *EnvironmentConfig) String() string

EnvironmentConfig_EnvironmentSize

type EnvironmentConfig_EnvironmentSize int32

The size of the Cloud Composer environment.

EnvironmentConfig_ENVIRONMENT_SIZE_UNSPECIFIED, EnvironmentConfig_ENVIRONMENT_SIZE_SMALL, EnvironmentConfig_ENVIRONMENT_SIZE_MEDIUM, EnvironmentConfig_ENVIRONMENT_SIZE_LARGE

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

func (EnvironmentConfig_EnvironmentSize) Descriptor

func (EnvironmentConfig_EnvironmentSize) Descriptor() protoreflect.EnumDescriptor

func (EnvironmentConfig_EnvironmentSize) Enum

func (x EnvironmentConfig_EnvironmentSize) Enum() *EnvironmentConfig_EnvironmentSize

func (EnvironmentConfig_EnvironmentSize) EnumDescriptor

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

Deprecated: Use EnvironmentConfig_EnvironmentSize.Descriptor instead.

func (EnvironmentConfig_EnvironmentSize) Number

func (x EnvironmentConfig_EnvironmentSize) Number() protoreflect.EnumNumber

func (EnvironmentConfig_EnvironmentSize) String

func (x EnvironmentConfig_EnvironmentSize) String() string

func (EnvironmentConfig_EnvironmentSize) Type

func (EnvironmentConfig_EnvironmentSize) Type() protoreflect.EnumType

Environment_State

type Environment_State int32

State of the environment.

Environment_STATE_UNSPECIFIED, Environment_CREATING, Environment_RUNNING, Environment_UPDATING, Environment_DELETING, Environment_ERROR

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

func (Environment_State) Descriptor

func (Environment_State) Descriptor() protoreflect.EnumDescriptor

func (Environment_State) Enum

func (x Environment_State) Enum() *Environment_State

func (Environment_State) EnumDescriptor

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

Deprecated: Use Environment_State.Descriptor instead.

func (Environment_State) Number

func (x Environment_State) Number() protoreflect.EnumNumber

func (Environment_State) String

func (x Environment_State) String() string

func (Environment_State) Type

func (Environment_State) Type() protoreflect.EnumType

EnvironmentsClient

type EnvironmentsClient interface {
	// Create a new environment.
	CreateEnvironment(ctx context.Context, in *CreateEnvironmentRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Get an existing environment.
	GetEnvironment(ctx context.Context, in *GetEnvironmentRequest, opts ...grpc.CallOption) (*Environment, error)
	// List environments.
	ListEnvironments(ctx context.Context, in *ListEnvironmentsRequest, opts ...grpc.CallOption) (*ListEnvironmentsResponse, error)
	// Update an environment.
	UpdateEnvironment(ctx context.Context, in *UpdateEnvironmentRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Delete an environment.
	DeleteEnvironment(ctx context.Context, in *DeleteEnvironmentRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Creates a snapshots of a Cloud Composer environment.
	//
	// As a result of this operation, snapshot of environment's state is stored
	// in a location specified in the SaveSnapshotRequest.
	SaveSnapshot(ctx context.Context, in *SaveSnapshotRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Loads a snapshot of a Cloud Composer environment.
	//
	// As a result of this operation, a snapshot of environment's specified in
	// LoadSnapshotRequest is loaded into the environment.
	LoadSnapshot(ctx context.Context, in *LoadSnapshotRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
}

EnvironmentsClient is the client API for Environments service.

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

func NewEnvironmentsClient

func NewEnvironmentsClient(cc grpc.ClientConnInterface) EnvironmentsClient

EnvironmentsServer

type EnvironmentsServer interface {
	// Create a new environment.
	CreateEnvironment(context.Context, *CreateEnvironmentRequest) (*longrunningpb.Operation, error)
	// Get an existing environment.
	GetEnvironment(context.Context, *GetEnvironmentRequest) (*Environment, error)
	// List environments.
	ListEnvironments(context.Context, *ListEnvironmentsRequest) (*ListEnvironmentsResponse, error)
	// Update an environment.
	UpdateEnvironment(context.Context, *UpdateEnvironmentRequest) (*longrunningpb.Operation, error)
	// Delete an environment.
	DeleteEnvironment(context.Context, *DeleteEnvironmentRequest) (*longrunningpb.Operation, error)
	// Creates a snapshots of a Cloud Composer environment.
	//
	// As a result of this operation, snapshot of environment's state is stored
	// in a location specified in the SaveSnapshotRequest.
	SaveSnapshot(context.Context, *SaveSnapshotRequest) (*longrunningpb.Operation, error)
	// Loads a snapshot of a Cloud Composer environment.
	//
	// As a result of this operation, a snapshot of environment's specified in
	// LoadSnapshotRequest is loaded into the environment.
	LoadSnapshot(context.Context, *LoadSnapshotRequest) (*longrunningpb.Operation, error)
}

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.
	//
	// This field is only supported for Cloud Composer environments in versions
	// composer-1.*.*-airflow-*.*.*. Environments in newer versions always use
	// VPC-native GKE clusters.
	UseIpAliases bool `protobuf:"varint,1,opt,name=use_ip_aliases,json=useIpAliases,proto3" json:"use_ip_aliases,omitempty"`
	// Configuration of allocating IP addresses for pods in the GKE cluster.
	//
	// Types that are assignable to ClusterIpAllocation:
	//	*IPAllocationPolicy_ClusterSecondaryRangeName
	//	*IPAllocationPolicy_ClusterIpv4CidrBlock
	ClusterIpAllocation isIPAllocationPolicy_ClusterIpAllocation `protobuf_oneof:"cluster_ip_allocation"`
	// Configuration of allocating IP addresses for services in the GKE cluster.
	//
	// Types that are assignable to ServicesIpAllocation:
	//	*IPAllocationPolicy_ServicesSecondaryRangeName
	//	*IPAllocationPolicy_ServicesIpv4CidrBlock
	ServicesIpAllocation isIPAllocationPolicy_ServicesIpAllocation `protobuf_oneof:"services_ip_allocation"`
	// contains filtered or unexported fields
}

Configuration for controlling how IPs are allocated in the GKE cluster running the Apache Airflow software.

func (*IPAllocationPolicy) Descriptor

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

Deprecated: Use IPAllocationPolicy.ProtoReflect.Descriptor instead.

func (*IPAllocationPolicy) GetClusterIpAllocation

func (m *IPAllocationPolicy) GetClusterIpAllocation() isIPAllocationPolicy_ClusterIpAllocation

func (*IPAllocationPolicy) GetClusterIpv4CidrBlock

func (x *IPAllocationPolicy) GetClusterIpv4CidrBlock() string

func (*IPAllocationPolicy) GetClusterSecondaryRangeName

func (x *IPAllocationPolicy) GetClusterSecondaryRangeName() string

func (*IPAllocationPolicy) GetServicesIpAllocation

func (m *IPAllocationPolicy) GetServicesIpAllocation() isIPAllocationPolicy_ServicesIpAllocation

func (*IPAllocationPolicy) GetServicesIpv4CidrBlock

func (x *IPAllocationPolicy) GetServicesIpv4CidrBlock() string

func (*IPAllocationPolicy) GetServicesSecondaryRangeName

func (x *IPAllocationPolicy) GetServicesSecondaryRangeName() string

func (*IPAllocationPolicy) GetUseIpAliases

func (x *IPAllocationPolicy) GetUseIpAliases() bool

func (*IPAllocationPolicy) ProtoMessage

func (*IPAllocationPolicy) ProtoMessage()

func (*IPAllocationPolicy) ProtoReflect

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

func (*IPAllocationPolicy) Reset

func (x *IPAllocationPolicy) Reset()

func (*IPAllocationPolicy) String

func (x *IPAllocationPolicy) String() string

IPAllocationPolicy_ClusterIpv4CidrBlock

type IPAllocationPolicy_ClusterIpv4CidrBlock struct {
	// Optional. The IP address range used to allocate IP addresses to pods in
	// the GKE cluster.
	//
	// For Cloud Composer environments in versions composer-1.*.*-airflow-*.*.*,
	// this field is applicable only when `use_ip_aliases` is true.
	//
	// Set to blank to have GKE choose a range with the default size.
	//
	// Set to /netmask (e.g. `/14`) to have GKE choose a range with a specific
	// netmask.
	//
	// Set to a
	// [CIDR](https://en.wikipedia.org/wiki/Classless_Inter-Domain_Routing)
	// notation (e.g. `10.96.0.0/14`) from the RFC-1918 private networks (e.g.
	// `10.0.0.0/8`, `172.16.0.0/12`, `192.168.0.0/16`) to pick a specific range
	// to use.
	ClusterIpv4CidrBlock string `protobuf:"bytes,4,opt,name=cluster_ipv4_cidr_block,json=clusterIpv4CidrBlock,proto3,oneof"`
}

IPAllocationPolicy_ClusterSecondaryRangeName

type IPAllocationPolicy_ClusterSecondaryRangeName struct {
	// Optional. The name of the GKE cluster's secondary range used to allocate
	// IP addresses to pods.
	//
	// For Cloud Composer environments in versions composer-1.*.*-airflow-*.*.*,
	// this field is applicable only when `use_ip_aliases` is true.
	ClusterSecondaryRangeName string `protobuf:"bytes,2,opt,name=cluster_secondary_range_name,json=clusterSecondaryRangeName,proto3,oneof"`
}

IPAllocationPolicy_ServicesIpv4CidrBlock

type IPAllocationPolicy_ServicesIpv4CidrBlock struct {
	// Optional. The IP address range of the services IP addresses in this
	// GKE cluster.
	//
	// For Cloud Composer environments in versions composer-1.*.*-airflow-*.*.*,
	// this field is applicable only when `use_ip_aliases` is true.
	//
	// Set to blank to have GKE choose a range with the default size.
	//
	// Set to /netmask (e.g. `/14`) to have GKE choose a range with a specific
	// netmask.
	//
	// Set to a
	// [CIDR](https://en.wikipedia.org/wiki/Classless_Inter-Domain_Routing)
	// notation (e.g. `10.96.0.0/14`) from the RFC-1918 private networks (e.g.
	// `10.0.0.0/8`, `172.16.0.0/12`, `192.168.0.0/16`) to pick a specific range
	// to use.
	ServicesIpv4CidrBlock string `protobuf:"bytes,5,opt,name=services_ipv4_cidr_block,json=servicesIpv4CidrBlock,proto3,oneof"`
}

IPAllocationPolicy_ServicesSecondaryRangeName

type IPAllocationPolicy_ServicesSecondaryRangeName struct {
	// Optional. The name of the services' secondary range used to allocate
	// IP addresses to the GKE cluster.
	//
	// For Cloud Composer environments in versions composer-1.*.*-airflow-*.*.*,
	// this field is applicable only when `use_ip_aliases` is true.
	ServicesSecondaryRangeName string `protobuf:"bytes,3,opt,name=services_secondary_range_name,json=servicesSecondaryRangeName,proto3,oneof"`
}

ImageVersion

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

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

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

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

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

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

}

ImageVersion information

func (*ImageVersion) Descriptor

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

Deprecated: Use ImageVersion.ProtoReflect.Descriptor instead.

func (*ImageVersion) GetCreationDisabled

func (x *ImageVersion) GetCreationDisabled() bool

func (*ImageVersion) GetImageVersionId

func (x *ImageVersion) GetImageVersionId() string

func (*ImageVersion) GetIsDefault

func (x *ImageVersion) GetIsDefault() bool

func (*ImageVersion) GetReleaseDate

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

func (*ImageVersion) GetSupportedPythonVersions

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

func (*ImageVersion) GetUpgradeDisabled

func (x *ImageVersion) GetUpgradeDisabled() bool

func (*ImageVersion) ProtoMessage

func (*ImageVersion) ProtoMessage()

func (*ImageVersion) ProtoReflect

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

func (*ImageVersion) Reset

func (x *ImageVersion) Reset()

func (*ImageVersion) String

func (x *ImageVersion) String() string

ImageVersionsClient

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

ImageVersionsClient is the client API for ImageVersions service.

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

func NewImageVersionsClient

func NewImageVersionsClient(cc grpc.ClientConnInterface) ImageVersionsClient

ImageVersionsServer

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

ImageVersionsServer is the server API for ImageVersions service.

ListEnvironmentsRequest

type ListEnvironmentsRequest struct {

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

List environments in a project and location.

func (*ListEnvironmentsRequest) Descriptor

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

Deprecated: Use ListEnvironmentsRequest.ProtoReflect.Descriptor instead.

func (*ListEnvironmentsRequest) GetPageSize

func (x *ListEnvironmentsRequest) GetPageSize() int32

func (*ListEnvironmentsRequest) GetPageToken

func (x *ListEnvironmentsRequest) GetPageToken() string

func (*ListEnvironmentsRequest) GetParent

func (x *ListEnvironmentsRequest) GetParent() string

func (*ListEnvironmentsRequest) ProtoMessage

func (*ListEnvironmentsRequest) ProtoMessage()

func (*ListEnvironmentsRequest) ProtoReflect

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

func (*ListEnvironmentsRequest) Reset

func (x *ListEnvironmentsRequest) Reset()

func (*ListEnvironmentsRequest) String

func (x *ListEnvironmentsRequest) String() string

ListEnvironmentsResponse

type ListEnvironmentsResponse struct {

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

The environments in a project and location.

func (*ListEnvironmentsResponse) Descriptor

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

Deprecated: Use ListEnvironmentsResponse.ProtoReflect.Descriptor instead.

func (*ListEnvironmentsResponse) GetEnvironments

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

func (*ListEnvironmentsResponse) GetNextPageToken

func (x *ListEnvironmentsResponse) GetNextPageToken() string

func (*ListEnvironmentsResponse) ProtoMessage

func (*ListEnvironmentsResponse) ProtoMessage()

func (*ListEnvironmentsResponse) ProtoReflect

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

func (*ListEnvironmentsResponse) Reset

func (x *ListEnvironmentsResponse) Reset()

func (*ListEnvironmentsResponse) String

func (x *ListEnvironmentsResponse) String() string

ListImageVersionsRequest

type ListImageVersionsRequest struct {

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

List ImageVersions in a project and location.

func (*ListImageVersionsRequest) Descriptor

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

Deprecated: Use ListImageVersionsRequest.ProtoReflect.Descriptor instead.

func (*ListImageVersionsRequest) GetIncludePastReleases

func (x *ListImageVersionsRequest) GetIncludePastReleases() bool

func (*ListImageVersionsRequest) GetPageSize

func (x *ListImageVersionsRequest) GetPageSize() int32

func (*ListImageVersionsRequest) GetPageToken

func (x *ListImageVersionsRequest) GetPageToken() string

func (*ListImageVersionsRequest) GetParent

func (x *ListImageVersionsRequest) GetParent() string

func (*ListImageVersionsRequest) ProtoMessage

func (*ListImageVersionsRequest) ProtoMessage()

func (*ListImageVersionsRequest) ProtoReflect

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

func (*ListImageVersionsRequest) Reset

func (x *ListImageVersionsRequest) Reset()

func (*ListImageVersionsRequest) String

func (x *ListImageVersionsRequest) String() string

ListImageVersionsResponse

type ListImageVersionsResponse struct {

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

The ImageVersions in a project and location.

func (*ListImageVersionsResponse) Descriptor

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

Deprecated: Use ListImageVersionsResponse.ProtoReflect.Descriptor instead.

func (*ListImageVersionsResponse) GetImageVersions

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

func (*ListImageVersionsResponse) GetNextPageToken

func (x *ListImageVersionsResponse) GetNextPageToken() string

func (*ListImageVersionsResponse) ProtoMessage

func (*ListImageVersionsResponse) ProtoMessage()

func (*ListImageVersionsResponse) ProtoReflect

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

func (*ListImageVersionsResponse) Reset

func (x *ListImageVersionsResponse) Reset()

func (*ListImageVersionsResponse) String

func (x *ListImageVersionsResponse) String() string

LoadSnapshotRequest

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

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

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

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

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

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

}

Request to load a snapshot into a Cloud Composer environment.

func (*LoadSnapshotRequest) Descriptor

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

Deprecated: Use LoadSnapshotRequest.ProtoReflect.Descriptor instead.

func (*LoadSnapshotRequest) GetEnvironment

func (x *LoadSnapshotRequest) GetEnvironment() string

func (*LoadSnapshotRequest) GetSkipAirflowOverridesSetting

func (x *LoadSnapshotRequest) GetSkipAirflowOverridesSetting() bool

func (*LoadSnapshotRequest) GetSkipEnvironmentVariablesSetting

func (x *LoadSnapshotRequest) GetSkipEnvironmentVariablesSetting() bool

func (*LoadSnapshotRequest) GetSkipGcsDataCopying

func (x *LoadSnapshotRequest) GetSkipGcsDataCopying() bool

func (*LoadSnapshotRequest) GetSkipPypiPackagesInstallation

func (x *LoadSnapshotRequest) GetSkipPypiPackagesInstallation() bool

func (*LoadSnapshotRequest) GetSnapshotPath

func (x *LoadSnapshotRequest) GetSnapshotPath() string

func (*LoadSnapshotRequest) ProtoMessage

func (*LoadSnapshotRequest) ProtoMessage()

func (*LoadSnapshotRequest) ProtoReflect

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

func (*LoadSnapshotRequest) Reset

func (x *LoadSnapshotRequest) Reset()

func (*LoadSnapshotRequest) String

func (x *LoadSnapshotRequest) String() string

LoadSnapshotResponse

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

Response to LoadSnapshotRequest.

func (*LoadSnapshotResponse) Descriptor

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

Deprecated: Use LoadSnapshotResponse.ProtoReflect.Descriptor instead.

func (*LoadSnapshotResponse) ProtoMessage

func (*LoadSnapshotResponse) ProtoMessage()

func (*LoadSnapshotResponse) ProtoReflect

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

func (*LoadSnapshotResponse) Reset

func (x *LoadSnapshotResponse) Reset()

func (*LoadSnapshotResponse) String

func (x *LoadSnapshotResponse) String() string

MaintenanceWindow

type MaintenanceWindow struct {

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

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

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

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

func (*MaintenanceWindow) Descriptor

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

Deprecated: Use MaintenanceWindow.ProtoReflect.Descriptor instead.

func (*MaintenanceWindow) GetEndTime

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

func (*MaintenanceWindow) GetRecurrence

func (x *MaintenanceWindow) GetRecurrence() string

func (*MaintenanceWindow) GetStartTime

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

func (*MaintenanceWindow) ProtoMessage

func (*MaintenanceWindow) ProtoMessage()

func (*MaintenanceWindow) ProtoReflect

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

func (*MaintenanceWindow) Reset

func (x *MaintenanceWindow) Reset()

func (*MaintenanceWindow) String

func (x *MaintenanceWindow) String() string

MasterAuthorizedNetworksConfig

type MasterAuthorizedNetworksConfig struct {

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

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

func (*MasterAuthorizedNetworksConfig) Descriptor

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

Deprecated: Use MasterAuthorizedNetworksConfig.ProtoReflect.Descriptor instead.

func (*MasterAuthorizedNetworksConfig) GetCidrBlocks

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

func (*MasterAuthorizedNetworksConfig) GetEnabled

func (x *MasterAuthorizedNetworksConfig) GetEnabled() bool

func (*MasterAuthorizedNetworksConfig) ProtoMessage

func (*MasterAuthorizedNetworksConfig) ProtoMessage()

func (*MasterAuthorizedNetworksConfig) ProtoReflect

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

func (*MasterAuthorizedNetworksConfig) Reset

func (x *MasterAuthorizedNetworksConfig) Reset()

func (*MasterAuthorizedNetworksConfig) String

func (x *MasterAuthorizedNetworksConfig) String() string

MasterAuthorizedNetworksConfig_CidrBlock

type MasterAuthorizedNetworksConfig_CidrBlock struct {

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

CIDR block with an optional name.

func (*MasterAuthorizedNetworksConfig_CidrBlock) Descriptor

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

Deprecated: Use MasterAuthorizedNetworksConfig_CidrBlock.ProtoReflect.Descriptor instead.

func (*MasterAuthorizedNetworksConfig_CidrBlock) GetCidrBlock

func (x *MasterAuthorizedNetworksConfig_CidrBlock) GetCidrBlock() string

func (*MasterAuthorizedNetworksConfig_CidrBlock) GetDisplayName

func (x *MasterAuthorizedNetworksConfig_CidrBlock) GetDisplayName() string

func (*MasterAuthorizedNetworksConfig_CidrBlock) ProtoMessage

func (*MasterAuthorizedNetworksConfig_CidrBlock) ProtoMessage()

func (*MasterAuthorizedNetworksConfig_CidrBlock) ProtoReflect

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

func (*MasterAuthorizedNetworksConfig_CidrBlock) Reset

func (x *MasterAuthorizedNetworksConfig_CidrBlock) Reset()

func (*MasterAuthorizedNetworksConfig_CidrBlock) String

func (x *MasterAuthorizedNetworksConfig_CidrBlock) String() string

NetworkingConfig

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

}

Configuration options for networking connections in the Composer 2 environment.

func (*NetworkingConfig) Descriptor

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

Deprecated: Use NetworkingConfig.ProtoReflect.Descriptor instead.

func (*NetworkingConfig) GetConnectionType

func (x *NetworkingConfig) GetConnectionType() NetworkingConfig_ConnectionType

func (*NetworkingConfig) ProtoMessage

func (*NetworkingConfig) ProtoMessage()

func (*NetworkingConfig) ProtoReflect

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

func (*NetworkingConfig) Reset

func (x *NetworkingConfig) Reset()

func (*NetworkingConfig) String

func (x *NetworkingConfig) String() string

NetworkingConfig_ConnectionType

type NetworkingConfig_ConnectionType int32

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

NetworkingConfig_CONNECTION_TYPE_UNSPECIFIED, NetworkingConfig_VPC_PEERING, NetworkingConfig_PRIVATE_SERVICE_CONNECT

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

func (NetworkingConfig_ConnectionType) Descriptor

func (NetworkingConfig_ConnectionType) Descriptor() protoreflect.EnumDescriptor

func (NetworkingConfig_ConnectionType) Enum

func (x NetworkingConfig_ConnectionType) Enum() *NetworkingConfig_ConnectionType

func (NetworkingConfig_ConnectionType) EnumDescriptor

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

Deprecated: Use NetworkingConfig_ConnectionType.Descriptor instead.

func (NetworkingConfig_ConnectionType) Number

func (x NetworkingConfig_ConnectionType) Number() protoreflect.EnumNumber

func (NetworkingConfig_ConnectionType) String

func (x NetworkingConfig_ConnectionType) String() string

func (NetworkingConfig_ConnectionType) Type

func (NetworkingConfig_ConnectionType) Type() protoreflect.EnumType

NodeConfig

type NodeConfig struct {

	// 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.
	//
	// This field is supported for Cloud Composer environments in versions
	// composer-1.*.*-airflow-*.*.*.
	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".
	//
	// This field is supported for Cloud Composer environments in versions
	// composer-1.*.*-airflow-*.*.*.
	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 30GB.
	// If unspecified, defaults to 100GB. Cannot be updated.
	//
	// This field is supported for Cloud Composer environments in versions
	// composer-1.*.*-airflow-*.*.*.
	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.
	//
	// This field is supported for Cloud Composer environments in versions
	// composer-1.*.*-airflow-*.*.*.
	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"`
	// Optional. Deploys 'ip-masq-agent' daemon set in the GKE cluster and defines
	// nonMasqueradeCIDRs equals to pod IP range so IP masquerading is used for
	// all destination addresses, except between pods traffic.
	//
	// See:
	// https://cloud.google.com/kubernetes-engine/docs/how-to/ip-masquerade-agent
	EnableIpMasqAgent bool `protobuf:"varint,11,opt,name=enable_ip_masq_agent,json=enableIpMasqAgent,proto3" json:"enable_ip_masq_agent,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) GetEnableIpMasqAgent

func (x *NodeConfig) GetEnableIpMasqAgent() bool

func (*NodeConfig) GetIpAllocationPolicy

func (x *NodeConfig) GetIpAllocationPolicy() *IPAllocationPolicy

func (*NodeConfig) GetLocation

func (x *NodeConfig) GetLocation() string

func (*NodeConfig) GetMachineType

func (x *NodeConfig) GetMachineType() string

func (*NodeConfig) GetNetwork

func (x *NodeConfig) GetNetwork() string

func (*NodeConfig) GetOauthScopes

func (x *NodeConfig) GetOauthScopes() []string

func (*NodeConfig) GetServiceAccount

func (x *NodeConfig) GetServiceAccount() string

func (*NodeConfig) GetSubnetwork

func (x *NodeConfig) GetSubnetwork() string

func (*NodeConfig) GetTags

func (x *NodeConfig) GetTags() []string

func (*NodeConfig) ProtoMessage

func (*NodeConfig) ProtoMessage()

func (*NodeConfig) ProtoReflect

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

func (*NodeConfig) Reset

func (x *NodeConfig) Reset()

func (*NodeConfig) String

func (x *NodeConfig) String() string

OperationMetadata

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

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

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

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

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

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

}

Metadata describing an operation.

func (*OperationMetadata) Descriptor

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

Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.

func (*OperationMetadata) GetCreateTime

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

func (*OperationMetadata) GetEndTime

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

func (*OperationMetadata) GetOperationType

func (x *OperationMetadata) GetOperationType() OperationMetadata_Type

func (*OperationMetadata) GetResource

func (x *OperationMetadata) GetResource() string

func (*OperationMetadata) GetResourceUuid

func (x *OperationMetadata) GetResourceUuid() string

func (*OperationMetadata) GetState

func (x *OperationMetadata) GetState() OperationMetadata_State

func (*OperationMetadata) ProtoMessage

func (*OperationMetadata) ProtoMessage()

func (*OperationMetadata) ProtoReflect

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

func (*OperationMetadata) Reset

func (x *OperationMetadata) Reset()

func (*OperationMetadata) String

func (x *OperationMetadata) String() string

OperationMetadata_State

type OperationMetadata_State int32

An enum describing the overall state of an operation.

OperationMetadata_STATE_UNSPECIFIED, OperationMetadata_PENDING, OperationMetadata_RUNNING, OperationMetadata_SUCCEEDED, OperationMetadata_SUCCESSFUL, OperationMetadata_FAILED

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

func (OperationMetadata_State) Descriptor

func (OperationMetadata_State) Descriptor() protoreflect.EnumDescriptor

func (OperationMetadata_State) Enum

func (x OperationMetadata_State) Enum() *OperationMetadata_State

func (OperationMetadata_State) EnumDescriptor

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

Deprecated: Use OperationMetadata_State.Descriptor instead.

func (OperationMetadata_State) Number

func (x OperationMetadata_State) Number() protoreflect.EnumNumber

func (OperationMetadata_State) String

func (x OperationMetadata_State) String() string

func (OperationMetadata_State) Type

func (OperationMetadata_State) Type() protoreflect.EnumType

OperationMetadata_Type

type OperationMetadata_Type int32

Type of longrunning operation.

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

const (
	// Unused.
	OperationMetadata_TYPE_UNSPECIFIED OperationMetadata_Type = 0
	// A resource creation operation.
	OperationMetadata_CREATE OperationMetadata_Type = 1
	// A resource deletion operation.
	OperationMetadata_DELETE OperationMetadata_Type = 2
	// A resource update operation.
	OperationMetadata_UPDATE OperationMetadata_Type = 3
	// A resource check operation.
	OperationMetadata_CHECK OperationMetadata_Type = 4
	// Saves snapshot of the resource operation.
	OperationMetadata_SAVE_SNAPSHOT OperationMetadata_Type = 5
	// Loads snapshot of the resource operation.
	OperationMetadata_LOAD_SNAPSHOT OperationMetadata_Type = 6
)

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

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

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

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

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

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

}

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

func (*PrivateEnvironmentConfig) Descriptor

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

Deprecated: Use PrivateEnvironmentConfig.ProtoReflect.Descriptor instead.

func (*PrivateEnvironmentConfig) GetCloudComposerConnectionSubnetwork

func (x *PrivateEnvironmentConfig) GetCloudComposerConnectionSubnetwork() string

func (*PrivateEnvironmentConfig) GetCloudComposerNetworkIpv4CidrBlock

func (x *PrivateEnvironmentConfig) GetCloudComposerNetworkIpv4CidrBlock() string

func (*PrivateEnvironmentConfig) GetCloudComposerNetworkIpv4ReservedRange

func (x *PrivateEnvironmentConfig) GetCloudComposerNetworkIpv4ReservedRange() string

func (*PrivateEnvironmentConfig) GetCloudSqlIpv4CidrBlock

func (x *PrivateEnvironmentConfig) GetCloudSqlIpv4CidrBlock() string

func (*PrivateEnvironmentConfig) GetEnablePrivateEnvironment

func (x *PrivateEnvironmentConfig) GetEnablePrivateEnvironment() bool

func (*PrivateEnvironmentConfig) GetEnablePrivatelyUsedPublicIps

func (x *PrivateEnvironmentConfig) GetEnablePrivatelyUsedPublicIps() bool

func (*PrivateEnvironmentConfig) GetNetworkingConfig

func (x *PrivateEnvironmentConfig) GetNetworkingConfig() *NetworkingConfig

func (*PrivateEnvironmentConfig) GetPrivateClusterConfig

func (x *PrivateEnvironmentConfig) GetPrivateClusterConfig() *PrivateClusterConfig

func (*PrivateEnvironmentConfig) GetWebServerIpv4CidrBlock

func (x *PrivateEnvironmentConfig) GetWebServerIpv4CidrBlock() string

func (*PrivateEnvironmentConfig) GetWebServerIpv4ReservedRange

func (x *PrivateEnvironmentConfig) GetWebServerIpv4ReservedRange() string

func (*PrivateEnvironmentConfig) ProtoMessage

func (*PrivateEnvironmentConfig) ProtoMessage()

func (*PrivateEnvironmentConfig) ProtoReflect

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

func (*PrivateEnvironmentConfig) Reset

func (x *PrivateEnvironmentConfig) Reset()

func (*PrivateEnvironmentConfig) String

func (x *PrivateEnvironmentConfig) String() string

RecoveryConfig

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

}

The Recovery settings of an environment.

func (*RecoveryConfig) Descriptor

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

Deprecated: Use RecoveryConfig.ProtoReflect.Descriptor instead.

func (*RecoveryConfig) GetScheduledSnapshotsConfig

func (x *RecoveryConfig) GetScheduledSnapshotsConfig() *ScheduledSnapshotsConfig

func (*RecoveryConfig) ProtoMessage

func (*RecoveryConfig) ProtoMessage()

func (*RecoveryConfig) ProtoReflect

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

func (*RecoveryConfig) Reset

func (x *RecoveryConfig) Reset()

func (*RecoveryConfig) String

func (x *RecoveryConfig) String() string

SaveSnapshotRequest

type SaveSnapshotRequest struct {

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

Request to create a snapshot of a Cloud Composer environment.

func (*SaveSnapshotRequest) Descriptor

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

Deprecated: Use SaveSnapshotRequest.ProtoReflect.Descriptor instead.

func (*SaveSnapshotRequest) GetEnvironment

func (x *SaveSnapshotRequest) GetEnvironment() string

func (*SaveSnapshotRequest) GetSnapshotLocation

func (x *SaveSnapshotRequest) GetSnapshotLocation() string

func (*SaveSnapshotRequest) ProtoMessage

func (*SaveSnapshotRequest) ProtoMessage()

func (*SaveSnapshotRequest) ProtoReflect

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

func (*SaveSnapshotRequest) Reset

func (x *SaveSnapshotRequest) Reset()

func (*SaveSnapshotRequest) String

func (x *SaveSnapshotRequest) String() string

SaveSnapshotResponse

type SaveSnapshotResponse struct {

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

Response to SaveSnapshotRequest.

func (*SaveSnapshotResponse) Descriptor

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

Deprecated: Use SaveSnapshotResponse.ProtoReflect.Descriptor instead.

func (*SaveSnapshotResponse) GetSnapshotPath

func (x *SaveSnapshotResponse) GetSnapshotPath() string

func (*SaveSnapshotResponse) ProtoMessage

func (*SaveSnapshotResponse) ProtoMessage()

func (*SaveSnapshotResponse) ProtoReflect

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

func (*SaveSnapshotResponse) Reset

func (x *SaveSnapshotResponse) Reset()

func (*SaveSnapshotResponse) String

func (x *SaveSnapshotResponse) String() string

ScheduledSnapshotsConfig

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

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

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

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

}

The configuration for scheduled snapshot creation mechanism.

func (*ScheduledSnapshotsConfig) Descriptor

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

Deprecated: Use ScheduledSnapshotsConfig.ProtoReflect.Descriptor instead.

func (*ScheduledSnapshotsConfig) GetEnabled

func (x *ScheduledSnapshotsConfig) GetEnabled() bool

func (*ScheduledSnapshotsConfig) GetSnapshotCreationSchedule

func (x *ScheduledSnapshotsConfig) GetSnapshotCreationSchedule() string

func (*ScheduledSnapshotsConfig) GetSnapshotLocation

func (x *ScheduledSnapshotsConfig) GetSnapshotLocation() string

func (*ScheduledSnapshotsConfig) GetTimeZone

func (x *ScheduledSnapshotsConfig) GetTimeZone() string

func (*ScheduledSnapshotsConfig) ProtoMessage

func (*ScheduledSnapshotsConfig) ProtoMessage()

func (*ScheduledSnapshotsConfig) ProtoReflect

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

func (*ScheduledSnapshotsConfig) Reset

func (x *ScheduledSnapshotsConfig) Reset()

func (*ScheduledSnapshotsConfig) String

func (x *ScheduledSnapshotsConfig) String() string

SoftwareConfig

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

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

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

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

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

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

}

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

func (x *SoftwareConfig) GetSchedulerCount() int32

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) (*longrunningpb.Operation, error)

func (*UnimplementedEnvironmentsServer) DeleteEnvironment

func (*UnimplementedEnvironmentsServer) DeleteEnvironment(context.Context, *DeleteEnvironmentRequest) (*longrunningpb.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) LoadSnapshot

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

func (*UnimplementedEnvironmentsServer) SaveSnapshot

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

func (*UnimplementedEnvironmentsServer) UpdateEnvironment

func (*UnimplementedEnvironmentsServer) UpdateEnvironment(context.Context, *UpdateEnvironmentRequest) (*longrunningpb.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. Supported for Cloud Composer environments in versions
	//       composer-1.*.*-airflow-*.*.*.
	// * `config.webServerNetworkAccessControl`
	//     * Replace the environment's current `WebServerNetworkAccessControl`.
	// * `config.softwareConfig.airflowConfigOverrides`
	//     * Replace all Apache Airflow config overrides. If a replacement config
	//       overrides map is not included in `environment`, all config overrides
	//       are cleared.
	//       It is an error to provide both this mask and a mask specifying one or
	//       more individual config overrides.
	// * `config.softwareConfig.airflowConfigOverrides.`section-name
	//     * Override the Apache Airflow config property *name* in the
	//       section named *section*, preserving other properties. To
	//       delete the property override, include it in `updateMask` and omit its
	//       mapping in
	//       `environment.config.softwareConfig.airflowConfigOverrides`.
	//       It is an error to provide both a mask of this form and the
	//       `config.softwareConfig.airflowConfigOverrides` mask.
	// * `config.softwareConfig.envVariables`
	//     * Replace all environment variables. If a replacement environment
	//       variable map is not included in `environment`, all custom environment
	//       variables are cleared.
	// * `config.softwareConfig.schedulerCount`
	//     * Horizontally scale the number of schedulers in Airflow. A positive
	//       integer not greater than the number of nodes must be provided in the
	//       `config.softwareConfig.schedulerCount` field. Supported for Cloud
	//       Composer environments in versions composer-1.*.*-airflow-2.*.*.
	// * `config.databaseConfig.machineType`
	//     * Cloud SQL machine type used by Airflow database.
	//       It has to be one of: db-n1-standard-2, db-n1-standard-4,
	//       db-n1-standard-8 or db-n1-standard-16. Supported for Cloud Composer
	//       environments in versions composer-1.*.*-airflow-*.*.*.
	// * `config.webServerConfig.machineType`
	//     * Machine type on which Airflow web server is running.
	//       It has to be one of: composer-n1-webserver-2, composer-n1-webserver-4
	//       or composer-n1-webserver-8. Supported for Cloud Composer environments
	//       in versions composer-1.*.*-airflow-*.*.*.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,3,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

Update an environment.

func (*UpdateEnvironmentRequest) Descriptor

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

Deprecated: Use UpdateEnvironmentRequest.ProtoReflect.Descriptor instead.

func (*UpdateEnvironmentRequest) GetEnvironment

func (x *UpdateEnvironmentRequest) GetEnvironment() *Environment

func (*UpdateEnvironmentRequest) GetName

func (x *UpdateEnvironmentRequest) GetName() string

func (*UpdateEnvironmentRequest) GetUpdateMask

func (x *UpdateEnvironmentRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateEnvironmentRequest) ProtoMessage

func (*UpdateEnvironmentRequest) ProtoMessage()

func (*UpdateEnvironmentRequest) ProtoReflect

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

func (*UpdateEnvironmentRequest) Reset

func (x *UpdateEnvironmentRequest) Reset()

func (*UpdateEnvironmentRequest) String

func (x *UpdateEnvironmentRequest) String() string

WebServerConfig

type WebServerConfig struct {

	// Optional. Machine type on which Airflow web server is running.
	// It has to be one of: composer-n1-webserver-2, composer-n1-webserver-4 or
	// composer-n1-webserver-8.
	// If not specified, composer-n1-webserver-2 will be used.
	// Value custom is returned only in response, if Airflow web server parameters
	// were manually changed to a non-standard values.
	MachineType string `protobuf:"bytes,1,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"`
	// contains filtered or unexported fields
}

The configuration settings for the Airflow web server App Engine instance. Supported for Cloud Composer environments in versions composer-1..-airflow-..*

func (*WebServerConfig) Descriptor

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

Deprecated: Use WebServerConfig.ProtoReflect.Descriptor instead.

func (*WebServerConfig) GetMachineType

func (x *WebServerConfig) GetMachineType() string

func (*WebServerConfig) ProtoMessage

func (*WebServerConfig) ProtoMessage()

func (*WebServerConfig) ProtoReflect

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

func (*WebServerConfig) Reset

func (x *WebServerConfig) Reset()

func (*WebServerConfig) String

func (x *WebServerConfig) String() string

WebServerNetworkAccessControl

type WebServerNetworkAccessControl struct {

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

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

func (*WebServerNetworkAccessControl) Descriptor

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

Deprecated: Use WebServerNetworkAccessControl.ProtoReflect.Descriptor instead.

func (*WebServerNetworkAccessControl) GetAllowedIpRanges

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

func (*WebServerNetworkAccessControl) ProtoMessage

func (*WebServerNetworkAccessControl) ProtoMessage()

func (*WebServerNetworkAccessControl) ProtoReflect

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

func (*WebServerNetworkAccessControl) Reset

func (x *WebServerNetworkAccessControl) Reset()

func (*WebServerNetworkAccessControl) String

func (x *WebServerNetworkAccessControl) String() string

WebServerNetworkAccessControl_AllowedIpRange

type WebServerNetworkAccessControl_AllowedIpRange struct {

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

Allowed IP range with user-provided description.

func (*WebServerNetworkAccessControl_AllowedIpRange) Descriptor

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

Deprecated: Use WebServerNetworkAccessControl_AllowedIpRange.ProtoReflect.Descriptor instead.

func (*WebServerNetworkAccessControl_AllowedIpRange) GetDescription

func (x *WebServerNetworkAccessControl_AllowedIpRange) GetDescription() string

func (*WebServerNetworkAccessControl_AllowedIpRange) GetValue

func (x *WebServerNetworkAccessControl_AllowedIpRange) GetValue() string

func (*WebServerNetworkAccessControl_AllowedIpRange) ProtoMessage

func (*WebServerNetworkAccessControl_AllowedIpRange) ProtoMessage()

func (*WebServerNetworkAccessControl_AllowedIpRange) ProtoReflect

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

func (*WebServerNetworkAccessControl_AllowedIpRange) Reset

func (x *WebServerNetworkAccessControl_AllowedIpRange) Reset()

func (*WebServerNetworkAccessControl_AllowedIpRange) String

func (x *WebServerNetworkAccessControl_AllowedIpRange) String() string

WorkloadsConfig

type WorkloadsConfig struct {

	// Optional. Resources used by Airflow schedulers.
	Scheduler *WorkloadsConfig_SchedulerResource `protobuf:"bytes,1,opt,name=scheduler,proto3" json:"scheduler,omitempty"`
	// Optional. Resources used by Airflow web server.
	WebServer *WorkloadsConfig_WebServerResource `protobuf:"bytes,2,opt,name=web_server,json=webServer,proto3" json:"web_server,omitempty"`
	// Optional. Resources used by Airflow workers.
	Worker *WorkloadsConfig_WorkerResource `protobuf:"bytes,3,opt,name=worker,proto3" json:"worker,omitempty"`
	// contains filtered or unexported fields
}

The Kubernetes workloads configuration for GKE cluster associated with the Cloud Composer environment. Supported for Cloud Composer environments in versions composer-2..-airflow-..* and newer.

func (*WorkloadsConfig) Descriptor

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

Deprecated: Use WorkloadsConfig.ProtoReflect.Descriptor instead.

func (*WorkloadsConfig) GetScheduler

func (x *WorkloadsConfig) GetScheduler() *WorkloadsConfig_SchedulerResource

func (*WorkloadsConfig) GetWebServer

func (x *WorkloadsConfig) GetWebServer() *WorkloadsConfig_WebServerResource

func (*WorkloadsConfig) GetWorker

func (x *WorkloadsConfig) GetWorker() *WorkloadsConfig_WorkerResource

func (*WorkloadsConfig) ProtoMessage

func (*WorkloadsConfig) ProtoMessage()

func (*WorkloadsConfig) ProtoReflect

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

func (*WorkloadsConfig) Reset

func (x *WorkloadsConfig) Reset()

func (*WorkloadsConfig) String

func (x *WorkloadsConfig) String() string

WorkloadsConfig_SchedulerResource

type WorkloadsConfig_SchedulerResource struct {

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

Configuration for resources used by Airflow schedulers.

func (*WorkloadsConfig_SchedulerResource) Descriptor

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

Deprecated: Use WorkloadsConfig_SchedulerResource.ProtoReflect.Descriptor instead.

func (*WorkloadsConfig_SchedulerResource) GetCount

func (x *WorkloadsConfig_SchedulerResource) GetCount() int32

func (*WorkloadsConfig_SchedulerResource) GetCpu

func (x *WorkloadsConfig_SchedulerResource) GetCpu() float32

func (*WorkloadsConfig_SchedulerResource) GetMemoryGb

func (x *WorkloadsConfig_SchedulerResource) GetMemoryGb() float32

func (*WorkloadsConfig_SchedulerResource) GetStorageGb

func (x *WorkloadsConfig_SchedulerResource) GetStorageGb() float32

func (*WorkloadsConfig_SchedulerResource) ProtoMessage

func (*WorkloadsConfig_SchedulerResource) ProtoMessage()

func (*WorkloadsConfig_SchedulerResource) ProtoReflect

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

func (*WorkloadsConfig_SchedulerResource) Reset

func (x *WorkloadsConfig_SchedulerResource) Reset()

func (*WorkloadsConfig_SchedulerResource) String

func (x *WorkloadsConfig_SchedulerResource) String() string

WorkloadsConfig_WebServerResource

type WorkloadsConfig_WebServerResource struct {

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

Configuration for resources used by Airflow web server.

func (*WorkloadsConfig_WebServerResource) Descriptor

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

Deprecated: Use WorkloadsConfig_WebServerResource.ProtoReflect.Descriptor instead.

func (*WorkloadsConfig_WebServerResource) GetCpu

func (x *WorkloadsConfig_WebServerResource) GetCpu() float32

func (*WorkloadsConfig_WebServerResource) GetMemoryGb

func (x *WorkloadsConfig_WebServerResource) GetMemoryGb() float32

func (*WorkloadsConfig_WebServerResource) GetStorageGb

func (x *WorkloadsConfig_WebServerResource) GetStorageGb() float32

func (*WorkloadsConfig_WebServerResource) ProtoMessage

func (*WorkloadsConfig_WebServerResource) ProtoMessage()

func (*WorkloadsConfig_WebServerResource) ProtoReflect

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

func (*WorkloadsConfig_WebServerResource) Reset

func (x *WorkloadsConfig_WebServerResource) Reset()

func (*WorkloadsConfig_WebServerResource) String

func (x *WorkloadsConfig_WebServerResource) String() string

WorkloadsConfig_WorkerResource

type WorkloadsConfig_WorkerResource struct {

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

Configuration for resources used by Airflow workers.

func (*WorkloadsConfig_WorkerResource) Descriptor

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

Deprecated: Use WorkloadsConfig_WorkerResource.ProtoReflect.Descriptor instead.

func (*WorkloadsConfig_WorkerResource) GetCpu

func (x *WorkloadsConfig_WorkerResource) GetCpu() float32

func (*WorkloadsConfig_WorkerResource) GetMaxCount

func (x *WorkloadsConfig_WorkerResource) GetMaxCount() int32

func (*WorkloadsConfig_WorkerResource) GetMemoryGb

func (x *WorkloadsConfig_WorkerResource) GetMemoryGb() float32

func (*WorkloadsConfig_WorkerResource) GetMinCount

func (x *WorkloadsConfig_WorkerResource) GetMinCount() int32

func (*WorkloadsConfig_WorkerResource) GetStorageGb

func (x *WorkloadsConfig_WorkerResource) GetStorageGb() float32

func (*WorkloadsConfig_WorkerResource) ProtoMessage

func (*WorkloadsConfig_WorkerResource) ProtoMessage()

func (*WorkloadsConfig_WorkerResource) ProtoReflect

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

func (*WorkloadsConfig_WorkerResource) Reset

func (x *WorkloadsConfig_WorkerResource) Reset()

func (*WorkloadsConfig_WorkerResource) String

func (x *WorkloadsConfig_WorkerResource) String() string