cache

type FlowCache ¶

type FlowCache struct {
	OutFlows chan pb.Flow
	// contains filtered or unexported fields
}

FlowCache caches flows to be exported. Evicts flows from the cache for: - lack of resources: cache has reached maxFlows capacity - active timeout: flow has been cached longer than activeTimeout.

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