definition

Documentation

Index

• type Definition
  • func (this *Definition) HasSynced() bool
  • func (this *Definition) Init(stop support.Channel) error
  • func (this *Definition) Run(stop support.Channel)
  • func (this *Definition) SetInformer(informer cache.SharedInformer)
• type Definitions
  • func New(s *settings.Settings, client kubernetes.Interface, resyncAfter time.Duration, ...) (*Definitions, error)
  • func (this *Definitions) HasSynced() bool
  • func (this *Definitions) Init(stop support.Channel) error
  • func (this *Definitions) SetNamespace(namespace string)
• type Ingress
  • func NewIngress(client kubernetes.Interface, resyncAfter time.Duration, logger log.Logger) (*Ingress, error)
  • func (this *Ingress) Get(key string) (*networkingv1.Ingress, error)
• type OnElementChangedFunc
• type OnElementRemovedFunc
• type OnElementUpdatedFunc
• type OnErrorFunc
• type Service
  • func NewService(client kubernetes.Interface, resyncAfter time.Duration, logger log.Logger) (*Service, error)
  • func (this *Service) Get(key string) (*v1.Service, error)
• type ServiceSecret
  • func NewServiceSecrets(s *settings.Settings, client kubernetes.Interface, resyncAfter time.Duration, ...) (*ServiceSecret, error)
  • func (this *ServiceSecret) Get(key string) (*v1.Service, error)
  • func (this *ServiceSecret) Init(stop support.Channel) error
  • func (this *ServiceSecret) SetNamespace(namespace string)

Types

type Definition

type Definition struct {
	MaxTries int
	Logger   log.Logger

	OnElementAdded   OnElementChangedFunc
	OnElementUpdated OnElementUpdatedFunc
	OnElementRemoved OnElementRemovedFunc
	OnError          OnErrorFunc
	// contains filtered or unexported fields
}

func (*Definition) HasSynced

func (this *Definition) HasSynced() bool

func (*Definition) Init

func (this *Definition) Init(stop support.Channel) error

func (*Definition) Run

func (this *Definition) Run(stop support.Channel)

func (*Definition) SetInformer

func (this *Definition) SetInformer(informer cache.SharedInformer)

type Definitions

type Definitions struct {
	ServiceSecrets *ServiceSecret
	Ingress        *Ingress
	Service        *Service
}

func New

func New(s *settings.Settings, client kubernetes.Interface, resyncAfter time.Duration, logger log.Logger) (*Definitions, error)

func (*Definitions) HasSynced

func (this *Definitions) HasSynced() bool

func (*Definitions) Init

func (this *Definitions) Init(stop support.Channel) error

func (*Definitions) SetNamespace

func (this *Definitions) SetNamespace(namespace string)

type Ingress

type Ingress struct {
	*Definition
}

func NewIngress

func NewIngress(client kubernetes.Interface, resyncAfter time.Duration, logger log.Logger) (*Ingress, error)

func (*Ingress) Get

func (this *Ingress) Get(key string) (*networkingv1.Ingress, error)

type OnElementChangedFunc

type OnElementChangedFunc func(ref support.ObjectReference, new metav1.Object) error

type OnElementRemovedFunc

type OnElementRemovedFunc func(ref support.ObjectReference) error

type OnElementUpdatedFunc

type OnElementUpdatedFunc func(ref support.ObjectReference, old, new metav1.Object) error

type OnErrorFunc

type OnErrorFunc func(ref support.ObjectReference, event string, err error)

type Service

type Service struct {
	*Definition
}

func NewService

func NewService(client kubernetes.Interface, resyncAfter time.Duration, logger log.Logger) (*Service, error)

func (*Service) Get

func (this *Service) Get(key string) (*v1.Service, error)

type ServiceSecret

type ServiceSecret struct {
	*Definition
	// contains filtered or unexported fields
}

func NewServiceSecrets

func NewServiceSecrets(s *settings.Settings, client kubernetes.Interface, resyncAfter time.Duration, logger log.Logger) (*ServiceSecret, error)

func (*ServiceSecret) Get

func (this *ServiceSecret) Get(key string) (*v1.Service, error)

func (*ServiceSecret) Init

func (this *ServiceSecret) Init(stop support.Channel) error

func (*ServiceSecret) SetNamespace

func (this *ServiceSecret) SetNamespace(namespace string)