clickhouse

type Address struct {
	Addr   string `json:"addr"`
	Weight int    `json:"weight"`
}

type Clickhouse interface {
	Close()
	Do(ctx context.Context, query ch.Query) error
}

type ColBool struct {
	// contains filtered or unexported fields
}

type ColDateTime struct {
	// contains filtered or unexported fields
}

type ColDateTime64 struct {
	// contains filtered or unexported fields
}

type ColEnum16 struct {
	// contains filtered or unexported fields
}

type ColEnum8 struct {
	// contains filtered or unexported fields
}

type ColFloat32 struct {
	// contains filtered or unexported fields
}

type ColFloat64 struct {
	// contains filtered or unexported fields
}

type ColIPv4 struct {
	// contains filtered or unexported fields
}

type ColIPv6 struct {
	// contains filtered or unexported fields
}

type ColInt128 struct {
	// contains filtered or unexported fields
}

type ColInt16 struct {
	// contains filtered or unexported fields
}

type ColInt256 struct {
	// contains filtered or unexported fields
}

type ColInt32 struct {
	// contains filtered or unexported fields
}

type ColInt64 struct {
	// contains filtered or unexported fields
}

type ColInt8 struct {
	// contains filtered or unexported fields
}

type ColString struct {
	// contains filtered or unexported fields
}

type ColStringArray struct {
	*proto.ColArr[string]
}

type ColUInt128 struct {
	// contains filtered or unexported fields
}

type ColUInt16 struct {
	// contains filtered or unexported fields
}

type ColUInt256 struct {
	// contains filtered or unexported fields
}

type ColUInt32 struct {
	// contains filtered or unexported fields
}

type ColUInt64 struct {
	// contains filtered or unexported fields
}

type ColUInt8 struct {
	// contains filtered or unexported fields
}

type ColUUID struct {
	// contains filtered or unexported fields
}

type Column struct {
	Name string `json:"name"`
	Type string `json:"type"`
}

type Config struct {
	// > @3@4@5@6
	// >
	// > TCP Clickhouse addresses, e.g.: 127.0.0.1:9000.
	// > Check the insert_strategy to find out how File.d will behave with a list of addresses.
	// >
	// > Accepts strings or objects, e.g.:
	// > “`yaml
	// > addresses:
	// >   - 127.0.0.1:9000 # the same as {addr:'127.0.0.1:9000',weight:1}
	// >   - addr: 127.0.0.1:9001
	// >     weight: 2
	// > “`
	// >
	// > When some addresses get weight greater than 1 and round_robin insert strategy is used,
	// > it works as classical weighted round robin. Given {(a_1,w_1),(a_1,w_1),...,{a_n,w_n}},
	// > where a_i is the ith address and w_i is the ith address' weight, requests are sent in order:
	// > w_1 times to a_1, w_2 times to a_2, ..., w_n times to a_n, w_1 times to a_1 and so on.
	Addresses []Address `json:"addresses" required:"true" slice:"true"` // *

	// > @3@4@5@6
	// >
	// > If more than one addresses are set, File.d will insert batches depends on the strategy:
	// > round_robin - File.d will send requests in the round-robin order.
	// > in_order - File.d will send requests starting from the first address, ending with the number of retries.
	InsertStrategy  string `json:"insert_strategy" default:"round_robin" options:"round_robin|in_order"` // *
	InsertStrategy_ InsertStrategy

	// > @3@4@5@6
	// >
	// > CA certificate in PEM encoding. This can be a path or the content of the certificate.
	CACert string `json:"ca_cert" default:""` // *

	// > @3@4@5@6
	// >
	// > Clickhouse database name to search the table.
	Database string `json:"database" default:"default"` // *

	// > @3@4@5@6
	// >
	// > Clickhouse database user.
	User string `json:"user" default:"default"` // *

	// > @3@4@5@6
	// >
	// > Clickhouse database password.
	Password string `json:"password" default:""` // *

	// > @3@4@5@6
	// >
	// > Clickhouse quota key.
	// > https://clickhouse.com/docs/en/operations/quotas
	QuotaKey string `json:"quota_key" default:""` // *

	// > @3@4@5@6
	// >
	// > Clickhouse target table.
	Table string `json:"table" required:"true"` // *

	// > @3@4@5@6
	// >
	// > Clickhouse table columns. Each column must contain `name` and `type`.
	// > File.d supports next data types:
	// > * Signed and unsigned integers from 8 to 64 bits.
	// > If you set 128-256 bits - File.d will cast the number to the int64.
	// > * DateTime, DateTime64
	// > * String
	// > * Enum8, Enum16
	// > * Bool
	// > * Nullable
	// > * IPv4, IPv6
	// > * LowCardinality(String)
	// > * Array(String)
	// >
	// > If you need more types, please, create an issue.
	Columns []Column `json:"columns" required:"true"` // *

	// > @3@4@5@6
	// >
	// > If true, file.d fails when types are mismatched.
	// >
	// > If false, file.d will cast any JSON type to the column type.
	// >
	// > For example, if strict_types is false and an event value is a Number,
	// > but the column type is a Bool, the Number will be converted to the "true"
	// > if the value is "1".
	// > But if the value is an Object and the column is an Int
	// > File.d converts the Object to "0" to prevent fall.
	// >
	// > In the non-strict mode, for String and Array(String) columns the value will be encoded to JSON.
	// >
	// > If the strict mode is enabled file.d fails (exit with code 1) in above examples.
	StrictTypes bool `json:"strict_types" default:"false"` // *

	// > @3@4@5@6
	// >
	// > The level of the Compression.
	// > Disabled - lowest CPU overhead.
	// > LZ4 - medium CPU overhead.
	// > ZSTD - high CPU overhead.
	// > None - uses no compression but data has checksums.
	Compression string `default:"disabled" options:"disabled|lz4|zstd|none"` // *

	// > @3@4@5@6
	// >
	// > Retries of insertion. If File.d cannot insert for this number of attempts,
	// > File.d will fall with non-zero exit code or skip message (see fatal_on_failed_insert).
	Retry int `json:"retry" default:"10"` // *

	// > @3@4@5@6
	// >
	// > After an insert error, fall with a non-zero exit code or not
	// > **Experimental feature**
	FatalOnFailedInsert bool `json:"fatal_on_failed_insert" default:"false"` // *

	// > @3@4@5@6
	// >
	// > Additional settings to the Clickhouse.
	// > Settings list: https://clickhouse.com/docs/en/operations/settings/settings
	ClickhouseSettings Settings `json:"clickhouse_settings"` // *

	// > @3@4@5@6
	// >
	// > Retention milliseconds for retry to DB.
	Retention  cfg.Duration `json:"retention" default:"50ms" parse:"duration"` // *
	Retention_ time.Duration

	// > @3@4@5@6
	// >
	// > Multiplier for exponential increase of retention between retries
	RetentionExponentMultiplier int `json:"retention_exponentially_multiplier" default:"2"` // *

	// > @3@4@5@6
	// >
	// > Timeout for each insert request.
	InsertTimeout  cfg.Duration `json:"insert_timeout" default:"10s" parse:"duration"` // *
	InsertTimeout_ time.Duration

	// > @3@4@5@6
	// >
	// > Max connections in the connection pool.
	MaxConns  cfg.Expression `json:"max_conns" default:"gomaxprocs*4"  parse:"expression"` // *
	MaxConns_ int32

	// > @3@4@5@6
	// >
	// > Min connections in the connection pool.
	MinConns  cfg.Expression `json:"min_conns" default:"gomaxprocs*1"  parse:"expression"` // *
	MinConns_ int32

	// > @3@4@5@6
	// >
	// > How long a connection lives before it is killed and recreated.
	MaxConnLifetime  cfg.Duration `json:"max_conn_lifetime" default:"30m" parse:"duration"` // *
	MaxConnLifetime_ time.Duration

	// > @3@4@5@6
	// >
	// > How long an unused connection lives before it is killed.
	MaxConnIdleTime  cfg.Duration `json:"max_conn_idle_time" default:"5m" parse:"duration"` // *
	MaxConnIdleTime_ time.Duration

	// > @3@4@5@6
	// >
	// > How often to check that idle connections is time to kill.
	HealthCheckPeriod  cfg.Duration `json:"health_check_period" default:"1m" parse:"duration"` // *
	HealthCheckPeriod_ time.Duration

	// > @3@4@5@6
	// >
	// > How much workers will be instantiated to send batches.
	// > It also configures the amount of minimum and maximum number of database connections.
	WorkersCount  cfg.Expression `json:"workers_count" default:"gomaxprocs*4" parse:"expression"` // *
	WorkersCount_ int

	// > @3@4@5@6
	// >
	// > Maximum quantity of events to pack into one batch.
	BatchSize  cfg.Expression `json:"batch_size" default:"capacity/4"  parse:"expression"` // *
	BatchSize_ int

	// > @3@4@5@6
	// >
	// > A minimum size of events in a batch to send.
	// > If both batch_size and batch_size_bytes are set, they will work together.
	BatchSizeBytes  cfg.Expression `json:"batch_size_bytes" default:"0" parse:"expression"` // *
	BatchSizeBytes_ int

	// > @3@4@5@6
	// >
	// > After this timeout batch will be sent even if batch isn't completed.
	BatchFlushTimeout  cfg.Duration `json:"batch_flush_timeout" default:"200ms" parse:"duration"` // *
	BatchFlushTimeout_ time.Duration
}

type InsaneColInput interface {
	proto.ColInput
	Append(node InsaneNode) error
	Reset()
}

type InsaneColumn struct {
	Name     string
	ColInput InsaneColInput
}

type InsaneNode interface {
	AsInt() (int, error)
	AsFloat32() (float32, error)
	AsFloat64() (float64, error)
	AsString() (string, error)
	AsBool() (bool, error)
	AsInt64() (int64, error)
	AsStringArray() ([]string, error)
	AsUUID() (uuid.UUID, error)
	AsIPv4() (proto.IPv4, error)
	AsIPv6() (proto.IPv6, error)
	AsTime(scale int64) (time.Time, error)

	IsNull() bool
}

type InsertStrategy byte

type NonStrictNode struct {
	*insaneJSON.Node
}

type Plugin struct {
	// contains filtered or unexported fields
}

type Setting struct {
	Key       string `json:"key"`
	Value     string `json:"value"`
	Important bool   `json:"important"`
}

type Settings []Setting

type StrictNode struct {
	*insaneJSON.StrictNode
}

type ZeroValueNode struct{}