memory

Documentation

Index

• func NewInMemory(log logger.Logger) pubsub.PubSub
• type Plugin
  • func (p *Plugin) Connections(topic string, res map[string]struct{})
  • func (p *Plugin) Next() (*websocketsv1.Message, error)
  • func (p *Plugin) Publish(message []byte) error
  • func (p *Plugin) PublishAsync(message []byte)
  • func (p *Plugin) Subscribe(connectionID string, topics ...string) error
  • func (p *Plugin) Unsubscribe(connectionID string, topics ...string) error

Functions

func NewInMemory

func NewInMemory(log logger.Logger) pubsub.PubSub

Types

type Plugin

type Plugin struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*Plugin) Connections

func (p *Plugin) Connections(topic string, res map[string]struct{})

func (*Plugin) Next

func (p *Plugin) Next() (*websocketsv1.Message, error)

func (*Plugin) Publish

func (p *Plugin) Publish(message []byte) error

func (*Plugin) PublishAsync

func (p *Plugin) PublishAsync(message []byte)

func (*Plugin) Subscribe

func (p *Plugin) Subscribe(connectionID string, topics ...string) error

func (*Plugin) Unsubscribe

func (p *Plugin) Unsubscribe(connectionID string, topics ...string) error