regioninformers

Documentation

Index

• type ClientSetOperation
• type DynamicClientSetOperation
• type DynamicFactoryOperation
• type DynamicInformerOperation
• type FactoryOperation
• type InformerOperation
• type LoggingMutext
  • func (m *LoggingMutext) Lock()
  • func (m *LoggingMutext) RLock()
  • func (m *LoggingMutext) RUnlock()
  • func (m *LoggingMutext) Unlock()
• type RegionClient
• type RegionInformers
  • func NewRegionInformers(regionMgr manager.Manager, defaultResync time.Duration) *RegionInformers
  • func (f *RegionInformers) DeleteRegionInformer(regionID uint)
  • func (f *RegionInformers) GVK2GVR(regionID uint, GVK schema.GroupVersionKind) (schema.GroupVersionResource, error)
  • func (f *RegionInformers) GetClientSet(regionID uint, operation ClientSetOperation) error
  • func (f *RegionInformers) GetDynamicClientSet(regionID uint, operation DynamicClientSetOperation) error
  • func (f *RegionInformers) GetDynamicFactory(regionID uint, operation DynamicFactoryOperation) error
  • func (f *RegionInformers) GetDynamicInformer(regionID uint, gvr schema.GroupVersionResource, ...) error
  • func (f *RegionInformers) GetFactory(regionID uint, operation FactoryOperation) error
  • func (f *RegionInformers) GetInformer(regionID uint, gvr schema.GroupVersionResource, operation InformerOperation) error
  • func (f *RegionInformers) GetRestConfig(regionID uint) (*rest.Config, error)
  • func (f *RegionInformers) NewRegionInformers(region *models.Region) error
  • func (f *RegionInformers) Register(handlers ...Resource)
  • func (f *RegionInformers) Start(regionIDs ...uint) error
  • func (f *RegionInformers) WatchRegion(ctx context.Context, pollInterval time.Duration)
• type Resource
• type Target

Types

type ClientSetOperation

type ClientSetOperation func(clientset kubernetes.Interface) error

type DynamicClientSetOperation

type DynamicClientSetOperation func(clientset dynamic.Interface) error

type DynamicFactoryOperation

type DynamicFactoryOperation func(factory dynamicinformer.DynamicSharedInformerFactory) error

type DynamicInformerOperation

type DynamicInformerOperation func(informer informers.GenericInformer) error

type FactoryOperation

type FactoryOperation func(factory informers.SharedInformerFactory) error

type InformerOperation

type InformerOperation func(informer informers.GenericInformer) error

type LoggingMutext

type LoggingMutext struct {
	sync.RWMutex
}

func (*LoggingMutext) Lock

func (m *LoggingMutext) Lock()

func (*LoggingMutext) RLock

func (m *LoggingMutext) RLock()

func (*LoggingMutext) RUnlock

func (m *LoggingMutext) RUnlock()

func (*LoggingMutext) Unlock

func (m *LoggingMutext) Unlock()

type RegionClient

type RegionClient struct {
	// contains filtered or unexported fields
}

type RegionInformers

type RegionInformers struct {
	// contains filtered or unexported fields
}

RegionInformers is a collection of informer factories for each region

func NewRegionInformers

func NewRegionInformers(regionMgr manager.Manager, defaultResync time.Duration) *RegionInformers

NewRegionInformers is called when initializing

func (*RegionInformers) DeleteRegionInformer

func (f *RegionInformers) DeleteRegionInformer(regionID uint)

func (*RegionInformers) GVK2GVR

func (f *RegionInformers) GVK2GVR(regionID uint, GVK schema.GroupVersionKind) (schema.GroupVersionResource, error)

func (*RegionInformers) GetClientSet

func (f *RegionInformers) GetClientSet(regionID uint, operation ClientSetOperation) error

GetClientSet gets the client for the given region it should have no reference for factory outside RegionInformers

func (*RegionInformers) GetDynamicClientSet

func (f *RegionInformers) GetDynamicClientSet(regionID uint, operation DynamicClientSetOperation) error

GetDynamicClientSet gets the dynamic clientset for the given region it should have no reference for factory outside RegionInformers

func (*RegionInformers) GetDynamicFactory

func (f *RegionInformers) GetDynamicFactory(regionID uint, operation DynamicFactoryOperation) error

func (*RegionInformers) GetDynamicInformer

func (f *RegionInformers) GetDynamicInformer(regionID uint,
	gvr schema.GroupVersionResource, operation DynamicInformerOperation) error

GetDynamicInformer gets the informer for the given region and gvr it should have no reference for factory outside RegionInformers

func (*RegionInformers) GetFactory

func (f *RegionInformers) GetFactory(regionID uint, operation FactoryOperation) error

func (*RegionInformers) GetInformer

func (f *RegionInformers) GetInformer(regionID uint,
	gvr schema.GroupVersionResource, operation InformerOperation) error

GetInformer gets the informer for the given region and gvr it should have no reference for factory outside RegionInformers

func (*RegionInformers) GetRestConfig

func (f *RegionInformers) GetRestConfig(regionID uint) (*rest.Config, error)

func (*RegionInformers) NewRegionInformers

func (f *RegionInformers) NewRegionInformers(region *models.Region) error

func (*RegionInformers) Register

func (f *RegionInformers) Register(handlers ...Resource)

func (*RegionInformers) Start

func (f *RegionInformers) Start(regionIDs ...uint) error

func (*RegionInformers) WatchRegion

func (f *RegionInformers) WatchRegion(ctx context.Context, pollInterval time.Duration)

WatchRegion blocks until ctx is done, and watch the database for region changes

type Resource

type Resource struct {
	MakeHandler func(uint, <-chan struct{}) (cache.ResourceEventHandler, error)
	GVR         schema.GroupVersionResource
}

type Target

type Target struct {
	Resource
	Regions map[uint]struct{}
}