header

package

v0.11.7 Latest Latest Go to latest Published: Nov 22, 2023 License: Apache-2.0 Imports: 1 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/stratosnet/sds

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func GetReqIdFromRspId(reqId uint8) uint8
type MessageHead
- func CopyMessageHeader(mh MessageHead) MessageHead
- func MakeMessageHeader(tag int16, version uint16, length uint32, cmd MsgType) MessageHead
- func (h *MessageHead) Decode(packet []byte)
- func (h *MessageHead) Encode(data []byte) int
type MsgType
- func GetMsgTypeFromId(id uint8) *MsgType

Constants ¶

View Source

const (
	MsgHeaderLen   = 21 // in bytes
	CommandTypeLen = 1
)

View Source

const (
	MSG_ID_INVALID uint8 = iota

	MSG_ID_REQ_GET_PPLIST
	MSG_ID_RSP_GET_PPLIST
	MSG_ID_REQ_GET_SPLIST
	MSG_ID_RSP_GET_SPLIST
	MSG_ID_REQ_GET_PPSTATUS
	MSG_ID_RSP_GET_PPSTATUS
	MSG_ID_REQ_GET_PPDOWNGRADEINFO
	MSG_ID_RSP_GET_PPDOWNGRADEINFO
	MSG_ID_REQ_GET_WALLETOZ
	MSG_ID_RSP_GET_WALLETOZ
	MSG_ID_REQ_REGISTER
	MSG_ID_RSP_REGISTER
	MSG_ID_REQ_ACTIVATE_PP
	MSG_ID_RSP_ACTIVATE_PP

	MSG_ID_NOTICE_ACTIVATED_SP

	MSG_ID_REQ_UPDATE_STAKE_PP
	MSG_ID_RSP_UPDATE_STAKE_PP
	MSG_ID_NOTICE_STATE_CHANGE_PP
	MSG_ID_REQ_STATE_CHANGE_PP
	MSG_ID_RSP_STATE_CHANGE_PP

	MSG_ID_REQ_UPDATED_STAKE_SP

	MSG_ID_REQ_DEACTIVATE_PP
	MSG_ID_RSP_DEACTIVATE_PP
	MSG_ID_NOTICE_UNBONDING_PP
	MSG_ID_NOTICE_ACTIVATE_PP

	MSG_ID_RSP_PPREGISTERED_TO_SP

	MSG_ID_REQ_PREPAY
	MSG_ID_RSP_PREPAY
	MSG_ID_REQ_PREPAID
	MSG_ID_RSP_PREPAID
	MSG_ID_REQ_MINING
	MSG_ID_RSP_MINING
	MSG_ID_REQ_START_MAINTENANCE
	MSG_ID_RSP_START_MAINTENANCE
	MSG_ID_REQ_STOP_MAINTENANCE
	MSG_ID_RSP_STOP_MAINTENANCE
	MSG_ID_REQ_UPLOAD_FILE
	MSG_ID_RSP_UPLOAD_FILE
	MSG_ID_REQ_UPLOAD_FILESLICE
	MSG_ID_RSP_UPLOAD_FILESLICE
	MSG_ID_REQ_BACKUP_FILESLICE
	MSG_ID_RSP_BACKUP_FILESLICE
	MSG_ID_REQ_UPLOAD_SLICES_WRONG
	MSG_ID_RSP_UPLOAD_SLICES_WRONG
	MSG_ID_REQ_REPORT_UPLOAD_SLICE_RESULT
	MSG_ID_RSP_REPORT_UPLOAD_SLICE_RESULT

	MSG_ID_UPLOAD_SPEED_OF_PROGRESS

	MSG_ID_REQ_FIND_MY_FILELIST
	MSG_ID_RSP_FIND_MY_FILELIST
	MSG_ID_REQ_DELETE_FILE
	MSG_ID_RSP_DELETE_FILE
	MSG_ID_REQ_GET_HDINFO
	MSG_ID_RSP_GET_HDINFO
	MSG_ID_REQ_FILE_STORAGEINFO
	MSG_ID_RSP_FILE_STORAGEINFO
	MSG_ID_REQ_DOWNLOAD_SLICE
	MSG_ID_RSP_DOWNLOAD_SLICE
	MSG_ID_REQ_REPORT_DOWNLOAD_RESULT
	MSG_ID_RSP_REPORT_DOWNLOAD_RESULT
	MSG_ID_REQ_DOWNLOAD_TASKINFO
	MSG_ID_RSP_DOWNLOAD_TASKINFO
	MSG_ID_REQ_DOWNLOAD_FILE_WRONG
	MSG_ID_RSP_DOWNLOAD_FILE_WRONG

	MSG_ID_REQ_CLEAR_DOWNLOAD_TASK

	MSG_ID_REQ_REGISTER_NEWPP
	MSG_ID_RSP_REGISTER_NEWPP

	MSG_ID_NOTICE_FILESLICE_BACKUP

	MSG_ID_REQ_TRANSFER_DOWNLOAD
	MSG_ID_RSP_TRANSFER_DOWNLOAD
	MSG_ID_REQ_TRANSFER_DOWNLOAD_WRONG
	MSG_ID_RSP_TRANSFER_DOWNLOAD_WRONG

	MSG_ID_RSP_TRANSFER_DOWNLOAD_RESULT

	MSG_ID_REQ_REPORT_BACKUP_SLICE_RESULT
	MSG_ID_RSP_REPORT_BACKUP_SLICE_RESULT
	MSG_ID_REQ_FILE_BACKUP_STATUS
	MSG_ID_RSP_FILE_BACKUP_STATUS
	MSG_ID_REQ_FILE_REPLICA_INFO
	MSG_ID_RSP_FILE_REPLICA_INFO
	MSG_ID_REQ_FILE_STATUS
	MSG_ID_RSP_FILE_STATUS
	MSG_ID_REQ_SHARELINK
	MSG_ID_RSP_SHARELINK
	MSG_ID_REQ_SHARE_FILE
	MSG_ID_RSP_SHARE_FILE
	MSG_ID_REQ_DELETE_SHARE
	MSG_ID_RSP_DELETE_SHARE
	MSG_ID_REQ_GET_SHAREFILE
	MSG_ID_RSP_GET_SHAREFILE
	MSG_ID_REQ_SP_LATENCY_CHECK
	MSG_ID_RSP_SP_LATENCY_CHECK
	MSG_ID_REQ_PP_LATENCY_CHECK
	MSG_ID_RSP_PP_LATENCY_CHECK

	MSG_ID_REQ_SPLATENCY_CHECK

	MSG_ID_REQ_REPORT_NODESTATUS
	MSG_ID_RSP_REPORT_NODESTATUS
	MSG_ID_REQ_SP_STATUS
	MSG_ID_RSP_SP_STATUS
	MSG_ID_REQ_TRANSFER_BLS_SIGNATURE
	MSG_ID_RSP_TRANSFER_BLS_SIGNATURE

	MSG_ID_RSP_BADVERSION
	MSG_ID_NOTICE_SP_UNDERMAINTENANCE
	MSG_ID_REQ_CLEAR_EXPIRED_SHARE_LINKS
	MSG_ID_RSP_CLEAR_EXPIRED_SHARE_LINKS
	NUMBER_MESSAGE_TYPES
)

Variables ¶

This section is empty.

Functions ¶

func GetReqIdFromRspId ¶ added in v0.10.0

func GetReqIdFromRspId(reqId uint8) uint8

Types ¶

type MessageHead ¶

type MessageHead struct {
	Tag     int16
	Len     uint32
	DataLen uint32
	Cmd     uint8
	ReqId   int64 //8 byte
	Version uint16
}

MessageHead every field in this struct shall be fixed length. Please change MsgHeaderLen when modifying this struct.

func CopyMessageHeader ¶ added in v0.10.0

func CopyMessageHeader(mh MessageHead) MessageHead

func MakeMessageHeader ¶

func MakeMessageHeader(tag int16, version uint16, length uint32, cmd MsgType) MessageHead

func (*MessageHead) Decode ¶ added in v0.10.0

func (h *MessageHead) Decode(packet []byte)

func (*MessageHead) Encode ¶ added in v0.10.0

func (h *MessageHead) Encode(data []byte) int

type MsgType ¶ added in v0.10.0

type MsgType struct {
	Id   uint8
	Name string
}

var (
	ReqGetPPList          MsgType
	RspGetPPList          MsgType
	ReqGetSPList          MsgType
	RspGetSPList          MsgType
	ReqGetPPStatus        MsgType
	RspGetPPStatus        MsgType
	ReqGetPPDowngradeInfo MsgType
	RspGetPPDowngradeInfo MsgType
	ReqGetWalletOz        MsgType
	RspGetWalletOz        MsgType
	ReqRegister           MsgType
	RspRegister           MsgType
	ReqActivatePP         MsgType
	RspActivatePP         MsgType

	NoticeActivatedPP MsgType

	ReqUpdateDepositPP MsgType
	RspUpdateDepositPP MsgType

	NoticeUpdatedDepositPP MsgType

	ReqStateChangePP MsgType
	RspStateChangePP MsgType

	ReqUpdatedStakeSP MsgType

	ReqDeactivatePP MsgType
	RspDeactivatePP MsgType

	NoticeUnbondingPP   MsgType
	NoticeDeactivatedPP MsgType

	RspPPRegisteredToSP MsgType

	ReqPrepay  MsgType
	RspPrepay  MsgType
	ReqPrepaid MsgType
	RspPrepaid MsgType
	ReqMining  MsgType
	RspMining  MsgType

	ReqStartMaintenance MsgType
	RspStartMaintenance MsgType
	ReqStopMaintenance  MsgType
	RspStopMaintenance  MsgType

	// upload
	ReqUploadFile              MsgType
	RspUploadFile              MsgType
	ReqUploadFileSlice         MsgType
	RspUploadFileSlice         MsgType
	ReqBackupFileSlice         MsgType
	RspBackupFileSlice         MsgType
	ReqUploadSlicesWrong       MsgType
	RspUploadSlicesWrong       MsgType
	ReqReportUploadSliceResult MsgType
	RspReportUploadSliceResult MsgType

	UploadSpeedOfProgress MsgType

	ReqFindMyFileList MsgType
	RspFindMyFileList MsgType
	ReqDeleteFile     MsgType
	RspDeleteFile     MsgType
	ReqGetHDInfo      MsgType
	RspGetHDInfo      MsgType

	//  download
	ReqFileStorageInfo      MsgType
	RspFileStorageInfo      MsgType
	ReqDownloadSlice        MsgType
	RspDownloadSlice        MsgType
	ReqReportDownloadResult MsgType
	RspReportDownloadResult MsgType
	ReqDownloadTaskInfo     MsgType
	RspDownloadTaskInfo     MsgType
	ReqDownloadFileWrong    MsgType
	RspDownloadFileWrong    MsgType

	ReqClearDownloadTask MsgType

	// register new pp
	ReqRegisterNewPP MsgType
	RspRegisterNewPP MsgType

	// backup and transfer
	NoticeFileSliceBackup MsgType

	ReqTransferDownload      MsgType
	RspTransferDownload      MsgType
	ReqTransferDownloadWrong MsgType
	RspTransferDownloadWrong MsgType

	RspTransferDownloadResult MsgType

	ReqReportBackupSliceResult MsgType
	RspReportBackupSliceResult MsgType
	ReqFileBackupStatus        MsgType
	RspFileBackupStatus        MsgType
	ReqFileReplicaInfo         MsgType
	RspFileReplicaInfo         MsgType
	ReqFileStatus              MsgType
	RspFileStatus              MsgType
	ReqShareLink               MsgType
	RspShareLink               MsgType
	ReqShareFile               MsgType
	RspShareFile               MsgType
	ReqDeleteShare             MsgType
	RspDeleteShare             MsgType
	ReqGetShareFile            MsgType
	RspGetShareFile            MsgType
	ReqSpLatencyCheck          MsgType
	RspSpLatencyCheck          MsgType
	ReqPpLatencyCheck          MsgType
	RspPpLatencyCheck          MsgType

	// report node status
	ReqReportNodeStatus MsgType
	RspReportNodeStatus MsgType
	// Check status of SP node
	ReqSpStatus             MsgType
	RspSpStatus             MsgType
	ReqTransferBLSSignature MsgType
	RspTransferBLSSignature MsgType

	RspBadVersion            MsgType
	NoticeSpUnderMaintenance MsgType

	ReqClearExpiredShareLinks MsgType
	RspClearExpiredShareLinks MsgType
)

func GetMsgTypeFromId ¶ added in v0.10.0

func GetMsgTypeFromId(id uint8) *MsgType

Source Files ¶

View all Source files

header.go

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