amqp10_client

Documentation

Index

• type Amqp10Consumer
  • func NewConsumer(cfg config.Config, id int) *Amqp10Consumer
  • func (c Amqp10Consumer) Start(ctx context.Context, subscribed chan bool)
  • func (c Amqp10Consumer) Stop(reason string)
• type Amqp10Publisher
  • func NewPublisher(cfg config.Config, n int) *Amqp10Publisher
  • func (p Amqp10Publisher) Send()
  • func (p Amqp10Publisher) Start(ctx context.Context)
  • func (p Amqp10Publisher) StartFullSpeed(ctx context.Context)
  • func (p Amqp10Publisher) StartRateLimited(ctx context.Context)
  • func (p Amqp10Publisher) Stop(reason string)

Types

type Amqp10Consumer

type Amqp10Consumer struct {
	Id         int
	Connection *amqp.Conn
	Session    *amqp.Session
	Topic      string
	Config     config.Config
}

func NewConsumer

func NewConsumer(cfg config.Config, id int) *Amqp10Consumer

func (Amqp10Consumer) Start

func (c Amqp10Consumer) Start(ctx context.Context, subscribed chan bool)

func (Amqp10Consumer) Stop

func (c Amqp10Consumer) Stop(reason string)

type Amqp10Publisher

type Amqp10Publisher struct {
	Id               int
	Sender           *amqp.Sender
	Connectionection *amqp.Conn
	Topic            string
	Config           config.Config
	// contains filtered or unexported fields
}

func NewPublisher

func NewPublisher(cfg config.Config, n int) *Amqp10Publisher

func (Amqp10Publisher) Send

func (p Amqp10Publisher) Send()

func (Amqp10Publisher) Start

func (p Amqp10Publisher) Start(ctx context.Context)

func (Amqp10Publisher) StartFullSpeed

func (p Amqp10Publisher) StartFullSpeed(ctx context.Context)

func (Amqp10Publisher) StartRateLimited

func (p Amqp10Publisher) StartRateLimited(ctx context.Context)

func (Amqp10Publisher) Stop

func (p Amqp10Publisher) Stop(reason string)