github.com/fluent/fluent-logger-golang/fluent
// 向配置文件赋初值
func New(config Config) (f *Fluent, err error) {
// post数据
func (f *Fluent) Post(tag string, message interface{}) error {
func (f *Fluent) PostWithTime(tag string, tm time.Time, message interface{}) error {
func (f *Fluent) EncodeAndPostData(tag string, tm time.Time, message interface{}) error {
func (f *Fluent) PostRawData(data []byte) {
func (f *Fluent) postRawData(data []byte) error {
func (chunk *MessageChunk) MarshalJSON() ([]byte, error) {
// 编码数据
func (f *Fluent) EncodeData(tag string, tm time.Time, message interface{}) (data []byte, err error) {
// 关闭连接
func (f *Fluent) Close() (err error) {
// 追加数据
func (f *Fluent) appendBuffer(data []byte) error {
func (f *Fluent) close() {
func (f *Fluent) connect() (err error) {
func e(x, y float64) int {
// 重连
func (f *Fluent) reconnect() {
// 发送数据
func (f *Fluent) send() error {