ws

Documentation

Index

• func GetChannels(port uint, db *gorm.DB, cleanup func(channels.Publisher)) (<-chan *WebsocketChannel, func() error)
• type WebsocketChannel
  • func (consumerChannel *WebsocketChannel) AddConsumer(consumer channels.Consumer) bool
  • func (pub *WebsocketChannel) Publish(payload string) bool
  • func (consumerChannel *WebsocketChannel) Publisher() channels.Publisher
  • func (consumerChannel *WebsocketChannel) PurgeRejected() int
  • func (consumerChannel *WebsocketChannel) ReturnAllUnacked() int
  • func (consumerChannel *WebsocketChannel) StartConsuming() bool
  • func (consumerChannel *WebsocketChannel) StopConsuming() bool

Functions

func GetChannels

func GetChannels(port uint, db *gorm.DB, cleanup func(channels.Publisher)) (<-chan *WebsocketChannel, func() error)

Types

type WebsocketChannel

type WebsocketChannel struct {
	Filter string
	// contains filtered or unexported fields
}

func (*WebsocketChannel) AddConsumer

func (consumerChannel *WebsocketChannel) AddConsumer(consumer channels.Consumer) bool

func (*WebsocketChannel) Publish

func (pub *WebsocketChannel) Publish(payload string) bool

func (*WebsocketChannel) Publisher

func (consumerChannel *WebsocketChannel) Publisher() channels.Publisher

func (*WebsocketChannel) PurgeRejected

func (consumerChannel *WebsocketChannel) PurgeRejected() int

func (*WebsocketChannel) ReturnAllUnacked

func (consumerChannel *WebsocketChannel) ReturnAllUnacked() int

func (*WebsocketChannel) StartConsuming

func (consumerChannel *WebsocketChannel) StartConsuming() bool

func (*WebsocketChannel) StopConsuming

func (consumerChannel *WebsocketChannel) StopConsuming() bool