connector

Documentation

Index

• type Connector
  • func New(opts *options.Options, c *options.ConnectorConfig, handler *handler.Handler) (Connector, error)

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

func New

func New(opts *options.Options, c *options.ConnectorConfig, handler *handler.Handler) (Connector, error)

New creates the connector of store