reader

Documentation

Index

• func GetCurrentPath(path string) string
• func GetFileInodeNum(path string) uint64
• type Reader
  • func NewReader(filepath string, stream chan string) (*Reader, error)
  • func (r *Reader) Start()
  • func (r *Reader) StartRead()
  • func (r *Reader) Stop()
  • func (r *Reader) StopRead() error

Functions

func GetCurrentPath

func GetCurrentPath(path string) string

func GetFileInodeNum

func GetFileInodeNum(path string) uint64

Types

type Reader

type Reader struct {
	FilePath string //配置的路径 正则路径

	Stream      chan string
	CurrentPath string //当前的路径
	Close       chan struct{}
	FD          uint64 // 文件的inode
	// contains filtered or unexported fields
}

func NewReader

func NewReader(filepath string, stream chan string) (*Reader, error)

func (*Reader) Start

func (r *Reader) Start()

func (*Reader) StartRead

func (r *Reader) StartRead()

func (*Reader) Stop

func (r *Reader) Stop()

func (*Reader) StopRead

func (r *Reader) StopRead() error