Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Connector ¶
type Connector interface { // ConsumerDelayTopic is the subject of the subscription latency processor ConsumerDelayTopic(confInfoList []*cc.ProducerConfInfo) // WatchDelayTopic watch the topic of the latency processor WatchDelayTopic(c *cc.ProducerConfInfo, eventType int32) error // ConsumerProcessorTopic is the topic of the subscription processor ConsumerProcessorTopic(confInfoList []*cc.ProcessorConfInfo) // WatchProcessorTopic watch the topic of the processor WatchProcessorTopic(c *cc.ProcessorConfInfo, eventType int32) error // Stop stops the connector gracefully. Stop() error }
Connector is a store of events
Click to show internal directories.
Click to hide internal directories.