buffer

Apr 7, 2025

Changes in this version

+ type AvgCache struct

+ func NewAvgCache(startTime time.Time, endTime time.Time) *AvgCache

+ func (ac *AvgCache) Add(o *outcome.Outcome)

+ func (ac *AvgCache) GetOutputs() []types.AverageOutput

+ func (ac *AvgCache) GetProtoOutputs() []*pb.AverageOutput

+ func (ac *AvgCache) Reset(nextStartTime time.Time, nextEndTime time.Time)

+ type Buffer struct

+ func New(ctx context.Context, cfg *config.Buffer, flushFunc FlushFunc, log *slog.Logger) (*Buffer, error)

+ func (b *Buffer) Add(ctx context.Context, data *outcome.Outcome)

+ func (b *Buffer) Flush(parentCtx context.Context) error

+ func (b *Buffer) Start(ctx context.Context)

+ func (b *Buffer) Stop() error

+ type FlushFunc func(ctx context.Context, data *FlushOutcome) error

+ type FlushOutcome struct

+ AvgOutputs []types.AverageOutput

+ Outcomes []outcome.Outcome

+ type RunningAvg struct

+ func NewRunningAvg(o *outcome.Outcome, startTime time.Time, endTime time.Time, baseline float64) *RunningAvg

+ func (ra *RunningAvg) Add(v float64)