- Sort Score
- Num 10 results
- Language All
Results 331 - 340 of 385 for runnable (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/bucket-targets.go
func newHCClient() *madmin.AnonymousClient { clnt, e := madmin.NewAnonymousClientNoEndpoint() if e != nil { bugLogIf(GlobalContext, errors.New("Unable to initialize health check client")) return nil } clnt.SetCustomTransport(globalRemoteTargetTransport) return clnt } // heartBeat performs liveness check on remote endpoints.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 20.9K bytes - Click Count (0) -
cmd/bucket-metadata-sys.go
return err } bucketMetas[index] = meta return nil }, index) } errs := g.Wait() for index, err := range errs { if err != nil { internalLogOnceIf(ctx, fmt.Errorf("Unable to load bucket metadata, will be retried: %w", err), "load-bucket-metadata-"+buckets[index], logger.WarningKind) } } // Hold lock here to update in-memory map at once,
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 20.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/DocumentHelper.java
final CrawlerClient client = crawlerClientFactory.getClient(url); if (client == null) { throw new CrawlingAccessException( "CrawlerClient is null for URL: " + url + ". Unable to access the document without a crawler client."); } final SystemHelper systemHelper = ComponentUtil.getSystemHelper(); final long startTime = systemHelper.getCurrentTimeAsLong();
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Mon Mar 30 14:27:04 GMT 2026 - 17.4K bytes - Click Count (0) -
docs/zh-hant/docs/tutorial/handling-errors.md
"type": "type_error.integer" } ] } ``` 你將會改而得到文字版: ``` Validation errors: Field: ('path', 'item_id'), Error: Input should be a valid integer, unable to parse string as an integer ``` ### 覆寫 `HTTPException` 的錯誤處理器 { #override-the-httpexception-error-handler } 同樣地,你也可以覆寫 `HTTPException` 的處理器。 例如,你可能想在這些錯誤時回傳純文字而非 JSON:
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Mar 20 17:05:38 GMT 2026 - 8.3K bytes - Click Count (0) -
internal/event/target/nats.go
queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension) if err := queueStore.Open(); err != nil { return nil, fmt.Errorf("unable to initialize the queue store of NATS `%s`: %w", id, err) } } target := &NATSTarget{ id: event.TargetID{ID: id, Name: "nats"}, args: args, loggerOnce: loggerOnce,
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Apr 27 04:30:57 GMT 2025 - 13.5K bytes - Click Count (0) -
internal/config/identity/plugin/config.go
} // Use the user provided ID here. resourceID += roleID } roleArn, err := arn.NewIAMRoleARN(resourceID, serverRegion) if err != nil { return args, config.Errorf("unable to generate ARN from the plugin config: %v", err) } args = Args{ URL: u, AuthToken: authToken, Transport: transport, CloseRespFn: closeRespFn, RolePolicy: rolePolicy,
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 13.3K bytes - Click Count (0) -
cmd/batch-rotate.go
globalBatchJobsMetrics.save(job.ID, ri) // persist in-memory state to disk. batchLogIf(ctx, ri.updateAfter(ctx, api, 0, job)) if err := r.Notify(ctx, ri); err != nil { batchLogIf(ctx, fmt.Errorf("unable to notify %v", err)) } cancel() return nil } //msgp:ignore batchKeyRotationJobError type batchKeyRotationJobError struct { Code string Description string
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 14.7K bytes - Click Count (0) -
android/guava/src/com/google/common/base/Throwables.java
/** * Returns the innermost cause of {@code throwable}. The first throwable in a chain provides * context from when the error or exception was initially detected. Example usage: * * <pre> * assertEquals("Unable to assign a customer id", Throwables.getRootCause(e).getMessage()); * </pre> * * @throws IllegalArgumentException if there is a loop in the causal chain */Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 20.6K bytes - Click Count (0) -
internal/ringbuffer/ring_buffer.go
ErrIsNotEmpty = errors.New("ringbuffer is not empty") // ErrAcquireLock is returned when the lock is not acquired on Try operations. ErrAcquireLock = errors.New("unable to acquire lock") // ErrWriteOnClosed is returned when write on a closed ringbuffer. ErrWriteOnClosed = errors.New("write on closed ringbuffer") )
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 13.3K bytes - Click Count (0) -
cmd/test-utils_test.go
} // initialize the server and obtain the credentials and root. // credentials are necessary to sign the HTTP request. if err = newTestConfig(globalMinioDefaultRegion, objLayer); err != nil { args.t.Fatalf("Unable to initialize server config. %s", err) } credentials := globalActiveCred // Executing the object layer tests for single node setup.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 77K bytes - Click Count (0)