Ctrl+K

ethos_penalps.stream_node_distributor

ethos_penalps.stream_node_distributor#

Module Contents#

Classes#

SplittedOrderCollection

OrderDistributor

class ethos_penalps.stream_node_distributor.SplittedOrderCollection#
stream_name: str#
commodity: ethos_penalps.data_classes.Commodity#
process_chain_identifier: ethos_penalps.data_classes.ProcessChainIdentifier#
order_data_frame: pandas.DataFrame#
target_mass: numbers.Number#
current_order_number: int = 0#
check_if_order_are_empty()#
get_order_by_order_number(order_number: int) → ethos_penalps.data_classes.ProductionOrder#
update_order(produced_mass: numbers.Number)#
class ethos_penalps.stream_node_distributor.OrderDistributor(stream_handler: ethos_penalps.stream_handler.StreamHandler, production_order_collection: ethos_penalps.data_classes.OrderCollection, node_name: str)#
update_order_collection(new_order_collection: ethos_penalps.data_classes.OrderCollection)#
set_current_splitted_order_by_chain_identifier(process_chain_identifier: ethos_penalps.data_classes.ProcessChainIdentifier)#
get_current_splitted_order() → SplittedOrderCollection#
check_if_there_are_sufficient_order_for_distribution()#
split_production_order_dict()#
aggregate_order_continuos_streams(order_data_frame: pandas.DataFrame, total_operation_rate_of_streams: numbers.Number) → pandas.DataFrame#
aggregate_order_batch_streams(input_order_data_frame: pandas.DataFrame, order_target_mass: numbers.Number) → pandas.DataFrame#
get_current_production_order() → ethos_penalps.data_classes.ProductionOrder#
update_production_order(produced_mass: numbers.Number)#
get_current_stream_name() → str#
add_stream_name(stream_name: str, process_chain_identifier: ethos_penalps.data_classes.ProcessChainIdentifier)#
check_if_current_order_is_fulfilled() → bool#
update_current_order_number()#
check_if_process_chain_orders_are_satisfied() → bool#
get_stream_name_chain_identifier(process_chain_identifier: ethos_penalps.data_classes.ProcessChainIdentifier) → str#
Contents