- Sort Score
- Result 10 results
- Languages All
Results 791 - 800 of 1,020 for err (0.03 sec)
-
src/archive/tar/strconv.go
} b := make([]byte, 0, len(s)) for _, c := range s { if c < 0x80 && c != 0x00 { b = append(b, byte(c)) } } return string(b) } type parser struct { err error // Last error seen } type formatter struct { err error // Last error seen } // parseString parses bytes as a NUL-terminated C-style string. // If a NUL byte is not found then the whole slice is returned as a string.
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Tue Aug 01 14:28:42 UTC 2023 - 9K bytes - Viewed (0) -
cmd/metrics-v3-system-memory.go
) // loadMemoryMetrics - `MetricsLoaderFn` for node memory metrics. func loadMemoryMetrics(ctx context.Context, m MetricValues, c *metricsCache) error { memMetrics, err := c.memoryMetrics.Get() if err != nil { metricsLogIf(ctx, err) return err } m.Set(memTotal, float64(memMetrics.Total)) m.Set(memUsed, float64(memMetrics.Used)) usedPerc := float64(memMetrics.Used) * 100 / float64(memMetrics.Total)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Apr 17 05:10:25 UTC 2024 - 2.2K bytes - Viewed (0) -
internal/bucket/encryption/bucket-sse-config.go
type Algorithm string // UnmarshalXML - Unmarshals XML tag to valid SSE algorithm func (alg *Algorithm) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error { var s string if err := d.DecodeElement(&s, &start); err != nil { return err } switch s { case string(AES256): *alg = AES256 case string(AWSKms): *alg = AWSKms default: return errors.New("Unknown SSE algorithm") } return nil }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Oct 25 00:44:15 UTC 2022 - 4.9K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status_test.go
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Wed Aug 14 19:36:19 UTC 2024 - 6.5K bytes - Viewed (0) -
cmd/service.go
cmd.Stdin = os.Stdin cmd.Env = os.Environ() err := cmd.Run() if err == nil { os.Exit(0) } return err } // Use the original binary location. This works with symlinks such that if // the file it points to has been changed we will use the updated symlink. argv0, err := exec.LookPath(os.Args[0]) if err != nil { return err } // Invokes the execve system call.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Feb 28 07:02:14 UTC 2024 - 3.8K bytes - Viewed (0) -
cni/pkg/plugin/kubernetes.go
// Some config can be passed in a kubeconfig file kubeconfig := filepath.Join(conf.CNIAgentRunDir, constants.CNIPluginKubeconfName) config, err := kube.DefaultRestConfig(kubeconfig, "") if err != nil { log.Errorf("Failed setting up kubernetes client with kubeconfig %s", kubeconfig) return nil, err } log.Debugf("istio-cni set up kubernetes client with kubeconfig %s", kubeconfig) // Create the client
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Thu Aug 01 18:38:14 UTC 2024 - 3.7K bytes - Viewed (0) -
internal/config/compress/compress_test.go
testCase := testCase t.Run(testCase.str, func(t *testing.T) { gotPatterns, err := parseCompressIncludes(testCase.str) if !testCase.success && err == nil { t.Error("expected failure but success instead") } if testCase.success && err != nil { t.Errorf("expected success but failed instead %s", err) } if testCase.success && !reflect.DeepEqual(testCase.expectedPatterns, gotPatterns) {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Jun 01 21:59:40 UTC 2021 - 1.8K bytes - Viewed (0) -
cmd/batch-replicate_test.go
` var job BatchJobRequest err := yaml.Unmarshal([]byte(replicateYaml), &job) if err != nil { t.Fatal("Failed to parse batch-job-replicate yaml", err) } if !slices.Equal(job.Replicate.Source.Prefix.F(), []string{"object-prefix1"}) { t.Fatal("Failed to parse batch-job-replicate yaml", err) } multiPrefixReplicateYaml := ` replicate: apiVersion: v1
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Aug 01 12:53:30 UTC 2024 - 7.9K bytes - Viewed (0) -
internal/http/check_port_linux.go
} }) return nil }, } ctx, cancel := context.WithTimeout(context.Background(), time.Second) defer cancel() l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port)) if err != nil { return err } // As we are able to listen on this network, the port is not in use. // Close the listener and continue check other networks. return l.Close()
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed May 03 21:12:25 UTC 2023 - 1.9K bytes - Viewed (0) -
internal/config/drive/drive.go
} // LookupConfig - lookup config and override with valid environment settings if any. func LookupConfig(kvs config.KVS) (cfg Config, err error) { cfg = Config{ MaxTimeout: 30 * time.Second, } if err = config.CheckValidKeys(config.DriveSubSys, kvs, DefaultKVS); err != nil { return cfg, err } // if not set. Get default value from environment
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 3K bytes - Viewed (0)