clickhouse

package
v0.0.0-...-6dec05a Latest Latest
Warning

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

Go to latest
Published: May 1, 2024 License: Apache-2.0 Imports: 12 Imported by: 3

Documentation

Index

Constants

View Source
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"
)
View Source
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"
)
View Source
const (
	OperationService_Get_FullMethodName  = "/doublecloud.clickhouse.v1.OperationService/Get"
	OperationService_List_FullMethodName = "/doublecloud.clickhouse.v1.OperationService/List"
)
View Source
const (
	VersionService_List_FullMethodName = "/doublecloud.clickhouse.v1.VersionService/List"
)

Variables

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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)

View Source
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)

View Source
var File_doublecloud_clickhouse_v1_backup_proto protoreflect.FileDescriptor
View Source
var File_doublecloud_clickhouse_v1_backup_service_proto protoreflect.FileDescriptor
View Source
var File_doublecloud_clickhouse_v1_cluster_proto protoreflect.FileDescriptor
View Source
var File_doublecloud_clickhouse_v1_cluster_service_proto protoreflect.FileDescriptor
View Source
var File_doublecloud_clickhouse_v1_config_proto protoreflect.FileDescriptor
View Source
var File_doublecloud_clickhouse_v1_operation_service_proto protoreflect.FileDescriptor
View Source
var File_doublecloud_clickhouse_v1_version_proto protoreflect.FileDescriptor
View Source
var File_doublecloud_clickhouse_v1_version_service_proto protoreflect.FileDescriptor
View Source
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)

View Source
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) Descriptor() ([]byte, []int)

Deprecated: Use Backup.ProtoReflect.Descriptor instead.

func (*Backup) GetCreateTime

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

func (*Backup) GetId

func (x *Backup) GetId() string

func (*Backup) GetName

func (x *Backup) GetName() string

func (*Backup) GetProjectId

func (x *Backup) GetProjectId() string

func (*Backup) GetSize

func (x *Backup) GetSize() int64

func (*Backup) GetSourceClusterId

func (x *Backup) GetSourceClusterId() string

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

func (*Backup) Reset

func (x *Backup) Reset()

func (*Backup) String

func (x *Backup) String() string

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.

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

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 (*ClickhouseConfig) GetKafkaTopics

func (x *ClickhouseConfig) GetKafkaTopics() map[string]*ClickhouseConfig_Kafka

func (*ClickhouseConfig) GetKeepAliveTimeout

func (x *ClickhouseConfig) GetKeepAliveTimeout() *durationpb.Duration

func (*ClickhouseConfig) GetLogLevel

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 (*ClickhouseConfig_Compression) GetMethod

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 (*ClickhouseConfig_Compression) Reset

func (x *ClickhouseConfig_Compression) Reset()

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

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 (ClickhouseConfig_Compression_Method) String

func (ClickhouseConfig_Compression_Method) Type

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 (*ClickhouseConfig_GraphiteRollup) ProtoMessage

func (*ClickhouseConfig_GraphiteRollup) ProtoMessage()

func (*ClickhouseConfig_GraphiteRollup) ProtoReflect

func (*ClickhouseConfig_GraphiteRollup) Reset

func (*ClickhouseConfig_GraphiteRollup) 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 (*ClickhouseConfig_GraphiteRollup_Pattern) GetRegexp

func (*ClickhouseConfig_GraphiteRollup_Pattern) GetRetention

func (*ClickhouseConfig_GraphiteRollup_Pattern) ProtoMessage

func (*ClickhouseConfig_GraphiteRollup_Pattern) ProtoReflect

func (*ClickhouseConfig_GraphiteRollup_Pattern) Reset

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

Deprecated: Use ClickhouseConfig_GraphiteRollup_Pattern_Retention.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) GetAge

func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) GetPrecision

func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) ProtoMessage

func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) ProtoReflect

func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) Reset

func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) 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 (*ClickhouseConfig_HybridStorage) Reset

func (x *ClickhouseConfig_HybridStorage) Reset()

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

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 (ClickhouseConfig_Kafka_SaslMechanism) String

func (ClickhouseConfig_Kafka_SaslMechanism) Type

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

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 (ClickhouseConfig_Kafka_SecurityProtocol) String

func (ClickhouseConfig_Kafka_SecurityProtocol) Type

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

func (ClickhouseConfig_LogLevel) EnumDescriptor deprecated

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

Deprecated: Use ClickhouseConfig_LogLevel.Descriptor instead.

func (ClickhouseConfig_LogLevel) Number

func (ClickhouseConfig_LogLevel) String

func (x ClickhouseConfig_LogLevel) String() string

func (ClickhouseConfig_LogLevel) Type

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 (*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 (*ClickhouseConfig_Rabbitmq) GetUsername

func (*ClickhouseConfig_Rabbitmq) GetVhost

func (*ClickhouseConfig_Rabbitmq) ProtoMessage

func (*ClickhouseConfig_Rabbitmq) ProtoMessage()

func (*ClickhouseConfig_Rabbitmq) ProtoReflect

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) Descriptor() ([]byte, []int)

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

func (*Cluster) GetAccess

func (x *Cluster) GetAccess() *v1.Access

func (*Cluster) GetClickhouseConfig

func (x *Cluster) GetClickhouseConfig() *ClickhouseConfig

func (*Cluster) GetCloudType

func (x *Cluster) GetCloudType() string

func (*Cluster) GetConnectionInfo

func (x *Cluster) GetConnectionInfo() *ConnectionInfo

func (*Cluster) GetCreateTime

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

func (*Cluster) GetDescription

func (x *Cluster) GetDescription() string

func (*Cluster) GetEncryption

func (x *Cluster) GetEncryption() *v1.DataEncryption

func (*Cluster) GetId

func (x *Cluster) GetId() string

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

func (x *Cluster) GetName() string

func (*Cluster) GetNetworkId

func (x *Cluster) GetNetworkId() string

func (*Cluster) GetPrivateConnectionInfo

func (x *Cluster) GetPrivateConnectionInfo() *PrivateConnectionInfo

func (*Cluster) GetProjectId

func (x *Cluster) GetProjectId() string

func (*Cluster) GetRegionId

func (x *Cluster) GetRegionId() string

func (*Cluster) GetResources

func (x *Cluster) GetResources() *ClusterResources

func (*Cluster) GetStatus

func (x *Cluster) GetStatus() v1.ClusterStatus

func (*Cluster) GetVersion

func (x *Cluster) GetVersion() string

func (*Cluster) ProtoMessage

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect

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

func (*Cluster) Reset

func (x *Cluster) Reset()

func (*Cluster) String

func (x *Cluster) String() string

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 (*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 (*ClusterResources_Clickhouse) ProtoMessage

func (*ClusterResources_Clickhouse) ProtoMessage()

func (*ClusterResources_Clickhouse) ProtoReflect

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.

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

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) Descriptor() ([]byte, []int)

Deprecated: Use Host.ProtoReflect.Descriptor instead.

func (*Host) GetClusterId

func (x *Host) GetClusterId() string

func (*Host) GetName

func (x *Host) GetName() string

func (*Host) GetPrivateName

func (x *Host) GetPrivateName() string

func (*Host) GetShardName

func (x *Host) GetShardName() string

func (*Host) GetStatus

func (x *Host) GetStatus() v1.HostStatus

func (*Host) ProtoMessage

func (*Host) ProtoMessage()

func (*Host) ProtoReflect

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

func (*Host) Reset

func (x *Host) Reset()

func (*Host) String

func (x *Host) String() string

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 (*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 (*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 (*ListClusterOperationsRequest) Reset

func (x *ListClusterOperationsRequest) Reset()

func (*ListClusterOperationsRequest) 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 (*ListClusterOperationsResponse) Reset

func (x *ListClusterOperationsResponse) Reset()

func (*ListClusterOperationsResponse) 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 (*MetricsExporterConnectionInfo) ProtoMessage

func (*MetricsExporterConnectionInfo) ProtoMessage()

func (*MetricsExporterConnectionInfo) ProtoReflect

func (*MetricsExporterConnectionInfo) Reset

func (x *MetricsExporterConnectionInfo) Reset()

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

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 (*RescheduleMaintenanceRequest) Reset

func (x *RescheduleMaintenanceRequest) Reset()

func (*RescheduleMaintenanceRequest) 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 (*ResetClusterCredentialsRequest) Reset

func (x *ResetClusterCredentialsRequest) Reset()

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

func (UnimplementedBackupServiceServer) Get

func (UnimplementedBackupServiceServer) List

type UnimplementedClusterServiceServer

type UnimplementedClusterServiceServer struct {
}

UnimplementedClusterServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedClusterServiceServer) Create

func (UnimplementedClusterServiceServer) Delete

func (UnimplementedClusterServiceServer) Get

func (UnimplementedClusterServiceServer) List

func (UnimplementedClusterServiceServer) ListHosts

func (UnimplementedClusterServiceServer) RescheduleMaintenance

func (UnimplementedClusterServiceServer) ResetCredentials

func (UnimplementedClusterServiceServer) Restore

func (UnimplementedClusterServiceServer) Start

func (UnimplementedClusterServiceServer) Stop

func (UnimplementedClusterServiceServer) Update

type UnimplementedOperationServiceServer

type UnimplementedOperationServiceServer struct {
}

UnimplementedOperationServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedOperationServiceServer) Get

func (UnimplementedOperationServiceServer) List

type UnimplementedVersionServiceServer

type UnimplementedVersionServiceServer struct {
}

UnimplementedVersionServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedVersionServiceServer) List

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) Descriptor() ([]byte, []int)

Deprecated: Use Version.ProtoReflect.Descriptor instead.

func (*Version) GetDeprecated

func (x *Version) GetDeprecated() bool

func (*Version) GetId

func (x *Version) GetId() string

func (*Version) GetName

func (x *Version) GetName() string

func (*Version) GetUpdatableTo

func (x *Version) GetUpdatableTo() []string

func (*Version) ProtoMessage

func (*Version) ProtoMessage()

func (*Version) ProtoReflect

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

func (*Version) Reset

func (x *Version) Reset()

func (*Version) String

func (x *Version) String() string

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.

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

Jump to

Keyboard shortcuts

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