- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 117 for geturl (0.35 sec)
-
cni/pkg/nodeagent/net_test.go
ipProto, podUID, true, ).Return(nil) fixture.ipsetDeps.On("addIP", "foo-v4", netip.MustParseAddr("2.2.2.2"), ipProto, podUID, true, ).Return(nil) // List should return one IP not in our "pod snapshot", which means we prune fixture.ipsetDeps.On("listEntriesByIP", "foo-v4", ).Return([]netip.Addr{ netip.MustParseAddr("2.2.2.2"),
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
istioctl/pkg/util/configdump/cluster.go
if err != nil { return false } return name < cluster.Name }) if stripVersions { for i := range dac { dac[i].VersionInfo = "" dac[i].LastUpdated = nil } } return &admin.ClustersConfigDump{DynamicActiveClusters: dac}, nil } // GetClusterConfigDump retrieves the cluster config dump from the ConfigDump func (w *Wrapper) GetClusterConfigDump() (*admin.ClustersConfigDump, error) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 2.1K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/clusters.go
kubeClient, err := ctx.CLIClientWithRevision(opts.Revision) if err != nil { return err } res, err := kubeClient.AllDiscoveryDo(context.Background(), ctx.IstioNamespace(), "debug/clusterz") if err != nil { return err } return writeMulticlusterStatus(cmd.OutOrStdout(), res) }, } opts.AttachControlPlaneFlags(cmd) return cmd } func writeMulticlusterStatus(out io.Writer, input map[string][]byte) error {
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) -
istioctl/pkg/xds/client.go
}, }, nil) if err != nil { return nil, fmt.Errorf("could not dial: %w", err) } err = adscConn.Run() if err != nil { return nil, fmt.Errorf("ADSC: failed running %v", err) } err = adscConn.Send(dr) if err != nil { return nil, err } response, err := adscConn.WaitVersion(opts.Timeout, dr.TypeUrl, "") return response, err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Dec 19 22:42:42 GMT 2023 - 3.7K bytes - Viewed (0) -
cni/test/install_cni.go
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) { return fmt.Errorf("expected != result. Diff: %v", cmp.Diff(string(expectedFile), string(resultFile))) } return nil }
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
} }() 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 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 01:05:12 GMT 2023 - 3.3K bytes - Viewed (0) -
cni/pkg/pluginlistener/listener.go
listener, err := net.Listen("unix", path) if err != nil { return nil, fmt.Errorf("failed to listen on unix socket %q: %v", path, err) } // Update file permission so that cni plugin has permission to access it. if _, err := os.Stat(path); err != nil { return nil, fmt.Errorf("cni listener file %q doesn't exist", path) } if err := os.Chmod(path, 0o666); err != nil { return nil, fmt.Errorf("failed to update %q permission", path) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 1.7K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
if err := cfg.addLoopbackRoute(); err != nil { return err } if err := cfg.addInpodMarkIPRule(); err != nil { return err } log.Debug("Adding iptables rules") if err := cfg.executeCommands(builder); err != nil { log.Errorf("failed to restore iptables rules: %v", err) return err } return nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 07 19:54:50 GMT 2024 - 19.7K bytes - Viewed (0) -
cni/pkg/nodeagent/netns_other.go
func inodeForFd(n NetnsFd) (uint64, error) { return 0, errors.New("not implemented") } func NetnsSet(n NetnsFd) error { return errors.New("not implemented") } func OpenNetns(nspath string) (NetnsCloser, error) { return nil, errors.New("not implemented") } // inspired by netns.Do() but with an existing fd. func NetnsDo(fdable NetnsFd, toRun func() error) error { return errors.New("not implemented")
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Mar 14 09:32:25 GMT 2024 - 1K bytes - Viewed (0) -
istioctl/pkg/util/common.go
Err error } func (c CommandParseError) Error() string { return c.Err.Error() } // Confirm waits for a user to confirm with the supplied message. func Confirm(msg string, writer io.Writer) bool { for { _, _ = fmt.Fprintf(writer, "%s ", msg) var response string _, err := fmt.Scanln(&response) if err != nil { return false } switch strings.ToUpper(response) { case "Y", "YES":
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 1.6K bytes - Viewed (0)