Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 371 - 380 of 546 for char (0.02 seconds)

  1. internal/store/batch.go

    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]
    	quitCh chan struct{}
    
    	sync.Mutex
    }
    
    // BatchConfig represents the batch config
    type BatchConfig[I any] struct {
    	Limit         uint32
    	Store         Store[I]
    	CommitTimeout time.Duration
    	Log           logger
    }
    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)
  2. android/guava-testlib/src/com/google/common/collect/testing/Platform.java

    import com.google.common.annotations.GwtCompatible;
    import java.util.Locale;
    
    /**
     * Methods factored out so that they can be emulated differently in GWT.
     *
     * <p>This class is emulated in GWT.
     *
     * @author Hayward Chan
     */
    @GwtCompatible
    final class Platform {
      static <T> T[] clone(T[] array) {
        return array.clone();
      }
    
      // Class.cast is not supported in GWT.  This method is a no-op in GWT.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 04 01:39:13 GMT 2022
    - 1.3K bytes
    - Click Count (0)
  3. guava-testlib/src/com/google/common/collect/testing/Platform.java

    import com.google.common.annotations.GwtCompatible;
    import java.util.Locale;
    
    /**
     * Methods factored out so that they can be emulated differently in GWT.
     *
     * <p>This class is emulated in GWT.
     *
     * @author Hayward Chan
     */
    @GwtCompatible
    final class Platform {
      static <T> T[] clone(T[] array) {
        return array.clone();
      }
    
      // Class.cast is not supported in GWT.  This method is a no-op in GWT.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 04 01:39:13 GMT 2022
    - 1.3K bytes
    - Click Count (0)
  4. guava-testlib/src/com/google/common/collect/testing/testers/Platform.java

     */
    
    package com.google.common.collect.testing.testers;
    
    import com.google.common.annotations.GwtCompatible;
    import java.util.Locale;
    
    /**
     * This class is emulated in GWT.
     *
     * @author Hayward Chan
     */
    @GwtCompatible
    final class Platform {
    
      /** Format the template with args, only supports the placeholder {@code %s}. */
      static String format(String template, Object... args) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Dec 04 17:37:03 GMT 2017
    - 1.3K bytes
    - Click Count (0)
  5. cmd/storage-interface.go

    	// has never been replaced.
    	Healing() *healingTracker
    	DiskInfo(ctx context.Context, opts DiskInfoOptions) (info DiskInfo, err error)
    	NSScanner(ctx context.Context, cache dataUsageCache, updates chan<- dataUsageEntry, scanMode madmin.HealScanMode, shouldSleep func() bool) (dataUsageCache, error)
    
    	// Volume operations.
    	MakeVol(ctx context.Context, volume string) (err error)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Apr 25 05:41:04 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  6. internal/stmt_store/stmt_store.go

    package stmt_store
    
    import (
    	"context"
    	"database/sql"
    	"math"
    	"sync"
    	"time"
    
    	"gorm.io/gorm/internal/lru"
    )
    
    type Stmt struct {
    	*sql.Stmt
    	Transaction bool
    	prepared    chan struct{}
    	prepareErr  error
    }
    
    func (stmt *Stmt) Error() error {
    	return stmt.prepareErr
    }
    
    func (stmt *Stmt) Close() error {
    	<-stmt.prepared
    
    	if stmt.Stmt != nil {
    		return stmt.Stmt.Close()
    	}
    	return nil
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Sun Apr 27 06:05:16 GMT 2025
    - 6K bytes
    - Click Count (0)
  7. helm/minio/templates/post-job.yaml

    apiVersion: batch/v1
    kind: Job
    metadata:
      name: {{ template "minio.fullname" . }}-post-job
      labels:
        app: {{ template "minio.name" . }}-post-job
        chart: {{ template "minio.chart" . }}
        release: {{ .Release.Name }}
        heritage: {{ .Release.Service }}
      annotations:
        "helm.sh/hook": post-install,post-upgrade
        "helm.sh/hook-delete-policy": hook-succeeded,before-hook-creation
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Oct 10 15:48:31 GMT 2024
    - 10.4K bytes
    - Click Count (0)
  8. android/guava-testlib/src/com/google/common/collect/testing/SampleElements.java

        public static final String MIN_ELEMENT = "a";
        public static final String AFTER_LAST = "z";
        public static final String AFTER_LAST_2 = "zz";
      }
    
      public static class Chars extends SampleElements<Character> {
        public Chars() {
          // elements aren't sorted, to better test SortedSet iteration ordering
          super('b', 'a', 'c', 'd', 'e');
        }
      }
    
      public static class Enums extends SampleElements<AnEnum> {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Jul 17 15:26:41 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  9. cmd/speedtest.go

    	enableSha256     bool
    	enableMultipart  bool
    	creds            auth.Credentials
    }
    
    // Get the max throughput and iops numbers.
    func objectSpeedTest(ctx context.Context, opts speedTestOpts) chan madmin.SpeedTestResult {
    	ch := make(chan madmin.SpeedTestResult, 1)
    	go func() {
    		defer xioutil.SafeClose(ch)
    
    		concurrency := opts.concurrencyStart
    
    		if opts.autotune {
    			// if we have less drives than concurrency then choose
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  10. internal/grid/grid.go

    func getDeadline(d time.Duration) time.Duration {
    	if d < time.Millisecond {
    		return 0
    	}
    	if d > MaxDeadline {
    		return MaxDeadline
    	}
    	return d
    }
    
    type writerWrapper struct {
    	ch  chan<- []byte
    	ctx context.Context
    }
    
    func (w *writerWrapper) Write(p []byte) (n int, err error) {
    	buf := GetByteBufferCap(len(p))
    	buf = buf[:len(p)]
    	copy(buf, p)
    	select {
    	case w.ch <- buf:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 7K bytes
    - Click Count (0)
Back to Top