ng_metric

type CollectdMetric struct {
	api.Identifier
	DSName   string
	DataType MetricDataType
	Interval time.Duration
}

type CollectdMetricSource struct {
	// contains filtered or unexported fields
}

type CollectdMetricWriter struct {
	// contains filtered or unexported fields
}

type MemoryMetricRing struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type MemoryMetricStorage struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type Metric interface {
	//Returns metric application name
	GetAppName() string
	//Returns host metric belnogs to
	GetHost() string
	//Returns map of string measurement criterias parameters
	GetCriterias() map[string]string
	//Returns measurement series name
	//In most cases it measurement series name which describes source of information
	GetMeasurementName() string
	//Returns metric data type
	GetType() MetricDataType
	//Get metric duraiton
	GetDuration() time.Duration
}

type MetricDataType int16

type MetricSource interface {
	AddStorage(store MetricStorage) bool
	FlushToStorage() bool
	Collect() error
}

type MetricStorage interface {
	AddMetricValue(m Metric, val MetricValue) error
	DeleteMetricValue(val MetricValue) bool
	GetLastMetricValue(m Metric) (MetricValue, error)
	GetLastMetricValues(m Metric, n_skip int, n_get int) ([]MetricValue, error)
	GetMetricValueByTimeRange(m Metric, since time.Time, duration time.Duration) ([]MetricValue, error)
	GetAllMetrics() ([]Metric, error)
	GetMetricByName(name string) (Metric, error)
	GetMetricsByHost(host_name string) ([]Metric, error)

	CountValues(m Metric) (int64, error)
	CountMetrics() int32
	GetName() string
	GetFullName() string
	IsMemory() bool
	IsLimited() bool
	Flush() bool
}

type MetricValue struct {
	Name      string
	Time      time.Time
	Kind      MetricDataType
	ValueType reflect.Type
	Value     interface{}
}