100
onRateLimited func(),
101
markAlive func(),
103
>
tm := &priTaskMatcher{
104
>
config: config,
105
>
data: newMatcherData(config, logger, clock.NewRealTimeSource(), fwdr != nil, rateLimitManager, onRateLimited),
106
>
tqCtx: tqCtx,
107
>
logger: logger,
108
>
metricsHandler: metricsHandler,
109
>
partition: partition,
110
>
fwdr: fwdr,
111
>
client: client,
112
>
validator: validator,
113
>
rateLimitManager: rateLimitManager,
114
>
markAlive: markAlive,
115
>
priorityBacklogForwarders: goro.NewKeyedSet[remotePriorityBacklog](tqCtx),
116
>
}
117
>
118
>
return tm
119
>
}
120
121
func (tm *priTaskMatcher) Start() {