Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for delete (0.15 sec)

  1. cni/pkg/nodeagent/net.go

    	}
    
    	log.Debug("in pod mode - removing pod from ztunnel")
    	if err := s.ztunnelServer.PodDeleted(ctx, string(pod.UID)); err != nil {
    		log.Errorf("failed to delete pod from ztunnel: %v", err)
    	}
    	return nil
    }
    
    // Delete pod from mesh: pod is deleted. iptables rules will die with it, we just need to update ztunnel
    func (s *NetServer) DelPodFromMesh(ctx context.Context, pod *corev1.Pod) error {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 12.2K bytes
    - Viewed (1)
  2. cni/pkg/nodeagent/server.go

    	}
    	return err
    }
    
    // Delete pod from mesh: pod is deleted. iptables rules will die with it, we just need to update ztunnel
    func (s *meshDataplane) DelPodFromMesh(ctx context.Context, pod *corev1.Pod) error {
    	log := log.WithLabels("ns", pod.Namespace, "name", pod.Name)
    	err := s.netServer.DelPodFromMesh(ctx, pod)
    	if err != nil {
    		log.Errorf("failed to delete pod from mesh: %v", err)
    		return err
    	}
    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)
  3. cni/pkg/nodeagent/pod_cache.go

    func (p *podNetnsCache) Take(uid string) Netns {
    	// lock current pod map
    	p.mu.Lock()
    	defer p.mu.Unlock()
    	if ns, ok := p.currentPodCache[uid]; ok {
    		delete(p.currentPodCache, uid)
    		// already in cache
    		return ns.Netns
    	}
    
    	return nil
    }
    
    func openNetnsInRoot(hostMountsPath string) func(nspath string) (NetnsCloser, error) {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 4.5K bytes
    - Viewed (0)
  4. 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...)
    }
    
    func podToWorkload(pod *v1.Pod) *zdsapi.WorkloadInfo {
    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)
  5. cni/pkg/iptables/iptables.go

    	}
    	return nil
    }
    
    func (cfg *IptablesConfigurator) DeleteHostRules() {
    	log.Debug("Attempting to delete hostside iptables rules (if they exist)")
    
    	cfg.executeHostDeleteCommands()
    }
    
    func (cfg *IptablesConfigurator) executeHostDeleteCommands() {
    	optionalDeleteCmds := [][]string{
    		// delete our main jump in the host ruleset. If it's not there, NBD.
    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)
  6. cni/pkg/install/cniconfig.go

    	if err != nil {
    		return nil, fmt.Errorf("error loading existing CNI config (JSON error): %v", err)
    	}
    
    	delete(istioMap, "cniVersion")
    
    	var newMap map[string]any
    
    	if _, ok := existingMap["type"]; ok {
    		// Assume it is a regular network conf file
    		delete(existingMap, "cniVersion")
    
    		plugins := make([]map[string]any, 2)
    		plugins[0] = existingMap
    		plugins[1] = istioMap
    
    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)
  7. cni/pkg/nodeagent/net_test.go

    	fixture.podNsMap.UpsertPodCacheWithNetns(string(pod.UID), workload)
    	err := netServer.DelPodFromMesh(ctx, pod)
    	assert.NoError(t, err)
    	assert.Equal(t, ztunnelServer.deletedPods.Load(), 1)
    	// with delete iptables is not called, as there is no need to delete the iptables rules
    	// from a pod that's gone from the cluster.
    	assert.Equal(t, nlDeps.DelInpodMarkIPRuleCnt.Load(), 0)
    	assert.Equal(t, nlDeps.DelLoopbackRoutesCnt.Load(), 0)
    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)
  8. cni/pkg/ipset/nldeps_linux.go

    	}
    	return nil
    }
    
    func (m *realDeps) deleteIP(name string, ip netip.Addr, ipProto uint8) error {
    	err := netlink.IpsetDel(name, &netlink.IPSetEntry{
    		IP:       net.IP(ip.AsSlice()),
    		Protocol: &ipProto,
    	})
    	if err != nil {
    		return fmt.Errorf("failed to delete IP %s with and proto %d from ipset %s: %w", ip, ipProto, name, err)
    	}
    	return nil
    }
    
    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)
  9. istioctl/pkg/waypoint/waypoint.go

    	waypointDeleteCmd := &cobra.Command{
    		Use:   "delete",
    		Short: "Delete a waypoint configuration",
    		Long:  "Delete a waypoint configuration from the cluster",
    		Example: `  # Delete a waypoint from the default namespace
      istioctl x waypoint delete
    
      # Delete a waypoint by name, which can obtain from istioctl x waypoint list
      istioctl x waypoint delete waypoint-name --namespace default
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 19:45:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  10. cni/pkg/nodeagent/ztunnelserver_test.go

    	}
    	sendAck(ztunClient)
    
    	// now remove the pod
    	ztunnelServer := fixture.ztunServer
    	errChan := make(chan error)
    	go func() {
    		errChan <- ztunnelServer.PodDeleted(ctx, uid)
    	}()
    	// read the msg to delete from ztunnel
    	m, fds = readRequest(t, ztunClient)
    	assert.Equal(t, len(fds), 0)
    	assert.Equal(t, m.Payload.(*zdsapi.WorkloadRequest_Del).Del.Uid, uid)
    	sendAck(ztunClient)
    
    	assert.NoError(t, <-errChan)
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 8.6K bytes
    - Viewed (0)
Back to top