Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 13 of 13 for isSnapshot (9.69 sec)

  1. cni/pkg/nodeagent/ztunnelserver_test.go

    	uid := fixture.uid
    	// read initial pod add
    	readRequest(t, ztunClient)
    	sendAck(ztunClient)
    	// read snapshot sent
    	m, fds := readRequest(t, ztunClient)
    	assert.Equal(t, len(fds), 0)
    	sent := m.Payload.(*zdsapi.WorkloadRequest_SnapshotSent).SnapshotSent
    	if sent == nil {
    		panic("expected snapshot sent")
    	}
    	sendAck(ztunClient)
    
    	// now remove the pod
    	ztunnelServer := fixture.ztunServer
    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)
  2. cni/pkg/nodeagent/informers.go

    				return nil
    			}
    
    			log.Debugf("Pod %s now matches, adding to mesh", newPod.Name)
    			// netns == ""; at this point netns should have been added via the initial snapshot,
    			// or via the cni plugin. If it happens to get here before the cni plugin somehow,
    			// then we will just fail to add the pod to the mesh, and it will be retried later when cni plugin adds it.
    
    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)
  3. cni/pkg/install/install.go

    		}
    		installLog.Info("Detected changes to the node-level CNI setup, checking to see if configs or binaries need redeploying")
    		// We don't support (or want) to silently (re)deploy any binaries that were not in the initial "snapshot"
    		// so we intentionally discard/do not update the list of installedBins on redeploys.
    		if _, err := in.installAll(ctx); err != nil {
    			return err
    		}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Feb 08 18:52:24 GMT 2024
    - 10.8K bytes
    - Viewed (0)
Back to top