- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 37 for Franke (0.38 sec)
-
cni/test/install_cni.go
t.Helper() t.Logf("Pre-populating working dirs") for i, f := range cniDirOrderedFiles { destFilenm := fmt.Sprintf("0%d-%s", i, f) t.Logf("Copying %v into temp config dir %v/%s", f, tempCNIConfDir, destFilenm) cp(wd+cniConfSubDir+f, tempCNIConfDir+"/"+destFilenm, t) } for _, f := range ls(wd+k8sSvcAcctSubDir, t) { t.Logf("Copying %v into temp k8s serviceaccount dir %v", f, tempK8sSvcAcctDir)
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/iptables/iptables.go
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...)) } for _, cmd := range optionalDeleteCmds { err := cfg.ext.Run(iptablesconstants.IPTables, &iptVer, nil, cmd...) if err != 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/install/cniconfig.go
switch { case err != nil: return "", err case len(files) == 0: return "", fmt.Errorf("no networks found in %s", confDir) } sort.Strings(files) for _, confFile := range files { var confList *libcni.NetworkConfigList if strings.HasSuffix(confFile, ".conflist") { confList, err = libcni.ConfListFromFile(confFile) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.4K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
if err != nil { return err } log.Debugf("sending delete pod to ztunnel: %s %v", uid, r) var delErr []error z.conns.mu.Lock() defer z.conns.mu.Unlock() for conn := range z.conns.connectionSet { _, err := conn.send(ctx, data, nil) if err != nil { delErr = append(delErr, err) } } return errors.Join(delErr...) }
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/dashboard/dashboard.go
var portPrefs []int if listenPort != 0 { portPrefs = []int{listenPort} } else { portPrefs = []int{remotePort, 0} } var err error for _, localPort := range portPrefs { var fw kube.PortForwarder fw, err = client.NewPortForwarder(podName, namespace, localAddress, localPort, remotePort) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
) func setupLogging() { opts := istiolog.DefaultOptions() opts.SetDefaultOutputLevel(istiolog.OverrideScopeName, istiolog.DebugLevel) istiolog.Configure(opts) for _, scope := range istiolog.Scopes() { scope.SetOutputLevel(istiolog.DebugLevel) } } type netTestFixture struct { netServer *NetServer podNsMap *podNetnsCache ztunnelServer *fakeZtunnel
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) -
cni/pkg/plugin/plugin_test.go
want: []string{}, }, { name: "Non-parseable", args: args{ports: []string{"abcd", "2345", "abcd"}}, want: []string{"abcd", "2345"}, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { if got := dedupPorts(tt.args.ports); !reflect.DeepEqual(got, tt.want) { t.Errorf("dedupPorts() = %v, want %v", got, tt.want) } }) }
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) -
istioctl/pkg/validate/validate.go
processedFiles[path] = true }); err != nil { errs = multierror.Append(errs, err) } } filenames = []string{} for p := range processedFiles { filenames = append(filenames, p) } if errs != nil { // Display warnings we encountered as well for _, fname := range filenames { if w := warningsByFilename[fname]; w != nil { if fname == "-" { _, _ = fmt.Fprint(writer, warningToString(w))
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/admin/istiodconfig.go
scopeName string }, len(scopes)) var wg sync.WaitGroup for _, scope := range scopes { wg.Add(1) go func(si *ScopeInfo) { defer wg.Done() err := c.PutScope(si) ch <- struct { err error scopeName string }{err: err, scopeName: si.Name} }(scope) } wg.Wait() close(ch) for result := range ch { if result.err != 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
enabledComponents = append(enabledComponents, name.UserFacingComponentName(c)) } } for _, c := range iop.Spec.Components.IngressGateways { if c.Enabled.GetValue() { enabledComponents = append(enabledComponents, name.UserFacingComponentName(name.IngressComponentName)) break } } for _, c := range iop.Spec.Components.EgressGateways { if c.Enabled.GetValue() {
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)