class_docstr: A client that streams log messages to :class:`LogStreamingServer`.
  In case of failures, the client will skip messages instead of raising an error.
class_docstr_tok: ["A","client","that","streams","log","messages","to",":","class",":","`","LogStreamingServer","`",".","In","case","of","failures",",","the","client","will","skip","messages","instead","of","raising","an","error","."]
docstr: Creates a connection to the logging server and authenticates.This client is best effort,
  if authentication or sending a message  fails, the client will be marked as not alive and
  stop trying to send message.
  
  :param address: Address where the service is running.
  :param port: Port where the service is listening for new connections.
docstr_tok: ["Creates","a","connection","to","the","logging","server","and","authenticates.This","client","is","best","effort",",","if","authentication","or","sending","a","message","fails",",","the","client","will","be","marked","as","not","alive","and","stop","trying","to","send","message",".",":","param","address",":","Address","where","the","service","is","running",".",":","param","port",":","Port","where","the","service","is","listening","for","new","connections","."]
code: def __init__(self, address: str, port: int, timeout: int = 10):
      """
      Creates a connection to the logging server and authenticates.This client is best effort,
      if authentication or sending a message  fails, the client will be marked as not alive and
      stop trying to send message.
  
      :param address: Address where the service is running.
      :param port: Port where the service is listening for new connections.
      """
      self.address = address
      self.port = port
      self.timeout = timeout
      self.sock = None
      self.failed = True
      self._lock = threading.RLock()
  
imports: from contextlib import closing
  import time
  import socket
  import socketserver
  from struct import pack, unpack
  import sys
  import threading
  import traceback
  from typing import Generator
  import warnings
label_desc: Use image node_id 3 to create a new LogStreamingClient object from inherited base classes: LogStreamingClientBase with example: obj = LogStreamingClient(address, port, timeout)