- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 157 for Equals (0.2 sec)
-
cni/pkg/nodeagent/net_test.go
err := netServer.RemovePodFromMesh(ctx, pod) assert.NoError(t, err) assert.Equal(t, ztunnelServer.deletedPods.Load(), 1) assert.Equal(t, nlDeps.DelInpodMarkIPRuleCnt.Load(), 1) assert.Equal(t, nlDeps.DelLoopbackRoutesCnt.Load(), 1) // make sure the uid was taken from cache and netns closed netns := fixture.podNsMap.Take(string(pod.UID)) assert.Equal(t, nil, netns) // run gc to clean up ns:
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
cni/pkg/plugin/plugin_test.go
testDoAddRun(t, cniConf, testNSName, pod, ns) wasCalled := serverClose() // Pod in namespace with enabled ambient label, should be added to mesh assert.Equal(t, wasCalled, true) } func TestCmdAddAmbientEnabledOnNSServerFails(t *testing.T) { url, serverClose := setupCNIEventClientWithMockServer(true) cniConf := buildMockConf(true, url)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 17.5K bytes - Viewed (0) -
cmd/os_unix.go
break // EOF } } consumed, name, typ, err := parseDirEnt(buf[boff:nbuf]) if err != nil { return err } boff += consumed if len(name) == 0 || bytes.Equal(name, []byte{'.'}) || bytes.Equal(name, []byte{'.', '.'}) { continue } // Fallback for filesystems (like old XFS) that don't // support Dirent.Type and have DT_UNKNOWN (0) there // instead.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/sts-handlers_test.go
if !(b.Access.Read && b.Access.Write) { c.Fatalf("root user should have read and write access to bucket: %v", b.Name) } } shouldHaveBuckets := set.CreateStringSet(bucket2, bucket) if !gotBuckets.Equals(shouldHaveBuckets) { c.Fatalf("root user should have access to all buckets") } // This must fail. if err := userAdmClient.AddUser(ctx, globalActiveCred.AccessKey, globalActiveCred.SecretKey); err == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 85.7K bytes - Viewed (0) -
cmd/bitrot.go
if algo != HighwayHash256S { h := algo.New() if n, err := io.Copy(h, r); err != nil || n != wantSize { // Premature failure in reading the object, file is corrupt. return errFileCorrupt } if !bytes.Equal(h.Sum(nil), want) { return errFileCorrupt } return nil } h := algo.New() hashBuf := make([]byte, h.Size()) left := wantSize // Calculate the size of the bitrot file and compare
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 7.6K bytes - Viewed (0) -
cmd/post-policy_test.go
expirationStr := fmt.Sprintf(`"expiration": "%s"`, expiration.Format(iso8601TimeFormat)) // Add the bucket condition, only accept buckets equal to the one passed. bucketConditionStr := fmt.Sprintf(`["eq", "$bucket", "%s"]`, bucketName) // Add the key condition, only accept keys equal to the one passed. keyConditionStr := fmt.Sprintf(`["eq", "$key", "%s/upload.txt"]`, objectKey)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 29.6K bytes - Viewed (0) -
internal/mountinfo/mountinfo_linux_test.go
} } // Helpers for tests. // Check if two `mountInfo` are equal. func mountPointsEqual(a, b mountInfo) bool { if a.Device != b.Device || a.Path != b.Path || a.FSType != b.FSType || !slicesEqual(a.Options, b.Options) || a.Pass != b.Pass || a.Freq != b.Freq { return false } return true } // Checks if two string slices are equal. func slicesEqual(a, b []string) bool { if len(a) != len(b) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.3K bytes - Viewed (0) -
cni/test/install_cni.go
} // checkResult checks if resultFile is equal to expectedFile at each tick until timeout func checkResult(result, expected string) error { resultFile, err := os.ReadFile(result) if err != nil { return fmt.Errorf("couldn't read result: %v", err) } expectedFile, err := os.ReadFile(expected) if err != nil { return fmt.Errorf("couldn't read expected: %v", err) } if !bytes.Equal(resultFile, expectedFile) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
internal/auth/credentials_test.go
// Secret key is different in credentials to compare. {cred, Credentials{AccessKey: cred.AccessKey, SecretKey: "mypassword"}, false}, } for i, testCase := range testCases { result := testCase.cred.Equal(testCase.ccred) if result != testCase.expectedResult { t.Fatalf("test %v: expected: %v, got: %v", i+1, testCase.expectedResult, result) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 5.4K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
} handlers := setupHandlers(ctx, client, server, "istio-system") client.RunAndWait(ctx.Done()) disabledPod, err := handlers.GetPodIfAmbient(pod.Name, ns.Name) assert.NoError(t, err) assert.Equal(t, disabledPod, nil) } func TestAmbientEnabledReturnsErrorIfBogusNS(t *testing.T) { setupLogging() NodeName = "testnode" ctx, cancel := context.WithCancel(context.Background()) defer cancel()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0)