Documentation ¶
Index ¶
- type ProxyApi
- type ProxyClient
- func (c *ProxyClient) Chmod(path string, mode uint32, log *ClientLogger) (resp SetAttrResponse, err error)
- func (c *ProxyClient) Chown(path string, uid, gid uint32, log *ClientLogger) (resp SetAttrResponse, err error)
- func (c *ProxyClient) ChownEx(path string, owner, group string, log *ClientLogger) (resp SetAttrResponse, err error)
- func (c *ProxyClient) Close()
- func (c *ProxyClient) Fsync(id uint64, log *ClientLogger) (resp FsyncResponse, err error)
- func (c *ProxyClient) GetIoClient() *http.HttpClient
- func (c *ProxyClient) GetXattr(path, name string, log *ClientLogger) (resp GetxattrResponse, err error)
- func (c *ProxyClient) Link(path, dstpath string, log *ClientLogger) (resp LinkResponse, err error)
- func (c *ProxyClient) ListXAttr(path string, log *ClientLogger) (resp ListxattrResponse, err error)
- func (c *ProxyClient) MkDir(path string, mode uint32, log *ClientLogger) (resp MkdirResponse, err error)
- func (c *ProxyClient) Open(path string, flag uint32, mode uint32, log *ClientLogger) (resp OpenResponse, err error)
- func (c *ProxyClient) Read(id, offset, length uint64, log *ClientLogger) (resp ReadResponse, err error)
- func (c *ProxyClient) ReadDir(path string, log *ClientLogger) (resp ReaddirResponse, err error)
- func (c *ProxyClient) ReadDirEx(path, startKey string, count uint16, log *ClientLogger) (resp ReaddirExResponse, err error)
- func (c *ProxyClient) Rename(path, dstPath string, log *ClientLogger) (resp RenameResponse, err error)
- func (c *ProxyClient) RmDir(path string, log *ClientLogger) (resp RmdirResponse, err error)
- func (c *ProxyClient) RmDirTree(path string, log *ClientLogger) (resp RmdirTreeResponse, err error)
- func (c *ProxyClient) RmXAttr(path, name string, log *ClientLogger) (resp RemovexattrResponse, err error)
- func (c *ProxyClient) SetXattr(path string, flag SetXattrFlag, name string, value []byte, log *ClientLogger) (resp SetxattrResponse, err error)
- func (c *ProxyClient) Stat(path string, log *ClientLogger) (resp StatResponse, err error)
- func (c *ProxyClient) StatFs(path string, log *ClientLogger) (resp StatfsResponse, err error)
- func (c *ProxyClient) SymLink(path string, dstpath string, log *ClientLogger) (resp SymlinkResponse, err error)
- func (c *ProxyClient) Truncate(path string, length uint64, log *ClientLogger) (resp TruncateResponse, err error)
- func (c *ProxyClient) Unlink(path string, log *ClientLogger) (resp UnlinkResponse, err error)
- func (c *ProxyClient) Utime(path string, utime, atime uint64, log *ClientLogger) (resp SetAttrResponse, err error)
- func (c *ProxyClient) Write(id uint64, buffer []byte, offset uint64, log *ClientLogger) (resp WriteResponse, err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ProxyApi ¶
type ProxyApi interface { Close() GetIoClient() *http.HttpClient GetThirdPartyClient() *http.HttpClient Unlink(path string, log *ClientLogger) (UnlinkResponse, error) Link(path, dstpath string, log *ClientLogger) (LinkResponse, error) MkDir(path string, mode uint32, log *ClientLogger) (MkdirResponse, error) ReadDir(path, log *ClientLogger) (ReaddirResponse, error) ReadDirEx(path, startKey string, count uint16, log *ClientLogger) (ReaddirExResponse, error) RmDir(path string, log *ClientLogger) (RmdirResponse, error) RmDirTree(path string, log *ClientLogger) (RmdirTreeResponse, error) Open(path string, flag int, mode uint32, log *ClientLogger) (OpenResponse, error) Read(id, offset, length uint64, log *ClientLogger) (ReadResponse, error) Write(req *WriteRequest, log *ClientLogger) (WriteResponse, error) Truncate(path string, length uint64, log *ClientLogger) (TruncateResponse, error) SetXattr(path string, flag SetXattrFlag, name string, value []byte, log *ClientLogger) (SetxattrResponse, error) GetXattr(path, name string, log *ClientLogger) (GetxattrResponse, error) ListXAttr(path string, log *ClientLogger) (ListxattrResponse, error) RmXAttr(path, name string, log *ClientLogger) (RemovexattrResponse, error) SetAttr(req SetAttrRequest, log *ClientLogger) (SetAttrResponse, error) Rename(path, dstPath string, log *ClientLogger) (RenameResponse, error) Stat(path string, log *ClientLogger) (StatResponse, error) Fstat(id uint64, log *ClientLogger) (StatResponse, error) StatFs(path string, log *ClientLogger) (StatfsResponse, error) Fsync(id uint64, log *ClientLogger) (FsyncResponse, error) }
type ProxyClient ¶
type ProxyClient struct { IoCli *http.HttpClient RetryCfg *conf.RetryCfg St *stat.Statistic sync.Mutex }
func NewProxyClient ¶
func NewProxyClient(io *http.HttpClient, retry *conf.RetryCfg, st *stat.Statistic) *ProxyClient
func (*ProxyClient) Chmod ¶
func (c *ProxyClient) Chmod(path string, mode uint32, log *ClientLogger) (resp SetAttrResponse, err error)
func (*ProxyClient) Chown ¶
func (c *ProxyClient) Chown(path string, uid, gid uint32, log *ClientLogger) (resp SetAttrResponse, err error)
func (*ProxyClient) ChownEx ¶
func (c *ProxyClient) ChownEx(path string, owner, group string, log *ClientLogger) (resp SetAttrResponse, err error)
func (*ProxyClient) Close ¶
func (c *ProxyClient) Close()
func (*ProxyClient) Fsync ¶
func (c *ProxyClient) Fsync(id uint64, log *ClientLogger) (resp FsyncResponse, err error)
func (*ProxyClient) GetIoClient ¶
func (c *ProxyClient) GetIoClient() *http.HttpClient
func (*ProxyClient) GetXattr ¶
func (c *ProxyClient) GetXattr(path, name string, log *ClientLogger) (resp GetxattrResponse, err error)
func (*ProxyClient) Link ¶
func (c *ProxyClient) Link(path, dstpath string, log *ClientLogger) (resp LinkResponse, err error)
func (*ProxyClient) ListXAttr ¶
func (c *ProxyClient) ListXAttr(path string, log *ClientLogger) (resp ListxattrResponse, err error)
func (*ProxyClient) MkDir ¶
func (c *ProxyClient) MkDir(path string, mode uint32, log *ClientLogger) (resp MkdirResponse, err error)
func (*ProxyClient) Open ¶
func (c *ProxyClient) Open(path string, flag uint32, mode uint32, log *ClientLogger) (resp OpenResponse, err error)
Create a new file or open an existing file
func (*ProxyClient) Read ¶
func (c *ProxyClient) Read(id, offset, length uint64, log *ClientLogger) (resp ReadResponse, err error)
查询文件信息
func (*ProxyClient) ReadDir ¶
func (c *ProxyClient) ReadDir(path string, log *ClientLogger) (resp ReaddirResponse, err error)
func (*ProxyClient) ReadDirEx ¶
func (c *ProxyClient) ReadDirEx(path, startKey string, count uint16, log *ClientLogger) (resp ReaddirExResponse, err error)
func (*ProxyClient) Rename ¶
func (c *ProxyClient) Rename(path, dstPath string, log *ClientLogger) (resp RenameResponse, err error)
func (*ProxyClient) RmDir ¶
func (c *ProxyClient) RmDir(path string, log *ClientLogger) (resp RmdirResponse, err error)
func (*ProxyClient) RmDirTree ¶
func (c *ProxyClient) RmDirTree(path string, log *ClientLogger) (resp RmdirTreeResponse, err error)
func (*ProxyClient) RmXAttr ¶
func (c *ProxyClient) RmXAttr(path, name string, log *ClientLogger) (resp RemovexattrResponse, err error)
func (*ProxyClient) SetXattr ¶
func (c *ProxyClient) SetXattr(path string, flag SetXattrFlag, name string, value []byte, log *ClientLogger) (resp SetxattrResponse, err error)
func (*ProxyClient) Stat ¶
func (c *ProxyClient) Stat(path string, log *ClientLogger) (resp StatResponse, err error)
get meta info
func (*ProxyClient) StatFs ¶
func (c *ProxyClient) StatFs(path string, log *ClientLogger) (resp StatfsResponse, err error)
Obtain the meta information about a file system or directory tree
func (*ProxyClient) SymLink ¶
func (c *ProxyClient) SymLink(path string, dstpath string, log *ClientLogger) (resp SymlinkResponse, err error)
func (*ProxyClient) Truncate ¶
func (c *ProxyClient) Truncate(path string, length uint64, log *ClientLogger) (resp TruncateResponse, err error)
func (*ProxyClient) Unlink ¶
func (c *ProxyClient) Unlink(path string, log *ClientLogger) (resp UnlinkResponse, err error)
delete a file
Click to show internal directories.
Click to hide internal directories.