- Sort Score
- Result 10 results
- Languages All
Results 231 - 240 of 463 for donde (0.03 sec)
-
internal/kms/kes.go
Endpoint string ItemState madmin.ItemState } var wg sync.WaitGroup results := make([]Result, len(c.client.Endpoints)) for i := range c.client.Endpoints { wg.Add(1) go func(i int) { defer wg.Done() client := kes.Client{ Endpoints: []string{c.client.Endpoints[i]}, HTTPClient: c.client.HTTPClient, } var item madmin.ItemState if _, err := client.Status(ctx); err == nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Aug 18 06:43:03 UTC 2024 - 7.3K bytes - Viewed (0) -
docs/en/docs/environment-variables.md
That means that **any value** read in Python from an environment variable **will be a `str`**, and any conversion to a different type or any validation has to be done in code. You will learn more about using environment variables for handling **application settings** in the [Advanced User Guide - Settings and Environment Variables](./advanced/settings.md){.internal-link target=_blank}.
Registered: Sun Oct 27 07:19:11 UTC 2024 - Last Modified: Sun Sep 08 20:36:53 UTC 2024 - 7.9K bytes - Viewed (0) -
internal/event/target/redis.go
return nil, err } } else { if _, err = conn.Do("AUTH", args.Password); err != nil { conn.Close() return nil, err } } } // Must be done after AUTH if _, err = conn.Do("CLIENT", "SETNAME", "MinIO"); err != nil { conn.Close() return nil, err } return conn, nil }, TestOnBorrow: func(c redis.Conn, t time.Time) error {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 9.1K bytes - Viewed (0) -
docs/pt/docs/python-types.md
No Python 3.6 e superior (incluindo o Python 3.10), você pode utilizar o tipo `Union` de `typing`, e colocar dentro dos colchetes os possíveis tipos aceitáveis. No Python 3.10 também existe uma **nova sintaxe** onde você pode colocar os possívels tipos separados por uma <abbr title='também chamado de "bitwise ou operador", mas o significado é irrelevante aqui'>barra vertical (`|`)</abbr>. //// tab | Python 3.10+ ```Python hl_lines="1"
Registered: Sun Oct 27 07:19:11 UTC 2024 - Last Modified: Tue Oct 15 12:32:27 UTC 2024 - 18K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor.go
} } m.tlock.RUnlock() } return report } func (m *Monitor) trackEWMA() { for { select { case <-m.bucketMovingAvgTicker.C: m.updateMovingAvg() case <-m.ctx.Done(): return } } } func (m *Monitor) updateMovingAvg() { m.mlock.Lock() defer m.mlock.Unlock() for _, bucketMeasurement := range m.bucketsMeasurement {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 6K bytes - Viewed (0) -
cmd/leak-detect_test.go
initialStackSnapShot := NewLeakDetect() return func() { initialStackSnapShot.DetectLeak(t) } } // list of functions to be ignored from the stack trace. // Leak detection is done when tests are run, should ignore the tests related functions, // and other runtime functions while identifying leaks. var ignoredStackFns = []string{ "", // Below are the stacks ignored by the upstream leaktest code.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 5.2K bytes - Viewed (0) -
docs/erasure/README.md
protect against two drive failure whereas in MinIO erasure code you can lose as many as half of drives and still the data remains safe. Further, MinIO's erasure code is at the object level and can heal one object at a time. For RAID, healing can be done only at the volume level which translates into high downtime. As MinIO encodes each object individually, it can heal objects incrementally. Storage servers once deployed should not require drive replacement or healing for the lifetime of the server....
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Sep 29 04:28:45 UTC 2022 - 4.1K bytes - Viewed (0) -
internal/s3select/simdj/reader.go
} r.onReaderExit = func() { close(r.decoded) readCloser.Close() for range r.input { // Read until EOF trickles through. // Otherwise, we risk the decoder hanging. } r.readerWg.Done() } // We cannot reuse as we are sending parsed objects elsewhere. simdjson.ParseNDStream(readCloser, r.input, nil) r.readerWg.Add(1) go r.startReader() return &r }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue May 30 17:02:22 UTC 2023 - 4.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/CrawlerLogHelper.java
super.processCleanupCrawling(objs); if (objs.length > 1 && objs[1] instanceof final UrlQueue<?> urlQueue) { ComponentUtil.getCrawlerStatsHelper().done(urlQueue); } } @Override protected void processProcessChildUrlByException(final Object... objs) { super.processProcessChildUrlByException(objs);
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 7.3K bytes - Viewed (0) -
cmd/dynamic-timeouts_test.go
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++ { timeout.LogSuccess(time.Duration(float64(time.Second) * rng.Float64())) } to := timeout.Timeout()
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Oct 14 10:08:40 UTC 2022 - 5.4K bytes - Viewed (0)