Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

refactor(tenant): change info level logs to debug (#17476)

pull/17518/head
Alirie Gray 2020-04-01 12:09:29 -07:00 committed by GitHub
parent 83c0f297c7
commit c4517a609e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 26 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
tenant/middleware_bucket_logging.go
View File

@ -31,7 +31,7 @@ func (l *BucketLogger) CreateBucket(ctx context.Context, u *influxdb.Bucket) (er
l.logger.Error("failed to create bucket", zap.Error(err), dur)
return
}
l.logger.Info("bucket create", dur)
l.logger.Debug("bucket create", dur)
}(time.Now())
return l.bucketService.CreateBucket(ctx, u)
}
@ -44,7 +44,7 @@ func (l *BucketLogger) FindBucketByID(ctx context.Context, id influxdb.ID) (u *i
l.logger.Error(msg, zap.Error(err), dur)
return
}
l.logger.Info("bucket find by ID", dur)
l.logger.Debug("bucket find by ID", dur)
}(time.Now())
return l.bucketService.FindBucketByID(ctx, id)
}
@ -57,7 +57,7 @@ func (l *BucketLogger) FindBucketByName(ctx context.Context, orgID influxdb.ID,
l.logger.Error(msg, zap.Error(err), dur)
return
}
l.logger.Info("bucket find by name", dur)
l.logger.Debug("bucket find by name", dur)
}(time.Now())
return l.bucketService.FindBucketByName(ctx, orgID, name)
}
@ -69,7 +69,7 @@ func (l *BucketLogger) FindBucket(ctx context.Context, filter influxdb.BucketFil
l.logger.Error("failed to find bucket matching the given filter", zap.Error(err), dur)
return
}
l.logger.Info("bucket find", dur)
l.logger.Debug("bucket find", dur)
}(time.Now())
return l.bucketService.FindBucket(ctx, filter)
}
@ -81,7 +81,7 @@ func (l *BucketLogger) FindBuckets(ctx context.Context, filter influxdb.BucketFi
l.logger.Error("failed to find bucket matching the given filter", zap.Error(err), dur)
return
}
l.logger.Info("buckets find", dur)
l.logger.Debug("buckets find", dur)
}(time.Now())
return l.bucketService.FindBuckets(ctx, filter)
}
@ -93,7 +93,7 @@ func (l *BucketLogger) UpdateBucket(ctx context.Context, id influxdb.ID, upd inf
l.logger.Error("failed to update bucket", zap.Error(err), dur)
return
}
l.logger.Info("bucket update", dur)
l.logger.Debug("bucket update", dur)
}(time.Now())
return l.bucketService.UpdateBucket(ctx, id, upd)
}
@ -106,7 +106,7 @@ func (l *BucketLogger) DeleteBucket(ctx context.Context, id influxdb.ID) (err er
l.logger.Error(msg, zap.Error(err), dur)
return
}
l.logger.Info("bucket delete", dur)
l.logger.Debug("bucket delete", dur)
}(time.Now())
return l.bucketService.DeleteBucket(ctx, id)
}

13
tenant/middleware_org_logging.go
View File

@ -31,7 +31,7 @@ func (l *OrgLogger) CreateOrganization(ctx context.Context, u *influxdb.Organiza
l.logger.Error("failed to create org", zap.Error(err), dur)
return
}
l.logger.Info("org create", dur)
l.logger.Debug("org create", dur)
}(time.Now())
return l.orgService.CreateOrganization(ctx, u)
}
@ -44,7 +44,7 @@ func (l *OrgLogger) FindOrganizationByID(ctx context.Context, id influxdb.ID) (u
l.logger.Error(msg, zap.Error(err), dur)
return
}
l.logger.Info("org find by ID", dur)
l.logger.Debug("org find by ID", dur)
}(time.Now())
return l.orgService.FindOrganizationByID(ctx, id)
}
@ -56,7 +56,8 @@ func (l *OrgLogger) FindOrganization(ctx context.Context, filter influxdb.Organi
l.logger.Error("failed to find org matching the given filter", zap.Error(err), dur)
return
}
l.logger.Info("org find", dur)
l.logger.Debug("org find", dur)
}(time.Now())
return l.orgService.FindOrganization(ctx, filter)
}
@ -68,7 +69,7 @@ func (l *OrgLogger) FindOrganizations(ctx context.Context, filter influxdb.Organ
l.logger.Error("failed to find org matching the given filter", zap.Error(err), dur)
return
}
l.logger.Info("orgs find", dur)
l.logger.Debug("orgs find", dur)
}(time.Now())
return l.orgService.FindOrganizations(ctx, filter)
}
@ -80,7 +81,7 @@ func (l *OrgLogger) UpdateOrganization(ctx context.Context, id influxdb.ID, upd
l.logger.Error("failed to update org", zap.Error(err), dur)
return
}
l.logger.Info("org update", dur)
l.logger.Debug("org update", dur)
}(time.Now())
return l.orgService.UpdateOrganization(ctx, id, upd)
}
@ -93,7 +94,7 @@ func (l *OrgLogger) DeleteOrganization(ctx context.Context, id influxdb.ID) (err
l.logger.Error(msg, zap.Error(err), dur)
return
}
l.logger.Info("org delete", dur)
l.logger.Debug("org delete", dur)
}(time.Now())
return l.orgService.DeleteOrganization(ctx, id)
}

6
tenant/middleware_urm_logging.go
View File

@ -31,7 +31,7 @@ func (l *URMLogger) CreateUserResourceMapping(ctx context.Context, u *influxdb.U
l.logger.Error("failed to create urm", zap.Error(err), dur)
return
}
l.logger.Info("urm create", dur)
l.logger.Debug("urm create", dur)
}(time.Now())
return l.urmService.CreateUserResourceMapping(ctx, u)
}
@ -43,7 +43,7 @@ func (l *URMLogger) FindUserResourceMappings(ctx context.Context, filter influxd
l.logger.Error("failed to find urms matching the given filter", zap.Error(err), dur)
return
}
l.logger.Info("urm find", dur)
l.logger.Debug("urm find", dur)
}(time.Now())
return l.urmService.FindUserResourceMappings(ctx, filter)
}
@ -56,7 +56,7 @@ func (l *URMLogger) DeleteUserResourceMapping(ctx context.Context, resourceID, u
l.logger.Error(msg, zap.Error(err), dur)
return
}
l.logger.Info("urm delete", dur)
l.logger.Debug("urm delete", dur)
}(time.Now())
return l.urmService.DeleteUserResourceMapping(ctx, resourceID, userID)
}

18
tenant/middleware_user_logging.go
View File

@ -32,7 +32,7 @@ func (l *UserLogger) CreateUser(ctx context.Context, u *influxdb.User) (err erro
l.logger.Error("failed to create user", zap.Error(err), dur)
return
}
l.logger.Info("user create", dur)
l.logger.Debug("user create", dur)
}(time.Now())
return l.userService.CreateUser(ctx, u)
}
@ -45,7 +45,7 @@ func (l *UserLogger) FindUserByID(ctx context.Context, id influxdb.ID) (u *influ
l.logger.Error(msg, zap.Error(err), dur)
return
}
l.logger.Info("user find by ID", dur)
l.logger.Debug("user find by ID", dur)
}(time.Now())
return l.userService.FindUserByID(ctx, id)
}
@ -57,7 +57,7 @@ func (l *UserLogger) FindUser(ctx context.Context, filter influxdb.UserFilter) (
l.logger.Error("failed to find user matching the given filter", zap.Error(err), dur)
return
}
l.logger.Info("user find", dur)
l.logger.Debug("user find", dur)
}(time.Now())
return l.userService.FindUser(ctx, filter)
}
@ -69,7 +69,7 @@ func (l *UserLogger) FindUsers(ctx context.Context, filter influxdb.UserFilter,
l.logger.Error("failed to find users matching the given filter", zap.Error(err), dur)
return
}
l.logger.Info("users find", dur)
l.logger.Debug("users find", dur)
}(time.Now())
return l.userService.FindUsers(ctx, filter)
}
@ -81,7 +81,7 @@ func (l *UserLogger) UpdateUser(ctx context.Context, id influxdb.ID, upd influxd
l.logger.Error("failed to update user", zap.Error(err), dur)
return
}
l.logger.Info("user update", dur)
l.logger.Debug("user update", dur)
}(time.Now())
return l.userService.UpdateUser(ctx, id, upd)
}
@ -94,7 +94,7 @@ func (l *UserLogger) DeleteUser(ctx context.Context, id influxdb.ID) (err error)
l.logger.Error(msg, zap.Error(err), dur)
return
}
l.logger.Info("user create", dur)
l.logger.Debug("user create", dur)
}(time.Now())
return l.userService.DeleteUser(ctx, id)
}
@ -120,7 +120,7 @@ func (l *PasswordLogger) SetPassword(ctx context.Context, userID influxdb.ID, pa
l.logger.Error(msg, zap.Error(err), dur)
return
}
l.logger.Info("set password", dur)
l.logger.Debug("set password", dur)
}(time.Now())
return l.pwdService.SetPassword(ctx, userID, password)
}
@ -133,7 +133,7 @@ func (l *PasswordLogger) ComparePassword(ctx context.Context, userID influxdb.ID
l.logger.Error(msg, zap.Error(err), dur)
return
}
l.logger.Info("compare password", dur)
l.logger.Debug("compare password", dur)
}(time.Now())
return l.pwdService.ComparePassword(ctx, userID, password)
}
@ -146,7 +146,7 @@ func (l *PasswordLogger) CompareAndSetPassword(ctx context.Context, userID influ
l.logger.Error(msg, zap.Error(err), dur)
return
}
l.logger.Info("compare and set password", dur)
l.logger.Debug("compare and set password", dur)
}(time.Now())
return l.pwdService.CompareAndSetPassword(ctx, userID, old, new)
}