- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for addedNodes (0.25 sec)
-
cni/pkg/nodeagent/fakes_test.go
type fakeZtunnel struct { deletedPods atomic.Int32 addedPods atomic.Int32 addError error } func (f *fakeZtunnel) Run(ctx context.Context) { } func (f *fakeZtunnel) PodDeleted(ctx context.Context, uid string) error { f.deletedPods.Add(1) return nil } func (f *fakeZtunnel) PodAdded(ctx context.Context, pod *corev1.Pod, netns Netns) error { f.addedPods.Add(1) return f.addError }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 21:47:31 UTC 2024 - 3.9K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
string(podMeta.UID), false, ).Return(nil) err := netServer.AddPodToMesh(ctx, &corev1.Pod{ObjectMeta: podMeta}, podIPs, "fakenetns") assert.NoError(t, err) assert.Equal(t, 1, ztunnelServer.addedPods.Load()) } func TestServerRemovePod(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() setupLogging() fixture := getTestFixure(ctx) netServer := fixture.netServer
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 17.8K bytes - Viewed (0) -
samples/bookinfo/src/productpage/static/tailwind/tailwind.css
["type"],characterData:!0,subtree:!0,childList:!0})}new MutationObserver(async i=>{let e=!1;if(!iu){iu=new MutationObserver(async()=>await nu(!0));for(let t of document.querySelectorAll(`style[type="${tu}"]`))yb(t)}for(let t of i)for(let r of t.addedNodes)r.nodeType===1&&r.tagName==="STYLE"&&r.getAttribute("type")===tu&&(yb(r),e=!0);await nu(e)}).observe(document.documentElement,{attributes:!0,attributeFilter:["class"],childList:!0,subtree:!0});async function nu(i=!1){i&&(hb++,ru.clear());let e="";for(let...
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 28 14:48:01 UTC 2024 - 357.1K bytes - Viewed (1)