channel

Documentation

Index

• Constants
• type ChanContext
  • func ChanContextInstance() *ChanContext
  • func (ctx *ChanContext) AddChannel(module string, moduleCh ChanMsgType)
  • func (ctx *ChanContext) DelChannel(module string)
  • func (ctx *ChanContext) GetChannel(module string) ChanMsgType
  • func (ctx *ChanContext) NewChannel() ChanMsgType
• type ChanMsgType

Constants

const (
	ChanSizeDefault = 1024
)

constants for channel context

const (
	ModuleNameContainerImage = "containerImage"
)

Types

type ChanContext

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

func ChanContextInstance

func ChanContextInstance() *ChanContext

func (*ChanContext) AddChannel

func (ctx *ChanContext) AddChannel(module string, moduleCh ChanMsgType)

func (*ChanContext) DelChannel

func (ctx *ChanContext) DelChannel(module string)

deleteChannel by module name

func (*ChanContext) GetChannel

func (ctx *ChanContext) GetChannel(module string) ChanMsgType

getChannel return chan

func (*ChanContext) NewChannel

func (ctx *ChanContext) NewChannel() ChanMsgType

type ChanMsgType

type ChanMsgType chan interface{}