goflow

Documentation

Index

• type Encoder
  • func (e *Encoder) OnVal(val string)
• type EncodingApp
  • func NewEncodingApp() *EncodingApp
• type Printer
  • func (p *Printer) OnLine(line string)

Types

type Encoder

type Encoder struct {
	flow.Component
	Val <-chan string
	Res chan<- string
}

Encoder base64 encodes all input

func (*Encoder) OnVal

func (e *Encoder) OnVal(val string)

OnVal does the encoding then pushes the result onto Res

type EncodingApp

type EncodingApp struct {
	flow.Graph
}

EncodingApp creates a flow-based pipeline to encode and print the result

func NewEncodingApp

func NewEncodingApp() *EncodingApp

NewEncodingApp wires together the componets

type Printer

type Printer struct {
	flow.Component
	Line <-chan string
}

Printer is a component for printing to stdout

func (*Printer) OnLine

func (p *Printer) OnLine(line string)

OnLine Prints the current line received