wpc

Documentation

Index

• func BuildTopicPath(tenantName, namespace, topicName string) string
• func Close()
• func GetConsumer(namespace string, topic string) wpcm.Consumer
• func GetProducer(namespace string, topic string) wpcm.Producer
• func RegisterConsumer(namespace string, topic string, handler wpcm.Handler)
• func RegisterProducer(namespace string, topic string)
• type Wpc
  • func New(connectionUrl string, tenant string, logger *zap.SugaredLogger, ...) *Wpc

Functions

func BuildTopicPath

func BuildTopicPath(tenantName, namespace, topicName string) string

func Close

func Close()

func GetConsumer

func GetConsumer(namespace string, topic string) wpcm.Consumer

func GetProducer

func GetProducer(namespace string, topic string) wpcm.Producer

func RegisterConsumer

func RegisterConsumer(namespace string, topic string, handler wpcm.Handler)

func RegisterProducer

func RegisterProducer(namespace string, topic string)

Types

type Wpc

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

func New

func New(connectionUrl string, tenant string, logger *zap.SugaredLogger, pulsarOptions ...*pulsar.ClientOptions) *Wpc