- Sort Score
- Result 10 results
- Languages All
Results 691 - 700 of 1,425 for Func (0.04 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)