resonate.message_sources.Poller

class documentation

class Poller:

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

View In Hierarchy

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 _auth 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, auth: tuple[str, 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

_auth =

Undocumented

_encoder =

Undocumented

_group =

Undocumented

_host =

Undocumented

_id =

Undocumented

_messages =

Undocumented

_port =

Undocumented

_stopped: bool =

Undocumented

_thread =

Undocumented

_timeout =

Undocumented