Versions in this module Expand all Collapse all v1 v1.0.0 Sep 20, 2019 Changes in this version + const ApplicationName + const CollapsingMergeTree + const DefaultRowIDColumn + const MergeTree + const ReplacingMergeTree + const TableLSNKeyPrefix + var DefaultInactivityMergeTimeout = time.Minute + var DefaultPostgresPort uint16 = 5432 + type CHConnConfig struct + Database string + Host string + Params map[string]string + Password string + Port uint32 + User string + type ChColumn struct + Name string + type ChTableName struct + DatabaseName string + TableName string + func (ct *ChTableName) UnmarshalYAML(unmarshal func(interface{}) error) error + func (ct ChTableName) IsEmpty() bool + func (ct ChTableName) String() string + type Column struct + BaseType string + Ext []int + IsArray bool + IsNullable bool + type ColumnProperty struct + Coalesce coalesceValue + IstoreKeysSuffix string + IstoreValuesSuffix string + type Config struct + ClickHouse CHConnConfig + CreateSlotMaxAttempts int + GzipBufSize int + GzipCompression GzipComprLevel + InactivityFlushTimeout time.Duration + LogLevel zapcore.Level + PersStoragePath string + PersStorageType string + PipeBufferSize int64 + Postgres pgConnConfig + PprofBind string + RedisBind string + SyncWorkers int + Tables map[PgTableName]*Table + func New(filepath string) (*Config, error) + func (c Config) Print() + type GzipComprLevel int + func (gc *GzipComprLevel) UnmarshalYAML(unmarshal func(interface{}) error) error + func (gc GzipComprLevel) String() string + func (gc GzipComprLevel) UseCompression() bool + type PgColumn struct + PkCol int + func (c PgColumn) IsIstore() bool + func (c PgColumn) IsTime() bool + type PgTableName struct + SchemaName string + TableName string + func (tn *PgTableName) Parse(val string) error + func (tn *PgTableName) ParseKey(key string) error + func (tn *PgTableName) UnmarshalYAML(unmarshal func(interface{}) error) error + func (tn PgTableName) KeyName() string + func (tn PgTableName) MarshalYAML() (interface{}, error) + func (tn PgTableName) NamespacedName() string + func (tn PgTableName) String() string + type Table struct + BufferSize int + ChMainTable ChTableName + ChSyncAuxTable ChTableName + ColumnMapping map[string]ChColumn + ColumnProperties map[string]*ColumnProperty + Columns map[string]string + Engine tableEngine + InitSyncSkip bool + InitSyncSkipTruncate bool + IsDeletedColumn string + LsnColumnName string + PgColumns map[string]*PgColumn + PgOID dbtypes.OID + PgTableName PgTableName + RowIDColumnName string + SignColumn string + TableNameColumnName string + TupleColumns []message.Column + func (t *Table) UnmarshalYAML(unmarshal func(interface{}) error) error
Go to main page