controller

Documentation

Index

• func NewLeaderElector(id string, logger *logger, cache *cache, subscriber LeaderSubscriber) types.LeaderElector
• type HAProxyController
  • func NewHAProxyController() *HAProxyController
  • func (hc *HAProxyController) AcmeCheck() (int, error)
  • func (hc *HAProxyController) Check(_ *http.Request) error
  • func (hc *HAProxyController) ConfigureFlags(flags *pflag.FlagSet)
  • func (hc *HAProxyController) DefaultIngressClass() string
  • func (hc *HAProxyController) Info() *ingress.BackendInfo
  • func (hc *HAProxyController) Name() string
  • func (hc *HAProxyController) OnNewLeader(identity string)
  • func (hc *HAProxyController) OnStartedLeading(ctx context.Context)
  • func (hc *HAProxyController) OnStoppedLeading()
  • 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
• type LeaderSubscriber

Functions

func NewLeaderElector

func NewLeaderElector(id string, logger *logger, cache *cache, subscriber LeaderSubscriber) types.LeaderElector

NewLeaderElector ...

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) AcmeCheck

func (hc *HAProxyController) AcmeCheck() (int, error)

AcmeCheck ...

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) DefaultIngressClass

func (hc *HAProxyController) DefaultIngressClass() string

DefaultIngressClass returns the ingress class name

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) OnNewLeader

func (hc *HAProxyController) OnNewLeader(identity string)

OnNewLeader ... implements LeaderSubscriber

func (*HAProxyController) OnStartedLeading

func (hc *HAProxyController) OnStartedLeading(ctx context.Context)

OnStartedLeading ... implements LeaderSubscriber

func (*HAProxyController) OnStoppedLeading

func (hc *HAProxyController) OnStoppedLeading()

OnStoppedLeading ... implements LeaderSubscriber

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.

type LeaderSubscriber

type LeaderSubscriber interface {
	OnStartedLeading(ctx context.Context)
	OnStoppedLeading()
	OnNewLeader(identity string)
}

LeaderSubscriber ...