Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 64 for setTags (0.2 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 07 19:28:10 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 14 19:28:10 GMT 2024
    - Last Modified: Wed Apr 10 22:37:42 GMT 2024
    - 64.4K 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 14 19:28:10 GMT 2024
    - Last Modified: Thu Apr 11 21:22:47 GMT 2024
    - 97.3K bytes
    - Viewed (2)
  4. 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 14 19:28:10 GMT 2024
    - Last Modified: Thu Apr 11 21:22:47 GMT 2024
    - 14.8K bytes
    - Viewed (0)
  5. 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)
  6. operator/cmd/mesh/profile-dump.go

    	}
    
    	if err := validateProfileOutputFormatFlag(pdArgs.outputFormat); err != nil {
    		return err
    	}
    
    	setFlags := applyFlagAliases(make([]string, 0), pdArgs.manifestsPath, "")
    	if len(args) == 1 {
    		setFlags = append(setFlags, "profile="+args[0])
    	}
    
    	y, _, err := manifest.GenerateConfig(pdArgs.inFilenames, setFlags, true, nil, l)
    	if err != nil {
    		return err
    	}
    	y, err = tpath.GetConfigSubtree(y, "spec")
    Go
    - Registered: Wed Mar 20 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 01:18:49 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  7. cmd/erasure-healing-common.go

    package cmd
    
    import (
    	"bytes"
    	"context"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    )
    
    func commonETags(etags []string) (etag string, maxima int) {
    	etagOccurrenceMap := make(map[string]int, len(etags))
    
    	// Ignore the uuid sentinel and count the rest.
    	for _, etag := range etags {
    		if etag == "" {
    			continue
    		}
    		etagOccurrenceMap[etag]++
    	}
    
    Go
    - Registered: Sun Apr 14 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 10.8K bytes
    - Viewed (0)
  8. internal/etag/etag.go

    // S3 singlepart ETags. It returns nil if the list of
    // ETags is empty.
    //
    // Any encrypted or multipart ETag will be ignored and not
    // used to compute the returned ETag.
    func Multipart(etags ...ETag) ETag {
    	if len(etags) == 0 {
    		return nil
    	}
    
    	var n int64
    	h := md5.New()
    	for _, etag := range etags {
    		if !etag.IsMultipart() && !etag.IsEncrypted() {
    Go
    - Registered: Sun Apr 14 19:28:10 GMT 2024
    - Last Modified: Sun Mar 10 21:09:36 GMT 2024
    - 13.3K bytes
    - Viewed (0)
  9. internal/etag/etag_test.go

    	}
    }
    
    var multipartTests = []struct { // Test cases have been generated using AWS S3
    	ETags     []ETag
    	Multipart ETag
    }{
    	{
    		ETags:     []ETag{},
    		Multipart: ETag{},
    	},
    	{
    		ETags:     []ETag{must("b10a8db164e0754105b7a99be72e3fe5")},
    		Multipart: must("7b976cc68452e003eec7cb0eb631a19a-1"),
    	},
    	{
    		ETags:     []ETag{must("5f363e0e58a95f06cbe9bbc662c5dfb6"), must("5f363e0e58a95f06cbe9bbc662c5dfb6")},
    Go
    - Registered: Sun Apr 14 19:28:10 GMT 2024
    - Last Modified: Mon Sep 18 17:00:54 GMT 2023
    - 12.6K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb1/ntlmssp/NtlmMessage.java

         */
        public int getFlags() {
            return flags;
        }
    
        /**
         * Sets the flags for this message.
         *
         * @param flags The flags for this message.
         */
        public void setFlags(int flags) {
            this.flags = flags;
        }
    
        /**
         * Returns the status of the specified flag.
         *
         * @param flag The flag to test (i.e., <code>NTLMSSP_NEGOTIATE_OEM</code>).
    Java
    - Registered: Sun Apr 14 00:10:09 GMT 2024
    - Last Modified: Fri Mar 22 20:39:42 GMT 2019
    - 4.3K bytes
    - Viewed (0)
Back to top