blocks

Documentation

Index

• type Block
• type DecodedBlock
  • func (b *DecodedBlock) UnmarshalJSON(data []byte) error
• type End
  • func (b *End) Run(_, _ *buses.Bus)
• type Mapper
  • func (b *Mapper) Run(public, private *buses.Bus)
• type Reducer
  • func (b *Reducer) Run(public, private *buses.Bus)
• type Runner
  • func (b *Runner) Run(public, private *buses.Bus)
• type Toggler
  • func (f *Toggler) Run(public, private *buses.Bus)

Types

type Block

type Block interface {
	Run(public, private *buses.Bus)
}

type DecodedBlock

type DecodedBlock struct {
	Inner Block
}

func (*DecodedBlock) UnmarshalJSON

func (b *DecodedBlock) UnmarshalJSON(data []byte) error

type End

type End struct{}

func (*End) Run

func (b *End) Run(_, _ *buses.Bus)

type Mapper

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

Mapper - block provide "map" flow

func (*Mapper) Run

func (b *Mapper) Run(public, private *buses.Bus)

Run - standard method for run block

type Reducer

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

Reducer - block block provides "reduce" flow

func (*Reducer) Run

func (b *Reducer) Run(public, private *buses.Bus)

Run - standard method for run block

type Runner

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

func (*Runner) Run

func (b *Runner) Run(public, private *buses.Bus)

type Toggler

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

Toggler - block block provides conditional switch

func (*Toggler) Run

func (f *Toggler) Run(public, private *buses.Bus)

Run - standard method for run block