controller

package
v1.8.11 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 10, 2023 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL