- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 77 for expectActions (0.29 sec)
-
pkg/controller/daemon/daemon_controller_test.go
informerFactory.Core().V1().Pods().Informer().GetStore(), informerFactory.Core().V1().Nodes().Informer().GetStore(), fakeRecorder, } podControl.expectations = newDsc.expectations return newDsc, podControl, clientset, nil } func resetCounters(manager *daemonSetsController) { manager.podControl.(*fakePodControl).Clear() fakeRecorder := record.NewFakeRecorder(100)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.4K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/node_expander_test.go
pv *v1.PersistentVolume // desired size, defaults to pv.Spec.Capacity desiredSize *resource.Quantity // actualSize, defaults to pvc.Status.Capacity actualSize *resource.Quantity // expectations of test expectedResizeStatus v1.ClaimResourceStatus expectedStatusSize resource.Quantity expectResizeCall bool assumeResizeOpAsFinished bool expectError bool }{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 5.7K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip_test.go
for _, ip := range test.expectedIPs { _, err := r.ipAddressLister.Get(ip) if err != nil { t.Errorf("Unexpected error trying to get IPAddress %s object: %v", ip, err) } } expectAction(t, c.Actions(), test.actions) expectEvents(t, recorder.Events, test.events) }) } } func TestRepairIPAddress_syncIPAddress(t *testing.T) { tests := []struct { name string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:06 UTC 2023 - 20.3K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
expectedReady: ptr.To[int32](0), }, "suspending a job with satisfied expectations": { // Suspended Job should delete active pods when expectations are // satisfied. suspend: true, parallelism: 2, activePods: 2, // parallelism == active, expectations satisfied completions: 4, backoffLimit: 6, expectedCreations: 0,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator_test.go
var tests = []struct { name string pvc *v1.PersistentVolumeClaim pv *v1.PersistentVolume recoverFeatureGate bool disableNodeExpansion bool // expectations of test expectedResizeStatus v1.ClaimResourceStatus expectedAllocatedSize resource.Quantity expectResizeCall bool }{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller_test.go
// so we skup the errors and only assert on the actions // https://github.com/kubernetes/kubernetes/issues/99953 _ = controller.sync(tCtx, tc.cidrSynced) expectAction(t, client.Actions(), tc.actions) }) } } func makeServiceCIDR(name, primary, secondary string) *networkingapiv1alpha1.ServiceCIDR { serviceCIDR := &networkingapiv1alpha1.ServiceCIDR{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 22K bytes - Viewed (0) -
src/cmd/vet/vet_test.go
// argument to errorCheck as it does double duty as both a // string that appears in the output, and as file name // openable relative to the test directory, containing text // expectations. // // So, we munge the file. stderr = strings.ReplaceAll(stderr, filepath.FromSlash("./rangeloop.go"), filename) if err := errorCheck(stderr, false, filename, filepath.Base(filename)); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 01:02:40 UTC 2024 - 12.5K bytes - Viewed (0) -
pilot/pkg/networking/core/listenertest/match.go
type ListenersTest struct { // Match listener by name Name string // Match listener by port Port uint32 // Listener assertions Listener ListenerTest } // ListenerTest provides a struct for defining expectations for a listener type ListenerTest struct { // Assert the listener contains these filter chains (in order, if TotalMatch) FilterChains []FilterChainTest
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 6.4K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
var podUID string = string(pod.ObjectMeta.UID) ipProto := uint8(unix.IPPROTO_TCP) ctx, cancel := context.WithCancel(context.Background()) fixture := getTestFixure(ctx) defer cancel() setupLogging() // expectations fixture.ipsetDeps.On("addIP", "foo-v4", netip.MustParseAddr("3.3.3.3"), ipProto, podUID, false, ).Return(nil) fixture.ipsetDeps.On("addIP", "foo-v4",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 17.8K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/dep-man/01-core-dependency-management/library_vs_application.adoc
A lot of the problems Gradle handles are about fixing the mismatch between the expectations of a consumer and a producer. However, some projects are easier than others:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 5.2K bytes - Viewed (0)