pubsub

Documentation

Index

• type Manager
  • func GetSubscribeManager() Manager
  • func InitSubscribeManager() Manager
• type ManagerImpl
  • func (c *ManagerImpl) AddSubscribe(key string, ch chan interface{})
  • func (c *ManagerImpl) Close(key string)
  • func (c *ManagerImpl) ShutDown()
  • func (c *ManagerImpl) TryPublish(key string, data interface{})
  • func (c *ManagerImpl) TrySendOnce(ch chan interface{}, data interface{})
  • func (c *ManagerImpl) UnSubscribe(key string, ch chan interface{})

Types

type Manager

type Manager interface {
	ShutDown()
	Close(string)
	AddSubscribe(string, chan interface{})
	UnSubscribe(string, chan interface{})
	TryPublish(string, interface{})
	TrySendOnce(ch chan interface{}, data interface{})
}

func GetSubscribeManager

func GetSubscribeManager() Manager

func InitSubscribeManager

func InitSubscribeManager() Manager

type ManagerImpl

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

func (*ManagerImpl) AddSubscribe

func (c *ManagerImpl) AddSubscribe(key string, ch chan interface{})

func (*ManagerImpl) Close

func (c *ManagerImpl) Close(key string)

func (*ManagerImpl) ShutDown

func (c *ManagerImpl) ShutDown()

func (*ManagerImpl) TryPublish

func (c *ManagerImpl) TryPublish(key string, data interface{})

func (*ManagerImpl) TrySendOnce

func (c *ManagerImpl) TrySendOnce(ch chan interface{}, data interface{})

func (*ManagerImpl) UnSubscribe

func (c *ManagerImpl) UnSubscribe(key string, ch chan interface{})