Documentation ¶
Overview ¶
Package pipefilter is to define the interfaces and the structures for pipe-filter style implementation
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var SplitFilterWrongFormatError = errors.New("input data should be string")
View Source
var SumFilterWrongFormatError = errors.New("input data should be []int")
View Source
var ToIntFilterWrongFormatError = errors.New("input data should be []string")
Functions ¶
This section is empty.
Types ¶
type Filter ¶
Filter interface is the definition of the data processing components Pipe-Filter structure
type SplitFilter ¶
type SplitFilter struct {
// contains filtered or unexported fields
}
func NewSplitFilter ¶
func NewSplitFilter(delimiter string) *SplitFilter
type StraightPipeline ¶
StraightPipeline is composed of the filters, and the filters are piled as a straigt line.
func NewStraightPipeline ¶
func NewStraightPipeline(name string, filters ...Filter) *StraightPipeline
NewStraightPipeline create a new StraightPipelineWithWallTime
type ToIntFilter ¶
type ToIntFilter struct { }
func NewToIntFilter ¶
func NewToIntFilter() *ToIntFilter
Click to show internal directories.
Click to hide internal directories.