node

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Aug 31, 2023 License: Apache-2.0 Imports: 36 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	HTTPHeader_Authorization = "Authorization"
	HTTPHeader_BucketName    = "BucketName"
	HTTPHeader_Account       = "Account"
	HTTPHeader_Digest        = "Digest"
	HTTPHeader_Operation     = "Operation"
	HTTPHeader_Message       = "Message"
	HTTPHeader_Signature     = "Signature"
	HTTPHeader_Fid           = "Fid"
)

HTTP HEADER

View Source 
const (
	Active = iota
	Calculate
	Missing
	Recovery
)
View Source 
const (
	HTTP_ParameterName = "name"
	FormFileKey1       = "file"
	FormFileKey2       = "File"
	FormFileKey3       = "FILE"
)
View Source 
const (
	INFO_PutRequest = "PutRequest"
	INFO_GetRequest = "GetRequest"
	INFO_DelRequest = "DelRequest"

	ERR_DuplicateOrder        = "duplicate order"
	ERR_MissToken             = "InvalidHead.MissToken"
	ERR_EmptySeed             = "InvalidProfile.EmptySeed"
	ERR_MissAccount           = "InvalidHead.MissAccount"
	ERR_InvalidAccount        = "InvalidHead.Account"
	ERR_NoPermission          = "InvalidToken.NoPermission"
	ERR_InvalidToken          = "InvalidHead.Token"
	ERR_InvalidName           = "InvalidParameter.Name"
	ERR_InvalidFilehash       = "InvalidParameter.FileHash"
	ERR_InvalidParaBucketName = "InvalidParameter.BucketName"
	ERR_InvalidBucketName     = "InvalidHead.BucketName"
	ERR_EmptyBucketName       = "Invalid.EmptyBucketName"
	ERR_UnauthorizedSpace     = "UnauthorizedSpace"
	ERR_EmptyFile             = "InvalidBody.EmptyFile"
	ERR_ReadBody              = "InvalidBody.ReadErr"
	ERR_ParseBody             = "InvalidBody.ParseErr"
	//ERR_SpaceExpired          = "space expired"
	ERR_NotEnoughSpace = "not enough account space"

	ERR_InternalServer = "InternalError"
)
View Source 
const (
	ERR_Authorization = "HeaderErr_Invalid_Authorization"

	ERR_HeadOperation = "HeaderErr_Invalid_Operation"

	ERR_NotFound = "Not found"

	ERR_BodyFormat         = "BodyErr_InvalidDataFormat"
	ERR_BodyFieldAccount   = "BodyErr_InvalidField_account"
	ERR_BodyFieldMessage   = "BodyErr_InvalidField_message"
	ERR_BodyFieldSignature = "BodyErr_InvalidField_signature"
	ERR_BodyEmptyFile      = "BodyErr_EmptyFile"

	ERR_HeaderFieldBucketName = "HeaderErr_InvalidBucketName"

	ERR_AccountNotExist   = "account does not exist"
	ERR_RpcFailed         = "rpc connection failed"
	ERR_SpaceExpiresSoon  = "space expires soon"
	ERR_SpaceNotAuth      = "space is not authorized"
	ERR_DeviceSpaceNoLeft = "no space left on the server device"

	ERR_SysMemNoLeft = "server unsupported file size"

	ERR_ReceiveFile = "InternalError"
)
View Source 
const MaxMemUsed = 512 << 20
View Source 
const MaxTrackThread = 50
View Source 
const MinRecordInfoLength = 132

MinRecordInfoLength = len(json.Marshal(RecordInfo{}))

View Source 
const TokenDated = 60 * 60 * 24 * 30

Variables

This section is empty.

Functions

func VerifySign 

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

Types

type AuthType 

type AuthType struct {
	Account   string `json:"account"`
	Message   string `json:"message"`
	Signature []byte `json:"signature"`
}

type CustomClaims 

type CustomClaims struct {
	Account string `json:"account"`
	jwt.StandardClaims
}

type DelList 

type DelList struct {
	Files []string `json:"files"`
}

type FileMetaData 

type FileMetaData struct {
	Completion  uint32
	State       string
	SegmentList []SegmentInfo
	Owner       []RtnUserBrief
}

file meta info

type FragmentInfo 

type FragmentInfo struct {
	FragmentHash string
	Avail        bool
	Miner        string
}

type Node 

type Node struct {
	confile.Confile
	logger.Logger
	db.Cache
	sdk.SDK
	*gin.Engine
	// contains filtered or unexported fields
}

func New 

func New() *Node

New is used to build a node instance

func (*Node) AddToBlacklist added in v0.3.0 

func (n *Node) AddToBlacklist(peerid string)

func (*Node) DelFromBlacklist added in v0.3.0 

func (n *Node) DelFromBlacklist(peerid string)

func (*Node) DeleteTrackFile 

func (n *Node) DeleteTrackFile(filehash string)

func (*Node) EncodePeers added in v0.2.5 

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

func (*Node) GetAllPeerId added in v0.2.1 

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

func (*Node) GetPeer 

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

func (*Node) HasBlacklist added in v0.3.0 

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

func (*Node) HasPeer 

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

func (*Node) HasTrackFile 

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

func (*Node) ListTrackFiles 

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

func (*Node) LoadPeersFromDisk added in v0.2.4 

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

func (*Node) ParseTrackFromFile 

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

func (*Node) QueryAssignedMiner 

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

func (*Node) RebuildDirs 

func (n *Node) RebuildDirs()

func (*Node) RemovePeerIntranetAddr added in v0.2.5 

func (n *Node) RemovePeerIntranetAddr()

func (*Node) Run 

func (n *Node) Run()

func (*Node) SaveOrUpdatePeerUnSafe added in v0.2.5 

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

func (*Node) SavePeer 

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

func (*Node) SavePeersToDisk added in v0.2.4 

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

func (*Node) SetSignkey 

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

func (*Node) SetTrackDir added in v0.2.4 

func (n *Node) SetTrackDir(dir string)

func (*Node) TaskMgt 

func (n *Node) TaskMgt()

func (*Node) WriteTrackFile 

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

type Oss 

type Oss interface {
	Run()
}

type RecordInfo 

type RecordInfo struct {
	SegmentInfo []pattern.SegmentDataInfo `json:"segmentInfo"`
	Owner       []byte                    `json:"owner"`
	Roothash    string                    `json:"roothash"`
	Filename    string                    `json:"filename"`
	Buckname    string                    `json:"buckname"`
	Filesize    uint64                    `json:"filesize"`
	Putflag     bool                      `json:"putflag"`
	Count       uint8                     `json:"count"`
	Duplicate   bool                      `json:"duplicate"`
}

type RespMsg 

type RespMsg struct {
	Code int
	Err  error
}

type RtnBlockInfo 

type RtnBlockInfo struct {
	MinerId  uint64
	BlockId  string
	MinerIp  string
	MinerAcc string
}

file block info

type RtnFileType 

type RtnFileType struct {
	FileSize   uint64
	FileState  string
	UserBriefs []RtnUserBrief
	BlockInfo  []RtnBlockInfo
}

type RtnUserBrief 

type RtnUserBrief struct {
	User       string
	FileName   string
	BucketName string
}

type SegmentInfo 

type SegmentInfo struct {
	SegmentHash  string
	FragmentList []FragmentInfo
}

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.