module

Documentation

Index

• func IsDisabledModuleError(err error) bool
• func MakePluggableFunc(informer cache.SharedIndexInformer) func(PluggableModule)
• type DisabledModuleError
  • func NewDisabledModuleError(moduleName string) *DisabledModuleError
  • func (e *DisabledModuleError) Error() string
• type DynamicSharedInformerFactory
• type Pluggable
  • func NewPluggable(name string) *Pluggable
  • func (p *Pluggable) Disable(disableModule func(disabledErr error))
  • func (p *Pluggable) Enable()
  • func (p *Pluggable) EnableAndSyncCache(sync func(stopCh chan struct{}))
  • func (p *Pluggable) EnableAndSyncDynamicInformerFactory(informerFactory DynamicSharedInformerFactory, onSync func())
  • func (p *Pluggable) EnableAndSyncInformerFactories(onSync func(), informerFactories ...SharedInformerFactory)
  • func (p *Pluggable) EnableAndSyncInformerFactory(informerFactory SharedInformerFactory, onSync func())
  • func (p *Pluggable) IsEnabled() bool
  • func (p *Pluggable) Name() string
  • func (p *Pluggable) StopCacheSyncOnClose(stopCh <-chan struct{})
• type PluggableModule
• type SharedInformerFactory

Functions

func IsDisabledModuleError

func IsDisabledModuleError(err error) bool

func MakePluggableFunc

func MakePluggableFunc(informer cache.SharedIndexInformer) func(PluggableModule)

Types

type DisabledModuleError

type DisabledModuleError struct {
	ModuleName string
}

func NewDisabledModuleError

func NewDisabledModuleError(moduleName string) *DisabledModuleError

func (*DisabledModuleError) Error

func (e *DisabledModuleError) Error() string

type DynamicSharedInformerFactory

type DynamicSharedInformerFactory interface {
	Start(stopCh <-chan struct{})
	ForResource(gvr schema.GroupVersionResource) informers.GenericInformer
	WaitForCacheSync(stopCh <-chan struct{}) map[schema.GroupVersionResource]bool
}

type Pluggable

type Pluggable struct {
	SyncCh chan bool
	// contains filtered or unexported fields
}

func NewPluggable

func NewPluggable(name string) *Pluggable

func (*Pluggable) Disable

func (p *Pluggable) Disable(disableModule func(disabledErr error))

func (*Pluggable) Enable

func (p *Pluggable) Enable()

func (*Pluggable) EnableAndSyncCache

func (p *Pluggable) EnableAndSyncCache(sync func(stopCh chan struct{}))

func (*Pluggable) EnableAndSyncDynamicInformerFactory

func (p *Pluggable) EnableAndSyncDynamicInformerFactory(informerFactory DynamicSharedInformerFactory, onSync func())

func (*Pluggable) EnableAndSyncInformerFactories

func (p *Pluggable) EnableAndSyncInformerFactories(onSync func(), informerFactories ...SharedInformerFactory)

func (*Pluggable) EnableAndSyncInformerFactory

func (p *Pluggable) EnableAndSyncInformerFactory(informerFactory SharedInformerFactory, onSync func())

func (*Pluggable) IsEnabled

func (p *Pluggable) IsEnabled() bool

func (*Pluggable) Name

func (p *Pluggable) Name() string

func (*Pluggable) StopCacheSyncOnClose

func (p *Pluggable) StopCacheSyncOnClose(stopCh <-chan struct{})

type PluggableModule

type PluggableModule interface {
	Enable() error
	Disable() error
	IsEnabled() bool
	Name() string
}

type SharedInformerFactory

type SharedInformerFactory interface {
	Start(stopCh <-chan struct{})
	WaitForCacheSync(stopCh <-chan struct{}) map[reflect.Type]bool
}