dispatcher

Documentation

Index

• type Dispatcher
  • func NewDispatcher() *Dispatcher
  • func (d *Dispatcher) HandlerBindTopic(bindParams *task.HandlerBindParams) error
  • func (d *Dispatcher) RegisteBrokerDriver(queueType string, args ...interface{}) error
• type DispatcherOptions
  • func (o *DispatcherOptions) Check()
• type DispatcherStat

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 //失败处理
}

当前状态