extrav1

Documentation

Index

• type AdminV1
  • func NewAdminClient(logger *zap.Logger, uri string, insecure bool, ...) *AdminV1
  • func (av1 *AdminV1) CreateBucket() error
• type QueryInput
• type QueryResult
• type QueryV1
  • func NewQueryClient(logger *zap.Logger, uri string, insecure bool, ...) *QueryV1
  • func (qv1 *QueryV1) ExecuteQuery(query *metricType.Query, measurement string) ([]metricType.ResponseData, error)
• type Result
• type Series

Types

type AdminV1

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

QueryV1 struct

func NewAdminClient

func NewAdminClient(logger *zap.Logger, uri string, insecure bool, bucket, username, password string) *AdminV1

NewAdminClient returns admin client

func (*AdminV1) CreateBucket

func (av1 *AdminV1) CreateBucket() error

CreateBucket adds a database to influxdb

type QueryInput

type QueryInput struct {
	Datbase  string `json:"db"`
	Epoch    string `json:"epoch"` // ns,u,µ,ms,s,m,h
	Username string `json:"u"`
	Password string `json:"p"`
	Pretty   bool   `json:"pretty"`
	Query    string `json:"q"`
}

QueryInput struct

type QueryResult

type QueryResult struct {
	Results []Result `json:"results"`
	Error   string   `json:"error"`
}

type QueryV1

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

QueryV1 struct

func NewQueryClient

func NewQueryClient(logger *zap.Logger, uri string, insecure bool, bucket, username, password string) *QueryV1

func (*QueryV1) ExecuteQuery

func (qv1 *QueryV1) ExecuteQuery(query *metricType.Query, measurement string) ([]metricType.ResponseData, error)

type Result

type Result struct {
	Series      []Series `json:"series"`
	StatementId int      `json:"statement_id"`
	Error       string   `json:"error"`
}

Result struct

type Series

type Series struct {
	Name    string            `json:"name"`
	Tags    map[string]string `json:"tags"`
	Columns []string          `json:"columns"`
	Values  [][]interface{}   `json:"values"`
}

Series struct