- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 98 for Append (0.15 sec)
-
cni/pkg/iptables/iptables.go
} var delErrs []error iptablesVariant := []dep.IptablesVersion{} iptablesVariant = append(iptablesVariant, cfg.iptV) if cfg.cfg.EnableIPv6 { iptablesVariant = append(iptablesVariant, cfg.ipt6V) } for _, iptVer := range iptablesVariant { for _, cmd := range deleteCmds { delErrs = append(delErrs, cfg.ext.Run(iptablesconstants.IPTables, &iptVer, nil, cmd...)) }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 19.6K bytes - Viewed (0) -
istioctl/pkg/completion/completion.go
if err != nil { return nil, err } var podsName []string for _, pod := range podList.Items { if toComplete == "" || strings.HasPrefix(pod.Name, toComplete) { podsName = append(podsName, pod.Name) } } return podsName, nil } func ValidPodsNameArgs(ctx cli.Context) func(_ *cobra.Command, args []string, toComplete string) ([]string, cobra.ShellCompDirective) {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 4.9K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status.go
} if s.Namespace != "" && meta.Namespace != s.Namespace { continue } cds, lds, eds, rds, ecds := getSyncStatus(&clientConfig) cp := multixds.CpInfo(dr) fullStatus = append(fullStatus, &xdsWriterStatus{ proxyID: clientConfig.GetNode().GetId(), clusterID: meta.ClusterID.String(), istiodID: cp.ID, istiodVersion: meta.IstioVersion,
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.1K bytes - Viewed (0) -
operator/cmd/mesh/operator_test.go
t.Run("", func(t *testing.T) { args := []string{"operator", "init", "--dry-run"} if test.operatorNamespace != "" { args = append(args, "--operatorNamespace", test.operatorNamespace) } if test.watchedNamespaces != "" { args = append(args, "--watchedNamespaces", test.watchedNamespaces) } kubeClientFunc = func() (kube.CLIClient, error) { return nil, nil }
Go - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Tue Aug 29 14:15:33 GMT 2023 - 6.4K bytes - Viewed (0) -
operator/cmd/mesh/manifest-generate.go
// This allows func orderedManifests(mm name.ManifestMap) ([]string, error) { var rawOutput []string var output []string for _, mfs := range mm { rawOutput = append(rawOutput, mfs...) } objects, err := object.ParseK8sObjectsFromYAMLManifest(strings.Join(rawOutput, helm.YAMLSeparator)) if err != nil { return nil, err }
Go - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 8.5K bytes - Viewed (0) -
cni/pkg/plugin/plugin_test.go
Labels: map[string]string{}, }, } return fakePod, fakeNS } func (mrdir *mockInterceptRuleMgr) Program(podName, netns string, redirect *Redirect) error { mrdir.lastRedirect = append(mrdir.lastRedirect, redirect) return nil } // returns the test server URL and a dispose func for the test server func setupCNIEventClientWithMockServer(serverErr bool) (string, func() bool) {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 17.5K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/ecds_test.go
var rm json.RawMessage = gotOut.Bytes() jsonOutput, err := json.MarshalIndent(rm, "", " ") if err != nil { assert.NoError(t, err) } jsonOutput = append(jsonOutput, '\n') util.CompareContent(t, jsonOutput, "testdata/ecds/output.json")
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Dec 13 01:08:07 GMT 2022 - 1.9K bytes - Viewed (0) -
cni/pkg/install/cniconfig.go
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.4K bytes - Viewed (0) -
cni/pkg/log/uds.go
var msg cniLog if err := json.Unmarshal([]byte(l), &msg); err != nil { log.Debugf("Failed to unmarshal CNI plugin log entry: %v", err) continue } msg.Msg = strings.TrimSpace(msg.Msg) messages = append(messages, msg) } // Lock log message printing to prevent log messages from different CNI // processes interleave. l.mu.Lock() defer l.mu.Unlock() for _, m := range messages {
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) -
operator/cmd/mesh/operator-init.go
} // create watched namespaces namespaces := strings.Split(oiArgs.common.watchedNamespaces, ",") // if the namespace in the CR is provided, consider creating it too. if istioNamespace != "" { namespaces = append(namespaces, istioNamespace) } for _, ns := range namespaces { if err := operatorutil.CreateNamespace(kubeClient.Kube(), ns, "", opts.DryRun); err != nil { l.LogAndFatal(err) } }
Go - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 6.2K bytes - Viewed (0)