Index

_

__init__() (Cluster method) (DistributionShapeError method) (FileBlockData method) (FileData method) (HDFSCluster method) (IllegalArgumentError method) (LoggingData method) (Master method) (MatlabEngineContainer method) (MatlabEngineContainerError method) (MatrixError method) (MatrixNotSquareError method) (NewscastCluster method) (NewscastMaster method) (NewscastNode method) (Node method) (SGCluster method) (SGClusterExt method) (SGClusterPerfect method) (SGNode method) __makedirs__() (in module app.hive_simulation) __select_fastest_topology__() (in module sample_scenario_fixer) __str__() (FileBlockData method) __validate_mc__() (in module sample_scenario_fixer) _adjency_matrix_sdp_optimization() (in module app.domain.helpers.matrices) _construct_random_walk_matrix() (in module app.domain.helpers.matrices) _construct_rejection_matrix() (in module app.domain.helpers.matrices) _create_network_nodes() (Master method) _epoch_complaints (SGClusterExt attribute) _get_diagonal_entry_probability_v1() (in module app.domain.helpers.matrices) _get_diagonal_entry_probability_v2() (in module app.domain.helpers.matrices) _get_new_members() (Cluster method) _in_yes_no() (in module app.simfile_generator) _init_nodes_uptime() (in module app.simfile_generator) _init_persisting_dict() (in module app.simfile_generator) _input_bounded_float() (in module app.simfile_generator)

_input_bounded_integer() (in module app.simfile_generator) _input_character_option() (in module app.simfile_generator) _input_filename() (in module app.simfile_generator) _instance (MatlabEngineContainer attribute) _LOCK (MatlabEngineContainer attribute) _log_evaluation() (Cluster method) (SGCluster method) _members_view (Cluster attribute) _membership_changed (Cluster attribute) _merge() (NewscastNode method) _metropolis_hastings() (in module app.domain.helpers.matrices) _NetworkView (in module app.domain.network_nodes) _new_cluster_group() (Master method) _new_network_node() (Master method) _normalize_avg_() (SGCluster method) _parallel_main() (in module app.hive_simulation) _PersistentingDict (in module app.domain.master_servers) _pretty_print_eq_distr_table() (SGCluster method) _process_simfile() (HDFSMaster method) (Master method) (NewscastMaster method) _recovery_epoch_calls (Cluster attribute) _recovery_epoch_sum (Cluster attribute) _recursive_len() (LoggingData method) _ResultsDict (in module app.mixing_rate_sampler) _select_view() (NewscastNode method) _set_fail() (Cluster method) _setup_epoch() (Cluster method) (NewscastCluster method) _simulate() (in module app.hive_simulation) _single_main() (in module app.hive_simulation) _SizeResultsDict (in module app.mixing_rate_sampler) _split_files() (Master method) _timer (SGCluster attribute) _validate_simfile() (in module app.hive_simulation) _validate_transition_matrix() (SGCluster method)

A

add_cloud_reference() (SGCluster method) add_neighbor() (NewscastNode method) aggregate() (NewscastNode method) aggregation_value (NewscastNode attribute) app module app.domain module app.domain.cluster_groups module app.domain.helpers module app.domain.helpers.enums module app.domain.helpers.exceptions module app.domain.helpers.matlab_utils module app.domain.helpers.matrices module app.domain.helpers.smart_dataclasses module app.domain.master_servers module

app.domain.network_nodes module app.environment_settings module app.hive_simulation module app.mixing_rate_sampler module app.sample_scenario_generator module app.simfile_generator module app.type_hints module app.utils module app.utils.convertions module app.utils.crypto module app.utils.randoms module ATOL (in module app.environment_settings) avg_ (SGCluster attribute)

B

BAD_REQUEST (HttpCodes attribute) base64_bytelike_obj_to_bytes() (in module app.utils.convertions) base64_string_to_bytes() (in module app.utils.convertions) blocks_corrupted (LoggingData attribute) BLOCKS_COUNT (in module app.environment_settings) blocks_existing (LoggingData attribute)

blocks_lost (LoggingData attribute) blocks_moved (LoggingData attribute) BLOCKS_SIZE (in module app.environment_settings) broadcast_transition_matrix() (SGCluster method) bytes_to_base64_string() (in module app.utils.convertions) bytes_to_utf8string() (in module app.utils.convertions)

C

can_replicate() (FileBlockData method) class_name_to_obj() (in module app.utils.convertions) Cluster (class in app.domain.cluster_groups) cluster_groups (Master attribute) cluster_id (FileBlockData attribute) cluster_size_am (LoggingData attribute) cluster_size_bm (LoggingData attribute) cluster_status_am (LoggingData attribute) cluster_status_bm (LoggingData attribute) ClusterDict (in module app.type_hints) clusters (SGNode attribute)

ClusterType (in module app.type_hints) complain() (Cluster method) (SGClusterExt method) complaint_threshold (SGClusterExt attribute) convergence_set (LoggingData attribute) convergence_sets (LoggingData attribute) corruption_chances (Cluster attribute) create_and_bcast_new_transition_matrix() (SGCluster method) critical_size (Cluster attribute) cswc (LoggingData attribute) current_epoch (Cluster attribute) cv_ (SGCluster attribute)

D

data (FileBlockData attribute) data_node_heartbeats (HDFSCluster attribute) DEBUG (in module app.environment_settings) decrement_and_get_references() (FileBlockData method) delay_replication (LoggingData attribute)

delay_suspects_detection (LoggingData attribute) DELIVER_CHANCE (in module app.environment_settings) discard_part() (Node method) DistributionShapeError DUMMY (HttpCodes attribute)

E

eng (MatlabEngineContainer attribute) epoch (Master attribute) equal_distributions() (SGCluster method) evaluate() (Cluster method) (HDFSCluster method) (NewscastCluster method) (SGCluster method) excluding_randrange() (in module app.utils.randoms) execute_epoch() (Cluster method) (HDFSNode method) (NewscastCluster method) (NewscastNode method) (Node method) (SGCluster method) (SGClusterExt method) (SGClusterPerfect method) (SGNode method)

execute_simulation() (Master method) existing_replicas (FileData attribute)

F

fclose() (FileData method) file (Cluster attribute) FileBlockData (class in app.domain.helpers.smart_dataclasses)

FileData (class in app.domain.helpers.smart_dataclasses) files (Node attribute) find_online_nodes() (Master method) fwrite() (FileData method)

G

get_cloud_reference() (SGMaster method) get_cluster_status() (Cluster method) get_degree() (NewscastNode method) get_disk_error_chances() (in module app.environment_settings) get_file_parts() (Node method)

get_file_parts_count() (Node method) get_instance() (MatlabEngineContainer static method) get_mixing_rate() (in module app.domain.helpers.matrices) get_next_scenario() (in module app.hive_simulation) get_node() (Cluster method) (NewscastNode method)

H

HDFSCluster (class in app.domain.cluster_groups) HDFSMaster (class in app.domain.master_servers)

HDFSNode (class in app.domain.network_nodes) HttpCodes (class in app.domain.helpers.enums) HttpResponse (in module app.type_hints)

I

id (Cluster attribute) (FileBlockData attribute) (Node attribute) IllegalArgumentError

initial_spread (LoggingData attribute) is_connected() (in module app.domain.helpers.matrices) is_suspect() (Node method) is_symmetric() (in module app.domain.helpers.matrices) is_up() (Node method)

J

json_string_to_obj() (in module app.utils.convertions)

jwrite() (FileData method)

L

largest_convergence_window (LoggingData attribute) log_aggregation() (NewscastCluster method) log_bandwidth_units() (LoggingData method) log_corrupted_file_blocks() (LoggingData method) log_existing_file_blocks() (LoggingData method) log_fail() (LoggingData method) log_lost_file_blocks() (LoggingData method) log_lost_messages() (LoggingData method)

log_maintenance() (LoggingData method) log_matrices_degrees() (LoggingData method) log_off_nodes() (LoggingData method) log_replication_delay() (LoggingData method) log_suspicous_node_detection_delay() (LoggingData method) log_topology_goal_performance() (LoggingData method) logger (FileData attribute) LoggingData (class in app.domain.helpers.smart_dataclasses) LOSS_CHANCE (in module app.environment_settings)

M

main() (in module app.mixing_rate_sampler) maintain() (Cluster method) (HDFSCluster method) (SGCluster method) (SGClusterExt method) make_connected() (in module app.domain.helpers.matrices) Master (class in app.domain.master_servers) master (Cluster attribute) MasterType (in module app.type_hints) MATLAB_DIR (in module app.environment_settings) MatlabEngineContainer (class in app.domain.helpers.matlab_utils) MatlabEngineContainerError matrices_nodes_degrees (LoggingData attribute) matrix_global_opt() (MatlabEngineContainer method) MatrixError MatrixNotSquareError MAX_EPOCHS (Master attribute) MAX_EPOCHS_PLUS_ONE (Master attribute) MAX_REPLICATION_DELAY (in module app.environment_settings) members (Cluster attribute) membership_maintenance() (Cluster method) (HDFSCluster method) (SGCluster method) MIN_CONVERGENCE_THRESHOLD (in module app.environment_settings)

MIN_REPLICATION_DELAY (in module app.environment_settings) module app app.domain app.domain.cluster_groups app.domain.helpers app.domain.helpers.enums app.domain.helpers.exceptions app.domain.helpers.matlab_utils app.domain.helpers.matrices app.domain.helpers.smart_dataclasses app.domain.master_servers app.domain.network_nodes app.environment_settings app.hive_simulation app.mixing_rate_sampler app.sample_scenario_generator app.simfile_generator app.type_hints app.utils app.utils.convertions app.utils.crypto app.utils.randoms sample_scenario_fixer MONTH_EPOCHS (in module app.environment_settings)

N

name (FileBlockData attribute) (FileData attribute) network_nodes (Master attribute) new_desired_distribution() (SGCluster method) new_go_transition_matrix() (in module app.domain.helpers.matrices) new_mgo_transition_matrix() (in module app.domain.helpers.matrices) new_mh_transition_matrix() (in module app.domain.helpers.matrices) new_sdp_mh_transition_matrix() (in module app.domain.helpers.matrices) new_symmetric_connected_matrix() (in module app.domain.helpers.matrices) new_symmetric_matrix() (in module app.domain.helpers.matrices) new_transition_matrix() (SGCluster method) (SGClusterPerfect method) new_vector() (in module app.domain.helpers.matrices) NEWSCAST_CACHE_SIZE (in module app.environment_settings) NewscastCluster (class in app.domain.cluster_groups)

NewscastMaster (class in app.domain.master_servers) NewscastNode (class in app.domain.network_nodes) Node (class in app.domain.network_nodes) NodeDict (in module app.type_hints) nodes_complaints (SGClusterExt attribute) nodes_execute() (Cluster method) (HDFSCluster method) (NewscastCluster method) (SGCluster method) (SGClusterExt method) (SGClusterPerfect method) NodeType (in module app.type_hints) NOT_ACCEPTABLE (HttpCodes attribute) NOT_FOUND (HttpCodes attribute) number (FileBlockData attribute)

O

obj_to_json_string() (in module app.utils.convertions) off_node_count (LoggingData attribute) OFFLINE (Status attribute) OK (HttpCodes attribute)

ONLINE (Status attribute) origin (Master attribute) original_size (Cluster attribute) out_file (FileData attribute) OUTFILE_ROOT (in module app.environment_settings)

R

random_index() (in module app.utils.randoms) receive_part() (Node method) redundant_size (Cluster attribute) references (FileBlockData attribute) register_convergence() (LoggingData method) remove_cloud_reference() (SGCluster method) remove_file_routing() (SGNode method) ReplicasDict (in module app.type_hints) replicate_part() (HDFSNode method) (NewscastNode method) (Node method) (SGNode method)

replication_epoch (FileBlockData attribute) REPLICATION_LEVEL (in module app.environment_settings) RESOURCES_ROOT (in module app.environment_settings) route_part() (Cluster method) routing_table (SGNode attribute) RTOL (in module app.environment_settings) running (Cluster attribute)

S

sample_scenario_fixer module save_sets_and_reset() (LoggingData method) select_destination() (SGNode method) select_fastest_topology() (SGCluster method) (SGClusterPerfect method) send_part() (Node method) SERVER_DOWN (HttpCodes attribute) set_blocks_count() (in module app.environment_settings) set_blocks_size() (in module app.environment_settings) set_file_routing() (SGNode method) set_loss_chance() (in module app.environment_settings) set_replication_epoch() (Cluster method) (FileBlockData method) set_replication_level() (in module app.environment_settings) SGCluster (class in app.domain.cluster_groups) SGClusterExt (class in app.domain.cluster_groups) SGClusterPerfect (class in app.domain.cluster_groups) SGMaster (class in app.domain.master_servers) SGNode (class in app.domain.network_nodes)

SGNodeExt (class in app.domain.network_nodes) sha256 (FileBlockData attribute) sha256() (in module app.utils.crypto) SHARED_ROOT (in module app.environment_settings) shuffle() (NewscastNode method) shuffle_request() (NewscastNode method) sid (Master attribute) SIMULATION_ROOT (in module app.environment_settings) spread_files() (Cluster method) (NewscastCluster method) (SGCluster method) Status (class in app.domain.helpers.enums) status (Node attribute) str_copy() (in module app.utils.convertions) successfull (LoggingData attribute) sufficient_size (Cluster attribute) SUSPECT (Status attribute) suspicious_nodes (HDFSCluster attribute) (SGClusterExt attribute) suspicious_replies (Node attribute)

T

terminated (LoggingData attribute) terminated_messages (LoggingData attribute) TIME_OUT (HttpCodes attribute)

topologies_goal_achieved (LoggingData attribute) topologies_goal_distance (LoggingData attribute) transmissions_failed (LoggingData attribute) truncate_float_value() (in module app.utils.convertions)

U

update_epochs_to_recover() (FileBlockData method) update_status() (HDFSNode method) (NewscastNode method) (Node method) (SGNodeExt method)

uptime (Node attribute) utf8string_to_bytes() (in module app.utils.convertions)

V

v_ (SGCluster attribute)

view (NewscastNode attribute)

W

wire_k_out() (NewscastCluster method)

Y

yield_label() (in module app.simfile_generator)