- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 1,642 for contexto (0.03 sec)
-
logger/slog.go
} func (l *slogLogger) Info(ctx context.Context, msg string, data ...interface{}) { if l.LogLevel >= Info { l.log(ctx, slog.LevelInfo, msg, slog.Any("data", data)) } } func (l *slogLogger) Warn(ctx context.Context, msg string, data ...interface{}) { if l.LogLevel >= Warn { l.log(ctx, slog.LevelWarn, msg, slog.Any("data", data)) } } func (l *slogLogger) Error(ctx context.Context, msg string, data ...interface{}) {
Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Thu Oct 30 10:56:26 UTC 2025 - 2.9K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
health *diskHealthTracker healthCheck bool metricsCache *cachevalue.Cache[DiskMetrics] diskCtx context.Context diskCancel context.CancelFunc } func (p *xlStorageDiskIDCheck) getMetrics() DiskMetrics { p.metricsCache.InitOnce(5*time.Second, cachevalue.Opts{}, func(ctx context.Context) (DiskMetrics, error) { diskMetric := DiskMetrics{ LastMinute: make(map[string]AccElem, len(p.apiLatencies)),
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Apr 25 05:41:04 UTC 2025 - 34.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/query/PhraseQueryCommand.java
} if (isSearchField(field)) { context.addFieldLog(field, text); stream(texts).of(stream -> stream.forEach(t -> context.addHighlightedQuery(t))); return buildMatchPhraseQuery(field, text); } context.addFieldLog(Constants.DEFAULT_FIELD, text);Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 4.5K bytes - Viewed (0) -
cmd/config.go
return err } func readServerConfigHistory(ctx context.Context, objAPI ObjectLayer, uuidKV string) ([]byte, error) { historyFile := pathJoin(minioConfigHistoryPrefix, uuidKV+kvPrefix) data, err := readConfig(ctx, objAPI, historyFile) if err != nil { return nil, err } return decryptData(data, historyFile) } func saveServerConfigHistory(ctx context.Context, objAPI ObjectLayer, kv []byte) error {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.9K bytes - Viewed (0) -
internal/cachevalue/cache.go
func NewFromFunc[T any](ttl time.Duration, opts Opts, update func(ctx context.Context) (T, error)) *Cache[T] { return &Cache[T]{ ttl: ttl, updateFn: update, opts: opts, } } // InitOnce initializes the cache with a TTL and an update function. It is // guaranteed to be called only once. func (t *Cache[T]) InitOnce(ttl time.Duration, opts Opts, update func(ctx context.Context) (T, error)) { t.Once.Do(func() { t.ttl = ttl
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri May 24 12:50:46 UTC 2024 - 4.4K bytes - Viewed (0) -
cmd/notification.go
func (sys *NotificationSys) ServerInfo(ctx context.Context, metrics bool) []madmin.ServerProperties { reply := make([]madmin.ServerProperties, len(sys.peerClients)) var wg sync.WaitGroup for i, client := range sys.peerClients { if client == nil { continue } wg.Add(1) go func(client *peerRESTClient, idx int) { defer wg.Done() ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 46K bytes - Viewed (0) -
internal/kms/kes.go
if err != nil { return nil, err } return c.client.Encrypt(context.Background(), keyID, plaintext, ctxBytes) } // DecryptKey decrypts the ciphertext with the key at the KES // server referenced by the key ID. The context must match the // context value used to generate the ciphertext. func (c *kesConn) Decrypt(ctx context.Context, req *DecryptRequest) ([]byte, error) { aad, err := req.AssociatedData.MarshalText() if err != nil {Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Aug 18 06:43:03 UTC 2024 - 7.3K bytes - Viewed (0) -
cmd/callhome.go
package cmd import ( "bytes" "compress/gzip" "context" "encoding/json" "errors" "fmt" "math/rand" "net/url" "time" "github.com/minio/madmin-go/v3" ) var callhomeLeaderLockTimeout = newDynamicTimeout(30*time.Second, 10*time.Second) // initCallhome will start the callhome task in the background. func initCallhome(ctx context.Context, objAPI ObjectLayer) { if !globalCallhomeConfig.Enabled() {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/query/FuzzyQueryCommand.java
final String field = getSearchField(context.getDefaultField(), term.field()); if (Constants.DEFAULT_FIELD.equals(field)) { final String text = term.text(); context.addFieldLog(field, text); context.addHighlightedQuery(text); return buildDefaultQueryBuilder(fessConfig, context, (f, b) -> QueryBuilders.fuzzyQuery(f, text)
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 5.7K bytes - Viewed (0) -
impl/maven-cli/src/test/java/org/apache/maven/cling/invoker/mvnup/goals/PluginUpgradeStrategyTest.java
when(options.plugins()).thenReturn(Optional.of(true)); when(options.all()).thenReturn(Optional.empty()); UpgradeContext context = createMockContext(options); assertTrue(strategy.isApplicable(context), "Strategy should be applicable when --plugins is true"); } @Test @DisplayName("should be applicable when --all option is specified")
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Tue Nov 18 18:03:26 UTC 2025 - 27.8K bytes - Viewed (0)