Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Dispatcher ¶
type Dispatcher struct { ApiService gin.Engine //提供对外操作API // contains filtered or unexported fields }
核心结构定义
func NewDispatcher ¶
func NewDispatcher() *Dispatcher
func (*Dispatcher) HandlerBindTopic ¶
func (d *Dispatcher) HandlerBindTopic(bindParams *task.HandlerBindParams) error
HandlerBindTopic:handler注入,绑定到topic
func (*Dispatcher) RegisteBrokerDriver ¶
func (d *Dispatcher) RegisteBrokerDriver(queueType string, args ...interface{}) error
注册broker
1. queueType:broker类型 2. args:broker配置
type DispatcherOptions ¶
type DispatcherOptions struct {
// contains filtered or unexported fields
}
func (*DispatcherOptions) Check ¶
func (o *DispatcherOptions) Check()
type DispatcherStat ¶
type DispatcherStat struct { PullTaskCount int64 SuccHandleCount int64 //成功处理 FailHandleCount int64 //失败处理 }
当前状态
Click to show internal directories.
Click to hide internal directories.