airflow

package
v0.0.0-...-204702d Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 14, 2024 License: MIT Imports: 15 Imported by: 3

Documentation

Index

Constants

View Source 
const (
	ClusterService_Get_FullMethodName            = "/yandex.cloud.airflow.v1.ClusterService/Get"
	ClusterService_List_FullMethodName           = "/yandex.cloud.airflow.v1.ClusterService/List"
	ClusterService_Create_FullMethodName         = "/yandex.cloud.airflow.v1.ClusterService/Create"
	ClusterService_Update_FullMethodName         = "/yandex.cloud.airflow.v1.ClusterService/Update"
	ClusterService_Delete_FullMethodName         = "/yandex.cloud.airflow.v1.ClusterService/Delete"
	ClusterService_Start_FullMethodName          = "/yandex.cloud.airflow.v1.ClusterService/Start"
	ClusterService_Stop_FullMethodName           = "/yandex.cloud.airflow.v1.ClusterService/Stop"
	ClusterService_ListOperations_FullMethodName = "/yandex.cloud.airflow.v1.ClusterService/ListOperations"
)

Variables

View Source 
var (
	Cluster_Status_name = map[int32]string{
		0: "STATUS_UNKNOWN",
		1: "CREATING",
		2: "RUNNING",
		3: "ERROR",
		4: "STOPPING",
		5: "STOPPED",
		6: "STARTING",
		7: "UPDATING",
	}
	Cluster_Status_value = map[string]int32{
		"STATUS_UNKNOWN": 0,
		"CREATING":       1,
		"RUNNING":        2,
		"ERROR":          3,
		"STOPPING":       4,
		"STOPPED":        5,
		"STARTING":       6,
		"UPDATING":       7,
	}
)

Enum value maps for Cluster_Status.

View Source 
var (
	Health_name = map[int32]string{
		0: "HEALTH_UNKNOWN",
		1: "ALIVE",
		2: "DEAD",
		3: "DEGRADED",
	}
	Health_value = map[string]int32{
		"HEALTH_UNKNOWN": 0,
		"ALIVE":          1,
		"DEAD":           2,
		"DEGRADED":       3,
	}
)

Enum value maps for Health.

View Source 
var ClusterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.airflow.v1.ClusterService",
	HandlerType: (*ClusterServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _ClusterService_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _ClusterService_List_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _ClusterService_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _ClusterService_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _ClusterService_Delete_Handler,
		},
		{
			MethodName: "Start",
			Handler:    _ClusterService_Start_Handler,
		},
		{
			MethodName: "Stop",
			Handler:    _ClusterService_Stop_Handler,
		},
		{
			MethodName: "ListOperations",
			Handler:    _ClusterService_ListOperations_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "yandex/cloud/airflow/v1/cluster_service.proto",
}

ClusterService_ServiceDesc is the grpc.ServiceDesc for ClusterService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_yandex_cloud_airflow_v1_cluster_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_airflow_v1_cluster_service_proto protoreflect.FileDescriptor
View Source 
var File_yandex_cloud_airflow_v1_common_proto protoreflect.FileDescriptor

Functions

func RegisterClusterServiceServer 

func RegisterClusterServiceServer(s grpc.ServiceRegistrar, srv ClusterServiceServer)

Types

type AirflowConfig 

type AirflowConfig struct {

	// Properties to be passed to Apache Airflow configuration file.
	Config map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AirflowConfig) Descriptor deprecated 

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

Deprecated: Use AirflowConfig.ProtoReflect.Descriptor instead.

func (*AirflowConfig) GetConfig 

func (x *AirflowConfig) GetConfig() map[string]string

func (*AirflowConfig) ProtoMessage 

func (*AirflowConfig) ProtoMessage()

func (*AirflowConfig) ProtoReflect 

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

func (*AirflowConfig) Reset 

func (x *AirflowConfig) Reset()

func (*AirflowConfig) SetConfig 

func (m *AirflowConfig) SetConfig(v map[string]string)

func (*AirflowConfig) String 

func (x *AirflowConfig) String() string

type Cluster 

type Cluster struct {

	// Unique ID of the Apache Airflow cluster.
	// This ID is assigned by Cloud during cluster creation.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// ID of the folder that the Apache Airflow cluster belongs to.
	FolderId string `protobuf:"bytes,2,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// The time when the Apache Airflow cluster was created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Name of the Apache Airflow cluster.
	// The name is unique within the folder. 1-64 characters long.
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the Apache Airflow cluster. 0-256 characters long.
	Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	// Resource labels as `key:value` pairs. Maximum of 64 per resource.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Monitoring systems relevant to the Apache Airflow cluster.
	Monitoring []*Monitoring `protobuf:"bytes,8,rep,name=monitoring,proto3" json:"monitoring,omitempty"`
	// Configuration of Apache Airflow components.
	Config *ClusterConfig `protobuf:"bytes,9,opt,name=config,proto3" json:"config,omitempty"`
	// Aggregated cluster health.
	Health Health `protobuf:"varint,10,opt,name=health,proto3,enum=yandex.cloud.airflow.v1.Health" json:"health,omitempty"`
	// Cluster status.
	Status Cluster_Status `protobuf:"varint,11,opt,name=status,proto3,enum=yandex.cloud.airflow.v1.Cluster_Status" json:"status,omitempty"`
	// Network related configuration options.
	Network *NetworkConfig `protobuf:"bytes,12,opt,name=network,proto3" json:"network,omitempty"`
	// Parameters of the location and access to the code that will be executed in the cluster.
	CodeSync *CodeSyncConfig `protobuf:"bytes,13,opt,name=code_sync,json=codeSync,proto3" json:"code_sync,omitempty"`
	// Deletion Protection inhibits deletion of the cluster.
	DeletionProtection bool `protobuf:"varint,14,opt,name=deletion_protection,json=deletionProtection,proto3" json:"deletion_protection,omitempty"`
	// Address of Apache Airflow web UI.
	WebserverUrl string `protobuf:"bytes,15,opt,name=webserver_url,json=webserverUrl,proto3" json:"webserver_url,omitempty"`
	// Service account used to access Cloud resources.
	// For more information, see [documentation](/docs/managed-airflow/concepts/impersonation).
	ServiceAccountId string `protobuf:"bytes,16,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// Cloud Logging configuration.
	Logging *LoggingConfig `protobuf:"bytes,17,opt,name=logging,proto3" json:"logging,omitempty"`
	// contains filtered or unexported fields
}

Apache Airflow cluster.

func (*Cluster) Descriptor deprecated 

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

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetCodeSync 

func (x *Cluster) GetCodeSync() *CodeSyncConfig

func (*Cluster) GetConfig 

func (x *Cluster) GetConfig() *ClusterConfig

func (*Cluster) GetCreatedAt 

func (x *Cluster) GetCreatedAt() *timestamppb.Timestamp

func (*Cluster) GetDeletionProtection 

func (x *Cluster) GetDeletionProtection() bool

func (*Cluster) GetDescription 

func (x *Cluster) GetDescription() string

func (*Cluster) GetFolderId 

func (x *Cluster) GetFolderId() string

func (*Cluster) GetHealth 

func (x *Cluster) GetHealth() Health

func (*Cluster) GetId 

func (x *Cluster) GetId() string

func (*Cluster) GetLabels 

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

func (*Cluster) GetLogging 

func (x *Cluster) GetLogging() *LoggingConfig

func (*Cluster) GetMonitoring 

func (x *Cluster) GetMonitoring() []*Monitoring

func (*Cluster) GetName 

func (x *Cluster) GetName() string

func (*Cluster) GetNetwork 

func (x *Cluster) GetNetwork() *NetworkConfig

func (*Cluster) GetServiceAccountId 

func (x *Cluster) GetServiceAccountId() string

func (*Cluster) GetStatus 

func (x *Cluster) GetStatus() Cluster_Status

func (*Cluster) GetWebserverUrl 

func (x *Cluster) GetWebserverUrl() string

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect 

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

func (*Cluster) Reset 

func (x *Cluster) Reset()

func (*Cluster) SetCodeSync 

func (m *Cluster) SetCodeSync(v *CodeSyncConfig)

func (*Cluster) SetConfig 

func (m *Cluster) SetConfig(v *ClusterConfig)

func (*Cluster) SetCreatedAt 

func (m *Cluster) SetCreatedAt(v *timestamppb.Timestamp)

func (*Cluster) SetDeletionProtection 

func (m *Cluster) SetDeletionProtection(v bool)

func (*Cluster) SetDescription 

func (m *Cluster) SetDescription(v string)

func (*Cluster) SetFolderId 

func (m *Cluster) SetFolderId(v string)

func (*Cluster) SetHealth 

func (m *Cluster) SetHealth(v Health)

func (*Cluster) SetId 

func (m *Cluster) SetId(v string)

func (*Cluster) SetLabels 

func (m *Cluster) SetLabels(v map[string]string)

func (*Cluster) SetLogging 

func (m *Cluster) SetLogging(v *LoggingConfig)

func (*Cluster) SetMonitoring 

func (m *Cluster) SetMonitoring(v []*Monitoring)

func (*Cluster) SetName 

func (m *Cluster) SetName(v string)

func (*Cluster) SetNetwork 

func (m *Cluster) SetNetwork(v *NetworkConfig)

func (*Cluster) SetServiceAccountId 

func (m *Cluster) SetServiceAccountId(v string)

func (*Cluster) SetStatus 

func (m *Cluster) SetStatus(v Cluster_Status)

func (*Cluster) SetWebserverUrl 

func (m *Cluster) SetWebserverUrl(v string)

func (*Cluster) String 

func (x *Cluster) String() string

type ClusterConfig 

type ClusterConfig struct {

	// Version of Apache that runs on the cluster.
	VersionId string `protobuf:"bytes,1,opt,name=version_id,json=versionId,proto3" json:"version_id,omitempty"`
	// Configuration of the Apache Airflow application itself.
	Airflow *AirflowConfig `protobuf:"bytes,2,opt,name=airflow,proto3" json:"airflow,omitempty"`
	// Configuration of webserver instances.
	Webserver *WebserverConfig `protobuf:"bytes,3,opt,name=webserver,proto3" json:"webserver,omitempty"`
	// Configuration of scheduler instances.
	Scheduler *SchedulerConfig `protobuf:"bytes,4,opt,name=scheduler,proto3" json:"scheduler,omitempty"`
	// Configuration of triggerer instances.
	Triggerer *TriggererConfig `protobuf:"bytes,5,opt,name=triggerer,proto3" json:"triggerer,omitempty"`
	// Configuration of worker instances.
	Worker *WorkerConfig `protobuf:"bytes,6,opt,name=worker,proto3" json:"worker,omitempty"`
	// The list of additional packages installed in the cluster.
	Dependencies *Dependencies `protobuf:"bytes,7,opt,name=dependencies,proto3" json:"dependencies,omitempty"`
	// Configuration of Lockbox Secret Backend.
	Lockbox *LockboxConfig `protobuf:"bytes,8,opt,name=lockbox,proto3" json:"lockbox,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterConfig) Descriptor deprecated 

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

Deprecated: Use ClusterConfig.ProtoReflect.Descriptor instead.

func (*ClusterConfig) GetAirflow 

func (x *ClusterConfig) GetAirflow() *AirflowConfig

func (*ClusterConfig) GetDependencies 

func (x *ClusterConfig) GetDependencies() *Dependencies

func (*ClusterConfig) GetLockbox 

func (x *ClusterConfig) GetLockbox() *LockboxConfig

func (*ClusterConfig) GetScheduler 

func (x *ClusterConfig) GetScheduler() *SchedulerConfig

func (*ClusterConfig) GetTriggerer 

func (x *ClusterConfig) GetTriggerer() *TriggererConfig

func (*ClusterConfig) GetVersionId 

func (x *ClusterConfig) GetVersionId() string

func (*ClusterConfig) GetWebserver 

func (x *ClusterConfig) GetWebserver() *WebserverConfig

func (*ClusterConfig) GetWorker 

func (x *ClusterConfig) GetWorker() *WorkerConfig

func (*ClusterConfig) ProtoMessage 

func (*ClusterConfig) ProtoMessage()

func (*ClusterConfig) ProtoReflect 

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

func (*ClusterConfig) Reset 

func (x *ClusterConfig) Reset()

func (*ClusterConfig) SetAirflow 

func (m *ClusterConfig) SetAirflow(v *AirflowConfig)

func (*ClusterConfig) SetDependencies 

func (m *ClusterConfig) SetDependencies(v *Dependencies)

func (*ClusterConfig) SetLockbox 

func (m *ClusterConfig) SetLockbox(v *LockboxConfig)

func (*ClusterConfig) SetScheduler 

func (m *ClusterConfig) SetScheduler(v *SchedulerConfig)

func (*ClusterConfig) SetTriggerer 

func (m *ClusterConfig) SetTriggerer(v *TriggererConfig)

func (*ClusterConfig) SetVersionId 

func (m *ClusterConfig) SetVersionId(v string)

func (*ClusterConfig) SetWebserver 

func (m *ClusterConfig) SetWebserver(v *WebserverConfig)

func (*ClusterConfig) SetWorker 

func (m *ClusterConfig) SetWorker(v *WorkerConfig)

func (*ClusterConfig) String 

func (x *ClusterConfig) String() string

type ClusterServiceClient 

type ClusterServiceClient interface {
	// Returns the specified Apache Airflow Cluster resource.
	Get(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*Cluster, error)
	// Retrieves a list of Apache Airflow Cluster resources.
	List(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error)
	// Creates an Apache Airflow cluster.
	Create(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Updates the specified Apache Airflow cluster.
	Update(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Deletes the specified Apache Airflow cluster.
	Delete(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Starts the specified Apache Airflow cluster.
	Start(ctx context.Context, in *StartClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Stops the specified Apache Airflow cluster.
	Stop(ctx context.Context, in *StopClusterRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Retrieves the list of Operation resources for the specified cluster.
	ListOperations(ctx context.Context, in *ListClusterOperationsRequest, opts ...grpc.CallOption) (*ListClusterOperationsResponse, error)
}

ClusterServiceClient is the client API for ClusterService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

A set of methods for managing Apache Airflow Cluster resources.

func NewClusterServiceClient 

func NewClusterServiceClient(cc grpc.ClientConnInterface) ClusterServiceClient

type ClusterServiceServer 

type ClusterServiceServer interface {
	// Returns the specified Apache Airflow Cluster resource.
	Get(context.Context, *GetClusterRequest) (*Cluster, error)
	// Retrieves a list of Apache Airflow Cluster resources.
	List(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
	// Creates an Apache Airflow cluster.
	Create(context.Context, *CreateClusterRequest) (*operation.Operation, error)
	// Updates the specified Apache Airflow cluster.
	Update(context.Context, *UpdateClusterRequest) (*operation.Operation, error)
	// Deletes the specified Apache Airflow cluster.
	Delete(context.Context, *DeleteClusterRequest) (*operation.Operation, error)
	// Starts the specified Apache Airflow cluster.
	Start(context.Context, *StartClusterRequest) (*operation.Operation, error)
	// Stops the specified Apache Airflow cluster.
	Stop(context.Context, *StopClusterRequest) (*operation.Operation, error)
	// Retrieves the list of Operation resources for the specified cluster.
	ListOperations(context.Context, *ListClusterOperationsRequest) (*ListClusterOperationsResponse, error)
}

ClusterServiceServer is the server API for ClusterService service. All implementations should embed UnimplementedClusterServiceServer for forward compatibility.

A set of methods for managing Apache Airflow Cluster resources.

type Cluster_Status 

type Cluster_Status int32
const (
	// Cluster state is unknown.
	Cluster_STATUS_UNKNOWN Cluster_Status = 0
	// Cluster is being created.
	Cluster_CREATING Cluster_Status = 1
	// Cluster is running normally.
	Cluster_RUNNING Cluster_Status = 2
	// Cluster encountered a problem and cannot operate.
	Cluster_ERROR Cluster_Status = 3
	// Cluster is stopping.
	Cluster_STOPPING Cluster_Status = 4
	// Cluster is stopped.
	Cluster_STOPPED Cluster_Status = 5
	// Cluster is starting.
	Cluster_STARTING Cluster_Status = 6
	// Cluster is being updated.
	Cluster_UPDATING Cluster_Status = 7
)

func (Cluster_Status) Descriptor 

func (Cluster_Status) Descriptor() protoreflect.EnumDescriptor

func (Cluster_Status) Enum 

func (x Cluster_Status) Enum() *Cluster_Status

func (Cluster_Status) EnumDescriptor deprecated 

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

Deprecated: Use Cluster_Status.Descriptor instead.

func (Cluster_Status) Number 

func (x Cluster_Status) Number() protoreflect.EnumNumber

func (Cluster_Status) String 

func (x Cluster_Status) String() string

func (Cluster_Status) Type 

func (Cluster_Status) Type() protoreflect.EnumType

type CodeSyncConfig 

type CodeSyncConfig struct {

	// Types that are assignable to Source:
	//
	//	*CodeSyncConfig_S3
	Source isCodeSyncConfig_Source `protobuf_oneof:"source"`
	// contains filtered or unexported fields
}

func (*CodeSyncConfig) Descriptor deprecated 

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

Deprecated: Use CodeSyncConfig.ProtoReflect.Descriptor instead.

func (*CodeSyncConfig) GetS3 

func (x *CodeSyncConfig) GetS3() *S3Config

func (*CodeSyncConfig) GetSource 

func (m *CodeSyncConfig) GetSource() isCodeSyncConfig_Source

func (*CodeSyncConfig) ProtoMessage 

func (*CodeSyncConfig) ProtoMessage()

func (*CodeSyncConfig) ProtoReflect 

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

func (*CodeSyncConfig) Reset 

func (x *CodeSyncConfig) Reset()

func (*CodeSyncConfig) SetS3 

func (m *CodeSyncConfig) SetS3(v *S3Config)

func (*CodeSyncConfig) SetSource 

func (m *CodeSyncConfig) SetSource(v CodeSyncConfig_Source)

func (*CodeSyncConfig) String 

func (x *CodeSyncConfig) String() string

type CodeSyncConfig_S3 

type CodeSyncConfig_S3 struct {
	S3 *S3Config `protobuf:"bytes,1,opt,name=s3,proto3,oneof"`
}

type CodeSyncConfig_Source 

type CodeSyncConfig_Source = isCodeSyncConfig_Source

type CreateClusterMetadata 

type CreateClusterMetadata struct {

	// ID of the Apache Airflow cluster that is being created.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateClusterMetadata) Descriptor deprecated 

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

Deprecated: Use CreateClusterMetadata.ProtoReflect.Descriptor instead.

func (*CreateClusterMetadata) GetClusterId 

func (x *CreateClusterMetadata) GetClusterId() string

func (*CreateClusterMetadata) ProtoMessage 

func (*CreateClusterMetadata) ProtoMessage()

func (*CreateClusterMetadata) ProtoReflect 

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

func (*CreateClusterMetadata) Reset 

func (x *CreateClusterMetadata) Reset()

func (*CreateClusterMetadata) SetClusterId 

func (m *CreateClusterMetadata) SetClusterId(v string)

func (*CreateClusterMetadata) String 

func (x *CreateClusterMetadata) String() string

type CreateClusterRequest 

type CreateClusterRequest struct {

	// ID of the folder to create Apache Airflow cluster in.
	FolderId string `protobuf:"bytes,1,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// Name of the Apache Airflow cluster. The name must be unique within the folder.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the Apache Airflow cluster.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Custom labels for the Apache Airflow cluster as “ key:value “ pairs. For example, "env": "prod".
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Configuration of Apache Airflow components.
	Config *ClusterConfig `protobuf:"bytes,6,opt,name=config,proto3" json:"config,omitempty"`
	// Network related configuration options.
	Network *NetworkConfig `protobuf:"bytes,7,opt,name=network,proto3" json:"network,omitempty"`
	// Parameters of the location and access to the code that will be executed in the cluster.
	CodeSync *CodeSyncConfig `protobuf:"bytes,8,opt,name=code_sync,json=codeSync,proto3" json:"code_sync,omitempty"`
	// Deletion Protection inhibits deletion of the cluster.
	DeletionProtection bool `protobuf:"varint,9,opt,name=deletion_protection,json=deletionProtection,proto3" json:"deletion_protection,omitempty"`
	// Service account used to access Cloud resources.
	// For more information, see [documentation](/docs/managed-airflow/concepts/impersonation).
	ServiceAccountId string `protobuf:"bytes,10,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// Cloud Logging configuration.
	Logging *LoggingConfig `protobuf:"bytes,11,opt,name=logging,proto3" json:"logging,omitempty"`
	// Password of user `admin`.
	AdminPassword string `protobuf:"bytes,12,opt,name=admin_password,json=adminPassword,proto3" json:"admin_password,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateClusterRequest) Descriptor deprecated 

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

Deprecated: Use CreateClusterRequest.ProtoReflect.Descriptor instead.

func (*CreateClusterRequest) GetAdminPassword 

func (x *CreateClusterRequest) GetAdminPassword() string

func (*CreateClusterRequest) GetCodeSync 

func (x *CreateClusterRequest) GetCodeSync() *CodeSyncConfig

func (*CreateClusterRequest) GetConfig 

func (x *CreateClusterRequest) GetConfig() *ClusterConfig

func (*CreateClusterRequest) GetDeletionProtection 

func (x *CreateClusterRequest) GetDeletionProtection() bool

func (*CreateClusterRequest) GetDescription 

func (x *CreateClusterRequest) GetDescription() string

func (*CreateClusterRequest) GetFolderId 

func (x *CreateClusterRequest) GetFolderId() string

func (*CreateClusterRequest) GetLabels 

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

func (*CreateClusterRequest) GetLogging 

func (x *CreateClusterRequest) GetLogging() *LoggingConfig

func (*CreateClusterRequest) GetName 

func (x *CreateClusterRequest) GetName() string

func (*CreateClusterRequest) GetNetwork 

func (x *CreateClusterRequest) GetNetwork() *NetworkConfig

func (*CreateClusterRequest) GetServiceAccountId 

func (x *CreateClusterRequest) GetServiceAccountId() string

func (*CreateClusterRequest) ProtoMessage 

func (*CreateClusterRequest) ProtoMessage()

func (*CreateClusterRequest) ProtoReflect 

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

func (*CreateClusterRequest) Reset 

func (x *CreateClusterRequest) Reset()

func (*CreateClusterRequest) SetAdminPassword 

func (m *CreateClusterRequest) SetAdminPassword(v string)

func (*CreateClusterRequest) SetCodeSync 

func (m *CreateClusterRequest) SetCodeSync(v *CodeSyncConfig)

func (*CreateClusterRequest) SetConfig 

func (m *CreateClusterRequest) SetConfig(v *ClusterConfig)

func (*CreateClusterRequest) SetDeletionProtection 

func (m *CreateClusterRequest) SetDeletionProtection(v bool)

func (*CreateClusterRequest) SetDescription 

func (m *CreateClusterRequest) SetDescription(v string)

func (*CreateClusterRequest) SetFolderId 

func (m *CreateClusterRequest) SetFolderId(v string)

func (*CreateClusterRequest) SetLabels 

func (m *CreateClusterRequest) SetLabels(v map[string]string)

func (*CreateClusterRequest) SetLogging 

func (m *CreateClusterRequest) SetLogging(v *LoggingConfig)

func (*CreateClusterRequest) SetName 

func (m *CreateClusterRequest) SetName(v string)

func (*CreateClusterRequest) SetNetwork 

func (m *CreateClusterRequest) SetNetwork(v *NetworkConfig)

func (*CreateClusterRequest) SetServiceAccountId 

func (m *CreateClusterRequest) SetServiceAccountId(v string)

func (*CreateClusterRequest) String 

func (x *CreateClusterRequest) String() string

type DeleteClusterMetadata 

type DeleteClusterMetadata struct {

	// ID of the Apache Airflow cluster that is being deleted.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteClusterMetadata) Descriptor deprecated 

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

Deprecated: Use DeleteClusterMetadata.ProtoReflect.Descriptor instead.

func (*DeleteClusterMetadata) GetClusterId 

func (x *DeleteClusterMetadata) GetClusterId() string

func (*DeleteClusterMetadata) ProtoMessage 

func (*DeleteClusterMetadata) ProtoMessage()

func (*DeleteClusterMetadata) ProtoReflect 

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

func (*DeleteClusterMetadata) Reset 

func (x *DeleteClusterMetadata) Reset()

func (*DeleteClusterMetadata) SetClusterId 

func (m *DeleteClusterMetadata) SetClusterId(v string)

func (*DeleteClusterMetadata) String 

func (x *DeleteClusterMetadata) String() string

type DeleteClusterRequest 

type DeleteClusterRequest struct {

	// ID of the Apache Airflow cluster to delete.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteClusterRequest) Descriptor deprecated 

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

Deprecated: Use DeleteClusterRequest.ProtoReflect.Descriptor instead.

func (*DeleteClusterRequest) GetClusterId 

func (x *DeleteClusterRequest) GetClusterId() string

func (*DeleteClusterRequest) ProtoMessage 

func (*DeleteClusterRequest) ProtoMessage()

func (*DeleteClusterRequest) ProtoReflect 

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

func (*DeleteClusterRequest) Reset 

func (x *DeleteClusterRequest) Reset()

func (*DeleteClusterRequest) SetClusterId 

func (m *DeleteClusterRequest) SetClusterId(v string)

func (*DeleteClusterRequest) String 

func (x *DeleteClusterRequest) String() string

type Dependencies 

type Dependencies struct {

	// Python packages that are installed in the cluster.
	PipPackages []string `protobuf:"bytes,1,rep,name=pip_packages,json=pipPackages,proto3" json:"pip_packages,omitempty"`
	// System packages that are installed in the cluster.
	DebPackages []string `protobuf:"bytes,2,rep,name=deb_packages,json=debPackages,proto3" json:"deb_packages,omitempty"`
	// contains filtered or unexported fields
}

func (*Dependencies) Descriptor deprecated 

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

Deprecated: Use Dependencies.ProtoReflect.Descriptor instead.

func (*Dependencies) GetDebPackages 

func (x *Dependencies) GetDebPackages() []string

func (*Dependencies) GetPipPackages 

func (x *Dependencies) GetPipPackages() []string

func (*Dependencies) ProtoMessage 

func (*Dependencies) ProtoMessage()

func (*Dependencies) ProtoReflect 

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

func (*Dependencies) Reset 

func (x *Dependencies) Reset()

func (*Dependencies) SetDebPackages 

func (m *Dependencies) SetDebPackages(v []string)

func (*Dependencies) SetPipPackages 

func (m *Dependencies) SetPipPackages(v []string)

func (*Dependencies) String 

func (x *Dependencies) String() string

type GetClusterRequest 

type GetClusterRequest struct {

	// ID of the Apache Airflow Cluster resource to return.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetClusterRequest) Descriptor deprecated 

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

Deprecated: Use GetClusterRequest.ProtoReflect.Descriptor instead.

func (*GetClusterRequest) GetClusterId 

func (x *GetClusterRequest) GetClusterId() string

func (*GetClusterRequest) ProtoMessage 

func (*GetClusterRequest) ProtoMessage()

func (*GetClusterRequest) ProtoReflect 

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

func (*GetClusterRequest) Reset 

func (x *GetClusterRequest) Reset()

func (*GetClusterRequest) SetClusterId 

func (m *GetClusterRequest) SetClusterId(v string)

func (*GetClusterRequest) String 

func (x *GetClusterRequest) String() string

type Health 

type Health int32
const (
	// Cluster is in unknown state (we have no data).
	Health_HEALTH_UNKNOWN Health = 0
	// Cluster is alive and well.
	Health_ALIVE Health = 1
	// Cluster is inoperable (it cannot perform any of its essential functions).
	Health_DEAD Health = 2
	// Cluster is partially alive (it can perform some of its essential functions).
	Health_DEGRADED Health = 3
)

func (Health) Descriptor 

func (Health) Descriptor() protoreflect.EnumDescriptor

func (Health) Enum 

func (x Health) Enum() *Health

func (Health) EnumDescriptor deprecated 

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

Deprecated: Use Health.Descriptor instead.

func (Health) Number 

func (x Health) Number() protoreflect.EnumNumber

func (Health) String 

func (x Health) String() string

func (Health) Type 

func (Health) Type() protoreflect.EnumType

type ListClusterOperationsRequest 

type ListClusterOperationsRequest struct {

	// ID of the Apache Airflow Cluster resource to list operations for.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// The maximum number of results per page to return. If the number of available
	// results is larger than [page_size], the service returns a [ListClusterOperationsResponse.next_page_token]
	// that can be used to get the next page of results in subsequent list requests.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token.  To get the next page of results, set [page_token] to the [ListClusterOperationsResponse.next_page_token]
	// returned by the previous list request.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClusterOperationsRequest) Descriptor deprecated 

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

Deprecated: Use ListClusterOperationsRequest.ProtoReflect.Descriptor instead.

func (*ListClusterOperationsRequest) GetClusterId 

func (x *ListClusterOperationsRequest) GetClusterId() string

func (*ListClusterOperationsRequest) GetPageSize 

func (x *ListClusterOperationsRequest) GetPageSize() int64

func (*ListClusterOperationsRequest) GetPageToken 

func (x *ListClusterOperationsRequest) GetPageToken() string

func (*ListClusterOperationsRequest) ProtoMessage 

func (*ListClusterOperationsRequest) ProtoMessage()

func (*ListClusterOperationsRequest) ProtoReflect 

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

func (*ListClusterOperationsRequest) Reset 

func (x *ListClusterOperationsRequest) Reset()

func (*ListClusterOperationsRequest) SetClusterId 

func (m *ListClusterOperationsRequest) SetClusterId(v string)

func (*ListClusterOperationsRequest) SetPageSize 

func (m *ListClusterOperationsRequest) SetPageSize(v int64)

func (*ListClusterOperationsRequest) SetPageToken 

func (m *ListClusterOperationsRequest) SetPageToken(v string)

func (*ListClusterOperationsRequest) String 

func (x *ListClusterOperationsRequest) String() string

type ListClusterOperationsResponse 

type ListClusterOperationsResponse struct {

	// List of Operation resources for the specified Apache Airflow cluster.
	Operations []*operation.Operation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	// This token allows you to get the next page of results for list requests. If the number of results
	// is larger than [ListClusterOperationsRequest.page_size], use the [next_page_token] as the value
	// for the [ListClusterOperationsRequest.page_token] query parameter in the next list request.
	// Each subsequent list request will have its own [next_page_token] to continue paging through the results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClusterOperationsResponse) Descriptor deprecated 

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

Deprecated: Use ListClusterOperationsResponse.ProtoReflect.Descriptor instead.

func (*ListClusterOperationsResponse) GetNextPageToken 

func (x *ListClusterOperationsResponse) GetNextPageToken() string

func (*ListClusterOperationsResponse) GetOperations 

func (x *ListClusterOperationsResponse) GetOperations() []*operation.Operation

func (*ListClusterOperationsResponse) ProtoMessage 

func (*ListClusterOperationsResponse) ProtoMessage()

func (*ListClusterOperationsResponse) ProtoReflect 

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

func (*ListClusterOperationsResponse) Reset 

func (x *ListClusterOperationsResponse) Reset()

func (*ListClusterOperationsResponse) SetNextPageToken 

func (m *ListClusterOperationsResponse) SetNextPageToken(v string)

func (*ListClusterOperationsResponse) SetOperations 

func (m *ListClusterOperationsResponse) SetOperations(v []*operation.Operation)

func (*ListClusterOperationsResponse) String 

func (x *ListClusterOperationsResponse) String() string

type ListClustersRequest 

type ListClustersRequest struct {

	// ID of the folder to list Apache Airflow clusters in.
	FolderId string `protobuf:"bytes,1,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// The maximum number of results per page to return. If the number of available
	// results is larger than [page_size], the service returns a [ListClustersResponse.next_page_token]
	// that can be used to get the next page of results in subsequent list requests.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token. To get the next page of results, set [page_token] to the [ListClustersResponse.next_page_token]
	// returned by the previous list request.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// A filter expression that filters resources listed in the response.
	// The expression must specify:
	// 1. The field name. Currently you can only use filtering with the [Cluster.name] field.
	// 2. An `=` operator.
	// 3. The value in double quotes (`"`). Must be 1-63 characters long and match the regular expression `[a-zA-Z0-9_-]+`.
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClustersRequest) Descriptor deprecated 

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

Deprecated: Use ListClustersRequest.ProtoReflect.Descriptor instead.

func (*ListClustersRequest) GetFilter 

func (x *ListClustersRequest) GetFilter() string

func (*ListClustersRequest) GetFolderId 

func (x *ListClustersRequest) GetFolderId() string

func (*ListClustersRequest) GetPageSize 

func (x *ListClustersRequest) GetPageSize() int64

func (*ListClustersRequest) GetPageToken 

func (x *ListClustersRequest) GetPageToken() string

func (*ListClustersRequest) ProtoMessage 

func (*ListClustersRequest) ProtoMessage()

func (*ListClustersRequest) ProtoReflect 

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

func (*ListClustersRequest) Reset 

func (x *ListClustersRequest) Reset()

func (*ListClustersRequest) SetFilter 

func (m *ListClustersRequest) SetFilter(v string)

func (*ListClustersRequest) SetFolderId 

func (m *ListClustersRequest) SetFolderId(v string)

func (*ListClustersRequest) SetPageSize 

func (m *ListClustersRequest) SetPageSize(v int64)

func (*ListClustersRequest) SetPageToken 

func (m *ListClustersRequest) SetPageToken(v string)

func (*ListClustersRequest) String 

func (x *ListClustersRequest) String() string

type ListClustersResponse 

type ListClustersResponse struct {

	// List of Apache Airflow Cluster resources.
	Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// This token allows you to get the next page of results for list requests. If the number of results
	// is larger than [ListClustersRequest.page_size], use the [next_page_token] as the value
	// for the [ListClustersRequest.page_token] parameter in the next list request. Each subsequent
	// list request will have its own [next_page_token] to continue paging through the results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClustersResponse) Descriptor deprecated 

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

Deprecated: Use ListClustersResponse.ProtoReflect.Descriptor instead.

func (*ListClustersResponse) GetClusters 

func (x *ListClustersResponse) GetClusters() []*Cluster

func (*ListClustersResponse) GetNextPageToken 

func (x *ListClustersResponse) GetNextPageToken() string

func (*ListClustersResponse) ProtoMessage 

func (*ListClustersResponse) ProtoMessage()

func (*ListClustersResponse) ProtoReflect 

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

func (*ListClustersResponse) Reset 

func (x *ListClustersResponse) Reset()

func (*ListClustersResponse) SetClusters 

func (m *ListClustersResponse) SetClusters(v []*Cluster)

func (*ListClustersResponse) SetNextPageToken 

func (m *ListClustersResponse) SetNextPageToken(v string)

func (*ListClustersResponse) String 

func (x *ListClustersResponse) String() string

type LockboxConfig 

type LockboxConfig struct {

	// The setting allows to enable Lockbox Secret Backend.
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// contains filtered or unexported fields
}

func (*LockboxConfig) Descriptor deprecated 

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

Deprecated: Use LockboxConfig.ProtoReflect.Descriptor instead.

func (*LockboxConfig) GetEnabled 

func (x *LockboxConfig) GetEnabled() bool

func (*LockboxConfig) ProtoMessage 

func (*LockboxConfig) ProtoMessage()

func (*LockboxConfig) ProtoReflect 

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

func (*LockboxConfig) Reset 

func (x *LockboxConfig) Reset()

func (*LockboxConfig) SetEnabled 

func (m *LockboxConfig) SetEnabled(v bool)

func (*LockboxConfig) String 

func (x *LockboxConfig) String() string

type LoggingConfig 

type LoggingConfig struct {

	// Logs generated by the Airflow components are delivered to Cloud Logging.
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// Destination of log records.
	//
	// Types that are assignable to Destination:
	//
	//	*LoggingConfig_FolderId
	//	*LoggingConfig_LogGroupId
	Destination isLoggingConfig_Destination `protobuf_oneof:"destination"`
	// Minimum log entry level.
	//
	// See [LogLevel.Level] for details.
	MinLevel v1.LogLevel_Level `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LoggingConfig) Descriptor deprecated 

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

Deprecated: Use LoggingConfig.ProtoReflect.Descriptor instead.

func (*LoggingConfig) GetDestination 

func (m *LoggingConfig) GetDestination() isLoggingConfig_Destination

func (*LoggingConfig) GetEnabled 

func (x *LoggingConfig) GetEnabled() bool

func (*LoggingConfig) GetFolderId 

func (x *LoggingConfig) GetFolderId() string

func (*LoggingConfig) GetLogGroupId 

func (x *LoggingConfig) GetLogGroupId() string

func (*LoggingConfig) GetMinLevel 

func (x *LoggingConfig) GetMinLevel() v1.LogLevel_Level

func (*LoggingConfig) ProtoMessage 

func (*LoggingConfig) ProtoMessage()

func (*LoggingConfig) ProtoReflect 

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

func (*LoggingConfig) Reset 

func (x *LoggingConfig) Reset()

func (*LoggingConfig) SetDestination 

func (m *LoggingConfig) SetDestination(v LoggingConfig_Destination)

func (*LoggingConfig) SetEnabled 

func (m *LoggingConfig) SetEnabled(v bool)

func (*LoggingConfig) SetFolderId 

func (m *LoggingConfig) SetFolderId(v string)

func (*LoggingConfig) SetLogGroupId 

func (m *LoggingConfig) SetLogGroupId(v string)

func (*LoggingConfig) SetMinLevel 

func (m *LoggingConfig) SetMinLevel(v v1.LogLevel_Level)

func (*LoggingConfig) String 

func (x *LoggingConfig) String() string

type LoggingConfig_Destination 

type LoggingConfig_Destination = isLoggingConfig_Destination

type LoggingConfig_FolderId 

type LoggingConfig_FolderId struct {
	// Logs should be written to default log group for specified folder.
	FolderId string `protobuf:"bytes,2,opt,name=folder_id,json=folderId,proto3,oneof"`
}

type LoggingConfig_LogGroupId 

type LoggingConfig_LogGroupId struct {
	// Logs should be written to log group resolved by ID.
	LogGroupId string `protobuf:"bytes,3,opt,name=log_group_id,json=logGroupId,proto3,oneof"`
}

type Monitoring 

type Monitoring struct {

	// Name of the monitoring system.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the monitoring system.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// Link to the monitoring system.
	Link string `protobuf:"bytes,3,opt,name=link,proto3" json:"link,omitempty"`
	// contains filtered or unexported fields
}

Monitoring system.

func (*Monitoring) Descriptor deprecated 

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

Deprecated: Use Monitoring.ProtoReflect.Descriptor instead.

func (*Monitoring) GetDescription 

func (x *Monitoring) GetDescription() string
func (x *Monitoring) GetLink() string

func (*Monitoring) GetName 

func (x *Monitoring) GetName() string

func (*Monitoring) ProtoMessage 

func (*Monitoring) ProtoMessage()

func (*Monitoring) ProtoReflect 

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

func (*Monitoring) Reset 

func (x *Monitoring) Reset()

func (*Monitoring) SetDescription 

func (m *Monitoring) SetDescription(v string)
func (m *Monitoring) SetLink(v string)

func (*Monitoring) SetName 

func (m *Monitoring) SetName(v string)

func (*Monitoring) String 

func (x *Monitoring) String() string

type NetworkConfig 

type NetworkConfig struct {

	// IDs of VPC network subnets where instances of the cluster are attached.
	SubnetIds []string `protobuf:"bytes,1,rep,name=subnet_ids,json=subnetIds,proto3" json:"subnet_ids,omitempty"`
	// User security groups.
	SecurityGroupIds []string `protobuf:"bytes,2,rep,name=security_group_ids,json=securityGroupIds,proto3" json:"security_group_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*NetworkConfig) Descriptor deprecated 

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

Deprecated: Use NetworkConfig.ProtoReflect.Descriptor instead.

func (*NetworkConfig) GetSecurityGroupIds 

func (x *NetworkConfig) GetSecurityGroupIds() []string

func (*NetworkConfig) GetSubnetIds 

func (x *NetworkConfig) GetSubnetIds() []string

func (*NetworkConfig) ProtoMessage 

func (*NetworkConfig) ProtoMessage()

func (*NetworkConfig) ProtoReflect 

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

func (*NetworkConfig) Reset 

func (x *NetworkConfig) Reset()

func (*NetworkConfig) SetSecurityGroupIds 

func (m *NetworkConfig) SetSecurityGroupIds(v []string)

func (*NetworkConfig) SetSubnetIds 

func (m *NetworkConfig) SetSubnetIds(v []string)

func (*NetworkConfig) String 

func (x *NetworkConfig) String() string

type Resources 

type Resources struct {

	// ID of the preset for computational resources available to an instance (CPU, memory etc.).
	ResourcePresetId string `protobuf:"bytes,3,opt,name=resource_preset_id,json=resourcePresetId,proto3" json:"resource_preset_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Resources) Descriptor deprecated 

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

Deprecated: Use Resources.ProtoReflect.Descriptor instead.

func (*Resources) GetResourcePresetId 

func (x *Resources) GetResourcePresetId() string

func (*Resources) ProtoMessage 

func (*Resources) ProtoMessage()

func (*Resources) ProtoReflect 

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

func (*Resources) Reset 

func (x *Resources) Reset()

func (*Resources) SetResourcePresetId 

func (m *Resources) SetResourcePresetId(v string)

func (*Resources) String 

func (x *Resources) String() string

type S3Config 

type S3Config struct {

	// The name of the Object Storage bucket that stores DAG files used in the cluster.
	Bucket string `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// contains filtered or unexported fields
}

func (*S3Config) Descriptor deprecated 

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

Deprecated: Use S3Config.ProtoReflect.Descriptor instead.

func (*S3Config) GetBucket 

func (x *S3Config) GetBucket() string

func (*S3Config) ProtoMessage 

func (*S3Config) ProtoMessage()

func (*S3Config) ProtoReflect 

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

func (*S3Config) Reset 

func (x *S3Config) Reset()

func (*S3Config) SetBucket 

func (m *S3Config) SetBucket(v string)

func (*S3Config) String 

func (x *S3Config) String() string

type SchedulerConfig 

type SchedulerConfig struct {

	// The number of scheduler instances in the cluster.
	Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// Resources allocated to scheduler instances.
	Resources *Resources `protobuf:"bytes,2,opt,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

func (*SchedulerConfig) Descriptor deprecated 

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

Deprecated: Use SchedulerConfig.ProtoReflect.Descriptor instead.

func (*SchedulerConfig) GetCount 

func (x *SchedulerConfig) GetCount() int64

func (*SchedulerConfig) GetResources 

func (x *SchedulerConfig) GetResources() *Resources

func (*SchedulerConfig) ProtoMessage 

func (*SchedulerConfig) ProtoMessage()

func (*SchedulerConfig) ProtoReflect 

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

func (*SchedulerConfig) Reset 

func (x *SchedulerConfig) Reset()

func (*SchedulerConfig) SetCount 

func (m *SchedulerConfig) SetCount(v int64)

func (*SchedulerConfig) SetResources 

func (m *SchedulerConfig) SetResources(v *Resources)

func (*SchedulerConfig) String 

func (x *SchedulerConfig) String() string

type StartClusterMetadata 

type StartClusterMetadata struct {

	// ID of the Apache Airflow cluster that is being started.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StartClusterMetadata) Descriptor deprecated 

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

Deprecated: Use StartClusterMetadata.ProtoReflect.Descriptor instead.

func (*StartClusterMetadata) GetClusterId 

func (x *StartClusterMetadata) GetClusterId() string

func (*StartClusterMetadata) ProtoMessage 

func (*StartClusterMetadata) ProtoMessage()

func (*StartClusterMetadata) ProtoReflect 

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

func (*StartClusterMetadata) Reset 

func (x *StartClusterMetadata) Reset()

func (*StartClusterMetadata) SetClusterId 

func (m *StartClusterMetadata) SetClusterId(v string)

func (*StartClusterMetadata) String 

func (x *StartClusterMetadata) String() string

type StartClusterRequest 

type StartClusterRequest struct {

	// ID of the Apache Airflow cluster to start.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StartClusterRequest) Descriptor deprecated 

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

Deprecated: Use StartClusterRequest.ProtoReflect.Descriptor instead.

func (*StartClusterRequest) GetClusterId 

func (x *StartClusterRequest) GetClusterId() string

func (*StartClusterRequest) ProtoMessage 

func (*StartClusterRequest) ProtoMessage()

func (*StartClusterRequest) ProtoReflect 

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

func (*StartClusterRequest) Reset 

func (x *StartClusterRequest) Reset()

func (*StartClusterRequest) SetClusterId 

func (m *StartClusterRequest) SetClusterId(v string)

func (*StartClusterRequest) String 

func (x *StartClusterRequest) String() string

type StopClusterMetadata 

type StopClusterMetadata struct {

	// ID of the Apache Airflow cluster that is being stopped.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StopClusterMetadata) Descriptor deprecated 

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

Deprecated: Use StopClusterMetadata.ProtoReflect.Descriptor instead.

func (*StopClusterMetadata) GetClusterId 

func (x *StopClusterMetadata) GetClusterId() string

func (*StopClusterMetadata) ProtoMessage 

func (*StopClusterMetadata) ProtoMessage()

func (*StopClusterMetadata) ProtoReflect 

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

func (*StopClusterMetadata) Reset 

func (x *StopClusterMetadata) Reset()

func (*StopClusterMetadata) SetClusterId 

func (m *StopClusterMetadata) SetClusterId(v string)

func (*StopClusterMetadata) String 

func (x *StopClusterMetadata) String() string

type StopClusterRequest 

type StopClusterRequest struct {

	// ID of the Apache Airflow cluster to stop.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StopClusterRequest) Descriptor deprecated 

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

Deprecated: Use StopClusterRequest.ProtoReflect.Descriptor instead.

func (*StopClusterRequest) GetClusterId 

func (x *StopClusterRequest) GetClusterId() string

func (*StopClusterRequest) ProtoMessage 

func (*StopClusterRequest) ProtoMessage()

func (*StopClusterRequest) ProtoReflect 

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

func (*StopClusterRequest) Reset 

func (x *StopClusterRequest) Reset()

func (*StopClusterRequest) SetClusterId 

func (m *StopClusterRequest) SetClusterId(v string)

func (*StopClusterRequest) String 

func (x *StopClusterRequest) String() string

type TriggererConfig 

type TriggererConfig struct {

	// The number of triggerer instances in the cluster.
	Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// Resources allocated to triggerer instances.
	Resources *Resources `protobuf:"bytes,2,opt,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

func (*TriggererConfig) Descriptor deprecated 

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

Deprecated: Use TriggererConfig.ProtoReflect.Descriptor instead.

func (*TriggererConfig) GetCount 

func (x *TriggererConfig) GetCount() int64

func (*TriggererConfig) GetResources 

func (x *TriggererConfig) GetResources() *Resources

func (*TriggererConfig) ProtoMessage 

func (*TriggererConfig) ProtoMessage()

func (*TriggererConfig) ProtoReflect 

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

func (*TriggererConfig) Reset 

func (x *TriggererConfig) Reset()

func (*TriggererConfig) SetCount 

func (m *TriggererConfig) SetCount(v int64)

func (*TriggererConfig) SetResources 

func (m *TriggererConfig) SetResources(v *Resources)

func (*TriggererConfig) String 

func (x *TriggererConfig) String() string

type UnimplementedClusterServiceServer 

type UnimplementedClusterServiceServer struct{}

UnimplementedClusterServiceServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedClusterServiceServer) Create 

func (UnimplementedClusterServiceServer) Create(context.Context, *CreateClusterRequest) (*operation.Operation, error)

func (UnimplementedClusterServiceServer) Delete 

func (UnimplementedClusterServiceServer) Delete(context.Context, *DeleteClusterRequest) (*operation.Operation, error)

func (UnimplementedClusterServiceServer) Get 

func (UnimplementedClusterServiceServer) Get(context.Context, *GetClusterRequest) (*Cluster, error)

func (UnimplementedClusterServiceServer) List 

func (UnimplementedClusterServiceServer) List(context.Context, *ListClustersRequest) (*ListClustersResponse, error)

func (UnimplementedClusterServiceServer) ListOperations 

func (UnimplementedClusterServiceServer) ListOperations(context.Context, *ListClusterOperationsRequest) (*ListClusterOperationsResponse, error)

func (UnimplementedClusterServiceServer) Start 

func (UnimplementedClusterServiceServer) Start(context.Context, *StartClusterRequest) (*operation.Operation, error)

func (UnimplementedClusterServiceServer) Stop 

func (UnimplementedClusterServiceServer) Stop(context.Context, *StopClusterRequest) (*operation.Operation, error)

func (UnimplementedClusterServiceServer) Update 

func (UnimplementedClusterServiceServer) Update(context.Context, *UpdateClusterRequest) (*operation.Operation, error)

type UnsafeClusterServiceServer 

type UnsafeClusterServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeClusterServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClusterServiceServer will result in compilation errors.

type UpdateClusterConfigSpec 

type UpdateClusterConfigSpec struct {

	// Configuration of the Apache Airflow application itself.
	Airflow *AirflowConfig `protobuf:"bytes,2,opt,name=airflow,proto3" json:"airflow,omitempty"`
	// Configuration of webserver instances.
	Webserver *WebserverConfig `protobuf:"bytes,3,opt,name=webserver,proto3" json:"webserver,omitempty"`
	// Configuration of scheduler instances.
	Scheduler *SchedulerConfig `protobuf:"bytes,4,opt,name=scheduler,proto3" json:"scheduler,omitempty"`
	// Configuration of triggerer instances.
	Triggerer *TriggererConfig `protobuf:"bytes,5,opt,name=triggerer,proto3" json:"triggerer,omitempty"`
	// Configuration of worker instances.
	Worker *WorkerConfig `protobuf:"bytes,6,opt,name=worker,proto3" json:"worker,omitempty"`
	// The list of additional packages installed in the cluster.
	Dependencies *Dependencies `protobuf:"bytes,7,opt,name=dependencies,proto3" json:"dependencies,omitempty"`
	// Configuration of Lockbox Secret Backend.
	Lockbox *LockboxConfig `protobuf:"bytes,8,opt,name=lockbox,proto3" json:"lockbox,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateClusterConfigSpec) Descriptor deprecated 

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

Deprecated: Use UpdateClusterConfigSpec.ProtoReflect.Descriptor instead.

func (*UpdateClusterConfigSpec) GetAirflow 

func (x *UpdateClusterConfigSpec) GetAirflow() *AirflowConfig

func (*UpdateClusterConfigSpec) GetDependencies 

func (x *UpdateClusterConfigSpec) GetDependencies() *Dependencies

func (*UpdateClusterConfigSpec) GetLockbox 

func (x *UpdateClusterConfigSpec) GetLockbox() *LockboxConfig

func (*UpdateClusterConfigSpec) GetScheduler 

func (x *UpdateClusterConfigSpec) GetScheduler() *SchedulerConfig

func (*UpdateClusterConfigSpec) GetTriggerer 

func (x *UpdateClusterConfigSpec) GetTriggerer() *TriggererConfig

func (*UpdateClusterConfigSpec) GetWebserver 

func (x *UpdateClusterConfigSpec) GetWebserver() *WebserverConfig

func (*UpdateClusterConfigSpec) GetWorker 

func (x *UpdateClusterConfigSpec) GetWorker() *WorkerConfig

func (*UpdateClusterConfigSpec) ProtoMessage 

func (*UpdateClusterConfigSpec) ProtoMessage()

func (*UpdateClusterConfigSpec) ProtoReflect 

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

func (*UpdateClusterConfigSpec) Reset 

func (x *UpdateClusterConfigSpec) Reset()

func (*UpdateClusterConfigSpec) SetAirflow 

func (m *UpdateClusterConfigSpec) SetAirflow(v *AirflowConfig)

func (*UpdateClusterConfigSpec) SetDependencies 

func (m *UpdateClusterConfigSpec) SetDependencies(v *Dependencies)

func (*UpdateClusterConfigSpec) SetLockbox 

func (m *UpdateClusterConfigSpec) SetLockbox(v *LockboxConfig)

func (*UpdateClusterConfigSpec) SetScheduler 

func (m *UpdateClusterConfigSpec) SetScheduler(v *SchedulerConfig)

func (*UpdateClusterConfigSpec) SetTriggerer 

func (m *UpdateClusterConfigSpec) SetTriggerer(v *TriggererConfig)

func (*UpdateClusterConfigSpec) SetWebserver 

func (m *UpdateClusterConfigSpec) SetWebserver(v *WebserverConfig)

func (*UpdateClusterConfigSpec) SetWorker 

func (m *UpdateClusterConfigSpec) SetWorker(v *WorkerConfig)

func (*UpdateClusterConfigSpec) String 

func (x *UpdateClusterConfigSpec) String() string

type UpdateClusterMetadata 

type UpdateClusterMetadata struct {

	// ID of the Apache Airflow Cluster resource that is being updated.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateClusterMetadata) Descriptor deprecated 

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

Deprecated: Use UpdateClusterMetadata.ProtoReflect.Descriptor instead.

func (*UpdateClusterMetadata) GetClusterId 

func (x *UpdateClusterMetadata) GetClusterId() string

func (*UpdateClusterMetadata) ProtoMessage 

func (*UpdateClusterMetadata) ProtoMessage()

func (*UpdateClusterMetadata) ProtoReflect 

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

func (*UpdateClusterMetadata) Reset 

func (x *UpdateClusterMetadata) Reset()

func (*UpdateClusterMetadata) SetClusterId 

func (m *UpdateClusterMetadata) SetClusterId(v string)

func (*UpdateClusterMetadata) String 

func (x *UpdateClusterMetadata) String() string

type UpdateClusterRequest 

type UpdateClusterRequest struct {

	// ID of the Apache Airflow Cluster resource to update.
	ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	// Field mask that specifies which fields of the Apache Airflow Cluster resource should be updated.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// New name of the cluster.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// New description of the Apache Airflow cluster.
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// Custom labels for the Apache Airflow cluster as “ key:value “ pairs. For example, "env": "prod".
	//
	// The new set of labels will completely replace the old ones. To add a label, request the current
	// set with the [ClusterService.Get] method, then send an [ClusterService.Update] request with the new label added to the set.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Configuration of Apache Airflow components.
	ConfigSpec *UpdateClusterConfigSpec `protobuf:"bytes,6,opt,name=config_spec,json=configSpec,proto3" json:"config_spec,omitempty"`
	// Parameters of the location and access to the code that will be executed in the cluster.
	CodeSync *CodeSyncConfig `protobuf:"bytes,7,opt,name=code_sync,json=codeSync,proto3" json:"code_sync,omitempty"`
	// Network related configuration options.
	NetworkSpec *UpdateNetworkConfigSpec `protobuf:"bytes,8,opt,name=network_spec,json=networkSpec,proto3" json:"network_spec,omitempty"`
	// Deletion Protection inhibits deletion of the cluster
	DeletionProtection bool `protobuf:"varint,9,opt,name=deletion_protection,json=deletionProtection,proto3" json:"deletion_protection,omitempty"`
	// Service account used to access Cloud resources.
	// For more information, see [documentation](/docs/managed-airflow/concepts/impersonation).
	ServiceAccountId string `protobuf:"bytes,10,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// Cloud Logging configuration.
	Logging *LoggingConfig `protobuf:"bytes,11,opt,name=logging,proto3" json:"logging,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateClusterRequest) Descriptor deprecated 

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

Deprecated: Use UpdateClusterRequest.ProtoReflect.Descriptor instead.

func (*UpdateClusterRequest) GetClusterId 

func (x *UpdateClusterRequest) GetClusterId() string

func (*UpdateClusterRequest) GetCodeSync 

func (x *UpdateClusterRequest) GetCodeSync() *CodeSyncConfig

func (*UpdateClusterRequest) GetConfigSpec 

func (x *UpdateClusterRequest) GetConfigSpec() *UpdateClusterConfigSpec

func (*UpdateClusterRequest) GetDeletionProtection 

func (x *UpdateClusterRequest) GetDeletionProtection() bool

func (*UpdateClusterRequest) GetDescription 

func (x *UpdateClusterRequest) GetDescription() string

func (*UpdateClusterRequest) GetLabels 

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

func (*UpdateClusterRequest) GetLogging 

func (x *UpdateClusterRequest) GetLogging() *LoggingConfig

func (*UpdateClusterRequest) GetName 

func (x *UpdateClusterRequest) GetName() string

func (*UpdateClusterRequest) GetNetworkSpec 

func (x *UpdateClusterRequest) GetNetworkSpec() *UpdateNetworkConfigSpec

func (*UpdateClusterRequest) GetServiceAccountId 

func (x *UpdateClusterRequest) GetServiceAccountId() string

func (*UpdateClusterRequest) GetUpdateMask 

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

func (*UpdateClusterRequest) ProtoMessage 

func (*UpdateClusterRequest) ProtoMessage()

func (*UpdateClusterRequest) ProtoReflect 

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

func (*UpdateClusterRequest) Reset 

func (x *UpdateClusterRequest) Reset()

func (*UpdateClusterRequest) SetClusterId 

func (m *UpdateClusterRequest) SetClusterId(v string)

func (*UpdateClusterRequest) SetCodeSync 

func (m *UpdateClusterRequest) SetCodeSync(v *CodeSyncConfig)

func (*UpdateClusterRequest) SetConfigSpec 

func (m *UpdateClusterRequest) SetConfigSpec(v *UpdateClusterConfigSpec)

func (*UpdateClusterRequest) SetDeletionProtection 

func (m *UpdateClusterRequest) SetDeletionProtection(v bool)

func (*UpdateClusterRequest) SetDescription 

func (m *UpdateClusterRequest) SetDescription(v string)

func (*UpdateClusterRequest) SetLabels 

func (m *UpdateClusterRequest) SetLabels(v map[string]string)

func (*UpdateClusterRequest) SetLogging 

func (m *UpdateClusterRequest) SetLogging(v *LoggingConfig)

func (*UpdateClusterRequest) SetName 

func (m *UpdateClusterRequest) SetName(v string)

func (*UpdateClusterRequest) SetNetworkSpec 

func (m *UpdateClusterRequest) SetNetworkSpec(v *UpdateNetworkConfigSpec)

func (*UpdateClusterRequest) SetServiceAccountId 

func (m *UpdateClusterRequest) SetServiceAccountId(v string)

func (*UpdateClusterRequest) SetUpdateMask 

func (m *UpdateClusterRequest) SetUpdateMask(v *fieldmaskpb.FieldMask)

func (*UpdateClusterRequest) String 

func (x *UpdateClusterRequest) String() string

type UpdateNetworkConfigSpec 

type UpdateNetworkConfigSpec struct {

	// User security groups.
	SecurityGroupIds []string `protobuf:"bytes,1,rep,name=security_group_ids,json=securityGroupIds,proto3" json:"security_group_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateNetworkConfigSpec) Descriptor deprecated 

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

Deprecated: Use UpdateNetworkConfigSpec.ProtoReflect.Descriptor instead.

func (*UpdateNetworkConfigSpec) GetSecurityGroupIds 

func (x *UpdateNetworkConfigSpec) GetSecurityGroupIds() []string

func (*UpdateNetworkConfigSpec) ProtoMessage 

func (*UpdateNetworkConfigSpec) ProtoMessage()

func (*UpdateNetworkConfigSpec) ProtoReflect 

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

func (*UpdateNetworkConfigSpec) Reset 

func (x *UpdateNetworkConfigSpec) Reset()

func (*UpdateNetworkConfigSpec) SetSecurityGroupIds 

func (m *UpdateNetworkConfigSpec) SetSecurityGroupIds(v []string)

func (*UpdateNetworkConfigSpec) String 

func (x *UpdateNetworkConfigSpec) String() string

type WebserverConfig 

type WebserverConfig struct {

	// The number of webserver instances in the cluster.
	Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// Resources allocated to webserver instances.
	Resources *Resources `protobuf:"bytes,2,opt,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

func (*WebserverConfig) Descriptor deprecated 

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

Deprecated: Use WebserverConfig.ProtoReflect.Descriptor instead.

func (*WebserverConfig) GetCount 

func (x *WebserverConfig) GetCount() int64

func (*WebserverConfig) GetResources 

func (x *WebserverConfig) GetResources() *Resources

func (*WebserverConfig) ProtoMessage 

func (*WebserverConfig) ProtoMessage()

func (*WebserverConfig) ProtoReflect 

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

func (*WebserverConfig) Reset 

func (x *WebserverConfig) Reset()

func (*WebserverConfig) SetCount 

func (m *WebserverConfig) SetCount(v int64)

func (*WebserverConfig) SetResources 

func (m *WebserverConfig) SetResources(v *Resources)

func (*WebserverConfig) String 

func (x *WebserverConfig) String() string

type WorkerConfig 

type WorkerConfig struct {

	// The minimum number of worker instances in the cluster.
	MinCount int64 `protobuf:"varint,1,opt,name=min_count,json=minCount,proto3" json:"min_count,omitempty"`
	// The maximum number of worker instances in the cluster.
	MaxCount int64 `protobuf:"varint,2,opt,name=max_count,json=maxCount,proto3" json:"max_count,omitempty"`
	// Resources allocated to worker instances.
	Resources *Resources `protobuf:"bytes,3,opt,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerConfig) Descriptor deprecated 

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

Deprecated: Use WorkerConfig.ProtoReflect.Descriptor instead.

func (*WorkerConfig) GetMaxCount 

func (x *WorkerConfig) GetMaxCount() int64

func (*WorkerConfig) GetMinCount 

func (x *WorkerConfig) GetMinCount() int64

func (*WorkerConfig) GetResources 

func (x *WorkerConfig) GetResources() *Resources

func (*WorkerConfig) ProtoMessage 

func (*WorkerConfig) ProtoMessage()

func (*WorkerConfig) ProtoReflect 

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

func (*WorkerConfig) Reset 

func (x *WorkerConfig) Reset()

func (*WorkerConfig) SetMaxCount 

func (m *WorkerConfig) SetMaxCount(v int64)

func (*WorkerConfig) SetMinCount 

func (m *WorkerConfig) SetMinCount(v int64)

func (*WorkerConfig) SetResources 

func (m *WorkerConfig) SetResources(v *Resources)

func (*WorkerConfig) String 

func (x *WorkerConfig) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.