Index

A

ACCEPT (ddf.mqtt_communication.message.ControlCommand attribute) add_info_subscriber() (ddf.node.Node method) add_neighbor() (ddf.lossnode.lossnode.LossNode method) (ddf.node.Node method) add_new_measurement() (ddf.ant_object_reference.AntObjectReference method) AddNeighborMessage (class in ddf.message) (class in ddf.mqtt_communication.message) alias (ddf.message.NodeInfoMessage attribute) (ddf.mqtt_communication.internal.InternalCommunicator attribute) (ddf.mqtt_communication.message.NodeInfoMessage attribute) (ddf.node.Node attribute)

AntCommunicatorMqtt (class in ddf.mqtt_communication.communicator) AntLink (class in ddf.ant_link.ant_link) AntLinkExternal (class in ddf.ant_link.external) AntLinkInternalObjectID (class in ddf.ant_link.internal) AntLinkLocal (class in ddf.ant_link.local) AntObjectReference (class in ddf.ant_object_reference) asdict() (ddf.mqtt_communication.message.GradientMessage method) (ddf.mqtt_communication.message.Message method) autorun (ddf.mqtt_communication.internal.InternalCommunicator attribute) available (ddf.message.NodeInfoMessage attribute) available_labels (ddf.node.Node attribute) available_list (ddf.mqtt_communication.message.NodeInfoMessage attribute)

B

backpropagate() (ddf.ant_link.ant_link.AntLink method) (ddf.ant_link.internal.AntLinkInternalObjectID method) (ddf.ant_object_reference.AntObjectReference method) (ddf.measurement.measurement.Measurement method)

backpropagate_from_neighbor() (ddf.ant_object_reference.AntObjectReference method) base_topic (ddf.mqtt_communication.internal.InternalCommunicator attribute)

C

calculate_residual_loss (ddf.node.Node attribute) client_id (ddf.mqtt_communication.internal.InternalCommunicator attribute) command (ddf.message.ControlMessage attribute) (ddf.mqtt_communication.message.ControlMessage attribute) communication_threshold (ddf.ant_object_reference.InfoSubscriber attribute) Communicator (class in ddf.communicator) communicator (ddf.lossnode.lossnode.LossNode attribute) (ddf.node.Node attribute) communicators (ddf.communicator.MockCommunicatorBuilder attribute) ControlCommand (class in ddf.message) (class in ddf.mqtt_communication.message)

ControlMessage (class in ddf.message) (class in ddf.mqtt_communication.message) convert_epoch() (in module ddf.object_id_utils) copy() (ddf.information.MVNEstimate method) cost_fn_gradient (ddf.lossnode.lossnode.Neighbor attribute) cov2whitening() (in module ddf.ant_object_reference) covariance (ddf.information.MVNEstimate attribute) (ddf.mqtt_communication.message.InfoMessage attribute) create_ant_object_reference() (ddf.node.Node method) create_uuidv7_from_datetime() (in module ddf.object_id_utils) create_uuidv7_from_epoch() (in module ddf.object_id_utils)

D

ddf module ddf.ant_link module ddf.ant_link.ant_link module ddf.ant_link.external module ddf.ant_link.internal module ddf.ant_link.local module ddf.ant_link.loss_channel module ddf.ant_object_reference module ddf.communicator module ddf.ddf module ddf.information module ddf.lossnode module ddf.lossnode.lossnode module

ddf.measurement module ddf.measurement.gradient_storage module ddf.measurement.measurement module ddf.message module ddf.mqtt_communication module ddf.mqtt_communication.communicator module ddf.mqtt_communication.internal module ddf.mqtt_communication.message module ddf.node module ddf.object_id_utils module ddf.operator module DECLINE (ddf.mqtt_communication.message.ControlCommand attribute) decode() (in module ddf.mqtt_communication.message) default_information_packets (ddf.node.Node attribute)

E

encode() (in module ddf.mqtt_communication.message) evaluate() (ddf.operator.IdentityOperator method) (ddf.operator.LinearOperator method) (ddf.operator.Operator method)

evaluate_operators() (ddf.ant_object_reference.AntObjectReference method) exchange (ddf.message.NodeInfoMessage attribute) exchange_list (ddf.mqtt_communication.message.NodeInfoMessage attribute) exchange_vector (ddf.measurement.measurement.Measurement attribute) ExchangeVector (class in ddf.information)

F

find_object_reference() (ddf.node.Node method) fixed_context (ddf.message.NodeContextMessage attribute) (ddf.mqtt_communication.message.NodeContextMessage attribute) (ddf.node.Node attribute) FREEZE_ZERO_BACKPROP (ddf.mqtt_communication.message.ControlCommand attribute)

from_string() (ddf.ant_link.loss_channel.LossChannel class method) fromdict() (ddf.mqtt_communication.message.Message class method) frozen (ddf.node.Node attribute) FUTURE (ddf.ant_link.loss_channel.FuturePastProbe attribute) FuturePastProbe (class in ddf.ant_link.loss_channel) FZB (ddf.message.ControlCommand attribute)

G

generate_gradient_messages() (ddf.ant_link.ant_link.AntLink method) (ddf.ant_link.external.AntLinkExternal method) (ddf.ant_object_reference.AntObjectReference method) generate_info_message() (ddf.ant_link.external.AntLinkExternal method) (ddf.ant_object_reference.InfoSubscriber method) generate_info_messages() (ddf.ant_object_reference.AntObjectReference method) get_asn1_content_choice() (ddf.mqtt_communication.message.AddNeighborMessage class method) (ddf.mqtt_communication.message.ControlMessage class method) (ddf.mqtt_communication.message.GradientMessage class method) (ddf.mqtt_communication.message.InfoMessage class method) (ddf.mqtt_communication.message.Message class method) (ddf.mqtt_communication.message.NodeContextMessage class method) (ddf.mqtt_communication.message.NodeInfoMessage class method) (ddf.mqtt_communication.message.ProbeResponseMessage class method) get_cov() (ddf.operator.IdentityOperator method) (ddf.operator.Operator method) get_eval_vec_len() (ddf.operator.IdentityOperator method) (ddf.operator.LinearOperator method) (ddf.operator.Operator method) get_exchange_vector() (ddf.operator.Operator method) get_instance() (ddf.communicator.MockCommunicatorBuilder method) get_jacobian() (ddf.operator.IdentityOperator method) (ddf.operator.LinearOperator method) (ddf.operator.Operator method) get_messages() (ddf.communicator.Communicator method) (ddf.communicator.MockCommunicatorBuilder method) (ddf.communicator.MockCommunicatorBuilder.InternalCommunicator method) (ddf.mqtt_communication.communicator.AntCommunicatorMqtt method)

GET_NODE_CONTEXT (ddf.mqtt_communication.message.ControlCommand attribute) GET_NODE_INFO (ddf.mqtt_communication.message.ControlCommand attribute) get_state_info_mat() (ddf.measurement.measurement.Measurement method) get_topic() (ddf.mqtt_communication.message.AddNeighborMessage method) (ddf.mqtt_communication.message.ControlMessage method) (ddf.mqtt_communication.message.GradientMessage method) (ddf.mqtt_communication.message.InfoMessage method) (ddf.mqtt_communication.message.Message method) (ddf.mqtt_communication.message.NodeContextMessage method) (ddf.mqtt_communication.message.NodeInfoMessage method) (ddf.mqtt_communication.message.ProbeResponseMessage method) get_weight_projection_mat() (ddf.ant_object_reference.AntObjectReference method) get_whitening_op() (ddf.information.MVNEstimate method) GetNodeContext (ddf.message.ControlCommand attribute) GetNodeInfo (ddf.message.ControlCommand attribute) gradient (ddf.message.GradientMessage attribute) (ddf.message.ProbeResponseMessage attribute) (ddf.mqtt_communication.message.GradientMessage attribute) (ddf.mqtt_communication.message.ProbeResponseMessage attribute) GRADIENT_MODE (ddf.node.ProcessingMode attribute) gradient_storage (ddf.measurement.measurement.Measurement attribute) gradient_subscriptions (ddf.ant_link.local.AntLinkLocal attribute) gradient_threshold (ddf.ant_link.external.AntLinkExternal attribute) GradientMessage (class in ddf.message) (class in ddf.mqtt_communication.message) GradientStorage (class in ddf.measurement.gradient_storage) GradientSubscription (class in ddf.ant_link.ant_link)

H

history (ddf.node.Node attribute)

I

Id (class in ddf.ddf) id (ddf.ant_link.ant_link.AntLink attribute) IdentityOperator (class in ddf.operator) index (ddf.communicator.MockCommunicatorBuilder.InternalCommunicator attribute) INFO_MODE (ddf.node.ProcessingMode attribute) info_subscribers (ddf.ant_object_reference.AntObjectReference attribute) (ddf.node.Node attribute) InfoMessage (class in ddf.message) (class in ddf.mqtt_communication.message)

InfoSubscriber (class in ddf.ant_object_reference) initial_state (ddf.ant_object_reference.AntObjectReference attribute) (ddf.node.Node attribute) insert_measurement_from_info_message() (ddf.node.Node method) insert_measurement_from_sensor() (ddf.node.Node method) internal_operator (ddf.node.Node attribute) InternalCommunicator (class in ddf.mqtt_communication.internal) InternalState (class in ddf.information)

K

kl_div() (ddf.ant_object_reference.InfoSubscriber method) (in module ddf.ant_object_reference)

L

last_message (ddf.ant_object_reference.InfoSubscriber attribute) LinearOperator (class in ddf.operator) loss_channel (ddf.ant_link.ant_link.GradientSubscription attribute) (ddf.message.GradientMessage attribute) (ddf.message.ProbeResponseMessage attribute) (ddf.mqtt_communication.message.GradientMessage attribute) (ddf.mqtt_communication.message.ProbeResponseMessage attribute)

LossChannel (class in ddf.ant_link.loss_channel) LossNode (class in ddf.lossnode.lossnode) lossref (ddf.ant_link.loss_channel.LossChannel attribute) lower_bound_x (ddf.ant_object_reference.AntObjectReference attribute) lower_bound_x_value (ddf.ant_object_reference.AntObjectReference attribute)

M

max_gradients (ddf.ant_link.external.AntLinkExternal attribute) mean (ddf.information.MVNEstimate attribute) (ddf.mqtt_communication.message.InfoMessage attribute) Measurement (class in ddf.measurement.measurement) measurements (ddf.ant_object_reference.AntObjectReference attribute) Message (class in ddf.message) (class in ddf.mqtt_communication.message) message_counter (ddf.message.InfoMessage attribute) MockCommunicatorBuilder (class in ddf.communicator) MockCommunicatorBuilder.InternalCommunicator (class in ddf.communicator) mode (ddf.ant_link.loss_channel.LossChannel attribute) (ddf.lossnode.lossnode.LossNode attribute) (ddf.node.Node attribute) module ddf ddf.ant_link ddf.ant_link.ant_link ddf.ant_link.external ddf.ant_link.internal ddf.ant_link.local ddf.ant_link.loss_channel ddf.ant_object_reference ddf.communicator ddf.ddf ddf.information ddf.lossnode ddf.lossnode.lossnode ddf.measurement ddf.measurement.gradient_storage ddf.measurement.measurement ddf.message ddf.mqtt_communication ddf.mqtt_communication.communicator ddf.mqtt_communication.internal ddf.mqtt_communication.message ddf.node ddf.object_id_utils ddf.operator

mqtt_host (ddf.mqtt_communication.internal.InternalCommunicator attribute) mqtt_port (ddf.mqtt_communication.internal.InternalCommunicator attribute) MVNEstimate (class in ddf.information)

N

name (ddf.ant_link.loss_channel.LossChannel attribute) Neighbor (class in ddf.lossnode.lossnode) (class in ddf.node) neighbor (ddf.message.AddNeighborMessage attribute) (ddf.mqtt_communication.message.AddNeighborMessage attribute) neighbors (ddf.lossnode.lossnode.LossNode attribute) (ddf.node.Node attribute) Node (class in ddf.node) node_id (ddf.ddf.Id attribute) (ddf.lossnode.lossnode.LossNode attribute) (ddf.lossnode.lossnode.Neighbor attribute) (ddf.node.Neighbor attribute) (ddf.node.Node attribute)

NodeContextMessage (class in ddf.message) (class in ddf.mqtt_communication.message) NodeId (class in ddf.ddf) NodeInfoMessage (class in ddf.message) (class in ddf.mqtt_communication.message)

O

object_id (ddf.ant_object_reference.AntObjectReference attribute) (ddf.ddf.Id attribute) (ddf.message.GradientMessage attribute) (ddf.message.InfoMessage attribute) object_ref_in_past() (ddf.node.Node method) ObjectId (class in ddf.ddf) old_info_messages (ddf.lossnode.lossnode.LossNode attribute) Operator (class in ddf.operator) operator (ddf.ant_object_reference.InfoSubscriber attribute) (ddf.measurement.measurement.Measurement attribute) (ddf.mqtt_communication.message.AddNeighborMessage attribute) (ddf.node.Neighbor attribute)

operator_jacobians() (ddf.ant_object_reference.AntObjectReference method) optimize() (ddf.ant_object_reference.AntObjectReference method) (ddf.node.Node method) optimize_step() (ddf.ant_link.ant_link.AntLink method) (ddf.ant_link.local.AntLinkLocal method) (ddf.measurement.measurement.Measurement method) optimizer_lsqs_method (ddf.ant_object_reference.AntObjectReference attribute)

P

parent (ddf.communicator.MockCommunicatorBuilder.InternalCommunicator attribute) parent_node (ddf.ant_object_reference.AntObjectReference attribute) parent_object_id (ddf.measurement.measurement.Measurement attribute) PAST (ddf.ant_link.loss_channel.FuturePastProbe attribute) peek_messages() (ddf.communicator.MockCommunicatorBuilder.InternalCommunicator method) poll_history_from_object_id() (ddf.node.Node method)

pretty_print_uuid7() (in module ddf.ddf) PROBE (ddf.ant_link.loss_channel.FuturePastProbe attribute) probe_storage (ddf.ant_object_reference.AntObjectReference attribute) ProbeResponseMessage (class in ddf.message) (class in ddf.mqtt_communication.message) ProcessingMode (class in ddf.node)

R

read_datetime_from_uuidv7() (in module ddf.object_id_utils) recipient (ddf.message.Message attribute) (ddf.mqtt_communication.message.Message attribute) reference (ddf.message.ProbeResponseMessage attribute) (ddf.mqtt_communication.message.GradientMessage attribute) (ddf.mqtt_communication.message.InfoMessage attribute) (ddf.mqtt_communication.message.ProbeResponseMessage attribute) req_id (ddf.message.AddNeighborMessage attribute) (ddf.message.NodeContextMessage attribute) (ddf.message.NodeInfoMessage attribute) (ddf.mqtt_communication.message.AddNeighborMessage attribute) (ddf.mqtt_communication.message.ControlMessage attribute) (ddf.mqtt_communication.message.NodeContextMessage attribute) (ddf.mqtt_communication.message.NodeInfoMessage attribute)

request_id (ddf.message.ControlMessage attribute) residual_loss() (ddf.node.Node method) Rprop_step() (in module ddf.ant_link.ant_link) run() (ddf.lossnode.lossnode.LossNode method) (ddf.node.Node method)

S

send_message() (ddf.communicator.Communicator method) (ddf.communicator.MockCommunicatorBuilder method) (ddf.communicator.MockCommunicatorBuilder.InternalCommunicator method) (ddf.mqtt_communication.communicator.AntCommunicatorMqtt method) (ddf.mqtt_communication.internal.InternalCommunicator method) sender (ddf.message.Message attribute) (ddf.mqtt_communication.message.Message attribute) set_available_labels() (ddf.node.Node method) set_gradients_to_zero() (ddf.measurement.measurement.Measurement method) set_user_context() (ddf.node.Node method) softmax() (ddf.ant_object_reference.AntObjectReference method) solve() (ddf.ant_object_reference.AntObjectReference method) (ddf.node.Node method)

solver (ddf.ant_link.ant_link.GradientSubscription attribute) solver_state (ddf.ant_link.ant_link.GradientSubscription attribute) source (ddf.ant_object_reference.InfoSubscriber attribute) (ddf.measurement.measurement.Measurement attribute) start() (ddf.mqtt_communication.internal.InternalCommunicator method) state (ddf.ant_object_reference.AntObjectReference attribute) (ddf.message.InfoMessage attribute) state_jacobian (ddf.measurement.measurement.Measurement attribute) step() (ddf.lossnode.lossnode.LossNode method) (ddf.node.Node method) stop() (ddf.mqtt_communication.internal.InternalCommunicator method) storage (ddf.measurement.gradient_storage.GradientStorage attribute)

T

test_send() (ddf.mqtt_communication.internal.InternalCommunicator method) to_string() (ddf.ant_link.loss_channel.LossChannel method) translate() (ddf.mqtt_communication.message.AddNeighborMessage class method) (ddf.mqtt_communication.message.ControlMessage class method) (ddf.mqtt_communication.message.GradientMessage class method) (ddf.mqtt_communication.message.InfoMessage class method) (ddf.mqtt_communication.message.Message class method) (ddf.mqtt_communication.message.NodeContextMessage class method) (ddf.mqtt_communication.message.NodeInfoMessage class method) (ddf.mqtt_communication.message.ProbeResponseMessage class method)

translate_mode() (in module ddf.mqtt_communication.communicator) translate_mode_inv() (in module ddf.mqtt_communication.communicator)

U

up_to_date (ddf.ant_object_reference.AntObjectReference attribute) update() (ddf.ant_object_reference.AntObjectReference method) (ddf.ant_object_reference.InfoSubscriber method) update_counter (ddf.ant_link.external.AntLinkExternal attribute) update_number (ddf.mqtt_communication.message.GradientMessage attribute) (ddf.mqtt_communication.message.InfoMessage attribute) UPDATE_UNFREEZE_INFORMATION (ddf.mqtt_communication.message.ControlCommand attribute) upper_bound_x (ddf.ant_object_reference.AntObjectReference attribute)

upper_bound_x_value (ddf.ant_object_reference.AntObjectReference attribute) user_context (ddf.message.NodeContextMessage attribute) (ddf.mqtt_communication.message.NodeContextMessage attribute) (ddf.node.Node attribute) UUI (ddf.message.ControlCommand attribute) uuid (ddf.ddf.NodeId attribute) (ddf.ddf.ObjectId attribute) UUID_VERSION (in module ddf.ddf)

V

visualize() (ddf.node.Node method)

W

weighted_inference() (ddf.ant_object_reference.AntObjectReference method)

Z

zero_non_timestamp_fields() (in module ddf.object_id_utils)

zerogradients() (ddf.node.Node method)