- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 35 for mocked (0.15 sec)
-
cni/pkg/nodeagent/informers_test.go
waitForMockCalls() // wait until pod add was called mt.Assert(EventTotals.Name(), map[string]string{"type": "add"}, monitortest.AtLeast(1)) assertPodAnnotated(t, client, pod) // check expectations on mocked calls fs.AssertExpectations(t) } func assertPodAnnotated(t *testing.T, client kube.Client, pod *corev1.Pod) { for i := 0; i < 5; i++ {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0) -
cmd/local-locker_gen.go
Krishnan Parthasarathi <******@****.***> 1711041695 -0700
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 13.8K bytes - Viewed (0) -
internal/grid/connection.go
// Wait for existing to exit c.handleMsgWg.Wait() } func (c *Connection) updateState(s State) { c.connChange.L.Lock() defer c.connChange.L.Unlock() // We may have reads that aren't locked, so update atomically. gotState := atomic.LoadUint32((*uint32)(&c.state)) if gotState == StateShutdown || State(gotState) == s { return } if s == StateConnected {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cmd/bucket-object-lock.go
// enforceRetentionForDeletion checks if it is appropriate to remove an // object according to locking configuration when this is lifecycle/ bucket quota asking. func enforceRetentionForDeletion(ctx context.Context, objInfo ObjectInfo) (locked bool) { if objInfo.DeleteMarker { return false } lhold := objectlock.GetObjectLegalHoldMeta(objInfo.UserDefined) if lhold.Status.Valid() && lhold.Status == objectlock.LegalHoldOn { return true }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 13.2K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
lc, err = globalLifecycleSys.Get(bi.Name) if err != nil && !errors.Is(err, BucketLifecycleNotFound{Bucket: bi.Name}) { return err } // Check if bucket is object locked. lr, err = globalBucketObjectLockSys.Get(bi.Name) if err != nil { return err } rcfg, err = getReplicationConfig(ctx, bi.Name) if err != nil { return err } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
cni/test/install_cni.go
} } t.Logf("PASS: All temporary files removed from %v", tempCNIConfDir) } // doTest sets up necessary environment variables, runs the Docker installation // container and verifies output file correctness. func doTest(t *testing.T, chainedCNIPlugin bool, wd, preConfFile, resultFileName, delayedConfFile, expectedOutputFile,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
internal/grid/muxclient.go
} m.addResponse(Response{Err: &err}) } func (m *muxClient) ack(seq uint32) { if !m.checkSeq(seq) { return } if m.acked || m.outBlock == nil { return } available := cap(m.outBlock) for i := 0; i < available; i++ { m.outBlock <- struct{}{} } m.acked = true } func (m *muxClient) unblockSend(seq uint32) { if !m.checkSeq(seq) { return } select {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/storage-datatypes.go
if fi.Deleted { return "delete-marker" } if fi.XLV1 && fi.DataDir == "" { return "legacy" } return fi.DataDir } // IsCompressed returns true if the object is marked as compressed. func (fi FileInfo) IsCompressed() bool { _, ok := fi.Metadata[ReservedMetadataPrefix+"compression"] return ok } // InlineData returns true if object contents are inlined alongside its metadata.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 15.3K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
// // We want to do the same thing in ambient but can't rely on podSpec injection. So, do effectively the same thing, // but with iptables rules - use `--socket-exists` as a proxy for "is this a forwarded packet" vs "is this originating from // a local node socket". If the latter, outside the pod in the host netns, redirect that traffic to a hardcoded/custom proxy
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) -
internal/grid/grid_test.go
handler.PutResponse(resp) n++ return nil }) errFatal(err) t.Log("EOF.", payloads, " Roundtrips:", time.Since(start)) } // testServerStreamResponseBlocked will test if server can handle a blocked response stream func testServerStreamResponseBlocked(t *testing.T, local, remote *Manager) { defer testlogger.T.SetErrorTB(t)() errFatal := func(err error) { t.Helper() if err != nil { t.Fatal(err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0)