pslog

Dec 26, 2024

Changes in this version

type FileInfo

+ func (f *FileInfo) ScanLinesOfInCr(fn func(row []byte) error) (int64, error)

Sep 1, 2024

Changes in this version

type FileInfo

+ func NewFileInfo(path string, handler *Handler) (*FileInfo, error)

+ func (f *FileInfo) Extension()

+ func (f *FileInfo) IsDir() bool

type PsLog

+ func (p *PsLog) AddDir2Handle(dir string, handler *Handler) error

type WatchFileInfo

+ Op fs.Op

Aug 29, 2024

Changes in this version

type Handler

+ NeedCollect func(filename string) bool

+ func (h *Handler) IsDir() bool

type PsLog

+ func (p *PsLog) AddDir2HandleMap(dir2HandleMap map[string]*Handler) error

type WatchFileInfo

+ ChangedFilename string

+ Dir string

+ IsRename bool

Aug 15, 2024

Changes in this version

type LogHandlerBus

+ TargetExt string

type Target

+ Ext string

Jul 18, 2023

Changes in this version

type Handler

+ LoopParse bool

Feb 14, 2023

Changes in this version

+ func PrintFilePool(print bool)

Feb 13, 2023

Changes in this version

type Handler

+ MergeRule line.Merger

Feb 8, 2023

Changes in this version

type PsLog

+ func (p *PsLog) ReplacePath2Handler(path2HandlerMap map[string]*Handler) error

Jan 18, 2023

Changes in this version

type FileInfo

+ func (f *FileInfo) PsLogDir() string

type Handler

+ CleanOffset bool

+ ExpireDur time.Duration

+ Ext string

+ type LogDir struct

+ Name string

+ Namespace string

+ TargetNames []string

+ type LogHandlerBus struct

+ Ext string

+ LogPath string

+ Msg string

+ func (l *LogHandlerBus) Reset()

+ func (l *LogHandlerBus) Write(b []byte)

+ type LogPath struct

+ func NewLogPath() *LogPath

+ func (l *LogPath) ParseLogPath(project *Project) []*ProjectLog

+ func (l *LogPath) ParseSrc(src *ProjectSrc) []*ProjectLog

+ func (l *LogPath) SetExcludeProjectDir(paths ...string)

+ type Matcher interface

+ GetTarget func(target []byte) (*Target, bool)

+ Insert func(bytes []byte, target ...*Target)

+ Null func() bool

+ Search func(target []byte) bool

+ type Project struct

+ LogDir *LogDir

+ ProjectPath string

+ type ProjectLog struct

+ LogPath string

+ Namespace string

+ ProjectName string

+ type ProjectSrc struct

+ LogDir *LogDir

+ SrcPath string

type PsLog

+ func (p *PsLog) AddPath2Handler(path string, handler *Handler) error

+ func (p *PsLog) HasClose() bool

+ func (p *PsLog) List() string

+ type PsLogWriter interface

+ WriteTo func(bus *LogHandlerBus)

+ type Simple struct

+ func (s *Simple) GetTarget(target []byte) (*Target, bool)

+ func (s *Simple) Insert(bytes []byte, target ...*Target)

+ func (s *Simple) Null() bool

+ func (s *Simple) Search(target []byte) bool

+ type Stdout struct

+ func (p *Stdout) WriteTo(bus *LogHandlerBus)

type Target

+ No int

+ type Tire struct

+ func (t *Tire) GetTarget(target []byte) (*Target, bool)

+ func (t *Tire) Insert(bytes []byte, target ...*Target)

+ func (t *Tire) Null() bool

+ func (t *Tire) Search(target []byte) bool

Jan 12, 2023

Changes in this version

+ var NoExpire = base.Datetime2TimeObj("9999-12-31 23:59:59")

+ func SetLogger(l PsLogger)

+ type FileInfo struct

+ Dir string

+ Handler *Handler

+ Name string

+ func (f *FileInfo) CleanNameFmt() string

+ func (f *FileInfo) FileName() string

+ func (f *FileInfo) HandlerIsNil() bool

+ func (f *FileInfo) IsExpire(t ...time.Time) bool

+ func (f *FileInfo) Parse(path string)

+ type Handler struct

+ Change int32

+ ExpireAt time.Time

+ Tail bool

+ Targets []*Target

+ func (h *Handler) Valid() error

+ type Opt func(*PsLog)

+ func WithAsync2Tos() Opt

+ func WithCleanUpTime(dur time.Duration) Opt

+ func WithPreCleanOffset() Opt

+ func WithTaskPoolSize(size int) Opt

+ type PsLog struct

+ func NewPsLog(opts ...Opt) (*PsLog, error)

+ func (p *PsLog) AddPath2HandlerMap(path2HandlerMap map[string]*Handler) error

+ func (p *PsLog) AddPaths(paths ...string) error

+ func (p *PsLog) Close()

+ func (p *PsLog) CronLogs()

+ func (p *PsLog) Register(handler *Handler) error

+ func (p *PsLog) TailLogs(watchChSize ...int) error

+ type PsLogger interface

+ Error func(v ...interface{})

+ Errorf func(format string, v ...interface{})

+ Info func(v ...interface{})

+ Infof func(format string, v ...interface{})

+ Warning func(v ...interface{})

+ Warningf func(format string, v ...interface{})

+ type Target struct

+ Content string

+ Excludes []string

+ To []io.Writer

+ type Watch struct

+ func NewWatch() (*Watch, error)

+ func (w *Watch) Add(paths ...string) error

+ func (w *Watch) Close()

+ func (w *Watch) Remove(paths ...string) error

+ func (w *Watch) Watch(busCh chan *WatchFileInfo)

+ func (w *Watch) WatchList() string

+ type WatchFileInfo struct

+ IsDir bool

+ Path string

+ WatchFilePath string