Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for deleted (0.18 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/ztunnelserver.go

    	so that we can remove stale entries when the ztunnel pod is deleted
    	or when the ztunnel pod is restarted in the same pod (remove old entries when the same uid connects again, but with different boot id?)
    
    	save a queue of what needs to be sent to the ztunnel pod and send it one by one when it connects.
    
    	when a new ztunnel connects with different uid, only propagate deletes to older ztunnels.
    */
    
    type connMgr struct {
    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)
  4. cni/pkg/install/install_test.go

    				t.Fatalf("file %s was not deleted", c.configFilename)
    			}
    
    			// check if kubeconfig is deleted
    			if file.Exists(kubeConfigFilePath) {
    				t.Fatal("kubeconfig was not deleted")
    			}
    
    			// check if binaries are deleted
    			if file.Exists(filepath.Join(cniBinDir, "istio-cni")) {
    				t.Fatalf("File %s was not deleted", "istio-cni")
    			}
    		})
    	}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Jan 26 20:34:28 GMT 2024
    - 11.1K bytes
    - Viewed (0)
  5. cni/pkg/repair/repaircontroller.go

    	})
    	if err != nil {
    		c.events.Write(pod, corev1.EventTypeWarning, ReasonDeleteBrokenPod, "pod detected as broken, but failed to delete: %v", err)
    		m.With(resultLabel.Value(resultFail)).Increment()
    		return err
    	}
    	c.events.Write(pod, corev1.EventTypeWarning, ReasonDeleteBrokenPod, "pod detected as broken, deleted")
    	m.With(resultLabel.Value(resultSuccess)).Increment()
    	return nil
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Feb 10 00:31:55 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top