telegraf/internal/buffer
..
buffer.go
buffer_test.go