fluent-logger-golangでtime.Timeを送ったら"error":"#<MessagePack::UnknownExtTypeError: unexpected extension type>"が出た

はじめに

以下のようなスクリプト、configでfluentdに送ってみる
Logについてはgo generateでmsgp.Marshalerを自動生成しています
msgpのgeneratorについてはこちら

main.go

package main

//go:generate msgp

import (
	"log"
	"time"

	"github.com/fluent/fluent-logger-golang/fluent"
)

func main() {
	logger, err := fluent.New(fluent.Config{FluentPort: 24224, FluentHost: "127.0.0.1"})
	if err != nil {
		log.Println(err.Error())
		return
	}
	defer logger.Close()

	logData := Log{
		ID:        12345,
		Name:      "hogehoge",
		CreatedAt: time.Now(),
	}
	if err := logger.Post("debug.test", logData); err != nil {
		log.Println(err.Error())
		return
	}
	log.Println("done")
}

type Log struct {
	ID        uint32    `msg:"id"`
	Name      string    `msg:"name"`
	CreatedAt time.Time `msg:"created_at"`
}

fluent.conf

<source>
    @type forward
</source>
<match **>
    @type file
    path /path/to/log
</match>

実行

$ go run main.go main_gen.go
2017/12/02 19:30:16 done

ログを見てみる
何かエラーが出ている。

cat log/app.log.20171202.b55f58f8a5413f5de
2017-12-02T19:30:16+09:00	fluent.error	{"error":"#<MessagePack::UnknownExtTypeError: unexpected extension type>","error_class":"MessagePack::UnknownExtTypeError","message":"forward error error=#<MessagePack::UnknownExtTypeError: unexpected extension type> error_class=MessagePack::UnknownExtTypeError"}

解決策

msgpでtime.Timeを扱うときにstringとして変換するように以下の１行を追加してgo generate

//msgp:shim time.Time as:string using:timeToStr/strToTime

これでtime.TimeはtimeToStrとstrToTimeメソッドでstringに変換されて用いられます。
なので、これらのメソッドも実装しておきます

func timeToStr(t time.Time) string {
	return t.Format("2006-01-02 15:04:05")
}

func strToTime(v string) time.Time {
	t, _ := time.Parse("2006-01-02 15:04:05", v)
	return t
}

最終的なスクリプトは以下

main.go

package main

//go:generate msgp
//msgp:shim time.Time as:string using:timeToStr/strToTime

import (
	"log"
	"time"

	"github.com/fluent/fluent-logger-golang/fluent"
)

func main() {
	logger, err := fluent.New(fluent.Config{FluentPort: 24224, FluentHost: "127.0.0.1"})
	if err != nil {
		log.Println(err.Error())
		return
	}
	defer logger.Close()

	logData := Log{
		ID:        12345,
		Name:      "hogehoge",
		CreatedAt: time.Now(),
	}
	if err := logger.Post("debug.test", logData); err != nil {
		log.Println(err.Error())
		return
	}
	log.Println("done")
}

type Log struct {
	ID        uint32    `msg:"id"`
	Name      string    `msg:"name"`
	CreatedAt time.Time `msg:"created_at"`
}

func timeToStr(t time.Time) string {
	return t.Format("2006-01-02 15:04:05")
}

func strToTime(v string) time.Time {
	t, _ := time.Parse("2006-01-02 15:04:05", v)
	return t
}

これで送信すると

$ go run main.go main_gen.go
2017/12/02 19:39:56 done

ちゃんとした形でログが出ています

$ cat log/app.log.20171202.b55f58f8a5413f5de
2017-12-02T19:39:56+09:00	debug.test	{"id":12345,"name":"hogehoge","created_at":"2017-12-02 19:39:56"}

こうやったら直った、っていうだけで実はあまり理由を理解してない。。。