core

type BoltConn interface {
	Connect()
	Context() *messages.Context
	Log(msg string)
	ReadBoltMsg(meta *messages.BoltMsgMeta, contentStructs ...interface{}) (err error)
	SendAck(id string)
	SendFail(id string)
	SendSync()
	Emit(anchors []string, stream string, content ...interface{}) (taskIds []int32)
	EmitDirect(anchors []string, stream string, directTask int64, contents ...interface{})
}

type Input interface {
	ReadMsg(msg interface{}) (err error)
	ReadTaskIds() (taskIds []int32)
	ReadBoltMsg(meta *messages.BoltMsgMeta, contentStructs ...interface{}) (err error)
}

type InputFactory interface {
	NewInput(reader io.Reader) Input
}

type Output interface {
	SendMsg(msg interface{})
	EmitGeneric(command, id, stream, msg string, anchors []string, directTask int64, needTaskIds bool, contents ...interface{})
	Flush()
}

type OutputFactory interface {
	NewOutput(writer io.Writer) Output
}

type SpoutConn interface {
	Connect()
	Context() *messages.Context
	Log(msg string)
	ReadSpoutMsg() (command, id string, err error)
	SendSync()
	Emit(id string, stream string, contents ...interface{}) (taskIds []int32)
	EmitDirect(id string, stream string, directTask int64, contents ...interface{})
}