package nv


import (
  "encoding/json"
  "time"
)

type NV_Event struct {
    ServerID    string
    Timestamp   time.Time
    ARI_Event   string
}

func Init(in chan []byte, out chan *NV_Event) {
  go func(in chan []byte, out chan *NV_Event) {
    for instring := range in {
      var e *NV_Event
      json.Unmarshal(instring, e)
      out <- e
    }
  }(in, out)
}
package nv


import (
  "encoding/json"
  "time"
)

type NV_Event struct {
  ServerID    string    `json:"server_id"`
  Timestamp   time.Time `json:"timestamp"`
  Type        string    `json:"type"`
  ARI_Event   string    `json:"ari_event"`
}

func Init(in chan []byte, out chan *NV_Event) {
  go func(in chan []byte, out chan *NV_Event) {
    for instring := range in {
      var e *NV_Event
      json.Unmarshal(instring, e)
      out <- e
    }
  }(in, out)
}
Update NV_Event struct to match proxy
Update NV_Event struct to match proxy
