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 BackendCRV1Alpha1
  • func NewBackendCRV1Alpha1() BackendCRV1Alpha1
  • func (c BackendCRV1Alpha1) GetInformer(eventChan chan SyncDataEvent, factory informers.SharedInformerFactory) cache.SharedIndexInformer
  • func (c BackendCRV1Alpha1) 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 DefaultsCRV1Alpha1
  • func NewDefaultsCRV1Alpha1() DefaultsCRV1Alpha1
  • func (c DefaultsCRV1Alpha1) GetInformer(eventChan chan SyncDataEvent, factory informers.SharedInformerFactory) cache.SharedIndexInformer
  • func (c DefaultsCRV1Alpha1) 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 GlobalCRV1Alpha1
  • func NewGlobalCRV1Alpha1() GlobalCRV1Alpha1
  • func (c GlobalCRV1Alpha1) GetInformer(eventChan chan SyncDataEvent, factory informers.SharedInformerFactory) cache.SharedIndexInformer
  • func (c GlobalCRV1Alpha1) GetKind() string
• type K8s
  • func New(osArgs utils.OSArgs, whitelist map[string]struct{}, ...) K8s
• type SyncDataEvent
• type SyncType

Constants

const (
	TRACE_API               = false //nolint:golint,stylecheck
	CRSGroupVersionV1alpha1 = "core.haproxy.org/v1alpha1"
	CRSGroupVersionV1alpha2 = "core.haproxy.org/v1alpha2"
)

TRACE_API outputs all k8s events received from k8s API

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 BackendCRV1Alpha1

type BackendCRV1Alpha1 struct{}

func NewBackendCRV1Alpha1

func NewBackendCRV1Alpha1() BackendCRV1Alpha1

func (BackendCRV1Alpha1) GetInformer

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

func (BackendCRV1Alpha1) GetKind

func (c BackendCRV1Alpha1) 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 DefaultsCRV1Alpha1

type DefaultsCRV1Alpha1 struct{}

func NewDefaultsCRV1Alpha1

func NewDefaultsCRV1Alpha1() DefaultsCRV1Alpha1

func (DefaultsCRV1Alpha1) GetInformer

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

func (DefaultsCRV1Alpha1) GetKind

func (c DefaultsCRV1Alpha1) 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 GlobalCRV1Alpha1

type GlobalCRV1Alpha1 struct{}

func NewGlobalCRV1Alpha1

func NewGlobalCRV1Alpha1() GlobalCRV1Alpha1

func (GlobalCRV1Alpha1) GetInformer

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

func (GlobalCRV1Alpha1) GetKind

func (c GlobalCRV1Alpha1) GetKind() string

type K8s

type K8s interface {
	GetClientset() *k8sclientset.Clientset
	MonitorChanges(eventChan chan SyncDataEvent, 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{}
	EventProcessed chan struct{}
	// 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"
)