part

Documentation

Index

• Variables
• type Config
• type File
  • func New(filePath string, curIndex int64, autoClose bool) *File
  • func (t *File) Close() error
  • func (t *File) CopyTo(to *File, byteInSec int64, tryLock bool) error
  • func (t *File) CopyToIoWriter(to io.Writer, byteInSec int64, tryLock bool) error
  • func (t *File) Delete() error
  • func (t *File) File() *os.File
  • func (t *File) IsExist() bool
  • func (t *File) Read(data []byte) (int, error)
  • func (t *File) ReadAll(perReadSize int, maxReadSize int) (data []byte, e error)
  • func (t *File) ReadUntil(separation byte, perReadSize int, maxReadSize int) (data []byte, e error)
  • func (t *File) Seed(index int64) (e error)
  • func (t *File) Sync() (e error)
  • func (t *File) Write(data []byte, tryLock bool) (int, error)

Variables

var (
	ErrFilePathTooLong  = errors.New("ErrFilePathTooLong")
	ErrNewFileCantSeed  = errors.New("ErrNewFileCantSeed")
	ErrFailToLock       = errors.New("ErrFailToLock")
	ErrMaxReadSizeReach = errors.New("ErrMaxReadSizeReach")
)

Types

type Config

type Config struct {
	FilePath  string //文件路径
	CurIndex  int64  //初始化光标位置
	AutoClose bool   //自动关闭句柄

	// wrap with encoder
	//https://pkg.go.dev/golang.org/x/text/encoding#section-directories
	Coder encoder.Encoding
}

type File

type File struct {
	Config Config

	sync.RWMutex
	// contains filtered or unexported fields
}

func New

func New(filePath string, curIndex int64, autoClose bool) *File

func (*File) Close

func (t *File) Close() error

func (*File) CopyTo

func (t *File) CopyTo(to *File, byteInSec int64, tryLock bool) error

func (*File) CopyToIoWriter

func (t *File) CopyToIoWriter(to io.Writer, byteInSec int64, tryLock bool) error

func (*File) Delete

func (t *File) Delete() error

func (*File) File

func (t *File) File() *os.File

func (*File) IsExist

func (t *File) IsExist() bool

func (*File) Read

func (t *File) Read(data []byte) (int, error)

func (*File) ReadAll

func (t *File) ReadAll(perReadSize int, maxReadSize int) (data []byte, e error)

func (*File) ReadUntil

func (t *File) ReadUntil(separation byte, perReadSize int, maxReadSize int) (data []byte, e error)

func (*File) Seed

func (t *File) Seed(index int64) (e error)

func (*File) Sync

func (t *File) Sync() (e error)

func (*File) Write

func (t *File) Write(data []byte, tryLock bool) (int, error)