- Sort Score
- Result 10 results
- Languages All
Results 341 - 350 of 1,214 for Func (0.06 sec)
-
docs/debugging/inspect/export.go
// afterVersion returns the payload after the version, if any. func (x xlMetaInlineData) afterVersion() []byte { if len(x) == 0 { return x } return x[1:] } // versionOK returns whether the version is ok. func (x xlMetaInlineData) versionOK() bool { if len(x) == 0 { return true } return x[0] > 0 && x[0] <= xlMetaInlineDataVer } func (x xlMetaInlineData) json() ([]byte, error) { if len(x) == 0 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Nov 08 15:58:02 UTC 2022 - 9.1K bytes - Viewed (0) -
cmd/erasure-metadata_test.go
} } func TestSkipTierFreeVersion(t *testing.T) { fi := newFileInfo("object", 8, 8) fi.SetSkipTierFreeVersion() if ok := fi.SkipTierFreeVersion(); !ok { t.Fatal("Expected SkipTierFreeVersion to be set on FileInfo but wasn't") } } func TestListObjectParities(t *testing.T) { mkMetaArr := func(N, parity, agree int) []FileInfo {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jul 25 21:02:50 UTC 2024 - 13.5K bytes - Viewed (0) -
cmd/metrics-resource.go
} // Describe sends the super-set of all possible descriptors of metrics func (c *minioResourceCollector) Describe(ch chan<- *prometheus.Desc) { ch <- c.desc } // Collect is called by the Prometheus registry when collecting metrics. func (c *minioResourceCollector) Collect(out chan<- prometheus.Metric) { var wg sync.WaitGroup publish := func(in <-chan MetricV2) { defer wg.Done() for metric := range in {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 24 23:30:33 UTC 2024 - 17.2K bytes - Viewed (0) -
cmd/dynamic-timeouts_test.go
t.Errorf("Failure to decrease timeout appropriately") } } func TestDynamicTimeoutConcurrent(t *testing.T) { // Race test. timeout := newDynamicTimeout(time.Second, time.Millisecond) var wg sync.WaitGroup for i := 0; i < runtime.GOMAXPROCS(0); i++ { wg.Add(1) rng := rand.New(rand.NewSource(int64(i))) go func() { defer wg.Done() for i := 0; i < 100; i++ { for j := 0; j < 100; j++ {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 14 10:08:40 UTC 2022 - 5.4K bytes - Viewed (0) -
cmd/jwt.go
} groups = ucred.Groups } return claims, groups, owner, nil } // newCachedAuthToken returns the cached token. func newCachedAuthToken() func() string { return func() string { return globalNodeAuthToken }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 22 07:04:48 UTC 2024 - 4.5K bytes - Viewed (0) -
cmd/signature-v2_test.go
package cmd import ( "context" "fmt" "net/http" "net/url" "os" "sort" "testing" ) // Tests for 'func TestResourceListSorting(t *testing.T)'. func TestResourceListSorting(t *testing.T) { sortedResourceList := make([]string, len(resourceList)) copy(sortedResourceList, resourceList) sort.Strings(sortedResourceList)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 14 10:08:40 UTC 2022 - 8K bytes - Viewed (0) -
internal/event/rules_test.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package event import ( "reflect" "testing" ) func TestNewPattern(t *testing.T) { testCases := []struct { prefix string suffix string expectedResult string }{ {"", "", ""}, {"*", "", "*"}, {"", "*", "*"},
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jun 01 21:59:40 UTC 2021 - 8.8K bytes - Viewed (0) -
tests/tests_test.go
db.Logger = db.Logger.LogMode(logger.Silent) } return } func RunMigrations() { var err error allModels := []interface{}{&User{}, &Account{}, &Pet{}, &Company{}, &Toy{}, &Language{}, &Coupon{}, &CouponProduct{}, &Order{}, &Parent{}, &Child{}, &Tools{}} rand.Seed(time.Now().UnixNano()) rand.Shuffle(len(allModels), func(i, j int) { allModels[i], allModels[j] = allModels[j], allModels[i] })
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Mon Sep 30 03:21:19 UTC 2024 - 3.3K bytes - Viewed (0) -
cmd/erasure-metadata-utils_test.go
if err != nil { removeRoots(disks) t.Fatal(err) } defer removeRoots(disks) z := objLayer.(*erasureServerPools) testShuffleDisks(t, z) } func Test_hashOrder(t *testing.T) { for x := 1; x < 17; x++ { t.Run(fmt.Sprintf("%d", x), func(t *testing.T) { var first [17]int rng := rand.New(rand.NewSource(0)) var tmp [16]byte rng.Read(tmp[:]) prefix := hex.EncodeToString(tmp[:])
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 7.4K bytes - Viewed (0) -
cmd/api-headers.go
xxml "github.com/minio/xxml" ) // Returns a hexadecimal representation of time at the // time response is sent to the client. func mustGetRequestID(t time.Time) string { return fmt.Sprintf("%X", t.UnixNano()) } // setEventStreamHeaders to allow proxies to avoid buffering proxy responses func setEventStreamHeaders(w http.ResponseWriter) { w.Header().Set(xhttp.ContentType, "text/event-stream")
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 28 04:44:00 UTC 2024 - 7K bytes - Viewed (0)