func()

in pipeline/endpoints/disk.go [85:104]

• 19 lines of code
• 5 McCabe index (conditional complexity)

func (ep *DiskEndpoint) Send(r pipeline.EndpointReport) error {
	dctx := diskContext{}
	err := r.UnmarshalContext(&dctx)
	if err != nil {
		return err
	}
	jsontext, err := json.Marshal(r.StampedMetricReport)
	if err != nil {
		return err
	}
	if err := os.MkdirAll(ep.path, directoryMode); err != nil {
		return err
	}
	file := path.Join(ep.path, dctx.Name)

	if err := ioutil.WriteFile(file, jsontext, fileMode); err != nil {
		return err
	}
	return nil
}