INNER CODE UNIT · Go

func

WaveSpeedAI/waverless · cmd/initializers.go:592

func (a *k8sPodCountAdapter) GetPodCountsBySpec(ctx context.Context) (map[string]capacity.PodCounts, error) {
	k8sCounts, err := a.provider.GetPodCountsBySpec(ctx)
	if err != nil {
		return nil, err
	}

	result := make(map[string]capacity.PodCounts)
	for specName, counts := range k8sCounts {
		result[specName] = capacity.PodCounts{
			Running: counts.Running,
			Pending: counts.Pending,
		}
	}
	return result, nil
}

// capacitySpotPriceLookup adapts capacity.Manager to lifecycle.SpotPriceLookup
type capacitySpotPriceLookup struct {

View source record →