- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for appendArgs (0.23 sec)
-
cmd/notification.go
if contextCanceled(ctx) { // context already canceled no retries. retryCount = 0 } // Last iteration log the error. if i == retryCount-1 { reqInfo := (&logger.ReqInfo{}).AppendTags("peerAddress", addr.String()) ctx := logger.SetReqInfo(ctx, reqInfo) peersLogOnceIf(ctx, err, addr.String()) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 44.9K bytes - Viewed (0) -
operator/pkg/apis/istio/v1alpha1/validation/validation.go
return util.NewErrs(err), "" } validationErrors = util.AppendErrs(validationErrors, ValidateSubTypes(reflect.ValueOf(values).Elem(), failOnMissingValidation, values, iopls)) featureErrors, featureWarningMessages := validateFeatures(values, iopls) validationErrors = util.AppendErrs(validationErrors, featureErrors) warningMessages = append(warningMessages, featureWarningMessages...)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 20:02:28 UTC 2024 - 14.9K bytes - Viewed (0) -
internal/logger/reqinfo.go
UserAgent: userAgent, API: api, DeploymentID: deploymentID, RequestID: requestID, BucketName: bucket, ObjectName: object, } } // AppendTags - appends key/val to ReqInfo.tags func (r *ReqInfo) AppendTags(key string, val interface{}) *ReqInfo { if r == nil { return nil } r.Lock() defer r.Unlock() r.tags = append(r.tags, KeyVal{key, val}) return r }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 4.4K bytes - Viewed (0) -
internal/event/targetlist.go
defer wg.Done() if err := target.Save(event); err != nil { list.eventsErrorsTotal.Add(1) list.incFailedEvents(id) reqInfo := &logger.ReqInfo{} reqInfo.AppendTags("targetID", id.String()) logger.LogOnceIf(logger.SetReqInfo(context.Background(), reqInfo), logSubsys, err, id.String()) } }(id, target) } wg.Wait() list.totalEvents.Add(1) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 9.2K bytes - Viewed (0) -
cmd/endpoint.go
reqInfo := (&logger.ReqInfo{}).AppendTags( "host", endpoints[i].Hostname(), ) if orchestrated && hostResolveToLocalhost(endpoints[i]) { // time elapsed timeElapsed := time.Since(startTime) // log error only if more than a second has elapsed if timeElapsed > time.Second { reqInfo.AppendTags("elapsedTime", humanize.RelTime(startTime,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 34.1K bytes - Viewed (0) -
operator/pkg/translate/translate.go
continue } if !fieldValue.CanInterface() { continue } errs = util.AppendErrs(errs, t.ProtoToHelmValues(fieldValue.Interface(), root, append(path, fieldName))) } case reflect.Map: scope.Debug("Map") for _, key := range vv.MapKeys() { nnp := append(path, key.String()) errs = util.AppendErrs(errs, t.insertLeaf(root, nnp, vv.MapIndex(key))) } case reflect.Slice: scope.Debug("Slice")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 12 19:43:09 UTC 2024 - 36.3K bytes - Viewed (0) -
operator/pkg/patch/patch.go
if overlayMatches(overlay, obj, defaultNamespace) { matches[overlay] = append(matches[overlay], obj) var errs2 util.Errors oys, errs2 = applyPatches(obj, overlay.Patches) errs = util.AppendErrs(errs, errs2) } } if _, err := ret.WriteString(oys + helm.YAMLSeparator); err != nil { errs = util.AppendErr(errs, fmt.Errorf("writeString: %s", err)) } } for _, overlay := range overlays {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Aug 10 15:35:03 UTC 2023 - 6.2K bytes - Viewed (0) -
cmd/prepare-storage.go
var printEndpointError = func() func(Endpoint, error, bool) { var mutex sync.Mutex printOnce := make(map[Endpoint]map[string]int) return func(endpoint Endpoint, err error, once bool) { reqInfo := (&logger.ReqInfo{}).AppendTags("endpoint", endpoint.String()) ctx := logger.SetReqInfo(GlobalContext, reqInfo) mutex.Lock() defer mutex.Unlock() m, ok := printOnce[endpoint] if !ok { m = make(map[string]int)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun May 19 08:06:49 UTC 2024 - 11.1K bytes - Viewed (0) -
operator/pkg/validate/common.go
printError(err) return util.NewErrs(err) } var errs util.Errors for _, s := range strings.Split(val.(string), ",") { errs = util.AppendErrs(errs, vf(path, s)) scope.Debugf("\nerrors(%d): %v", len(errs), errs) msg += fmt.Sprintf("\nerrors(%d): %v", len(errs), errs) } logWithError(errs.ToError(), msg) return errs } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Aug 10 15:35:03 UTC 2023 - 11K bytes - Viewed (0) -
cmd/update.go
helmInfoFile, err := Open(helmInfoFilePath) if err != nil { // Log errors and return "" as MinIO can be deployed // without Helm charts as well. if !osIsNotExist(err) { reqInfo := (&logger.ReqInfo{}).AppendTags("helmInfoFilePath", helmInfoFilePath) ctx := logger.SetReqInfo(GlobalContext, reqInfo) internalLogIf(ctx, err) } return "" } defer helmInfoFile.Close() scanner := bufio.NewScanner(helmInfoFile)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 18.7K bytes - Viewed (0)