Go Pub Sub Channels

Easily send messages between multiple go routines with error response handling.

Setup

rt := router.NewRouter()
defer rt.Close()

Subscribing

subChan := rt.Subscribe("channel id")
for {
    select {
    case msg, ok := <-subChan:
        if ok == false {
            // Either was closed from Unsubscribe call or
            // rt.Close()
            break
        }
    }
}

Publishing

err := rt.Publish(context.Background(), "channel_id", "Hello World!")
if err == router.ErrNotDelivered {
    // The message didn't get delivered to any subscribers.
} else if err == router.ErrTimedOut {
    // The message may have been delivered to some subscribers,
    // but the context timed out.
} else err != nil {
    // Errors passed back by one or more subscribers.
}

Unsubscribing

doneChan := rt.Unsubscribe("channel_id", subChan)
// Either wait for the doneChan to close
<-doneChan
// Or wait for the subChan to close