opensdk

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

type CopyNodeBo struct {
	SRC      string
	DST      string
	Override bool
}

type CreateUserBo struct {
	UserType int
	UserID   string
	UserName string
	UserPWD  string
}

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

type DirNameListDto struct {
	Datas []string
	Total int
}

type DirNodeListDto struct {
	Datas []TNode
	Total int
}

type IConn4RPC interface {
	GetAccessKey() (string, error)
	GetClient() (IRPCClient, error)
	DoRPC(method string, args interface{}, reply interface{}) error
}

type IOpenApi interface {
	ConnTest(user User) error

	IsDir(src string) (bool, error)
	IsFile(src string) (bool, error)
	IsExist(src string) (bool, error)
	GetFileSize(src string) (int64, error)

	GetNode(src string) (*TNode, error)
	GetNodes(src []string) ([]TNode, error)
	GetDirNameList(src string, limit, offset int) (*DirNameListDto, error)
	GetDirNodeList(src string, limit, offset int) (*DirNodeListDto, error)

	DoMkDir(path string) (string, error)
	DoDelete(src string) error
	DoRename(src string, dst string) error
	DoCopy(src, dst string, override bool) (string, error)
	DoMove(src, dst string, override bool) error

	DoQueryToken(token string) (*StreamToken, error)
	DoAskReadToken(src string) (*StreamToken, error)
	DoAskWriteToken(src string) (*StreamToken, error)
	DoRefreshToken(token string) (*StreamToken, error)
	DoSubmitWriteToken(token string, override bool) (*TNode, error)
	SetDataNodeDNS(nodes map[string]string)
	GetReadStreamURL(nodeNo, token, endpoint string) (string, error)
	GetWriteStreamURL(nodeNo, token, endpoint string) (string, error)
	DoWriteToken(nodeNo, token, endpoint string, pieceNumber int, sha256 string, reader io.Reader) error
	DoReadToken(nodeNo, token, endpoint string, offset int64) (io.ReadCloser, error)
}

type IRPCClient interface {
	Close() error
	Call(serviceMethod string, args interface{}, reply interface{}) error
}

type IServerMG interface {
	ConnTest(user User) error
	DoCreateUser(user CreateUserBo) (bool, error)
	DoUpdatePWD(user, pwd string) (bool, error)
	DoDeleteUser(userID string) (bool, error)
	DoListAllUsers() (*UserListDto, error)
}

type LimitQueryBo struct {
	Query  string
	Limit  int
	Offset int
}

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

type MoveNodeBo struct {
	SRC      string
	DST      string
	Override bool
}

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

type PwdUpdateBo struct {
	User string
	Pwd  string
}

type RPCClient struct {
	ClientID string

	*rpc.Client
	// contains filtered or unexported fields
}

type RequestBody struct {
	AccessKey   string
	Signature   string
	RequestBody interface{}
}

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

type Session struct {
	AccessKey string
	SecretKey string
}

type SrcAndDstBo struct {
	SRC string
	DST string
}

type StreamToken struct {
	Token    string
	NodeNo   string
	FileID   string
	FilePath string
	FileSize int64
	CTime    int64
	MTime    int64
	EndPoint string
	Type     StreamTokenType
}

type StreamTokenType int

type TNode struct {
	Id    string
	Pid   string
	Addr  string
	Flag  int
	Name  string
	Size  int64
	Ctime int64
	Mtime int64
	Props string
}

type User struct {
	User     string
	Passwd   string
	PropJSON string
}

type UserInfo struct {
	UserType int
	UserID   string
	UserName string
	CtTime   time.Time
}

type UserListDto struct {
	Datas []UserInfo
	Total int
}

type WriteTokenBo struct {
	Token    string
	Override bool
}