Documentation ¶
Index ¶
- Variables
- type Message
- type Router
- func (router *Router) Close()
- func (router *Router) NonBlockingPublish(ctx context.Context, channelID string, obj interface{}) <-chan error
- func (router *Router) Publish(ctx context.Context, channelID string, obj interface{}) error
- func (router *Router) Subscribe(channelID string) chan Message
- func (router *Router) Unsubscribe(channelID string, ch chan Message) chan struct{}
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrTimedOut = errors.New("timed out") ErrNotDelivered = errors.New("not delivered") )
Functions ¶
This section is empty.
Types ¶
type Router ¶
type Router struct {
// contains filtered or unexported fields
}
func (*Router) NonBlockingPublish ¶
func (*Router) Unsubscribe ¶
Click to show internal directories.
Click to hide internal directories.