haproxy

Documentation

Index

• func BuildCustomConfig(lbConfig *config.LoadBalancerConfig, customConfig string) error
• func GetDefaultConfig() map[string]map[string]string
• type Provider
  • func (lbp *Provider) ApplyConfig(lbConfig *config.LoadBalancerConfig) error
  • func (lbp *Provider) CleanupConfig(name string) error
  • func (lbp *Provider) GetName() string
  • func (lbp *Provider) GetPublicEndpoints(configName string) []string
  • func (lbp *Provider) IsHealthy() bool
  • func (lbp *Provider) ProcessCustomConfig(lbConfig *config.LoadBalancerConfig, customConfig string) error
  • func (lbp *Provider) Run(syncEndpointsQueue *utils.TaskQueue)
  • func (lbp *Provider) StartHaproxy() error
  • func (lbp *Provider) Stop() error

Functions

func BuildCustomConfig

func BuildCustomConfig(lbConfig *config.LoadBalancerConfig, customConfig string) error

BuildCustomConfig reads custom config and updates appropriate parts of lbConfig

Custom config example:

global

maxconn 4096
maxpipes 1024

defaults

log global
mode    tcp
option  tcplog

frontend 80

balance leastconn

frontend 90

balance roundrobin

backend mystack_foo

cookie my_cookie insert indirect nocache postonly
server $IP <server parameters>

backend customUUID

server $IP <server parameters>

func GetDefaultConfig

func GetDefaultConfig() map[string]map[string]string

Types

type Provider

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

func (*Provider) ApplyConfig

func (lbp *Provider) ApplyConfig(lbConfig *config.LoadBalancerConfig) error

func (*Provider) CleanupConfig

func (lbp *Provider) CleanupConfig(name string) error

func (*Provider) GetName

func (lbp *Provider) GetName() string

func (*Provider) GetPublicEndpoints

func (lbp *Provider) GetPublicEndpoints(configName string) []string

func (*Provider) IsHealthy

func (lbp *Provider) IsHealthy() bool

func (*Provider) ProcessCustomConfig

func (lbp *Provider) ProcessCustomConfig(lbConfig *config.LoadBalancerConfig, customConfig string) error

func (*Provider) Run

func (lbp *Provider) Run(syncEndpointsQueue *utils.TaskQueue)

func (*Provider) StartHaproxy

func (lbp *Provider) StartHaproxy() error

func (*Provider) Stop

func (lbp *Provider) Stop() error