Documentation ¶
Index ¶
- func EncodePipeline(pl Pipeline) (*bytes.Buffer, error)
- type Column2RowPipe
- func (c *Column2RowPipe) GetConfigUI(changed func()) g.Layout
- func (c *Column2RowPipe) GetInputType() DataType
- func (c *Column2RowPipe) GetName() string
- func (c *Column2RowPipe) GetOutputType() DataType
- func (c *Column2RowPipe) GetTip() string
- func (c *Column2RowPipe) Process(data interface{}) interface{}
- type DataType
- type FieldsPipe
- type FmtRowPipe
- type JoinPipe
- type LinePipe
- type MatchPipe
- type Parameter
- type Pipe
- type PipeBuilder
- type Pipeline
- type RegexpSplitPipe
- func (r *RegexpSplitPipe) GetConfigUI(changed func()) g.Layout
- func (r *RegexpSplitPipe) GetInputType() DataType
- func (r *RegexpSplitPipe) GetName() string
- func (r *RegexpSplitPipe) GetOutputType() DataType
- func (r *RegexpSplitPipe) GetTip() string
- func (r *RegexpSplitPipe) Process(data interface{}) interface{}
- type ReplacePipe
- type SurroundPipe
- type TablePipe
- type TrimPipe
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Column2RowPipe ¶
type Column2RowPipe struct{}
func (*Column2RowPipe) GetConfigUI ¶
func (c *Column2RowPipe) GetConfigUI(changed func()) g.Layout
func (*Column2RowPipe) GetInputType ¶
func (c *Column2RowPipe) GetInputType() DataType
func (*Column2RowPipe) GetName ¶
func (c *Column2RowPipe) GetName() string
func (*Column2RowPipe) GetOutputType ¶
func (c *Column2RowPipe) GetOutputType() DataType
func (*Column2RowPipe) GetTip ¶
func (c *Column2RowPipe) GetTip() string
func (*Column2RowPipe) Process ¶
func (c *Column2RowPipe) Process(data interface{}) interface{}
type FieldsPipe ¶
type FieldsPipe struct{}
func (*FieldsPipe) GetConfigUI ¶
func (f *FieldsPipe) GetConfigUI(changed func()) g.Layout
func (*FieldsPipe) GetInputType ¶
func (f *FieldsPipe) GetInputType() DataType
func (*FieldsPipe) GetName ¶
func (f *FieldsPipe) GetName() string
func (*FieldsPipe) GetOutputType ¶
func (f *FieldsPipe) GetOutputType() DataType
func (*FieldsPipe) GetTip ¶
func (f *FieldsPipe) GetTip() string
func (*FieldsPipe) Process ¶
func (f *FieldsPipe) Process(data interface{}) interface{}
type FmtRowPipe ¶
type FmtRowPipe struct {
FmtStr string
}
func (*FmtRowPipe) GetConfigUI ¶
func (f *FmtRowPipe) GetConfigUI(changed func()) g.Layout
func (*FmtRowPipe) GetInputType ¶
func (f *FmtRowPipe) GetInputType() DataType
func (*FmtRowPipe) GetName ¶
func (f *FmtRowPipe) GetName() string
func (*FmtRowPipe) GetOutputType ¶
func (f *FmtRowPipe) GetOutputType() DataType
func (*FmtRowPipe) GetTip ¶
func (f *FmtRowPipe) GetTip() string
func (*FmtRowPipe) Process ¶
func (f *FmtRowPipe) Process(data interface{}) interface{}
type JoinPipe ¶
type JoinPipe struct {
JoinWith string
}
func (*JoinPipe) GetConfigUI ¶
func (*JoinPipe) GetInputType ¶
func (*JoinPipe) GetOutputType ¶
type LinePipe ¶
type LinePipe struct{}
func (*LinePipe) GetConfigUI ¶
func (*LinePipe) GetInputType ¶
func (*LinePipe) GetOutputType ¶
type MatchPipe ¶
type MatchPipe struct {
MatchWith string
}
func (*MatchPipe) GetConfigUI ¶
func (*MatchPipe) GetInputType ¶
func (*MatchPipe) GetOutputType ¶
type Pipe ¶
type Pipe interface { // Get information for the pipe including name, bgColor, nameColor and borderColor GetName() string GetTip() string GetInputType() DataType GetOutputType() DataType GetConfigUI(changed func()) g.Layout Process(data interface{}) interface{} }
func NewColumn2RowPipe ¶
func NewColumn2RowPipe() Pipe
func NewFieldsPipe ¶
func NewFieldsPipe() Pipe
func NewFmtRowPipe ¶
func NewFmtRowPipe() Pipe
func NewJoinPipe ¶
func NewJoinPipe() Pipe
func NewLinePipe ¶
func NewLinePipe() Pipe
func NewMatchPipe ¶
func NewMatchPipe() Pipe
func NewRegexpSplitPipe ¶
func NewRegexpSplitPipe() Pipe
func NewReplacePipe ¶
func NewReplacePipe() Pipe
func NewSurroundPipe ¶
func NewSurroundPipe() Pipe
func NewTablePipe ¶
func NewTablePipe() Pipe
func NewTrimPipe ¶
func NewTrimPipe() Pipe
type PipeBuilder ¶
func QueryPipes ¶
func QueryPipes(byType DataType) []*PipeBuilder
func QueryPipesBetween ¶
func QueryPipesBetween(inType, outType DataType) []*PipeBuilder
type RegexpSplitPipe ¶
type RegexpSplitPipe struct {
SplitWith string
}
func (*RegexpSplitPipe) GetConfigUI ¶
func (r *RegexpSplitPipe) GetConfigUI(changed func()) g.Layout
func (*RegexpSplitPipe) GetInputType ¶
func (r *RegexpSplitPipe) GetInputType() DataType
func (*RegexpSplitPipe) GetName ¶
func (r *RegexpSplitPipe) GetName() string
func (*RegexpSplitPipe) GetOutputType ¶
func (r *RegexpSplitPipe) GetOutputType() DataType
func (*RegexpSplitPipe) GetTip ¶
func (r *RegexpSplitPipe) GetTip() string
func (*RegexpSplitPipe) Process ¶
func (r *RegexpSplitPipe) Process(data interface{}) interface{}
type ReplacePipe ¶
func (*ReplacePipe) GetConfigUI ¶
func (r *ReplacePipe) GetConfigUI(changed func()) g.Layout
func (*ReplacePipe) GetInputType ¶
func (r *ReplacePipe) GetInputType() DataType
func (*ReplacePipe) GetName ¶
func (r *ReplacePipe) GetName() string
func (*ReplacePipe) GetOutputType ¶
func (r *ReplacePipe) GetOutputType() DataType
func (*ReplacePipe) GetTip ¶
func (r *ReplacePipe) GetTip() string
func (*ReplacePipe) Process ¶
func (r *ReplacePipe) Process(data interface{}) interface{}
type SurroundPipe ¶
func (*SurroundPipe) GetConfigUI ¶
func (p *SurroundPipe) GetConfigUI(changed func()) g.Layout
func (*SurroundPipe) GetInputType ¶
func (p *SurroundPipe) GetInputType() DataType
func (*SurroundPipe) GetName ¶
func (p *SurroundPipe) GetName() string
func (*SurroundPipe) GetOutputType ¶
func (p *SurroundPipe) GetOutputType() DataType
func (*SurroundPipe) GetTip ¶
func (p *SurroundPipe) GetTip() string
func (*SurroundPipe) Process ¶
func (p *SurroundPipe) Process(data interface{}) interface{}
type TablePipe ¶
func (*TablePipe) GetConfigUI ¶
func (*TablePipe) GetInputType ¶
func (*TablePipe) GetOutputType ¶
type TrimPipe ¶
type TrimPipe struct {
TrimWith string
}
func (*TrimPipe) GetConfigUI ¶
func (*TrimPipe) GetInputType ¶
func (*TrimPipe) GetOutputType ¶
Click to show internal directories.
Click to hide internal directories.