service

type ElasticClient interface {
	GetInput() chan<- model.Document
}

type KafkaConsumerGroup interface {
	GetOutput() <-chan model.KafkaData
}

type LogicService interface {
	CreateAndStartLogic(l *model.Logic) error
	RemoveLogic(sid, lid int) error
	GetLogicChans(sid int) (map[int]chan model.LogicData, error)
}