Search Options

Results per page
Sort
Preferred Languages
Advance

Results 281 - 290 of 906 for errh (0.02 sec)

  1. misc/linkcheck/linkcheck.go

    func crawlLoop() {
    	for url := range urlq {
    		if err := doCrawl(url); err != nil {
    			addProblem(url, err.Error())
    		}
    	}
    }
    
    func doCrawl(url string) error {
    	defer wg.Done()
    
    	req, err := http.NewRequest("GET", url, nil)
    	if err != nil {
    		return err
    	}
    	res, err := http.DefaultTransport.RoundTrip(req)
    	if err != nil {
    		return err
    	}
    	// Handle redirects.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 06 15:53:04 UTC 2021
    - 3.9K bytes
    - Viewed (0)
  2. istioctl/pkg/writer/compare/comparator.go

    		istiodDump := &configdump.Wrapper{}
    		err := json.Unmarshal(resp, istiodDump)
    		if err != nil {
    			continue
    		}
    		c.istiod = istiodDump
    		break
    	}
    	if c.istiod == nil {
    		return nil, fmt.Errorf("unable to find config dump in Istiod responses")
    	}
    	envoyDump := &configdump.Wrapper{}
    	err := json.Unmarshal(envoyResponse, envoyDump)
    	if err != nil {
    		return nil, err
    	}
    	c.envoy = envoyDump
    	c.w = w
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sun Apr 21 17:42:54 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  3. cmd/sts-handlers.go

    	}
    
    	if err := claims.populateSessionPolicy(r.Form); err != nil {
    		writeSTSErrorResponse(ctx, w, ErrSTSInvalidParameterValue, err)
    		return
    	}
    
    	secret, err := getTokenSigningKey()
    	if err != nil {
    		writeSTSErrorResponse(ctx, w, ErrSTSInternalError, err)
    		return
    	}
    	cred, err := auth.GetNewCredentialsWithMetadata(claims, secret)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 33.9K bytes
    - Viewed (0)
  4. cmd/bucket-handlers_test.go

    	credentials auth.Credentials, t *testing.T,
    ) {
    	_, err := obj.PutObject(GlobalContext, bucketName, "test-object", mustGetPutObjReader(t, bytes.NewReader([]byte{}), int64(0), "", "e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855"), ObjectOptions{})
    	// if object upload fails stop the test.
    	if err != nil {
    		t.Fatalf("Error uploading object: <ERROR> %v", err)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 39.8K bytes
    - Viewed (0)
  5. internal/config/notify/legacy.go

    )
    
    // SetNotifyKafka - helper for config migration from older config.
    func SetNotifyKafka(s config.Config, name string, cfg target.KafkaArgs) error {
    	if !cfg.Enable {
    		return nil
    	}
    
    	if err := cfg.Validate(); err != nil {
    		return err
    	}
    
    	s[config.NotifyKafkaSubSys][name] = config.KVS{
    		config.KV{
    			Key:   config.Enable,
    			Value: config.EnableOn,
    		},
    		config.KV{
    			Key: target.KafkaBrokers,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 19 04:37:54 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  6. istioctl/pkg/metrics/metrics.go

    	var me *multierror.Error
    	var err error
    	sm := workloadMetrics{workload: workload}
    	sm.totalRPS, err = vectorValue(promAPI, rpsQuery)
    	if err != nil {
    		me = multierror.Append(me, err)
    	}
    
    	sm.errorRPS, err = vectorValue(promAPI, errRPSQuery)
    	if err != nil {
    		me = multierror.Append(me, err)
    	}
    
    	p50Latency, err := getLatency(promAPI, wname, wns, duration, 0.5)
    	if err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  7. schema/schema_test.go

    	if err != nil {
    		t.Fatalf("failed to parse user with map, got error %v", err)
    	}
    
    	if field := user.FieldsByName["Attrs"]; field.DataType != "Map(String,String)" {
    		t.Errorf("failed to parse user field Attrs")
    	}
    }
    
    func TestParseSchemaWithPointerFields(t *testing.T) {
    	user, err := schema.Parse(&User{}, &sync.Map{}, schema.NamingStrategy{})
    	if err != nil {
    		t.Fatalf("failed to parse pointer user, got error %v", err)
    	}
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jun 20 12:19:31 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  8. cni/pkg/cmd/root.go

    		// the CNI binary installed.
    		if err = installer.Run(ctx); err != nil {
    			if errors.Is(err, context.Canceled) || errors.Is(err, context.DeadlineExceeded) {
    				log.Infof("installer complete: %v", err)
    				// Error was caused by interrupt/termination signal
    				err = nil
    			} else {
    				log.Errorf("installer failed: %v", err)
    			}
    		}
    
    		if cleanErr := installer.Cleanup(); cleanErr != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 16 15:33:47 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  9. tests/connpool_test.go

    		}
    	}()
    
    	db, err := gorm.Open(mysql.New(mysql.Config{Conn: conn, DisableWithReturning: true}))
    	if err != nil {
    		t.Fatalf("Should open db success, but got %v", err)
    	}
    
    	tx := db.Begin()
    	user := *GetUser("transaction", Config{})
    
    	if err = tx.Save(&user).Error; err != nil {
    		t.Fatalf("No error should raise, but got %v", err)
    	}
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Feb 06 02:54:40 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  10. cmd/batch-job-common-types.go

    func (s *BatchJobSize) UnmarshalYAML(unmarshal func(interface{}) error) error {
    	var batchExpireSz string
    	err := unmarshal(&batchExpireSz)
    	if err != nil {
    		return err
    	}
    	sz, err := humanize.ParseBytes(batchExpireSz)
    	if err != nil {
    		return err
    	}
    	*s = BatchJobSize(sz)
    	return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 11 03:13:30 UTC 2024
    - 7.9K bytes
    - Viewed (0)
Back to top