Versions in this module Expand all Collapse all v1 v1.1.2 Mar 3, 2020 v1.1.0 Mar 2, 2020 Changes in this version + var BuildCommit = "" + var BuildTime = "" + var Filehash = "" + var Version = "1.0.0" + func Execute() error + func GetFlowFactory(name string) (func() tlog.Flow, bool) + func RegisterFlow(factory func() tlog.Flow) + type Dumper struct + func NewDumper(dsn string, batch int, interval time.Duration, buffer int) *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 struct + func (this *FmtxPrinter) Ext() string + func (this *FmtxPrinter) Format(buffer *bytes.Buffer) error + func (this *FmtxPrinter) Print(mode string, sheet *optimus.SheetInfo) *optimus.Stream + func (this *FmtxPrinter) Title(name string) string + type Receiver struct + func NewReceiver(dir string, port string, rbuf int) *Receiver + func (r *Receiver) Close() + func (r *Receiver) Serve() + type SQLPrinter struct + func (this *SQLPrinter) Ext() string + func (this *SQLPrinter) Print(mode string, sheet *optimus.SheetInfo) *optimus.Stream