Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 1,387 for funcs (0.05 sec)

  1. internal/ioutil/ioutil_test.go

    )
    
    type sleepWriter struct {
    	timeout time.Duration
    }
    
    func (w *sleepWriter) Write(p []byte) (n int, err error) {
    	time.Sleep(w.timeout)
    	return len(p), nil
    }
    
    func (w *sleepWriter) Close() error {
    	return nil
    }
    
    func TestDeadlineWorker(t *testing.T) {
    	work := NewDeadlineWorker(500 * time.Millisecond)
    
    	err := work.Run(func() error {
    		time.Sleep(600 * time.Millisecond)
    		return nil
    	})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  2. internal/config/lambda/target/webhook.go

    	return target.httpClient.Do(req)
    }
    
    // Close the target. Will cancel all active requests.
    func (target *WebhookTarget) Close() error {
    	target.cancel()
    	return nil
    }
    
    func (target *WebhookTarget) init() error {
    	return target.lazyInit.Do(target.initWebhook)
    }
    
    // Only called from init()
    func (target *WebhookTarget) initWebhook() error {
    	args := target.args
    	transport := target.transport
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 08 21:39:49 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  3. cmd/warm-backend-azure.go

    	Bucket       string
    	Prefix       string
    	StorageClass string
    }
    
    func (az *warmBackendAzure) tier() *blob.AccessTier {
    	if az.StorageClass == "" {
    		return nil
    	}
    	for _, t := range blob.PossibleAccessTierValues() {
    		if strings.EqualFold(az.StorageClass, string(t)) {
    			return &t
    		}
    	}
    	return nil
    }
    
    func (az *warmBackendAzure) getDest(object string) string {
    	destObj := object
    	if az.Prefix != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 7K bytes
    - Viewed (0)
  4. internal/bucket/lifecycle/expiration.go

    	return nil
    }
    
    // IsDaysNull returns true if days field is null
    func (e Expiration) IsDaysNull() bool {
    	return e.Days == ExpirationDays(0)
    }
    
    // IsDateNull returns true if date field is null
    func (e Expiration) IsDateNull() bool {
    	return e.Date.Time.IsZero()
    }
    
    // IsNull returns true if both date and days fields are null
    func (e Expiration) IsNull() bool {
    	return e.IsDaysNull() && e.IsDateNull()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Feb 21 20:28:34 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  5. src/archive/zip/zip_test.go

    // 0xFFFFFFFF, but not before.
    func TestZip64DirectoryOffset(t *testing.T) {
    	if testing.Short() {
    		t.Skip("skipping in short mode")
    	}
    	t.Parallel()
    	const filename = "huge.txt"
    	gen := func(wantOff uint64) func(*Writer) {
    		return func(w *Writer) {
    			w.testHookCloseSizeOffset = func(size, off uint64) {
    				if off != wantOff {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  6. cmd/erasure-encode_test.go

    	b.Run(" 000000|X00000 ", func(b *testing.B) { benchmarkErasureEncode(6, 6, 0, 1, size, b) })
    	b.Run(" X00000|000000 ", func(b *testing.B) { benchmarkErasureEncode(6, 6, 1, 0, size, b) })
    	b.Run(" 000000|XXXXX0 ", func(b *testing.B) { benchmarkErasureEncode(6, 6, 0, 5, size, b) })
    	b.Run(" XXXXX0|000000 ", func(b *testing.B) { benchmarkErasureEncode(6, 6, 5, 0, size, b) })
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  7. src/archive/tar/writer_test.go

    }
    
    // failOnceWriter fails exactly once and then always reports success.
    type failOnceWriter bool
    
    func (w *failOnceWriter) Write(b []byte) (int, error) {
    	if !*w {
    		return 0, io.ErrShortWrite
    	}
    	*w = true
    	return len(b), nil
    }
    
    func TestWriterErrors(t *testing.T) {
    	t.Run("HeaderOnly", func(t *testing.T) {
    		tw := NewWriter(new(bytes.Buffer))
    		hdr := &Header{Name: "dir/", Typeflag: TypeDir}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Sep 23 14:32:33 UTC 2024
    - 39.4K bytes
    - Viewed (0)
  8. cmd/erasure-server-pool-decom_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgPoolDecommissionInfo(b *testing.B) {
    	v := PoolDecommissionInfo{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgPoolDecommissionInfo(b *testing.B) {
    	v := PoolDecommissionInfo{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jan 12 02:48:43 UTC 2022
    - 11K bytes
    - Viewed (0)
  9. cmd/batch-job-common-types_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgBatchJobKV(b *testing.B) {
    	v := BatchJobKV{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgBatchJobKV(b *testing.B) {
    	v := BatchJobKV{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 02 10:51:33 UTC 2023
    - 11.3K bytes
    - Viewed (0)
  10. cmd/batch-rotate_gen_test.go

    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgBatchJobKeyRotateEncryption(b *testing.B) {
    	v := BatchJobKeyRotateEncryption{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgBatchJobKeyRotateEncryption(b *testing.B) {
    	v := BatchJobKeyRotateEncryption{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 29 18:27:23 UTC 2023
    - 11.8K bytes
    - Viewed (0)
Back to top