Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Process ¶
func Process(procArr []string, channelLen int, timeoutSec int, m *consistenthash.Map, messaageHandler HandlerCallBack, message <-chan []byte, distributeKeyHandler GetdistributeKeyCallBack, timeoutHandler HandlerTimeoutCallBack) error
Process 数据处理,并发处理
Types ¶
type GetdistributeKeyCallBack ¶
GetdistributeKeyCallBack 获取分发键值
type HandlerCallBack ¶
HandlerCallBack 处理回调函数
type HandlerTimeoutCallBack ¶
type HandlerTimeoutCallBack func()
HandlerTimeoutCallBack 数据处理超时回调函数,一般用于数据流监控, 监控数据是否产生出现了异常
Click to show internal directories.
Click to hide internal directories.