processors

Documentation

Index

• Variables
• func Add(name string, creator Creator)
• func AddStreaming(name string, creator StreamingCreator)
• func NewStreamingProcessorFromProcessor(p cua.Processor) cua.StreamingProcessor
• type Creator
• type StreamingCreator

Variables

var Processors = map[string]StreamingCreator{}

all processors are streaming processors. cua.Processor processors are upgraded to cua.StreamingProcessor

Functions

func Add

func Add(name string, creator Creator)

Add adds a cua.Processor processor

func AddStreaming

func AddStreaming(name string, creator StreamingCreator)

AddStreaming adds a cua.StreamingProcessor streaming processor

func NewStreamingProcessorFromProcessor

func NewStreamingProcessorFromProcessor(p cua.Processor) cua.StreamingProcessor

NewStreamingProcessorFromProcessor is a converter that turns a standard processor into a streaming processor

Types

type Creator

type Creator func() cua.Processor

type StreamingCreator

type StreamingCreator func() cua.StreamingProcessor