/ doc / toc / ARCCore / Enum / StreamProcessorP

StreamProcessorP

Edit keys at this level only

Edit keys at all sub levels.
NOTE: Edits are always additive. Use 'Invalid' in order to delete keys.

__TOCDet/Assembly = ARCCore
__TOCDet/Description = Describes class -StreamProcessor-.
__TOCDet/DocFragType = Enum
__TOCDet/Name = StreamProcessorP
__TOCDet/Namespace = ARCCore
__TOCDet/Type = StreamProcessorP
__TOCDet/Attribute/AREnumType = PropertyKeyEnum
__TOCDet/Attribute/AssemblyName = ARCCore
__TOCDet/Attribute/CorrespondingClass = StreamProcessor
__TOCDet/Attribute/Description = Describes class -StreamProcessor-.
__TOCDet/Attribute/EnumNamespace = ARCCore
__TOCDet/Attribute/EnumType = StreamProcessorP
CacheDiskWrites/__TOCDet/Assembly = ARCCore
CacheDiskWrites/__TOCDet/Description = If TRUE then will write the -PropertyStream- to disk in bigger chunks, thereby increasing performance.0x000D0x000A0x000D0x000AThis entails some risk of loosing data (especially with -CoreDB-) because of ungraceful shutdown to application.0x000D0x000A(-Client- / -ArmDB- is less vulnerable since -ClientUpdatePosition- is normally stored at the same time.).0x000D0x000AMake little sense to use for -CoreDB- unless storage-speed is too slow. More relevant for -Client- / -ArmDB- since these will more often read big amounts of historical data from -CoreDB-, especially the first time a new node is run.0x000D0x000A0x000D0x000ANOTE: Implementation will have to add some graceful application shutdown mechanism, so at least the write-to-disk thread does not suffer a NOTE: ThreadAbortException at normal shutdowns. This is not implemented as of April 20200x000D0x000Ar0x000ANOTE: Value can probably be changed from FALSE to TRUE while running, but not the other way around (could lead to wrong ordering of writing to disk at moment of change)
CacheDiskWrites/__TOCDet/DocFragType = EnumMember
CacheDiskWrites/__TOCDet/Name = CacheDiskWrites
CacheDiskWrites/__TOCDet/Namespace = ARCCore
CacheDiskWrites/__TOCDet/Type = StreamProcessorP
CacheDiskWrites/__TOCDet/Attribute/Description = If TRUE then will write the -PropertyStream- to disk in bigger chunks, thereby increasing performance.0x000D0x000A0x000D0x000AThis entails some risk of loosing data (especially with -CoreDB-) because of ungraceful shutdown to application.0x000D0x000A(-Client- / -ArmDB- is less vulnerable since -ClientUpdatePosition- is normally stored at the same time.).0x000D0x000AMake little sense to use for -CoreDB- unless storage-speed is too slow. More relevant for -Client- / -ArmDB- since these will more often read big amounts of historical data from -CoreDB-, especially the first time a new node is run.0x000D0x000A0x000D0x000ANOTE: Implementation will have to add some graceful application shutdown mechanism, so at least the write-to-disk thread does not suffer a NOTE: ThreadAbortException at normal shutdowns. This is not implemented as of April 20200x000D0x000Ar0x000ANOTE: Value can probably be changed from FALSE to TRUE while running, but not the other way around (could lead to wrong ordering of writing to disk at moment of change)
CacheDiskWrites/__TOCDet/Attribute/PKTypeAttribute/BoilerplateCodeProperties = // Autogenerated boilerplate code. Paste into your class as needed.0x000D0x000Apublic Boolean CacheDiskWrites0x007B0x000D0x000A  get =0x003E IP.GetPV0x003CBoolean0x003E(StreamProcessorP.CacheDiskWrites)0x003B0x000D0x000A  set =0x003E IP.SetPV(StreamProcessorP.CacheDiskWrites, value)0x003B0x000D0x000A0x007D0x000D0x000Apublic AddCacheDiskWrites(Boolean cacheDiskWrites) =0x003E IP.AddPV(StreamProcessorP.CacheDiskWrites, cacheDiskWrites)0x003B0x000D0x000Apublic Boolean? GetCacheDiskWrites() =0x003E TryGetCacheDiskWrites(out var retval) ? retval : null0x003B0x000D0x000Apublic Boolean GetCacheDiskWrites(Boolean defaultValue) =0x003E TryGetCacheDiskWrites(out var retval) ? retval : defaultValue0x003B0x000D0x000Apublic bool TryGetCacheDiskWrites(out Boolean cacheDiskWrites) =0x003E IP.TryGetPV(StreamProcessorP.CacheDiskWrites, out cacheDiskWrites)0x003B0x000D0x000A0x000D0x000A0x000D0x000A
CacheDiskWrites/__TOCDet/Attribute/PKTypeAttribute/Cardinality = HistoryOnly
CacheDiskWrites/__TOCDet/Attribute/PKTypeAttribute/Description = If TRUE then will write the -PropertyStream- to disk in bigger chunks, thereby increasing performance.0x000D0x000A0x000D0x000AThis entails some risk of loosing data (especially with -CoreDB-) because of ungraceful shutdown to application.0x000D0x000A(-Client- / -ArmDB- is less vulnerable since -ClientUpdatePosition- is normally stored at the same time.).0x000D0x000AMake little sense to use for -CoreDB- unless storage-speed is too slow. More relevant for -Client- / -ArmDB- since these will more often read big amounts of historical data from -CoreDB-, especially the first time a new node is run.0x000D0x000A0x000D0x000ANOTE: Implementation will have to add some graceful application shutdown mechanism, so at least the write-to-disk thread does not suffer a NOTE: ThreadAbortException at normal shutdowns. This is not implemented as of April 20200x000D0x000Ar0x000ANOTE: Value can probably be changed from FALSE to TRUE while running, but not the other way around (could lead to wrong ordering of writing to disk at moment of change)
CacheDiskWrites/__TOCDet/Attribute/PKTypeAttribute/EnumMember = CacheDiskWrites
CacheDiskWrites/__TOCDet/Attribute/PKTypeAttribute/EnumType = StreamProcessorP
CacheDiskWrites/__TOCDet/Attribute/PKTypeAttribute/IsObligatory = False
CacheDiskWrites/__TOCDet/Attribute/PKTypeAttribute/Type = Boolean
ClientUpdatePosition/__TOCDet/Assembly = ARCCore
ClientUpdatePosition/__TOCDet/Description = Note how this is stored both as -ClientUpdatePosition- (on the client side) and -ClientUpdatePosition- (on the server side).0x000D0x000A-StreamProcessor- (on the client side) also stores it locally 'on disk' and initializes from there.
ClientUpdatePosition/__TOCDet/DocFragType = EnumMember
ClientUpdatePosition/__TOCDet/Name = ClientUpdatePosition
ClientUpdatePosition/__TOCDet/Namespace = ARCCore
ClientUpdatePosition/__TOCDet/Type = StreamProcessorP
ClientUpdatePosition/__TOCDet/Attribute/Description = Note how this is stored both as -ClientUpdatePosition- (on the client side) and -ClientUpdatePosition- (on the server side).0x000D0x000A-StreamProcessor- (on the client side) also stores it locally 'on disk' and initializes from there.
ClientUpdatePosition/__TOCDet/Attribute/PKLogAttribute/DoNotLogAtAll = True
ClientUpdatePosition/__TOCDet/Attribute/PKLogAttribute/EnumMember = ClientUpdatePosition
ClientUpdatePosition/__TOCDet/Attribute/PKLogAttribute/EnumType = StreamProcessorP
ClientUpdatePosition/__TOCDet/Attribute/PKTypeAttribute/BoilerplateCodeProperties = // Autogenerated boilerplate code. Paste into your class as needed.0x000D0x000Apublic ClientUpdatePosition ClientUpdatePosition0x007B0x000D0x000A  get =0x003E IP.GetPV0x003CClientUpdatePosition0x003E(StreamProcessorP.ClientUpdatePosition)0x003B0x000D0x000A  set =0x003E IP.SetPV(StreamProcessorP.ClientUpdatePosition, value)0x003B0x000D0x000A0x007D0x000D0x000Apublic AddClientUpdatePosition(ClientUpdatePosition clientUpdatePosition) =0x003E IP.AddPV(StreamProcessorP.ClientUpdatePosition, clientUpdatePosition)0x003B0x000D0x000Apublic ClientUpdatePosition? GetClientUpdatePosition() =0x003E TryGetClientUpdatePosition(out var retval) ? retval : null0x003B0x000D0x000Apublic ClientUpdatePosition GetClientUpdatePosition(ClientUpdatePosition defaultValue) =0x003E TryGetClientUpdatePosition(out var retval) ? retval : defaultValue0x003B0x000D0x000Apublic bool TryGetClientUpdatePosition(out ClientUpdatePosition clientUpdatePosition) =0x003E IP.TryGetPV(StreamProcessorP.ClientUpdatePosition, out clientUpdatePosition)0x003B0x000D0x000A0x000D0x000A0x000D0x000A
ClientUpdatePosition/__TOCDet/Attribute/PKTypeAttribute/Cardinality = HistoryOnly
ClientUpdatePosition/__TOCDet/Attribute/PKTypeAttribute/Description = Note how this is stored both as -ClientUpdatePosition- (on the client side) and -ClientUpdatePosition- (on the server side).0x000D0x000A-StreamProcessor- (on the client side) also stores it locally 'on disk' and initializes from there.
ClientUpdatePosition/__TOCDet/Attribute/PKTypeAttribute/EnumMember = ClientUpdatePosition
ClientUpdatePosition/__TOCDet/Attribute/PKTypeAttribute/EnumType = StreamProcessorP
ClientUpdatePosition/__TOCDet/Attribute/PKTypeAttribute/IsObligatory = False
ClientUpdatePosition/__TOCDet/Attribute/PKTypeAttribute/Type = ClientUpdatePosition
ClientUpdatePositionPath/__TOCDet/Assembly = ARCCore
ClientUpdatePositionPath/__TOCDet/Description = Complete path to file containing -ClientUpdatePosition-.0x000D0x000AOnly relevant if outgoing connections (with -Receive-) are to be made.0x000D0x000ASet by -StartTCPIPCommunication-.
ClientUpdatePositionPath/__TOCDet/DocFragType = EnumMember
ClientUpdatePositionPath/__TOCDet/Name = ClientUpdatePositionPath
ClientUpdatePositionPath/__TOCDet/Namespace = ARCCore
ClientUpdatePositionPath/__TOCDet/Type = StreamProcessorP
ClientUpdatePositionPath/__TOCDet/Attribute/Description = Complete path to file containing -ClientUpdatePosition-.0x000D0x000AOnly relevant if outgoing connections (with -Receive-) are to be made.0x000D0x000ASet by -StartTCPIPCommunication-.
ClientUpdatePositionPath/__TOCDet/Attribute/PKTypeAttribute/BoilerplateCodeProperties = // Autogenerated boilerplate code. Paste into your class as needed.0x000D0x000Apublic String ClientUpdatePositionPath0x007B0x000D0x000A  get =0x003E IP.GetPV0x003CString0x003E(StreamProcessorP.ClientUpdatePositionPath)0x003B0x000D0x000A  set =0x003E IP.SetPV(StreamProcessorP.ClientUpdatePositionPath, value)0x003B0x000D0x000A0x007D0x000D0x000Apublic AddClientUpdatePositionPath(String clientUpdatePositionPath) =0x003E IP.AddPV(StreamProcessorP.ClientUpdatePositionPath, clientUpdatePositionPath)0x003B0x000D0x000Apublic String? GetClientUpdatePositionPath() =0x003E TryGetClientUpdatePositionPath(out var retval) ? retval : null0x003B0x000D0x000Apublic String GetClientUpdatePositionPath(String defaultValue) =0x003E TryGetClientUpdatePositionPath(out var retval) ? retval : defaultValue0x003B0x000D0x000Apublic bool TryGetClientUpdatePositionPath(out String clientUpdatePositionPath) =0x003E IP.TryGetPV(StreamProcessorP.ClientUpdatePositionPath, out clientUpdatePositionPath)0x003B0x000D0x000A0x000D0x000A0x000D0x000A
ClientUpdatePositionPath/__TOCDet/Attribute/PKTypeAttribute/Cardinality = HistoryOnly
ClientUpdatePositionPath/__TOCDet/Attribute/PKTypeAttribute/Description = Complete path to file containing -ClientUpdatePosition-.0x000D0x000AOnly relevant if outgoing connections (with -Receive-) are to be made.0x000D0x000ASet by -StartTCPIPCommunication-.
ClientUpdatePositionPath/__TOCDet/Attribute/PKTypeAttribute/EnumMember = ClientUpdatePositionPath
ClientUpdatePositionPath/__TOCDet/Attribute/PKTypeAttribute/EnumType = StreamProcessorP
ClientUpdatePositionPath/__TOCDet/Attribute/PKTypeAttribute/IsObligatory = False
ClientUpdatePositionPath/__TOCDet/Attribute/PKTypeAttribute/Type = String
CopyFileStructureFromCore/__TOCDet/Assembly = ARCCore
CopyFileStructureFromCore/__TOCDet/Description = If TRUE, will copy the exact file structure (through information given in -ClientUpdatePosition-). 0x000D0x000AThat is, instead of independently decide when to add new storage files, -StreamProcessor- will use the same filenames as received from its 'partner'.0x000D0x000A0x000D0x000AThis is useful in situations where you want to use -Simultaneous.0x000D0x000A0x000D0x000ANote how this only gives meaning for -IsAll- starting from -ClientDatastoreIsEmpty-.0x000D0x000A0x000D0x000ATODO: Rename into something better, like 'CopyFileStructureFromPartner' or similar.0x000D0x000A0x000D0x000ANOTE: Support for TRUE not implemented as of Apr 2020
CopyFileStructureFromCore/__TOCDet/DocFragType = EnumMember
CopyFileStructureFromCore/__TOCDet/LongDescription = By using -Hash-, exact copies of files can be maintained between servers
CopyFileStructureFromCore/__TOCDet/Name = CopyFileStructureFromCore
CopyFileStructureFromCore/__TOCDet/Namespace = ARCCore
CopyFileStructureFromCore/__TOCDet/Type = StreamProcessorP
CopyFileStructureFromCore/__TOCDet/Attribute/Description = If TRUE, will copy the exact file structure (through information given in -ClientUpdatePosition-). 0x000D0x000AThat is, instead of independently decide when to add new storage files, -StreamProcessor- will use the same filenames as received from its 'partner'.0x000D0x000A0x000D0x000AThis is useful in situations where you want to use -Simultaneous.0x000D0x000A0x000D0x000ANote how this only gives meaning for -IsAll- starting from -ClientDatastoreIsEmpty-.0x000D0x000A0x000D0x000ATODO: Rename into something better, like 'CopyFileStructureFromPartner' or similar.0x000D0x000A0x000D0x000ANOTE: Support for TRUE not implemented as of Apr 2020
CopyFileStructureFromCore/__TOCDet/Attribute/LongDescription = By using -Hash-, exact copies of files can be maintained between servers
CopyFileStructureFromCore/__TOCDet/Attribute/PKTypeAttribute/BoilerplateCodeProperties = // Autogenerated boilerplate code. Paste into your class as needed.0x000D0x000Apublic String CopyFileStructureFromCore0x007B0x000D0x000A  get =0x003E IP.GetPV0x003CString0x003E(StreamProcessorP.CopyFileStructureFromCore)0x003B0x000D0x000A  set =0x003E IP.SetPV(StreamProcessorP.CopyFileStructureFromCore, value)0x003B0x000D0x000A0x007D0x000D0x000Apublic AddCopyFileStructureFromCore(String copyFileStructureFromCore) =0x003E IP.AddPV(StreamProcessorP.CopyFileStructureFromCore, copyFileStructureFromCore)0x003B0x000D0x000Apublic String? GetCopyFileStructureFromCore() =0x003E TryGetCopyFileStructureFromCore(out var retval) ? retval : null0x003B0x000D0x000Apublic String GetCopyFileStructureFromCore(String defaultValue) =0x003E TryGetCopyFileStructureFromCore(out var retval) ? retval : defaultValue0x003B0x000D0x000Apublic bool TryGetCopyFileStructureFromCore(out String copyFileStructureFromCore) =0x003E IP.TryGetPV(StreamProcessorP.CopyFileStructureFromCore, out copyFileStructureFromCore)0x003B0x000D0x000A0x000D0x000A0x000D0x000A
CopyFileStructureFromCore/__TOCDet/Attribute/PKTypeAttribute/Cardinality = HistoryOnly
CopyFileStructureFromCore/__TOCDet/Attribute/PKTypeAttribute/Description = If TRUE, will copy the exact file structure (through information given in -ClientUpdatePosition-). 0x000D0x000AThat is, instead of independently decide when to add new storage files, -StreamProcessor- will use the same filenames as received from its 'partner'.0x000D0x000A0x000D0x000AThis is useful in situations where you want to use -Simultaneous.0x000D0x000A0x000D0x000ANote how this only gives meaning for -IsAll- starting from -ClientDatastoreIsEmpty-.0x000D0x000A0x000D0x000ATODO: Rename into something better, like 'CopyFileStructureFromPartner' or similar.0x000D0x000A0x000D0x000ANOTE: Support for TRUE not implemented as of Apr 2020
CopyFileStructureFromCore/__TOCDet/Attribute/PKTypeAttribute/EnumMember = CopyFileStructureFromCore
CopyFileStructureFromCore/__TOCDet/Attribute/PKTypeAttribute/EnumType = StreamProcessorP
CopyFileStructureFromCore/__TOCDet/Attribute/PKTypeAttribute/IsObligatory = False
CopyFileStructureFromCore/__TOCDet/Attribute/PKTypeAttribute/LongDescription = By using -Hash-, exact copies of files can be maintained between servers
CopyFileStructureFromCore/__TOCDet/Attribute/PKTypeAttribute/Type = String
CountIncomingConnections/__TOCDet/Assembly = ARCCore
CountIncomingConnections/__TOCDet/DocFragType = EnumMember
CountIncomingConnections/__TOCDet/Name = CountIncomingConnections
CountIncomingConnections/__TOCDet/Namespace = ARCCore
CountIncomingConnections/__TOCDet/Type = StreamProcessorP
CountIncomingConnections/__TOCDet/Attribute/PKTypeAttribute/BoilerplateCodeProperties = // Autogenerated boilerplate code. Paste into your class as needed.0x000D0x000Apublic Int32 CountIncomingConnections0x007B0x000D0x000A  get =0x003E IP.GetPV0x003CInt320x003E(StreamProcessorP.CountIncomingConnections)0x003B0x000D0x000A  set =0x003E IP.SetPV(StreamProcessorP.CountIncomingConnections, value)0x003B0x000D0x000A0x007D0x000D0x000Apublic AddCountIncomingConnections(Int32 countIncomingConnections) =0x003E IP.AddPV(StreamProcessorP.CountIncomingConnections, countIncomingConnections)0x003B0x000D0x000Apublic Int32? GetCountIncomingConnections() =0x003E TryGetCountIncomingConnections(out var retval) ? retval : null0x003B0x000D0x000Apublic Int32 GetCountIncomingConnections(Int32 defaultValue) =0x003E TryGetCountIncomingConnections(out var retval) ? retval : defaultValue0x003B0x000D0x000Apublic bool TryGetCountIncomingConnections(out Int32 countIncomingConnections) =0x003E IP.TryGetPV(StreamProcessorP.CountIncomingConnections, out countIncomingConnections)0x003B0x000D0x000A0x000D0x000A0x000D0x000A
CountIncomingConnections/__TOCDet/Attribute/PKTypeAttribute/Cardinality = HistoryOnly
CountIncomingConnections/__TOCDet/Attribute/PKTypeAttribute/EnumMember = CountIncomingConnections
CountIncomingConnections/__TOCDet/Attribute/PKTypeAttribute/EnumType = StreamProcessorP
CountIncomingConnections/__TOCDet/Attribute/PKTypeAttribute/IsObligatory = False
CountIncomingConnections/__TOCDet/Attribute/PKTypeAttribute/Type = Int32
CountOutgoingConnections/__TOCDet/Assembly = ARCCore
CountOutgoingConnections/__TOCDet/DocFragType = EnumMember
CountOutgoingConnections/__TOCDet/Name = CountOutgoingConnections
CountOutgoingConnections/__TOCDet/Namespace = ARCCore
CountOutgoingConnections/__TOCDet/Type = StreamProcessorP
CountOutgoingConnections/__TOCDet/Attribute/PKTypeAttribute/BoilerplateCodeProperties = // Autogenerated boilerplate code. Paste into your class as needed.0x000D0x000Apublic Int32 CountOutgoingConnections0x007B0x000D0x000A  get =0x003E IP.GetPV0x003CInt320x003E(StreamProcessorP.CountOutgoingConnections)0x003B0x000D0x000A  set =0x003E IP.SetPV(StreamProcessorP.CountOutgoingConnections, value)0x003B0x000D0x000A0x007D0x000D0x000Apublic AddCountOutgoingConnections(Int32 countOutgoingConnections) =0x003E IP.AddPV(StreamProcessorP.CountOutgoingConnections, countOutgoingConnections)0x003B0x000D0x000Apublic Int32? GetCountOutgoingConnections() =0x003E TryGetCountOutgoingConnections(out var retval) ? retval : null0x003B0x000D0x000Apublic Int32 GetCountOutgoingConnections(Int32 defaultValue) =0x003E TryGetCountOutgoingConnections(out var retval) ? retval : defaultValue0x003B0x000D0x000Apublic bool TryGetCountOutgoingConnections(out Int32 countOutgoingConnections) =0x003E IP.TryGetPV(StreamProcessorP.CountOutgoingConnections, out countOutgoingConnections)0x003B0x000D0x000A0x000D0x000A0x000D0x000A
CountOutgoingConnections/__TOCDet/Attribute/PKTypeAttribute/Cardinality = HistoryOnly
CountOutgoingConnections/__TOCDet/Attribute/PKTypeAttribute/EnumMember = CountOutgoingConnections
CountOutgoingConnections/__TOCDet/Attribute/PKTypeAttribute/EnumType = StreamProcessorP
CountOutgoingConnections/__TOCDet/Attribute/PKTypeAttribute/IsObligatory = False
CountOutgoingConnections/__TOCDet/Attribute/PKTypeAttribute/Type = Int32
CountOutsideLocalReceiver/__TOCDet/Assembly = ARCCore
CountOutsideLocalReceiver/__TOCDet/Description = Count of calls to -OutsideLocalReceiver-.0x000D0x000AUseful for debugging, especially for API's (ensuring that subscription is active).0x000D0x000ACount of -PropertyStreamLine- sent to -OutsideLocalReceiver- (after initialization) (because they were received from an 'outside' source, that is, from a -Subscription- to -PropertyStream-).0x000D0x000A
CountOutsideLocalReceiver/__TOCDet/DocFragType = EnumMember
CountOutsideLocalReceiver/__TOCDet/Name = CountOutsideLocalReceiver
CountOutsideLocalReceiver/__TOCDet/Namespace = ARCCore
CountOutsideLocalReceiver/__TOCDet/Type = StreamProcessorP
CountOutsideLocalReceiver/__TOCDet/Attribute/Description = Count of calls to -OutsideLocalReceiver-.0x000D0x000AUseful for debugging, especially for API's (ensuring that subscription is active).0x000D0x000ACount of -PropertyStreamLine- sent to -OutsideLocalReceiver- (after initialization) (because they were received from an 'outside' source, that is, from a -Subscription- to -PropertyStream-).0x000D0x000A
CountOutsideLocalReceiver/__TOCDet/Attribute/PKLogAttribute/DoNotLogAtAll = True
CountOutsideLocalReceiver/__TOCDet/Attribute/PKLogAttribute/EnumMember = CountOutsideLocalReceiver
CountOutsideLocalReceiver/__TOCDet/Attribute/PKLogAttribute/EnumType = StreamProcessorP
CountOutsideLocalReceiver/__TOCDet/Attribute/PKTypeAttribute/BoilerplateCodeProperties = // Autogenerated boilerplate code. Paste into your class as needed.0x000D0x000Apublic Int64 CountOutsideLocalReceiver0x007B0x000D0x000A  get =0x003E IP.GetPV0x003CInt640x003E(StreamProcessorP.CountOutsideLocalReceiver)0x003B0x000D0x000A  set =0x003E IP.SetPV(StreamProcessorP.CountOutsideLocalReceiver, value)0x003B0x000D0x000A0x007D0x000D0x000Apublic AddCountOutsideLocalReceiver(Int64 countOutsideLocalReceiver) =0x003E IP.AddPV(StreamProcessorP.CountOutsideLocalReceiver, countOutsideLocalReceiver)0x003B0x000D0x000Apublic Int64? GetCountOutsideLocalReceiver() =0x003E TryGetCountOutsideLocalReceiver(out var retval) ? retval : null0x003B0x000D0x000Apublic Int64 GetCountOutsideLocalReceiver(Int64 defaultValue) =0x003E TryGetCountOutsideLocalReceiver(out var retval) ? retval : defaultValue0x003B0x000D0x000Apublic bool TryGetCountOutsideLocalReceiver(out Int64 countOutsideLocalReceiver) =0x003E IP.TryGetPV(StreamProcessorP.CountOutsideLocalReceiver, out countOutsideLocalReceiver)0x003B0x000D0x000A0x000D0x000A0x000D0x000A
CountOutsideLocalReceiver/__TOCDet/Attribute/PKTypeAttribute/Cardinality = HistoryOnly
CountOutsideLocalReceiver/__TOCDet/Attribute/PKTypeAttribute/Description = Count of calls to -OutsideLocalReceiver-.0x000D0x000AUseful for debugging, especially for API's (ensuring that subscription is active).0x000D0x000ACount of -PropertyStreamLine- sent to -OutsideLocalReceiver- (after initialization) (because they were received from an 'outside' source, that is, from a -Subscription- to -PropertyStream-).0x000D0x000A
CountOutsideLocalReceiver/__TOCDet/Attribute/PKTypeAttribute/EnumMember = CountOutsideLocalReceiver
CountOutsideLocalReceiver/__TOCDet/Attribute/PKTypeAttribute/EnumType = StreamProcessorP
CountOutsideLocalReceiver/__TOCDet/Attribute/PKTypeAttribute/IsObligatory = False
CountOutsideLocalReceiver/__TOCDet/Attribute/PKTypeAttribute/Type = Int64
CountReceiveLocalOrigin/__TOCDet/Assembly = ARCCore
CountReceiveLocalOrigin/__TOCDet/Description = Count of -PropertyStreamLine- with -HasLocalOrigin-.
CountReceiveLocalOrigin/__TOCDet/DocFragType = EnumMember
CountReceiveLocalOrigin/__TOCDet/Name = CountReceiveLocalOrigin
CountReceiveLocalOrigin/__TOCDet/Namespace = ARCCore
CountReceiveLocalOrigin/__TOCDet/Type = StreamProcessorP
CountReceiveLocalOrigin/__TOCDet/Attribute/Description = Count of -PropertyStreamLine- with -HasLocalOrigin-.
CountReceiveLocalOrigin/__TOCDet/Attribute/PKLogAttribute/DoNotLogAtAll = True
CountReceiveLocalOrigin/__TOCDet/Attribute/PKLogAttribute/EnumMember = CountReceiveLocalOrigin
CountReceiveLocalOrigin/__TOCDet/Attribute/PKLogAttribute/EnumType = StreamProcessorP
CountReceiveLocalOrigin/__TOCDet/Attribute/PKTypeAttribute/BoilerplateCodeProperties = // Autogenerated boilerplate code. Paste into your class as needed.0x000D0x000Apublic Int64 CountReceiveLocalOrigin0x007B0x000D0x000A  get =0x003E IP.GetPV0x003CInt640x003E(StreamProcessorP.CountReceiveLocalOrigin)0x003B0x000D0x000A  set =0x003E IP.SetPV(StreamProcessorP.CountReceiveLocalOrigin, value)0x003B0x000D0x000A0x007D0x000D0x000Apublic AddCountReceiveLocalOrigin(Int64 countReceiveLocalOrigin) =0x003E IP.AddPV(StreamProcessorP.CountReceiveLocalOrigin, countReceiveLocalOrigin)0x003B0x000D0x000Apublic Int64? GetCountReceiveLocalOrigin() =0x003E TryGetCountReceiveLocalOrigin(out var retval) ? retval : null0x003B0x000D0x000Apublic Int64 GetCountReceiveLocalOrigin(Int64 defaultValue) =0x003E TryGetCountReceiveLocalOrigin(out var retval) ? retval : defaultValue0x003B0x000D0x000Apublic bool TryGetCountReceiveLocalOrigin(out Int64 countReceiveLocalOrigin) =0x003E IP.TryGetPV(StreamProcessorP.CountReceiveLocalOrigin, out countReceiveLocalOrigin)0x003B0x000D0x000A0x000D0x000A0x000D0x000A
CountReceiveLocalOrigin/__TOCDet/Attribute/PKTypeAttribute/Cardinality = HistoryOnly
CountReceiveLocalOrigin/__TOCDet/Attribute/PKTypeAttribute/Description = Count of -PropertyStreamLine- with -HasLocalOrigin-.
CountReceiveLocalOrigin/__TOCDet/Attribute/PKTypeAttribute/EnumMember = CountReceiveLocalOrigin
CountReceiveLocalOrigin/__TOCDet/Attribute/PKTypeAttribute/EnumType = StreamProcessorP
CountReceiveLocalOrigin/__TOCDet/Attribute/PKTypeAttribute/IsObligatory = False
CountReceiveLocalOrigin/__TOCDet/Attribute/PKTypeAttribute/Type = Int64
CountReceiveNonLocalOrigin/__TOCDet/Assembly = ARCCore
CountReceiveNonLocalOrigin/__TOCDet/Description = Count of -PropertyStreamLine- not with -HasLocalOrigin-.
CountReceiveNonLocalOrigin/__TOCDet/DocFragType = EnumMember
CountReceiveNonLocalOrigin/__TOCDet/Name = CountReceiveNonLocalOrigin
CountReceiveNonLocalOrigin/__TOCDet/Namespace = ARCCore
CountReceiveNonLocalOrigin/__TOCDet/Type = StreamProcessorP
CountReceiveNonLocalOrigin/__TOCDet/Attribute/Description = Count of -PropertyStreamLine- not with -HasLocalOrigin-.
CountReceiveNonLocalOrigin/__TOCDet/Attribute/PKLogAttribute/DoNotLogAtAll = True
CountReceiveNonLocalOrigin/__TOCDet/Attribute/PKLogAttribute/EnumMember = CountReceiveNonLocalOrigin
CountReceiveNonLocalOrigin/__TOCDet/Attribute/PKLogAttribute/EnumType = StreamProcessorP
CountReceiveNonLocalOrigin/__TOCDet/Attribute/PKTypeAttribute/BoilerplateCodeProperties = // Autogenerated boilerplate code. Paste into your class as needed.0x000D0x000Apublic Int64 CountReceiveNonLocalOrigin0x007B0x000D0x000A  get =0x003E IP.GetPV0x003CInt640x003E(StreamProcessorP.CountReceiveNonLocalOrigin)0x003B0x000D0x000A  set =0x003E IP.SetPV(StreamProcessorP.CountReceiveNonLocalOrigin, value)0x003B0x000D0x000A0x007D0x000D0x000Apublic AddCountReceiveNonLocalOrigin(Int64 countReceiveNonLocalOrigin) =0x003E IP.AddPV(StreamProcessorP.CountReceiveNonLocalOrigin, countReceiveNonLocalOrigin)0x003B0x000D0x000Apublic Int64? GetCountReceiveNonLocalOrigin() =0x003E TryGetCountReceiveNonLocalOrigin(out var retval) ? retval : null0x003B0x000D0x000Apublic Int64 GetCountReceiveNonLocalOrigin(Int64 defaultValue) =0x003E TryGetCountReceiveNonLocalOrigin(out var retval) ? retval : defaultValue0x003B0x000D0x000Apublic bool TryGetCountReceiveNonLocalOrigin(out Int64 countReceiveNonLocalOrigin) =0x003E IP.TryGetPV(StreamProcessorP.CountReceiveNonLocalOrigin, out countReceiveNonLocalOrigin)0x003B0x000D0x000A0x000D0x000A0x000D0x000A
CountReceiveNonLocalOrigin/__TOCDet/Attribute/PKTypeAttribute/Cardinality = HistoryOnly
CountReceiveNonLocalOrigin/__TOCDet/Attribute/PKTypeAttribute/Description = Count of -PropertyStreamLine- not with -HasLocalOrigin-.
CountReceiveNonLocalOrigin/__TOCDet/Attribute/PKTypeAttribute/EnumMember = CountReceiveNonLocalOrigin
CountReceiveNonLocalOrigin/__TOCDet/Attribute/PKTypeAttribute/EnumType = StreamProcessorP
CountReceiveNonLocalOrigin/__TOCDet/Attribute/PKTypeAttribute/IsObligatory = False
CountReceiveNonLocalOrigin/__TOCDet/Attribute/PKTypeAttribute/Type = Int64
CurrentlyInitializing/__TOCDet/Assembly = ARCCore
CurrentlyInitializing/__TOCDet/Description = Set to TRUE at initialization (signals for instance -ReceiveAndDistribute- that it can only queue messages, not process them).0x000D0x000A0x000D0x000AWith a local data storage (that is, when -DoNotStoreLocally- is false (default)), initialization can take quite some time.0x000D0x000A0x000D0x000ASee also -TimestampIsOld-
CurrentlyInitializing/__TOCDet/DocFragType = EnumMember
CurrentlyInitializing/__TOCDet/Name = CurrentlyInitializing
CurrentlyInitializing/__TOCDet/Namespace = ARCCore
CurrentlyInitializing/__TOCDet/Type = StreamProcessorP
CurrentlyInitializing/__TOCDet/Attribute/Description = Set to TRUE at initialization (signals for instance -ReceiveAndDistribute- that it can only queue messages, not process them).0x000D0x000A0x000D0x000AWith a local data storage (that is, when -DoNotStoreLocally- is false (default)), initialization can take quite some time.0x000D0x000A0x000D0x000ASee also -TimestampIsOld-
CurrentlyInitializing/__TOCDet/Attribute/PKTypeAttribute/BoilerplateCodeProperties = // Autogenerated boilerplate code. Paste into your class as needed.0x000D0x000Apublic Boolean CurrentlyInitializing0x007B0x000D0x000A  get =0x003E IP.GetPV0x003CBoolean0x003E(StreamProcessorP.CurrentlyInitializing)0x003B0x000D0x000A  set =0x003E IP.SetPV(StreamProcessorP.CurrentlyInitializing, value)0x003B0x000D0x000A0x007D0x000D0x000Apublic AddCurrentlyInitializing(Boolean currentlyInitializing) =0x003E IP.AddPV(StreamProcessorP.CurrentlyInitializing, currentlyInitializing)0x003B0x000D0x000Apublic Boolean? GetCurrentlyInitializing() =0x003E TryGetCurrentlyInitializing(out var retval) ? retval : null0x003B0x000D0x000Apublic Boolean GetCurrentlyInitializing(Boolean defaultValue) =0x003E TryGetCurrentlyInitializing(out var retval) ? retval : defaultValue0x003B0x000D0x000Apublic bool TryGetCurrentlyInitializing(out Boolean currentlyInitializing) =0x003E IP.TryGetPV(StreamProcessorP.CurrentlyInitializing, out currentlyInitializing)0x003B0x000D0x000A0x000D0x000A0x000D0x000A
CurrentlyInitializing/__TOCDet/Attribute/PKTypeAttribute/Cardinality = HistoryOnly
CurrentlyInitializing/__TOCDet/Attribute/PKTypeAttribute/Description = Set to TRUE at initialization (signals for instance -ReceiveAndDistribute- that it can only queue messages, not process them).0x000D0x000A0x000D0x000AWith a local data storage (that is, when -DoNotStoreLocally- is false (default)), initialization can take quite some time.0x000D0x000A0x000D0x000ASee also -TimestampIsOld-
CurrentlyInitializing/__TOCDet/Attribute/PKTypeAttribute/EnumMember = CurrentlyInitializing
CurrentlyInitializing/__TOCDet/Attribute/PKTypeAttribute/EnumType = StreamProcessorP
CurrentlyInitializing/__TOCDet/Attribute/PKTypeAttribute/IsObligatory = False
CurrentlyInitializing/__TOCDet/Attribute/PKTypeAttribute/Type = Boolean
DoNotStoreLocally/__TOCDet/Assembly = ARCCore
DoNotStoreLocally/__TOCDet/Description = For -Client-, incoming data (as received from a -Outgoing-) is possible to store BOTH to disk, AND to (normally) a -PRich-.0x000D0x000A0x000D0x000AAt application startup the data stored to disk can then be read locally directly into the -PRich-, meaning that the application only has to ask for updated information, not the whole picture.0x000D0x000A0x000D0x000ASet to TRUE if this is not desired. That is, when no local storage is desired (for instance if you only want an ephemeral live-stream log window for instance). Be careful so your subscription correspondingly only asks for relatively new data, not historical data (typical by setting -ClientUpdatePosition- to -OnlyNewDataIsRequestedInstance-). (If not, you will receive the whole database every you connect to the -CoreDB-.)
DoNotStoreLocally/__TOCDet/DocFragType = EnumMember
DoNotStoreLocally/__TOCDet/LongDescription = Note that for -CoreDB- incoming data (as received from a -Incoming-) is supposed to always be stored locally, meaning this property is not relevant.0x000D0x000A0x000D0x000ANote that for -ArmDB- incoming data (as received from a -Outgoing-, that is, from a -CoreDB-) is supposed to always be stored locally, meaning this property is not relevant.0x000D0x000A0x000D0x000ANote that for -ArmDB- incoming data (as received from a -Incoming-, that is, from a -Client-) is supposed to always be cached locally until sent to -CoreDB-, meaning this property is not relevant.0x000D0x000A
DoNotStoreLocally/__TOCDet/Name = DoNotStoreLocally
DoNotStoreLocally/__TOCDet/Namespace = ARCCore
DoNotStoreLocally/__TOCDet/Type = StreamProcessorP
DoNotStoreLocally/__TOCDet/Attribute/Description = For -Client-, incoming data (as received from a -Outgoing-) is possible to store BOTH to disk, AND to (normally) a -PRich-.0x000D0x000A0x000D0x000AAt application startup the data stored to disk can then be read locally directly into the -PRich-, meaning that the application only has to ask for updated information, not the whole picture.0x000D0x000A0x000D0x000ASet to TRUE if this is not desired. That is, when no local storage is desired (for instance if you only want an ephemeral live-stream log window for instance). Be careful so your subscription correspondingly only asks for relatively new data, not historical data (typical by setting -ClientUpdatePosition- to -OnlyNewDataIsRequestedInstance-). (If not, you will receive the whole database every you connect to the -CoreDB-.)
DoNotStoreLocally/__TOCDet/Attribute/LongDescription = Note that for -CoreDB- incoming data (as received from a -Incoming-) is supposed to always be stored locally, meaning this property is not relevant.0x000D0x000A0x000D0x000ANote that for -ArmDB- incoming data (as received from a -Outgoing-, that is, from a -CoreDB-) is supposed to always be stored locally, meaning this property is not relevant.0x000D0x000A0x000D0x000ANote that for -ArmDB- incoming data (as received from a -Incoming-, that is, from a -Client-) is supposed to always be cached locally until sent to -CoreDB-, meaning this property is not relevant.0x000D0x000A
DoNotStoreLocally/__TOCDet/Attribute/PKTypeAttribute/BoilerplateCodeProperties = // Autogenerated boilerplate code. Paste into your class as needed.0x000D0x000Apublic Boolean DoNotStoreLocally0x007B0x000D0x000A  get =0x003E IP.GetPV0x003CBoolean0x003E(StreamProcessorP.DoNotStoreLocally)0x003B0x000D0x000A  set =0x003E IP.SetPV(StreamProcessorP.DoNotStoreLocally, value)0x003B0x000D0x000A0x007D0x000D0x000Apublic AddDoNotStoreLocally(Boolean doNotStoreLocally) =0x003E IP.AddPV(StreamProcessorP.DoNotStoreLocally, doNotStoreLocally)0x003B0x000D0x000Apublic Boolean? GetDoNotStoreLocally() =0x003E TryGetDoNotStoreLocally(out var retval) ? retval : null0x003B0x000D0x000Apublic Boolean GetDoNotStoreLocally(Boolean defaultValue) =0x003E TryGetDoNotStoreLocally(out var retval) ? retval : defaultValue0x003B0x000D0x000Apublic bool TryGetDoNotStoreLocally(out Boolean doNotStoreLocally) =0x003E IP.TryGetPV(StreamProcessorP.DoNotStoreLocally, out doNotStoreLocally)0x003B0x000D0x000A0x000D0x000A0x000D0x000A
DoNotStoreLocally/__TOCDet/Attribute/PKTypeAttribute/Cardinality = HistoryOnly
DoNotStoreLocally/__TOCDet/Attribute/PKTypeAttribute/Description = For -Client-, incoming data (as received from a -Outgoing-) is possible to store BOTH to disk, AND to (normally) a -PRich-.0x000D0x000A0x000D0x000AAt application startup the data stored to disk can then be read locally directly into the -PRich-, meaning that the application only has to ask for updated information, not the whole picture.0x000D0x000A0x000D0x000ASet to TRUE if this is not desired. That is, when no local storage is desired (for instance if you only want an ephemeral live-stream log window for instance). Be careful so your subscription correspondingly only asks for relatively new data, not historical data (typical by setting -ClientUpdatePosition- to -OnlyNewDataIsRequestedInstance-). (If not, you will receive the whole database every you connect to the -CoreDB-.)
DoNotStoreLocally/__TOCDet/Attribute/PKTypeAttribute/EnumMember = DoNotStoreLocally
DoNotStoreLocally/__TOCDet/Attribute/PKTypeAttribute/EnumType = StreamProcessorP
DoNotStoreLocally/__TOCDet/Attribute/PKTypeAttribute/IsObligatory = False
DoNotStoreLocally/__TOCDet/Attribute/PKTypeAttribute/LongDescription = Note that for -CoreDB- incoming data (as received from a -Incoming-) is supposed to always be stored locally, meaning this property is not relevant.0x000D0x000A0x000D0x000ANote that for -ArmDB- incoming data (as received from a -Outgoing-, that is, from a -CoreDB-) is supposed to always be stored locally, meaning this property is not relevant.0x000D0x000A0x000D0x000ANote that for -ArmDB- incoming data (as received from a -Incoming-, that is, from a -Client-) is supposed to always be cached locally until sent to -CoreDB-, meaning this property is not relevant.0x000D0x000A
DoNotStoreLocally/__TOCDet/Attribute/PKTypeAttribute/Type = Boolean
DoNotStoreLocalOriginLocally/__TOCDet/Assembly = ARCCore
DoNotStoreLocalOriginLocally/__TOCDet/Description = Means 'do not store local origin locally but wait until it gets confirmed by core storage'.0x000D0x000A0x000D0x000ASet to TRUE if you do not want locally orginated data to be stored directly locally0x000D0x000A0x000D0x000AThis is normally relevant to do when you have outgoing connections, one for sending to -CoreDB- and one subscribing to the same content again.0x000D0x000ASetting this value to TRUE will then ensure that locally originated data do not get stored twice (and also ensure that data is not stored permanently on the client side (-Client-) before it has been confirmed stored by -CoreDB-.)
DoNotStoreLocalOriginLocally/__TOCDet/DocFragType = EnumMember
DoNotStoreLocalOriginLocally/__TOCDet/Name = DoNotStoreLocalOriginLocally
DoNotStoreLocalOriginLocally/__TOCDet/Namespace = ARCCore
DoNotStoreLocalOriginLocally/__TOCDet/Type = StreamProcessorP
DoNotStoreLocalOriginLocally/__TOCDet/Attribute/Description = Means 'do not store local origin locally but wait until it gets confirmed by core storage'.0x000D0x000A0x000D0x000ASet to TRUE if you do not want locally orginated data to be stored directly locally0x000D0x000A0x000D0x000AThis is normally relevant to do when you have outgoing connections, one for sending to -CoreDB- and one subscribing to the same content again.0x000D0x000ASetting this value to TRUE will then ensure that locally originated data do not get stored twice (and also ensure that data is not stored permanently on the client side (-Client-) before it has been confirmed stored by -CoreDB-.)
DoNotStoreLocalOriginLocally/__TOCDet/Attribute/PKTypeAttribute/BoilerplateCodeProperties = // Autogenerated boilerplate code. Paste into your class as needed.0x000D0x000Apublic Boolean DoNotStoreLocalOriginLocally0x007B0x000D0x000A  get =0x003E IP.GetPV0x003CBoolean0x003E(StreamProcessorP.DoNotStoreLocalOriginLocally)0x003B0x000D0x000A  set =0x003E IP.SetPV(StreamProcessorP.DoNotStoreLocalOriginLocally, value)0x003B0x000D0x000A0x007D0x000D0x000Apublic AddDoNotStoreLocalOriginLocally(Boolean doNotStoreLocalOriginLocally) =0x003E IP.AddPV(StreamProcessorP.DoNotStoreLocalOriginLocally, doNotStoreLocalOriginLocally)0x003B0x000D0x000Apublic Boolean? GetDoNotStoreLocalOriginLocally() =0x003E TryGetDoNotStoreLocalOriginLocally(out var retval) ? retval : null0x003B0x000D0x000Apublic Boolean GetDoNotStoreLocalOriginLocally(Boolean defaultValue) =0x003E TryGetDoNotStoreLocalOriginLocally(out var retval) ? retval : defaultValue0x003B0x000D0x000Apublic bool TryGetDoNotStoreLocalOriginLocally(out Boolean doNotStoreLocalOriginLocally) =0x003E IP.TryGetPV(StreamProcessorP.DoNotStoreLocalOriginLocally, out doNotStoreLocalOriginLocally)0x003B0x000D0x000A0x000D0x000A0x000D0x000A
DoNotStoreLocalOriginLocally/__TOCDet/Attribute/PKTypeAttribute/Cardinality = HistoryOnly
DoNotStoreLocalOriginLocally/__TOCDet/Attribute/PKTypeAttribute/Description = Means 'do not store local origin locally but wait until it gets confirmed by core storage'.0x000D0x000A0x000D0x000ASet to TRUE if you do not want locally orginated data to be stored directly locally0x000D0x000A0x000D0x000AThis is normally relevant to do when you have outgoing connections, one for sending to -CoreDB- and one subscribing to the same content again.0x000D0x000ASetting this value to TRUE will then ensure that locally originated data do not get stored twice (and also ensure that data is not stored permanently on the client side (-Client-) before it has been confirmed stored by -CoreDB-.)
DoNotStoreLocalOriginLocally/__TOCDet/Attribute/PKTypeAttribute/EnumMember = DoNotStoreLocalOriginLocally
DoNotStoreLocalOriginLocally/__TOCDet/Attribute/PKTypeAttribute/EnumType = StreamProcessorP
DoNotStoreLocalOriginLocally/__TOCDet/Attribute/PKTypeAttribute/IsObligatory = False
DoNotStoreLocalOriginLocally/__TOCDet/Attribute/PKTypeAttribute/Type = Boolean
IncomingConnectionsPortNo/__TOCDet/Assembly = ARCCore
IncomingConnectionsPortNo/__TOCDet/Description = If not set, then class will not listen for incoming connections (meaning that our application is probably a -Client-).
IncomingConnectionsPortNo/__TOCDet/DocFragType = EnumMember
IncomingConnectionsPortNo/__TOCDet/Name = IncomingConnectionsPortNo
IncomingConnectionsPortNo/__TOCDet/Namespace = ARCCore
IncomingConnectionsPortNo/__TOCDet/Type = StreamProcessorP
IncomingConnectionsPortNo/__TOCDet/Attribute/Description = If not set, then class will not listen for incoming connections (meaning that our application is probably a -Client-).
IncomingConnectionsPortNo/__TOCDet/Attribute/PKTypeAttribute/BoilerplateCodeProperties = // Autogenerated boilerplate code. Paste into your class as needed.0x000D0x000Apublic Int32 IncomingConnectionsPortNo0x007B0x000D0x000A  get =0x003E IP.GetPV0x003CInt320x003E(StreamProcessorP.IncomingConnectionsPortNo)0x003B0x000D0x000A  set =0x003E IP.SetPV(StreamProcessorP.IncomingConnectionsPortNo, value)0x003B0x000D0x000A0x007D0x000D0x000Apublic AddIncomingConnectionsPortNo(Int32 incomingConnectionsPortNo) =0x003E IP.AddPV(StreamProcessorP.IncomingConnectionsPortNo, incomingConnectionsPortNo)0x003B0x000D0x000Apublic Int32? GetIncomingConnectionsPortNo() =0x003E TryGetIncomingConnectionsPortNo(out var retval) ? retval : null0x003B0x000D0x000Apublic Int32 GetIncomingConnectionsPortNo(Int32 defaultValue) =0x003E TryGetIncomingConnectionsPortNo(out var retval) ? retval : defaultValue0x003B0x000D0x000Apublic bool TryGetIncomingConnectionsPortNo(out Int32 incomingConnectionsPortNo) =0x003E IP.TryGetPV(StreamProcessorP.IncomingConnectionsPortNo, out incomingConnectionsPortNo)0x003B0x000D0x000A0x000D0x000A0x000D0x000A
IncomingConnectionsPortNo/__TOCDet/Attribute/PKTypeAttribute/Cardinality = HistoryOnly
IncomingConnectionsPortNo/__TOCDet/Attribute/PKTypeAttribute/Description = If not set, then class will not listen for incoming connections (meaning that our application is probably a -Client-).
IncomingConnectionsPortNo/__TOCDet/Attribute/PKTypeAttribute/EnumMember = IncomingConnectionsPortNo
IncomingConnectionsPortNo/__TOCDet/Attribute/PKTypeAttribute/EnumType = StreamProcessorP
IncomingConnectionsPortNo/__TOCDet/Attribute/PKTypeAttribute/IsObligatory = False
IncomingConnectionsPortNo/__TOCDet/Attribute/PKTypeAttribute/Type = Int32
IndividualStorageFileSize/__TOCDet/Assembly = ARCCore
IndividualStorageFileSize/__TOCDet/Description = Max size (in bytes) for a single storage file before a new file is created by call to -StreamProcessor.CreateNewStorageFile-.0x000D0x000ANote: The actual resulting file-size will vary depending on actual method used for measuring file-size.0x000D0x000A0x000D0x000AThe value to be chosen will affect in the following manner:0x000D0x000A0x000D0x000A1) Memory usage for -CoreDB- / -ArmDB- (smaller value is better). These nodes do not need to hold the whole database in memory, but they will as a minimum have to read the last (the current) storage file into memory, and possible also some older files for subscribing clients which do not yet have an updated copy of the data relevant for their -Subscription-.0x000D0x000A(note that memory used will under normal circumstances be more than double the size of the storage file.)0x000D0x000A0x000D0x000A2) Response time at startup (smaller value is better). For instance for -CoreDB-, if all clients are 'up-to-date', then having a small current storage file is advantageous because only that (last) file have to be read into memory at startup.0x000D0x000A0x000D0x000A3) -DataRetention- (smaller value is better). Smaller filesize would mean each file gets processed quicker, meaning it should affect less the performance of more critical processing (data retention is assumed not time-critical / performance critical).0x000D0x000A0x000D0x000A4) If a file-system (file copy) method of backup is used, then more copying will be needed the greater the file size chosen (smaller value is better).0x000D0x000ANOTE: You can as well do backup through an -Subscription-, instead of by file-copying at the -CoreDB- server.0x000D0x000A5) Debugging / administrative tasks. Opening of a storage file in an editor (smaller value is maybe better). Changing content of storage values (higher value is maybe better, a lesser number of files to contend with).0x000D0x000A0x000D0x000A6) The actual number of files stored in the -LocalStorageFolder- (higher value is better). All filenames are read by -StartTCPIPCommunication- at startup so having a huge amount of files may be less optimal.0x000D0x000A0x000D0x000A7) Coordination among different -CoreDB- instances (smaller value is better). (currently not implemented, Apr 2020). It is assumed much easier to coordinate with smaller filesizes. Like calculating hash-values in order to ensure identical files for instance, which in turn will ensure that -ClientUpdatePosition- between different -CoreDB- instances are compatible.0x000D0x000A
IndividualStorageFileSize/__TOCDet/DocFragType = EnumMember
IndividualStorageFileSize/__TOCDet/LongDescription = Note that setting a really huge value could breach limits of object storage in RAM (like number of items in a List0x003C0x003E (because index is 32 bit only) and similar).0x000D0x000AA value of up to 1GB is considered quite safe though.0x000D0x000A" +TODO: Research further these limitations
IndividualStorageFileSize/__TOCDet/Name = IndividualStorageFileSize
IndividualStorageFileSize/__TOCDet/Namespace = ARCCore
IndividualStorageFileSize/__TOCDet/Type = StreamProcessorP
IndividualStorageFileSize/__TOCDet/Attribute/Description = Max size (in bytes) for a single storage file before a new file is created by call to -StreamProcessor.CreateNewStorageFile-.0x000D0x000ANote: The actual resulting file-size will vary depending on actual method used for measuring file-size.0x000D0x000A0x000D0x000AThe value to be chosen will affect in the following manner:0x000D0x000A0x000D0x000A1) Memory usage for -CoreDB- / -ArmDB- (smaller value is better). These nodes do not need to hold the whole database in memory, but they will as a minimum have to read the last (the current) storage file into memory, and possible also some older files for subscribing clients which do not yet have an updated copy of the data relevant for their -Subscription-.0x000D0x000A(note that memory used will under normal circumstances be more than double the size of the storage file.)0x000D0x000A0x000D0x000A2) Response time at startup (smaller value is better). For instance for -CoreDB-, if all clients are 'up-to-date', then having a small current storage file is advantageous because only that (last) file have to be read into memory at startup.0x000D0x000A0x000D0x000A3) -DataRetention- (smaller value is better). Smaller filesize would mean each file gets processed quicker, meaning it should affect less the performance of more critical processing (data retention is assumed not time-critical / performance critical).0x000D0x000A0x000D0x000A4) If a file-system (file copy) method of backup is used, then more copying will be needed the greater the file size chosen (smaller value is better).0x000D0x000ANOTE: You can as well do backup through an -Subscription-, instead of by file-copying at the -CoreDB- server.0x000D0x000A5) Debugging / administrative tasks. Opening of a storage file in an editor (smaller value is maybe better). Changing content of storage values (higher value is maybe better, a lesser number of files to contend with).0x000D0x000A0x000D0x000A6) The actual number of files stored in the -LocalStorageFolder- (higher value is better). All filenames are read by -StartTCPIPCommunication- at startup so having a huge amount of files may be less optimal.0x000D0x000A0x000D0x000A7) Coordination among different -CoreDB- instances (smaller value is better). (currently not implemented, Apr 2020). It is assumed much easier to coordinate with smaller filesizes. Like calculating hash-values in order to ensure identical files for instance, which in turn will ensure that -ClientUpdatePosition- between different -CoreDB- instances are compatible.0x000D0x000A
IndividualStorageFileSize/__TOCDet/Attribute/LongDescription = Note that setting a really huge value could breach limits of object storage in RAM (like number of items in a List0x003C0x003E (because index is 32 bit only) and similar).0x000D0x000AA value of up to 1GB is considered quite safe though.0x000D0x000A" +TODO: Research further these limitations
IndividualStorageFileSize/__TOCDet/Attribute/PKTypeAttribute/BoilerplateCodeProperties = // Autogenerated boilerplate code. Paste into your class as needed.0x000D0x000Apublic Int64 IndividualStorageFileSize0x007B0x000D0x000A  get =0x003E IP.GetPV0x003CInt640x003E(StreamProcessorP.IndividualStorageFileSize)0x003B0x000D0x000A  set =0x003E IP.SetPV(StreamProcessorP.IndividualStorageFileSize, value)0x003B0x000D0x000A0x007D0x000D0x000Apublic AddIndividualStorageFileSize(Int64 individualStorageFileSize) =0x003E IP.AddPV(StreamProcessorP.IndividualStorageFileSize, individualStorageFileSize)0x003B0x000D0x000A/// 0x003Csee cref="PKTypeAttributeP.IsObligatory"/0x003E for StreamProcessorP.IndividualStorageFileSize, therefore Get as possible null, Get with default value and TryGet not offered here0x000D0x000A0x000D0x000A0x000D0x000A
IndividualStorageFileSize/__TOCDet/Attribute/PKTypeAttribute/Cardinality = HistoryOnly
IndividualStorageFileSize/__TOCDet/Attribute/PKTypeAttribute/DefaultValue = 100000000
IndividualStorageFileSize/__TOCDet/Attribute/PKTypeAttribute/Description = Max size (in bytes) for a single storage file before a new file is created by call to -StreamProcessor.CreateNewStorageFile-.0x000D0x000ANote: The actual resulting file-size will vary depending on actual method used for measuring file-size.0x000D0x000A0x000D0x000AThe value to be chosen will affect in the following manner:0x000D0x000A0x000D0x000A1) Memory usage for -CoreDB- / -ArmDB- (smaller value is better). These nodes do not need to hold the whole database in memory, but they will as a minimum have to read the last (the current) storage file into memory, and possible also some older files for subscribing clients which do not yet have an updated copy of the data relevant for their -Subscription-.0x000D0x000A(note that memory used will under normal circumstances be more than double the size of the storage file.)0x000D0x000A0x000D0x000A2) Response time at startup (smaller value is better). For instance for -CoreDB-, if all clients are 'up-to-date', then having a small current storage file is advantageous because only that (last) file have to be read into memory at startup.0x000D0x000A0x000D0x000A3) -DataRetention- (smaller value is better). Smaller filesize would mean each file gets processed quicker, meaning it should affect less the performance of more critical processing (data retention is assumed not time-critical / performance critical).0x000D0x000A0x000D0x000A4) If a file-system (file copy) method of backup is used, then more copying will be needed the greater the file size chosen (smaller value is better).0x000D0x000ANOTE: You can as well do backup through an -Subscription-, instead of by file-copying at the -CoreDB- server.0x000D0x000A5) Debugging / administrative tasks. Opening of a storage file in an editor (smaller value is maybe better). Changing content of storage values (higher value is maybe better, a lesser number of files to contend with).0x000D0x000A0x000D0x000A6) The actual number of files stored in the -LocalStorageFolder- (higher value is better). All filenames are read by -StartTCPIPCommunication- at startup so having a huge amount of files may be less optimal.0x000D0x000A0x000D0x000A7) Coordination among different -CoreDB- instances (smaller value is better). (currently not implemented, Apr 2020). It is assumed much easier to coordinate with smaller filesizes. Like calculating hash-values in order to ensure identical files for instance, which in turn will ensure that -ClientUpdatePosition- between different -CoreDB- instances are compatible.0x000D0x000A
IndividualStorageFileSize/__TOCDet/Attribute/PKTypeAttribute/EnumMember = IndividualStorageFileSize
IndividualStorageFileSize/__TOCDet/Attribute/PKTypeAttribute/EnumType = StreamProcessorP
IndividualStorageFileSize/__TOCDet/Attribute/PKTypeAttribute/IsObligatory = True
IndividualStorageFileSize/__TOCDet/Attribute/PKTypeAttribute/LongDescription = Note that setting a really huge value could breach limits of object storage in RAM (like number of items in a List0x003C0x003E (because index is 32 bit only) and similar).0x000D0x000AA value of up to 1GB is considered quite safe though.0x000D0x000A" +TODO: Research further these limitations
IndividualStorageFileSize/__TOCDet/Attribute/PKTypeAttribute/Type = Int64
LocalStorageFolder/__TOCDet/Assembly = ARCCore
LocalStorageFolder/__TOCDet/Description = The local path to which new properties are stored. Should NOT end with any trailing DirectorySeparatorChar
LocalStorageFolder/__TOCDet/DocFragType = EnumMember
LocalStorageFolder/__TOCDet/Name = LocalStorageFolder
LocalStorageFolder/__TOCDet/Namespace = ARCCore
LocalStorageFolder/__TOCDet/Type = StreamProcessorP
LocalStorageFolder/__TOCDet/Attribute/Description = The local path to which new properties are stored. Should NOT end with any trailing DirectorySeparatorChar
LocalStorageFolder/__TOCDet/Attribute/PKTypeAttribute/BoilerplateCodeProperties = // Autogenerated boilerplate code. Paste into your class as needed.0x000D0x000Apublic String LocalStorageFolder0x007B0x000D0x000A  get =0x003E IP.GetPV0x003CString0x003E(StreamProcessorP.LocalStorageFolder)0x003B0x000D0x000A  set =0x003E IP.SetPV(StreamProcessorP.LocalStorageFolder, value)0x003B0x000D0x000A0x007D0x000D0x000Apublic AddLocalStorageFolder(String localStorageFolder) =0x003E IP.AddPV(StreamProcessorP.LocalStorageFolder, localStorageFolder)0x003B0x000D0x000Apublic String? GetLocalStorageFolder() =0x003E TryGetLocalStorageFolder(out var retval) ? retval : null0x003B0x000D0x000Apublic String GetLocalStorageFolder(String defaultValue) =0x003E TryGetLocalStorageFolder(out var retval) ? retval : defaultValue0x003B0x000D0x000Apublic bool TryGetLocalStorageFolder(out String localStorageFolder) =0x003E IP.TryGetPV(StreamProcessorP.LocalStorageFolder, out localStorageFolder)0x003B0x000D0x000A0x000D0x000A0x000D0x000A
LocalStorageFolder/__TOCDet/Attribute/PKTypeAttribute/Cardinality = HistoryOnly
LocalStorageFolder/__TOCDet/Attribute/PKTypeAttribute/Description = The local path to which new properties are stored. Should NOT end with any trailing DirectorySeparatorChar
LocalStorageFolder/__TOCDet/Attribute/PKTypeAttribute/EnumMember = LocalStorageFolder
LocalStorageFolder/__TOCDet/Attribute/PKTypeAttribute/EnumType = StreamProcessorP
LocalStorageFolder/__TOCDet/Attribute/PKTypeAttribute/IsObligatory = False
LocalStorageFolder/__TOCDet/Attribute/PKTypeAttribute/Type = String
Timestamp/__TOCDet/Assembly = ARCCore
Timestamp/__TOCDet/Description = The timestamp inserted at regular intervals in the -PropertyStream- according to -TimestampResolution-.0x000D0x000A0x000D0x000ANote how -AddTimestampAsRequired- uses a format reflecting the resolution, for instance if resolution is in whole minutes, then timestamp will be in format yyyy-MM-dd HH:mm.0x000D0x000A0x000D0x000ASpecially understood by -TryStore-.0x000D0x000A0x000D0x000AThis property can always be assumed to be at the top hierarchical level in the property stream. (outside can look for it at the top level in the hierarchical data storage).0x000D0x000A0x000D0x000AGets specific treatmeant by -TryStore- (see -CurrentTimestamp-).
Timestamp/__TOCDet/DocFragType = EnumMember
Timestamp/__TOCDet/Name = Timestamp
Timestamp/__TOCDet/Namespace = ARCCore
Timestamp/__TOCDet/Type = StreamProcessorP
Timestamp/__TOCDet/Attribute/Description = The timestamp inserted at regular intervals in the -PropertyStream- according to -TimestampResolution-.0x000D0x000A0x000D0x000ANote how -AddTimestampAsRequired- uses a format reflecting the resolution, for instance if resolution is in whole minutes, then timestamp will be in format yyyy-MM-dd HH:mm.0x000D0x000A0x000D0x000ASpecially understood by -TryStore-.0x000D0x000A0x000D0x000AThis property can always be assumed to be at the top hierarchical level in the property stream. (outside can look for it at the top level in the hierarchical data storage).0x000D0x000A0x000D0x000AGets specific treatmeant by -TryStore- (see -CurrentTimestamp-).
Timestamp/__TOCDet/Attribute/PKTypeAttribute/BoilerplateCodeProperties = // Autogenerated boilerplate code. Paste into your class as needed.0x000D0x000Apublic DateTime Timestamp0x007B0x000D0x000A  get =0x003E IP.GetPV0x003CDateTime0x003E(StreamProcessorP.Timestamp)0x003B0x000D0x000A  set =0x003E IP.SetPV(StreamProcessorP.Timestamp, value)0x003B0x000D0x000A0x007D0x000D0x000Apublic AddTimestamp(DateTime timestamp) =0x003E IP.AddPV(StreamProcessorP.Timestamp, timestamp)0x003B0x000D0x000Apublic DateTime? GetTimestamp() =0x003E TryGetTimestamp(out var retval) ? retval : null0x003B0x000D0x000Apublic DateTime GetTimestamp(DateTime defaultValue) =0x003E TryGetTimestamp(out var retval) ? retval : defaultValue0x003B0x000D0x000Apublic bool TryGetTimestamp(out DateTime timestamp) =0x003E IP.TryGetPV(StreamProcessorP.Timestamp, out timestamp)0x003B0x000D0x000A0x000D0x000A0x000D0x000A
Timestamp/__TOCDet/Attribute/PKTypeAttribute/Cardinality = HistoryOnly
Timestamp/__TOCDet/Attribute/PKTypeAttribute/Description = The timestamp inserted at regular intervals in the -PropertyStream- according to -TimestampResolution-.0x000D0x000A0x000D0x000ANote how -AddTimestampAsRequired- uses a format reflecting the resolution, for instance if resolution is in whole minutes, then timestamp will be in format yyyy-MM-dd HH:mm.0x000D0x000A0x000D0x000ASpecially understood by -TryStore-.0x000D0x000A0x000D0x000AThis property can always be assumed to be at the top hierarchical level in the property stream. (outside can look for it at the top level in the hierarchical data storage).0x000D0x000A0x000D0x000AGets specific treatmeant by -TryStore- (see -CurrentTimestamp-).
Timestamp/__TOCDet/Attribute/PKTypeAttribute/EnumMember = Timestamp
Timestamp/__TOCDet/Attribute/PKTypeAttribute/EnumType = StreamProcessorP
Timestamp/__TOCDet/Attribute/PKTypeAttribute/IsObligatory = False
Timestamp/__TOCDet/Attribute/PKTypeAttribute/Type = DateTime
TimestampIsOld/__TOCDet/Assembly = ARCCore
TimestampIsOld/__TOCDet/Description = A warning sent by -StreamProcessor- to -OutsideLocalReceiver- when it knows that data as served is out of date.0x000D0x000A0x000D0x000AWill normally correspond to -CurrentlyInitializing-, or that application has initialized but reading from data storage is still in progress.0x000D0x000A0x000D0x000ATODO: Expand use of this to also include when Stream processor knows that it has connection problems with TODO: an upstream source of data.0x000D0x000A0x000D0x000ASpecially understood by -TryStore-.0x000D0x000A0x000D0x000AThis property can always be assumed to be at the top hierarchical level in the property stream. (outside can look for it at the top level in the hierarchical data storage)
TimestampIsOld/__TOCDet/DocFragType = EnumMember
TimestampIsOld/__TOCDet/Name = TimestampIsOld
TimestampIsOld/__TOCDet/Namespace = ARCCore
TimestampIsOld/__TOCDet/Type = StreamProcessorP
TimestampIsOld/__TOCDet/Attribute/Description = A warning sent by -StreamProcessor- to -OutsideLocalReceiver- when it knows that data as served is out of date.0x000D0x000A0x000D0x000AWill normally correspond to -CurrentlyInitializing-, or that application has initialized but reading from data storage is still in progress.0x000D0x000A0x000D0x000ATODO: Expand use of this to also include when Stream processor knows that it has connection problems with TODO: an upstream source of data.0x000D0x000A0x000D0x000ASpecially understood by -TryStore-.0x000D0x000A0x000D0x000AThis property can always be assumed to be at the top hierarchical level in the property stream. (outside can look for it at the top level in the hierarchical data storage)
TimestampIsOld/__TOCDet/Attribute/PKTypeAttribute/BoilerplateCodeProperties = // Autogenerated boilerplate code. Paste into your class as needed.0x000D0x000Apublic Boolean TimestampIsOld0x007B0x000D0x000A  get =0x003E IP.GetPV0x003CBoolean0x003E(StreamProcessorP.TimestampIsOld)0x003B0x000D0x000A  set =0x003E IP.SetPV(StreamProcessorP.TimestampIsOld, value)0x003B0x000D0x000A0x007D0x000D0x000Apublic AddTimestampIsOld(Boolean timestampIsOld) =0x003E IP.AddPV(StreamProcessorP.TimestampIsOld, timestampIsOld)0x003B0x000D0x000Apublic Boolean? GetTimestampIsOld() =0x003E TryGetTimestampIsOld(out var retval) ? retval : null0x003B0x000D0x000Apublic Boolean GetTimestampIsOld(Boolean defaultValue) =0x003E TryGetTimestampIsOld(out var retval) ? retval : defaultValue0x003B0x000D0x000Apublic bool TryGetTimestampIsOld(out Boolean timestampIsOld) =0x003E IP.TryGetPV(StreamProcessorP.TimestampIsOld, out timestampIsOld)0x003B0x000D0x000A0x000D0x000A0x000D0x000A
TimestampIsOld/__TOCDet/Attribute/PKTypeAttribute/Cardinality = HistoryOnly
TimestampIsOld/__TOCDet/Attribute/PKTypeAttribute/Description = A warning sent by -StreamProcessor- to -OutsideLocalReceiver- when it knows that data as served is out of date.0x000D0x000A0x000D0x000AWill normally correspond to -CurrentlyInitializing-, or that application has initialized but reading from data storage is still in progress.0x000D0x000A0x000D0x000ATODO: Expand use of this to also include when Stream processor knows that it has connection problems with TODO: an upstream source of data.0x000D0x000A0x000D0x000ASpecially understood by -TryStore-.0x000D0x000A0x000D0x000AThis property can always be assumed to be at the top hierarchical level in the property stream. (outside can look for it at the top level in the hierarchical data storage)
TimestampIsOld/__TOCDet/Attribute/PKTypeAttribute/EnumMember = TimestampIsOld
TimestampIsOld/__TOCDet/Attribute/PKTypeAttribute/EnumType = StreamProcessorP
TimestampIsOld/__TOCDet/Attribute/PKTypeAttribute/IsObligatory = False
TimestampIsOld/__TOCDet/Attribute/PKTypeAttribute/Type = Boolean
TimestampResolution/__TOCDet/Assembly = ARCCore
TimestampResolution/__TOCDet/Description = The time interval between each timestamp update in the -PropertyStream-.0x000D0x000A0x000D0x000A(See also -TimestampResolution- concept in -ARCEvent-.-UtilEvent-.)0x000D0x000A0x000D0x000AUsed by -AddTimestampAsRequired-.0x000D0x000A0x000D0x000AOnly relevant for -CoreDB- (there should only be one source of timestamps in the system).0x000D0x000A(If this value is present, then -StreamProcessor- will insert timestamps at the specified interval).0x000D0x000A0x000D0x000ABackground: The -PropertyStream- principle lends itself well to keeping historical track of changes in your database. A method for timestamping the updates is therefore also natural to include.0x000D0x000A0x000D0x000ABut, by default, timestamps are not stored with each -PropertyStream--line. (you might have expected each property stream line to start with a timestamp like '2020-04-26 11:02:37' but that is not the case.)0x000D0x000A0x000D0x000AInstead, timestamps are inserted at regular intervals in the stream as Timestamp = 0x005Byyyy-MM-dd HH:mm ...0x005D. This is a practical approach reflecting the fact that consecutive timestamps will often be identical anyway and therefore just taking up space.0x000D0x000A0x000D0x000ANote that if this value is not set at all, then neither will timestamps be inserted into the -PropertyStream-.0x000D0x000A0x000D0x000AThe higher value chosen, the less space timestamps will take up in storage and transfer.0x000D0x000A0x000D0x000ASet to the highest value acceptable according to your time-resolution needs. If you have a need for a one-minute accuracy for timestamps, set this value to 1 minute.0x000D0x000A0x000D0x000AIf you want the highest possible resolution for when properties are created (down to the millisecond), set a resolution of one millisecond (ticks are not supported).0x000D0x000A
TimestampResolution/__TOCDet/DocFragType = EnumMember
TimestampResolution/__TOCDet/LongDescription = Properties for which we want to store in-memory a -Created-, / -Invalid- field or similar are given the latest timestamp value found.
TimestampResolution/__TOCDet/Name = TimestampResolution
TimestampResolution/__TOCDet/Namespace = ARCCore
TimestampResolution/__TOCDet/Type = StreamProcessorP
TimestampResolution/__TOCDet/Attribute/Description = The time interval between each timestamp update in the -PropertyStream-.0x000D0x000A0x000D0x000A(See also -TimestampResolution- concept in -ARCEvent-.-UtilEvent-.)0x000D0x000A0x000D0x000AUsed by -AddTimestampAsRequired-.0x000D0x000A0x000D0x000AOnly relevant for -CoreDB- (there should only be one source of timestamps in the system).0x000D0x000A(If this value is present, then -StreamProcessor- will insert timestamps at the specified interval).0x000D0x000A0x000D0x000ABackground: The -PropertyStream- principle lends itself well to keeping historical track of changes in your database. A method for timestamping the updates is therefore also natural to include.0x000D0x000A0x000D0x000ABut, by default, timestamps are not stored with each -PropertyStream--line. (you might have expected each property stream line to start with a timestamp like '2020-04-26 11:02:37' but that is not the case.)0x000D0x000A0x000D0x000AInstead, timestamps are inserted at regular intervals in the stream as Timestamp = 0x005Byyyy-MM-dd HH:mm ...0x005D. This is a practical approach reflecting the fact that consecutive timestamps will often be identical anyway and therefore just taking up space.0x000D0x000A0x000D0x000ANote that if this value is not set at all, then neither will timestamps be inserted into the -PropertyStream-.0x000D0x000A0x000D0x000AThe higher value chosen, the less space timestamps will take up in storage and transfer.0x000D0x000A0x000D0x000ASet to the highest value acceptable according to your time-resolution needs. If you have a need for a one-minute accuracy for timestamps, set this value to 1 minute.0x000D0x000A0x000D0x000AIf you want the highest possible resolution for when properties are created (down to the millisecond), set a resolution of one millisecond (ticks are not supported).0x000D0x000A
TimestampResolution/__TOCDet/Attribute/LongDescription = Properties for which we want to store in-memory a -Created-, / -Invalid- field or similar are given the latest timestamp value found.
TimestampResolution/__TOCDet/Attribute/PKTypeAttribute/BoilerplateCodeProperties = // Autogenerated boilerplate code. Paste into your class as needed.0x000D0x000Apublic TimeSpan TimestampResolution0x007B0x000D0x000A  get =0x003E IP.GetPV0x003CTimeSpan0x003E(StreamProcessorP.TimestampResolution)0x003B0x000D0x000A  set =0x003E IP.SetPV(StreamProcessorP.TimestampResolution, value)0x003B0x000D0x000A0x007D0x000D0x000Apublic AddTimestampResolution(TimeSpan timestampResolution) =0x003E IP.AddPV(StreamProcessorP.TimestampResolution, timestampResolution)0x003B0x000D0x000Apublic TimeSpan? GetTimestampResolution() =0x003E TryGetTimestampResolution(out var retval) ? retval : null0x003B0x000D0x000Apublic TimeSpan GetTimestampResolution(TimeSpan defaultValue) =0x003E TryGetTimestampResolution(out var retval) ? retval : defaultValue0x003B0x000D0x000Apublic bool TryGetTimestampResolution(out TimeSpan timestampResolution) =0x003E IP.TryGetPV(StreamProcessorP.TimestampResolution, out timestampResolution)0x003B0x000D0x000A0x000D0x000A0x000D0x000A
TimestampResolution/__TOCDet/Attribute/PKTypeAttribute/Cardinality = HistoryOnly
TimestampResolution/__TOCDet/Attribute/PKTypeAttribute/Description = The time interval between each timestamp update in the -PropertyStream-.0x000D0x000A0x000D0x000A(See also -TimestampResolution- concept in -ARCEvent-.-UtilEvent-.)0x000D0x000A0x000D0x000AUsed by -AddTimestampAsRequired-.0x000D0x000A0x000D0x000AOnly relevant for -CoreDB- (there should only be one source of timestamps in the system).0x000D0x000A(If this value is present, then -StreamProcessor- will insert timestamps at the specified interval).0x000D0x000A0x000D0x000ABackground: The -PropertyStream- principle lends itself well to keeping historical track of changes in your database. A method for timestamping the updates is therefore also natural to include.0x000D0x000A0x000D0x000ABut, by default, timestamps are not stored with each -PropertyStream--line. (you might have expected each property stream line to start with a timestamp like '2020-04-26 11:02:37' but that is not the case.)0x000D0x000A0x000D0x000AInstead, timestamps are inserted at regular intervals in the stream as Timestamp = 0x005Byyyy-MM-dd HH:mm ...0x005D. This is a practical approach reflecting the fact that consecutive timestamps will often be identical anyway and therefore just taking up space.0x000D0x000A0x000D0x000ANote that if this value is not set at all, then neither will timestamps be inserted into the -PropertyStream-.0x000D0x000A0x000D0x000AThe higher value chosen, the less space timestamps will take up in storage and transfer.0x000D0x000A0x000D0x000ASet to the highest value acceptable according to your time-resolution needs. If you have a need for a one-minute accuracy for timestamps, set this value to 1 minute.0x000D0x000A0x000D0x000AIf you want the highest possible resolution for when properties are created (down to the millisecond), set a resolution of one millisecond (ticks are not supported).0x000D0x000A
TimestampResolution/__TOCDet/Attribute/PKTypeAttribute/EnumMember = TimestampResolution
TimestampResolution/__TOCDet/Attribute/PKTypeAttribute/EnumType = StreamProcessorP
TimestampResolution/__TOCDet/Attribute/PKTypeAttribute/IsObligatory = False
TimestampResolution/__TOCDet/Attribute/PKTypeAttribute/LongDescription = Properties for which we want to store in-memory a -Created-, / -Invalid- field or similar are given the latest timestamp value found.
TimestampResolution/__TOCDet/Attribute/PKTypeAttribute/Type = TimeSpan
UnderClosure/__TOCDet/Assembly = ARCCore
UnderClosure/__TOCDet/Description = Set to TRUE if to be closed, whenever an exception occurs or when class goes out of scope
UnderClosure/__TOCDet/DocFragType = EnumMember
UnderClosure/__TOCDet/Name = UnderClosure
UnderClosure/__TOCDet/Namespace = ARCCore
UnderClosure/__TOCDet/Type = StreamProcessorP
UnderClosure/__TOCDet/Attribute/Description = Set to TRUE if to be closed, whenever an exception occurs or when class goes out of scope
UnderClosure/__TOCDet/Attribute/PKTypeAttribute/BoilerplateCodeProperties = // Autogenerated boilerplate code. Paste into your class as needed.0x000D0x000Apublic Boolean UnderClosure0x007B0x000D0x000A  get =0x003E IP.GetPV0x003CBoolean0x003E(StreamProcessorP.UnderClosure)0x003B0x000D0x000A  set =0x003E IP.SetPV(StreamProcessorP.UnderClosure, value)0x003B0x000D0x000A0x007D0x000D0x000Apublic AddUnderClosure(Boolean underClosure) =0x003E IP.AddPV(StreamProcessorP.UnderClosure, underClosure)0x003B0x000D0x000Apublic Boolean? GetUnderClosure() =0x003E TryGetUnderClosure(out var retval) ? retval : null0x003B0x000D0x000Apublic Boolean GetUnderClosure(Boolean defaultValue) =0x003E TryGetUnderClosure(out var retval) ? retval : defaultValue0x003B0x000D0x000Apublic bool TryGetUnderClosure(out Boolean underClosure) =0x003E IP.TryGetPV(StreamProcessorP.UnderClosure, out underClosure)0x003B0x000D0x000A0x000D0x000A0x000D0x000A
UnderClosure/__TOCDet/Attribute/PKTypeAttribute/Cardinality = HistoryOnly
UnderClosure/__TOCDet/Attribute/PKTypeAttribute/Description = Set to TRUE if to be closed, whenever an exception occurs or when class goes out of scope
UnderClosure/__TOCDet/Attribute/PKTypeAttribute/EnumMember = UnderClosure
UnderClosure/__TOCDet/Attribute/PKTypeAttribute/EnumType = StreamProcessorP
UnderClosure/__TOCDet/Attribute/PKTypeAttribute/IsObligatory = False
UnderClosure/__TOCDet/Attribute/PKTypeAttribute/Type = Boolean
WriteToConsole/__TOCDet/Assembly = ARCCore
WriteToConsole/__TOCDet/Description = If true then incoming data (from other nodes will be written to console.0x000D0x000ANote that data with -HasLocalOrigin- will not be written to console (the local originator can to that by 'itself' instead, if so desired)
WriteToConsole/__TOCDet/DocFragType = EnumMember
WriteToConsole/__TOCDet/Name = WriteToConsole
WriteToConsole/__TOCDet/Namespace = ARCCore
WriteToConsole/__TOCDet/Type = StreamProcessorP
WriteToConsole/__TOCDet/Attribute/Description = If true then incoming data (from other nodes will be written to console.0x000D0x000ANote that data with -HasLocalOrigin- will not be written to console (the local originator can to that by 'itself' instead, if so desired)
WriteToConsole/__TOCDet/Attribute/PKTypeAttribute/BoilerplateCodeProperties = // Autogenerated boilerplate code. Paste into your class as needed.0x000D0x000Apublic Boolean WriteToConsole0x007B0x000D0x000A  get =0x003E IP.GetPV0x003CBoolean0x003E(StreamProcessorP.WriteToConsole)0x003B0x000D0x000A  set =0x003E IP.SetPV(StreamProcessorP.WriteToConsole, value)0x003B0x000D0x000A0x007D0x000D0x000Apublic AddWriteToConsole(Boolean writeToConsole) =0x003E IP.AddPV(StreamProcessorP.WriteToConsole, writeToConsole)0x003B0x000D0x000Apublic Boolean? GetWriteToConsole() =0x003E TryGetWriteToConsole(out var retval) ? retval : null0x003B0x000D0x000Apublic Boolean GetWriteToConsole(Boolean defaultValue) =0x003E TryGetWriteToConsole(out var retval) ? retval : defaultValue0x003B0x000D0x000Apublic bool TryGetWriteToConsole(out Boolean writeToConsole) =0x003E IP.TryGetPV(StreamProcessorP.WriteToConsole, out writeToConsole)0x003B0x000D0x000A0x000D0x000A0x000D0x000A
WriteToConsole/__TOCDet/Attribute/PKTypeAttribute/Cardinality = HistoryOnly
WriteToConsole/__TOCDet/Attribute/PKTypeAttribute/Description = If true then incoming data (from other nodes will be written to console.0x000D0x000ANote that data with -HasLocalOrigin- will not be written to console (the local originator can to that by 'itself' instead, if so desired)
WriteToConsole/__TOCDet/Attribute/PKTypeAttribute/EnumMember = WriteToConsole
WriteToConsole/__TOCDet/Attribute/PKTypeAttribute/EnumType = StreamProcessorP
WriteToConsole/__TOCDet/Attribute/PKTypeAttribute/IsObligatory = False
WriteToConsole/__TOCDet/Attribute/PKTypeAttribute/Type = Boolean

Edit single sub keys only: __TOCDet / CacheDiskWrites / ClientUpdatePosition / ClientUpdatePositionPath / CopyFileStructureFromCore / CountIncomingConnections / CountOutgoingConnections / CountOutsideLocalReceiver / CountReceiveLocalOrigin / CountReceiveNonLocalOrigin / CurrentlyInitializing / DoNotStoreLocally / DoNotStoreLocalOriginLocally / IncomingConnectionsPortNo / IndividualStorageFileSize / LocalStorageFolder / Timestamp / TimestampIsOld / TimestampResolution / UnderClosure / WriteToConsole

Generated 2025-03-20 08:57:51.819 UTC