Documentation ¶
Index ¶
- Constants
- Variables
- func InstallExt(ctrlName string, mc IMCGeter, conf *ConnConf)
- func PreClose(name string) error
- func Publish(nsqdAddr, topic string, value interface{}) error
- type CParam
- type ConnConf
- type Consum
- func (this *Consum) Count() int
- func (this *Consum) HandleInit()
- func (this *Consum) HandleTerm()
- func (this *Consum) HasUnit(name string) int
- func (this *Consum) Mount(source TUnits)
- func (this *Consum) Overview() string
- func (this *Consum) Ping() error
- func (this *Consum) Start(name string, handle IConsumer) error
- type HandlerMsgFunc
- type IConsumer
- type IMCGeter
- type Logger
- type Msg
- type TUnits
- type To
- type Unit
Constants ¶
View Source
const (
DEF_UNIT_MSIZE = 10
)
Variables ¶
View Source
var ( ErrOK = error(nil) ErrRequeue = errors.New("ErrRequeue") )
Functions ¶
Types ¶
type Consum ¶
type Consum struct { cto.ControlBase // contains filtered or unexported fields }
=> nsq consum control
func (*Consum) HandleInit ¶
func (this *Consum) HandleInit()
func (*Consum) HandleTerm ¶
func (this *Consum) HandleTerm()
type HandlerMsgFunc ¶
HandleMessage implements the nsq.Handler interface
func (HandlerMsgFunc) HandleMessage ¶
func (h HandlerMsgFunc) HandleMessage(m *nsq.Message) error
type IMCGeter ¶
type IMCGeter interface { cto.ICtrlHandler // 获取基类对象 HandleConsum() *Consum }
=> 消费管理器接口
Click to show internal directories.
Click to hide internal directories.