Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 39 for setTags (0.19 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top