nsq

type Client ¶

type Client struct {
	sync.RWMutex
	ID                 int64 // GUID
	Producer           *nsq.Producer
	Topics             map[string]byte          // "topic": client-client'
	Subscribes         map[string]*nsq.Consumer // "topic/channel" -> Consumer
	LookupdHTTPAddress string                   // Lookupd HTTP address
}

Client can use a producer for publish and subscribe multi topic/channel message

func NewClient(id int64, addr, lookupdHTTPAddress string, config *Config) (*Client, error)

func (c *Client) Publish(topic string, message string) error

func (c *Client) SetHandler(topic, channel string, handler Handler) error

func (c *Client) Subscribe(topic, channel string, config *Config, handler Handler) error

type Config ¶

type Config = nsq.Config

Config for nsq.producer

func NewConfig() *Config

type Handler ¶

type Handler = nsq.Handler

Handler for consumer

type HandlerFunc ¶

type HandlerFunc func(message *Message) error

HandlerFunc for consumer

func (h HandlerFunc) HandleMessage(m *Message) error

type LookupdOptions ¶

type LookupdOptions = nsqlookupd.Options

LookupdOptions https://nsq.io/components/nsqlookupd.html nsqlookupd.NewOptions() return default Option

func NewLookupdOptions() *LookupdOptions

type Message ¶

type Message = nsq.Message

Message for topic

type NSQAdmin ¶

type NSQAdmin = nsqadmin.NSQAdmin

NSQAdmin is a Web UI to view aggregated cluster stats in realtime and perform various administrative tasks.

func StartNsqAdmin(opts *NsqadminOptions) (*NSQAdmin, error)

type NSQD ¶

type NSQD = nsqd.NSQD

NSQD is the daemon that receives, queues, and delivers messages to clients. It can be run standalone but is normally configured in a cluster with nsqlookupd instance(s) (in which case it will announce topics and channels for discovery). It listens on two TCP ports, one for clients and another for the HTTP API. It can optionally listen on a third port for HTTPS.

func StartNsqd(opts *NsqdOptions) (*NSQD, error)

type NSQLookupd ¶

type NSQLookupd = nsqlookupd.NSQLookupd

NSQLookupd is the daemon that manages topology information. Clients query nsqlookupd to discover nsqd producers for a specific topic and nsqd nodes broadcasts topic and channel information.

There are two interfaces: A TCP interface which is used by nsqd for broadcasts, and an HTTP interface for clients to perform discovery and administrative actions.

func StartNsqlookupd(opts *LookupdOptions) (*NSQLookupd, error)

type NsqadminOptions ¶

type NsqadminOptions = nsqadmin.Options

NsqadminOptions https://nsq.io/components/nsqadmin.html nsqadmin.NewOptions() return default Option

func NewNsqadminOptions() *NsqadminOptions

type NsqdOptions ¶

type NsqdOptions = nsqd.Options

NsqdOptions https://nsq.io/components/nsqd.html nsqd.NewOptions() return default Option

func NewNsqdOptions() *NsqdOptions