amqp

Documentation

Index

• type Producer
  • func NewProducer(config ProducerConfig) (*Producer, error)
  • func (p *Producer) Publish(imageId int) error
  • func (p *Producer) Shutdown() error
• type ProducerConfig

Types

type Producer

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

func NewProducer

func NewProducer(config ProducerConfig) (*Producer, error)

func (*Producer) Publish

func (p *Producer) Publish(imageId int) error

func (*Producer) Shutdown

func (p *Producer) Shutdown() error

type ProducerConfig

type ProducerConfig struct {
	Username string
	Password string
	Host     string
	Port     string
}