Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 156 for neil (0.15 sec)

  1. istioctl/pkg/util/configdump/bootstrap.go

    	bootstrapDumpAny, err := w.getSection(bootstrap)
    	if err != nil {
    		return nil, err
    	}
    	bootstrapDump := &admin.BootstrapConfigDump{}
    	err = bootstrapDumpAny.UnmarshalTo(bootstrapDump)
    	if err != nil {
    		return nil, err
    	}
    	return bootstrapDump, nil
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Nov 03 08:41:32 GMT 2022
    - 1.1K bytes
    - Viewed (0)
  2. istioctl/pkg/util/configdump/util.go

    	var dumpAny *anypb.Any
    	for _, conf := range w.Configs {
    		if conf.TypeUrl == string(sectionTypeURL) {
    			dumpAny = conf
    		}
    	}
    	if dumpAny == nil {
    		return nil, fmt.Errorf("config dump has no configuration type %s", sectionTypeURL)
    	}
    
    	return dumpAny, nil
    }
    
    func (w *Wrapper) getSections(sectionTypeURL configTypeURL) ([]*anypb.Any, error) {
    	var dumpAny []*anypb.Any
    	for _, conf := range w.Configs {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sun Dec 24 08:16:26 GMT 2023
    - 2.1K bytes
    - Viewed (0)
  3. cni/pkg/pluginlistener/listener_test.go

    		var d net.Dialer
    		return d.DialContext(ctx, "unix", socket)
    	}))
    
    	conn, err := grpc.Dial(socket, opts...)
    	if err != nil {
    		return nil, err
    	}
    
    	return conn, nil
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Feb 08 21:58:32 GMT 2024
    - 1.4K bytes
    - Viewed (0)
  4. cni/pkg/iptables/iptables_linux.go

    		rules = append(rules, inpodMarkRule)
    	}
    
    	for _, rule := range rules {
    		log.Debugf("Iterating netlink rule : %+v", rule)
    		if err := f(rule); err != nil {
    			return fmt.Errorf("failed to configure netlink rule: %w", err)
    		}
    	}
    
    	return nil
    }
    
    func AddLoopbackRoutes(cfg *Config) error {
    	return forEachLoopbackRoute(cfg, netlink.RouteReplace)
    }
    
    func DelLoopbackRoutes(cfg *Config) error {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.3K bytes
    - Viewed (0)
  5. istioctl/pkg/writer/envoy/configdump/configdump_test.go

    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			cw := &ConfigWriter{}
    			cd, _ := os.ReadFile(tt.inputFile)
    			err := cw.Prime(cd)
    			if cw.configDump == nil {
    				if tt.wantConfigs != 0 {
    					t.Errorf("wanted some configs loaded but config dump was nil")
    				}
    			} else if len(cw.configDump.Configs) != tt.wantConfigs {
    				t.Errorf("wanted %v configs loaded in got %v", tt.wantConfigs, len(cw.configDump.Configs))
    			}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Jan 03 23:08:06 GMT 2024
    - 3.5K bytes
    - Viewed (0)
  6. cni/pkg/plugin/kubernetes.go

    	pod, err := client.CoreV1().Pods(podNamespace).Get(context.TODO(), podName, metav1.GetOptions{})
    	if err != nil {
    		return nil, err
    	}
    
    	pi := ExtractPodInfo(pod)
    	log.Debugf("Pod %v/%v info: \n%+v", podNamespace, podName, pi)
    
    	return pi, nil
    }
    
    func ExtractPodInfo(pod *v1.Pod) *PodInfo {
    	pi := &PodInfo{
    		Containers:        sets.New[string](),
    		Labels:            pod.Labels,
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Feb 10 00:31:55 GMT 2024
    - 3.6K bytes
    - Viewed (0)
  7. cni/pkg/iptables/nldeps.go

    	return &emptyDeps{}
    }
    
    func (r *emptyDeps) AddInpodMarkIPRule(cfg *Config) error {
    	return nil
    }
    
    func (r *emptyDeps) DelInpodMarkIPRule(cfg *Config) error {
    	return nil
    }
    
    func (r *emptyDeps) AddLoopbackRoutes(cfg *Config) error {
    	return nil
    }
    
    func (r *emptyDeps) DelLoopbackRoutes(cfg *Config) error {
    	return nil
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 1.6K bytes
    - Viewed (0)
  8. istioctl/pkg/tag/revision.go

    			}
    		}
    	}
    
    	return revisions, nil
    }
    
    func Webhooks(ctx context.Context, client kube.CLIClient) ([]admitv1.MutatingWebhookConfiguration, error) {
    	hooks, err := client.Kube().AdmissionregistrationV1().MutatingWebhookConfigurations().List(ctx, metav1.ListOptions{})
    	if err != nil {
    		return []admitv1.MutatingWebhookConfiguration{}, err
    	}
    	return hooks.Items, nil
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Jan 28 13:16:05 GMT 2023
    - 4.5K bytes
    - Viewed (0)
  9. istioctl/pkg/kubeinject/google.go

    	creds, err := google.FindDefaultCredentials(ctx, "https://www.googleapis.com/auth/cloud-platform")
    	if err != nil {
    		return nil, fmt.Errorf("finding default GCP credentials: %w", err)
    	}
    	return &oauth2.Transport{
    		Base:   tr,
    		Source: creds.TokenSource,
    	}, nil
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Jun 15 15:02:17 GMT 2023
    - 1.2K bytes
    - Viewed (0)
  10. istioctl/pkg/util/testutil/util.go

    	}
    
    	if c.ExpectedRegexp != nil && !c.ExpectedRegexp.MatchString(output) {
    		t.Fatalf("Output didn't match for '%s %s'\n got %v\nwant: %v", cmd.Name(),
    			strings.Join(c.Args, " "), output, c.ExpectedRegexp)
    	}
    
    	if c.GoldenFilename != "" {
    		util.CompareContent(t, []byte(output), c.GoldenFilename)
    	}
    
    	if c.WantException {
    		if fErr == nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Jun 15 15:02:17 GMT 2023
    - 2K bytes
    - Viewed (0)
Back to top