module

Kiq::PipelineDslExtension

Constants

REGISTRY = {} of String => NodeMetadata

Class methods

clear_registry
get_pipeline_data(module_name : String) : Hash(String, NodeMetadata)
node_registry
register_node(module_name : String, node_name : String, metadata : NodeMetadata) : Nil
register_node_with_class(full_class_name : String, metadata : NodeMetadata) : Nil

Used by the node DSL macro: derives module_name/node_name from the generated node class's full name (the macro cannot see the caller's namespace — @type inside a macro invoked with an explicit receiver is the receiver module itself).

Nested types