func DecodeFromJSON()

in app/pubsub-integration/avro/avro.go [50:63]


func DecodeFromJSON(codec *goavro.Codec, json []byte) (map[string]interface{}, error) {
	native, _, err := codec.NativeFromTextual(json)
	if err != nil {
		log.Println("fail to decode json=", json, "err=", err)
		return nil, err
	}
	data, ok := native.(map[string]interface{})
	if !ok {
		log.Println("fail to decode json=", json, "err=", err)
		return nil, err
	}
	return data, err

}