subscription

Documentation

Index

• Variables
• func IsValidPublishName(channel string) bool
• func IsValidSubscriptionName(channel string) bool
• type Subscription
  • func NewSubscription(chanel string, unsub Unsubscriber, msgCh chan *message.Message) (*Subscription, error)
  • func (s *Subscription) MsgChannel() chan *message.Message
  • func (s *Subscription) Name() string
  • func (s *Subscription) OnMessage(onMessage func(channel string, msg message.Data)) error
  • func (s *Subscription) Unsubscribe() error
• type Unsubscriber

Variables

var ErrInvalidChannelName = errors.New("invalid channel channel")

Functions

func IsValidPublishName

func IsValidPublishName(channel string) bool

isValidPublishName

func IsValidSubscriptionName

func IsValidSubscriptionName(channel string) bool

Types

type Subscription

type Subscription struct {
	// contains filtered or unexported fields
}

func NewSubscription

func NewSubscription(chanel string, unsub Unsubscriber, msgCh chan *message.Message) (*Subscription, error)

todo error

func (*Subscription) MsgChannel

func (s *Subscription) MsgChannel() chan *message.Message

func (*Subscription) Name

func (s *Subscription) Name() string

func (*Subscription) OnMessage

func (s *Subscription) OnMessage(onMessage func(channel string, msg message.Data)) error

func (*Subscription) Unsubscribe

func (s *Subscription) Unsubscribe() error

Unsubscribe ...

type Unsubscriber

type Unsubscriber func(subscription *Subscription) error