diff --git a/internal/disabler/disabler.go b/internal/disabler/disabler.go index 2dd241496..8ebf2e302 100644 --- a/internal/disabler/disabler.go +++ b/internal/disabler/disabler.go @@ -4,6 +4,8 @@ package disabler import ( "context" "errors" + + "github.com/pomerium/pomerium/internal/log" ) var errDisabled = errors.New("disabled") @@ -19,6 +21,7 @@ type Disabler interface { } type disabler struct { + name string handler Handler onChangeEnabled chan bool } @@ -27,8 +30,8 @@ type disabler struct { // RunEnabled will be called. If the Disabler is subsequently disabled the // context passed to RunEnabled will be canceled. If the Disabler is subseqently // enabled, RunEnabled will be started again. -func New(handler Handler, enabled bool) Disabler { - d := disabler{handler: handler, onChangeEnabled: make(chan bool, 1)} +func New(name string, handler Handler, enabled bool) Disabler { + d := disabler{name: name, handler: handler, onChangeEnabled: make(chan bool, 1)} d.change(enabled) return d } @@ -47,8 +50,10 @@ func (d disabler) Run(ctx context.Context) error { continue } + log.Ctx(ctx).Info().Msgf("enabled %s", d.name) err := d.runEnabledOnce(ctx) if errors.Is(err, errDisabled) { + log.Ctx(ctx).Info().Msgf("disabled %s", d.name) continue } diff --git a/internal/identity/manager/manager.go b/internal/identity/manager/manager.go index 7d9256aa8..8daf74279 100644 --- a/internal/identity/manager/manager.go +++ b/internal/identity/manager/manager.go @@ -64,7 +64,7 @@ func New( sessionScheduler: scheduler.New(), userScheduler: scheduler.New(), } - mgr.Disabler = disabler.New(mgr, true) + mgr.Disabler = disabler.New("identity_manager", mgr, true) mgr.reset() mgr.UpdateConfig(options...) return mgr