- Sort Score
- Num 10 results
- Language All
Results 291 - 300 of 1,056 for timer (0.02 seconds)
-
internal/s3select/sql/value.go
case bool: _, ok = b.value.(bool) case string: _, ok = b.value.(string) case int64: _, ok = b.value.(int64) case float64: _, ok = b.value.(float64) case time.Time: _, ok = b.value.(time.Time) case []byte: _, ok = b.value.([]byte) case []Value: _, ok = b.value.([]Value) default: ok = reflect.TypeOf(v.value) == reflect.TypeOf(b.value) } return ok }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 20.4K bytes - Click Count (0) -
internal/config/callhome/callhome.go
// callhomeCycleDefault is the default interval between two callhome cycles (24hrs) const callhomeCycleDefault = 24 * time.Hour // Config represents the subnet related configuration type Config struct { // Flag indicating whether callhome is enabled. Enable bool `json:"enable"` // The interval between callhome cycles Frequency time.Duration `json:"frequency"` } var configLock sync.RWMutex
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 24 23:05:23 GMT 2024 - 2.6K bytes - Click Count (0) -
api/go1.17.txt
pkg text/template/parse, const SkipFuncCheck Mode pkg time, const Layout = "01/02 03:04:05PM '06 -0700" pkg time, const Layout ideal-string pkg time, func UnixMicro(int64) Time pkg time, func UnixMilli(int64) Time pkg time, method (Time) GoString() string pkg time, method (Time) IsDST() bool pkg time, method (Time) UnixMicro() int64
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Fri Feb 17 20:31:46 GMT 2023 - 18K bytes - Click Count (0) -
cmd/erasure-common.go
package cmd import ( "context" "math/rand" "sync" "time" ) func (er erasureObjects) getOnlineDisks() (newDisks []StorageAPI) { disks := er.getDisks() var wg sync.WaitGroup var mu sync.Mutex r := rand.New(rand.NewSource(time.Now().UnixNano())) for _, i := range r.Perm(len(disks)) { wg.Add(1) go func() { defer wg.Done()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 2.3K bytes - Click Count (0) -
internal/config/dns/operator_dns.go
Transport: &http.Transport{ Proxy: http.ProxyFromEnvironment, DialContext: (&net.Dialer{ Timeout: 3 * time.Second, KeepAlive: 5 * time.Second, }).DialContext, ResponseHeaderTimeout: 3 * time.Second, TLSHandshakeTimeout: 3 * time.Second, ExpectContinueTimeout: 3 * time.Second, TLSClientConfig: &tls.Config{ RootCAs: args.rootCAs, },Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Nov 11 14:51:43 GMT 2024 - 6.6K bytes - Click Count (0) -
internal/store/batch.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package store import ( "context" "errors" "sync" "time" ) // ErrBatchFull indicates that the batch is full var ErrBatchFull = errors.New("batch is full") const defaultCommitTimeout = 30 * time.Second // Batch represents an ordered batch type Batch[I any] struct { items []I limit uint32 store Store[I]
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 2.9K bytes - Click Count (0) -
cmd/version_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "testing" "time" ) func TestVersion(t *testing.T) { Version = "2017-05-07T06:37:49Z" _, err := time.Parse(time.RFC3339, Version) if err != nil { t.Fatal(err) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 956 bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/AutobahnTester.kt
response: Response?, ) { t.printStackTrace(System.out) latch.countDown() } }, ) check(latch.await(30, TimeUnit.SECONDS)) { "Timed out waiting for test $number to finish." } val endNanos = System.nanoTime() val tookMs = TimeUnit.NANOSECONDS.toMillis(endNanos - startNanos.get()) println("Took ${tookMs}ms") }Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 4.6K bytes - Click Count (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/CertificateAdapters.kt
} } } /** * ``` * Validity ::= SEQUENCE { * notBefore Time, * notAfter Time * } * ``` */ private val validity: BasicDerAdapter<Validity> = Adapters.sequence( "Validity", time, time, decompose = { listOf( it.notBefore, it.notAfter, ) },Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 13.6K bytes - Click Count (0) -
docs/distributed/decom.sh
policy_count=$(./mc admin policy list myminio/ | wc -l) ## create a warm tier instance (minio server /tmp/xltier/{1...4}/disk{0...1} --address :9002 2>&1 >/dev/null) & export MC_HOST_mytier="http://minioadmin:minioadmin@localhost:9002/" ./mc ready myminio ./mc mb -l myminio/bucket2 ./mc mb -l mytier/tiered ## create a tier and set up ilm policy to tier immediatelyCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon May 27 19:17:46 GMT 2024 - 6.4K bytes - Click Count (0)