Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 1,425 for Func (0.07 sec)

  1. internal/grid/connection_test.go

    )
    
    func TestDisconnect(t *testing.T) {
    	defer testlogger.T.SetLogTB(t)()
    	defer timeout(10 * time.Second)()
    	hosts, listeners, _ := getHosts(2)
    	dialer := &net.Dialer{
    		Timeout: 1 * time.Second,
    	}
    	errFatal := func(err error) {
    		t.Helper()
    		if err != nil {
    			t.Fatal(err)
    		}
    	}
    	wrapServer := func(handler http.Handler) http.Handler {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 08 21:44:00 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  2. internal/pubsub/pubsub.go

    	"encoding/json"
    	"fmt"
    	"sync"
    	"sync/atomic"
    )
    
    // GetByteBuffer returns a byte buffer from the pool.
    var GetByteBuffer = func() []byte {
    	return make([]byte, 0, 4096)
    }
    
    // Sub - subscriber entity.
    type Sub[T Maskable] struct {
    	ch     chan T
    	types  Mask
    	filter func(entry T) bool
    }
    
    // PubSub holds publishers and subscribers
    type PubSub[T Maskable, M Maskable] struct {
    	// atomics, keep at top:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 16:57:30 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  3. cmd/xl-storage-disk-id-check.go

    func (p *xlStorageDiskIDCheck) IsLocal() bool {
    	return p.storage.IsLocal()
    }
    
    func (p *xlStorageDiskIDCheck) Endpoint() Endpoint {
    	return p.storage.Endpoint()
    }
    
    func (p *xlStorageDiskIDCheck) Hostname() string {
    	return p.storage.Hostname()
    }
    
    func (p *xlStorageDiskIDCheck) Healing() *healingTracker {
    	return p.storage.Healing()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  4. internal/s3select/jstream/scanner_test.go

    		t.Fatalf("expected null byte, got %v", c)
    	}
    }
    
    func BenchmarkBufioScanner(b *testing.B) {
    	b.Run("small", func(b *testing.B) {
    		for i := 0; i < b.N; i++ {
    			benchmarkBufioScanner(smallInput)
    		}
    	})
    	b.Run("medium", func(b *testing.B) {
    		for i := 0; i < b.N; i++ {
    			benchmarkBufioScanner(mediumInput)
    		}
    	})
    	b.Run("large", func(b *testing.B) {
    		for i := 0; i < b.N; i++ {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  5. schema/serializer.go

    	"reflect"
    	"strings"
    	"sync"
    	"time"
    )
    
    var serializerMap = sync.Map{}
    
    // RegisterSerializer register serializer
    func RegisterSerializer(name string, serializer SerializerInterface) {
    	serializerMap.Store(strings.ToLower(name), serializer)
    }
    
    // GetSerializer get serializer
    func GetSerializer(name string) (serializer SerializerInterface, ok bool) {
    	v, ok := serializerMap.Load(strings.ToLower(name))
    	if ok {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jun 20 08:45:38 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  6. internal/store/store.go

    	Extension string
    	ItemCount int
    }
    
    // String returns the filepath name
    func (k Key) String() string {
    	keyStr := k.Name
    	if k.ItemCount > 1 {
    		keyStr = fmt.Sprintf("%d:%s", k.ItemCount, k.Name)
    	}
    	return keyStr + k.Extension + func() string {
    		if k.Compress {
    			return compressExt
    		}
    		return ""
    	}()
    }
    
    func getItemCount(k string) (count int, err error) {
    	count = 1
    	v := strings.Split(k, ":")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  7. cmd/batch-job-common-types.go

    	line, col int
    	msg       string
    }
    
    // message returns the error message excluding line, col information.
    // Intended to be used in unit tests.
    func (b BatchJobYamlErr) message() string {
    	return b.msg
    }
    
    // Error implements Error interface
    func (b BatchJobYamlErr) Error() string {
    	return fmt.Sprintf("%s\n Hint: error near line: %d, col: %d", b.msg, b.line, b.col)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 11 03:13:30 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  8. cmd/bucket-stats_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgBucketReplicationStat(b *testing.B) {
    	v := BucketReplicationStat{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgBucketReplicationStat(b *testing.B) {
    	v := BucketReplicationStat{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 30 08:00:59 UTC 2023
    - 20.5K bytes
    - Viewed (0)
  9. cmd/batch-handlers.go

    func (oi ObjectInfo) TraceVersionID() string {
    	return oi.VersionID
    }
    
    func (m *batchJobMetrics) trace(d batchJobMetric, job string, attempts int) func(info objTraceInfoer, err error) {
    	startTime := time.Now()
    	return func(info objTraceInfoer, err error) {
    		duration := time.Since(startTime)
    		if globalTrace.NumSubscribers(madmin.TraceBatch) > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  10. internal/lsync/lrwmutex_test.go

    		}
    		wl.Unlock()
    	}
    }
    
    // Borrowed from rwmutex_test.go
    func TestUnlockPanic(t *testing.T) {
    	defer func() {
    		if recover() == nil {
    			t.Fatalf("unlock of unlocked RWMutex did not panic")
    		}
    	}()
    	mu := NewLRWMutex()
    	mu.Unlock()
    }
    
    // Borrowed from rwmutex_test.go
    func TestUnlockPanic2(t *testing.T) {
    	defer func() {
    		if recover() == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 05 04:57:35 UTC 2023
    - 7.9K bytes
    - Viewed (0)
Back to top