View Source cets_status (cets v0.3.0)

-type info() ::
          #{available_nodes := [node()],
            unavailable_nodes := [node()],
            joined_nodes := [node()],
            discovered_nodes := [node()],
            discovery_works := boolean(),
            remote_nodes_without_disco := [node()],
            remote_nodes_with_unknown_tables := [node()],
            remote_unknown_tables := [table_name()],
            remote_nodes_with_missing_tables => [node()],
            remote_missing_tables := [table_name()],
            conflict_nodes := [node()],
            conflict_tables := [table_name()]}.

node_to_tab_nodes_map/0

-type node_to_tab_nodes_map() :: #{node() => tab_nodes_map()}.

Mapping from a node name to tab_nodes_map.

status_data/0

-type status_data() ::
          #{this_node := node(),
            online_nodes := [node()],
            system_info := cets_discovery:system_info(),
            available_nodes := [node()],
            local_table_to_other_nodes_map := tab_nodes_map(),
            node_to_tab_nodes_map := node_to_tab_nodes_map()}.

Intermediate status information.

tab_nodes_map/0

-type tab_nodes_map() :: #{Table :: atom() => Nodes :: ordsets:ordset(node())}.

Mapping from a table name to a node list.

table_name/0

-type table_name() :: cets:table_name().

Table name (atom).

Functions

format_data(_)

-spec format_data(status_data()) -> info().

Formats gathered data.

Contains pure functions logic.

gather_data(Disco)

-spec gather_data(disco_name()) -> status_data().

Collects status information.

get_local_table_to_other_nodes_map_from_disco(Disco)

-spec get_local_table_to_other_nodes_map_from_disco(disco_name()) -> tab_nodes_map().

status(Disco)

-spec status(disco_name()) -> info().

Collects and analyses status information.