reg

type DbEngine interface {
	FindAll() ([]Registry, error)
	FindBy(jobUid string, sourceName string, pipelineName string) (Registry, error)
	Insert(registries []Registry) error
	Update(registries []Registry) error
	UpdateFileName(rs []Registry) error
	Delete(r Registry) error
	DeleteBy(jobUid string, sourceName string, pipelineName string) error
	Close() error
}

type Registry struct {
	Id           int    `json:"id"`
	PipelineName string `json:"pipelineName"`
	SourceName   string `json:"sourceName"`
	Filename     string `json:"filename"`
	JobUid       string `json:"jobUid"`
	Offset       int64  `json:"offset"`
	CollectTime  string `json:"collectTime"`
	Version      string `json:"version"`
	LineNumber   int64  `json:"lineNumber"`
}

type RegistryList []Registry