Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ReadFromFile ¶
ReadFromFile reads data from a file
Types ¶
type AMQPConfig ¶
type AMQPConfig struct {
Exchange string `yaml:"exchange" envconfig:"AMQP_EXCHANGE"`
ExchangeType string `yaml:"exchange_type" envconfig:"AMQP_EXCHANGE_TYPE"`
QueueBindingArgs QueueBindingArgs `yaml:"queue_binding_args" envconfig:"AMQP_QUEUE_BINDING_ARGS"`
BindingKey string `yaml:"binding_key" envconfig:"AMQP_BINDING_KEY"`
PrefetchCount int `yaml:"prefetch_count" envconfig:"AMQP_PREFETCH_COUNT"`
DropUnregisteredTasks bool `yaml:"drop_unregistered_tasks" envconfig:"AMQP_DROP_UNREGISTERED_TASKS"`
}
AMQPConfig wraps RabbitMQ related configuration
type Config ¶
type Config struct {
Broker string `yaml:"broker" envconfig:"BROKER"`
DefaultQueue string `yaml:"default_queue" envconfig:"DEFAULT_QUEUE"`
ResultBackend string `yaml:"result_backend" envconfig:"RESULT_BACKEND"`
ResultsExpireIn int `yaml:"results_expire_in" envconfig:"RESULTS_EXPIRE_IN"`
AMQP *AMQPConfig `yaml:"amqp"`
TLSConfig *tls.Config
}
Config holds all configuration for our program
func NewFromEnvironment ¶
NewFromEnvironment creates a config object from environment variables
func NewFromYaml ¶
NewFromYaml creates a config object from YAML file
type QueueBindingArgs ¶
type QueueBindingArgs map[string]interface{}
QueueBindingArgs arguments which are used when binding to the exchange
func (*QueueBindingArgs) Decode ¶
func (args *QueueBindingArgs) Decode(value string) error
Decode from yaml to map (any field whose type or pointer-to-type implements envconfig.Decoder can control its own deserialization)
Source Files
Click to show internal directories.
Click to hide internal directories.