Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 291 - 300 of 1,056 for timer (0.02 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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 immediately
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon May 27 19:17:46 GMT 2024
    - 6.4K bytes
    - Click Count (0)
Back to Top