process

Documentation

Index

• type Balancer
  • func (pr *Balancer) Process(ctx context.Context, inCh <-chan *ast.Day, outCh chan<- *ast.Day) error
• type Error
  • func (be Error) Error() string
• type JournalSource
  • func (pr *JournalSource) Source(ctx context.Context, outCh chan<- *ast.Day) error
• type PeriodDiffer
  • func (pf PeriodDiffer) Process(ctx context.Context, inCh <-chan *ast.Day, outCh chan<- *ast.Day) error
• type PeriodFilter
  • func (pf PeriodFilter) Process(ctx context.Context, inCh <-chan *ast.Day, outCh chan<- *ast.Day) 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 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 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
}

JournalSource emits journal data in daily batches.

func (*JournalSource) Source

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

Source is a source of days.

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.Day, outCh chan<- *ast.Day) 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.Day) error

Process does the filtering.

type PriceUpdater

type PriceUpdater struct {
	Context   journal.Context
	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.