performConnect (self)

connect (self)

defaultOnPointChange (self, point)

runAllPointChangeMethods (self)

log (self, severity, message)

runPointChangeMethod (self, point)

runCallback (self, callback)

getCnxState (self)

getCnxStateString (self)

MarkAllPointsAsNotConnected (self)

read_messages (self)

message_writer (self)

startDomainListTimer (self)

cancelDomainListTimer (self)

DomainListEventHandler (self)

sendAlive (self)

timeoutCheck (self)

sendLogin (self)

sendWantSuccess (self)

appendPointValueMetaData (self, list sb, MetadataFlags valid_flags, Union[str, float, None] value, MetadataFlags flag)

Optional[Exception] writeMetadata (self, str point_name, Optional[PointMetaInfo] metadata)

Exception setDefaultDomain (self, str domain)

sendHeartbeatTimes (self)

startHeartbeatTimers (self)

activeHeartbeatTimers (self)

cancelHeartbeatTimers (self)

setHeartbeatTimes (self, heartbeat_ms, timeout_ms)

getPort (self)

getHostName (self)

getReconnectionDelay (self)

getHeartbeat (self)

getTimeout (self)

setConnState (self, newstate)

startReconnectionTimer (self)

RetryEventHandler (self)

setReconnectionDelay (self, recon_ms)

cancelReconnectionTimer (self)

setUsername (self, username, password)

setSsl (self, isSSL, acceptInvalidCertificates, clientCertificate)

setProxyParms (self, proxyHostname, proxyPort, proxyUsername, proxyPassword)

setWebparms (self, httpPort, isHttps)

setConnectionParms (self, hostname, port, username=None, password=None, parent_session_id=None)

getPointCache (self)

registerDomain (self, domainname, flags)

registerPoint (self, point_or_name, create=False)

unregisterPoint (self, point)

LookupOrCreatePoint (self, point)

lookupPoint (self, point)

createPoint (self, point)

sendCommand (self, message)

preciseTimer (self, loop, delay, interval, callback, *args, **kwargs)

Timer (self, loop, delay, interval, callback, *args, **kwargs)

writePoint (self, pointname, value, type=None, seconds=None, nanoseconds=None, quality=None, create=None, force=None)

performWritePoint (self, pointname, point_type, strval, seconds, nanoseconds, quality, create, force)

initializePointCache (self, model=None)

getDefaultDomain (self)

shutdown (self)

changeType (self, valueType, stringValue)

mathPointValue (self, operation, pointname, value, sec, nsec)

dividePointValue (self, point, value)

multiplyPointValue (self, point, value)

addPointValue (self, point, value)

appendPointValue (self, point, value)

setPointTimeStamp (point, datetime_obj)

sendConnectionCommands (self)

Connection_ConnectFailed (self, host, port)

Connection_ConnectSucceeded (self, host, port)

Connection_Connecting (self, host, port)

closeConnection (self)

onConnected = None

onDisconnected = None

onPointChange = lambda x : self.defaultOnPointChange(x)

onCommand = None

onEcho = None

onAsyncMessage = None

onAlive = None

onSuccess = None

onError = None

onLog = None

onConnectionSuccess = None

onConnectionFailure = None

onConnecting = None

onStatusChange = None

data = bytearray()

m_connstate = DataHubConnectionStatus.Idle

ConnectionStatus = self.m_connstate

m_aliveTimer = None

m_retrytimer = None

m_domainlisttimer = None

Options = ConnectionOptions()

loop = loop

writer = None

reader = None

name = None

m_datamodel = dict()

message_queue = asyncio.Queue()

m_timeoutTimer = None

bool dataWasRead = False