- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 513 for shouldn (0.15 sec)
-
istioctl/pkg/writer/ztunnel/configdump/workload.go
return svc.Name } return "NA" // Shouldn't normally reach here } func serviceWaypointName(svc *ZtunnelService, services map[string]*ZtunnelService) string { if svc.Waypoint == nil { return "None" } if svc, ok := services[svc.Waypoint.Destination]; ok { return svc.Name } return "NA" // Shouldn't normally reach here
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 4K bytes - Viewed (0) -
cmd/generic-handlers_test.go
r := &http.Request{ Proto: "HTTP/1.0", Method: http.MethodPost, URL: u, } if !guessIsRPCReq(r) { t.Fatal("Test shouldn't fail for a possible net/rpc request.") } r = &http.Request{ Proto: "HTTP/1.1", Method: http.MethodGet, } if guessIsRPCReq(r) { t.Fatal("Test shouldn't report as net/rpc for a non net/rpc request.") } r = &http.Request{ Proto: "HTTP/1.1", Method: http.MethodGet,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 5.4K bytes - Viewed (0) -
operator/cmd/mesh/profile-diff_test.go
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Jan 10 05:10:03 GMT 2024 - 3.6K bytes - Viewed (1) -
cni/pkg/nodeagent/server.go
// Note that if the ipset already exist by name, Create will not return an error. // // We will unconditionally flush our set before use here, so it shouldn't matter. func createHostsideProbeIpset(isV6 bool) (ipset.IPSet, error) { linDeps := ipset.RealNlDeps() probeSet, err := ipset.NewIPSet(iptables.ProbeIPSet, isV6, linDeps) if err != nil { return probeSet, err
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
// we got am essage from ztun, so it should have observed us being connected mt.Assert(ztunnelConnected.Name(), nil, monitortest.Exactly(1)) // we should get the fd to dev null. note that we can't assert the fd number // as the kernel may have given us a different number that refers to the same file. assert.Equal(t, len(fds), 1) // in theory we should close the fd, but it's just a test..
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0) -
src/archive/zip/zip_test.go
} } if err := w.Close(); err != nil { t.Fatal(err) } } } // 16k-1 records shouldn't make a zip64: t.Run("uint16max-1_NoZip64", func(t *testing.T) { t.Parallel() if generatesZip64(t, gen(0xfffe)) { t.Error("unexpected zip64") } }) // 16k records should make a zip64: t.Run("uint16max_Zip64", func(t *testing.T) { t.Parallel() if !generatesZip64(t, gen(0xffff)) {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Mar 27 18:23:49 GMT 2024 - 19.5K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
err: err, resp: resp, } case <-time.After(ztunnelKeepAliveCheckInterval): // do a short read, just to see if the connection to ztunnel is // still alive. As ztunnel shouldn't send anything unless we send // something first, we expect to get an os.ErrDeadlineExceeded error // here if the connection is still alive. // note that unlike tcp connections, reading is a good enough test here.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/signature-v4-utils_test.go
// Test case - 5. // Enabling PreSigned Signature v4, but X-Amz-Content-Sha256 set and its not UNSIGNED-PAYLOAD, we shouldn't skip. {"X-Amz-Content-Sha256", "somevalue", "X-Amz-Credential", "", false}, // Test case - 6. // Test case with "X-Amz-Content-Sha256" header set to "UNSIGNED-PAYLOAD" and its not presigned, we should skip. {"X-Amz-Content-Sha256", unsignedPayload, "", "", true}, // Test case - 7.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 14.3K bytes - Viewed (0) -
internal/grid/muxclient.go
fmt.Println("Mux", m.MuxID, "Request took", time.Since(start).Round(time.Millisecond)) }() } defer func() { // addErrorNonBlockingClose will close the response channel // - maybe async, so we shouldn't do it here. if m.respErr.Load() == nil { xioutil.SafeClose(respHandler) } }() var pingTimer <-chan time.Time if m.deadline == 0 || m.deadline > clientPingInterval {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
tests/migrate_test.go
} // RelationModel3 should be existed _, err = findColumnType(&RelationModel3{}, "id") AssertEqual(t, nil, err) // RelationModel1 should not be existed _, err = findColumnType(&RelationModel1{}, "id") if err == nil { t.Errorf("RelationModel1 should not be migrated") } // RelationModel2 should not be existed _, err = findColumnType(&RelationModel2{}, "id")
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Mon Mar 18 11:24:16 GMT 2024 - 56.2K bytes - Viewed (0)