publisher

Documentation

Index

• type Message
  • func Json(body []byte) *Message
  • func PlainText(body []byte) *Message
  • func (m *Message) WithHeader(key string, value string) *Message
• type Middleware
• type Option
  • func WithConnectionOptions(connOpts ...consumer.ConnOption) Option
  • func WithMiddlewares(mws ...Middleware) Option
• type PublishOption
• type Publisher
  • func NewPublisher(address string, queue string, opts ...Option) *Publisher
  • func (p *Publisher) Close() error
  • func (p *Publisher) Publish(ctx context.Context, msg *Message) error
  • func (p *Publisher) PublishTo(ctx context.Context, queue string, msg *Message) error
• type RoundTripper
• type RoundTripperFunc
  • func (f RoundTripperFunc) Publish(ctx context.Context, queue string, msg *Message) error

Types

type Message

type Message struct {
	ContentType string
	Body        []byte
	Opts        []PublishOption
}

func Json

func Json(body []byte) *Message

func PlainText

func PlainText(body []byte) *Message

func (*Message) WithHeader

func (m *Message) WithHeader(key string, value string) *Message

type Middleware

type Middleware func(next RoundTripper) RoundTripper

type Option

type Option func(p *Publisher)

func WithConnectionOptions

func WithConnectionOptions(connOpts ...consumer.ConnOption) Option

func WithMiddlewares

func WithMiddlewares(mws ...Middleware) Option

type PublishOption

type PublishOption = func(*frame.Frame) error

type Publisher

type Publisher struct {
	Address     string
	Queue       string
	ConnOpts    []consumer.ConnOption
	Middlewares []Middleware
	// contains filtered or unexported fields
}

func NewPublisher

func NewPublisher(address string, queue string, opts ...Option) *Publisher

func (*Publisher) Close

func (p *Publisher) Close() error

func (*Publisher) Publish

func (p *Publisher) Publish(ctx context.Context, msg *Message) error

func (*Publisher) PublishTo

func (p *Publisher) PublishTo(ctx context.Context, queue string, msg *Message) error

type RoundTripper

type RoundTripper interface {
	Publish(ctx context.Context, queue string, msg *Message) error
}

type RoundTripperFunc

type RoundTripperFunc func(ctx context.Context, queue string, msg *Message) error

func (RoundTripperFunc) Publish

func (f RoundTripperFunc) Publish(ctx context.Context, queue string, msg *Message) error