clickhousecache

type ClickhouseStorage struct {
	Metrics      Metrics
	OnBatchError func(batch []map[string]any, err error)
	// contains filtered or unexported fields
}

type ClickhouseStorageConfig struct {
	Config      TClickHouseConfig // параметры подключения к ClickHouse
	TableName   string            // имя таблицы в ClickHouse
	FieldNames  []string          // список полей (колонок) в таблице
	WriteTime   time.Duration     // период записи данных из буфера в ClickHouse
	MaxBatch    int               // максимальный размер батча для записи
	JSONFields  []string          // список полей, которые нужно сериализовать в JSON
	MaxRetries  int               // максимальное количество попыток записи при ошибке
	BackoffBase time.Duration     // базовая задержка для экспоненциального бэкоффа
	BackoffMax  time.Duration     // максимальная задержка для бэкоффа
}

type Metrics struct {
	SuccessInserts uint64 // count of successful batches
	FailedInserts  uint64 // count of failed batches
	LastBatchSize  uint64 // size of the last batch (successful or not)
}

type TClickHouseConfig struct {
	ClkAddress   []string // list of clickhouse servers (host:port)
	ClkDBName    string
	ClkUserName  string
	ClkPassword  string
	MaxOpenConns int
	DialTimeout  time.Duration
	ReadTimeout  time.Duration
	WriteTimeout time.Duration
}