Versions in this module Expand all Collapse all v0 v0.0.2 Nov 26, 2021 v0.0.1 Nov 26, 2021 Changes in this version + func GroupCheckDuration(duration time.Duration) func(*Group) + func GroupHeadSizeLimit(limit int64) func(*Group) + func GroupTotalSizeLimit(limit int64) func(*Group) + type AutoFile struct + ID string + Path string + func OpenAutoFile(path string) (*AutoFile, error) + func (af *AutoFile) Close() error + func (af *AutoFile) Size() (int64, error) + func (af *AutoFile) Sync() error + func (af *AutoFile) Write(b []byte) (n int, err error) + type Group struct + Dir string + Head *AutoFile + ID string + func OpenGroup(headPath string, groupOptions ...func(*Group)) (*Group, error) + func (g *Group) Buffered() int + func (g *Group) Close() + func (g *Group) FlushAndSync() error + func (g *Group) HeadSizeLimit() int64 + func (g *Group) MaxIndex() int + func (g *Group) MinIndex() int + func (g *Group) NewReader(index int) (*GroupReader, error) + func (g *Group) OnStart() error + func (g *Group) OnStop() + func (g *Group) ReadGroupInfo() GroupInfo + func (g *Group) RotateFile() + func (g *Group) TotalSizeLimit() int64 + func (g *Group) Wait() + func (g *Group) Write(p []byte) (nn int, err error) + func (g *Group) WriteLine(line string) error + type GroupInfo struct + HeadSize int64 + MaxIndex int + MinIndex int + TotalSize int64 + type GroupReader struct + func (gr *GroupReader) Close() error + func (gr *GroupReader) CurIndex() int + func (gr *GroupReader) Read(p []byte) (n int, err error) + func (gr *GroupReader) SetIndex(index int) error
Go to main page