src

• ddf package
  • Subpackages
    • ddf.ant_link package
      • Submodules
      • 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
      • Module contents
    • ddf.lossnode package
      • Submodules
      • ddf.lossnode.lossnode module
      • Module contents
    • ddf.measurement package
      • Submodules
      • ddf.measurement.gradient_storage module
      • ddf.measurement.measurement module
      • Module contents
    • ddf.mqtt_communication package
      • Submodules
      • ddf.mqtt_communication.communicator module
      • ddf.mqtt_communication.internal module
      • ddf.mqtt_communication.message module
      • Module contents
  • Submodules
  • ddf.ant_object_reference module
    • AntObjectReference
      • AntObjectReference.add_new_measurement()
      • AntObjectReference.backpropagate()
      • AntObjectReference.backpropagate_from_neighbor()
      • AntObjectReference.evaluate_operators()
      • AntObjectReference.generate_gradient_messages()
      • AntObjectReference.generate_info_messages()
      • AntObjectReference.get_weight_projection_mat()
      • AntObjectReference.info_subscribers
      • AntObjectReference.initial_state
      • AntObjectReference.lower_bound_x
      • AntObjectReference.lower_bound_x_value
      • AntObjectReference.measurements
      • AntObjectReference.object_id
      • AntObjectReference.operator_jacobians()
      • AntObjectReference.optimize()
      • AntObjectReference.optimizer_lsqs_method
      • AntObjectReference.parent_node
      • AntObjectReference.probe_storage
      • AntObjectReference.softmax()
      • AntObjectReference.solve()
      • AntObjectReference.state
      • AntObjectReference.up_to_date
      • AntObjectReference.update()
      • AntObjectReference.upper_bound_x
      • AntObjectReference.upper_bound_x_value
      • AntObjectReference.weighted_inference()
    • InfoSubscriber
      • InfoSubscriber.communication_threshold
      • InfoSubscriber.generate_info_message()
      • InfoSubscriber.kl_div()
      • InfoSubscriber.last_message
      • InfoSubscriber.operator
      • InfoSubscriber.source
      • InfoSubscriber.update()
    • cov2whitening()
    • kl_div()
  • ddf.communicator module
    • Communicator
      • Communicator.get_messages()
      • Communicator.send_message()
    • MockCommunicatorBuilder
      • MockCommunicatorBuilder.InternalCommunicator
      • MockCommunicatorBuilder.communicators
      • MockCommunicatorBuilder.get_instance()
      • MockCommunicatorBuilder.get_messages()
      • MockCommunicatorBuilder.send_message()
  • ddf.ddf module
    • Id
      • Id.node_id
      • Id.object_id
    • NodeId
      • NodeId.uuid
    • ObjectId
      • ObjectId.uuid
    • UUID_VERSION
    • pretty_print_uuid7()
  • ddf.information module
    • ExchangeVector
    • InternalState
    • MVNEstimate
      • MVNEstimate.copy()
      • MVNEstimate.covariance
      • MVNEstimate.get_whitening_op()
      • MVNEstimate.mean
  • ddf.message module
    • AddNeighborMessage
      • AddNeighborMessage.neighbor
      • AddNeighborMessage.req_id
    • ControlCommand
      • ControlCommand.FZB
      • ControlCommand.GetNodeContext
      • ControlCommand.GetNodeInfo
      • ControlCommand.UUI
    • ControlMessage
      • ControlMessage.command
      • ControlMessage.request_id
    • GradientMessage
      • GradientMessage.gradient
      • GradientMessage.loss_channel
      • GradientMessage.object_id
    • InfoMessage
      • InfoMessage.message_counter
      • InfoMessage.object_id
      • InfoMessage.state
    • Message
      • Message.recipient
      • Message.sender
    • NodeContextMessage
      • NodeContextMessage.fixed_context
      • NodeContextMessage.req_id
      • NodeContextMessage.user_context
    • NodeInfoMessage
      • NodeInfoMessage.alias
      • NodeInfoMessage.available
      • NodeInfoMessage.exchange
      • NodeInfoMessage.req_id
    • ProbeResponseMessage
      • ProbeResponseMessage.gradient
      • ProbeResponseMessage.loss_channel
      • ProbeResponseMessage.reference
  • ddf.node module
    • Neighbor
      • Neighbor.node_id
      • Neighbor.operator
    • Node
      • Node.add_info_subscriber()
      • Node.add_neighbor()
      • Node.alias
      • Node.available_labels
      • Node.calculate_residual_loss
      • Node.communicator
      • Node.create_ant_object_reference()
      • Node.default_information_packets
      • Node.find_object_reference()
      • Node.fixed_context
      • Node.frozen
      • Node.history
      • Node.info_subscribers
      • Node.initial_state
      • Node.insert_measurement_from_info_message()
      • Node.insert_measurement_from_sensor()
      • Node.internal_operator
      • Node.mode
      • Node.neighbors
      • Node.node_id
      • Node.object_ref_in_past()
      • Node.optimize()
      • Node.poll_history_from_object_id()
      • Node.residual_loss()
      • Node.run()
      • Node.set_available_labels()
      • Node.set_user_context()
      • Node.solve()
      • Node.step()
      • Node.user_context
      • Node.visualize()
      • Node.zerogradients()
    • ProcessingMode
      • ProcessingMode.GRADIENT_MODE
      • ProcessingMode.INFO_MODE
  • ddf.object_id_utils module
    • convert_epoch()
    • create_uuidv7_from_datetime()
    • create_uuidv7_from_epoch()
    • read_datetime_from_uuidv7()
    • zero_non_timestamp_fields()
  • ddf.operator module
    • IdentityOperator
      • IdentityOperator.evaluate()
      • IdentityOperator.get_cov()
      • IdentityOperator.get_eval_vec_len()
      • IdentityOperator.get_jacobian()
    • LinearOperator
      • LinearOperator.evaluate()
      • LinearOperator.get_eval_vec_len()
      • LinearOperator.get_jacobian()
    • Operator
      • Operator.evaluate()
      • Operator.get_cov()
      • Operator.get_eval_vec_len()
      • Operator.get_exchange_vector()
      • Operator.get_jacobian()
  • Module contents