hosts.go

package main

import (
	"fmt"
	"strings"

	"github.com/go-logr/logr"

	"github.com/kedacore/http-add-on/pkg/routing"
	externalscaler "github.com/kedacore/http-add-on/proto"
)

// getHostCount gets proper count for given host regardless whether
// host is in counts or only in routerTable
func getHostCount(
	host string,
	counts map[string]int,
	table routing.TableReader,
) (int, bool) {
	count, exists := counts[host]
	if exists {
		return count, exists
	}

	exists = table.HasHost(host)
	return 0, exists
}

// gets hosts from scaledobjectref
func getHostsFromScaledObjectRef(lggr logr.Logger, sor *externalscaler.ScaledObjectRef) ([]string, error) {
	serializedHosts, ok := sor.ScalerMetadata["hosts"]
	if !ok {
		err := fmt.Errorf("no 'hosts' field in the scaler metadata field")
		lggr.Error(err, "'hosts' not found in the scaler metadata field")
		return make([]string, 0), err
	}
	return strings.Split(serializedHosts, ","), nil
}