servicepb

package

Go to main page

Versions in this module

v1

v1.11.2

Dec 12, 2024

v1.11.1

Oct 23, 2024

v1.11.0

Sep 19, 2024

Changes in this version

+ var AirflowMetadataRetentionPolicyConfig_RetentionMode_name = map[int32]string

+ var AirflowMetadataRetentionPolicyConfig_RetentionMode_value = map[string]int32

+ type AirflowMetadataRetentionPolicyConfig struct

+ RetentionDays int32

+ RetentionMode AirflowMetadataRetentionPolicyConfig_RetentionMode

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

+ func (*AirflowMetadataRetentionPolicyConfig) ProtoMessage()

+ func (x *AirflowMetadataRetentionPolicyConfig) GetRetentionDays() int32

+ func (x *AirflowMetadataRetentionPolicyConfig) GetRetentionMode() AirflowMetadataRetentionPolicyConfig_RetentionMode

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

+ func (x *AirflowMetadataRetentionPolicyConfig) Reset()

+ func (x *AirflowMetadataRetentionPolicyConfig) String() string

+ type AirflowMetadataRetentionPolicyConfig_RetentionMode int32

+ const AirflowMetadataRetentionPolicyConfig_RETENTION_MODE_DISABLED

+ const AirflowMetadataRetentionPolicyConfig_RETENTION_MODE_ENABLED

+ const AirflowMetadataRetentionPolicyConfig_RETENTION_MODE_UNSPECIFIED

+ func (AirflowMetadataRetentionPolicyConfig_RetentionMode) Descriptor() protoreflect.EnumDescriptor

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

+ func (AirflowMetadataRetentionPolicyConfig_RetentionMode) Type() protoreflect.EnumType

+ func (x AirflowMetadataRetentionPolicyConfig_RetentionMode) Enum() *AirflowMetadataRetentionPolicyConfig_RetentionMode

+ func (x AirflowMetadataRetentionPolicyConfig_RetentionMode) Number() protoreflect.EnumNumber

+ func (x AirflowMetadataRetentionPolicyConfig_RetentionMode) String() string

+ type CheckUpgradeRequest struct

+ Environment string

+ ImageVersion string

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

+ func (*CheckUpgradeRequest) ProtoMessage()

+ func (x *CheckUpgradeRequest) GetEnvironment() string

+ func (x *CheckUpgradeRequest) GetImageVersion() string

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

+ func (x *CheckUpgradeRequest) Reset()

+ func (x *CheckUpgradeRequest) String() string

type DataRetentionConfig

+ AirflowMetadataRetentionConfig *AirflowMetadataRetentionPolicyConfig

+ func (x *DataRetentionConfig) GetAirflowMetadataRetentionConfig() *AirflowMetadataRetentionPolicyConfig

type Environment

+ SatisfiesPzi bool

+ func (x *Environment) GetSatisfiesPzi() bool

type EnvironmentsClient

+ CheckUpgrade func(ctx context.Context, in *CheckUpgradeRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)

type EnvironmentsServer

+ CheckUpgrade func(context.Context, *CheckUpgradeRequest) (*longrunningpb.Operation, error)

type UnimplementedEnvironmentsServer

+ func (*UnimplementedEnvironmentsServer) CheckUpgrade(context.Context, *CheckUpgradeRequest) (*longrunningpb.Operation, error)

v1.10.1

Sep 12, 2024

v1.10.0

Aug 20, 2024

v1.9.7

Aug 8, 2024

v1.9.6

Jul 24, 2024

v1.9.5

Jul 10, 2024

v1.9.4

Jul 1, 2024

v1.9.3

Jun 26, 2024

v1.9.2

May 1, 2024

v1.9.1

Mar 14, 2024

v1.9.0

Feb 21, 2024

Changes in this version

+ var ListWorkloadsResponse_ComposerWorkloadState_name = map[int32]string

+ var ListWorkloadsResponse_ComposerWorkloadState_value = map[string]int32

+ var ListWorkloadsResponse_ComposerWorkloadType_name = map[int32]string

+ var ListWorkloadsResponse_ComposerWorkloadType_value = map[string]int32

+ var SoftwareConfig_WebServerPluginsMode_name = map[int32]string

+ var SoftwareConfig_WebServerPluginsMode_value = map[string]int32

+ var TaskLogsRetentionConfig_TaskLogsStorageMode_name = map[int32]string

+ var TaskLogsRetentionConfig_TaskLogsStorageMode_value = map[string]int32

+ type CloudDataLineageIntegration struct

+ Enabled bool

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

+ func (*CloudDataLineageIntegration) ProtoMessage()

+ func (x *CloudDataLineageIntegration) GetEnabled() bool

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

+ func (x *CloudDataLineageIntegration) Reset()

+ func (x *CloudDataLineageIntegration) String() string

+ type CreateUserWorkloadsConfigMapRequest struct

+ Parent string

+ UserWorkloadsConfigMap *UserWorkloadsConfigMap

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

+ func (*CreateUserWorkloadsConfigMapRequest) ProtoMessage()

+ func (x *CreateUserWorkloadsConfigMapRequest) GetParent() string

+ func (x *CreateUserWorkloadsConfigMapRequest) GetUserWorkloadsConfigMap() *UserWorkloadsConfigMap

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

+ func (x *CreateUserWorkloadsConfigMapRequest) Reset()

+ func (x *CreateUserWorkloadsConfigMapRequest) String() string

+ type CreateUserWorkloadsSecretRequest struct

+ Parent string

+ UserWorkloadsSecret *UserWorkloadsSecret

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

+ func (*CreateUserWorkloadsSecretRequest) ProtoMessage()

+ func (x *CreateUserWorkloadsSecretRequest) GetParent() string

+ func (x *CreateUserWorkloadsSecretRequest) GetUserWorkloadsSecret() *UserWorkloadsSecret

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

+ func (x *CreateUserWorkloadsSecretRequest) Reset()

+ func (x *CreateUserWorkloadsSecretRequest) String() string

+ type DataRetentionConfig struct

+ TaskLogsRetentionConfig *TaskLogsRetentionConfig

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

+ func (*DataRetentionConfig) ProtoMessage()

+ func (x *DataRetentionConfig) GetTaskLogsRetentionConfig() *TaskLogsRetentionConfig

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

+ func (x *DataRetentionConfig) Reset()

+ func (x *DataRetentionConfig) String() string

type DatabaseConfig

+ Zone string

+ func (x *DatabaseConfig) GetZone() string

+ type DeleteUserWorkloadsConfigMapRequest struct

+ Name string

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

+ func (*DeleteUserWorkloadsConfigMapRequest) ProtoMessage()

+ func (x *DeleteUserWorkloadsConfigMapRequest) GetName() string

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

+ func (x *DeleteUserWorkloadsConfigMapRequest) Reset()

+ func (x *DeleteUserWorkloadsConfigMapRequest) String() string

+ type DeleteUserWorkloadsSecretRequest struct

+ Name string

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

+ func (*DeleteUserWorkloadsSecretRequest) ProtoMessage()

+ func (x *DeleteUserWorkloadsSecretRequest) GetName() string

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

+ func (x *DeleteUserWorkloadsSecretRequest) Reset()

+ func (x *DeleteUserWorkloadsSecretRequest) String() string

type Environment

+ SatisfiesPzs bool

+ StorageConfig *StorageConfig

+ func (x *Environment) GetSatisfiesPzs() bool

+ func (x *Environment) GetStorageConfig() *StorageConfig

type EnvironmentConfig

+ DataRetentionConfig *DataRetentionConfig

+ func (x *EnvironmentConfig) GetDataRetentionConfig() *DataRetentionConfig

type EnvironmentsClient

+ CreateUserWorkloadsConfigMap func(ctx context.Context, in *CreateUserWorkloadsConfigMapRequest, ...) (*UserWorkloadsConfigMap, error)

+ CreateUserWorkloadsSecret func(ctx context.Context, in *CreateUserWorkloadsSecretRequest, ...) (*UserWorkloadsSecret, error)

+ DeleteUserWorkloadsConfigMap func(ctx context.Context, in *DeleteUserWorkloadsConfigMapRequest, ...) (*emptypb.Empty, error)

+ DeleteUserWorkloadsSecret func(ctx context.Context, in *DeleteUserWorkloadsSecretRequest, ...) (*emptypb.Empty, error)

+ GetUserWorkloadsConfigMap func(ctx context.Context, in *GetUserWorkloadsConfigMapRequest, ...) (*UserWorkloadsConfigMap, error)

+ GetUserWorkloadsSecret func(ctx context.Context, in *GetUserWorkloadsSecretRequest, ...) (*UserWorkloadsSecret, error)

+ ListUserWorkloadsConfigMaps func(ctx context.Context, in *ListUserWorkloadsConfigMapsRequest, ...) (*ListUserWorkloadsConfigMapsResponse, error)

+ ListUserWorkloadsSecrets func(ctx context.Context, in *ListUserWorkloadsSecretsRequest, ...) (*ListUserWorkloadsSecretsResponse, error)

+ ListWorkloads func(ctx context.Context, in *ListWorkloadsRequest, opts ...grpc.CallOption) (*ListWorkloadsResponse, error)

+ UpdateUserWorkloadsConfigMap func(ctx context.Context, in *UpdateUserWorkloadsConfigMapRequest, ...) (*UserWorkloadsConfigMap, error)

+ UpdateUserWorkloadsSecret func(ctx context.Context, in *UpdateUserWorkloadsSecretRequest, ...) (*UserWorkloadsSecret, error)

type EnvironmentsServer

+ CreateUserWorkloadsConfigMap func(context.Context, *CreateUserWorkloadsConfigMapRequest) (*UserWorkloadsConfigMap, error)

+ CreateUserWorkloadsSecret func(context.Context, *CreateUserWorkloadsSecretRequest) (*UserWorkloadsSecret, error)

+ DeleteUserWorkloadsConfigMap func(context.Context, *DeleteUserWorkloadsConfigMapRequest) (*emptypb.Empty, error)

+ DeleteUserWorkloadsSecret func(context.Context, *DeleteUserWorkloadsSecretRequest) (*emptypb.Empty, error)

+ GetUserWorkloadsConfigMap func(context.Context, *GetUserWorkloadsConfigMapRequest) (*UserWorkloadsConfigMap, error)

+ GetUserWorkloadsSecret func(context.Context, *GetUserWorkloadsSecretRequest) (*UserWorkloadsSecret, error)

+ ListUserWorkloadsConfigMaps func(context.Context, *ListUserWorkloadsConfigMapsRequest) (*ListUserWorkloadsConfigMapsResponse, error)

+ ListUserWorkloadsSecrets func(context.Context, *ListUserWorkloadsSecretsRequest) (*ListUserWorkloadsSecretsResponse, error)

+ ListWorkloads func(context.Context, *ListWorkloadsRequest) (*ListWorkloadsResponse, error)

+ UpdateUserWorkloadsConfigMap func(context.Context, *UpdateUserWorkloadsConfigMapRequest) (*UserWorkloadsConfigMap, error)

+ UpdateUserWorkloadsSecret func(context.Context, *UpdateUserWorkloadsSecretRequest) (*UserWorkloadsSecret, error)

+ type GetUserWorkloadsConfigMapRequest struct

+ Name string

+ func (*GetUserWorkloadsConfigMapRequest) Descriptor() ([]byte, []int)

+ func (*GetUserWorkloadsConfigMapRequest) ProtoMessage()

+ func (x *GetUserWorkloadsConfigMapRequest) GetName() string

+ func (x *GetUserWorkloadsConfigMapRequest) ProtoReflect() protoreflect.Message

+ func (x *GetUserWorkloadsConfigMapRequest) Reset()

+ func (x *GetUserWorkloadsConfigMapRequest) String() string

+ type GetUserWorkloadsSecretRequest struct

+ Name string

+ func (*GetUserWorkloadsSecretRequest) Descriptor() ([]byte, []int)

+ func (*GetUserWorkloadsSecretRequest) ProtoMessage()

+ func (x *GetUserWorkloadsSecretRequest) GetName() string

+ func (x *GetUserWorkloadsSecretRequest) ProtoReflect() protoreflect.Message

+ func (x *GetUserWorkloadsSecretRequest) Reset()

+ func (x *GetUserWorkloadsSecretRequest) String() string

+ type ListUserWorkloadsConfigMapsRequest struct

+ PageSize int32

+ PageToken string

+ Parent string

+ func (*ListUserWorkloadsConfigMapsRequest) Descriptor() ([]byte, []int)

+ func (*ListUserWorkloadsConfigMapsRequest) ProtoMessage()

+ func (x *ListUserWorkloadsConfigMapsRequest) GetPageSize() int32

+ func (x *ListUserWorkloadsConfigMapsRequest) GetPageToken() string

+ func (x *ListUserWorkloadsConfigMapsRequest) GetParent() string

+ func (x *ListUserWorkloadsConfigMapsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListUserWorkloadsConfigMapsRequest) Reset()

+ func (x *ListUserWorkloadsConfigMapsRequest) String() string

+ type ListUserWorkloadsConfigMapsResponse struct

+ NextPageToken string

+ UserWorkloadsConfigMaps []*UserWorkloadsConfigMap

+ func (*ListUserWorkloadsConfigMapsResponse) Descriptor() ([]byte, []int)

+ func (*ListUserWorkloadsConfigMapsResponse) ProtoMessage()

+ func (x *ListUserWorkloadsConfigMapsResponse) GetNextPageToken() string

+ func (x *ListUserWorkloadsConfigMapsResponse) GetUserWorkloadsConfigMaps() []*UserWorkloadsConfigMap

+ func (x *ListUserWorkloadsConfigMapsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListUserWorkloadsConfigMapsResponse) Reset()

+ func (x *ListUserWorkloadsConfigMapsResponse) String() string

+ type ListUserWorkloadsSecretsRequest struct

+ PageSize int32

+ PageToken string

+ Parent string

+ func (*ListUserWorkloadsSecretsRequest) Descriptor() ([]byte, []int)

+ func (*ListUserWorkloadsSecretsRequest) ProtoMessage()

+ func (x *ListUserWorkloadsSecretsRequest) GetPageSize() int32

+ func (x *ListUserWorkloadsSecretsRequest) GetPageToken() string

+ func (x *ListUserWorkloadsSecretsRequest) GetParent() string

+ func (x *ListUserWorkloadsSecretsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListUserWorkloadsSecretsRequest) Reset()

+ func (x *ListUserWorkloadsSecretsRequest) String() string

+ type ListUserWorkloadsSecretsResponse struct

+ NextPageToken string

+ UserWorkloadsSecrets []*UserWorkloadsSecret

+ func (*ListUserWorkloadsSecretsResponse) Descriptor() ([]byte, []int)

+ func (*ListUserWorkloadsSecretsResponse) ProtoMessage()

+ func (x *ListUserWorkloadsSecretsResponse) GetNextPageToken() string

+ func (x *ListUserWorkloadsSecretsResponse) GetUserWorkloadsSecrets() []*UserWorkloadsSecret

+ func (x *ListUserWorkloadsSecretsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListUserWorkloadsSecretsResponse) Reset()

+ func (x *ListUserWorkloadsSecretsResponse) String() string

+ type ListWorkloadsRequest struct

+ Filter string

+ PageSize int32

+ PageToken string

+ Parent string

+ func (*ListWorkloadsRequest) Descriptor() ([]byte, []int)

+ func (*ListWorkloadsRequest) ProtoMessage()

+ func (x *ListWorkloadsRequest) GetFilter() string

+ func (x *ListWorkloadsRequest) GetPageSize() int32

+ func (x *ListWorkloadsRequest) GetPageToken() string

+ func (x *ListWorkloadsRequest) GetParent() string

+ func (x *ListWorkloadsRequest) ProtoReflect() protoreflect.Message

+ func (x *ListWorkloadsRequest) Reset()

+ func (x *ListWorkloadsRequest) String() string

+ type ListWorkloadsResponse struct

+ NextPageToken string

+ Workloads []*ListWorkloadsResponse_ComposerWorkload

+ func (*ListWorkloadsResponse) Descriptor() ([]byte, []int)

+ func (*ListWorkloadsResponse) ProtoMessage()

+ func (x *ListWorkloadsResponse) GetNextPageToken() string

+ func (x *ListWorkloadsResponse) GetWorkloads() []*ListWorkloadsResponse_ComposerWorkload

+ func (x *ListWorkloadsResponse) ProtoReflect() protoreflect.Message

+ func (x *ListWorkloadsResponse) Reset()

+ func (x *ListWorkloadsResponse) String() string

+ type ListWorkloadsResponse_ComposerWorkload struct

+ Name string

+ Status *ListWorkloadsResponse_ComposerWorkloadStatus

+ Type ListWorkloadsResponse_ComposerWorkloadType

+ func (*ListWorkloadsResponse_ComposerWorkload) Descriptor() ([]byte, []int)

+ func (*ListWorkloadsResponse_ComposerWorkload) ProtoMessage()

+ func (x *ListWorkloadsResponse_ComposerWorkload) GetName() string

+ func (x *ListWorkloadsResponse_ComposerWorkload) GetStatus() *ListWorkloadsResponse_ComposerWorkloadStatus

+ func (x *ListWorkloadsResponse_ComposerWorkload) GetType() ListWorkloadsResponse_ComposerWorkloadType

+ func (x *ListWorkloadsResponse_ComposerWorkload) ProtoReflect() protoreflect.Message

+ func (x *ListWorkloadsResponse_ComposerWorkload) Reset()

+ func (x *ListWorkloadsResponse_ComposerWorkload) String() string

+ type ListWorkloadsResponse_ComposerWorkloadState int32

+ const ListWorkloadsResponse_COMPOSER_WORKLOAD_STATE_UNSPECIFIED

+ const ListWorkloadsResponse_ERROR

+ const ListWorkloadsResponse_FAILED

+ const ListWorkloadsResponse_OK

+ const ListWorkloadsResponse_PENDING

+ const ListWorkloadsResponse_SUCCEEDED

+ const ListWorkloadsResponse_WARNING

+ func (ListWorkloadsResponse_ComposerWorkloadState) Descriptor() protoreflect.EnumDescriptor

+ func (ListWorkloadsResponse_ComposerWorkloadState) EnumDescriptor() ([]byte, []int)

+ func (ListWorkloadsResponse_ComposerWorkloadState) Type() protoreflect.EnumType

+ func (x ListWorkloadsResponse_ComposerWorkloadState) Enum() *ListWorkloadsResponse_ComposerWorkloadState

+ func (x ListWorkloadsResponse_ComposerWorkloadState) Number() protoreflect.EnumNumber

+ func (x ListWorkloadsResponse_ComposerWorkloadState) String() string

+ type ListWorkloadsResponse_ComposerWorkloadStatus struct

+ DetailedStatusMessage string

+ State ListWorkloadsResponse_ComposerWorkloadState

+ StatusMessage string

+ func (*ListWorkloadsResponse_ComposerWorkloadStatus) Descriptor() ([]byte, []int)

+ func (*ListWorkloadsResponse_ComposerWorkloadStatus) ProtoMessage()

+ func (x *ListWorkloadsResponse_ComposerWorkloadStatus) GetDetailedStatusMessage() string

+ func (x *ListWorkloadsResponse_ComposerWorkloadStatus) GetState() ListWorkloadsResponse_ComposerWorkloadState

+ func (x *ListWorkloadsResponse_ComposerWorkloadStatus) GetStatusMessage() string

+ func (x *ListWorkloadsResponse_ComposerWorkloadStatus) ProtoReflect() protoreflect.Message

+ func (x *ListWorkloadsResponse_ComposerWorkloadStatus) Reset()

+ func (x *ListWorkloadsResponse_ComposerWorkloadStatus) String() string

+ type ListWorkloadsResponse_ComposerWorkloadType int32

+ const ListWorkloadsResponse_CELERY_WORKER

+ const ListWorkloadsResponse_COMPOSER_WORKLOAD_TYPE_UNSPECIFIED

+ const ListWorkloadsResponse_DAG_PROCESSOR

+ const ListWorkloadsResponse_KUBERNETES_OPERATOR_POD

+ const ListWorkloadsResponse_KUBERNETES_WORKER

+ const ListWorkloadsResponse_REDIS

+ const ListWorkloadsResponse_SCHEDULER

+ const ListWorkloadsResponse_TRIGGERER

+ const ListWorkloadsResponse_WEB_SERVER

+ func (ListWorkloadsResponse_ComposerWorkloadType) Descriptor() protoreflect.EnumDescriptor

+ func (ListWorkloadsResponse_ComposerWorkloadType) EnumDescriptor() ([]byte, []int)

+ func (ListWorkloadsResponse_ComposerWorkloadType) Type() protoreflect.EnumType

+ func (x ListWorkloadsResponse_ComposerWorkloadType) Enum() *ListWorkloadsResponse_ComposerWorkloadType

+ func (x ListWorkloadsResponse_ComposerWorkloadType) Number() protoreflect.EnumNumber

+ func (x ListWorkloadsResponse_ComposerWorkloadType) String() string

type NodeConfig

+ ComposerInternalIpv4CidrBlock string

+ ComposerNetworkAttachment string

+ func (x *NodeConfig) GetComposerInternalIpv4CidrBlock() string

+ func (x *NodeConfig) GetComposerNetworkAttachment() string

type PrivateEnvironmentConfig

+ EnablePrivateBuildsOnly bool

+ func (x *PrivateEnvironmentConfig) GetEnablePrivateBuildsOnly() bool

type SoftwareConfig

+ CloudDataLineageIntegration *CloudDataLineageIntegration

+ WebServerPluginsMode SoftwareConfig_WebServerPluginsMode

+ func (x *SoftwareConfig) GetCloudDataLineageIntegration() *CloudDataLineageIntegration

+ func (x *SoftwareConfig) GetWebServerPluginsMode() SoftwareConfig_WebServerPluginsMode

+ type SoftwareConfig_WebServerPluginsMode int32

+ const SoftwareConfig_PLUGINS_DISABLED

+ const SoftwareConfig_PLUGINS_ENABLED

+ const SoftwareConfig_WEB_SERVER_PLUGINS_MODE_UNSPECIFIED

+ func (SoftwareConfig_WebServerPluginsMode) Descriptor() protoreflect.EnumDescriptor

+ func (SoftwareConfig_WebServerPluginsMode) EnumDescriptor() ([]byte, []int)

+ func (SoftwareConfig_WebServerPluginsMode) Type() protoreflect.EnumType

+ func (x SoftwareConfig_WebServerPluginsMode) Enum() *SoftwareConfig_WebServerPluginsMode

+ func (x SoftwareConfig_WebServerPluginsMode) Number() protoreflect.EnumNumber

+ func (x SoftwareConfig_WebServerPluginsMode) String() string

+ type StorageConfig struct

+ Bucket string

+ func (*StorageConfig) Descriptor() ([]byte, []int)

+ func (*StorageConfig) ProtoMessage()

+ func (x *StorageConfig) GetBucket() string

+ func (x *StorageConfig) ProtoReflect() protoreflect.Message

+ func (x *StorageConfig) Reset()

+ func (x *StorageConfig) String() string

+ type TaskLogsRetentionConfig struct

+ StorageMode TaskLogsRetentionConfig_TaskLogsStorageMode

+ func (*TaskLogsRetentionConfig) Descriptor() ([]byte, []int)

+ func (*TaskLogsRetentionConfig) ProtoMessage()

+ func (x *TaskLogsRetentionConfig) GetStorageMode() TaskLogsRetentionConfig_TaskLogsStorageMode

+ func (x *TaskLogsRetentionConfig) ProtoReflect() protoreflect.Message

+ func (x *TaskLogsRetentionConfig) Reset()

+ func (x *TaskLogsRetentionConfig) String() string

+ type TaskLogsRetentionConfig_TaskLogsStorageMode int32

+ const TaskLogsRetentionConfig_CLOUD_LOGGING_AND_CLOUD_STORAGE

+ const TaskLogsRetentionConfig_CLOUD_LOGGING_ONLY

+ const TaskLogsRetentionConfig_TASK_LOGS_STORAGE_MODE_UNSPECIFIED

+ func (TaskLogsRetentionConfig_TaskLogsStorageMode) Descriptor() protoreflect.EnumDescriptor

+ func (TaskLogsRetentionConfig_TaskLogsStorageMode) EnumDescriptor() ([]byte, []int)

+ func (TaskLogsRetentionConfig_TaskLogsStorageMode) Type() protoreflect.EnumType

+ func (x TaskLogsRetentionConfig_TaskLogsStorageMode) Enum() *TaskLogsRetentionConfig_TaskLogsStorageMode

+ func (x TaskLogsRetentionConfig_TaskLogsStorageMode) Number() protoreflect.EnumNumber

+ func (x TaskLogsRetentionConfig_TaskLogsStorageMode) String() string

type UnimplementedEnvironmentsServer

+ func (*UnimplementedEnvironmentsServer) CreateUserWorkloadsConfigMap(context.Context, *CreateUserWorkloadsConfigMapRequest) (*UserWorkloadsConfigMap, error)

+ func (*UnimplementedEnvironmentsServer) CreateUserWorkloadsSecret(context.Context, *CreateUserWorkloadsSecretRequest) (*UserWorkloadsSecret, error)

+ func (*UnimplementedEnvironmentsServer) DeleteUserWorkloadsConfigMap(context.Context, *DeleteUserWorkloadsConfigMapRequest) (*emptypb.Empty, error)

+ func (*UnimplementedEnvironmentsServer) DeleteUserWorkloadsSecret(context.Context, *DeleteUserWorkloadsSecretRequest) (*emptypb.Empty, error)

+ func (*UnimplementedEnvironmentsServer) GetUserWorkloadsConfigMap(context.Context, *GetUserWorkloadsConfigMapRequest) (*UserWorkloadsConfigMap, error)

+ func (*UnimplementedEnvironmentsServer) GetUserWorkloadsSecret(context.Context, *GetUserWorkloadsSecretRequest) (*UserWorkloadsSecret, error)

+ func (*UnimplementedEnvironmentsServer) ListUserWorkloadsConfigMaps(context.Context, *ListUserWorkloadsConfigMapsRequest) (*ListUserWorkloadsConfigMapsResponse, error)

+ func (*UnimplementedEnvironmentsServer) ListUserWorkloadsSecrets(context.Context, *ListUserWorkloadsSecretsRequest) (*ListUserWorkloadsSecretsResponse, error)

+ func (*UnimplementedEnvironmentsServer) ListWorkloads(context.Context, *ListWorkloadsRequest) (*ListWorkloadsResponse, error)

+ func (*UnimplementedEnvironmentsServer) UpdateUserWorkloadsConfigMap(context.Context, *UpdateUserWorkloadsConfigMapRequest) (*UserWorkloadsConfigMap, error)

+ func (*UnimplementedEnvironmentsServer) UpdateUserWorkloadsSecret(context.Context, *UpdateUserWorkloadsSecretRequest) (*UserWorkloadsSecret, error)

+ type UpdateUserWorkloadsConfigMapRequest struct

+ UserWorkloadsConfigMap *UserWorkloadsConfigMap

+ func (*UpdateUserWorkloadsConfigMapRequest) Descriptor() ([]byte, []int)

+ func (*UpdateUserWorkloadsConfigMapRequest) ProtoMessage()

+ func (x *UpdateUserWorkloadsConfigMapRequest) GetUserWorkloadsConfigMap() *UserWorkloadsConfigMap

+ func (x *UpdateUserWorkloadsConfigMapRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateUserWorkloadsConfigMapRequest) Reset()

+ func (x *UpdateUserWorkloadsConfigMapRequest) String() string

+ type UpdateUserWorkloadsSecretRequest struct

+ UserWorkloadsSecret *UserWorkloadsSecret

+ func (*UpdateUserWorkloadsSecretRequest) Descriptor() ([]byte, []int)

+ func (*UpdateUserWorkloadsSecretRequest) ProtoMessage()

+ func (x *UpdateUserWorkloadsSecretRequest) GetUserWorkloadsSecret() *UserWorkloadsSecret

+ func (x *UpdateUserWorkloadsSecretRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateUserWorkloadsSecretRequest) Reset()

+ func (x *UpdateUserWorkloadsSecretRequest) String() string

+ type UserWorkloadsConfigMap struct

+ Data map[string]string

+ Name string

+ func (*UserWorkloadsConfigMap) Descriptor() ([]byte, []int)

+ func (*UserWorkloadsConfigMap) ProtoMessage()

+ func (x *UserWorkloadsConfigMap) GetData() map[string]string

+ func (x *UserWorkloadsConfigMap) GetName() string

+ func (x *UserWorkloadsConfigMap) ProtoReflect() protoreflect.Message

+ func (x *UserWorkloadsConfigMap) Reset()

+ func (x *UserWorkloadsConfigMap) String() string

+ type UserWorkloadsSecret struct

+ Data map[string]string

+ Name string

+ func (*UserWorkloadsSecret) Descriptor() ([]byte, []int)

+ func (*UserWorkloadsSecret) ProtoMessage()

+ func (x *UserWorkloadsSecret) GetData() map[string]string

+ func (x *UserWorkloadsSecret) GetName() string

+ func (x *UserWorkloadsSecret) ProtoReflect() protoreflect.Message

+ func (x *UserWorkloadsSecret) Reset()

+ func (x *UserWorkloadsSecret) String() string

type WorkloadsConfig

+ DagProcessor *WorkloadsConfig_DagProcessorResource

+ Triggerer *WorkloadsConfig_TriggererResource

+ func (x *WorkloadsConfig) GetDagProcessor() *WorkloadsConfig_DagProcessorResource

+ func (x *WorkloadsConfig) GetTriggerer() *WorkloadsConfig_TriggererResource

+ type WorkloadsConfig_DagProcessorResource struct

+ Count int32

+ Cpu float32

+ MemoryGb float32

+ StorageGb float32

+ func (*WorkloadsConfig_DagProcessorResource) Descriptor() ([]byte, []int)

+ func (*WorkloadsConfig_DagProcessorResource) ProtoMessage()

+ func (x *WorkloadsConfig_DagProcessorResource) GetCount() int32

+ func (x *WorkloadsConfig_DagProcessorResource) GetCpu() float32

+ func (x *WorkloadsConfig_DagProcessorResource) GetMemoryGb() float32

+ func (x *WorkloadsConfig_DagProcessorResource) GetStorageGb() float32

+ func (x *WorkloadsConfig_DagProcessorResource) ProtoReflect() protoreflect.Message

+ func (x *WorkloadsConfig_DagProcessorResource) Reset()

+ func (x *WorkloadsConfig_DagProcessorResource) String() string

+ type WorkloadsConfig_TriggererResource struct

+ Count int32

+ Cpu float32

+ MemoryGb float32

+ func (*WorkloadsConfig_TriggererResource) Descriptor() ([]byte, []int)

+ func (*WorkloadsConfig_TriggererResource) ProtoMessage()

+ func (x *WorkloadsConfig_TriggererResource) GetCount() int32

+ func (x *WorkloadsConfig_TriggererResource) GetCpu() float32

+ func (x *WorkloadsConfig_TriggererResource) GetMemoryGb() float32

+ func (x *WorkloadsConfig_TriggererResource) ProtoReflect() protoreflect.Message

+ func (x *WorkloadsConfig_TriggererResource) Reset()

+ func (x *WorkloadsConfig_TriggererResource) String() string

v1.8.5

Jan 30, 2024

v1.8.4

Nov 1, 2023

v1.8.3

Oct 26, 2023

v1.8.2

Oct 12, 2023

v1.8.1

Jun 20, 2023

v1.8.0

Jun 13, 2023

Changes in this version

+ var EnvironmentConfig_ResilienceMode_name = map[int32]string

+ var EnvironmentConfig_ResilienceMode_value = map[string]int32

+ type DatabaseFailoverRequest struct

+ Environment string

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

+ func (*DatabaseFailoverRequest) ProtoMessage()

+ func (x *DatabaseFailoverRequest) GetEnvironment() string

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

+ func (x *DatabaseFailoverRequest) Reset()

+ func (x *DatabaseFailoverRequest) String() string

+ type DatabaseFailoverResponse struct

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

+ func (*DatabaseFailoverResponse) ProtoMessage()

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

+ func (x *DatabaseFailoverResponse) Reset()

+ func (x *DatabaseFailoverResponse) String() string

type EnvironmentConfig

+ ResilienceMode EnvironmentConfig_ResilienceMode

+ func (x *EnvironmentConfig) GetResilienceMode() EnvironmentConfig_ResilienceMode

+ type EnvironmentConfig_ResilienceMode int32

+ const EnvironmentConfig_HIGH_RESILIENCE

+ const EnvironmentConfig_RESILIENCE_MODE_UNSPECIFIED

+ func (EnvironmentConfig_ResilienceMode) Descriptor() protoreflect.EnumDescriptor

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

+ func (EnvironmentConfig_ResilienceMode) Type() protoreflect.EnumType

+ func (x EnvironmentConfig_ResilienceMode) Enum() *EnvironmentConfig_ResilienceMode

+ func (x EnvironmentConfig_ResilienceMode) Number() protoreflect.EnumNumber

+ func (x EnvironmentConfig_ResilienceMode) String() string

type EnvironmentsClient

+ DatabaseFailover func(ctx context.Context, in *DatabaseFailoverRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)

+ ExecuteAirflowCommand func(ctx context.Context, in *ExecuteAirflowCommandRequest, opts ...grpc.CallOption) (*ExecuteAirflowCommandResponse, error)

+ FetchDatabaseProperties func(ctx context.Context, in *FetchDatabasePropertiesRequest, ...) (*FetchDatabasePropertiesResponse, error)

+ PollAirflowCommand func(ctx context.Context, in *PollAirflowCommandRequest, opts ...grpc.CallOption) (*PollAirflowCommandResponse, error)

+ StopAirflowCommand func(ctx context.Context, in *StopAirflowCommandRequest, opts ...grpc.CallOption) (*StopAirflowCommandResponse, error)

type EnvironmentsServer

+ DatabaseFailover func(context.Context, *DatabaseFailoverRequest) (*longrunningpb.Operation, error)

+ ExecuteAirflowCommand func(context.Context, *ExecuteAirflowCommandRequest) (*ExecuteAirflowCommandResponse, error)

+ FetchDatabaseProperties func(context.Context, *FetchDatabasePropertiesRequest) (*FetchDatabasePropertiesResponse, error)

+ PollAirflowCommand func(context.Context, *PollAirflowCommandRequest) (*PollAirflowCommandResponse, error)

+ StopAirflowCommand func(context.Context, *StopAirflowCommandRequest) (*StopAirflowCommandResponse, error)

+ type ExecuteAirflowCommandRequest struct

+ Command string

+ Environment string

+ Parameters []string

+ Subcommand string

+ func (*ExecuteAirflowCommandRequest) Descriptor() ([]byte, []int)

+ func (*ExecuteAirflowCommandRequest) ProtoMessage()

+ func (x *ExecuteAirflowCommandRequest) GetCommand() string

+ func (x *ExecuteAirflowCommandRequest) GetEnvironment() string

+ func (x *ExecuteAirflowCommandRequest) GetParameters() []string

+ func (x *ExecuteAirflowCommandRequest) GetSubcommand() string

+ func (x *ExecuteAirflowCommandRequest) ProtoReflect() protoreflect.Message

+ func (x *ExecuteAirflowCommandRequest) Reset()

+ func (x *ExecuteAirflowCommandRequest) String() string

+ type ExecuteAirflowCommandResponse struct

+ Error string

+ ExecutionId string

+ Pod string

+ PodNamespace string

+ func (*ExecuteAirflowCommandResponse) Descriptor() ([]byte, []int)

+ func (*ExecuteAirflowCommandResponse) ProtoMessage()

+ func (x *ExecuteAirflowCommandResponse) GetError() string

+ func (x *ExecuteAirflowCommandResponse) GetExecutionId() string

+ func (x *ExecuteAirflowCommandResponse) GetPod() string

+ func (x *ExecuteAirflowCommandResponse) GetPodNamespace() string

+ func (x *ExecuteAirflowCommandResponse) ProtoReflect() protoreflect.Message

+ func (x *ExecuteAirflowCommandResponse) Reset()

+ func (x *ExecuteAirflowCommandResponse) String() string

+ type FetchDatabasePropertiesRequest struct

+ Environment string

+ func (*FetchDatabasePropertiesRequest) Descriptor() ([]byte, []int)

+ func (*FetchDatabasePropertiesRequest) ProtoMessage()

+ func (x *FetchDatabasePropertiesRequest) GetEnvironment() string

+ func (x *FetchDatabasePropertiesRequest) ProtoReflect() protoreflect.Message

+ func (x *FetchDatabasePropertiesRequest) Reset()

+ func (x *FetchDatabasePropertiesRequest) String() string

+ type FetchDatabasePropertiesResponse struct

+ IsFailoverReplicaAvailable bool

+ PrimaryGceZone string

+ SecondaryGceZone string

+ func (*FetchDatabasePropertiesResponse) Descriptor() ([]byte, []int)

+ func (*FetchDatabasePropertiesResponse) ProtoMessage()

+ func (x *FetchDatabasePropertiesResponse) GetIsFailoverReplicaAvailable() bool

+ func (x *FetchDatabasePropertiesResponse) GetPrimaryGceZone() string

+ func (x *FetchDatabasePropertiesResponse) GetSecondaryGceZone() string

+ func (x *FetchDatabasePropertiesResponse) ProtoReflect() protoreflect.Message

+ func (x *FetchDatabasePropertiesResponse) Reset()

+ func (x *FetchDatabasePropertiesResponse) String() string

type OperationMetadata_Type

+ const OperationMetadata_DATABASE_FAILOVER

+ type PollAirflowCommandRequest struct

+ Environment string

+ ExecutionId string

+ NextLineNumber int32

+ Pod string

+ PodNamespace string

+ func (*PollAirflowCommandRequest) Descriptor() ([]byte, []int)

+ func (*PollAirflowCommandRequest) ProtoMessage()

+ func (x *PollAirflowCommandRequest) GetEnvironment() string

+ func (x *PollAirflowCommandRequest) GetExecutionId() string

+ func (x *PollAirflowCommandRequest) GetNextLineNumber() int32

+ func (x *PollAirflowCommandRequest) GetPod() string

+ func (x *PollAirflowCommandRequest) GetPodNamespace() string

+ func (x *PollAirflowCommandRequest) ProtoReflect() protoreflect.Message

+ func (x *PollAirflowCommandRequest) Reset()

+ func (x *PollAirflowCommandRequest) String() string

+ type PollAirflowCommandResponse struct

+ ExitInfo *PollAirflowCommandResponse_ExitInfo

+ Output []*PollAirflowCommandResponse_Line

+ OutputEnd bool

+ func (*PollAirflowCommandResponse) Descriptor() ([]byte, []int)

+ func (*PollAirflowCommandResponse) ProtoMessage()

+ func (x *PollAirflowCommandResponse) GetExitInfo() *PollAirflowCommandResponse_ExitInfo

+ func (x *PollAirflowCommandResponse) GetOutput() []*PollAirflowCommandResponse_Line

+ func (x *PollAirflowCommandResponse) GetOutputEnd() bool

+ func (x *PollAirflowCommandResponse) ProtoReflect() protoreflect.Message

+ func (x *PollAirflowCommandResponse) Reset()

+ func (x *PollAirflowCommandResponse) String() string

+ type PollAirflowCommandResponse_ExitInfo struct

+ Error string

+ ExitCode int32

+ func (*PollAirflowCommandResponse_ExitInfo) Descriptor() ([]byte, []int)

+ func (*PollAirflowCommandResponse_ExitInfo) ProtoMessage()

+ func (x *PollAirflowCommandResponse_ExitInfo) GetError() string

+ func (x *PollAirflowCommandResponse_ExitInfo) GetExitCode() int32

+ func (x *PollAirflowCommandResponse_ExitInfo) ProtoReflect() protoreflect.Message

+ func (x *PollAirflowCommandResponse_ExitInfo) Reset()

+ func (x *PollAirflowCommandResponse_ExitInfo) String() string

+ type PollAirflowCommandResponse_Line struct

+ Content string

+ LineNumber int32

+ func (*PollAirflowCommandResponse_Line) Descriptor() ([]byte, []int)

+ func (*PollAirflowCommandResponse_Line) ProtoMessage()

+ func (x *PollAirflowCommandResponse_Line) GetContent() string

+ func (x *PollAirflowCommandResponse_Line) GetLineNumber() int32

+ func (x *PollAirflowCommandResponse_Line) ProtoReflect() protoreflect.Message

+ func (x *PollAirflowCommandResponse_Line) Reset()

+ func (x *PollAirflowCommandResponse_Line) String() string

+ type StopAirflowCommandRequest struct

+ Environment string

+ ExecutionId string

+ Force bool

+ Pod string

+ PodNamespace string

+ func (*StopAirflowCommandRequest) Descriptor() ([]byte, []int)

+ func (*StopAirflowCommandRequest) ProtoMessage()

+ func (x *StopAirflowCommandRequest) GetEnvironment() string

+ func (x *StopAirflowCommandRequest) GetExecutionId() string

+ func (x *StopAirflowCommandRequest) GetForce() bool

+ func (x *StopAirflowCommandRequest) GetPod() string

+ func (x *StopAirflowCommandRequest) GetPodNamespace() string

+ func (x *StopAirflowCommandRequest) ProtoReflect() protoreflect.Message

+ func (x *StopAirflowCommandRequest) Reset()

+ func (x *StopAirflowCommandRequest) String() string

+ type StopAirflowCommandResponse struct

+ IsDone bool

+ Output []string

+ func (*StopAirflowCommandResponse) Descriptor() ([]byte, []int)

+ func (*StopAirflowCommandResponse) ProtoMessage()

+ func (x *StopAirflowCommandResponse) GetIsDone() bool

+ func (x *StopAirflowCommandResponse) GetOutput() []string

+ func (x *StopAirflowCommandResponse) ProtoReflect() protoreflect.Message

+ func (x *StopAirflowCommandResponse) Reset()

+ func (x *StopAirflowCommandResponse) String() string

type UnimplementedEnvironmentsServer

+ func (*UnimplementedEnvironmentsServer) DatabaseFailover(context.Context, *DatabaseFailoverRequest) (*longrunningpb.Operation, error)

+ func (*UnimplementedEnvironmentsServer) ExecuteAirflowCommand(context.Context, *ExecuteAirflowCommandRequest) (*ExecuteAirflowCommandResponse, error)

+ func (*UnimplementedEnvironmentsServer) FetchDatabaseProperties(context.Context, *FetchDatabasePropertiesRequest) (*FetchDatabasePropertiesResponse, error)

+ func (*UnimplementedEnvironmentsServer) PollAirflowCommand(context.Context, *PollAirflowCommandRequest) (*PollAirflowCommandResponse, error)

+ func (*UnimplementedEnvironmentsServer) StopAirflowCommand(context.Context, *StopAirflowCommandRequest) (*StopAirflowCommandResponse, error)

v1.7.0

May 30, 2023

v1.6.1

May 8, 2023

Changes in this version

type EnvironmentConfig

+ AirflowByoidUri string

+ func (x *EnvironmentConfig) GetAirflowByoidUri() string

v1.6.0

Jan 5, 2023

v1.5.0

Dec 15, 2022

Changes in this version

+ var EnvironmentConfig_EnvironmentSize_name = map[int32]string

+ var EnvironmentConfig_EnvironmentSize_value = map[string]int32

+ var NetworkingConfig_ConnectionType_name = map[int32]string

+ var NetworkingConfig_ConnectionType_value = map[string]int32

type EnvironmentConfig

+ EnvironmentSize EnvironmentConfig_EnvironmentSize

+ MaintenanceWindow *MaintenanceWindow

+ MasterAuthorizedNetworksConfig *MasterAuthorizedNetworksConfig

+ RecoveryConfig *RecoveryConfig

+ WorkloadsConfig *WorkloadsConfig

+ func (x *EnvironmentConfig) GetEnvironmentSize() EnvironmentConfig_EnvironmentSize

+ func (x *EnvironmentConfig) GetMaintenanceWindow() *MaintenanceWindow

+ func (x *EnvironmentConfig) GetMasterAuthorizedNetworksConfig() *MasterAuthorizedNetworksConfig

+ func (x *EnvironmentConfig) GetRecoveryConfig() *RecoveryConfig

+ func (x *EnvironmentConfig) GetWorkloadsConfig() *WorkloadsConfig

+ type EnvironmentConfig_EnvironmentSize int32

+ const EnvironmentConfig_ENVIRONMENT_SIZE_LARGE

+ const EnvironmentConfig_ENVIRONMENT_SIZE_MEDIUM

+ const EnvironmentConfig_ENVIRONMENT_SIZE_SMALL

+ const EnvironmentConfig_ENVIRONMENT_SIZE_UNSPECIFIED

+ func (EnvironmentConfig_EnvironmentSize) Descriptor() protoreflect.EnumDescriptor

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

+ func (EnvironmentConfig_EnvironmentSize) Type() protoreflect.EnumType

+ func (x EnvironmentConfig_EnvironmentSize) Enum() *EnvironmentConfig_EnvironmentSize

+ func (x EnvironmentConfig_EnvironmentSize) Number() protoreflect.EnumNumber

+ func (x EnvironmentConfig_EnvironmentSize) String() string

type EnvironmentsClient

+ LoadSnapshot func(ctx context.Context, in *LoadSnapshotRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)

+ SaveSnapshot func(ctx context.Context, in *SaveSnapshotRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)

type EnvironmentsServer

+ LoadSnapshot func(context.Context, *LoadSnapshotRequest) (*longrunning.Operation, error)

+ SaveSnapshot func(context.Context, *SaveSnapshotRequest) (*longrunning.Operation, error)

+ type LoadSnapshotRequest struct

+ Environment string

+ SkipAirflowOverridesSetting bool

+ SkipEnvironmentVariablesSetting bool

+ SkipGcsDataCopying bool

+ SkipPypiPackagesInstallation bool

+ SnapshotPath string

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

+ func (*LoadSnapshotRequest) ProtoMessage()

+ func (x *LoadSnapshotRequest) GetEnvironment() string

+ func (x *LoadSnapshotRequest) GetSkipAirflowOverridesSetting() bool

+ func (x *LoadSnapshotRequest) GetSkipEnvironmentVariablesSetting() bool

+ func (x *LoadSnapshotRequest) GetSkipGcsDataCopying() bool

+ func (x *LoadSnapshotRequest) GetSkipPypiPackagesInstallation() bool

+ func (x *LoadSnapshotRequest) GetSnapshotPath() string

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

+ func (x *LoadSnapshotRequest) Reset()

+ func (x *LoadSnapshotRequest) String() string

+ type LoadSnapshotResponse struct

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

+ func (*LoadSnapshotResponse) ProtoMessage()

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

+ func (x *LoadSnapshotResponse) Reset()

+ func (x *LoadSnapshotResponse) String() string

+ type MaintenanceWindow struct

+ EndTime *timestamppb.Timestamp

+ Recurrence string

+ StartTime *timestamppb.Timestamp

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

+ func (*MaintenanceWindow) ProtoMessage()

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

+ func (x *MaintenanceWindow) GetRecurrence() string

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

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

+ func (x *MaintenanceWindow) Reset()

+ func (x *MaintenanceWindow) String() string

+ type MasterAuthorizedNetworksConfig struct

+ CidrBlocks []*MasterAuthorizedNetworksConfig_CidrBlock

+ Enabled bool

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

+ func (*MasterAuthorizedNetworksConfig) ProtoMessage()

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

+ func (x *MasterAuthorizedNetworksConfig) GetEnabled() bool

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

+ func (x *MasterAuthorizedNetworksConfig) Reset()

+ func (x *MasterAuthorizedNetworksConfig) String() string

+ type MasterAuthorizedNetworksConfig_CidrBlock struct

+ CidrBlock string

+ DisplayName string

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

+ func (*MasterAuthorizedNetworksConfig_CidrBlock) ProtoMessage()

+ func (x *MasterAuthorizedNetworksConfig_CidrBlock) GetCidrBlock() string

+ func (x *MasterAuthorizedNetworksConfig_CidrBlock) GetDisplayName() string

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

+ func (x *MasterAuthorizedNetworksConfig_CidrBlock) Reset()

+ func (x *MasterAuthorizedNetworksConfig_CidrBlock) String() string

+ type NetworkingConfig struct

+ ConnectionType NetworkingConfig_ConnectionType

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

+ func (*NetworkingConfig) ProtoMessage()

+ func (x *NetworkingConfig) GetConnectionType() NetworkingConfig_ConnectionType

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

+ func (x *NetworkingConfig) Reset()

+ func (x *NetworkingConfig) String() string

+ type NetworkingConfig_ConnectionType int32

+ const NetworkingConfig_CONNECTION_TYPE_UNSPECIFIED

+ const NetworkingConfig_PRIVATE_SERVICE_CONNECT

+ const NetworkingConfig_VPC_PEERING

+ func (NetworkingConfig_ConnectionType) Descriptor() protoreflect.EnumDescriptor

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

+ func (NetworkingConfig_ConnectionType) Type() protoreflect.EnumType

+ func (x NetworkingConfig_ConnectionType) Enum() *NetworkingConfig_ConnectionType

+ func (x NetworkingConfig_ConnectionType) Number() protoreflect.EnumNumber

+ func (x NetworkingConfig_ConnectionType) String() string

type NodeConfig

+ EnableIpMasqAgent bool

+ func (x *NodeConfig) GetEnableIpMasqAgent() bool

type OperationMetadata_Type

+ const OperationMetadata_LOAD_SNAPSHOT

+ const OperationMetadata_SAVE_SNAPSHOT

type PrivateEnvironmentConfig

+ CloudComposerConnectionSubnetwork string

+ CloudComposerNetworkIpv4CidrBlock string

+ CloudComposerNetworkIpv4ReservedRange string

+ EnablePrivatelyUsedPublicIps bool

+ NetworkingConfig *NetworkingConfig

+ func (x *PrivateEnvironmentConfig) GetCloudComposerConnectionSubnetwork() string

+ func (x *PrivateEnvironmentConfig) GetCloudComposerNetworkIpv4CidrBlock() string

+ func (x *PrivateEnvironmentConfig) GetCloudComposerNetworkIpv4ReservedRange() string

+ func (x *PrivateEnvironmentConfig) GetEnablePrivatelyUsedPublicIps() bool

+ func (x *PrivateEnvironmentConfig) GetNetworkingConfig() *NetworkingConfig

+ type RecoveryConfig struct

+ ScheduledSnapshotsConfig *ScheduledSnapshotsConfig

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

+ func (*RecoveryConfig) ProtoMessage()

+ func (x *RecoveryConfig) GetScheduledSnapshotsConfig() *ScheduledSnapshotsConfig

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

+ func (x *RecoveryConfig) Reset()

+ func (x *RecoveryConfig) String() string

+ type SaveSnapshotRequest struct

+ Environment string

+ SnapshotLocation string

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

+ func (*SaveSnapshotRequest) ProtoMessage()

+ func (x *SaveSnapshotRequest) GetEnvironment() string

+ func (x *SaveSnapshotRequest) GetSnapshotLocation() string

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

+ func (x *SaveSnapshotRequest) Reset()

+ func (x *SaveSnapshotRequest) String() string

+ type SaveSnapshotResponse struct

+ SnapshotPath string

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

+ func (*SaveSnapshotResponse) ProtoMessage()

+ func (x *SaveSnapshotResponse) GetSnapshotPath() string

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

+ func (x *SaveSnapshotResponse) Reset()

+ func (x *SaveSnapshotResponse) String() string

+ type ScheduledSnapshotsConfig struct

+ Enabled bool

+ SnapshotCreationSchedule string

+ SnapshotLocation string

+ TimeZone string

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

+ func (*ScheduledSnapshotsConfig) ProtoMessage()

+ func (x *ScheduledSnapshotsConfig) GetEnabled() bool

+ func (x *ScheduledSnapshotsConfig) GetSnapshotCreationSchedule() string

+ func (x *ScheduledSnapshotsConfig) GetSnapshotLocation() string

+ func (x *ScheduledSnapshotsConfig) GetTimeZone() string

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

+ func (x *ScheduledSnapshotsConfig) Reset()

+ func (x *ScheduledSnapshotsConfig) String() string

type SoftwareConfig

+ SchedulerCount int32

+ func (x *SoftwareConfig) GetSchedulerCount() int32

type UnimplementedEnvironmentsServer

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

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

+ type WorkloadsConfig struct

+ Scheduler *WorkloadsConfig_SchedulerResource

+ WebServer *WorkloadsConfig_WebServerResource

+ Worker *WorkloadsConfig_WorkerResource

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

+ func (*WorkloadsConfig) ProtoMessage()

+ func (x *WorkloadsConfig) GetScheduler() *WorkloadsConfig_SchedulerResource

+ func (x *WorkloadsConfig) GetWebServer() *WorkloadsConfig_WebServerResource

+ func (x *WorkloadsConfig) GetWorker() *WorkloadsConfig_WorkerResource

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

+ func (x *WorkloadsConfig) Reset()

+ func (x *WorkloadsConfig) String() string

+ type WorkloadsConfig_SchedulerResource struct

+ Count int32

+ Cpu float32

+ MemoryGb float32

+ StorageGb float32

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

+ func (*WorkloadsConfig_SchedulerResource) ProtoMessage()

+ func (x *WorkloadsConfig_SchedulerResource) GetCount() int32

+ func (x *WorkloadsConfig_SchedulerResource) GetCpu() float32

+ func (x *WorkloadsConfig_SchedulerResource) GetMemoryGb() float32

+ func (x *WorkloadsConfig_SchedulerResource) GetStorageGb() float32

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

+ func (x *WorkloadsConfig_SchedulerResource) Reset()

+ func (x *WorkloadsConfig_SchedulerResource) String() string

+ type WorkloadsConfig_WebServerResource struct

+ Cpu float32

+ MemoryGb float32

+ StorageGb float32

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

+ func (*WorkloadsConfig_WebServerResource) ProtoMessage()

+ func (x *WorkloadsConfig_WebServerResource) GetCpu() float32

+ func (x *WorkloadsConfig_WebServerResource) GetMemoryGb() float32

+ func (x *WorkloadsConfig_WebServerResource) GetStorageGb() float32

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

+ func (x *WorkloadsConfig_WebServerResource) Reset()

+ func (x *WorkloadsConfig_WebServerResource) String() string

+ type WorkloadsConfig_WorkerResource struct

+ Cpu float32

+ MaxCount int32

+ MemoryGb float32

+ MinCount int32

+ StorageGb float32

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

+ func (*WorkloadsConfig_WorkerResource) ProtoMessage()

+ func (x *WorkloadsConfig_WorkerResource) GetCpu() float32

+ func (x *WorkloadsConfig_WorkerResource) GetMaxCount() int32

+ func (x *WorkloadsConfig_WorkerResource) GetMemoryGb() float32

+ func (x *WorkloadsConfig_WorkerResource) GetMinCount() int32

+ func (x *WorkloadsConfig_WorkerResource) GetStorageGb() float32

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

+ func (x *WorkloadsConfig_WorkerResource) Reset()

+ func (x *WorkloadsConfig_WorkerResource) String() string

v1.4.0

Nov 3, 2022

v1.3.0

Oct 25, 2022

Changes in this version

+ var CheckUpgradeResponse_ConflictResult_name = map[int32]string

+ var CheckUpgradeResponse_ConflictResult_value = map[string]int32

+ var Environment_State_name = map[int32]string

+ var Environment_State_value = map[string]int32

+ var File_google_cloud_orchestration_airflow_service_v1_environments_proto protoreflect.FileDescriptor

+ var File_google_cloud_orchestration_airflow_service_v1_image_versions_proto protoreflect.FileDescriptor

+ var File_google_cloud_orchestration_airflow_service_v1_operations_proto protoreflect.FileDescriptor

+ var OperationMetadata_State_name = map[int32]string

+ var OperationMetadata_State_value = map[string]int32

+ var OperationMetadata_Type_name = map[int32]string

+ var OperationMetadata_Type_value = map[string]int32

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

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

+ type CheckUpgradeResponse struct

+ BuildLogUri string

+ ContainsPypiModulesConflict CheckUpgradeResponse_ConflictResult

+ ImageVersion string

+ PypiConflictBuildLogExtract string

+ PypiDependencies map[string]string

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

+ func (*CheckUpgradeResponse) ProtoMessage()

+ func (x *CheckUpgradeResponse) GetBuildLogUri() string

+ func (x *CheckUpgradeResponse) GetContainsPypiModulesConflict() CheckUpgradeResponse_ConflictResult

+ func (x *CheckUpgradeResponse) GetImageVersion() string

+ func (x *CheckUpgradeResponse) GetPypiConflictBuildLogExtract() string

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

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

+ func (x *CheckUpgradeResponse) Reset()

+ func (x *CheckUpgradeResponse) String() string

+ type CheckUpgradeResponse_ConflictResult int32

+ const CheckUpgradeResponse_CONFLICT

+ const CheckUpgradeResponse_CONFLICT_RESULT_UNSPECIFIED

+ const CheckUpgradeResponse_NO_CONFLICT

+ func (CheckUpgradeResponse_ConflictResult) Descriptor() protoreflect.EnumDescriptor

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

+ func (CheckUpgradeResponse_ConflictResult) Type() protoreflect.EnumType

+ func (x CheckUpgradeResponse_ConflictResult) Enum() *CheckUpgradeResponse_ConflictResult

+ func (x CheckUpgradeResponse_ConflictResult) Number() protoreflect.EnumNumber

+ func (x CheckUpgradeResponse_ConflictResult) String() string

+ type CreateEnvironmentRequest struct

+ Environment *Environment

+ Parent string

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

+ func (*CreateEnvironmentRequest) ProtoMessage()

+ func (x *CreateEnvironmentRequest) GetEnvironment() *Environment

+ func (x *CreateEnvironmentRequest) GetParent() string

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

+ func (x *CreateEnvironmentRequest) Reset()

+ func (x *CreateEnvironmentRequest) String() string

+ type DatabaseConfig struct

+ MachineType string

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

+ func (*DatabaseConfig) ProtoMessage()

+ func (x *DatabaseConfig) GetMachineType() string

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

+ func (x *DatabaseConfig) Reset()

+ func (x *DatabaseConfig) String() string

+ type DeleteEnvironmentRequest struct

+ Name string

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

+ func (*DeleteEnvironmentRequest) ProtoMessage()

+ func (x *DeleteEnvironmentRequest) GetName() string

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

+ func (x *DeleteEnvironmentRequest) Reset()

+ func (x *DeleteEnvironmentRequest) String() string

+ type EncryptionConfig struct

+ KmsKeyName string

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

+ func (*EncryptionConfig) ProtoMessage()

+ func (x *EncryptionConfig) GetKmsKeyName() string

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

+ func (x *EncryptionConfig) Reset()

+ func (x *EncryptionConfig) String() string

+ type Environment struct

+ Config *EnvironmentConfig

+ CreateTime *timestamp.Timestamp

+ Labels map[string]string

+ Name string

+ State Environment_State

+ UpdateTime *timestamp.Timestamp

+ Uuid string

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

+ func (*Environment) ProtoMessage()

+ func (x *Environment) GetConfig() *EnvironmentConfig

+ func (x *Environment) GetCreateTime() *timestamp.Timestamp

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

+ func (x *Environment) GetName() string

+ func (x *Environment) GetState() Environment_State

+ func (x *Environment) GetUpdateTime() *timestamp.Timestamp

+ func (x *Environment) GetUuid() string

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

+ func (x *Environment) Reset()

+ func (x *Environment) String() string

+ type EnvironmentConfig struct

+ AirflowUri string

+ DagGcsPrefix string

+ DatabaseConfig *DatabaseConfig

+ EncryptionConfig *EncryptionConfig

+ GkeCluster string

+ NodeConfig *NodeConfig

+ NodeCount int32

+ PrivateEnvironmentConfig *PrivateEnvironmentConfig

+ SoftwareConfig *SoftwareConfig

+ WebServerConfig *WebServerConfig

+ WebServerNetworkAccessControl *WebServerNetworkAccessControl

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

+ func (*EnvironmentConfig) ProtoMessage()

+ func (x *EnvironmentConfig) GetAirflowUri() string

+ func (x *EnvironmentConfig) GetDagGcsPrefix() string

+ func (x *EnvironmentConfig) GetDatabaseConfig() *DatabaseConfig

+ func (x *EnvironmentConfig) GetEncryptionConfig() *EncryptionConfig

+ func (x *EnvironmentConfig) GetGkeCluster() string

+ func (x *EnvironmentConfig) GetNodeConfig() *NodeConfig

+ func (x *EnvironmentConfig) GetNodeCount() int32

+ func (x *EnvironmentConfig) GetPrivateEnvironmentConfig() *PrivateEnvironmentConfig

+ func (x *EnvironmentConfig) GetSoftwareConfig() *SoftwareConfig

+ func (x *EnvironmentConfig) GetWebServerConfig() *WebServerConfig

+ func (x *EnvironmentConfig) GetWebServerNetworkAccessControl() *WebServerNetworkAccessControl

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

+ func (x *EnvironmentConfig) Reset()

+ func (x *EnvironmentConfig) String() string

+ type Environment_State int32

+ const Environment_CREATING

+ const Environment_DELETING

+ const Environment_ERROR

+ const Environment_RUNNING

+ const Environment_STATE_UNSPECIFIED

+ const Environment_UPDATING

+ func (Environment_State) Descriptor() protoreflect.EnumDescriptor

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

+ func (Environment_State) Type() protoreflect.EnumType

+ func (x Environment_State) Enum() *Environment_State

+ func (x Environment_State) Number() protoreflect.EnumNumber

+ func (x Environment_State) String() string

+ type EnvironmentsClient interface

+ CreateEnvironment func(ctx context.Context, in *CreateEnvironmentRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)

+ DeleteEnvironment func(ctx context.Context, in *DeleteEnvironmentRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)

+ GetEnvironment func(ctx context.Context, in *GetEnvironmentRequest, opts ...grpc.CallOption) (*Environment, error)

+ ListEnvironments func(ctx context.Context, in *ListEnvironmentsRequest, opts ...grpc.CallOption) (*ListEnvironmentsResponse, error)

+ UpdateEnvironment func(ctx context.Context, in *UpdateEnvironmentRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)

+ func NewEnvironmentsClient(cc grpc.ClientConnInterface) EnvironmentsClient

+ type EnvironmentsServer interface

+ CreateEnvironment func(context.Context, *CreateEnvironmentRequest) (*longrunning.Operation, error)

+ DeleteEnvironment func(context.Context, *DeleteEnvironmentRequest) (*longrunning.Operation, error)

+ GetEnvironment func(context.Context, *GetEnvironmentRequest) (*Environment, error)

+ ListEnvironments func(context.Context, *ListEnvironmentsRequest) (*ListEnvironmentsResponse, error)

+ UpdateEnvironment func(context.Context, *UpdateEnvironmentRequest) (*longrunning.Operation, error)

+ type GetEnvironmentRequest struct

+ Name string

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

+ func (*GetEnvironmentRequest) ProtoMessage()

+ func (x *GetEnvironmentRequest) GetName() string

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

+ func (x *GetEnvironmentRequest) Reset()

+ func (x *GetEnvironmentRequest) String() string

+ type IPAllocationPolicy struct

+ ClusterIpAllocation isIPAllocationPolicy_ClusterIpAllocation

+ ServicesIpAllocation isIPAllocationPolicy_ServicesIpAllocation

+ UseIpAliases bool

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

+ func (*IPAllocationPolicy) ProtoMessage()

+ func (m *IPAllocationPolicy) GetClusterIpAllocation() isIPAllocationPolicy_ClusterIpAllocation

+ func (m *IPAllocationPolicy) GetServicesIpAllocation() isIPAllocationPolicy_ServicesIpAllocation

+ func (x *IPAllocationPolicy) GetClusterIpv4CidrBlock() string

+ func (x *IPAllocationPolicy) GetClusterSecondaryRangeName() string

+ func (x *IPAllocationPolicy) GetServicesIpv4CidrBlock() string

+ func (x *IPAllocationPolicy) GetServicesSecondaryRangeName() string

+ func (x *IPAllocationPolicy) GetUseIpAliases() bool

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

+ func (x *IPAllocationPolicy) Reset()

+ func (x *IPAllocationPolicy) String() string

+ type IPAllocationPolicy_ClusterIpv4CidrBlock struct

+ ClusterIpv4CidrBlock string

+ type IPAllocationPolicy_ClusterSecondaryRangeName struct

+ ClusterSecondaryRangeName string

+ type IPAllocationPolicy_ServicesIpv4CidrBlock struct

+ ServicesIpv4CidrBlock string

+ type IPAllocationPolicy_ServicesSecondaryRangeName struct

+ ServicesSecondaryRangeName string

+ type ImageVersion struct

+ CreationDisabled bool

+ ImageVersionId string

+ IsDefault bool

+ ReleaseDate *date.Date

+ SupportedPythonVersions []string

+ UpgradeDisabled bool

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

+ func (*ImageVersion) ProtoMessage()

+ func (x *ImageVersion) GetCreationDisabled() bool

+ func (x *ImageVersion) GetImageVersionId() string

+ func (x *ImageVersion) GetIsDefault() bool

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

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

+ func (x *ImageVersion) GetUpgradeDisabled() bool

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

+ func (x *ImageVersion) Reset()

+ func (x *ImageVersion) String() string

+ type ImageVersionsClient interface

+ ListImageVersions func(ctx context.Context, in *ListImageVersionsRequest, opts ...grpc.CallOption) (*ListImageVersionsResponse, error)

+ func NewImageVersionsClient(cc grpc.ClientConnInterface) ImageVersionsClient

+ type ImageVersionsServer interface

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

+ type ListEnvironmentsRequest struct

+ PageSize int32

+ PageToken string

+ Parent string

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

+ func (*ListEnvironmentsRequest) ProtoMessage()

+ func (x *ListEnvironmentsRequest) GetPageSize() int32

+ func (x *ListEnvironmentsRequest) GetPageToken() string

+ func (x *ListEnvironmentsRequest) GetParent() string

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

+ func (x *ListEnvironmentsRequest) Reset()

+ func (x *ListEnvironmentsRequest) String() string

+ type ListEnvironmentsResponse struct

+ Environments []*Environment

+ NextPageToken string

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

+ func (*ListEnvironmentsResponse) ProtoMessage()

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

+ func (x *ListEnvironmentsResponse) GetNextPageToken() string

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

+ func (x *ListEnvironmentsResponse) Reset()

+ func (x *ListEnvironmentsResponse) String() string

+ type ListImageVersionsRequest struct

+ IncludePastReleases bool

+ PageSize int32

+ PageToken string

+ Parent string

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

+ func (*ListImageVersionsRequest) ProtoMessage()

+ func (x *ListImageVersionsRequest) GetIncludePastReleases() bool

+ func (x *ListImageVersionsRequest) GetPageSize() int32

+ func (x *ListImageVersionsRequest) GetPageToken() string

+ func (x *ListImageVersionsRequest) GetParent() string

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

+ func (x *ListImageVersionsRequest) Reset()

+ func (x *ListImageVersionsRequest) String() string

+ type ListImageVersionsResponse struct

+ ImageVersions []*ImageVersion

+ NextPageToken string

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

+ func (*ListImageVersionsResponse) ProtoMessage()

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

+ func (x *ListImageVersionsResponse) GetNextPageToken() string

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

+ func (x *ListImageVersionsResponse) Reset()

+ func (x *ListImageVersionsResponse) String() string

+ type NodeConfig struct

+ DiskSizeGb int32

+ IpAllocationPolicy *IPAllocationPolicy

+ Location string

+ MachineType string

+ Network string

+ OauthScopes []string

+ ServiceAccount string

+ Subnetwork string

+ Tags []string

+ func (*NodeConfig) Descriptor() ([]byte, []int)

+ func (*NodeConfig) ProtoMessage()

+ func (x *NodeConfig) GetDiskSizeGb() int32

+ func (x *NodeConfig) GetIpAllocationPolicy() *IPAllocationPolicy

+ func (x *NodeConfig) GetLocation() string

+ func (x *NodeConfig) GetMachineType() string

+ func (x *NodeConfig) GetNetwork() string

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

+ func (x *NodeConfig) GetServiceAccount() string

+ func (x *NodeConfig) GetSubnetwork() string

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

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

+ func (x *NodeConfig) Reset()

+ func (x *NodeConfig) String() string

+ type OperationMetadata struct

+ CreateTime *timestamp.Timestamp

+ EndTime *timestamp.Timestamp

+ OperationType OperationMetadata_Type

+ Resource string

+ ResourceUuid string

+ State OperationMetadata_State

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

+ func (*OperationMetadata) ProtoMessage()

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

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

+ func (x *OperationMetadata) GetOperationType() OperationMetadata_Type

+ func (x *OperationMetadata) GetResource() string

+ func (x *OperationMetadata) GetResourceUuid() string

+ func (x *OperationMetadata) GetState() OperationMetadata_State

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

+ func (x *OperationMetadata) Reset()

+ func (x *OperationMetadata) String() string

+ type OperationMetadata_State int32

+ const OperationMetadata_FAILED

+ const OperationMetadata_PENDING

+ const OperationMetadata_RUNNING

+ const OperationMetadata_STATE_UNSPECIFIED

+ const OperationMetadata_SUCCEEDED

+ const OperationMetadata_SUCCESSFUL

+ func (OperationMetadata_State) Descriptor() protoreflect.EnumDescriptor

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

+ func (OperationMetadata_State) Type() protoreflect.EnumType

+ func (x OperationMetadata_State) Enum() *OperationMetadata_State

+ func (x OperationMetadata_State) Number() protoreflect.EnumNumber

+ func (x OperationMetadata_State) String() string

+ type OperationMetadata_Type int32

+ const OperationMetadata_CHECK

+ const OperationMetadata_CREATE

+ const OperationMetadata_DELETE

+ const OperationMetadata_TYPE_UNSPECIFIED

+ const OperationMetadata_UPDATE

+ func (OperationMetadata_Type) Descriptor() protoreflect.EnumDescriptor

+ func (OperationMetadata_Type) EnumDescriptor() ([]byte, []int)

+ func (OperationMetadata_Type) Type() protoreflect.EnumType

+ func (x OperationMetadata_Type) Enum() *OperationMetadata_Type

+ func (x OperationMetadata_Type) Number() protoreflect.EnumNumber

+ func (x OperationMetadata_Type) String() string

+ type PrivateClusterConfig struct

+ EnablePrivateEndpoint bool

+ MasterIpv4CidrBlock string

+ MasterIpv4ReservedRange string

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

+ func (*PrivateClusterConfig) ProtoMessage()

+ func (x *PrivateClusterConfig) GetEnablePrivateEndpoint() bool

+ func (x *PrivateClusterConfig) GetMasterIpv4CidrBlock() string

+ func (x *PrivateClusterConfig) GetMasterIpv4ReservedRange() string

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

+ func (x *PrivateClusterConfig) Reset()

+ func (x *PrivateClusterConfig) String() string

+ type PrivateEnvironmentConfig struct

+ CloudSqlIpv4CidrBlock string

+ EnablePrivateEnvironment bool

+ PrivateClusterConfig *PrivateClusterConfig

+ WebServerIpv4CidrBlock string

+ WebServerIpv4ReservedRange string

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

+ func (*PrivateEnvironmentConfig) ProtoMessage()

+ func (x *PrivateEnvironmentConfig) GetCloudSqlIpv4CidrBlock() string

+ func (x *PrivateEnvironmentConfig) GetEnablePrivateEnvironment() bool

+ func (x *PrivateEnvironmentConfig) GetPrivateClusterConfig() *PrivateClusterConfig

+ func (x *PrivateEnvironmentConfig) GetWebServerIpv4CidrBlock() string

+ func (x *PrivateEnvironmentConfig) GetWebServerIpv4ReservedRange() string

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

+ func (x *PrivateEnvironmentConfig) Reset()

+ func (x *PrivateEnvironmentConfig) String() string

+ type SoftwareConfig struct

+ AirflowConfigOverrides map[string]string

+ EnvVariables map[string]string

+ ImageVersion string

+ PypiPackages map[string]string

+ PythonVersion string

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

+ func (*SoftwareConfig) ProtoMessage()

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

+ func (x *SoftwareConfig) GetEnvVariables() map[string]string

+ func (x *SoftwareConfig) GetImageVersion() string

+ func (x *SoftwareConfig) GetPypiPackages() map[string]string

+ func (x *SoftwareConfig) GetPythonVersion() string

+ func (x *SoftwareConfig) ProtoReflect() protoreflect.Message

+ func (x *SoftwareConfig) Reset()

+ func (x *SoftwareConfig) String() string

+ type UnimplementedEnvironmentsServer struct

+ func (*UnimplementedEnvironmentsServer) CreateEnvironment(context.Context, *CreateEnvironmentRequest) (*longrunning.Operation, error)

+ func (*UnimplementedEnvironmentsServer) DeleteEnvironment(context.Context, *DeleteEnvironmentRequest) (*longrunning.Operation, error)

+ func (*UnimplementedEnvironmentsServer) GetEnvironment(context.Context, *GetEnvironmentRequest) (*Environment, error)

+ func (*UnimplementedEnvironmentsServer) ListEnvironments(context.Context, *ListEnvironmentsRequest) (*ListEnvironmentsResponse, error)

+ func (*UnimplementedEnvironmentsServer) UpdateEnvironment(context.Context, *UpdateEnvironmentRequest) (*longrunning.Operation, error)

+ type UnimplementedImageVersionsServer struct

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

+ type UpdateEnvironmentRequest struct

+ Environment *Environment

+ Name string

+ UpdateMask *field_mask.FieldMask

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

+ func (*UpdateEnvironmentRequest) ProtoMessage()

+ func (x *UpdateEnvironmentRequest) GetEnvironment() *Environment

+ func (x *UpdateEnvironmentRequest) GetName() string

+ func (x *UpdateEnvironmentRequest) GetUpdateMask() *field_mask.FieldMask

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

+ func (x *UpdateEnvironmentRequest) Reset()

+ func (x *UpdateEnvironmentRequest) String() string

+ type WebServerConfig struct

+ MachineType string

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

+ func (*WebServerConfig) ProtoMessage()

+ func (x *WebServerConfig) GetMachineType() string

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

+ func (x *WebServerConfig) Reset()

+ func (x *WebServerConfig) String() string

+ type WebServerNetworkAccessControl struct

+ AllowedIpRanges []*WebServerNetworkAccessControl_AllowedIpRange

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

+ func (*WebServerNetworkAccessControl) ProtoMessage()

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

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

+ func (x *WebServerNetworkAccessControl) Reset()

+ func (x *WebServerNetworkAccessControl) String() string

+ type WebServerNetworkAccessControl_AllowedIpRange struct

+ Description string

+ Value string

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

+ func (*WebServerNetworkAccessControl_AllowedIpRange) ProtoMessage()

+ func (x *WebServerNetworkAccessControl_AllowedIpRange) GetDescription() string

+ func (x *WebServerNetworkAccessControl_AllowedIpRange) GetValue() string

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

+ func (x *WebServerNetworkAccessControl_AllowedIpRange) Reset()

+ func (x *WebServerNetworkAccessControl_AllowedIpRange) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL