Search Options

Results per page
Sort
Preferred Languages
Advance

Results 411 - 420 of 1,179 for funcs (0.02 sec)

  1. internal/event/arn.go

    type ARN struct {
    	TargetID
    	region string
    }
    
    // String - returns string representation.
    func (arn ARN) String() string {
    	if arn.TargetID.ID == "" && arn.TargetID.Name == "" && arn.region == "" {
    		return ""
    	}
    
    	return "arn:minio:sqs:" + arn.region + ":" + arn.TargetID.String()
    }
    
    // MarshalXML - encodes to XML data.
    func (arn ARN) MarshalXML(e *xml.Encoder, start xml.StartElement) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.1K bytes
    - Viewed (0)
  2. internal/bucket/replication/sourceselectioncriteria.go

    }
    
    // IsValid - checks whether SourceSelectionCriteria is valid or not.
    func (s SourceSelectionCriteria) IsValid() bool {
    	return s.ReplicaModifications.Status == Enabled || s.ReplicaModifications.Status == Disabled
    }
    
    // Validate source selection criteria
    func (s SourceSelectionCriteria) Validate() error {
    	if (s == SourceSelectionCriteria{}) {
    		return nil
    	}
    	if !s.IsValid() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  3. cmd/format-erasure.go

    		DistributionAlgo string `json:"distributionAlgo"`
    	} `json:"xl"`
    	Info DiskInfo `json:"-"`
    }
    
    func (f *formatErasureV3) Drives() (drives int) {
    	for _, set := range f.Erasure.Sets {
    		drives += len(set)
    	}
    	return drives
    }
    
    func (f *formatErasureV3) Clone() *formatErasureV3 {
    	b, err := json.Marshal(f)
    	if err != nil {
    		panic(err)
    	}
    	var dst formatErasureV3
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  4. cmd/sftp-server-driver.go

    		Custom: map[string]string{
    			"user":   user,
    			"cmd":    s.Method,
    			"param":  s.Filepath,
    			"source": source,
    		},
    	}
    }
    
    func (m *sftpMetrics) log(s *sftp.Request, user string) func(sz int64, err error) {
    	startTime := time.Now()
    	source := getSource(2)
    	return func(sz int64, err error) {
    		globalTrace.Publish(sftpTrace(s, startTime, source, user, err, sz))
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 05 07:51:13 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  5. cmd/xl-storage-format-utils_test.go

    	}
    	chkNumVersions := func(fis []FileInfo) bool {
    		for i := 0; i < len(fis)-1; i++ {
    			if fis[i].NumVersions != fis[i+1].NumVersions {
    				return false
    			}
    		}
    		return true
    	}
    	if !chkNumVersions(fivs.Versions) {
    		t.Fatalf("Expected all versions to have the same NumVersions")
    	}
    
    	sort.Slice(versions, func(i, j int) bool {
    		if versions[i].IsLatest {
    			return true
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  6. cmd/bootstrap-peer-server_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgServerSystemConfig(b *testing.B) {
    	v := ServerSystemConfig{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgServerSystemConfig(b *testing.B) {
    	v := ServerSystemConfig{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jan 24 21:36:44 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  7. cmd/bucket-metadata_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgBucketMetadata(b *testing.B) {
    	v := BucketMetadata{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgBucketMetadata(b *testing.B) {
    	v := BucketMetadata{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 2.3K bytes
    - Viewed (0)
  8. internal/http/response-recorder.go

    // when the request is finished to provide accurate data
    func (lrw *ResponseRecorder) TTFB() time.Duration {
    	if lrw.ttfbBody != 0 {
    		return lrw.ttfbBody
    	}
    	return lrw.ttfbHeader
    }
    
    // NewResponseRecorder - returns a wrapped response writer to trap
    // http status codes for auditing purposes.
    func NewResponseRecorder(w http.ResponseWriter) *ResponseRecorder {
    	rf, _ := w.(io.ReaderFrom)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  9. internal/fips/api.go

    // for the DARE object encryption.
    func DARECiphers() []byte {
    	if Enabled {
    		return []byte{sio.AES_256_GCM}
    	}
    	return []byte{sio.AES_256_GCM, sio.CHACHA20_POLY1305}
    }
    
    // TLSCiphers returns a list of supported TLS transport
    // cipher suite IDs.
    //
    // The list contains only ciphers that use AES-GCM or
    // (non-FIPS) CHACHA20-POLY1305 and ellitpic curve key
    // exchange.
    func TLSCiphers() []uint16 {
    	if Enabled {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:11:25 UTC 2024
    - 5K bytes
    - Viewed (0)
  10. cmd/kms-handlers_test.go

    	adminTestBed, err := prepareAdminErasureTestBed(context.Background())
    	if err != nil {
    		t.Fatal(err)
    	}
    	registerKMSRouter(adminTestBed.router)
    
    	if enableKMS {
    		GlobalKMS = kms.NewStub("default-test-key")
    	}
    
    	tearDown := func() {
    		adminTestBed.TearDown()
    		GlobalKMS = nil
    	}
    	return adminTestBed, tearDown
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 22.3K bytes
    - Viewed (0)
Back to top