Documentation ¶
Index ¶
- Variables
- func Execute() error
- func GetFlowFactory(name string) (func() tlog.Flow, bool)
- func RegisterFlow(factory func() tlog.Flow)
- type Dumper
- func (p *Dumper) Close() error
- func (p *Dumper) CloseWait()
- func (p *Dumper) GetPipeline(name string) *pipeline.Pipeline
- func (p *Dumper) Insert(name string, factory func() tlog.Flow) func([]interface{})
- func (p *Dumper) Publish(e fswatch.Event)
- func (p *Dumper) SetACKHandler(ack fswatch.ACKHandler)
- type FmtxPrinter
- type Receiver
- type SQLPrinter
Constants ¶
This section is empty.
Variables ¶
View Source
var ( Version = "1.0.0" BuildTime = "" BuildCommit = "" Filehash = "" )
Functions ¶
func RegisterFlow ¶
Types ¶
type Dumper ¶
type Dumper struct {
// contains filtered or unexported fields
}
func (*Dumper) SetACKHandler ¶
func (p *Dumper) SetACKHandler(ack fswatch.ACKHandler)
type FmtxPrinter ¶
type FmtxPrinter struct{}
func (*FmtxPrinter) Ext ¶
func (this *FmtxPrinter) Ext() string
func (*FmtxPrinter) Title ¶
func (this *FmtxPrinter) Title(name string) string
type SQLPrinter ¶
type SQLPrinter struct{}
func (*SQLPrinter) Ext ¶
func (this *SQLPrinter) Ext() string
Click to show internal directories.
Click to hide internal directories.