dbconfig

type Config interface {
	// Kind returns the component kind of the config.
	Kind() v1alpha1.RoleKind

	// ConfigureByCluster configures the config by the given cluster.
	ConfigureByCluster(cluster *v1alpha1.GreptimeDBCluster, roleSpec v1alpha1.RoleSpec) error

	// ConfigureByStandalone configures the config by the given standalone.
	ConfigureByStandalone(standalone *v1alpha1.GreptimeDBStandalone) error

	// GetInputConfig returns the input config.
	GetInputConfig() string

	// SetInputConfig sets the input config.
	SetInputConfig(input string) error
}

type DatanodeConfig struct {
	NodeID        *uint64 `tomlmapping:"node_id"`
	RPCBindAddr   *string `tomlmapping:"grpc.bind_addr"`
	RPCServerAddr *string `tomlmapping:"grpc.server_addr"`

	// StorageConfig is the configuration for the storage.
	StorageConfig `tomlmapping:",inline"`

	// WALConfig is the configuration for the WAL.
	WALConfig `tomlmapping:",inline"`

	// LoggingConfig is the configuration for the logging.
	LoggingConfig `tomlmapping:",inline"`

	// TracingConfig is the configuration for the tracing.
	TracingConfig `tomlmapping:",inline"`

	// InputConfig is from config field of cluster spec.
	InputConfig string
}

type FlownodeConfig struct {
	NodeID        *uint64 `tomlmapping:"node_id"`
	RPCBindAddr   *string `tomlmapping:"grpc.bind_addr"`
	RPCServerAddr *string `tomlmapping:"grpc.server_addr"`

	// LoggingConfig is the configuration for the logging.
	LoggingConfig `tomlmapping:",inline"`

	// TracingConfig is the configuration for the tracing.
	TracingConfig `tomlmapping:",inline"`

	// InputConfig is from config field of cluster spec.
	InputConfig string
}

type FrontendConfig struct {
	// StoreConfig is the configuration for the store.
	StorageConfig `tomlmapping:",inline"`

	// LoggingConfig is the configuration for the logging.
	LoggingConfig `tomlmapping:",inline"`

	// SlowQueryConfig is the configuration for the slow query.
	SlowQueryConfig `tomlmapping:",inline"`

	// TracingConfig is the configuration for the tracing.
	TracingConfig `tomlmapping:",inline"`

	// InputConfig is from config field of cluster spec.
	InputConfig string
}

type LoggingConfig struct {
	// The directory to store the log files. If set to empty, logs will not be written to files.
	Dir *string `tomlmapping:"logging.dir"`

	// The log level. Can be `info`/`debug`/`warn`/`error`.
	Level *string `tomlmapping:"logging.level"`

	// The log format. Can be `text`/`json`.
	LogFormat *string `tomlmapping:"logging.log_format"`
}

type MetaConfig struct {
	// Enable region failover.
	EnableRegionFailover *bool `tomlmapping:"enable_region_failover"`

	// If it's not empty, the meta will store all data with this key prefix.
	StoreKeyPrefix *string `tomlmapping:"store_key_prefix"`

	// The store addrs.
	StoreAddrs []string `tomlmapping:"store_addrs"`

	// The meta table name.
	MetaTableName *string `tomlmapping:"meta_table_name"`

	// The meta election lock id.
	MetaElectionLockID *uint64 `tomlmapping:"meta_election_lock_id"`

	// The backend storage type.
	Backend *string `tomlmapping:"backend"`

	// The wal provider.
	WalProvider *string `tomlmapping:"wal.provider"`

	// The kafka broker endpoints.
	WalBrokerEndpoints []string `tomlmapping:"wal.broker_endpoints"`

	// LoggingConfig is the configuration for the logging.
	LoggingConfig `tomlmapping:",inline"`

	// TracingConfig is the configuration for the tracing.
	TracingConfig `tomlmapping:",inline"`

	// InputConfig is from config field of cluster spec.
	InputConfig string
}

type SlowQueryConfig struct {
	// The slow query enabled.
	Enabled *bool `tomlmapping:"slow_query.enable"`

	// The slow query record type.
	RecordType *string `tomlmapping:"slow_query.record_type"`

	// The slow query threshold.
	Threshold *string `tomlmapping:"slow_query.threshold"`

	// The slow query sample ratio.
	SampleRatio *float64 `tomlmapping:"slow_query.sample_ratio"`

	// The TTL of the `slow_queries` system table.
	TTL *string `tomlmapping:"slow_query.ttl"`
}

type StandaloneConfig struct {
	// StorageConfig is the configuration for the storage.
	StorageConfig `tomlmapping:",inline"`

	// WALConfig is the configuration for the WAL.
	WALConfig `tomlmapping:",inline"`

	// LoggingConfig is the configuration for the logging.
	LoggingConfig `tomlmapping:",inline"`

	// SlowQueryConfig is the configuration for the slow query.
	SlowQueryConfig `tomlmapping:",inline"`

	// TracingConfig is the configuration for the tracing.
	TracingConfig `tomlmapping:",inline"`

	// InputConfig is from config field of cluster spec.
	InputConfig string
}

type StorageConfig struct {
	StorageType            *string `tomlmapping:"storage.type"`
	StorageDataHome        *string `tomlmapping:"storage.data_home"`
	StorageAccessKeyID     *string `tomlmapping:"storage.access_key_id"`
	StorageSecretAccessKey *string `tomlmapping:"storage.secret_access_key"`
	StorageAccessKeySecret *string `tomlmapping:"storage.access_key_secret"`
	StorageBucket          *string `tomlmapping:"storage.bucket"`
	StorageRoot            *string `tomlmapping:"storage.root"`
	StorageRegion          *string `tomlmapping:"storage.region"`
	StorageEndpoint        *string `tomlmapping:"storage.endpoint"`
	StorageScope           *string `tomlmapping:"storage.scope"`
	StorageCredential      *string `tomlmapping:"storage.credential"`
	Container              *string `tomlmapping:"storage.container"`
	AccountName            *string `tomlmapping:"storage.account_name"`
	AccountKey             *string `tomlmapping:"storage.account_key"`
	CacheCapacity          *string `tomlmapping:"storage.cache_capacity"`
	CachePath              *string `tomlmapping:"storage.cache_path"`
	EnableVirtualHostStyle *bool   `tomlmapping:"storage.enable_virtual_host_style"`
}

type TracingConfig struct {
	// Enable OTLP tracing.
	Enabled *bool `tomlmapping:"logging.enable_otlp_tracing"`

	// The OTLP tracing endpoint.
	Endpoint *string `tomlmapping:"logging.otlp_endpoint"`

	// The percentage of tracing will be sampled and exported.
	SampleRatio *float64 `tomlmapping:"logging.tracing_sample_ratio.default_ratio"`
}

type WALConfig struct {
	// The wal file directory.
	WalDir *string `tomlmapping:"wal.dir"`

	// The wal provider.
	WalProvider *string `tomlmapping:"wal.provider"`

	// The kafka broker endpoints.
	WalBrokerEndpoints []string `tomlmapping:"wal.broker_endpoints"`
}