Morgoth closing a closed channel[GoLang] about morgoth HOT 3 OPEN

// The measurement to analyze
var measurement = 'cpu'

// Optional group by dimensions
var groups = []

// Optional where filter
var whereFilter = lambda: TRUE

// The amount of data to window at once
var window = 1h
var interval = 1m

// The field to process
var field = 'usage_idle'

// The name for the anomaly score field  
var scoreField = 'anomalyScore'

// The minimum support
var minSupport = 0.95

// The error tolerance
var errorTolerance = 0.01

// The consensus
var consensus = 0.5

// Number of sigmas allowed for normal window deviation
var sigmas = 3.5

var details = 'This mail is getting generated when %change of {{.ID}} in last 1hour'
var message = '[{{ .Level }}] Terago {{.ID}} , Difference: {{ index .Fields "value" }} , {{.Time}}'

var idTag = 'alertID'

var levelTag = 'level'

var messageField = 'message'

var durationField = 'duration'

var rp = 'autogen'
var db = 'telegraf'
var name = 'cpu alert'
var triggerType = 'relative'
var idVar = name + ':{{.Group}}'
var outputDB = 'alertsDB'
var outputMeasurement = 'cpu_1h'

var trigger = stream
   // Select the data we want
  |from()
      .database(db)
      .retentionPolicy(rp)
      .measurement(measurement)
     .groupBy(groups)
     .where(whereFilter)
  // Window the data for a certain amount of time
  |window()
     .period(window)
    .every(interval)
    .align()
  // Send each window to Morgoth
  @morgoth()
     .field(field)
    .scoreField(scoreField)
    .minSupport(minSupport)
    .errorTolerance(errorTolerance)
    .consensus(consensus)
   // Configure a single Sigma fingerprinter
   .sigma(sigmas)
 // Morgoth returns any anomalous windows
  |alert()
     .stateChangesOnly()
     .details(details)
    .message(message)
    .id(idVar)
    .idTag(idTag)
    .levelTag(levelTag)
    .messageField(messageField)
    .durationField(durationField)
    .details(details)
    .crit(lambda: TRUE)
    .log('/tmp/cpu_1h.log')  
trigger
    |influxDBOut()
        .create()
        .database(outputDB)
        .retentionPolicy(rp)
        .measurement(outputMeasurement)
        .tag('alertName', name)
        .tag('triggerType', triggerType)

trigger
    |httpOut('output')