kafkaflow

Documentation

Index

• func NewUpperApp() *goflow.Graph
• type Printer
  • func (p *Printer) Process()
• type Upper
  • func (e *Upper) Process()

Functions

func NewUpperApp

func NewUpperApp() *goflow.Graph

NewUpperApp wires together the compoents

Types

type Printer

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

Printer is a component for printing to stdout

func (*Printer) Process

func (p *Printer) Process()

Process Prints the current line received

type Upper

type Upper struct {
	Val <-chan string
	Res chan<- string
}

Struct for upper cases of the incoming stream

func (*Upper) Process

func (e *Upper) Process()

Process loops over the input values and writes the upper case string version of them to Res