script

package

v1.5.0 Latest Latest Go to latest Published: Jun 11, 2018 License: Apache-2.0 Imports: 11 Imported by: 3

Details

This section is empty.

This section is empty.

func NewReader(meta *reader.Meta, conf conf.MapConf) (sr reader.Reader, err error)

type Reader struct {
	Cron *cron.Cron //定时任务
	// contains filtered or unexported fields
}

func (sr *Reader) Close() (err error)

func (sr *Reader) LoopRun()

func (sr *Reader) Name() string

func (sr *Reader) ReadLine() (data string, err error)

func (sr *Reader) SetMode(mode string, v interface{}) error

func (sr *Reader) Source() string

func (sr *Reader) Start()

Start 仅调用一次，借用ReadLine启动，不能在new实例的时候启动，会有并发问题

func (sr *Reader) SyncMeta()