controller

Documentation

Index

• func NewLeaderElector(id string, logger *logger, cache *k8scache, 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) GetIngressList() ([]*networking.Ingress, error)
  • func (hc *HAProxyController) GetSecret(name string) (*api.Secret, error)
  • func (hc *HAProxyController) Info() *ingress.BackendInfo
  • func (hc *HAProxyController) IsValidClass(ing *networking.Ingress) bool
  • 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) Start()
  • func (hc *HAProxyController) Stop() error
  • func (hc *HAProxyController) UpdateIngressStatus(*networking.Ingress) []api.LoadBalancerIngress
• type LeaderSubscriber
• type ListerEvents

Functions

func NewLeaderElector

func NewLeaderElector(id string, logger *logger, cache *k8scache, 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) GetIngressList

func (hc *HAProxyController) GetIngressList() ([]*networking.Ingress, error)

GetIngressList ... implements oldcontroller.NewCtrlIntf

func (*HAProxyController) GetSecret

func (hc *HAProxyController) GetSecret(name string) (*api.Secret, error)

GetSecret ... implements oldcontroller.NewCtrlIntf

func (*HAProxyController) Info

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

Info provides controller name and repository infos

func (*HAProxyController) IsValidClass

func (hc *HAProxyController) IsValidClass(ing *networking.Ingress) bool

IsValidClass ... implements oldcontroller.NewCtrlIntf

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

func (hc *HAProxyController) Start()

Start starts the controller

func (*HAProxyController) Stop

func (hc *HAProxyController) Stop() error

Stop shutdown the controller process

func (*HAProxyController) UpdateIngressStatus

func (hc *HAProxyController) UpdateIngressStatus(*networking.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 ...

type ListerEvents

type ListerEvents interface {
	IsValidIngress(ing *networking.Ingress) bool
	IsValidIngressClass(ingClass *networking.IngressClass) bool
	IsValidGateway(gw *gateway.Gateway) bool
	IsValidGatewayClass(gwClass *gateway.GatewayClass) bool
	IsValidConfigMap(cm *api.ConfigMap) bool
	Notify(old, cur interface{})
}

ListerEvents ...