198
}
199
200
>
func (c *backlogManagerImpl) BacklogStatsByPriority() map[int32]*taskqueuepb.TaskQueueStats {
backlog_manager.go
201
>
defaultPriority := int32(c.config.DefaultPriorityKey)
202
>
return map[int32]*taskqueuepb.TaskQueueStats{
203
>
defaultPriority: &taskqueuepb.TaskQueueStats{
204
>
ApproximateBacklogCount: c.db.getTotalApproximateBacklogCount(),
205
>
ApproximateBacklogAge: durationpb.New(c.taskReader.getBacklogHeadAge()),
206
>
},
207
>
}
208
>
}
209
210
func (c *backlogManagerImpl) InternalStatus() []*taskqueuespb.InternalTaskQueueStatus {