- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 372 for derer (0.13 sec)
-
cni/pkg/nodeagent/podcgroupns_test.go
Namespace: "bar", UID: types.UID("863b91d4-4b68-4efa-917f-4b560e3e86aa"), }} podUIDNetns, err := n.FindNetnsForPods(map[types.UID]*corev1.Pod{ pod.UID: pod, }) if err != nil { panic(err) } defer podUIDNetns.Close() if len(podUIDNetns) == 0 { t.Fatal("expected to find pod netns") } expectedUID := "863b91d4-4b68-4efa-917f-4b560e3e86aa" if podUIDNetns[expectedUID] == (WorkloadInfo{}) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.6K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
if err != nil { return nil, err } err = fw.Start() if err != nil { return nil, err } defer fw.Close() xdsOpts.Xds = fw.Address() response, err := GetXdsResponse(dr, istioNamespace, tokenServiceAccount, xdsOpts, dialOpts) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
src/cmd/addr2line/addr2line_test.go
func TestAddr2Line(t *testing.T) { testenv.MustHaveGoBuild(t) tmpDir, err := os.MkdirTemp("", "TestAddr2Line") if err != nil { t.Fatal("TempDir failed: ", err) } defer os.RemoveAll(tmpDir) // Build copy of test binary with debug symbols, // since the one running now may not have them. exepath := filepath.Join(tmpDir, "testaddr2line_test.exe")
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Feb 21 22:16:54 GMT 2024 - 3.8K bytes - Viewed (0) -
cmd/bucket-quota.go
bucketStorageCache.InitOnce(10*time.Second, cachevalue.Opts{ReturnLastGood: true, NoWait: true}, func() (DataUsageInfo, error) { ctx, done := context.WithTimeout(context.Background(), 2*time.Second) defer done() return loadDataUsageFromBackend(ctx, objAPI) }, ) } // GetBucketUsageInfo return bucket usage info for a given bucket
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.3K bytes - Viewed (0) -
internal/config/identity/openid/providercfg.go
req.Header.Set("Authorization", "Bearer "+accessToken) } client := &http.Client{ Transport: transport, } resp, err := client.Do(req) if err != nil { return nil, err } defer xhttp.DrainBody(resp.Body) if resp.StatusCode != http.StatusOK { // uncomment this for debugging when needed. // reqBytes, _ := httputil.DumpRequest(req, false) // fmt.Println(string(reqBytes))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 4.6K bytes - Viewed (0) -
internal/s3select/simdj/reader_amd64_test.go
) type tester interface { Fatal(args ...interface{}) } func loadCompressed(t tester, file string) (js []byte) { dec, err := zstd.NewReader(nil) if err != nil { t.Fatal(err) } defer dec.Close() js, err = os.ReadFile(filepath.Join("testdata", file+".json.zst")) if err != nil { t.Fatal(err) } js, err = dec.DecodeAll(js, nil) if err != nil { t.Fatal(err) } return js }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 3.9K bytes - Viewed (0) -
internal/cachevalue/cache.go
return v.v, v.e } } // Fetch new value. if t.opts.NoWait && v != nil && tNow-vTime < ttl.Milliseconds()*2 && (v.e == nil || t.opts.CacheError) { if t.updating.TryLock() { go func() { defer t.updating.Unlock() t.update() }() } return v.v, v.e } // Get lock. Either we get it or we wait for it. t.updating.Lock() if time.Since(time.UnixMilli(t.lastUpdateMs.Load())) < ttl {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 16:00:42 GMT 2024 - 4.2K bytes - Viewed (0) -
cmd/peer-rest-server.go
vars := mux.Vars(r) profiles := strings.Split(vars[peerRESTProfiler], ",") if len(profiles) == 0 { s.writeErrorResponse(w, errors.New("profiler name is missing")) return } globalProfilerMu.Lock() defer globalProfilerMu.Unlock() if globalProfiler == nil { globalProfiler = make(map[string]minioProfiler, 10) } // Stop profiler of all types if already running for k, v := range globalProfiler {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
cmd/batch-rotate.go
lock := api.NewNSLock(r.Bucket, objInfo.Name) lkctx, err := lock.GetLock(ctx, globalOperationTimeout) if err != nil { return err } ctx = lkctx.Context() defer lock.Unlock(lkctx) opts := ObjectOptions{ VersionID: objInfo.VersionID, Versioned: versioned, VersionSuspended: versionSuspended, NoLock: true, }
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/config.go
return &ConfigSys{} } // Initialize and load config from remote etcd or local config directory func initConfig(objAPI ObjectLayer) (err error) { bootstrapTraceMsg("load the configuration") defer func() { if err != nil { bootstrapTraceMsg(fmt.Sprintf("loading configuration failed: %v", err)) } }() if objAPI == nil { return errServerNotInitialized }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Aug 23 10:07:06 GMT 2023 - 6K bytes - Viewed (0)