Search Options

Results per page
Sort
Preferred Languages
Advance

Results 581 - 590 of 1,214 for Func (0.04 sec)

  1. internal/bucket/replication/filter.go

    	cachedTags map[string]string
    }
    
    // IsEmpty returns true if filter is not set
    func (f Filter) IsEmpty() bool {
    	return f.And.isEmpty() && f.Tag.IsEmpty() && f.Prefix == ""
    }
    
    // MarshalXML - produces the xml representation of the Filter struct
    // only one of Prefix, And and Tag should be present in the output.
    func (f Filter) MarshalXML(e *xml.Encoder, start xml.StartElement) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 28 18:25:46 UTC 2022
    - 3.5K bytes
    - Viewed (0)
  2. cmd/site-replication-metrics_gen.go

    		}
    	}
    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z RStat) Msgsize() (s int) {
    	s = 1 + 6 + msgp.Int64Size + 6 + msgp.Int64Size
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *RTimedMetrics) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 06:00:45 UTC 2024
    - 40.6K bytes
    - Viewed (0)
  3. src/archive/tar/reader_test.go

    		}
    	}
    }
    
    func TestReadOldGNUSparseMap(t *testing.T) {
    	populateSparseMap := func(sa sparseArray, sps []string) []string {
    		for i := 0; len(sps) > 0 && i < sa.maxEntries(); i++ {
    			copy(sa.entry(i), sps[0])
    			sps = sps[1:]
    		}
    		if len(sps) > 0 {
    			copy(sa.isExtended(), "\x80")
    		}
    		return sps
    	}
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 03 15:48:09 UTC 2024
    - 46.9K bytes
    - Viewed (0)
  4. cmd/bucket-lifecycle.go

    	ObjectInfo
    }
    
    func (f freeVersionTask) OpHash() uint64 {
    	return xxh3.HashString(f.TransitionedObject.Tier + f.TransitionedObject.Name)
    }
    
    func (n newerNoncurrentTask) OpHash() uint64 {
    	return xxh3.HashString(n.bucket + n.versions[0].ObjectV.ObjectName)
    }
    
    func (j jentry) OpHash() uint64 {
    	return xxh3.HashString(j.TierName + j.ObjName)
    }
    
    func (e expiryTask) OpHash() uint64 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  5. clause/returning_test.go

    package clause_test
    
    import (
    	"fmt"
    	"testing"
    
    	"gorm.io/gorm/clause"
    )
    
    func TestReturning(t *testing.T) {
    	results := []struct {
    		Clauses []clause.Interface
    		Result  string
    		Vars    []interface{}
    	}{
    		{
    			[]clause.Interface{clause.Select{}, clause.From{}, clause.Returning{
    				[]clause.Column{clause.PrimaryColumn},
    			}},
    			"SELECT * FROM `users` RETURNING `users`.`id`", nil,
    		}, {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Jun 02 01:18:01 UTC 2020
    - 845 bytes
    - Viewed (0)
  6. cmd/rebalancemetric_string.go

    // Code generated by "stringer -type=rebalanceMetric -trimprefix=rebalanceMetric erasure-server-pool-rebalance.go"; DO NOT EDIT.
    
    package cmd
    
    import "strconv"
    
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    	// Re-run the stringer command to generate them again.
    	var x [1]struct{}
    	_ = x[rebalanceMetricRebalanceBuckets-0]
    	_ = x[rebalanceMetricRebalanceBucket-1]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 19:36:57 UTC 2022
    - 988 bytes
    - Viewed (0)
  7. internal/ioutil/ioutil.go

    )
    
    // aligned sync.Pool's
    var (
    	ODirectPoolLarge = sync.Pool{
    		New: func() interface{} {
    			b := disk.AlignedBlock(LargeBlock)
    			return &b
    		},
    	}
    	ODirectPoolMedium = sync.Pool{
    		New: func() interface{} {
    			b := disk.AlignedBlock(MediumBlock)
    			return &b
    		},
    	}
    	ODirectPoolSmall = sync.Pool{
    		New: func() interface{} {
    			b := disk.AlignedBlock(SmallBlock)
    			return &b
    		},
    	}
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  8. internal/config/callhome/callhome.go

    }
    
    var configLock sync.RWMutex
    
    // Enabled - indicates if callhome is enabled or not
    func (c *Config) Enabled() bool {
    	configLock.RLock()
    	defer configLock.RUnlock()
    
    	return c.Enable
    }
    
    // FrequencyDur - returns the currently configured callhome frequency
    func (c *Config) FrequencyDur() time.Duration {
    	configLock.RLock()
    	defer configLock.RUnlock()
    
    	if c.Frequency == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  9. prepare_stmt.go

    	return nil, ErrInvalidDB
    }
    
    func (db *PreparedStmtDB) Close() {
    	db.Mux.Lock()
    	defer db.Mux.Unlock()
    
    	for _, stmt := range db.Stmts {
    		go func(s *Stmt) {
    			// make sure the stmt must finish preparation first
    			<-s.prepared
    			if s.Stmt != nil {
    				_ = s.Close()
    			}
    		}(stmt)
    	}
    	// setting db.Stmts to nil to avoid further using
    	db.Stmts = nil
    }
    
    func (sdb *PreparedStmtDB) Reset() {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:02:05 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  10. clause/group_by_test.go

    package clause_test
    
    import (
    	"fmt"
    	"testing"
    
    	"gorm.io/gorm/clause"
    )
    
    func TestGroupBy(t *testing.T) {
    	results := []struct {
    		Clauses []clause.Interface
    		Result  string
    		Vars    []interface{}
    	}{
    		{
    			[]clause.Interface{clause.Select{}, clause.From{}, clause.GroupBy{
    				Columns: []clause.Column{{Name: "role"}},
    				Having:  []clause.Expression{clause.Eq{"role", "admin"}},
    			}},
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jan 06 07:02:53 UTC 2022
    - 1.1K bytes
    - Viewed (0)
Back to top