clusters

package

v0.9.16 Latest Latest Go to latest Published: Nov 26, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Details

View Source

const (

	// PingRetryCount is the number of times the ping will be retried
	// to determine if the node is healthy of not.
	PingRetryCount = 5
)

View Source

var ErrEchoTimeout = errors.New("icmp request timeout")

ErrEchoTimeout is returned when the reply is not received within the requested timeout.

func DetermineLBApiEndpointChange(currentLbs, desiredLbs []*spec.LBcluster) (string, string, spec.ApiEndpointChangeState)

func FindAssignedLbApiEndpoint(clusters []*spec.LBcluster) *spec.LBcluster

func IndexLoadbalancerById(target string, clusters []*spec.LBcluster) int

func NodePublic(name string, cluster *spec.K8Scluster) string

func Ping(logger zerolog.Logger, count int, dst string) error

Ping pings a single IPv4 address with the requested amount of retries. An error is returned when more then count/2 packets are lost.

func PingNodes(logger zerolog.Logger, state *spec.Clusters) (map[string][]string, map[string]map[string][]string, error)

PingNodes pings nodes of the cluster, including loadbalancer nodes, using the public IPv4 Address of the nodes.

This section is empty.