Function newZoneAwareResultTracker

pkg/ring/replication_set_tracker.go:103–121

(instances []InstanceDesc, maxUnavailableZones int, zoneResultsQuorum bool)

}

func newZoneAwareResultTracker(instances []InstanceDesc, maxUnavailableZones int, zoneResultsQuorum bool) *zoneAwareResultTracker {
	t := &zoneAwareResultTracker{
		waitingByZone:       make(map[string]int),
		failuresByZone:      make(map[string]int),
		maxUnavailableZones: maxUnavailableZones,
		numInstances:        len(instances),
		zoneResultsQuorum:   zoneResultsQuorum,
		errors:              make([]error, 0, len(instances)),
	}

	for _, instance := range instances {
		t.waitingByZone[instance.Zone]++
	}
	t.minSuccessfulZones = len(t.waitingByZone) - maxUnavailableZones
	t.resultsPerZone = make(map[string][]any, len(t.waitingByZone))
	t.zoneCount = len(t.waitingByZone)

	return t
}

func (t *zoneAwareResultTracker) done(instance *InstanceDesc, result any, err error) {
	if err != nil {