Documentation ¶
Index ¶
- Variables
- type Message
- type Noqueue
- func (noqueue *Noqueue) Close()
- func (noqueue *Noqueue) NonBlockingPublish(ctx context.Context, channelID string, obj interface{}) <-chan error
- func (noqueue *Noqueue) Publish(ctx context.Context, channelID string, obj interface{}) error
- func (noqueue *Noqueue) Subscribe(channelID string) chan Message
- func (noqueue *Noqueue) 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 Noqueue ¶
type Noqueue struct {
// contains filtered or unexported fields
}
func NewNoqueue ¶
func NewNoqueue() *Noqueue
func (*Noqueue) NonBlockingPublish ¶
func (*Noqueue) Unsubscribe ¶
Click to show internal directories.
Click to hide internal directories.