util

package

Go to main page

Versions in this module

v1

v1.4.0-beta.7

May 5, 2022

v1.4.0-beta.6

May 5, 2022

v1.4.0-beta.5

Oct 12, 2021

v1.4.0-beta.4

Mar 12, 2021

v1.4.0-beta.3

Feb 3, 2021

v1.3.0

Sep 10, 2020

Changes in this version

+ func DeregByWebhook(bg *lbcfapi.BackendGroup) bool

+ func DeregIfNotRunning(bg *lbcfapi.BackendGroup) bool

+ func IsLoadBalancerAllowedForBackendGroup(lb *lbcfapi.LoadBalancer, bgNamespace string) bool

+ func NamespaceOfSharedObj(name string, defaultNamespace string) string

+ func PodAvailableByRunning(obj *v1.Pod) bool

type WebhookInvoker

+ CallJudgePodDeregister func(driver *lbcfapi.LoadBalancerDriver, req *webhooks.JudgePodDeregisterRequest) (*webhooks.JudgePodDeregisterResponse, error)

type WebhookInvokerImpl

+ func (w *WebhookInvokerImpl) CallJudgePodDeregister(driver *lbcfapi.LoadBalancerDriver, req *webhooks.JudgePodDeregisterRequest) (*webhooks.JudgePodDeregisterResponse, error)

v1.3.0-alpha

Jun 2, 2020

v1.2.1

Oct 10, 2020

v1.2.0

May 20, 2020

Changes in this version

type ConditionalRateLimitingInterface

+ GetName func() string

v1.2.0-rc.2

Apr 28, 2020

v1.2.0-rc.1

Apr 26, 2020

v1.1.2

Apr 26, 2020

Changes in this version

+ func GetPodCondition(status *v1.PodStatus, conditionType v1.PodConditionType) (int, *v1.PodCondition)

+ func GetPodConditionFromList(conditions []v1.PodCondition, conditionType v1.PodConditionType) (int, *v1.PodCondition)

+ func GetPodReadyCondition(status v1.PodStatus) *v1.PodCondition

+ func IsPodReady(pod *v1.Pod) bool

+ func IsPodReadyConditionTrue(status v1.PodStatus) bool

v1.1.0

Apr 7, 2020

v1.0.0-rc.2

Nov 28, 2019

v1.0.0-rc.1

Nov 27, 2019

v0

v0.2.2

Nov 26, 2019

Changes in this version

+ const DefaultEnsurePeriod

+ const DefaultRetryInterval

+ func AddBackendCondition(beStatus *lbcfapi.BackendRecordStatus, ...)

+ func AddLBCondition(lbStatus *lbcfapi.LoadBalancerStatus, ...)

+ func BackendRegistered(backend *lbcfapi.BackendRecord) bool

+ func CalculateRetryInterval(userValueInSeconds int32) time.Duration

+ func CompareBackendRecords(expect []*lbcfapi.BackendRecord, have []*lbcfapi.BackendRecord) (needCreate, needUpdate, needDelete []*lbcfapi.BackendRecord)

+ func ConstructPodBackendRecord(lb *lbcfapi.LoadBalancer, group *lbcfapi.BackendGroup, pod *v1.Pod) *lbcfapi.BackendRecord

+ func ConstructServiceBackendRecord(lb *lbcfapi.LoadBalancer, group *lbcfapi.BackendGroup, svc *v1.Service, ...) *lbcfapi.BackendRecord

+ func ConstructStaticBackend(lb *lbcfapi.LoadBalancer, group *lbcfapi.BackendGroup, staticAddr string) *lbcfapi.BackendRecord

+ func DetermineNeededBackendGroupUpdates(oldGroups, groups sets.String, podStatusChanged bool) sets.String

+ func FilterBackendGroup(all []*lbcfapi.BackendGroup, filter func(*lbcfapi.BackendGroup) bool) []*lbcfapi.BackendGroup

+ func FilterPods(all []*v1.Pod, filter func(pod *v1.Pod) bool) []*v1.Pod

+ func GetBackendRecordCondition(status *lbcfapi.BackendRecordStatus, ...) *lbcfapi.BackendRecordCondition

+ func GetDriverNamespace(driverName string, defaultNamespace string) string

+ func GetDuration(cfg *lbcfapi.Duration, defaultValue time.Duration) time.Duration

+ func GetLBCondition(status *lbcfapi.LoadBalancerStatus, ...) *lbcfapi.LoadBalancerCondition

+ func HasFinalizer(all []string, expect string) bool

+ func IsDriverDraining(driver *lbcfapi.LoadBalancerDriver) bool

+ func IsLBMatchBackendGroup(group *lbcfapi.BackendGroup, lb *lbcfapi.LoadBalancer) bool

+ func IsPodMatchBackendGroup(group *lbcfapi.BackendGroup, pod *v1.Pod) bool

+ func IsSvcMatchBackendGroup(group *lbcfapi.BackendGroup, svc *v1.Service) bool

+ func IterateBackends(all []*lbcfapi.BackendRecord, handler func(*lbcfapi.BackendRecord) error) error

+ func LBCreated(lb *lbcfapi.LoadBalancer) bool

+ func LBEnsured(lb *lbcfapi.LoadBalancer) bool

+ func MakeBackendLabels(driverName, lbName, groupName, svcName, podName string) map[string]string

+ func MakePodBackendName(lbName, groupName string, podUID types.UID, port lbcfapi.PortSelector) string

+ func MakeServiceBackendName(lbName, groupName, svcName string, nodePort int32, nodePortProtocol string, ...) string

+ func MakeStaticBackendName(lbName, groupName, staticAddr string) string

+ func NamespacedNameKeyFunc(namespace, name string) string

+ func NeedEnqueueBackend(old *lbcfapi.BackendRecord, cur *lbcfapi.BackendRecord) bool

+ func NeedEnqueueLB(old *lbcfapi.LoadBalancer, cur *lbcfapi.LoadBalancer) bool

+ func NeedPeriodicEnsure(cfg *lbcfapi.EnsurePolicyConfig, deleting bool) bool

+ func PodAvailable(obj *v1.Pod) bool

+ func RemoveFinalizer(all []string, toDelete string) []string

+ type BackendType string

+ const TypePod

+ const TypeService

+ const TypeStatic

+ const TypeUnknown

+ func GetBackendType(bg *lbcfapi.BackendGroup) BackendType

+ type ConditionalRateLimitingInterface interface

+ AddAfterFiltered func(item interface{}, duration time.Duration)

+ AddAfterMinimumDelay func(item interface{}, duration time.Duration)

+ Forget func(item interface{})

+ LenWaitingForFilter func() int

+ func NewConditionalDelayingQueue(filter QueueFilter, minDelay time.Duration, step time.Duration, ...) ConditionalRateLimitingInterface

+ type ErrorList []error

+ func (e ErrorList) Error() string

+ type QueueFilter func(item interface{}) (bool, error)

+ func QueueFilterForBackend(backendLister v1beta1.BackendRecordLister) QueueFilter

+ func QueueFilterForLB(lbLister v1beta1.LoadBalancerLister) QueueFilter

+ type SyncResult struct

+ func AsyncResult(period time.Duration) *SyncResult

+ func ErrorResult(err error) *SyncResult

+ func FailResult(delay time.Duration, msg string) *SyncResult

+ func FinishedResult() *SyncResult

+ func PeriodicResult(period time.Duration) *SyncResult

+ func (s *SyncResult) GetFailReason() string

+ func (s *SyncResult) GetNextRun() time.Duration

+ func (s *SyncResult) IsFailed() bool

+ func (s *SyncResult) IsFinished() bool

+ func (s *SyncResult) IsPeriodic() bool

+ func (s *SyncResult) IsRunning() bool

+ type WebhookInvoker interface

+ CallCreateLoadBalancer func(driver *lbcfapi.LoadBalancerDriver, req *webhooks.CreateLoadBalancerRequest) (*webhooks.CreateLoadBalancerResponse, error)

+ CallDeleteLoadBalancer func(driver *lbcfapi.LoadBalancerDriver, req *webhooks.DeleteLoadBalancerRequest) (*webhooks.DeleteLoadBalancerResponse, error)

+ CallDeregisterBackend func(driver *lbcfapi.LoadBalancerDriver, req *webhooks.BackendOperationRequest) (*webhooks.BackendOperationResponse, error)

+ CallEnsureBackend func(driver *lbcfapi.LoadBalancerDriver, req *webhooks.BackendOperationRequest) (*webhooks.BackendOperationResponse, error)

+ CallEnsureLoadBalancer func(driver *lbcfapi.LoadBalancerDriver, req *webhooks.EnsureLoadBalancerRequest) (*webhooks.EnsureLoadBalancerResponse, error)

+ CallGenerateBackendAddr func(driver *lbcfapi.LoadBalancerDriver, req *webhooks.GenerateBackendAddrRequest) (*webhooks.GenerateBackendAddrResponse, error)

+ CallValidateBackend func(driver *lbcfapi.LoadBalancerDriver, req *webhooks.ValidateBackendRequest) (*webhooks.ValidateBackendResponse, error)

+ CallValidateLoadBalancer func(driver *lbcfapi.LoadBalancerDriver, req *webhooks.ValidateLoadBalancerRequest) (*webhooks.ValidateLoadBalancerResponse, error)

+ func NewWebhookInvoker() WebhookInvoker

+ type WebhookInvokerImpl struct

+ func (w *WebhookInvokerImpl) CallCreateLoadBalancer(driver *lbcfapi.LoadBalancerDriver, req *webhooks.CreateLoadBalancerRequest) (*webhooks.CreateLoadBalancerResponse, error)

+ func (w *WebhookInvokerImpl) CallDeleteLoadBalancer(driver *lbcfapi.LoadBalancerDriver, req *webhooks.DeleteLoadBalancerRequest) (*webhooks.DeleteLoadBalancerResponse, error)

+ func (w *WebhookInvokerImpl) CallDeregisterBackend(driver *lbcfapi.LoadBalancerDriver, req *webhooks.BackendOperationRequest) (*webhooks.BackendOperationResponse, error)

+ func (w *WebhookInvokerImpl) CallEnsureBackend(driver *lbcfapi.LoadBalancerDriver, req *webhooks.BackendOperationRequest) (*webhooks.BackendOperationResponse, error)

+ func (w *WebhookInvokerImpl) CallEnsureLoadBalancer(driver *lbcfapi.LoadBalancerDriver, req *webhooks.EnsureLoadBalancerRequest) (*webhooks.EnsureLoadBalancerResponse, error)

+ func (w *WebhookInvokerImpl) CallGenerateBackendAddr(driver *lbcfapi.LoadBalancerDriver, req *webhooks.GenerateBackendAddrRequest) (*webhooks.GenerateBackendAddrResponse, error)

+ func (w *WebhookInvokerImpl) CallValidateBackend(driver *lbcfapi.LoadBalancerDriver, req *webhooks.ValidateBackendRequest) (*webhooks.ValidateBackendResponse, error)

+ func (w *WebhookInvokerImpl) CallValidateLoadBalancer(driver *lbcfapi.LoadBalancerDriver, req *webhooks.ValidateLoadBalancerRequest) (*webhooks.ValidateLoadBalancerResponse, error)

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