vice
vice copied to clipboard
matryer
Go channels at horizontal scale (powered by message queues)
This PR adds a new underlying queuing technology to "vice" called Emitter which is a high-performance, low-latency, and secure platform based on MQTT. More details can be found at [emitter.io](https://emitter.io).
Adding MQTT transport that need shared subscription. AFAIK shared subscription is supported by VerneMQ and EMQ.
https://github.com/matryer/vice/blob/660007f4486b289078664b182d1ecd2a22b29b02/transport.go#L24 Done() in context.Context returns a `
I have this use case: - A Redis list is initialized with 3 messages '1', '2' and '3'. - A main function iterates forever on a redis receiver. - After...
Hi, I have a huge file, on each line I have a value to send for a GET request. I would like to create a queue with the file information,...
Right now, when connection to broker drops, there is no way to reconnect and restore channels functionality. Also, as I see, `chan []byte`s created by `vice.Transport` blocks forever after disconnection....
If anyone is interested i am experimenting with adding this. https://ipfs.io/blog/25-pubsub/ I know its a bit unusual but its inherently has storage that is redundant because its backed by IPFS....
I get this build error when I try to build after importing "github.com/matryer/vice/queues/nats". ..\..\pkg\mod\github.com\matryer\[email protected]\queues\nats\nats.go:83:99: cannot use t.natsConn (variable of type *"github.com/nats-io/go-nats".Conn) as *"github.com/nats-io/nats.go".Conn value in argument to stan.NatsConn
