node

package

Go to main page

Versions in this module

v0

v0.4.2

Mar 20, 2025

Changes in this version

+ const ERR_FileNotFound

type FileHandler

+ func (f *FileHandler) GetUserFilesHandle(c *gin.Context)

+ type UserFilesInfo struct

+ Fid string

+ Size uint64

+ Territory string

v0.4.1

Feb 14, 2025

Changes in this version

type FileHandler

+ func (f *FileHandler) DownloadFragmentHandle(c *gin.Context)

v0.4.0

Jan 20, 2025

Changes in this version

+ const ERR_EmptyFileName

+ const ERR_FailedToRecvData

+ const ERR_IllegalContentRange

+ const ERR_InvalidFid

+ const ERR_InvalidFormFile

+ const ERR_InvalidRangeEnd

+ const ERR_InvalidRangeStart

+ const ERR_InvalidRangeValue

+ const ERR_MissingContentRange

+ const ERR_RPCConnection

+ const ERR_RPCSyncing

+ const ERR_ReceiveData

+ const ERR_ServerBusy

+ const ERR_SystemErr

+ const ERR_UnknownFileFormat

+ const HTTPHeader_Filename

+ const HTTPHeader_Latitude

+ const HTTPHeader_Longitude

+ const HTTPHeader_Miner

+ const HTTPHeader_Range

+ const HTTPHeader_X_Forwarded_For

+ const MSG_OK

+ func CheckAuthorize(cli chain.Chainer, c *gin.Context, pkey []byte) error

+ func CheckChainSt(cli chain.Chainer, c *gin.Context) error

+ func CheckFileType(cli chain.Chainer, fid string, account string) (string, error)

+ func CheckFilename(c *gin.Context, filename string) error

+ func CheckMinerLocation(cli chain.Chainer, puk []byte) (float64, float64, error)

+ func CheckPermissionsMdl(account string, accessmode string, priority, blackwhite []string) bool

+ func CheckTerritory(cli chain.Chainer, c *gin.Context, pkey []byte, territoryName string) (uint64, error)

+ func CreateTmpPath(c *gin.Context, dir, account string) (string, string, error)

+ func DownloadFileFromGW(url, fpath, account, message, signature string) (uint64, error)

+ func FindFileFromGW(cli chain.Chainer, fid string, fpath string) (uint64, error)

+ func FindLocalFile(fid string, dirs ...string) (uint64, string, error)

+ func GetCoordinate(addr string) (coordinate.Coordinate, error)

+ func GetGWVersion(url string) error

+ func InitMiddlewares() []gin.HandlerFunc

+ func IsComplete(index int, completeInfo []schain.CompleteInfo) (string, bool)

+ func IsStoraged(account string, complete []string) bool

+ func ParseCity(addr string) (float64, float64, bool)

+ func ReturnFileRangeStream(c *gin.Context, rng string, content_type string, file string) error

+ func ReturnFileStream(c *gin.Context, reader io.Reader, fid, contenttype, format string, size int64)

+ func ReturnJSON(c *gin.Context, code int, msg string, data any)

+ func VerifySignatureMdl(c *gin.Context) (string, []byte, bool)

+ func VerifySignatureMdl2(account, ethAccount, message, signature string) (string, []byte, bool)

+ type FileHandler struct

+ func NewFileHandler(cli chain.Chainer, track tracker.Tracker, ws workspace.Workspace, ...) *FileHandler

+ func (f *FileHandler) DeleteFileHandle(c *gin.Context)

+ func (f *FileHandler) DownloadFileHandle(c *gin.Context)

+ func (f *FileHandler) GetLocationhandle(c *gin.Context)

+ func (f *FileHandler) GetMetadataHandle(c *gin.Context)

+ func (f *FileHandler) OpenFileHandle(c *gin.Context)

+ func (f *FileHandler) RegisterRoutes(server *gin.Engine)

+ func (f *FileHandler) UploadFormFileHandle(c *gin.Context)

+ type FilesHandler struct

+ func NewFilesHandler(cli chain.Chainer, track tracker.Tracker, ws workspace.Workspace, ...) *FilesHandler

+ func (f *FilesHandler) RegisterRoutes(server *gin.Engine)

+ func (f *FilesHandler) UploadFormFilesHandle(c *gin.Context)

+ type Handler struct

+ func NewHandler(cli chain.Chainer, track tracker.Tracker, ws workspace.Workspace, ...) *Handler

+ func (h *Handler) RegisterRoutes(server *gin.Engine)

+ type MultiFormFiles struct

+ Fapth string

+ Fid string

+ Name string

+ Reason string

+ Result string

+ SegmentDataInfo []chain.SegmentDataInfo

+ Size int64

type Node

+ func NewEmptyNode() *Node

+ func NewNodeWithConfig(cfg *confile.Config) *Node

+ func (n *Node) InitCache()

+ func (n *Node) InitChainClient()

+ func (n *Node) InitChainclient(cli chain.Chainer)

+ func (n *Node) InitLRUCache(lru *lru.LRUCache)

+ func (n *Node) InitLogger(lg logger.Logger)

+ func (n *Node) InitLogs()

+ func (n *Node) InitMinerRecord(r record.MinerRecorder)

+ func (n *Node) InitNode() *Node

+ func (n *Node) InitServer(s *gin.Engine)

+ func (n *Node) InitTracker(t tracker.Tracker)

+ func (n *Node) InitWebServer(mdls []gin.HandlerFunc, hdl *Handler)

+ func (n *Node) InitWorkspace(ws string)

+ func (n *Node) RefreshBlacklist(ch chan<- bool)

+ func (n *Node) Start()

+ func (n *Node) StoragePartAssignment(ch chan<- bool, data StorageDataType, assignments []string)

+ func (n *Node) StoragePartFixed(data StorageDataType, assignments []string) (StorageDataType, error)

+ func (n *Node) StorageRangeAssignment(ch chan<- bool, data StorageDataType)

+ func (n *Node) TrackerV2()

+ func (n *Node) UploadFragmentToMiner(addr, fid, fragmentHash, fragmentPath string) error

type NodeInfo

+ Account string

+ type ObjectHandler struct

+ func NewObjectHandler(cli chain.Chainer, track tracker.Tracker, ws workspace.Workspace, ...) *ObjectHandler

+ func (o *ObjectHandler) RegisterRoutes(server *gin.Engine)

+ func (o *ObjectHandler) UploadObjectHandle(c *gin.Context)

+ type RespType struct

+ Code int

+ Data any

+ Msg string

+ type ResumeHandler struct

+ func NewResumeHandler(cli chain.Chainer, track tracker.Tracker, ws workspace.Workspace, ...) *ResumeHandler

+ func (r *ResumeHandler) RegisterRoutes(server *gin.Engine)

+ func (r *ResumeHandler) ResumeHandle(c *gin.Context)

+ type StorageDataType struct

+ Assignments []string

+ Complete []string

+ Data [][]string

+ Fid string

+ Range coordinate.Range

+ StorageType StorageType

+ type StorageType uint8

+ const Storage_FullAssignment

+ const Storage_NoAssignment

+ const Storage_PartAssignment

+ const Storage_RangeAssignment

v0.3.7

Aug 5, 2024

Changes in this version

+ const CANS_ARCHIVE_FORMAT_HEADER

+ const CANS_PROTO_FLAG

+ const CANS_PROTO_HEADER

+ const CANS_SPLIT_FILE_HEADER

+ const CHUNK_FILE_FLAG

+ const ERR_EmptyBody

+ const ERR_FileNameTooShort

+ const ERR_InsufficientTerritorySpace

+ const ERR_NoTerritory

+ const ERR_TerritoryExpiresSoon

+ const FILE_METADATA_KEY

+ const HTTPHeader_BIdx

+ const HTTPHeader_BNum

+ const HTTPHeader_Bucket

+ const HTTPHeader_Fname

+ const HTTPHeader_Format

+ const HTTPHeader_TSize

+ const HTTPHeader_Territory

+ const HTTP_ParameterName_Fid

+ const HTTP_Parameter_BucketNme

+ const Notfound

+ func DecryptSegment(fpath, cipher string) error

+ func OtherHeader(c *gin.Context, fname string)

+ func Subscribe(ctx context.Context, h host.Host, bootnode string, ...)

+ func VideoAndAudioHeader(c *gin.Context, fname string)

+ type CansRequestParams struct

+ Cipher string

+ SegmentIndex int

+ SubFile string

+ type ChunksInfo struct

+ BlockNum int

+ FileName string

+ Finished int

+ FlushTime time.Time

+ SavedBlocks []bool

+ SavedFileSize int64

+ TotalSize int64

+ type DuplicateType uint8

+ const Duplicate0

+ const Duplicate1

+ const Duplicate2

+ type Location struct

+ Latitude float64

+ Longitude float64

+ type Metadata struct

+ Fid string

+ Owner []RtnUserBrief

+ Size uint64

type Node

+ func (n *Node) CheckLocalFile(fid string) (int64, string, error)

+ func (n *Node) Delete_bucket(c *gin.Context)

+ func (n *Node) Delete_file(c *gin.Context)

+ func (n *Node) Download_file(c *gin.Context)

+ func (n *Node) FeedbackLog(c *gin.Context)

+ func (n *Node) GetCanFileHandle(c *gin.Context)

+ func (n *Node) GetRestoreHandle(c *gin.Context)

+ func (n *Node) GetSegment(fdir, fhash, cipher string, sid int) (fpath string, err error)

+ func (n *Node) Get_bucket(c *gin.Context)

+ func (n *Node) Get_location(c *gin.Context)

+ func (n *Node) Get_metadata(c *gin.Context)

+ func (n *Node) Get_version(c *gin.Context)

+ func (n *Node) InitFileCache(exp time.Duration, maxSpace int64, cacheDir string)

+ func (n *Node) InitNodeSelector(strategy string, nodeFilePath string, maxNodeNum int, ...) error

+ func (n *Node) NotFound(c *gin.Context)

+ func (n *Node) Preview_file(c *gin.Context)

+ func (n *Node) PutChunksHandle(c *gin.Context)

+ func (n *Node) Put_bucket(c *gin.Context)

+ func (n *Node) Put_file(c *gin.Context)

+ func (n *Node) Put_object(c *gin.Context)

+ func (n *Node) QueryFileType(fid string, account string) (string, string, int, error)

+ func (n *Node) RefreshMiner(ch chan<- bool)

+ func (n *Node) RefreshSelf() error

+ func (n *Node) RestoreFile(c *gin.Context)

+ func (n *Node) ReturnFile(c *gin.Context, reader io.Reader, fid, contenttype, format string, size int64)

+ func (n *Node) Tracker(ch chan<- bool)

+ type NodeInfo struct

+ Location Location

+ PeerId string

+ type PeerRecord interface

+ BackupPeer func(path string) error

+ GetAllPeerId func() []string

+ GetPeer func(peerid string) (peer.AddrInfo, bool)

+ GetPeerByAccount func(account string) (peer.AddrInfo, bool)

+ HasPeer func(peerid string) bool

+ LoadPeer func(path string) error

+ SavePeer func(addr peer.AddrInfo) error

+ SavePeerAccount func(account string, peerid string) error

+ func NewPeerRecord() PeerRecord

+ type PeerRecordType struct

+ func (p *PeerRecordType) BackupPeer(path string) error

+ func (p *PeerRecordType) GetAllPeerId() []string

+ func (p *PeerRecordType) GetPeer(peerid string) (peer.AddrInfo, bool)

+ func (p *PeerRecordType) GetPeerByAccount(account string) (peer.AddrInfo, bool)

+ func (p *PeerRecordType) HasPeer(peerid string) bool

+ func (p *PeerRecordType) LoadPeer(path string) error

+ func (p *PeerRecordType) SavePeer(addr peer.AddrInfo) error

+ func (p PeerRecordType) SavePeerAccount(account string, peerid string) error

type RecordInfo

+ BucketName string

+ CacheDir string

+ Cipher string

+ Fid string

+ FileName string

+ FileSize uint64

+ PutFlag bool

+ Segment []chain.SegmentDataInfo

+ TerritoryName string

v0.3.6

Mar 19, 2024

Changes in this version

+ const HTTPHeader_EthAccount

+ func VerifyEthSign(message string, sign string) (string, error)

type Node

+ func (n *Node) Run2(port int, workspace string)

+ func (n *Node) VerifyAccountSignature(account, msg, signature string) ([]byte, error)

v0.3.5

Jan 31, 2024

Changes in this version

+ const ERR_FileNameTooLang

+ const ERR_MissingAccount

+ const ERR_NoSpace

v0.3.4

Dec 13, 2023

v0.3.3

Nov 29, 2023

Changes in this version

+ const ERR_Forbidden

type Node

+ func (n *Node) AccessControl(account string) bool

+ func (n *Node) DeleteStoragePeer(peerid string)

+ func (n *Node) GetAllStoragePeerId() []string

+ func (n *Node) HasStoragePeer(peerid string) bool

+ func (n *Node) ParseTrackFile(filehash string) (RecordInfo, error)

+ func (n *Node) SaveStoragePeer(peerid string)

v0.3.2

Oct 30, 2023

Changes in this version

+ const Cache_SyncBlock

+ const Cache_UserDeleteFiles

+ const Cache_UserFiles

+ const Cache_WantFiles

+ const HTTPHeader_Cipher

+ const INFO_GetRestoreRequest

+ const INFO_PostRestoreRequest

type Node

+ func (n *Node) SetDfileDir(dir string)

+ func (n *Node) SetUfileDir(dir string)

+ type RestoreList struct

+ Files []string

v0.3.1

Sep 6, 2023

Changes in this version

type Node

+ func (n *Node) SetFadebackDir(dir string)

v0.3.0

Aug 31, 2023

Changes in this version

+ const MaxTrackThread

type Node

+ func (n *Node) AddToBlacklist(peerid string)

+ func (n *Node) DelFromBlacklist(peerid string)

+ func (n *Node) HasBlacklist(peerid string) (int64, bool)

v0.2.5

Jul 21, 2023

Changes in this version

+ const ERR_NotFound

+ const HTTPHeader_Fid

type Node

+ func (n *Node) EncodePeers() []byte

+ func (n *Node) RemovePeerIntranetAddr()

+ func (n *Node) SaveOrUpdatePeerUnSafe(peerid string, addr peer.AddrInfo)

v0.2.4

Jul 13, 2023

Changes in this version

+ const HTTPHeader_Message

+ const HTTPHeader_Signature

type Node

+ func (n *Node) LoadPeersFromDisk(path string) error

+ func (n *Node) SavePeersToDisk(path string) error

+ func (n *Node) SetTrackDir(dir string)

v0.2.3

Jul 10, 2023

Changes in this version

+ const ERR_BodyEmptyFile

+ const ERR_HeadOperation

v0.2.2

Jul 8, 2023

v0.2.1

Jul 6, 2023

Changes in this version

type Node

+ func (n *Node) GetAllPeerId() []string

v0.2.0

Jul 4, 2023

Changes in this version

+ const Active

+ const Calculate

+ const ERR_AccountNotExist

+ const ERR_Authorization

+ const ERR_BodyFieldAccount

+ const ERR_BodyFieldMessage

+ const ERR_BodyFieldSignature

+ const ERR_BodyFormat

+ const ERR_DeviceSpaceNoLeft

+ const ERR_DuplicateOrder

+ const ERR_EmptyBucketName

+ const ERR_EmptyFile

+ const ERR_EmptySeed

+ const ERR_HeaderFieldBucketName

+ const ERR_InternalServer

+ const ERR_InvalidAccount

+ const ERR_InvalidBucketName

+ const ERR_InvalidFilehash

+ const ERR_InvalidName

+ const ERR_InvalidParaBucketName

+ const ERR_InvalidToken

+ const ERR_MissAccount

+ const ERR_MissToken

+ const ERR_NoPermission

+ const ERR_NotEnoughSpace

+ const ERR_ParseBody

+ const ERR_ReadBody

+ const ERR_ReceiveFile

+ const ERR_RpcFailed

+ const ERR_SpaceExpiresSoon

+ const ERR_SpaceNotAuth

+ const ERR_SysMemNoLeft

+ const ERR_UnauthorizedSpace

+ const FormFileKey1

+ const FormFileKey2

+ const FormFileKey3

+ const HTTPHeader_Account

+ const HTTPHeader_Authorization

+ const HTTPHeader_BucketName

+ const HTTPHeader_Digest

+ const HTTPHeader_Operation

+ const HTTP_ParameterName

+ const INFO_DelRequest

+ const INFO_GetRequest

+ const INFO_PutRequest

+ const MaxMemUsed

+ const MinRecordInfoLength

+ const Missing

+ const Recovery

+ const TokenDated

+ func VerifySign(pkey, signmsg, sign []byte) (bool, error)

+ type AuthType struct

+ Account string

+ Message string

+ Signature []byte

+ type CustomClaims struct

+ Account string

+ type DelList struct

+ Files []string

+ type FileMetaData struct

+ Completion uint32

+ Owner []RtnUserBrief

+ SegmentList []SegmentInfo

+ State string

+ type FragmentInfo struct

+ Avail bool

+ FragmentHash string

+ Miner string

+ type Node struct

+ TrackDir string

+ func New() *Node

+ func (n *Node) DeleteTrackFile(filehash string)

+ func (n *Node) GetPeer(peerid string) (peer.AddrInfo, bool)

+ func (n *Node) HasPeer(peerid string) bool

+ func (n *Node) HasTrackFile(filehash string) bool

+ func (n *Node) ListTrackFiles() ([]string, error)

+ func (n *Node) ParseTrackFromFile(filehash string) (RecordInfo, error)

+ func (n *Node) QueryAssignedMiner(minerTaskList []pattern.MinerTaskList) ([]string, []string, error)

+ func (n *Node) RebuildDirs()

+ func (n *Node) Run()

+ func (n *Node) SavePeer(peerid string, addr peer.AddrInfo)

+ func (n *Node) SetSignkey(signkey []byte)

+ func (n *Node) TaskMgt()

+ func (n *Node) WriteTrackFile(filehash string, data []byte) error

+ type Oss interface

+ Run func()

+ type RecordInfo struct

+ Buckname string

+ Count uint8

+ Duplicate bool

+ Filename string

+ Filesize uint64

+ Owner []byte

+ Putflag bool

+ Roothash string

+ SegmentInfo []pattern.SegmentDataInfo

+ type RespMsg struct

+ Code int

+ Err error

+ type RtnBlockInfo struct

+ BlockId string

+ MinerAcc string

+ MinerId uint64

+ MinerIp string

+ type RtnFileType struct

+ BlockInfo []RtnBlockInfo

+ FileSize uint64

+ FileState string

+ UserBriefs []RtnUserBrief

+ type RtnUserBrief struct

+ BucketName string

+ FileName string

+ User string

+ type SegmentInfo struct

+ FragmentList []FragmentInfo

+ SegmentHash string

v0.2.0-dev

Jul 6, 2023

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL