- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 39 for setTags (0.19 sec)
-
internal/logger/reqinfo.go
if r == nil { return nil } r.Lock() defer r.Unlock() r.tags = append(r.tags, KeyVal{key, val}) return r } // SetTags - sets key/val to ReqInfo.tags func (r *ReqInfo) SetTags(key string, val interface{}) *ReqInfo { if r == nil { return nil } r.Lock() defer r.Unlock() // Search of tag key already exists in tags var updated bool
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.4K bytes - Viewed (0) -
cmd/iam.go
return nil } // Notify all other MinIO peers to delete policy for _, nerr := range globalNotificationSys.DeletePolicy(policyName) { if nerr.Err != nil { logger.GetReqInfo(ctx).SetTags("peerAddress", nerr.Host.String()) iamLogIf(ctx, nerr.Err) } } return nil } // InfoPolicy - returns the policy definition with some metadata.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
cmd/admin-handlers.go
if nerr.Err != nil { err := AdminError{ Code: AdminUpdateApplyFailure, Message: nerr.Err.Error(), StatusCode: http.StatusInternalServerError, } logger.GetReqInfo(ctx).SetTags("peerAddress", nerr.Host.String()) adminLogIf(ctx, fmt.Errorf("server update failed with %w", err)) writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
istioctl/cmd/root_test.go
} _ = parent.PersistentFlags().String(childFlag2, "", childFlag2) parent.AddCommand(child) // verify both parent flags and the child flag are visible by default parent.SetArgs([]string{"child", "--help"}) if err := parent.Execute(); err != nil { t.Fatal(err) } got := out.String() out.Reset() checkHelpForFlag(t, got, parentFlag0, true) checkHelpForFlag(t, got, parentFlag1, true)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 15 17:59:55 GMT 2021 - 2.4K bytes - Viewed (0) -
src/cmd/addr2line/main.go
fmt.Fprintf(w, "\tfunction name\n") fmt.Fprintf(w, "\tfile:line\n") } func usage() { printUsage(os.Stderr) os.Exit(2) } func main() { log.SetFlags(0) log.SetPrefix("addr2line: ") // pprof expects this behavior when checking for addr2line if len(os.Args) > 1 && os.Args[1] == "--help" { printUsage(os.Stdout) os.Exit(0) } flag.Usage = usage
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Apr 11 16:34:30 GMT 2022 - 2.3K bytes - Viewed (0) -
operator/cmd/mesh/install.go
warnMarker, operatorVer.OperatorCodeBaseVersion) } setFlags := applyFlagAliases(iArgs.Set, iArgs.ManifestsPath, iArgs.Revision) _, iop, err := manifest.GenerateConfig(iArgs.InFilenames, setFlags, iArgs.Force, kubeClient, l) if err != nil { return fmt.Errorf("generate config: %v", err) }
Go - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 15.2K bytes - Viewed (0) -
operator/cmd/mesh/profile-diff.go
l := clog.NewConsoleLogger(cmd.OutOrStdout(), cmd.OutOrStderr(), nil) setFlags := make([]string, 0) if pfArgs.manifestsPath != "" { setFlags = append(setFlags, fmt.Sprintf("installPackagePath=%s", pfArgs.manifestsPath)) } return profileDiffInternal(args[0], args[1], setFlags, cmd.OutOrStdout(), l) } func profileDiffInternal(profileA, profileB string, setFlags []string, writer io.Writer, l clog.Logger) (bool, error) {
Go - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 3.1K bytes - Viewed (0) -
internal/etag/reader.go
// A Reader wraps an io.Reader and computes the // MD5 checksum of the read content as ETag. // // Optionally, a Reader can also verify that // the computed ETag matches an expected value. // Therefore, it compares both ETags once the // underlying io.Reader returns io.EOF. // If the computed ETag does not match the // expected ETag then Read returns a VerifyError. // // Reader implements the Tagger interface. type Reader struct {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 4.8K bytes - Viewed (0) -
cmd/erasure-multipart.go
} } } var checksumCombined []byte // However, in case of encryption, the persisted part ETags don't match // what we have sent to the client during PutObjectPart. The reason is // that ETags are encrypted. Hence, the client will send a list of complete // part ETags of which non can match the ETag of any part. For example // ETag (client): 30902184f4e62dd8f98f0aaff810c626
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
misc/go_android_exec/main.go
} return exec.Command("adb", args...) } const ( deviceRoot = "/data/local/tmp/go_android_exec" deviceGoroot = deviceRoot + "/goroot" ) func main() { log.SetFlags(0) log.SetPrefix("go_android_exec: ") exitCode, err := runMain() if err != nil { log.Fatal(err) } os.Exit(exitCode) } func runMain() (int, error) {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Aug 21 17:46:57 GMT 2023 - 15.3K bytes - Viewed (0)