nsq

Documentation

Index

• func NewConsumer(h Consumer, m Marshaller) nsq.Handler
• type Consumer
• type Headers
• type Marshaller
  • func NewMsgPackMarshaller() Marshaller
• type Message
  • func NewMessage(body []byte) *Message
• type Producer

Functions

func NewConsumer

func NewConsumer(h Consumer, m Marshaller) nsq.Handler

NewConsumer handler for NSQ.

Types

type Consumer

type Consumer interface {
	Consume(ctx context.Context, message *Message) error
}

Consumer for NSQ.

type Headers

type Headers map[string]string

Headers of message.

type Marshaller

type Marshaller marshaller.Marshaller

Marshaller for NSQ.

func NewMsgPackMarshaller

func NewMsgPackMarshaller() Marshaller

NewMsgPackMarshaller for NSQ.

type Message

type Message struct {
	Headers Headers `msgpack:"headers"`
	Body    []byte  `msgpack:"body"`

	*nsq.Message `msgpack:"-"`
}

Message for NSQ.

func NewMessage

func NewMessage(body []byte) *Message

New message.

type Producer

type Producer interface {
	Produce(ctx context.Context, topic string, message *Message) error
}

Producer for NSQ.