reg

Documentation

Index

• func GenKey(jobuid, source, pipeline string) []byte
• type DbEngine
• type Registry
  • func (r *Registry) CheckIntegrity() bool
  • func (r *Registry) Key() []byte
  • func (r *Registry) Merge(registry Registry)
  • func (r *Registry) Value() []byte
• type RegistryList

Functions

func GenKey

func GenKey(jobuid, source, pipeline string) []byte

Types

type DbEngine

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

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"`
}

func (*Registry) CheckIntegrity

func (r *Registry) CheckIntegrity() bool

func (*Registry) Key

func (r *Registry) Key() []byte

func (*Registry) Merge

func (r *Registry) Merge(registry Registry)

func (*Registry) Value

func (r *Registry) Value() []byte

type RegistryList

type RegistryList []Registry