flow

Module adapter

Source
Expand description

for getting data from source and sending results to sink and communicating with other parts of the database

Modules§

  • flownode_impl 🔒
    impl FlowNode trait for FlowNodeManager so standalone can call them
  • node_context 🔒
    Node context, prone to change with every incoming requests
  • parse_expr 🔒
    parse expr like “ts <= now() - interval ‘5 m’”
  • refill 🔒
    This module contains the refill flow task, which is used to refill flow with given table id and a time range.
  • stat 🔒
  • table_source 🔒
    How to query table information from database
  • util 🔒
    Util functions for adapter
  • worker 🔒
    For single-thread flow worker

Structs§

Enums§

Constants§

Functions§

Type Aliases§