api

package
v0.0.0-...-fa4cddc Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 21, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

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 (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 (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 (c *ProxyClient) Unlink(path string, log *ClientLogger) (resp UnlinkResponse, err error)

delete a file

func (*ProxyClient) Utime 

func (c *ProxyClient) Utime(path string, utime, atime uint64, log *ClientLogger) (resp SetAttrResponse, err error)

update timestamps of dir entry

func (*ProxyClient) Write 

func (c *ProxyClient) Write(id uint64, buffer []byte, offset uint64, log *ClientLogger) (resp WriteResponse, err error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.