fedn.network.storage package

Module handling both transient and persistent storage of model objects and system state.

Subpackages

• fedn.network.storage.models package
  • Submodules
  • fedn.network.storage.models.memorymodelstorage module
    • MemoryModelStorage
      • MemoryModelStorage.__init__()
      • MemoryModelStorage.exist()
      • MemoryModelStorage.get()
      • MemoryModelStorage.get_model_metadata()
      • MemoryModelStorage.get_ptr()
      • MemoryModelStorage.set_model_metadata()
  • fedn.network.storage.models.modelstorage module
    • ModelStorage
      • ModelStorage.delete()
      • ModelStorage.delete_all()
      • ModelStorage.exist()
      • ModelStorage.get()
      • ModelStorage.get_model_metadata()
      • ModelStorage.set_model_metadata()
  • fedn.network.storage.models.tempmodelstorage module
    • TempModelStorage
      • TempModelStorage.__init__()
      • TempModelStorage.delete()
      • TempModelStorage.delete_all()
      • TempModelStorage.exist()
      • TempModelStorage.get()
      • TempModelStorage.get_model_metadata()
      • TempModelStorage.get_ptr()
      • TempModelStorage.set_model_metadata()
• fedn.network.storage.s3 package
  • Submodules
  • fedn.network.storage.s3.base module
    • RepositoryBase
      • RepositoryBase.get_artifact()
      • RepositoryBase.get_artifact_stream()
      • RepositoryBase.set_artifact()
  • fedn.network.storage.s3.boto3repository module
    • Boto3Repository
      • Boto3Repository.__init__()
      • Boto3Repository.create_bucket()
      • Boto3Repository.delete_artifact()
      • Boto3Repository.get_artifact()
      • Boto3Repository.get_artifact_stream()
      • Boto3Repository.list_artifacts()
      • Boto3Repository.set_artifact()
  • fedn.network.storage.s3.miniorepository module
  • fedn.network.storage.s3.repository module
    • Repository
      • Repository.__init__()
      • Repository.delete_compute_package()
      • Repository.delete_model()
      • Repository.get_compute_package()
      • Repository.get_model()
      • Repository.get_model_stream()
      • Repository.presigned_get_url()
      • Repository.presigned_put_url()
      • Repository.set_compute_package()
      • Repository.set_model()
  • fedn.network.storage.s3.saasrepository module
    • SAASRepository
      • SAASRepository.__init__()
      • SAASRepository.create_bucket()
      • SAASRepository.delete_artifact()
      • SAASRepository.get_artifact()
      • SAASRepository.get_artifact_stream()
      • SAASRepository.list_artifacts()
      • SAASRepository.set_artifact()
• fedn.network.storage.statestore package
  • Subpackages
    • fedn.network.storage.statestore.stores package
      • ClientStore
      • CombinerStore
      • MetricStore
      • ModelStore
      • PackageStore
      • PredictionStore
      • RoundStore
      • SessionStore
      • StatusStore
      • ValidationStore
      • Subpackages
      • Submodules
      • fedn.network.storage.statestore.stores.attribute_store module
      • fedn.network.storage.statestore.stores.client_store module
      • fedn.network.storage.statestore.stores.combiner_store module
      • fedn.network.storage.statestore.stores.metric_store module
      • fedn.network.storage.statestore.stores.model_store module
      • fedn.network.storage.statestore.stores.package_store module
      • fedn.network.storage.statestore.stores.prediction_store module
      • fedn.network.storage.statestore.stores.round_store module
      • fedn.network.storage.statestore.stores.run_store module
      • fedn.network.storage.statestore.stores.session_store module
      • fedn.network.storage.statestore.stores.shared module
      • fedn.network.storage.statestore.stores.status_store module
      • fedn.network.storage.statestore.stores.store module
      • fedn.network.storage.statestore.stores.telemetry_store module
      • fedn.network.storage.statestore.stores.validation_store module

Submodules

fedn.network.storage.dbconnection module

This module provides classes for managing database connections and stores in a federated network environment.

Classes:

StoreContainer: A container for various store instances. DatabaseConnection: A singleton class for managing database connections and stores.

class fedn.network.storage.dbconnection.DatabaseConnection(statestore_config, network_id, connect: bool = True)

Bases: object

Singleton class for managing database connections and stores.

__init__(statestore_config, network_id, connect: bool = True)

attribute_store: AttributeStore

client_store: ClientStore

combiner_store: CombinerStore

initialize_connection()

metric_store: MetricStore

model_store: ModelStore

package_store: PackageStore

prediction_store: PredictionStore

round_store: RoundStore

run_store: RunStore

session_store: SessionStore

status_store: StatusStore

telemetry_store: TelemetryStore

validation_store: ValidationStore