file

type ChecksumFlusher interface {
	//Checksum generate checksum and write a check file for the corresponding data file
	Checksum(fd FileObjectModel) error
}

type ChecksumVerifier interface {
	//Verify verify a data file according to the corresponding check file
	Verify(fd FileObjectModel) (bool, error)
}

type Checksumer interface {
	ChecksumVerifier
	ChecksumFlusher
}

type FTPFileInStream struct {
	// contains filtered or unexported fields
}

type FTPFileOutStream struct {
	// contains filtered or unexported fields
}

type FTPFileSystem struct {
	Hort        string
	Port        int
	User        string
	Password    string
	ConnTimeout time.Duration
}

type FileItemReader interface {
	//Open open file of the FileObjectModel, returns a handle for later read
	Open(fd FileObjectModel) (handle interface{}, err error)
	//Close open the file handle
	Close(handle interface{}) error
	//ReadItem read an item from the file handle
	ReadItem(handle interface{}) (interface{}, error)
	//SkipTo skip to the pos'th record in the file
	SkipTo(handle interface{}, pos int64) error
	//Count return number of items contained by the file
	Count(fd FileObjectModel) (int64, error)
}

type FileItemWriter interface {
	//Open open file of the FileObjectModel, returns a handle for later write
	Open(fd FileObjectModel) (handle interface{}, err error)
	//Close open the file handle
	Close(handle interface{}) error
	//WriteItem write an item to the file
	WriteItem(handle interface{}, data interface{}) error
}

type FileMerger interface {
	//Merge merge multiple files into a simple one
	Merge(src []FileObjectModel, dest FileObjectModel) (err error)
}

type FileMove struct {
	FromFileName  string
	FromFileStore FileStorage
	ToFileName    string
	ToFileStore   FileStorage
}

type FileObjectModel struct {
	FileStore      FileStorage
	FileName       string
	Type           string
	Encoding       string
	Header         bool
	FieldSeparator string
	Checksum       string
	ItemPrototype  interface{}
}

type FileSplitStrategy interface {
	//DecideDestIndex decide the destination of every record, return the index of destination file in the dest array
	DecideDestIndex(line string, dest []FileObjectModel) int
}

type FileSplitter interface {
	//Split split a src file into multiple destinations, decide the destination of every record according to a FileSplitStrategy
	Split(src FileObjectModel, dest []FileObjectModel, strategy FileSplitStrategy) (err error)
}

type FileStorage interface {
	//Name return name of the file store
	Name() string
	//Exists check if a file with the specified fileName exists
	Exists(fileName string) (ok bool, err error)
	//Open return a reader of the specified fileName, transform encoding if necessary
	Open(fileName, encoding string) (reader io.ReadCloser, err error)
	//Create return a writer of the specified fileName, transform encoding if necessary
	Create(fileName, encoding string) (writer io.WriteCloser, err error)
}

type LocalFileSystem struct {
}

type MD5Checksumer struct {
}

type MergeSplitter interface {
	FileMerger
	FileSplitter
}

type OKFlagChecksumer struct {
}

type SHA1Checksumer struct {
}

type SHA256Checksumer struct {
}

type SHA512Checksumer struct {
}