Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 26 of 26 for TestWatch (0.21 sec)

  1. pkg/registry/networking/ingress/storage/storage_test.go

    	test := genericregistrytest.New(t, storage.Store)
    	test.TestList(validIngress())
    }
    
    func TestWatch(t *testing.T) {
    	storage, _, server := newStorage(t)
    	defer server.Terminate(t)
    	defer storage.Store.DestroyFunc()
    	test := genericregistrytest.New(t, storage.Store)
    	test.TestWatch(
    		validIngress(),
    		// matching labels
    		[]labels.Set{},
    		// not matching labels
    		[]labels.Set{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 15 09:01:21 UTC 2023
    - 8.4K bytes
    - Viewed (0)
  2. pkg/registry/core/serviceaccount/storage/storage_test.go

    	test := genericregistrytest.New(t, storage.Store)
    	test.TestList(validNewServiceAccount("foo"))
    }
    
    func TestWatch(t *testing.T) {
    	storage, server := newStorage(t)
    	defer server.Terminate(t)
    	defer storage.Store.DestroyFunc()
    	test := genericregistrytest.New(t, storage.Store)
    	test.TestWatch(
    		validNewServiceAccount("foo"),
    		// matching labels
    		[]labels.Set{},
    		// not matching labels
    		[]labels.Set{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  3. pkg/registry/core/persistentvolumeclaim/storage/storage_test.go

    	test.TestList(validNewPersistentVolumeClaim("foo", metav1.NamespaceDefault))
    }
    
    func TestWatch(t *testing.T) {
    	storage, _, server := newStorage(t)
    	defer server.Terminate(t)
    	defer storage.Store.DestroyFunc()
    	test := genericregistrytest.New(t, storage.Store)
    	test.TestWatch(
    		validNewPersistentVolumeClaim("foo", metav1.NamespaceDefault),
    		// matching labels
    		[]labels.Set{},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  4. internal/store/batch_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package store
    
    import (
    	"errors"
    	"sync"
    	"testing"
    )
    
    func TestBatch(t *testing.T) {
    	var limit uint32 = 100
    	batch := NewBatch[int, int](limit)
    	for i := 0; i < int(limit); i++ {
    		if err := batch.Add(i, i); err != nil {
    			t.Fatalf("failed to add %v; %v", i, err)
    		}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sat Oct 07 15:07:38 UTC 2023
    - 3.8K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/matchconditions/matcher_test.go

    	if f.throwError {
    		return nil, 0, errors.New("test error")
    	}
    	return f.evaluations, 0, nil
    }
    
    func (f *fakeCelFilter) CompilationErrors() []error {
    	return []error{}
    }
    
    func TestMatch(t *testing.T) {
    	fakeAttr := admission.NewAttributesRecord(nil, nil, schema.GroupVersionKind{}, "default", "foo", schema.GroupVersionResource{}, "", admission.Create, nil, false, nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jul 15 00:53:08 UTC 2023
    - 8.6K bytes
    - Viewed (0)
  6. src/path/filepath/match_test.go

    	{"a[", "x", false, ErrBadPattern},
    	{"a/b[", "x", false, ErrBadPattern},
    	{"*x", "xxx", true, nil},
    }
    
    func errp(e error) string {
    	if e == nil {
    		return "<nil>"
    	}
    	return e.Error()
    }
    
    func TestMatch(t *testing.T) {
    	for _, tt := range matchTests {
    		pattern := tt.pattern
    		s := tt.s
    		if runtime.GOOS == "windows" {
    			if strings.Contains(pattern, "\\") {
    				// no escape allowed on windows.
    				continue
    			}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 22 16:38:19 UTC 2024
    - 8.6K bytes
    - Viewed (0)
Back to top