gather

type MetricType int

type Metrics struct {
	Name      string                 `json:"name"`
	Tags      map[string]string      `json:"tags"`
	Fields    map[string]interface{} `json:"fields"`
	Timestamp int64                  `json:"timestamp"`
	Type      MetricType             `json:"type"`
}

type Scheduler struct {
	Targets platform.ScraperTargetStoreService
	// Interval is between each metrics gathering event.
	Interval time.Duration
	// Timeout is the maxisium time duration allowed by each TCP request
	Timeout time.Duration

	// Publisher will send the gather requests and gathered metrics to the queue.
	Publisher nats.Publisher

	Logger *zap.Logger
	// contains filtered or unexported fields
}

type Scraper interface {
	Gather(ctx context.Context, target platform.ScraperTarget) (ms []Metrics, err error)
}

type Storage interface {
	//Subscriber nats.Subscriber
	Record([]Metrics) error
}

type StorageHandler struct {
	Storage Storage
	Logger  *zap.Logger
}