Lotty

Lotty是一个将命令输出通过HTTP API发送到Grafana Loki的Go程序，支持PTY能力、内存缓存和批量发送。

特性

双模式输入：支持PTY模式（默认）和简单管道模式
内存缓存：使用环形缓冲区，默认10000条消息，FIFO丢弃策略
批量发送：支持时间触发（默认900ms）和缓冲区满载触发
Basic Auth：完整的Loki HTTP API认证支持
配置灵活：支持命令行参数和环境变量
重试机制：指数退避算法，默认重试3次
优雅关闭：支持SIGINT和SIGTERM信号处理

安装

从源码构建


git clone https://github.com/yourname/lotty.git
cd lotty
make build

使用Docker


docker build -t lotty:latest .
docker run -e LOKI_ENDPOINT=http://loki:3100 \
           -e LOKI_USERNAME=admin \
           -e LOKI_PASSWORD=password \
           lotty:latest -- your-command

配置

所有配置项都支持环境变量，优先级：命令行参数 > 环境变量 > 默认值

环境变量

变量名	描述	默认值
`LOKI_ENDPOINT`	Loki服务地址	无（必需）
`LOKI_USERNAME`	Basic Auth用户名	无
`LOKI_PASSWORD`	Basic Auth密码	无
`LOKI_LABELS`	Loki标签，格式key=value	无
`BUFFER_SIZE`	缓冲区大小	10000
`BATCH_INTERVAL`	批量发送间隔	900ms
`BATCH_SIZE`	批量大小	1000
`RETRY_COUNT`	重试次数	3
`INPUT_MODE`	输入模式(pty/pipe)	pty
`LOG_LEVEL`	日志级别	info

命令行参数


lotty [flags] -- command [args...]

Flags:
  --config string       配置文件 (默认是 $HOME/.lotty.yaml)
  --input-mode string   输入模式 (pty, pipe) (默认 "pty")
  --log-level string    日志级别 (debug, info, warn, error) (默认 "info")
  -h, --help           显示帮助信息

使用示例

基本用法


# 使用环境变量配置
export LOKI_ENDPOINT="http://localhost:3100/loki/api/v1/push"
export LOKI_USERNAME="admin"
export LOKI_PASSWORD="password"
export LOKI_LABELS="service=myapp,env=prod"

# 发送ping输出到Loki
lotty -- ping google.com

使用管道模式


# 监控日志文件
lotty --input-mode pipe -- tail -f /var/log/app.log

使用PTY模式（默认）


# 监控应用程序输出（支持彩色输出和交互式程序）
lotty -- my-app --arg1 --arg2

架构


命令输出 → PTY/管道捕获 → 行解析 → 内存缓存 → 批量处理器 → HTTP客户端 → Loki

核心组件

输入处理：支持PTY和管道两种模式，捕获命令的标准输出和标准错误
内存缓存：环形缓冲区实现，线程安全，满载时FIFO丢弃
批量处理器：定时器触发和缓冲区满载触发，支持动态批量大小
Loki客户端：HTTP客户端，支持Basic Auth，JSON格式请求
重试机制：指数退避算法，最大重试次数可配置

开发

运行测试


# 运行所有测试
make test

# 生成测试覆盖率报告
make test-coverage

代码检查


# 运行linter
make lint

# 格式化代码
make fmt

构建


# 构建二进制文件
make build

# 交叉编译
make build-all

项目结构


lotty/
├── cmd/lotty/main.go          # 主入口
├── internal/
│   ├── config/              # 配置管理
│   ├── input/               # 输入处理（pty + reader）
│   ├── buffer/              # 环形缓冲区
│   ├── loki/                # HTTP客户端 + Auth
│   ├── batcher/             # 批量处理器
│   └── retry/               # 重试机制
├── pkg/
│   └── types/               # 公共类型
├── go.mod
├── go.sum
├── Makefile
├── Dockerfile
└── README.md