controller

Documentation

Index

• type HAProxyController
  • func NewHAProxyController() *HAProxyController
  • func (hc *HAProxyController) BackendDefaults() defaults.Backend
  • func (hc *HAProxyController) Check(_ *http.Request) error
  • func (hc *HAProxyController) ConfigureFlags(flags *pflag.FlagSet)
  • func (hc *HAProxyController) CreateX509CertsDir(bindName string, certs []string) (string, error)
  • func (hc *HAProxyController) DefaultEndpoint() ingress.Endpoint
  • func (hc *HAProxyController) DefaultIngressClass() string
  • func (hc *HAProxyController) DrainSupport() (drainSupport bool)
  • func (hc *HAProxyController) Info() *ingress.BackendInfo
  • func (hc *HAProxyController) Name() string
  • func (hc *HAProxyController) OnUpdate(cfg ingress.Configuration) error
  • func (hc *HAProxyController) OverrideFlags(flags *pflag.FlagSet)
  • func (hc *HAProxyController) SetConfig(configMap *api.ConfigMap)
  • func (hc *HAProxyController) SetListers(lister *ingress.StoreLister)
  • func (hc *HAProxyController) Start()
  • func (hc *HAProxyController) Stop() error
  • func (hc *HAProxyController) SyncIngress(item interface{}) error
  • func (hc *HAProxyController) UpdateIngressStatus(*extensions.Ingress) []api.LoadBalancerIngress

Types

type HAProxyController

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

HAProxyController has internal data of a HAProxyController instance

func NewHAProxyController

func NewHAProxyController() *HAProxyController

NewHAProxyController constructor

func (*HAProxyController) BackendDefaults

func (hc *HAProxyController) BackendDefaults() defaults.Backend

BackendDefaults defines default values to the ingress core

func (*HAProxyController) Check

func (hc *HAProxyController) Check(_ *http.Request) error

Check health check implementation

func (*HAProxyController) ConfigureFlags

func (hc *HAProxyController) ConfigureFlags(flags *pflag.FlagSet)

ConfigureFlags allow to configure more flags before the parsing of command line arguments

func (*HAProxyController) CreateX509CertsDir

func (hc *HAProxyController) CreateX509CertsDir(bindName string, certs []string) (string, error)

CreateX509CertsDir hard link files from certs to a single directory.

func (*HAProxyController) DefaultEndpoint

func (hc *HAProxyController) DefaultEndpoint() ingress.Endpoint

DefaultEndpoint returns the Endpoint to use as default when the referenced service does not exists

func (*HAProxyController) DefaultIngressClass

func (hc *HAProxyController) DefaultIngressClass() string

DefaultIngressClass returns the ingress class name

func (*HAProxyController) DrainSupport

func (hc *HAProxyController) DrainSupport() (drainSupport bool)

DrainSupport indicates whether or not this controller supports a "drain" mode where unavailable and terminating pods are included in the list of returned pods and used to direct certain traffic (e.g., traffic using persistence) to terminating/unavailable pods.

func (*HAProxyController) Info

func (hc *HAProxyController) Info() *ingress.BackendInfo

Info provides controller name and repository infos

func (*HAProxyController) Name

func (hc *HAProxyController) Name() string

Name provides the complete name of the controller

func (*HAProxyController) OnUpdate

func (hc *HAProxyController) OnUpdate(cfg ingress.Configuration) error

OnUpdate regenerate the configuration file of the backend

func (*HAProxyController) OverrideFlags

func (hc *HAProxyController) OverrideFlags(flags *pflag.FlagSet)

OverrideFlags allows controller to override command line parameter flags

func (*HAProxyController) SetConfig

func (hc *HAProxyController) SetConfig(configMap *api.ConfigMap)

SetConfig receives the ConfigMap the user has configured

func (*HAProxyController) SetListers

func (hc *HAProxyController) SetListers(lister *ingress.StoreLister)

SetListers give access to the store listers

func (*HAProxyController) Start

func (hc *HAProxyController) Start()

Start starts the controller

func (*HAProxyController) Stop

func (hc *HAProxyController) Stop() error

Stop shutdown the controller process

func (*HAProxyController) SyncIngress

func (hc *HAProxyController) SyncIngress(item interface{}) error

SyncIngress sync HAProxy config from a very early stage

func (*HAProxyController) UpdateIngressStatus

func (hc *HAProxyController) UpdateIngressStatus(*extensions.Ingress) []api.LoadBalancerIngress

UpdateIngressStatus custom callback used to update the status in an Ingress rule If the function returns nil the standard functions will be executed.