vcloud

Documentation

Index

• Constants
• Variables
• func IsIpInRange(testIp string, startIp string, endIp string) bool
• type Config
  • func ReadConfig(config io.Reader) (*Config, error)
• type FirewallConfig
• type IpAddress
• type IpAddressAllocation
• type LB
  • func (loadBalancer *LB) CreatePool(pool *types.LbPool) (*types.LbPool, error)
  • func (loadBalancer *LB) CreateVirtualServer(name string, ip string, protocol LbProtocol, port int, ...) (*types.LbVirtualServer, error)
  • func (loadBalancer *LB) DeleteFirewallRule(rule *types.EdgeFirewallRule) (bool, error)
  • func (loadBalancer *LB) DeleteLbServerPoolById(id string) error
  • func (loadBalancer *LB) DeleteLbVirtualServerById(id string) error
  • func (loadBalancer *LB) EnsureLoadBalancer(ctx context.Context, clusterName string, service *corev1.Service, ...) (*corev1.LoadBalancerStatus, error)
  • func (loadBalancer *LB) EnsureLoadBalancerDeleted(ctx context.Context, clusterName string, service *corev1.Service) error
  • func (loadBalancer *LB) GetFirewallRule(name string) (*types.EdgeFirewallRule, error)
  • func (loadBalancer *LB) GetLoadBalancer(ctx context.Context, clusterName string, service *corev1.Service) (status *corev1.LoadBalancerStatus, exists bool, err error)
  • func (loadBalancer *LB) GetLoadBalancerByName(name string) (*types.LbVirtualServer, error)
  • func (loadBalancer *LB) GetLoadBalancerName(ctx context.Context, clusterName string, service *corev1.Service) string
  • func (loadBalancer *LB) GetLoadBalancerPool(name string) (*types.LbPool, error)
  • func (loadBalancer *LB) GetNextAvailableIpAddressInVCloudNet(networkName string, ipnet string) (string, error)
  • func (loadBalancer *LB) UpdateLoadBalancer(ctx context.Context, clusterName string, service *corev1.Service, ...) error
  • func (loadBalancer *LB) UpdatePool(pool *types.LbPool) (*types.LbPool, error)
• type LbAlgorithm
• type LbProtocol
• type LoadBalancerOptions

Constants

const (
	HTTP  LbProtocol = "HTTP"
	HTTPS            = "HTTPS"
	TCP              = "TCP"
	UDP              = "UDP"
)

const (
	ROUND_ROBIN LbAlgorithm = "ROUND_ROBIN"
	IP_HASH                 = "IP_HASH"
	LEASTCONN               = "LEASTCONN"
	URI                     = "URI"
	HTTPHEADER              = "HTTPHEADER"
	URL                     = "URL"
)

const (
	IsWorkerNode = "node-role.kubernetes.io/worker"

	LoadBalancerType                     = "mk.plus.io/load-balancer-type"
	LoadBalancerExternalIP               = "mk.plus.io/load-balancer-external-ip"
	LoadBalancerPoolAlgorithm            = "mk.plus.io/pool-algorithm"
	LoadBalancerPoolMemberMinConnections = "mk.plus.io/pool-min-con"
	LoadBalancerPoolMemberMaxConnections = "mk.plus.io/pool-max-con"
)

const (
	VirtualServerDescription string = "This Service was automatically created and managed by vCloud-cloud-controller-manager"
	PoolDescription          string = "This Pool was automatically created and managed by vCloud-cloud-controller-manager"
)

const (
	ProviderName = "vCloud"
)

Variables

var (
	ErrNotFound = errors.New("not found")
)

var LbProtocols = []LbProtocol{
	HTTP,
	HTTPS,
	TCP,
	UDP,
}

Functions

func IsIpInRange

func IsIpInRange(testIp string, startIp string, endIp string) bool

Types

type Config

type Config struct {
	User        string `yaml:"user"`
	Password    string `yaml:"password"`
	Org         string `yaml:"org"`
	Href        string `yaml:"href"`
	VDC         string `yaml:"vdc"`
	Insecure    bool   `yaml:"insecure"`
	EdgeGateway string `yaml:"edgeGateway"`
}

func ReadConfig

func ReadConfig(config io.Reader) (*Config, error)

type FirewallConfig

type FirewallConfig struct {
	Source      types.EdgeFirewallEndpoint
	Destination types.EdgeFirewallEndpoint
	Application types.EdgeFirewallApplication
	// contains filtered or unexported fields
}

type IpAddress

type IpAddress struct {
	XMLName   xml.Name `xml:"IpAddress"`
	IpAddress string   `xml:"IpAddress"`
}

type IpAddressAllocation

type IpAddressAllocation struct {
	XMLName   xml.Name `xml:"AllocatedIpAddresses"`
	IpAddress []IpAddress
}

type LB

type LB struct {
	LoadBalancerOptions
	// contains filtered or unexported fields
}

func (*LB) CreatePool

func (loadBalancer *LB) CreatePool(pool *types.LbPool) (*types.LbPool, error)

func (*LB) CreateVirtualServer

func (loadBalancer *LB) CreateVirtualServer(name string, ip string, protocol LbProtocol, port int, applicationProfile string, poolName string) (*types.LbVirtualServer, error)

func (*LB) DeleteFirewallRule

func (loadBalancer *LB) DeleteFirewallRule(rule *types.EdgeFirewallRule) (bool, error)

func (*LB) DeleteLbServerPoolById

func (loadBalancer *LB) DeleteLbServerPoolById(id string) error

func (*LB) DeleteLbVirtualServerById

func (loadBalancer *LB) DeleteLbVirtualServerById(id string) error

func (*LB) EnsureLoadBalancer

func (loadBalancer *LB) EnsureLoadBalancer(ctx context.Context, clusterName string, service *corev1.Service, nodes []*corev1.Node) (*corev1.LoadBalancerStatus, error)

func (*LB) EnsureLoadBalancerDeleted

func (loadBalancer *LB) EnsureLoadBalancerDeleted(ctx context.Context, clusterName string, service *corev1.Service) error

func (*LB) GetFirewallRule

func (loadBalancer *LB) GetFirewallRule(name string) (*types.EdgeFirewallRule, error)

func (*LB) GetLoadBalancer

func (loadBalancer *LB) GetLoadBalancer(ctx context.Context, clusterName string, service *corev1.Service) (status *corev1.LoadBalancerStatus, exists bool, err error)

func (*LB) GetLoadBalancerByName

func (loadBalancer *LB) GetLoadBalancerByName(name string) (*types.LbVirtualServer, error)

func (*LB) GetLoadBalancerName

func (loadBalancer *LB) GetLoadBalancerName(ctx context.Context, clusterName string, service *corev1.Service) string

func (*LB) GetLoadBalancerPool

func (loadBalancer *LB) GetLoadBalancerPool(name string) (*types.LbPool, error)

func (*LB) GetNextAvailableIpAddressInVCloudNet

func (loadBalancer *LB) GetNextAvailableIpAddressInVCloudNet(networkName string, ipnet string) (string, error)

func (*LB) UpdateLoadBalancer

func (loadBalancer *LB) UpdateLoadBalancer(ctx context.Context, clusterName string, service *corev1.Service, nodes []*corev1.Node) error

func (*LB) UpdatePool

func (loadBalancer *LB) UpdatePool(pool *types.LbPool) (*types.LbPool, error)

type LbAlgorithm

type LbAlgorithm string

type LbProtocol

type LbProtocol string

type LoadBalancerOptions

type LoadBalancerOptions struct {
	LBVersion string
}