- Sort Score
- Result 10 results
- Languages All
Results 371 - 380 of 1,179 for funcs (0.05 sec)
-
schema/naming_test.go
} } type CustomReplacer struct { f func(string) string } func (r CustomReplacer) Replace(name string) string { return r.f(name) } func TestCustomReplacer(t *testing.T) { ns := NamingStrategy{ TablePrefix: "public.", SingularTable: true, NameReplacer: CustomReplacer{ func(name string) string { replaced := "REPLACED_" + strings.ToUpper(name)
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Tue May 30 02:00:48 UTC 2023 - 7K bytes - Viewed (0) -
cmd/erasure-multipart.go
} func (er erasureObjects) getMultipartSHADir(bucket, object string) string { return getSHA256Hash([]byte(pathJoin(bucket, object))) } // checkUploadIDExists - verify if a given uploadID exists and is valid. func (er erasureObjects) checkUploadIDExists(ctx context.Context, bucket, object, uploadID string, write bool) (fi FileInfo, metArr []FileInfo, err error) { defer func() { if errors.Is(err, errFileNotFound) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 44.7K bytes - Viewed (0) -
cmd/handler-utils.go
} return path, nil } var regexVersion = regexp.MustCompile(`^/minio.*/(v\d+)/.*`) func extractAPIVersion(r *http.Request) string { if matches := regexVersion.FindStringSubmatch(r.URL.Path); len(matches) > 1 { return matches[1] } return "unknown" } func methodNotAllowedHandler(api string) func(w http.ResponseWriter, r *http.Request) { return errorResponseHandler }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 15.5K bytes - Viewed (0) -
cmd/tier.go
}, []string{"tier"}), } func (t *tierMetrics) Observe(tier string, dur time.Duration) { t.histogram.With(prometheus.Labels{"tier": tier}).Observe(dur.Seconds()) } func (t *tierMetrics) logSuccess(tier string) { t.Lock() defer t.Unlock() stat := t.requestsCount[tier] stat.success++ t.requestsCount[tier] = stat } func (t *tierMetrics) logFailure(tier string) { t.Lock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 12 20:44:05 UTC 2024 - 15.7K bytes - Viewed (0) -
internal/bucket/replication/rule.go
Status Status `xml:"Status"` // should be set to "Disabled" by default } // IsEmpty returns true if DeleteMarkerReplication is not set func (d DeleteMarkerReplication) IsEmpty() bool { return len(d.Status) == 0 } // Validate validates whether the status is disabled. func (d DeleteMarkerReplication) Validate() error { if d.IsEmpty() { return errDeleteMarkerReplicationMissing }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jan 24 23:22:20 UTC 2022 - 8.3K bytes - Viewed (0) -
internal/bucket/replication/tag.go
errInvalidTagValue = Errorf("The TagValue you have provided is invalid") ) 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: Tue Jun 01 21:59:40 UTC 2021 - 1.6K bytes - Viewed (0) -
clause/insert.go
package clause type Insert struct { Table Table Modifier string } // Name insert clause name func (insert Insert) Name() string { return "INSERT" } // Build build insert clause func (insert Insert) Build(builder Builder) { if insert.Modifier != "" { builder.WriteString(insert.Modifier) builder.WriteByte(' ') } builder.WriteString("INTO ") if insert.Table.Name == "" {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Mon Mar 09 09:07:00 UTC 2020 - 767 bytes - Viewed (0) -
cmd/erasure-server-pool.go
} var unlockOnDefer bool nsUnlocker := func() {} defer func() { if unlockOnDefer { nsUnlocker() } }() // Acquire lock if !opts.NoLock { lock := z.NewNSLock(bucket, object) lkctx, err := lock.GetRLock(ctx, globalOperationTimeout) if err != nil { return nil, err } ctx = lkctx.Context() nsUnlocker = func() { lock.RUnlock(lkctx) } unlockOnDefer = true }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 89.8K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance_gen.go
"github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *rebalSaveOpts) DecodeMsg(dc *msgp.Reader) (err error) { { var zb0001 uint8 zb0001, err = dc.ReadUint8() if err != nil { err = msgp.WrapError(err) return } (*z) = rebalSaveOpts(zb0001) } return } // EncodeMsg implements msgp.Encodable func (z rebalSaveOpts) EncodeMsg(en *msgp.Writer) (err error) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Mar 21 17:21:35 UTC 2024 - 26.8K bytes - Viewed (0) -
internal/bucket/lifecycle/noncurrentversion.go
func (n NoncurrentVersionExpiration) IsNull() bool { return n.IsDaysNull() && n.NewerNoncurrentVersions == 0 } // IsDaysNull returns true if days field is null func (n NoncurrentVersionExpiration) IsDaysNull() bool { return n.NoncurrentDays == ExpirationDays(0) } // Validate returns an error with wrong value func (n NoncurrentVersionExpiration) Validate() error { if !n.set {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Dec 14 17:41:44 UTC 2021 - 5.3K bytes - Viewed (0)