Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for pickBy (0.12 sec)

  1. internal/s3select/csv/reader_contrib_test.go

    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 38.5K bytes
    - Viewed (0)
  2. docs/sts/ldap.md

    If the DNS SRV record is at an entirely different place, say `_ldapsrv._tcpish.myldapserver.com`, then set `srv_record_name` to the special value `on` and set `server_addr=_ldapsrv._tcpish.myldapserver.com`.
    
    When using this feature, do not specify a port in the `server_addr` as the port is picked up automatically from the SRV record.
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 18.9K bytes
    - Viewed (0)
  3. cmd/erasure-metadata.go

    			candidate.NumVersions = props.numVersions
    		}
    		return candidate, nil
    	}
    	return FileInfo{}, InsufficientReadQuorum{Err: errErasureReadQuorum, Type: RQInconsistentMeta}
    }
    
    // pickValidFileInfo - picks one valid FileInfo content and returns from a
    // slice of FileInfo.
    func pickValidFileInfo(ctx context.Context, metaArr []FileInfo, modTime time.Time, etag string, quorum int) (FileInfo, error) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 09:42:21 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  4. docs/bucket/replication/DESIGN.md

    All replication failures are picked up by the scanner which runs at a one minute frequency, each time scanning upto a sixteenth of the namespace. Object versions marked `PENDING` or `FAILED` are re-queued for replication.
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 14.7K bytes
    - Viewed (0)
  5. cmd/storage-rest-server.go

    // keepHTTPReqResponseAlive will wait for the returned body to be read before starting the ticker.
    // The returned function should always be called to release resources.
    // An optional error can be sent which will be picked as text only error,
    // without its original type by the receiver.
    // waitForHTTPResponse should be used to the receiving side.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  6. internal/grid/benchmark_test.go

    					rng := rand.New(rand.NewSource(time.Now().UnixNano()))
    					n := 0
    					var latency int64
    					managers := grid.Managers
    					hosts := grid.Hosts
    					for pb.Next() {
    						// Pick a random manager.
    						src, dst := rng.Intn(len(managers)), rng.Intn(len(managers))
    						if src == dst {
    							dst = (dst + 1) % len(managers)
    						}
    						local := managers[src]
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  7. cmd/data-usage_test.go

    			size: 200,
    		},
    	}
    	createUsageTestFiles(t, base, bucket, files)
    	err = os.RemoveAll(filepath.Join(base, bucket, "dir1/dira/dirasub/dcfile"))
    	if err != nil {
    		t.Fatal(err)
    	}
    	// Changed dir must be picked up in this many cycles.
    	for i := 0; i < dataUsageUpdateDirCycles; i++ {
    		got, err = scanDataFolder(context.Background(), nil, &xls, got, getSize, 0, weSleep)
    		got.Info.NextCycle++
    		if err != nil {
    			t.Fatal(err)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  8. internal/grid/manager.go

    	if m.handlers.hasSubhandler(subID) && !id.isTestHandler() {
    		return fmt.Errorf("handler %v, subroute:%v: %w", id.String(), s, ErrHandlerAlreadyExists)
    	}
    	m.handlers.subSingle[subID] = h
    	// Copy so clients can also pick it up for other subpaths.
    	m.handlers.subSingle[makeZeroSubHandlerID(id)] = h
    	return nil
    }
    
    /*
    // RegisterStateless will register a stateless handler that serves
    // []byte -> stream of ([]byte, error) requests.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  9. cmd/batch-rotate.go

    //     createdAfter: "date" # match objects created after "date"
    //     createdBefore: "date" # match objects created before "date"
    //     tags:
    //       - key: "name"
    //         value: "pick*" # match objects with tag 'name', with all values starting with 'pick'
    //     metadata:
    //       - key: "content-type"
    //         value: "image/*" # match objects with 'content-type', with all values starting with 'image/'
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  10. tensorflow/c/eager/c_api_test_util.cc

      for (int i = 0; i < num_tasks; i++) {
        int port = tensorflow::testing::PickUnusedPortOrDie();
        job_def->mutable_tasks()->insert(
            {i, tensorflow::strings::StrCat("localhost:", port)});
        LOG(INFO) << "Picked test port: " << port << " for job: " << job_name
                  << ", task: " << i;
      }
      return server_def;
    }
    
    tensorflow::ServerDef GetServerDef(int num_tasks) {
      return GetServerDef("localhost", num_tasks);
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Wed Feb 21 22:37:46 UTC 2024
    - 23.5K bytes
    - Viewed (0)
Back to top