- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 150 for ctx (0.01 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/dummy-handlers.go
writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return } // Validate if bucket exists, before proceeding further... _, err := objAPI.GetBucketInfo(ctx, bucket, BucketOptions{}) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Aug 13 15:25:16 GMT 2024 - 8.8K bytes - Click Count (0) -
cmd/object-api-input-checks.go
) // Checks on CopyObject arguments, bucket and object. func checkCopyObjArgs(ctx context.Context, bucket, object string) error { return checkBucketAndObjectNames(ctx, bucket, object) } // Checks on GetObject arguments, bucket and object. func checkGetObjArgs(ctx context.Context, bucket, object string) error { return checkBucketAndObjectNames(ctx, bucket, object) } // Checks on DeleteObject arguments, bucket and object.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.7K bytes - Click Count (0) -
internal/grid/muxserver.go
var cancel context.CancelFunc ctx = setCaller(ctx, c.remote) if msg.DeadlineMS > 0 { ctx, cancel = context.WithTimeout(ctx, time.Duration(msg.DeadlineMS)*time.Millisecond) } else { ctx, cancel = context.WithCancel(ctx) } m := muxServer{ ID: msg.MuxID, RecvSeq: msg.Seq + 1, SendSeq: msg.Seq, ctx: ctx, cancel: cancel, parent: c, LastPing: time.Now().Unix(), BaseFlags: c.baseFlags,
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 9.7K bytes - Click Count (0) -
cmd/callhome.go
} ctx = lkctx.Context() defer locker.Unlock(lkctx) // Perform callhome once and then keep running it at regular intervals. performCallhome(ctx) callhomeTimer := time.NewTimer(globalCallhomeConfig.FrequencyDur()) defer callhomeTimer.Stop() for { if !globalCallhomeConfig.Enabled() { // Stop the processing as callhome got disabled return false } select { case <-ctx.Done():
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.3K bytes - Click Count (0) -
cmd/lock-rest-client.go
func (c *lockRESTClient) RLock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) { return c.call(ctx, lockRPCRLock, &args) } // Lock calls lock REST API. func (c *lockRESTClient) Lock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) { return c.call(ctx, lockRPCLock, &args) } // RUnlock calls read unlock REST API.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Jul 29 18:10:04 GMT 2024 - 3.3K bytes - Click Count (0) -
cmd/object-lambda-handlers.go
if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } eventData, err := getLambdaEventData(bucket, object, cred, r) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } resp, err := target.Send(eventData) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } defer resp.Body.Close()Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Jul 18 21:56:31 GMT 2025 - 6.5K bytes - Click Count (0) -
cmd/admin-handler-utils.go
if entity == "" { return toAPIError(ctx, fmt.Errorf("error exporting %s with: %w", fname, err)) } return toAPIError(ctx, fmt.Errorf("error exporting %s from %s with: %w", entity, fname, err)) } // wraps import error for more context func importError(ctx context.Context, err error, fname, entity string) APIError { if entity == "" {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Jul 03 07:17:20 GMT 2024 - 8.4K bytes - Click Count (0) -
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{}) {
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Thu Oct 30 10:56:26 GMT 2025 - 2.9K bytes - Click Count (0) -
internal/logger/targets.go
func UpdateHTTPWebhooks(ctx context.Context, cfgs map[string]http.Config) (errs []error) { return updateHTTPTargets(ctx, cfgs, systemTargets) } // UpdateAuditWebhooks swaps audit webhook targets with newly loaded ones from the cfg func UpdateAuditWebhooks(ctx context.Context, cfgs map[string]http.Config) (errs []error) { return updateHTTPTargets(ctx, cfgs, auditTargets) }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 6K bytes - Click Count (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 {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.9K bytes - Click Count (0)