regioninformers

package
v0.0.0-...-6cdb919 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 26, 2024 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 (*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{}
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL