Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 211 - 220 of 1,201 for Func (0.04 seconds)

  1. 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])
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11.3K bytes
    - Click Count (0)
  2. 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{}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  3. cmd/xl-storage-format-v2_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgxlMetaDataDirDecoder(b *testing.B) {
    	v := xlMetaDataDirDecoder{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgxlMetaDataDirDecoder(b *testing.B) {
    	v := xlMetaDataDirDecoder{}
    	bts := make([]byte, 0, v.Msgsize())
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11.5K bytes
    - Click Count (0)
  4. src/archive/tar/writer.go

    	default:
    		return n, nil
    	}
    }
    
    func (fw *regFileWriter) ReadFrom(r io.Reader) (int64, error) {
    	return io.Copy(struct{ io.Writer }{fw}, r)
    }
    
    // logicalRemaining implements fileState.logicalRemaining.
    func (fw regFileWriter) logicalRemaining() int64 {
    	return fw.nb
    }
    
    // physicalRemaining implements fileState.physicalRemaining.
    func (fw regFileWriter) physicalRemaining() int64 {
    	return fw.nb
    }
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Feb 03 16:38:43 GMT 2025
    - 19.7K bytes
    - Click Count (0)
  5. cmd/signature-v4-parser.go

    		date    time.Time
    		region  string
    		service string
    		request string
    	}
    }
    
    // Return scope string.
    func (c credentialHeader) getScope() string {
    	return strings.Join([]string{
    		c.scope.date.Format(yyyymmdd),
    		c.scope.region,
    		c.scope.service,
    		c.scope.request,
    	}, SlashSeparator)
    }
    
    func getReqAccessKeyV4(r *http.Request, region string, stype serviceType) (auth.Credentials, bool, APIErrorCode) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 10 18:57:35 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  6. internal/crypto/sse-s3.go

    	// SSE-S3 requests.
    	S3 = sses3{}
    
    	_ Type = S3
    )
    
    // String returns the SSE domain as string. For SSE-S3 the
    // domain is "SSE-S3".
    func (sses3) String() string { return "SSE-S3" }
    
    func (sses3) IsRequested(h http.Header) bool {
    	_, ok := h[xhttp.AmzServerSideEncryption]
    	// Return only true if the SSE header is specified and does not contain the SSE-KMS value
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 07 23:55:37 GMT 2024
    - 7.6K bytes
    - Click Count (0)
  7. cmd/dummy-handlers.go

    }
    
    // DeleteBucketWebsiteHandler - DELETE bucket website, a dummy api
    func (api objectAPIHandlers) DeleteBucketWebsiteHandler(w http.ResponseWriter, r *http.Request) {
    	writeSuccessResponseHeadersOnly(w)
    }
    
    // GetBucketCorsHandler - GET bucket cors, a dummy api
    func (api objectAPIHandlers) GetBucketCorsHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "GetBucketCors")
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 13 15:25:16 GMT 2024
    - 8.8K bytes
    - Click Count (0)
  8. cmd/admin-handler-utils.go

    }
    
    // AdminError - is a generic error for all admin APIs.
    type AdminError struct {
    	Code       string
    	Message    string
    	StatusCode int
    }
    
    func (ae AdminError) Error() string {
    	return ae.Message
    }
    
    func toAdminAPIErr(ctx context.Context, err error) APIError {
    	if err == nil {
    		return noError
    	}
    
    	var apiErr APIError
    	switch e := err.(type) {
    	case policy.Error:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Jul 03 07:17:20 GMT 2024
    - 8.4K bytes
    - Click Count (0)
  9. internal/ringbuffer/ring_buffer.go

    // A goroutine will be started and run until the provided context is canceled.
    func (r *RingBuffer) WithCancel(ctx context.Context) *RingBuffer {
    	go func() {
    		<-ctx.Done()
    		r.CloseWithError(ctx.Err())
    	}()
    	return r
    }
    
    func (r *RingBuffer) setErr(err error, locked bool) error {
    	if !locked {
    		r.mu.Lock()
    		defer r.mu.Unlock()
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 13.3K bytes
    - Click Count (0)
  10. internal/bucket/object/lock/lock.go

    	// RetCompliance - compliance mode.
    	RetCompliance RetMode = "COMPLIANCE"
    )
    
    // Valid - returns if retention mode is valid
    func (r RetMode) Valid() bool {
    	switch r {
    	case RetGovernance, RetCompliance:
    		return true
    	}
    	return false
    }
    
    func parseRetMode(modeStr string) (mode RetMode) {
    	switch strings.ToUpper(modeStr) {
    	case "GOVERNANCE":
    		mode = RetGovernance
    	case "COMPLIANCE":
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 17.9K bytes
    - Click Count (0)
Back to Top