- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 30 for our (0.13 sec)
-
cni/pkg/iptables/iptables.go
// // Note that SortedList is used here because the istio sets class has no order guarantees, // and our unit tests will flake if rules have a nondeterministic ordering. // CLI: -t mangle -A ISTIO_PRERT -s 169.254.7.127 -p tcp -m tcp --dport <PROBEPORT> -j ACCEPT // // DESC: If this is one of our node-probe ports and is from our SNAT-ed/"special" hostside IP, short-circuit out here
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) -
cni/pkg/nodeagent/cni-watcher_test.go
types.MergePatchType, labelsPatch, metav1.PatchOptions{}) assert.NoError(t, err) client.RunAndWait(ctx.Done()) payload, _ := json.Marshal(valid) // serialize our fake plugin event addEvent, err := processAddEvent(payload) assert.Equal(t, err, nil) // Push it thru the handler pluginServer.ReconcileCNIAddEvent(ctx, addEvent) waitForMockCalls()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 5.4K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
} // createHostsideProbeIpset creates an ipset. This is designed to be called from the host netns. // Note that if the ipset already exist by name, Create will not return an error. // // We will unconditionally flush our set before use here, so it shouldn't matter. func createHostsideProbeIpset(isV6 bool) (ipset.IPSet, error) { linDeps := ipset.RealNlDeps() probeSet, err := ipset.NewIPSet(iptables.ProbeIPSet, isV6, linDeps) if err != nil {
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) -
cmd/object-api-utils.go
dec, err := decrypt(oi.Parts[firstPartIdx].Index) if err == nil { // Load Index var idx s2.Index _, err := idx.Load(s2.RestoreIndexHeaders(dec)) // Find compressed/uncompressed offsets of our partskip compOff, uCompOff, err2 := idx.Find(partSkip) if err == nil && err2 == nil && compOff > 0 { // Encrypted. const sseDAREEncPackageBlockSize = SSEDAREPackageBlockSize + SSEDAREPackageMetaSize
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1) -
cmd/metacache-server-pool.go
c.error = "no longer used" c.status = scanStateError rpc.UpdateMetacacheListing(ctx, *c) } } }() o.ID = "" } // Do listing in-place. // Create output for our results. // Create filter for results. o.debugln("Raw List", o) filterCh := make(chan metaCacheEntry, o.Limit) listCtx, cancelList := context.WithCancel(ctx) filteredResults := o.gatherResults(listCtx, filterCh)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0) -
cmd/update.go
gopsutilcpu "github.com/shirou/gopsutil/v3/cpu" "github.com/valyala/bytebufferpool" ) const ( envMinisignPubKey = "MINIO_UPDATE_MINISIGN_PUBKEY" updateTimeout = 10 * time.Second ) // For windows our files have .exe additionally. var minioReleaseWindowsInfoURL = MinioReleaseURL + "minio.exe.sha256sum" // minioVersionToReleaseTime - parses a standard official release // MinIO version string. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 18.7K bytes - Viewed (0) -
operator/cmd/mesh/manifest-generate_test.go
found = sn match = i } } // If our predicate can tell us the expected match, use that if want, ok := predicate(s); ok { if want != found { t.Fatalf("expected webhook to go to service %q, found %q", want, found) } return } // Otherwise, look through our assertions for a matching one, and check that for _, w := range tt.checks {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 18 18:16:49 GMT 2024 - 43.5K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
true, ).Return(nil) fixture.ipsetDeps.On("addIP", "foo-v4", netip.MustParseAddr("2.2.2.2"), ipProto, podUID, true, ).Return(nil) // List should return one IP not in our "pod snapshot", which means we prune fixture.ipsetDeps.On("listEntriesByIP", "foo-v4", ).Return([]netip.Addr{ netip.MustParseAddr("2.2.2.2"), netip.MustParseAddr("6.6.6.6"), netip.MustParseAddr("3.3.3.3"),
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) -
cni/pkg/nodeagent/informers.go
switch event.Event { case controllers.EventAdd: // pod was added to our cache // we get here in 2 cases: // 1. new pod was created on our node // 2. we were restarted and current existing pods are added to our cache // We have no good way to distinguish between these two cases from here. But we don't need to!
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) -
cmd/api-errors.go
HTTPStatusCode: http.StatusInternalServerError, }, ErrInvalidAccessKeyID: { Code: "InvalidAccessKeyId", Description: "The Access Key Id you provided does not exist in our records.", HTTPStatusCode: http.StatusForbidden, }, ErrAccessKeyDisabled: { Code: "InvalidAccessKeyId", Description: "Your account is disabled; please contact your administrator.",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 91.4K bytes - Viewed (7)