Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrInvalidChannelName = errors.New("invalid channel channel")
Functions ¶
func IsValidSubscriptionName ¶
Types ¶
type Subscription ¶
type Subscription struct {
// contains filtered or unexported fields
}
func NewSubscription ¶
func NewSubscription(chanel string, unsub Unsubscriber, authToken string, msgCh chan *message.Message) (*Subscription, error)
todo error
func (*Subscription) AuthToken ¶ added in v0.0.3
func (s *Subscription) AuthToken() string
func (*Subscription) MsgChannel ¶
func (s *Subscription) MsgChannel() chan *message.Message
func (*Subscription) Name ¶
func (s *Subscription) Name() string
type Unsubscriber ¶
type Unsubscriber func(subscription *Subscription) error
Click to show internal directories.
Click to hide internal directories.