Module refill

This module contains the refill flow task, which is used to refill flow with given table id and a time range.

Modules

test_send 🔒

Structs

RefillTask

Task to refill flow with given table id and a time range

TaskData 🔒

Enums

QueryStream 🔒

Query stream of RefillTask, simply wrap RecordBatches and RecordBatchStream and check output is not AffectedRows

TaskState 🔒

Refill task state