kafkaflow

Documentation

Index

• type Printer
  • func (p *Printer) OnLine(line string)
• type Upper
  • func (e *Upper) OnVal(val string)
• type UpperApp
  • func NewUpperApp() *UpperApp

Types

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

type Upper

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

Upper upper cases the incoming stream

func (*Upper) OnVal

func (e *Upper) OnVal(val string)

OnVal does the encoding then pushes the result onto Re

type UpperApp

type UpperApp struct {
	flow.Graph
}

UpperApp creates a flow-based pipeline to upper case and print the result

func NewUpperApp

func NewUpperApp() *UpperApp

NewUpperApp wires together the compoents