definition

Documentation

Index

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

Types

type Definition

type Definition struct {
	MaxTries int

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

func (*Definition) HasSynced

func (instance *Definition) HasSynced() bool

func (*Definition) Init

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

func (*Definition) Run

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

func (*Definition) SetInformer

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

type Definitions

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

func New

func New(client kubernetes.Interface, resyncAfter time.Duration) (*Definitions, error)

func (*Definitions) HasSynced

func (instance *Definitions) HasSynced() bool

func (*Definitions) Init

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

func (*Definitions) SetNamespace

func (instance *Definitions) SetNamespace(namespace string)

type Ingress

type Ingress struct {
	*Definition
}

func NewIngress

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

func (*Ingress) Get

func (instance *Ingress) Get(key string) (*v1beta1.Ingress, error)

type OnElementChangedFunc

type OnElementChangedFunc func(key string, new metav1.Object) error

type OnElementRemovedFunc

type OnElementRemovedFunc func(key string) error

type OnElementUpdatedFunc

type OnElementUpdatedFunc func(key string, old, new metav1.Object) error

type OnErrorFunc

type OnErrorFunc func(key string, event string, err error)

type Service

type Service struct {
	*Definition
}

func NewService

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

func (*Service) Get

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

type ServiceSecret

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

func NewServiceSecrets

func NewServiceSecrets(client kubernetes.Interface, resyncAfter time.Duration) (*ServiceSecret, error)

func (*ServiceSecret) Get

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

func (*ServiceSecret) Init

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

func (*ServiceSecret) SetNamespace

func (instance *ServiceSecret) SetNamespace(namespace string)