pulsar

Dec 12, 2023

Changes in this version

+ var ConsumerElementKey = micro.ElementKey("PulsarConsumerComponent")

+ var ProducerElementKey = micro.ElementKey("PulsarProducerComponent")

+ func SetDefaultConfig()

+ type Config struct

+ Enable bool

+ Topic string

+ URL string

+ func GetConfig() *Config

+ type Consumer struct

+ func NewConsumer(url string, topic string) (*Consumer, error)

+ func (c *Consumer) Close() error

+ func (c *Consumer) ReceiverChannel(out chan<- []byte)

+ type ConsumerComponent struct

+ func (c *ConsumerComponent) Init(server *micro.Server) error

+ func (c *ConsumerComponent) Name() string

+ func (c *ConsumerComponent) PostStop(ctx context.Context) error

+ func (c *ConsumerComponent) PreInit(ctx context.Context) error

+ type Producer struct

+ func NewProducer(logger logging.ILogger, url string, topic string) (*Producer, error)

+ func (c *Producer) Close() error

+ func (c *Producer) Send(data []byte)

+ type ProducerComponent struct

+ func (c *ProducerComponent) Init(server *micro.Server) error

+ func (c *ProducerComponent) Name() string

+ func (c *ProducerComponent) PostStop(ctx context.Context) error

+ func (c *ProducerComponent) PreInit(ctx context.Context) error