pulsar

Documentation

Overview

Package pulsar handles publishing and subscribing with Apache Pulsar

Index

• func NewConsumer(ctx context.Context, logger *zap.SugaredLogger, topic string, ...) (pubsub.Consumer, error)
• func NewPublisher(ctx context.Context, cancelFn context.CancelFunc, logger *zap.SugaredLogger, ...) (pubsub.Publisher, error)

Functions

func NewConsumer

func NewConsumer(
	ctx context.Context,
	logger *zap.SugaredLogger,
	topic string,
	subscriber chan string,
) (pubsub.Consumer, error)

NewConsumer returns a pulsar consumer

func NewPublisher

func NewPublisher(
	ctx context.Context,
	cancelFn context.CancelFunc,
	logger *zap.SugaredLogger,
	topic string,
) (pubsub.Publisher, error)

NewPublisher returns a pulsar publisher