cleaner

Documentation

Index

• Constants
• type CleanSignal
• type Cleaner
  • func NewCleaner(conf conf.MapConf, meta *reader.Meta, cleanChan chan<- CleanSignal, ...) (c *Cleaner, err error)
  • func (c *Cleaner) Clean() (err error)
  • func (c *Cleaner) Close()
  • func (c *Cleaner) LogDir() string
  • func (c *Cleaner) Name() string
  • func (c *Cleaner) Run()

Constants

const (
	MB = 1024 * 1024
)

Types

type CleanSignal

type CleanSignal struct {
	Logdir   string
	Filename string
	Cleaner  string
}

type Cleaner

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

func NewCleaner

func NewCleaner(conf conf.MapConf, meta *reader.Meta, cleanChan chan<- CleanSignal, logdir string) (c *Cleaner, err error)

删除文件时遍历全部 删除时生成filedeleted文件

func (*Cleaner) Clean

func (c *Cleaner) Clean() (err error)

func (*Cleaner) Close

func (c *Cleaner) Close()

func (*Cleaner) LogDir

func (c *Cleaner) LogDir() string

func (*Cleaner) Name

func (c *Cleaner) Name() string

func (*Cleaner) Run

func (c *Cleaner) Run()