Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 1,214 for Func (0.02 sec)

  1. internal/bucket/bandwidth/monitor.go

    func SelectBuckets(buckets ...string) SelectionFunction {
    	if len(buckets) == 0 {
    		return func(bucket string) bool {
    			return true
    		}
    	}
    	return func(bucket string) bool {
    		for _, bkt := range buckets {
    			if bkt == bucket {
    				return true
    			}
    		}
    		return false
    	}
    }
    
    // Details for the measured bandwidth
    type Details struct {
    	LimitInBytesPerSecond            int64   `json:"limitInBits"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 6K bytes
    - Viewed (0)
  2. 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":
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 29 01:20:27 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  3. internal/grid/connection.go

    	"github.com/tinylib/msgp/msgp"
    	"github.com/zeebo/xxh3"
    )
    
    func gridLogIf(ctx context.Context, err error, errKind ...interface{}) {
    	logger.LogIf(ctx, "grid", err, errKind...)
    }
    
    func gridLogIfNot(ctx context.Context, err error, ignored ...error) {
    	logger.LogIfNot(ctx, "grid", err, ignored...)
    }
    
    func gridLogOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  4. cmd/bucket-replication-metrics.go

    		sma:     newSMA(50),
    	}
    }
    
    func (rx *XferStats) String() string {
    	return fmt.Sprintf("curr=%f avg=%f, peak=%f", rx.curr(), rx.Avg, rx.Peak)
    }
    
    func (rx *XferStats) curr() float64 {
    	if rx.measure == nil {
    		return 0.0
    	}
    	return rx.measure.getExpMovingAvgBytesPerSecond()
    }
    
    func (rx *XferStats) merge(o XferStats) XferStats {
    	curr := calcAvg(rx.curr(), o.curr(), rx.N, o.N)
    	peak := rx.Peak
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  5. src/archive/zip/reader.go

    func (f *fileListEntry) Type() fs.FileMode { return fs.ModeDir }
    func (f *fileListEntry) IsDir() bool       { return true }
    func (f *fileListEntry) Sys() any          { return nil }
    
    func (f *fileListEntry) ModTime() time.Time {
    	if f.file == nil {
    		return time.Time{}
    	}
    	return f.file.FileHeader.Modified.UTC()
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Sat Aug 03 01:05:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  6. schema/field.go

    	Schema                 *Schema
    	EmbeddedSchema         *Schema
    	OwnerSchema            *Schema
    	ReflectValueOf         func(context.Context, reflect.Value) reflect.Value
    	ValueOf                func(context.Context, reflect.Value) (value interface{}, zero bool)
    	Set                    func(context.Context, reflect.Value, interface{}) error
    	Serializer             SerializerInterface
    	NewValuePool           FieldNewValuePool
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Apr 15 03:20:20 UTC 2024
    - 32K bytes
    - Viewed (0)
  7. cmd/object-api-putobject_test.go

    )
    
    func md5Header(data []byte) map[string]string {
    	return map[string]string{"etag": getMD5Hash(data)}
    }
    
    // Wrapper for calling PutObject tests for both Erasure multiple disks and single node setup.
    func TestObjectAPIPutObjectSingle(t *testing.T) {
    	ExecExtendedObjectLayerTest(t, testObjectAPIPutObject)
    }
    
    // Tests validate correctness of PutObject.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  8. src/cmd/api/testdata/src/pkg/p1/golden.txt

    pkg p1, const StrConst = "foo"
    pkg p1, const StrConst ideal-string
    pkg p1, func Bar(int8, int16, int64)
    pkg p1, func Bar1(int8, int16, int64) uint64
    pkg p1, func Bar2(int8, int16, int64) (uint8, uint64)
    pkg p1, func BarE() Error
    pkg p1, func Now() Time
    pkg p1, func PlainFunc(int, int, string) (*B, error)
    pkg p1, func TakesFunc(func(int) int)
    pkg p1, method (*B) JustOnB()
    pkg p1, method (*B) OnBothTandBPtr()
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Dec 02 16:29:41 UTC 2022
    - 3.6K bytes
    - Viewed (0)
  9. internal/bucket/replication/replication.go

    	ExistingObjectReplicationType
    	ResyncReplicationType
    	AllReplicationType
    )
    
    // Valid returns true if replication type is set
    func (t Type) Valid() bool {
    	return t > 0
    }
    
    // IsDataReplication returns true if content being replicated
    func (t Type) IsDataReplication() bool {
    	switch t {
    	case ObjectReplicationType, HealReplicationType, ExistingObjectReplicationType:
    		return true
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 28 17:44:56 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  10. src/bytes/buffer_test.go

    type negativeReader struct{}
    
    func (r *negativeReader) Read([]byte) (int, error) { return -1, nil }
    
    func init() {
    	testBytes = make([]byte, N)
    	for i := 0; i < N; i++ {
    		testBytes[i] = 'a' + byte(i%26)
    	}
    	testString = string(testBytes)
    }
    
    // Verify that contents of buf match the string s.
    func check(t *testing.T, testname string, buf *Buffer, s string) {
    	bytes := buf.Bytes()
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Sep 03 20:55:15 UTC 2024
    - 18.6K bytes
    - Viewed (0)
Back to top