clickhouse

package
v0.0.0-...-a04abcf Latest Latest
Warning

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

Go to latest
Published: Apr 15, 2024 License: MIT Imports: 6 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ClickhouseConfig_LogLevel_name = map[int32]string{
		0: "LOG_LEVEL_UNSPECIFIED",
		1: "TRACE",
		2: "DEBUG",
		3: "INFORMATION",
		4: "WARNING",
		5: "ERROR",
	}
	ClickhouseConfig_LogLevel_value = map[string]int32{
		"LOG_LEVEL_UNSPECIFIED": 0,
		"TRACE":                 1,
		"DEBUG":                 2,
		"INFORMATION":           3,
		"WARNING":               4,
		"ERROR":                 5,
	}
)

Enum value maps for ClickhouseConfig_LogLevel.

View Source
var (
	ClickhouseConfig_Kafka_SecurityProtocol_name = map[int32]string{
		0: "SECURITY_PROTOCOL_UNSPECIFIED",
		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_UNSPECIFIED":    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_UNSPECIFIED",
		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_UNSPECIFIED":   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_UNSPECIFIED",
		1: "LZ4",
		2: "ZSTD",
	}
	ClickhouseConfig_Compression_Method_value = map[string]int32{
		"METHOD_UNSPECIFIED": 0,
		"LZ4":                1,
		"ZSTD":               2,
	}
)

Enum value maps for ClickhouseConfig_Compression_Method.

View Source
var (
	ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode_name = map[int32]string{
		0: "SSL_MODE_UNSPECIFIED",
		1: "DISABLE",
		2: "ALLOW",
		3: "PREFER",
		4: "VERIFY_CA",
		5: "VERIFY_FULL",
	}
	ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode_value = map[string]int32{
		"SSL_MODE_UNSPECIFIED": 0,
		"DISABLE":              1,
		"ALLOW":                2,
		"PREFER":               3,
		"VERIFY_CA":            4,
		"VERIFY_FULL":          5,
	}
)

Enum value maps for ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode.

View Source
var (
	ClickhouseConfig_ExternalDictionary_Layout_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "FLAT",
		2: "HASHED",
		3: "COMPLEX_KEY_HASHED",
		4: "RANGE_HASHED",
		5: "CACHE",
		6: "COMPLEX_KEY_CACHE",
	}
	ClickhouseConfig_ExternalDictionary_Layout_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED":   0,
		"FLAT":               1,
		"HASHED":             2,
		"COMPLEX_KEY_HASHED": 3,
		"RANGE_HASHED":       4,
		"CACHE":              5,
		"COMPLEX_KEY_CACHE":  6,
	}
)

Enum value maps for ClickhouseConfig_ExternalDictionary_Layout_Type.

View Source
var File_yandex_cloud_mdb_clickhouse_v1_config_clickhouse_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ClickhouseConfig

type ClickhouseConfig struct {

	// Logging level for the ClickHouse cluster. Possible values: TRACE, DEBUG, INFORMATION, WARNING, ERROR.
	LogLevel ClickhouseConfig_LogLevel `` /* 155-byte string literal not displayed */
	// Settings for the MergeTree engine.
	// See description in [ClickHouse documentation](https://clickhouse.com/docs/en/operations/server_settings/settings/#merge_tree).
	MergeTree *ClickhouseConfig_MergeTree `protobuf:"bytes,2,opt,name=merge_tree,json=mergeTree,proto3" json:"merge_tree,omitempty"`
	// Compression settings for the ClickHouse cluster.
	// See in-depth description in [ClickHouse documentation](https://clickhouse.com/docs/en/operations/server_settings/settings/#compression).
	Compression []*ClickhouseConfig_Compression `protobuf:"bytes,3,rep,name=compression,proto3" json:"compression,omitempty"`
	// Configuration of external dictionaries to be used by the ClickHouse cluster.
	// See in-depth description in [ClickHouse documentation](https://clickhouse.com/docs/en/query_language/dicts/external_dicts/).
	Dictionaries []*ClickhouseConfig_ExternalDictionary `protobuf:"bytes,4,rep,name=dictionaries,proto3" json:"dictionaries,omitempty"`
	// Settings for thinning Graphite data.
	// See in-depth description in [ClickHouse documentation](https://clickhouse.com/docs/en/operations/server_settings/settings/#server_settings-graphite_rollup).
	GraphiteRollup []*ClickhouseConfig_GraphiteRollup `protobuf:"bytes,5,rep,name=graphite_rollup,json=graphiteRollup,proto3" json:"graphite_rollup,omitempty"`
	Kafka          *ClickhouseConfig_Kafka            `protobuf:"bytes,35,opt,name=kafka,proto3" json:"kafka,omitempty"`
	KafkaTopics    []*ClickhouseConfig_KafkaTopic     `protobuf:"bytes,36,rep,name=kafka_topics,json=kafkaTopics,proto3" json:"kafka_topics,omitempty"`
	Rabbitmq       *ClickhouseConfig_Rabbitmq         `protobuf:"bytes,37,opt,name=rabbitmq,proto3" json:"rabbitmq,omitempty"`
	// Maximum number of inbound connections.
	MaxConnections *wrapperspb.Int64Value `protobuf:"bytes,6,opt,name=max_connections,json=maxConnections,proto3" json:"max_connections,omitempty"`
	// Maximum number of simultaneously processed requests.
	MaxConcurrentQueries *wrapperspb.Int64Value `protobuf:"bytes,7,opt,name=max_concurrent_queries,json=maxConcurrentQueries,proto3" json:"max_concurrent_queries,omitempty"`
	// Number of milliseconds that ClickHouse waits for incoming requests before closing the connection.
	KeepAliveTimeout *wrapperspb.Int64Value `protobuf:"bytes,8,opt,name=keep_alive_timeout,json=keepAliveTimeout,proto3" json:"keep_alive_timeout,omitempty"`
	// Cache size (in bytes) for uncompressed data used by MergeTree tables.
	UncompressedCacheSize *wrapperspb.Int64Value `` /* 126-byte string literal not displayed */
	// Approximate size (in bytes) of the cache of "marks" used by MergeTree tables.
	MarkCacheSize *wrapperspb.Int64Value `protobuf:"bytes,10,opt,name=mark_cache_size,json=markCacheSize,proto3" json:"mark_cache_size,omitempty"`
	// Maximum size of the table that can be deleted using a DROP query.
	MaxTableSizeToDrop *wrapperspb.Int64Value `protobuf:"bytes,11,opt,name=max_table_size_to_drop,json=maxTableSizeToDrop,proto3" json:"max_table_size_to_drop,omitempty"`
	// Maximum size of the partition that can be deleted using a DROP query.
	MaxPartitionSizeToDrop *wrapperspb.Int64Value `` /* 134-byte string literal not displayed */
	// The setting is deprecated and has no effect.
	//
	// Deprecated: Marked as deprecated in yandex/cloud/mdb/clickhouse/v1/config/clickhouse.proto.
	BuiltinDictionariesReloadInterval *wrapperspb.Int64Value `` /* 165-byte string literal not displayed */
	// The server's time zone to be used in DateTime fields conversions. Specified as an IANA identifier.
	Timezone string `protobuf:"bytes,14,opt,name=timezone,proto3" json:"timezone,omitempty"`
	// Enable or disable geobase.
	GeobaseEnabled *wrapperspb.BoolValue `protobuf:"bytes,66,opt,name=geobase_enabled,json=geobaseEnabled,proto3" json:"geobase_enabled,omitempty"`
	// Address of the archive with the user geobase in Object Storage.
	GeobaseUri string `protobuf:"bytes,15,opt,name=geobase_uri,json=geobaseUri,proto3" json:"geobase_uri,omitempty"`
	// The maximum size that query_log can grow to before old data will be removed. If set to 0, automatic removal of
	// query_log data based on size is disabled.
	QueryLogRetentionSize *wrapperspb.Int64Value `` /* 129-byte string literal not displayed */
	// The maximum time that query_log records will be retained before removal. If set to 0, automatic removal of
	// query_log data based on time is disabled.
	QueryLogRetentionTime *wrapperspb.Int64Value `` /* 129-byte string literal not displayed */
	// Whether query_thread_log system table is enabled.
	QueryThreadLogEnabled *wrapperspb.BoolValue `` /* 129-byte string literal not displayed */
	// The maximum size that query_thread_log can grow to before old data will be removed. If set to 0, automatic removal of
	// query_thread_log data based on size is disabled.
	QueryThreadLogRetentionSize *wrapperspb.Int64Value `` /* 149-byte string literal not displayed */
	// The maximum time that query_thread_log records will be retained before removal. If set to 0, automatic removal of
	// query_thread_log data based on time is disabled.
	QueryThreadLogRetentionTime *wrapperspb.Int64Value `` /* 149-byte string literal not displayed */
	// The maximum size that part_log can grow to before old data will be removed. If set to 0, automatic removal of
	// part_log data based on size is disabled.
	PartLogRetentionSize *wrapperspb.Int64Value `` /* 126-byte string literal not displayed */
	// The maximum time that part_log records will be retained before removal. If set to 0, automatic removal of
	// part_log data based on time is disabled.
	PartLogRetentionTime *wrapperspb.Int64Value `` /* 126-byte string literal not displayed */
	// Whether metric_log system table is enabled.
	MetricLogEnabled *wrapperspb.BoolValue `protobuf:"bytes,23,opt,name=metric_log_enabled,json=metricLogEnabled,proto3" json:"metric_log_enabled,omitempty"`
	// The maximum size that metric_log can grow to before old data will be removed. If set to 0, automatic removal of
	// metric_log data based on size is disabled.
	MetricLogRetentionSize *wrapperspb.Int64Value `` /* 132-byte string literal not displayed */
	// The maximum time that metric_log records will be retained before removal. If set to 0, automatic removal of
	// metric_log data based on time is disabled.
	MetricLogRetentionTime *wrapperspb.Int64Value `` /* 132-byte string literal not displayed */
	// Whether trace_log system table is enabled.
	TraceLogEnabled *wrapperspb.BoolValue `protobuf:"bytes,26,opt,name=trace_log_enabled,json=traceLogEnabled,proto3" json:"trace_log_enabled,omitempty"`
	// The maximum size that trace_log can grow to before old data will be removed. If set to 0, automatic removal of
	// trace_log data based on size is disabled.
	TraceLogRetentionSize *wrapperspb.Int64Value `` /* 129-byte string literal not displayed */
	// The maximum time that trace_log records will be retained before removal. If set to 0, automatic removal of
	// trace_log data based on time is disabled.
	TraceLogRetentionTime *wrapperspb.Int64Value `` /* 129-byte string literal not displayed */
	// Whether text_log system table is enabled.
	TextLogEnabled *wrapperspb.BoolValue `protobuf:"bytes,29,opt,name=text_log_enabled,json=textLogEnabled,proto3" json:"text_log_enabled,omitempty"`
	// The maximum size that text_log can grow to before old data will be removed. If set to 0, automatic removal of
	// text_log data based on size is disabled.
	TextLogRetentionSize *wrapperspb.Int64Value `` /* 126-byte string literal not displayed */
	// The maximum time that text_log records will be retained before removal. If set to 0, automatic removal of
	// text_log data based on time is disabled.
	TextLogRetentionTime *wrapperspb.Int64Value `` /* 126-byte string literal not displayed */
	// Logging level for text_log system table. Possible values: TRACE, DEBUG, INFORMATION, WARNING, ERROR.
	TextLogLevel ClickhouseConfig_LogLevel `` /* 170-byte string literal not displayed */
	// Enable or disable opentelemetry_span_log system table. Default value: false.
	OpentelemetrySpanLogEnabled *wrapperspb.BoolValue `` /* 147-byte string literal not displayed */
	// The maximum size that opentelemetry_span_log can grow to before old data will be removed. If set to 0 (default),
	// automatic removal of opentelemetry_span_log data based on size is disabled.
	OpentelemetrySpanLogRetentionSize *wrapperspb.Int64Value `` /* 167-byte string literal not displayed */
	// The maximum time that opentelemetry_span_log records will be retained before removal. If set to 0,
	// automatic removal of opentelemetry_span_log data based on time is disabled.
	OpentelemetrySpanLogRetentionTime *wrapperspb.Int64Value `` /* 167-byte string literal not displayed */
	// Enable or disable query_views_log system table. Default value: false.
	QueryViewsLogEnabled *wrapperspb.BoolValue `` /* 126-byte string literal not displayed */
	// The maximum size that query_views_log can grow to before old data will be removed. If set to 0 (default),
	// automatic removal of query_views_log data based on size is disabled.
	QueryViewsLogRetentionSize *wrapperspb.Int64Value `` /* 146-byte string literal not displayed */
	// The maximum time that query_views_log records will be retained before removal. If set to 0,
	// automatic removal of query_views_log data based on time is disabled.
	QueryViewsLogRetentionTime *wrapperspb.Int64Value `` /* 146-byte string literal not displayed */
	// Enable or disable asynchronous_metric_log system table. Default value: false.
	AsynchronousMetricLogEnabled *wrapperspb.BoolValue `` /* 150-byte string literal not displayed */
	// The maximum size that asynchronous_metric_log can grow to before old data will be removed. If set to 0 (default),
	// automatic removal of asynchronous_metric_log data based on size is disabled.
	AsynchronousMetricLogRetentionSize *wrapperspb.Int64Value `` /* 170-byte string literal not displayed */
	// The maximum time that asynchronous_metric_log records will be retained before removal. If set to 0,
	// automatic removal of asynchronous_metric_log data based on time is disabled.
	AsynchronousMetricLogRetentionTime *wrapperspb.Int64Value `` /* 170-byte string literal not displayed */
	// Enable or disable session_log system table. Default value: false.
	SessionLogEnabled *wrapperspb.BoolValue `protobuf:"bytes,57,opt,name=session_log_enabled,json=sessionLogEnabled,proto3" json:"session_log_enabled,omitempty"`
	// The maximum size that session_log can grow to before old data will be removed. If set to 0 (default),
	// automatic removal of session_log data based on size is disabled.
	SessionLogRetentionSize *wrapperspb.Int64Value `` /* 135-byte string literal not displayed */
	// The maximum time that session_log records will be retained before removal. If set to 0,
	// automatic removal of session_log data based on time is disabled.
	SessionLogRetentionTime *wrapperspb.Int64Value `` /* 135-byte string literal not displayed */
	// Enable or disable zookeeper_log system table. Default value: false.
	ZookeeperLogEnabled *wrapperspb.BoolValue `protobuf:"bytes,60,opt,name=zookeeper_log_enabled,json=zookeeperLogEnabled,proto3" json:"zookeeper_log_enabled,omitempty"`
	// The maximum size that zookeeper_log can grow to before old data will be removed. If set to 0 (default),
	// automatic removal of zookeeper_log data based on size is disabled.
	ZookeeperLogRetentionSize *wrapperspb.Int64Value `` /* 141-byte string literal not displayed */
	// The maximum time that zookeeper_log records will be retained before removal. If set to 0,
	// automatic removal of zookeeper_log data based on time is disabled.
	ZookeeperLogRetentionTime *wrapperspb.Int64Value `` /* 141-byte string literal not displayed */
	// Enable or disable asynchronous_insert_log system table. Default value: false.
	// Minimal required ClickHouse version: 22.10.
	AsynchronousInsertLogEnabled *wrapperspb.BoolValue `` /* 150-byte string literal not displayed */
	// The maximum size that asynchronous_insert_log can grow to before old data will be removed. If set to 0 (default),
	// automatic removal of asynchronous_insert_log data based on size is disabled.
	AsynchronousInsertLogRetentionSize *wrapperspb.Int64Value `` /* 170-byte string literal not displayed */
	// The maximum time that asynchronous_insert_log records will be retained before removal. If set to 0,
	// automatic removal of asynchronous_insert_log data based on time is disabled.
	AsynchronousInsertLogRetentionTime *wrapperspb.Int64Value `` /* 170-byte string literal not displayed */
	BackgroundPoolSize                 *wrapperspb.Int64Value `protobuf:"bytes,33,opt,name=background_pool_size,json=backgroundPoolSize,proto3" json:"background_pool_size,omitempty"`
	// Sets a ratio between the number of threads and the number of background merges and mutations that can be executed concurrently. For example, if the ratio equals to 2 and background_pool_size is set to 16 then ClickHouse can execute 32 background merges concurrently. This is possible, because background operations could be suspended and postponed. This is needed to give small merges more execution priority. You can only increase this ratio at runtime. To lower it you have to restart the server. The same as for background_pool_size setting background_merges_mutations_concurrency_ratio could be applied from the default profile for backward compatibility.
	// Default: 2
	// See in-depth description in [ClickHouse documentation](https://clickhouse.com/docs/en/operations/server-configuration-parameters/settings#background_merges_mutations_concurrency_ratio)
	BackgroundMergesMutationsConcurrencyRatio *wrapperspb.Int64Value `` /* 191-byte string literal not displayed */
	BackgroundSchedulePoolSize                *wrapperspb.Int64Value `` /* 144-byte string literal not displayed */
	// Sets the number of threads performing background fetches for tables with **ReplicatedMergeTree** engines. Default value: 8.
	//
	// More info see in [ClickHouse documentation](https://clickhouse.com/docs/en/operations/server-configuration-parameters/settings/#background_fetches_pool_size).
	BackgroundFetchesPoolSize               *wrapperspb.Int64Value `` /* 141-byte string literal not displayed */
	BackgroundMovePoolSize                  *wrapperspb.Int64Value `` /* 132-byte string literal not displayed */
	BackgroundDistributedSchedulePoolSize   *wrapperspb.Int64Value `` /* 179-byte string literal not displayed */
	BackgroundBufferFlushSchedulePoolSize   *wrapperspb.Int64Value `` /* 181-byte string literal not displayed */
	BackgroundMessageBrokerSchedulePoolSize *wrapperspb.Int64Value `` /* 187-byte string literal not displayed */
	// The maximum number of threads that will be used for performing a variety of operations (mostly garbage collection) for *MergeTree-engine tables in a background.
	// Default: 8
	// See in-depth description in [ClickHouse documentation](https://clickhouse.com/docs/en/operations/server-configuration-parameters/settings#background_common_pool_size)
	BackgroundCommonPoolSize *wrapperspb.Int64Value `` /* 138-byte string literal not displayed */
	// The default database.
	//
	// To get a list of cluster databases, see [Yandex Managed ClickHouse documentation](https://cloud.yandex.com/en/docs/managed-clickhouse/operations/databases#list-db).
	DefaultDatabase *wrapperspb.StringValue `protobuf:"bytes,43,opt,name=default_database,json=defaultDatabase,proto3" json:"default_database,omitempty"`
	// Sets the memory size (in bytes) for a stack trace at every peak allocation step. Default value: **4194304**.
	//
	// More info see in [ClickHouse documentation](https://clickhouse.com/docs/en/operations/server-configuration-parameters/settings/#total-memory-profiler-step).
	TotalMemoryProfilerStep             *wrapperspb.Int64Value  `` /* 135-byte string literal not displayed */
	TotalMemoryTrackerSampleProbability *wrapperspb.DoubleValue `` /* 173-byte string literal not displayed */
	// contains filtered or unexported fields
}

ClickHouse configuration options. Detailed description for each set of options is available in [ClickHouse documentation](https://clickhouse.com/docs/en/operations/server_settings/settings/).

Any options not listed here are not supported.

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() *wrapperspb.Int64Value

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() *wrapperspb.Int64Value

func (*ClickhouseConfig) GetBackgroundBufferFlushSchedulePoolSize

func (x *ClickhouseConfig) GetBackgroundBufferFlushSchedulePoolSize() *wrapperspb.Int64Value

func (*ClickhouseConfig) GetBackgroundCommonPoolSize

func (x *ClickhouseConfig) GetBackgroundCommonPoolSize() *wrapperspb.Int64Value

func (*ClickhouseConfig) GetBackgroundDistributedSchedulePoolSize

func (x *ClickhouseConfig) GetBackgroundDistributedSchedulePoolSize() *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) GetBuiltinDictionariesReloadInterval deprecated

func (x *ClickhouseConfig) GetBuiltinDictionariesReloadInterval() *wrapperspb.Int64Value

Deprecated: Marked as deprecated in yandex/cloud/mdb/clickhouse/v1/config/clickhouse.proto.

func (*ClickhouseConfig) GetCompression

func (x *ClickhouseConfig) GetCompression() []*ClickhouseConfig_Compression

func (*ClickhouseConfig) GetDefaultDatabase

func (x *ClickhouseConfig) GetDefaultDatabase() *wrapperspb.StringValue

func (*ClickhouseConfig) GetDictionaries

func (x *ClickhouseConfig) GetDictionaries() []*ClickhouseConfig_ExternalDictionary

func (*ClickhouseConfig) GetGeobaseEnabled

func (x *ClickhouseConfig) GetGeobaseEnabled() *wrapperspb.BoolValue

func (*ClickhouseConfig) GetGeobaseUri

func (x *ClickhouseConfig) GetGeobaseUri() string

func (*ClickhouseConfig) GetGraphiteRollup

func (x *ClickhouseConfig) GetGraphiteRollup() []*ClickhouseConfig_GraphiteRollup

func (*ClickhouseConfig) GetKafka

func (*ClickhouseConfig) GetKafkaTopics

func (x *ClickhouseConfig) GetKafkaTopics() []*ClickhouseConfig_KafkaTopic

func (*ClickhouseConfig) GetKeepAliveTimeout

func (x *ClickhouseConfig) GetKeepAliveTimeout() *wrapperspb.Int64Value

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() *wrapperspb.Int64Value

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() *wrapperspb.Int64Value

func (*ClickhouseConfig) GetPartLogRetentionSize

func (x *ClickhouseConfig) GetPartLogRetentionSize() *wrapperspb.Int64Value

func (*ClickhouseConfig) GetPartLogRetentionTime

func (x *ClickhouseConfig) GetPartLogRetentionTime() *wrapperspb.Int64Value

func (*ClickhouseConfig) GetQueryLogRetentionSize

func (x *ClickhouseConfig) GetQueryLogRetentionSize() *wrapperspb.Int64Value

func (*ClickhouseConfig) GetQueryLogRetentionTime

func (x *ClickhouseConfig) GetQueryLogRetentionTime() *wrapperspb.Int64Value

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() *wrapperspb.Int64Value

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() *wrapperspb.Int64Value

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() *wrapperspb.Int64Value

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() *wrapperspb.Int64Value

func (*ClickhouseConfig) GetTimezone

func (x *ClickhouseConfig) GetTimezone() string

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() *wrapperspb.Int64Value

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() *wrapperspb.Int64Value

func (*ClickhouseConfig) ProtoMessage

func (*ClickhouseConfig) ProtoMessage()

func (*ClickhouseConfig) ProtoReflect

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

func (*ClickhouseConfig) Reset

func (x *ClickhouseConfig) Reset()

func (*ClickhouseConfig) SetAsynchronousInsertLogEnabled

func (m *ClickhouseConfig) SetAsynchronousInsertLogEnabled(v *wrapperspb.BoolValue)

func (*ClickhouseConfig) SetAsynchronousInsertLogRetentionSize

func (m *ClickhouseConfig) SetAsynchronousInsertLogRetentionSize(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetAsynchronousInsertLogRetentionTime

func (m *ClickhouseConfig) SetAsynchronousInsertLogRetentionTime(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetAsynchronousMetricLogEnabled

func (m *ClickhouseConfig) SetAsynchronousMetricLogEnabled(v *wrapperspb.BoolValue)

func (*ClickhouseConfig) SetAsynchronousMetricLogRetentionSize

func (m *ClickhouseConfig) SetAsynchronousMetricLogRetentionSize(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetAsynchronousMetricLogRetentionTime

func (m *ClickhouseConfig) SetAsynchronousMetricLogRetentionTime(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetBackgroundBufferFlushSchedulePoolSize

func (m *ClickhouseConfig) SetBackgroundBufferFlushSchedulePoolSize(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetBackgroundCommonPoolSize

func (m *ClickhouseConfig) SetBackgroundCommonPoolSize(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetBackgroundDistributedSchedulePoolSize

func (m *ClickhouseConfig) SetBackgroundDistributedSchedulePoolSize(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetBackgroundFetchesPoolSize

func (m *ClickhouseConfig) SetBackgroundFetchesPoolSize(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetBackgroundMergesMutationsConcurrencyRatio

func (m *ClickhouseConfig) SetBackgroundMergesMutationsConcurrencyRatio(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetBackgroundMessageBrokerSchedulePoolSize

func (m *ClickhouseConfig) SetBackgroundMessageBrokerSchedulePoolSize(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetBackgroundMovePoolSize

func (m *ClickhouseConfig) SetBackgroundMovePoolSize(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetBackgroundPoolSize

func (m *ClickhouseConfig) SetBackgroundPoolSize(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetBackgroundSchedulePoolSize

func (m *ClickhouseConfig) SetBackgroundSchedulePoolSize(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetBuiltinDictionariesReloadInterval

func (m *ClickhouseConfig) SetBuiltinDictionariesReloadInterval(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetCompression

func (m *ClickhouseConfig) SetCompression(v []*ClickhouseConfig_Compression)

func (*ClickhouseConfig) SetDefaultDatabase

func (m *ClickhouseConfig) SetDefaultDatabase(v *wrapperspb.StringValue)

func (*ClickhouseConfig) SetDictionaries

func (m *ClickhouseConfig) SetDictionaries(v []*ClickhouseConfig_ExternalDictionary)

func (*ClickhouseConfig) SetGeobaseEnabled

func (m *ClickhouseConfig) SetGeobaseEnabled(v *wrapperspb.BoolValue)

func (*ClickhouseConfig) SetGeobaseUri

func (m *ClickhouseConfig) SetGeobaseUri(v string)

func (*ClickhouseConfig) SetGraphiteRollup

func (m *ClickhouseConfig) SetGraphiteRollup(v []*ClickhouseConfig_GraphiteRollup)

func (*ClickhouseConfig) SetKafka

func (m *ClickhouseConfig) SetKafka(v *ClickhouseConfig_Kafka)

func (*ClickhouseConfig) SetKafkaTopics

func (m *ClickhouseConfig) SetKafkaTopics(v []*ClickhouseConfig_KafkaTopic)

func (*ClickhouseConfig) SetKeepAliveTimeout

func (m *ClickhouseConfig) SetKeepAliveTimeout(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetLogLevel

func (m *ClickhouseConfig) SetLogLevel(v ClickhouseConfig_LogLevel)

func (*ClickhouseConfig) SetMarkCacheSize

func (m *ClickhouseConfig) SetMarkCacheSize(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetMaxConcurrentQueries

func (m *ClickhouseConfig) SetMaxConcurrentQueries(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetMaxConnections

func (m *ClickhouseConfig) SetMaxConnections(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetMaxPartitionSizeToDrop

func (m *ClickhouseConfig) SetMaxPartitionSizeToDrop(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetMaxTableSizeToDrop

func (m *ClickhouseConfig) SetMaxTableSizeToDrop(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetMergeTree

func (m *ClickhouseConfig) SetMergeTree(v *ClickhouseConfig_MergeTree)

func (*ClickhouseConfig) SetMetricLogEnabled

func (m *ClickhouseConfig) SetMetricLogEnabled(v *wrapperspb.BoolValue)

func (*ClickhouseConfig) SetMetricLogRetentionSize

func (m *ClickhouseConfig) SetMetricLogRetentionSize(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetMetricLogRetentionTime

func (m *ClickhouseConfig) SetMetricLogRetentionTime(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetOpentelemetrySpanLogEnabled

func (m *ClickhouseConfig) SetOpentelemetrySpanLogEnabled(v *wrapperspb.BoolValue)

func (*ClickhouseConfig) SetOpentelemetrySpanLogRetentionSize

func (m *ClickhouseConfig) SetOpentelemetrySpanLogRetentionSize(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetOpentelemetrySpanLogRetentionTime

func (m *ClickhouseConfig) SetOpentelemetrySpanLogRetentionTime(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetPartLogRetentionSize

func (m *ClickhouseConfig) SetPartLogRetentionSize(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetPartLogRetentionTime

func (m *ClickhouseConfig) SetPartLogRetentionTime(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetQueryLogRetentionSize

func (m *ClickhouseConfig) SetQueryLogRetentionSize(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetQueryLogRetentionTime

func (m *ClickhouseConfig) SetQueryLogRetentionTime(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetQueryThreadLogEnabled

func (m *ClickhouseConfig) SetQueryThreadLogEnabled(v *wrapperspb.BoolValue)

func (*ClickhouseConfig) SetQueryThreadLogRetentionSize

func (m *ClickhouseConfig) SetQueryThreadLogRetentionSize(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetQueryThreadLogRetentionTime

func (m *ClickhouseConfig) SetQueryThreadLogRetentionTime(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetQueryViewsLogEnabled

func (m *ClickhouseConfig) SetQueryViewsLogEnabled(v *wrapperspb.BoolValue)

func (*ClickhouseConfig) SetQueryViewsLogRetentionSize

func (m *ClickhouseConfig) SetQueryViewsLogRetentionSize(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetQueryViewsLogRetentionTime

func (m *ClickhouseConfig) SetQueryViewsLogRetentionTime(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetRabbitmq

func (m *ClickhouseConfig) SetRabbitmq(v *ClickhouseConfig_Rabbitmq)

func (*ClickhouseConfig) SetSessionLogEnabled

func (m *ClickhouseConfig) SetSessionLogEnabled(v *wrapperspb.BoolValue)

func (*ClickhouseConfig) SetSessionLogRetentionSize

func (m *ClickhouseConfig) SetSessionLogRetentionSize(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetSessionLogRetentionTime

func (m *ClickhouseConfig) SetSessionLogRetentionTime(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetTextLogEnabled

func (m *ClickhouseConfig) SetTextLogEnabled(v *wrapperspb.BoolValue)

func (*ClickhouseConfig) SetTextLogLevel

func (m *ClickhouseConfig) SetTextLogLevel(v ClickhouseConfig_LogLevel)

func (*ClickhouseConfig) SetTextLogRetentionSize

func (m *ClickhouseConfig) SetTextLogRetentionSize(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetTextLogRetentionTime

func (m *ClickhouseConfig) SetTextLogRetentionTime(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetTimezone

func (m *ClickhouseConfig) SetTimezone(v string)

func (*ClickhouseConfig) SetTotalMemoryProfilerStep

func (m *ClickhouseConfig) SetTotalMemoryProfilerStep(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetTotalMemoryTrackerSampleProbability

func (m *ClickhouseConfig) SetTotalMemoryTrackerSampleProbability(v *wrapperspb.DoubleValue)

func (*ClickhouseConfig) SetTraceLogEnabled

func (m *ClickhouseConfig) SetTraceLogEnabled(v *wrapperspb.BoolValue)

func (*ClickhouseConfig) SetTraceLogRetentionSize

func (m *ClickhouseConfig) SetTraceLogRetentionSize(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetTraceLogRetentionTime

func (m *ClickhouseConfig) SetTraceLogRetentionTime(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetUncompressedCacheSize

func (m *ClickhouseConfig) SetUncompressedCacheSize(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetZookeeperLogEnabled

func (m *ClickhouseConfig) SetZookeeperLogEnabled(v *wrapperspb.BoolValue)

func (*ClickhouseConfig) SetZookeeperLogRetentionSize

func (m *ClickhouseConfig) SetZookeeperLogRetentionSize(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) SetZookeeperLogRetentionTime

func (m *ClickhouseConfig) SetZookeeperLogRetentionTime(v *wrapperspb.Int64Value)

func (*ClickhouseConfig) String

func (x *ClickhouseConfig) String() string

type ClickhouseConfigSet

type ClickhouseConfigSet struct {

	// Effective settings for a ClickHouse cluster (a combination of settings defined
	// in [user_config] and [default_config]).
	EffectiveConfig *ClickhouseConfig `protobuf:"bytes,1,opt,name=effective_config,json=effectiveConfig,proto3" json:"effective_config,omitempty"`
	// User-defined settings for a ClickHouse cluster.
	UserConfig *ClickhouseConfig `protobuf:"bytes,2,opt,name=user_config,json=userConfig,proto3" json:"user_config,omitempty"`
	// Default configuration for a ClickHouse cluster.
	DefaultConfig *ClickhouseConfig `protobuf:"bytes,3,opt,name=default_config,json=defaultConfig,proto3" json:"default_config,omitempty"`
	// contains filtered or unexported fields
}

func (*ClickhouseConfigSet) Descriptor deprecated

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

Deprecated: Use ClickhouseConfigSet.ProtoReflect.Descriptor instead.

func (*ClickhouseConfigSet) GetDefaultConfig

func (x *ClickhouseConfigSet) GetDefaultConfig() *ClickhouseConfig

func (*ClickhouseConfigSet) GetEffectiveConfig

func (x *ClickhouseConfigSet) GetEffectiveConfig() *ClickhouseConfig

func (*ClickhouseConfigSet) GetUserConfig

func (x *ClickhouseConfigSet) GetUserConfig() *ClickhouseConfig

func (*ClickhouseConfigSet) ProtoMessage

func (*ClickhouseConfigSet) ProtoMessage()

func (*ClickhouseConfigSet) ProtoReflect

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

func (*ClickhouseConfigSet) Reset

func (x *ClickhouseConfigSet) Reset()

func (*ClickhouseConfigSet) SetDefaultConfig

func (m *ClickhouseConfigSet) SetDefaultConfig(v *ClickhouseConfig)

func (*ClickhouseConfigSet) SetEffectiveConfig

func (m *ClickhouseConfigSet) SetEffectiveConfig(v *ClickhouseConfig)

func (*ClickhouseConfigSet) SetUserConfig

func (m *ClickhouseConfigSet) SetUserConfig(v *ClickhouseConfig)

func (*ClickhouseConfigSet) String

func (x *ClickhouseConfigSet) String() string

type ClickhouseConfig_Compression

type ClickhouseConfig_Compression struct {

	// Compression method to use for the specified combination of [min_part_size] and [min_part_size_ratio].
	Method ClickhouseConfig_Compression_Method `` /* 145-byte string literal not displayed */
	// Minimum size of a part of a table.
	MinPartSize int64 `protobuf:"varint,2,opt,name=min_part_size,json=minPartSize,proto3" json:"min_part_size,omitempty"`
	// Minimum ratio of a part relative to the size of all the data in the table.
	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) SetLevel

func (*ClickhouseConfig_Compression) SetMethod

func (*ClickhouseConfig_Compression) SetMinPartSize

func (m *ClickhouseConfig_Compression) SetMinPartSize(v int64)

func (*ClickhouseConfig_Compression) SetMinPartSizeRatio

func (m *ClickhouseConfig_Compression) SetMinPartSizeRatio(v float64)

func (*ClickhouseConfig_Compression) String

type ClickhouseConfig_Compression_Method

type ClickhouseConfig_Compression_Method int32
const (
	ClickhouseConfig_Compression_METHOD_UNSPECIFIED ClickhouseConfig_Compression_Method = 0
	// [LZ4 compression algorithm](https://lz4.github.io/lz4/).
	ClickhouseConfig_Compression_LZ4 ClickhouseConfig_Compression_Method = 1
	// [Zstandard compression algorithm](https://facebook.github.io/zstd/).
	ClickhouseConfig_Compression_ZSTD ClickhouseConfig_Compression_Method = 2
)

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_ExternalDictionary

type ClickhouseConfig_ExternalDictionary struct {

	// Name of the external dictionary.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Set of attributes for the external dictionary.
	// For in-depth description, see [ClickHouse documentation](https://clickhouse.com/docs/en/query_language/dicts/external_dicts_dict_structure/).
	Structure *ClickhouseConfig_ExternalDictionary_Structure `protobuf:"bytes,2,opt,name=structure,proto3" json:"structure,omitempty"`
	// Layout for storing the dictionary in memory.
	// For in-depth description, see [ClickHouse documentation](https://clickhouse.com/docs/en/query_language/dicts/external_dicts_dict_layout/).
	Layout *ClickhouseConfig_ExternalDictionary_Layout `protobuf:"bytes,3,opt,name=layout,proto3" json:"layout,omitempty"`
	// Setting for the period of time between dictionary updates.
	// For details, see [ClickHouse documentation](https://clickhouse.com/docs/en/query_language/dicts/external_dicts_dict_lifetime/).
	//
	// Types that are assignable to Lifetime:
	//
	//	*ClickhouseConfig_ExternalDictionary_FixedLifetime
	//	*ClickhouseConfig_ExternalDictionary_LifetimeRange
	Lifetime isClickhouseConfig_ExternalDictionary_Lifetime `protobuf_oneof:"lifetime"`
	// Description of the source for the external dictionary.
	//
	// Types that are assignable to Source:
	//
	//	*ClickhouseConfig_ExternalDictionary_HttpSource_
	//	*ClickhouseConfig_ExternalDictionary_MysqlSource_
	//	*ClickhouseConfig_ExternalDictionary_ClickhouseSource_
	//	*ClickhouseConfig_ExternalDictionary_MongodbSource_
	//	*ClickhouseConfig_ExternalDictionary_PostgresqlSource_
	Source isClickhouseConfig_ExternalDictionary_Source `protobuf_oneof:"source"`
	// contains filtered or unexported fields
}

func (*ClickhouseConfig_ExternalDictionary) Descriptor deprecated

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

Deprecated: Use ClickhouseConfig_ExternalDictionary.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary) GetClickhouseSource

func (*ClickhouseConfig_ExternalDictionary) GetFixedLifetime

func (x *ClickhouseConfig_ExternalDictionary) GetFixedLifetime() int64

func (*ClickhouseConfig_ExternalDictionary) GetHttpSource

func (*ClickhouseConfig_ExternalDictionary) GetLayout

func (*ClickhouseConfig_ExternalDictionary) GetLifetime

func (m *ClickhouseConfig_ExternalDictionary) GetLifetime() isClickhouseConfig_ExternalDictionary_Lifetime

func (*ClickhouseConfig_ExternalDictionary) GetLifetimeRange

func (*ClickhouseConfig_ExternalDictionary) GetMongodbSource

func (*ClickhouseConfig_ExternalDictionary) GetMysqlSource

func (*ClickhouseConfig_ExternalDictionary) GetName

func (*ClickhouseConfig_ExternalDictionary) GetPostgresqlSource

func (*ClickhouseConfig_ExternalDictionary) GetSource

func (m *ClickhouseConfig_ExternalDictionary) GetSource() isClickhouseConfig_ExternalDictionary_Source

func (*ClickhouseConfig_ExternalDictionary) GetStructure

func (*ClickhouseConfig_ExternalDictionary) ProtoMessage

func (*ClickhouseConfig_ExternalDictionary) ProtoMessage()

func (*ClickhouseConfig_ExternalDictionary) ProtoReflect

func (*ClickhouseConfig_ExternalDictionary) Reset

func (*ClickhouseConfig_ExternalDictionary) SetClickhouseSource

func (*ClickhouseConfig_ExternalDictionary) SetFixedLifetime

func (m *ClickhouseConfig_ExternalDictionary) SetFixedLifetime(v int64)

func (*ClickhouseConfig_ExternalDictionary) SetHttpSource

func (*ClickhouseConfig_ExternalDictionary) SetLayout

func (*ClickhouseConfig_ExternalDictionary) SetLifetime

func (*ClickhouseConfig_ExternalDictionary) SetLifetimeRange

func (*ClickhouseConfig_ExternalDictionary) SetMongodbSource

func (*ClickhouseConfig_ExternalDictionary) SetMysqlSource

func (*ClickhouseConfig_ExternalDictionary) SetName

func (*ClickhouseConfig_ExternalDictionary) SetPostgresqlSource

func (*ClickhouseConfig_ExternalDictionary) SetSource

func (*ClickhouseConfig_ExternalDictionary) SetStructure

func (*ClickhouseConfig_ExternalDictionary) String

type ClickhouseConfig_ExternalDictionary_ClickhouseSource

type ClickhouseConfig_ExternalDictionary_ClickhouseSource struct {

	// Name of the ClickHouse database.
	Db string `protobuf:"bytes,1,opt,name=db,proto3" json:"db,omitempty"`
	// Name of the table in the specified database to be used as the dictionary source.
	Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	// ClickHouse host of the specified database.
	Host string `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	// Port to use when connecting to the host.
	Port int64 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	// Name of the ClickHouse database user.
	User string `protobuf:"bytes,5,opt,name=user,proto3" json:"user,omitempty"`
	// Password of the ClickHouse database user.
	Password string `protobuf:"bytes,6,opt,name=password,proto3" json:"password,omitempty"`
	// Selection criteria for the data in the specified ClickHouse table.
	Where string `protobuf:"bytes,7,opt,name=where,proto3" json:"where,omitempty"`
	// contains filtered or unexported fields
}

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) Descriptor deprecated

Deprecated: Use ClickhouseConfig_ExternalDictionary_ClickhouseSource.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) GetDb

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) GetHost

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) GetPassword

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) GetPort

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) GetTable

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) GetUser

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) GetWhere

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) ProtoMessage

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) ProtoReflect

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) Reset

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) SetDb

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) SetHost

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) SetPassword

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) SetPort

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) SetTable

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) SetUser

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) SetWhere

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) String

type ClickhouseConfig_ExternalDictionary_ClickhouseSource_

type ClickhouseConfig_ExternalDictionary_ClickhouseSource_ struct {
	// ClickHouse source for the dictionary.
	ClickhouseSource *ClickhouseConfig_ExternalDictionary_ClickhouseSource `protobuf:"bytes,8,opt,name=clickhouse_source,json=clickhouseSource,proto3,oneof"`
}

type ClickhouseConfig_ExternalDictionary_FixedLifetime

type ClickhouseConfig_ExternalDictionary_FixedLifetime struct {
	// Fixed interval between dictionary updates.
	FixedLifetime int64 `protobuf:"varint,4,opt,name=fixed_lifetime,json=fixedLifetime,proto3,oneof"`
}

type ClickhouseConfig_ExternalDictionary_HttpSource

type ClickhouseConfig_ExternalDictionary_HttpSource struct {

	// URL of the source dictionary available over HTTP.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// The data format. Valid values are all formats supported by ClickHouse SQL dialect.
	Format string `protobuf:"bytes,2,opt,name=format,proto3" json:"format,omitempty"`
	// contains filtered or unexported fields
}

func (*ClickhouseConfig_ExternalDictionary_HttpSource) Descriptor deprecated

Deprecated: Use ClickhouseConfig_ExternalDictionary_HttpSource.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary_HttpSource) GetFormat

func (*ClickhouseConfig_ExternalDictionary_HttpSource) GetUrl

func (*ClickhouseConfig_ExternalDictionary_HttpSource) ProtoMessage

func (*ClickhouseConfig_ExternalDictionary_HttpSource) ProtoReflect

func (*ClickhouseConfig_ExternalDictionary_HttpSource) Reset

func (*ClickhouseConfig_ExternalDictionary_HttpSource) SetFormat

func (*ClickhouseConfig_ExternalDictionary_HttpSource) SetUrl

func (*ClickhouseConfig_ExternalDictionary_HttpSource) String

type ClickhouseConfig_ExternalDictionary_HttpSource_

type ClickhouseConfig_ExternalDictionary_HttpSource_ struct {
	// HTTP source for the dictionary.
	HttpSource *ClickhouseConfig_ExternalDictionary_HttpSource `protobuf:"bytes,6,opt,name=http_source,json=httpSource,proto3,oneof"`
}

type ClickhouseConfig_ExternalDictionary_Layout

type ClickhouseConfig_ExternalDictionary_Layout struct {

	// Layout type for an external dictionary.
	Type ClickhouseConfig_ExternalDictionary_Layout_Type `` /* 153-byte string literal not displayed */
	// Number of cells in the cache. Rounded up to a power of two.
	// Applicable only for CACHE and COMPLEX_KEY_CACHE layout types.
	SizeInCells int64 `protobuf:"varint,2,opt,name=size_in_cells,json=sizeInCells,proto3" json:"size_in_cells,omitempty"`
	// contains filtered or unexported fields
}

Layout determining how to store the dictionary in memory.

func (*ClickhouseConfig_ExternalDictionary_Layout) Descriptor deprecated

Deprecated: Use ClickhouseConfig_ExternalDictionary_Layout.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary_Layout) GetSizeInCells

func (*ClickhouseConfig_ExternalDictionary_Layout) GetType

func (*ClickhouseConfig_ExternalDictionary_Layout) ProtoMessage

func (*ClickhouseConfig_ExternalDictionary_Layout) ProtoReflect

func (*ClickhouseConfig_ExternalDictionary_Layout) Reset

func (*ClickhouseConfig_ExternalDictionary_Layout) SetSizeInCells

func (*ClickhouseConfig_ExternalDictionary_Layout) SetType

func (*ClickhouseConfig_ExternalDictionary_Layout) String

type ClickhouseConfig_ExternalDictionary_Layout_Type

type ClickhouseConfig_ExternalDictionary_Layout_Type int32
const (
	ClickhouseConfig_ExternalDictionary_Layout_TYPE_UNSPECIFIED ClickhouseConfig_ExternalDictionary_Layout_Type = 0
	// The entire dictionary is stored in memory in the form of flat arrays.
	// Available for all dictionary sources.
	ClickhouseConfig_ExternalDictionary_Layout_FLAT ClickhouseConfig_ExternalDictionary_Layout_Type = 1
	// The entire dictionary is stored in memory in the form of a hash table.
	// Available for all dictionary sources.
	ClickhouseConfig_ExternalDictionary_Layout_HASHED ClickhouseConfig_ExternalDictionary_Layout_Type = 2
	// Similar to HASHED, to be used with composite keys.
	// Available for all dictionary sources.
	ClickhouseConfig_ExternalDictionary_Layout_COMPLEX_KEY_HASHED ClickhouseConfig_ExternalDictionary_Layout_Type = 3
	// The entire dictionary is stored in memory in the form of a hash table,
	// with an ordered array of ranges and their corresponding values.
	// Available for all dictionary sources.
	ClickhouseConfig_ExternalDictionary_Layout_RANGE_HASHED ClickhouseConfig_ExternalDictionary_Layout_Type = 4
	// The dictionary is stored in a cache with a set number of cells.
	// Available for MySQL, ClickHouse and HTTP dictionary sources.
	ClickhouseConfig_ExternalDictionary_Layout_CACHE ClickhouseConfig_ExternalDictionary_Layout_Type = 5
	// Similar to CACHE, to be used with composite keys.
	// Available for MySQL, ClickHouse and HTTP dictionary sources.
	ClickhouseConfig_ExternalDictionary_Layout_COMPLEX_KEY_CACHE ClickhouseConfig_ExternalDictionary_Layout_Type = 6
)

func (ClickhouseConfig_ExternalDictionary_Layout_Type) Descriptor

func (ClickhouseConfig_ExternalDictionary_Layout_Type) Enum

func (ClickhouseConfig_ExternalDictionary_Layout_Type) EnumDescriptor deprecated

Deprecated: Use ClickhouseConfig_ExternalDictionary_Layout_Type.Descriptor instead.

func (ClickhouseConfig_ExternalDictionary_Layout_Type) Number

func (ClickhouseConfig_ExternalDictionary_Layout_Type) String

func (ClickhouseConfig_ExternalDictionary_Layout_Type) Type

type ClickhouseConfig_ExternalDictionary_Lifetime

type ClickhouseConfig_ExternalDictionary_Lifetime = isClickhouseConfig_ExternalDictionary_Lifetime

type ClickhouseConfig_ExternalDictionary_LifetimeRange

type ClickhouseConfig_ExternalDictionary_LifetimeRange struct {
	// Range of intervals between dictionary updates for ClickHouse to choose from.
	LifetimeRange *ClickhouseConfig_ExternalDictionary_Range `protobuf:"bytes,5,opt,name=lifetime_range,json=lifetimeRange,proto3,oneof"`
}

type ClickhouseConfig_ExternalDictionary_MongodbSource

type ClickhouseConfig_ExternalDictionary_MongodbSource struct {

	// Name of the MongoDB database.
	Db string `protobuf:"bytes,1,opt,name=db,proto3" json:"db,omitempty"`
	// Name of the collection in the specified database to be used as the dictionary source.
	Collection string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	// MongoDB host of the specified database.
	Host string `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	// Port to use when connecting to the host.
	Port int64 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	// Name of the MongoDB database user.
	User string `protobuf:"bytes,5,opt,name=user,proto3" json:"user,omitempty"`
	// Password of the MongoDB database user.
	Password string `protobuf:"bytes,6,opt,name=password,proto3" json:"password,omitempty"`
	Options  string `protobuf:"bytes,7,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) Descriptor deprecated

Deprecated: Use ClickhouseConfig_ExternalDictionary_MongodbSource.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) GetCollection

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) GetDb

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) GetHost

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) GetOptions

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) GetPassword

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) GetPort

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) GetUser

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) ProtoMessage

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) ProtoReflect

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) Reset

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) SetCollection

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) SetDb

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) SetHost

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) SetOptions

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) SetPassword

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) SetPort

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) SetUser

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) String

type ClickhouseConfig_ExternalDictionary_MongodbSource_

type ClickhouseConfig_ExternalDictionary_MongodbSource_ struct {
	// MongoDB source for the dictionary.
	MongodbSource *ClickhouseConfig_ExternalDictionary_MongodbSource `protobuf:"bytes,9,opt,name=mongodb_source,json=mongodbSource,proto3,oneof"`
}

type ClickhouseConfig_ExternalDictionary_MysqlSource

type ClickhouseConfig_ExternalDictionary_MysqlSource struct {

	// Name of the MySQL database to connect to.
	Db string `protobuf:"bytes,1,opt,name=db,proto3" json:"db,omitempty"`
	// Name of the database table to use as a ClickHouse dictionary.
	Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	// Default port to use when connecting to a replica of the dictionary source.
	Port int64 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	// Name of the default user for replicas of the dictionary source.
	User string `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"`
	// Password of the default user for replicas of the dictionary source.
	Password string `protobuf:"bytes,5,opt,name=password,proto3" json:"password,omitempty"`
	// List of MySQL replicas of the database used as dictionary source.
	Replicas []*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica `protobuf:"bytes,6,rep,name=replicas,proto3" json:"replicas,omitempty"`
	// Selection criteria for the data in the specified MySQL table.
	Where string `protobuf:"bytes,7,opt,name=where,proto3" json:"where,omitempty"`
	// Query for checking the dictionary status, to pull only updated data.
	// For more details, see [ClickHouse documentation on dictionaries](https://clickhouse.com/docs/en/query_language/dicts/external_dicts_dict_lifetime/).
	InvalidateQuery string `protobuf:"bytes,8,opt,name=invalidate_query,json=invalidateQuery,proto3" json:"invalidate_query,omitempty"`
	// contains filtered or unexported fields
}

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) Descriptor deprecated

Deprecated: Use ClickhouseConfig_ExternalDictionary_MysqlSource.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) GetDb

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) GetInvalidateQuery

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) GetPassword

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) GetPort

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) GetReplicas

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) GetTable

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) GetUser

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) GetWhere

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) ProtoMessage

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) ProtoReflect

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) Reset

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) SetDb

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) SetInvalidateQuery

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) SetPassword

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) SetPort

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) SetReplicas

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) SetTable

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) SetUser

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) SetWhere

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) String

type ClickhouseConfig_ExternalDictionary_MysqlSource_

type ClickhouseConfig_ExternalDictionary_MysqlSource_ struct {
	// MySQL source for the dictionary.
	MysqlSource *ClickhouseConfig_ExternalDictionary_MysqlSource `protobuf:"bytes,7,opt,name=mysql_source,json=mysqlSource,proto3,oneof"`
}

type ClickhouseConfig_ExternalDictionary_MysqlSource_Replica

type ClickhouseConfig_ExternalDictionary_MysqlSource_Replica struct {

	// MySQL host of the replica.
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// The priority of the replica that ClickHouse takes into account when connecting.
	// Replica with the highest priority should have this field set to the lowest number.
	Priority int64 `protobuf:"varint,2,opt,name=priority,proto3" json:"priority,omitempty"`
	// Port to use when connecting to the replica.
	// If a port is not specified for a replica, ClickHouse uses the port specified for the source.
	Port int64 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	// Name of the MySQL database user.
	User string `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"`
	// Password of the MySQL database user.
	Password string `protobuf:"bytes,5,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) Descriptor deprecated

Deprecated: Use ClickhouseConfig_ExternalDictionary_MysqlSource_Replica.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) GetHost

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) GetPassword

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) GetPort

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) GetPriority

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) GetUser

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) ProtoMessage

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) ProtoReflect

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) Reset

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) SetHost

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) SetPassword

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) SetPort

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) SetPriority

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) SetUser

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) String

type ClickhouseConfig_ExternalDictionary_PostgresqlSource

type ClickhouseConfig_ExternalDictionary_PostgresqlSource struct {

	// Name of the PostrgreSQL database.
	Db string `protobuf:"bytes,1,opt,name=db,proto3" json:"db,omitempty"`
	// Name of the table in the specified database to be used as the dictionary source.
	Table string `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	// Name of the PostrgreSQL host
	Hosts []string `protobuf:"bytes,3,rep,name=hosts,proto3" json:"hosts,omitempty"`
	// Port to use when connecting to the host.
	Port int64 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	// Name of the PostrgreSQL database user.
	User string `protobuf:"bytes,5,opt,name=user,proto3" json:"user,omitempty"`
	// Password of the PostrgreSQL database user.
	Password string `protobuf:"bytes,6,opt,name=password,proto3" json:"password,omitempty"`
	// Query for checking the dictionary status, to pull only updated data.
	// For more details, see [ClickHouse documentation on dictionaries](https://clickhouse.com/docs/en/query_language/dicts/external_dicts_dict_lifetime/).
	InvalidateQuery string `protobuf:"bytes,7,opt,name=invalidate_query,json=invalidateQuery,proto3" json:"invalidate_query,omitempty"`
	// Mode of SSL TCP/IP connection to the PostgreSQL host.
	// For more details, see [PostgreSQL documentation](https://www.postgresql.org/docs/current/libpq-ssl.html).
	SslMode ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode `` /* 187-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) Descriptor deprecated

Deprecated: Use ClickhouseConfig_ExternalDictionary_PostgresqlSource.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetDb

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetHosts

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetInvalidateQuery

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetPassword

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetPort

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetSslMode

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetTable

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetUser

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) ProtoMessage

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) ProtoReflect

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) Reset

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetDb

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetHosts

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetInvalidateQuery

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetPassword

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetPort

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetSslMode

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetTable

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetUser

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) String

type ClickhouseConfig_ExternalDictionary_PostgresqlSource_

type ClickhouseConfig_ExternalDictionary_PostgresqlSource_ struct {
	// PostgreSQL source for the dictionary.
	PostgresqlSource *ClickhouseConfig_ExternalDictionary_PostgresqlSource `protobuf:"bytes,10,opt,name=postgresql_source,json=postgresqlSource,proto3,oneof"`
}

type ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode

type ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode int32
const (
	ClickhouseConfig_ExternalDictionary_PostgresqlSource_SSL_MODE_UNSPECIFIED ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode = 0
	// Only try a non-SSL connection.
	ClickhouseConfig_ExternalDictionary_PostgresqlSource_DISABLE ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode = 1
	// First try a non-SSL connection; if that fails, try an SSL connection.
	ClickhouseConfig_ExternalDictionary_PostgresqlSource_ALLOW ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode = 2
	// First try an SSL connection; if that fails, try a non-SSL connection.
	ClickhouseConfig_ExternalDictionary_PostgresqlSource_PREFER ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode = 3
	// Only try an SSL connection, and verify that the server certificate is issued by a trusted certificate authority (CA).
	ClickhouseConfig_ExternalDictionary_PostgresqlSource_VERIFY_CA ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode = 4
	// Only try an SSL connection, verify that the server certificate is issued by a trusted CA and that the requested server host name matches that in the certificate.
	ClickhouseConfig_ExternalDictionary_PostgresqlSource_VERIFY_FULL ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode = 5
)

func (ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode) Descriptor

func (ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode) Enum

func (ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode) EnumDescriptor deprecated

Deprecated: Use ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode.Descriptor instead.

func (ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode) Number

func (ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode) String

func (ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode) Type

type ClickhouseConfig_ExternalDictionary_Range

type ClickhouseConfig_ExternalDictionary_Range struct {

	// Minimum dictionary lifetime.
	Min int64 `protobuf:"varint,1,opt,name=min,proto3" json:"min,omitempty"`
	// Maximum dictionary lifetime.
	Max int64 `protobuf:"varint,2,opt,name=max,proto3" json:"max,omitempty"`
	// contains filtered or unexported fields
}

func (*ClickhouseConfig_ExternalDictionary_Range) Descriptor deprecated

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

Deprecated: Use ClickhouseConfig_ExternalDictionary_Range.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary_Range) GetMax

func (*ClickhouseConfig_ExternalDictionary_Range) GetMin

func (*ClickhouseConfig_ExternalDictionary_Range) ProtoMessage

func (*ClickhouseConfig_ExternalDictionary_Range) ProtoReflect

func (*ClickhouseConfig_ExternalDictionary_Range) Reset

func (*ClickhouseConfig_ExternalDictionary_Range) SetMax

func (*ClickhouseConfig_ExternalDictionary_Range) SetMin

func (*ClickhouseConfig_ExternalDictionary_Range) String

type ClickhouseConfig_ExternalDictionary_Source

type ClickhouseConfig_ExternalDictionary_Source = isClickhouseConfig_ExternalDictionary_Source

type ClickhouseConfig_ExternalDictionary_Structure

type ClickhouseConfig_ExternalDictionary_Structure struct {

	// Single numeric key column for the dictionary.
	Id *ClickhouseConfig_ExternalDictionary_Structure_Id `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Composite key for the dictionary, containing of one or more key columns.
	// For details, see [ClickHouse documentation](https://clickhouse.com/docs/en/query_language/dicts/external_dicts_dict_structure/#composite-key).
	Key *ClickhouseConfig_ExternalDictionary_Structure_Key `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// Field holding the beginning of the range for dictionaries with `RANGE_HASHED` layout.
	// For details, see [ClickHouse documentation](https://clickhouse.com/docs/en/query_language/dicts/external_dicts_dict_layout/#range-hashed).
	RangeMin *ClickhouseConfig_ExternalDictionary_Structure_Attribute `protobuf:"bytes,4,opt,name=range_min,json=rangeMin,proto3" json:"range_min,omitempty"`
	// Field holding the end of the range for dictionaries with `RANGE_HASHED` layout.
	// For details, see [ClickHouse documentation](https://clickhouse.com/docs/en/query_language/dicts/external_dicts_dict_layout/#range-hashed).
	RangeMax *ClickhouseConfig_ExternalDictionary_Structure_Attribute `protobuf:"bytes,5,opt,name=range_max,json=rangeMax,proto3" json:"range_max,omitempty"`
	// Description of the fields available for database queries.
	// For details, see [ClickHouse documentation](https://clickhouse.com/docs/en/query_language/dicts/external_dicts_dict_structure/#attributes).
	Attributes []*ClickhouseConfig_ExternalDictionary_Structure_Attribute `protobuf:"bytes,2,rep,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

func (*ClickhouseConfig_ExternalDictionary_Structure) Descriptor deprecated

Deprecated: Use ClickhouseConfig_ExternalDictionary_Structure.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary_Structure) GetAttributes

func (*ClickhouseConfig_ExternalDictionary_Structure) GetId

func (*ClickhouseConfig_ExternalDictionary_Structure) GetKey

func (*ClickhouseConfig_ExternalDictionary_Structure) GetRangeMax

func (*ClickhouseConfig_ExternalDictionary_Structure) GetRangeMin

func (*ClickhouseConfig_ExternalDictionary_Structure) ProtoMessage

func (*ClickhouseConfig_ExternalDictionary_Structure) ProtoReflect

func (*ClickhouseConfig_ExternalDictionary_Structure) Reset

func (*ClickhouseConfig_ExternalDictionary_Structure) SetAttributes

func (*ClickhouseConfig_ExternalDictionary_Structure) SetId

func (*ClickhouseConfig_ExternalDictionary_Structure) SetKey

func (*ClickhouseConfig_ExternalDictionary_Structure) SetRangeMax

func (*ClickhouseConfig_ExternalDictionary_Structure) SetRangeMin

func (*ClickhouseConfig_ExternalDictionary_Structure) String

type ClickhouseConfig_ExternalDictionary_Structure_Attribute

type ClickhouseConfig_ExternalDictionary_Structure_Attribute struct {

	// Name of the column.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Type of the column.
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Default value for an element without data (for example, an empty string).
	NullValue string `protobuf:"bytes,3,opt,name=null_value,json=nullValue,proto3" json:"null_value,omitempty"`
	// Expression, describing the attribute, if applicable.
	Expression string `protobuf:"bytes,4,opt,name=expression,proto3" json:"expression,omitempty"`
	// Indication of hierarchy support.
	// Default value: `false`.
	Hierarchical bool `protobuf:"varint,5,opt,name=hierarchical,proto3" json:"hierarchical,omitempty"`
	// Indication of injective mapping "id -> attribute".
	// Default value: `false`.
	Injective bool `protobuf:"varint,6,opt,name=injective,proto3" json:"injective,omitempty"`
	// contains filtered or unexported fields
}

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) Descriptor deprecated

Deprecated: Use ClickhouseConfig_ExternalDictionary_Structure_Attribute.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) GetExpression

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) GetHierarchical

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) GetInjective

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) GetName

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) GetNullValue

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) GetType

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) ProtoMessage

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) ProtoReflect

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) Reset

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) SetExpression

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) SetHierarchical

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) SetInjective

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) SetName

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) SetNullValue

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) SetType

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) String

type ClickhouseConfig_ExternalDictionary_Structure_Id

type ClickhouseConfig_ExternalDictionary_Structure_Id struct {

	// Name of the numeric key.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Numeric key.

func (*ClickhouseConfig_ExternalDictionary_Structure_Id) Descriptor deprecated

Deprecated: Use ClickhouseConfig_ExternalDictionary_Structure_Id.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary_Structure_Id) GetName

func (*ClickhouseConfig_ExternalDictionary_Structure_Id) ProtoMessage

func (*ClickhouseConfig_ExternalDictionary_Structure_Id) ProtoReflect

func (*ClickhouseConfig_ExternalDictionary_Structure_Id) Reset

func (*ClickhouseConfig_ExternalDictionary_Structure_Id) SetName

func (*ClickhouseConfig_ExternalDictionary_Structure_Id) String

type ClickhouseConfig_ExternalDictionary_Structure_Key

type ClickhouseConfig_ExternalDictionary_Structure_Key struct {

	// Attributes of a complex key.
	Attributes []*ClickhouseConfig_ExternalDictionary_Structure_Attribute `protobuf:"bytes,1,rep,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

Complex key.

func (*ClickhouseConfig_ExternalDictionary_Structure_Key) Descriptor deprecated

Deprecated: Use ClickhouseConfig_ExternalDictionary_Structure_Key.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary_Structure_Key) GetAttributes

func (*ClickhouseConfig_ExternalDictionary_Structure_Key) ProtoMessage

func (*ClickhouseConfig_ExternalDictionary_Structure_Key) ProtoReflect

func (*ClickhouseConfig_ExternalDictionary_Structure_Key) Reset

func (*ClickhouseConfig_ExternalDictionary_Structure_Key) SetAttributes

func (*ClickhouseConfig_ExternalDictionary_Structure_Key) String

type ClickhouseConfig_GraphiteRollup

type ClickhouseConfig_GraphiteRollup struct {

	// Name for the specified combination of settings for Graphite rollup.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Pattern to use for the rollup.
	Patterns []*ClickhouseConfig_GraphiteRollup_Pattern `protobuf:"bytes,2,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) GetName

func (*ClickhouseConfig_GraphiteRollup) GetPatterns

func (*ClickhouseConfig_GraphiteRollup) ProtoMessage

func (*ClickhouseConfig_GraphiteRollup) ProtoMessage()

func (*ClickhouseConfig_GraphiteRollup) ProtoReflect

func (*ClickhouseConfig_GraphiteRollup) Reset

func (*ClickhouseConfig_GraphiteRollup) SetName

func (*ClickhouseConfig_GraphiteRollup) SetPatterns

func (*ClickhouseConfig_GraphiteRollup) String

type ClickhouseConfig_GraphiteRollup_Pattern

type ClickhouseConfig_GraphiteRollup_Pattern struct {

	// Pattern for metric names.
	Regexp string `protobuf:"bytes,1,opt,name=regexp,proto3" json:"regexp,omitempty"`
	// Name of the aggregating function to apply to data of the age specified in [retention].
	Function string `protobuf:"bytes,2,opt,name=function,proto3" json:"function,omitempty"`
	// Age of data to use for thinning.
	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) SetFunction

func (*ClickhouseConfig_GraphiteRollup_Pattern) SetRegexp

func (*ClickhouseConfig_GraphiteRollup_Pattern) SetRetention

func (*ClickhouseConfig_GraphiteRollup_Pattern) String

type ClickhouseConfig_GraphiteRollup_Pattern_Retention

type ClickhouseConfig_GraphiteRollup_Pattern_Retention struct {

	// Minimum age of the data in seconds.
	Age int64 `protobuf:"varint,1,opt,name=age,proto3" json:"age,omitempty"`
	// Precision of determining the age of the data, in seconds.
	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) SetAge

func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) SetPrecision

func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) String

type ClickhouseConfig_Kafka

type ClickhouseConfig_Kafka struct {
	SecurityProtocol                 ClickhouseConfig_Kafka_SecurityProtocol `` /* 193-byte string literal not displayed */
	SaslMechanism                    ClickhouseConfig_Kafka_SaslMechanism    `` /* 181-byte string literal not displayed */
	SaslUsername                     string                                  `protobuf:"bytes,3,opt,name=sasl_username,json=saslUsername,proto3" json:"sasl_username,omitempty"`
	SaslPassword                     string                                  `protobuf:"bytes,4,opt,name=sasl_password,json=saslPassword,proto3" json:"sasl_password,omitempty"`
	EnableSslCertificateVerification *wrapperspb.BoolValue                   `` /* 161-byte string literal not displayed */
	MaxPollIntervalMs                *wrapperspb.Int64Value                  `protobuf:"bytes,6,opt,name=max_poll_interval_ms,json=maxPollIntervalMs,proto3" json:"max_poll_interval_ms,omitempty"`
	SessionTimeoutMs                 *wrapperspb.Int64Value                  `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() *wrapperspb.Int64Value

func (*ClickhouseConfig_Kafka) GetSaslMechanism

func (*ClickhouseConfig_Kafka) GetSaslPassword

func (x *ClickhouseConfig_Kafka) GetSaslPassword() string

func (*ClickhouseConfig_Kafka) GetSaslUsername

func (x *ClickhouseConfig_Kafka) GetSaslUsername() string

func (*ClickhouseConfig_Kafka) GetSecurityProtocol

func (*ClickhouseConfig_Kafka) GetSessionTimeoutMs

func (x *ClickhouseConfig_Kafka) GetSessionTimeoutMs() *wrapperspb.Int64Value

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

func (m *ClickhouseConfig_Kafka) SetEnableSslCertificateVerification(v *wrapperspb.BoolValue)

func (*ClickhouseConfig_Kafka) SetMaxPollIntervalMs

func (m *ClickhouseConfig_Kafka) SetMaxPollIntervalMs(v *wrapperspb.Int64Value)

func (*ClickhouseConfig_Kafka) SetSaslMechanism

func (*ClickhouseConfig_Kafka) SetSaslPassword

func (m *ClickhouseConfig_Kafka) SetSaslPassword(v string)

func (*ClickhouseConfig_Kafka) SetSaslUsername

func (m *ClickhouseConfig_Kafka) SetSaslUsername(v string)

func (*ClickhouseConfig_Kafka) SetSecurityProtocol

func (*ClickhouseConfig_Kafka) SetSessionTimeoutMs

func (m *ClickhouseConfig_Kafka) SetSessionTimeoutMs(v *wrapperspb.Int64Value)

func (*ClickhouseConfig_Kafka) String

func (x *ClickhouseConfig_Kafka) String() string

type ClickhouseConfig_KafkaTopic

type ClickhouseConfig_KafkaTopic struct {
	Name     string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Settings *ClickhouseConfig_Kafka `protobuf:"bytes,2,opt,name=settings,proto3" json:"settings,omitempty"`
	// contains filtered or unexported fields
}

func (*ClickhouseConfig_KafkaTopic) Descriptor deprecated

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

Deprecated: Use ClickhouseConfig_KafkaTopic.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_KafkaTopic) GetName

func (x *ClickhouseConfig_KafkaTopic) GetName() string

func (*ClickhouseConfig_KafkaTopic) GetSettings

func (*ClickhouseConfig_KafkaTopic) ProtoMessage

func (*ClickhouseConfig_KafkaTopic) ProtoMessage()

func (*ClickhouseConfig_KafkaTopic) ProtoReflect

func (*ClickhouseConfig_KafkaTopic) Reset

func (x *ClickhouseConfig_KafkaTopic) Reset()

func (*ClickhouseConfig_KafkaTopic) SetName

func (m *ClickhouseConfig_KafkaTopic) SetName(v string)

func (*ClickhouseConfig_KafkaTopic) SetSettings

func (*ClickhouseConfig_KafkaTopic) String

func (x *ClickhouseConfig_KafkaTopic) String() string

type ClickhouseConfig_Kafka_SaslMechanism

type ClickhouseConfig_Kafka_SaslMechanism int32
const (
	ClickhouseConfig_Kafka_SASL_MECHANISM_UNSPECIFIED   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_UNSPECIFIED    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_UNSPECIFIED ClickhouseConfig_LogLevel = 0
	ClickhouseConfig_TRACE                 ClickhouseConfig_LogLevel = 1
	ClickhouseConfig_DEBUG                 ClickhouseConfig_LogLevel = 2
	ClickhouseConfig_INFORMATION           ClickhouseConfig_LogLevel = 3
	ClickhouseConfig_WARNING               ClickhouseConfig_LogLevel = 4
	ClickhouseConfig_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 {

	// Number of blocks of hashes to keep in ZooKeeper.
	ReplicatedDeduplicationWindow *wrapperspb.Int64Value `` /* 150-byte string literal not displayed */
	// Period of time to keep blocks of hashes for.
	ReplicatedDeduplicationWindowSeconds *wrapperspb.Int64Value `` /* 173-byte string literal not displayed */
	// If table contains at least that many active parts in single partition, artificially slow down insert into table.
	PartsToDelayInsert *wrapperspb.Int64Value `protobuf:"bytes,3,opt,name=parts_to_delay_insert,json=partsToDelayInsert,proto3" json:"parts_to_delay_insert,omitempty"`
	// If more than this number active parts in single partition, throw 'Too many parts ...' exception.
	PartsToThrowInsert         *wrapperspb.Int64Value `protobuf:"bytes,4,opt,name=parts_to_throw_insert,json=partsToThrowInsert,proto3" json:"parts_to_throw_insert,omitempty"`
	InactivePartsToDelayInsert *wrapperspb.Int64Value `` /* 145-byte string literal not displayed */
	InactivePartsToThrowInsert *wrapperspb.Int64Value `` /* 146-byte string literal not displayed */
	// How many tasks of merging and mutating parts are allowed simultaneously in ReplicatedMergeTree queue.
	MaxReplicatedMergesInQueue *wrapperspb.Int64Value `` /* 145-byte string literal not displayed */
	// If there is less than specified number of free entries in background pool (or replicated queue), start to lower
	// maximum size of merge to process.
	NumberOfFreeEntriesInPoolToLowerMaxSizeOfMerge *wrapperspb.Int64Value `` /* 219-byte string literal not displayed */
	// Maximum in total size of parts to merge, when there are minimum free threads in background pool (or entries
	// in replication queue).
	MaxBytesToMergeAtMinSpaceInPool *wrapperspb.Int64Value `` /* 168-byte string literal not displayed */
	MaxBytesToMergeAtMaxSpaceInPool *wrapperspb.Int64Value `` /* 168-byte string literal not displayed */
	// Minimum number of bytes in a data part that can be stored in **Wide** format.
	//
	// More info see in [ClickHouse documentation](https://clickhouse.com/docs/en/engines/table-engines/mergetree-family/mergetree/#min_bytes_for_wide_part).
	MinBytesForWidePart *wrapperspb.Int64Value `protobuf:"bytes,11,opt,name=min_bytes_for_wide_part,json=minBytesForWidePart,proto3" json:"min_bytes_for_wide_part,omitempty"`
	// Minimum number of rows in a data part that can be stored in **Wide** format.
	//
	// More info see in [ClickHouse documentation](https://clickhouse.com/docs/en/engines/table-engines/mergetree-family/mergetree/#min_bytes_for_wide_part).
	MinRowsForWidePart *wrapperspb.Int64Value `protobuf:"bytes,12,opt,name=min_rows_for_wide_part,json=minRowsForWidePart,proto3" json:"min_rows_for_wide_part,omitempty"`
	// Enables or disables complete dropping of data parts where all rows are expired in MergeTree tables.
	//
	// More info see in [ClickHouse documentation](https://clickhouse.com/docs/en/operations/settings/settings/#ttl_only_drop_parts).
	TtlOnlyDropParts                           *wrapperspb.BoolValue  `protobuf:"bytes,13,opt,name=ttl_only_drop_parts,json=ttlOnlyDropParts,proto3" json:"ttl_only_drop_parts,omitempty"`
	AllowRemoteFsZeroCopyReplication           *wrapperspb.BoolValue  `` /* 166-byte string literal not displayed */
	MergeWithTtlTimeout                        *wrapperspb.Int64Value `protobuf:"bytes,15,opt,name=merge_with_ttl_timeout,json=mergeWithTtlTimeout,proto3" json:"merge_with_ttl_timeout,omitempty"`
	MergeWithRecompressionTtlTimeout           *wrapperspb.Int64Value `` /* 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                         *wrapperspb.Int64Value `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 */
	// The 'too many parts' check according to 'parts_to_delay_insert' and 'parts_to_throw_insert' will be active only if the average part size (in the relevant partition) is not larger than the specified threshold. If it is larger than the specified threshold, the INSERTs will be neither delayed or rejected. This allows to have hundreds of terabytes in a single table on a single server if the parts are successfully merged to larger parts. This does not affect the thresholds on inactive parts or total parts.
	// Default: 1 GiB
	// Min version: 22.10
	// See in-depth description in [ClickHouse GitHub](https://github.com/ClickHouse/ClickHouse/blob/f9558345e886876b9132d9c018e357f7fa9b22a3/src/Storages/MergeTree/MergeTreeSettings.h#L80)
	MaxAvgPartSizeForTooManyParts *wrapperspb.Int64Value `` /* 161-byte string literal not displayed */
	// Merge parts if every part in the range is older than the value of min_age_to_force_merge_seconds.
	// Default: 0 - disabled
	// Min_version: 22.10
	// See in-depth description in [ClickHouse documentation](https://clickhouse.com/docs/en/operations/settings/merge-tree-settings#min_age_to_force_merge_seconds)
	MinAgeToForceMergeSeconds *wrapperspb.Int64Value `` /* 145-byte string literal not displayed */
	// Whether min_age_to_force_merge_seconds should be applied only on the entire partition and not on subset.
	// Default: false
	// Min_version: 22.11
	// See in-depth description in [ClickHouse documentation](https://clickhouse.com/docs/en/operations/settings/merge-tree-settings#min_age_to_force_merge_seconds)
	MinAgeToForceMergeOnPartitionOnly *wrapperspb.BoolValue `` /* 173-byte string literal not displayed */
	// Sleep time for merge selecting when no part is selected. A lower setting triggers selecting tasks in background_schedule_pool frequently, which results in a large number of requests to ClickHouse Keeper in large-scale clusters.
	// Default: 5000
	// Min_version: 21.10
	// See in-depth description in [ClickHouse documentation](https://clickhouse.com/docs/en/operations/settings/settings#merge_selecting_sleep_ms)
	MergeSelectingSleepMs *wrapperspb.Int64Value `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

Options specific to the MergeTree table engine.

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() *wrapperspb.Int64Value

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() *wrapperspb.Int64Value

func (*ClickhouseConfig_MergeTree) GetMergeWithRecompressionTtlTimeout

func (x *ClickhouseConfig_MergeTree) GetMergeWithRecompressionTtlTimeout() *wrapperspb.Int64Value

func (*ClickhouseConfig_MergeTree) GetMergeWithTtlTimeout

func (x *ClickhouseConfig_MergeTree) GetMergeWithTtlTimeout() *wrapperspb.Int64Value

func (*ClickhouseConfig_MergeTree) GetMinAgeToForceMergeOnPartitionOnly

func (x *ClickhouseConfig_MergeTree) GetMinAgeToForceMergeOnPartitionOnly() *wrapperspb.BoolValue

func (*ClickhouseConfig_MergeTree) GetMinAgeToForceMergeSeconds

func (x *ClickhouseConfig_MergeTree) GetMinAgeToForceMergeSeconds() *wrapperspb.Int64Value

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() *wrapperspb.Int64Value

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

func (m *ClickhouseConfig_MergeTree) SetAllowRemoteFsZeroCopyReplication(v *wrapperspb.BoolValue)

func (*ClickhouseConfig_MergeTree) SetCleanupDelayPeriod

func (m *ClickhouseConfig_MergeTree) SetCleanupDelayPeriod(v *wrapperspb.Int64Value)

func (*ClickhouseConfig_MergeTree) SetInactivePartsToDelayInsert

func (m *ClickhouseConfig_MergeTree) SetInactivePartsToDelayInsert(v *wrapperspb.Int64Value)

func (*ClickhouseConfig_MergeTree) SetInactivePartsToThrowInsert

func (m *ClickhouseConfig_MergeTree) SetInactivePartsToThrowInsert(v *wrapperspb.Int64Value)

func (*ClickhouseConfig_MergeTree) SetMaxAvgPartSizeForTooManyParts

func (m *ClickhouseConfig_MergeTree) SetMaxAvgPartSizeForTooManyParts(v *wrapperspb.Int64Value)

func (*ClickhouseConfig_MergeTree) SetMaxBytesToMergeAtMaxSpaceInPool

func (m *ClickhouseConfig_MergeTree) SetMaxBytesToMergeAtMaxSpaceInPool(v *wrapperspb.Int64Value)

func (*ClickhouseConfig_MergeTree) SetMaxBytesToMergeAtMinSpaceInPool

func (m *ClickhouseConfig_MergeTree) SetMaxBytesToMergeAtMinSpaceInPool(v *wrapperspb.Int64Value)

func (*ClickhouseConfig_MergeTree) SetMaxNumberOfMergesWithTtlInPool

func (m *ClickhouseConfig_MergeTree) SetMaxNumberOfMergesWithTtlInPool(v *wrapperspb.Int64Value)

func (*ClickhouseConfig_MergeTree) SetMaxPartsInTotal

func (m *ClickhouseConfig_MergeTree) SetMaxPartsInTotal(v *wrapperspb.Int64Value)

func (*ClickhouseConfig_MergeTree) SetMaxReplicatedMergesInQueue

func (m *ClickhouseConfig_MergeTree) SetMaxReplicatedMergesInQueue(v *wrapperspb.Int64Value)

func (*ClickhouseConfig_MergeTree) SetMergeSelectingSleepMs

func (m *ClickhouseConfig_MergeTree) SetMergeSelectingSleepMs(v *wrapperspb.Int64Value)

func (*ClickhouseConfig_MergeTree) SetMergeWithRecompressionTtlTimeout

func (m *ClickhouseConfig_MergeTree) SetMergeWithRecompressionTtlTimeout(v *wrapperspb.Int64Value)

func (*ClickhouseConfig_MergeTree) SetMergeWithTtlTimeout

func (m *ClickhouseConfig_MergeTree) SetMergeWithTtlTimeout(v *wrapperspb.Int64Value)

func (*ClickhouseConfig_MergeTree) SetMinAgeToForceMergeOnPartitionOnly

func (m *ClickhouseConfig_MergeTree) SetMinAgeToForceMergeOnPartitionOnly(v *wrapperspb.BoolValue)

func (*ClickhouseConfig_MergeTree) SetMinAgeToForceMergeSeconds

func (m *ClickhouseConfig_MergeTree) SetMinAgeToForceMergeSeconds(v *wrapperspb.Int64Value)

func (*ClickhouseConfig_MergeTree) SetMinBytesForWidePart

func (m *ClickhouseConfig_MergeTree) SetMinBytesForWidePart(v *wrapperspb.Int64Value)

func (*ClickhouseConfig_MergeTree) SetMinRowsForWidePart

func (m *ClickhouseConfig_MergeTree) SetMinRowsForWidePart(v *wrapperspb.Int64Value)

func (*ClickhouseConfig_MergeTree) SetNumberOfFreeEntriesInPoolToExecuteMutation

func (m *ClickhouseConfig_MergeTree) SetNumberOfFreeEntriesInPoolToExecuteMutation(v *wrapperspb.Int64Value)

func (*ClickhouseConfig_MergeTree) SetNumberOfFreeEntriesInPoolToLowerMaxSizeOfMerge

func (m *ClickhouseConfig_MergeTree) SetNumberOfFreeEntriesInPoolToLowerMaxSizeOfMerge(v *wrapperspb.Int64Value)

func (*ClickhouseConfig_MergeTree) SetPartsToDelayInsert

func (m *ClickhouseConfig_MergeTree) SetPartsToDelayInsert(v *wrapperspb.Int64Value)

func (*ClickhouseConfig_MergeTree) SetPartsToThrowInsert

func (m *ClickhouseConfig_MergeTree) SetPartsToThrowInsert(v *wrapperspb.Int64Value)

func (*ClickhouseConfig_MergeTree) SetReplicatedDeduplicationWindow

func (m *ClickhouseConfig_MergeTree) SetReplicatedDeduplicationWindow(v *wrapperspb.Int64Value)

func (*ClickhouseConfig_MergeTree) SetReplicatedDeduplicationWindowSeconds

func (m *ClickhouseConfig_MergeTree) SetReplicatedDeduplicationWindowSeconds(v *wrapperspb.Int64Value)

func (*ClickhouseConfig_MergeTree) SetTtlOnlyDropParts

func (m *ClickhouseConfig_MergeTree) SetTtlOnlyDropParts(v *wrapperspb.BoolValue)

func (*ClickhouseConfig_MergeTree) String

func (x *ClickhouseConfig_MergeTree) String() string

type ClickhouseConfig_Rabbitmq

type ClickhouseConfig_Rabbitmq struct {

	// [RabbitMQ](https://clickhouse.com/docs/en/engines/table-engines/integrations/rabbitmq/) username
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	// [RabbitMQ](https://clickhouse.com/docs/en/engines/table-engines/integrations/rabbitmq/) password
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// [RabbitMQ](https://clickhouse.com/docs/en/engines/table-engines/integrations/rabbitmq/) virtual host
	Vhost string `protobuf:"bytes,3,opt,name=vhost,proto3" json:"vhost,omitempty"`
	// contains filtered or unexported fields
}

func (*ClickhouseConfig_Rabbitmq) Descriptor deprecated

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

Deprecated: Use ClickhouseConfig_Rabbitmq.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_Rabbitmq) GetPassword

func (x *ClickhouseConfig_Rabbitmq) GetPassword() string

func (*ClickhouseConfig_Rabbitmq) GetUsername

func (x *ClickhouseConfig_Rabbitmq) GetUsername() string

func (*ClickhouseConfig_Rabbitmq) GetVhost

func (x *ClickhouseConfig_Rabbitmq) GetVhost() string

func (*ClickhouseConfig_Rabbitmq) ProtoMessage

func (*ClickhouseConfig_Rabbitmq) ProtoMessage()

func (*ClickhouseConfig_Rabbitmq) ProtoReflect

func (*ClickhouseConfig_Rabbitmq) Reset

func (x *ClickhouseConfig_Rabbitmq) Reset()

func (*ClickhouseConfig_Rabbitmq) SetPassword

func (m *ClickhouseConfig_Rabbitmq) SetPassword(v string)

func (*ClickhouseConfig_Rabbitmq) SetUsername

func (m *ClickhouseConfig_Rabbitmq) SetUsername(v string)

func (*ClickhouseConfig_Rabbitmq) SetVhost

func (m *ClickhouseConfig_Rabbitmq) SetVhost(v string)

func (*ClickhouseConfig_Rabbitmq) String

func (x *ClickhouseConfig_Rabbitmq) String() string

Jump to

Keyboard shortcuts

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