channelManager

Documentation

Index

• func CanCluster() bool
• func HasModuleInit() bool
• func InitModule() error
• func RecvMsgFromChain(chainName string) (string, interface{}, gerror.IError)
• func RegisterChain(chainName string) gerror.IError
• func ReleaseChain(chainName string)
• func SendMsgToChain(srcName, chainName string, msg interface{}) gerror.IError
• type ChainManagerMap
  • func (this ChainManagerMap) CanCluster() bool
  • func (this *ChainManagerMap) RecvMsgFromChain(chainName string) (string, interface{}, gerror.IError)
  • func (this *ChainManagerMap) RegisterChain(chainName string) gerror.IError
  • func (this *ChainManagerMap) ReleaseChain(chainName string)
  • func (this *ChainManagerMap) SendMsgToChain(srcName, chainName string, msg interface{}) gerror.IError
• type ChannelMsg
• type IChainManager
  • func GetChainManager(chainType string, clusterId int, mapSize, cacheSize int) (ch IChainManager, ok bool)
  • func NewChainManagerMap(mapSize, cacheSize int) IChainManager

Functions

func CanCluster

func CanCluster() bool

func HasModuleInit

func HasModuleInit() bool

func InitModule

func InitModule() error

func RecvMsgFromChain

func RecvMsgFromChain(chainName string) (string, interface{}, gerror.IError)

func RegisterChain

func RegisterChain(chainName string) gerror.IError

func ReleaseChain

func ReleaseChain(chainName string)

func SendMsgToChain

func SendMsgToChain(srcName, chainName string, msg interface{}) gerror.IError

Types

type ChainManagerMap

type ChainManagerMap struct {
	ChainMap map[string]chan ChannelMsg
	// contains filtered or unexported fields
}

func (ChainManagerMap) CanCluster

func (this ChainManagerMap) CanCluster() bool

func (*ChainManagerMap) RecvMsgFromChain

func (this *ChainManagerMap) RecvMsgFromChain(chainName string) (string, interface{}, gerror.IError)

func (*ChainManagerMap) RegisterChain

func (this *ChainManagerMap) RegisterChain(chainName string) gerror.IError

*************for IChainManager****************

func (*ChainManagerMap) ReleaseChain

func (this *ChainManagerMap) ReleaseChain(chainName string)

func (*ChainManagerMap) SendMsgToChain

func (this *ChainManagerMap) SendMsgToChain(srcName, chainName string, msg interface{}) gerror.IError

type ChannelMsg

type ChannelMsg struct {
	FromChain string
	ToChain   string
	Msg       interface{}
}

内部收发信息结构

type IChainManager

type IChainManager interface {
	RegisterChain(chainName string) gerror.IError //注册通道
	ReleaseChain(chainName string)                //释放通道
	SendMsgToChain(srcName, chainName string, msg interface{}) gerror.IError
	RecvMsgFromChain(chainName string) (string, interface{}, gerror.IError)
	CanCluster() bool //判断是否支持集群
}

func GetChainManager

func GetChainManager(chainType string, clusterId int,
	mapSize, cacheSize int) (ch IChainManager, ok bool)

func NewChainManagerMap

func NewChainManagerMap(mapSize, cacheSize int) IChainManager