Chronaxis用户手册English
本页目录相关类型对象导航RecordPointBufferRecordPointBuffer._require_openRecordPointBuffer.consumeRecordPointBuffer.expire_at

chronaxis.execution.record_point_buffer

共享有限驱动点的接收与失效处理,不执行数值统计或创建历史。

积分和时间统计沿用同一同一时刻/递增/条件门槛,具体owner负责预付缓冲费用并实现_flush。 该内部基类不能独立构造使用;没有独立预算或第二份输入缓冲。

这是模块参考。日常调用先查公开API索引;下划线对象和嵌套函数供维护者查阅。签名来自固定源码,公开类构造签名经实际Python接口核对。

相关类型

D、ResultClosedError、ScalarValue

对象导航

对象 用途
RecordPointBuffer 复用一份有限点缓冲,子类初始化字段并拥有数值状态及关闭过程。
RecordPointBuffer._require_open 失败/清理/关闭后拒绝读取与推进。
RecordPointBuffer.consume 接收已按所选驱动求值的有限点,不先截掉窗口两侧记录。
RecordPointBuffer.expire_at 依赖中途失效时截断最后待结算驱动点,不新增驱动点或补计周期。
导入与重导出来源(展开)
python
from ..core.numeric import ScalarValue
from ..core.types import SignalDType as D
from ..results.errors import ResultClosedError
from ..timebase.conversion import require_int64_ns

RecordPointBuffer

复用一份有限点缓冲,子类初始化字段并拥有数值状态及关闭过程。

python
class RecordPointBuffer

源码:src/chronaxis/execution/record_point_buffer.py:13(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

RecordPointBuffer._require_open

失败/清理/关闭后拒绝读取与推进。

python
RecordPointBuffer._require_open()

参数:无显式参数。

参数说明

无。

返回说明

None。

异常说明

ResultClosedError。

源码:src/chronaxis/execution/record_point_buffer.py:16(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

RecordPointBuffer.consume

接收已按所选驱动求值的有限点,不先截掉窗口两侧记录。

python
RecordPointBuffer.consume(rows, *, conditions=None, condition_valid_until_ns=None, actual_value_updates=None)

参数

名称 数据类型 必填 省略时的值 用途、取值和效果
rows Sequence[tuple] 是 无 位置或关键字。有限计算点序列:实际时刻、ScalarValue、数值实际截止、条件ScalarValue及其实际截止;样本统计另附真实更新标志。
conditions Sequence[tuple[int, ScalarValue, int | None]] | None 否 None 仅关键字。与值点对应的条件记录,分别含实际时间、布尔值及实际截止;None表示无外部条件。
condition_valid_until_ns Sequence[int | None] | None 否 None 仅关键字。各筛选条件的真实有效截止,单位纳秒;条件未知不能当作False或补零。
actual_value_updates tuple[bool, ...] | None 否 None 仅关键字。逐点真实值更新标志;用于样本统计排除条件变化和有效期边界。None不额外附加样本标志。

返回说明

None。

异常说明

类型、时间倒退/同一时刻、预算/取消;任何错误后不交付前缀结果。

约束说明

上游处理同一时刻、条件及TTL;无效值必须传入,不能跳过后连接有效值。

源码:src/chronaxis/execution/record_point_buffer.py:21(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

RecordPointBuffer.expire_at

依赖中途失效时截断最后待结算驱动点,不新增驱动点或补计周期。

python
RecordPointBuffer.expire_at(time_ns, *, condition=False)

参数

名称 数据类型 必填 省略时的值 用途、取值和效果
time_ns int | None 是 无 位置或关键字。指定依赖失效的实际时刻,传已按时间顺序处理的整数纳秒;必须在下一驱动点前通知,不接受None。
condition bool 否 False 仅关键字。是否操作条件列的有效截止;False操作数值列,True操作条件列。

返回说明

None。

异常说明

非法/回退时间或对象关闭失败;调用方必须在下一驱动点进入前通知。

源码:src/chronaxis/execution/record_point_buffer.py:79(行号属于 8904c2f744951857659abd40aaa3535d57faf53c)。

Chronaxis 用户手册 · 离线阅读