pub

Documentation

Index

• type Publisher
  • func NewPublisher(conn *amqp.Connection) (*Publisher, error)
  • func (p *Publisher) Close() error
  • func (p *Publisher) Publish(ctx context.Context, pack PublishingPackage) error
• type PublishingPackage

Types

type Publisher

type Publisher struct {
	bindings.PubSubChannel
}

Publisher's channel(for now)

func NewPublisher

func NewPublisher(conn *amqp.Connection) (*Publisher, error)

Create New publisher from connection(No way, right?) it should be defered btw

func (*Publisher) Close

func (p *Publisher) Close() error

Want to close publisher early? That's for you

func (*Publisher) Publish

func (p *Publisher) Publish(ctx context.Context, pack PublishingPackage) error

Publishes whatever you want wherever you want

type PublishingPackage

type PublishingPackage struct {
	Exchange  string
	Key       string
	Mandatory bool
	Immediate bool
	Message   amqp.Publishing
}