rabbitmq

Documentation

Index

• type RabbitMQ
  • func NewRabbitMQ(config RabbitMQConfig) *RabbitMQ
  • func (r *RabbitMQ) Close() error
  • func (r *RabbitMQ) SendAlarm(events model.Events) error
  • func (r *RabbitMQ) Start(ctx context.Context, wg *sync.WaitGroup)
• type RabbitMQConfig

Types

type RabbitMQ

type RabbitMQ struct {
	ConnectionString string
	QueueName        string
	// contains filtered or unexported fields
}

func NewRabbitMQ

func NewRabbitMQ(config RabbitMQConfig) *RabbitMQ

NewRabbitMQ initializes the RabbitMQ struct with a predefined logger

func (*RabbitMQ) Close

func (r *RabbitMQ) Close() error

Close gracefully shuts down the connection and channel

func (*RabbitMQ) SendAlarm

func (r *RabbitMQ) SendAlarm(events model.Events) error

func (*RabbitMQ) Start

func (r *RabbitMQ) Start(ctx context.Context, wg *sync.WaitGroup)

Start the controller

type RabbitMQConfig

type RabbitMQConfig struct {
	ConnectionString string `yaml:"ConnectionString"`
	QueueName        string `yaml:"QueueName"`
	Scheme           string `yaml:"Scheme"`
	Host             string `yaml:"Host"`
	Port             int    `yaml:"Port"`
	UserName         string `yaml:"UserName"`
	Password         string `yaml:"Password"`
	Resource         string `yaml:"Resource"`
}