pulsar.ServiceInfoProvider

class documentation

class ServiceInfoProvider: (source)

View In Hierarchy

Base class for Python-defined service discovery and failover providers.

Subclasses must return the initial ServiceInfo and may keep the provided update callback to push later service changes into the client.

Method close Stop background work and release resources.
Method initial_service_info Undocumented
Method initialize Undocumented
def close(self): (source)

Stop background work and release resources.

This is invoked when the underlying C++ client destroys the provider, typically during Client.close.

def initial_service_info(self) -> ServiceInfo: (source)

Undocumented

def initialize(self, on_service_info_update: Callable[[ServiceInfo], None]): (source)

Undocumented