- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for interfaces (0.2 sec)
-
cni/pkg/plugin/plugin_test.go
}, "prevResult": { "cniversion": "%s", "interfaces": [ { "name": "%s", "sandbox": "%s" } ], "ips": [ { "version": "4", "address": "10.0.0.2/24", "gateway": "10.0.0.1", "interface": 0 } ], "routes": [] },
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 17.5K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
readWriteDeadline = 5 * time.Second ) var ztunnelConnected = monitoring.NewGauge("ztunnel_connected", "number of connections to ztunnel") type ZtunnelServer interface { Run(ctx context.Context) PodDeleted(ctx context.Context, uid string) error PodAdded(ctx context.Context, pod *v1.Pod, netns Netns) error Close() error } /* To clean up stale ztunnels
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) -
istioctl/pkg/admin/istiodconfig.go
"sigs.k8s.io/yaml" "istio.io/api/label" "istio.io/istio/istioctl/pkg/cli" "istio.io/istio/istioctl/pkg/clioptions" "istio.io/istio/istioctl/pkg/completion" "istio.io/istio/pkg/log" ) type flagState interface { run(out io.Writer) error } var ( _ flagState = (*resetState)(nil) _ flagState = (*logLevelState)(nil) _ flagState = (*stackTraceLevelState)(nil) _ flagState = (*getAllLogLevelsState)(nil) )
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 13.5K bytes - Viewed (0) -
operator/cmd/mesh/install.go
} if iop.Spec.Revision != "" { ret += "-" + iop.Spec.Revision } return ret } // detectIstioVersionDiff will show warning if istioctl version and control plane version are different // nolint: interfacer func detectIstioVersionDiff(p Printer, tag string, ns string, kubeClient kube.CLIClient, iop *v1alpha12.IstioOperator) error { warnMarker := color.New(color.FgYellow).Add(color.Italic).Sprint("WARNING:")
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 14:30:43 GMT 2024 - 15.5K bytes - Viewed (1) -
istioctl/pkg/kubeinject/kubeinject.go
func GetFirstPod(client v1.CoreV1Interface, namespace string, selector string) (*corev1.Pod, error) { options := metav1.ListOptions{LabelSelector: selector} sortBy := func(pods []*corev1.Pod) sort.Interface { return sort.Reverse(podutils.ActivePods(pods)) } podList, err := client.Pods(namespace).List(context.TODO(), options) if err != nil { return nil, err } pods := make([]*corev1.Pod, 0, len(podList.Items))
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) -
istioctl/pkg/tag/tag.go
} return nil } // removeTag removes an existing revision tag. func removeTag(ctx context.Context, kubeClient kubernetes.Interface, tagName string, skipConfirmation bool, w io.Writer) error { webhooks, err := GetWebhooksWithTag(ctx, kubeClient, tagName) if err != nil { return fmt.Errorf("failed to retrieve tag with name %s: %v", tagName, err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 16.3K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
if err := doAddRun(args, conf, client, IptablesInterceptRuleMgr()); err != nil { return err } return pluginResponse(conf) } func doAddRun(args *skel.CmdArgs, conf *Config, kClient kubernetes.Interface, rulesMgr InterceptRuleMgr) error { setupLogging(conf) var loggedPrevResult any if conf.PrevResult == nil { loggedPrevResult = "none" } else { loggedPrevResult = conf.PrevResult }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 10.5K bytes - Viewed (0) -
operator/cmd/mesh/test-util_test.go
} // HavePathValueEqual matches map[string]interface{} tree against a PathValue. func HavePathValueEqual(expected any) types.GomegaMatcher { return &HavePathValueEqualMatcher{ expected: expected, } } // HavePathValueEqualMatcher is a matcher type for HavePathValueEqual. type HavePathValueEqualMatcher struct { expected any } // Match implements the Matcher interface.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Oct 31 14:48:28 GMT 2023 - 15.3K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret.go
return nil }, } opts.addFlags(c.PersistentFlags()) return c } func createRemoteServiceAccountSecret(kubeconfig *api.Config, clusterName, secName string) (*v1.Secret, error) { // nolint:interfacer var data bytes.Buffer if err := latest.Codec.Encode(kubeconfig, &data); err != nil { return nil, err } key := clusterName if secName == configSecretName { key = configSecretKey }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Oct 11 01:43:17 GMT 2023 - 24K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns.go
"istio.io/istio/pkg/util/sets" ) type PodToNetns map[string]WorkloadInfo func (p PodToNetns) Close() { for _, wl := range p { wl.Netns.Close() } } type PodNetnsFinder interface { FindNetnsForPods(filter map[types.UID]*corev1.Pod) (PodToNetns, error) } type PodNetnsProcFinder struct { proc fs.FS } func NewPodNetnsProcFinder(proc fs.FS) *PodNetnsProcFinder {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 11K bytes - Viewed (0)