HyperStream
stable
hyperstream package
tests package
HyperStream
Docs
»
Index
Edit on GitHub
Index
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
K
|
L
|
M
|
N
|
O
|
P
|
R
|
S
|
T
|
U
|
V
|
W
A
absolute() (hyperstream.time_interval.RelativeTimeInterval method)
add_workflow() (hyperstream.hyperstream.HyperStream method)
(hyperstream.workflow.workflow_manager.WorkflowManager method)
AggregateTool (class in hyperstream.tool.aggregate_tool)
alignment_node (hyperstream.models.factor.FactorDefinitionModel attribute)
all_time() (hyperstream.time_interval.TimeInterval class method)
any_set() (in module hyperstream.itertools2.itertools2)
append() (hyperstream.stream.stream_collections.StreamInstanceCollection method)
as_dict() (hyperstream.stream.stream_id.StreamId method)
(hyperstream.stream.stream_instance.StreamInstance method)
as_list() (hyperstream.stream.stream_instance.StreamInstance method)
as_raw() (hyperstream.stream.stream_id.StreamId method)
assert_all_close() (in module tests.helpers)
assert_dict_equal() (in module tests.helpers)
AssetsChannel (class in hyperstream.channels.assets_channel)
AssetStream (class in hyperstream.stream.stream)
B
BaseChannel (class in hyperstream.channels.base_channel)
BaseTool (class in hyperstream.tool.base_tool)
C
calculated_intervals (hyperstream.models.stream.StreamDefinitionModel attribute)
(hyperstream.stream.stream.AssetStream attribute)
(hyperstream.stream.stream.DatabaseStream attribute)
(hyperstream.stream.stream.Stream attribute)
channel_id (hyperstream.models.node.NodeDefinitionModel attribute)
(hyperstream.models.stream.StreamDefinitionModel attribute)
ChannelAlreadyExistsError
ChannelNotFoundError
check_calculation_times() (hyperstream.channels.memory_channel.MemoryChannel method)
check_input_stream_count() (in module hyperstream.utils.decorators)
check_multi_output_plate_compatibility() (hyperstream.workflow.workflow.Workflow static method)
check_output_format() (in module hyperstream.utils.decorators)
check_plate_compatibility() (hyperstream.workflow.workflow.Workflow static method)
check_tool_defined() (in module hyperstream.utils.decorators)
clear_sessions() (hyperstream.hyperstream.HyperStream method)
Client (class in hyperstream.client)
client (hyperstream.client.Client attribute)
code_pickler() (in module hyperstream.workflow.workflow_manager)
code_unpickler() (in module hyperstream.workflow.workflow_manager)
commit_all() (hyperstream.workflow.workflow_manager.WorkflowManager method)
commit_workflow() (hyperstream.workflow.workflow_manager.WorkflowManager method)
complement (hyperstream.models.plate.PlateDefinitionModel attribute)
(hyperstream.models.plate.PlateModel attribute)
component() (hyperstream.stream.stream_view.StreamView method)
component_filter() (hyperstream.stream.stream_view.StreamView method)
compress() (hyperstream.time_interval.TimeIntervals method)
ConfigurationError
connect() (hyperstream.client.Client method)
construct_experiment_id() (in module hyperstream.utils.time_utils)
count() (in module hyperstream.itertools2.itertools2)
create_factor() (hyperstream.workflow.workflow.Workflow method)
create_factor_general() (hyperstream.workflow.workflow.Workflow method)
create_multi_output_factor() (hyperstream.workflow.workflow.Workflow method)
create_node() (hyperstream.workflow.workflow.Workflow method)
create_node_creation_factor() (hyperstream.workflow.workflow.Workflow method)
create_plate() (in module tests.helpers)
create_stream() (hyperstream.channels.assets_channel.AssetsChannel method)
(hyperstream.channels.base_channel.BaseChannel method)
(hyperstream.channels.database_channel.DatabaseChannel method)
(hyperstream.channels.memory_channel.MemoryChannel method)
(hyperstream.channels.memory_channel.ReadOnlyMemoryChannel method)
create_workflow() (hyperstream.hyperstream.HyperStream method)
current_session (hyperstream.hyperstream.HyperStream attribute)
D
data (hyperstream.models.meta_data.MetaDataModel attribute)
data_loader() (hyperstream.channels.file_channel.FileChannel method)
(hyperstream.channels.module_channel.ModuleChannel method)
DatabaseChannel (class in hyperstream.channels.database_channel)
DatabaseStream (class in hyperstream.stream.stream)
datetime (hyperstream.models.stream.StreamInstanceModel attribute)
datetime2unix() (in module hyperstream.utils.time_utils)
db (hyperstream.client.Client attribute)
delete_meta_data() (in module tests.helpers)
delete_nones() (hyperstream.stream.stream_view.StreamView method)
delete_plate() (in module tests.helpers)
delete_workflow() (hyperstream.workflow.workflow_manager.WorkflowManager method)
description (hyperstream.models.factor.OutputPlateDefinitionModel attribute)
(hyperstream.models.plate.PlateDefinitionModel attribute)
(hyperstream.models.workflow.WorkflowDefinitionModel attribute)
dict_items() (hyperstream.stream.stream_view.StreamView method)
dict_iteritems() (hyperstream.stream.stream_view.StreamView method)
duration2str() (in module hyperstream.utils.time_utils)
E
end (hyperstream.models.time_interval.TimeIntervalModel attribute)
(hyperstream.time_interval.RelativeTimeInterval attribute)
(hyperstream.time_interval.TimeInterval attribute)
(hyperstream.time_interval.TimeIntervals attribute)
execute() (hyperstream.online_engine.OnlineEngine method)
(hyperstream.tool.multi_output_tool.MultiOutputTool method)
(hyperstream.tool.plate_creation_tool.PlateCreationTool method)
(hyperstream.tool.selector_tool.SelectorTool method)
(hyperstream.tool.tool.Tool method)
(hyperstream.workflow.workflow.Workflow method)
execute_all() (hyperstream.workflow.workflow_manager.WorkflowManager method)
execute_tool() (hyperstream.channels.base_channel.BaseChannel method)
extend() (hyperstream.stream.stream_collections.StreamInstanceCollection method)
F
factor_type (hyperstream.models.factor.FactorDefinitionModel attribute)
FactorAlreadyExistsError
FactorDefinitionError
FactorDefinitionModel (class in hyperstream.models.factor)
factorgraph_viz() (hyperstream.workflow.workflow.Workflow static method)
factors (hyperstream.models.workflow.WorkflowDefinitionModel attribute)
file_filter() (hyperstream.channels.file_channel.FileChannel method)
(hyperstream.channels.module_channel.ModuleChannel method)
FileChannel (class in hyperstream.channels.file_channel)
FileDateTimeVersion (class in hyperstream.channels.file_channel)
find_stream() (hyperstream.channels.base_channel.BaseChannel method)
find_streams() (hyperstream.channels.base_channel.BaseChannel method)
first() (hyperstream.stream.stream_view.StreamView method)
func_dump() (in module hyperstream.utils.serialization)
func_load() (in module hyperstream.utils.serialization)
func_reconstruct_closure() (in module hyperstream.utils.serialization)
G
get_calculated_intervals() (hyperstream.models.stream.StreamDefinitionModel method)
get_config_value() (hyperstream.client.Client method)
get_meta_data() (in module tests.helpers)
get_model() (hyperstream.tool.base_tool.BaseTool method)
get_or_create_stream() (hyperstream.channels.base_channel.BaseChannel method)
get_results() (hyperstream.channels.base_channel.BaseChannel method)
(hyperstream.channels.database_channel.DatabaseChannel method)
(hyperstream.channels.file_channel.FileChannel method)
(hyperstream.channels.memory_channel.MemoryChannel method)
(hyperstream.channels.memory_channel.ReadOnlyMemoryChannel method)
(hyperstream.channels.tool_channel.ToolChannel method)
get_stream_id() (in module hyperstream.stream.stream_id)
get_stream_writer() (hyperstream.channels.base_channel.BaseChannel method)
(hyperstream.channels.database_channel.DatabaseChannel method)
(hyperstream.channels.memory_channel.MemoryChannel method)
(hyperstream.channels.memory_channel.ReadOnlyMemoryChannel method)
get_timedelta() (in module hyperstream.utils.time_utils)
H
handle_exception() (in module hyperstream.utils.errors)
head() (hyperstream.stream.stream_view.StreamView method)
humanized (hyperstream.time_interval.TimeInterval attribute)
(hyperstream.time_interval.TimeIntervals attribute)
HyperStream (class in hyperstream.hyperstream)
hyperstream (module)
hyperstream.channels (module)
hyperstream.channels.assets_channel (module)
hyperstream.channels.base_channel (module)
hyperstream.channels.database_channel (module)
hyperstream.channels.file_channel (module)
hyperstream.channels.memory_channel (module)
hyperstream.channels.module_channel (module)
hyperstream.channels.tool_channel (module)
hyperstream.client (module)
hyperstream.config (module)
hyperstream.hyperstream (module)
hyperstream.itertools2 (module)
hyperstream.itertools2.itertools2 (module)
hyperstream.models (module)
hyperstream.models.factor (module)
hyperstream.models.meta_data (module)
hyperstream.models.node (module)
hyperstream.models.plate (module)
hyperstream.models.stream (module)
hyperstream.models.time_interval (module)
hyperstream.models.tool (module)
hyperstream.models.workflow (module)
hyperstream.online_engine (module)
hyperstream.plugin_manager (module)
hyperstream.stream (module)
hyperstream.stream.stream (module)
hyperstream.stream.stream_collections (module)
hyperstream.stream.stream_id (module)
hyperstream.stream.stream_instance (module)
hyperstream.stream.stream_view (module)
hyperstream.time_interval (module)
hyperstream.tool (module)
hyperstream.tool.aggregate_tool (module)
hyperstream.tool.base_tool (module)
hyperstream.tool.multi_output_tool (module)
hyperstream.tool.plate_creation_tool (module)
hyperstream.tool.selector_tool (module)
hyperstream.tool.tool (module)
hyperstream.utils (module)
hyperstream.utils.decorators (module)
hyperstream.utils.errors (module)
hyperstream.utils.serialization (module)
hyperstream.utils.time_utils (module)
hyperstream.version (module)
hyperstream.workflow (module)
hyperstream.workflow.workflow (module)
hyperstream.workflow.workflow_manager (module)
HyperStreamConfig (class in hyperstream.config)
HyperStreamTimeIntervalTests (class in tests.test_time_interval)
I
id (hyperstream.models.meta_data.MetaDataModel attribute)
(hyperstream.models.plate.PlateDefinitionModel attribute)
(hyperstream.models.stream.StreamDefinitionModel attribute)
(hyperstream.models.stream.StreamInstanceModel attribute)
(hyperstream.models.workflow.WorkflowDefinitionModel attribute)
(hyperstream.models.workflow.WorkflowStatusModel attribute)
identifier (hyperstream.models.meta_data.MetaDataModel attribute)
IncompatiblePlatesError
IncompatibleToolError
insert_meta_data() (in module tests.helpers)
is_close() (in module tests.helpers)
is_empty (hyperstream.time_interval.TimeIntervals attribute)
is_function (hyperstream.models.tool.ToolParameterModel attribute)
is_naive() (in module hyperstream.utils.time_utils)
is_python (hyperstream.channels.file_channel.FileDateTimeVersion attribute)
is_set (hyperstream.models.tool.ToolParameterModel attribute)
islice() (hyperstream.stream.stream_view.StreamView method)
items() (hyperstream.stream.stream_view.StreamView method)
iteritems() (hyperstream.stream.stream_view.StreamView method)
itertimestamps() (hyperstream.stream.stream_view.StreamView method)
itervalues() (hyperstream.stream.stream_view.StreamView method)
J
json_serial() (in module hyperstream.utils.time_utils)
K
key (hyperstream.models.tool.ToolParameterModel attribute)
L
last() (hyperstream.stream.stream_view.StreamView method)
last_accessed (hyperstream.models.stream.StreamDefinitionModel attribute)
(hyperstream.models.workflow.WorkflowStatusModel attribute)
(hyperstream.stream.stream.DatabaseStream attribute)
last_messages (tests.helpers.MqttClient attribute)
last_updated (hyperstream.models.stream.StreamDefinitionModel attribute)
(hyperstream.models.workflow.WorkflowStatusModel attribute)
(hyperstream.stream.stream.DatabaseStream attribute)
LinkageError
load() (hyperstream.stream.stream.DatabaseStream method)
load_channels() (hyperstream.plugin_manager.Plugin method)
load_workflow() (hyperstream.workflow.workflow_manager.WorkflowManager method)
M
MemoryChannel (class in hyperstream.channels.memory_channel)
message (hyperstream.utils.errors.FactorAlreadyExistsError attribute)
(hyperstream.utils.errors.NodeAlreadyExistsError attribute)
(hyperstream.utils.errors.PlateDefinitionError attribute)
(hyperstream.utils.errors.PlateEmptyError attribute)
(hyperstream.utils.errors.StreamNotAvailableError attribute)
(hyperstream.utils.errors.ToolExecutionError attribute)
message() (hyperstream.tool.base_tool.BaseTool method)
meta_data (hyperstream.models.stream.StreamIdField attribute)
meta_data_id (hyperstream.models.factor.OutputPlateDefinitionModel attribute)
(hyperstream.models.plate.PlateDefinitionModel attribute)
(hyperstream.models.plate.PlateModel attribute)
MetaDataModel (class in hyperstream.models.meta_data)
MetaDataModel.DoesNotExist
MetaDataModel.MultipleObjectsReturned
ModuleChannel (class in hyperstream.channels.module_channel)
monitor (hyperstream.models.workflow.WorkflowDefinitionModel attribute)
mosquitto_is_running() (in module tests.helpers)
MqttClient (class in tests.helpers)
MultiOutputTool (class in hyperstream.tool.multi_output_tool)
MultipleStreamsFoundError
N
name (hyperstream.models.stream.StreamIdField attribute)
(hyperstream.models.tool.ToolModel attribute)
(hyperstream.models.workflow.WorkflowDefinitionModel attribute)
(hyperstream.tool.base_tool.BaseTool attribute)
new_session() (hyperstream.hyperstream.HyperStream method)
NodeAlreadyExistsError
NodeDefinitionError
NodeDefinitionModel (class in hyperstream.models.node)
nodes (hyperstream.models.workflow.WorkflowDefinitionModel attribute)
non_empty_streams (hyperstream.channels.memory_channel.MemoryChannel attribute)
now_minus() (hyperstream.time_interval.TimeInterval class method)
O
objects (hyperstream.models.meta_data.MetaDataModel attribute)
(hyperstream.models.plate.PlateDefinitionModel attribute)
(hyperstream.models.stream.StreamDefinitionModel attribute)
(hyperstream.models.stream.StreamInstanceModel attribute)
(hyperstream.models.workflow.WorkflowDefinitionModel attribute)
(hyperstream.models.workflow.WorkflowStatusModel attribute)
on_connect() (tests.helpers.MqttClient method)
on_message() (tests.helpers.MqttClient method)
online (hyperstream.models.workflow.WorkflowDefinitionModel attribute)
online_average() (in module hyperstream.itertools2.itertools2)
online_product() (in module hyperstream.itertools2.itertools2)
online_sum() (in module hyperstream.itertools2.itertools2)
online_variance() (in module hyperstream.itertools2.itertools2)
OnlineEngine (class in hyperstream.online_engine)
OnlineEngineConfig (class in hyperstream.config)
output_plate (hyperstream.models.factor.FactorDefinitionModel attribute)
OutputPlateDefinitionModel (class in hyperstream.models.factor)
owner (hyperstream.models.workflow.WorkflowDefinitionModel attribute)
P
parameters (hyperstream.models.tool.ToolModel attribute)
(hyperstream.tool.base_tool.BaseTool attribute)
parameters_dict (hyperstream.tool.base_tool.BaseTool attribute)
parameters_from_dicts() (hyperstream.tool.base_tool.BaseTool static method)
parameters_from_model() (hyperstream.tool.base_tool.BaseTool static method)
parent (hyperstream.models.meta_data.MetaDataModel attribute)
parent_node (hyperstream.stream.stream.Stream attribute)
parent_plate (hyperstream.models.plate.PlateDefinitionModel attribute)
parse() (hyperstream.time_interval.TimeIntervals method)
parse_time_tuple() (in module hyperstream.time_interval)
path (hyperstream.channels.file_channel.FileChannel attribute)
plate_id (hyperstream.models.factor.OutputPlateDefinitionModel attribute)
(hyperstream.models.plate.PlateDefinitionModel attribute)
plate_ids (hyperstream.models.node.NodeDefinitionModel attribute)
PlateCreationTool (class in hyperstream.tool.plate_creation_tool)
PlateDefinitionError
PlateDefinitionModel (class in hyperstream.models.plate)
PlateDefinitionModel.DoesNotExist
PlateDefinitionModel.MultipleObjectsReturned
PlateEmptyError
PlateModel (class in hyperstream.models.plate)
PlateNotFoundError
Plugin (class in hyperstream.plugin_manager)
populate_tools_and_factors() (hyperstream.hyperstream.HyperStream method)
profile() (in module hyperstream.time_interval)
purge() (hyperstream.stream.stream.Stream method)
purge_all() (hyperstream.channels.memory_channel.MemoryChannel method)
purge_node() (hyperstream.channels.base_channel.BaseChannel method)
purge_stream() (hyperstream.channels.assets_channel.AssetsChannel method)
(hyperstream.channels.base_channel.BaseChannel method)
(hyperstream.channels.database_channel.DatabaseChannel method)
(hyperstream.channels.memory_channel.MemoryChannel method)
R
ReadOnlyMemoryChannel (class in hyperstream.channels.memory_channel)
reconstruct_interval() (in module hyperstream.utils.time_utils)
RelativeTimeInterval (class in hyperstream.time_interval)
remove_microseconds() (in module hyperstream.utils.time_utils)
requested_intervals (hyperstream.models.workflow.WorkflowStatusModel attribute)
(hyperstream.workflow.workflow.Workflow attribute)
resource_manager() (in module tests.helpers)
S
sandbox (hyperstream.models.stream.StreamDefinitionModel attribute)
save() (hyperstream.stream.stream.DatabaseStream method)
SelectorTool (class in hyperstream.tool.selector_tool)
session (hyperstream.client.Client attribute)
sessions (hyperstream.hyperstream.HyperStream attribute)
set_all_requested_intervals() (hyperstream.workflow.workflow_manager.WorkflowManager method)
set_calculated_intervals() (hyperstream.models.stream.StreamDefinitionModel method)
set_requested_intervals() (hyperstream.workflow.workflow_manager.WorkflowManager method)
set_tool_reference() (hyperstream.stream.stream.Stream method)
setup() (in module tests.helpers)
sinks (hyperstream.models.factor.FactorDefinitionModel attribute)
sources (hyperstream.models.factor.FactorDefinitionModel attribute)
span (hyperstream.time_interval.TimeIntervals attribute)
split() (hyperstream.time_interval.TimeIntervals method)
splitting_node (hyperstream.models.factor.FactorDefinitionModel attribute)
start (hyperstream.models.time_interval.TimeIntervalModel attribute)
(hyperstream.time_interval.RelativeTimeInterval attribute)
(hyperstream.time_interval.TimeInterval attribute)
(hyperstream.time_interval.TimeIntervals attribute)
Stream (class in hyperstream.stream.stream)
stream_id (hyperstream.models.stream.StreamDefinitionModel attribute)
(hyperstream.models.stream.StreamInstanceModel attribute)
stream_name (hyperstream.models.node.NodeDefinitionModel attribute)
stream_type (hyperstream.models.stream.StreamDefinitionModel attribute)
(hyperstream.models.stream.StreamInstanceModel attribute)
StreamAlreadyExistsError
StreamDataNotAvailableError
StreamDefinitionModel (class in hyperstream.models.stream)
StreamDefinitionModel.DoesNotExist
StreamDefinitionModel.MultipleObjectsReturned
StreamDict (class in hyperstream.stream.stream_collections)
StreamId (class in hyperstream.stream.stream_id)
StreamIdField (class in hyperstream.models.stream)
StreamInstance (class in hyperstream.stream.stream_instance)
StreamInstanceCollection (class in hyperstream.stream.stream_collections)
StreamInstanceModel (class in hyperstream.models.stream)
StreamInstanceModel.DoesNotExist
StreamInstanceModel.MultipleObjectsReturned
StreamMetaInstance (class in hyperstream.stream.stream_instance)
StreamNotAvailableError
StreamNotFoundError
StreamView (class in hyperstream.stream.stream_view)
T
tag (hyperstream.models.meta_data.MetaDataModel attribute)
tail() (hyperstream.stream.stream_view.StreamView method)
teardown() (in module tests.helpers)
test_constructors() (tests.test_time_interval.HyperStreamTimeIntervalTests method)
test_relative_time_interval() (tests.test_time_interval.HyperStreamTimeIntervalTests method)
test_time_interval() (tests.test_time_interval.HyperStreamTimeIntervalTests method)
tests (module)
tests.helpers (module)
tests.test_time_interval (module)
TimeInterval (class in hyperstream.time_interval)
TimeIntervalModel (class in hyperstream.models.time_interval)
TimeIntervals (class in hyperstream.time_interval)
timeit() (in module hyperstream.utils.decorators)
timestamps() (hyperstream.stream.stream_view.StreamView method)
to_dict() (hyperstream.models.meta_data.MetaDataModel method)
(hyperstream.workflow.workflow.Workflow method)
to_json() (hyperstream.stream.stream_id.StreamId method)
(hyperstream.time_interval.TimeInterval method)
(hyperstream.time_interval.TimeIntervals method)
(hyperstream.workflow.workflow.Workflow method)
to_tuple() (hyperstream.time_interval.TimeInterval method)
Tool (class in hyperstream.tool.tool)
tool (hyperstream.models.factor.FactorDefinitionModel attribute)
ToolChannel (class in hyperstream.channels.tool_channel)
ToolExecutionError
ToolInitialisationError
ToolModel (class in hyperstream.models.tool)
ToolNotFoundError
ToolParameterModel (class in hyperstream.models.tool)
U
unix2datetime() (in module hyperstream.utils.time_utils)
up_to_now() (hyperstream.time_interval.TimeInterval class method)
update_state() (hyperstream.channels.memory_channel.ReadOnlyMemoryChannel method)
(hyperstream.channels.module_channel.ModuleChannel method)
update_streams() (hyperstream.channels.assets_channel.AssetsChannel method)
(hyperstream.channels.base_channel.BaseChannel method)
(hyperstream.channels.database_channel.DatabaseChannel method)
(hyperstream.channels.file_channel.FileChannel method)
(hyperstream.channels.memory_channel.MemoryChannel method)
(hyperstream.channels.memory_channel.ReadOnlyMemoryChannel method)
use_provided_values (hyperstream.models.factor.OutputPlateDefinitionModel attribute)
utcnow() (in module hyperstream.utils.time_utils)
V
value (hyperstream.models.stream.StreamInstanceModel attribute)
(hyperstream.models.tool.ToolParameterModel attribute)
values (hyperstream.models.plate.PlateDefinitionModel attribute)
(hyperstream.models.plate.PlateModel attribute)
values() (hyperstream.stream.stream_view.StreamView method)
version (hyperstream.models.tool.ToolModel attribute)
versions (hyperstream.channels.module_channel.ModuleChannel attribute)
W
walk() (hyperstream.channels.file_channel.FileChannel static method)
width (hyperstream.time_interval.TimeInterval attribute)
window() (hyperstream.stream.stream.Stream method)
Workflow (class in hyperstream.workflow.workflow)
workflow_id (hyperstream.models.workflow.WorkflowDefinitionModel attribute)
(hyperstream.models.workflow.WorkflowStatusModel attribute)
WorkflowDefinitionModel (class in hyperstream.models.workflow)
WorkflowDefinitionModel.DoesNotExist
WorkflowDefinitionModel.MultipleObjectsReturned
WorkflowManager (class in hyperstream.workflow.workflow_manager)
WorkflowMonitor (class in hyperstream.workflow.workflow)
WorkflowStatusModel (class in hyperstream.models.workflow)
WorkflowStatusModel.DoesNotExist
WorkflowStatusModel.MultipleObjectsReturned
write_to_history() (hyperstream.tool.base_tool.BaseTool static method)
write_to_stream() (hyperstream.channels.assets_channel.AssetsChannel method)
writer (hyperstream.stream.stream.Stream attribute)
Read the Docs
v: stable
Versions
latest
stable
Downloads
pdf
htmlzip
epub
On Read the Docs
Project Home
Builds
Free document hosting provided by
Read the Docs
.