|
def | __init__ (self, subservice, data, addressspace, callback) |
|
def | __str__ (self) |
|
def | enqueue_datachange_event (self, mid, eventdata, maxsize) |
|
def | enqueue_event (self, mid, eventdata, maxsize) |
|
def | enqueue_statuschange (self, code) |
|
def | has_published_results (self) |
|
def | publish (self, acks) |
|
def | publish_results (self) |
|
def | republish (self, nb) |
|
def | start (self) |
|
def | stop (self) |
|
Definition at line 244 of file internal_subscription.py.
def opcua.server.internal_subscription.InternalSubscription.__init__ |
( |
|
self, |
|
|
|
subservice, |
|
|
|
data, |
|
|
|
addressspace, |
|
|
|
callback |
|
) |
| |
def opcua.server.internal_subscription.InternalSubscription.__str__ |
( |
|
self | ) |
|
def opcua.server.internal_subscription.InternalSubscription._enqueue_event |
( |
|
self, |
|
|
|
mid, |
|
|
|
eventdata, |
|
|
|
size, |
|
|
|
queue |
|
) |
| |
|
private |
def opcua.server.internal_subscription.InternalSubscription._pop_publish_result |
( |
|
self | ) |
|
|
private |
def opcua.server.internal_subscription.InternalSubscription._pop_triggered_datachanges |
( |
|
self, |
|
|
|
result |
|
) |
| |
|
private |
def opcua.server.internal_subscription.InternalSubscription._pop_triggered_events |
( |
|
self, |
|
|
|
result |
|
) |
| |
|
private |
def opcua.server.internal_subscription.InternalSubscription._pop_triggered_statuschanges |
( |
|
self, |
|
|
|
result |
|
) |
| |
|
private |
def opcua.server.internal_subscription.InternalSubscription._sub_loop |
( |
|
self | ) |
|
|
private |
def opcua.server.internal_subscription.InternalSubscription._subscription_loop |
( |
|
self | ) |
|
|
private |
def opcua.server.internal_subscription.InternalSubscription.enqueue_datachange_event |
( |
|
self, |
|
|
|
mid, |
|
|
|
eventdata, |
|
|
|
maxsize |
|
) |
| |
def opcua.server.internal_subscription.InternalSubscription.enqueue_event |
( |
|
self, |
|
|
|
mid, |
|
|
|
eventdata, |
|
|
|
maxsize |
|
) |
| |
def opcua.server.internal_subscription.InternalSubscription.enqueue_statuschange |
( |
|
self, |
|
|
|
code |
|
) |
| |
def opcua.server.internal_subscription.InternalSubscription.has_published_results |
( |
|
self | ) |
|
def opcua.server.internal_subscription.InternalSubscription.publish |
( |
|
self, |
|
|
|
acks |
|
) |
| |
def opcua.server.internal_subscription.InternalSubscription.publish_results |
( |
|
self | ) |
|
def opcua.server.internal_subscription.InternalSubscription.republish |
( |
|
self, |
|
|
|
nb |
|
) |
| |
def opcua.server.internal_subscription.InternalSubscription.start |
( |
|
self | ) |
|
def opcua.server.internal_subscription.InternalSubscription.stop |
( |
|
self | ) |
|
opcua.server.internal_subscription.InternalSubscription._keep_alive_count |
|
private |
opcua.server.internal_subscription.InternalSubscription._lock |
|
private |
opcua.server.internal_subscription.InternalSubscription._not_acknowledged_results |
|
private |
opcua.server.internal_subscription.InternalSubscription._notification_seq |
|
private |
opcua.server.internal_subscription.InternalSubscription._publish_cycles_count |
|
private |
opcua.server.internal_subscription.InternalSubscription._startup |
|
private |
opcua.server.internal_subscription.InternalSubscription._stopev |
|
private |
opcua.server.internal_subscription.InternalSubscription._triggered_datachanges |
|
private |
opcua.server.internal_subscription.InternalSubscription._triggered_events |
|
private |
opcua.server.internal_subscription.InternalSubscription._triggered_statuschanges |
|
private |
opcua.server.internal_subscription.InternalSubscription.aspace |
opcua.server.internal_subscription.InternalSubscription.callback |
opcua.server.internal_subscription.InternalSubscription.data |
opcua.server.internal_subscription.InternalSubscription.logger |
opcua.server.internal_subscription.InternalSubscription.monitored_item_srv |
opcua.server.internal_subscription.InternalSubscription.subservice |
opcua.server.internal_subscription.InternalSubscription.task |
The documentation for this class was generated from the following file: