helper

package

Go to main page

Versions in this module

v0

v0.21.3

Mar 7, 2024

v0.21.2

Mar 6, 2024

v0.21.1

Mar 6, 2024

v0.21.0

Feb 29, 2024

v0.20.0

Jan 22, 2024

Changes in this version

+ const YawolletHealthCheckScript

+ func AreRelevantConditionsMet(machine *yawolv1beta1.LoadBalancerMachine, expiration metav1.Time, ...) (ok bool, reason string)

v0.19.0

Dec 5, 2023

Changes in this version

type LoadbalancerCondition

+ const DeletionMarkerCondition

v0.18.2

Oct 23, 2023

v0.18.1

Oct 17, 2023

v0.18.0

Sep 14, 2023

v0.17.2

Jul 28, 2023

v0.17.1

Jul 21, 2023

v0.17.0

Jul 20, 2023

Changes in this version

+ const DefaultLoadbalancerClass

+ func CheckLoadBalancerClasses(service *coreV1.Service, validClasses []string) bool

v0.16.1

Jun 29, 2023

Changes in this version

+ func GetNextRevisionForLoadBalancer(setList *yawolv1beta1.LoadBalancerSetList) (int, error)

+ func NewLoadBalancerSetForLoadBalancer(lb *yawolv1beta1.LoadBalancer, hash string, revision int) *yawolv1beta1.LoadBalancerSet

+ func ScaleDownOldLoadBalancerSets(ctx context.Context, c client.Client, ...) error

+ func StatusReplicasFromSetList(setList *yawolv1beta1.LoadBalancerSetList) (replicas, readyReplicas int)

v0.16.0

Jun 14, 2023

Changes in this version

+ const HasKeepalivedMaster

+ const YawolLibDir

+ const YawolSetIsLatestRevisionFile

+ func LBSetHasKeepalivedMaster(set *yawolv1beta1.LoadBalancerSet) bool

+ func ReconcileLatestRevisionFile(filesystem afero.Fs, lb *yawolv1beta1.LoadBalancer, ...) error

v0.15.1

Jun 13, 2023

v0.15.0

Jun 9, 2023

Changes in this version

+ var ErrNoLBMFoundForScaleDown = errors.New("no lbm found for scale down")

+ func GetMetrics(keepalivedStatsFile string) ([]yawolv1beta1.LoadBalancerMachineMetric, error)

v0.14.0

Mar 30, 2023

Changes in this version

+ const OpenstackReconcileTime

+ func EnableAdHocDebugging(lb *yawolv1beta1.LoadBalancer, lbm *yawolv1beta1.LoadBalancerMachine, ...) error

+ func UpdateKeepalivedPIDStatus(ctx context.Context, c client.StatusWriter, ...) error

+ func UpdateKeepalivedStatsStatus(ctx context.Context, c client.StatusWriter, keepalivedStatsFile string, ...) error

type LoadbalancerCondition

+ const KeepalivedProcess

type LoadbalancerMetric

+ const MetricUptime

v0.13.0

Mar 9, 2023

v0.12.0

Feb 2, 2023

Changes in this version

+ const FilterUDPProxy

v0.11.0

Jan 16, 2023

Changes in this version

+ var ErrPortNameEmpty = errors.New("port name is empty")

+ var ErrProjectIsImmutable = errors.New("project id is immutable, cant be changed after initial creation")

+ var ErrServerGroupIDEmpty = errors.New("server group was successfully created but server group id is empty")

v0.10.0

Nov 24, 2022

v0.9.2

Nov 16, 2022

Changes in this version

+ func GetHashForLoadBalancerMachineSet(lb *yawolv1beta1.LoadBalancer) (string, error)

v0.9.1

Nov 16, 2022

v0.9.0

Nov 14, 2022

Changes in this version

+ var ErrConditionsLastHeartbeatTimeToOld = errors.New("lastHeartbeatTime in condition to old")

+ var ErrConditionsNotInCorrectState = errors.New("condition is in wrong state")

v0.8.5

Sep 29, 2022

v0.8.4

Sep 13, 2022

v0.8.3

Sep 8, 2022

v0.8.2

Sep 7, 2022

Changes in this version

+ const DefaultRequeueTime

+ const HashLabel

+ const LoadBalancerKind

+ const RevisionAnnotation

+ const VRRPInstanceName

+ var ErrCANotFoundInSecret = errors.New("ca in secret not found")

+ var ErrConfigNotReady = errors.New("config not ready")

+ var ErrCouldNotParseSourceRange = errors.New("could not parse LoadBalancerSourceRange")

+ var ErrCouldNotReadSvcNameSpacedNameFromAnno = errors.New("could not read service namespacedname from annotation")

+ var ErrEndpointAddressWrongFormat = errors.New("endpoint address wrong address format (DNS name) not correct")

+ var ErrEndpointAddressesNil = errors.New("endpoint addresses are nil")

+ var ErrEndpointDoesNotMatchingNodeCount = errors.New("less or more than two endpoint in LB found")

+ var ErrEndpointValuesWrong = errors.New("endpoint values wrong")

+ var ErrEndpointsFound = errors.New("endpoints found")

+ var ErrEnvoyListenerNotFound = errors.New("envoy listener not found")

+ var ErrEnvoyNotReady = errors.New("envoy not ready")

+ var ErrEnvoyNotUpToDate = errors.New("envoy not upToDate")

+ var ErrFIPIDEmpty = errors.New("fip was successfully created but fip id is empty")

+ var ErrFIPNotFound = errors.New("FIP not found")

+ var ErrFailToReadRevisionFromAnnotation = errors.New("failed to read revision from annotation")

+ var ErrFailedToCreatePortForLBM = errors.New("failed to create port for lbm")

+ var ErrIPNotInStatus = errors.New("ip not in status")

+ var ErrIPSetInStatusLBNotReady = errors.New("ip is set in status but lb is not ready")

+ var ErrIncorrectEvent = errors.New("event not correct")

+ var ErrInvalidClassname = errors.New("invalid classname LB created")

+ var ErrInvalidProtocol = errors.New("invalid protocol LB created")

+ var ErrInvalidRevision = errors.New("revision number for lb must be >0")

+ var ErrLBMPortNotSet = errors.New("load balancer machine port not set")

+ var ErrLBMustNotBeNil = errors.New("LoadBalancer must no be nil")

+ var ErrLBNotCleanedUp = errors.New("load balancer didn't clean up")

+ var ErrLBOnlyOneIPFamily = errors.New("LB only has one IP family type")

+ var ErrLBOrLBMPortsAreNil = errors.New("lb or lbm ports are nil")

+ var ErrLBPortNotSet = errors.New("load balancer port not set")

+ var ErrLBUIDMustNotBeNil = errors.New("LoadBalancer.UID must not be nil")

+ var ErrListingChildLBMs = errors.New("unable to list child loadbalancerMachines")

+ var ErrMaxTriesExceeded = errors.New("max tries exceeded")

+ var ErrNoEndpointFound = errors.New("no endpoint in LB found")

+ var ErrNoEventFound = errors.New("no event found")

+ var ErrNoExistingFIP = errors.New("no existingFloatingIP set")

+ var ErrNoFixedIPForLBPort = errors.New("no fixed ip for loadbalancer port")

+ var ErrNoNetworkID = errors.New("cant get networkID for loadbalancer")

+ var ErrNoSourceRangesEvent = errors.New("no source ranges event found")

+ var ErrNodePortInvalidRange = errors.New("NodePort is not between 1 and 65535")

+ var ErrNotAValidIP = errors.New("not a valid IP address")

+ var ErrNotAllConditionsSet = errors.New("no or not all conditions are set")

+ var ErrPortIDEmpty = errors.New("port was successfully created but port id is empty")

+ var ErrPortInvalidRange = errors.New("port is not between 1 and 65535")

+ var ErrPortProtocolNotSupported = errors.New("port is not of supported protocol")

+ var ErrPortValuesWrong = errors.New("port values wrong")

+ var ErrSecGroupIDEmpty = errors.New("secGroup was successfully created but secGroup id is empty")

+ var ErrSecGroupNil = errors.New("SecGroup is nil, cannot create rules")

+ var ErrSecretNotFound = errors.New("secret not found")

+ var ErrSourceRangesAreWrong = errors.New("source ranges are wrong")

+ var ErrSourceRangesWrongLength = errors.New("source ranges update length does not match")

+ var ErrSvcEventNotFound = errors.New("event on service not found")

+ var ErrTokenNotFoundInSecret = errors.New("token in secret not found")

+ var ErrUnexpectedOpenstackStatus = errors.New("unexpected openstack status")

+ var ErrUnsupportedProtocol = errors.New("unsupported protocol used (TCP and UDP is supported)")

+ var ErrWaitingForPortsAndEndpoints = errors.New("wait for ports and endpoints")

+ var ErrYawolletIPNotFound = errors.New("listen-interface is set but no IP found")

+ var ErrYawolletRequiredFlags = errors.New(...)

+ var ErrZeroOrMoreThanOnePortFoundInLB = errors.New("zero or more than one port found in LB")

+ var ErrZeroOrMoreThanOneSRFoundInLB = errors.New("zero or more than one source range in LB found")

+ func AreAllLoadBalancerSetsForLBButDownscaled(ctx context.Context, c client.Client, lb *yawolv1beta1.LoadBalancer, ...) (bool, error)

+ func CheckEnvoyVersion(ctx context.Context, c client.StatusWriter, ...) error

+ func CreateEnvoyConfig(r record.EventRecorder, oldSnapshot *envoycache.Snapshot, ...) (bool, envoycache.Snapshot, error)

+ func CreateLoadBalancerSet(ctx context.Context, c client.Client, lb *yawolv1beta1.LoadBalancer, ...) error

+ func GenerateUserData(kubeconfig string, loadBalancerName string, loadBalancerMachineName string, ...) string

+ func GetDebugSettings(svc *coreV1.Service) yawolv1beta1.LoadBalancerDebugSettings

+ func GetDesiredSecGroupRulesForLoadBalancer(r record.EventRecorder, lb *yawolv1beta1.LoadBalancer, secGroupID string) []rules.SecGroupRule

+ func GetExistingFloatingIPFromAnnotation(svc *coreV1.Service) *string

+ func GetFlavorID(spec yawolv1beta1.OpenstackFlavorRef) (string, error)

+ func GetHashForLoadBalancerMachineSpecFromLoadBalancer(lb *yawolv1beta1.LoadBalancer) (string, error)

+ func GetIPFromStatus(svc *coreV1.Service) *string

+ func GetImageID(spec yawolv1beta1.OpenstackImageRef) (string, error)

+ func GetLoadBalancerForLoadBalancerSet(ctx context.Context, c client.Client, ...) (*yawolv1beta1.LoadBalancer, error)

+ func GetLoadBalancerNameFromService(service *coreV1.Service) string

+ func GetLoadBalancerSetForHash(ctx context.Context, c client.Client, filterLabels map[string]string, ...) (*yawolv1beta1.LoadBalancerSet, error)

+ func GetLoadBalancerSetLabelsFromLoadBalancer(lb *yawolv1beta1.LoadBalancer) map[string]string

+ func GetLoadBalancerSetsForLoadBalancer(ctx context.Context, c client.Client, lb *yawolv1beta1.LoadBalancer) (yawolv1beta1.LoadBalancerSetList, error)

+ func GetLoadBalancerSourceRanges(lb *yawolv1beta1.LoadBalancer) []string

+ func GetNextRevisionFromLB(ctx context.Context, c client.Client, lb *yawolv1beta1.LoadBalancer) (int, error)

+ func GetOpenStackReconcileHash(lb *yawolv1beta1.LoadBalancer) (string, error)

+ func GetOptions(svc *coreV1.Service) yawolv1beta1.LoadBalancerOptions

+ func GetOwnersReferenceForLB(lb *yawolv1beta1.LoadBalancer) metaV1.OwnerReference

+ func GetReplicasFromService(service *coreV1.Service) int

+ func GetRoleRules(loadBalancer *yawolv1beta1.LoadBalancer, ...) []rbac.PolicyRule

+ func HashData(data interface{}) (string, error)

+ func LoadBalancerMachineOpenstackReconcileIsNeeded(lbm *yawolv1beta1.LoadBalancerMachine) bool

+ func LoadBalancerOpenstackReconcileIsNeeded(lb *yawolv1beta1.LoadBalancer) bool

+ func LoadBalancerSetConditionIsFalse(condition v1.NodeCondition) bool

+ func LoadBalancerSetIsReady(ctx context.Context, c client.Client, lb *yawolv1beta1.LoadBalancer, ...) (bool, error)

+ func ParseLoadBalancerMachineMetrics(loadBalancerMachine *yawolv1beta1.LoadBalancerMachine, ...)

+ func ParseLoadBalancerMetrics(lb yawolv1beta1.LoadBalancer, metrics *helpermetrics.LoadBalancerMetricList)

+ func ParseLoadBalancerSetMetrics(lbs yawolv1beta1.LoadBalancerSet, ...)

+ func PatchLBMStatus(ctx context.Context, sw client.StatusWriter, ...) error

+ func PatchLBStatus(ctx context.Context, sw client.StatusWriter, lb *yawolv1beta1.LoadBalancer, ...) error

+ func PatchLoadBalancerRevision(ctx context.Context, c client.Client, lb *yawolv1beta1.LoadBalancer, ...) error

+ func PatchLoadBalancerSetReplicas(ctx context.Context, c client.Client, lbs *yawolv1beta1.LoadBalancerSet, ...) error

+ func PatchServiceStatus(ctx context.Context, sw client.StatusWriter, svc *coreV1.Service, ...) error

+ func ReadCurrentRevisionFromLB(lb *yawolv1beta1.LoadBalancer) (int, error)

+ func ReadRevisionFromLBS(lbs *yawolv1beta1.LoadBalancerSet) (int, error)

+ func RemoveFromLBMStatus(ctx context.Context, sw client.StatusWriter, ...) error

+ func RemoveFromLBStatus(ctx context.Context, sw client.StatusWriter, lb *yawolv1beta1.LoadBalancer, ...) error

+ func RemoveLoadBalancerMachineMetrics(loadBalancerMachine *yawolv1beta1.LoadBalancerMachine, ...)

+ func RemoveLoadBalancerMetrics(lb yawolv1beta1.LoadBalancer, metrics *helpermetrics.LoadBalancerMetricList)

+ func RemoveLoadBalancerSetMetrics(lbs yawolv1beta1.LoadBalancerSet, ...)

+ func ScaleDownAllLoadBalancerSetsForLBBut(ctx context.Context, c client.Client, lb *yawolv1beta1.LoadBalancer, ...) (ctrl.Result, error)

+ func UpdateEnvoyStatus(ctx context.Context, c client.StatusWriter, ...) error

+ func UpdateKeepalivedStatus(ctx context.Context, c client.StatusWriter, keepalivedStatsFile string, ...) error

+ func UpdateLBMConditions(ctx context.Context, c client.StatusWriter, ...) error

+ func ValidateService(svc *coreV1.Service) error

+ func WriteLBMMetrics(ctx context.Context, c client.StatusWriter, keepalivedStatsFile string, ...) error

+ type LoadbalancerCondition string

+ const ConfigReady

+ const EnvoyReady

+ const EnvoyUpToDate

+ const KeepalivedMaster

+ const KeepalivedStatsFile

+ type LoadbalancerConditionStatus string

+ const ConditionFalse

+ const ConditionTrue

+ type LoadbalancerMetric string

+ const MetricKeepalivedAdvertisementsReceived

+ const MetricKeepalivedAdvertisementsSent

+ const MetricKeepalivedBecameMaster

+ const MetricKeepalivedIsMaster

+ const MetricKeepalivedReleasedMaster

+ const MetricLoad1

+ const MetricLoad15

+ const MetricLoad5

+ const MetricMemAvailable

+ const MetricMemFree

+ const MetricMemTotal

+ const MetricNumCPU

+ const MetricStealTime

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL