Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for Spring (0.18 sec)

  1. cni/pkg/config/config.go

    	b.WriteString("LogUDSAddress: " + fmt.Sprint(c.LogUDSAddress) + "\n")
    
    	b.WriteString("AmbientEnabled: " + fmt.Sprint(c.AmbientEnabled) + "\n")
    	b.WriteString("AmbientDNSCapture: " + fmt.Sprint(c.AmbientDNSCapture) + "\n")
    	b.WriteString("AmbientIPv6: " + fmt.Sprint(c.AmbientIPv6) + "\n")
    
    	return b.String()
    }
    
    func (c RepairConfig) String() string {
    	var b strings.Builder
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 5.5K bytes
    - Viewed (0)
  2. cni/pkg/ipset/nldeps_unspecified.go

    }
    
    type realDeps struct{}
    
    func (m *realDeps) ipsetIPHashCreate(name string, v6 bool) error {
    	return errors.New("not implemented on this platform")
    }
    
    func (m *realDeps) destroySet(name string) error {
    	return errors.New("not implemented on this platform")
    }
    
    func (m *realDeps) addIP(name string, ip netip.Addr, ipProto uint8, comment string, replace bool) error {
    	return errors.New("not implemented on this platform")
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  3. cni/pkg/iptables/iptables_linux.go

    	loopbackLink, err := netlink.LinkByName("lo")
    	if err != nil {
    		return fmt.Errorf("failed to find 'lo' link: %v", err)
    	}
    
    	// Set up netlink routes for localhost
    	cidrs := []string{"0.0.0.0/0"}
    	if cfg.EnableIPv6 {
    		cidrs = append(cidrs, "0::0/0")
    	}
    	for _, fullCIDR := range cidrs {
    		_, localhostDst, err := net.ParseCIDR(fullCIDR)
    		if err != nil {
    			return fmt.Errorf("parse CIDR: %v", err)
    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)
  4. istioctl/pkg/writer/ztunnel/configdump/certificates.go

    					secret.Identity, t, secret.State, certNotExpired(ca), n, valueOrNA(ca.ExpirationTime), valueOrNA(ca.ValidFrom))
    			}
    		}
    	}
    	return w.Flush()
    }
    
    func valueOrNA(value string) string {
    	if value == "" {
    		return "NA"
    	}
    	return value
    }
    
    func certNotExpired(cert *Cert) bool {
    	// case where cert state is in either Initializing or Unavailable state
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Apr 25 16:38:16 GMT 2024
    - 3.2K bytes
    - Viewed (0)
  5. cni/pkg/ipset/nldeps_linux.go

    		return nil
    	}
    
    	return err
    }
    
    func (m *realDeps) destroySet(name string) error {
    	err := netlink.IpsetDestroy(name)
    	return err
    }
    
    func (m *realDeps) addIP(name string, ip netip.Addr, ipProto uint8, comment string, replace bool) error {
    	err := netlink.IpsetAdd(name, &netlink.IPSetEntry{
    		Comment:  comment,
    		IP:       net.IP(ip.AsSlice()),
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/server.go

    	ConstructInitialSnapshot(ambientPods []*corev1.Pod) error
    	Start(ctx context.Context)
    
    	//	IsPodInMesh(ctx context.Context, pod *metav1.ObjectMeta, netNs string) (bool, error)
    	AddPodToMesh(ctx context.Context, pod *corev1.Pod, podIPs []netip.Addr, netNs string) error
    	RemovePodFromMesh(ctx context.Context, pod *corev1.Pod) error
    	DelPodFromMesh(ctx context.Context, pod *corev1.Pod) error
    
    	Stop()
    }
    
    type Server struct {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  7. cni/pkg/util/podutil_test.go

    }
    
    func TestPodRedirectionEnabled(t *testing.T) {
    	var (
    		ambientEnabledLabel     = map[string]string{constants.DataplaneModeLabel: constants.DataplaneModeAmbient}
    		ambientDisabledLabel    = map[string]string{constants.DataplaneModeLabel: constants.DataplaneModeNone}
    		sidecarStatusAnnotation = map[string]string{annotation.SidecarStatus.Name: "test"}
    
    		namespaceWithAmbientEnabledLabel = &corev1.Namespace{
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 4.9K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/informers.go

    		}
    	}
    	return nil
    }
    
    func getModeLabel(m map[string]string) string {
    	if m == nil {
    		return ""
    	}
    	return m[constants.DataplaneModeLabel]
    }
    
    func (s *InformerHandlers) reconcilePod(input any) error {
    	event := input.(controllers.Event)
    	pod := event.Latest().(*corev1.Pod)
    
    	defer EventTotals.With(eventTypeTag.Value(event.Event.String())).Increment()
    
    	switch event.Event {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 9.6K bytes
    - Viewed (0)
  9. cni/pkg/ipset/nldeps_mock.go

    	return &MockedIpsetDeps{}
    }
    
    func (m *MockedIpsetDeps) ipsetIPHashCreate(name string, v6 bool) error {
    	args := m.Called(name, v6)
    	return args.Error(0)
    }
    
    func (m *MockedIpsetDeps) destroySet(name string) error {
    	args := m.Called(name)
    	return args.Error(0)
    }
    
    func (m *MockedIpsetDeps) addIP(name string, ip netip.Addr, ipProto uint8, comment string, replace bool) error {
    	args := m.Called(name, ip, ipProto, comment, replace)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 1.8K bytes
    - Viewed (0)
  10. cni/pkg/iptables/iptables_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    
    	compareToGolden(t, false, tt.name, ext.ExecutedAll)
    }
    
    func ipstr(ipv6 bool) string {
    	if ipv6 {
    		return "ipv6"
    	}
    	return "ipv4"
    }
    
    func compareToGolden(t *testing.T, ipv6 bool, name string, actual []string) {
    	t.Helper()
    	gotBytes := []byte(strings.Join(actual, "\n"))
    	goldenFile := filepath.Join("testdata", name+".golden")
    	if ipv6 {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.7K bytes
    - Viewed (0)
Back to top