mrrabbitmq

Documentation

Index

• type ConnAdapter
  • func New() *ConnAdapter
  • func (c *ConnAdapter) Cli() *amqp.Connection
  • func (c *ConnAdapter) Close() error
  • func (c *ConnAdapter) Connect(_ context.Context, opts Options) error
• type Options

Types

type ConnAdapter

type ConnAdapter struct {
	// contains filtered or unexported fields
}

ConnAdapter - адаптер для работы с Rabbitmq клиентом.

func New

func New() *ConnAdapter

New - создаёт объект ConnAdapter.

func (*ConnAdapter) Cli

func (c *ConnAdapter) Cli() *amqp.Connection

Cli - возвращается нативный объект, с которым работает данный адаптер.

func (*ConnAdapter) Close

func (c *ConnAdapter) Close() error

Close - закрывает текущее соединение.

func (*ConnAdapter) Connect

func (c *ConnAdapter) Connect(_ context.Context, opts Options) error

Connect - создаёт соединение с указанными опциями.

type Options

type Options struct {
	Host     string
	Port     string
	User     string
	Password string
}

Options - опции для создания соединения для ConnAdapter.