database

package
v0.0.0-...-4a54890 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 12, 2020 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DatabaseName = "InfluxDB"
)

Variables

View Source
var (
	MeanResponseCount = 5 // Number of response times to calcuate mean response time
	ErrorCount        = 1 // Threshold to send notification

	ErrResposeCode   = errors.New("Response code does not Match expected value")
	ErrResposeBody   = errors.New("Response body does not match expected value")
	ErrTimeout       = errors.New("Request Time out Error")
	ErrCreateRequest = errors.New("Invalid Request Config. Not able to create request")
	ErrDoRequest     = errors.New("Request failed")
)

Functions

func AddErrorInfo

func AddErrorInfo(errorInfo model.ErrorInfo)

Called by requests package when a request fails Error Information inserted to all registered databases

func AddNew

func AddNew(databaseTypes DatabaseTypes)

Add database to the database List

func AddRequestInfo

func AddRequestInfo(requestInfo model.RequestInfo)

Function called by requests package when request was successfull Request data is inserted to all registered databases

func EnableLogging

func EnableLogging(fileName string)

func Initialize

func Initialize(ids map[int]int64, mMeanResponseCount int, mErrorCount int)

Intialize responseMean app and counts

Types

type Database

type Database interface {
	Initialize() error
	GetDatabaseName() string
	AddRequestInfo(requestInfo model.RequestInfo) error
	AddErrorInfo(errorInfo model.ErrorInfo) error
}

type DatabaseTypes

type DatabaseTypes struct {
	InfluxDb InfluxDb `json:"influxDb"`
}

type InfluxDb

type InfluxDb struct {
	Host         string `json:"host"`
	Port         int    `json:"port"`
	DatabaseName string `json:"databaseName"`
	Username     string `json:"username"`
	Password     string `json:"password"`
}

func (InfluxDb) AddErrorInfo

func (influxDb InfluxDb) AddErrorInfo(errorInfo model.ErrorInfo) error

Add Error information to database

func (InfluxDb) AddRequestInfo

func (influxDb InfluxDb) AddRequestInfo(requestInfo model.RequestInfo) error

Add request information to database

func (InfluxDb) GetDatabaseName

func (influxDb InfluxDb) GetDatabaseName() string

Return database name

func (InfluxDb) GetMeanResponseTime

func (influxDb InfluxDb) GetMeanResponseTime(Url string, span int) (float64, error)

Returns mean response time of url in given time.

func (InfluxDb) Initialize

func (influxDb InfluxDb) Initialize() error

Intiliaze influx db

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL