Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for setTags (0.26 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/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)
  3. 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)
  4. 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)
  5. 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)
  6. 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 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 10.8K bytes
    - Viewed (0)
  7. 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 28 19:28:10 GMT 2024
    - Last Modified: Sun Mar 10 21:09:36 GMT 2024
    - 13.3K bytes
    - Viewed (0)
  8. 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 28 19:28:10 GMT 2024
    - Last Modified: Mon Sep 18 17:00:54 GMT 2023
    - 12.6K bytes
    - Viewed (0)
  9. cmd/xl-storage-format-v2.go

    	PartNumbers        []int             `json:"PartNums" msg:"PartNums"`                        // Part Numbers
    	PartETags          []string          `json:"PartETags" msg:"PartETags,allownil"`             // Part ETags
    	PartSizes          []int64           `json:"PartSizes" msg:"PartSizes"`                      // Part Sizes
    	PartActualSizes    []int64           `json:"PartASizes,omitempty" msg:"PartASizes,allownil"` // Part ActualSizes (compression)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 05:07:37 GMT 2024
    - 63.6K bytes
    - Viewed (1)
  10. 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)
Back to top