pulsar

Documentation

Index

• func KeyConsumer(topic, subName string) string
• type Consumer
  • func (s *Consumer) ProcessMessage(topic string, msg pulsar.Message) error
• type EventType
• type Pulsar
  • func New(opts *options.Options, c *options.PulsarConfig, handler *handler.Handler) (*Pulsar, error)
  • func (s *Pulsar) ConsumerDelayTopic(confInfoList []*cc.ProducerConfInfo)
  • func (s *Pulsar) ConsumerProcessorTopic(confInfoList []*cc.ProcessorConfInfo)
  • func (s *Pulsar) Stop() error
  • func (s *Pulsar) WatchDelayTopic(c *cc.ProducerConfInfo, eventType int32) error
  • func (s *Pulsar) WatchProcessorTopic(c *cc.ProcessorConfInfo, eventType int32) error

Functions

func KeyConsumer

func KeyConsumer(topic, subName string) string

KeyConsumer assembly consumer key

Types

type Consumer

type Consumer struct {
	// contains filtered or unexported fields
}

Consumer is a consumer of Pulsar

func (*Consumer) ProcessMessage

func (s *Consumer) ProcessMessage(topic string, msg pulsar.Message) error

ProcessMessage processing message

type EventType

type EventType int

const (
	EventTypeProcessor EventType = 1
	EventTypeDelay     EventType = 2
)

type Pulsar

type Pulsar struct {
	// contains filtered or unexported fields
}

Pulsar is a type of connector

func New

func New(opts *options.Options, c *options.PulsarConfig, handler *handler.Handler) (*Pulsar, error)

New creates a Pulsar connector

func (*Pulsar) ConsumerDelayTopic

func (s *Pulsar) ConsumerDelayTopic(confInfoList []*cc.ProducerConfInfo)

ConsumerDelayTopic is the subject of the subscription latency processor

func (*Pulsar) ConsumerProcessorTopic

func (s *Pulsar) ConsumerProcessorTopic(confInfoList []*cc.ProcessorConfInfo)

ConsumerProcessorTopic is the topic of the subscription processor

func (*Pulsar) Stop

func (s *Pulsar) Stop() error

Stop stops the Pulsar connector gracefully.

func (*Pulsar) WatchDelayTopic

func (s *Pulsar) WatchDelayTopic(c *cc.ProducerConfInfo, eventType int32) error

WatchDelayTopic watch the topic of the latency processor

func (*Pulsar) WatchProcessorTopic

func (s *Pulsar) WatchProcessorTopic(c *cc.ProcessorConfInfo, eventType int32) error

WatchProcessorTopic watch the topic of the processor