135 lines
3.6 KiB
Go
135 lines
3.6 KiB
Go
/*
|
|
Copyright 2016 The Kubernetes Authors.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
package storage
|
|
|
|
import (
|
|
"errors"
|
|
"testing"
|
|
|
|
"k8s.io/apimachinery/pkg/fields"
|
|
"k8s.io/apimachinery/pkg/labels"
|
|
"k8s.io/apimachinery/pkg/runtime"
|
|
"k8s.io/apimachinery/pkg/runtime/schema"
|
|
)
|
|
|
|
type Ignored struct {
|
|
ID string
|
|
}
|
|
|
|
type IgnoredList struct {
|
|
Items []Ignored
|
|
}
|
|
|
|
func (obj *Ignored) GetObjectKind() schema.ObjectKind { return schema.EmptyObjectKind }
|
|
func (obj *IgnoredList) GetObjectKind() schema.ObjectKind { return schema.EmptyObjectKind }
|
|
func (obj *Ignored) DeepCopyObject() runtime.Object {
|
|
panic("Ignored does not support DeepCopy")
|
|
}
|
|
func (obj *IgnoredList) DeepCopyObject() runtime.Object {
|
|
panic("IgnoredList does not support DeepCopy")
|
|
}
|
|
|
|
func TestSelectionPredicate(t *testing.T) {
|
|
table := map[string]struct {
|
|
labelSelector, fieldSelector string
|
|
labels labels.Set
|
|
fields fields.Set
|
|
uninitialized bool
|
|
err error
|
|
shouldMatch bool
|
|
matchSingleKey string
|
|
}{
|
|
"A": {
|
|
labelSelector: "name=foo",
|
|
fieldSelector: "uid=12345",
|
|
labels: labels.Set{"name": "foo"},
|
|
fields: fields.Set{"uid": "12345"},
|
|
shouldMatch: true,
|
|
},
|
|
"B": {
|
|
labelSelector: "name=foo",
|
|
fieldSelector: "uid=12345",
|
|
labels: labels.Set{"name": "foo"},
|
|
fields: fields.Set{},
|
|
shouldMatch: false,
|
|
},
|
|
"C": {
|
|
labelSelector: "name=foo",
|
|
fieldSelector: "uid=12345",
|
|
labels: labels.Set{},
|
|
fields: fields.Set{"uid": "12345"},
|
|
shouldMatch: false,
|
|
},
|
|
"D": {
|
|
fieldSelector: "metadata.name=12345",
|
|
labels: labels.Set{},
|
|
fields: fields.Set{"metadata.name": "12345"},
|
|
shouldMatch: true,
|
|
matchSingleKey: "12345",
|
|
},
|
|
"E": {
|
|
fieldSelector: "metadata.name=12345",
|
|
labels: labels.Set{},
|
|
fields: fields.Set{"metadata.name": "12345"},
|
|
uninitialized: true,
|
|
shouldMatch: false,
|
|
matchSingleKey: "12345",
|
|
},
|
|
"error": {
|
|
labelSelector: "name=foo",
|
|
fieldSelector: "uid=12345",
|
|
err: errors.New("maybe this is a 'wrong object type' error"),
|
|
shouldMatch: false,
|
|
},
|
|
}
|
|
|
|
for name, item := range table {
|
|
parsedLabel, err := labels.Parse(item.labelSelector)
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
parsedField, err := fields.ParseSelector(item.fieldSelector)
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
sp := &SelectionPredicate{
|
|
Label: parsedLabel,
|
|
Field: parsedField,
|
|
GetAttrs: func(runtime.Object) (label labels.Set, field fields.Set, uninitialized bool, err error) {
|
|
return item.labels, item.fields, item.uninitialized, item.err
|
|
},
|
|
}
|
|
got, err := sp.Matches(&Ignored{})
|
|
if e, a := item.err, err; e != a {
|
|
t.Errorf("%v: expected %v, got %v", name, e, a)
|
|
continue
|
|
}
|
|
if e, a := item.shouldMatch, got; e != a {
|
|
t.Errorf("%v: expected %v, got %v", name, e, a)
|
|
}
|
|
if key := item.matchSingleKey; key != "" {
|
|
got, ok := sp.MatchesSingle()
|
|
if !ok {
|
|
t.Errorf("%v: expected single match", name)
|
|
}
|
|
if e, a := key, got; e != a {
|
|
t.Errorf("%v: expected %v, got %v", name, e, a)
|
|
}
|
|
}
|
|
}
|
|
}
|