config

type Auth struct {
	Username string `yaml:"username"`
	Password string `yaml:"password"`
}

type BaseConfig struct {
	LogFile          string           `yaml:"log-file"`
	LogLevel         string           `yaml:"log-level"`
	TraceIdWithIndex TraceIdWithIndex `yaml:"trace-id-with-index"`
	Base             Config           `yaml:"ingester"`
}

type CKDB struct {
	External bool   `yaml:"external"`
	Type     string `yaml:"type"`
	Host     string `yaml:"host"`

	ActualAddrs         *[]string
	Watcher             *Watcher
	Port                int    `yaml:"port"`
	EndpointTCPPortName string `yaml:"endpoint-tcp-port-name"`
	ClusterName         string `yaml:"cluster-name"`
	StoragePolicy       string `yaml:"storage-policy"`
	TimeZone            string `yaml:"time-zone"`
	// contains filtered or unexported fields
}

type CKDBColdStorage struct {
	Enabled  bool             `yaml:"enabled"`
	ColdDisk Disk             `yaml:"cold-disk"`
	Settings []StorageSetting `yaml:"settings,flow"`
}

type CKDiskMonitor struct {
	CheckInterval    int             `yaml:"check-interval"` // s
	TTLCheckDisabled bool            `yaml:"ttl-check-disabled"`
	DiskCleanups     []DiskCleanup   `yaml:"disk-cleanups"`
	PriorityDrops    []DatabaseTable `yaml:"priority-drops"`
}

type CKWriterConfig struct {
	QueueCount   int `yaml:"queue-count"`
	QueueSize    int `yaml:"queue-size"`
	BatchSize    int `yaml:"batch-size"`
	FlushTimeout int `yaml:"flush-timeout"`
}

type Config struct {
	IsRunningModeStandalone bool
	StorageDisabled         bool            `yaml:"storage-disabled"`
	ListenPort              uint16          `yaml:"listen-port"`
	CKDB                    CKDB            `yaml:"ckdb"`
	ControllerIPs           []string        `yaml:"controller-ips,flow"`
	ControllerPort          uint16          `yaml:"controller-port"`
	CKDBAuth                Auth            `yaml:"ckdb-auth"`
	IngesterEnabled         bool            `yaml:"ingester-enabled"`
	UDPReadBuffer           int             `yaml:"udp-read-buffer"`
	TCPReadBuffer           int             `yaml:"tcp-read-buffer"`
	TCPReaderBuffer         int             `yaml:"tcp-reader-buffer"`
	CKDiskMonitor           CKDiskMonitor   `yaml:"ck-disk-monitor"`
	ColdStorage             CKDBColdStorage `yaml:"ckdb-cold-storage"`

	NodeIP                   string `yaml:"node-ip"`
	GrpcBufferSize           int    `yaml:"grpc-buffer-size"`
	ServiceLabelerLruCap     int    `yaml:"service-labeler-lru-cap"`
	StatsInterval            int    `yaml:"stats-interval"`
	FlowTagCacheFlushTimeout uint32 `yaml:"flow-tag-cache-flush-timeout"`
	FlowTagCacheMaxSize      uint32 `yaml:"flow-tag-cache-max-size"`
	LogFile                  string
	LogLevel                 string
	MyNodeName               string
	TraceIdWithIndex         TraceIdWithIndex
	// contains filtered or unexported fields
}

type DatabaseTable struct {
	Database      string `yaml:"database"`
	TablesContain string `yaml:"tables-contain"`
}

type Disk struct {
	Type string `yaml:"type"`
	Name string `yaml:"name"`
}

type DiskCleanup struct {
	DiskNamePrefix string `yaml:"disk-name-prefix"`
	UsedPercent    int    `yaml:"used-percent"` // 0-100
	FreeSpace      int    `yaml:"free-space"`   // Gb
	UsedSpace      int    `yaml:"used-space"`   // Gb
}

type Endpoint struct {
	Host string
	Port uint16
}

type EndpointsOnChange interface {
	EndpointsChange([]string)
}

type HostPort struct {
	Host string `yaml:"host"`
	Port string `yaml:"port"`
}

type InstanceInfo struct {
	PodName  string
	NodeName string
}

type Location struct {
	Start  int    `yaml:"start"`
	Length int    `yaml:"length"`
	Format string `yaml:"format"`
}

type ServerInstanceInfo struct {
	GrpcSession *grpc.GrpcSession
	// contains filtered or unexported fields
}

type StorageSetting struct {
	Db        string   `yaml:"db"`
	Tables    []string `yaml:"tables,flow"`
	TTLToMove int      `yaml:"ttl-hour-to-move"`
}

type TraceIdWithIndex struct {
	Disabled              bool     `yaml:"disabled"`
	Type                  string   `yaml:"type"`
	IncrementalIdLocation Location `yaml:"incremental-id-location"`
	FormatIsHex           bool
	TypeIsIncrementalId   bool
}

type Watcher struct {
	NodePodNamesWatch *ServerInstanceInfo
	EndpointWatch     libs.Watcher
	// contains filtered or unexported fields
}