servicepb

package

Go to main page

Versions in this module

v1

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