- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 24 for TestWatch (0.14 sec)
-
pkg/registry/core/replicationcontroller/storage/storage_test.go
test := genericregistrytest.New(t, storage.Controller.Store) test.TestList(validNewController()) } func TestWatch(t *testing.T) { storage, server := newStorage(t) defer server.Terminate(t) defer storage.Controller.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Controller.Store) test.TestWatch( validController, // matching labels []labels.Set{ {"a": "b"}, }, // not matching labels
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 16 06:57:01 UTC 2024 - 16.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/fieldselector_test.go
}, }...) } t.Run("watch", func(t *testing.T) { testWatch(ctx, t, tcs, dynamicClient) }) t.Run("list", func(t *testing.T) { testList(ctx, t, tcs, dynamicClient) }) t.Run("deleteCollection", func(t *testing.T) { testDeleteCollection(ctx, t, tcs, dynamicClient) }) } func testWatch(ctx context.Context, t *testing.T, tcs []selectableFieldTestCase, dynamicClient dynamic.Interface) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 15:53:03 UTC 2024 - 27K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go
storagetesting "k8s.io/apiserver/pkg/storage/testing" utilfeature "k8s.io/apiserver/pkg/util/feature" featuregatetesting "k8s.io/component-base/featuregate/testing" "k8s.io/utils/ptr" ) func TestWatch(t *testing.T) { ctx, store, _ := testSetup(t) storagetesting.RunTestWatch(ctx, t, store) } func TestClusterScopedWatch(t *testing.T) { ctx, store, _ := testSetup(t)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 12.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_test.go
} func TestCount(t *testing.T) { ctx, cacher, terminate := testSetup(t) t.Cleanup(terminate) storagetesting.RunTestCount(ctx, t, cacher) } func TestWatch(t *testing.T) { ctx, cacher, terminate := testSetup(t) t.Cleanup(terminate) storagetesting.RunTestWatch(ctx, t, cacher) } func TestWatchFromZero(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 17K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
) func RunTestWatch(ctx context.Context, t *testing.T, store storage.Interface) { testWatch(ctx, t, store, false) testWatch(ctx, t, store, true) } // It tests that // - first occurrence of objects should notify Add event // - update should trigger Modified event // - update that gets filtered should trigger Deleted event func testWatch(ctx context.Context, t *testing.T, store storage.Interface, recursive bool) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
pkg/registry/core/pod/storage/storage_test.go
test := genericregistrytest.New(t, storage.Store) test.TestList(validNewPod()) } 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( validNewPod(), // matching labels []labels.Set{}, // not matching labels []labels.Set{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 29 07:18:44 UTC 2024 - 38.8K bytes - Viewed (0) -
pilot/pkg/simulation/traffic.go
} } // prefix match var bestMatch *route.VirtualHost longest := 0 for _, vh := range rc.VirtualHosts { for _, d := range vh.Domains { if d[0] != '*' { continue } if len(host) >= len(d) && strings.HasSuffix(host, d[1:]) && len(d) > longest { bestMatch = vh longest = len(d) } } } if bestMatch != nil { return bestMatch } // Suffix match longest = 0
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 19.4K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/text/language/match.go
} if best.conf <= No { if len(want) != 0 { return nil, want[0].tag(), No } return nil, language.Tag{}, No } return best.have, best.want, best.conf } // bestMatch accumulates the best match so far. type bestMatch struct { have *haveTag want language.Tag conf Confidence pinnedRegion language.Region pinLanguage bool sameRegionGroup bool
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 25.1K bytes - Viewed (0) -
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) -
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)