Versions in this module Expand all Collapse all v1 v1.3.14 May 13, 2026 v1.3.13 Apr 17, 2026 Changes in this version + type FlowCache struct + OutFlows chan pb.Flow + func NewFlowCache(activeTimeout time.Duration, maxFlows int, outFlows chan pb.Flow) *FlowCache + func (c *FlowCache) CacheFlow(ctx context.Context, flow pb.Flow) error + func (c *FlowCache) Close() error + func (c *FlowCache) Run(ctx context.Context, logger *zap.Logger) error
Go to main page