extern/zrok
1
1
Fork 0
mirror of https://github.com/openziti/zrok.git synced 2025-02-08 06:20:54 +01:00
Code Issues Packages Projects Releases Wiki Activity

explicit lint

Browse Source
This commit is contained in:
Michael Quigley 2023-01-20 12:45:02 -05:00
parent 37d4586a03
commit 088283d528
No known key found for this signature in database
GPG Key ID: 9B60314A9DD20A62
1 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
controller/maintenance.go
View File

@ -11,14 +11,14 @@ import (
) )
type maintenanceRegistrationAgent struct { type maintenanceRegistrationAgent struct {
*RegistrationMaintenanceConfig cfg *RegistrationMaintenanceConfig
ctx context.Context ctx context.Context
} }
func newRegistrationMaintenanceAgent(ctx context.Context, cfg *RegistrationMaintenanceConfig) *maintenanceRegistrationAgent { func newRegistrationMaintenanceAgent(ctx context.Context, cfg *RegistrationMaintenanceConfig) *maintenanceRegistrationAgent {
return &maintenanceRegistrationAgent{ return &maintenanceRegistrationAgent{
RegistrationMaintenanceConfig: cfg, cfg: cfg,
ctx: ctx, ctx: ctx,
} }
} }
@ -26,7 +26,7 @@ func (ma *maintenanceRegistrationAgent) run() {
logrus.Infof("started") logrus.Infof("started")
defer logrus.Info("exited") defer logrus.Info("exited")
ticker := time.NewTicker(ma.CheckFrequency) ticker := time.NewTicker(ma.cfg.CheckFrequency)
for { for {
select { select {
case <-ma.ctx.Done(): case <-ma.ctx.Done():
@ -51,8 +51,8 @@ func (ma *maintenanceRegistrationAgent) deleteExpiredAccountRequests() error {
} }
defer func() { _ = tx.Rollback() }() defer func() { _ = tx.Rollback() }()
timeout := time.Now().UTC().Add(-ma.ExpirationTimeout) timeout := time.Now().UTC().Add(-ma.cfg.ExpirationTimeout)
accountRequests, err := str.FindExpiredAccountRequests(timeout, ma.BatchLimit, tx) accountRequests, err := str.FindExpiredAccountRequests(timeout, ma.cfg.BatchLimit, tx)
if err != nil { if err != nil {
return errors.Wrapf(err, "error finding expire account requests before %v", timeout) return errors.Wrapf(err, "error finding expire account requests before %v", timeout)
} }
@ -78,14 +78,14 @@ func (ma *maintenanceRegistrationAgent) deleteExpiredAccountRequests() error {
} }
type maintenanceResetPasswordAgent struct { type maintenanceResetPasswordAgent struct {
*ResetPasswordMaintenanceConfig cfg *ResetPasswordMaintenanceConfig
ctx context.Context ctx context.Context
} }
func newMaintenanceResetPasswordAgent(ctx context.Context, cfg *ResetPasswordMaintenanceConfig) *maintenanceResetPasswordAgent { func newMaintenanceResetPasswordAgent(ctx context.Context, cfg *ResetPasswordMaintenanceConfig) *maintenanceResetPasswordAgent {
return &maintenanceResetPasswordAgent{ return &maintenanceResetPasswordAgent{
ResetPasswordMaintenanceConfig: cfg, cfg: cfg,
ctx: ctx, ctx: ctx,
} }
} }
@ -93,7 +93,7 @@ func (ma *maintenanceResetPasswordAgent) run() {
logrus.Infof("started") logrus.Infof("started")
defer logrus.Info("exited") defer logrus.Info("exited")
ticker := time.NewTicker(ma.CheckFrequency) ticker := time.NewTicker(ma.cfg.CheckFrequency)
for { for {
select { select {
case <-ma.ctx.Done(): case <-ma.ctx.Done():
@ -117,8 +117,8 @@ func (ma *maintenanceResetPasswordAgent) deleteExpiredForgetPasswordRequests() e
} }
defer func() { _ = tx.Rollback() }() defer func() { _ = tx.Rollback() }()
timeout := time.Now().UTC().Add(-ma.ExpirationTimeout) timeout := time.Now().UTC().Add(-ma.cfg.ExpirationTimeout)
passwordResetRequests, err := str.FindExpiredPasswordResetRequests(timeout, ma.BatchLimit, tx) passwordResetRequests, err := str.FindExpiredPasswordResetRequests(timeout, ma.cfg.BatchLimit, tx)
if err != nil { if err != nil {
return errors.Wrapf(err, "error finding expired password reset requests before %v", timeout) return errors.Wrapf(err, "error finding expired password reset requests before %v", timeout)
} }