94
return PartitionScalerDecision{NoChange: true}
95
}
97
>
98
>
// update backlog target based on counts
99
>
backlogTarget := updateBacklogTarget(cfg, in.BacklogCounts, (*bitSet)(&state.BacklogTarget))
100
>
101
>
// add them and clamp
102
>
totalTarget := addTarget + backlogTarget
103
>
if cfg.Min > 0 {
104
totalTarget = max(totalTarget, int(cfg.Min))
105
}
107
totalTarget = min(totalTarget, int(cfg.Max))
108
}
109
111
>
return PartitionScalerDecision{
112
>
NewTarget: totalTarget,
113
>
BacklogCap: int(cfg.BacklogCap),
114
>
PrivateState: privateState,
115
>
}
116
}
117