extrav2

Documentation

Index

• type AdminV2
  • func NewAdminClient(ctx context.Context, logger *zap.Logger, client influxdb2.Client, ...) *AdminV2
  • func (av2 *AdminV2) CreateBucket() error
  • func (av2 *AdminV2) IsBucketAvailable() (bool, error)
• type QueryV2
  • func NewQueryClient(logger *zap.Logger, api api.QueryAPI, bucket string) *QueryV2
  • func (qv2 *QueryV2) ExecuteQuery(q *metricTY.Query, measurement string) ([]metricTY.ResponseData, error)

Types

type AdminV2

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

AdminV2 struct

func NewAdminClient

func NewAdminClient(ctx context.Context, logger *zap.Logger, client influxdb2.Client, organizationName, bucketName string) *AdminV2

NewAdminClient returns influxdb admin client

func (*AdminV2) CreateBucket

func (av2 *AdminV2) CreateBucket() error

CreateBucket adds a bucket to influxdb

func (*AdminV2) IsBucketAvailable

func (av2 *AdminV2) IsBucketAvailable() (bool, error)

IsBucketAvailable returns the availability of the database

type QueryV2

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

QueryV2 struct

func NewQueryClient

func NewQueryClient(logger *zap.Logger, api api.QueryAPI, bucket string) *QueryV2

func (*QueryV2) ExecuteQuery

func (qv2 *QueryV2) ExecuteQuery(q *metricTY.Query, measurement string) ([]metricTY.ResponseData, error)