Versions in this module Expand all Collapse all v1 v1.8.4 Feb 5, 2018 Changes in this version + const MAX_LOADBALANCER_BACKEND + const MagicHealthCheckConnectPort + const ServiceAnnotationLoadBalancerBackendLabel + const ServiceAnnotationLoadBalancerId + const ServiceAnnotationLoadBalancerPrefix + var ROLE_NAME = "KubernetesMasterRole" + var TOKEN_RESYNC_PERIOD = 5 * time.Minute + func GetDeletedSvcKeeper() *deletedSVCKeeper type AnnotationRequest + BackendLabel string + Loadbalancerid string + type ClientMgr struct + func NewClientMgr(key, secret string) (*ClientMgr, error) + func (c *ClientMgr) Instances(region common.Region) *InstancerClient + func (c *ClientMgr) LoadBalancers(region common.Region) *LoadBalancerClient + func (c *ClientMgr) MetaData() *metadata.MetaData + func (c *ClientMgr) Routes(region common.Region) *RoutesClient type Cloud + func (c *Cloud) GetZoneByNodeName(nodeName types.NodeName) (cloudprovider.Zone, error) + func (c *Cloud) GetZoneByProviderID(providerID string) (cloudprovider.Zone, error) + func (c *Cloud) HasClusterID() bool + func (c *Cloud) InstanceExistsByProviderID(providerID string) (bool, error) + type InstancerClient struct + CurrentNodeName types.NodeName + func (s *InstancerClient) Regions() map[string][]string + func (s *InstancerClient) Update(client *ecs.Client) + type LoadBalancerClient struct + func (s *LoadBalancerClient) EnsureBackendServer(service *v1.Service, nodes []*v1.Node, lb *slb.LoadBalancerType) (*slb.LoadBalancerType, error) + func (s *LoadBalancerClient) EnsureHealthCheck(service *v1.Service, old *PortListener, new *PortListener) (*slb.LoadBalancerType, error) + func (s *LoadBalancerClient) EnsureLoadBalanceDeleted(service *v1.Service) error + func (s *LoadBalancerClient) EnsureLoadBalancer(service *v1.Service, nodes []*v1.Node, vswitchid string) (*slb.LoadBalancerType, error) + func (s *LoadBalancerClient) EnsureLoadBalancerListener(service *v1.Service, lb *slb.LoadBalancerType) (*slb.LoadBalancerType, error) + func (s *LoadBalancerClient) EnsureSVCNotDeleted(service *v1.Service) error + func (s *LoadBalancerClient) SaveDeletedSVCResourceVersion(service *v1.Service) error + func (s *LoadBalancerClient) UpdateLoadBalancer(service *v1.Service, nodes []*v1.Node) error + type RoutesClient struct + func (r *RoutesClient) CreateRoute(route *cloudprovider.Route, region common.Region, vpcid string) error + func (r *RoutesClient) DeleteRoute(route *cloudprovider.Route, region common.Region, vpcid string) error + func (r *RoutesClient) ListRoutes(region common.Region, vpcs []string) ([]*cloudprovider.Route, error) + type TokenAuth struct v1.7.2 Oct 23, 2017 Changes in this version + const DEFAULT_SERVER_WEIGHT + const ProviderName + const ServiceAnnotationLoadBalancerAddressType + const ServiceAnnotationLoadBalancerBandwidth + const ServiceAnnotationLoadBalancerCertID + const ServiceAnnotationLoadBalancerChargeType + const ServiceAnnotationLoadBalancerHealthCheckConnectPort + const ServiceAnnotationLoadBalancerHealthCheckConnectTimeout + const ServiceAnnotationLoadBalancerHealthCheckFlag + const ServiceAnnotationLoadBalancerHealthCheckHealthyThreshold + const ServiceAnnotationLoadBalancerHealthCheckInterval + const ServiceAnnotationLoadBalancerHealthCheckTimeout + const ServiceAnnotationLoadBalancerHealthCheckType + const ServiceAnnotationLoadBalancerHealthCheckURI + const ServiceAnnotationLoadBalancerHealthCheckUnhealthyThreshold + const ServiceAnnotationLoadBalancerProtocolPort + const ServiceAnnotationLoadBalancerRegion + const ServiceAnnotationLoadBalancerSLBNetworkType + var DEFAULT_ADDRESS_TYPE = slb.InternetAddressType + var DEFAULT_BANDWIDTH = 50 + var DEFAULT_CHARGE_TYPE = common.PayByTraffic + var DEFAULT_REGION = common.Hangzhou + var KUBERNETES_ALICLOUD_IDENTITY = fmt.Sprintf("Kubernetes.Alicloud/%s", version.Get().String()) + type AnnotationRequest struct + AddressType slb.AddressType + Bandwidth int + CertID string + ChargeType slb.InternetChargeType + HealthCheck slb.FlagType + HealthCheckConnectPort int + HealthCheckConnectTimeout int + HealthCheckInterval int + HealthCheckTimeout int + HealthCheckType slb.HealthCheckType + HealthCheckURI string + HealthyThreshold int + Region common.Region + SLBNetworkType string + SSLPorts string + UnhealthyThreshold int + func ExtractAnnotationRequest(service *v1.Service) *AnnotationRequest + type Cloud struct + func (c *Cloud) AddSSHKeyToAllInstances(user string, keyData []byte) error + func (c *Cloud) Clusters() (cloudprovider.Clusters, bool) + func (c *Cloud) CreateRoute(clusterName string, nameHint string, route *cloudprovider.Route) error + func (c *Cloud) CurrentNodeName(hostname string) (types.NodeName, error) + func (c *Cloud) DeleteRoute(clusterName string, route *cloudprovider.Route) error + func (c *Cloud) EnsureLoadBalancer(clusterName string, service *v1.Service, nodes []*v1.Node) (*v1.LoadBalancerStatus, error) + func (c *Cloud) EnsureLoadBalancerDeleted(clusterName string, service *v1.Service) error + func (c *Cloud) ExternalID(nodeName types.NodeName) (string, error) + func (c *Cloud) GetLoadBalancer(clusterName string, service *v1.Service) (status *v1.LoadBalancerStatus, exists bool, err error) + func (c *Cloud) GetZone() (cloudprovider.Zone, error) + func (c *Cloud) Initialize(clientBuilder controller.ControllerClientBuilder) + func (c *Cloud) InstanceID(nodeName types.NodeName) (string, error) + func (c *Cloud) InstanceType(name types.NodeName) (string, error) + func (c *Cloud) InstanceTypeByProviderID(providerID string) (string, error) + func (c *Cloud) Instances() (cloudprovider.Instances, bool) + func (c *Cloud) ListClusters() ([]string, error) + func (c *Cloud) ListRoutes(clusterName string) ([]*cloudprovider.Route, error) + func (c *Cloud) LoadBalancer() (cloudprovider.LoadBalancer, bool) + func (c *Cloud) Master(clusterName string) (string, error) + func (c *Cloud) NodeAddresses(name types.NodeName) ([]v1.NodeAddress, error) + func (c *Cloud) NodeAddressesByProviderID(providerID string) ([]v1.NodeAddress, error) + func (c *Cloud) ProviderName() string + func (c *Cloud) Routes() (cloudprovider.Routes, bool) + func (c *Cloud) ScrubDNS(nameservers, searches []string) (nsOut, srchOut []string) + func (c *Cloud) UpdateLoadBalancer(clusterName string, service *v1.Service, nodes []*v1.Node) error + func (c *Cloud) Zones() (cloudprovider.Zones, bool) + type CloudConfig struct + Global struct{ ... } + type PortListener struct + Bandwidth int + CertID string + HealthCheck slb.FlagType + HealthCheckConnectPort int + HealthCheckConnectTimeout int + HealthCheckInterval int + HealthCheckTimeout int + HealthCheckType slb.HealthCheckType + HealthCheckURI string + HealthyThreshold int + NodePort int + Port int + Protocol string + Scheduler slb.SchedulerType + StickySession slb.FlagType + UnhealthyThreshold int + type SDKClientINS struct + CurrentNodeName types.NodeName + func NewSDKClientINS(access_key_id string, access_key_secret string) *SDKClientINS + func (s *SDKClientINS) Regions() map[string][]string + type SDKClientRoutes struct + func NewSDKClientRoutes(access_key_id string, access_key_secret string) (*SDKClientRoutes, error) + func (r *SDKClientRoutes) CreateRoute(route *cloudprovider.Route, region common.Region, vpcid string) error + func (r *SDKClientRoutes) DeleteRoute(route *cloudprovider.Route, region common.Region, vpcid string) error + func (r *SDKClientRoutes) ListRoutes(region common.Region, vpcs []string) ([]*cloudprovider.Route, error) + type SDKClientSLB struct + func NewSDKClientSLB(key string, secret string) *SDKClientSLB + func (s *SDKClientSLB) EnsureBackendServer(service *v1.Service, nodes []*v1.Node, lb *slb.LoadBalancerType) (*slb.LoadBalancerType, error) + func (s *SDKClientSLB) EnsureHealthCheck(service *v1.Service, old *PortListener, new *PortListener) (*slb.LoadBalancerType, error) + func (s *SDKClientSLB) EnsureLoadBalanceDeleted(service *v1.Service) error + func (s *SDKClientSLB) EnsureLoadBalancer(service *v1.Service, nodes []*v1.Node, vswitchid string) (*slb.LoadBalancerType, error) + func (s *SDKClientSLB) EnsureLoadBalancerListener(service *v1.Service, lb *slb.LoadBalancerType) (*slb.LoadBalancerType, error) + func (s *SDKClientSLB) GetLoadBalancerByName(lbn string, service *v1.Service) (*slb.LoadBalancerType, bool, error) + func (s *SDKClientSLB) UpdateLoadBalancer(service *v1.Service, nodes []*v1.Node) error
Go to main page