- Sort Score
- Result 10 results
- Languages All
Results 221 - 230 of 2,275 for Mirror (0.08 sec)
-
internal/s3select/sql/aggregation.go
return e.Expression.aggregateRow(r, tableAlias) } func (e *Expression) aggregateRow(r Record, tableAlias string) error { for _, ex := range e.And { err := ex.aggregateRow(r, tableAlias) if err != nil { return err } } return nil } func (e *ListExpr) aggregateRow(r Record, tableAlias string) error { for _, ex := range e.Elements {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sat Dec 23 07:19:11 UTC 2023 - 7.9K bytes - Viewed (0) -
internal/stmt_store/stmt_store.go
"sync" "time" "gorm.io/gorm/internal/lru" ) type Stmt struct { *sql.Stmt Transaction bool prepared chan struct{} prepareErr error } func (stmt *Stmt) Error() error { return stmt.prepareErr } func (stmt *Stmt) Close() error { <-stmt.prepared if stmt.Stmt != nil { return stmt.Stmt.Close() } return nil }
Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Sun Apr 27 06:05:16 UTC 2025 - 6K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
Duration: duration, Path: path, Error: errStr, Bytes: sz, } } func (m *decomMetrics) log(d decomMetric, poolIdx int, paths ...string) func(z int64, err error) { startTime := time.Now() return func(sz int64, err error) { duration := time.Since(startTime) if globalTrace.NumSubscribers(madmin.TraceDecommission) > 0 {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 42.2K bytes - Viewed (1) -
internal/config/errors-utils.go
} } // Failed to identify what type of error this, return a simple UI error return Err{msg: err.Error()} } // FmtError converts a fatal error message to a more clear error // using some colors func FmtError(introMsg string, err error, jsonFlag bool) string { renderedTxt := "" uiErr := ErrorToErr(err) // JSON print if jsonFlag {Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 3.8K bytes - Viewed (0) -
internal/store/queuestore.go
} } return nil } // Delete - Remove the store directory from disk func (store *QueueStore[_]) Delete() error { return os.Remove(store.directory) } // PutMultiple - puts an item to the store. func (store *QueueStore[I]) PutMultiple(items []I) (Key, error) { // Generate a new UUID for the key. uid, err := uuid.NewRandom() if err != nil { return Key{}, err } store.Lock()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 7.8K bytes - Viewed (0) -
tests/named_argument_test.go
Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Tue Dec 21 11:50:00 UTC 2021 - 2.7K bytes - Viewed (0) -
internal/rest/client.go
online closed ) // NetworkError - error type in case of errors related to http/transport // for ex. connection refused, connection reset, dns resolution failure etc. // All errors returned by storage-rest-server (ex errFileNotFound, errDiskNotFound) are not considered to be network errors. type NetworkError struct { Err error } func (n *NetworkError) Error() string { return n.Err.Error() }Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 14.7K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/metadata/ArtifactMetadata.java
} public void setWhy(String why) { this.why = why; } public String getError() { return error; } public void setError(String error) { this.error = error; } public boolean isError() { return error == null; } public String getDependencyConflictId() { return groupId + ":" + artifactId; }Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Sun Mar 30 23:08:36 UTC 2025 - 8K bytes - Viewed (0) -
internal/cachevalue/cache.go
// If the Update function returns an error the value is forwarded as is and not cached. func (t *Cache[T]) GetWithCtx(ctx context.Context) (T, error) { v := t.val.Load() ttl := t.ttl vTime := t.lastUpdateMs.Load() tNow := time.Now().UnixMilli() if v != nil && tNow-vTime < ttl.Milliseconds() { return *v, nil } // Fetch new value asynchronously, while we do not return an error // if v != nil value or
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri May 24 12:50:46 UTC 2024 - 4.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/error/ErrorAction.java
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 2.1K bytes - Viewed (0)