service

Documentation

Index

• type ElasticClient
• type KafkaConsumerGroup
• type LogicCore

Types

type ElasticClient

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

type KafkaConsumerGroup

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

type LogicCore

type LogicCore interface {
	CreateAndStartLogic(r *model.RingRequest, id string, event chan interface{})
	GetLogicChans(key string) map[string]chan model.LogicData
	RemoveLogic(lname string) error
	RemoveLogicsBySID(sid string) error
}