- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 64 for setTags (0.2 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)