code: func (h *StorageHandler) Process(s nats.Subscription, m nats.Message) {
  	defer m.Ack()
  	ms := make([]Metrics, 0)
  	err := json.Unmarshal(m.Data(), &ms)
  	if err != nil {
  		h.Logger.Error(fmt.Sprintf("storage handler process err: %v", err))
  		return
  	}
  	err = h.Storage.Record(ms)
  	if err != nil {
  		h.Logger.Error(fmt.Sprintf("storage handler store err: %v", err))
  	}
  }
docs: // Process consumes job queue, and use storage to record.