influx

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

type Config struct {
	// ServerURL 服务地址(如 http://127.0.0.1:8086)。
	ServerURL string
	// Token 访问令牌(InfluxDB 2.x Token;1.x 兼容模式用 user:password 的 base64)。
	Token string
	// Org 组织(InfluxDB 2.x 概念)。
	Org string
	// Bucket 默认桶(可空,操作时显式指定)。
	Bucket string
	// Timeout 请求超时(默认 10s)。
	Timeout time.Duration
}

type InfluxTemplate interface {
	// Ping 健康检查。
	Ping(ctx context.Context) error
	// Write 写入一个数据点(measurement + tags + fields + 时间戳)。
	// timestamp 为零值时使用当前时间。
	Write(ctx context.Context, bucket, measurement string,
		tags, fields map[string]interface{}, timestamp time.Time) error
	// WritePoint 写入预构造的数据点。
	WritePoint(ctx context.Context, bucket string, point *write.Point) error
	// WriteRaw 写入行协议(Line Protocol)原始字符串。
	WriteRaw(ctx context.Context, bucket, lineProtocol string) error
	// Query 执行 Flux 查询,返回记录列表(每行 map:列名 → 值)。
	Query(ctx context.Context, bucket, flux string) ([]map[string]interface{}, error)
	// QueryRaw 执行 Flux 查询,返回原始 CSV 文本。
	QueryRaw(ctx context.Context, flux string) (string, error)
	// Buckets 列出全部桶(管理用)。
	Buckets(ctx context.Context) ([]string, error)
	// Client 返回原生客户端(高级操作入口)。
	Client() influxdb2.Client
}