matcher

Documentation

Index

• Constants
• func GetValidNodeOvercommitConfig(nocIndexer cache.Indexer, key string) (*v1alpha1.NodeOvercommitConfig, error)
• type ConfigToNodes
• type DummyMatcher
  • func (dm *DummyMatcher) DelNode(_ string)
  • func (dm *DummyMatcher) GetConfig(_ string) *v1alpha1.NodeOvercommitConfig
  • func (dm *DummyMatcher) GetNodeToConfig(_ string) *v1alpha1.NodeOvercommitConfig
  • func (dm *DummyMatcher) GetNodes(_ string) []string
  • func (dm *DummyMatcher) ListNodeToConfig() map[string]string
  • func (dm *DummyMatcher) MatchConfig(_ string) ([]string, error)
  • func (dm *DummyMatcher) MatchNode(_ string) (*v1alpha1.NodeOvercommitConfig, error)
  • func (dm *DummyMatcher) Reconcile() error
• type Matcher
• type MatcherImpl
  • func NewMatcher(nodelister corelisters.NodeLister, ...) *MatcherImpl
  • func (i *MatcherImpl) DelNode(nodeName string)
  • func (i *MatcherImpl) GetConfig(nodeName string) *v1alpha1.NodeOvercommitConfig
  • func (i *MatcherImpl) GetNodes(configName string) []string
  • func (i *MatcherImpl) ListNodeToConfig() map[string]string
  • func (i *MatcherImpl) MatchConfig(configName string) ([]string, error)
  • func (i *MatcherImpl) MatchNode(nodeName string) (*v1alpha1.NodeOvercommitConfig, error)
  • func (i *MatcherImpl) Reconcile() error
• type NocList
  • func (nl NocList) Len() int
  • func (nl NocList) Less(i, j int) bool
  • func (nl NocList) Swap(i, j int)
• type NodeMatchEvent
• type NodeToConfig

Constants

const LabelSelectorValIndex = "spec.nodeOvercommitSelectorVal"

Functions

func GetValidNodeOvercommitConfig

func GetValidNodeOvercommitConfig(nocIndexer cache.Indexer, key string) (*v1alpha1.NodeOvercommitConfig, error)

Types

type ConfigToNodes

type ConfigToNodes map[string]sets.String

type DummyMatcher

type DummyMatcher struct{}

func (*DummyMatcher) DelNode

func (dm *DummyMatcher) DelNode(_ string)

func (*DummyMatcher) GetConfig

func (dm *DummyMatcher) GetConfig(_ string) *v1alpha1.NodeOvercommitConfig

func (*DummyMatcher) GetNodeToConfig

func (dm *DummyMatcher) GetNodeToConfig(_ string) *v1alpha1.NodeOvercommitConfig

func (*DummyMatcher) GetNodes

func (dm *DummyMatcher) GetNodes(_ string) []string

func (*DummyMatcher) ListNodeToConfig

func (dm *DummyMatcher) ListNodeToConfig() map[string]string

func (*DummyMatcher) MatchConfig

func (dm *DummyMatcher) MatchConfig(_ string) ([]string, error)

func (*DummyMatcher) MatchNode

func (dm *DummyMatcher) MatchNode(_ string) (*v1alpha1.NodeOvercommitConfig, error)

func (*DummyMatcher) Reconcile

func (dm *DummyMatcher) Reconcile() error

type Matcher

type Matcher interface {
	// Reconcile rematch all configs and nodes
	Reconcile() error

	// MatchConfig matches nodes for config, return nodeNames whose matched config maybe updated.
	MatchConfig(configName string) ([]string, error)
	// MatchNode matches and sorts configs for node.
	MatchNode(nodeName string) (*v1alpha1.NodeOvercommitConfig, error)
	// ListNodeToConfig list nodes with matched configName
	ListNodeToConfig() map[string]string
	// GetConfig get matched config by nodeName
	GetConfig(nodeName string) *v1alpha1.NodeOvercommitConfig
	// GetNodes get matched nodes by configName
	GetNodes(configName string) []string
	// DelNode delete node in matcher cache
	DelNode(nodeName string)
}

type MatcherImpl

type MatcherImpl struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewMatcher

func NewMatcher(nodelister corelisters.NodeLister, noclister overcommitlisters.NodeOvercommitConfigLister, indexer cache.Indexer) *MatcherImpl

func (*MatcherImpl) DelNode

func (i *MatcherImpl) DelNode(nodeName string)

func (*MatcherImpl) GetConfig

func (i *MatcherImpl) GetConfig(nodeName string) *v1alpha1.NodeOvercommitConfig

func (*MatcherImpl) GetNodes

func (i *MatcherImpl) GetNodes(configName string) []string

func (*MatcherImpl) ListNodeToConfig

func (i *MatcherImpl) ListNodeToConfig() map[string]string

func (*MatcherImpl) MatchConfig

func (i *MatcherImpl) MatchConfig(configName string) ([]string, error)

func (*MatcherImpl) MatchNode

func (i *MatcherImpl) MatchNode(nodeName string) (*v1alpha1.NodeOvercommitConfig, error)

func (*MatcherImpl) Reconcile

func (i *MatcherImpl) Reconcile() error

type NocList

type NocList []*v1alpha1.NodeOvercommitConfig

func (NocList) Len

func (nl NocList) Len() int

func (NocList) Less

func (nl NocList) Less(i, j int) bool

func (NocList) Swap

func (nl NocList) Swap(i, j int)

type NodeMatchEvent

type NodeMatchEvent struct {
	NodeName   string
	NodeUpdate bool
}

type NodeToConfig

type NodeToConfig map[string]*v1alpha1.NodeOvercommitConfig