header

Documentation

Index

• Constants
• func GetMessageHeader(tag int16, varsion uint16, length uint32, cmd string, data []byte)
• func NewDecodeHeader(packet []byte, msgH *MessageHead)
• type MessageHead
  • func DecodeHeader(packet []byte) MessageHead
  • func MakeMessageHeader(tag int16, varsion uint16, length uint32, cmd string) MessageHead

Constants

const (
	ReqGetPPList   = "ReqGPPL" // request to get pp list
	RspGetPPList   = "RspGPPL" // response to get pp list
	ReqGetSPList   = "ReqGSPL" // request to get sp list
	RspGetSPList   = "RspGSPL" // response to get sp list
	ReqGetPPStatus = "ReqGPPS" // request to get pp status
	RspGetPPStatus = "RspGPPS" // response to get pp status
	ReqRegister    = "ReqReg"  // request to register
	RspRegister    = "RspReg"  // response to register

	ReqActivatePP  = "ReqActvp" // request to activate a PP node
	RspActivatePP  = "RspActvp" // response to activate a PP node
	ReqActivatedPP = "ReqActdp" // request when a PP node was successfully activated
	ReqActivatedSP = "ReqActds" // request when a SP node was successfully activated
	RspActivatedPP = "RspActdp" // response when a PP node was successfully activated

	ReqUpdateStakePP  = "ReqUpdtp"  // request to update stake for a PP node
	RspUpdateStakePP  = "RspUpdtp"  // response to update stake for a PP node
	ReqUpdatedStakePP = "ReqUpdtdp" // request when a PP node's stake was successfully updated
	ReqUpdatedStakeSP = "ReqUpdtds" // request when a SP node's stake was successfully updated
	RspUpdatedStakePP = "RspUpdtdp" // response when a PP node's stake  was successfully updated

	ReqDeactivatePP     = "ReqDctvp"  // request to deactivate a PP node
	RspDeactivatePP     = "RspDctvp"  // response to deactivate a PP node
	ReqUnbondingPP      = "ReqUbdp"   // request to unbonding a PP node
	RspUnbondingPP      = "RspUbdp"   // response to unbonding a PP node
	ReqDeactivatedPP    = "ReqDctdp"  // request when a PP node was successfully deactivated
	RspDeactivatedPP    = "RspDctdp"  // response when a PP node was successfully deactivated
	RspPPRegisteredToSP = "RspPRegds" // response when a PP node was successfully registered to SP

	ReqPrepay  = "ReqPrpay" // request for a PP node sending a prepay transaction
	RspPrepay  = "RspPrpay" // response for a PP node sending a prepay transaction
	ReqPrepaid = "ReqPrpad" // request when a PP node prepay transaction was successful
	RspPrepaid = "RspPrpad" // response when a PP node prepay transaction was successful

	ReqMining = "ReqMin" // request to mining
	RspMining = "RspMin" //  response to mining

	// upload
	ReqUploadFile              = "ReqUpl"
	RspUploadFile              = "RspUpl"
	ReqUploadFileSlice         = "ReqUpLFS"
	RspUploadFileSlice         = "RspUpLFS"
	ReqReportUploadSliceResult = "ReqUFR"
	RspReportUploadSliceResult = "RspUFR"
	UploadSpeedOfProgress      = "USOP"
	Uploaded                   = "Uploaded"

	ReqFindMyFileList = "ReqFFL"
	RspFindMyFileList = "RspFFL"

	ReqDeleteFile = "ReqDF"
	RspDeleteFile = "RspDF"

	ReqGetHDInfo = "ReqHDI"
	RspGetHDInfo = "RspHDI"

	ReqDeleteSlice = "ReqDLS"
	RspDeleteSlice = "RspDLS"

	//  download
	ReqFileStorageInfo      = "ReqQDLF"
	RspFileStorageInfo      = "RspQDLF"
	ReqDownloadSlice        = "ReqDLFS"
	RspDownloadSlice        = "RspDLFS"
	ReqReportDownloadResult = "ReqDLRep" // request to download result report
	RspReportDownloadResult = "RspDLRep" // response to download result report
	ReqDownloadTaskInfo     = "ReqDLTI"
	RspDownloadTaskInfo     = "RspDLTI"
	ReqDownloadSliceWrong   = "ReqDSW"
	RspDownloadSliceWrong   = "RspDSW"
	ReqClearDownloadTask    = "ReqCDT"

	// register new pp
	ReqRegisterNewPP = "ReqRgNPP"
	RspRegisterNewPP = "RspRgNPP"

	// backup
	ReqFileSliceBackupNotice   = "ReqFBNot"
	ReqTransferDownload        = "ReqTdl"
	RspTransferDownload        = "RspTdl"
	RspTransferDownloadResult  = "RspTdlR"
	ReqReportBackupSliceResult = "ReqRBSR"
	RspReportBackupSliceResult = "RspRBSR"

	//TODO change to report to SP
	ReqReportTaskBP = "ReqRTBP" // report to BP

	ReqShareLink    = "ReqSL"
	RspShareLink    = "RspSL"
	ReqShareFile    = "ReqSF"
	RspShareFile    = "RspSF"
	ReqDeleteShare  = "ReqDSF"
	RspDeleteShare  = "RspDSF"
	ReqGetShareFile = "ReqGSF"
	RspGetShareFile = "RspGSF"

	// heartbeat
	ReqHeart = "ReqHeart"
	RspHeart = "RspHeart"
	// test sp latency
	ReqSpLatencyCheck = "ReqSpLatencyCheck"

	// report node status
	ReqReportNodeStatus = "ReqRNS"
	RspReportNodeStatus = "RspRNS"

	ReqTransferBLSSignature = "ReqTrBLS"
	RspTransferBLSSignature = "RspTrBLS"
)

cmd, 8 bytes string, exceeded will be truncate

Functions

func GetMessageHeader

func GetMessageHeader(tag int16, varsion uint16, length uint32, cmd string, data []byte)

GetMessageHeader

func NewDecodeHeader

func NewDecodeHeader(packet []byte, msgH *MessageHead)

NewDecodeHeader

Types

type MessageHead

type MessageHead struct {
	Tag     int16
	Len     uint32
	Cmd     []byte //8 byte
	Version uint16
}

MessageHead

func DecodeHeader

func DecodeHeader(packet []byte) MessageHead

DecodeHeader

func MakeMessageHeader

func MakeMessageHeader(tag int16, varsion uint16, length uint32, cmd string) MessageHead

MakeMessageHeader