Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 331 - 340 of 385 for runnable (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top