Function doWFSAppend

pkg/jobcontroller/jobcontroller.go:774–792

(ctx context.Context, oref waveobj.ORef, fileName string, data []byte)

}

func doWFSAppend(ctx context.Context, oref waveobj.ORef, fileName string, data []byte) error {
	err := filestore.WFS.AppendData(ctx, oref.OID, fileName, data)
	if err != nil {
		return err
	}
	wps.Broker.Publish(wps.WaveEvent{
		Event: wps.Event_BlockFile,
		Scopes: []string{
			oref.String(),
		},
		Data: &wps.WSFileEventData{
			ZoneId:   oref.OID,
			FileName: fileName,
			FileOp:   wps.FileOp_Append,
			Data64:   base64.StdEncoding.EncodeToString(data),
		},
	})
	return nil
}

func handleAppendJobFile(ctx context.Context, jobId string, fileName string, data []byte) error {
	err := doWFSAppend(ctx, waveobj.MakeORef(waveobj.OType_Job, jobId), fileName, data)