client

Documentation

Index

• type Config
• type InfluxClient
  • func NewClient(config Config, timeout uint) (*InfluxClient, func())
  • func (w *InfluxClient) Buckets(ctx context.Context) ([]string, error)
  • func (w *InfluxClient) CreateBucket(ctx context.Context, bucket string, retention int64) error
  • func (w *InfluxClient) GetOrg() string
  • func (w *InfluxClient) Query(ctx context.Context, q query.FluxQuery) ([]*iq.FluxRecord, error)
  • func (w *InfluxClient) QueryRaw(ctx context.Context, q query.FluxQuery) (string, error)
  • func (w *InfluxClient) Schema(ctx context.Context, bucket string) ([]*MeasurementSchema, error)
  • func (w *InfluxClient) SetBucketRetention(ctx context.Context, bucket string, retention int64) error
  • func (w *InfluxClient) StrQuery(ctx context.Context, q string) ([]*iq.FluxRecord, error)
  • func (w *InfluxClient) TagValues(ctx context.Context, bucket, measurement, tag string) ([]string, error)
  • func (w *InfluxClient) WriteAPI(bucket string) api.WriteAPI
• type MeasurementSchema

Types

type Config

type Config struct {
	Uri   string `mapstructure:"uri"`
	Token string `mapstructure:"token"`
	Org   string `mapstructure:"org"`
}

type InfluxClient

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

func NewClient

func NewClient(config Config, timeout uint) (*InfluxClient, func())

func (*InfluxClient) Buckets

func (w *InfluxClient) Buckets(ctx context.Context) ([]string, error)

func (*InfluxClient) CreateBucket

func (w *InfluxClient) CreateBucket(ctx context.Context, bucket string, retention int64) error

func (*InfluxClient) GetOrg

func (w *InfluxClient) GetOrg() string

func (*InfluxClient) Query

func (w *InfluxClient) Query(ctx context.Context, q query.FluxQuery) ([]*iq.FluxRecord, error)

func (*InfluxClient) QueryRaw

func (w *InfluxClient) QueryRaw(ctx context.Context, q query.FluxQuery) (string, error)

func (*InfluxClient) Schema

func (w *InfluxClient) Schema(ctx context.Context, bucket string) ([]*MeasurementSchema, error)

func (*InfluxClient) SetBucketRetention

func (w *InfluxClient) SetBucketRetention(ctx context.Context, bucket string, retention int64) error

func (*InfluxClient) StrQuery

func (w *InfluxClient) StrQuery(ctx context.Context, q string) ([]*iq.FluxRecord, error)

func (*InfluxClient) TagValues

func (w *InfluxClient) TagValues(ctx context.Context, bucket, measurement, tag string) ([]string, error)

func (*InfluxClient) WriteAPI

func (w *InfluxClient) WriteAPI(bucket string) api.WriteAPI

type MeasurementSchema

type MeasurementSchema struct {
	Measurement string   `json:"measurement"`
	Fields      []string `json:"fields"`
	Tags        []string `json:"tags"`
}