- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 269 for cout (0.16 sec)
-
cmd/xl-storage.go
// platforms, look for this value as NAME_MAX in // /usr/include/linux/limits.h var count int64 for _, p := range pathName { switch p { case '/': count = 0 // Reset case '\\': if runtime.GOOS == globalWindowsOSName { count = 0 } default: count++ if count > 255 { return errFileNameTooLong } } } // Success. return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/policies.go
return r } return cmp.Compare(a.Name, b.Name) }) out, err := json.MarshalIndent(policies, "", " ") if err != nil { return fmt.Errorf("failed to marshal policies: %v", err) } if outputFormat == "yaml" { if out, err = yaml.JSONToYAML(out); err != nil { return err } } fmt.Fprintln(c.Stdout, string(out)) return nil
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 2.5K bytes - Viewed (0) -
cmd/erasure-sets_test.go
testCases := []struct { objectName string sipHash int }{ // cases which should pass the test. // passing in valid object name. {"object", 37}, {"The Shining Script <v1>.pdf", 38}, {"Cost Benefit Analysis (2009-2010).pptx", 59}, {"117Gn8rfHL2ACARPAhaFd0AGzic9pUbIA/5OCn5A", 35}, {"SHØRT", 49}, {"There are far too many object names, and far too few bucket names!", 8}, {"a/b/c/", 159}, {"/a/b/c", 96},
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 12 07:21:56 GMT 2024 - 6.9K bytes - Viewed (0) -
docs/iam/access-manager-plugin.go
} func mainHandler(w http.ResponseWriter, r *http.Request) { body, err := io.ReadAll(r.Body) if err != nil { writeErrorResponse(w, err) return } var out bytes.Buffer json.Indent(&out, body, "", " ") fmt.Printf("Received JSON payload:\n%s\n", out.String()) reqMap := make(map[string]interface{}) err = json.Unmarshal(body, &reqMap) if err != nil { writeErrorResponse(w, err) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 08 17:15:20 GMT 2024 - 2.7K bytes - Viewed (0) -
internal/grid/errors.go
// ErrHandlerAlreadyExists is returned when a handler is already registered. ErrHandlerAlreadyExists = errors.New("mux handler already exists") // ErrIncorrectSequence is returned when an out-of-sequence item is received. ErrIncorrectSequence = errors.New("out-of-sequence item received") ) // ErrResponse is a remote error response. type ErrResponse struct { msg string } func (e ErrResponse) Error() string {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 1.4K bytes - Viewed (0) -
src/archive/zip/example_test.go
buf := new(bytes.Buffer) // Create a new zip archive. w := zip.NewWriter(buf) // Register a custom Deflate compressor. w.RegisterCompressor(zip.Deflate, func(out io.Writer) (io.WriteCloser, error) { return flate.NewWriter(out, flate.BestCompression) }) // Proceed to add files to w.
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Jan 27 00:22:03 GMT 2016 - 2K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/clusters.go
}, } opts.AttachControlPlaneFlags(cmd) return cmd } func writeMulticlusterStatus(out io.Writer, input map[string][]byte) error { statuses, err := parseClusterStatuses(input) if err != nil { return err } w := new(tabwriter.Writer).Init(out, 0, 8, 5, ' ', 0) _, _ = fmt.Fprintln(w, "NAME\tSECRET\tSTATUS\tISTIOD") for istiod, clusters := range statuses {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 2.3K bytes - Viewed (0) -
cmd/admin-handlers-config-kv.go
if objectAPI == nil { return } vars := mux.Vars(r) count, err := strconv.Atoi(vars["count"]) if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } chEntries, err := listServerConfigHistory(ctx, objectAPI, true, count) if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.7K bytes - Viewed (0) -
cni/pkg/install/kubeconfig_test.go
tempDir := t.TempDir() cfg := &config.InstallConfig{ MountedCNINetDir: tempDir, KubeCAFile: kubeCAFilepath, K8sServiceHost: k8sServiceHost, K8sServicePort: k8sServicePort, } // Write out a kubeconfig with one cert result, err := createKubeConfig(cfg) if err != nil { t.Fatalf("did not expect failure: %v", err) } goldenFilepath := "testdata/kubeconfig-tls"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 03:52:24 GMT 2024 - 5.1K bytes - Viewed (0) -
internal/grid/muxclient.go
// req may not be read/written to after calling. // TODO: Not implemented func (m *muxClient) RequestStateless(h HandlerID, req []byte, out chan<- Response) { if m.init { out <- Response{Err: errors.New("mux client already used")} } m.init = true // Try to grab an initial block. m.singleResp = false msg := message{ Op: OpConnectMux,
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)