config

type App string

type Castor struct {
	Enabled           bool       `toml:"enabled"`
	PyWorkerAddr      []string   `toml:"pyworker-addr"`
	ConnPoolSize      int        `toml:"connect-pool-size"`
	ResultWaitTimeout int        `toml:"result-wait-timeout"`
	FitDetect         algoConfig `toml:"fit_detect"`
	Detect            algoConfig `toml:"detect"`
	Predict           algoConfig `toml:"predict"`
	Fit               algoConfig `toml:"fit"`
}

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

type Common struct {
	MetaJoin  []string `toml:"meta-join"`
	ClusterID string   `toml:"cluster-id"`
	CPUNum    int      `toml:"cpu-num"`

	MemorySize      itoml.Size     `toml:"memory-size"`
	MemoryLimitSize itoml.Size     `toml:"executor-memory-size-limit"`
	MemoryWaitTime  itoml.Duration `toml:"executor-memory-wait-time"`
}

type Config interface {
	ApplyEnvOverrides(func(string) string) error
	Validate() error
	GetLogging() *Logger
	GetSpdy() *Spdy
	GetCommon() *Common
}

type Coordinator struct {
	WriteTimeout         toml.Duration `toml:"write-timeout"`
	MaxConcurrentQueries int           `toml:"max-concurrent-queries"`
	QueryTimeout         toml.Duration `toml:"query-timeout"`
	LogQueriesAfter      toml.Duration `toml:"log-queries-after"`
	ShardWriterTimeout   toml.Duration `toml:"shard-writer-timeout"`
	ShardMapperTimeout   toml.Duration `toml:"shard-mapper-timeout"`
	// Maximum number of memory bytes to use from the query
	MaxQueryMem              toml.Size     `toml:"max-query-mem"`
	MetaExecutorWriteTimeout toml.Duration `toml:"meta-executor-write-timeout"`
	QueryLimitIntervalTime   int           `toml:"query-limit-interval-time"`
	QueryLimitLevel          int           `toml:"query-limit-level"`
	RetentionPolicyLimit     int           `toml:"rp-limit"`
	ShardTier                string        `toml:"shard-tier"`

	QueryLimitFlag          bool `toml:"query-limit-flag"`
	QueryTimeCompareEnabled bool `toml:"query-time-compare-enabled"`
	ForceBroadcastQuery     bool `toml:"force-broadcast-query"`
}

type Gossip struct {
	Enabled       bool          `toml:"enabled"`
	LogEnabled    bool          `toml:"log-enabled"`
	BindAddr      string        `toml:"bind-address"`
	MetaBindPort  int           `toml:"meta-bind-port"`
	StoreBindPort int           `toml:"store-bind-port"`
	ProbInterval  toml.Duration `toml:"prob-interval"`
	SuspicionMult int           `toml:"suspicion-mult"`
	Members       []string      `toml:"members"`
}

type Logger struct {
	Format          string        `toml:"format"`
	Level           zapcore.Level `toml:"level"`
	MaxSize         toml.Size     `toml:"max-size"`
	MaxNum          int           `toml:"max-num"`
	MaxAge          int           `toml:"max-age"`
	CompressEnabled bool          `toml:"compress-enabled"`
	Path            string        `toml:"path"`
	// contains filtered or unexported fields
}

type Meta struct {
	HTTPSEnabled        bool `toml:"https-enabled"`
	PprofEnabled        bool `toml:"pprof-enabled"`
	RetentionAutoCreate bool `toml:"retention-autocreate"`
	ClusterTracing      bool `toml:"cluster-tracing"`
	LoggingEnabled      bool `toml:"logging-enabled"`
	BatchApplyCh        bool `toml:"batch-enabled"`

	Domain                  string  `toml:"domain"`
	Dir                     string  `toml:"dir"`
	HTTPBindAddress         string  `toml:"http-bind-address"`
	RPCBindAddress          string  `toml:"rpc-bind-address"`
	BindAddress             string  `toml:"bind-address"`
	HTTPSCertificate        string  `toml:"https-certificate"`
	HTTPSPrivateKey         string  `toml:"https-private-key"`
	MaxConcurrentWriteLimit int     `toml:"-"`
	Version                 int     `toml:"meta-version"`
	Hostname                string  `toml:"hostname"`
	SplitRowThreshold       uint64  `toml:"split-row-threshold"`
	ImbalanceFactor         float64 `toml:"imbalance-factor"`
	RaftStore               string  `toml:"raft-store"`
	RemoteHostname          string

	JoinPeers          []string
	ElectionTimeout    toml.Duration `toml:"election-timeout"`
	HeartbeatTimeout   toml.Duration `toml:"heartbeat-timeout"`
	LeaderLeaseTimeout toml.Duration `toml:"leader-lease-timeout"`
	CommitTimeout      toml.Duration `toml:"commit-timeout"`
	LeaseDuration      toml.Duration `toml:"lease-duration"`
	Logging            Logger        `toml:"logging"`
}

type Monitor struct {
	Pushers       string        `toml:"pushers"`
	StoreEnabled  bool          `toml:"store-enabled"`
	StoreDatabase string        `toml:"store-database"`
	StoreInterval toml.Duration `toml:"store-interval"`
	StorePath     string        `toml:"store-path"`
	Compress      bool          `toml:"compress"`
	HttpsEnabled  bool          `toml:"https-enabled"`
	HttpAuth      []string      `toml:"http-auth"`
	HttpEndPoint  string        `toml:"http-endpoint"`
	// contains filtered or unexported fields
}

type MonitorMain struct {
	Host        string `toml:"host"`
	MetricPath  string `toml:"metric-path"`
	ErrLogPath  string `toml:"error-log-path"`
	Process     string `toml:"process"`
	DiskPath    string `toml:"disk-path"`
	AuxDiskPath string `toml:"aux-disk-path"`
	History     string `toml:"history-file"`
	Compress    bool   `toml:"compress"`
}

type MonitorQuery struct {
	QueryEnable   bool          `toml:"query-enable"`
	HttpEndpoint  string        `toml:"http-endpoint"`
	QueryInterval toml.Duration `toml:"query-interval"`
}

type MonitorReport struct {
	Address    string        `toml:"address"`
	Database   string        `toml:"database"`
	Rp         string        `toml:"rp"`
	RpDuration toml.Duration `toml:"rp-duration"`
}

type Spdy struct {
	ByteBufferPoolDefaultSize uint64

	RecvWindowSize          int `toml:"recv-window-size"`
	ConcurrentAcceptSession int `toml:"concurrent-accept-session"`
	ConnPoolSize            int `toml:"conn-pool-size"`

	OpenSessionTimeout   toml.Duration `toml:"open-session-timeout"`
	SessionSelectTimeout toml.Duration `toml:"session-select-timeout"`
	TCPDialTimeout       toml.Duration `toml:"tcp-dial-timeout"`
	DataAckTimeout       toml.Duration `toml:"data-ack-timeout"`

	TLSEnable             bool   `toml:"tls-enable"`
	TLSClientAuth         bool   `toml:"tls-client-auth"`
	TLSInsecureSkipVerify bool   `toml:"tls-insecure-skip-verify"`
	TLSCertificate        string `toml:"tls-certificate"`
	TLSPrivateKey         string `toml:"tls-private-key"`
	TLSClientCertificate  string `toml:"tls-client-certificate"`
	TLSClientPrivateKey   string `toml:"tls-client-private-key"`
	TLSCARoot             string `toml:"tls-ca-root"`
	TLSServerName         string `toml:"tls-server-name"`
}

type Store struct {
	IngesterAddress string `toml:"store-ingest-addr"`
	SelectAddress   string `toml:"store-select-addr"`
	DataDir         string `toml:"store-data-dir"`
	Domain          string `toml:"domain"`
	WALDir          string `toml:"store-wal-dir"`
	MetaDir         string `toml:"store-meta-dir"`
	Engine          string `toml:"engine-type"`
	Index           string `toml:"index-version"`

	// The max inmem percent of immutable
	ImmTableMaxMemoryPercentage int `toml:"imm-table-max-memory-percentage"`

	// Compaction options for tssp1 (descriptions above with defaults)
	CompactFullWriteColdDuration toml.Duration `toml:"compact-full-write-cold-duration"`
	MaxConcurrentCompactions     int           `toml:"max-concurrent-compactions"`
	MaxFullCompactions           int           `toml:"max-full-compactions"`
	CompactThroughput            toml.Size     `toml:"compact-throughput"`
	CompactThroughputBurst       toml.Size     `toml:"compact-throughput-burst"`
	SnapshotThroughput           toml.Size     `toml:"snapshot-throughput"`
	SnapshotThroughputBurst      toml.Size     `toml:"snapshot-throughput-burst"`
	CompactionMethod             int           `toml:"compaction-method"` // 0:auto, 1: streaming, 2: non-streaming

	// Configs for snapshot
	WriteColdDuration     toml.Duration `toml:"write-cold-duration"`
	ShardMutableSizeLimit toml.Size     `toml:"shard-mutable-size-limit"`
	NodeMutableSizeLimit  toml.Size     `toml:"node-mutable-size-limit"`
	MaxWriteHangTime      toml.Duration `toml:"max-write-hang-time"`
	WalSyncInterval       toml.Duration `toml:"wal-sync-interval"`

	WalEnabled        bool `toml:"wal-enabled"`
	WalReplayParallel bool `toml:"wal-replay-parallel"`
	CacheDataBlock    bool `toml:"cache-table-data-block"`
	CacheMetaBlock    bool `toml:"cache-table-meta-block"`
	EnableMmapRead    bool `toml:"enable-mmap-read"`
	Readonly          bool `toml:"readonly"`
	CompactRecovery   bool `toml:"compact-recovery"`

	ReadCacheLimit       int `toml:"read-cache-limit"`
	WriteConcurrentLimit int `toml:"write-concurrent-limit"`
}

type TSMeta struct {
	Common  Common  `toml:"common"`
	Meta    *Meta   `toml:"meta"`
	Logging Logger  `toml:"logging"`
	Monitor Monitor `toml:"monitor"`
	Gossip  *Gossip `toml:"gossip"`
	Spdy    Spdy    `toml:"spdy"`

	// TLS provides configuration options for all https endpoints.
	TLS tlsconfig.Config `toml:"tls"`
}

type TSMonitor struct {
	MonitorConfig MonitorMain   `toml:"monitor"`
	QueryConfig   MonitorQuery  `toml:"query"`
	ReportConfig  MonitorReport `toml:"report"`
	Logging       Logger        `toml:"logging"`
}

type TSSql struct {
	Common      *Common     `toml:"common"`
	Coordinator Coordinator `toml:"coordinator"`
	Monitor     Monitor     `toml:"monitor"`
	Logging     Logger      `toml:"logging"`
	Spdy        Spdy        `toml:"spdy"`

	HTTP httpdConfig.Config `toml:"http"`

	// TLS provides configuration options for all https endpoints.
	TLS      tlsconfig.Config `toml:"tls"`
	Analysis Castor           `toml:"castor"`
}

type TSStore struct {
	Common      *Common     `toml:"common"`
	Data        Store       `toml:"data"`
	Coordinator Coordinator `toml:"coordinator"`
	Monitor     Monitor     `toml:"monitor"`
	Logging     Logger      `toml:"logging"`
	Gossip      *Gossip     `toml:"gossip"`
	Spdy        Spdy        `toml:"spdy"`

	HTTPD             httpdConf.Config `toml:"http"`
	Retention         retention.Config `toml:"retention"`
	HierarchicalStore retention.Config `toml:"hierarchical-storage"`

	// TLS provides configuration options for all https endpoints.
	TLS      tlsconfig.Config `toml:"tls"`
	Analysis Castor           `toml:"castor"`
}

type Validator interface {
	Validate() error
}