Search Options

Results per page
Sort
Preferred Languages
Advance

Results 691 - 700 of 1,425 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. internal/mountinfo/mountinfo_linux.go

    }
    
    // CheckCrossDevice - check if any list of paths has any sub-mounts at /proc/mounts.
    func CheckCrossDevice(absPaths []string) error {
    	return checkCrossDevice(absPaths, procMountsPath)
    }
    
    // Check cross device is an internal function.
    func checkCrossDevice(absPaths []string, mountsPath string) error {
    	mounts, err := readProcMounts(mountsPath)
    	if err != nil {
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.7K bytes
    - Viewed (0)
  3. internal/bucket/lifecycle/tag.go

    			default:
    				return errUnknownXMLTag
    			}
    		}
    	}
    
    	return nil
    }
    
    func (tag Tag) String() string {
    	return tag.Key + "=" + tag.Value
    }
    
    // IsEmpty returns whether this tag is empty or not.
    func (tag Tag) IsEmpty() bool {
    	return tag.Key == ""
    }
    
    // Validate checks this tag.
    func (tag Tag) Validate() error {
    	if len(tag.Key) == 0 || utf8.RuneCountInString(tag.Key) > 128 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/error.go

    )
    
    var ErrPartialAdd = errors.New("partial add error")
    
    type PartialAddError struct {
    	inner error
    }
    
    func (e *PartialAddError) Error() string {
    	return fmt.Sprintf("%s: %v", ErrPartialAdd.Error(), e.inner)
    }
    
    func (e *PartialAddError) Unwrap() []error {
    	return []error{ErrPartialAdd, e.inner}
    }
    
    func NewErrPartialAdd(err error) *PartialAddError {
    	return &PartialAddError{
    		inner: err,
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 1K bytes
    - Viewed (0)
  5. internal/s3select/parquet/args.go

    type ReaderArgs struct {
    	unmarshaled bool
    }
    
    // IsEmpty - returns whether reader args is empty or not.
    func (args *ReaderArgs) IsEmpty() bool {
    	return !args.unmarshaled
    }
    
    // UnmarshalXML - decodes XML data.
    func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	// Make subtype to avoid recursive UnmarshalXML().
    	type subReaderArgs ReaderArgs
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.4K bytes
    - Viewed (0)
  6. internal/ioutil/discard.go

    // and as such incurred latencies.
    var Discard io.Writer = discard{}
    
    // discard is /dev/null for Golang.
    type discard struct{}
    
    func (discard) Write(p []byte) (int, error) {
    	return len(p), nil
    }
    
    // DiscardReader discarded reader
    func DiscardReader(r io.Reader) {
    	Copy(Discard, r)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Nov 06 22:26:08 UTC 2023
    - 1.3K bytes
    - Viewed (0)
  7. cni/pkg/install/cniconfig_test.go

    			CNIConfName:      c.specifiedConfName,
    			ChainedCNIPlugin: c.chainedCNIPlugin,
    			PluginLogLevel:   "debug",
    			CNIAgentRunDir:   kubeconfigFilename,
    		}
    		test := func(cfg config.InstallConfig) func(t *testing.T) {
    			return func(t *testing.T) {
    				// Create temp directory for files
    				tempDir := t.TempDir()
    
    				// Create existing config files if specified in test case
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 18:38:14 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  8. cmd/bucket-replication-stats.go

    	qTimer          *time.Ticker // ticker for calculating queue stats
    }
    
    func (r *ReplicationStats) trackEWMA() {
    	for {
    		select {
    		case <-r.movingAvgTicker.C:
    			r.updateMovingAvg()
    		case <-GlobalContext.Done():
    			return
    		}
    	}
    }
    
    func (r *ReplicationStats) updateMovingAvg() {
    	r.RLock()
    	for _, s := range r.Cache {
    		for _, st := range s.Stats {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  9. cmd/admin-heal-ops.go

    	return func() error {
    		// NOTE: Healing on meta is run regardless
    		// of any bucket being selected, this is to ensure that
    		// meta are always upto date and correct.
    		return objAPI.HealObjects(h.ctx, minioMetaBucket, metaPrefix, h.settings, func(bucket, object, versionID string, scanMode madmin.HealScanMode) error {
    			if h.isQuitting() {
    				return errHealStopSignalled
    			}
    
    			err := h.queueHealTask(healSource{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  10. schema/naming.go

    // RelationshipFKName generate fk name for relation
    func (ns NamingStrategy) RelationshipFKName(rel Relationship) string {
    	return ns.formatName("fk", rel.Schema.Table, ns.toDBName(rel.Name))
    }
    
    // CheckerName generate checker name
    func (ns NamingStrategy) CheckerName(table, column string) string {
    	return ns.formatName("chk", table, column)
    }
    
    // IndexName generate index name
    func (ns NamingStrategy) IndexName(table, column string) string {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jun 12 03:46:59 UTC 2024
    - 5.3K bytes
    - Viewed (0)
Back to top