config

type AMQPConfig struct {
	Url                string           `env:"URL" validate:"required"`
	Exchange           string           `env:"EXCHANGE" envDefault:"paota_task_exchange"`
	ExchangeType       string           `env:"EXCHANGE_TYPE" envDefault:"direct"`
	QueueDeclareArgs   QueueDeclareArgs `env:"QUEUE_DECLARE_ARGS"`
	QueueBindingArgs   QueueBindingArgs `env:"QUEUE_BINDING_ARGS"`
	BindingKey         string           `env:"BINDING_KEY" envDefault:"paota_task_binding_key"`
	PrefetchCount      int              `env:"PREFETCH_COUNT" validate:"required"`
	AutoDelete         bool             `env:"AUTO_DELETE"`
	DelayedQueue       string           `env:"DELAYED_QUEUE" envDefault:"paota_task_delayed_queue"`
	ConnectionPoolSize int              `env:"CONNECTION_POOL_SIZE" envDefault:"5"`
	HeartBeatInterval  int              `env:"HEARTBEAT_INTERVAL" envDefault:"10"`
}

type Config struct {
	Broker         string         `env:"BROKER" envDefault:"amqp" validate:"required,oneof=amqp"` //allowed amqp
	Store          string         `env:"STORE"`
	TaskQueueName  string         `env:"QUEUE_NAME" envDefault:"paota_tasks" validate:"required"`
	StoreQueueName string         `env:"STORE_QUEUE_NAME"`
	AMQP           *AMQPConfig    `envPrefix:"AMQP_"`
	MongoDB        *MongoDBConfig `envPrefix:"MONGO_"`
}

type ConfigProvider interface {
	ReadFromEnv() error
	SetApplicationConfig(config Config) error
	ValidateConfig(cfg Config) error
	GetConfig() *Config
}

type MongoDBConfig struct {
	Client   *mongo.Client
	Database string
}

type QueueBindingArgs map[string]interface{}

type QueueDeclareArgs map[string]interface{}