IoTPy.code.helper_functions package

Submodules

IoTPy.code.helper_functions.check_agent_parameter_types module

IoTPy.code.helper_functions.check_agent_parameter_types.check_func_output_for_multiple_streams(func, name, num_out_streams, output_snapshots)

IoTPy.code.helper_functions.check_agent_parameter_types.check_function_type(name, func)

IoTPy.code.helper_functions.check_agent_parameter_types.check_in_lists_type(name, in_lists, num_in_streams)

IoTPy.code.helper_functions.check_agent_parameter_types.check_list_of_streams_type(list_of_streams, agent_name, parameter_name)

Helper function to check the types of streams used by an agent. Used by: check_agent_arguments()

IoTPy.code.helper_functions.check_agent_parameter_types.check_many_agent_arguments(func, in_streams, out_streams, call_streams, name)

Checks the types of arguments used by an agent.

IoTPy.code.helper_functions.check_agent_parameter_types.check_map_agent_arguments(func, in_stream, out_stream, call_streams, name)

IoTPy.code.helper_functions.check_agent_parameter_types.check_merge_agent_arguments(func, in_streams, out_stream, call_streams, name)

IoTPy.code.helper_functions.check_agent_parameter_types.check_num_args_in_func(state, name, func, func_args, func_kwargs)

IoTPy.code.helper_functions.check_agent_parameter_types.check_num_args_in_func_no_state(name, func, func_args=[], func_kwargs={})

IoTPy.code.helper_functions.check_agent_parameter_types.check_num_args_in_func_with_state(name, func, func_args=[], func_kwargs={})

IoTPy.code.helper_functions.check_agent_parameter_types.check_sink_agent_arguments(func, in_stream, call_streams, name)

IoTPy.code.helper_functions.check_agent_parameter_types.check_split_agent_arguments(func, in_stream, out_streams, call_streams, name)

IoTPy.code.helper_functions.check_agent_parameter_types.check_stream_type(name, in_or_out_stream_str, stream)

IoTPy.code.helper_functions.check_agent_parameter_types.check_window_and_step_sizes(name, window_size, step_size)

IoTPy.code.helper_functions.check_agent_parameter_types.check_zip_agent_arguments(in_streams, out_stream, name)

IoTPy.code.helper_functions.recent_values module

IoTPy.code.helper_functions.recent_values.recent_values(stream)

Module contents