We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 06290cd commit 5ce277bCopy full SHA for 5ce277b
ttl/ttlworker/job_manager.go
@@ -88,6 +88,7 @@ func NewJobManager(id string, sessPool sessionPool, store kv.Storage) (manager *
88
manager.store = store
89
manager.sessPool = sessPool
90
manager.delCh = make(chan *ttlDeleteTask)
91
+ manager.notifyStateCh = make(chan interface{}, 1)
92
93
manager.init(manager.jobLoop)
94
manager.ctx = logutil.WithKeyValue(manager.ctx, "ttl-worker", "manager")
0 commit comments