summaryrefslogtreecommitdiff
path: root/internal/server/server.go
diff options
context:
space:
mode:
authorPaul Buetow <pbuetow@mimecast.com>2020-07-03 12:15:59 +0100
committerPaul Buetow <pbuetow@mimecast.com>2020-07-03 12:15:59 +0100
commiteb9c8d4ae7f8fb7e65f912ff4838c7737b5487d0 (patch)
treef5e6c0be15200b18f306878037c3896e1084cf53 /internal/server/server.go
parent912f7dce7222d345dc6cc6cc593a45ee7e2e15f8 (diff)
refactor mapr client
Diffstat (limited to 'internal/server/server.go')
-rw-r--r--internal/server/server.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/internal/server/server.go b/internal/server/server.go
index 0377598..486b8c6 100644
--- a/internal/server/server.go
+++ b/internal/server/server.go
@@ -33,7 +33,7 @@ type Server struct {
// To run scheduled tasks (if configured)
sched *scheduler
// Mointor log files for pattern (if configured)
- mon *monitoring
+ cont *continuous
// Wait counter, e.g. there might be still subprocesses (forked by drun) to be killed.
shutdownWaitFor chan struct{}
// Background jobs
@@ -50,7 +50,7 @@ func New() *Server {
tailLimiter: make(chan struct{}, config.Server.MaxConcurrentTails),
shutdownWaitFor: make(chan struct{}, 1000),
sched: newScheduler(),
- mon: newMonitoring(),
+ cont: newContinuous(),
background: background.New(),
}
@@ -80,7 +80,7 @@ func (s *Server) Start(ctx context.Context) int {
go s.stats.start(ctx)
go s.sched.start(ctx)
- go s.mon.start(ctx)
+ go s.cont.start(ctx)
go s.listenerLoop(ctx, listener)
select {