Skip to main content
Ctrl+K
ECLYPSE - Home ECLYPSE - Home

ECLYPSE

  • Overview
  • Reference
  • Changelog
  • GitHub
  • Overview
  • Reference
  • Changelog
  • GitHub

Section Navigation

  • builders
    • application
      • anomaly_detection
        • application
        • mpi_services
        • rest_services
      • crud_api
        • application
        • mpi_services
        • rest_services
      • deathstarbench
        • hotel_reservation
        • media_service
        • social_network
      • keyword_spotting
        • application
        • mpi_services
        • rest_services
      • sock_shop
        • application
        • mpi_services
        • rest_services
      • thumbnailer
        • application
        • mpi_services
        • rest_services
      • video_analytics_serving
        • application
        • mpi_services
        • rest_services
    • infrastructure
      • generators
        • b_cube
        • fat_tree
        • hierarchical
        • random
        • scale_free
        • small_world
        • star
      • patterns
        • continuum_tiered
        • factory_cells
        • industrial_tsn
        • mec_5g
        • multi_region_wan
        • vehicular_edge
      • references
        • orion_cev
        • topohub
    • workflow
      • base_method
        • WorkflowBaseMethod
      • workflow
        • get_workflow
      • workflow_family
        • WorkflowFamily
  • graph
    • application
      • Application
        • Application.__init__
        • Application.add_service
        • Application.set_flows
        • Application.has_service_implementations
    • asset_graph
      • AssetGraph
        • AssetGraph.__init__
        • AssetGraph.add_edge
        • AssetGraph.add_node
        • AssetGraph.evolve
        • AssetGraph.is_dynamic
        • AssetGraph.logger
    • assets
      • additive
        • Additive
      • asset
        • Asset
      • bucket
        • AssetBucket
      • concave
        • Concave
      • convex
        • Convex
      • defaults
        • availability
        • bandwidth
        • cpu
        • get_default_edge_assets
        • get_default_node_assets
        • get_default_path_aggregators
        • gpu
        • latency
        • processing_time
        • ram
        • storage
      • multiplicative
        • Multiplicative
      • space
        • AssetSpace
        • Choice
        • IntUniform
        • Sample
        • Uniform
      • symbolic
        • Symbolic
    • infrastructure
      • Infrastructure
        • Infrastructure.__init__
        • Infrastructure.add_edge
        • Infrastructure.add_node
        • Infrastructure.evolve
        • Infrastructure.is_available
        • Infrastructure.path
        • Infrastructure.path_resources
        • Infrastructure.processing_time
        • Infrastructure.remove_edge
        • Infrastructure.remove_node
        • Infrastructure.validate
        • Infrastructure.available
  • placement
    • placement
      • Placement
        • Placement.__init__
        • Placement.clear_reset
        • Placement.interactions_on_link
        • Placement.link_interaction_mapping
        • Placement.link_requirements_mapping
        • Placement.mark_deployed
        • Placement.mark_for_reset
        • Placement.mark_undeployed
        • Placement.node_requirements_mapping
        • Placement.node_service_mapping
        • Placement.service_placement
        • Placement.services_on_node
        • Placement.deployed
        • Placement.is_partial
        • Placement.reset_requested
    • strategies
      • best_fit
        • BestFitStrategy
      • first_fit
        • FirstFitStrategy
      • random
        • RandomStrategy
      • round_robin
        • RoundRobinStrategy
      • static
        • StaticStrategy
      • strategy
        • PlacementStrategy
    • view
      • PlacementView
        • PlacementView.__init__
        • PlacementView.get_edge_view
        • PlacementView.get_node_view
        • PlacementView.edge_aggregate
        • PlacementView.edge_assets
        • PlacementView.node_aggregate
        • PlacementView.node_assets
  • policies
    • compose
      • all_of
      • chain
      • conditional
      • one_of
      • weighted_choice
    • constraints
      • clamp_values
      • ensure_capacity_floor
      • normalise
      • round_int
    • degrade
      • clamp_values
      • decay
      • increase
      • ramp_to
      • reduce
      • restore
      • scale
      • set_value
    • distribution
      • bernoulli
      • beta
      • categorical
      • constant
      • discrete
      • empirical
      • exponential
      • gamma
      • lognormal
      • normal
      • pareto
      • poisson
      • triangular
      • truncated_normal
      • uniform
      • weibull
    • failure
      • availability_flap
      • brownout
      • correlated_failure
      • edge_availability_flap
      • kill_edges
      • kill_nodes
      • latency_spike
      • network_partition
      • resource_exhaustion
      • revive_edges
      • revive_nodes
    • noise
      • additive_jitter
      • bounded_random_walk
      • correlated_noise
      • dropout
      • gaussian_jitter
      • impulse
      • momentum_walk
      • multiplicative_jitter
      • seasonal_noise
    • replay
      • from_csv
      • from_dataframe
      • from_parquet
      • from_records
      • interpolated_replay
      • replay_edges
      • replay_events
      • replay_graph
      • replay_nodes
      • replay_with_mapping
    • schedule
      • after
      • at
      • between
      • cooldown
      • every
      • jittered_every
      • once_at
      • repeat
      • until
      • with_probability
    • topology
      • add_edge
      • add_node
      • churn
      • remove_node
      • rewire
    • workload
      • arrival_process
      • diurnal_load
      • traffic_matrix
  • remote
    • bootstrap
      • bootstrap
        • RemoteBootstrap
      • options_factory
        • RayOptionsFactory
    • communication
      • interface
        • EclypseCommunicationInterface
      • mpi
        • interface
        • requests
        • response
      • request
        • EclypseRequest
        • eclypse.remote.communication.request.RouteNotFoundError
      • rest
        • codes
        • http_request
        • interface
        • methods
      • route
        • eclypse.remote.communication.route.MILLISECONDS_PER_SECOND
        • eclypse.remote.communication.route.BYTES_TO_MEGABITS
        • Route
    • service
      • rest
        • RESTService
      • service
        • Service
    • utils
      • op_result
        • RemoteOpResult
      • ops
        • RemoteOps
      • ray_interface
        • RayInterface
      • response_code
        • ResponseCode
  • report
    • backend
      • get_report_columns
      • get_report_source
      • list_parquet_parts
      • load_jsonl_rows
      • FrameBackend
        • FrameBackend.__init__
        • FrameBackend.columns
        • FrameBackend.filter_eq
        • FrameBackend.filter_events
        • FrameBackend.filter_in
        • FrameBackend.filter_range_step
        • FrameBackend.is_empty
        • FrameBackend.max
        • FrameBackend.read_frame
        • FrameBackend.name
    • backends
      • get_backend
      • pandas_backend
        • PandasBackend
      • polars_backend
        • PolarsBackend
      • polars_lazy_backend
        • PolarsLazyBackend
    • metrics
      • defaults
        • get_default_metrics
      • metric
        • application
        • infrastructure
        • interaction
        • link
        • node
        • service
        • simulation
    • query
      • ReportQuery
        • ReportQuery.__init__
        • ReportQuery.range
        • ReportQuery.step
        • ReportQuery.to_frame
        • ReportQuery.where
    • report
      • Report
        • Report.__init__
        • Report.application
        • Report.describe
        • Report.filter
        • Report.frame
        • Report.get_dataframes
        • Report.infrastructure
        • Report.interaction
        • Report.link
        • Report.node
        • Report.query
        • Report.service
        • Report.simulation
        • Report.backend_name
        • Report.config
        • Report.report_format
    • reporter
      • Reporter
        • Reporter.__init__
        • Reporter.callback_rows
        • Reporter.close
        • Reporter.dfs_data
        • Reporter.init
        • Reporter.report
        • Reporter.write
    • reporters
      • get_default_reporters
      • csv
        • CSVReporter
      • gml
        • GMLReporter
      • json
        • JSONReporter
      • parquet
        • ParquetReporter
      • tensorboard
        • TensorBoardReporter
    • schema
  • simulation
    • config
      • SimulationConfig
        • SimulationConfig.__init__
        • SimulationConfig.prepare_runtime
        • SimulationConfig.runtime_env
        • SimulationConfig.to_dict
        • SimulationConfig.step_every_ms
        • SimulationConfig.timeout
        • SimulationConfig.max_steps
        • SimulationConfig.reporters
        • SimulationConfig.events
        • SimulationConfig.include_default_metrics
        • SimulationConfig.seed
        • SimulationConfig.path
        • SimulationConfig.log_to_file
        • SimulationConfig.log_level
        • SimulationConfig.report_chunk_size
        • SimulationConfig.report_format
        • SimulationConfig.report_backend
        • SimulationConfig.remote
        • SimulationConfig.default_strategy
        • SimulationConfig.callbacks
        • SimulationConfig.logger
    • runtime
      • apply_runtime_env
      • build_runtime_env
    • simulation
      • Simulation
        • Simulation.__init__
        • Simulation.prepare_runtime
        • Simulation.register
        • Simulation.run
        • Simulation.start
        • Simulation.step
        • Simulation.stop
        • Simulation.trigger
        • Simulation.wait
        • Simulation.applications
        • Simulation.logger
        • Simulation.path
        • Simulation.report
        • Simulation.status
  • workflow
    • event
      • decorator
        • after
        • every
        • once_at
      • defaults
        • get_default_events
        • EnactEvent
        • StartEvent
        • StepEvent
        • StopEvent
      • event
        • EclypseEvent
      • role
        • EventRole
      • wrapper
        • EventWrapper
    • trigger
      • bucket
        • TriggerBucket
      • cascade
        • CascadeTrigger
        • PeriodicCascadeTrigger
        • RandomCascadeTrigger
        • ScheduledCascadeTrigger
      • trigger
        • PeriodicTrigger
        • RandomTrigger
        • ScheduledTrigger
        • Trigger
  • utils
    • constants
      • eclypse.utils.constants.MIN_FLOAT
      • eclypse.utils.constants.MAX_FLOAT
      • eclypse.utils.constants.FLOAT_EPSILON
      • eclypse.utils.constants.RND_SEED
      • eclypse.utils.constants.LOG_LEVEL
      • eclypse.utils.constants.LOG_FILE
      • eclypse.utils.constants.MIN_BANDWIDTH
      • eclypse.utils.constants.MAX_BANDWIDTH
      • eclypse.utils.constants.MIN_LATENCY
      • eclypse.utils.constants.MAX_LATENCY
      • eclypse.utils.constants.MIN_AVAILABILITY
      • eclypse.utils.constants.MAX_AVAILABILITY
      • eclypse.utils.constants.COST_RECOMPUTATION_THRESHOLD
      • eclypse.utils.constants.START_EVENT
      • eclypse.utils.constants.ENACT_EVENT
      • eclypse.utils.constants.STEP_EVENT
      • eclypse.utils.constants.STOP_EVENT
      • eclypse.utils.constants.DRIVING_EVENT
    • defaults
      • eclypse.utils.defaults.DEFAULT_REPORT_TYPE
      • eclypse.utils.defaults.DEFAULT_REPORT_BACKEND
      • eclypse.utils.defaults.DEFAULT_REPORT_CHUNK_SIZE
      • eclypse.utils.defaults.DEFAULT_STEP_QUEUE_SIZE
      • eclypse.utils.defaults.DEFAULT_EDGE_LATENCY
      • eclypse.utils.defaults.DEFAULT_REPORT_RANGE
      • eclypse.utils.defaults.DEFAULT_REPORT_STEP
      • eclypse.utils.defaults.SIMULATION_CONFIG_FILENAME
      • eclypse.utils.defaults.SIMULATION_LOG_FILENAME
      • eclypse.utils.defaults.CSV_REPORT_DIR
      • eclypse.utils.defaults.GML_REPORT_DIR
      • eclypse.utils.defaults.JSON_REPORT_DIR
      • eclypse.utils.defaults.PARQUET_REPORT_DIR
      • eclypse.utils.defaults.TENSORBOARD_REPORT_DIR
      • eclypse.utils.defaults.DEFAULT_RAY_RUNTIME_ENV_VARS
      • eclypse.utils.defaults.SUPPORTED_COMMUNICATION_INTERFACES
      • get_default_sim_path
    • types
      • eclypse.utils.types.PrimitiveType
      • eclypse.utils.types.CascadeTriggerType
      • eclypse.utils.types.ActivatesOnType
      • eclypse.utils.types.TriggerCondition
      • eclypse.utils.types.HTTPMethodLiteral
      • eclypse.utils.types.CommunicationInterface
      • eclypse.utils.types.ConnectivityFn
      • eclypse.utils.types.EventType
      • eclypse.utils.types.InitPolicy
      • eclypse.utils.types.UpdatePolicy
      • eclypse.utils.types.UpdatePolicies
      • eclypse.utils.types.ReportFormat
      • eclypse.utils.types.ReportBackend
      • eclypse.utils.types.ValueAdjustmentDirection
      • eclypse.utils.types.ValueAdjustmentOverrides
      • eclypse.utils.types.Distribution
      • eclypse.utils.types.ReplayTarget
      • eclypse.utils.types.MissingPolicyBehaviour
      • eclypse.utils.types.LogLevel
      • ValueAdjustmentOverride
  • Reference
  • remote
  • communication
  • mpi

mpi#

Package for the MPI communication interface.

Based on the Message Passing Interface (MPI) protocol.

Modules

interface

Module for the EclypseMPI class.

requests

Package collecting MPI requests that can be sent to remote nodes.

response

Module for the Response class.

previous

EclypseCommunicationInterface.service

next

interface

© Copyright 2026, Jacopo Massa & Valerio De Caro.

Created using Sphinx 9.0.4.

Built with the PyData Sphinx Theme 0.17.1.