fileinfostore

Documentation

Index

• Constants
• Variables
• func IsNotFound(err error) bool
• type FileInfoStore
  • func NewFileInfoStore(store kvstore.IKVStore) (*FileInfoStore, error)
  • func (fi *FileInfoStore) AddSharing(dirPath string) error
  • func (fi *FileInfoStore) AddUploadInfo(user, filePath, tmpPath string, fileSize int64) error
  • func (fi *FileInfoStore) DelInfo(itemPath string) error
  • func (fi *FileInfoStore) DelSharing(dirPath string) error
  • func (fi *FileInfoStore) DelUploadInfo(user, filePath string) error
  • func (fi *FileInfoStore) GetInfo(itemPath string) (*db.FileInfo, error)
  • func (fi *FileInfoStore) GetInfos(itemPaths []string) (map[string]*db.FileInfo, error)
  • func (fi *FileInfoStore) GetSharing(dirPath string) (bool, bool)
  • func (fi *FileInfoStore) GetSharingDir(hashID string) (string, error)
  • func (fi *FileInfoStore) GetUploadInfo(user, filePath string) (string, int64, int64, error)
  • func (fi *FileInfoStore) ListSharings(prefix string) (map[string]string, error)
  • func (fi *FileInfoStore) ListUploadInfo(user string) ([]*db.UploadInfo, error)
  • func (fi *FileInfoStore) SetInfo(itemPath string, info *db.FileInfo) error
  • func (fi *FileInfoStore) SetSha1(itemPath, sign string) error
  • func (fi *FileInfoStore) SetUploadInfo(user, filePath string, newUploaded int64) error
• type IFileInfoStore

Constants

const (
	InitNs       = "Init"
	InitTimeKey  = "initTime"
	SchemaVerKey = "SchemaVersion"
	SchemaV1     = "v1"
)

Variables

var (
	ErrEmpty           = errors.New("can not hash empty string")
	ErrNotFound        = errors.New("file info not found")
	ErrSharingNotFound = errors.New("sharing id not found")
	ErrConflicted      = errors.New("conflict found in hashing")
	ErrVerNotFound     = errors.New("file info schema version not found")
)

var (
	ErrGreaterThanSize = errors.New("uploaded is greater than file size")
	ErrUploadNotFound  = errors.New("upload info not found")
)

Functions

func IsNotFound

func IsNotFound(err error) bool

Types

type FileInfoStore

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

func NewFileInfoStore

func NewFileInfoStore(store kvstore.IKVStore) (*FileInfoStore, error)

func (*FileInfoStore) AddSharing

func (fi *FileInfoStore) AddSharing(dirPath string) error

func (*FileInfoStore) AddUploadInfo

func (fi *FileInfoStore) AddUploadInfo(user, filePath, tmpPath string, fileSize int64) error

func (*FileInfoStore) DelInfo

func (fi *FileInfoStore) DelInfo(itemPath string) error

func (*FileInfoStore) DelSharing

func (fi *FileInfoStore) DelSharing(dirPath string) error

func (*FileInfoStore) DelUploadInfo

func (fi *FileInfoStore) DelUploadInfo(user, filePath string) error

func (*FileInfoStore) GetInfo

func (fi *FileInfoStore) GetInfo(itemPath string) (*db.FileInfo, error)

func (*FileInfoStore) GetInfos

func (fi *FileInfoStore) GetInfos(itemPaths []string) (map[string]*db.FileInfo, error)

func (*FileInfoStore) GetSharing

func (fi *FileInfoStore) GetSharing(dirPath string) (bool, bool)

func (*FileInfoStore) GetSharingDir

func (fi *FileInfoStore) GetSharingDir(hashID string) (string, error)

func (*FileInfoStore) GetUploadInfo

func (fi *FileInfoStore) GetUploadInfo(user, filePath string) (string, int64, int64, error)

func (*FileInfoStore) ListSharings

func (fi *FileInfoStore) ListSharings(prefix string) (map[string]string, error)

func (*FileInfoStore) ListUploadInfo

func (fi *FileInfoStore) ListUploadInfo(user string) ([]*db.UploadInfo, error)

func (*FileInfoStore) SetInfo

func (fi *FileInfoStore) SetInfo(itemPath string, info *db.FileInfo) error

func (*FileInfoStore) SetSha1

func (fi *FileInfoStore) SetSha1(itemPath, sign string) error

func (*FileInfoStore) SetUploadInfo

func (fi *FileInfoStore) SetUploadInfo(user, filePath string, newUploaded int64) error

type IFileInfoStore

type IFileInfoStore interface {
	AddSharing(dirPath string) error
	DelSharing(dirPath string) error
	GetSharing(dirPath string) (bool, bool)
	ListSharings(prefix string) (map[string]string, error)
	GetInfo(itemPath string) (*db.FileInfo, error)
	SetInfo(itemPath string, info *db.FileInfo) error
	DelInfo(itemPath string) error
	SetSha1(itemPath, sign string) error
	GetInfos(itemPaths []string) (map[string]*db.FileInfo, error)
	GetSharingDir(hashID string) (string, error)
	// upload info
	AddUploadInfo(user, filePath, tmpPath string, fileSize int64) error
	SetUploadInfo(user, filePath string, newUploaded int64) error
	GetUploadInfo(user, filePath string) (string, int64, int64, error)
	DelUploadInfo(user, filePath string) error
	ListUploadInfo(user string) ([]*db.UploadInfo, error)
}