resourcecache

Documentation

Index

• Constants
• type CacheFilterPolicy
  • func FilterByNamespacePolicy(ns string, nsGetter func(resource interface{}) string) CacheFilterPolicy
  • func NoFilterPolicy() CacheFilterPolicy
• type NetworkServiceCache
  • func NewNetworkServiceCache(policy CacheFilterPolicy) *NetworkServiceCache
  • func (c *NetworkServiceCache) Add(ns *v1.NetworkService)
  • func (c *NetworkServiceCache) Delete(key string)
  • func (c *NetworkServiceCache) Get(key string) *v1.NetworkService
  • func (c *NetworkServiceCache) Start(f SharedInformerFactory, init ...v1.NetworkService) (func(), error)
  • func (c *NetworkServiceCache) StartWithResync(f SharedInformerFactory, cs *versioned.Clientset) (func(), error)
• type NetworkServiceEndpointCache
  • func NewNetworkServiceEndpointCache(policy CacheFilterPolicy) *NetworkServiceEndpointCache
  • func (c *NetworkServiceEndpointCache) Add(nse *v1.NetworkServiceEndpoint)
  • func (c *NetworkServiceEndpointCache) Delete(key string)
  • func (c *NetworkServiceEndpointCache) Get(key string) *v1.NetworkServiceEndpoint
  • func (c *NetworkServiceEndpointCache) GetByNetworkService(networkServiceName string) []*v1.NetworkServiceEndpoint
  • func (c *NetworkServiceEndpointCache) GetByNetworkServiceManager(nsmName string) []*v1.NetworkServiceEndpoint
  • func (c *NetworkServiceEndpointCache) Start(f SharedInformerFactory, init ...v1.NetworkServiceEndpoint) (func(), error)
  • func (c *NetworkServiceEndpointCache) StartWithResync(f SharedInformerFactory, cs *versioned.Clientset) (func(), error)
• type NetworkServiceManagerCache
  • func NewNetworkServiceManagerCache(policy CacheFilterPolicy) *NetworkServiceManagerCache
  • func (c *NetworkServiceManagerCache) Add(nsm *v1.NetworkServiceManager)
  • func (c *NetworkServiceManagerCache) Delete(key string)
  • func (c *NetworkServiceManagerCache) Get(key string) *v1.NetworkServiceManager
  • func (c *NetworkServiceManagerCache) Start(f SharedInformerFactory, init ...v1.NetworkServiceManager) (func(), error)
  • func (c *NetworkServiceManagerCache) StartWithResync(f SharedInformerFactory, cs *versioned.Clientset) (func(), error)
  • func (c *NetworkServiceManagerCache) Update(nsm *v1.NetworkServiceManager)

Constants

const (
	NseResource = "networkserviceendpoints"
	NsResource  = "networkservices"
	NsmResource = "networkservicemanagers"
)

Types

type CacheFilterPolicy

type CacheFilterPolicy interface {
	//Filter means resource filter function. Accepts resource. Returns true if the resource should be skipped
	Filter(resource interface{}) bool
}

CacheFilterPolicy uses for filtering resources

func FilterByNamespacePolicy

func FilterByNamespacePolicy(ns string, nsGetter func(resource interface{}) string) CacheFilterPolicy

FilterByNamespacePolicy returns policy for filtering resources by namespace

func NoFilterPolicy

func NoFilterPolicy() CacheFilterPolicy

NoFilterPolicy returns default filter policy

type NetworkServiceCache

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

func NewNetworkServiceCache

func NewNetworkServiceCache(policy CacheFilterPolicy) *NetworkServiceCache

NewNetworkServiceCache creates cache for network services

func (*NetworkServiceCache) Add

func (c *NetworkServiceCache) Add(ns *v1.NetworkService)

func (*NetworkServiceCache) Delete

func (c *NetworkServiceCache) Delete(key string)

func (*NetworkServiceCache) Get

func (c *NetworkServiceCache) Get(key string) *v1.NetworkService

func (*NetworkServiceCache) Start

func (c *NetworkServiceCache) Start(f SharedInformerFactory, init ...v1.NetworkService) (func(), error)

func (*NetworkServiceCache) StartWithResync

func (c *NetworkServiceCache) StartWithResync(f SharedInformerFactory, cs *versioned.Clientset) (func(), error)

type NetworkServiceEndpointCache

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

func NewNetworkServiceEndpointCache

func NewNetworkServiceEndpointCache(policy CacheFilterPolicy) *NetworkServiceEndpointCache

NewNetworkServiceEndpointCache creates cache for network service endpoints

func (*NetworkServiceEndpointCache) Add

func (c *NetworkServiceEndpointCache) Add(nse *v1.NetworkServiceEndpoint)

func (*NetworkServiceEndpointCache) Delete

func (c *NetworkServiceEndpointCache) Delete(key string)

func (*NetworkServiceEndpointCache) Get

func (c *NetworkServiceEndpointCache) Get(key string) *v1.NetworkServiceEndpoint

func (*NetworkServiceEndpointCache) GetByNetworkService

func (c *NetworkServiceEndpointCache) GetByNetworkService(networkServiceName string) []*v1.NetworkServiceEndpoint

func (*NetworkServiceEndpointCache) GetByNetworkServiceManager

func (c *NetworkServiceEndpointCache) GetByNetworkServiceManager(nsmName string) []*v1.NetworkServiceEndpoint

func (*NetworkServiceEndpointCache) Start

func (c *NetworkServiceEndpointCache) Start(f SharedInformerFactory, init ...v1.NetworkServiceEndpoint) (func(), error)

func (*NetworkServiceEndpointCache) StartWithResync

func (c *NetworkServiceEndpointCache) StartWithResync(f SharedInformerFactory, cs *versioned.Clientset) (func(), error)

type NetworkServiceManagerCache

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

func NewNetworkServiceManagerCache

func NewNetworkServiceManagerCache(policy CacheFilterPolicy) *NetworkServiceManagerCache

NewNetworkServiceManagerCache creates cache for network service managers

func (*NetworkServiceManagerCache) Add

func (c *NetworkServiceManagerCache) Add(nsm *v1.NetworkServiceManager)

func (*NetworkServiceManagerCache) Delete

func (c *NetworkServiceManagerCache) Delete(key string)

func (*NetworkServiceManagerCache) Get

func (c *NetworkServiceManagerCache) Get(key string) *v1.NetworkServiceManager

func (*NetworkServiceManagerCache) Start

func (c *NetworkServiceManagerCache) Start(f SharedInformerFactory, init ...v1.NetworkServiceManager) (func(), error)

func (*NetworkServiceManagerCache) StartWithResync

func (c *NetworkServiceManagerCache) StartWithResync(f SharedInformerFactory, cs *versioned.Clientset) (func(), error)

func (*NetworkServiceManagerCache) Update

func (c *NetworkServiceManagerCache) Update(nsm *v1.NetworkServiceManager)