clickhouse

package
v0.0.0-...-ea71516 Latest Latest
Warning

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

 Go to latest Published: Apr 19, 2021 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.yandex/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.yandex/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.yandex/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.yandex/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 *wrappers.Int64Value `protobuf:"bytes,6,opt,name=max_connections,json=maxConnections,proto3" json:"max_connections,omitempty"`
	// Maximum number of simultaneously processed requests.
	MaxConcurrentQueries *wrappers.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 *wrappers.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 *wrappers.Int64Value `` /* 126-byte string literal not displayed */
	// Approximate size (in bytes) of the cache of "marks" used by MergeTree tables.
	MarkCacheSize *wrappers.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 *wrappers.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 *wrappers.Int64Value `` /* 134-byte string literal not displayed */
	// The setting is deprecated and has no effect.
	//
	// Deprecated: Do not use.
	BuiltinDictionariesReloadInterval *wrappers.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"`
	// 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 *wrappers.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 *wrappers.Int64Value `` /* 129-byte string literal not displayed */
	// Whether query_thread_log system table is enabled.
	QueryThreadLogEnabled *wrappers.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 *wrappers.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 *wrappers.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 *wrappers.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 *wrappers.Int64Value `` /* 126-byte string literal not displayed */
	// Whether metric_log system table is enabled.
	MetricLogEnabled *wrappers.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 *wrappers.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 *wrappers.Int64Value `` /* 132-byte string literal not displayed */
	// Whether trace_log system table is enabled.
	TraceLogEnabled *wrappers.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 *wrappers.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 *wrappers.Int64Value `` /* 129-byte string literal not displayed */
	// Whether text_log system table is enabled.
	TextLogEnabled *wrappers.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 *wrappers.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 *wrappers.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 */
	BackgroundPoolSize         *wrappers.Int64Value      `protobuf:"bytes,33,opt,name=background_pool_size,json=backgroundPoolSize,proto3" json:"background_pool_size,omitempty"`
	BackgroundSchedulePoolSize *wrappers.Int64Value      `` /* 144-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.yandex/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) GetBackgroundPoolSize 

func (x *ClickhouseConfig) GetBackgroundPoolSize() *wrappers.Int64Value

func (*ClickhouseConfig) GetBackgroundSchedulePoolSize 

func (x *ClickhouseConfig) GetBackgroundSchedulePoolSize() *wrappers.Int64Value

func (*ClickhouseConfig) GetBuiltinDictionariesReloadInterval deprecated 

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

Deprecated: Do not use.

func (*ClickhouseConfig) GetCompression 

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

func (*ClickhouseConfig) GetDictionaries 

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

func (*ClickhouseConfig) GetGeobaseUri 

func (x *ClickhouseConfig) GetGeobaseUri() string

func (*ClickhouseConfig) GetGraphiteRollup 

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

func (*ClickhouseConfig) GetKafka 

func (x *ClickhouseConfig) GetKafka() *ClickhouseConfig_Kafka

func (*ClickhouseConfig) GetKafkaTopics 

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

func (*ClickhouseConfig) GetKeepAliveTimeout 

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

func (*ClickhouseConfig) GetLogLevel 

func (x *ClickhouseConfig) GetLogLevel() ClickhouseConfig_LogLevel

func (*ClickhouseConfig) GetMarkCacheSize 

func (x *ClickhouseConfig) GetMarkCacheSize() *wrappers.Int64Value

func (*ClickhouseConfig) GetMaxConcurrentQueries 

func (x *ClickhouseConfig) GetMaxConcurrentQueries() *wrappers.Int64Value

func (*ClickhouseConfig) GetMaxConnections 

func (x *ClickhouseConfig) GetMaxConnections() *wrappers.Int64Value

func (*ClickhouseConfig) GetMaxPartitionSizeToDrop 

func (x *ClickhouseConfig) GetMaxPartitionSizeToDrop() *wrappers.Int64Value

func (*ClickhouseConfig) GetMaxTableSizeToDrop 

func (x *ClickhouseConfig) GetMaxTableSizeToDrop() *wrappers.Int64Value

func (*ClickhouseConfig) GetMergeTree 

func (x *ClickhouseConfig) GetMergeTree() *ClickhouseConfig_MergeTree

func (*ClickhouseConfig) GetMetricLogEnabled 

func (x *ClickhouseConfig) GetMetricLogEnabled() *wrappers.BoolValue

func (*ClickhouseConfig) GetMetricLogRetentionSize 

func (x *ClickhouseConfig) GetMetricLogRetentionSize() *wrappers.Int64Value

func (*ClickhouseConfig) GetMetricLogRetentionTime 

func (x *ClickhouseConfig) GetMetricLogRetentionTime() *wrappers.Int64Value

func (*ClickhouseConfig) GetPartLogRetentionSize 

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

func (*ClickhouseConfig) GetPartLogRetentionTime 

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

func (*ClickhouseConfig) GetQueryLogRetentionSize 

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

func (*ClickhouseConfig) GetQueryLogRetentionTime 

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

func (*ClickhouseConfig) GetQueryThreadLogEnabled 

func (x *ClickhouseConfig) GetQueryThreadLogEnabled() *wrappers.BoolValue

func (*ClickhouseConfig) GetQueryThreadLogRetentionSize 

func (x *ClickhouseConfig) GetQueryThreadLogRetentionSize() *wrappers.Int64Value

func (*ClickhouseConfig) GetQueryThreadLogRetentionTime 

func (x *ClickhouseConfig) GetQueryThreadLogRetentionTime() *wrappers.Int64Value

func (*ClickhouseConfig) GetRabbitmq 

func (x *ClickhouseConfig) GetRabbitmq() *ClickhouseConfig_Rabbitmq

func (*ClickhouseConfig) GetTextLogEnabled 

func (x *ClickhouseConfig) GetTextLogEnabled() *wrappers.BoolValue

func (*ClickhouseConfig) GetTextLogLevel 

func (x *ClickhouseConfig) GetTextLogLevel() ClickhouseConfig_LogLevel

func (*ClickhouseConfig) GetTextLogRetentionSize 

func (x *ClickhouseConfig) GetTextLogRetentionSize() *wrappers.Int64Value

func (*ClickhouseConfig) GetTextLogRetentionTime 

func (x *ClickhouseConfig) GetTextLogRetentionTime() *wrappers.Int64Value

func (*ClickhouseConfig) GetTimezone 

func (x *ClickhouseConfig) GetTimezone() string

func (*ClickhouseConfig) GetTraceLogEnabled 

func (x *ClickhouseConfig) GetTraceLogEnabled() *wrappers.BoolValue

func (*ClickhouseConfig) GetTraceLogRetentionSize 

func (x *ClickhouseConfig) GetTraceLogRetentionSize() *wrappers.Int64Value

func (*ClickhouseConfig) GetTraceLogRetentionTime 

func (x *ClickhouseConfig) GetTraceLogRetentionTime() *wrappers.Int64Value

func (*ClickhouseConfig) GetUncompressedCacheSize 

func (x *ClickhouseConfig) GetUncompressedCacheSize() *wrappers.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) SetBackgroundPoolSize 

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

func (*ClickhouseConfig) SetBackgroundSchedulePoolSize 

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

func (*ClickhouseConfig) SetBuiltinDictionariesReloadInterval 

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

func (*ClickhouseConfig) SetCompression 

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

func (*ClickhouseConfig) SetDictionaries 

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

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

func (*ClickhouseConfig) SetLogLevel 

func (m *ClickhouseConfig) SetLogLevel(v ClickhouseConfig_LogLevel)

func (*ClickhouseConfig) SetMarkCacheSize 

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

func (*ClickhouseConfig) SetMaxConcurrentQueries 

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

func (*ClickhouseConfig) SetMaxConnections 

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

func (*ClickhouseConfig) SetMaxPartitionSizeToDrop 

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

func (*ClickhouseConfig) SetMaxTableSizeToDrop 

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

func (*ClickhouseConfig) SetMergeTree 

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

func (*ClickhouseConfig) SetMetricLogEnabled 

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

func (*ClickhouseConfig) SetMetricLogRetentionSize 

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

func (*ClickhouseConfig) SetMetricLogRetentionTime 

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

func (*ClickhouseConfig) SetPartLogRetentionSize 

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

func (*ClickhouseConfig) SetPartLogRetentionTime 

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

func (*ClickhouseConfig) SetQueryLogRetentionSize 

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

func (*ClickhouseConfig) SetQueryLogRetentionTime 

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

func (*ClickhouseConfig) SetQueryThreadLogEnabled 

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

func (*ClickhouseConfig) SetQueryThreadLogRetentionSize 

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

func (*ClickhouseConfig) SetQueryThreadLogRetentionTime 

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

func (*ClickhouseConfig) SetRabbitmq 

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

func (*ClickhouseConfig) SetTextLogEnabled 

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

func (*ClickhouseConfig) SetTextLogLevel 

func (m *ClickhouseConfig) SetTextLogLevel(v ClickhouseConfig_LogLevel)

func (*ClickhouseConfig) SetTextLogRetentionSize 

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

func (*ClickhouseConfig) SetTextLogRetentionTime 

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

func (*ClickhouseConfig) SetTimezone 

func (m *ClickhouseConfig) SetTimezone(v string)

func (*ClickhouseConfig) SetTraceLogEnabled 

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

func (*ClickhouseConfig) SetTraceLogRetentionSize 

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

func (*ClickhouseConfig) SetTraceLogRetentionTime 

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

func (*ClickhouseConfig) SetUncompressedCacheSize 

func (m *ClickhouseConfig) SetUncompressedCacheSize(v *wrappers.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"`
	// 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) GetMethod 

func (x *ClickhouseConfig_Compression) GetMethod() ClickhouseConfig_Compression_Method

func (*ClickhouseConfig_Compression) GetMinPartSize 

func (x *ClickhouseConfig_Compression) GetMinPartSize() int64

func (*ClickhouseConfig_Compression) GetMinPartSizeRatio 

func (x *ClickhouseConfig_Compression) GetMinPartSizeRatio() float64

func (*ClickhouseConfig_Compression) ProtoMessage 

func (*ClickhouseConfig_Compression) ProtoMessage()

func (*ClickhouseConfig_Compression) ProtoReflect 

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

func (*ClickhouseConfig_Compression) Reset 

func (x *ClickhouseConfig_Compression) Reset()

func (*ClickhouseConfig_Compression) SetMethod 

func (m *ClickhouseConfig_Compression) SetMethod(v ClickhouseConfig_Compression_Method)

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 

func (x *ClickhouseConfig_Compression) String() 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) Descriptor() protoreflect.EnumDescriptor

func (ClickhouseConfig_Compression_Method) Enum 

func (x ClickhouseConfig_Compression_Method) Enum() *ClickhouseConfig_Compression_Method

func (ClickhouseConfig_Compression_Method) EnumDescriptor deprecated 

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

Deprecated: Use ClickhouseConfig_Compression_Method.Descriptor instead.

func (ClickhouseConfig_Compression_Method) Number 

func (x ClickhouseConfig_Compression_Method) Number() protoreflect.EnumNumber

func (ClickhouseConfig_Compression_Method) String 

func (x ClickhouseConfig_Compression_Method) String() string

func (ClickhouseConfig_Compression_Method) Type 

func (ClickhouseConfig_Compression_Method) Type() protoreflect.EnumType

type ClickhouseConfig_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.yandex/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.yandex/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.yandex/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 (x *ClickhouseConfig_ExternalDictionary) GetClickhouseSource() *ClickhouseConfig_ExternalDictionary_ClickhouseSource

func (*ClickhouseConfig_ExternalDictionary) GetFixedLifetime 

func (x *ClickhouseConfig_ExternalDictionary) GetFixedLifetime() int64

func (*ClickhouseConfig_ExternalDictionary) GetHttpSource 

func (x *ClickhouseConfig_ExternalDictionary) GetHttpSource() *ClickhouseConfig_ExternalDictionary_HttpSource

func (*ClickhouseConfig_ExternalDictionary) GetLayout 

func (x *ClickhouseConfig_ExternalDictionary) GetLayout() *ClickhouseConfig_ExternalDictionary_Layout

func (*ClickhouseConfig_ExternalDictionary) GetLifetime 

func (m *ClickhouseConfig_ExternalDictionary) GetLifetime() isClickhouseConfig_ExternalDictionary_Lifetime

func (*ClickhouseConfig_ExternalDictionary) GetLifetimeRange 

func (x *ClickhouseConfig_ExternalDictionary) GetLifetimeRange() *ClickhouseConfig_ExternalDictionary_Range

func (*ClickhouseConfig_ExternalDictionary) GetMongodbSource 

func (x *ClickhouseConfig_ExternalDictionary) GetMongodbSource() *ClickhouseConfig_ExternalDictionary_MongodbSource

func (*ClickhouseConfig_ExternalDictionary) GetMysqlSource 

func (x *ClickhouseConfig_ExternalDictionary) GetMysqlSource() *ClickhouseConfig_ExternalDictionary_MysqlSource

func (*ClickhouseConfig_ExternalDictionary) GetName 

func (x *ClickhouseConfig_ExternalDictionary) GetName() string

func (*ClickhouseConfig_ExternalDictionary) GetPostgresqlSource 

func (x *ClickhouseConfig_ExternalDictionary) GetPostgresqlSource() *ClickhouseConfig_ExternalDictionary_PostgresqlSource

func (*ClickhouseConfig_ExternalDictionary) GetSource 

func (m *ClickhouseConfig_ExternalDictionary) GetSource() isClickhouseConfig_ExternalDictionary_Source

func (*ClickhouseConfig_ExternalDictionary) GetStructure 

func (x *ClickhouseConfig_ExternalDictionary) GetStructure() *ClickhouseConfig_ExternalDictionary_Structure

func (*ClickhouseConfig_ExternalDictionary) ProtoMessage 

func (*ClickhouseConfig_ExternalDictionary) ProtoMessage()

func (*ClickhouseConfig_ExternalDictionary) ProtoReflect 

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

func (*ClickhouseConfig_ExternalDictionary) Reset 

func (x *ClickhouseConfig_ExternalDictionary) Reset()

func (*ClickhouseConfig_ExternalDictionary) SetClickhouseSource 

func (m *ClickhouseConfig_ExternalDictionary) SetClickhouseSource(v *ClickhouseConfig_ExternalDictionary_ClickhouseSource)

func (*ClickhouseConfig_ExternalDictionary) SetFixedLifetime 

func (m *ClickhouseConfig_ExternalDictionary) SetFixedLifetime(v int64)

func (*ClickhouseConfig_ExternalDictionary) SetHttpSource 

func (m *ClickhouseConfig_ExternalDictionary) SetHttpSource(v *ClickhouseConfig_ExternalDictionary_HttpSource)

func (*ClickhouseConfig_ExternalDictionary) SetLayout 

func (m *ClickhouseConfig_ExternalDictionary) SetLayout(v *ClickhouseConfig_ExternalDictionary_Layout)

func (*ClickhouseConfig_ExternalDictionary) SetLifetime 

func (m *ClickhouseConfig_ExternalDictionary) SetLifetime(v ClickhouseConfig_ExternalDictionary_Lifetime)

func (*ClickhouseConfig_ExternalDictionary) SetLifetimeRange 

func (m *ClickhouseConfig_ExternalDictionary) SetLifetimeRange(v *ClickhouseConfig_ExternalDictionary_Range)

func (*ClickhouseConfig_ExternalDictionary) SetMongodbSource 

func (m *ClickhouseConfig_ExternalDictionary) SetMongodbSource(v *ClickhouseConfig_ExternalDictionary_MongodbSource)

func (*ClickhouseConfig_ExternalDictionary) SetMysqlSource 

func (m *ClickhouseConfig_ExternalDictionary) SetMysqlSource(v *ClickhouseConfig_ExternalDictionary_MysqlSource)

func (*ClickhouseConfig_ExternalDictionary) SetName 

func (m *ClickhouseConfig_ExternalDictionary) SetName(v string)

func (*ClickhouseConfig_ExternalDictionary) SetPostgresqlSource 

func (m *ClickhouseConfig_ExternalDictionary) SetPostgresqlSource(v *ClickhouseConfig_ExternalDictionary_PostgresqlSource)

func (*ClickhouseConfig_ExternalDictionary) SetSource 

func (m *ClickhouseConfig_ExternalDictionary) SetSource(v ClickhouseConfig_ExternalDictionary_Source)

func (*ClickhouseConfig_ExternalDictionary) SetStructure 

func (m *ClickhouseConfig_ExternalDictionary) SetStructure(v *ClickhouseConfig_ExternalDictionary_Structure)

func (*ClickhouseConfig_ExternalDictionary) String 

func (x *ClickhouseConfig_ExternalDictionary) String() 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 

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

Deprecated: Use ClickhouseConfig_ExternalDictionary_ClickhouseSource.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) GetDb 

func (x *ClickhouseConfig_ExternalDictionary_ClickhouseSource) GetDb() string

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) GetHost 

func (x *ClickhouseConfig_ExternalDictionary_ClickhouseSource) GetHost() string

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) GetPassword 

func (x *ClickhouseConfig_ExternalDictionary_ClickhouseSource) GetPassword() string

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) GetPort 

func (x *ClickhouseConfig_ExternalDictionary_ClickhouseSource) GetPort() int64

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) GetTable 

func (x *ClickhouseConfig_ExternalDictionary_ClickhouseSource) GetTable() string

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) GetUser 

func (x *ClickhouseConfig_ExternalDictionary_ClickhouseSource) GetUser() string

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) GetWhere 

func (x *ClickhouseConfig_ExternalDictionary_ClickhouseSource) GetWhere() string

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) ProtoMessage 

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) ProtoMessage()

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) ProtoReflect 

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

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) Reset 

func (x *ClickhouseConfig_ExternalDictionary_ClickhouseSource) Reset()

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) SetDb 

func (m *ClickhouseConfig_ExternalDictionary_ClickhouseSource) SetDb(v string)

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) SetHost 

func (m *ClickhouseConfig_ExternalDictionary_ClickhouseSource) SetHost(v string)

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) SetPassword 

func (m *ClickhouseConfig_ExternalDictionary_ClickhouseSource) SetPassword(v string)

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) SetPort 

func (m *ClickhouseConfig_ExternalDictionary_ClickhouseSource) SetPort(v int64)

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) SetTable 

func (m *ClickhouseConfig_ExternalDictionary_ClickhouseSource) SetTable(v string)

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) SetUser 

func (m *ClickhouseConfig_ExternalDictionary_ClickhouseSource) SetUser(v string)

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) SetWhere 

func (m *ClickhouseConfig_ExternalDictionary_ClickhouseSource) SetWhere(v string)

func (*ClickhouseConfig_ExternalDictionary_ClickhouseSource) String 

func (x *ClickhouseConfig_ExternalDictionary_ClickhouseSource) String() 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 

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

Deprecated: Use ClickhouseConfig_ExternalDictionary_HttpSource.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary_HttpSource) GetFormat 

func (x *ClickhouseConfig_ExternalDictionary_HttpSource) GetFormat() string

func (*ClickhouseConfig_ExternalDictionary_HttpSource) GetUrl 

func (x *ClickhouseConfig_ExternalDictionary_HttpSource) GetUrl() string

func (*ClickhouseConfig_ExternalDictionary_HttpSource) ProtoMessage 

func (*ClickhouseConfig_ExternalDictionary_HttpSource) ProtoMessage()

func (*ClickhouseConfig_ExternalDictionary_HttpSource) ProtoReflect 

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

func (*ClickhouseConfig_ExternalDictionary_HttpSource) Reset 

func (x *ClickhouseConfig_ExternalDictionary_HttpSource) Reset()

func (*ClickhouseConfig_ExternalDictionary_HttpSource) SetFormat 

func (m *ClickhouseConfig_ExternalDictionary_HttpSource) SetFormat(v string)

func (*ClickhouseConfig_ExternalDictionary_HttpSource) SetUrl 

func (m *ClickhouseConfig_ExternalDictionary_HttpSource) SetUrl(v string)

func (*ClickhouseConfig_ExternalDictionary_HttpSource) String 

func (x *ClickhouseConfig_ExternalDictionary_HttpSource) String() 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 

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

Deprecated: Use ClickhouseConfig_ExternalDictionary_Layout.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary_Layout) GetSizeInCells 

func (x *ClickhouseConfig_ExternalDictionary_Layout) GetSizeInCells() int64

func (*ClickhouseConfig_ExternalDictionary_Layout) GetType 

func (x *ClickhouseConfig_ExternalDictionary_Layout) GetType() ClickhouseConfig_ExternalDictionary_Layout_Type

func (*ClickhouseConfig_ExternalDictionary_Layout) ProtoMessage 

func (*ClickhouseConfig_ExternalDictionary_Layout) ProtoMessage()

func (*ClickhouseConfig_ExternalDictionary_Layout) ProtoReflect 

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

func (*ClickhouseConfig_ExternalDictionary_Layout) Reset 

func (x *ClickhouseConfig_ExternalDictionary_Layout) Reset()

func (*ClickhouseConfig_ExternalDictionary_Layout) SetSizeInCells 

func (m *ClickhouseConfig_ExternalDictionary_Layout) SetSizeInCells(v int64)

func (*ClickhouseConfig_ExternalDictionary_Layout) SetType 

func (m *ClickhouseConfig_ExternalDictionary_Layout) SetType(v ClickhouseConfig_ExternalDictionary_Layout_Type)

func (*ClickhouseConfig_ExternalDictionary_Layout) String 

func (x *ClickhouseConfig_ExternalDictionary_Layout) String() 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) Descriptor() protoreflect.EnumDescriptor

func (ClickhouseConfig_ExternalDictionary_Layout_Type) Enum 

func (x ClickhouseConfig_ExternalDictionary_Layout_Type) Enum() *ClickhouseConfig_ExternalDictionary_Layout_Type

func (ClickhouseConfig_ExternalDictionary_Layout_Type) EnumDescriptor deprecated 

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

Deprecated: Use ClickhouseConfig_ExternalDictionary_Layout_Type.Descriptor instead.

func (ClickhouseConfig_ExternalDictionary_Layout_Type) Number 

func (x ClickhouseConfig_ExternalDictionary_Layout_Type) Number() protoreflect.EnumNumber

func (ClickhouseConfig_ExternalDictionary_Layout_Type) String 

func (x ClickhouseConfig_ExternalDictionary_Layout_Type) String() string

func (ClickhouseConfig_ExternalDictionary_Layout_Type) Type 

func (ClickhouseConfig_ExternalDictionary_Layout_Type) Type() protoreflect.EnumType

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"`
	// contains filtered or unexported fields
}

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) Descriptor deprecated 

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

Deprecated: Use ClickhouseConfig_ExternalDictionary_MongodbSource.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) GetCollection 

func (x *ClickhouseConfig_ExternalDictionary_MongodbSource) GetCollection() string

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) GetDb 

func (x *ClickhouseConfig_ExternalDictionary_MongodbSource) GetDb() string

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) GetHost 

func (x *ClickhouseConfig_ExternalDictionary_MongodbSource) GetHost() string

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) GetPassword 

func (x *ClickhouseConfig_ExternalDictionary_MongodbSource) GetPassword() string

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) GetPort 

func (x *ClickhouseConfig_ExternalDictionary_MongodbSource) GetPort() int64

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) GetUser 

func (x *ClickhouseConfig_ExternalDictionary_MongodbSource) GetUser() string

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) ProtoMessage 

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) ProtoMessage()

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) ProtoReflect 

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

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) Reset 

func (x *ClickhouseConfig_ExternalDictionary_MongodbSource) Reset()

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) SetCollection 

func (m *ClickhouseConfig_ExternalDictionary_MongodbSource) SetCollection(v string)

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) SetDb 

func (m *ClickhouseConfig_ExternalDictionary_MongodbSource) SetDb(v string)

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) SetHost 

func (m *ClickhouseConfig_ExternalDictionary_MongodbSource) SetHost(v string)

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) SetPassword 

func (m *ClickhouseConfig_ExternalDictionary_MongodbSource) SetPassword(v string)

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) SetPort 

func (m *ClickhouseConfig_ExternalDictionary_MongodbSource) SetPort(v int64)

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) SetUser 

func (m *ClickhouseConfig_ExternalDictionary_MongodbSource) SetUser(v string)

func (*ClickhouseConfig_ExternalDictionary_MongodbSource) String 

func (x *ClickhouseConfig_ExternalDictionary_MongodbSource) String() 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.yandex/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 

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

Deprecated: Use ClickhouseConfig_ExternalDictionary_MysqlSource.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) GetDb 

func (x *ClickhouseConfig_ExternalDictionary_MysqlSource) GetDb() string

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) GetInvalidateQuery 

func (x *ClickhouseConfig_ExternalDictionary_MysqlSource) GetInvalidateQuery() string

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) GetPassword 

func (x *ClickhouseConfig_ExternalDictionary_MysqlSource) GetPassword() string

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) GetPort 

func (x *ClickhouseConfig_ExternalDictionary_MysqlSource) GetPort() int64

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) GetReplicas 

func (x *ClickhouseConfig_ExternalDictionary_MysqlSource) GetReplicas() []*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) GetTable 

func (x *ClickhouseConfig_ExternalDictionary_MysqlSource) GetTable() string

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) GetUser 

func (x *ClickhouseConfig_ExternalDictionary_MysqlSource) GetUser() string

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) GetWhere 

func (x *ClickhouseConfig_ExternalDictionary_MysqlSource) GetWhere() string

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) ProtoMessage 

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) ProtoMessage()

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) ProtoReflect 

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

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) Reset 

func (x *ClickhouseConfig_ExternalDictionary_MysqlSource) Reset()

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) SetDb 

func (m *ClickhouseConfig_ExternalDictionary_MysqlSource) SetDb(v string)

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) SetInvalidateQuery 

func (m *ClickhouseConfig_ExternalDictionary_MysqlSource) SetInvalidateQuery(v string)

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) SetPassword 

func (m *ClickhouseConfig_ExternalDictionary_MysqlSource) SetPassword(v string)

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) SetPort 

func (m *ClickhouseConfig_ExternalDictionary_MysqlSource) SetPort(v int64)

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) SetReplicas 

func (m *ClickhouseConfig_ExternalDictionary_MysqlSource) SetReplicas(v []*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica)

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) SetTable 

func (m *ClickhouseConfig_ExternalDictionary_MysqlSource) SetTable(v string)

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) SetUser 

func (m *ClickhouseConfig_ExternalDictionary_MysqlSource) SetUser(v string)

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) SetWhere 

func (m *ClickhouseConfig_ExternalDictionary_MysqlSource) SetWhere(v string)

func (*ClickhouseConfig_ExternalDictionary_MysqlSource) String 

func (x *ClickhouseConfig_ExternalDictionary_MysqlSource) String() 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 

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

Deprecated: Use ClickhouseConfig_ExternalDictionary_MysqlSource_Replica.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) GetHost 

func (x *ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) GetHost() string

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) GetPassword 

func (x *ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) GetPassword() string

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) GetPort 

func (x *ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) GetPort() int64

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) GetPriority 

func (x *ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) GetPriority() int64

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) GetUser 

func (x *ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) GetUser() string

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) ProtoMessage 

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) ProtoMessage()

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) ProtoReflect 

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

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) Reset 

func (x *ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) Reset()

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) SetHost 

func (m *ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) SetHost(v string)

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) SetPassword 

func (m *ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) SetPassword(v string)

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) SetPort 

func (m *ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) SetPort(v int64)

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) SetPriority 

func (m *ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) SetPriority(v int64)

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) SetUser 

func (m *ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) SetUser(v string)

func (*ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) String 

func (x *ClickhouseConfig_ExternalDictionary_MysqlSource_Replica) String() 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.yandex/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 

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

Deprecated: Use ClickhouseConfig_ExternalDictionary_PostgresqlSource.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetDb 

func (x *ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetDb() string

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetHosts 

func (x *ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetHosts() []string

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetInvalidateQuery 

func (x *ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetInvalidateQuery() string

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetPassword 

func (x *ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetPassword() string

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetPort 

func (x *ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetPort() int64

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetSslMode 

func (x *ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetSslMode() ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetTable 

func (x *ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetTable() string

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetUser 

func (x *ClickhouseConfig_ExternalDictionary_PostgresqlSource) GetUser() string

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) ProtoMessage 

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) ProtoMessage()

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) ProtoReflect 

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

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) Reset 

func (x *ClickhouseConfig_ExternalDictionary_PostgresqlSource) Reset()

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetDb 

func (m *ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetDb(v string)

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetHosts 

func (m *ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetHosts(v []string)

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetInvalidateQuery 

func (m *ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetInvalidateQuery(v string)

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetPassword 

func (m *ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetPassword(v string)

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetPort 

func (m *ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetPort(v int64)

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetSslMode 

func (m *ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetSslMode(v ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode)

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetTable 

func (m *ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetTable(v string)

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetUser 

func (m *ClickhouseConfig_ExternalDictionary_PostgresqlSource) SetUser(v string)

func (*ClickhouseConfig_ExternalDictionary_PostgresqlSource) String 

func (x *ClickhouseConfig_ExternalDictionary_PostgresqlSource) String() 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) Descriptor() protoreflect.EnumDescriptor

func (ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode) Enum 

func (x ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode) Enum() *ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode

func (ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode) EnumDescriptor deprecated 

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

Deprecated: Use ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode.Descriptor instead.

func (ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode) Number 

func (x ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode) Number() protoreflect.EnumNumber

func (ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode) String 

func (x ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode) String() string

func (ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode) Type 

func (ClickhouseConfig_ExternalDictionary_PostgresqlSource_SslMode) Type() protoreflect.EnumType

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 (x *ClickhouseConfig_ExternalDictionary_Range) GetMax() int64

func (*ClickhouseConfig_ExternalDictionary_Range) GetMin 

func (x *ClickhouseConfig_ExternalDictionary_Range) GetMin() int64

func (*ClickhouseConfig_ExternalDictionary_Range) ProtoMessage 

func (*ClickhouseConfig_ExternalDictionary_Range) ProtoMessage()

func (*ClickhouseConfig_ExternalDictionary_Range) ProtoReflect 

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

func (*ClickhouseConfig_ExternalDictionary_Range) Reset 

func (x *ClickhouseConfig_ExternalDictionary_Range) Reset()

func (*ClickhouseConfig_ExternalDictionary_Range) SetMax 

func (m *ClickhouseConfig_ExternalDictionary_Range) SetMax(v int64)

func (*ClickhouseConfig_ExternalDictionary_Range) SetMin 

func (m *ClickhouseConfig_ExternalDictionary_Range) SetMin(v int64)

func (*ClickhouseConfig_ExternalDictionary_Range) String 

func (x *ClickhouseConfig_ExternalDictionary_Range) String() 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.yandex/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.yandex/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.yandex/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.yandex/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 

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

Deprecated: Use ClickhouseConfig_ExternalDictionary_Structure.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary_Structure) GetAttributes 

func (x *ClickhouseConfig_ExternalDictionary_Structure) GetAttributes() []*ClickhouseConfig_ExternalDictionary_Structure_Attribute

func (*ClickhouseConfig_ExternalDictionary_Structure) GetId 

func (x *ClickhouseConfig_ExternalDictionary_Structure) GetId() *ClickhouseConfig_ExternalDictionary_Structure_Id

func (*ClickhouseConfig_ExternalDictionary_Structure) GetKey 

func (x *ClickhouseConfig_ExternalDictionary_Structure) GetKey() *ClickhouseConfig_ExternalDictionary_Structure_Key

func (*ClickhouseConfig_ExternalDictionary_Structure) GetRangeMax 

func (x *ClickhouseConfig_ExternalDictionary_Structure) GetRangeMax() *ClickhouseConfig_ExternalDictionary_Structure_Attribute

func (*ClickhouseConfig_ExternalDictionary_Structure) GetRangeMin 

func (x *ClickhouseConfig_ExternalDictionary_Structure) GetRangeMin() *ClickhouseConfig_ExternalDictionary_Structure_Attribute

func (*ClickhouseConfig_ExternalDictionary_Structure) ProtoMessage 

func (*ClickhouseConfig_ExternalDictionary_Structure) ProtoMessage()

func (*ClickhouseConfig_ExternalDictionary_Structure) ProtoReflect 

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

func (*ClickhouseConfig_ExternalDictionary_Structure) Reset 

func (x *ClickhouseConfig_ExternalDictionary_Structure) Reset()

func (*ClickhouseConfig_ExternalDictionary_Structure) SetAttributes 

func (m *ClickhouseConfig_ExternalDictionary_Structure) SetAttributes(v []*ClickhouseConfig_ExternalDictionary_Structure_Attribute)

func (*ClickhouseConfig_ExternalDictionary_Structure) SetId 

func (m *ClickhouseConfig_ExternalDictionary_Structure) SetId(v *ClickhouseConfig_ExternalDictionary_Structure_Id)

func (*ClickhouseConfig_ExternalDictionary_Structure) SetKey 

func (m *ClickhouseConfig_ExternalDictionary_Structure) SetKey(v *ClickhouseConfig_ExternalDictionary_Structure_Key)

func (*ClickhouseConfig_ExternalDictionary_Structure) SetRangeMax 

func (m *ClickhouseConfig_ExternalDictionary_Structure) SetRangeMax(v *ClickhouseConfig_ExternalDictionary_Structure_Attribute)

func (*ClickhouseConfig_ExternalDictionary_Structure) SetRangeMin 

func (m *ClickhouseConfig_ExternalDictionary_Structure) SetRangeMin(v *ClickhouseConfig_ExternalDictionary_Structure_Attribute)

func (*ClickhouseConfig_ExternalDictionary_Structure) String 

func (x *ClickhouseConfig_ExternalDictionary_Structure) String() 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 

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

Deprecated: Use ClickhouseConfig_ExternalDictionary_Structure_Attribute.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) GetExpression 

func (x *ClickhouseConfig_ExternalDictionary_Structure_Attribute) GetExpression() string

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) GetHierarchical 

func (x *ClickhouseConfig_ExternalDictionary_Structure_Attribute) GetHierarchical() bool

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) GetInjective 

func (x *ClickhouseConfig_ExternalDictionary_Structure_Attribute) GetInjective() bool

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) GetName 

func (x *ClickhouseConfig_ExternalDictionary_Structure_Attribute) GetName() string

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) GetNullValue 

func (x *ClickhouseConfig_ExternalDictionary_Structure_Attribute) GetNullValue() string

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) GetType 

func (x *ClickhouseConfig_ExternalDictionary_Structure_Attribute) GetType() string

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) ProtoMessage 

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) ProtoMessage()

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) ProtoReflect 

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

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) Reset 

func (x *ClickhouseConfig_ExternalDictionary_Structure_Attribute) Reset()

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) SetExpression 

func (m *ClickhouseConfig_ExternalDictionary_Structure_Attribute) SetExpression(v string)

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) SetHierarchical 

func (m *ClickhouseConfig_ExternalDictionary_Structure_Attribute) SetHierarchical(v bool)

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) SetInjective 

func (m *ClickhouseConfig_ExternalDictionary_Structure_Attribute) SetInjective(v bool)

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) SetName 

func (m *ClickhouseConfig_ExternalDictionary_Structure_Attribute) SetName(v string)

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) SetNullValue 

func (m *ClickhouseConfig_ExternalDictionary_Structure_Attribute) SetNullValue(v string)

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) SetType 

func (m *ClickhouseConfig_ExternalDictionary_Structure_Attribute) SetType(v string)

func (*ClickhouseConfig_ExternalDictionary_Structure_Attribute) String 

func (x *ClickhouseConfig_ExternalDictionary_Structure_Attribute) String() 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 

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

Deprecated: Use ClickhouseConfig_ExternalDictionary_Structure_Id.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary_Structure_Id) GetName 

func (x *ClickhouseConfig_ExternalDictionary_Structure_Id) GetName() string

func (*ClickhouseConfig_ExternalDictionary_Structure_Id) ProtoMessage 

func (*ClickhouseConfig_ExternalDictionary_Structure_Id) ProtoMessage()

func (*ClickhouseConfig_ExternalDictionary_Structure_Id) ProtoReflect 

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

func (*ClickhouseConfig_ExternalDictionary_Structure_Id) Reset 

func (x *ClickhouseConfig_ExternalDictionary_Structure_Id) Reset()

func (*ClickhouseConfig_ExternalDictionary_Structure_Id) SetName 

func (m *ClickhouseConfig_ExternalDictionary_Structure_Id) SetName(v string)

func (*ClickhouseConfig_ExternalDictionary_Structure_Id) String 

func (x *ClickhouseConfig_ExternalDictionary_Structure_Id) String() 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 

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

Deprecated: Use ClickhouseConfig_ExternalDictionary_Structure_Key.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_ExternalDictionary_Structure_Key) GetAttributes 

func (x *ClickhouseConfig_ExternalDictionary_Structure_Key) GetAttributes() []*ClickhouseConfig_ExternalDictionary_Structure_Attribute

func (*ClickhouseConfig_ExternalDictionary_Structure_Key) ProtoMessage 

func (*ClickhouseConfig_ExternalDictionary_Structure_Key) ProtoMessage()

func (*ClickhouseConfig_ExternalDictionary_Structure_Key) ProtoReflect 

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

func (*ClickhouseConfig_ExternalDictionary_Structure_Key) Reset 

func (x *ClickhouseConfig_ExternalDictionary_Structure_Key) Reset()

func (*ClickhouseConfig_ExternalDictionary_Structure_Key) SetAttributes 

func (m *ClickhouseConfig_ExternalDictionary_Structure_Key) SetAttributes(v []*ClickhouseConfig_ExternalDictionary_Structure_Attribute)

func (*ClickhouseConfig_ExternalDictionary_Structure_Key) String 

func (x *ClickhouseConfig_ExternalDictionary_Structure_Key) String() 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 (x *ClickhouseConfig_GraphiteRollup) GetName() string

func (*ClickhouseConfig_GraphiteRollup) GetPatterns 

func (x *ClickhouseConfig_GraphiteRollup) GetPatterns() []*ClickhouseConfig_GraphiteRollup_Pattern

func (*ClickhouseConfig_GraphiteRollup) ProtoMessage 

func (*ClickhouseConfig_GraphiteRollup) ProtoMessage()

func (*ClickhouseConfig_GraphiteRollup) ProtoReflect 

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

func (*ClickhouseConfig_GraphiteRollup) Reset 

func (x *ClickhouseConfig_GraphiteRollup) Reset()

func (*ClickhouseConfig_GraphiteRollup) SetName 

func (m *ClickhouseConfig_GraphiteRollup) SetName(v string)

func (*ClickhouseConfig_GraphiteRollup) SetPatterns 

func (m *ClickhouseConfig_GraphiteRollup) SetPatterns(v []*ClickhouseConfig_GraphiteRollup_Pattern)

func (*ClickhouseConfig_GraphiteRollup) String 

func (x *ClickhouseConfig_GraphiteRollup) String() 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 (x *ClickhouseConfig_GraphiteRollup_Pattern) GetFunction() string

func (*ClickhouseConfig_GraphiteRollup_Pattern) GetRegexp 

func (x *ClickhouseConfig_GraphiteRollup_Pattern) GetRegexp() string

func (*ClickhouseConfig_GraphiteRollup_Pattern) GetRetention 

func (x *ClickhouseConfig_GraphiteRollup_Pattern) GetRetention() []*ClickhouseConfig_GraphiteRollup_Pattern_Retention

func (*ClickhouseConfig_GraphiteRollup_Pattern) ProtoMessage 

func (*ClickhouseConfig_GraphiteRollup_Pattern) ProtoMessage()

func (*ClickhouseConfig_GraphiteRollup_Pattern) ProtoReflect 

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

func (*ClickhouseConfig_GraphiteRollup_Pattern) Reset 

func (x *ClickhouseConfig_GraphiteRollup_Pattern) Reset()

func (*ClickhouseConfig_GraphiteRollup_Pattern) SetFunction 

func (m *ClickhouseConfig_GraphiteRollup_Pattern) SetFunction(v string)

func (*ClickhouseConfig_GraphiteRollup_Pattern) SetRegexp 

func (m *ClickhouseConfig_GraphiteRollup_Pattern) SetRegexp(v string)

func (*ClickhouseConfig_GraphiteRollup_Pattern) SetRetention 

func (m *ClickhouseConfig_GraphiteRollup_Pattern) SetRetention(v []*ClickhouseConfig_GraphiteRollup_Pattern_Retention)

func (*ClickhouseConfig_GraphiteRollup_Pattern) String 

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

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

Deprecated: Use ClickhouseConfig_GraphiteRollup_Pattern_Retention.ProtoReflect.Descriptor instead.

func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) GetAge 

func (x *ClickhouseConfig_GraphiteRollup_Pattern_Retention) GetAge() int64

func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) GetPrecision 

func (x *ClickhouseConfig_GraphiteRollup_Pattern_Retention) GetPrecision() int64

func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) ProtoMessage 

func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) ProtoMessage()

func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) ProtoReflect 

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

func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) Reset 

func (x *ClickhouseConfig_GraphiteRollup_Pattern_Retention) Reset()

func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) SetAge 

func (m *ClickhouseConfig_GraphiteRollup_Pattern_Retention) SetAge(v int64)

func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) SetPrecision 

func (m *ClickhouseConfig_GraphiteRollup_Pattern_Retention) SetPrecision(v int64)

func (*ClickhouseConfig_GraphiteRollup_Pattern_Retention) String 

func (x *ClickhouseConfig_GraphiteRollup_Pattern_Retention) String() 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"`
	// 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) GetSaslMechanism 

func (x *ClickhouseConfig_Kafka) GetSaslMechanism() ClickhouseConfig_Kafka_SaslMechanism

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 (x *ClickhouseConfig_Kafka) GetSecurityProtocol() ClickhouseConfig_Kafka_SecurityProtocol

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

func (m *ClickhouseConfig_Kafka) SetSaslMechanism(v ClickhouseConfig_Kafka_SaslMechanism)

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 (m *ClickhouseConfig_Kafka) SetSecurityProtocol(v ClickhouseConfig_Kafka_SecurityProtocol)

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 (x *ClickhouseConfig_KafkaTopic) GetSettings() *ClickhouseConfig_Kafka

func (*ClickhouseConfig_KafkaTopic) ProtoMessage 

func (*ClickhouseConfig_KafkaTopic) ProtoMessage()

func (*ClickhouseConfig_KafkaTopic) ProtoReflect 

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

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 (m *ClickhouseConfig_KafkaTopic) SetSettings(v *ClickhouseConfig_Kafka)

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) Descriptor() protoreflect.EnumDescriptor

func (ClickhouseConfig_Kafka_SaslMechanism) Enum 

func (x ClickhouseConfig_Kafka_SaslMechanism) Enum() *ClickhouseConfig_Kafka_SaslMechanism

func (ClickhouseConfig_Kafka_SaslMechanism) EnumDescriptor deprecated 

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

Deprecated: Use ClickhouseConfig_Kafka_SaslMechanism.Descriptor instead.

func (ClickhouseConfig_Kafka_SaslMechanism) Number 

func (x ClickhouseConfig_Kafka_SaslMechanism) Number() protoreflect.EnumNumber

func (ClickhouseConfig_Kafka_SaslMechanism) String 

func (x ClickhouseConfig_Kafka_SaslMechanism) String() string

func (ClickhouseConfig_Kafka_SaslMechanism) Type 

func (ClickhouseConfig_Kafka_SaslMechanism) Type() protoreflect.EnumType

type ClickhouseConfig_Kafka_SecurityProtocol 

type ClickhouseConfig_Kafka_SecurityProtocol int32
const (
	ClickhouseConfig_Kafka_SECURITY_PROTOCOL_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) Descriptor() protoreflect.EnumDescriptor

func (ClickhouseConfig_Kafka_SecurityProtocol) Enum 

func (x ClickhouseConfig_Kafka_SecurityProtocol) Enum() *ClickhouseConfig_Kafka_SecurityProtocol

func (ClickhouseConfig_Kafka_SecurityProtocol) EnumDescriptor deprecated 

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

Deprecated: Use ClickhouseConfig_Kafka_SecurityProtocol.Descriptor instead.

func (ClickhouseConfig_Kafka_SecurityProtocol) Number 

func (x ClickhouseConfig_Kafka_SecurityProtocol) Number() protoreflect.EnumNumber

func (ClickhouseConfig_Kafka_SecurityProtocol) String 

func (x ClickhouseConfig_Kafka_SecurityProtocol) String() string

func (ClickhouseConfig_Kafka_SecurityProtocol) Type 

func (ClickhouseConfig_Kafka_SecurityProtocol) Type() protoreflect.EnumType

type ClickhouseConfig_LogLevel 

type ClickhouseConfig_LogLevel int32
const (
	ClickhouseConfig_LOG_LEVEL_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) Descriptor() protoreflect.EnumDescriptor

func (ClickhouseConfig_LogLevel) Enum 

func (x ClickhouseConfig_LogLevel) Enum() *ClickhouseConfig_LogLevel

func (ClickhouseConfig_LogLevel) EnumDescriptor deprecated 

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

Deprecated: Use ClickhouseConfig_LogLevel.Descriptor instead.

func (ClickhouseConfig_LogLevel) Number 

func (x ClickhouseConfig_LogLevel) Number() protoreflect.EnumNumber

func (ClickhouseConfig_LogLevel) String 

func (x ClickhouseConfig_LogLevel) String() string

func (ClickhouseConfig_LogLevel) Type 

func (ClickhouseConfig_LogLevel) Type() protoreflect.EnumType

type ClickhouseConfig_MergeTree 

type ClickhouseConfig_MergeTree struct {

	// Number of blocks of hashes to keep in ZooKeeper.
	ReplicatedDeduplicationWindow *wrappers.Int64Value `` /* 150-byte string literal not displayed */
	// Period of time to keep blocks of hashes for.
	ReplicatedDeduplicationWindowSeconds *wrappers.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 *wrappers.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 *wrappers.Int64Value `protobuf:"bytes,4,opt,name=parts_to_throw_insert,json=partsToThrowInsert,proto3" json:"parts_to_throw_insert,omitempty"`
	// How many tasks of merging and mutating parts are allowed simultaneously in ReplicatedMergeTree queue.
	MaxReplicatedMergesInQueue *wrappers.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 *wrappers.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 *wrappers.Int64Value `` /* 168-byte string literal not displayed */
	MaxBytesToMergeAtMaxSpaceInPool *wrappers.Int64Value `` /* 168-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) GetMaxBytesToMergeAtMaxSpaceInPool 

func (x *ClickhouseConfig_MergeTree) GetMaxBytesToMergeAtMaxSpaceInPool() *wrappers.Int64Value

func (*ClickhouseConfig_MergeTree) GetMaxBytesToMergeAtMinSpaceInPool 

func (x *ClickhouseConfig_MergeTree) GetMaxBytesToMergeAtMinSpaceInPool() *wrappers.Int64Value

func (*ClickhouseConfig_MergeTree) GetMaxReplicatedMergesInQueue 

func (x *ClickhouseConfig_MergeTree) GetMaxReplicatedMergesInQueue() *wrappers.Int64Value

func (*ClickhouseConfig_MergeTree) GetNumberOfFreeEntriesInPoolToLowerMaxSizeOfMerge 

func (x *ClickhouseConfig_MergeTree) GetNumberOfFreeEntriesInPoolToLowerMaxSizeOfMerge() *wrappers.Int64Value

func (*ClickhouseConfig_MergeTree) GetPartsToDelayInsert 

func (x *ClickhouseConfig_MergeTree) GetPartsToDelayInsert() *wrappers.Int64Value

func (*ClickhouseConfig_MergeTree) GetPartsToThrowInsert 

func (x *ClickhouseConfig_MergeTree) GetPartsToThrowInsert() *wrappers.Int64Value

func (*ClickhouseConfig_MergeTree) GetReplicatedDeduplicationWindow 

func (x *ClickhouseConfig_MergeTree) GetReplicatedDeduplicationWindow() *wrappers.Int64Value

func (*ClickhouseConfig_MergeTree) GetReplicatedDeduplicationWindowSeconds 

func (x *ClickhouseConfig_MergeTree) GetReplicatedDeduplicationWindowSeconds() *wrappers.Int64Value

func (*ClickhouseConfig_MergeTree) ProtoMessage 

func (*ClickhouseConfig_MergeTree) ProtoMessage()

func (*ClickhouseConfig_MergeTree) ProtoReflect 

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

func (*ClickhouseConfig_MergeTree) Reset 

func (x *ClickhouseConfig_MergeTree) Reset()

func (*ClickhouseConfig_MergeTree) SetMaxBytesToMergeAtMaxSpaceInPool 

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

func (*ClickhouseConfig_MergeTree) SetMaxBytesToMergeAtMinSpaceInPool 

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

func (*ClickhouseConfig_MergeTree) SetMaxReplicatedMergesInQueue 

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

func (*ClickhouseConfig_MergeTree) SetNumberOfFreeEntriesInPoolToLowerMaxSizeOfMerge 

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

func (*ClickhouseConfig_MergeTree) SetPartsToDelayInsert 

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

func (*ClickhouseConfig_MergeTree) SetPartsToThrowInsert 

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

func (*ClickhouseConfig_MergeTree) SetReplicatedDeduplicationWindow 

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

func (*ClickhouseConfig_MergeTree) SetReplicatedDeduplicationWindowSeconds 

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

func (*ClickhouseConfig_MergeTree) String 

func (x *ClickhouseConfig_MergeTree) String() string

type ClickhouseConfig_Rabbitmq 

type ClickhouseConfig_Rabbitmq struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,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) ProtoMessage 

func (*ClickhouseConfig_Rabbitmq) ProtoMessage()

func (*ClickhouseConfig_Rabbitmq) ProtoReflect 

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

func (*ClickhouseConfig_Rabbitmq) Reset 

func (x *ClickhouseConfig_Rabbitmq) Reset()

func (*ClickhouseConfig_Rabbitmq) SetPassword 

func (m *ClickhouseConfig_Rabbitmq) SetPassword(v string)

func (*ClickhouseConfig_Rabbitmq) SetUsername 

func (m *ClickhouseConfig_Rabbitmq) SetUsername(v string)

func (*ClickhouseConfig_Rabbitmq) String 

func (x *ClickhouseConfig_Rabbitmq) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.