def

type Point struct {
	Measurement string
	Bucket      string
	Tags        map[string]string
	Fields      map[string]any
	Time        time.Time
}

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

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

type TsdbQueryOptions struct {
	Bucket      string
	Measurement string
	Fields      []string
	Groups      []string

	Start *time.Time
	End   *time.Time
	Query *string
	// contains filtered or unexported fields
}

type TsdbReader interface {
	Query(ctx context.Context, opts ...func(*TsdbQueryOptions)) ([]*Series, error)
	Close() error
}

type TsdbWriter interface {
	LogPoint(ctx context.Context, bucket, measurement string, tags map[string]string, fields map[string]any) error
	LogPointWithTime(ctx context.Context, bucket, measurement string, tags map[string]string, fields map[string]any, date time.Time) error
	LogPoints(ctx context.Context, bucket string, points []Point) error
	LogPointToDefault(ctx context.Context, measurement string, tags map[string]string, fields map[string]any) error
	Counter(ctx context.Context, bucket, measurement string, tags map[string]string, value float64) error
	Gauge(ctx context.Context, bucket, measurement string, tags map[string]string, value float64) error
	Histogram(ctx context.Context, bucket, measurement string, tags map[string]string, value float64) error
	Summary(ctx context.Context, bucket, measurement string, tags map[string]string, value float64) error
	Ping(ctx context.Context) error
	Close() error
}