k8scache

package

v0.0.0-...-aa771b6 Latest Latest Go to latest Published: Jan 12, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func CreateHandler(h CacheHandler) cache.ResourceEventHandler

CreateHandler creates a cache.ResourceEventHandler from CacheHandler

type CacheHandler interface {
	Add(obj interface{})
	Update(old, new interface{})
	Delete(obj interface{})
}

CacheHandler is the interface for cache updates from external source.

type NodeLister interface {
	// ListNode list all nodes in Kubernetes cluster
	ListNode() ([]*v1.Node, error)
}

NodeLister list nodes

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

SchedCache is the cache for scheduler

func New(client kubernetes.Interface) *SchedCache

New creates a SchedCache instance

func (c SchedCache) GetHost(node string) string

GetHost returns the hostname of a given node

func (c SchedCache) GetNodes(host string) []string

GetNodes returns all the nodes running on a given host

func (c SchedCache) GetPodsOnNode(nodename string) []string

func (c *SchedCache) ListNode() ([]*v1.Node, error)

ListNode lists all nodes cached in SchedCached

func (c *SchedCache) ListPod(selector selector.Selector) ([]*v1.Pod, error)

ListPod list pods that matched the selector cached in SchedCache

func (c *SchedCache) NodeInformer() cache.SharedIndexInformer

NodeInformer returns the SharedIndexInformer for nodes

func (c *SchedCache) PodInformer() cache.SharedIndexInformer

PodInformer returns the SharedIndexInformer for pods

func (c *SchedCache) Run(stopCh <-chan struct{})

Run starts the shared informer in cache, which will be stopped when stopCh is closed.