NewClient returns a Pulsar client for the given configuration options.

NewClientPool initializes a ClientPool.

NewManagedClient returns a ManagedClient for the given address.

NewManagedConsumer returns an initialized ManagedConsumer.

NewManagedProducer returns an initialized ManagedProducer.

1.

3.

2.

ErrorInvalidSubMode When SubscriptionMode is not one of SubscriptionModeExclusive, SubscriptionModeShard, SubscriptionModeFailover.

Client is a Pulsar client, capable of sending and receiving messages and managing the associated state.

ClientConfig is used to configure a Pulsar client.

ClientPool provides a thread-safe store for ManagedClients, based on their address.

ConsumerConfig is used to configure a ManagedConsumer.

ManagedClient wraps a Client with re-connect and connection management logic.

ManagedConsumer wraps a Consumer with reconnect logic.

ManagedProducer wraps a Producer with re-connect logic.

ProducerConfig is used to configure a ManagedProducer.

SubscriptionMode represents Pulsar's three subscription models.