func()

in beater/pubsubbeat.go [224:236]

• 13 lines of code
• 3 McCabe index (conditional complexity)

func (bt *Pubsubbeat) decode(s []byte, i *common.MapStr) error {
	if bt.config.Json.UseNumber {
		decoder := json.NewDecoder(bytes.NewReader(s))
		decoder.UseNumber()
		err := decoder.Decode(i)
		if err == nil {
			jsontransform.TransformNumbers(*i)
		}
		return err
	} else {
		return json.Unmarshal(s, i)
	}
}