Search Options

Results per page
Sort
Preferred Languages
Advance

Results 681 - 690 of 1,020 for err (0.04 sec)

  1. internal/event/target/postgresql_test.go

    	for _, name := range validTables {
    		if err := validatePsqlTableName(name); err != nil {
    			t.Errorf("Should be valid: %s - %s", name, err)
    		}
    	}
    	for _, name := range invalidTables {
    		if err := validatePsqlTableName(name); err != errInvalidPsqlTablename {
    			t.Errorf("Should be invalid: %s - %s", name, err)
    		}
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Apr 24 17:51:07 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  2. docs/site-replication/gen-oidc-sts-cred.go

    		ProviderURL:  "http://127.0.0.1:5556/dex",
    		RedirectURL:  "http://127.0.0.1:10000/oauth_callback",
    	}
    
    	oidcToken, err := cmd.MockOpenIDTestUserInteraction(ctx, appParams, "******@****.***", "dillon")
    	if err != nil {
    		log.Fatalf("Failed to generate OIDC token: %v", err)
    	}
    
    	roleARN := os.Getenv("ROLE_ARN")
    	webID := cr.STSWebIdentity{
    		Client:      &http.Client{},
    		STSEndpoint: endpoint,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Apr 29 01:27:09 UTC 2022
    - 2.3K bytes
    - Viewed (0)
  3. cmd/namespace-lock.go

    		Timeout:       timeout.Timeout(),
    		RetryInterval: timeout.RetryInterval(),
    	}) {
    		timeout.LogFailure()
    		defer cancel()
    		if err := newCtx.Err(); err == context.Canceled {
    			return LockContext{ctx: ctx, cancel: func() {}}, err
    		}
    		return LockContext{ctx: ctx, cancel: func() {}}, OperationTimedOut{}
    	}
    	timeout.LogSuccess(UTCNow().Sub(start))
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  4. internal/event/name.go

    }
    
    // UnmarshalXML - decodes XML data.
    func (name *Name) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	var s string
    	if err := d.DecodeElement(&s, &start); err != nil {
    		return err
    	}
    
    	eventName, err := ParseName(s)
    	if err != nil {
    		return err
    	}
    
    	*name = eventName
    	return nil
    }
    
    // MarshalJSON - encodes to JSON data.
    func (name Name) MarshalJSON() ([]byte, error) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 01 01:11:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  5. cni/pkg/util/executil.go

    	stdout := &bytes.Buffer{}
    	stderr := &bytes.Buffer{}
    	externalCommand.Stdout = stdout
    	externalCommand.Stderr = stderr
    
    	err := externalCommand.Run()
    
    	if err != nil || len(stderr.Bytes()) != 0 {
    		return stderr.String(), err
    	}
    
    	return strings.TrimSuffix(stdout.String(), "\n"), err
    }
    
    func Execute(cmd string, args ...string) error {
    	log.Debugf("Running command: %s %s", cmd, strings.Join(args, " "))
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  6. internal/bucket/bandwidth/reader.go

    	av := int(r.throttle.Tokens())
    	if av < tokens && av > 0 {
    		tokens = av
    		need = int(math.Min(float64(tokens), float64(need)))
    	}
    	err = r.throttle.WaitN(r.ctx, tokens)
    	if err != nil {
    		return
    	}
    	n, err = r.r.Read(buf[:need])
    	if err != nil {
    		r.lastErr = err
    		return
    	}
    	r.m.updateMeasurement(r.opts.BucketOptions, uint64(tokens))
    	return
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 12 14:57:31 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  7. internal/handlers/forwarder.go

    //
    //	`http: proxy error: context canceled` printed by Golang
    func (f *Forwarder) customErrHandler(w http.ResponseWriter, r *http.Request, err error) {
    	if f.Logger != nil && err != context.Canceled {
    		f.Logger(err)
    	}
    	w.WriteHeader(http.StatusBadGateway)
    }
    
    func (f *Forwarder) getURLFromRequest(req *http.Request) *url.URL {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Apr 07 05:42:10 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  8. istioctl/pkg/validate/validate_test.go

    	t.Helper()
    	validFile, err := os.CreateTemp("", "TestValidateCommand")
    	if err != nil {
    		t.Fatal(err)
    	}
    	if _, err := validFile.WriteString(data); err != nil {
    		t.Fatal(err)
    	}
    	return validFile.Name(), validFile
    }
    
    func createTestDirectory(t *testing.T, files map[string]string) string {
    	t.Helper()
    	tempDir, err := os.MkdirTemp("", "TestValidateCommand")
    	if err != nil {
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Fri Aug 02 16:18:14 UTC 2024
    - 21.4K bytes
    - Viewed (0)
  9. cni/pkg/nodeagent/pod_cache.go

    		nspathInContainer := filepath.Join(hostMountsPath, nspath)
    		ns, err := OpenNetns(nspathInContainer)
    		if err != nil {
    			err = fmt.Errorf("failed to open netns: %w. Make sure that the netns host path %s is mounted in under %s in the container", err, nspath, hostMountsPath)
    			log.Error(err.Error())
    		}
    		return ns, err
    	}
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Fri May 31 17:18:11 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  10. schema/constraint_test.go

    	Name2 string `gorm:"check:name <> 'jinzhu'"`
    	Name3 string `gorm:"check:,name <> 'jinzhu'"`
    }
    
    func TestParseCheck(t *testing.T) {
    	user, err := schema.Parse(&UserCheck{}, &sync.Map{}, schema.NamingStrategy{})
    	if err != nil {
    		t.Fatalf("failed to parse user check, got error %v", err)
    	}
    
    	results := map[string]schema.CheckConstraint{
    		"name_checker": {
    			Name:       "name_checker",
    			Constraint: "name <> 'jinzhu'",
    		},
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Sun Feb 04 07:49:19 UTC 2024
    - 2.2K bytes
    - Viewed (0)
Back to top