func()

in internal/output/azureeventhub/azure_event_hub.go [64:80]

• 14 lines of code
• 4 McCabe index (conditional complexity)

func (o *Output) Write(b []byte) (int, error) {
	batch, err := o.producerClient.NewEventDataBatch(o.cancelCtx, nil)
	if err != nil {
		return 0, fmt.Errorf("error while creating new event data batch: %w", err)
	}
	eventData := azeventhubs.EventData{Body: b}

	if err := batch.AddEventData(&eventData, nil); err != nil {
		return 0, fmt.Errorf("error while adding data to event data batch: %w", err)
	}

	if err := o.producerClient.SendEventDataBatch(context.TODO(), batch, nil); err != nil {
		return 0, fmt.Errorf("error while sending event data batch: %w", err)
	}

	return len(b), nil
}