process

Documentation

Index

• type Aggregator
  • func (agg *Aggregator) Sink(ctx context.Context, inCh <-chan *ast.Day) error
• type Balancer
  • func (pr *Balancer) Process(ctx context.Context, inCh <-chan *ast.Day, outCh chan<- *ast.Day) error
• type Collection
• type Error
  • func (be Error) Error() string
• type JournalSource
  • func (js *JournalSource) Load(ctx context.Context) error
  • func (js JournalSource) Max() time.Time
  • func (js JournalSource) Min() time.Time
  • func (js JournalSource) Source(ctx context.Context, outCh chan<- *ast.Day) error
• type PeriodDiffer
  • func (pf PeriodDiffer) Process(ctx context.Context, inCh <-chan *ast.Period, outCh chan<- *ast.Period) error
• type PeriodFilter
  • func (pf *PeriodFilter) Process(ctx context.Context, inCh <-chan *ast.Day, outCh chan<- *ast.Period) error
• type PriceUpdater
  • func (pu PriceUpdater) Process(ctx context.Context, inCh <-chan *ast.Day, outCh chan<- *ast.Day) error
• type Valuator
  • func (pr *Valuator) Process(ctx context.Context, inCh <-chan *ast.Day, outCh chan<- *ast.Day) error

Types

type Aggregator

type Aggregator struct {
	Mappers   amounts.Mapper
	Filter    filter.Filter[amounts.Key]
	Valuation *journal.Commodity
	Value     bool

	Collection Collection
}

func (*Aggregator) Sink

func (agg *Aggregator) Sink(ctx context.Context, inCh <-chan *ast.Day) error

type Balancer

type Balancer struct {
	Context journal.Context
}

Balancer processes ASTs.

func (*Balancer) Process

func (pr *Balancer) Process(ctx context.Context, inCh <-chan *ast.Day, outCh chan<- *ast.Day) error

Process processes days.

type Collection

type Collection interface {
	Insert(k amounts.Key, v decimal.Decimal)
}

type Error

type Error struct {
	// contains filtered or unexported fields
}

Error is an error.

func (Error) Error

func (be Error) Error() string

type JournalSource

type JournalSource struct {
	Context journal.Context

	Path     string
	Expand   bool
	Filter   journal.Filter
	AutoLoad bool
	// contains filtered or unexported fields
}

JournalSource emits journal data in daily batches.

func (*JournalSource) Load

func (js *JournalSource) Load(ctx context.Context) error

func (JournalSource) Max

func (js JournalSource) Max() time.Time

func (JournalSource) Min

func (js JournalSource) Min() time.Time

func (JournalSource) Source

func (js JournalSource) Source(ctx context.Context, outCh chan<- *ast.Day) error

type PeriodDiffer

type PeriodDiffer struct {
	Valuation *journal.Commodity
}

PeriodDiffer filters the incoming days according to the dates specified.

func (PeriodDiffer) Process

func (pf PeriodDiffer) Process(ctx context.Context, inCh <-chan *ast.Period, outCh chan<- *ast.Period) error

Process does the diffing.

type PeriodFilter

type PeriodFilter struct {
	From, To time.Time
	Interval date.Interval
	Last     int
}

PeriodFilter filters the incoming days according to the dates specified.

func (*PeriodFilter) Process

func (pf *PeriodFilter) Process(ctx context.Context, inCh <-chan *ast.Day, outCh chan<- *ast.Period) error

Process does the filtering.

type PriceUpdater

type PriceUpdater struct {
	Valuation *journal.Commodity
}

PriceUpdater updates the prices in a stream of days.

func (PriceUpdater) Process

func (pu PriceUpdater) Process(ctx context.Context, inCh <-chan *ast.Day, outCh chan<- *ast.Day) error

Process computes prices.

type Valuator

type Valuator struct {
	Context   journal.Context
	Valuation *journal.Commodity
}

Valuator produces valuated days.

func (*Valuator) Process

func (pr *Valuator) Process(ctx context.Context, inCh <-chan *ast.Day, outCh chan<- *ast.Day) error

Process computes prices.