mirror of
https://github.com/datarhei/core.git
synced 2025-09-27 04:16:25 +08:00
Fix require positive persist interval
This commit is contained in:
@@ -394,7 +394,7 @@ func newCollector(id string, persistFS fs.Filesystem, logger log.Logger, config
|
|||||||
|
|
||||||
func (c *collector) start() {
|
func (c *collector) start() {
|
||||||
c.startOnce.Do(func() {
|
c.startOnce.Do(func() {
|
||||||
if c.persist.enable && c.persist.interval != 0 {
|
if c.persist.enable && c.persist.interval > 0 {
|
||||||
ctx, cancel := context.WithCancel(context.Background())
|
ctx, cancel := context.WithCancel(context.Background())
|
||||||
c.persist.done = cancel
|
c.persist.done = cancel
|
||||||
go c.persister(ctx, c.persist.interval)
|
go c.persister(ctx, c.persist.interval)
|
||||||
@@ -409,7 +409,7 @@ func (c *collector) start() {
|
|||||||
|
|
||||||
func (c *collector) Stop() {
|
func (c *collector) Stop() {
|
||||||
c.stopOnce.Do(func() {
|
c.stopOnce.Do(func() {
|
||||||
if c.persist.enable && c.persist.interval != 0 {
|
if c.persist.enable && c.persist.interval > 0 {
|
||||||
c.persist.done()
|
c.persist.done()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user