config

type AggregationConfiguration struct {
	ClickHouse ClickHouseAggregationConfiguration
}

type ClickHouseAggregationConfiguration struct {
	Address  string
	TLS      bool
	Username string
	Password string
	Database string
}

type ClickHouseConnectorTypeKafkaConnectSinkConfiguration struct {
	Hostname string
	Port     int
	SSL      bool
	Username string
	Password string
	Database string

	DeadLetterQueue DeadLetterQueueKafkaConnectSinkConfiguration
}

type Configuration struct {
	Address     string
	Environment string

	Telemetry TelemetryConfig

	Namespace   NamespaceConfiguration
	Ingest      IngestConfiguration
	Aggregation AggregationConfiguration
	Sink        SinkConfiguration
	Dedupe      DedupeConfiguration

	Meters []*models.Meter
}

type ConnectorKafkaConnectSinkConfiguration struct {
	Name string

	ConnectorTypeKafkaConnectSinkConfiguration
}

type ConnectorTypeKafkaConnectSinkConfiguration interface {
	ConnectorConfig() (map[string]string, error)
	Validate() error
}

type DeadLetterQueueKafkaConnectSinkConfiguration struct {
	TopicName         string
	ReplicationFactor int
	ContextHeaders    bool
}

type DedupeConfiguration struct {
	Enabled bool

	DedupeDriverConfiguration
}

type DedupeDriverConfiguration interface {
	DriverName() string
	NewDeduplicator() (ingest.Deduplicator, error)
	Validate() error
}

type DedupeDriverMemoryConfiguration struct {
	Enabled bool
	Size    int
}

type DedupeDriverRedisConfiguration struct {
	Address    string
	Database   int
	Username   string
	Password   string
	Expiration time.Duration
	Sentinel   struct {
		Enabled    bool
		MasterName string
	}
	TLS struct {
		Enabled            bool
		InsecureSkipVerify bool
	}
}

type ExporterTraceTelemetryConfig struct {
	Enabled bool
	Address string
}

type IngestConfiguration struct {
	Kafka KafkaIngestConfiguration
}

type KafkaConnectSinkConfiguration struct {
	Enabled bool
	URL     string

	Connectors []ConnectorKafkaConnectSinkConfiguration
}

type KafkaIngestConfiguration struct {
	Broker              string
	SecurityProtocol    string
	SaslMechanisms      string
	SaslUsername        string
	SaslPassword        string
	Partitions          int
	EventsTopicTemplate string
}

type LogTelemetryConfiguration struct {
	// Format specifies the output log format.
	// Accepted values are: json, text
	Format string

	// Level is the minimum log level that should appear on the output.
	//
	// Requires [mapstructure.TextUnmarshallerHookFunc] to be high up in the decode hook chain.
	Level slog.Level
}

type NamespaceConfiguration struct {
	Default           string
	DisableManagement bool
}

type SinkConfiguration struct {
	KafkaConnect KafkaConnectSinkConfiguration
}

type TelemetryConfig struct {
	// Telemetry HTTP server address
	Address string

	Trace TraceTelemetryConfig

	Log LogTelemetryConfiguration
}

type TraceTelemetryConfig struct {
	Exporter ExporterTraceTelemetryConfig
	Sampler  string
}