func()

in plugins/forwarder/grpc/nativeebpfprofiling/forwarder.go [75:98]

• 24 lines of code
• 7 McCabe index (conditional complexity)

func (f *Forwarder) Forward(batch event.BatchEvents) error {
	stream, err := f.profilingClient.CollectProfilingData(context.Background())
	if err != nil {
		return err
	}
	for _, e := range batch {
		data, ok := e.GetData().(*v1.SniffData_EBPFProfilingDataList)
		if !ok {
			continue
		}
		for _, d := range data.EBPFProfilingDataList.DataList {
			err := stream.Send(d)
			if err != nil {
				log.Logger.Errorf("%s send log data error: %v", f.Name(), err)
				err = closeStream(stream)
				if err != nil {
					log.Logger.Errorf("%s close stream error: %v", f.Name(), err)
				}
				return err
			}
		}
	}
	return closeStream(stream)
}