zmq4 icon indicating copy to clipboard operation
zmq4 copied to clipboard

High/Low Water mark support?

Open junkblocker opened this issue 6 years ago • 2 comments

I want to be able to PUSH only a limited number of packets to avoid losing them if the PULL side crashes. Is this possible or planned? Looking at the code I see that go's io.ReadWriteCloser is used underneath so it seems no message level limiting is possible.

junkblocker avatar Jul 14 '18 23:07 junkblocker

It probably isn't possible right now but it's definitely something most people will need at some point.

I don't think having based the transport on 'io.ReadWriteCloser' will prevent to implement that (but happy to hear otherwise)

sbinet avatar Jul 15 '18 08:07 sbinet

Since I need it soon, I'd like to take a stab at implementing this. Any general clues about the implementation design to save me time investigating would be highly appreciated.

junkblocker avatar Jul 15 '18 16:07 junkblocker