@@ 10609-10659 (lines=51) @@ | ||
10606 | __repr__ = __str__ |
|
10607 | ||
10608 | ||
10609 | class SetTriggeringParameters(FrozenClass): |
|
10610 | ''' |
|
10611 | :ivar SubscriptionId: |
|
10612 | :vartype SubscriptionId: UInt32 |
|
10613 | :ivar TriggeringItemId: |
|
10614 | :vartype TriggeringItemId: UInt32 |
|
10615 | :ivar LinksToAdd: |
|
10616 | :vartype LinksToAdd: UInt32 |
|
10617 | :ivar LinksToRemove: |
|
10618 | :vartype LinksToRemove: UInt32 |
|
10619 | ''' |
|
10620 | def __init__(self, binary=None): |
|
10621 | if binary is not None: |
|
10622 | self._binary_init(binary) |
|
10623 | self._freeze = True |
|
10624 | return |
|
10625 | self.SubscriptionId = 0 |
|
10626 | self.TriggeringItemId = 0 |
|
10627 | self.LinksToAdd = [] |
|
10628 | self.LinksToRemove = [] |
|
10629 | self._freeze = True |
|
10630 | ||
10631 | def to_binary(self): |
|
10632 | packet = [] |
|
10633 | packet.append(uatype_UInt32.pack(self.SubscriptionId)) |
|
10634 | packet.append(uatype_UInt32.pack(self.TriggeringItemId)) |
|
10635 | packet.append(uatype_Int32.pack(len(self.LinksToAdd))) |
|
10636 | for fieldname in self.LinksToAdd: |
|
10637 | packet.append(uatype_UInt32.pack(fieldname)) |
|
10638 | packet.append(uatype_Int32.pack(len(self.LinksToRemove))) |
|
10639 | for fieldname in self.LinksToRemove: |
|
10640 | packet.append(uatype_UInt32.pack(fieldname)) |
|
10641 | return b''.join(packet) |
|
10642 | ||
10643 | @staticmethod |
|
10644 | def from_binary(data): |
|
10645 | return SetTriggeringParameters(data) |
|
10646 | ||
10647 | def _binary_init(self, data): |
|
10648 | self.SubscriptionId = uatype_UInt32.unpack(data.read(4))[0] |
|
10649 | self.TriggeringItemId = uatype_UInt32.unpack(data.read(4))[0] |
|
10650 | self.LinksToAdd = unpack_uatype_array('UInt32', data) |
|
10651 | self.LinksToRemove = unpack_uatype_array('UInt32', data) |
|
10652 | ||
10653 | def __str__(self): |
|
10654 | return 'SetTriggeringParameters(' + 'SubscriptionId:' + str(self.SubscriptionId) + ', ' + \ |
|
10655 | 'TriggeringItemId:' + str(self.TriggeringItemId) + ', ' + \ |
|
10656 | 'LinksToAdd:' + str(self.LinksToAdd) + ', ' + \ |
|
10657 | 'LinksToRemove:' + str(self.LinksToRemove) + ')' |
|
10658 | ||
10659 | __repr__ = __str__ |
|
10660 | ||
10661 | ||
10662 | class SetTriggeringRequest(FrozenClass): |
|
@@ 10271-10318 (lines=48) @@ | ||
10268 | __repr__ = __str__ |
|
10269 | ||
10270 | ||
10271 | class ModifyMonitoredItemsParameters(FrozenClass): |
|
10272 | ''' |
|
10273 | :ivar SubscriptionId: |
|
10274 | :vartype SubscriptionId: UInt32 |
|
10275 | :ivar TimestampsToReturn: |
|
10276 | :vartype TimestampsToReturn: TimestampsToReturn |
|
10277 | :ivar ItemsToModify: |
|
10278 | :vartype ItemsToModify: MonitoredItemModifyRequest |
|
10279 | ''' |
|
10280 | def __init__(self, binary=None): |
|
10281 | if binary is not None: |
|
10282 | self._binary_init(binary) |
|
10283 | self._freeze = True |
|
10284 | return |
|
10285 | self.SubscriptionId = 0 |
|
10286 | self.TimestampsToReturn = TimestampsToReturn(0) |
|
10287 | self.ItemsToModify = [] |
|
10288 | self._freeze = True |
|
10289 | ||
10290 | def to_binary(self): |
|
10291 | packet = [] |
|
10292 | packet.append(uatype_UInt32.pack(self.SubscriptionId)) |
|
10293 | packet.append(uatype_UInt32.pack(self.TimestampsToReturn.value)) |
|
10294 | packet.append(uatype_Int32.pack(len(self.ItemsToModify))) |
|
10295 | for fieldname in self.ItemsToModify: |
|
10296 | packet.append(fieldname.to_binary()) |
|
10297 | return b''.join(packet) |
|
10298 | ||
10299 | @staticmethod |
|
10300 | def from_binary(data): |
|
10301 | return ModifyMonitoredItemsParameters(data) |
|
10302 | ||
10303 | def _binary_init(self, data): |
|
10304 | self.SubscriptionId = uatype_UInt32.unpack(data.read(4))[0] |
|
10305 | self.TimestampsToReturn = TimestampsToReturn(uatype_UInt32.unpack(data.read(4))[0]) |
|
10306 | length = uatype_Int32.unpack(data.read(4))[0] |
|
10307 | array = [] |
|
10308 | if length != -1: |
|
10309 | for _ in range(0, length): |
|
10310 | array.append(MonitoredItemModifyRequest.from_binary(data)) |
|
10311 | self.ItemsToModify = array |
|
10312 | ||
10313 | def __str__(self): |
|
10314 | return 'ModifyMonitoredItemsParameters(' + 'SubscriptionId:' + str(self.SubscriptionId) + ', ' + \ |
|
10315 | 'TimestampsToReturn:' + str(self.TimestampsToReturn) + ', ' + \ |
|
10316 | 'ItemsToModify:' + str(self.ItemsToModify) + ')' |
|
10317 | ||
10318 | __repr__ = __str__ |
|
10319 | ||
10320 | ||
10321 | class ModifyMonitoredItemsRequest(FrozenClass): |
|
@@ 10029-10076 (lines=48) @@ | ||
10026 | __repr__ = __str__ |
|
10027 | ||
10028 | ||
10029 | class CreateMonitoredItemsParameters(FrozenClass): |
|
10030 | ''' |
|
10031 | :ivar SubscriptionId: |
|
10032 | :vartype SubscriptionId: UInt32 |
|
10033 | :ivar TimestampsToReturn: |
|
10034 | :vartype TimestampsToReturn: TimestampsToReturn |
|
10035 | :ivar ItemsToCreate: |
|
10036 | :vartype ItemsToCreate: MonitoredItemCreateRequest |
|
10037 | ''' |
|
10038 | def __init__(self, binary=None): |
|
10039 | if binary is not None: |
|
10040 | self._binary_init(binary) |
|
10041 | self._freeze = True |
|
10042 | return |
|
10043 | self.SubscriptionId = 0 |
|
10044 | self.TimestampsToReturn = TimestampsToReturn(0) |
|
10045 | self.ItemsToCreate = [] |
|
10046 | self._freeze = True |
|
10047 | ||
10048 | def to_binary(self): |
|
10049 | packet = [] |
|
10050 | packet.append(uatype_UInt32.pack(self.SubscriptionId)) |
|
10051 | packet.append(uatype_UInt32.pack(self.TimestampsToReturn.value)) |
|
10052 | packet.append(uatype_Int32.pack(len(self.ItemsToCreate))) |
|
10053 | for fieldname in self.ItemsToCreate: |
|
10054 | packet.append(fieldname.to_binary()) |
|
10055 | return b''.join(packet) |
|
10056 | ||
10057 | @staticmethod |
|
10058 | def from_binary(data): |
|
10059 | return CreateMonitoredItemsParameters(data) |
|
10060 | ||
10061 | def _binary_init(self, data): |
|
10062 | self.SubscriptionId = uatype_UInt32.unpack(data.read(4))[0] |
|
10063 | self.TimestampsToReturn = TimestampsToReturn(uatype_UInt32.unpack(data.read(4))[0]) |
|
10064 | length = uatype_Int32.unpack(data.read(4))[0] |
|
10065 | array = [] |
|
10066 | if length != -1: |
|
10067 | for _ in range(0, length): |
|
10068 | array.append(MonitoredItemCreateRequest.from_binary(data)) |
|
10069 | self.ItemsToCreate = array |
|
10070 | ||
10071 | def __str__(self): |
|
10072 | return 'CreateMonitoredItemsParameters(' + 'SubscriptionId:' + str(self.SubscriptionId) + ', ' + \ |
|
10073 | 'TimestampsToReturn:' + str(self.TimestampsToReturn) + ', ' + \ |
|
10074 | 'ItemsToCreate:' + str(self.ItemsToCreate) + ')' |
|
10075 | ||
10076 | __repr__ = __str__ |
|
10077 | ||
10078 | ||
10079 | class CreateMonitoredItemsRequest(FrozenClass): |