K8s源码1-LabelSelector-Selector

标签（Labels） 是附加到 Kubernetes 对象（比如 Pod）上的键值对。 标签旨在用于指定对用户有意义且相关的对象的标识属性，但不直接对核心系统有语义含义。 标签可以用于组织和选择对象的子集。标签可以在创建时附加到对象，随后可以随时添加和修改。 每个对象都可以定义一组键/值标签。每个键对于给定对象必须是唯一的。

"labels": { "key1" : "value1", "key2" : "value2" }

使用方法

// test文件中调用方法，给一个Set x:y和现有的标签"x=y"进行匹配，显然可以看出，匹配成功
expectMatch(t, "x=y", Set{"x": "y"})


// ls Set是匹配目标，selector是现有标签
func expectMatch(t *testing.T, selector string, ls Set) {
  // 这里将selector x=y解析成Selector，解析Parse的实现在下一篇文章讲，Selector会在后文讲。
	lq, err := Parse(selector)
	if err != nil {
		t.Errorf("Unable to parse %v as a selector\n", selector)
		return}
  // Selector有一个方法matches，进行匹配
	if !lq.Matches(ls) {
		t.Errorf("Wanted %s to match '%s', but it did not.\n", selector, ls)
	}
}

源码分析

// labels.go
// Labels allows you to present labels independently from their storage.
type Labels interface {
	Has(label string) (exists bool)

	Get(label string) (value string)
}

type Set map[string]string// .. 省略Set的接口实现

// selector.go
// Selector represents a label selector.
type Selector interface {
	Matches(Labels) boolEmpty() boolString() stringAdd(r ...Requirement) Selector

	// ... 省略了一些方法
}

// selector.go
// Requirement是对标签匹配的一个抽象。在internalSelector进行匹配的时候，会遍历所有的Requirement，将目标label和每一个Requirement进行Match匹配。
type Requirement struct {
  // 键
	key      string
  
 	// == != exists等运算符
	operator selection.Operator
  // 值
	strValues []string}

// internalSelector是默认的Selector，实现and运算，即要满足每一个Reqirement的匹配。有一个匹配失败，则整体匹配失败。
type internalSelector []Requirement

func (s internalSelector) Matches(l Labels) bool {
	for ix := range s {
		if matches := s[ix].Matches(l); !matches {
			return false}
	}
	return true}

func NewSelector() Selector {
	return internalSelector(nil)
}

// 这里根据每一种运算类型，分别进行匹配，调用了Labels的has方法，Labels接口在上文有提到。
func (r *Requirement) Matches(ls Labels) bool {
	switch r.operator {
	case selection.In, selection.Equals, selection.DoubleEquals:
		if !ls.Has(r.key) {
			return false}
		return r.hasValue(ls.Get(r.key))
	case selection.NotIn, selection.NotEquals:
		if !ls.Has(r.key) {
			return true}
		return !r.hasValue(ls.Get(r.key))
	case selection.Exists:
		return ls.Has(r.key)

  // ... 省略一些case
default:
		return false}
}

总结