Index

_

_addr_to_future (p2pfl.learning.frameworks.simulation.actor_pool.SuperActorPool attribute)

_instance (p2pfl.learning.frameworks.simulation.actor_pool.SuperActorPool attribute) _lock (p2pfl.learning.frameworks.simulation.actor_pool.SuperActorPool attribute)

A

actor_to_remove (p2pfl.learning.frameworks.simulation.actor_pool.SuperActorPool attribute) add() (p2pfl.communication.protocols.protobuff.neighbors.Neighbors method) add_actor() (p2pfl.learning.frameworks.simulation.actor_pool.SuperActorPool method) add_callback_info_to_model() (p2pfl.learning.frameworks.learner.Learner method) (p2pfl.learning.frameworks.simulation.virtual_learner.VirtualNodeLearner method) add_command() (p2pfl.communication.protocols.communication_protocol.CommunicationProtocol method) (p2pfl.communication.protocols.protobuff.protobuff_communication_protocol.ProtobuffCommunicationProtocol method) (p2pfl.communication.protocols.protobuff.server.ProtobuffServer method) add_handler() (p2pfl.management.logger.logger.P2PFLogger method) add_info() (p2pfl.learning.frameworks.p2pfl_model.P2PFLModel method) add_log() (p2pfl.management.metric_storage.GlobalMetricStorage method) (p2pfl.management.metric_storage.LocalMetricStorage method) add_message() (p2pfl.communication.protocols.protobuff.gossiper.Gossiper method) (p2pfl.management.message_storage.MessageStorage method) add_model() (p2pfl.learning.aggregators.aggregator.Aggregator method) add_NodeServicesServicer_to_server() (in module p2pfl.communication.protocols.protobuff.proto.node_pb2_grpc) addr (p2pfl.node_state.NodeState attribute) AddressCounter (class in p2pfl.communication.protocols.protobuff.memory.server) AddressParser (class in p2pfl.communication.protocols.protobuff.grpc.address) aggregate() (p2pfl.learning.aggregators.aggregator.Aggregator method) (p2pfl.learning.aggregators.fedadagrad.FedAdagrad method) (p2pfl.learning.aggregators.fedadam.FedAdam method) (p2pfl.learning.aggregators.fedavg.FedAvg method) (p2pfl.learning.aggregators.fedmedian.FedMedian method) (p2pfl.learning.aggregators.fedprox.FedProx method) (p2pfl.learning.aggregators.fedyogi.FedYogi method) (p2pfl.learning.aggregators.krum.Krum method) (p2pfl.learning.aggregators.scaffold.Scaffold method)

AGGREGATION_TIMEOUT (p2pfl.settings.Training attribute) Aggregator (class in p2pfl.learning.aggregators.aggregator) AMOUNT_LAST_MESSAGES_SAVED (p2pfl.settings.Gossip attribute) apply() (p2pfl.learning.compression.manager.CompressionManager static method) apply_gradients() (p2pfl.learning.frameworks.tensorflow.callbacks.scaffold_callback.ScaffoldOptimizerWrapper method) apply_strategy() (p2pfl.learning.compression.base_compression_strategy.ByteCompressor method) (p2pfl.learning.compression.base_compression_strategy.CompressionStrategy method) (p2pfl.learning.compression.base_compression_strategy.TensorCompressor method) (p2pfl.learning.compression.dp_strategy.DifferentialPrivacyCompressor method) (p2pfl.learning.compression.lra_strategy.LowRankApproximation method) (p2pfl.learning.compression.lzma_strategy.LZMACompressor method) (p2pfl.learning.compression.quantization_strategy.PTQuantization method) (p2pfl.learning.compression.topk_strategy.TopKSparsification method) (p2pfl.learning.compression.zlib_strategy.ZlibCompressor method) assert_running() (p2pfl.node.Node method)

B

BASE_DIR (p2pfl.settings.SSL attribute) beat() (p2pfl.communication.protocols.protobuff.heartbeater.Heartbeater method) bluid_client() (p2pfl.communication.protocols.protobuff.grpc.GrpcCommunicationProtocol method) (p2pfl.communication.protocols.protobuff.memory.MemoryCommunicationProtocol method) (p2pfl.communication.protocols.protobuff.protobuff_communication_protocol.ProtobuffCommunicationProtocol method) broadcast() (p2pfl.communication.protocols.communication_protocol.CommunicationProtocol method) (p2pfl.communication.protocols.protobuff.protobuff_communication_protocol.ProtobuffCommunicationProtocol method) build_copy() (p2pfl.learning.frameworks.flax.flax_model.FlaxModel method) (p2pfl.learning.frameworks.p2pfl_model.P2PFLModel method)

build_msg() (p2pfl.communication.protocols.communication_protocol.CommunicationProtocol method) (p2pfl.communication.protocols.protobuff.protobuff_communication_protocol.ProtobuffCommunicationProtocol method) build_server() (p2pfl.communication.protocols.protobuff.grpc.GrpcCommunicationProtocol method) (p2pfl.communication.protocols.protobuff.memory.MemoryCommunicationProtocol method) (p2pfl.communication.protocols.protobuff.protobuff_communication_protocol.ProtobuffCommunicationProtocol method) build_weights() (p2pfl.communication.protocols.communication_protocol.CommunicationProtocol method) (p2pfl.communication.protocols.protobuff.protobuff_communication_protocol.ProtobuffCommunicationProtocol method) ByteCompressor (class in p2pfl.learning.compression.base_compression_strategy)

C

CA_CRT (p2pfl.settings.SSL attribute) CallbackFactory (class in p2pfl.learning.frameworks.callback_factory) check_and_set_processed() (p2pfl.communication.protocols.protobuff.gossiper.Gossiper method) check_early_stop() (in module p2pfl.stages.stage) cleanup() (p2pfl.management.logger.logger.P2PFLogger method) clear() (p2pfl.learning.aggregators.aggregator.Aggregator method) (p2pfl.node_state.NodeState method) clear_neighbors() (p2pfl.communication.protocols.protobuff.neighbors.Neighbors method) CLIENT_CRT (p2pfl.settings.SSL attribute) CLIENT_KEY (p2pfl.settings.SSL attribute) ColoredFormatter (class in p2pfl.management.logger.logger) Command (class in p2pfl.communication.commands.command) CommunicationError

CommunicationProtocol (class in p2pfl.communication.protocols.communication_protocol) CompressionManager (class in p2pfl.learning.compression.manager) CompressionStrategy (class in p2pfl.learning.compression.base_compression_strategy) connect() (p2pfl.communication.protocols.communication_protocol.CommunicationProtocol method) (p2pfl.communication.protocols.protobuff.client.ProtobuffClient method) (p2pfl.communication.protocols.protobuff.grpc.client.GrpcClient method) (p2pfl.communication.protocols.protobuff.memory.client.MemoryClient method) (p2pfl.communication.protocols.protobuff.protobuff_communication_protocol.ProtobuffCommunicationProtocol method) (p2pfl.node.Node method) connect_web() (p2pfl.management.logger.logger.P2PFLogger method) create_actor() (p2pfl.learning.frameworks.simulation.actor_pool.SuperActorPool method) create_callbacks() (p2pfl.learning.frameworks.callback_factory.CallbackFactory class method) create_learner() (p2pfl.learning.frameworks.learner_factory.LearnerFactory class method) critical() (p2pfl.management.logger.logger.P2PFLogger method)

D

DataExportStrategy (class in p2pfl.learning.dataset.p2pfl_dataset) DataPartitionStrategy (class in p2pfl.learning.dataset.partition_strategies) debug() (p2pfl.management.logger.logger.P2PFLogger method) decode_parameters() (p2pfl.learning.frameworks.flax.flax_model.FlaxModel method) (p2pfl.learning.frameworks.p2pfl_model.P2PFLModel method) DecodingParamsError DEFAULT_BATCH_SIZE (p2pfl.settings.Training attribute) description (p2pfl.management.cli.ExampleInfo attribute) DifferentialPrivacyCompressor (class in p2pfl.learning.compression.dp_strategy) DirichletPartitionStrategy (class in p2pfl.learning.dataset.partition_strategies)

DISABLE_RAY (p2pfl.settings.General attribute) disconnect() (p2pfl.communication.protocols.communication_protocol.CommunicationProtocol method) (p2pfl.communication.protocols.protobuff.client.ProtobuffClient method) (p2pfl.communication.protocols.protobuff.grpc.client.GrpcClient method) (p2pfl.communication.protocols.protobuff.memory.client.MemoryClient method) (p2pfl.communication.protocols.protobuff.proto.node_pb2_grpc.NodeServices static method) (p2pfl.communication.protocols.protobuff.proto.node_pb2_grpc.NodeServicesServicer method) (p2pfl.communication.protocols.protobuff.protobuff_communication_protocol.ProtobuffCommunicationProtocol method) (p2pfl.communication.protocols.protobuff.server.ProtobuffServer method) (p2pfl.node.Node method)

E

EarlyStopException encode_parameters() (p2pfl.learning.frameworks.flax.flax_model.FlaxModel method) (p2pfl.learning.frameworks.p2pfl_model.P2PFLModel method) error() (p2pfl.management.logger.logger.P2PFLogger method) evaluate() (p2pfl.learning.frameworks.flax.flax_learner.FlaxLearner method) (p2pfl.learning.frameworks.learner.Learner method) (p2pfl.learning.frameworks.pytorch.lightning_learner.LightningLearner method) (p2pfl.learning.frameworks.simulation.virtual_learner.VirtualNodeLearner method) (p2pfl.learning.frameworks.tensorflow.keras_learner.KerasLearner method) ExampleInfo (class in p2pfl.management.cli) EXCLUDE_BEAT_LOGS (p2pfl.settings.Heartbeat attribute) execute() (p2pfl.communication.commands.command.Command method) (p2pfl.communication.commands.message.heartbeat_command.HeartbeatCommand method) (p2pfl.communication.commands.message.metrics_command.MetricsCommand method) (p2pfl.communication.commands.message.model_initialized_command.ModelInitializedCommand method) (p2pfl.communication.commands.message.models_agregated_command.ModelsAggregatedCommand method) (p2pfl.communication.commands.message.models_ready_command.ModelsReadyCommand method) (p2pfl.communication.commands.message.pre_send_model_command.PreSendModelCommand method) (p2pfl.communication.commands.message.start_learning_command.StartLearningCommand method) (p2pfl.communication.commands.message.stop_learning_command.StopLearningCommand method) (p2pfl.communication.commands.message.vote_train_set_command.VoteTrainSetCommand method) (p2pfl.communication.commands.weights.full_model_command.FullModelCommand method) (p2pfl.communication.commands.weights.init_model_command.InitModelCommand method) (p2pfl.communication.commands.weights.partial_model_command.PartialModelCommand method) (p2pfl.stages.base_node.gossip_model_stage.GossipModelStage static method) (p2pfl.stages.base_node.round_finished_stage.RoundFinishedStage static method) (p2pfl.stages.base_node.start_learning_stage.StartLearningStage static method) (p2pfl.stages.base_node.train_stage.TrainStage static method) (p2pfl.stages.base_node.vote_train_set_stage.VoteTrainSetStage static method) (p2pfl.stages.base_node.wait_agg_models_stage.WaitAggregatedModelsStage static method) (p2pfl.stages.stage.Stage static method)

exists() (p2pfl.communication.protocols.protobuff.neighbors.Neighbors method) EXIT_ON_X_EQUAL_ROUNDS (p2pfl.settings.Gossip attribute) exp_name (p2pfl.experiment.Experiment attribute) (p2pfl.node_state.NodeState attribute) (p2pfl.node_state.NodeState property) Experiment (class in p2pfl.experiment) experiment_finished() (p2pfl.management.logger.logger.P2PFLogger method) experiment_started() (p2pfl.management.logger.logger.P2PFLogger method) experiment_updated() (p2pfl.management.logger.logger.P2PFLogger method) export() (p2pfl.learning.dataset.p2pfl_dataset.DataExportStrategy static method) (p2pfl.learning.dataset.p2pfl_dataset.P2PFLDataset method) (p2pfl.learning.frameworks.flax.flax_dataset.FlaxExportStrategy static method) (p2pfl.learning.frameworks.pytorch.lightning_dataset.PyTorchExportStrategy static method) (p2pfl.learning.frameworks.tensorflow.keras_dataset.KerasExportStrategy static method)

F

FedAdagrad (class in p2pfl.learning.aggregators.fedadagrad) FedAdam (class in p2pfl.learning.aggregators.fedadam) FedAvg (class in p2pfl.learning.aggregators.fedavg) FederatedLogger (class in p2pfl.learning.frameworks.pytorch.lightning_logger) (class in p2pfl.learning.frameworks.tensorflow.callbacks.keras_logger) FedMedian (class in p2pfl.learning.aggregators.fedmedian) FedProx (class in p2pfl.learning.aggregators.fedprox) FedProxCallback (class in p2pfl.learning.frameworks.pytorch.callbacks.fedprox_callback) FedYogi (class in p2pfl.learning.aggregators.fedyogi) finalize() (p2pfl.learning.frameworks.pytorch.lightning_logger.FederatedLogger method) fit() (p2pfl.learning.frameworks.flax.flax_learner.FlaxLearner method) (p2pfl.learning.frameworks.learner.Learner method) (p2pfl.learning.frameworks.pytorch.lightning_learner.LightningLearner method) (p2pfl.learning.frameworks.simulation.virtual_learner.VirtualNodeLearner method) (p2pfl.learning.frameworks.tensorflow.keras_learner.KerasLearner method)

FLAX (p2pfl.learning.frameworks.Framework attribute) flax_model (p2pfl.learning.frameworks.flax.flax_learner.FlaxLearner property) FlaxExportStrategy (class in p2pfl.learning.frameworks.flax.flax_dataset) FlaxLearner (class in p2pfl.learning.frameworks.flax.flax_learner) FlaxModel (class in p2pfl.learning.frameworks.flax.flax_model) format() (p2pfl.management.logger.logger.ColoredFormatter method) Framework (class in p2pfl.learning.frameworks) from_csv() (p2pfl.learning.dataset.p2pfl_dataset.P2PFLDataset class method) from_generator() (p2pfl.learning.dataset.p2pfl_dataset.P2PFLDataset class method) from_huggingface() (p2pfl.learning.dataset.p2pfl_dataset.P2PFLDataset class method) from_json() (p2pfl.learning.dataset.p2pfl_dataset.P2PFLDataset class method) from_pandas() (p2pfl.learning.dataset.p2pfl_dataset.P2PFLDataset class method) from_parquet() (p2pfl.learning.dataset.p2pfl_dataset.P2PFLDataset class method) FullModelCommand (class in p2pfl.communication.commands.weights.full_model_command)

G

General (class in p2pfl.settings) general (p2pfl.settings.Settings attribute) generate_partitions() (p2pfl.learning.dataset.p2pfl_dataset.P2PFLDataset method) (p2pfl.learning.dataset.partition_strategies.DataPartitionStrategy static method) (p2pfl.learning.dataset.partition_strategies.DirichletPartitionStrategy class method) (p2pfl.learning.dataset.partition_strategies.LabelSkewedPartitionStrategy static method) (p2pfl.learning.dataset.partition_strategies.RandomIIDPartitionStrategy static method) generate_train_test_split() (p2pfl.learning.dataset.p2pfl_dataset.P2PFLDataset method) get() (p2pfl.communication.protocols.protobuff.memory.server.AddressCounter method) (p2pfl.communication.protocols.protobuff.neighbors.Neighbors method) (p2pfl.learning.dataset.p2pfl_dataset.P2PFLDataset method) get_address() (p2pfl.communication.protocols.communication_protocol.CommunicationProtocol method) get_aggregated_models() (p2pfl.learning.aggregators.aggregator.Aggregator method) get_all() (p2pfl.communication.protocols.protobuff.neighbors.Neighbors method) get_all_logs() (p2pfl.management.metric_storage.GlobalMetricStorage method) (p2pfl.management.metric_storage.LocalMetricStorage method) get_contributors() (p2pfl.learning.frameworks.p2pfl_model.P2PFLModel method) get_data() (p2pfl.learning.frameworks.learner.Learner method) (p2pfl.learning.frameworks.simulation.virtual_learner.VirtualNodeLearner method) (p2pfl.node.Node method) get_experiment_logs() (p2pfl.management.metric_storage.GlobalMetricStorage method) (p2pfl.management.metric_storage.LocalMetricStorage method) get_experiment_node_logs() (p2pfl.management.metric_storage.GlobalMetricStorage method) get_experiment_round_logs() (p2pfl.management.metric_storage.LocalMetricStorage method) get_experiment_round_node_logs() (p2pfl.management.metric_storage.LocalMetricStorage method) get_framework() (p2pfl.learning.frameworks.flax.flax_learner.FlaxLearner method) (p2pfl.learning.frameworks.flax.flax_model.FlaxModel method) (p2pfl.learning.frameworks.learner.Learner method) (p2pfl.learning.frameworks.p2pfl_model.P2PFLModel method) (p2pfl.learning.frameworks.pytorch.lightning_learner.LightningLearner method) (p2pfl.learning.frameworks.pytorch.lightning_model.LightningModel method) (p2pfl.learning.frameworks.simulation.virtual_learner.VirtualNodeLearner method) (p2pfl.learning.frameworks.tensorflow.keras_learner.KerasLearner method) (p2pfl.learning.frameworks.tensorflow.keras_model.KerasModel method) get_global_logs() (p2pfl.management.logger.logger.P2PFLogger method) get_info() (p2pfl.learning.frameworks.callback.P2PFLCallback method) (p2pfl.learning.frameworks.p2pfl_model.P2PFLModel method) get_learner_result() (p2pfl.learning.frameworks.simulation.actor_pool.SuperActorPool method) get_level() (p2pfl.management.logger.logger.P2PFLogger method) get_level_name() (p2pfl.management.logger.logger.P2PFLogger method) get_local_logs() (p2pfl.management.logger.logger.P2PFLogger method) get_logs() (p2pfl.management.node_monitor.NodeMonitor method) get_messages() (p2pfl.management.logger.logger.P2PFLogger method) (p2pfl.management.message_storage.MessageStorage method) get_missing_models() (p2pfl.learning.aggregators.aggregator.Aggregator method) get_mnist() (p2pfl.learning.frameworks.pytorch.lightning_dataset.TorchvisionDatasetFactory static method) get_model() (p2pfl.learning.aggregators.aggregator.Aggregator method) (p2pfl.learning.frameworks.learner.Learner method) (p2pfl.learning.frameworks.p2pfl_model.P2PFLModel method) (p2pfl.learning.frameworks.simulation.virtual_learner.VirtualNodeLearner method) (p2pfl.node.Node method)

get_name() (p2pfl.communication.commands.command.Command static method) (p2pfl.communication.commands.message.heartbeat_command.HeartbeatCommand static method) (p2pfl.communication.commands.message.metrics_command.MetricsCommand static method) (p2pfl.communication.commands.message.model_initialized_command.ModelInitializedCommand static method) (p2pfl.communication.commands.message.models_agregated_command.ModelsAggregatedCommand static method) (p2pfl.communication.commands.message.models_ready_command.ModelsReadyCommand static method) (p2pfl.communication.commands.message.pre_send_model_command.PreSendModelCommand static method) (p2pfl.communication.commands.message.start_learning_command.StartLearningCommand static method) (p2pfl.communication.commands.message.stop_learning_command.StopLearningCommand static method) (p2pfl.communication.commands.message.vote_train_set_command.VoteTrainSetCommand static method) (p2pfl.communication.commands.weights.full_model_command.FullModelCommand static method) (p2pfl.communication.commands.weights.init_model_command.InitModelCommand static method) (p2pfl.communication.commands.weights.partial_model_command.PartialModelCommand static method) (p2pfl.learning.frameworks.callback.P2PFLCallback static method) (p2pfl.learning.frameworks.pytorch.callbacks.fedprox_callback.FedProxCallback static method) (p2pfl.learning.frameworks.pytorch.callbacks.scaffold_callback.SCAFFOLDCallback static method) (p2pfl.learning.frameworks.tensorflow.callbacks.keras_logger.FederatedLogger static method) (p2pfl.learning.frameworks.tensorflow.callbacks.scaffold_callback.SCAFFOLDCallback static method) get_neighbors() (p2pfl.communication.protocols.communication_protocol.CommunicationProtocol method) (p2pfl.communication.protocols.protobuff.protobuff_communication_protocol.ProtobuffCommunicationProtocol method) (p2pfl.node.Node method) get_nodes() (p2pfl.management.logger.logger.P2PFLogger method) get_num_samples() (p2pfl.learning.dataset.p2pfl_dataset.P2PFLDataset method) (p2pfl.learning.frameworks.p2pfl_model.P2PFLModel method) get_parameters() (p2pfl.learning.frameworks.flax.flax_model.FlaxModel method) (p2pfl.learning.frameworks.p2pfl_model.P2PFLModel method) (p2pfl.learning.frameworks.pytorch.lightning_model.LightningModel method) (p2pfl.learning.frameworks.tensorflow.keras_model.KerasModel method) get_parsed_address() (p2pfl.communication.protocols.protobuff.grpc.address.AddressParser method) get_pending_actions() (p2pfl.management.p2pfl_web_services.P2pflWebServices method) get_received_messages() (p2pfl.management.message_storage.MessageStorage method) get_registry() (p2pfl.learning.compression.manager.CompressionManager static method) get_required_callbacks() (p2pfl.learning.aggregators.aggregator.Aggregator method) (p2pfl.learning.aggregators.fedprox.FedProx method) (p2pfl.learning.aggregators.scaffold.Scaffold method) get_sent_messages() (p2pfl.management.message_storage.MessageStorage method) get_stage() (p2pfl.stages.stage_factory.StageFactory static method) get_system_metrics() (p2pfl.management.logger.logger.P2PFLogger method) GlobalMetricStorage (class in p2pfl.management.metric_storage) Gossip (class in p2pfl.settings) gossip (p2pfl.settings.Settings attribute) gossip_weights() (p2pfl.communication.protocols.communication_protocol.CommunicationProtocol method) (p2pfl.communication.protocols.protobuff.gossiper.Gossiper method) (p2pfl.communication.protocols.protobuff.protobuff_communication_protocol.ProtobuffCommunicationProtocol method) Gossiper (class in p2pfl.communication.protocols.protobuff.gossiper) GossipModelStage (class in p2pfl.stages.base_node.gossip_model_stage) GRPC_TIMEOUT (p2pfl.settings.General attribute) GrpcClient (class in p2pfl.communication.protocols.protobuff.grpc.client) GrpcCommunicationProtocol (class in p2pfl.communication.protocols.protobuff.grpc) GrpcServer (class in p2pfl.communication.protocols.protobuff.grpc.server)

H

handshake() (p2pfl.communication.protocols.protobuff.proto.node_pb2_grpc.NodeServices static method) (p2pfl.communication.protocols.protobuff.proto.node_pb2_grpc.NodeServicesServicer method) (p2pfl.communication.protocols.protobuff.server.ProtobuffServer method) has_temporal_connection() (p2pfl.communication.protocols.protobuff.client.ProtobuffClient method)

Heartbeat (class in p2pfl.settings) heartbeat (p2pfl.settings.Settings attribute) HeartbeatCommand (class in p2pfl.communication.commands.message.heartbeat_command) Heartbeater (class in p2pfl.communication.protocols.protobuff.heartbeater)

I

increase_round() (p2pfl.experiment.Experiment method) (p2pfl.node_state.NodeState method) indicate_aggregator() (p2pfl.learning.frameworks.learner.Learner method) (p2pfl.learning.frameworks.simulation.virtual_learner.VirtualNodeLearner method) info() (p2pfl.management.logger.logger.P2PFLogger method) initialized (p2pfl.learning.frameworks.simulation.actor_pool.SuperActorPool attribute) InitModelCommand (class in p2pfl.communication.commands.weights.init_model_command) interrupt_fit() (p2pfl.learning.frameworks.flax.flax_learner.FlaxLearner method) (p2pfl.learning.frameworks.learner.Learner method) (p2pfl.learning.frameworks.pytorch.lightning_learner.LightningLearner method) (p2pfl.learning.frameworks.simulation.virtual_learner.VirtualNodeLearner method) (p2pfl.learning.frameworks.tensorflow.keras_learner.KerasLearner method)

is_connected() (p2pfl.communication.protocols.protobuff.client.ProtobuffClient method) (p2pfl.communication.protocols.protobuff.grpc.client.GrpcClient method) (p2pfl.communication.protocols.protobuff.memory.client.MemoryClient method) is_running() (p2pfl.communication.protocols.protobuff.grpc.server.GrpcServer method) (p2pfl.communication.protocols.protobuff.memory.server.MemoryServer method) (p2pfl.communication.protocols.protobuff.server.ProtobuffServer method)

K

KerasExportStrategy (class in p2pfl.learning.frameworks.tensorflow.keras_dataset) KerasLearner (class in p2pfl.learning.frameworks.tensorflow.keras_learner)

KerasModel (class in p2pfl.learning.frameworks.tensorflow.keras_model) Krum (class in p2pfl.learning.aggregators.krum)

L

LabelSkewedPartitionStrategy (class in p2pfl.learning.dataset.partition_strategies) Learner (class in p2pfl.learning.frameworks.learner) learner (p2pfl.node_state.NodeState attribute) LearnerFactory (class in p2pfl.learning.frameworks.learner_factory) LearnerRunningException LearningWorkflow (class in p2pfl.stages.workflows) LightningLearner (class in p2pfl.learning.frameworks.pytorch.lightning_learner) LightningModel (class in p2pfl.learning.frameworks.pytorch.lightning_model) list_examples() (in module p2pfl.management.cli) load_by_package_and_name() (in module p2pfl.management.launch_from_yaml) LocalDPCompressor (in module p2pfl.learning.compression.dp_strategy) LocalMetricStorage (class in p2pfl.management.metric_storage)

lock (p2pfl.learning.frameworks.simulation.actor_pool.SuperActorPool attribute) log() (p2pfl.management.logger.logger.P2PFLogger method) log_communication() (p2pfl.management.logger.logger.P2PFLogger method) LOG_DIR (p2pfl.settings.General attribute) log_hyperparams() (p2pfl.learning.frameworks.pytorch.lightning_logger.FederatedLogger method) LOG_LEVEL (p2pfl.settings.General attribute) log_metric() (p2pfl.management.logger.logger.P2PFLogger method) log_metrics() (p2pfl.learning.frameworks.pytorch.lightning_logger.FederatedLogger method) log_successful_send() (p2pfl.communication.protocols.protobuff.client.ProtobuffClient method) login() (in module p2pfl.management.cli) LowRankApproximation (class in p2pfl.learning.compression.lra_strategy) LZMACompressor (class in p2pfl.learning.compression.lzma_strategy)

M

MAX_LOG_RUNS (p2pfl.settings.General attribute) MemoryClient (class in p2pfl.communication.protocols.protobuff.memory.client) MemoryCommunicationProtocol (class in p2pfl.communication.protocols.protobuff.memory) MemoryServer (class in p2pfl.communication.protocols.protobuff.memory.server) MESSAGES_PER_PERIOD (p2pfl.settings.Gossip attribute) MessageStorage (class in p2pfl.management.message_storage) MetricsCommand (class in p2pfl.communication.commands.message.metrics_command) MODE_EXPECTATION_TIMEOUT (p2pfl.settings.Gossip attribute) model_initialized_lock (p2pfl.node_state.NodeState attribute) ModelInitializedCommand (class in p2pfl.communication.commands.message.model_initialized_command) ModelNotBuiltError ModelNotMatchingError models_aggregated (p2pfl.node_state.NodeState attribute) MODELS_PER_ROUND (p2pfl.settings.Gossip attribute) MODELS_PERIOD (p2pfl.settings.Gossip attribute) ModelsAggregatedCommand (class in p2pfl.communication.commands.message.models_agregated_command) ModelsReadyCommand (class in p2pfl.communication.commands.message.models_ready_command) module p2pfl p2pfl.communication p2pfl.communication.commands p2pfl.communication.commands.command p2pfl.communication.commands.message p2pfl.communication.commands.message.heartbeat_command p2pfl.communication.commands.message.metrics_command p2pfl.communication.commands.message.model_initialized_command p2pfl.communication.commands.message.models_agregated_command p2pfl.communication.commands.message.models_ready_command p2pfl.communication.commands.message.pre_send_model_command p2pfl.communication.commands.message.start_learning_command p2pfl.communication.commands.message.stop_learning_command p2pfl.communication.commands.message.vote_train_set_command p2pfl.communication.commands.weights p2pfl.communication.commands.weights.full_model_command p2pfl.communication.commands.weights.init_model_command p2pfl.communication.commands.weights.partial_model_command p2pfl.communication.protocols p2pfl.communication.protocols.communication_protocol p2pfl.communication.protocols.exceptions p2pfl.communication.protocols.protobuff p2pfl.communication.protocols.protobuff.client p2pfl.communication.protocols.protobuff.gossiper p2pfl.communication.protocols.protobuff.grpc p2pfl.communication.protocols.protobuff.grpc.address p2pfl.communication.protocols.protobuff.grpc.client p2pfl.communication.protocols.protobuff.grpc.server p2pfl.communication.protocols.protobuff.heartbeater p2pfl.communication.protocols.protobuff.memory p2pfl.communication.protocols.protobuff.memory.client p2pfl.communication.protocols.protobuff.memory.server p2pfl.communication.protocols.protobuff.memory.singleton_dict p2pfl.communication.protocols.protobuff.neighbors p2pfl.communication.protocols.protobuff.proto p2pfl.communication.protocols.protobuff.proto.generate_proto p2pfl.communication.protocols.protobuff.proto.node_pb2 p2pfl.communication.protocols.protobuff.proto.node_pb2_grpc p2pfl.communication.protocols.protobuff.protobuff_communication_protocol p2pfl.communication.protocols.protobuff.server p2pfl.examples p2pfl.exceptions p2pfl.experiment p2pfl.learning p2pfl.learning.aggregators p2pfl.learning.aggregators.aggregator p2pfl.learning.aggregators.fedadagrad p2pfl.learning.aggregators.fedadam p2pfl.learning.aggregators.fedavg p2pfl.learning.aggregators.fedmedian p2pfl.learning.aggregators.fedprox p2pfl.learning.aggregators.fedyogi p2pfl.learning.aggregators.krum p2pfl.learning.aggregators.scaffold p2pfl.learning.compression p2pfl.learning.compression.base_compression_strategy p2pfl.learning.compression.dp_strategy p2pfl.learning.compression.lra_strategy p2pfl.learning.compression.lzma_strategy p2pfl.learning.compression.manager p2pfl.learning.compression.quantization_strategy p2pfl.learning.compression.topk_strategy p2pfl.learning.compression.zlib_strategy p2pfl.learning.dataset p2pfl.learning.dataset.p2pfl_dataset p2pfl.learning.dataset.partition_strategies p2pfl.learning.frameworks p2pfl.learning.frameworks.callback p2pfl.learning.frameworks.callback_factory p2pfl.learning.frameworks.exceptions p2pfl.learning.frameworks.flax p2pfl.learning.frameworks.flax.flax_dataset p2pfl.learning.frameworks.flax.flax_learner p2pfl.learning.frameworks.flax.flax_model p2pfl.learning.frameworks.learner p2pfl.learning.frameworks.learner_factory p2pfl.learning.frameworks.p2pfl_model p2pfl.learning.frameworks.pytorch p2pfl.learning.frameworks.pytorch.callbacks p2pfl.learning.frameworks.pytorch.callbacks.fedprox_callback p2pfl.learning.frameworks.pytorch.callbacks.scaffold_callback p2pfl.learning.frameworks.pytorch.lightning_dataset p2pfl.learning.frameworks.pytorch.lightning_learner p2pfl.learning.frameworks.pytorch.lightning_logger p2pfl.learning.frameworks.pytorch.lightning_model p2pfl.learning.frameworks.simulation p2pfl.learning.frameworks.simulation.actor_pool p2pfl.learning.frameworks.simulation.virtual_learner p2pfl.learning.frameworks.tensorflow p2pfl.learning.frameworks.tensorflow.callbacks p2pfl.learning.frameworks.tensorflow.callbacks.keras_logger p2pfl.learning.frameworks.tensorflow.callbacks.scaffold_callback p2pfl.learning.frameworks.tensorflow.keras_dataset p2pfl.learning.frameworks.tensorflow.keras_learner p2pfl.learning.frameworks.tensorflow.keras_model p2pfl.management p2pfl.management.cli p2pfl.management.launch_from_yaml p2pfl.management.logger p2pfl.management.logger.logger p2pfl.management.message_storage p2pfl.management.metric_storage p2pfl.management.node_monitor p2pfl.management.p2pfl_web_services p2pfl.node p2pfl.node_state p2pfl.settings p2pfl.stages p2pfl.stages.base_node p2pfl.stages.base_node.gossip_model_stage p2pfl.stages.base_node.round_finished_stage p2pfl.stages.base_node.start_learning_stage p2pfl.stages.base_node.train_stage p2pfl.stages.base_node.vote_train_set_stage p2pfl.stages.base_node.wait_agg_models_stage p2pfl.stages.stage p2pfl.stages.stage_factory p2pfl.stages.workflows

N

name (p2pfl.learning.frameworks.pytorch.lightning_logger.FederatedLogger property) name() (p2pfl.stages.base_node.gossip_model_stage.GossipModelStage static method) (p2pfl.stages.base_node.round_finished_stage.RoundFinishedStage static method) (p2pfl.stages.base_node.start_learning_stage.StartLearningStage static method) (p2pfl.stages.base_node.train_stage.TrainStage static method) (p2pfl.stages.base_node.vote_train_set_stage.VoteTrainSetStage static method) (p2pfl.stages.base_node.wait_agg_models_stage.WaitAggregatedModelsStage static method) (p2pfl.stages.stage.Stage static method) nei_status (p2pfl.node_state.NodeState attribute) NeighborNotConnectedError

Neighbors (class in p2pfl.communication.protocols.protobuff.neighbors) Node (class in p2pfl.node) NodeMonitor (class in p2pfl.management.node_monitor) NodeNotRegistered NodeRunningException NodeServices (class in p2pfl.communication.protocols.protobuff.proto.node_pb2_grpc) NodeServicesServicer (class in p2pfl.communication.protocols.protobuff.proto.node_pb2_grpc) NodeServicesStub (class in p2pfl.communication.protocols.protobuff.proto.node_pb2_grpc) NodeState (class in p2pfl.node_state) NoModelsToAggregateError num_actors (p2pfl.learning.frameworks.simulation.actor_pool.SuperActorPool attribute)

O

on_before_optimizer_step() (p2pfl.learning.frameworks.pytorch.callbacks.fedprox_callback.FedProxCallback method) on_before_zero_grad() (p2pfl.learning.frameworks.pytorch.callbacks.scaffold_callback.SCAFFOLDCallback method) on_epoch_end() (p2pfl.learning.frameworks.tensorflow.callbacks.keras_logger.FederatedLogger method) on_train_batch_end() (p2pfl.learning.frameworks.tensorflow.callbacks.keras_logger.FederatedLogger method) (p2pfl.learning.frameworks.tensorflow.callbacks.scaffold_callback.SCAFFOLDCallback method)

on_train_batch_start() (p2pfl.learning.frameworks.pytorch.callbacks.scaffold_callback.SCAFFOLDCallback method) on_train_begin() (p2pfl.learning.frameworks.tensorflow.callbacks.scaffold_callback.SCAFFOLDCallback method) on_train_end() (p2pfl.learning.frameworks.pytorch.callbacks.scaffold_callback.SCAFFOLDCallback method) (p2pfl.learning.frameworks.tensorflow.callbacks.scaffold_callback.SCAFFOLDCallback method) on_train_start() (p2pfl.learning.frameworks.pytorch.callbacks.fedprox_callback.FedProxCallback method) (p2pfl.learning.frameworks.pytorch.callbacks.scaffold_callback.SCAFFOLDCallback method)

P

p2pfl module p2pfl.communication module p2pfl.communication.commands module p2pfl.communication.commands.command module p2pfl.communication.commands.message module p2pfl.communication.commands.message.heartbeat_command module p2pfl.communication.commands.message.metrics_command module p2pfl.communication.commands.message.model_initialized_command module p2pfl.communication.commands.message.models_agregated_command module p2pfl.communication.commands.message.models_ready_command module p2pfl.communication.commands.message.pre_send_model_command module p2pfl.communication.commands.message.start_learning_command module p2pfl.communication.commands.message.stop_learning_command module p2pfl.communication.commands.message.vote_train_set_command module p2pfl.communication.commands.weights module p2pfl.communication.commands.weights.full_model_command module p2pfl.communication.commands.weights.init_model_command module p2pfl.communication.commands.weights.partial_model_command module p2pfl.communication.protocols module p2pfl.communication.protocols.communication_protocol module p2pfl.communication.protocols.exceptions module p2pfl.communication.protocols.protobuff module p2pfl.communication.protocols.protobuff.client module p2pfl.communication.protocols.protobuff.gossiper module p2pfl.communication.protocols.protobuff.grpc module p2pfl.communication.protocols.protobuff.grpc.address module p2pfl.communication.protocols.protobuff.grpc.client module p2pfl.communication.protocols.protobuff.grpc.server module p2pfl.communication.protocols.protobuff.heartbeater module p2pfl.communication.protocols.protobuff.memory module p2pfl.communication.protocols.protobuff.memory.client module p2pfl.communication.protocols.protobuff.memory.server module p2pfl.communication.protocols.protobuff.memory.singleton_dict module p2pfl.communication.protocols.protobuff.neighbors module p2pfl.communication.protocols.protobuff.proto module p2pfl.communication.protocols.protobuff.proto.generate_proto module p2pfl.communication.protocols.protobuff.proto.node_pb2 module p2pfl.communication.protocols.protobuff.proto.node_pb2_grpc module p2pfl.communication.protocols.protobuff.protobuff_communication_protocol module p2pfl.communication.protocols.protobuff.server module p2pfl.examples module p2pfl.exceptions module p2pfl.experiment module p2pfl.learning module p2pfl.learning.aggregators module p2pfl.learning.aggregators.aggregator module p2pfl.learning.aggregators.fedadagrad module p2pfl.learning.aggregators.fedadam module p2pfl.learning.aggregators.fedavg module p2pfl.learning.aggregators.fedmedian module p2pfl.learning.aggregators.fedprox module p2pfl.learning.aggregators.fedyogi module p2pfl.learning.aggregators.krum module p2pfl.learning.aggregators.scaffold module p2pfl.learning.compression module p2pfl.learning.compression.base_compression_strategy module p2pfl.learning.compression.dp_strategy module p2pfl.learning.compression.lra_strategy module p2pfl.learning.compression.lzma_strategy module p2pfl.learning.compression.manager module p2pfl.learning.compression.quantization_strategy module p2pfl.learning.compression.topk_strategy module p2pfl.learning.compression.zlib_strategy module p2pfl.learning.dataset module

p2pfl.learning.dataset.p2pfl_dataset module p2pfl.learning.dataset.partition_strategies module p2pfl.learning.frameworks module p2pfl.learning.frameworks.callback module p2pfl.learning.frameworks.callback_factory module p2pfl.learning.frameworks.exceptions module p2pfl.learning.frameworks.flax module p2pfl.learning.frameworks.flax.flax_dataset module p2pfl.learning.frameworks.flax.flax_learner module p2pfl.learning.frameworks.flax.flax_model module p2pfl.learning.frameworks.learner module p2pfl.learning.frameworks.learner_factory module p2pfl.learning.frameworks.p2pfl_model module p2pfl.learning.frameworks.pytorch module p2pfl.learning.frameworks.pytorch.callbacks module p2pfl.learning.frameworks.pytorch.callbacks.fedprox_callback module p2pfl.learning.frameworks.pytorch.callbacks.scaffold_callback module p2pfl.learning.frameworks.pytorch.lightning_dataset module p2pfl.learning.frameworks.pytorch.lightning_learner module p2pfl.learning.frameworks.pytorch.lightning_logger module p2pfl.learning.frameworks.pytorch.lightning_model module p2pfl.learning.frameworks.simulation module p2pfl.learning.frameworks.simulation.actor_pool module p2pfl.learning.frameworks.simulation.virtual_learner module p2pfl.learning.frameworks.tensorflow module p2pfl.learning.frameworks.tensorflow.callbacks module p2pfl.learning.frameworks.tensorflow.callbacks.keras_logger module p2pfl.learning.frameworks.tensorflow.callbacks.scaffold_callback module p2pfl.learning.frameworks.tensorflow.keras_dataset module p2pfl.learning.frameworks.tensorflow.keras_learner module p2pfl.learning.frameworks.tensorflow.keras_model module p2pfl.management module p2pfl.management.cli module p2pfl.management.launch_from_yaml module p2pfl.management.logger module p2pfl.management.logger.logger module p2pfl.management.message_storage module p2pfl.management.metric_storage module p2pfl.management.node_monitor module p2pfl.management.p2pfl_web_services module p2pfl.node module p2pfl.node_state module p2pfl.settings module p2pfl.stages module p2pfl.stages.base_node module p2pfl.stages.base_node.gossip_model_stage module p2pfl.stages.base_node.round_finished_stage module p2pfl.stages.base_node.start_learning_stage module p2pfl.stages.base_node.train_stage module p2pfl.stages.base_node.vote_train_set_stage module p2pfl.stages.base_node.wait_agg_models_stage module p2pfl.stages.stage module p2pfl.stages.stage_factory module p2pfl.stages.workflows module P2PFLCallback (class in p2pfl.learning.frameworks.callback) P2PFLDataset (class in p2pfl.learning.dataset.p2pfl_dataset) P2PFLModel (class in p2pfl.learning.frameworks.p2pfl_model) P2PFLogger (class in p2pfl.management.logger.logger) P2pflWebServices (class in p2pfl.management.p2pfl_web_services) P2pflWebServicesError PartialModelCommand (class in p2pfl.communication.commands.weights.partial_model_command) path (p2pfl.management.cli.ExampleInfo attribute) PercentageBasedNonIIDPartitionStrategy (class in p2pfl.learning.dataset.partition_strategies) PERIOD (p2pfl.settings.Gossip attribute) (p2pfl.settings.Heartbeat attribute) PreSendModelCommand (class in p2pfl.communication.commands.message.pre_send_model_command) process_unordered_future() (p2pfl.learning.frameworks.simulation.actor_pool.SuperActorPool method) ProtobuffClient (class in p2pfl.communication.protocols.protobuff.client) ProtobuffCommunicationProtocol (class in p2pfl.communication.protocols.protobuff.protobuff_communication_protocol) ProtobuffServer (class in p2pfl.communication.protocols.protobuff.server) ProtocolNotStartedError PTQuantization (class in p2pfl.learning.compression.quantization_strategy) PYTORCH (p2pfl.learning.frameworks.Framework attribute) PyTorchExportStrategy (class in p2pfl.learning.frameworks.pytorch.lightning_dataset)

R

RandomIIDPartitionStrategy (class in p2pfl.learning.dataset.partition_strategies) RAY_ACTOR_POOL_SIZE (p2pfl.settings.Training attribute) refresh_or_add() (p2pfl.communication.protocols.protobuff.neighbors.Neighbors method) register_callback() (p2pfl.learning.frameworks.callback_factory.CallbackFactory class method) register_node() (p2pfl.management.logger.logger.P2PFLogger method) (p2pfl.management.p2pfl_web_services.P2pflWebServices method) remote() (in module p2pfl.management.cli) remove() (p2pfl.communication.protocols.protobuff.neighbors.Neighbors method) remove_hashed() (p2pfl.communication.commands.message.pre_send_model_command.PreSendModelCommand static method) REQUIRED_INFO_KEYS (p2pfl.learning.aggregators.scaffold.Scaffold attribute) reset() (p2pfl.management.logger.logger.P2PFLogger method) RESOURCE_MONITOR_PERIOD (p2pfl.settings.General attribute) resources (p2pfl.learning.frameworks.simulation.actor_pool.SuperActorPool attribute) reverse() (p2pfl.learning.compression.manager.CompressionManager static method) reverse_strategy() (p2pfl.learning.compression.base_compression_strategy.ByteCompressor method) (p2pfl.learning.compression.base_compression_strategy.CompressionStrategy method) (p2pfl.learning.compression.base_compression_strategy.TensorCompressor method) (p2pfl.learning.compression.dp_strategy.DifferentialPrivacyCompressor method) (p2pfl.learning.compression.lra_strategy.LowRankApproximation method) (p2pfl.learning.compression.lzma_strategy.LZMACompressor method) (p2pfl.learning.compression.quantization_strategy.PTQuantization method) (p2pfl.learning.compression.topk_strategy.TopKSparsification method) (p2pfl.learning.compression.zlib_strategy.ZlibCompressor method)

round (p2pfl.experiment.Experiment attribute) (p2pfl.node_state.NodeState property) RoundFinishedStage (class in p2pfl.stages.base_node.round_finished_stage) run() (in module p2pfl.management.cli) (p2pfl.communication.protocols.protobuff.gossiper.Gossiper method) (p2pfl.communication.protocols.protobuff.heartbeater.Heartbeater method) (p2pfl.management.node_monitor.NodeMonitor method) (p2pfl.stages.workflows.StageWokflow method) run_from_yaml() (in module p2pfl.management.launch_from_yaml) running() (in module p2pfl.communication.protocols.protobuff.protobuff_communication_protocol)

S

save() (p2pfl.learning.frameworks.pytorch.lightning_logger.FederatedLogger method) Scaffold (class in p2pfl.learning.aggregators.scaffold) SCAFFOLDCallback (class in p2pfl.learning.frameworks.pytorch.callbacks.scaffold_callback) (class in p2pfl.learning.frameworks.tensorflow.callbacks.scaffold_callback) ScaffoldOptimizerWrapper (class in p2pfl.learning.frameworks.tensorflow.callbacks.scaffold_callback) SEED (p2pfl.settings.General attribute) self() (p2pfl.experiment.Experiment method) send() (p2pfl.communication.protocols.communication_protocol.CommunicationProtocol method) (p2pfl.communication.protocols.protobuff.client.ProtobuffClient method) (p2pfl.communication.protocols.protobuff.grpc.client.GrpcClient method) (p2pfl.communication.protocols.protobuff.memory.client.MemoryClient method) (p2pfl.communication.protocols.protobuff.proto.node_pb2_grpc.NodeServices static method) (p2pfl.communication.protocols.protobuff.proto.node_pb2_grpc.NodeServicesServicer method) (p2pfl.communication.protocols.protobuff.protobuff_communication_protocol.ProtobuffCommunicationProtocol method) (p2pfl.communication.protocols.protobuff.server.ProtobuffServer method) send_communication_log() (p2pfl.management.p2pfl_web_services.P2pflWebServices method) send_global_metric() (p2pfl.management.p2pfl_web_services.P2pflWebServices method) send_local_metric() (p2pfl.management.p2pfl_web_services.P2pflWebServices method) send_log() (p2pfl.management.p2pfl_web_services.P2pflWebServices method) send_system_metric() (p2pfl.management.p2pfl_web_services.P2pflWebServices method) SERVER_CRT (p2pfl.settings.SSL attribute) SERVER_KEY (p2pfl.settings.SSL attribute) set_additional_info() (p2pfl.learning.frameworks.tensorflow.callbacks.scaffold_callback.SCAFFOLDCallback method) set_addr() (p2pfl.communication.protocols.protobuff.gossiper.Gossiper method) (p2pfl.communication.protocols.protobuff.grpc.server.GrpcServer method) (p2pfl.communication.protocols.protobuff.heartbeater.Heartbeater method) (p2pfl.communication.protocols.protobuff.memory.server.MemoryServer method) (p2pfl.communication.protocols.protobuff.protobuff_communication_protocol.ProtobuffCommunicationProtocol method) (p2pfl.learning.frameworks.pytorch.lightning_learner.LightningLearner method) (p2pfl.learning.frameworks.simulation.virtual_learner.VirtualNodeLearner method) (p2pfl.learning.frameworks.tensorflow.keras_learner.KerasLearner method) set_batch_size() (p2pfl.learning.dataset.p2pfl_dataset.P2PFLDataset method) set_contribution() (p2pfl.learning.frameworks.p2pfl_model.P2PFLModel method) set_data() (p2pfl.learning.frameworks.learner.Learner method) (p2pfl.learning.frameworks.simulation.virtual_learner.VirtualNodeLearner method) (p2pfl.node.Node method) set_epochs() (p2pfl.learning.frameworks.learner.Learner method) (p2pfl.learning.frameworks.simulation.virtual_learner.VirtualNodeLearner method) set_experiment() (p2pfl.node_state.NodeState method) set_from_dict() (p2pfl.settings.Settings class method) set_info() (p2pfl.learning.frameworks.callback.P2PFLCallback method) set_learner() (p2pfl.node.Node method) set_level() (p2pfl.management.logger.logger.P2PFLogger method) set_model() (p2pfl.learning.frameworks.learner.Learner method) (p2pfl.learning.frameworks.simulation.virtual_learner.VirtualNodeLearner method) (p2pfl.learning.frameworks.tensorflow.keras_learner.KerasLearner method) (p2pfl.node.Node method)

set_nodes_to_aggregate() (p2pfl.learning.aggregators.aggregator.Aggregator method) set_parameters() (p2pfl.learning.frameworks.flax.flax_model.FlaxModel method) (p2pfl.learning.frameworks.p2pfl_model.P2PFLModel method) (p2pfl.learning.frameworks.pytorch.lightning_model.LightningModel method) (p2pfl.learning.frameworks.tensorflow.keras_model.KerasModel method) set_report_fn() (p2pfl.management.node_monitor.NodeMonitor method) set_start_learning() (p2pfl.node.Node method) set_stop_learning() (p2pfl.node.Node method) set_transforms() (p2pfl.learning.dataset.p2pfl_dataset.P2PFLDataset method) Settings (class in p2pfl.settings) SingletonDict (class in p2pfl.communication.protocols.protobuff.memory.singleton_dict) SSL (class in p2pfl.settings) ssl (p2pfl.settings.Settings attribute) Stage (class in p2pfl.stages.stage) StageFactory (class in p2pfl.stages.stage_factory) StageWokflow (class in p2pfl.stages.workflows) start() (p2pfl.communication.protocols.communication_protocol.CommunicationProtocol method) (p2pfl.communication.protocols.protobuff.gossiper.Gossiper method) (p2pfl.communication.protocols.protobuff.grpc.server.GrpcServer method) (p2pfl.communication.protocols.protobuff.memory.server.MemoryServer method) (p2pfl.communication.protocols.protobuff.protobuff_communication_protocol.ProtobuffCommunicationProtocol method) (p2pfl.communication.protocols.protobuff.server.ProtobuffServer method) (p2pfl.node.Node method) start_thread_lock (p2pfl.node_state.NodeState attribute) StartLearningCommand (class in p2pfl.communication.commands.message.start_learning_command) StartLearningStage (class in p2pfl.stages.base_node.start_learning_stage) status (p2pfl.node_state.NodeState attribute) stop() (p2pfl.communication.protocols.communication_protocol.CommunicationProtocol method) (p2pfl.communication.protocols.protobuff.gossiper.Gossiper method) (p2pfl.communication.protocols.protobuff.grpc.server.GrpcServer method) (p2pfl.communication.protocols.protobuff.heartbeater.Heartbeater method) (p2pfl.communication.protocols.protobuff.memory.server.MemoryServer method) (p2pfl.communication.protocols.protobuff.protobuff_communication_protocol.ProtobuffCommunicationProtocol method) (p2pfl.communication.protocols.protobuff.server.ProtobuffServer method) (p2pfl.management.node_monitor.NodeMonitor method) (p2pfl.node.Node method) StopLearningCommand (class in p2pfl.communication.commands.message.stop_learning_command) submit() (p2pfl.learning.frameworks.simulation.actor_pool.SuperActorPool method) submit_learner_job() (p2pfl.learning.frameworks.simulation.actor_pool.SuperActorPool method) SuperActorPool (class in p2pfl.learning.frameworks.simulation.actor_pool) SUPPORTS_PARTIAL_AGGREGATION (p2pfl.learning.aggregators.aggregator.Aggregator attribute) (p2pfl.learning.aggregators.fedadagrad.FedAdagrad attribute) (p2pfl.learning.aggregators.fedadam.FedAdam attribute) (p2pfl.learning.aggregators.fedavg.FedAvg attribute) (p2pfl.learning.aggregators.fedmedian.FedMedian attribute) (p2pfl.learning.aggregators.fedyogi.FedYogi attribute) (p2pfl.learning.aggregators.krum.Krum attribute) (p2pfl.learning.aggregators.scaffold.Scaffold attribute)

T

TensorCompressor (class in p2pfl.learning.compression.base_compression_strategy) TENSORFLOW (p2pfl.learning.frameworks.Framework attribute) TIMEOUT (p2pfl.settings.Heartbeat attribute) TopKSparsification (class in p2pfl.learning.compression.topk_strategy) TorchvisionDatasetFactory (class in p2pfl.learning.frameworks.pytorch.lightning_dataset) total_rounds (p2pfl.experiment.Experiment attribute) (p2pfl.node_state.NodeState attribute) (p2pfl.node_state.NodeState property)

train_set (p2pfl.node_state.NodeState attribute) train_set_votes (p2pfl.node_state.NodeState attribute) train_set_votes_lock (p2pfl.node_state.NodeState attribute) train_step() (p2pfl.learning.frameworks.flax.flax_learner.FlaxLearner method) Training (class in p2pfl.settings) training (p2pfl.settings.Settings attribute) TrainStage (class in p2pfl.stages.base_node.train_stage) try_init_learner_with_ray() (in module p2pfl.learning.frameworks.simulation) TTL (p2pfl.settings.Gossip attribute)

U

unregister_node() (p2pfl.management.logger.logger.P2PFLogger method) (p2pfl.management.p2pfl_web_services.P2pflWebServices method)

update_callbacks_with_model_info() (p2pfl.learning.frameworks.learner.Learner method) (p2pfl.learning.frameworks.simulation.virtual_learner.VirtualNodeLearner method) USE_SSL (p2pfl.settings.SSL attribute)

V

version (p2pfl.learning.frameworks.pytorch.lightning_logger.FederatedLogger property) VirtualNodeLearner (class in p2pfl.learning.frameworks.simulation.virtual_learner)

VOTE_TIMEOUT (p2pfl.settings.Training attribute) VoteTrainSetCommand (class in p2pfl.communication.commands.message.vote_train_set_command) VoteTrainSetStage (class in p2pfl.stages.base_node.vote_train_set_stage)

W

wait_and_get_aggregation() (p2pfl.learning.aggregators.aggregator.Aggregator method) WAIT_CONVERGENCE (p2pfl.settings.Heartbeat attribute) wait_for_termination() (p2pfl.communication.protocols.communication_protocol.CommunicationProtocol method) (p2pfl.communication.protocols.protobuff.grpc.server.GrpcServer method) (p2pfl.communication.protocols.protobuff.memory.server.MemoryServer method) (p2pfl.communication.protocols.protobuff.protobuff_communication_protocol.ProtobuffCommunicationProtocol method) (p2pfl.communication.protocols.protobuff.server.ProtobuffServer method)

wait_votes_ready_lock (p2pfl.node_state.NodeState attribute) WaitAggregatedModelsStage (class in p2pfl.stages.base_node.wait_agg_models_stage) warning() (p2pfl.management.logger.logger.P2PFLogger method)

Z

ZeroRoundsException

ZlibCompressor (class in p2pfl.learning.compression.zlib_strategy)