models

Documentation

Index

• Variables
• type Alarm
• type AlarmRepository
• type Probe
• type ProbeRepository
• type RedisAlarmRepository
  • func (rar *RedisAlarmRepository) Find(probe Probe) (*Alarm, error)
• type RedisProbeRepository
  • func (rpr *RedisProbeRepository) Delete(probe Probe) error
  • func (rpr *RedisProbeRepository) FindAll() ([]Probe, error)
  • func (rpr *RedisProbeRepository) FindLatestValues(probe Probe, limit int) ([]interface{}, *time.Time, error)
  • func (rpr *RedisProbeRepository) HasHeartbeat(probe Probe) (bool, error)
  • func (rpr *RedisProbeRepository) SetHeartbeat(probe Probe, sleep int) error
• type RedisSeriesRepository
  • func (rsr *RedisSeriesRepository) ChunkSize(seriesType SeriesType) int
  • func (rsr *RedisSeriesRepository) FindCPU(probe Probe, seriesType SeriesType) (Series, Series, Series, error)
  • func (rsr *RedisSeriesRepository) FindDisk(probe Probe, seriesType SeriesType, path string) (Series, Series, Series, error)
  • func (rsr *RedisSeriesRepository) FindDiskPaths(probe Probe) ([]string, error)
  • func (rsr *RedisSeriesRepository) FindMemory(probe Probe, seriesType SeriesType) (Series, Series, Series, error)
• type Series
• type SeriesRepository
• type SeriesType
• type Value

Variables

var (
	// ErrNoRecord error.
	ErrNoRecord = errors.New("models: no matching record found")

	// ErrInvalidLimit error.
	ErrInvalidLimit = errors.New("models: invalid limit")
)

Types

type Alarm

type Alarm struct {
	CPU    float64 `redis:"cpu"`
	Memory float64 `redis:"memory"`
	Disk   float64 `redis:"disk"`
}

Alarm type.

type AlarmRepository

type AlarmRepository interface {
	Find(Probe) (*Alarm, error)
}

AlarmRepository type.

type Probe

type Probe string

Probe type.

type ProbeRepository

type ProbeRepository interface {
	FindAll() ([]Probe, error)
	FindLatestValues(Probe, int) ([]interface{}, *time.Time, error)
	HasHeartbeat(Probe) (bool, error)
	SetHeartbeat(Probe, int) error
	Delete(Probe) error
}

ProbeRepository type.

type RedisAlarmRepository

type RedisAlarmRepository struct {
	RedisPool *redis.Pool
}

RedisAlarmRepository type.

func (*RedisAlarmRepository) Find

func (rar *RedisAlarmRepository) Find(probe Probe) (*Alarm, error)

Find function.

type RedisProbeRepository

type RedisProbeRepository struct {
	RedisPool *redis.Pool
}

RedisProbeRepository type.

func (*RedisProbeRepository) Delete

func (rpr *RedisProbeRepository) Delete(probe Probe) error

Delete function.

func (*RedisProbeRepository) FindAll

func (rpr *RedisProbeRepository) FindAll() ([]Probe, error)

FindAll function.

func (*RedisProbeRepository) FindLatestValues

func (rpr *RedisProbeRepository) FindLatestValues(probe Probe, limit int) ([]interface{}, *time.Time, error)

FindLatestValues function.

func (*RedisProbeRepository) HasHeartbeat

func (rpr *RedisProbeRepository) HasHeartbeat(probe Probe) (bool, error)

HasHeartbeat function.

func (*RedisProbeRepository) SetHeartbeat

func (rpr *RedisProbeRepository) SetHeartbeat(probe Probe, sleep int) error

SetHeartbeat function.

type RedisSeriesRepository

type RedisSeriesRepository struct {
	RedisPool *redis.Pool
}

RedisSeriesRepository type.

func (*RedisSeriesRepository) ChunkSize

func (rsr *RedisSeriesRepository) ChunkSize(seriesType SeriesType) int

ChunkSize function.

func (*RedisSeriesRepository) FindCPU

func (rsr *RedisSeriesRepository) FindCPU(probe Probe, seriesType SeriesType) (Series, Series, Series, error)

FindCPU function.

func (*RedisSeriesRepository) FindDisk

func (rsr *RedisSeriesRepository) FindDisk(probe Probe, seriesType SeriesType, path string) (Series, Series, Series, error)

FindDisk function.

func (*RedisSeriesRepository) FindDiskPaths

func (rsr *RedisSeriesRepository) FindDiskPaths(probe Probe) ([]string, error)

FindDiskPaths function.

func (*RedisSeriesRepository) FindMemory

func (rsr *RedisSeriesRepository) FindMemory(probe Probe, seriesType SeriesType) (Series, Series, Series, error)

FindMemory function.

type Series

type Series []Value

Series type.

type SeriesRepository

type SeriesRepository interface {
	FindCPU(Probe, SeriesType) (Series, Series, Series, error)
	FindMemory(Probe, SeriesType) (Series, Series, Series, error)
	FindDisk(Probe, SeriesType, string) (Series, Series, Series, error)
	FindDiskPaths(Probe) ([]string, error)
	ChunkSize(seriesType SeriesType) int
}

SeriesRepository type.

type SeriesType

type SeriesType string

SeriesType type.

const (
	// Day series.
	Day SeriesType = "day"

	// Week series.
	Week SeriesType = "week"

	// Month series.
	Month SeriesType = "month"
)

type Value

type Value struct {
	X int64   `json:"x"`
	Y float64 `json:"y"`
}

Value type.