Versions in this module Expand all Collapse all v0 v0.2.4 Apr 18, 2014 Changes in this version + func BlockRoutine(bi BlockInterface) + func ConnectionRoutine(c *Connection) + type AddChanMsg struct + Channel chan *Msg + Route string + type Block struct + Desc string + Id string + Kind string + func (b *Block) Broadcast() chan interface{} + func (b *Block) Build(c BlockChans) + func (b *Block) CleanUp() + func (b *Block) Error(msg interface{}) + func (b *Block) GetBlock() *Block + func (b *Block) GetDef() *BlockDef + func (b *Block) InRoute(routeName string) chan interface{} + func (b *Block) Log(msg interface{}) + func (b *Block) QueryRoute(routeName string) chan chan interface{} + func (b *Block) Quit() chan interface{} + func (b *Block) SetId(Id string) + type BlockChans struct + AddChan chan *AddChanMsg + DelChan chan *Msg + ErrChan chan error + InChan chan *Msg + QueryChan chan *QueryMsg + QuitChan chan bool + type BlockDef struct + Desc string + InRoutes []string + OutRoutes []string + QueryRoutes []string + Type string + type BlockInterface interface + Broadcast func() chan interface{} + Build func(BlockChans) + CleanUp func() + Error func(interface{}) + GetBlock func() *Block + GetDef func() *BlockDef + InRoute func(string) chan interface{} + Log func(interface{}) + QueryRoute func(string) chan chan interface{} + Quit func() chan interface{} + Run func() + SetId func(string) + Setup func() + type Connection struct + Id string + ToRoute string + func (c *Connection) Build(chans BlockChans) + func (c *Connection) CleanUp() + func (c *Connection) SetId(Id string) + type LogStreams struct + type Msg struct + Msg interface{} + Route string + type QueryMsg struct + RespChan chan interface{} + Route string