Versions in this module Expand all Collapse all v0 v0.1.0 Mar 5, 2024 Changes in this version + const ACTIVE_LOADBALANCER_STATUS + const CreateEvent + const DEFAULT_PORTAL_NAME_LENGTH + const DeleteEvent + const DeprecatedLabelNodeRoleMaster + const IngressClass + const IngressKey + const IngressSecretCertName + const IngressSecretKeyName + const LabelNodeExcludeLB + const ServiceAnnotationLoadBalancerID + const ServiceAnnotationPackageID + const UpdateEvent + func CheckIfPoolMemberExist(mems []*pool.Member, mem *pool.Member) bool + func CheckIfPoolMemberExist2(mems []*lObjects.Member, mem *pool.Member) bool + func ComparePoolMembers(p1, p2 []*pool.Member) bool + func ConvertObjectToPoolMember(obj *lObjects.Member) *pool.Member + func ConvertObjectToPoolMemberArray(obj []*lObjects.Member) []*pool.Member + func DecodeFromValidName(str string) string + func EncodeToValidName(str string) string + func GetCertificateName(clusterID, namespace, name string) string + func GetPolicyName(prefix string, mode bool, ruleIndex, pathIndex int) string + func GetPoolName(prefix, serviceName string, port int) string + func GetResourceHashName(ing *nwv1.Ingress, clusterID string) string + func GetResourceName(ing *nwv1.Ingress, clusterID string) string + func HashString(str string) string + func IsLoadBalancerNotReady(err error) bool + func IsValid(ing *nwv1.Ingress) bool + func MapIDExpander(old, cur *IngressInspect) + func MinInt(a, b int) int + func NodeNames(nodes []*apiv1.Node) []string + func NodeSlicesEqual(x, y []*apiv1.Node) bool + func Sleep(t int) + func TrimString(str string, length int) string + type API struct + ProjectID string + VLBSC *client.ServiceClient + VServerSC *client.ServiceClient + func (c *API) CreateLB(name, packageId, subnetID string, scheme loadbalancer.CreateOptsSchemeOpt, ...) (*lObjects.LoadBalancer, error) + func (c *API) CreateListener(lbID string, opt *listener.CreateOpts) (*lObjects.Listener, error) + func (c *API) CreatePolicy(lbID, listenerID string, opt *policy.CreateOptsBuilder) (*lObjects.Policy, error) + func (c *API) CreatePool(lbID string, opt *pool.CreateOpts) (*lObjects.Pool, error) + func (c *API) DeleteCertificate(certificateID string) error + func (c *API) DeleteLB(lbID string) error + func (c *API) DeleteListener(lbID, listenerID string) error + func (c *API) DeletePolicy(lbID, listenerID, policyID string) error + func (c *API) DeletePool(lbID, poolID string) error + func (c *API) FindListenerByName(lbID, name string) (*lObjects.Listener, error) + func (c *API) FindListenerByPort(lbID string, port int) (*lObjects.Listener, error) + func (c *API) FindPolicyByName(lbID, listenerID, name string) (*lObjects.Policy, error) + func (c *API) FindPoolByName(lbID, name string) (*lObjects.Pool, error) + func (c *API) GetCertificate(certificateID string) (*lObjects.Certificate, error) + func (c *API) GetClusterInfo(clusterID string) (*lObjects.Cluster, error) + func (c *API) GetLB(lbID string) (*lObjects.LoadBalancer, error) + func (c *API) GetMemberPool(lbID, poolID string) ([]*lObjects.Member, error) + func (c *API) GetPolicy(lbID, listenerID, policyID string) (*lObjects.Policy, error) + func (c *API) GetPool(lbID, poolID string) (*lObjects.Pool, error) + func (c *API) ImportCertificate(opt *certificates.ImportOpts) (*lObjects.Certificate, error) + func (c *API) ListCertificate() ([]*lObjects.Certificate, error) + func (c *API) ListLBBySubnetID(subnetID string) ([]*lObjects.LoadBalancer, error) + func (c *API) ListListenerOfLB(lbID string) ([]*lObjects.Listener, error) + func (c *API) ListPolicyOfListener(lbID, listenerID string) ([]*lObjects.Policy, error) + func (c *API) ListPoolOfLB(lbID string) ([]*lObjects.Pool, error) + func (c *API) UpdateListener(lbID, listenerID string, opt *listener.UpdateOpts) error + func (c *API) UpdatePolicy(lbID, listenerID, policyID string, opt *policy.UpdateOptsBuilder) error + func (c *API) UpdatePoolMember(lbID, poolID string, mems []*pool.Member) error + func (c *API) WaitForLBActive(lbID string) *lObjects.LoadBalancer + type CertificateExpander struct + Name string + SecretName string + UUID string + Version string + type Config struct + Global client.AuthOpts + Metadata metadata.Opts + VLB VLBOpts + type Controller struct + SecretTrackers *SecretTracker + func NewController(conf config.Config) *Controller + func (c *Controller) DeleteLoadbalancer(ing *nwv1.Ingress) error + func (c *Controller) GetLoadbalancerIDByIngress(ing *nwv1.Ingress) (string, error) + func (c *Controller) Init() error + func (c *Controller) Start() + type ErrorRespone struct + ErrorCode string + Message string + StatusCode int + func ParseError(errStr string) *ErrorRespone + type Event struct + Obj interface{} + Type EventType + type EventType string + type ExtraInfo struct + ProjectID string + UserID int64 + type IngressInspect struct + CertificateExpander []*CertificateExpander + ListenerExpander []*ListenerExpander + PolicyExpander []*PolicyExpander + PoolExpander []*PoolExpander + func (ing *IngressInspect) Print() + type ListenerExpander struct + UUID string + type NodeConditionPredicate func(node *apiv1.Node) bool + type PolicyExpander struct + Action policy.PolicyOptsActionOpt + L7Rules []policy.Rule + Name string + RedirectPoolID string + RedirectPoolName string + UUID string + type PoolExpander struct + Members []*pool.Member + Name string + UUID string + type SecretTracker struct + SecretTrackers []*secret + func NewSecretTracker() *SecretTracker + func (c *SecretTracker) AddSecretTracker(namespace, name, uuid, version string) + func (c *SecretTracker) CheckSecretTrackerChange(kubeClient kubernetes.Interface) bool + func (c *SecretTracker) ClearSecretTracker() + func (c *SecretTracker) RemoveSecretTracker(namespace, name string) + type VLBOpts struct + EnableVMonitor bool + Enabled bool + FlavorID string + InternalLB bool + LBMethod string + MaxSharedLB int
Go to main page