file_helper

Documentation

Index

• Constants
• Variables
• type FileSyncer
• type FileSyncerOption
  • func NewFileSyncerOption() *FileSyncerOption
• type RandomFileSyncer
  • func NewRandomFileSyncer(opts ...SetFileSyncerOption) (*RandomFileSyncer, error)
  • func (fs *RandomFileSyncer) Close() (err error)
  • func (fs *RandomFileSyncer) Next(batch int) (offsets []int64, err error)
  • func (fs *RandomFileSyncer) Sync(offset int64, data []byte, size int) (err error)
• type SequenceFileSyncer
  • func NewSequenceFileSyncer(writeCloser io.WriteCloser, size int64, sha1_hash string, chunk_size int64) *SequenceFileSyncer
  • func (sfs *SequenceFileSyncer) Close() error
  • func (sfs *SequenceFileSyncer) Next(_ int) (offsets []int64, err error)
  • func (sfs *SequenceFileSyncer) Sync(offset int64, data []byte, size int) (err error)
• type SetFileSyncerOption
  • func SetCachePath(path string) SetFileSyncerOption
  • func SetChunkSize(size int64) SetFileSyncerOption
  • func SetPath(path string) SetFileSyncerOption
  • func SetSha1Hash(hash string) SetFileSyncerOption
  • func SetSize(size int64) SetFileSyncerOption

Constants

const (
	DEFAULT_CHUNK_SIZE int64 = 512 * 1024
)

Variables

var (
	ErrInvalidArgument = errors.New("invalid argument")
	ErrHashNotMatch    = errors.New("hash not match")
	ErrBadChunkIndex   = errors.New("bad chunk index")
	ErrEmptyCacheFile  = errors.New("empty cache file")
)

var (
	DONE = errors.New("done")
)

Types

type FileSyncer

type FileSyncer interface {
	Next(count int) (offsets []int64, err error)
	Sync(offset int64, data []byte, size int) (err error)
	Close() error
}

type FileSyncerOption

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

func NewFileSyncerOption

func NewFileSyncerOption() *FileSyncerOption

type RandomFileSyncer

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

func NewRandomFileSyncer

func NewRandomFileSyncer(opts ...SetFileSyncerOption) (*RandomFileSyncer, error)

func (*RandomFileSyncer) Close

func (fs *RandomFileSyncer) Close() (err error)

func (*RandomFileSyncer) Next

func (fs *RandomFileSyncer) Next(batch int) (offsets []int64, err error)

func (*RandomFileSyncer) Sync

func (fs *RandomFileSyncer) Sync(offset int64, data []byte, size int) (err error)

type SequenceFileSyncer

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

func NewSequenceFileSyncer

func NewSequenceFileSyncer(writeCloser io.WriteCloser, size int64, sha1_hash string, chunk_size int64) *SequenceFileSyncer

func (*SequenceFileSyncer) Close

func (sfs *SequenceFileSyncer) Close() error

func (*SequenceFileSyncer) Next

func (sfs *SequenceFileSyncer) Next(_ int) (offsets []int64, err error)

HACK: ignore count

func (*SequenceFileSyncer) Sync

func (sfs *SequenceFileSyncer) Sync(offset int64, data []byte, size int) (err error)

TODO: verify chunk hash

type SetFileSyncerOption

type SetFileSyncerOption func(*FileSyncerOption)

func SetCachePath

func SetCachePath(path string) SetFileSyncerOption

func SetChunkSize

func SetChunkSize(size int64) SetFileSyncerOption

func SetPath

func SetPath(path string) SetFileSyncerOption

func SetSha1Hash

func SetSha1Hash(hash string) SetFileSyncerOption

func SetSize

func SetSize(size int64) SetFileSyncerOption