Versions in this module Expand all Collapse all v1 v1.0.1 Jan 19, 2023 Changes in this version + const CSV + const FTPFileStorage + const JSON + const LocalFileStorage + const MD5 + const OKFlag + const SHA1 + const SHA256 + const SHA512 + const TSV + func Count(fd FileObjectModel) (int64, error) + func Merge(src []FileObjectModel, dest FileObjectModel) error + func RegisterChecksumer(key string, ch Checksumer) + func RegisterFileType(ftype string, reader FileItemReader, writer FileItemWriter, ...) + func Split(srcFd FileObjectModel, destFds []FileObjectModel, strategy FileSplitStrategy) error + type ChecksumFlusher interface + Checksum func(fd FileObjectModel) error + type ChecksumVerifier interface + Verify func(fd FileObjectModel) (bool, error) + type Checksumer interface + func GetChecksumer(key string) Checksumer + type FTPFileInStream struct + func (fis *FTPFileInStream) Close() (err error) + func (fis *FTPFileInStream) Read(p []byte) (n int, err error) + type FTPFileOutStream struct + func (fis *FTPFileOutStream) Close() (err error) + func (fis *FTPFileOutStream) Write(p []byte) (n int, err error) + type FTPFileSystem struct + ConnTimeout time.Duration + Hort string + Password string + Port int + User string + func (fs *FTPFileSystem) Create(fileName, encoding string) (writer io.WriteCloser, err error) + func (fs *FTPFileSystem) Exists(fileName string) (bool, error) + func (fs *FTPFileSystem) Name() string + func (fs *FTPFileSystem) Open(fileName, encoding string) (io.ReadCloser, error) + type FileItemReader interface + Close func(handle interface{}) error + Count func(fd FileObjectModel) (int64, error) + Open func(fd FileObjectModel) (handle interface{}, err error) + ReadItem func(handle interface{}) (interface{}, error) + SkipTo func(handle interface{}, pos int64) error + func GetFileItemReader(ftype string) FileItemReader + type FileItemWriter interface + Close func(handle interface{}) error + Open func(fd FileObjectModel) (handle interface{}, err error) + WriteItem func(handle interface{}, data interface{}) error + func GetFileItemWriter(ftype string) FileItemWriter + type FileMerger interface + Merge func(src []FileObjectModel, dest FileObjectModel) (err error) + type FileMove struct + FromFileName string + FromFileStore FileStorage + ToFileName string + ToFileStore FileStorage + type FileObjectModel struct + Checksum string + Encoding string + FieldSeparator string + FileName string + FileStore FileStorage + Header bool + ItemPrototype interface{} + Type string + func (fd FileObjectModel) ItemType() (reflect.Type, error) + func (fd FileObjectModel) String() string + type FileSplitStrategy interface + DecideDestIndex func(line string, dest []FileObjectModel) int + type FileSplitter interface + Split func(src FileObjectModel, dest []FileObjectModel, strategy FileSplitStrategy) (err error) + type FileStorage interface + Create func(fileName, encoding string) (writer io.WriteCloser, err error) + Exists func(fileName string) (ok bool, err error) + Name func() string + Open func(fileName, encoding string) (reader io.ReadCloser, err error) + type LocalFileSystem struct + func (fs *LocalFileSystem) Create(fileName, encoding string) (io.WriteCloser, error) + func (fs *LocalFileSystem) Exists(fileName string) (bool, error) + func (fs *LocalFileSystem) Name() string + func (fs *LocalFileSystem) Open(fileName, encoding string) (io.ReadCloser, error) + type MD5Checksumer struct + func (ch *MD5Checksumer) Checksum(fd FileObjectModel) error + func (ch *MD5Checksumer) Verify(fd FileObjectModel) (bool, error) + type MergeSplitter interface + func GetFileMergeSplitter(ftype string) MergeSplitter + type OKFlagChecksumer struct + func (ch *OKFlagChecksumer) Checksum(fd FileObjectModel) error + func (ch *OKFlagChecksumer) Verify(fd FileObjectModel) (bool, error) + type SHA1Checksumer struct + func (ch *SHA1Checksumer) Checksum(fd FileObjectModel) error + func (ch *SHA1Checksumer) Verify(fd FileObjectModel) (bool, error) + type SHA256Checksumer struct + func (ch *SHA256Checksumer) Checksum(fd FileObjectModel) error + func (ch *SHA256Checksumer) Verify(fd FileObjectModel) (bool, error) + type SHA512Checksumer struct + func (ch *SHA512Checksumer) Checksum(fd FileObjectModel) error + func (ch *SHA512Checksumer) Verify(fd FileObjectModel) (bool, error)