Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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 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
}
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 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
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()
Click to show internal directories.
Click to hide internal directories.