- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for setTags (0.23 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) -
cmd/endpoint-ellipses.go
} s := endpointSet{ endpoints: args, setIndexes: setIndexes, } setArgs = s.Get() } else { s, err := parseEndpointSet(customSetDriveCount, args...) if err != nil { return nil, err } setArgs = s.Get() } uniqueArgs := set.NewStringSet() for _, sargs := range setArgs { for _, arg := range sargs { if uniqueArgs.Contains(arg) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 21:22:47 GMT 2024 - 14.8K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint_test.go
t.Fatal(err) } expectedOut := string(defaultFile) if len(expectedOut) == 0 { t.Fatal("expected output is empty") } var out bytes.Buffer rootCmd := Cmd(ctx) rootCmd.SetArgs(tt.args) rootCmd.SetOut(&out) rootCmd.SetErr(&out) fErr := rootCmd.Execute() if fErr != nil { t.Fatal(fErr) } output := out.String() if output != expectedOut {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Apr 04 15:53:09 GMT 2024 - 4.4K bytes - Viewed (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/ServeDocs.java
builder.getMainModule().set("jdk.httpserver"); builder.setStandardOutput(System.out); builder.setErrorOutput(System.err); builder.setArgs(Arrays.asList("-p", getPort().get(), "-d", getDocsDirectory().get().getAsFile().getAbsolutePath())); registry.start(getPath(), DeploymentRegistry.ChangeBehavior.RESTART, JavaApplicationHandle.class, builder); }
Java - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Thu Apr 18 12:38:47 GMT 2024 - 2.9K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig_test.go
Namespace: "default", })), c) }) } } func verifyExecTestOutput(t *testing.T, cmd *cobra.Command, c execTestCase) { t.Helper() var out bytes.Buffer cmd.SetArgs(c.args) cmd.SilenceUsage = true cmd.SetOut(&out) cmd.SetErr(&out) fErr := cmd.Execute() output := out.String() if c.expectedOutput != "" && c.expectedOutput != output {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Apr 10 21:51:29 GMT 2024 - 8.9K bytes - Viewed (0) -
cmd/encryption-v1.go
// objects are slightly larger due to encryption overhead. // Further, it decrypts all single-part SSE-S3 encrypted objects // and formats ETags of SSE-C / SSE-KMS encrypted objects to // be AWS S3 compliant. // // DecryptETags uses a KMS bulk decryption API, if available, which // is more efficient than decrypting ETags sequentually. func DecryptETags(ctx context.Context, k kms.KMS, objects []ObjectInfo) error {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 36.5K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig_test.go
Results: c.execClientConfig, Namespace: "default", })), c) }) } } func verifyExecTestOutput(t *testing.T, cmd *cobra.Command, c execTestCase) { t.Helper() var out bytes.Buffer cmd.SetArgs(c.args) cmd.SilenceUsage = true cmd.SetOut(&out) cmd.SetErr(&out) fErr := cmd.Execute() output := out.String() if c.expectedOutput != "" && c.expectedOutput != output {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Apr 10 21:51:29 GMT 2024 - 3.8K bytes - Viewed (0) -
istioctl/cmd/root.go
DisableAutoGenTag: true, PersistentPreRunE: ConfigureLogging, Long: `Istio configuration command line utility for service operators to debug and diagnose their Istio mesh. `, } rootCmd.SetArgs(args) flags := rootCmd.PersistentFlags() rootOptions := cli.AddRootFlags(flags) ctx := cli.NewCLIContext(rootOptions) _ = rootCmd.RegisterFlagCompletionFunc(cli.FlagIstioNamespace, func(
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Apr 11 20:51:30 GMT 2024 - 10K bytes - Viewed (0)