config

type AMQPConfig struct {
	// Host is the host of the queue
	Host string `yaml:"host,omitempty"`

	// Port is the port of the queue
	Port int `yaml:"port,omitempty"`

	// Username is the username of the queue
	Username string `yaml:"username,omitempty"`

	// Password is the password of the queue
	Password string `yaml:"password,omitempty"`
}

type Config struct {
	// Providers is a list of sources that will be connected to
	Providers []*ProviderConfig `yaml:"providers"`

	// Queues is a list of queues that will be consumed
	Queues []*QueueConfig `yaml:"queues"`

	// Debug is a flag that enables debug logging
	Debug bool `yaml:"debug"`
}

type KafkaConfig struct {
	// Brokers is a list of brokers that will be consumed
	Brokers []string `yaml:"brokers,omitempty"`

	// Topic is a list of topics that will be consumed
	Topic string `yaml:"topic,omitempty"`

	// Group is the consumer group that will be used
	Group string `yaml:"group,omitempty"`
}

type ProviderConfig struct {
	// Name is the name of the provider
	Name string `yaml:"name"`

	// Type is the type of the provider, such as "amqp" or "kafka"
	Type string `yaml:"type"`

	// Retry is the number of times to retry connecting to the provider
	Retry int `yaml:"retry,omitempty"`

	// AMQPConfig is the configuration for the AMQP provider
	AMQPConfig *AMQPConfig `yaml:"amqp-config,omitempty"`

	// KafkaConfig is the configuration for the Kafka provider
	KafkaConfig *KafkaConfig `yaml:"kafka-config,omitempty"`

	// StompMQConfig is the configuration for the ActiveMQ provider
	StompMQConfig *StompConfig `yaml:"stomp-config,omitempty"`
}

type QueueConfig struct {
	// Name is the name of the queue
	Name string `yaml:"name"`

	// Provider is the provider that will be used to consume the queue
	Provider string `yaml:"provider"`

	// Retry is the retry configuration for the queue
	Retry *RetryConfig `yaml:"retry,omitempty"`

	// Routes is the list of routes that will be used to send the messages
	Routes []*RouteConfig `yaml:"routes"`
}

type RetryConfig struct {
	// Enabled is the flag that indicates if the retry is enabled, defaults to false
	Enabled bool `yaml:"enabled,omitempty"`

	// MaxRetries is the maximum number of retries for the queue
	MaxRetries int `yaml:"max_retries"`

	// Strategy is the retry strategy for the queue, defaults to "fixed"
	Strategy string `yaml:"strategy,omitempty"`

	// Interval is the interval between retries
	Interval time.Duration `yaml:"interval"`

	// ThresholdStatus is the minimum status code that will trigger a retry, defaults to 500
	ThresholdStatus int `yaml:"threshold_status,omitempty"`
}

type RouteConfig struct {
	// Name is the name of the route
	Name string `yaml:"name"`

	// URL is the URL of the service
	URL string `yaml:"url"`

	// Method is the HTTP method of the request, defaults to "POST"
	Method string `yaml:"method,omitempty"`

	// Type is the type of the request, defaults to "REST"
	Type string `yaml:"type,omitempty"`

	// Headers is the list of headers that will be sent with the request
	Headers map[string]string `yaml:"headers,omitempty"`

	// Body is the body of the request
	Body map[string]interface{} `yaml:"body,omitempty"`

	// Query is the query string of the request
	Query map[string]string `yaml:"query,omitempty"`

	// Timeout is the timeout of the request, defaults to 10 seconds
	Timeout time.Duration `yaml:"timeout,omitempty"`
}

type StompConfig struct {
	// Host is the host of the queue
	Host string `yaml:"host,omitempty"`

	// Port is the port of the queue
	Port int `yaml:"port,omitempty"`

	// Username is the username of the queue
	Username string `yaml:"username,omitempty"`

	// Password is the password of the queue
	Password string `yaml:"password,omitempty"`
}