resourcecache

package
v1.0.4 Latest Latest
Warning

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

Go to latest
Published: Dec 11, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

This section is empty.

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 (*NetworkServiceCache) Delete

func (c *NetworkServiceCache) Delete(key string)

func (*NetworkServiceCache) Get

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 (*NetworkServiceEndpointCache) Delete

func (c *NetworkServiceEndpointCache) Delete(key string)

func (*NetworkServiceEndpointCache) Get

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 (*NetworkServiceManagerCache) Delete

func (c *NetworkServiceManagerCache) Delete(key string)

func (*NetworkServiceManagerCache) Get

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

Jump to

Keyboard shortcuts

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