- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for read (3.71 sec)
-
cni/pkg/repair/netns.go
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Dec 20 22:14:13 GMT 2023 - 4.8K bytes - Viewed (0) -
operator/cmd/mesh/manifest-diff.go
) (bool, error) { a, err := os.ReadFile(args[0]) if err != nil { return false, fmt.Errorf("could not read %q: %v", args[0], err) } b, err := os.ReadFile(args[1]) if err != nil { return false, fmt.Errorf("could not read %q: %v", args[1], err) } diff, err := compare.ManifestDiffWithRenameSelectIgnore(string(a), string(b), renameResources, selectResources,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 5.8K bytes - Viewed (0) -
cni/test/install_cni.go
func checkResult(result, expected string) error { resultFile, err := os.ReadFile(result) if err != nil { return fmt.Errorf("couldn't read result: %v", err) } expectedFile, err := os.ReadFile(expected) if err != nil { return fmt.Errorf("couldn't read expected: %v", err) } if !bytes.Equal(resultFile, expectedFile) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
cni/pkg/log/uds.go
} 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) err := json.Unmarshal(body, &cniLogs) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 01:05:12 GMT 2023 - 3.3K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
// Safety: Resp is buffered, so this will not block update.Resp <- updateResponse{ 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.
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) -
cni/pkg/nodeagent/ztunnelserver_test.go
setupLogging() ctx, cancel := context.WithCancel(context.Background()) defer cancel() fixture := connect(ctx) ztunClient := fixture.ztunClient uid := fixture.uid // read initial pod add readRequest(t, ztunClient) sendAck(ztunClient) // read snapshot sent m, fds := readRequest(t, ztunClient) assert.Equal(t, len(fds), 0) sent := m.Payload.(*zdsapi.WorkloadRequest_SnapshotSent).SnapshotSent if sent == nil {
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) -
istioctl/pkg/checkinject/checkinject.go
for _, ws := range was { if ws.Injected { injectedTotal++ } w.AddRow(ws) } w.Flush() if injectedTotal > 1 { fmt.Fprintf(writer, "ERROR: multiple webhooks will inject, which can lead to errors") } return nil } type webhookAnalysis struct { Name string Revision string Injected bool Reason string }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 9.3K bytes - Viewed (0) -
istioctl/pkg/root/root.go
// limitations under the License. package root import ( "istio.io/istio/pkg/env" "istio.io/istio/pkg/log" ) const ( // Location to read istioctl defaults from defaultIstioctlConfig = "$HOME/.istioctl/config.yaml" ) var ( // IstioConfig is the name of the istioctl config file (if any) IstioConfig = env.Register("ISTIOCONFIG", defaultIstioctlConfig,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Mar 26 20:38:10 GMT 2024 - 1.5K bytes - Viewed (0) -
istioctl/pkg/validate/validate.go
var err error if path == "-" { reader = io.NopCloser(os.Stdin) } else { reader, err = os.Open(path) if err != nil { errs = multierror.Append(errs, fmt.Errorf("cannot read file %q: %v", path, err)) return } } warning, err := v.validateFile(path, istioNamespace, defaultNamespace, reader, writer) if err != nil { errs = multierror.Append(errs, err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Jan 22 17:58:52 GMT 2024 - 15K bytes - Viewed (0) -
istioctl/pkg/kubeinject/kubeinject.go
} meshConfigMap, err := client.Kube().CoreV1().ConfigMaps(ctx.IstioNamespace()).Get(context.TODO(), meshConfigMapName, metav1.GetOptions{}) if err != nil { return nil, fmt.Errorf("could not read valid configmap %q from namespace %q: %v - "+ "Use --meshConfigFile or re-run "+command+" with `-i <istioSystemNamespace> and ensure valid MeshConfig exists", meshConfigMapName, ctx.IstioNamespace(), err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 21.6K bytes - Viewed (0)