Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 49 for setTags (0.13 sec)

  1. internal/logger/reqinfo.go

    func (r *ReqInfo) AppendTags(key, val string) *ReqInfo {
    	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, val string) *ReqInfo {
    	if r == nil {
    		return nil
    	}
    	r.Lock()
    	defer r.Unlock()
    	// Search of tag key already exists in tags
    	var updated bool
    	for _, tag := range r.tags {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 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(ctx, 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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  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
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/suggest/entity/SuggestItem.java

            }
            mergedItem.fields = fieldList.toArray(new String[fieldList.size()]);
    
            final List<String> tagList = new ArrayList<>(item1.getTags().length + item2.getTags().length);
            Collections.addAll(tagList, item1.getTags());
            for (final String tag : item2.getTags()) {
                if (!tagList.contains(tag)) {
                    tagList.add(tag);
                }
            }
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Sat Oct 12 00:10:39 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/suggest/entity/ElevateWord.java

            return new SuggestItem(new String[] { this.getElevateWord() }, readingArray, fields.toArray(new String[fields.size()]), 1, 0,
                    this.getBoost(), this.getTags().toArray(new String[this.getTags().size()]),
                    this.getRoles().toArray(new String[this.getRoles().size()]), null, SuggestItem.Kind.USER);
        }
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  6. cmd/endpoint-ellipses.go

    		}
    		s := endpointSet{
    			endpoints:  args,
    			setIndexes: setIndexes,
    		}
    		setArgs = s.Get()
    	} else {
    		s, err := parseEndpointSet(setDriveCount, 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) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  7. 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")},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 18 17:00:54 UTC 2023
    - 12.6K 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() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 10 21:09:36 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  9. cmd/erasure-healing-common.go

    package cmd
    
    import (
    	"bytes"
    	"context"
    	"slices"
    	"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]++
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  10. 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);
            }
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Thu Apr 18 12:38:47 UTC 2024
    - 2.9K bytes
    - Viewed (0)
Back to top