ccm

package
v0.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 8, 2024 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

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

	KeyKubevipLoadBalancerIP = "kube-vip.io/loadbalancerIPs"
)
View Source
const (
	ProviderName = "harvester"
)

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

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