controller

Documentation

Index

• type Builder
  • func NewBuilder() *Builder
  • func (builder *Builder) Build() *HAProxyController
  • func (builder *Builder) WithAnnotations(a annotations.Annotations) *Builder
  • func (builder *Builder) WithArgs(osArgs utils.OSArgs) *Builder
  • func (builder *Builder) WithClientSet(clientSet *kubernetes.Clientset) *Builder
  • func (builder *Builder) WithEventChan(eventChan chan k8s.SyncDataEvent) *Builder
  • func (builder *Builder) WithHAProxyProcess(process process.Process) *Builder
  • func (builder *Builder) WithHAProxyRules(rules rules.Rules) *Builder
  • func (builder *Builder) WithHaproxyCfgFile(cfgFile []byte) *Builder
  • func (builder *Builder) WithHaproxyClient(haproxyClient api.HAProxyClient) *Builder
  • func (builder *Builder) WithHaproxyEnv(env env.Env) *Builder
  • func (builder *Builder) WithIngressChan(ingressChan chan ingress.Sync) *Builder
  • func (builder *Builder) WithPublishService(publishService *utils.NamespaceValue) *Builder
  • func (builder *Builder) WithStore(store store.K8s) *Builder
  • func (builder *Builder) WithUpdatePublishServiceFunc(...) *Builder
• type HAProxyController
  • func (c *HAProxyController) Start()
  • func (c *HAProxyController) Stop()
  • func (c *HAProxyController) SyncData()
• type UpdateHandler

Types

type Builder

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

func NewBuilder

func NewBuilder() *Builder

func (*Builder) Build

func (builder *Builder) Build() *HAProxyController

func (*Builder) WithAnnotations

func (builder *Builder) WithAnnotations(a annotations.Annotations) *Builder

func (*Builder) WithArgs

func (builder *Builder) WithArgs(osArgs utils.OSArgs) *Builder

func (*Builder) WithClientSet

func (builder *Builder) WithClientSet(clientSet *kubernetes.Clientset) *Builder

func (*Builder) WithEventChan

func (builder *Builder) WithEventChan(eventChan chan k8s.SyncDataEvent) *Builder

func (*Builder) WithHAProxyProcess

func (builder *Builder) WithHAProxyProcess(process process.Process) *Builder

func (*Builder) WithHAProxyRules

func (builder *Builder) WithHAProxyRules(rules rules.Rules) *Builder

func (*Builder) WithHaproxyCfgFile

func (builder *Builder) WithHaproxyCfgFile(cfgFile []byte) *Builder

func (*Builder) WithHaproxyClient

func (builder *Builder) WithHaproxyClient(haproxyClient api.HAProxyClient) *Builder

func (*Builder) WithHaproxyEnv

func (builder *Builder) WithHaproxyEnv(env env.Env) *Builder

func (*Builder) WithIngressChan

func (builder *Builder) WithIngressChan(ingressChan chan ingress.Sync) *Builder

func (*Builder) WithPublishService

func (builder *Builder) WithPublishService(publishService *utils.NamespaceValue) *Builder

func (*Builder) WithStore

func (builder *Builder) WithStore(store store.K8s) *Builder

func (*Builder) WithUpdatePublishServiceFunc

func (builder *Builder) WithUpdatePublishServiceFunc(updatePublishServiceFunc func(ingresses []*ingress.Ingress, publishServiceAddresses []string)) *Builder

type HAProxyController

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

HAProxyController is ingress controller

func (*HAProxyController) Start

func (c *HAProxyController) Start()

Start initializes and runs HAProxyController

func (*HAProxyController) Stop

func (c *HAProxyController) Stop()

Stop handles shutting down HAProxyController

func (*HAProxyController) SyncData

func (c *HAProxyController) SyncData()

SyncData gets all kubernetes changes, aggregates them and apply to HAProxy. All the changes must come through this function

type UpdateHandler

type UpdateHandler interface {
	Update(k store.K8s, h haproxy.HAProxy, a annotations.Annotations) (reload bool, err error)
}