config

type EndpointHydratorConfig struct {
	// List of service IDs to disable QoS checks for.
	// By default all configured service IDs will be checked unless specified here.
	// Startup will error if a service ID is specified here that is not in the protocol's configured service IDs.
	// Primarily just used for testing & development.
	QoSDisabledServiceIDs []protocol.ServiceID `yaml:"qos_disabled_service_ids"`

	// Interval between hydrator runs during which endpoint checks are performed
	RunInterval time.Duration `yaml:"run_interval_ms"`

	// Maximum number of concurrent endpoint check workers for performance tuning
	MaxEndpointCheckWorkers int `yaml:"max_endpoint_check_workers"`
}

type EnvConfigError struct {
	Description string
}

type GatewayConfig struct {
	ShannonConfig      *shannon.ShannonGatewayConfig `yaml:"shannon_config"`
	Router             RouterConfig                  `yaml:"router_config"`
	Logger             LoggerConfig                  `yaml:"logger_config"`
	HydratorConfig     EndpointHydratorConfig        `yaml:"hydrator_config"`
	MessagingConfig    MessagingConfig               `yaml:"messaging_config"`
	DataReporterConfig HTTPDataReporterConfig        `yaml:"data_reporter_config"`
}

type HTTPDataReporterConfig struct {
	// HTTP endpoint for data delivery.
	// Example: Fluentd HTTP input plugin address.
	TargetURL string `yaml:"target_url"`

	// Timeout in milliseconds for HTTP POST operations.
	// If zero or negative, a default timeout will be used.
	PostTimeoutMS int `yaml:"post_timeout_ms"`
}

type LoggerConfig struct {
	// Level sets the minimum log level. Valid values are:
	// "debug", "info", "warn", "error"
	Level string `yaml:"level"`
}

type MessagingConfig struct{}

type RouterConfig struct {
	Port                            int           `yaml:"port"`
	MaxRequestHeaderBytes           int           `yaml:"max_request_header_bytes"`
	ReadTimeout                     time.Duration `yaml:"read_timeout"`
	WriteTimeout                    time.Duration `yaml:"write_timeout"`
	IdleTimeout                     time.Duration `yaml:"idle_timeout"`
	SystemOverheadAllowanceDuration time.Duration `yaml:"system_overhead_allowance_duration"`
	// WebsocketMessageBufferSize is the buffer size for websocket message observation channels.
	// Larger values use more memory but can handle higher message throughput.
	// Default: 50 (prevents OOM while maintaining reasonable throughput)
	WebsocketMessageBufferSize int `yaml:"websocket_message_buffer_size"`
}

type ServiceQoSConfig interface {
	GetServiceID() protocol.ServiceID
	GetServiceQoSType() string
}