resonate.message_sources.Poller

class documentation

class Poller:

Constructor: Poller(group, id, host, port, ...)

Undocumented

Method	`__init__`	Undocumented
Method	`enqueue`	Undocumented
Method	`loop`	Undocumented
Method	`next`	Undocumented
Method	`start`	Undocumented
Method	`stop`	Undocumented
Property	`anycast`	Undocumented
Property	`unicast`	Undocumented
Property	`url`	Undocumented
Method	`_process_line`	Undocumented
Instance Variable	`_encoder`	Undocumented
Instance Variable	`_group`	Undocumented
Instance Variable	`_host`	Undocumented
Instance Variable	`_id`	Undocumented
Instance Variable	`_messages`	Undocumented
Instance Variable	`_port`	Undocumented
Instance Variable	`_stopped`	Undocumented
Instance Variable	`_thread`	Undocumented
Instance Variable	`_timeout`	Undocumented

def __init__(self, group: str, id: str, host: str | None = None, port: str | None = None, timeout: float | None = None, encoder: Encoder[Any, str] | None = None): ¶

Undocumented

def enqueue(self, mesg: Mesg): ¶

Undocumented

@exit_on_exception

def loop(self): ¶

Undocumented

def next(self) -> Mesg | None: ¶

Undocumented

def start(self): ¶

Undocumented

def stop(self): ¶

Undocumented

@property

anycast: str = ¶

Undocumented

@property

unicast: str = ¶

Undocumented

@property

url: str = ¶

Undocumented

def _process_line(self, line: str) -> Mesg | None: ¶

Undocumented

_encoder = ¶

Undocumented

_group = ¶

Undocumented

_host = ¶

Undocumented

_id = ¶

Undocumented

_messages = ¶

Undocumented

_port = ¶

Undocumented

_stopped: bool = ¶

Undocumented

_thread = ¶

Undocumented

_timeout = ¶

Undocumented