Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterBackupServiceServer(s grpc.ServiceRegistrar, srv BackupServiceServer)
- func RegisterClusterServiceServer(s grpc.ServiceRegistrar, srv ClusterServiceServer)
- func RegisterOperationServiceServer(s grpc.ServiceRegistrar, srv OperationServiceServer)
- func RegisterVersionServiceServer(s grpc.ServiceRegistrar, srv VersionServiceServer)
- type Backup
- func (*Backup) Descriptor() ([]byte, []int)deprecated
- func (x *Backup) GetCreateTime() *timestamppb.Timestamp
- func (x *Backup) GetId() string
- func (x *Backup) GetName() string
- func (x *Backup) GetProjectId() string
- func (x *Backup) GetSize() int64
- func (x *Backup) GetSourceClusterId() string
- func (x *Backup) GetStartTime() *timestamppb.Timestamp
- func (x *Backup) GetType() Backup_Type
- func (*Backup) ProtoMessage()
- func (x *Backup) ProtoReflect() protoreflect.Message
- func (x *Backup) Reset()
- func (x *Backup) String() string
- type BackupServiceClient
- type BackupServiceServer
- type Backup_Type
- func (Backup_Type) Descriptor() protoreflect.EnumDescriptor
- func (x Backup_Type) Enum() *Backup_Type
- func (Backup_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x Backup_Type) Number() protoreflect.EnumNumber
- func (x Backup_Type) String() string
- func (Backup_Type) Type() protoreflect.EnumType
- type ClickhouseConfig
- func (*ClickhouseConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ClickhouseConfig) GetAsynchronousInsertLogEnabled() *wrapperspb.BoolValue
- func (x *ClickhouseConfig) GetAsynchronousInsertLogRetentionSize() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetAsynchronousInsertLogRetentionTime() *durationpb.Duration
- func (x *ClickhouseConfig) GetAsynchronousMetricLogEnabled() *wrapperspb.BoolValue
- func (x *ClickhouseConfig) GetAsynchronousMetricLogRetentionSize() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetAsynchronousMetricLogRetentionTime() *durationpb.Duration
- func (x *ClickhouseConfig) GetBackgroundCommonPoolSize() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetBackgroundFetchesPoolSize() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetBackgroundMergesMutationsConcurrencyRatio() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetBackgroundMessageBrokerSchedulePoolSize() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetBackgroundMovePoolSize() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetBackgroundPoolSize() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetBackgroundSchedulePoolSize() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetCompression() []*ClickhouseConfig_Compression
- func (x *ClickhouseConfig) GetGraphiteRollup() map[string]*ClickhouseConfig_GraphiteRollup
- func (x *ClickhouseConfig) GetHybridStorage() *ClickhouseConfig_HybridStorage
- func (x *ClickhouseConfig) GetKafka() *ClickhouseConfig_Kafka
- func (x *ClickhouseConfig) GetKafkaTopics() map[string]*ClickhouseConfig_Kafka
- func (x *ClickhouseConfig) GetKeepAliveTimeout() *durationpb.Duration
- func (x *ClickhouseConfig) GetLogLevel() ClickhouseConfig_LogLevel
- func (x *ClickhouseConfig) GetMarkCacheSize() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetMaxConcurrentQueries() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetMaxConnections() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetMaxPartitionSizeToDrop() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetMaxTableSizeToDrop() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetMergeTree() *ClickhouseConfig_MergeTree
- func (x *ClickhouseConfig) GetMetricLogEnabled() *wrapperspb.BoolValue
- func (x *ClickhouseConfig) GetMetricLogRetentionSize() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetMetricLogRetentionTime() *durationpb.Duration
- func (x *ClickhouseConfig) GetOpentelemetrySpanLogEnabled() *wrapperspb.BoolValue
- func (x *ClickhouseConfig) GetOpentelemetrySpanLogRetentionSize() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetOpentelemetrySpanLogRetentionTime() *durationpb.Duration
- func (x *ClickhouseConfig) GetPartLogRetentionSize() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetPartLogRetentionTime() *durationpb.Duration
- func (x *ClickhouseConfig) GetQueryLogRetentionSize() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetQueryLogRetentionTime() *durationpb.Duration
- func (x *ClickhouseConfig) GetQueryThreadLogEnabled() *wrapperspb.BoolValue
- func (x *ClickhouseConfig) GetQueryThreadLogRetentionSize() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetQueryThreadLogRetentionTime() *durationpb.Duration
- func (x *ClickhouseConfig) GetQueryViewsLogEnabled() *wrapperspb.BoolValue
- func (x *ClickhouseConfig) GetQueryViewsLogRetentionSize() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetQueryViewsLogRetentionTime() *durationpb.Duration
- func (x *ClickhouseConfig) GetRabbitmq() *ClickhouseConfig_Rabbitmq
- func (x *ClickhouseConfig) GetSessionLogEnabled() *wrapperspb.BoolValue
- func (x *ClickhouseConfig) GetSessionLogRetentionSize() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetSessionLogRetentionTime() *durationpb.Duration
- func (x *ClickhouseConfig) GetTextLogEnabled() *wrapperspb.BoolValue
- func (x *ClickhouseConfig) GetTextLogLevel() ClickhouseConfig_LogLevel
- func (x *ClickhouseConfig) GetTextLogRetentionSize() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetTextLogRetentionTime() *durationpb.Duration
- func (x *ClickhouseConfig) GetTimezone() *wrapperspb.StringValue
- func (x *ClickhouseConfig) GetTotalMemoryProfilerStep() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetTotalMemoryTrackerSampleProbability() *wrapperspb.DoubleValue
- func (x *ClickhouseConfig) GetTraceLogEnabled() *wrapperspb.BoolValue
- func (x *ClickhouseConfig) GetTraceLogRetentionSize() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetTraceLogRetentionTime() *durationpb.Duration
- func (x *ClickhouseConfig) GetUncompressedCacheSize() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetZookeeperLogEnabled() *wrapperspb.BoolValue
- func (x *ClickhouseConfig) GetZookeeperLogRetentionSize() *wrapperspb.Int64Value
- func (x *ClickhouseConfig) GetZookeeperLogRetentionTime() *durationpb.Duration
- func (*ClickhouseConfig) ProtoMessage()
- func (x *ClickhouseConfig) ProtoReflect() protoreflect.Message
- func (x *ClickhouseConfig) Reset()
- func (x *ClickhouseConfig) String() string
- type ClickhouseConfig_Compression
- func (*ClickhouseConfig_Compression) Descriptor() ([]byte, []int)deprecated
- func (x *ClickhouseConfig_Compression) GetLevel() *wrapperspb.Int64Value
- func (x *ClickhouseConfig_Compression) GetMethod() ClickhouseConfig_Compression_Method
- func (x *ClickhouseConfig_Compression) GetMinPartSize() int64
- func (x *ClickhouseConfig_Compression) GetMinPartSizeRatio() float64
- func (*ClickhouseConfig_Compression) ProtoMessage()
- func (x *ClickhouseConfig_Compression) ProtoReflect() protoreflect.Message
- func (x *ClickhouseConfig_Compression) Reset()
- func (x *ClickhouseConfig_Compression) String() string
- type ClickhouseConfig_Compression_Method
- func (ClickhouseConfig_Compression_Method) Descriptor() protoreflect.EnumDescriptor
- func (x ClickhouseConfig_Compression_Method) Enum() *ClickhouseConfig_Compression_Method
- func (ClickhouseConfig_Compression_Method) EnumDescriptor() ([]byte, []int)deprecated
- func (x ClickhouseConfig_Compression_Method) Number() protoreflect.EnumNumber
- func (x ClickhouseConfig_Compression_Method) String() string
- func (ClickhouseConfig_Compression_Method) Type() protoreflect.EnumType
- type ClickhouseConfig_GraphiteRollup
- func (*ClickhouseConfig_GraphiteRollup) Descriptor() ([]byte, []int)deprecated
- func (x *ClickhouseConfig_GraphiteRollup) GetPatterns() []*ClickhouseConfig_GraphiteRollup_Pattern
- func (*ClickhouseConfig_GraphiteRollup) ProtoMessage()
- func (x *ClickhouseConfig_GraphiteRollup) ProtoReflect() protoreflect.Message
- func (x *ClickhouseConfig_GraphiteRollup) Reset()
- func (x *ClickhouseConfig_GraphiteRollup) String() string
- type ClickhouseConfig_GraphiteRollup_Pattern
- func (*ClickhouseConfig_GraphiteRollup_Pattern) Descriptor() ([]byte, []int)deprecated
- func (x *ClickhouseConfig_GraphiteRollup_Pattern) GetFunction() *wrapperspb.StringValue
- func (x *ClickhouseConfig_GraphiteRollup_Pattern) GetRegexp() *wrapperspb.StringValue
- func (x *ClickhouseConfig_GraphiteRollup_Pattern) GetRetention() []*ClickhouseConfig_GraphiteRollup_Pattern_Retention
- func (*ClickhouseConfig_GraphiteRollup_Pattern) ProtoMessage()
- func (x *ClickhouseConfig_GraphiteRollup_Pattern) ProtoReflect() protoreflect.Message
- func (x *ClickhouseConfig_GraphiteRollup_Pattern) Reset()
- func (x *ClickhouseConfig_GraphiteRollup_Pattern) String() string
- type ClickhouseConfig_GraphiteRollup_Pattern_Retention
- func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) Descriptor() ([]byte, []int)deprecated
- func (x *ClickhouseConfig_GraphiteRollup_Pattern_Retention) GetAge() int64
- func (x *ClickhouseConfig_GraphiteRollup_Pattern_Retention) GetPrecision() int64
- func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) ProtoMessage()
- func (x *ClickhouseConfig_GraphiteRollup_Pattern_Retention) ProtoReflect() protoreflect.Message
- func (x *ClickhouseConfig_GraphiteRollup_Pattern_Retention) Reset()
- func (x *ClickhouseConfig_GraphiteRollup_Pattern_Retention) String() string
- type ClickhouseConfig_HybridStorage
- func (*ClickhouseConfig_HybridStorage) Descriptor() ([]byte, []int)deprecated
- func (x *ClickhouseConfig_HybridStorage) GetMaxDataPartSize() *wrapperspb.Int64Value
- func (x *ClickhouseConfig_HybridStorage) GetPreferNotToMerge() *wrapperspb.BoolValue
- func (*ClickhouseConfig_HybridStorage) ProtoMessage()
- func (x *ClickhouseConfig_HybridStorage) ProtoReflect() protoreflect.Message
- func (x *ClickhouseConfig_HybridStorage) Reset()
- func (x *ClickhouseConfig_HybridStorage) String() string
- type ClickhouseConfig_Kafka
- func (*ClickhouseConfig_Kafka) Descriptor() ([]byte, []int)deprecated
- func (x *ClickhouseConfig_Kafka) GetEnableSslCertificateVerification() *wrapperspb.BoolValue
- func (x *ClickhouseConfig_Kafka) GetMaxPollIntervalMs() *durationpb.Duration
- func (x *ClickhouseConfig_Kafka) GetSaslMechanism() ClickhouseConfig_Kafka_SaslMechanism
- func (x *ClickhouseConfig_Kafka) GetSaslPassword() *wrapperspb.StringValue
- func (x *ClickhouseConfig_Kafka) GetSaslUsername() *wrapperspb.StringValue
- func (x *ClickhouseConfig_Kafka) GetSecurityProtocol() ClickhouseConfig_Kafka_SecurityProtocol
- func (x *ClickhouseConfig_Kafka) GetSessionTimeoutMs() *durationpb.Duration
- func (*ClickhouseConfig_Kafka) ProtoMessage()
- func (x *ClickhouseConfig_Kafka) ProtoReflect() protoreflect.Message
- func (x *ClickhouseConfig_Kafka) Reset()
- func (x *ClickhouseConfig_Kafka) String() string
- type ClickhouseConfig_Kafka_SaslMechanism
- func (ClickhouseConfig_Kafka_SaslMechanism) Descriptor() protoreflect.EnumDescriptor
- func (x ClickhouseConfig_Kafka_SaslMechanism) Enum() *ClickhouseConfig_Kafka_SaslMechanism
- func (ClickhouseConfig_Kafka_SaslMechanism) EnumDescriptor() ([]byte, []int)deprecated
- func (x ClickhouseConfig_Kafka_SaslMechanism) Number() protoreflect.EnumNumber
- func (x ClickhouseConfig_Kafka_SaslMechanism) String() string
- func (ClickhouseConfig_Kafka_SaslMechanism) Type() protoreflect.EnumType
- type ClickhouseConfig_Kafka_SecurityProtocol
- func (ClickhouseConfig_Kafka_SecurityProtocol) Descriptor() protoreflect.EnumDescriptor
- func (x ClickhouseConfig_Kafka_SecurityProtocol) Enum() *ClickhouseConfig_Kafka_SecurityProtocol
- func (ClickhouseConfig_Kafka_SecurityProtocol) EnumDescriptor() ([]byte, []int)deprecated
- func (x ClickhouseConfig_Kafka_SecurityProtocol) Number() protoreflect.EnumNumber
- func (x ClickhouseConfig_Kafka_SecurityProtocol) String() string
- func (ClickhouseConfig_Kafka_SecurityProtocol) Type() protoreflect.EnumType
- type ClickhouseConfig_LogLevel
- func (ClickhouseConfig_LogLevel) Descriptor() protoreflect.EnumDescriptor
- func (x ClickhouseConfig_LogLevel) Enum() *ClickhouseConfig_LogLevel
- func (ClickhouseConfig_LogLevel) EnumDescriptor() ([]byte, []int)deprecated
- func (x ClickhouseConfig_LogLevel) Number() protoreflect.EnumNumber
- func (x ClickhouseConfig_LogLevel) String() string
- func (ClickhouseConfig_LogLevel) Type() protoreflect.EnumType
- type ClickhouseConfig_MergeTree
- func (*ClickhouseConfig_MergeTree) Descriptor() ([]byte, []int)deprecated
- func (x *ClickhouseConfig_MergeTree) GetAllowRemoteFsZeroCopyReplication() *wrapperspb.BoolValue
- func (x *ClickhouseConfig_MergeTree) GetCleanupDelayPeriod() *durationpb.Duration
- func (x *ClickhouseConfig_MergeTree) GetInactivePartsToDelayInsert() *wrapperspb.Int64Value
- func (x *ClickhouseConfig_MergeTree) GetInactivePartsToThrowInsert() *wrapperspb.Int64Value
- func (x *ClickhouseConfig_MergeTree) GetMaxAvgPartSizeForTooManyParts() *wrapperspb.Int64Value
- func (x *ClickhouseConfig_MergeTree) GetMaxBytesToMergeAtMaxSpaceInPool() *wrapperspb.Int64Value
- func (x *ClickhouseConfig_MergeTree) GetMaxBytesToMergeAtMinSpaceInPool() *wrapperspb.Int64Value
- func (x *ClickhouseConfig_MergeTree) GetMaxNumberOfMergesWithTtlInPool() *wrapperspb.Int64Value
- func (x *ClickhouseConfig_MergeTree) GetMaxPartsInTotal() *wrapperspb.Int64Value
- func (x *ClickhouseConfig_MergeTree) GetMaxReplicatedMergesInQueue() *wrapperspb.Int64Value
- func (x *ClickhouseConfig_MergeTree) GetMergeSelectingSleepMs() *durationpb.Duration
- func (x *ClickhouseConfig_MergeTree) GetMergeWithRecompressionTtlTimeout() *durationpb.Duration
- func (x *ClickhouseConfig_MergeTree) GetMergeWithTtlTimeout() *durationpb.Duration
- func (x *ClickhouseConfig_MergeTree) GetMinAgeToForceMergeOnPartitionOnly() *wrapperspb.BoolValue
- func (x *ClickhouseConfig_MergeTree) GetMinAgeToForceMergeSeconds() *durationpb.Duration
- func (x *ClickhouseConfig_MergeTree) GetMinBytesForWidePart() *wrapperspb.Int64Value
- func (x *ClickhouseConfig_MergeTree) GetMinRowsForWidePart() *wrapperspb.Int64Value
- func (x *ClickhouseConfig_MergeTree) GetNumberOfFreeEntriesInPoolToExecuteMutation() *wrapperspb.Int64Value
- func (x *ClickhouseConfig_MergeTree) GetNumberOfFreeEntriesInPoolToLowerMaxSizeOfMerge() *wrapperspb.Int64Value
- func (x *ClickhouseConfig_MergeTree) GetPartsToDelayInsert() *wrapperspb.Int64Value
- func (x *ClickhouseConfig_MergeTree) GetPartsToThrowInsert() *wrapperspb.Int64Value
- func (x *ClickhouseConfig_MergeTree) GetReplicatedDeduplicationWindow() *wrapperspb.Int64Value
- func (x *ClickhouseConfig_MergeTree) GetReplicatedDeduplicationWindowSeconds() *durationpb.Duration
- func (x *ClickhouseConfig_MergeTree) GetTtlOnlyDropParts() *wrapperspb.BoolValue
- func (*ClickhouseConfig_MergeTree) ProtoMessage()
- func (x *ClickhouseConfig_MergeTree) ProtoReflect() protoreflect.Message
- func (x *ClickhouseConfig_MergeTree) Reset()
- func (x *ClickhouseConfig_MergeTree) String() string
- type ClickhouseConfig_Rabbitmq
- func (*ClickhouseConfig_Rabbitmq) Descriptor() ([]byte, []int)deprecated
- func (x *ClickhouseConfig_Rabbitmq) GetPassword() *wrapperspb.StringValue
- func (x *ClickhouseConfig_Rabbitmq) GetUsername() *wrapperspb.StringValue
- func (x *ClickhouseConfig_Rabbitmq) GetVhost() *wrapperspb.StringValue
- func (*ClickhouseConfig_Rabbitmq) ProtoMessage()
- func (x *ClickhouseConfig_Rabbitmq) ProtoReflect() protoreflect.Message
- func (x *ClickhouseConfig_Rabbitmq) Reset()
- func (x *ClickhouseConfig_Rabbitmq) String() string
- type Cluster
- func (*Cluster) Descriptor() ([]byte, []int)deprecated
- func (x *Cluster) GetAccess() *v1.Access
- func (x *Cluster) GetClickhouseConfig() *ClickhouseConfig
- func (x *Cluster) GetCloudType() string
- func (x *Cluster) GetConnectionInfo() *ConnectionInfo
- func (x *Cluster) GetCreateTime() *timestamppb.Timestamp
- func (x *Cluster) GetDescription() string
- func (x *Cluster) GetEncryption() *v1.DataEncryption
- func (x *Cluster) GetId() string
- func (x *Cluster) GetMaintenanceOperation() *v1.MaintenanceOperation
- func (x *Cluster) GetMaintenanceWindow() *v1.MaintenanceWindow
- func (x *Cluster) GetMetricsExporterConnectionInfo() *MetricsExporterConnectionInfo
- func (x *Cluster) GetName() string
- func (x *Cluster) GetNetworkId() string
- func (x *Cluster) GetPrivateConnectionInfo() *PrivateConnectionInfo
- func (x *Cluster) GetProjectId() string
- func (x *Cluster) GetRegionId() string
- func (x *Cluster) GetResources() *ClusterResources
- func (x *Cluster) GetStatus() v1.ClusterStatus
- func (x *Cluster) GetVersion() string
- func (*Cluster) ProtoMessage()
- func (x *Cluster) ProtoReflect() protoreflect.Message
- func (x *Cluster) Reset()
- func (x *Cluster) String() string
- type ClusterResources
- func (*ClusterResources) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterResources) GetClickhouse() *ClusterResources_Clickhouse
- func (x *ClusterResources) GetDedicatedKeeper() *ClusterResources_Keeper
- func (*ClusterResources) ProtoMessage()
- func (x *ClusterResources) ProtoReflect() protoreflect.Message
- func (x *ClusterResources) Reset()
- func (x *ClusterResources) String() string
- type ClusterResources_Clickhouse
- func (*ClusterResources_Clickhouse) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterResources_Clickhouse) GetDiskSize() *wrapperspb.Int64Value
- func (x *ClusterResources_Clickhouse) GetMaxDiskSize() *wrapperspb.Int64Value
- func (x *ClusterResources_Clickhouse) GetMaxResourcePresetId() *wrapperspb.StringValue
- func (x *ClusterResources_Clickhouse) GetMinResourcePresetId() *wrapperspb.StringValue
- func (x *ClusterResources_Clickhouse) GetReplicaCount() *wrapperspb.Int64Value
- func (x *ClusterResources_Clickhouse) GetResourcePresetId() string
- func (x *ClusterResources_Clickhouse) GetShardCount() *wrapperspb.Int64Value
- func (*ClusterResources_Clickhouse) ProtoMessage()
- func (x *ClusterResources_Clickhouse) ProtoReflect() protoreflect.Message
- func (x *ClusterResources_Clickhouse) Reset()
- func (x *ClusterResources_Clickhouse) String() string
- type ClusterResources_Keeper
- func (*ClusterResources_Keeper) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterResources_Keeper) GetDiskSize() *wrapperspb.Int64Value
- func (x *ClusterResources_Keeper) GetMaxDiskSize() *wrapperspb.Int64Value
- func (x *ClusterResources_Keeper) GetMaxResourcePresetId() *wrapperspb.StringValue
- func (x *ClusterResources_Keeper) GetMinResourcePresetId() *wrapperspb.StringValue
- func (x *ClusterResources_Keeper) GetReplicaCount() *wrapperspb.Int64Value
- func (x *ClusterResources_Keeper) GetResourcePresetId() string
- func (*ClusterResources_Keeper) ProtoMessage()
- func (x *ClusterResources_Keeper) ProtoReflect() protoreflect.Message
- func (x *ClusterResources_Keeper) Reset()
- func (x *ClusterResources_Keeper) String() string
- type ClusterServiceClient
- type ClusterServiceServer
- type ClusterView
- func (ClusterView) Descriptor() protoreflect.EnumDescriptor
- func (x ClusterView) Enum() *ClusterView
- func (ClusterView) EnumDescriptor() ([]byte, []int)deprecated
- func (x ClusterView) Number() protoreflect.EnumNumber
- func (x ClusterView) String() string
- func (ClusterView) Type() protoreflect.EnumType
- type ConnectionInfo
- func (*ConnectionInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectionInfo) GetHost() string
- func (x *ConnectionInfo) GetHttpsPort() *wrapperspb.Int64Value
- func (x *ConnectionInfo) GetHttpsUri() string
- func (x *ConnectionInfo) GetJdbcUri() string
- func (x *ConnectionInfo) GetNativeProtocol() string
- func (x *ConnectionInfo) GetOdbcUri() string
- func (x *ConnectionInfo) GetPassword() string
- func (x *ConnectionInfo) GetTcpPortSecure() *wrapperspb.Int64Value
- func (x *ConnectionInfo) GetUser() string
- func (*ConnectionInfo) ProtoMessage()
- func (x *ConnectionInfo) ProtoReflect() protoreflect.Message
- func (x *ConnectionInfo) Reset()
- func (x *ConnectionInfo) String() string
- type CreateBackupRequest
- func (*CreateBackupRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateBackupRequest) GetClusterId() string
- func (x *CreateBackupRequest) GetName() string
- func (*CreateBackupRequest) ProtoMessage()
- func (x *CreateBackupRequest) ProtoReflect() protoreflect.Message
- func (x *CreateBackupRequest) Reset()
- func (x *CreateBackupRequest) String() string
- type CreateClusterRequest
- func (*CreateClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateClusterRequest) GetAccess() *v1.Access
- func (x *CreateClusterRequest) GetClickhouseConfig() *ClickhouseConfig
- func (x *CreateClusterRequest) GetCloudType() string
- func (x *CreateClusterRequest) GetDescription() string
- func (x *CreateClusterRequest) GetEncryption() *v1.DataEncryption
- func (x *CreateClusterRequest) GetMaintenanceWindow() *v1.MaintenanceWindow
- func (x *CreateClusterRequest) GetName() string
- func (x *CreateClusterRequest) GetNetworkId() string
- func (x *CreateClusterRequest) GetProjectId() string
- func (x *CreateClusterRequest) GetRegionId() string
- func (x *CreateClusterRequest) GetResources() *ClusterResources
- func (x *CreateClusterRequest) GetVersion() string
- func (*CreateClusterRequest) ProtoMessage()
- func (x *CreateClusterRequest) ProtoReflect() protoreflect.Message
- func (x *CreateClusterRequest) Reset()
- func (x *CreateClusterRequest) String() string
- type DeleteBackupRequest
- func (*DeleteBackupRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteBackupRequest) GetBackupId() string
- func (*DeleteBackupRequest) ProtoMessage()
- func (x *DeleteBackupRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteBackupRequest) Reset()
- func (x *DeleteBackupRequest) String() string
- type DeleteClusterRequest
- func (*DeleteClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteClusterRequest) GetClusterId() string
- func (*DeleteClusterRequest) ProtoMessage()
- func (x *DeleteClusterRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteClusterRequest) Reset()
- func (x *DeleteClusterRequest) String() string
- type GetBackupRequest
- type GetClusterRequest
- func (*GetClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetClusterRequest) GetClusterId() string
- func (x *GetClusterRequest) GetSensitive() bool
- func (*GetClusterRequest) ProtoMessage()
- func (x *GetClusterRequest) ProtoReflect() protoreflect.Message
- func (x *GetClusterRequest) Reset()
- func (x *GetClusterRequest) String() string
- type GetOperationRequest
- func (*GetOperationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetOperationRequest) GetOperationId() string
- func (*GetOperationRequest) ProtoMessage()
- func (x *GetOperationRequest) ProtoReflect() protoreflect.Message
- func (x *GetOperationRequest) Reset()
- func (x *GetOperationRequest) String() string
- type Host
- func (*Host) Descriptor() ([]byte, []int)deprecated
- func (x *Host) GetClusterId() string
- func (x *Host) GetName() string
- func (x *Host) GetPrivateName() string
- func (x *Host) GetShardName() string
- func (x *Host) GetStatus() v1.HostStatus
- func (*Host) ProtoMessage()
- func (x *Host) ProtoReflect() protoreflect.Message
- func (x *Host) Reset()
- func (x *Host) String() string
- type ListBackupsRequest
- func (*ListBackupsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListBackupsRequest) GetPaging() *v1.Paging
- func (x *ListBackupsRequest) GetProjectId() string
- func (*ListBackupsRequest) ProtoMessage()
- func (x *ListBackupsRequest) ProtoReflect() protoreflect.Message
- func (x *ListBackupsRequest) Reset()
- func (x *ListBackupsRequest) String() string
- type ListBackupsResponse
- func (*ListBackupsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListBackupsResponse) GetBackups() []*Backup
- func (x *ListBackupsResponse) GetNextPage() *v1.NextPage
- func (*ListBackupsResponse) ProtoMessage()
- func (x *ListBackupsResponse) ProtoReflect() protoreflect.Message
- func (x *ListBackupsResponse) Reset()
- func (x *ListBackupsResponse) String() string
- type ListClusterBackupsRequest
- func (*ListClusterBackupsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListClusterBackupsRequest) GetClusterId() string
- func (x *ListClusterBackupsRequest) GetPaging() *v1.Paging
- func (*ListClusterBackupsRequest) ProtoMessage()
- func (x *ListClusterBackupsRequest) ProtoReflect() protoreflect.Message
- func (x *ListClusterBackupsRequest) Reset()
- func (x *ListClusterBackupsRequest) String() string
- type ListClusterBackupsResponse
- func (*ListClusterBackupsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListClusterBackupsResponse) GetBackups() []*Backup
- func (x *ListClusterBackupsResponse) GetNextPage() *v1.NextPage
- func (*ListClusterBackupsResponse) ProtoMessage()
- func (x *ListClusterBackupsResponse) ProtoReflect() protoreflect.Message
- func (x *ListClusterBackupsResponse) Reset()
- func (x *ListClusterBackupsResponse) String() string
- type ListClusterHostsRequest
- func (*ListClusterHostsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListClusterHostsRequest) GetClusterId() string
- func (x *ListClusterHostsRequest) GetPaging() *v1.Paging
- func (*ListClusterHostsRequest) ProtoMessage()
- func (x *ListClusterHostsRequest) ProtoReflect() protoreflect.Message
- func (x *ListClusterHostsRequest) Reset()
- func (x *ListClusterHostsRequest) String() string
- type ListClusterHostsResponse
- func (*ListClusterHostsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListClusterHostsResponse) GetHosts() []*Host
- func (x *ListClusterHostsResponse) GetNextPage() *v1.NextPage
- func (*ListClusterHostsResponse) ProtoMessage()
- func (x *ListClusterHostsResponse) ProtoReflect() protoreflect.Message
- func (x *ListClusterHostsResponse) Reset()
- func (x *ListClusterHostsResponse) String() string
- type ListClusterOperationsRequest
- func (*ListClusterOperationsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListClusterOperationsRequest) GetClusterId() string
- func (x *ListClusterOperationsRequest) GetPaging() *v1.Paging
- func (*ListClusterOperationsRequest) ProtoMessage()
- func (x *ListClusterOperationsRequest) ProtoReflect() protoreflect.Message
- func (x *ListClusterOperationsRequest) Reset()
- func (x *ListClusterOperationsRequest) String() string
- type ListClusterOperationsResponse
- func (*ListClusterOperationsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListClusterOperationsResponse) GetNextPage() *v1.NextPage
- func (x *ListClusterOperationsResponse) GetOperations() []*v1.Operation
- func (*ListClusterOperationsResponse) ProtoMessage()
- func (x *ListClusterOperationsResponse) ProtoReflect() protoreflect.Message
- func (x *ListClusterOperationsResponse) Reset()
- func (x *ListClusterOperationsResponse) String() string
- type ListClustersRequest
- func (*ListClustersRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListClustersRequest) GetPaging() *v1.Paging
- func (x *ListClustersRequest) GetProjectId() string
- func (x *ListClustersRequest) GetView() ClusterView
- func (*ListClustersRequest) ProtoMessage()
- func (x *ListClustersRequest) ProtoReflect() protoreflect.Message
- func (x *ListClustersRequest) Reset()
- func (x *ListClustersRequest) String() string
- type ListClustersResponse
- func (*ListClustersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListClustersResponse) GetClusters() []*Cluster
- func (x *ListClustersResponse) GetNextPage() *v1.NextPage
- func (*ListClustersResponse) ProtoMessage()
- func (x *ListClustersResponse) ProtoReflect() protoreflect.Message
- func (x *ListClustersResponse) Reset()
- func (x *ListClustersResponse) String() string
- type ListOperationsRequest
- func (*ListOperationsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListOperationsRequest) GetPaging() *v1.Paging
- func (x *ListOperationsRequest) GetProjectId() string
- func (*ListOperationsRequest) ProtoMessage()
- func (x *ListOperationsRequest) ProtoReflect() protoreflect.Message
- func (x *ListOperationsRequest) Reset()
- func (x *ListOperationsRequest) String() string
- type ListOperationsResponse
- func (*ListOperationsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListOperationsResponse) GetNextPage() *v1.NextPage
- func (x *ListOperationsResponse) GetOperations() []*v1.Operation
- func (*ListOperationsResponse) ProtoMessage()
- func (x *ListOperationsResponse) ProtoReflect() protoreflect.Message
- func (x *ListOperationsResponse) Reset()
- func (x *ListOperationsResponse) String() string
- type ListVersionsRequest
- func (*ListVersionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListVersionsRequest) GetPaging() *v1.Paging
- func (*ListVersionsRequest) ProtoMessage()
- func (x *ListVersionsRequest) ProtoReflect() protoreflect.Message
- func (x *ListVersionsRequest) Reset()
- func (x *ListVersionsRequest) String() string
- type ListVersionsResponse
- func (*ListVersionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListVersionsResponse) GetNextPage() *v1.NextPage
- func (x *ListVersionsResponse) GetVersions() []*Version
- func (*ListVersionsResponse) ProtoMessage()
- func (x *ListVersionsResponse) ProtoReflect() protoreflect.Message
- func (x *ListVersionsResponse) Reset()
- func (x *ListVersionsResponse) String() string
- type MetricsExporterConnectionInfo
- func (*MetricsExporterConnectionInfo) Descriptor() ([]byte, []int)deprecated
- func (x *MetricsExporterConnectionInfo) GetPassword() string
- func (x *MetricsExporterConnectionInfo) GetUser() string
- func (*MetricsExporterConnectionInfo) ProtoMessage()
- func (x *MetricsExporterConnectionInfo) ProtoReflect() protoreflect.Message
- func (x *MetricsExporterConnectionInfo) Reset()
- func (x *MetricsExporterConnectionInfo) String() string
- type OperationServiceClient
- type OperationServiceServer
- type PrivateConnectionInfo
- func (*PrivateConnectionInfo) Descriptor() ([]byte, []int)deprecated
- func (x *PrivateConnectionInfo) GetHost() string
- func (x *PrivateConnectionInfo) GetHttpsPort() *wrapperspb.Int64Value
- func (x *PrivateConnectionInfo) GetHttpsUri() string
- func (x *PrivateConnectionInfo) GetJdbcUri() string
- func (x *PrivateConnectionInfo) GetNativeProtocol() string
- func (x *PrivateConnectionInfo) GetOdbcUri() string
- func (x *PrivateConnectionInfo) GetPassword() string
- func (x *PrivateConnectionInfo) GetTcpPortSecure() *wrapperspb.Int64Value
- func (x *PrivateConnectionInfo) GetUser() string
- func (*PrivateConnectionInfo) ProtoMessage()
- func (x *PrivateConnectionInfo) ProtoReflect() protoreflect.Message
- func (x *PrivateConnectionInfo) Reset()
- func (x *PrivateConnectionInfo) String() string
- type RescheduleMaintenanceRequest
- func (*RescheduleMaintenanceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RescheduleMaintenanceRequest) GetClusterId() string
- func (x *RescheduleMaintenanceRequest) GetDelayedUntilTime() *timestamppb.Timestamp
- func (x *RescheduleMaintenanceRequest) GetRescheduleType() v1.RescheduleType
- func (*RescheduleMaintenanceRequest) ProtoMessage()
- func (x *RescheduleMaintenanceRequest) ProtoReflect() protoreflect.Message
- func (x *RescheduleMaintenanceRequest) Reset()
- func (x *RescheduleMaintenanceRequest) String() string
- type ResetClusterCredentialsRequest
- func (*ResetClusterCredentialsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ResetClusterCredentialsRequest) GetClusterId() string
- func (*ResetClusterCredentialsRequest) ProtoMessage()
- func (x *ResetClusterCredentialsRequest) ProtoReflect() protoreflect.Message
- func (x *ResetClusterCredentialsRequest) Reset()
- func (x *ResetClusterCredentialsRequest) String() string
- type RestoreClusterRequest
- func (*RestoreClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RestoreClusterRequest) GetAccess() *v1.Access
- func (x *RestoreClusterRequest) GetBackupId() string
- func (x *RestoreClusterRequest) GetClickhouseConfig() *ClickhouseConfig
- func (x *RestoreClusterRequest) GetDescription() string
- func (x *RestoreClusterRequest) GetEncryption() *v1.DataEncryption
- func (x *RestoreClusterRequest) GetMaintenanceWindow() *v1.MaintenanceWindow
- func (x *RestoreClusterRequest) GetName() string
- func (x *RestoreClusterRequest) GetNetworkId() string
- func (x *RestoreClusterRequest) GetProjectId() string
- func (x *RestoreClusterRequest) GetRegionId() string
- func (x *RestoreClusterRequest) GetResources() *ClusterResources
- func (x *RestoreClusterRequest) GetVersion() string
- func (*RestoreClusterRequest) ProtoMessage()
- func (x *RestoreClusterRequest) ProtoReflect() protoreflect.Message
- func (x *RestoreClusterRequest) Reset()
- func (x *RestoreClusterRequest) String() string
- type StartClusterRequest
- func (*StartClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartClusterRequest) GetClusterId() string
- func (*StartClusterRequest) ProtoMessage()
- func (x *StartClusterRequest) ProtoReflect() protoreflect.Message
- func (x *StartClusterRequest) Reset()
- func (x *StartClusterRequest) String() string
- type StopClusterRequest
- func (*StopClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StopClusterRequest) GetClusterId() string
- func (*StopClusterRequest) ProtoMessage()
- func (x *StopClusterRequest) ProtoReflect() protoreflect.Message
- func (x *StopClusterRequest) Reset()
- func (x *StopClusterRequest) String() string
- type UnimplementedBackupServiceServer
- func (UnimplementedBackupServiceServer) Create(context.Context, *CreateBackupRequest) (*v1.Operation, error)
- func (UnimplementedBackupServiceServer) Delete(context.Context, *DeleteBackupRequest) (*v1.Operation, error)
- func (UnimplementedBackupServiceServer) Get(context.Context, *GetBackupRequest) (*Backup, error)
- func (UnimplementedBackupServiceServer) List(context.Context, *ListBackupsRequest) (*ListBackupsResponse, error)
- type UnimplementedClusterServiceServer
- func (UnimplementedClusterServiceServer) Create(context.Context, *CreateClusterRequest) (*v1.Operation, error)
- func (UnimplementedClusterServiceServer) Delete(context.Context, *DeleteClusterRequest) (*v1.Operation, error)
- func (UnimplementedClusterServiceServer) Get(context.Context, *GetClusterRequest) (*Cluster, error)
- func (UnimplementedClusterServiceServer) List(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
- func (UnimplementedClusterServiceServer) ListBackups(context.Context, *ListClusterBackupsRequest) (*ListClusterBackupsResponse, error)
- func (UnimplementedClusterServiceServer) ListHosts(context.Context, *ListClusterHostsRequest) (*ListClusterHostsResponse, error)
- func (UnimplementedClusterServiceServer) ListOperations(context.Context, *ListClusterOperationsRequest) (*ListClusterOperationsResponse, error)
- func (UnimplementedClusterServiceServer) RescheduleMaintenance(context.Context, *RescheduleMaintenanceRequest) (*v1.Operation, error)
- func (UnimplementedClusterServiceServer) ResetCredentials(context.Context, *ResetClusterCredentialsRequest) (*v1.Operation, error)
- func (UnimplementedClusterServiceServer) Restore(context.Context, *RestoreClusterRequest) (*v1.Operation, error)
- func (UnimplementedClusterServiceServer) Start(context.Context, *StartClusterRequest) (*v1.Operation, error)
- func (UnimplementedClusterServiceServer) Stop(context.Context, *StopClusterRequest) (*v1.Operation, error)
- func (UnimplementedClusterServiceServer) Update(context.Context, *UpdateClusterRequest) (*v1.Operation, error)
- type UnimplementedOperationServiceServer
- type UnimplementedVersionServiceServer
- type UnsafeBackupServiceServer
- type UnsafeClusterServiceServer
- type UnsafeOperationServiceServer
- type UnsafeVersionServiceServer
- type UpdateClusterRequest
- func (*UpdateClusterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateClusterRequest) GetAccess() *v1.Access
- func (x *UpdateClusterRequest) GetClickhouseConfig() *ClickhouseConfig
- func (x *UpdateClusterRequest) GetClusterId() string
- func (x *UpdateClusterRequest) GetDescription() string
- func (x *UpdateClusterRequest) GetMaintenanceWindow() *v1.MaintenanceWindow
- func (x *UpdateClusterRequest) GetName() string
- func (x *UpdateClusterRequest) GetResources() *ClusterResources
- func (x *UpdateClusterRequest) GetVersion() string
- func (*UpdateClusterRequest) ProtoMessage()
- func (x *UpdateClusterRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateClusterRequest) Reset()
- func (x *UpdateClusterRequest) String() string
- type Version
- func (*Version) Descriptor() ([]byte, []int)deprecated
- func (x *Version) GetDeprecated() bool
- func (x *Version) GetId() string
- func (x *Version) GetName() string
- func (x *Version) GetUpdatableTo() []string
- func (*Version) ProtoMessage()
- func (x *Version) ProtoReflect() protoreflect.Message
- func (x *Version) Reset()
- func (x *Version) String() string
- type VersionServiceClient
- type VersionServiceServer
Constants ¶
const ( BackupService_Get_FullMethodName = "/doublecloud.clickhouse.v1.BackupService/Get" BackupService_List_FullMethodName = "/doublecloud.clickhouse.v1.BackupService/List" BackupService_Create_FullMethodName = "/doublecloud.clickhouse.v1.BackupService/Create" BackupService_Delete_FullMethodName = "/doublecloud.clickhouse.v1.BackupService/Delete" )
const ( ClusterService_Get_FullMethodName = "/doublecloud.clickhouse.v1.ClusterService/Get" ClusterService_List_FullMethodName = "/doublecloud.clickhouse.v1.ClusterService/List" ClusterService_Create_FullMethodName = "/doublecloud.clickhouse.v1.ClusterService/Create" ClusterService_Update_FullMethodName = "/doublecloud.clickhouse.v1.ClusterService/Update" ClusterService_Delete_FullMethodName = "/doublecloud.clickhouse.v1.ClusterService/Delete" ClusterService_ResetCredentials_FullMethodName = "/doublecloud.clickhouse.v1.ClusterService/ResetCredentials" ClusterService_ListHosts_FullMethodName = "/doublecloud.clickhouse.v1.ClusterService/ListHosts" ClusterService_Restore_FullMethodName = "/doublecloud.clickhouse.v1.ClusterService/Restore" ClusterService_ListBackups_FullMethodName = "/doublecloud.clickhouse.v1.ClusterService/ListBackups" ClusterService_Start_FullMethodName = "/doublecloud.clickhouse.v1.ClusterService/Start" ClusterService_Stop_FullMethodName = "/doublecloud.clickhouse.v1.ClusterService/Stop" ClusterService_RescheduleMaintenance_FullMethodName = "/doublecloud.clickhouse.v1.ClusterService/RescheduleMaintenance" ClusterService_ListOperations_FullMethodName = "/doublecloud.clickhouse.v1.ClusterService/ListOperations" )
const ( OperationService_Get_FullMethodName = "/doublecloud.clickhouse.v1.OperationService/Get" OperationService_List_FullMethodName = "/doublecloud.clickhouse.v1.OperationService/List" )
const (
VersionService_List_FullMethodName = "/doublecloud.clickhouse.v1.VersionService/List"
)
Variables ¶
var ( Backup_Type_name = map[int32]string{ 0: "TYPE_INVALID", 1: "TYPE_AUTOMATED", 2: "TYPE_MANUAL", } Backup_Type_value = map[string]int32{ "TYPE_INVALID": 0, "TYPE_AUTOMATED": 1, "TYPE_MANUAL": 2, } )
Enum value maps for Backup_Type.
var ( ClusterView_name = map[int32]string{ 0: "CLUSTER_VIEW_INVALID", 1: "CLUSTER_VIEW_BASIC", 2: "CLUSTER_VIEW_FULL", } ClusterView_value = map[string]int32{ "CLUSTER_VIEW_INVALID": 0, "CLUSTER_VIEW_BASIC": 1, "CLUSTER_VIEW_FULL": 2, } )
Enum value maps for ClusterView.
var ( ClickhouseConfig_LogLevel_name = map[int32]string{ 0: "LOG_LEVEL_DEFAULT", 1: "LOG_LEVEL_TRACE", 2: "LOG_LEVEL_DEBUG", 3: "LOG_LEVEL_INFORMATION", 4: "LOG_LEVEL_WARNING", 5: "LOG_LEVEL_ERROR", } ClickhouseConfig_LogLevel_value = map[string]int32{ "LOG_LEVEL_DEFAULT": 0, "LOG_LEVEL_TRACE": 1, "LOG_LEVEL_DEBUG": 2, "LOG_LEVEL_INFORMATION": 3, "LOG_LEVEL_WARNING": 4, "LOG_LEVEL_ERROR": 5, } )
Enum value maps for ClickhouseConfig_LogLevel.
var ( ClickhouseConfig_Kafka_SecurityProtocol_name = map[int32]string{ 0: "SECURITY_PROTOCOL_INVALID", 1: "SECURITY_PROTOCOL_PLAINTEXT", 2: "SECURITY_PROTOCOL_SSL", 3: "SECURITY_PROTOCOL_SASL_PLAINTEXT", 4: "SECURITY_PROTOCOL_SASL_SSL", } ClickhouseConfig_Kafka_SecurityProtocol_value = map[string]int32{ "SECURITY_PROTOCOL_INVALID": 0, "SECURITY_PROTOCOL_PLAINTEXT": 1, "SECURITY_PROTOCOL_SSL": 2, "SECURITY_PROTOCOL_SASL_PLAINTEXT": 3, "SECURITY_PROTOCOL_SASL_SSL": 4, } )
Enum value maps for ClickhouseConfig_Kafka_SecurityProtocol.
var ( ClickhouseConfig_Kafka_SaslMechanism_name = map[int32]string{ 0: "SASL_MECHANISM_INVALID", 1: "SASL_MECHANISM_GSSAPI", 2: "SASL_MECHANISM_PLAIN", 3: "SASL_MECHANISM_SCRAM_SHA_256", 4: "SASL_MECHANISM_SCRAM_SHA_512", } ClickhouseConfig_Kafka_SaslMechanism_value = map[string]int32{ "SASL_MECHANISM_INVALID": 0, "SASL_MECHANISM_GSSAPI": 1, "SASL_MECHANISM_PLAIN": 2, "SASL_MECHANISM_SCRAM_SHA_256": 3, "SASL_MECHANISM_SCRAM_SHA_512": 4, } )
Enum value maps for ClickhouseConfig_Kafka_SaslMechanism.
var ( ClickhouseConfig_Compression_Method_name = map[int32]string{ 0: "METHOD_INVALID", 1: "METHOD_LZ4", 2: "METHOD_ZSTD", 3: "METHOD_LZ4HC", } ClickhouseConfig_Compression_Method_value = map[string]int32{ "METHOD_INVALID": 0, "METHOD_LZ4": 1, "METHOD_ZSTD": 2, "METHOD_LZ4HC": 3, } )
Enum value maps for ClickhouseConfig_Compression_Method.
var BackupService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "doublecloud.clickhouse.v1.BackupService", HandlerType: (*BackupServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Get", Handler: _BackupService_Get_Handler, }, { MethodName: "List", Handler: _BackupService_List_Handler, }, { MethodName: "Create", Handler: _BackupService_Create_Handler, }, { MethodName: "Delete", Handler: _BackupService_Delete_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "doublecloud/clickhouse/v1/backup_service.proto", }
BackupService_ServiceDesc is the grpc.ServiceDesc for BackupService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ClusterService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "doublecloud.clickhouse.v1.ClusterService", HandlerType: (*ClusterServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Get", Handler: _ClusterService_Get_Handler, }, { MethodName: "List", Handler: _ClusterService_List_Handler, }, { MethodName: "Create", Handler: _ClusterService_Create_Handler, }, { MethodName: "Update", Handler: _ClusterService_Update_Handler, }, { MethodName: "Delete", Handler: _ClusterService_Delete_Handler, }, { MethodName: "ResetCredentials", Handler: _ClusterService_ResetCredentials_Handler, }, { MethodName: "ListHosts", Handler: _ClusterService_ListHosts_Handler, }, { MethodName: "Restore", Handler: _ClusterService_Restore_Handler, }, { MethodName: "ListBackups", Handler: _ClusterService_ListBackups_Handler, }, { MethodName: "Start", Handler: _ClusterService_Start_Handler, }, { MethodName: "Stop", Handler: _ClusterService_Stop_Handler, }, { MethodName: "RescheduleMaintenance", Handler: _ClusterService_RescheduleMaintenance_Handler, }, { MethodName: "ListOperations", Handler: _ClusterService_ListOperations_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "doublecloud/clickhouse/v1/cluster_service.proto", }
ClusterService_ServiceDesc is the grpc.ServiceDesc for ClusterService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_doublecloud_clickhouse_v1_backup_proto protoreflect.FileDescriptor
var File_doublecloud_clickhouse_v1_backup_service_proto protoreflect.FileDescriptor
var File_doublecloud_clickhouse_v1_cluster_proto protoreflect.FileDescriptor
var File_doublecloud_clickhouse_v1_cluster_service_proto protoreflect.FileDescriptor
var File_doublecloud_clickhouse_v1_config_proto protoreflect.FileDescriptor
var File_doublecloud_clickhouse_v1_operation_service_proto protoreflect.FileDescriptor
var File_doublecloud_clickhouse_v1_version_proto protoreflect.FileDescriptor
var File_doublecloud_clickhouse_v1_version_service_proto protoreflect.FileDescriptor
var OperationService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "doublecloud.clickhouse.v1.OperationService", HandlerType: (*OperationServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Get", Handler: _OperationService_Get_Handler, }, { MethodName: "List", Handler: _OperationService_List_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "doublecloud/clickhouse/v1/operation_service.proto", }
OperationService_ServiceDesc is the grpc.ServiceDesc for OperationService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var VersionService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "doublecloud.clickhouse.v1.VersionService", HandlerType: (*VersionServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "List", Handler: _VersionService_List_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "doublecloud/clickhouse/v1/version_service.proto", }
VersionService_ServiceDesc is the grpc.ServiceDesc for VersionService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterBackupServiceServer ¶
func RegisterBackupServiceServer(s grpc.ServiceRegistrar, srv BackupServiceServer)
func RegisterClusterServiceServer ¶
func RegisterClusterServiceServer(s grpc.ServiceRegistrar, srv ClusterServiceServer)
func RegisterOperationServiceServer ¶
func RegisterOperationServiceServer(s grpc.ServiceRegistrar, srv OperationServiceServer)
func RegisterVersionServiceServer ¶
func RegisterVersionServiceServer(s grpc.ServiceRegistrar, srv VersionServiceServer)
Types ¶
type Backup ¶
type Backup struct { // Required. ID of the backup. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // ID of the project that the backup belongs to. ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` // User defined or autogenerated backup name. Contains shard name until we // implement consistent multishard backups. Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` // The time when the backup was created (i.e. when the backup operation completed). CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // The time when the backup operation was started. StartTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` // ID of the associated ClickHouse cluster. SourceClusterId string `protobuf:"bytes,6,opt,name=source_cluster_id,json=sourceClusterId,proto3" json:"source_cluster_id,omitempty"` // Size of backup in bytes Size int64 `protobuf:"varint,7,opt,name=size,proto3" json:"size,omitempty"` // How this backup was created (manual/automatic/etc...) Type Backup_Type `protobuf:"varint,8,opt,name=type,proto3,enum=doublecloud.clickhouse.v1.Backup_Type" json:"type,omitempty"` // contains filtered or unexported fields }
func (*Backup) Descriptor
deprecated
func (*Backup) GetCreateTime ¶
func (x *Backup) GetCreateTime() *timestamppb.Timestamp
func (*Backup) GetProjectId ¶
func (*Backup) GetSourceClusterId ¶
func (*Backup) GetStartTime ¶
func (x *Backup) GetStartTime() *timestamppb.Timestamp
func (*Backup) GetType ¶
func (x *Backup) GetType() Backup_Type
func (*Backup) ProtoMessage ¶
func (*Backup) ProtoMessage()
func (*Backup) ProtoReflect ¶
func (x *Backup) ProtoReflect() protoreflect.Message
type BackupServiceClient ¶
type BackupServiceClient interface { // Returns the specified backup of ClickHouse cluster. Get(ctx context.Context, in *GetBackupRequest, opts ...grpc.CallOption) (*Backup, error) // Returns the list of available backups for the specified ClickHouse cluster. List(ctx context.Context, in *ListBackupsRequest, opts ...grpc.CallOption) (*ListBackupsResponse, error) // Creates new ClickHouse cluster backup. Create(ctx context.Context, in *CreateBackupRequest, opts ...grpc.CallOption) (*v1.Operation, error) // Delete specified ClickHouse cluster backup. Delete(ctx context.Context, in *DeleteBackupRequest, opts ...grpc.CallOption) (*v1.Operation, error) }
BackupServiceClient is the client API for BackupService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewBackupServiceClient ¶
func NewBackupServiceClient(cc grpc.ClientConnInterface) BackupServiceClient
type BackupServiceServer ¶
type BackupServiceServer interface { // Returns the specified backup of ClickHouse cluster. Get(context.Context, *GetBackupRequest) (*Backup, error) // Returns the list of available backups for the specified ClickHouse cluster. List(context.Context, *ListBackupsRequest) (*ListBackupsResponse, error) // Creates new ClickHouse cluster backup. Create(context.Context, *CreateBackupRequest) (*v1.Operation, error) // Delete specified ClickHouse cluster backup. Delete(context.Context, *DeleteBackupRequest) (*v1.Operation, error) // contains filtered or unexported methods }
BackupServiceServer is the server API for BackupService service. All implementations must embed UnimplementedBackupServiceServer for forward compatibility
type Backup_Type ¶
type Backup_Type int32
const ( Backup_TYPE_INVALID Backup_Type = 0 // Backup created by automated daily schedule Backup_TYPE_AUTOMATED Backup_Type = 1 // Backup created by user request Backup_TYPE_MANUAL Backup_Type = 2 )
func (Backup_Type) Descriptor ¶
func (Backup_Type) Descriptor() protoreflect.EnumDescriptor
func (Backup_Type) Enum ¶
func (x Backup_Type) Enum() *Backup_Type
func (Backup_Type) EnumDescriptor
deprecated
func (Backup_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use Backup_Type.Descriptor instead.
func (Backup_Type) Number ¶
func (x Backup_Type) Number() protoreflect.EnumNumber
func (Backup_Type) String ¶
func (x Backup_Type) String() string
func (Backup_Type) Type ¶
func (Backup_Type) Type() protoreflect.EnumType
type ClickhouseConfig ¶
type ClickhouseConfig struct { LogLevel ClickhouseConfig_LogLevel `` /* 143-byte string literal not displayed */ MaxConnections *wrapperspb.Int64Value `protobuf:"bytes,2,opt,name=max_connections,json=maxConnections,proto3" json:"max_connections,omitempty"` MaxConcurrentQueries *wrapperspb.Int64Value `protobuf:"bytes,3,opt,name=max_concurrent_queries,json=maxConcurrentQueries,proto3" json:"max_concurrent_queries,omitempty"` KeepAliveTimeout *durationpb.Duration `protobuf:"bytes,4,opt,name=keep_alive_timeout,json=keepAliveTimeout,proto3" json:"keep_alive_timeout,omitempty"` UncompressedCacheSize *wrapperspb.Int64Value `` /* 126-byte string literal not displayed */ MarkCacheSize *wrapperspb.Int64Value `protobuf:"bytes,6,opt,name=mark_cache_size,json=markCacheSize,proto3" json:"mark_cache_size,omitempty"` MaxTableSizeToDrop *wrapperspb.Int64Value `protobuf:"bytes,7,opt,name=max_table_size_to_drop,json=maxTableSizeToDrop,proto3" json:"max_table_size_to_drop,omitempty"` MaxPartitionSizeToDrop *wrapperspb.Int64Value `` /* 133-byte string literal not displayed */ Timezone *wrapperspb.StringValue `protobuf:"bytes,9,opt,name=timezone,proto3" json:"timezone,omitempty"` BackgroundPoolSize *wrapperspb.Int64Value `protobuf:"bytes,10,opt,name=background_pool_size,json=backgroundPoolSize,proto3" json:"background_pool_size,omitempty"` BackgroundSchedulePoolSize *wrapperspb.Int64Value `` /* 144-byte string literal not displayed */ BackgroundFetchesPoolSize *wrapperspb.Int64Value `` /* 141-byte string literal not displayed */ BackgroundMovePoolSize *wrapperspb.Int64Value `` /* 132-byte string literal not displayed */ BackgroundCommonPoolSize *wrapperspb.Int64Value `` /* 138-byte string literal not displayed */ BackgroundMergesMutationsConcurrencyRatio *wrapperspb.Int64Value `` /* 191-byte string literal not displayed */ TotalMemoryProfilerStep *wrapperspb.Int64Value `` /* 135-byte string literal not displayed */ MergeTree *ClickhouseConfig_MergeTree `protobuf:"bytes,17,opt,name=merge_tree,json=mergeTree,proto3" json:"merge_tree,omitempty"` Compression []*ClickhouseConfig_Compression `protobuf:"bytes,18,rep,name=compression,proto3" json:"compression,omitempty"` GraphiteRollup map[string]*ClickhouseConfig_GraphiteRollup `` /* 192-byte string literal not displayed */ Kafka *ClickhouseConfig_Kafka `protobuf:"bytes,20,opt,name=kafka,proto3" json:"kafka,omitempty"` KafkaTopics map[string]*ClickhouseConfig_Kafka `` /* 183-byte string literal not displayed */ Rabbitmq *ClickhouseConfig_Rabbitmq `protobuf:"bytes,22,opt,name=rabbitmq,proto3" json:"rabbitmq,omitempty"` TotalMemoryTrackerSampleProbability *wrapperspb.DoubleValue `` /* 173-byte string literal not displayed */ BackgroundMessageBrokerSchedulePoolSize *wrapperspb.Int64Value `` /* 187-byte string literal not displayed */ QueryLogRetentionSize *wrapperspb.Int64Value `` /* 129-byte string literal not displayed */ QueryLogRetentionTime *durationpb.Duration `` /* 129-byte string literal not displayed */ QueryThreadLogEnabled *wrapperspb.BoolValue `` /* 129-byte string literal not displayed */ QueryThreadLogRetentionSize *wrapperspb.Int64Value `` /* 149-byte string literal not displayed */ QueryThreadLogRetentionTime *durationpb.Duration `` /* 149-byte string literal not displayed */ QueryViewsLogEnabled *wrapperspb.BoolValue `` /* 126-byte string literal not displayed */ QueryViewsLogRetentionSize *wrapperspb.Int64Value `` /* 146-byte string literal not displayed */ QueryViewsLogRetentionTime *durationpb.Duration `` /* 146-byte string literal not displayed */ PartLogRetentionSize *wrapperspb.Int64Value `` /* 126-byte string literal not displayed */ PartLogRetentionTime *durationpb.Duration `` /* 126-byte string literal not displayed */ MetricLogEnabled *wrapperspb.BoolValue `protobuf:"bytes,35,opt,name=metric_log_enabled,json=metricLogEnabled,proto3" json:"metric_log_enabled,omitempty"` MetricLogRetentionSize *wrapperspb.Int64Value `` /* 132-byte string literal not displayed */ MetricLogRetentionTime *durationpb.Duration `` /* 132-byte string literal not displayed */ AsynchronousMetricLogEnabled *wrapperspb.BoolValue `` /* 150-byte string literal not displayed */ AsynchronousMetricLogRetentionSize *wrapperspb.Int64Value `` /* 170-byte string literal not displayed */ AsynchronousMetricLogRetentionTime *durationpb.Duration `` /* 170-byte string literal not displayed */ TraceLogEnabled *wrapperspb.BoolValue `protobuf:"bytes,41,opt,name=trace_log_enabled,json=traceLogEnabled,proto3" json:"trace_log_enabled,omitempty"` TraceLogRetentionSize *wrapperspb.Int64Value `` /* 129-byte string literal not displayed */ TraceLogRetentionTime *durationpb.Duration `` /* 129-byte string literal not displayed */ TextLogEnabled *wrapperspb.BoolValue `protobuf:"bytes,44,opt,name=text_log_enabled,json=textLogEnabled,proto3" json:"text_log_enabled,omitempty"` TextLogRetentionSize *wrapperspb.Int64Value `` /* 126-byte string literal not displayed */ TextLogRetentionTime *durationpb.Duration `` /* 126-byte string literal not displayed */ TextLogLevel ClickhouseConfig_LogLevel `` /* 158-byte string literal not displayed */ OpentelemetrySpanLogEnabled *wrapperspb.BoolValue `` /* 147-byte string literal not displayed */ OpentelemetrySpanLogRetentionSize *wrapperspb.Int64Value `` /* 167-byte string literal not displayed */ OpentelemetrySpanLogRetentionTime *durationpb.Duration `` /* 167-byte string literal not displayed */ SessionLogEnabled *wrapperspb.BoolValue `protobuf:"bytes,51,opt,name=session_log_enabled,json=sessionLogEnabled,proto3" json:"session_log_enabled,omitempty"` SessionLogRetentionSize *wrapperspb.Int64Value `` /* 135-byte string literal not displayed */ SessionLogRetentionTime *durationpb.Duration `` /* 135-byte string literal not displayed */ ZookeeperLogEnabled *wrapperspb.BoolValue `protobuf:"bytes,54,opt,name=zookeeper_log_enabled,json=zookeeperLogEnabled,proto3" json:"zookeeper_log_enabled,omitempty"` ZookeeperLogRetentionSize *wrapperspb.Int64Value `` /* 141-byte string literal not displayed */ ZookeeperLogRetentionTime *durationpb.Duration `` /* 141-byte string literal not displayed */ AsynchronousInsertLogEnabled *wrapperspb.BoolValue `` /* 150-byte string literal not displayed */ AsynchronousInsertLogRetentionSize *wrapperspb.Int64Value `` /* 170-byte string literal not displayed */ AsynchronousInsertLogRetentionTime *durationpb.Duration `` /* 170-byte string literal not displayed */ HybridStorage *ClickhouseConfig_HybridStorage `protobuf:"bytes,61,opt,name=hybrid_storage,json=hybridStorage,proto3" json:"hybrid_storage,omitempty"` // contains filtered or unexported fields }
ClickHouse server configuration.
func (*ClickhouseConfig) Descriptor
deprecated
func (*ClickhouseConfig) Descriptor() ([]byte, []int)
Deprecated: Use ClickhouseConfig.ProtoReflect.Descriptor instead.
func (*ClickhouseConfig) GetAsynchronousInsertLogEnabled ¶
func (x *ClickhouseConfig) GetAsynchronousInsertLogEnabled() *wrapperspb.BoolValue
func (*ClickhouseConfig) GetAsynchronousInsertLogRetentionSize ¶
func (x *ClickhouseConfig) GetAsynchronousInsertLogRetentionSize() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetAsynchronousInsertLogRetentionTime ¶
func (x *ClickhouseConfig) GetAsynchronousInsertLogRetentionTime() *durationpb.Duration
func (*ClickhouseConfig) GetAsynchronousMetricLogEnabled ¶
func (x *ClickhouseConfig) GetAsynchronousMetricLogEnabled() *wrapperspb.BoolValue
func (*ClickhouseConfig) GetAsynchronousMetricLogRetentionSize ¶
func (x *ClickhouseConfig) GetAsynchronousMetricLogRetentionSize() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetAsynchronousMetricLogRetentionTime ¶
func (x *ClickhouseConfig) GetAsynchronousMetricLogRetentionTime() *durationpb.Duration
func (*ClickhouseConfig) GetBackgroundCommonPoolSize ¶
func (x *ClickhouseConfig) GetBackgroundCommonPoolSize() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetBackgroundFetchesPoolSize ¶
func (x *ClickhouseConfig) GetBackgroundFetchesPoolSize() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetBackgroundMergesMutationsConcurrencyRatio ¶
func (x *ClickhouseConfig) GetBackgroundMergesMutationsConcurrencyRatio() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetBackgroundMessageBrokerSchedulePoolSize ¶
func (x *ClickhouseConfig) GetBackgroundMessageBrokerSchedulePoolSize() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetBackgroundMovePoolSize ¶
func (x *ClickhouseConfig) GetBackgroundMovePoolSize() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetBackgroundPoolSize ¶
func (x *ClickhouseConfig) GetBackgroundPoolSize() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetBackgroundSchedulePoolSize ¶
func (x *ClickhouseConfig) GetBackgroundSchedulePoolSize() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetCompression ¶
func (x *ClickhouseConfig) GetCompression() []*ClickhouseConfig_Compression
func (*ClickhouseConfig) GetGraphiteRollup ¶
func (x *ClickhouseConfig) GetGraphiteRollup() map[string]*ClickhouseConfig_GraphiteRollup
func (*ClickhouseConfig) GetHybridStorage ¶
func (x *ClickhouseConfig) GetHybridStorage() *ClickhouseConfig_HybridStorage
func (*ClickhouseConfig) GetKafka ¶
func (x *ClickhouseConfig) GetKafka() *ClickhouseConfig_Kafka
func (*ClickhouseConfig) GetKafkaTopics ¶
func (x *ClickhouseConfig) GetKafkaTopics() map[string]*ClickhouseConfig_Kafka
func (*ClickhouseConfig) GetKeepAliveTimeout ¶
func (x *ClickhouseConfig) GetKeepAliveTimeout() *durationpb.Duration
func (*ClickhouseConfig) GetLogLevel ¶
func (x *ClickhouseConfig) GetLogLevel() ClickhouseConfig_LogLevel
func (*ClickhouseConfig) GetMarkCacheSize ¶
func (x *ClickhouseConfig) GetMarkCacheSize() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetMaxConcurrentQueries ¶
func (x *ClickhouseConfig) GetMaxConcurrentQueries() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetMaxConnections ¶
func (x *ClickhouseConfig) GetMaxConnections() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetMaxPartitionSizeToDrop ¶
func (x *ClickhouseConfig) GetMaxPartitionSizeToDrop() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetMaxTableSizeToDrop ¶
func (x *ClickhouseConfig) GetMaxTableSizeToDrop() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetMergeTree ¶
func (x *ClickhouseConfig) GetMergeTree() *ClickhouseConfig_MergeTree
func (*ClickhouseConfig) GetMetricLogEnabled ¶
func (x *ClickhouseConfig) GetMetricLogEnabled() *wrapperspb.BoolValue
func (*ClickhouseConfig) GetMetricLogRetentionSize ¶
func (x *ClickhouseConfig) GetMetricLogRetentionSize() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetMetricLogRetentionTime ¶
func (x *ClickhouseConfig) GetMetricLogRetentionTime() *durationpb.Duration
func (*ClickhouseConfig) GetOpentelemetrySpanLogEnabled ¶
func (x *ClickhouseConfig) GetOpentelemetrySpanLogEnabled() *wrapperspb.BoolValue
func (*ClickhouseConfig) GetOpentelemetrySpanLogRetentionSize ¶
func (x *ClickhouseConfig) GetOpentelemetrySpanLogRetentionSize() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetOpentelemetrySpanLogRetentionTime ¶
func (x *ClickhouseConfig) GetOpentelemetrySpanLogRetentionTime() *durationpb.Duration
func (*ClickhouseConfig) GetPartLogRetentionSize ¶
func (x *ClickhouseConfig) GetPartLogRetentionSize() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetPartLogRetentionTime ¶
func (x *ClickhouseConfig) GetPartLogRetentionTime() *durationpb.Duration
func (*ClickhouseConfig) GetQueryLogRetentionSize ¶
func (x *ClickhouseConfig) GetQueryLogRetentionSize() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetQueryLogRetentionTime ¶
func (x *ClickhouseConfig) GetQueryLogRetentionTime() *durationpb.Duration
func (*ClickhouseConfig) GetQueryThreadLogEnabled ¶
func (x *ClickhouseConfig) GetQueryThreadLogEnabled() *wrapperspb.BoolValue
func (*ClickhouseConfig) GetQueryThreadLogRetentionSize ¶
func (x *ClickhouseConfig) GetQueryThreadLogRetentionSize() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetQueryThreadLogRetentionTime ¶
func (x *ClickhouseConfig) GetQueryThreadLogRetentionTime() *durationpb.Duration
func (*ClickhouseConfig) GetQueryViewsLogEnabled ¶
func (x *ClickhouseConfig) GetQueryViewsLogEnabled() *wrapperspb.BoolValue
func (*ClickhouseConfig) GetQueryViewsLogRetentionSize ¶
func (x *ClickhouseConfig) GetQueryViewsLogRetentionSize() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetQueryViewsLogRetentionTime ¶
func (x *ClickhouseConfig) GetQueryViewsLogRetentionTime() *durationpb.Duration
func (*ClickhouseConfig) GetRabbitmq ¶
func (x *ClickhouseConfig) GetRabbitmq() *ClickhouseConfig_Rabbitmq
func (*ClickhouseConfig) GetSessionLogEnabled ¶
func (x *ClickhouseConfig) GetSessionLogEnabled() *wrapperspb.BoolValue
func (*ClickhouseConfig) GetSessionLogRetentionSize ¶
func (x *ClickhouseConfig) GetSessionLogRetentionSize() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetSessionLogRetentionTime ¶
func (x *ClickhouseConfig) GetSessionLogRetentionTime() *durationpb.Duration
func (*ClickhouseConfig) GetTextLogEnabled ¶
func (x *ClickhouseConfig) GetTextLogEnabled() *wrapperspb.BoolValue
func (*ClickhouseConfig) GetTextLogLevel ¶
func (x *ClickhouseConfig) GetTextLogLevel() ClickhouseConfig_LogLevel
func (*ClickhouseConfig) GetTextLogRetentionSize ¶
func (x *ClickhouseConfig) GetTextLogRetentionSize() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetTextLogRetentionTime ¶
func (x *ClickhouseConfig) GetTextLogRetentionTime() *durationpb.Duration
func (*ClickhouseConfig) GetTimezone ¶
func (x *ClickhouseConfig) GetTimezone() *wrapperspb.StringValue
func (*ClickhouseConfig) GetTotalMemoryProfilerStep ¶
func (x *ClickhouseConfig) GetTotalMemoryProfilerStep() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetTotalMemoryTrackerSampleProbability ¶
func (x *ClickhouseConfig) GetTotalMemoryTrackerSampleProbability() *wrapperspb.DoubleValue
func (*ClickhouseConfig) GetTraceLogEnabled ¶
func (x *ClickhouseConfig) GetTraceLogEnabled() *wrapperspb.BoolValue
func (*ClickhouseConfig) GetTraceLogRetentionSize ¶
func (x *ClickhouseConfig) GetTraceLogRetentionSize() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetTraceLogRetentionTime ¶
func (x *ClickhouseConfig) GetTraceLogRetentionTime() *durationpb.Duration
func (*ClickhouseConfig) GetUncompressedCacheSize ¶
func (x *ClickhouseConfig) GetUncompressedCacheSize() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetZookeeperLogEnabled ¶
func (x *ClickhouseConfig) GetZookeeperLogEnabled() *wrapperspb.BoolValue
func (*ClickhouseConfig) GetZookeeperLogRetentionSize ¶
func (x *ClickhouseConfig) GetZookeeperLogRetentionSize() *wrapperspb.Int64Value
func (*ClickhouseConfig) GetZookeeperLogRetentionTime ¶
func (x *ClickhouseConfig) GetZookeeperLogRetentionTime() *durationpb.Duration
func (*ClickhouseConfig) ProtoMessage ¶
func (*ClickhouseConfig) ProtoMessage()
func (*ClickhouseConfig) ProtoReflect ¶
func (x *ClickhouseConfig) ProtoReflect() protoreflect.Message
func (*ClickhouseConfig) Reset ¶
func (x *ClickhouseConfig) Reset()
func (*ClickhouseConfig) String ¶
func (x *ClickhouseConfig) String() string
type ClickhouseConfig_Compression ¶
type ClickhouseConfig_Compression struct { Method ClickhouseConfig_Compression_Method `` /* 133-byte string literal not displayed */ MinPartSize int64 `protobuf:"varint,2,opt,name=min_part_size,json=minPartSize,proto3" json:"min_part_size,omitempty"` MinPartSizeRatio float64 `protobuf:"fixed64,3,opt,name=min_part_size_ratio,json=minPartSizeRatio,proto3" json:"min_part_size_ratio,omitempty"` Level *wrapperspb.Int64Value `protobuf:"bytes,4,opt,name=level,proto3" json:"level,omitempty"` // contains filtered or unexported fields }
func (*ClickhouseConfig_Compression) Descriptor
deprecated
func (*ClickhouseConfig_Compression) Descriptor() ([]byte, []int)
Deprecated: Use ClickhouseConfig_Compression.ProtoReflect.Descriptor instead.
func (*ClickhouseConfig_Compression) GetLevel ¶
func (x *ClickhouseConfig_Compression) GetLevel() *wrapperspb.Int64Value
func (*ClickhouseConfig_Compression) GetMethod ¶
func (x *ClickhouseConfig_Compression) GetMethod() ClickhouseConfig_Compression_Method
func (*ClickhouseConfig_Compression) GetMinPartSize ¶
func (x *ClickhouseConfig_Compression) GetMinPartSize() int64
func (*ClickhouseConfig_Compression) GetMinPartSizeRatio ¶
func (x *ClickhouseConfig_Compression) GetMinPartSizeRatio() float64
func (*ClickhouseConfig_Compression) ProtoMessage ¶
func (*ClickhouseConfig_Compression) ProtoMessage()
func (*ClickhouseConfig_Compression) ProtoReflect ¶
func (x *ClickhouseConfig_Compression) ProtoReflect() protoreflect.Message
func (*ClickhouseConfig_Compression) Reset ¶
func (x *ClickhouseConfig_Compression) Reset()
func (*ClickhouseConfig_Compression) String ¶
func (x *ClickhouseConfig_Compression) String() string
type ClickhouseConfig_Compression_Method ¶
type ClickhouseConfig_Compression_Method int32
const ( ClickhouseConfig_Compression_METHOD_INVALID ClickhouseConfig_Compression_Method = 0 ClickhouseConfig_Compression_METHOD_LZ4 ClickhouseConfig_Compression_Method = 1 ClickhouseConfig_Compression_METHOD_ZSTD ClickhouseConfig_Compression_Method = 2 ClickhouseConfig_Compression_METHOD_LZ4HC ClickhouseConfig_Compression_Method = 3 )
func (ClickhouseConfig_Compression_Method) Descriptor ¶
func (ClickhouseConfig_Compression_Method) Descriptor() protoreflect.EnumDescriptor
func (ClickhouseConfig_Compression_Method) Enum ¶
func (x ClickhouseConfig_Compression_Method) Enum() *ClickhouseConfig_Compression_Method
func (ClickhouseConfig_Compression_Method) EnumDescriptor
deprecated
func (ClickhouseConfig_Compression_Method) EnumDescriptor() ([]byte, []int)
Deprecated: Use ClickhouseConfig_Compression_Method.Descriptor instead.
func (ClickhouseConfig_Compression_Method) Number ¶
func (x ClickhouseConfig_Compression_Method) Number() protoreflect.EnumNumber
func (ClickhouseConfig_Compression_Method) String ¶
func (x ClickhouseConfig_Compression_Method) String() string
func (ClickhouseConfig_Compression_Method) Type ¶
func (ClickhouseConfig_Compression_Method) Type() protoreflect.EnumType
type ClickhouseConfig_GraphiteRollup ¶
type ClickhouseConfig_GraphiteRollup struct { Patterns []*ClickhouseConfig_GraphiteRollup_Pattern `protobuf:"bytes,1,rep,name=patterns,proto3" json:"patterns,omitempty"` // contains filtered or unexported fields }
Rollup settings for the GraphiteMergeTree table engine.
func (*ClickhouseConfig_GraphiteRollup) Descriptor
deprecated
func (*ClickhouseConfig_GraphiteRollup) Descriptor() ([]byte, []int)
Deprecated: Use ClickhouseConfig_GraphiteRollup.ProtoReflect.Descriptor instead.
func (*ClickhouseConfig_GraphiteRollup) GetPatterns ¶
func (x *ClickhouseConfig_GraphiteRollup) GetPatterns() []*ClickhouseConfig_GraphiteRollup_Pattern
func (*ClickhouseConfig_GraphiteRollup) ProtoMessage ¶
func (*ClickhouseConfig_GraphiteRollup) ProtoMessage()
func (*ClickhouseConfig_GraphiteRollup) ProtoReflect ¶
func (x *ClickhouseConfig_GraphiteRollup) ProtoReflect() protoreflect.Message
func (*ClickhouseConfig_GraphiteRollup) Reset ¶
func (x *ClickhouseConfig_GraphiteRollup) Reset()
func (*ClickhouseConfig_GraphiteRollup) String ¶
func (x *ClickhouseConfig_GraphiteRollup) String() string
type ClickhouseConfig_GraphiteRollup_Pattern ¶
type ClickhouseConfig_GraphiteRollup_Pattern struct { Regexp *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=regexp,proto3" json:"regexp,omitempty"` Function *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=function,proto3" json:"function,omitempty"` Retention []*ClickhouseConfig_GraphiteRollup_Pattern_Retention `protobuf:"bytes,3,rep,name=retention,proto3" json:"retention,omitempty"` // contains filtered or unexported fields }
func (*ClickhouseConfig_GraphiteRollup_Pattern) Descriptor
deprecated
func (*ClickhouseConfig_GraphiteRollup_Pattern) Descriptor() ([]byte, []int)
Deprecated: Use ClickhouseConfig_GraphiteRollup_Pattern.ProtoReflect.Descriptor instead.
func (*ClickhouseConfig_GraphiteRollup_Pattern) GetFunction ¶
func (x *ClickhouseConfig_GraphiteRollup_Pattern) GetFunction() *wrapperspb.StringValue
func (*ClickhouseConfig_GraphiteRollup_Pattern) GetRegexp ¶
func (x *ClickhouseConfig_GraphiteRollup_Pattern) GetRegexp() *wrapperspb.StringValue
func (*ClickhouseConfig_GraphiteRollup_Pattern) GetRetention ¶
func (x *ClickhouseConfig_GraphiteRollup_Pattern) GetRetention() []*ClickhouseConfig_GraphiteRollup_Pattern_Retention
func (*ClickhouseConfig_GraphiteRollup_Pattern) ProtoMessage ¶
func (*ClickhouseConfig_GraphiteRollup_Pattern) ProtoMessage()
func (*ClickhouseConfig_GraphiteRollup_Pattern) ProtoReflect ¶
func (x *ClickhouseConfig_GraphiteRollup_Pattern) ProtoReflect() protoreflect.Message
func (*ClickhouseConfig_GraphiteRollup_Pattern) Reset ¶
func (x *ClickhouseConfig_GraphiteRollup_Pattern) Reset()
func (*ClickhouseConfig_GraphiteRollup_Pattern) String ¶
func (x *ClickhouseConfig_GraphiteRollup_Pattern) String() string
type ClickhouseConfig_GraphiteRollup_Pattern_Retention ¶
type ClickhouseConfig_GraphiteRollup_Pattern_Retention struct { Age int64 `protobuf:"varint,1,opt,name=age,proto3" json:"age,omitempty"` Precision int64 `protobuf:"varint,2,opt,name=precision,proto3" json:"precision,omitempty"` // contains filtered or unexported fields }
func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) Descriptor
deprecated
func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) Descriptor() ([]byte, []int)
Deprecated: Use ClickhouseConfig_GraphiteRollup_Pattern_Retention.ProtoReflect.Descriptor instead.
func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) GetAge ¶
func (x *ClickhouseConfig_GraphiteRollup_Pattern_Retention) GetAge() int64
func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) GetPrecision ¶
func (x *ClickhouseConfig_GraphiteRollup_Pattern_Retention) GetPrecision() int64
func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) ProtoMessage ¶
func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) ProtoMessage()
func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) ProtoReflect ¶
func (x *ClickhouseConfig_GraphiteRollup_Pattern_Retention) ProtoReflect() protoreflect.Message
func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) Reset ¶
func (x *ClickhouseConfig_GraphiteRollup_Pattern_Retention) Reset()
func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) String ¶
func (x *ClickhouseConfig_GraphiteRollup_Pattern_Retention) String() string
type ClickhouseConfig_HybridStorage ¶
type ClickhouseConfig_HybridStorage struct { PreferNotToMerge *wrapperspb.BoolValue `protobuf:"bytes,1,opt,name=prefer_not_to_merge,json=preferNotToMerge,proto3" json:"prefer_not_to_merge,omitempty"` MaxDataPartSize *wrapperspb.Int64Value `protobuf:"bytes,2,opt,name=max_data_part_size,json=maxDataPartSize,proto3" json:"max_data_part_size,omitempty"` // contains filtered or unexported fields }
func (*ClickhouseConfig_HybridStorage) Descriptor
deprecated
func (*ClickhouseConfig_HybridStorage) Descriptor() ([]byte, []int)
Deprecated: Use ClickhouseConfig_HybridStorage.ProtoReflect.Descriptor instead.
func (*ClickhouseConfig_HybridStorage) GetMaxDataPartSize ¶
func (x *ClickhouseConfig_HybridStorage) GetMaxDataPartSize() *wrapperspb.Int64Value
func (*ClickhouseConfig_HybridStorage) GetPreferNotToMerge ¶
func (x *ClickhouseConfig_HybridStorage) GetPreferNotToMerge() *wrapperspb.BoolValue
func (*ClickhouseConfig_HybridStorage) ProtoMessage ¶
func (*ClickhouseConfig_HybridStorage) ProtoMessage()
func (*ClickhouseConfig_HybridStorage) ProtoReflect ¶
func (x *ClickhouseConfig_HybridStorage) ProtoReflect() protoreflect.Message
func (*ClickhouseConfig_HybridStorage) Reset ¶
func (x *ClickhouseConfig_HybridStorage) Reset()
func (*ClickhouseConfig_HybridStorage) String ¶
func (x *ClickhouseConfig_HybridStorage) String() string
type ClickhouseConfig_Kafka ¶
type ClickhouseConfig_Kafka struct { SecurityProtocol ClickhouseConfig_Kafka_SecurityProtocol `` /* 181-byte string literal not displayed */ SaslMechanism ClickhouseConfig_Kafka_SaslMechanism `` /* 169-byte string literal not displayed */ SaslUsername *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=sasl_username,json=saslUsername,proto3" json:"sasl_username,omitempty"` SaslPassword *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=sasl_password,json=saslPassword,proto3" json:"sasl_password,omitempty"` EnableSslCertificateVerification *wrapperspb.BoolValue `` /* 161-byte string literal not displayed */ MaxPollIntervalMs *durationpb.Duration `protobuf:"bytes,6,opt,name=max_poll_interval_ms,json=maxPollIntervalMs,proto3" json:"max_poll_interval_ms,omitempty"` SessionTimeoutMs *durationpb.Duration `protobuf:"bytes,7,opt,name=session_timeout_ms,json=sessionTimeoutMs,proto3" json:"session_timeout_ms,omitempty"` // contains filtered or unexported fields }
func (*ClickhouseConfig_Kafka) Descriptor
deprecated
func (*ClickhouseConfig_Kafka) Descriptor() ([]byte, []int)
Deprecated: Use ClickhouseConfig_Kafka.ProtoReflect.Descriptor instead.
func (*ClickhouseConfig_Kafka) GetEnableSslCertificateVerification ¶
func (x *ClickhouseConfig_Kafka) GetEnableSslCertificateVerification() *wrapperspb.BoolValue
func (*ClickhouseConfig_Kafka) GetMaxPollIntervalMs ¶
func (x *ClickhouseConfig_Kafka) GetMaxPollIntervalMs() *durationpb.Duration
func (*ClickhouseConfig_Kafka) GetSaslMechanism ¶
func (x *ClickhouseConfig_Kafka) GetSaslMechanism() ClickhouseConfig_Kafka_SaslMechanism
func (*ClickhouseConfig_Kafka) GetSaslPassword ¶
func (x *ClickhouseConfig_Kafka) GetSaslPassword() *wrapperspb.StringValue
func (*ClickhouseConfig_Kafka) GetSaslUsername ¶
func (x *ClickhouseConfig_Kafka) GetSaslUsername() *wrapperspb.StringValue
func (*ClickhouseConfig_Kafka) GetSecurityProtocol ¶
func (x *ClickhouseConfig_Kafka) GetSecurityProtocol() ClickhouseConfig_Kafka_SecurityProtocol
func (*ClickhouseConfig_Kafka) GetSessionTimeoutMs ¶
func (x *ClickhouseConfig_Kafka) GetSessionTimeoutMs() *durationpb.Duration
func (*ClickhouseConfig_Kafka) ProtoMessage ¶
func (*ClickhouseConfig_Kafka) ProtoMessage()
func (*ClickhouseConfig_Kafka) ProtoReflect ¶
func (x *ClickhouseConfig_Kafka) ProtoReflect() protoreflect.Message
func (*ClickhouseConfig_Kafka) Reset ¶
func (x *ClickhouseConfig_Kafka) Reset()
func (*ClickhouseConfig_Kafka) String ¶
func (x *ClickhouseConfig_Kafka) String() string
type ClickhouseConfig_Kafka_SaslMechanism ¶
type ClickhouseConfig_Kafka_SaslMechanism int32
const ( ClickhouseConfig_Kafka_SASL_MECHANISM_INVALID ClickhouseConfig_Kafka_SaslMechanism = 0 ClickhouseConfig_Kafka_SASL_MECHANISM_GSSAPI ClickhouseConfig_Kafka_SaslMechanism = 1 ClickhouseConfig_Kafka_SASL_MECHANISM_PLAIN ClickhouseConfig_Kafka_SaslMechanism = 2 ClickhouseConfig_Kafka_SASL_MECHANISM_SCRAM_SHA_256 ClickhouseConfig_Kafka_SaslMechanism = 3 ClickhouseConfig_Kafka_SASL_MECHANISM_SCRAM_SHA_512 ClickhouseConfig_Kafka_SaslMechanism = 4 )
func (ClickhouseConfig_Kafka_SaslMechanism) Descriptor ¶
func (ClickhouseConfig_Kafka_SaslMechanism) Descriptor() protoreflect.EnumDescriptor
func (ClickhouseConfig_Kafka_SaslMechanism) Enum ¶
func (x ClickhouseConfig_Kafka_SaslMechanism) Enum() *ClickhouseConfig_Kafka_SaslMechanism
func (ClickhouseConfig_Kafka_SaslMechanism) EnumDescriptor
deprecated
func (ClickhouseConfig_Kafka_SaslMechanism) EnumDescriptor() ([]byte, []int)
Deprecated: Use ClickhouseConfig_Kafka_SaslMechanism.Descriptor instead.
func (ClickhouseConfig_Kafka_SaslMechanism) Number ¶
func (x ClickhouseConfig_Kafka_SaslMechanism) Number() protoreflect.EnumNumber
func (ClickhouseConfig_Kafka_SaslMechanism) String ¶
func (x ClickhouseConfig_Kafka_SaslMechanism) String() string
func (ClickhouseConfig_Kafka_SaslMechanism) Type ¶
func (ClickhouseConfig_Kafka_SaslMechanism) Type() protoreflect.EnumType
type ClickhouseConfig_Kafka_SecurityProtocol ¶
type ClickhouseConfig_Kafka_SecurityProtocol int32
const ( ClickhouseConfig_Kafka_SECURITY_PROTOCOL_INVALID ClickhouseConfig_Kafka_SecurityProtocol = 0 ClickhouseConfig_Kafka_SECURITY_PROTOCOL_PLAINTEXT ClickhouseConfig_Kafka_SecurityProtocol = 1 ClickhouseConfig_Kafka_SECURITY_PROTOCOL_SSL ClickhouseConfig_Kafka_SecurityProtocol = 2 ClickhouseConfig_Kafka_SECURITY_PROTOCOL_SASL_PLAINTEXT ClickhouseConfig_Kafka_SecurityProtocol = 3 ClickhouseConfig_Kafka_SECURITY_PROTOCOL_SASL_SSL ClickhouseConfig_Kafka_SecurityProtocol = 4 )
func (ClickhouseConfig_Kafka_SecurityProtocol) Descriptor ¶
func (ClickhouseConfig_Kafka_SecurityProtocol) Descriptor() protoreflect.EnumDescriptor
func (ClickhouseConfig_Kafka_SecurityProtocol) EnumDescriptor
deprecated
func (ClickhouseConfig_Kafka_SecurityProtocol) EnumDescriptor() ([]byte, []int)
Deprecated: Use ClickhouseConfig_Kafka_SecurityProtocol.Descriptor instead.
func (ClickhouseConfig_Kafka_SecurityProtocol) Number ¶
func (x ClickhouseConfig_Kafka_SecurityProtocol) Number() protoreflect.EnumNumber
func (ClickhouseConfig_Kafka_SecurityProtocol) String ¶
func (x ClickhouseConfig_Kafka_SecurityProtocol) String() string
func (ClickhouseConfig_Kafka_SecurityProtocol) Type ¶
func (ClickhouseConfig_Kafka_SecurityProtocol) Type() protoreflect.EnumType
type ClickhouseConfig_LogLevel ¶
type ClickhouseConfig_LogLevel int32
const ( ClickhouseConfig_LOG_LEVEL_DEFAULT ClickhouseConfig_LogLevel = 0 ClickhouseConfig_LOG_LEVEL_TRACE ClickhouseConfig_LogLevel = 1 ClickhouseConfig_LOG_LEVEL_DEBUG ClickhouseConfig_LogLevel = 2 ClickhouseConfig_LOG_LEVEL_INFORMATION ClickhouseConfig_LogLevel = 3 ClickhouseConfig_LOG_LEVEL_WARNING ClickhouseConfig_LogLevel = 4 ClickhouseConfig_LOG_LEVEL_ERROR ClickhouseConfig_LogLevel = 5 )
func (ClickhouseConfig_LogLevel) Descriptor ¶
func (ClickhouseConfig_LogLevel) Descriptor() protoreflect.EnumDescriptor
func (ClickhouseConfig_LogLevel) Enum ¶
func (x ClickhouseConfig_LogLevel) Enum() *ClickhouseConfig_LogLevel
func (ClickhouseConfig_LogLevel) EnumDescriptor
deprecated
func (ClickhouseConfig_LogLevel) EnumDescriptor() ([]byte, []int)
Deprecated: Use ClickhouseConfig_LogLevel.Descriptor instead.
func (ClickhouseConfig_LogLevel) Number ¶
func (x ClickhouseConfig_LogLevel) Number() protoreflect.EnumNumber
func (ClickhouseConfig_LogLevel) String ¶
func (x ClickhouseConfig_LogLevel) String() string
func (ClickhouseConfig_LogLevel) Type ¶
func (ClickhouseConfig_LogLevel) Type() protoreflect.EnumType
type ClickhouseConfig_MergeTree ¶
type ClickhouseConfig_MergeTree struct { ReplicatedDeduplicationWindow *wrapperspb.Int64Value `` /* 150-byte string literal not displayed */ ReplicatedDeduplicationWindowSeconds *durationpb.Duration `` /* 173-byte string literal not displayed */ PartsToDelayInsert *wrapperspb.Int64Value `protobuf:"bytes,3,opt,name=parts_to_delay_insert,json=partsToDelayInsert,proto3" json:"parts_to_delay_insert,omitempty"` PartsToThrowInsert *wrapperspb.Int64Value `protobuf:"bytes,4,opt,name=parts_to_throw_insert,json=partsToThrowInsert,proto3" json:"parts_to_throw_insert,omitempty"` MaxReplicatedMergesInQueue *wrapperspb.Int64Value `` /* 145-byte string literal not displayed */ NumberOfFreeEntriesInPoolToLowerMaxSizeOfMerge *wrapperspb.Int64Value `` /* 219-byte string literal not displayed */ MaxBytesToMergeAtMinSpaceInPool *wrapperspb.Int64Value `` /* 168-byte string literal not displayed */ MaxBytesToMergeAtMaxSpaceInPool *wrapperspb.Int64Value `` /* 168-byte string literal not displayed */ MinBytesForWidePart *wrapperspb.Int64Value `protobuf:"bytes,9,opt,name=min_bytes_for_wide_part,json=minBytesForWidePart,proto3" json:"min_bytes_for_wide_part,omitempty"` MinRowsForWidePart *wrapperspb.Int64Value `protobuf:"bytes,10,opt,name=min_rows_for_wide_part,json=minRowsForWidePart,proto3" json:"min_rows_for_wide_part,omitempty"` TtlOnlyDropParts *wrapperspb.BoolValue `protobuf:"bytes,11,opt,name=ttl_only_drop_parts,json=ttlOnlyDropParts,proto3" json:"ttl_only_drop_parts,omitempty"` InactivePartsToDelayInsert *wrapperspb.Int64Value `` /* 146-byte string literal not displayed */ InactivePartsToThrowInsert *wrapperspb.Int64Value `` /* 146-byte string literal not displayed */ AllowRemoteFsZeroCopyReplication *wrapperspb.BoolValue `` /* 166-byte string literal not displayed */ MergeWithTtlTimeout *durationpb.Duration `protobuf:"bytes,15,opt,name=merge_with_ttl_timeout,json=mergeWithTtlTimeout,proto3" json:"merge_with_ttl_timeout,omitempty"` MergeWithRecompressionTtlTimeout *durationpb.Duration `` /* 164-byte string literal not displayed */ MaxPartsInTotal *wrapperspb.Int64Value `protobuf:"bytes,17,opt,name=max_parts_in_total,json=maxPartsInTotal,proto3" json:"max_parts_in_total,omitempty"` MaxNumberOfMergesWithTtlInPool *wrapperspb.Int64Value `` /* 164-byte string literal not displayed */ CleanupDelayPeriod *durationpb.Duration `protobuf:"bytes,19,opt,name=cleanup_delay_period,json=cleanupDelayPeriod,proto3" json:"cleanup_delay_period,omitempty"` NumberOfFreeEntriesInPoolToExecuteMutation *wrapperspb.Int64Value `` /* 202-byte string literal not displayed */ MaxAvgPartSizeForTooManyParts *wrapperspb.Int64Value `` /* 161-byte string literal not displayed */ MinAgeToForceMergeSeconds *durationpb.Duration `` /* 145-byte string literal not displayed */ MinAgeToForceMergeOnPartitionOnly *wrapperspb.BoolValue `` /* 173-byte string literal not displayed */ MergeSelectingSleepMs *durationpb.Duration `` /* 129-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ClickhouseConfig_MergeTree) Descriptor
deprecated
func (*ClickhouseConfig_MergeTree) Descriptor() ([]byte, []int)
Deprecated: Use ClickhouseConfig_MergeTree.ProtoReflect.Descriptor instead.
func (*ClickhouseConfig_MergeTree) GetAllowRemoteFsZeroCopyReplication ¶
func (x *ClickhouseConfig_MergeTree) GetAllowRemoteFsZeroCopyReplication() *wrapperspb.BoolValue
func (*ClickhouseConfig_MergeTree) GetCleanupDelayPeriod ¶
func (x *ClickhouseConfig_MergeTree) GetCleanupDelayPeriod() *durationpb.Duration
func (*ClickhouseConfig_MergeTree) GetInactivePartsToDelayInsert ¶
func (x *ClickhouseConfig_MergeTree) GetInactivePartsToDelayInsert() *wrapperspb.Int64Value
func (*ClickhouseConfig_MergeTree) GetInactivePartsToThrowInsert ¶
func (x *ClickhouseConfig_MergeTree) GetInactivePartsToThrowInsert() *wrapperspb.Int64Value
func (*ClickhouseConfig_MergeTree) GetMaxAvgPartSizeForTooManyParts ¶
func (x *ClickhouseConfig_MergeTree) GetMaxAvgPartSizeForTooManyParts() *wrapperspb.Int64Value
func (*ClickhouseConfig_MergeTree) GetMaxBytesToMergeAtMaxSpaceInPool ¶
func (x *ClickhouseConfig_MergeTree) GetMaxBytesToMergeAtMaxSpaceInPool() *wrapperspb.Int64Value
func (*ClickhouseConfig_MergeTree) GetMaxBytesToMergeAtMinSpaceInPool ¶
func (x *ClickhouseConfig_MergeTree) GetMaxBytesToMergeAtMinSpaceInPool() *wrapperspb.Int64Value
func (*ClickhouseConfig_MergeTree) GetMaxNumberOfMergesWithTtlInPool ¶
func (x *ClickhouseConfig_MergeTree) GetMaxNumberOfMergesWithTtlInPool() *wrapperspb.Int64Value
func (*ClickhouseConfig_MergeTree) GetMaxPartsInTotal ¶
func (x *ClickhouseConfig_MergeTree) GetMaxPartsInTotal() *wrapperspb.Int64Value
func (*ClickhouseConfig_MergeTree) GetMaxReplicatedMergesInQueue ¶
func (x *ClickhouseConfig_MergeTree) GetMaxReplicatedMergesInQueue() *wrapperspb.Int64Value
func (*ClickhouseConfig_MergeTree) GetMergeSelectingSleepMs ¶
func (x *ClickhouseConfig_MergeTree) GetMergeSelectingSleepMs() *durationpb.Duration
func (*ClickhouseConfig_MergeTree) GetMergeWithRecompressionTtlTimeout ¶
func (x *ClickhouseConfig_MergeTree) GetMergeWithRecompressionTtlTimeout() *durationpb.Duration
func (*ClickhouseConfig_MergeTree) GetMergeWithTtlTimeout ¶
func (x *ClickhouseConfig_MergeTree) GetMergeWithTtlTimeout() *durationpb.Duration
func (*ClickhouseConfig_MergeTree) GetMinAgeToForceMergeOnPartitionOnly ¶
func (x *ClickhouseConfig_MergeTree) GetMinAgeToForceMergeOnPartitionOnly() *wrapperspb.BoolValue
func (*ClickhouseConfig_MergeTree) GetMinAgeToForceMergeSeconds ¶
func (x *ClickhouseConfig_MergeTree) GetMinAgeToForceMergeSeconds() *durationpb.Duration
func (*ClickhouseConfig_MergeTree) GetMinBytesForWidePart ¶
func (x *ClickhouseConfig_MergeTree) GetMinBytesForWidePart() *wrapperspb.Int64Value
func (*ClickhouseConfig_MergeTree) GetMinRowsForWidePart ¶
func (x *ClickhouseConfig_MergeTree) GetMinRowsForWidePart() *wrapperspb.Int64Value
func (*ClickhouseConfig_MergeTree) GetNumberOfFreeEntriesInPoolToExecuteMutation ¶
func (x *ClickhouseConfig_MergeTree) GetNumberOfFreeEntriesInPoolToExecuteMutation() *wrapperspb.Int64Value
func (*ClickhouseConfig_MergeTree) GetNumberOfFreeEntriesInPoolToLowerMaxSizeOfMerge ¶
func (x *ClickhouseConfig_MergeTree) GetNumberOfFreeEntriesInPoolToLowerMaxSizeOfMerge() *wrapperspb.Int64Value
func (*ClickhouseConfig_MergeTree) GetPartsToDelayInsert ¶
func (x *ClickhouseConfig_MergeTree) GetPartsToDelayInsert() *wrapperspb.Int64Value
func (*ClickhouseConfig_MergeTree) GetPartsToThrowInsert ¶
func (x *ClickhouseConfig_MergeTree) GetPartsToThrowInsert() *wrapperspb.Int64Value
func (*ClickhouseConfig_MergeTree) GetReplicatedDeduplicationWindow ¶
func (x *ClickhouseConfig_MergeTree) GetReplicatedDeduplicationWindow() *wrapperspb.Int64Value
func (*ClickhouseConfig_MergeTree) GetReplicatedDeduplicationWindowSeconds ¶
func (x *ClickhouseConfig_MergeTree) GetReplicatedDeduplicationWindowSeconds() *durationpb.Duration
func (*ClickhouseConfig_MergeTree) GetTtlOnlyDropParts ¶
func (x *ClickhouseConfig_MergeTree) GetTtlOnlyDropParts() *wrapperspb.BoolValue
func (*ClickhouseConfig_MergeTree) ProtoMessage ¶
func (*ClickhouseConfig_MergeTree) ProtoMessage()
func (*ClickhouseConfig_MergeTree) ProtoReflect ¶
func (x *ClickhouseConfig_MergeTree) ProtoReflect() protoreflect.Message
func (*ClickhouseConfig_MergeTree) Reset ¶
func (x *ClickhouseConfig_MergeTree) Reset()
func (*ClickhouseConfig_MergeTree) String ¶
func (x *ClickhouseConfig_MergeTree) String() string
type ClickhouseConfig_Rabbitmq ¶
type ClickhouseConfig_Rabbitmq struct { Username *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` Password *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"` Vhost *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=vhost,proto3" json:"vhost,omitempty"` // contains filtered or unexported fields }
func (*ClickhouseConfig_Rabbitmq) Descriptor
deprecated
func (*ClickhouseConfig_Rabbitmq) Descriptor() ([]byte, []int)
Deprecated: Use ClickhouseConfig_Rabbitmq.ProtoReflect.Descriptor instead.
func (*ClickhouseConfig_Rabbitmq) GetPassword ¶
func (x *ClickhouseConfig_Rabbitmq) GetPassword() *wrapperspb.StringValue
func (*ClickhouseConfig_Rabbitmq) GetUsername ¶
func (x *ClickhouseConfig_Rabbitmq) GetUsername() *wrapperspb.StringValue
func (*ClickhouseConfig_Rabbitmq) GetVhost ¶
func (x *ClickhouseConfig_Rabbitmq) GetVhost() *wrapperspb.StringValue
func (*ClickhouseConfig_Rabbitmq) ProtoMessage ¶
func (*ClickhouseConfig_Rabbitmq) ProtoMessage()
func (*ClickhouseConfig_Rabbitmq) ProtoReflect ¶
func (x *ClickhouseConfig_Rabbitmq) ProtoReflect() protoreflect.Message
func (*ClickhouseConfig_Rabbitmq) Reset ¶
func (x *ClickhouseConfig_Rabbitmq) Reset()
func (*ClickhouseConfig_Rabbitmq) String ¶
func (x *ClickhouseConfig_Rabbitmq) String() string
type Cluster ¶
type Cluster struct { // ID of the ClickHouse cluster. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // ID of the project that the ClickHouse cluster belongs to. ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` // Type of the cloud where instances should be hosted. CloudType string `protobuf:"bytes,3,opt,name=cloud_type,json=cloudType,proto3" json:"cloud_type,omitempty"` // ID of the region to place instances. RegionId string `protobuf:"bytes,4,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"` // Creation timestamp. CreateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"` // Name of the ClickHouse cluster. // The name is unique within the project. Name string `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"` // Description of the ClickHouse cluster. Description string `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"` // Current state of the cluster. Status v1.ClusterStatus `protobuf:"varint,8,opt,name=status,proto3,enum=doublecloud.v1.ClusterStatus" json:"status,omitempty"` // Version of ClickHouse DBMS. Version string `protobuf:"bytes,9,opt,name=version,proto3" json:"version,omitempty"` // Resources allocated to the ClickHouse cluster. Resources *ClusterResources `protobuf:"bytes,10,opt,name=resources,proto3" json:"resources,omitempty"` // Connection information. ConnectionInfo *ConnectionInfo `protobuf:"bytes,11,opt,name=connection_info,json=connectionInfo,proto3" json:"connection_info,omitempty"` // Access settings Access *v1.Access `protobuf:"bytes,12,opt,name=access,proto3" json:"access,omitempty"` // Private connection information. PrivateConnectionInfo *PrivateConnectionInfo `` /* 127-byte string literal not displayed */ // DataEncryption settings Encryption *v1.DataEncryption `protobuf:"bytes,14,opt,name=encryption,proto3" json:"encryption,omitempty"` // ID of the network that the ClickHouse cluster belongs to. NetworkId string `protobuf:"bytes,15,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"` // ClickHouse server configuration. ClickhouseConfig *ClickhouseConfig `protobuf:"bytes,16,opt,name=clickhouse_config,json=clickhouseConfig,proto3" json:"clickhouse_config,omitempty"` // Window of maintenance operations. MaintenanceWindow *v1.MaintenanceWindow `protobuf:"bytes,17,opt,name=maintenance_window,json=maintenanceWindow,proto3" json:"maintenance_window,omitempty"` // Maintenance operation planned at nearest maintenance_window. MaintenanceOperation *v1.MaintenanceOperation `protobuf:"bytes,18,opt,name=maintenance_operation,json=maintenanceOperation,proto3" json:"maintenance_operation,omitempty"` // Prometheus JMX exporter endpoint HTTP basic auth information. MetricsExporterConnectionInfo *MetricsExporterConnectionInfo `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
A ClickHouse cluster resource.
func (*Cluster) Descriptor
deprecated
func (*Cluster) GetClickhouseConfig ¶
func (x *Cluster) GetClickhouseConfig() *ClickhouseConfig
func (*Cluster) GetCloudType ¶
func (*Cluster) GetConnectionInfo ¶
func (x *Cluster) GetConnectionInfo() *ConnectionInfo
func (*Cluster) GetCreateTime ¶
func (x *Cluster) GetCreateTime() *timestamppb.Timestamp
func (*Cluster) GetDescription ¶
func (*Cluster) GetEncryption ¶
func (x *Cluster) GetEncryption() *v1.DataEncryption
func (*Cluster) GetMaintenanceOperation ¶
func (x *Cluster) GetMaintenanceOperation() *v1.MaintenanceOperation
func (*Cluster) GetMaintenanceWindow ¶
func (x *Cluster) GetMaintenanceWindow() *v1.MaintenanceWindow
func (*Cluster) GetMetricsExporterConnectionInfo ¶
func (x *Cluster) GetMetricsExporterConnectionInfo() *MetricsExporterConnectionInfo
func (*Cluster) GetNetworkId ¶
func (*Cluster) GetPrivateConnectionInfo ¶
func (x *Cluster) GetPrivateConnectionInfo() *PrivateConnectionInfo
func (*Cluster) GetProjectId ¶
func (*Cluster) GetRegionId ¶
func (*Cluster) GetResources ¶
func (x *Cluster) GetResources() *ClusterResources
func (*Cluster) GetStatus ¶
func (x *Cluster) GetStatus() v1.ClusterStatus
func (*Cluster) GetVersion ¶
func (*Cluster) ProtoMessage ¶
func (*Cluster) ProtoMessage()
func (*Cluster) ProtoReflect ¶
func (x *Cluster) ProtoReflect() protoreflect.Message
type ClusterResources ¶
type ClusterResources struct { // Resources allocated to ClickHouse hosts. Clickhouse *ClusterResources_Clickhouse `protobuf:"bytes,1,opt,name=clickhouse,proto3" json:"clickhouse,omitempty"` // Resources allocated to dedicated ClickHouse Keeper hosts. DedicatedKeeper *ClusterResources_Keeper `protobuf:"bytes,2,opt,name=dedicated_keeper,json=dedicatedKeeper,proto3" json:"dedicated_keeper,omitempty"` // contains filtered or unexported fields }
Resources allocated to ClickHouse cluster.
func (*ClusterResources) Descriptor
deprecated
func (*ClusterResources) Descriptor() ([]byte, []int)
Deprecated: Use ClusterResources.ProtoReflect.Descriptor instead.
func (*ClusterResources) GetClickhouse ¶
func (x *ClusterResources) GetClickhouse() *ClusterResources_Clickhouse
func (*ClusterResources) GetDedicatedKeeper ¶
func (x *ClusterResources) GetDedicatedKeeper() *ClusterResources_Keeper
func (*ClusterResources) ProtoMessage ¶
func (*ClusterResources) ProtoMessage()
func (*ClusterResources) ProtoReflect ¶
func (x *ClusterResources) ProtoReflect() protoreflect.Message
func (*ClusterResources) Reset ¶
func (x *ClusterResources) Reset()
func (*ClusterResources) String ¶
func (x *ClusterResources) String() string
type ClusterResources_Clickhouse ¶
type ClusterResources_Clickhouse struct { // ID of the preset for computational resources available to a host (CPU, memory // etc.). // Means the minimal resource preset for autoscaling. ResourcePresetId string `protobuf:"bytes,1,opt,name=resource_preset_id,json=resourcePresetId,proto3" json:"resource_preset_id,omitempty"` // Volume of the storage available to a host, in bytes. DiskSize *wrapperspb.Int64Value `protobuf:"bytes,2,opt,name=disk_size,json=diskSize,proto3" json:"disk_size,omitempty"` // Number of hosts per shard. ReplicaCount *wrapperspb.Int64Value `protobuf:"bytes,3,opt,name=replica_count,json=replicaCount,proto3" json:"replica_count,omitempty"` // Number of shards in the cluster. ShardCount *wrapperspb.Int64Value `protobuf:"bytes,4,opt,name=shard_count,json=shardCount,proto3" json:"shard_count,omitempty"` // Limit for automatical storage volume scale, in bytes. Autoscaling disabled if // not set. MaxDiskSize *wrapperspb.Int64Value `protobuf:"bytes,5,opt,name=max_disk_size,json=maxDiskSize,proto3" json:"max_disk_size,omitempty"` // Lower limit for automatical resource preset scale. Equal to resource_preset_id // on creation if not set. MinResourcePresetId *wrapperspb.StringValue `protobuf:"bytes,6,opt,name=min_resource_preset_id,json=minResourcePresetId,proto3" json:"min_resource_preset_id,omitempty"` // Upper limit for automatical resource preset scale. Autoscaling disabled if not // set. MaxResourcePresetId *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=max_resource_preset_id,json=maxResourcePresetId,proto3" json:"max_resource_preset_id,omitempty"` // contains filtered or unexported fields }
func (*ClusterResources_Clickhouse) Descriptor
deprecated
func (*ClusterResources_Clickhouse) Descriptor() ([]byte, []int)
Deprecated: Use ClusterResources_Clickhouse.ProtoReflect.Descriptor instead.
func (*ClusterResources_Clickhouse) GetDiskSize ¶
func (x *ClusterResources_Clickhouse) GetDiskSize() *wrapperspb.Int64Value
func (*ClusterResources_Clickhouse) GetMaxDiskSize ¶
func (x *ClusterResources_Clickhouse) GetMaxDiskSize() *wrapperspb.Int64Value
func (*ClusterResources_Clickhouse) GetMaxResourcePresetId ¶
func (x *ClusterResources_Clickhouse) GetMaxResourcePresetId() *wrapperspb.StringValue
func (*ClusterResources_Clickhouse) GetMinResourcePresetId ¶
func (x *ClusterResources_Clickhouse) GetMinResourcePresetId() *wrapperspb.StringValue
func (*ClusterResources_Clickhouse) GetReplicaCount ¶
func (x *ClusterResources_Clickhouse) GetReplicaCount() *wrapperspb.Int64Value
func (*ClusterResources_Clickhouse) GetResourcePresetId ¶
func (x *ClusterResources_Clickhouse) GetResourcePresetId() string
func (*ClusterResources_Clickhouse) GetShardCount ¶
func (x *ClusterResources_Clickhouse) GetShardCount() *wrapperspb.Int64Value
func (*ClusterResources_Clickhouse) ProtoMessage ¶
func (*ClusterResources_Clickhouse) ProtoMessage()
func (*ClusterResources_Clickhouse) ProtoReflect ¶
func (x *ClusterResources_Clickhouse) ProtoReflect() protoreflect.Message
func (*ClusterResources_Clickhouse) Reset ¶
func (x *ClusterResources_Clickhouse) Reset()
func (*ClusterResources_Clickhouse) String ¶
func (x *ClusterResources_Clickhouse) String() string
type ClusterResources_Keeper ¶
type ClusterResources_Keeper struct { // ID of the preset for computational resources available to a host (CPU, memory // etc.). // Means the minimal resource preset for autoscaling. ResourcePresetId string `protobuf:"bytes,1,opt,name=resource_preset_id,json=resourcePresetId,proto3" json:"resource_preset_id,omitempty"` // Volume of the storage available to a host, in bytes. DiskSize *wrapperspb.Int64Value `protobuf:"bytes,2,opt,name=disk_size,json=diskSize,proto3" json:"disk_size,omitempty"` // Number of keeper hosts. ReplicaCount *wrapperspb.Int64Value `protobuf:"bytes,3,opt,name=replica_count,json=replicaCount,proto3" json:"replica_count,omitempty"` // Limit for automatical storage volume scale, in bytes. Autoscaling disabled if // not set. MaxDiskSize *wrapperspb.Int64Value `protobuf:"bytes,5,opt,name=max_disk_size,json=maxDiskSize,proto3" json:"max_disk_size,omitempty"` // Lower limit for automatical resource preset scale. Equal to resource_preset_id // on creation if not set. MinResourcePresetId *wrapperspb.StringValue `protobuf:"bytes,6,opt,name=min_resource_preset_id,json=minResourcePresetId,proto3" json:"min_resource_preset_id,omitempty"` // Upper limit for automatical resource preset scale. Autoscaling disabled if not // set. MaxResourcePresetId *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=max_resource_preset_id,json=maxResourcePresetId,proto3" json:"max_resource_preset_id,omitempty"` // contains filtered or unexported fields }
func (*ClusterResources_Keeper) Descriptor
deprecated
func (*ClusterResources_Keeper) Descriptor() ([]byte, []int)
Deprecated: Use ClusterResources_Keeper.ProtoReflect.Descriptor instead.
func (*ClusterResources_Keeper) GetDiskSize ¶
func (x *ClusterResources_Keeper) GetDiskSize() *wrapperspb.Int64Value
func (*ClusterResources_Keeper) GetMaxDiskSize ¶
func (x *ClusterResources_Keeper) GetMaxDiskSize() *wrapperspb.Int64Value
func (*ClusterResources_Keeper) GetMaxResourcePresetId ¶
func (x *ClusterResources_Keeper) GetMaxResourcePresetId() *wrapperspb.StringValue
func (*ClusterResources_Keeper) GetMinResourcePresetId ¶
func (x *ClusterResources_Keeper) GetMinResourcePresetId() *wrapperspb.StringValue
func (*ClusterResources_Keeper) GetReplicaCount ¶
func (x *ClusterResources_Keeper) GetReplicaCount() *wrapperspb.Int64Value
func (*ClusterResources_Keeper) GetResourcePresetId ¶
func (x *ClusterResources_Keeper) GetResourcePresetId() string
func (*ClusterResources_Keeper) ProtoMessage ¶
func (*ClusterResources_Keeper) ProtoMessage()
func (*ClusterResources_Keeper) ProtoReflect ¶
func (x *ClusterResources_Keeper) ProtoReflect() protoreflect.Message
func (*ClusterResources_Keeper) Reset ¶
func (x *ClusterResources_Keeper) Reset()
func (*ClusterResources_Keeper) String ¶
func (x *ClusterResources_Keeper) String() string
type ClusterServiceClient ¶
type ClusterServiceClient interface { // Returns the specified ClickHouse cluster. Get(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*Cluster, error) // Retrieves a list of ClickHouse clusters that belong to the specified project. List(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error) // Creates a ClickHouse cluster in the specified project. Create(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*v1.Operation, error) // Updates the specified ClickHouse cluster. Update(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*v1.Operation, error) // Deletes the specified ClickHouse cluster. Delete(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*v1.Operation, error) // Reset credentials for the specified cluster. ResetCredentials(ctx context.Context, in *ResetClusterCredentialsRequest, opts ...grpc.CallOption) (*v1.Operation, error) // Retrieves a list of hosts for the specified cluster. ListHosts(ctx context.Context, in *ListClusterHostsRequest, opts ...grpc.CallOption) (*ListClusterHostsResponse, error) // Creates a new ClickHouse cluster from the specified backup. Restore(ctx context.Context, in *RestoreClusterRequest, opts ...grpc.CallOption) (*v1.Operation, error) // Returns the list of available backups for the specified ClickHouse cluster. ListBackups(ctx context.Context, in *ListClusterBackupsRequest, opts ...grpc.CallOption) (*ListClusterBackupsResponse, error) // Starts stopped ClickHouse cluster. Start(ctx context.Context, in *StartClusterRequest, opts ...grpc.CallOption) (*v1.Operation, error) // Stops running ClickHouse cluster. Stop(ctx context.Context, in *StopClusterRequest, opts ...grpc.CallOption) (*v1.Operation, error) // Reschedule planned maintenance operation. RescheduleMaintenance(ctx context.Context, in *RescheduleMaintenanceRequest, opts ...grpc.CallOption) (*v1.Operation, error) // List cluster operations. ListOperations(ctx context.Context, in *ListClusterOperationsRequest, opts ...grpc.CallOption) (*ListClusterOperationsResponse, error) }
ClusterServiceClient is the client API for ClusterService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewClusterServiceClient ¶
func NewClusterServiceClient(cc grpc.ClientConnInterface) ClusterServiceClient
type ClusterServiceServer ¶
type ClusterServiceServer interface { // Returns the specified ClickHouse cluster. Get(context.Context, *GetClusterRequest) (*Cluster, error) // Retrieves a list of ClickHouse clusters that belong to the specified project. List(context.Context, *ListClustersRequest) (*ListClustersResponse, error) // Creates a ClickHouse cluster in the specified project. Create(context.Context, *CreateClusterRequest) (*v1.Operation, error) // Updates the specified ClickHouse cluster. Update(context.Context, *UpdateClusterRequest) (*v1.Operation, error) // Deletes the specified ClickHouse cluster. Delete(context.Context, *DeleteClusterRequest) (*v1.Operation, error) // Reset credentials for the specified cluster. ResetCredentials(context.Context, *ResetClusterCredentialsRequest) (*v1.Operation, error) // Retrieves a list of hosts for the specified cluster. ListHosts(context.Context, *ListClusterHostsRequest) (*ListClusterHostsResponse, error) // Creates a new ClickHouse cluster from the specified backup. Restore(context.Context, *RestoreClusterRequest) (*v1.Operation, error) // Returns the list of available backups for the specified ClickHouse cluster. ListBackups(context.Context, *ListClusterBackupsRequest) (*ListClusterBackupsResponse, error) // Starts stopped ClickHouse cluster. Start(context.Context, *StartClusterRequest) (*v1.Operation, error) // Stops running ClickHouse cluster. Stop(context.Context, *StopClusterRequest) (*v1.Operation, error) // Reschedule planned maintenance operation. RescheduleMaintenance(context.Context, *RescheduleMaintenanceRequest) (*v1.Operation, error) // List cluster operations. ListOperations(context.Context, *ListClusterOperationsRequest) (*ListClusterOperationsResponse, error) // contains filtered or unexported methods }
ClusterServiceServer is the server API for ClusterService service. All implementations must embed UnimplementedClusterServiceServer for forward compatibility
type ClusterView ¶
type ClusterView int32
const ( // Invalid cluster view value. ClusterView_CLUSTER_VIEW_INVALID ClusterView = 0 // Output basic information about the cluster. ClusterView_CLUSTER_VIEW_BASIC ClusterView = 1 // Output full information about the cluster including allocated resources and // ClickHouse settings. ClusterView_CLUSTER_VIEW_FULL ClusterView = 2 )
func (ClusterView) Descriptor ¶
func (ClusterView) Descriptor() protoreflect.EnumDescriptor
func (ClusterView) Enum ¶
func (x ClusterView) Enum() *ClusterView
func (ClusterView) EnumDescriptor
deprecated
func (ClusterView) EnumDescriptor() ([]byte, []int)
Deprecated: Use ClusterView.Descriptor instead.
func (ClusterView) Number ¶
func (x ClusterView) Number() protoreflect.EnumNumber
func (ClusterView) String ¶
func (x ClusterView) String() string
func (ClusterView) Type ¶
func (ClusterView) Type() protoreflect.EnumType
type ConnectionInfo ¶
type ConnectionInfo struct { // Host to connect. Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` // ClickHouse user. User string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"` // Password for ClickHouse user. Password string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"` // Port to connect using HTTPS protocol. HttpsPort *wrapperspb.Int64Value `protobuf:"bytes,4,opt,name=https_port,json=httpsPort,proto3" json:"https_port,omitempty"` // Port to connect using TCP/native protocol. TcpPortSecure *wrapperspb.Int64Value `protobuf:"bytes,5,opt,name=tcp_port_secure,json=tcpPortSecure,proto3" json:"tcp_port_secure,omitempty"` // Connection string for ClickHouse native protocol. NativeProtocol string `protobuf:"bytes,6,opt,name=native_protocol,json=nativeProtocol,proto3" json:"native_protocol,omitempty"` // URI to connect using HTTPS protocol. HttpsUri string `protobuf:"bytes,7,opt,name=https_uri,json=httpsUri,proto3" json:"https_uri,omitempty"` // URI to connect using JDBC protocol. JdbcUri string `protobuf:"bytes,8,opt,name=jdbc_uri,json=jdbcUri,proto3" json:"jdbc_uri,omitempty"` // URI to connect using ODBC protocol. OdbcUri string `protobuf:"bytes,9,opt,name=odbc_uri,json=odbcUri,proto3" json:"odbc_uri,omitempty"` // contains filtered or unexported fields }
func (*ConnectionInfo) Descriptor
deprecated
func (*ConnectionInfo) Descriptor() ([]byte, []int)
Deprecated: Use ConnectionInfo.ProtoReflect.Descriptor instead.
func (*ConnectionInfo) GetHost ¶
func (x *ConnectionInfo) GetHost() string
func (*ConnectionInfo) GetHttpsPort ¶
func (x *ConnectionInfo) GetHttpsPort() *wrapperspb.Int64Value
func (*ConnectionInfo) GetHttpsUri ¶
func (x *ConnectionInfo) GetHttpsUri() string
func (*ConnectionInfo) GetJdbcUri ¶
func (x *ConnectionInfo) GetJdbcUri() string
func (*ConnectionInfo) GetNativeProtocol ¶
func (x *ConnectionInfo) GetNativeProtocol() string
func (*ConnectionInfo) GetOdbcUri ¶
func (x *ConnectionInfo) GetOdbcUri() string
func (*ConnectionInfo) GetPassword ¶
func (x *ConnectionInfo) GetPassword() string
func (*ConnectionInfo) GetTcpPortSecure ¶
func (x *ConnectionInfo) GetTcpPortSecure() *wrapperspb.Int64Value
func (*ConnectionInfo) GetUser ¶
func (x *ConnectionInfo) GetUser() string
func (*ConnectionInfo) ProtoMessage ¶
func (*ConnectionInfo) ProtoMessage()
func (*ConnectionInfo) ProtoReflect ¶
func (x *ConnectionInfo) ProtoReflect() protoreflect.Message
func (*ConnectionInfo) Reset ¶
func (x *ConnectionInfo) Reset()
func (*ConnectionInfo) String ¶
func (x *ConnectionInfo) String() string
type CreateBackupRequest ¶
type CreateBackupRequest struct { // Required. ID of the ClickHouse cluster to back up. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // Optional. Name of the ClickHouse cluster backup. Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*CreateBackupRequest) Descriptor
deprecated
func (*CreateBackupRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateBackupRequest.ProtoReflect.Descriptor instead.
func (*CreateBackupRequest) GetClusterId ¶
func (x *CreateBackupRequest) GetClusterId() string
func (*CreateBackupRequest) GetName ¶
func (x *CreateBackupRequest) GetName() string
func (*CreateBackupRequest) ProtoMessage ¶
func (*CreateBackupRequest) ProtoMessage()
func (*CreateBackupRequest) ProtoReflect ¶
func (x *CreateBackupRequest) ProtoReflect() protoreflect.Message
func (*CreateBackupRequest) Reset ¶
func (x *CreateBackupRequest) Reset()
func (*CreateBackupRequest) String ¶
func (x *CreateBackupRequest) String() string
type CreateClusterRequest ¶
type CreateClusterRequest struct { // ID of the project to create the ClickHouse cluster in. ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` // Type of the cloud where instances should be hosted. CloudType string `protobuf:"bytes,2,opt,name=cloud_type,json=cloudType,proto3" json:"cloud_type,omitempty"` // ID of the region to place instances. RegionId string `protobuf:"bytes,3,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"` // Name of the ClickHouse cluster. The name must be unique within the project. Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` // Description of the ClickHouse cluster. Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"` // Version of ClickHouse DBMS. Version string `protobuf:"bytes,6,opt,name=version,proto3" json:"version,omitempty"` // Resources allocated to the ClickHouse cluster. Resources *ClusterResources `protobuf:"bytes,7,opt,name=resources,proto3" json:"resources,omitempty"` // Access settings Access *v1.Access `protobuf:"bytes,8,opt,name=access,proto3" json:"access,omitempty"` // DataEncryption settings Encryption *v1.DataEncryption `protobuf:"bytes,9,opt,name=encryption,proto3" json:"encryption,omitempty"` // ID of the network to create ClickHouse cluster in. NetworkId string `protobuf:"bytes,10,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"` // ClickHouse server configuration. ClickhouseConfig *ClickhouseConfig `protobuf:"bytes,11,opt,name=clickhouse_config,json=clickhouseConfig,proto3" json:"clickhouse_config,omitempty"` // Window of maintenance operations. MaintenanceWindow *v1.MaintenanceWindow `protobuf:"bytes,12,opt,name=maintenance_window,json=maintenanceWindow,proto3" json:"maintenance_window,omitempty"` // contains filtered or unexported fields }
func (*CreateClusterRequest) Descriptor
deprecated
func (*CreateClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateClusterRequest.ProtoReflect.Descriptor instead.
func (*CreateClusterRequest) GetAccess ¶
func (x *CreateClusterRequest) GetAccess() *v1.Access
func (*CreateClusterRequest) GetClickhouseConfig ¶
func (x *CreateClusterRequest) GetClickhouseConfig() *ClickhouseConfig
func (*CreateClusterRequest) GetCloudType ¶
func (x *CreateClusterRequest) GetCloudType() string
func (*CreateClusterRequest) GetDescription ¶
func (x *CreateClusterRequest) GetDescription() string
func (*CreateClusterRequest) GetEncryption ¶
func (x *CreateClusterRequest) GetEncryption() *v1.DataEncryption
func (*CreateClusterRequest) GetMaintenanceWindow ¶
func (x *CreateClusterRequest) GetMaintenanceWindow() *v1.MaintenanceWindow
func (*CreateClusterRequest) GetName ¶
func (x *CreateClusterRequest) GetName() string
func (*CreateClusterRequest) GetNetworkId ¶
func (x *CreateClusterRequest) GetNetworkId() string
func (*CreateClusterRequest) GetProjectId ¶
func (x *CreateClusterRequest) GetProjectId() string
func (*CreateClusterRequest) GetRegionId ¶
func (x *CreateClusterRequest) GetRegionId() string
func (*CreateClusterRequest) GetResources ¶
func (x *CreateClusterRequest) GetResources() *ClusterResources
func (*CreateClusterRequest) GetVersion ¶
func (x *CreateClusterRequest) GetVersion() string
func (*CreateClusterRequest) ProtoMessage ¶
func (*CreateClusterRequest) ProtoMessage()
func (*CreateClusterRequest) ProtoReflect ¶
func (x *CreateClusterRequest) ProtoReflect() protoreflect.Message
func (*CreateClusterRequest) Reset ¶
func (x *CreateClusterRequest) Reset()
func (*CreateClusterRequest) String ¶
func (x *CreateClusterRequest) String() string
type DeleteBackupRequest ¶
type DeleteBackupRequest struct { // Required. ID of the backup to delete. BackupId string `protobuf:"bytes,1,opt,name=backup_id,json=backupId,proto3" json:"backup_id,omitempty"` // contains filtered or unexported fields }
func (*DeleteBackupRequest) Descriptor
deprecated
func (*DeleteBackupRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteBackupRequest.ProtoReflect.Descriptor instead.
func (*DeleteBackupRequest) GetBackupId ¶
func (x *DeleteBackupRequest) GetBackupId() string
func (*DeleteBackupRequest) ProtoMessage ¶
func (*DeleteBackupRequest) ProtoMessage()
func (*DeleteBackupRequest) ProtoReflect ¶
func (x *DeleteBackupRequest) ProtoReflect() protoreflect.Message
func (*DeleteBackupRequest) Reset ¶
func (x *DeleteBackupRequest) Reset()
func (*DeleteBackupRequest) String ¶
func (x *DeleteBackupRequest) String() string
type DeleteClusterRequest ¶
type DeleteClusterRequest struct { // ID of the ClickHouse cluster to delete. // To get the ClickHouse cluster ID, use a [ClusterService.List] request. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // contains filtered or unexported fields }
func (*DeleteClusterRequest) Descriptor
deprecated
func (*DeleteClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteClusterRequest.ProtoReflect.Descriptor instead.
func (*DeleteClusterRequest) GetClusterId ¶
func (x *DeleteClusterRequest) GetClusterId() string
func (*DeleteClusterRequest) ProtoMessage ¶
func (*DeleteClusterRequest) ProtoMessage()
func (*DeleteClusterRequest) ProtoReflect ¶
func (x *DeleteClusterRequest) ProtoReflect() protoreflect.Message
func (*DeleteClusterRequest) Reset ¶
func (x *DeleteClusterRequest) Reset()
func (*DeleteClusterRequest) String ¶
func (x *DeleteClusterRequest) String() string
type GetBackupRequest ¶
type GetBackupRequest struct { // Required. ID of the backup to return. BackupId string `protobuf:"bytes,1,opt,name=backup_id,json=backupId,proto3" json:"backup_id,omitempty"` // contains filtered or unexported fields }
func (*GetBackupRequest) Descriptor
deprecated
func (*GetBackupRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetBackupRequest.ProtoReflect.Descriptor instead.
func (*GetBackupRequest) GetBackupId ¶
func (x *GetBackupRequest) GetBackupId() string
func (*GetBackupRequest) ProtoMessage ¶
func (*GetBackupRequest) ProtoMessage()
func (*GetBackupRequest) ProtoReflect ¶
func (x *GetBackupRequest) ProtoReflect() protoreflect.Message
func (*GetBackupRequest) Reset ¶
func (x *GetBackupRequest) Reset()
func (*GetBackupRequest) String ¶
func (x *GetBackupRequest) String() string
type GetClusterRequest ¶
type GetClusterRequest struct { // ID of the ClickHouse cluster resource to return. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // Whether to include sensitive data in the response. If unspecified, defaults to // false. Sensitive bool `protobuf:"varint,2,opt,name=sensitive,proto3" json:"sensitive,omitempty"` // contains filtered or unexported fields }
func (*GetClusterRequest) Descriptor
deprecated
func (*GetClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetClusterRequest.ProtoReflect.Descriptor instead.
func (*GetClusterRequest) GetClusterId ¶
func (x *GetClusterRequest) GetClusterId() string
func (*GetClusterRequest) GetSensitive ¶
func (x *GetClusterRequest) GetSensitive() bool
func (*GetClusterRequest) ProtoMessage ¶
func (*GetClusterRequest) ProtoMessage()
func (*GetClusterRequest) ProtoReflect ¶
func (x *GetClusterRequest) ProtoReflect() protoreflect.Message
func (*GetClusterRequest) Reset ¶
func (x *GetClusterRequest) Reset()
func (*GetClusterRequest) String ¶
func (x *GetClusterRequest) String() string
type GetOperationRequest ¶
type GetOperationRequest struct { // Required. ID of the operation to return. OperationId string `protobuf:"bytes,1,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"` // contains filtered or unexported fields }
func (*GetOperationRequest) Descriptor
deprecated
func (*GetOperationRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetOperationRequest.ProtoReflect.Descriptor instead.
func (*GetOperationRequest) GetOperationId ¶
func (x *GetOperationRequest) GetOperationId() string
func (*GetOperationRequest) ProtoMessage ¶
func (*GetOperationRequest) ProtoMessage()
func (*GetOperationRequest) ProtoReflect ¶
func (x *GetOperationRequest) ProtoReflect() protoreflect.Message
func (*GetOperationRequest) Reset ¶
func (x *GetOperationRequest) Reset()
func (*GetOperationRequest) String ¶
func (x *GetOperationRequest) String() string
type Host ¶
type Host struct { // Name of the host. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // ID of the ClickHouse cluster. ClusterId string `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // Name of the shard that the host belongs to. ShardName string `protobuf:"bytes,3,opt,name=shard_name,json=shardName,proto3" json:"shard_name,omitempty"` // Private dns name. PrivateName string `protobuf:"bytes,4,opt,name=private_name,json=privateName,proto3" json:"private_name,omitempty"` // Aggregated host status. Status v1.HostStatus `protobuf:"varint,5,opt,name=status,proto3,enum=doublecloud.v1.HostStatus" json:"status,omitempty"` // contains filtered or unexported fields }
func (*Host) Descriptor
deprecated
func (*Host) GetClusterId ¶
func (*Host) GetPrivateName ¶
func (*Host) GetShardName ¶
func (*Host) GetStatus ¶
func (x *Host) GetStatus() v1.HostStatus
func (*Host) ProtoMessage ¶
func (*Host) ProtoMessage()
func (*Host) ProtoReflect ¶
func (x *Host) ProtoReflect() protoreflect.Message
type ListBackupsRequest ¶
type ListBackupsRequest struct { // Required. ID of the project to list backups in. ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` // Paging information of the request Paging *v1.Paging `protobuf:"bytes,2,opt,name=paging,proto3" json:"paging,omitempty"` // contains filtered or unexported fields }
func (*ListBackupsRequest) Descriptor
deprecated
func (*ListBackupsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListBackupsRequest.ProtoReflect.Descriptor instead.
func (*ListBackupsRequest) GetPaging ¶
func (x *ListBackupsRequest) GetPaging() *v1.Paging
func (*ListBackupsRequest) GetProjectId ¶
func (x *ListBackupsRequest) GetProjectId() string
func (*ListBackupsRequest) ProtoMessage ¶
func (*ListBackupsRequest) ProtoMessage()
func (*ListBackupsRequest) ProtoReflect ¶
func (x *ListBackupsRequest) ProtoReflect() protoreflect.Message
func (*ListBackupsRequest) Reset ¶
func (x *ListBackupsRequest) Reset()
func (*ListBackupsRequest) String ¶
func (x *ListBackupsRequest) String() string
type ListBackupsResponse ¶
type ListBackupsResponse struct { // Requested list of backups. Backups []*Backup `protobuf:"bytes,1,rep,name=backups,proto3" json:"backups,omitempty"` // Pagination information of the response NextPage *v1.NextPage `protobuf:"bytes,2,opt,name=next_page,json=nextPage,proto3" json:"next_page,omitempty"` // contains filtered or unexported fields }
func (*ListBackupsResponse) Descriptor
deprecated
func (*ListBackupsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListBackupsResponse.ProtoReflect.Descriptor instead.
func (*ListBackupsResponse) GetBackups ¶
func (x *ListBackupsResponse) GetBackups() []*Backup
func (*ListBackupsResponse) GetNextPage ¶
func (x *ListBackupsResponse) GetNextPage() *v1.NextPage
func (*ListBackupsResponse) ProtoMessage ¶
func (*ListBackupsResponse) ProtoMessage()
func (*ListBackupsResponse) ProtoReflect ¶
func (x *ListBackupsResponse) ProtoReflect() protoreflect.Message
func (*ListBackupsResponse) Reset ¶
func (x *ListBackupsResponse) Reset()
func (*ListBackupsResponse) String ¶
func (x *ListBackupsResponse) String() string
type ListClusterBackupsRequest ¶
type ListClusterBackupsRequest struct { // Required. ID of the ClickHouse cluster. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // Paging information of the request Paging *v1.Paging `protobuf:"bytes,2,opt,name=paging,proto3" json:"paging,omitempty"` // contains filtered or unexported fields }
func (*ListClusterBackupsRequest) Descriptor
deprecated
func (*ListClusterBackupsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListClusterBackupsRequest.ProtoReflect.Descriptor instead.
func (*ListClusterBackupsRequest) GetClusterId ¶
func (x *ListClusterBackupsRequest) GetClusterId() string
func (*ListClusterBackupsRequest) GetPaging ¶
func (x *ListClusterBackupsRequest) GetPaging() *v1.Paging
func (*ListClusterBackupsRequest) ProtoMessage ¶
func (*ListClusterBackupsRequest) ProtoMessage()
func (*ListClusterBackupsRequest) ProtoReflect ¶
func (x *ListClusterBackupsRequest) ProtoReflect() protoreflect.Message
func (*ListClusterBackupsRequest) Reset ¶
func (x *ListClusterBackupsRequest) Reset()
func (*ListClusterBackupsRequest) String ¶
func (x *ListClusterBackupsRequest) String() string
type ListClusterBackupsResponse ¶
type ListClusterBackupsResponse struct { // Requested list of backups. Backups []*Backup `protobuf:"bytes,1,rep,name=backups,proto3" json:"backups,omitempty"` // Pagination information of the response NextPage *v1.NextPage `protobuf:"bytes,2,opt,name=next_page,json=nextPage,proto3" json:"next_page,omitempty"` // contains filtered or unexported fields }
func (*ListClusterBackupsResponse) Descriptor
deprecated
func (*ListClusterBackupsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListClusterBackupsResponse.ProtoReflect.Descriptor instead.
func (*ListClusterBackupsResponse) GetBackups ¶
func (x *ListClusterBackupsResponse) GetBackups() []*Backup
func (*ListClusterBackupsResponse) GetNextPage ¶
func (x *ListClusterBackupsResponse) GetNextPage() *v1.NextPage
func (*ListClusterBackupsResponse) ProtoMessage ¶
func (*ListClusterBackupsResponse) ProtoMessage()
func (*ListClusterBackupsResponse) ProtoReflect ¶
func (x *ListClusterBackupsResponse) ProtoReflect() protoreflect.Message
func (*ListClusterBackupsResponse) Reset ¶
func (x *ListClusterBackupsResponse) Reset()
func (*ListClusterBackupsResponse) String ¶
func (x *ListClusterBackupsResponse) String() string
type ListClusterHostsRequest ¶
type ListClusterHostsRequest struct { // ID of the ClickHouse cluster to list hosts in. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // Paging information of the request Paging *v1.Paging `protobuf:"bytes,2,opt,name=paging,proto3" json:"paging,omitempty"` // contains filtered or unexported fields }
func (*ListClusterHostsRequest) Descriptor
deprecated
func (*ListClusterHostsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListClusterHostsRequest.ProtoReflect.Descriptor instead.
func (*ListClusterHostsRequest) GetClusterId ¶
func (x *ListClusterHostsRequest) GetClusterId() string
func (*ListClusterHostsRequest) GetPaging ¶
func (x *ListClusterHostsRequest) GetPaging() *v1.Paging
func (*ListClusterHostsRequest) ProtoMessage ¶
func (*ListClusterHostsRequest) ProtoMessage()
func (*ListClusterHostsRequest) ProtoReflect ¶
func (x *ListClusterHostsRequest) ProtoReflect() protoreflect.Message
func (*ListClusterHostsRequest) Reset ¶
func (x *ListClusterHostsRequest) Reset()
func (*ListClusterHostsRequest) String ¶
func (x *ListClusterHostsRequest) String() string
type ListClusterHostsResponse ¶
type ListClusterHostsResponse struct { // Requested list of hosts for the cluster. Hosts []*Host `protobuf:"bytes,1,rep,name=hosts,proto3" json:"hosts,omitempty"` // Pagination information of the response NextPage *v1.NextPage `protobuf:"bytes,2,opt,name=next_page,json=nextPage,proto3" json:"next_page,omitempty"` // contains filtered or unexported fields }
func (*ListClusterHostsResponse) Descriptor
deprecated
func (*ListClusterHostsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListClusterHostsResponse.ProtoReflect.Descriptor instead.
func (*ListClusterHostsResponse) GetHosts ¶
func (x *ListClusterHostsResponse) GetHosts() []*Host
func (*ListClusterHostsResponse) GetNextPage ¶
func (x *ListClusterHostsResponse) GetNextPage() *v1.NextPage
func (*ListClusterHostsResponse) ProtoMessage ¶
func (*ListClusterHostsResponse) ProtoMessage()
func (*ListClusterHostsResponse) ProtoReflect ¶
func (x *ListClusterHostsResponse) ProtoReflect() protoreflect.Message
func (*ListClusterHostsResponse) Reset ¶
func (x *ListClusterHostsResponse) Reset()
func (*ListClusterHostsResponse) String ¶
func (x *ListClusterHostsResponse) String() string
type ListClusterOperationsRequest ¶
type ListClusterOperationsRequest struct { // Required. ID of the ClickHouse cluster. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // Paging information of the request Paging *v1.Paging `protobuf:"bytes,2,opt,name=paging,proto3" json:"paging,omitempty"` // contains filtered or unexported fields }
func (*ListClusterOperationsRequest) Descriptor
deprecated
func (*ListClusterOperationsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListClusterOperationsRequest.ProtoReflect.Descriptor instead.
func (*ListClusterOperationsRequest) GetClusterId ¶
func (x *ListClusterOperationsRequest) GetClusterId() string
func (*ListClusterOperationsRequest) GetPaging ¶
func (x *ListClusterOperationsRequest) GetPaging() *v1.Paging
func (*ListClusterOperationsRequest) ProtoMessage ¶
func (*ListClusterOperationsRequest) ProtoMessage()
func (*ListClusterOperationsRequest) ProtoReflect ¶
func (x *ListClusterOperationsRequest) ProtoReflect() protoreflect.Message
func (*ListClusterOperationsRequest) Reset ¶
func (x *ListClusterOperationsRequest) Reset()
func (*ListClusterOperationsRequest) String ¶
func (x *ListClusterOperationsRequest) String() string
type ListClusterOperationsResponse ¶
type ListClusterOperationsResponse struct { Operations []*v1.Operation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"` // Pagination information of the response NextPage *v1.NextPage `protobuf:"bytes,2,opt,name=next_page,json=nextPage,proto3" json:"next_page,omitempty"` // contains filtered or unexported fields }
func (*ListClusterOperationsResponse) Descriptor
deprecated
func (*ListClusterOperationsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListClusterOperationsResponse.ProtoReflect.Descriptor instead.
func (*ListClusterOperationsResponse) GetNextPage ¶
func (x *ListClusterOperationsResponse) GetNextPage() *v1.NextPage
func (*ListClusterOperationsResponse) GetOperations ¶
func (x *ListClusterOperationsResponse) GetOperations() []*v1.Operation
func (*ListClusterOperationsResponse) ProtoMessage ¶
func (*ListClusterOperationsResponse) ProtoMessage()
func (*ListClusterOperationsResponse) ProtoReflect ¶
func (x *ListClusterOperationsResponse) ProtoReflect() protoreflect.Message
func (*ListClusterOperationsResponse) Reset ¶
func (x *ListClusterOperationsResponse) Reset()
func (*ListClusterOperationsResponse) String ¶
func (x *ListClusterOperationsResponse) String() string
type ListClustersRequest ¶
type ListClustersRequest struct { // ID of the project to list ClickHouse clusters in. ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` // Paging information of the request Paging *v1.Paging `protobuf:"bytes,2,opt,name=paging,proto3" json:"paging,omitempty"` // The level of detail to be returned. If unspecified, defaults to // CLUSTER_VIEW_BASIC. View ClusterView `protobuf:"varint,3,opt,name=view,proto3,enum=doublecloud.clickhouse.v1.ClusterView" json:"view,omitempty"` // contains filtered or unexported fields }
func (*ListClustersRequest) Descriptor
deprecated
func (*ListClustersRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListClustersRequest.ProtoReflect.Descriptor instead.
func (*ListClustersRequest) GetPaging ¶
func (x *ListClustersRequest) GetPaging() *v1.Paging
func (*ListClustersRequest) GetProjectId ¶
func (x *ListClustersRequest) GetProjectId() string
func (*ListClustersRequest) GetView ¶
func (x *ListClustersRequest) GetView() ClusterView
func (*ListClustersRequest) ProtoMessage ¶
func (*ListClustersRequest) ProtoMessage()
func (*ListClustersRequest) ProtoReflect ¶
func (x *ListClustersRequest) ProtoReflect() protoreflect.Message
func (*ListClustersRequest) Reset ¶
func (x *ListClustersRequest) Reset()
func (*ListClustersRequest) String ¶
func (x *ListClustersRequest) String() string
type ListClustersResponse ¶
type ListClustersResponse struct { // List of ClickHouse cluster resources. Clusters []*Cluster `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"` // Pagination information of the response NextPage *v1.NextPage `protobuf:"bytes,2,opt,name=next_page,json=nextPage,proto3" json:"next_page,omitempty"` // contains filtered or unexported fields }
func (*ListClustersResponse) Descriptor
deprecated
func (*ListClustersResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListClustersResponse.ProtoReflect.Descriptor instead.
func (*ListClustersResponse) GetClusters ¶
func (x *ListClustersResponse) GetClusters() []*Cluster
func (*ListClustersResponse) GetNextPage ¶
func (x *ListClustersResponse) GetNextPage() *v1.NextPage
func (*ListClustersResponse) ProtoMessage ¶
func (*ListClustersResponse) ProtoMessage()
func (*ListClustersResponse) ProtoReflect ¶
func (x *ListClustersResponse) ProtoReflect() protoreflect.Message
func (*ListClustersResponse) Reset ¶
func (x *ListClustersResponse) Reset()
func (*ListClustersResponse) String ¶
func (x *ListClustersResponse) String() string
type ListOperationsRequest ¶
type ListOperationsRequest struct { // ID of the project to list clusters operations in. ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` // Paging information of the request Paging *v1.Paging `protobuf:"bytes,2,opt,name=paging,proto3" json:"paging,omitempty"` // contains filtered or unexported fields }
func (*ListOperationsRequest) Descriptor
deprecated
func (*ListOperationsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListOperationsRequest.ProtoReflect.Descriptor instead.
func (*ListOperationsRequest) GetPaging ¶
func (x *ListOperationsRequest) GetPaging() *v1.Paging
func (*ListOperationsRequest) GetProjectId ¶
func (x *ListOperationsRequest) GetProjectId() string
func (*ListOperationsRequest) ProtoMessage ¶
func (*ListOperationsRequest) ProtoMessage()
func (*ListOperationsRequest) ProtoReflect ¶
func (x *ListOperationsRequest) ProtoReflect() protoreflect.Message
func (*ListOperationsRequest) Reset ¶
func (x *ListOperationsRequest) Reset()
func (*ListOperationsRequest) String ¶
func (x *ListOperationsRequest) String() string
type ListOperationsResponse ¶
type ListOperationsResponse struct { // List of operations. Operations []*v1.Operation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"` // Pagination information of the response NextPage *v1.NextPage `protobuf:"bytes,2,opt,name=next_page,json=nextPage,proto3" json:"next_page,omitempty"` // contains filtered or unexported fields }
func (*ListOperationsResponse) Descriptor
deprecated
func (*ListOperationsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListOperationsResponse.ProtoReflect.Descriptor instead.
func (*ListOperationsResponse) GetNextPage ¶
func (x *ListOperationsResponse) GetNextPage() *v1.NextPage
func (*ListOperationsResponse) GetOperations ¶
func (x *ListOperationsResponse) GetOperations() []*v1.Operation
func (*ListOperationsResponse) ProtoMessage ¶
func (*ListOperationsResponse) ProtoMessage()
func (*ListOperationsResponse) ProtoReflect ¶
func (x *ListOperationsResponse) ProtoReflect() protoreflect.Message
func (*ListOperationsResponse) Reset ¶
func (x *ListOperationsResponse) Reset()
func (*ListOperationsResponse) String ¶
func (x *ListOperationsResponse) String() string
type ListVersionsRequest ¶
type ListVersionsRequest struct { // Paging information of the request Paging *v1.Paging `protobuf:"bytes,1,opt,name=paging,proto3" json:"paging,omitempty"` // contains filtered or unexported fields }
func (*ListVersionsRequest) Descriptor
deprecated
func (*ListVersionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListVersionsRequest.ProtoReflect.Descriptor instead.
func (*ListVersionsRequest) GetPaging ¶
func (x *ListVersionsRequest) GetPaging() *v1.Paging
func (*ListVersionsRequest) ProtoMessage ¶
func (*ListVersionsRequest) ProtoMessage()
func (*ListVersionsRequest) ProtoReflect ¶
func (x *ListVersionsRequest) ProtoReflect() protoreflect.Message
func (*ListVersionsRequest) Reset ¶
func (x *ListVersionsRequest) Reset()
func (*ListVersionsRequest) String ¶
func (x *ListVersionsRequest) String() string
type ListVersionsResponse ¶
type ListVersionsResponse struct { // Requested list of available versions. Versions []*Version `protobuf:"bytes,1,rep,name=versions,proto3" json:"versions,omitempty"` // Pagination information of the response NextPage *v1.NextPage `protobuf:"bytes,2,opt,name=next_page,json=nextPage,proto3" json:"next_page,omitempty"` // contains filtered or unexported fields }
func (*ListVersionsResponse) Descriptor
deprecated
func (*ListVersionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListVersionsResponse.ProtoReflect.Descriptor instead.
func (*ListVersionsResponse) GetNextPage ¶
func (x *ListVersionsResponse) GetNextPage() *v1.NextPage
func (*ListVersionsResponse) GetVersions ¶
func (x *ListVersionsResponse) GetVersions() []*Version
func (*ListVersionsResponse) ProtoMessage ¶
func (*ListVersionsResponse) ProtoMessage()
func (*ListVersionsResponse) ProtoReflect ¶
func (x *ListVersionsResponse) ProtoReflect() protoreflect.Message
func (*ListVersionsResponse) Reset ¶
func (x *ListVersionsResponse) Reset()
func (*ListVersionsResponse) String ¶
func (x *ListVersionsResponse) String() string
type MetricsExporterConnectionInfo ¶
type MetricsExporterConnectionInfo struct { // User for HTTP basic auth. User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` // Password for HTTP basic auth. Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"` // contains filtered or unexported fields }
func (*MetricsExporterConnectionInfo) Descriptor
deprecated
func (*MetricsExporterConnectionInfo) Descriptor() ([]byte, []int)
Deprecated: Use MetricsExporterConnectionInfo.ProtoReflect.Descriptor instead.
func (*MetricsExporterConnectionInfo) GetPassword ¶
func (x *MetricsExporterConnectionInfo) GetPassword() string
func (*MetricsExporterConnectionInfo) GetUser ¶
func (x *MetricsExporterConnectionInfo) GetUser() string
func (*MetricsExporterConnectionInfo) ProtoMessage ¶
func (*MetricsExporterConnectionInfo) ProtoMessage()
func (*MetricsExporterConnectionInfo) ProtoReflect ¶
func (x *MetricsExporterConnectionInfo) ProtoReflect() protoreflect.Message
func (*MetricsExporterConnectionInfo) Reset ¶
func (x *MetricsExporterConnectionInfo) Reset()
func (*MetricsExporterConnectionInfo) String ¶
func (x *MetricsExporterConnectionInfo) String() string
type OperationServiceClient ¶
type OperationServiceClient interface { // Returns the specified operation. Get(ctx context.Context, in *GetOperationRequest, opts ...grpc.CallOption) (*v1.Operation, error) // Retrieves a list of operations that belong to the specified project. List(ctx context.Context, in *ListOperationsRequest, opts ...grpc.CallOption) (*ListOperationsResponse, error) }
OperationServiceClient is the client API for OperationService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewOperationServiceClient ¶
func NewOperationServiceClient(cc grpc.ClientConnInterface) OperationServiceClient
type OperationServiceServer ¶
type OperationServiceServer interface { // Returns the specified operation. Get(context.Context, *GetOperationRequest) (*v1.Operation, error) // Retrieves a list of operations that belong to the specified project. List(context.Context, *ListOperationsRequest) (*ListOperationsResponse, error) // contains filtered or unexported methods }
OperationServiceServer is the server API for OperationService service. All implementations must embed UnimplementedOperationServiceServer for forward compatibility
type PrivateConnectionInfo ¶
type PrivateConnectionInfo struct { // Host to connect. Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` // ClickHouse user. User string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"` // Password for ClickHouse user. Password string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"` // Port to connect using HTTPS protocol. HttpsPort *wrapperspb.Int64Value `protobuf:"bytes,4,opt,name=https_port,json=httpsPort,proto3" json:"https_port,omitempty"` // Port to connect using TCP/native protocol. TcpPortSecure *wrapperspb.Int64Value `protobuf:"bytes,5,opt,name=tcp_port_secure,json=tcpPortSecure,proto3" json:"tcp_port_secure,omitempty"` // Connection string for ClickHouse native protocol. NativeProtocol string `protobuf:"bytes,6,opt,name=native_protocol,json=nativeProtocol,proto3" json:"native_protocol,omitempty"` // URI to connect using HTTPS protocol. HttpsUri string `protobuf:"bytes,7,opt,name=https_uri,json=httpsUri,proto3" json:"https_uri,omitempty"` // URI to connect using JDBC protocol. JdbcUri string `protobuf:"bytes,8,opt,name=jdbc_uri,json=jdbcUri,proto3" json:"jdbc_uri,omitempty"` // URI to connect using ODBC protocol. OdbcUri string `protobuf:"bytes,9,opt,name=odbc_uri,json=odbcUri,proto3" json:"odbc_uri,omitempty"` // contains filtered or unexported fields }
func (*PrivateConnectionInfo) Descriptor
deprecated
func (*PrivateConnectionInfo) Descriptor() ([]byte, []int)
Deprecated: Use PrivateConnectionInfo.ProtoReflect.Descriptor instead.
func (*PrivateConnectionInfo) GetHost ¶
func (x *PrivateConnectionInfo) GetHost() string
func (*PrivateConnectionInfo) GetHttpsPort ¶
func (x *PrivateConnectionInfo) GetHttpsPort() *wrapperspb.Int64Value
func (*PrivateConnectionInfo) GetHttpsUri ¶
func (x *PrivateConnectionInfo) GetHttpsUri() string
func (*PrivateConnectionInfo) GetJdbcUri ¶
func (x *PrivateConnectionInfo) GetJdbcUri() string
func (*PrivateConnectionInfo) GetNativeProtocol ¶
func (x *PrivateConnectionInfo) GetNativeProtocol() string
func (*PrivateConnectionInfo) GetOdbcUri ¶
func (x *PrivateConnectionInfo) GetOdbcUri() string
func (*PrivateConnectionInfo) GetPassword ¶
func (x *PrivateConnectionInfo) GetPassword() string
func (*PrivateConnectionInfo) GetTcpPortSecure ¶
func (x *PrivateConnectionInfo) GetTcpPortSecure() *wrapperspb.Int64Value
func (*PrivateConnectionInfo) GetUser ¶
func (x *PrivateConnectionInfo) GetUser() string
func (*PrivateConnectionInfo) ProtoMessage ¶
func (*PrivateConnectionInfo) ProtoMessage()
func (*PrivateConnectionInfo) ProtoReflect ¶
func (x *PrivateConnectionInfo) ProtoReflect() protoreflect.Message
func (*PrivateConnectionInfo) Reset ¶
func (x *PrivateConnectionInfo) Reset()
func (*PrivateConnectionInfo) String ¶
func (x *PrivateConnectionInfo) String() string
type RescheduleMaintenanceRequest ¶
type RescheduleMaintenanceRequest struct { // Required. ID of the ClickHouse cluster to maintenance reschedule. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // Required. The type of reschedule request. RescheduleType v1.RescheduleType `` /* 139-byte string literal not displayed */ // The time for SPECIFIC_TIME reschedule. Limited by two weeks since first time // scheduled. DelayedUntilTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=delayed_until_time,json=delayedUntilTime,proto3" json:"delayed_until_time,omitempty"` // contains filtered or unexported fields }
func (*RescheduleMaintenanceRequest) Descriptor
deprecated
func (*RescheduleMaintenanceRequest) Descriptor() ([]byte, []int)
Deprecated: Use RescheduleMaintenanceRequest.ProtoReflect.Descriptor instead.
func (*RescheduleMaintenanceRequest) GetClusterId ¶
func (x *RescheduleMaintenanceRequest) GetClusterId() string
func (*RescheduleMaintenanceRequest) GetDelayedUntilTime ¶
func (x *RescheduleMaintenanceRequest) GetDelayedUntilTime() *timestamppb.Timestamp
func (*RescheduleMaintenanceRequest) GetRescheduleType ¶
func (x *RescheduleMaintenanceRequest) GetRescheduleType() v1.RescheduleType
func (*RescheduleMaintenanceRequest) ProtoMessage ¶
func (*RescheduleMaintenanceRequest) ProtoMessage()
func (*RescheduleMaintenanceRequest) ProtoReflect ¶
func (x *RescheduleMaintenanceRequest) ProtoReflect() protoreflect.Message
func (*RescheduleMaintenanceRequest) Reset ¶
func (x *RescheduleMaintenanceRequest) Reset()
func (*RescheduleMaintenanceRequest) String ¶
func (x *RescheduleMaintenanceRequest) String() string
type ResetClusterCredentialsRequest ¶
type ResetClusterCredentialsRequest struct { // ID of the ClickHouse cluster to reset credentials. // To get the ClickHouse cluster ID, use a [ClusterService.List] request. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // contains filtered or unexported fields }
func (*ResetClusterCredentialsRequest) Descriptor
deprecated
func (*ResetClusterCredentialsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ResetClusterCredentialsRequest.ProtoReflect.Descriptor instead.
func (*ResetClusterCredentialsRequest) GetClusterId ¶
func (x *ResetClusterCredentialsRequest) GetClusterId() string
func (*ResetClusterCredentialsRequest) ProtoMessage ¶
func (*ResetClusterCredentialsRequest) ProtoMessage()
func (*ResetClusterCredentialsRequest) ProtoReflect ¶
func (x *ResetClusterCredentialsRequest) ProtoReflect() protoreflect.Message
func (*ResetClusterCredentialsRequest) Reset ¶
func (x *ResetClusterCredentialsRequest) Reset()
func (*ResetClusterCredentialsRequest) String ¶
func (x *ResetClusterCredentialsRequest) String() string
type RestoreClusterRequest ¶
type RestoreClusterRequest struct { // Required. ID of the backup to restore from. BackupId string `protobuf:"bytes,1,opt,name=backup_id,json=backupId,proto3" json:"backup_id,omitempty"` // ID of the project to create the ClickHouse cluster in. ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` // ID of the region to place instances. RegionId string `protobuf:"bytes,3,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"` // Name of the ClickHouse cluster. The name must be unique within the project. Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` // Description of the ClickHouse cluster. Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"` // Version of ClickHouse DBMS. Version string `protobuf:"bytes,6,opt,name=version,proto3" json:"version,omitempty"` // Resources allocated to the ClickHouse cluster. Resources *ClusterResources `protobuf:"bytes,7,opt,name=resources,proto3" json:"resources,omitempty"` // Security settings Access *v1.Access `protobuf:"bytes,8,opt,name=access,proto3" json:"access,omitempty"` // DataEncryption settings Encryption *v1.DataEncryption `protobuf:"bytes,9,opt,name=encryption,proto3" json:"encryption,omitempty"` // ID of the network to create ClickHouse cluster in. NetworkId string `protobuf:"bytes,10,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"` // ClickHouse server configuration. ClickhouseConfig *ClickhouseConfig `protobuf:"bytes,11,opt,name=clickhouse_config,json=clickhouseConfig,proto3" json:"clickhouse_config,omitempty"` // Window of maintenance operations. MaintenanceWindow *v1.MaintenanceWindow `protobuf:"bytes,12,opt,name=maintenance_window,json=maintenanceWindow,proto3" json:"maintenance_window,omitempty"` // contains filtered or unexported fields }
func (*RestoreClusterRequest) Descriptor
deprecated
func (*RestoreClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use RestoreClusterRequest.ProtoReflect.Descriptor instead.
func (*RestoreClusterRequest) GetAccess ¶
func (x *RestoreClusterRequest) GetAccess() *v1.Access
func (*RestoreClusterRequest) GetBackupId ¶
func (x *RestoreClusterRequest) GetBackupId() string
func (*RestoreClusterRequest) GetClickhouseConfig ¶
func (x *RestoreClusterRequest) GetClickhouseConfig() *ClickhouseConfig
func (*RestoreClusterRequest) GetDescription ¶
func (x *RestoreClusterRequest) GetDescription() string
func (*RestoreClusterRequest) GetEncryption ¶
func (x *RestoreClusterRequest) GetEncryption() *v1.DataEncryption
func (*RestoreClusterRequest) GetMaintenanceWindow ¶
func (x *RestoreClusterRequest) GetMaintenanceWindow() *v1.MaintenanceWindow
func (*RestoreClusterRequest) GetName ¶
func (x *RestoreClusterRequest) GetName() string
func (*RestoreClusterRequest) GetNetworkId ¶
func (x *RestoreClusterRequest) GetNetworkId() string
func (*RestoreClusterRequest) GetProjectId ¶
func (x *RestoreClusterRequest) GetProjectId() string
func (*RestoreClusterRequest) GetRegionId ¶
func (x *RestoreClusterRequest) GetRegionId() string
func (*RestoreClusterRequest) GetResources ¶
func (x *RestoreClusterRequest) GetResources() *ClusterResources
func (*RestoreClusterRequest) GetVersion ¶
func (x *RestoreClusterRequest) GetVersion() string
func (*RestoreClusterRequest) ProtoMessage ¶
func (*RestoreClusterRequest) ProtoMessage()
func (*RestoreClusterRequest) ProtoReflect ¶
func (x *RestoreClusterRequest) ProtoReflect() protoreflect.Message
func (*RestoreClusterRequest) Reset ¶
func (x *RestoreClusterRequest) Reset()
func (*RestoreClusterRequest) String ¶
func (x *RestoreClusterRequest) String() string
type StartClusterRequest ¶
type StartClusterRequest struct { // ID of the ClickHouse cluster to start. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // contains filtered or unexported fields }
func (*StartClusterRequest) Descriptor
deprecated
func (*StartClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartClusterRequest.ProtoReflect.Descriptor instead.
func (*StartClusterRequest) GetClusterId ¶
func (x *StartClusterRequest) GetClusterId() string
func (*StartClusterRequest) ProtoMessage ¶
func (*StartClusterRequest) ProtoMessage()
func (*StartClusterRequest) ProtoReflect ¶
func (x *StartClusterRequest) ProtoReflect() protoreflect.Message
func (*StartClusterRequest) Reset ¶
func (x *StartClusterRequest) Reset()
func (*StartClusterRequest) String ¶
func (x *StartClusterRequest) String() string
type StopClusterRequest ¶
type StopClusterRequest struct { // ID of the ClickHouse cluster to stop. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // contains filtered or unexported fields }
func (*StopClusterRequest) Descriptor
deprecated
func (*StopClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use StopClusterRequest.ProtoReflect.Descriptor instead.
func (*StopClusterRequest) GetClusterId ¶
func (x *StopClusterRequest) GetClusterId() string
func (*StopClusterRequest) ProtoMessage ¶
func (*StopClusterRequest) ProtoMessage()
func (*StopClusterRequest) ProtoReflect ¶
func (x *StopClusterRequest) ProtoReflect() protoreflect.Message
func (*StopClusterRequest) Reset ¶
func (x *StopClusterRequest) Reset()
func (*StopClusterRequest) String ¶
func (x *StopClusterRequest) String() string
type UnimplementedBackupServiceServer ¶
type UnimplementedBackupServiceServer struct { }
UnimplementedBackupServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedBackupServiceServer) Create ¶
func (UnimplementedBackupServiceServer) Create(context.Context, *CreateBackupRequest) (*v1.Operation, error)
func (UnimplementedBackupServiceServer) Delete ¶
func (UnimplementedBackupServiceServer) Delete(context.Context, *DeleteBackupRequest) (*v1.Operation, error)
func (UnimplementedBackupServiceServer) Get ¶
func (UnimplementedBackupServiceServer) Get(context.Context, *GetBackupRequest) (*Backup, error)
func (UnimplementedBackupServiceServer) List ¶
func (UnimplementedBackupServiceServer) List(context.Context, *ListBackupsRequest) (*ListBackupsResponse, error)
type UnimplementedClusterServiceServer ¶
type UnimplementedClusterServiceServer struct { }
UnimplementedClusterServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedClusterServiceServer) Create ¶
func (UnimplementedClusterServiceServer) Create(context.Context, *CreateClusterRequest) (*v1.Operation, error)
func (UnimplementedClusterServiceServer) Delete ¶
func (UnimplementedClusterServiceServer) Delete(context.Context, *DeleteClusterRequest) (*v1.Operation, error)
func (UnimplementedClusterServiceServer) Get ¶
func (UnimplementedClusterServiceServer) Get(context.Context, *GetClusterRequest) (*Cluster, error)
func (UnimplementedClusterServiceServer) List ¶
func (UnimplementedClusterServiceServer) List(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
func (UnimplementedClusterServiceServer) ListBackups ¶
func (UnimplementedClusterServiceServer) ListBackups(context.Context, *ListClusterBackupsRequest) (*ListClusterBackupsResponse, error)
func (UnimplementedClusterServiceServer) ListHosts ¶
func (UnimplementedClusterServiceServer) ListHosts(context.Context, *ListClusterHostsRequest) (*ListClusterHostsResponse, error)
func (UnimplementedClusterServiceServer) ListOperations ¶
func (UnimplementedClusterServiceServer) ListOperations(context.Context, *ListClusterOperationsRequest) (*ListClusterOperationsResponse, error)
func (UnimplementedClusterServiceServer) RescheduleMaintenance ¶
func (UnimplementedClusterServiceServer) RescheduleMaintenance(context.Context, *RescheduleMaintenanceRequest) (*v1.Operation, error)
func (UnimplementedClusterServiceServer) ResetCredentials ¶
func (UnimplementedClusterServiceServer) ResetCredentials(context.Context, *ResetClusterCredentialsRequest) (*v1.Operation, error)
func (UnimplementedClusterServiceServer) Restore ¶
func (UnimplementedClusterServiceServer) Restore(context.Context, *RestoreClusterRequest) (*v1.Operation, error)
func (UnimplementedClusterServiceServer) Start ¶
func (UnimplementedClusterServiceServer) Start(context.Context, *StartClusterRequest) (*v1.Operation, error)
func (UnimplementedClusterServiceServer) Stop ¶
func (UnimplementedClusterServiceServer) Stop(context.Context, *StopClusterRequest) (*v1.Operation, error)
func (UnimplementedClusterServiceServer) Update ¶
func (UnimplementedClusterServiceServer) Update(context.Context, *UpdateClusterRequest) (*v1.Operation, error)
type UnimplementedOperationServiceServer ¶
type UnimplementedOperationServiceServer struct { }
UnimplementedOperationServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedOperationServiceServer) Get ¶
func (UnimplementedOperationServiceServer) Get(context.Context, *GetOperationRequest) (*v1.Operation, error)
type UnimplementedVersionServiceServer ¶
type UnimplementedVersionServiceServer struct { }
UnimplementedVersionServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedVersionServiceServer) List ¶
func (UnimplementedVersionServiceServer) List(context.Context, *ListVersionsRequest) (*ListVersionsResponse, error)
type UnsafeBackupServiceServer ¶
type UnsafeBackupServiceServer interface {
// contains filtered or unexported methods
}
UnsafeBackupServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BackupServiceServer will result in compilation errors.
type UnsafeClusterServiceServer ¶
type UnsafeClusterServiceServer interface {
// contains filtered or unexported methods
}
UnsafeClusterServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClusterServiceServer will result in compilation errors.
type UnsafeOperationServiceServer ¶
type UnsafeOperationServiceServer interface {
// contains filtered or unexported methods
}
UnsafeOperationServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OperationServiceServer will result in compilation errors.
type UnsafeVersionServiceServer ¶
type UnsafeVersionServiceServer interface {
// contains filtered or unexported methods
}
UnsafeVersionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to VersionServiceServer will result in compilation errors.
type UpdateClusterRequest ¶
type UpdateClusterRequest struct { // ID of the ClickHouse cluster resource to update. // To get the ClickHouse cluster ID, use a [ClusterService.List] request. ClusterId string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"` // New name for the cluster. Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // New description of the ClickHouse cluster. Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` // Version of ClickHouse DBMS. Version string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"` // Resources allocated to the ClickHouse cluster. Resources *ClusterResources `protobuf:"bytes,5,opt,name=resources,proto3" json:"resources,omitempty"` // Access settings Access *v1.Access `protobuf:"bytes,6,opt,name=access,proto3" json:"access,omitempty"` // ClickHouse server configuration. ClickhouseConfig *ClickhouseConfig `protobuf:"bytes,7,opt,name=clickhouse_config,json=clickhouseConfig,proto3" json:"clickhouse_config,omitempty"` // Window of maintenance operations. MaintenanceWindow *v1.MaintenanceWindow `protobuf:"bytes,8,opt,name=maintenance_window,json=maintenanceWindow,proto3" json:"maintenance_window,omitempty"` // contains filtered or unexported fields }
func (*UpdateClusterRequest) Descriptor
deprecated
func (*UpdateClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateClusterRequest.ProtoReflect.Descriptor instead.
func (*UpdateClusterRequest) GetAccess ¶
func (x *UpdateClusterRequest) GetAccess() *v1.Access
func (*UpdateClusterRequest) GetClickhouseConfig ¶
func (x *UpdateClusterRequest) GetClickhouseConfig() *ClickhouseConfig
func (*UpdateClusterRequest) GetClusterId ¶
func (x *UpdateClusterRequest) GetClusterId() string
func (*UpdateClusterRequest) GetDescription ¶
func (x *UpdateClusterRequest) GetDescription() string
func (*UpdateClusterRequest) GetMaintenanceWindow ¶
func (x *UpdateClusterRequest) GetMaintenanceWindow() *v1.MaintenanceWindow
func (*UpdateClusterRequest) GetName ¶
func (x *UpdateClusterRequest) GetName() string
func (*UpdateClusterRequest) GetResources ¶
func (x *UpdateClusterRequest) GetResources() *ClusterResources
func (*UpdateClusterRequest) GetVersion ¶
func (x *UpdateClusterRequest) GetVersion() string
func (*UpdateClusterRequest) ProtoMessage ¶
func (*UpdateClusterRequest) ProtoMessage()
func (*UpdateClusterRequest) ProtoReflect ¶
func (x *UpdateClusterRequest) ProtoReflect() protoreflect.Message
func (*UpdateClusterRequest) Reset ¶
func (x *UpdateClusterRequest) Reset()
func (*UpdateClusterRequest) String ¶
func (x *UpdateClusterRequest) String() string
type Version ¶
type Version struct { // ID of the version. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Name of the version. Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // Whether version is deprecated. Deprecated bool `protobuf:"varint,3,opt,name=deprecated,proto3" json:"deprecated,omitempty"` // List of versions that can be updated from current. UpdatableTo []string `protobuf:"bytes,4,rep,name=updatable_to,json=updatableTo,proto3" json:"updatable_to,omitempty"` // contains filtered or unexported fields }
func (*Version) Descriptor
deprecated
func (*Version) GetDeprecated ¶
func (*Version) GetUpdatableTo ¶
func (*Version) ProtoMessage ¶
func (*Version) ProtoMessage()
func (*Version) ProtoReflect ¶
func (x *Version) ProtoReflect() protoreflect.Message
type VersionServiceClient ¶
type VersionServiceClient interface { // Returns list of available ClickHouse versions. List(ctx context.Context, in *ListVersionsRequest, opts ...grpc.CallOption) (*ListVersionsResponse, error) }
VersionServiceClient is the client API for VersionService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewVersionServiceClient ¶
func NewVersionServiceClient(cc grpc.ClientConnInterface) VersionServiceClient
type VersionServiceServer ¶
type VersionServiceServer interface { // Returns list of available ClickHouse versions. List(context.Context, *ListVersionsRequest) (*ListVersionsResponse, error) // contains filtered or unexported methods }
VersionServiceServer is the server API for VersionService service. All implementations must embed UnimplementedVersionServiceServer for forward compatibility