Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 1,440 for ERROR (0.03 sec)

  1. internal/rest/client_test.go

    	tests := []struct {
    		name   string
    		err    error
    		target interface{}
    		want   bool
    	}{
    		{
    			name:   "url.Error",
    			err:    &url.Error{Op: "PUT", URL: "http://localhost/1234", Err: restError("remote server offline")},
    			target: &url.Error{},
    			want:   true,
    		},
    		{
    			name: "net.Error",
    			err:  &url.Error{Op: "PUT", URL: "http://localhost/1234", Err: restError("remote server offline")},
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Nov 16 17:28:29 UTC 2021
    - 1.9K bytes
    - Viewed (0)
  2. src/main/webapp/js/admin/plugins/form-validator/theme-default.min.css

    5px center;background-repeat:no-repeat;background-color:#FFF}div.form-error{background-color:#f2dede;padding:15px;margin-bottom:20px;border:1px solid #b94a48;border-radius:4px}div.form-error strong{font-weight:700;display:block;margin:0;padding:0 0 10px}div.form-error strong,div.form-error ul li{line-height:140%;color:#b94a48;font-family:"Helvetica Neue",Helvetica,Arial,sans-serif;font-size:14px}div.form-error ul,div.form-error ul li{background:0 0}...
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Mon Jan 01 05:12:47 UTC 2018
    - 33.3K bytes
    - Viewed (0)
  3. cmd/metrics-v3-cache.go

    	}
    }
    
    type nodesOnline struct {
    	Online, Offline int
    }
    
    func newNodesUpDownCache() *cachevalue.Cache[nodesOnline] {
    	loadNodesUpDown := func(ctx context.Context) (v nodesOnline, err error) {
    		v.Online, v.Offline = globalNotificationSys.GetPeerOnlineCount()
    		return
    	}
    	return cachevalue.NewFromFunc(1*time.Minute,
    		cachevalue.Opts{ReturnLastGood: true},
    		loadNodesUpDown)
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  4. internal/event/target/kafka.go

    	return target.store
    }
    
    // IsActive - Return true if target is up and active
    func (target *KafkaTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    		return false, err
    	}
    	return target.isActive()
    }
    
    func (target *KafkaTarget) isActive() (bool, error) {
    	// Refer https://github.com/IBM/sarama/issues/1341
    	brokers := target.client.Brokers()
    	if len(brokers) == 0 {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  5. cmd/kms-handlers.go

    	}
    
    	stat, err := GlobalKMS.Status(ctx)
    	if err != nil {
    		writeCustomErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInternalError), err.Error(), r.URL)
    		return
    	}
    	resp, err := json.Marshal(stat)
    	if err != nil {
    		writeCustomErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInternalError), err.Error(), r.URL)
    		return
    	}
    	writeSuccessResponseJSON(w, resp)
    }
    
    // KMSMetricsHandler - GET /minio/kms/v1/metrics
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  6. lib/wasm/wasm_exec_node.js

    	process.on("exit", (code) => { // Node.js exits if no event handler is pending
    		if (code === 0 && !go.exited) {
    			// deadlock, make Go print error and stack traces
    			go._pendingEvent = { id: 0 };
    			go._resume();
    		}
    	});
    	return go.run(result.instance);
    }).catch((err) => {
    	console.error(err);
    	process.exit(1);
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Fri Aug 30 19:15:21 UTC 2024
    - 1.2K bytes
    - Viewed (0)
  7. tests/test_starlette_exception.py

    
    @app.get("/items/{item_id}")
    async def read_item(item_id: str):
        if item_id not in items:
            raise HTTPException(
                status_code=404,
                detail="Item not found",
                headers={"X-Error": "Some custom header"},
            )
        return {"item": items[item_id]}
    
    
    @app.get("/http-no-body-statuscode-exception")
    async def no_body_status_code_exception():
        raise HTTPException(status_code=204)
    
    
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Fri Jun 30 18:25:16 UTC 2023
    - 7.4K bytes
    - Viewed (0)
  8. internal/logger/target/kafka/kafka.go

    		return nil
    	}
    
    	select {
    	case h.logCh <- entry:
    	case <-ctx.Done():
    		// return error only for context timedout.
    		if errors.Is(ctx.Err(), context.DeadlineExceeded) {
    			return ctx.Err()
    		}
    		return nil
    	default:
    		// log channel is full, do not wait and return
    		// an error immediately to the caller
    		atomic.AddInt64(&h.totalMessages, 1)
    		atomic.AddInt64(&h.failedMessages, 1)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  9. cmd/endpoint.go

    func NewEndpoints(args ...string) (endpoints Endpoints, err error) {
    	var endpointType EndpointType
    	var scheme string
    
    	uniqueArgs := set.NewStringSet()
    	// Loop through args and adds to endpoint list.
    	for i, arg := range args {
    		endpoint, err := NewEndpoint(arg)
    		if err != nil {
    			return nil, fmt.Errorf("'%s': %s", arg, err.Error())
    		}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 34.2K bytes
    - Viewed (0)
  10. internal/event/target/webhook.go

    // Close - does nothing and available for interface compatibility.
    func (target *WebhookTarget) Close() error {
    	target.cancel()
    	return nil
    }
    
    func (target *WebhookTarget) init() error {
    	return target.initOnce.Do(target.initWebhook)
    }
    
    // Only called from init()
    func (target *WebhookTarget) initWebhook() error {
    	args := target.args
    	transport := target.transport
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
Back to top