mss

type Config ¶

type Config struct {
}

Config defines a struct containing all the available configuration for this package.

type Data ¶

type Data map[string]interface{}

type Driver ¶

type Driver interface {
	Persist([]*Measurement) error
}

type InfluxDBConfig ¶

type InfluxDBConfig struct {
	URL      string
	Username string
	Password string
	Database string
}

InfluxDBConfig specifies the configuration for connecting to a InfluxDB instance that is a little bit more friendly to instantiate from.

type InfluxDBDriver ¶

type InfluxDBDriver struct {
	Client   *influx.Client
	Database string
	// contains filtered or unexported fields
}

InfluxDBDriver implements the Driver interface that knows how to persist data points into InfluxDB.

func NewInfluxDBDriver(cfg *InfluxDBConfig) (*InfluxDBDriver, error)

func (d *InfluxDBDriver) CreateInfluxDB() error

func (d *InfluxDBDriver) DropInfluxDB() error

func (d *InfluxDBDriver) Persist(batch []*Measurement) error

type Measurement ¶

type Measurement struct {
	Info ctxinfo.Info

	Name       string
	StartedAt  time.Time
	FinishedAt time.Time
	Data       Data
}

func NewMeasurement(ctx context.Context, name string, data Data) *Measurement

func (m Measurement) Duration() time.Duration

func (m *Measurement) Finish() error

func (m *Measurement) SetData(d map[string]interface{})