MCPcopy Create free account
hub / github.com/SeeFlowerX/stackplz / IWorker

Interface IWorker

user/event_processor/iworker.go:10–19  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

8)
9
10type IWorker interface {
11
12 // 定时器1 ,定时判断没有后续包,则解析输出
13
14 // 定时器2, 定时判断没后续包,则通知上层销毁自己
15
16 // 收包
17 Write(event.IEventStruct) error
18 GetUUID() string
19}
20
21const (
22 MAX_TICKER_COUNT = 10 // 1 Sencond/(eventWorker.ticker.C) = 10

Callers 11

perfEventReaderMethod · 0.65
handleConnectionFunction · 0.65
FormatMethod · 0.65
dispatchMethod · 0.65
IntToBytesFunction · 0.65
UIntToBytesFunction · 0.65
DumpRecordMethod · 0.65
FormatMethod · 0.65
dispatchMethod · 0.65
addWorkerByUUIDMethod · 0.65
delWorkerByUUIDMethod · 0.65

Implementers 1

eventWorkeruser/event_processor/iworker.go

Calls

no outgoing calls

Tested by

no test coverage detected