pipelines

Documentation

Index

• func BuildPipeline(identifier string, data interface{}, m map[string]definitions.Pipeline) (definitions.Pipeline, error)
• func FanIn(ctx context.Context, chs []chan events.Collection, ...) error
• func FanOut(ctx context.Context, ch chan events.Collection, ...) error

Functions

func BuildPipeline

func BuildPipeline(identifier string, data interface{}, m map[string]definitions.Pipeline) (definitions.Pipeline, error)

BuildPipeline will construct a pipeline.

func FanIn

func FanIn(ctx context.Context, chs []chan events.Collection, combined chan events.Collection) error

FanIn will merge multiple input channels to a singular output channel.

func FanOut

func FanOut(ctx context.Context, ch chan events.Collection, outputs []chan events.Collection) error

FanOut will split a single input channel into multiple output channels.