src

• gsf package
  • Submodules
  • gsf.binarystream module
    • BinaryStream
      • BinaryStream.IO_BUFFERSIZE
      • BinaryStream.VALUE_BUFFERSIZE
      • BinaryStream.flush()
      • BinaryStream.read()
      • BinaryStream.read7bit_int32()
      • BinaryStream.read7bit_int64()
      • BinaryStream.read7bit_uint32()
      • BinaryStream.read7bit_uint64()
      • BinaryStream.read_all()
      • BinaryStream.read_boolean()
      • BinaryStream.read_buffer()
      • BinaryStream.read_byte()
      • BinaryStream.read_bytes()
      • BinaryStream.read_guid()
      • BinaryStream.read_int16()
      • BinaryStream.read_int32()
      • BinaryStream.read_int64()
      • BinaryStream.read_string()
      • BinaryStream.read_uint16()
      • BinaryStream.read_uint32()
      • BinaryStream.read_uint64()
      • BinaryStream.write()
      • BinaryStream.write7bit_int32()
      • BinaryStream.write7bit_int64()
      • BinaryStream.write7bit_uint32()
      • BinaryStream.write7bit_uint64()
      • BinaryStream.write_boolean()
      • BinaryStream.write_buffer()
      • BinaryStream.write_byte()
      • BinaryStream.write_guid()
      • BinaryStream.write_int16()
      • BinaryStream.write_int32()
      • BinaryStream.write_int64()
      • BinaryStream.write_string()
      • BinaryStream.write_uint16()
      • BinaryStream.write_uint32()
      • BinaryStream.write_uint64()
  • gsf.encoding7bit module
    • Encoding7Bit
      • Encoding7Bit.read_int16()
      • Encoding7Bit.read_int32()
      • Encoding7Bit.read_int64()
      • Encoding7Bit.read_uint16()
      • Encoding7Bit.read_uint32()
      • Encoding7Bit.read_uint64()
      • Encoding7Bit.write_int16()
      • Encoding7Bit.write_int32()
      • Encoding7Bit.write_int64()
      • Encoding7Bit.write_uint16()
      • Encoding7Bit.write_uint32()
      • Encoding7Bit.write_uint64()
  • gsf.endianorder module
    • BigEndian
      • BigEndian.static_init()
      • BigEndian.swaporder
      • BigEndian.target_byteorder
    • LittleEndian
      • LittleEndian.static_init()
      • LittleEndian.swaporder
      • LittleEndian.target_byteorder
    • NativeEndian
      • NativeEndian.from_float16()
      • NativeEndian.from_float32()
      • NativeEndian.from_float64()
      • NativeEndian.from_int16()
      • NativeEndian.from_int32()
      • NativeEndian.from_int64()
      • NativeEndian.from_uint16()
      • NativeEndian.from_uint32()
      • NativeEndian.from_uint64()
      • NativeEndian.static_init()
      • NativeEndian.swaporder
      • NativeEndian.target_byteorder
      • NativeEndian.to_float16()
      • NativeEndian.to_float32()
      • NativeEndian.to_float64()
      • NativeEndian.to_int16()
      • NativeEndian.to_int32()
      • NativeEndian.to_int64()
      • NativeEndian.to_uint16()
      • NativeEndian.to_uint32()
      • NativeEndian.to_uint64()
  • gsf.streamencoder module
    • StreamEncoder
      • StreamEncoder.default_byteorder
      • StreamEncoder.read()
      • StreamEncoder.read7bit_uint32()
      • StreamEncoder.read7bit_uint64()
      • StreamEncoder.read_bool()
      • StreamEncoder.read_byte()
      • StreamEncoder.read_int16()
      • StreamEncoder.read_int32()
      • StreamEncoder.read_int64()
      • StreamEncoder.read_uint16()
      • StreamEncoder.read_uint32()
      • StreamEncoder.read_uint64()
      • StreamEncoder.write()
      • StreamEncoder.write7bit_uint32()
      • StreamEncoder.write7bit_uint64()
      • StreamEncoder.write_bool()
      • StreamEncoder.write_byte()
      • StreamEncoder.write_int16()
      • StreamEncoder.write_int32()
      • StreamEncoder.write_int64()
      • StreamEncoder.write_uint16()
      • StreamEncoder.write_uint32()
      • StreamEncoder.write_uint64()
  • Module contents
    • ByteSize
      • ByteSize.FLOAT16
      • ByteSize.FLOAT32
      • ByteSize.FLOAT64
      • ByteSize.INT16
      • ByteSize.INT32
      • ByteSize.INT64
      • ByteSize.INT8
      • ByteSize.UINT16
      • ByteSize.UINT32
      • ByteSize.UINT64
      • ByteSize.UINT8
    • Convert
      • Convert.from_str()
    • Empty
      • Empty.DATETIME
      • Empty.DECIMAL
      • Empty.DOUBLE
      • Empty.GUID
      • Empty.INT16
      • Empty.INT32
      • Empty.INT64
      • Empty.INT8
      • Empty.SINGLE
      • Empty.STRING
      • Empty.TICKS
      • Empty.UINT16
      • Empty.UINT32
      • Empty.UINT64
      • Empty.UINT8
    • Limits
      • Limits.MAXBYTE
      • Limits.MAXINT16
      • Limits.MAXINT32
      • Limits.MAXINT64
      • Limits.MAXTICKS
      • Limits.MAXUINT16
      • Limits.MAXUINT32
      • Limits.MAXUINT64
      • Limits.MININT16
      • Limits.MININT32
      • Limits.MININT64
    • Validate
      • Validate.parameters()
    • normalize_enumname()
    • override()
    • static_init()
    • virtual()
• sttp package
  • Subpackages
    • sttp.data package
      • Submodules
      • sttp.data.callbackerrorlistener module
      • sttp.data.columnexpression module
      • sttp.data.constants module
      • sttp.data.datacolumn module
      • sttp.data.datarow module
      • sttp.data.dataset module
      • sttp.data.datatable module
      • sttp.data.datatype module
      • sttp.data.errors module
      • sttp.data.expression module
      • sttp.data.expressiontree module
      • sttp.data.filterexpressionparser module
      • sttp.data.functionexpression module
      • sttp.data.inlistexpression module
      • sttp.data.operatorexpression module
      • sttp.data.orderbyterm module
      • sttp.data.tableidfields module
      • sttp.data.unaryexpression module
      • sttp.data.valueexpression module
      • Module contents
    • sttp.metadata package
      • Subpackages
      • Submodules
      • sttp.metadata.cache module
      • Module contents
    • sttp.transport package
      • Subpackages
      • Submodules
      • sttp.transport.bufferblock module
      • sttp.transport.compactmeasurement module
      • sttp.transport.constants module
      • sttp.transport.datapublisher module
      • sttp.transport.datasubscriber module
      • sttp.transport.measurement module
      • sttp.transport.routingtables module
      • sttp.transport.signalindexcache module
      • sttp.transport.signalkind module
      • sttp.transport.subscriberconnection module
      • sttp.transport.subscriberconnector module
      • sttp.transport.subscriptioninfo module
      • Module contents
  • Submodules
  • sttp.config module
    • Config
      • Config.DEFAULT_AUTORECONNECT
      • Config.DEFAULT_AUTOREQUESTMETADATA
      • Config.DEFAULT_AUTOSUBSCRIBE
      • Config.DEFAULT_COMPRESS_METADATA
      • Config.DEFAULT_COMPRESS_PAYLOADDATA
      • Config.DEFAULT_COMPRESS_SIGNALINDEXCACHE
      • Config.DEFAULT_MAXRETRIES
      • Config.DEFAULT_MAXRETRYINTERVAL
      • Config.DEFAULT_METADATAFILTERS
      • Config.DEFAULT_RETRYINTERVAL
      • Config.DEFAULT_SOCKET_TIMEOUT
      • Config.DEFAULT_VERSION
      • Config.autoreconnect
      • Config.autorequestmetadata
      • Config.autosubscribe
      • Config.compress_metadata
      • Config.compress_payloaddata
      • Config.compress_signalindexcache
      • Config.maxretries
      • Config.maxretryinterval
      • Config.metadatafilters
      • Config.retryinterval
      • Config.socket_timeout
      • Config.version
  • sttp.publisher module
    • Publisher
      • Publisher.clientconnected_receiver
      • Publisher.clientdisconnected_receiver
      • Publisher.default_clientconnected_receiver()
      • Publisher.default_clientdisconnected_receiver()
      • Publisher.default_errormessage_logger()
      • Publisher.default_statusmessage_logger()
      • Publisher.define_metadata()
      • Publisher.dispose()
      • Publisher.errormessage_logger
      • Publisher.filter_metadata()
      • Publisher.is_metadata_refresh_allowed
      • Publisher.is_nan_value_filter_allowed
      • Publisher.is_nan_value_filter_forced
      • Publisher.maximum_allowed_connections
      • Publisher.publish_measurements()
      • Publisher.start()
      • Publisher.started
      • Publisher.statusmessage_logger
      • Publisher.stop()
  • sttp.reader module
    • MeasurementReader
      • MeasurementReader.dispose()
      • MeasurementReader.next_measurement()
  • sttp.settings module
    • Settings
      • Settings.DEFAULT_CONSTRAINTPARAMETERS
      • Settings.DEFAULT_ENABLE_TIME_REASONABILITY_CHECK
      • Settings.DEFAULT_EXTRA_CONNECTIONSTRING_PARAMETERS
      • Settings.DEFAULT_INCLUDETIME
      • Settings.DEFAULT_LAGTIME
      • Settings.DEFAULT_LEADTIME
      • Settings.DEFAULT_PROCESSINGINTERVAL
      • Settings.DEFAULT_PUBLISHINTERVAL
      • Settings.DEFAULT_REQUEST_NANVALUEFILTER
      • Settings.DEFAULT_STARTTIME
      • Settings.DEFAULT_STOPTIME
      • Settings.DEFAULT_THROTTLED
      • Settings.DEFAULT_UDPINTERFACE
      • Settings.DEFAULT_UDPPORT
      • Settings.DEFAULT_USE_LOCALCLOCK_AS_REALTIME
      • Settings.DEFAULT_USE_MILLISECONDRESOLUTION
      • Settings.constraintparameters
      • Settings.enabletimereasonabilitycheck
      • Settings.extra_connectionstring_parameters
      • Settings.includetime
      • Settings.lagtime
      • Settings.leadtime
      • Settings.processinginterval
      • Settings.publishinterval
      • Settings.request_nanvaluefilter
      • Settings.starttime
      • Settings.stoptime
      • Settings.throttled
      • Settings.udpinterface
      • Settings.udpport
      • Settings.use_millisecondresolution
      • Settings.uselocalclockasrealtime
  • sttp.subscriber module
    • Subscriber
      • Subscriber.activesignalindexcache
      • Subscriber.adjustedvalue()
      • Subscriber.connect()
      • Subscriber.connected
      • Subscriber.default_connectionestablished_receiver()
      • Subscriber.default_connectionterminated_receiver()
      • Subscriber.default_errormessage_logger()
      • Subscriber.default_statusmessage_logger()
      • Subscriber.disconnect()
      • Subscriber.dispose()
      • Subscriber.errormessage()
      • Subscriber.measurement_metadata()
      • Subscriber.metadatacache
      • Subscriber.read_measurements()
      • Subscriber.request_metadata()
      • Subscriber.set_configurationchanged_receiver()
      • Subscriber.set_connectionestablished_receiver()
      • Subscriber.set_connectionterminated_receiver()
      • Subscriber.set_data_starttime_receiver()
      • Subscriber.set_errormessage_logger()
      • Subscriber.set_historicalreadcomplete_receiver()
      • Subscriber.set_metadatanotification_receiver()
      • Subscriber.set_newbufferblock_receiver()
      • Subscriber.set_newmeasurements_receiver()
      • Subscriber.set_notification_receiver()
      • Subscriber.set_statusmessage_logger()
      • Subscriber.set_subscriptionupdated_receiver()
      • Subscriber.statusmessage()
      • Subscriber.subscribe()
      • Subscriber.subscribed
      • Subscriber.subscriberid
      • Subscriber.total_commandchannel_bytesreceived
      • Subscriber.total_datachannel_bytesreceived
      • Subscriber.total_measurementsreceived
      • Subscriber.unsubscribe()
  • sttp.ticks module
    • Ticks
      • Ticks.LEAPSECOND_DIRECTION
      • Ticks.LEAPSECOND_FLAG
      • Ticks.PERDAY
      • Ticks.PERHOUR
      • Ticks.PERMICROSECOND
      • Ticks.PERMILLISECOND
      • Ticks.PERMINUTE
      • Ticks.PERSECOND
      • Ticks.UNIXBASEOFFSET
      • Ticks.VALUEMASK
      • Ticks.from_datetime()
      • Ticks.from_timedelta()
      • Ticks.is_leapsecond()
      • Ticks.is_negative_leapsecond()
      • Ticks.now()
      • Ticks.set_leapsecond()
      • Ticks.set_negative_leapsecond()
      • Ticks.timestampvalue()
      • Ticks.to_datetime()
      • Ticks.to_shortstring()
      • Ticks.to_string()
      • Ticks.utcnow()
  • sttp.version module
    • Version
      • Version.STTP_SOURCE
      • Version.STTP_UPDATEDON
      • Version.STTP_VERSION
  • Module contents
    • Publisher
      • Publisher.clientconnected_receiver
      • Publisher.clientdisconnected_receiver
      • Publisher.default_clientconnected_receiver()
      • Publisher.default_clientdisconnected_receiver()
      • Publisher.default_errormessage_logger()
      • Publisher.default_statusmessage_logger()
      • Publisher.define_metadata()
      • Publisher.dispose()
      • Publisher.errormessage_logger
      • Publisher.filter_metadata()
      • Publisher.is_metadata_refresh_allowed
      • Publisher.is_nan_value_filter_allowed
      • Publisher.is_nan_value_filter_forced
      • Publisher.maximum_allowed_connections
      • Publisher.publish_measurements()
      • Publisher.start()
      • Publisher.started
      • Publisher.statusmessage_logger
      • Publisher.stop()
    • Subscriber
      • Subscriber.activesignalindexcache
      • Subscriber.adjustedvalue()
      • Subscriber.connect()
      • Subscriber.connected
      • Subscriber.default_connectionestablished_receiver()
      • Subscriber.default_connectionterminated_receiver()
      • Subscriber.default_errormessage_logger()
      • Subscriber.default_statusmessage_logger()
      • Subscriber.disconnect()
      • Subscriber.dispose()
      • Subscriber.errormessage()
      • Subscriber.measurement_metadata()
      • Subscriber.metadatacache
      • Subscriber.read_measurements()
      • Subscriber.request_metadata()
      • Subscriber.set_configurationchanged_receiver()
      • Subscriber.set_connectionestablished_receiver()
      • Subscriber.set_connectionterminated_receiver()
      • Subscriber.set_data_starttime_receiver()
      • Subscriber.set_errormessage_logger()
      • Subscriber.set_historicalreadcomplete_receiver()
      • Subscriber.set_metadatanotification_receiver()
      • Subscriber.set_newbufferblock_receiver()
      • Subscriber.set_newmeasurements_receiver()
      • Subscriber.set_notification_receiver()
      • Subscriber.set_statusmessage_logger()
      • Subscriber.set_subscriptionupdated_receiver()
      • Subscriber.statusmessage()
      • Subscriber.subscribe()
      • Subscriber.subscribed
      • Subscriber.subscriberid
      • Subscriber.total_commandchannel_bytesreceived
      • Subscriber.total_datachannel_bytesreceived
      • Subscriber.total_measurementsreceived
      • Subscriber.unsubscribe()