tsdb

Documentation

Index

• func NewInfluxDB(conf ConfInfluxDB) (*vInfluxDB, error)
• func NewWarp10(conf ConfWarp10) (*warp10, error)
• type ConfDatadog
• type ConfInfluxDB
• type ConfInfluxDBv2
• type ConfWarp10
• type TsdbEndpoint
• type Tsdbs
  • func (ts *Tsdbs) AddTsdb(endpoint TsdbEndpoint)
  • func (ts *Tsdbs) UpdateTestStateToDB(task teststruct.Task)
  • func (ts *Tsdbs) WriteOnTsdbs(task teststruct.Task)

Functions

func NewInfluxDB

func NewInfluxDB(conf ConfInfluxDB) (*vInfluxDB, error)

func NewWarp10

func NewWarp10(conf ConfWarp10) (*warp10, error)

Types

type ConfDatadog

type ConfDatadog struct {
	Enable       bool          `toml:"enable"`
	Endpoint     string        `toml:"endpoint"`
	APIKey       string        `toml:"api_key"`
	APPKey       string        `toml:"app_key"`
	CustomPrefix string        `toml:"customprefix"`
	Timeout      time.Duration `toml:"timeout"`
}

type ConfInfluxDB

type ConfInfluxDB struct {
	Enable   bool          `toml:"enable"`
	Addr     string        `toml:"addr"`
	User     string        `toml:"user"`
	Password string        `toml:"password"`
	Database string        `toml:"database"`
	Timeout  time.Duration `toml:"timeout"`
}

type ConfInfluxDBv2

type ConfInfluxDBv2 struct {
	Enable       bool   `toml:"enable"`
	Addr         string `toml:"addr"`
	Organization string `toml:"organization"`
	Bucket       string `toml:"bucket"`
	Precision    string `toml:"precision"`
	Token        string `toml:"token"`
}

type ConfWarp10

type ConfWarp10 struct {
	Enable  bool `toml:"enable"`
	Addr    string
	Token   string
	Prefix  string
	Timeout time.Duration `toml:"timeout"`
}

type TsdbEndpoint

type TsdbEndpoint interface {
	Name() string

	WritePoint(task teststruct.Task) error
	UpdateTestState(task teststruct.Task) error
	// contains filtered or unexported methods
}

type Tsdbs

type Tsdbs struct {
	sync.RWMutex
	Enable        bool
	TsdbEndpoints []TsdbEndpoint
}

var TsdbManager Tsdbs

func (*Tsdbs) AddTsdb

func (ts *Tsdbs) AddTsdb(endpoint TsdbEndpoint)

func (*Tsdbs) UpdateTestStateToDB

func (ts *Tsdbs) UpdateTestStateToDB(task teststruct.Task)

func (*Tsdbs) WriteOnTsdbs

func (ts *Tsdbs) WriteOnTsdbs(task teststruct.Task)