Documentation ¶
Index ¶
- type Cluster
- func (cluster *Cluster) StartCluster(c *kubevip.Config, sm *Manager, bgpServer *bgp.Server) error
- func (cluster *Cluster) StartDDNS(ctx context.Context) error
- func (cluster *Cluster) StartLoadBalancerService(c *kubevip.Config, bgp *bgp.Server)
- func (cluster *Cluster) StartSingleNode(c *kubevip.Config, disableVIP bool) error
- func (cluster *Cluster) StartVipService(c *kubevip.Config, sm *Manager, bgp *bgp.Server, packetClient *packngo.Client) error
- func (cluster *Cluster) Stop()
- type Manager
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Cluster ¶
Cluster - The Cluster object manages the state of the cluster for a particular node
func InitCluster ¶
InitCluster - Will attempt to initialise all of the required settings for the cluster
func (*Cluster) StartCluster ¶ added in v0.4.0
StartCluster - Begins a running instance of the Leader Election cluster
func (*Cluster) StartDDNS ¶
StartDDNS should start go routine for dhclient to hold the lease for the IP StartDDNS should wait until IP is allocated from DHCP, set it to cluster.Network so the OnStartedLeading can continue to configure the VIP initially during runtime if IP changes, startDDNS don't have to do reconfigure because dnsUpdater already have the functionality to keep trying resolve the IP and update the VIP configuration if it changes
func (*Cluster) StartLoadBalancerService ¶
StartLoadBalancerService will start a VIP instance and leave it for kube-proxy to handle
func (*Cluster) StartSingleNode ¶
StartSingleNode will start a single node cluster
func (*Cluster) StartVipService ¶ added in v0.4.0
type Manager ¶
type Manager struct { KubernetesClient *kubernetes.Clientset // This channel is used to signal a shutdown SignalChan chan os.Signal EtcdClient *clientv3.Client }
Manager degines the manager of the load-balancing services
func NewManager ¶
NewManager will create a new managing object
func (*Manager) NodeWatcher ¶ added in v0.4.0
func (sm *Manager) NodeWatcher(lb *loadbalancer.IPVSLoadBalancer, port int) error