- Sort Score
- Result 10 results
- Languages All
Results 651 - 660 of 1,020 for err (0.02 sec)
-
cmd/signature-v2.go
// if any while unescaping the values. func unescapeQueries(encodedQuery string) (unescapedQueries []string, err error) { for _, query := range strings.Split(encodedQuery, "&") { var unescapedQuery string unescapedQuery, err = url.QueryUnescape(query) if err != nil { return nil, err } unescapedQueries = append(unescapedQueries, unescapedQuery) } return unescapedQueries, nil }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 12.2K bytes - Viewed (0) -
internal/deadlineconn/deadlineconn.go
func (c *DeadlineConn) Read(b []byte) (n int, err error) { c.setReadDeadline() n, err = c.Conn.Read(b) return n, err } // Write - writes data to the connection. func (c *DeadlineConn) Write(b []byte) (n int, err error) { c.setWriteDeadline() n, err = c.Conn.Write(b) return n, err } // WithReadDeadline sets a new read side net.Conn deadline.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Jul 26 17:40:11 UTC 2024 - 2.6K bytes - Viewed (0) -
src/cmd/addr2line/main.go
counter.CountFlags("addr2line/flag:", *flag.CommandLine) if flag.NArg() != 1 { usage() } f, err := objfile.Open(flag.Arg(0)) if err != nil { log.Fatal(err) } defer f.Close() tab, err := f.PCLineTable() if err != nil { log.Fatalf("reading %s: %v", flag.Arg(0), err) } stdin := bufio.NewScanner(os.Stdin) stdout := bufio.NewWriter(os.Stdout) for stdin.Scan() {
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Fri Jun 21 19:58:04 UTC 2024 - 2.4K bytes - Viewed (0) -
istioctl/pkg/workload/workload_test.go
IstioNamespace: "istio-system", }) rootCmd := Cmd(ctx) rootCmd.SetArgs(args) client, err := ctx.CLIClientWithRevision(rev) if err != nil { return "", err } createResourceFunc(client) rootCmd.SetOut(&out) rootCmd.SetErr(&out) err = rootCmd.Execute() output := out.String() return output, err } func checkOutputFiles(t *testing.T, testdir string, checkFiles map[string]bool) {
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Thu Aug 01 20:04:20 UTC 2024 - 14.6K bytes - Viewed (0) -
cmd/xl-storage-format-v1.go
json := jsoniter.ConfigCompatibleWithStandardLibrary if err := json.Unmarshal(data, &info); err != nil { return err } sum, err := hex.DecodeString(info.Hash) if err != nil { return err } c.Algorithm = BitrotAlgorithmFromString(info.Algorithm) c.Hash = sum if _, err = fmt.Sscanf(info.Name, "part.%d", &c.PartNumber); err != nil { return err } if !c.Algorithm.Available() {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Oct 22 15:30:50 UTC 2024 - 8.4K bytes - Viewed (0) -
cni/pkg/plugin/sidecar_iptables_linux.go
cfg.DualStack = rdrct.dualStack netNs, err := getNs(netns) if err != nil { err = fmt.Errorf("failed to open netns %q: %s", netns, err) return err } defer netNs.Close() return netNs.Do(func(_ ns.NetNS) error { // Important: run within the pod network namespace since some attributes are namespace specific if err := cfg.FillConfigFromEnvironment(); err != nil { return err }
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Sat Jun 29 01:24:47 UTC 2024 - 2.6K bytes - Viewed (0) -
internal/s3select/sql/jsonpath.go
case simdjson.Object: elem := kvs.FindKey(key, nil) if elem == nil { // Key not found - return nil result return Missing{}, false, nil } val, err := IterToValue(elem.Iter) if err != nil { return nil, false, err } return jsonpathEval(p[1:], val) default: return nil, false, errKeyLookup } case p[0].Index != nil: idx := *p[0].Index
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 3.5K bytes - Viewed (0) -
internal/bucket/lifecycle/tag.go
var keyAlreadyParsed, valueAlreadyParsed bool for { // Read tokens from the XML document in a stream. t, err := d.Token() if err != nil { if err == io.EOF { break } return err } if se, ok := t.(xml.StartElement); ok { var s string if err = d.DecodeElement(&s, &se); err != nil { return err } switch se.Name.Local {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Mar 06 16:56:10 UTC 2023 - 2.4K bytes - Viewed (0) -
internal/bucket/lifecycle/transition.go
var dateStr string err := d.DecodeElement(&dateStr, &startElement) if err != nil { return err } // While AWS documentation mentions that the date specified // must be present in ISO 8601 format, in reality they allow // users to provide RFC 3339 compliant dates. trnDate, err := time.Parse(time.RFC3339, dateStr) if err != nil { return errTransitionInvalidDate }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jan 10 17:07:49 UTC 2022 - 5.1K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
Name: "foo", Namespace: "bar", UID: "123", } podIP := netip.MustParseAddr("99.9.9.9") podIPs := []netip.Addr{podIP} err := netServer.AddPodToMesh(ctx, &corev1.Pod{ObjectMeta: podMeta}, podIPs, "fakenetns") assert.NoError(t, err) assert.Equal(t, 1, ztunnelServer.addedPods.Load()) } func TestServerRemovePod(t *testing.T) { ctx, cancel := context.WithCancel(context.Background())
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Thu Jul 25 16:13:38 UTC 2024 - 10.7K bytes - Viewed (0)