cmd

package
v1.1.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 3, 2020 License: MIT Imports: 40 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Version     = "1.0.0"
	BuildTime   = ""
	BuildCommit = ""
	Filehash    = ""
)

Functions

func Execute

func Execute() error

func GetFlowFactory

func GetFlowFactory(name string) (func() tlog.Flow, bool)

func RegisterFlow

func RegisterFlow(factory func() tlog.Flow)

Types

type Dumper

type Dumper struct {
	// contains filtered or unexported fields
}

func NewDumper

func NewDumper(dsn string, batch int, interval time.Duration, buffer int) *Dumper

func (*Dumper) Close

func (p *Dumper) Close() error

func (*Dumper) CloseWait

func (p *Dumper) CloseWait()

func (*Dumper) GetPipeline

func (p *Dumper) GetPipeline(name string) *pipeline.Pipeline

func (*Dumper) Insert

func (p *Dumper) Insert(name string, factory func() tlog.Flow) func([]interface{})

func (*Dumper) Publish

func (p *Dumper) Publish(e fswatch.Event)

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) Format

func (this *FmtxPrinter) Format(buffer *bytes.Buffer) error

func (*FmtxPrinter) Print

func (this *FmtxPrinter) Print(mode string, sheet *optimus.SheetInfo) *optimus.Stream

func (*FmtxPrinter) Title

func (this *FmtxPrinter) Title(name string) string

type Receiver

type Receiver struct {
	// contains filtered or unexported fields
}

func NewReceiver

func NewReceiver(dir string, port string, rbuf int) *Receiver

func (*Receiver) Close

func (r *Receiver) Close()

func (*Receiver) Serve

func (r *Receiver) Serve()

type SQLPrinter

type SQLPrinter struct{}

func (*SQLPrinter) Ext

func (this *SQLPrinter) Ext() string

func (*SQLPrinter) Print

func (this *SQLPrinter) Print(mode string, sheet *optimus.SheetInfo) *optimus.Stream

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL