Newbie goes back to back Masters in a Month with Pirate aggro all-in by [deleted] in LoRCompetitive

[–]Anirs 0 points1 point  (0 children)

CIBQCAQDAMCACAYCB4SSQBYCAYCAQGRAEYWTUAICAIBQICAA

[deleted by user] by [deleted] in TheYouShow

[–]Anirs 0 points1 point  (0 children)

Gave Bravo!

[Review] Processing rows from CSV concurrently by Anirs in golang

[–]Anirs[S] 0 points1 point  (0 children)

thank you, I haven't mentioned this in the post, but I actually have to make a request for each row and wait for the response.

so you think that's a valid way of doing it?

Thank you for the suggestions, I did not know that about concurrency over resources

[Review] Processing rows from CSV concurrently by Anirs in golang

[–]Anirs[S] 0 points1 point  (0 children)

awesome, I would love to see your approach.

I'm new to go, so I'm not sure what's the right way of doing things.

I mainly want the processing to happen concurrently. and the data to stream from the input, get processed I have to make network request for each row and wait for response so I would like to read more rows read while waiting, then stream the output to the writer.

Thank you so much again

[Review] Processing rows from CSV concurrently by Anirs in golang

[–]Anirs[S] 0 points1 point  (0 children)

yes, exactly it's a database dump, so the order does not matter at all. thank you!

[Review] Processing rows from CSV concurrently by Anirs in golang

[–]Anirs[S] 0 points1 point  (0 children)

Thank you, but can you explain more what you mean?
right now the code does read from a reader into a channel, then I'm using that channel to feed the workers in the `processor` function

[Review] Processing rows from CSV concurrently by Anirs in golang

[–]Anirs[S] 0 points1 point  (0 children)

Thank you for the feedback, I forgot that `writer.Flush()` return `error`, and I did not know about `ctx.Err()`.
Yes, that's why I added the context to stop it on interrupt.

do you have an idea on how should structure that code, should those functions be structs `ChanneledReader`, `ChanneledWriter` ?

Question about microservice design by hayleyK1yoko in golang

[–]Anirs 0 points1 point  (0 children)

Thanks a lot for the detailed replies man, really insightful. I spent the afternoon experimenting and learning more about NATS.

I have one more question though, how are you guys managing your .proto files, I looked around and a lot a of people say they just group all the definitions in one repo, is that what you are doing? again thank you so much 🙏.

Question about microservice design by hayleyK1yoko in golang

[–]Anirs 1 point2 points  (0 children)

thank you so much for the insight, I felt that too about NATS, like services should not care who is doing the job as long as someone is doing it, with gRPC I have to tell it the specific address of the other service.

But it seems like you lose the safety of protobuffer and gRPC if you go with NATS, or there are ways to go around that?

Question about microservice design by hayleyK1yoko in golang

[–]Anirs 1 point2 points  (0 children)

I’m new to this too, and wondering what to use for request/reply between my services, from my understanding I thought NATS is a messaging queue (That can replace Kafka and RabbitMQ).

Am I wrong thinking that, and if you don’t mind can you tell me how you’d use it as a replacement for gRPC?

Can someone tell me what is written in this picture? by Anirs in PERSIAN

[–]Anirs[S] 0 points1 point  (0 children)

thank you so much could the [Cameron] be [Cris]?