Method getAssignedPartitions

modules/blockbuilder/blockbuilder.go:648–665

Gets assigned partitions, these can be active or inactive. Pending partitions won't be included

()

// Gets assigned partitions, these can be active or inactive. Pending partitions won't be included
func (b *BlockBuilder) getAssignedPartitions() []int32 {
	partitions := b.partitionRing.PartitionRing().Partitions()
	ringAssignedPartitions := make(map[int32]string, len(partitions))
	for _, p := range partitions {
		if p.IsActive() || p.IsInactive() {
			ringAssignedPartitions[p.Id] = p.GetState().String()
		}
	}

	assignedActivePartitions := make([]int32, 0, len(b.cfg.AssignedPartitions()))
	for _, partition := range b.cfg.AssignedPartitions() {
		if s, ok := ringAssignedPartitions[partition]; ok {
			metricOwnedPartitions.WithLabelValues(strconv.Itoa(int(partition)), s).Set(1)
			assignedActivePartitions = append(assignedActivePartitions, partition)
		}
	}
	return assignedActivePartitions
}