k8s

Documentation

Index

• Constants
• Variables
• type BackendCR
  • func NewBackendCR() BackendCR
  • func (c BackendCR) GetInformer(eventChan chan SyncDataEvent, factory informers.SharedInformerFactory) cache.SharedIndexInformer
  • func (c BackendCR) GetKind() string
• type CR
• type DefaultsCR
  • func NewDefaultsCR() DefaultsCR
  • func (c DefaultsCR) GetInformer(eventChan chan SyncDataEvent, factory informers.SharedInformerFactory) cache.SharedIndexInformer
  • func (c DefaultsCR) GetKind() string
• type GlobalCR
  • func NewGlobalCR() GlobalCR
  • func (c GlobalCR) GetInformer(eventChan chan SyncDataEvent, factory informers.SharedInformerFactory) cache.SharedIndexInformer
  • func (c GlobalCR) GetKind() string
• type K8s
  • func New(osArgs utils.OSArgs, whitelist map[string]struct{}, ...) K8s
• type SyncDataEvent
• type SyncType

Constants

const (
	TRACE_API        = false
	CoreGroupVersion = "core.haproxy.org/v1alpha1"
)

TRACE_API outputs all k8s events received from k8s API nolint golint

Variables

var ErrIgnored = errors.New("ignored resource")

Types

type BackendCR

type BackendCR struct {
}

func NewBackendCR

func NewBackendCR() BackendCR

func (BackendCR) GetInformer

func (c BackendCR) GetInformer(eventChan chan SyncDataEvent, factory informers.SharedInformerFactory) cache.SharedIndexInformer

func (BackendCR) GetKind

func (c BackendCR) GetKind() string

type CR

type CR interface {
	GetKind() string
	GetInformer(chan SyncDataEvent, crinformers.SharedInformerFactory) cache.SharedIndexInformer
}

A Custom Resource interface Any CR should be able to provide its kind, its kubernetes Informer and a method to process the update of a CR

type DefaultsCR

type DefaultsCR struct {
}

func NewDefaultsCR

func NewDefaultsCR() DefaultsCR

func (DefaultsCR) GetInformer

func (c DefaultsCR) GetInformer(eventChan chan SyncDataEvent, factory informers.SharedInformerFactory) cache.SharedIndexInformer

func (DefaultsCR) GetKind

func (c DefaultsCR) GetKind() string

type GlobalCR

type GlobalCR struct {
}

func NewGlobalCR

func NewGlobalCR() GlobalCR

func (GlobalCR) GetInformer

func (c GlobalCR) GetInformer(eventChan chan SyncDataEvent, factory informers.SharedInformerFactory) cache.SharedIndexInformer

func (GlobalCR) GetKind

func (c GlobalCR) GetKind() string

type K8s

type K8s interface {
	GetClientset() *k8sclientset.Clientset
	MonitorChanges(eventChan chan SyncDataEvent, ingressChan chan ingress.Sync, stop chan struct{})
	UpdatePublishService(ingresses []*ingress.Ingress, publishServiceAddresses []string)
}

func New

func New(osArgs utils.OSArgs, whitelist map[string]struct{}, publishSvc *utils.NamespaceValue) K8s

type SyncDataEvent

type SyncDataEvent struct {
	SyncType
	Namespace string
	Name      string
	Data      interface{}
	// contains filtered or unexported fields
}

k8s.SyncDataEvent represents converted k8s received message

type SyncType

type SyncType string

SyncType represents type of k8s received message

const (
	// SyncType values
	COMMAND         SyncType = "COMMAND"
	CONFIGMAP       SyncType = "CONFIGMAP"
	ENDPOINTS       SyncType = "ENDPOINTS"
	INGRESS         SyncType = "INGRESS"
	INGRESS_CLASS   SyncType = "INGRESS_CLASS"
	NAMESPACE       SyncType = "NAMESPACE"
	POD             SyncType = "POD"
	SERVICE         SyncType = "SERVICE"
	SECRET          SyncType = "SECRET"
	CR_GLOBAL       SyncType = "Global"
	CR_DEFAULTS     SyncType = "Defaults"
	CR_BACKEND      SyncType = "Backend"
	PUBLISH_SERVICE SyncType = "PUBLISH_SERVICE"
)