- Sort Score
- Result 10 results
- Languages All
Results 681 - 690 of 1,020 for err (0.04 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)