pulsarmq

Documentation

Index

• Variables
• func CompressLevel(val pulsar.CompressionLevel) variadic.Option
• func CompressType(val pulsar.CompressionType) variadic.Option
• func DLQPolicy(val *pulsar.DLQPolicy) variadic.Option
• func DisableBatch() variadic.Option
• func NewClient(ctx context.Context, uri string) (mq.MQ, error)
• func SubscriptionType(val pulsar.SubscriptionType) variadic.Option

Variables

var (
	ErrMalformedMessage = errors.New("pulsar: malformed message")
)

Functions

func CompressLevel

func CompressLevel(val pulsar.CompressionLevel) variadic.Option

func CompressType

func CompressType(val pulsar.CompressionType) variadic.Option

func DLQPolicy

func DLQPolicy(val *pulsar.DLQPolicy) variadic.Option

func DisableBatch

func DisableBatch() variadic.Option

func NewClient

func NewClient(ctx context.Context, uri string) (mq.MQ, error)

func SubscriptionType

func SubscriptionType(val pulsar.SubscriptionType) variadic.Option

default Exclusive