pubsub

Documentation

Index

• func Commands() []internal.Command
• func WithName(name string) func(channel *Channel)
• func WithPattern(pattern string) func(channel *Channel)
• type Channel
  • func NewChannel(options ...func(channel *Channel)) *Channel
  • func (ch *Channel) IsActive() bool
  • func (ch *Channel) Name() string
  • func (ch *Channel) NumSubs() int
  • func (ch *Channel) Pattern() glob.Glob
  • func (ch *Channel) Publish(message string)
  • func (ch *Channel) Start()
  • func (ch *Channel) Subscribe(conn *net.Conn) bool
  • func (ch *Channel) Subscribers() map[*net.Conn]*resp.Conn
  • func (ch *Channel) Unsubscribe(conn *net.Conn) bool
• type PubSub
  • func NewPubSub() *PubSub
  • func (ps *PubSub) Channels(pattern string) []byte
  • func (ps *PubSub) GetAllChannels() []*Channel
  • func (ps *PubSub) NumPat() int
  • func (ps *PubSub) NumSub(channels []string) []byte
  • func (ps *PubSub) Publish(_ context.Context, message string, channelName string)
  • func (ps *PubSub) Subscribe(_ context.Context, conn *net.Conn, channels []string, withPattern bool)
  • func (ps *PubSub) Unsubscribe(_ context.Context, conn *net.Conn, channels []string, withPattern bool) []byte

Functions

func Commands

func Commands() []internal.Command

func WithName

func WithName(name string) func(channel *Channel)

WithName option sets the channels name.

func WithPattern

func WithPattern(pattern string) func(channel *Channel)

WithPattern option sets the compiled glob pattern for the channel if it's a pattern channel.

Types

type Channel

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

func NewChannel

func NewChannel(options ...func(channel *Channel)) *Channel

func (*Channel) IsActive

func (ch *Channel) IsActive() bool

func (*Channel) Name

func (ch *Channel) Name() string

func (*Channel) NumSubs

func (ch *Channel) NumSubs() int

func (*Channel) Pattern

func (ch *Channel) Pattern() glob.Glob

func (*Channel) Publish

func (ch *Channel) Publish(message string)

func (*Channel) Start

func (ch *Channel) Start()

func (*Channel) Subscribe

func (ch *Channel) Subscribe(conn *net.Conn) bool

func (*Channel) Subscribers

func (ch *Channel) Subscribers() map[*net.Conn]*resp.Conn

func (*Channel) Unsubscribe

func (ch *Channel) Unsubscribe(conn *net.Conn) bool

type PubSub

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

func NewPubSub

func NewPubSub() *PubSub

func (*PubSub) Channels

func (ps *PubSub) Channels(pattern string) []byte

func (*PubSub) GetAllChannels

func (ps *PubSub) GetAllChannels() []*Channel

func (*PubSub) NumPat

func (ps *PubSub) NumPat() int

func (*PubSub) NumSub

func (ps *PubSub) NumSub(channels []string) []byte

func (*PubSub) Publish

func (ps *PubSub) Publish(_ context.Context, message string, channelName string)

func (*PubSub) Subscribe

func (ps *PubSub) Subscribe(_ context.Context, conn *net.Conn, channels []string, withPattern bool)

func (*PubSub) Unsubscribe

func (ps *PubSub) Unsubscribe(_ context.Context, conn *net.Conn, channels []string, withPattern bool) []byte