group_coordinator_publication.go

/*
  Copyright 2026 The ARCORIS Authors

  Licensed under the Apache License, Version 2.0 (the "License");
  you may not use this file except in compliance with the License.
  You may obtain a copy of the License at

      http://www.apache.org/licenses/LICENSE-2.0

  Unless required by applicable law or agreed to in writing, software
  distributed under the License is distributed on an "AS IS" BASIS,
  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  See the License for the specific language governing permissions and
  limitations under the License.
*/

package bufferpool

// publishGroupCoordinatorBudgets publishes the evaluated partition target batch.
//
// Publication crosses only the group-to-partition ownership boundary. It does
// not run partition TickInto, enable partition schedulers, inspect Pool shards,
// or execute Pool trim. A returned error is a failed coordinator cycle; a nil
// error with Published=false returns diagnostics for the existing no-work,
// infeasible, or skipped-child path handled by selectGroupCoordinatorStatus.
func (g *PoolGroup) publishGroupCoordinatorBudgets(
	cycle *groupCoordinatorCycleEvaluation,
	skippedPartitions []PoolGroupSkippedPartition,
) (PoolGroupBudgetPublicationReport, error) {
	cycle.skippedPartitions = skippedPartitions
	publication := cycle.budgetPublication

	if len(cycle.partitionBudgetTargets) == 0 {
		return publication, nil
	}

	if !cycle.partitionBudgetAllocation.Allocation.Feasible {
		publication.FailureReason = cycle.partitionBudgetAllocation.Allocation.Reason
		return publication, nil
	}

	skippedPartitions, err := g.publishPartitionBudgetTargets(cycle.partitionBudgetTargets, skippedPartitions)
	if err != nil {
		return publication, err
	}

	cycle.skippedPartitions = skippedPartitions
	publication.SkippedPartitions = skippedPartitions
	publication.Published = len(skippedPartitions) == 0
	if !publication.Published {
		publication.FailureReason = policyUpdateFailureSkippedChild
	}

	return publication, nil
}