ccm

Documentation

Index

• Constants
• Variables
• type CloudProvider
  • func (c *CloudProvider) Clusters() (cloudprovider.Clusters, bool)
  • func (c *CloudProvider) HasClusterID() bool
  • func (c *CloudProvider) Initialize(clientBuilder cloudprovider.ControllerClientBuilder, stop <-chan struct{})
  • func (c *CloudProvider) Instances() (cloudprovider.Instances, bool)
  • func (c *CloudProvider) InstancesV2() (cloudprovider.InstancesV2, bool)
  • func (c *CloudProvider) LoadBalancer() (cloudprovider.LoadBalancer, bool)
  • func (c *CloudProvider) ProviderName() string
  • func (c *CloudProvider) Routes() (cloudprovider.Routes, bool)
  • func (c *CloudProvider) Zones() (cloudprovider.Zones, bool)
• type LoadBalancerManager
  • func (l *LoadBalancerManager) EnsureLoadBalancer(ctx context.Context, clusterName string, service *v1.Service, nodes []*v1.Node) (*v1.LoadBalancerStatus, error)
  • func (l *LoadBalancerManager) EnsureLoadBalancerDeleted(ctx context.Context, clusterName string, service *v1.Service) error
  • func (l *LoadBalancerManager) GetLoadBalancer(ctx context.Context, clusterName string, service *v1.Service) (status *v1.LoadBalancerStatus, exists bool, err error)
  • func (l *LoadBalancerManager) GetLoadBalancerName(ctx context.Context, clusterName string, service *v1.Service) string
  • func (l *LoadBalancerManager) UpdateLoadBalancer(ctx context.Context, clusterName string, service *v1.Service, nodes []*v1.Node) error

Constants

const (
	KeyIPAM           = prefix + "ipam"
	KeyNetwork        = prefix + "network"
	KeyProject        = prefix + "project"
	KeyNamespace      = prefix + "namespace"
	KeyPrimaryService = prefix + "primary-service"

	KeyKubevipLoadBalancerIP = "kube-vip.io/loadbalancerIPs"
)

const (
	ProviderName = "harvester"
)

Variables

var DisableVMIController bool

Types

type CloudProvider

type CloudProvider struct {
	Context context.Context
	// contains filtered or unexported fields
}

func (*CloudProvider) Clusters

func (c *CloudProvider) Clusters() (cloudprovider.Clusters, bool)

func (*CloudProvider) HasClusterID

func (c *CloudProvider) HasClusterID() bool

func (*CloudProvider) Initialize

func (c *CloudProvider) Initialize(clientBuilder cloudprovider.ControllerClientBuilder, stop <-chan struct{})

func (*CloudProvider) Instances

func (c *CloudProvider) Instances() (cloudprovider.Instances, bool)

func (*CloudProvider) InstancesV2

func (c *CloudProvider) InstancesV2() (cloudprovider.InstancesV2, bool)

func (*CloudProvider) LoadBalancer

func (c *CloudProvider) LoadBalancer() (cloudprovider.LoadBalancer, bool)

func (*CloudProvider) ProviderName

func (c *CloudProvider) ProviderName() string

func (*CloudProvider) Routes

func (c *CloudProvider) Routes() (cloudprovider.Routes, bool)

func (*CloudProvider) Zones

func (c *CloudProvider) Zones() (cloudprovider.Zones, bool)

type LoadBalancerManager

type LoadBalancerManager struct {
	// contains filtered or unexported fields
}

func (*LoadBalancerManager) EnsureLoadBalancer

func (l *LoadBalancerManager) EnsureLoadBalancer(ctx context.Context, clusterName string, service *v1.Service, nodes []*v1.Node) (*v1.LoadBalancerStatus, error)

EnsureLoadBalancer is to create/update a Harvester load balancer for the service

func (*LoadBalancerManager) EnsureLoadBalancerDeleted

func (l *LoadBalancerManager) EnsureLoadBalancerDeleted(ctx context.Context, clusterName string, service *v1.Service) error

func (*LoadBalancerManager) GetLoadBalancer

func (l *LoadBalancerManager) GetLoadBalancer(ctx context.Context, clusterName string, service *v1.Service) (status *v1.LoadBalancerStatus, exists bool, err error)

func (*LoadBalancerManager) GetLoadBalancerName

func (l *LoadBalancerManager) GetLoadBalancerName(ctx context.Context, clusterName string, service *v1.Service) string

func (*LoadBalancerManager) UpdateLoadBalancer

func (l *LoadBalancerManager) UpdateLoadBalancer(ctx context.Context, clusterName string, service *v1.Service, nodes []*v1.Node) error