pulsar

Documentation

Index

• Constants
• func NewPulsarMessageConsumerService(logger *zap.SugaredLogger, pulsarSettings PulsarSettings) (messaging.MessageConsumerService, error)
• type PulsarSettings

Constants

const ConfigKey = "pulsar"

Functions

func NewPulsarMessageConsumerService

func NewPulsarMessageConsumerService(
	logger *zap.SugaredLogger,
	pulsarSettings PulsarSettings) (messaging.MessageConsumerService, error)

Types

type PulsarSettings

type PulsarSettings struct {
	Url              string
	SubscriptionName string
}