blocks

type AddChanMsg struct {
	Route   string
	Channel chan *Msg
}

type Block struct {
	Id   string // the name of the block specifed by the user (like MyBlock)
	Kind string // the kind of block this is (like count, toFile, fromSQS)
	Desc string // the description of block ('counts the number of messages it has seen')

	BlockChans
	LogStreams
	// contains filtered or unexported fields
}

type BlockChans struct {
	InChan    chan *Msg
	QueryChan chan *QueryMsg
	AddChan   chan *AddChanMsg
	DelChan   chan *Msg
	ErrChan   chan error
	QuitChan  chan bool
}

type BlockDef struct {
	Type        string
	Desc        string
	InRoutes    []string
	QueryRoutes []string
	OutRoutes   []string
}

type BlockInterface interface {
	Setup()
	Run()
	CleanUp()
	Build(BlockChans)
	Quit() chan interface{}
	Broadcast() chan interface{}
	InRoute(string) chan interface{}
	QueryRoute(string) chan chan interface{}
	GetBlock() *Block
	GetDef() *BlockDef
	Log(interface{})
	Error(interface{})
	SetId(string)
}

type Connection struct {
	Id      string
	ToRoute string
	BlockChans
	LogStreams
}

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

type Msg struct {
	Msg   interface{}
	Route string
}

type QueryMsg struct {
	Route    string
	RespChan chan interface{}
}