consumer

package

v0.0.0-...-23205d1 Latest Latest Go to latest Published: Apr 6, 2015 License: MIT Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/vincent3i/nsqueue

Links

Open Source Insights

Documentation ¶

Index ¶

func Connect(addr string) error
func ConnectList(addrs []string) error
func ConnectLookupd(addr string) error
func ConnectLookupdList(addrs []string) error
func Register(topic, channel string, maxInFlight int, fnc Handler) error
func Start(debug bool)
type Consumer
- func New() *Consumer
type Handler
type Message

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Connect ¶

func Connect(addr string) error

Connect - Look for Consumer.Connect() (on default consumer)

func ConnectList ¶

func ConnectList(addrs []string) error

ConnectList - Look for Consumer.ConnectList() (on default consumer)

func ConnectLookupd ¶

func ConnectLookupd(addr string) error

ConnectLookupd - Look for Consumer.ConnectLookupd() (on default consumer)

func ConnectLookupdList ¶

func ConnectLookupdList(addrs []string) error

ConnectLookupdList - Look for Consumer.ConnectLookupdList() (on default consumer)

func Register ¶

func Register(topic, channel string, maxInFlight int, fnc Handler) error

Register - Look for Consumer.Register() (on default consumer)

func Start ¶

func Start(debug bool)

Start - Look for Consumer.Start() (on default consumer)

Types ¶

type Consumer ¶

type Consumer struct {
	Logger   *nsqlog.NsqLogger
	LogLevel *nsq.LogLevel
	// contains filtered or unexported fields
}

Consumer - NSQ messages consumer.

var DefaultConsumer *Consumer

Shortcuts for apps using only one consumer

func New ¶

func New() *Consumer

New - Creates a new consumer structure

func (*Consumer) Connect ¶

func (c *Consumer) Connect(addr string) error

Connect - Connects all readers to NSQ

func (*Consumer) ConnectList ¶

func (c *Consumer) ConnectList(addrs []string) error

ConnectList - Connects all readers to NSQ instances

func (*Consumer) ConnectLookupd ¶

func (c *Consumer) ConnectLookupd(addr string) error

ConnectLookupd - Connects all readers to NSQ lookupd

func (*Consumer) ConnectLookupdList ¶

func (c *Consumer) ConnectLookupdList(addrs []string) error

ConnectLookupdList - Connects all readers to NSQ lookupd instances

func (*Consumer) Register ¶

func (c *Consumer) Register(topic, channel string, maxInFlight int, handler Handler) error

Register - Registers topic/channel handler for messages This function creates a new nsq.Reader

func (*Consumer) Start ¶

func (c *Consumer) Start(debug bool) error

Start - Just waits

type Handler ¶

type Handler func(*Message)

Handler - Function that handles incoming message.

type Message ¶

type Message struct {
	*nsq.Message
}

Message - Inherent nsq

func (*Message) Fail ¶

func (m *Message) Fail()

Fail - Mark message as failed to process

func (*Message) Finish ¶

func (m *Message) Finish(success bool)

Finish - Finish processing message

func (*Message) GiveUp ¶

func (m *Message) GiveUp()

GiveUp - Finish message with success state because message never will be possible to process

func (*Message) ReadJSON ¶

func (m *Message) ReadJSON(v interface{}) error

ReadJSON - Unmarshals JSON message body to interface.

func (*Message) Success ¶

func (m *Message) Success()

Success - Finish message as successfully proccessed

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL