pubsub

Documentation

Index

• type IncomingMessage
  • func (m *IncomingMessage) Channel() (string, bool)
  • func (m *IncomingMessage) Kind() MessageKind
  • func (m *IncomingMessage) NumChannels() (int64, bool)
  • func (m *IncomingMessage) Pattern() (string, bool)
  • func (m *IncomingMessage) Payload() (string, bool)
  • func (m *IncomingMessage) UnmarshalRESP(value resp.Value) error
• type MessageKind
• type Subscription
• type Subscriptions
  • func (s *Subscriptions) Active() (channels, patterns []string)
  • func (s *Subscriptions) Subscribe(ch string, pattern bool)
  • func (s *Subscriptions) Unsubscribe(ch string, pattern bool)

Types

type IncomingMessage

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

func (*IncomingMessage) Channel

func (m *IncomingMessage) Channel() (string, bool)

func (*IncomingMessage) Kind

func (m *IncomingMessage) Kind() MessageKind

func (*IncomingMessage) NumChannels

func (m *IncomingMessage) NumChannels() (int64, bool)

func (*IncomingMessage) Pattern

func (m *IncomingMessage) Pattern() (string, bool)

func (*IncomingMessage) Payload

func (m *IncomingMessage) Payload() (string, bool)

func (*IncomingMessage) UnmarshalRESP

func (m *IncomingMessage) UnmarshalRESP(value resp.Value) error

type MessageKind

type MessageKind string

const (
	KindSubscribe    MessageKind = "subscribe"
	KindSubscribeP   MessageKind = "psubscribe"
	KindUnsubscribe  MessageKind = "unsubscribe"
	KindUnsubscribeP MessageKind = "punsubscribe"
	KindMessage      MessageKind = "message"
	KindPong         MessageKind = "pong"
)

type Subscription

type Subscription struct {
	Channel string
	Pattern bool
}

type Subscriptions

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

func (*Subscriptions) Active

func (s *Subscriptions) Active() (channels, patterns []string)

func (*Subscriptions) Subscribe

func (s *Subscriptions) Subscribe(ch string, pattern bool)

func (*Subscriptions) Unsubscribe

func (s *Subscriptions) Unsubscribe(ch string, pattern bool)