README
¶
DisqChan - distributed channels over Disque
This is an example project with a higher level abstraction over go-disque.
This library provides a disque-based networked channels, on which you can send and receive objects between machines. Messages are encoded as JSON and deserialized when received.
Example Usage:
Sending messages:
func ExampleSend() {
sc := disqchan.NewChan("mychan", false, "127.0.0.1:7711")
defer sc.Stop()
ch := sc.SendChan()
for i := 0; i < 100; i++ {
ch <- fmt.Sprintf("Message %d", i)
}
}
Receiving Messages:
func ExampleRecv() {
c := NewChan("mychan", false, "127.0.0.1:7711")
rch := c.RecvChan()
i := 0
for v := range rch {
fmt.Println("Received: ", v)
i++
if i == 10 {
fmt.Println("finished")
break
}
}
}
Documentation
¶
Overview ¶
Package disqchan is an abstraction of Disque messages over Go channels.
The idea is that you create Chan objects on multiple machines. Each of them has to have the same name across machines, and can be used to send and/or receive messages.
Messages can be any object. Messages are serialized as JSON, so the usual rules of JSON marshalling apply
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ( // The timeout on GETJOB requests GetTimeout = time.Second )
Functions ¶
This section is empty.
Types ¶
type Chan ¶
type Chan struct {
// contains filtered or unexported fields
}
Chan represents a cross machine "channel" over disque
func NewChan ¶
NewChan creates a new disque channel objec with a given name, over a disque cluster with the given addrs. If async is true, messages are sent using disque async replication (see disque docs for details)
func (*Chan) RecvChan ¶
func (c *Chan) RecvChan() <-chan interface{}
RecvChan returns a channel from which received messages can be received.
Before it is called, this Chan is not receiving from the queue
Source Files