- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 49 for setTags (0.13 sec)
-
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) -
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) -
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) -
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) -
src/main/java/org/codelibs/fess/suggest/entity/ElevateWord.java
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 2.5K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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)