weblab

Documentation

Overview

Package weblab extends the fgbase package with web and http primitives.

Index

• func FuncHTTP(x fgbase.Edge, addr string, quitChan chan struct{}) fgbase.Node
• func FuncKcons(x fgbase.Edge, topic string) fgbase.Node
• func FuncKprod(a fgbase.Edge) fgbase.Node

Functions

func FuncHTTP

func FuncHTTP(x fgbase.Edge, addr string, quitChan chan struct{}) fgbase.Node

FuncHTTP creates an http server and passes requests downstream.

func FuncKcons

func FuncKcons(x fgbase.Edge, topic string) fgbase.Node

FuncKcons wraps a Kafka consumer.

func FuncKprod

func FuncKprod(a fgbase.Edge) fgbase.Node

FuncKprod wraps a Kafka producer.