Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 231 for Func (0.04 sec)

  1. cmd/data-usage-cache_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgallTierStats(b *testing.B) {
    	v := allTierStats{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgallTierStats(b *testing.B) {
    	v := allTierStats{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 19K bytes
    - Viewed (0)
  2. cni/pkg/iptables/iptables_test.go

    	dep "istio.io/istio/tools/istio-iptables/pkg/dependencies"
    )
    
    func TestIptables(t *testing.T) {
    	cases := []struct {
    		name        string
    		config      func(cfg *Config)
    		ingressMode bool
    	}{
    		{
    			name: "default",
    			config: func(cfg *Config) {
    				cfg.RedirectDNS = true
    			},
    		},
    		{
    			name: "tproxy",
    			config: func(cfg *Config) {
    				cfg.TPROXYRedirection = true
    				cfg.RedirectDNS = true
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Oct 15 15:39:28 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  3. cmd/storage-rest-client.go

    }
    
    // LastConn - returns when the disk is seen to be connected the last time
    func (client *storageRESTClient) LastConn() time.Time {
    	return client.restClient.LastConn()
    }
    
    func (client *storageRESTClient) IsLocal() bool {
    	return false
    }
    
    func (client *storageRESTClient) Hostname() string {
    	return client.endpoint.Host
    }
    
    func (client *storageRESTClient) Endpoint() Endpoint {
    	return client.endpoint
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  4. internal/store/queuestore.go

    }
    
    // Del - Deletes an entry from the store.
    func (store *QueueStore[_]) Del(key Key) error {
    	store.Lock()
    	defer store.Unlock()
    	return store.del(key)
    }
    
    // Len returns the entry count.
    func (store *QueueStore[_]) Len() int {
    	store.RLock()
    	l := len(store.entries)
    	defer store.RUnlock()
    	return l
    }
    
    // lockless call
    func (store *QueueStore[_]) del(key Key) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/server_test.go

    type WaitGroup struct {
    	count int32
    	done  chan struct{}
    }
    
    func NewWaitGroup() *WaitGroup {
    	return &WaitGroup{
    		done: make(chan struct{}),
    	}
    }
    
    func NewWaitForNCalls(t *testing.T, n int32) (*WaitGroup, func()) {
    	wg := &WaitGroup{
    		done: make(chan struct{}),
    	}
    
    	wg.Add(n)
    	return wg, func() {
    		select {
    		case <-wg.C():
    			return
    		case <-time.After(time.Second):
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  6. cmd/erasure.go

    	setIndex  int
    	poolIndex int
    
    	// getDisks returns list of storageAPIs.
    	getDisks func() []StorageAPI
    
    	// getLockers returns list of remote and local lockers.
    	getLockers func() ([]dsync.NetLocker, string)
    
    	// getEndpoints returns list of endpoint belonging this set.
    	// some may be local and some remote.
    	getEndpoints func() []Endpoint
    
    	// getEndpoints returns list of endpoint strings belonging this set.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  7. cmd/peer-rest-client.go

    	if err != nil {
    		return
    	}
    	st.Results(func(b *grid.Bytes) error {
    		select {
    		case listenCh <- *b:
    		default:
    			// Do not block on slow receivers.
    			b.Recycle()
    		}
    		return nil
    	})
    }
    
    // Listen - listen on peers.
    func (client *peerRESTClient) Listen(ctx context.Context, listenCh chan<- []byte, v url.Values) {
    	go func() {
    		for {
    			client.doListen(ctx, listenCh, v)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top