amqpx

Documentation

Index

• Variables
• func NewConnection(config *Config) (*amqp091.Connection, error)
• func NewConnections(configs Configs) (map[string]*amqp091.Connection, error)
• type Config
• type Configs
• type TLSConfig

Variables

var Provider = wire.NewSet(
	NewConnections,
)

Functions

func NewConnection

func NewConnection(config *Config) (*amqp091.Connection, error)

func NewConnections

func NewConnections(configs Configs) (map[string]*amqp091.Connection, error)

Types

type Config

type Config struct {
	URL           string          `mapstructure:"url" json:"url" yaml:"url"`
	TLS           *TLSConfig      `mapstructure:"tls" json:"tls" yaml:"tls"`
	ExternalAuth  bool            `mapstructure:"external_auth" json:"external_auth" yaml:"external_auth"`
	Amqp091Config *amqp091.Config `mapstructure:"amqp_091_config" json:"amqp_091_config" yaml:"amqp_091_config"`
}

type Configs

type Configs map[string]*Config

type TLSConfig

type TLSConfig struct {
	PEMFile  string `mapstructure:"pem_file" json:"pem_file" yaml:"pem_file"`
	CertFile string `mapstructure:"cert_file" json:"cert_file" yaml:"cert_file"`
	KeyFile  string `mapstructure:"key_file" json:"key_file" yaml:"key_file"`
}