dao

Documentation

Index

• type Dao
  • func New(c config.Config) *Dao
  • func NewDFSHelper(minio *minio_util.MinioConfig, idgen zrpc.RpcClientConf, ssdb kv.KvConf) *Dao
  • func (d *Dao) FPutDocumentFile(ctx context.Context, path string, r string) (n minio.UploadInfo, err error)
  • func (d *Dao) GetCacheDfsFileInfo(ctx context.Context, id int64) (*model.DfsFileInfo, error)
  • func (d *Dao) GetCacheFile(ctx context.Context, bucket string, id int64, offset int64, limit int32) (bytes []byte, err error)
  • func (d *Dao) GetFile(ctx context.Context, bucket, path string, offset int64, limit int32) (bytes []byte, err error)
  • func (d *Dao) GetFileInfo(ctx context.Context, ownerId, fileId int64) (fileInfo *model.DfsFileInfo, err error)
  • func (d *Dao) GetFileObject(ctx context.Context, bucket, path string) (*minio.Object, error)
  • func (d *Dao) NewSSDBReader(fileInfo *model.DfsFileInfo) *SSDBReader
  • func (d *Dao) OpenFile(ctx context.Context, ownerId, fileId int64, parts int32) (*SSDBReader, error)
  • func (d *Dao) PutDocumentFile(ctx context.Context, path string, r io.Reader) (n minio.UploadInfo, err error)
  • func (d *Dao) PutEncryptedFile(ctx context.Context, path string, r io.Reader) (n minio.UploadInfo, err error)
  • func (d *Dao) PutPhotoFile(ctx context.Context, path string, buf []byte) (n minio.UploadInfo, err error)
  • func (d *Dao) PutPhotoFileV2(ctx context.Context, path string, r io.Reader) (n minio.UploadInfo, err error)
  • func (d *Dao) PutVideoFile(ctx context.Context, path string, buf []byte) (n minio.UploadInfo, err error)
  • func (d *Dao) ReadFile(ctx context.Context, ownerId, fileId int64, parts int32) (partLength int32, bytes []byte, err error)
  • func (d *Dao) ReadFileCB(ctx context.Context, ownerId, fileId int64, parts int32, ...) (err error)
  • func (d *Dao) ReadOffsetLimit(ctx context.Context, fileInfo *model.DfsFileInfo, offset, limit int32) (bytes []byte, err error)
  • func (d *Dao) SetCacheFileInfo(ctx context.Context, id int64, dfsFileInfo *model.DfsFileInfo) (err error)
  • func (d *Dao) SetFileInfo(ctx context.Context, fileInfo *model.DfsFileInfo) (err error)
  • func (d *Dao) WriteFilePartData(ctx context.Context, ownerId, fileId int64, filePart int32, bytes []byte) (err error)
• type SSDBReader
  • func (r *SSDBReader) Read(p []byte) (n int, err error)
  • func (r *SSDBReader) ReadAll(ctx context.Context) ([]byte, error)
  • func (r *SSDBReader) Seek(offset int64, whence int) (int64, error)

Types

type Dao

type Dao struct {
	idgen_client.IDGenClient2
	// contains filtered or unexported fields
}

func New

func New(c config.Config) *Dao

func NewDFSHelper

func NewDFSHelper(minio *minio_util.MinioConfig, idgen zrpc.RpcClientConf, ssdb kv.KvConf) *Dao

func (*Dao) FPutDocumentFile

func (d *Dao) FPutDocumentFile(ctx context.Context, path string, r string) (n minio.UploadInfo, err error)

func (*Dao) GetCacheDfsFileInfo

func (d *Dao) GetCacheDfsFileInfo(ctx context.Context, id int64) (*model.DfsFileInfo, error)

func (*Dao) GetCacheFile

func (d *Dao) GetCacheFile(ctx context.Context, bucket string, id int64, offset int64, limit int32) (bytes []byte, err error)

func (*Dao) GetFile

func (d *Dao) GetFile(ctx context.Context, bucket, path string, offset int64, limit int32) (bytes []byte, err error)

func (*Dao) GetFileInfo

func (d *Dao) GetFileInfo(ctx context.Context, ownerId, fileId int64) (fileInfo *model.DfsFileInfo, err error)

func (*Dao) GetFileObject

func (d *Dao) GetFileObject(ctx context.Context, bucket, path string) (*minio.Object, error)

func (*Dao) NewSSDBReader

func (d *Dao) NewSSDBReader(fileInfo *model.DfsFileInfo) *SSDBReader

func (*Dao) OpenFile

func (d *Dao) OpenFile(ctx context.Context, ownerId, fileId int64, parts int32) (*SSDBReader, error)

func (*Dao) PutDocumentFile

func (d *Dao) PutDocumentFile(ctx context.Context, path string, r io.Reader) (n minio.UploadInfo, err error)

func (*Dao) PutEncryptedFile

func (d *Dao) PutEncryptedFile(ctx context.Context, path string, r io.Reader) (n minio.UploadInfo, err error)

func (*Dao) PutPhotoFile

func (d *Dao) PutPhotoFile(ctx context.Context, path string, buf []byte) (n minio.UploadInfo, err error)

func (*Dao) PutPhotoFileV2

func (d *Dao) PutPhotoFileV2(ctx context.Context, path string, r io.Reader) (n minio.UploadInfo, err error)

func (*Dao) PutVideoFile

func (d *Dao) PutVideoFile(ctx context.Context, path string, buf []byte) (n minio.UploadInfo, err error)

func (*Dao) ReadFile

func (d *Dao) ReadFile(ctx context.Context, ownerId, fileId int64, parts int32) (partLength int32, bytes []byte, err error)

func (*Dao) ReadFileCB

func (d *Dao) ReadFileCB(ctx context.Context, ownerId, fileId int64, parts int32, cb func(part int32, bytes []byte) error) (err error)

func (*Dao) ReadOffsetLimit

func (d *Dao) ReadOffsetLimit(ctx context.Context, fileInfo *model.DfsFileInfo, offset, limit int32) (bytes []byte, err error)

func (*Dao) SetCacheFileInfo

func (d *Dao) SetCacheFileInfo(ctx context.Context, id int64, dfsFileInfo *model.DfsFileInfo) (err error)

func (*Dao) SetFileInfo

func (d *Dao) SetFileInfo(ctx context.Context, fileInfo *model.DfsFileInfo) (err error)

func (*Dao) WriteFilePartData

func (d *Dao) WriteFilePartData(ctx context.Context, ownerId, fileId int64, filePart int32, bytes []byte) (err error)

type SSDBReader

type SSDBReader struct {
	*model.DfsFileInfo
	// contains filtered or unexported fields
}

func (*SSDBReader) Read

func (r *SSDBReader) Read(p []byte) (n int, err error)

func (*SSDBReader) ReadAll

func (r *SSDBReader) ReadAll(ctx context.Context) ([]byte, error)

func (*SSDBReader) Seek

func (r *SSDBReader) Seek(offset int64, whence int) (int64, error)

Seek implements the io.Seeker interface.