in out_writeapi.go [380:389]
func sendRequest(ctx context.Context, data [][]byte, config **outputConfig, streamIndex int) error {
if len(data) > 0 {
if (*config).exactlyOnce {
return sendRequestRetries(ctx, data, config, streamIndex)
} else {
return sendRequestDefault(ctx, data, config, streamIndex)
}
}
return nil
}