nsq

package

v0.0.37 Latest Latest Go to latest Published: Apr 1, 2020 License: MIT Imports: 9 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/dipperin/go-ms-toolkit

Links

Open Source Insights

Documentation ¶

Index ¶

func SetLog(l logger)
func SetLogLv(lv nsq.LogLevel)
type BaseNsqWriter
- func (writer *BaseNsqWriter) Publish(topic string, jsonObj interface{}) error
- func (writer *BaseNsqWriter) PublishString(topic string, msg string) error
- func (writer *BaseNsqWriter) Refresh()
- func (writer *BaseNsqWriter) Stop()
type Consumer
- func NewConsumer(topic, channel string) *Consumer
- func (c *Consumer) Set(option string, value interface{})
- func (c *Consumer) SetLogger(log logger, level nsq.LogLevel)
- func (c *Consumer) SetMap(options map[string]interface{})
- func (c *Consumer) Start(handler nsq.Handler) error
- func (c *Consumer) Stop() error
type MqHostConfigs
- func (c *MqHostConfigs) IsValid()
type MqReceiver
- func NewNsqReceiver(config *MqHostConfigs) MqReceiver
type MqTask
- func NewNsqTask() MqTask
type MqTaskConfigs
type NsqHandler
type NsqHandlerFunc
- func (f NsqHandlerFunc) TaskConfig() (config *MqTaskConfigs)
type NsqReceiver
- func (r *NsqReceiver) AddTask(tasks ...MqTask) MqReceiver
- func (r *NsqReceiver) BaseHost() (baseHost *MqHostConfigs)
- func (r *NsqReceiver) Start()
- func (r *NsqReceiver) Stop()
type NsqTask
type NsqWriter
- func NewNsqWriter(addrs []string) NsqWriter
type ReceiverManager
- func NewReceiverManager(receiver MqReceiver, h ...NsqHandler) *ReceiverManager
- func (a *ReceiverManager) Add(h ...NsqHandler)
- func (a *ReceiverManager) Start()
- func (a *ReceiverManager) Stop()

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func SetLog ¶ added in v0.0.19

func SetLog(l logger)

func SetLogLv ¶ added in v0.0.18

func SetLogLv(lv nsq.LogLevel)

Types ¶

type BaseNsqWriter ¶ added in v0.0.24

type BaseNsqWriter struct {
	// contains filtered or unexported fields
}

func (*BaseNsqWriter) Publish ¶ added in v0.0.24

func (writer *BaseNsqWriter) Publish(topic string, jsonObj interface{}) error

func (*BaseNsqWriter) PublishString ¶ added in v0.0.24

func (writer *BaseNsqWriter) PublishString(topic string, msg string) error

func (*BaseNsqWriter) Refresh ¶ added in v0.0.24

func (writer *BaseNsqWriter) Refresh()

func (*BaseNsqWriter) Stop ¶ added in v0.0.30

func (writer *BaseNsqWriter) Stop()

type Consumer ¶

type Consumer struct {
	// contains filtered or unexported fields
}

func NewConsumer ¶

func NewConsumer(topic, channel string) *Consumer

初始化消费端

func (*Consumer) Set ¶

func (c *Consumer) Set(option string, value interface{})

func (*Consumer) SetLogger ¶

func (c *Consumer) SetLogger(log logger, level nsq.LogLevel)

func (*Consumer) SetMap ¶

func (c *Consumer) SetMap(options map[string]interface{})

func (*Consumer) Start ¶

func (c *Consumer) Start(handler nsq.Handler) error

func (*Consumer) Stop ¶

func (c *Consumer) Stop() error

stop and wait

type MqHostConfigs ¶ added in v0.0.17

type MqHostConfigs struct {
	Lookup, Nsq []string
}

func (*MqHostConfigs) IsValid ¶ added in v0.0.17

func (c *MqHostConfigs) IsValid()

type MqReceiver ¶ added in v0.0.17

type MqReceiver interface {
	AddTask(task ...MqTask) MqReceiver
	BaseHost() (baseHost *MqHostConfigs)
	Start()
	Stop()
}

func NewNsqReceiver ¶ added in v0.0.19

func NewNsqReceiver(config *MqHostConfigs) MqReceiver

type MqTask ¶ added in v0.0.17

type MqTask interface {
	// contains filtered or unexported methods
}

func NewNsqTask ¶ added in v0.0.17

func NewNsqTask() MqTask

type MqTaskConfigs ¶ added in v0.0.17

type MqTaskConfigs struct {
	Topic, Channel string
	Handler        nsq.HandlerFunc
	Host           *MqHostConfigs
	Configs        map[string]interface{} // nsq tls configs
	Concurrency    int                    // goroutines numbers
}

type NsqHandler ¶ added in v0.0.17

type NsqHandler interface {
	TaskConfig() (config *MqTaskConfigs)
}

type NsqHandlerFunc ¶ added in v0.0.17

type NsqHandlerFunc func() (config *MqTaskConfigs)

func (NsqHandlerFunc) TaskConfig ¶ added in v0.0.17

func (f NsqHandlerFunc) TaskConfig() (config *MqTaskConfigs)

type NsqReceiver ¶ added in v0.0.17

type NsqReceiver struct {
	Index uint32
	// contains filtered or unexported fields
}

func (*NsqReceiver) AddTask ¶ added in v0.0.17

func (r *NsqReceiver) AddTask(tasks ...MqTask) MqReceiver

func (*NsqReceiver) BaseHost ¶ added in v0.0.17

func (r *NsqReceiver) BaseHost() (baseHost *MqHostConfigs)

func (*NsqReceiver) Start ¶ added in v0.0.17

func (r *NsqReceiver) Start()

func (*NsqReceiver) Stop ¶ added in v0.0.30

func (r *NsqReceiver) Stop()

type NsqTask ¶ added in v0.0.17

type NsqTask struct {
	Fatal  error
	ConErr []error
	// contains filtered or unexported fields
}

type NsqWriter ¶ added in v0.0.19

type NsqWriter interface {
	Refresh()
	Publish(topic string, jsonObj interface{}) error
	PublishString(topic string, msg string) error
	Stop()
}

func NewNsqWriter ¶ added in v0.0.19

func NewNsqWriter(addrs []string) NsqWriter

type ReceiverManager ¶ added in v0.0.17

type ReceiverManager struct {
	// contains filtered or unexported fields
}

func NewReceiverManager ¶ added in v0.0.17

func NewReceiverManager(receiver MqReceiver, h ...NsqHandler) *ReceiverManager

func (*ReceiverManager) Add ¶ added in v0.0.17

func (a *ReceiverManager) Add(h ...NsqHandler)

func (*ReceiverManager) Start ¶ added in v0.0.17

func (a *ReceiverManager) Start()

func (*ReceiverManager) Stop ¶ added in v0.0.30

func (a *ReceiverManager) Stop()

Source Files ¶

View all Source files

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