Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Consumer ¶
type Option ¶
type Option func(*Resource)
Option are modifications that will be applied to the resource.
func WithCustomPulsarConfig ¶
func WithCustomPulsarConfig(f func(opts *pulsar.ClientOptions)) Option
WithCustomPulsarConfig allows you to change the pulsar.ClientOptions before the client is created. If you need a config that is not supported by the rscpulsar package, you can use this option to apply your own config.
type PlatformConfig ¶
type Resource ¶
func New ¶
func New(cfg PlatformConfig, opts ...Option) *Resource
New builds a new services.Resource for connecting to an Apache Pulsar server.
func (*Resource) Subscribe ¶
func (r *Resource) Subscribe(cfg SubscriptionPlatformConfig, handler consume.MessageHandler, opts ...consume.Option) (*Consumer, error)
Click to show internal directories.
Click to hide internal directories.