- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for read_all (0.2 sec)
-
cni/pkg/log/uds_test.go
_ = log.Sync() // Restore os stdout. os.Stdout = stdout assert.NoError(t, log.Configure(loggingOptions)) assert.NoError(t, w.Close()) out, err := io.ReadAll(r) assert.NoError(t, err) // For each level, there should be two lines, one from direct log, // the other one from UDS server wantLevels := []string{"debug", "info", "warn", "error", "debug", "info", "warn", "error"}
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Mar 16 00:20:01 GMT 2024 - 2.5K bytes - Viewed (0) -
istioctl/pkg/proxystatus/proxystatus.go
if err != nil { return nil, err } } defer func() { if err := file.Close(); err != nil { log.Errorf("failed to close %s: %s", filename, err) } }() data, err := io.ReadAll(file) if err != nil { return nil, err } return data, nil } func StableXdsStatusCommand(ctx cli.Context) *cobra.Command { cmd := XdsStatusCommand(ctx)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 6.2K bytes - Viewed (0) -
istioctl/pkg/kubeinject/kubeinject.go
if err != nil { return nil, err } resp, err := client.Post(address, "application/json", bytes.NewBuffer(revBytes)) if err != nil { return nil, err } defer resp.Body.Close() body, err := io.ReadAll(resp.Body) if err != nil { return nil, err } var obj runtime.Object var ar *kube.AdmissionReview out, _, err := deserializer.Decode(body, nil, obj) if err != nil {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 21.6K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig.go
if err != nil { return nil, err } } defer func() { if err := file.Close(); err != nil { log.Errorf("failed to close %s: %s", filename, err) } }() return io.ReadAll(file) } func setupFileConfigdumpWriter(filename string, out io.Writer) (*configdump.ConfigWriter, error) { data, err := readFile(filename) if err != nil { return nil, err }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 16 03:28:36 GMT 2024 - 48K bytes - Viewed (0) -
cni/pkg/log/uds.go
} }() return nil } func (l *UDSLogger) handleLog(w http.ResponseWriter, req *http.Request) { if req.Body == nil { return } defer req.Body.Close() data, err := io.ReadAll(req.Body) if err != nil { log.Errorf("Failed to read log report from cni plugin: %v", err) return } l.processLog(data) } func (l *UDSLogger) processLog(body []byte) { cniLogs := make([]string, 0)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Nov 29 01:05:12 GMT 2023 - 3.3K bytes - Viewed (0) -
istioctl/pkg/authz/authz.go
if err != nil { return nil, err } defer func() { if err := file.Close(); err != nil { log.Errorf("failed to close %s: %s", filename, err) } }() data, err := io.ReadAll(file) if err != nil { return nil, err } envoyConfig := &configdump.Wrapper{} if err := envoyConfig.UnmarshalJSON(data); err != nil { return nil, fmt.Errorf("failed to unmarshal proxy config: %s", err)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 5K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/secret_test.go
} defer configDumpFile.Close() configDump, err := io.ReadAll(configDumpFile) if err != nil { t.Errorf("error reading test data file: %v", err) } outFile, err := os.Open("testdata/secret/output") if err != nil { t.Errorf("error opening test data output file: %v", err) } defer outFile.Close() expectedOut, err := io.ReadAll(outFile) if err != nil {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Jun 06 15:14:48 GMT 2023 - 1.5K bytes - Viewed (0) -
cni/pkg/plugin/cnieventclient_test.go
testServer := httptest.NewServer(http.HandlerFunc(func(res http.ResponseWriter, req *http.Request) { defer req.Body.Close() data, err := io.ReadAll(req.Body) assert.NoError(t, err) var msg nodeagent.CNIPluginAddEvent err = json.Unmarshal(data, &msg) assert.NoError(t, err) assert.Equal(t, msg.PodName, testPod)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 4.2K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
if req.Body == nil { log.Error("empty request body") http.Error(w, "empty request body", http.StatusBadRequest) return } defer req.Body.Close() data, err := io.ReadAll(req.Body) if err != nil { log.Errorf("Failed to read event report from cni plugin: %v", err) http.Error(w, err.Error(), http.StatusInternalServerError) return } msg, err := processAddEvent(data)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 6.1K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
if err != nil { return nil, err } } defer func() { if err := file.Close(); err != nil { log.Errorf("failed to close %s: %s", filename, err) } }() return io.ReadAll(file) } func extractZtunnelConfigDump(kubeClient kube.CLIClient, podName, podNamespace string) ([]byte, error) { path := "config_dump"
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed May 01 13:11:40 GMT 2024 - 22.2K bytes - Viewed (0)