core

package
v0.1.3 Latest Latest
Warning

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

 Go to latest Published: Jul 10, 2023 License: Apache-2.0 Imports: 44 Imported by: 4

Documentation

Index

Constants

View Source 
const (
	SIZE_1KiB = 1024
	SIZE_1MiB = 1024 * SIZE_1KiB
	SIZE_1GiB = 1024 * SIZE_1MiB
)

byte size

View Source 
const (
	FileType_ServiceFile uint32 = iota
	FileType_IdleFile
	FileType_TagFile
	FileType_MusFile
	FileType_UsFile
	FileType_NamesFile
)
View Source 
const (
	//
	FileDataDirectionry   = "file"
	TmpDataDirectionry    = "tmp"
	IdleDataDirectionry   = "space"
	IdleTagDirectionry    = "itag"
	ServiceTagDirectionry = "stag"
	ProofDirectionry      = "proof"
	//
	IdleProofFile    = "iproof"
	ServiceProofFile = "sproof"
)
View Source 
const (
	ERR_RespTimeOut     = "peer response timeout"
	ERR_RespFailure     = "peer response failure"
	ERR_RespInvalidData = "peer response invalid data"
)
View Source 
const AggrProof_PROTOCOL = "/apv/1"
View Source 
const AllIpAddress = "0.0.0.0"
View Source 
const BufferSize = 64 * SIZE_1KiB
View Source 
const CustomDataTag_Protocol = "/cdtg/1"
View Source 
const DataShards = 2
View Source 
const DirMode = 0644
View Source 
const FILE_PROTOCOL = "/kft/1"
View Source 
const FileProtocolBufSize = 2 * 1024 * 1024
View Source 
const FileProtocolMsgBuf = 16 * 1024 * 1024
View Source 
const FragmentSize = 8 * SIZE_1MiB
View Source 
const IdleDataTag_Protocol = "/idtg/1"
View Source 
const IdleProtocolMsgBuf = 1024
View Source 
const LocalAddress = "127.0.0.1"
View Source 
const MaxCustomDataLength = 255
View Source 
const MaxFileNameLength = 255
View Source 
const MusProtocolMsgBuf = 32
View Source 
const P2PReadReqRespTime = time.Duration(time.Second * 30)
View Source 
const P2PResponseFailed uint32 = 400
View Source 
const P2PResponseFinish uint32 = 210
View Source 
const P2PResponseOK uint32 = 200
View Source 
const P2PWriteReqRespTime = time.Duration(time.Second * 30)
View Source 
const ParShards = 1
View Source 
const PushTag_Protocol = "/tagpush/1"
View Source 
const SegmentSize = 16 * SIZE_1MiB
View Source 
const TagProtocolMsgBuf = 1024 * 1024

Variables

View Source 
var (
	FileNameLengthErr   = fmt.Errorf("filename length exceeds %d", MaxFileNameLength)
	FileNameEmptyErr    = fmt.Errorf("filename is empty")
	CustomDataLengthErr = fmt.Errorf("custom data length exceeds %d", MaxCustomDataLength)
)

Functions

func CalcFileSHA256 added in v0.0.24 

func CalcFileSHA256(f *os.File) (string, error)

CalcFileSHA256 is used to calculate the sha256 value of the file type.

func CalcPathSHA256 added in v0.0.24 

func CalcPathSHA256(fpath string) (string, error)

CalcPathSHA256 is used to calculate the sha256 value of a file with a given path.

func CalcSHA256 added in v0.0.24 

func CalcSHA256(data []byte) (string, error)

CalcSHA256 is used to calculate the sha256 value of the data.

func GetExternalIp added in v0.0.2 

func GetExternalIp() (string, error)

Get external ip address

func GetLocalIp added in v0.0.29 

func GetLocalIp() ([]string, error)

Get local ip address

func IsIPv4 added in v0.1.0 

func IsIPv4(ipAddr string) bool

IsIPv4 is used to determine whether ipAddr is an ipv4 address

func IsIPv6 added in v0.1.0 

func IsIPv6(ipAddr string) bool

IsIPv6 is used to determine whether ipAddr is an ipv6 address

func NewProtocol added in v0.0.24 

func NewProtocol() *protocols

func ParseMultiaddrs added in v0.0.37 

func ParseMultiaddrs(domain string) ([]string, error)

ParseMultiaddrs

Types

type AggrProofProtocol added in v0.0.24 

type AggrProofProtocol struct {
	*Node
}

func (AggrProofProtocol) AggrProofReq added in v0.0.24 

func (e AggrProofProtocol) AggrProofReq(peerId peer.ID, ihash, shash []byte, qslice []*pb.Qslice, puk, sign []byte) (uint32, error)

func (AggrProofProtocol) FileReq added in v0.0.24 

func (e AggrProofProtocol) FileReq(peerId peer.ID, filehash string, filetype pb.FileType, fpath string) (uint32, error)

func (AggrProofProtocol) IdleReq added in v0.0.24 

func (e AggrProofProtocol) IdleReq(peerId peer.ID, filesize, blocknum uint64, pubkey, sign []byte) (uint32, error)

func (AggrProofProtocol) ReadFileAction added in v0.0.24 

func (e AggrProofProtocol) ReadFileAction(id peer.ID, roothash, datahash, path string, size int64) error

func (AggrProofProtocol) SetProtocolPrefix added in v0.0.37 

func (p AggrProofProtocol) SetProtocolPrefix(protocolPrefix string)

func (AggrProofProtocol) TagPushReq added in v0.0.24 

func (e AggrProofProtocol) TagPushReq(peerid peer.ID) (uint32, error)

remote peer requests handler

func (AggrProofProtocol) TagReq added in v0.0.24 

func (e AggrProofProtocol) TagReq(peerId peer.ID, filename, customdata string, blocknum uint64) (uint32, error)

func (AggrProofProtocol) WriteFileAction added in v0.0.24 

func (e AggrProofProtocol) WriteFileAction(id peer.ID, roothash, path string) error

type CustomDataTagProtocol added in v0.0.24 

type CustomDataTagProtocol struct {
	*Node
}

func (CustomDataTagProtocol) AggrProofReq added in v0.0.25 

func (e CustomDataTagProtocol) AggrProofReq(peerId peer.ID, ihash, shash []byte, qslice []*pb.Qslice, puk, sign []byte) (uint32, error)

func (CustomDataTagProtocol) FileReq added in v0.0.24 

func (e CustomDataTagProtocol) FileReq(peerId peer.ID, filehash string, filetype pb.FileType, fpath string) (uint32, error)

func (CustomDataTagProtocol) IdleReq added in v0.0.24 

func (e CustomDataTagProtocol) IdleReq(peerId peer.ID, filesize, blocknum uint64, pubkey, sign []byte) (uint32, error)

func (CustomDataTagProtocol) ReadFileAction added in v0.0.24 

func (e CustomDataTagProtocol) ReadFileAction(id peer.ID, roothash, datahash, path string, size int64) error

func (CustomDataTagProtocol) SetProtocolPrefix added in v0.0.37 

func (p CustomDataTagProtocol) SetProtocolPrefix(protocolPrefix string)

func (CustomDataTagProtocol) TagPushReq added in v0.0.24 

func (e CustomDataTagProtocol) TagPushReq(peerid peer.ID) (uint32, error)

remote peer requests handler

func (CustomDataTagProtocol) TagReq added in v0.0.24 

func (e CustomDataTagProtocol) TagReq(peerId peer.ID, filename, customdata string, blocknum uint64) (uint32, error)

func (CustomDataTagProtocol) WriteFileAction added in v0.0.24 

func (e CustomDataTagProtocol) WriteFileAction(id peer.ID, roothash, path string) error

type DataDirs added in v0.0.24 

type DataDirs struct {
	FileDir       string
	TmpDir        string
	IdleDataDir   string
	IdleTagDir    string
	ServiceTagDir string
	ProofDir      string
	IproofFile    string
	SproofFile    string
}

type DiscoveredPeer added in v0.0.24 

type DiscoveredPeer struct {
	PeerID peer.ID
	Addr   ma.Multiaddr
}

type FileProtocol added in v0.0.24 

type FileProtocol struct {
	*Node
}

func (FileProtocol) AggrProofReq added in v0.0.25 

func (e FileProtocol) AggrProofReq(peerId peer.ID, ihash, shash []byte, qslice []*pb.Qslice, puk, sign []byte) (uint32, error)

func (FileProtocol) FileReq added in v0.0.24 

func (e FileProtocol) FileReq(peerId peer.ID, filehash string, filetype pb.FileType, fpath string) (uint32, error)

func (FileProtocol) IdleReq added in v0.0.24 

func (e FileProtocol) IdleReq(peerId peer.ID, filesize, blocknum uint64, pubkey, sign []byte) (uint32, error)

func (FileProtocol) ReadFileAction added in v0.0.24 

func (e FileProtocol) ReadFileAction(id peer.ID, roothash, datahash, path string, size int64) error

func (FileProtocol) SetProtocolPrefix added in v0.0.37 

func (p FileProtocol) SetProtocolPrefix(protocolPrefix string)

func (FileProtocol) TagPushReq added in v0.0.24 

func (e FileProtocol) TagPushReq(peerid peer.ID) (uint32, error)

remote peer requests handler

func (FileProtocol) TagReq added in v0.0.24 

func (e FileProtocol) TagReq(peerId peer.ID, filename, customdata string, blocknum uint64) (uint32, error)

func (FileProtocol) WriteFileAction added in v0.0.24 

func (e FileProtocol) WriteFileAction(id peer.ID, roothash, path string) error

type IdleDataTagProtocol added in v0.0.24 

type IdleDataTagProtocol struct {
	*Node
}

func (IdleDataTagProtocol) AggrProofReq added in v0.0.25 

func (e IdleDataTagProtocol) AggrProofReq(peerId peer.ID, ihash, shash []byte, qslice []*pb.Qslice, puk, sign []byte) (uint32, error)

func (IdleDataTagProtocol) FileReq added in v0.0.24 

func (e IdleDataTagProtocol) FileReq(peerId peer.ID, filehash string, filetype pb.FileType, fpath string) (uint32, error)

func (IdleDataTagProtocol) IdleReq added in v0.0.24 

func (e IdleDataTagProtocol) IdleReq(peerId peer.ID, filesize, blocknum uint64, pubkey, sign []byte) (uint32, error)

func (IdleDataTagProtocol) ReadFileAction added in v0.0.24 

func (e IdleDataTagProtocol) ReadFileAction(id peer.ID, roothash, datahash, path string, size int64) error

func (IdleDataTagProtocol) SetProtocolPrefix added in v0.0.37 

func (p IdleDataTagProtocol) SetProtocolPrefix(protocolPrefix string)

func (IdleDataTagProtocol) TagPushReq added in v0.0.24 

func (e IdleDataTagProtocol) TagPushReq(peerid peer.ID) (uint32, error)

remote peer requests handler

func (IdleDataTagProtocol) TagReq added in v0.0.24 

func (e IdleDataTagProtocol) TagReq(peerId peer.ID, filename, customdata string, blocknum uint64) (uint32, error)

func (IdleDataTagProtocol) WriteFileAction added in v0.0.24 

func (e IdleDataTagProtocol) WriteFileAction(id peer.ID, roothash, path string) error

type Node 

type Node struct {
	*dht.IpfsDHT
	*drouting.RoutingDiscovery
	// contains filtered or unexported fields
}

Node type - Implementation of a P2P Host

func (*Node) AddMultiaddrToPeerstore added in v0.0.32 

func (n *Node) AddMultiaddrToPeerstore(multiaddr string, t time.Duration) (peer.ID, error)

func (*Node) Addrs 

func (n *Node) Addrs() []ma.Multiaddr

Returns the listen addresses of the Host

func (Node) AggrProofReq added in v0.0.25 

func (e Node) AggrProofReq(peerId peer.ID, ihash, shash []byte, qslice []*pb.Qslice, puk, sign []byte) (uint32, error)

func (*Node) Close 

func (n *Node) Close() error

Close shuts down the host, its Network, and services.

func (*Node) ConnManager 

func (n *Node) ConnManager() connmgr.ConnManager

ConnManager returns this hosts connection manager

func (*Node) Connect 

func (n *Node) Connect(ctx context.Context, pi peer.AddrInfo) error

Connect ensures there is a connection between this host and the peer with given peer.ID. Connect will absorb the addresses in pi into its internal peerstore. If there is not an active connection, Connect will issue a h.Network.Dial, and block until a connection is open, or an error is returned. // TODO: Relay + NAT.

func (*Node) DHTFindPeer added in v0.1.0 

func (n *Node) DHTFindPeer(peerid string) (peer.AddrInfo, error)

DHTFindPeer searches for a peer with given ID.

func (*Node) EventBus 

func (n *Node) EventBus() event.Bus

EventBus returns the hosts eventbus

func (Node) FileReq added in v0.0.24 

func (e Node) FileReq(peerId peer.ID, filehash string, filetype pb.FileType, fpath string) (uint32, error)

func (*Node) GetBootstraps added in v0.0.24 

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

func (*Node) GetCtxCancelFromRoot added in v0.1.1 

func (n *Node) GetCtxCancelFromRoot() context.Context

func (*Node) GetCtxQueryFromCtxCancel added in v0.1.1 

func (n *Node) GetCtxQueryFromCtxCancel() context.Context

func (*Node) GetCtxRoot added in v0.1.1 

func (n *Node) GetCtxRoot() context.Context

func (*Node) GetDhtProtocolVersion added in v0.0.24 

func (n *Node) GetDhtProtocolVersion() string

func (*Node) GetDirs added in v0.0.24 

func (n *Node) GetDirs() DataDirs

func (*Node) GetDiscoveredPeers added in v0.1.1 

func (n *Node) GetDiscoveredPeers() <-chan *routing.QueryEvent

GetDiscoveredPeers

func (*Node) GetIdleDataCh added in v0.0.24 

func (n *Node) GetIdleDataCh() <-chan string

func (*Node) GetIdleFileTee added in v0.0.15 

func (n *Node) GetIdleFileTee() string

func (*Node) GetIdleTagCh added in v0.0.24 

func (n *Node) GetIdleTagCh() <-chan string

func (*Node) GetPeerPublickey added in v0.0.25 

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

func (*Node) GetProtocolPrefix added in v0.0.37 

func (n *Node) GetProtocolPrefix() string

func (*Node) GetProtocolVersion added in v0.0.24 

func (n *Node) GetProtocolVersion() string

func (*Node) GetRendezvousVersion added in v0.1.0 

func (n *Node) GetRendezvousVersion() string

func (*Node) GetServiceFileTee added in v0.0.15 

func (n *Node) GetServiceFileTee() string

func (*Node) GetServiceTagCh added in v0.0.24 

func (n *Node) GetServiceTagCh() <-chan string

func (*Node) ID 

func (n *Node) ID() peer.ID

ID returns the (local) peer.ID associated with this Host

func (Node) IdleReq added in v0.0.24 

func (e Node) IdleReq(peerId peer.ID, filesize, blocknum uint64, pubkey, sign []byte) (uint32, error)

func (*Node) Mux 

func (n *Node) Mux() protocol.Switch

Mux returns the Mux multiplexing incoming streams to protocol handlers

func (*Node) Network 

func (n *Node) Network() network.Network

Networks returns the Network interface of the Host

func (*Node) NewAggrProofProtocol added in v0.0.24 

func (n *Node) NewAggrProofProtocol() *AggrProofProtocol

func (*Node) NewCustomDataTagProtocol added in v0.0.24 

func (n *Node) NewCustomDataTagProtocol() *CustomDataTagProtocol

func (*Node) NewFileProtocol added in v0.0.24 

func (n *Node) NewFileProtocol() *FileProtocol

func (*Node) NewIdleDataTagProtocol added in v0.0.24 

func (n *Node) NewIdleDataTagProtocol() *IdleDataTagProtocol

func (*Node) NewMessageData 

func (n *Node) NewMessageData(messageId string, gossip bool) *pb.MessageData

helper method - generate message data shared between all node's p2p protocols messageId: unique for requests, copied from request for responses

func (*Node) NewPeerStream added in v0.0.9 

func (n *Node) NewPeerStream(id peer.ID, p protocol.ID) (network.Stream, error)

NewPeerStream

func (*Node) NewPushTagProtocol added in v0.0.24 

func (n *Node) NewPushTagProtocol() *PushTagProtocol

func (*Node) NewReadFileProtocol added in v0.0.24 

func (n *Node) NewReadFileProtocol() *ReadFileProtocol

func (*Node) NewStream 

func (n *Node) NewStream(ctx context.Context, p peer.ID, pids ...protocol.ID) (network.Stream, error)

NewStream opens a new stream to given peer p, and writes a p2p/protocol header with given ProtocolID. If there is no connection to p, attempts to create one. If ProtocolID is "", writes no header. (Threadsafe)

func (*Node) NewWriteFileProtocol added in v0.0.24 

func (n *Node) NewWriteFileProtocol() *WriteFileProtocol

func (*Node) Peerstore 

func (n *Node) Peerstore() peerstore.Peerstore

Peerstore returns the Host's repository of Peer Addresses and Keys.

func (*Node) PrivatekeyPath 

func (n *Node) PrivatekeyPath() string

func (Node) ReadFileAction added in v0.0.24 

func (e Node) ReadFileAction(id peer.ID, roothash, datahash, path string, size int64) error

func (*Node) RemoveStreamHandler 

func (n *Node) RemoveStreamHandler(pid protocol.ID)

RemoveStreamHandler removes a handler on the mux that was set by SetStreamHandler

func (*Node) RouteTableFindPeers added in v0.1.0 

func (n *Node) RouteTableFindPeers(limit int) (<-chan peer.AddrInfo, error)

RouteTableFindPeers

func (*Node) SendFile added in v0.0.9 

func (n *Node) SendFile(ctx context.Context, id peer.ID, path string) error

func (*Node) SendMsgToStream added in v0.0.9 

func (n *Node) SendMsgToStream(s network.Stream, msg []byte) error

SendMsgToStream

func (*Node) SendProtoMessage 

func (n *Node) SendProtoMessage(id peer.ID, p protocol.ID, data proto.Message) error

helper method - writes a protobuf go data object to a network stream data: reference of protobuf go data object to send (not the object itself) s: network stream to write the data to

func (*Node) SetBootstraps added in v0.0.24 

func (n *Node) SetBootstraps(bootstrap []string)

func (*Node) SetIdleFileTee added in v0.0.15 

func (n *Node) SetIdleFileTee(peerid string)

func (Node) SetProtocolPrefix added in v0.0.37 

func (p Node) SetProtocolPrefix(protocolPrefix string)

func (*Node) SetServiceFileTee added in v0.0.15 

func (n *Node) SetServiceFileTee(peerid string)

func (*Node) SetStreamHandler 

func (n *Node) SetStreamHandler(pid protocol.ID, handler network.StreamHandler)

SetStreamHandler sets the protocol handler on the Host's Mux. This is equivalent to: host.Mux().SetHandler(proto, handler) (Threadsafe)

func (*Node) SetStreamHandlerMatch 

func (n *Node) SetStreamHandlerMatch(pid protocol.ID, m func(protocol.ID) bool, handler network.StreamHandler)

SetStreamHandlerMatch sets the protocol handler on the Host's Mux using a matching function for protocol selection.

func (*Node) StarFileTransferProtocol added in v0.0.9 

func (n *Node) StarFileTransferProtocol()

func (Node) TagPushReq added in v0.0.24 

func (e Node) TagPushReq(peerid peer.ID) (uint32, error)

remote peer requests handler

func (Node) TagReq added in v0.0.24 

func (e Node) TagReq(peerId peer.ID, filename, customdata string, blocknum uint64) (uint32, error)

func (*Node) Workspace 

func (n *Node) Workspace() string

func (Node) WriteFileAction added in v0.0.24 

func (e Node) WriteFileAction(id peer.ID, roothash, path string) error

type P2P 

type P2P interface {
	// Lib-p2p host
	host.Host

	// Message protocol
	Protocol

	// GetCtxRoot returns the root context of the host
	GetCtxRoot() context.Context

	// GetCtxCancelFromRoot returns the cancel context from root context
	GetCtxCancelFromRoot() context.Context

	// GetCtxQueryFromCtxCancel returns tne query context from cancel context
	GetCtxQueryFromCtxCancel() context.Context

	// PrivatekeyPath returns the key file location
	PrivatekeyPath() string

	// Workspace returns to the working directory
	Workspace() string

	// AddMultiaddrToPeerstore adds multiaddr to the host's peerstore
	AddMultiaddrToPeerstore(multiaddr string, t time.Duration) (peer.ID, error)

	// GetPeerPublickey returns the host's public key
	GetPeerPublickey() []byte

	// GetProtocolVersion returns the ProtocolVersion of the host
	GetProtocolVersion() string

	// GetDhtProtocolVersion returns the host's DHT ProtocolVersion
	GetDhtProtocolVersion() string

	// GetRendezvousVersion returns the rendezvous protocol
	GetRendezvousVersion() string

	// GetProtocolPrefix returns protocols prefix
	GetProtocolPrefix() string

	// GetDirs returns the data directory structure of the host
	GetDirs() DataDirs

	// GetBootstraps returns a list of host bootstraps
	GetBootstraps() []string

	// SetBootstraps updates the host's bootstrap list
	SetBootstraps(bootstrap []string)

	// FindPeer searches for a peer with given ID.
	DHTFindPeer(peerid string) (peer.AddrInfo, error)

	// Close p2p
	Close() error

	//
	GetDiscoveredPeers() <-chan *routing.QueryEvent

	// RouteTableFindPeers
	RouteTableFindPeers(limit int) (<-chan peer.AddrInfo, error)

	// GetIdleDataCh returns the idle data channel received by the host
	GetIdleDataCh() <-chan string

	// GetIdleTagCh returns the tag channel of the idle data received by the host
	GetIdleTagCh() <-chan string

	// GetServiceTagCh returns the tag channel of the service data received by the host
	GetServiceTagCh() <-chan string
}

P2P is an object participating in a p2p network, which implements protocols or provides services. It handles requests like a Server, and issues requests like a Client. It is called Host because it is both Server and Client (and Peer may be confusing). It references libp2p: https://github.com/libp2p/go-libp2p

func NewBasicNode 

func NewBasicNode(
	ctx context.Context,
	port int,
	workspace string,
	privatekeypath string,
	bootstrap []string,
	cmgr connmgr.ConnManager,
	protocolPrefix string,
	publicip string,
) (P2P, error)

NewBasicNode constructs a new *Node 

  multiaddr: listen addresses of p2p host
  workspace: service working directory
  privatekeypath: private key file
	  If it's empty, automatically created in the program working directory
	  If it's a directory, it will be created in the specified directory

type ProofFileType added in v0.0.24 

type ProofFileType struct {
	Names []string `json:"names"`
	Us    []string `json:"us"`
	Mus   []string `json:"mus"`
	Sigma string   `json:"sigma"`
}

type Protocol added in v0.0.24 

type Protocol interface {
	WriteFileAction(id peer.ID, roothash, path string) error
	ReadFileAction(id peer.ID, roothash, datahash, path string, size int64) error
	TagPushReq(peerid peer.ID) (uint32, error)
	IdleReq(peerId peer.ID, filesize, blocknum uint64, pubkey, sign []byte) (uint32, error)
	TagReq(peerId peer.ID, filename, customdata string, blocknum uint64) (uint32, error)
	FileReq(peerId peer.ID, filehash string, filetype pb.FileType, fpath string) (uint32, error)
	AggrProofReq(peerId peer.ID, ihash, shash []byte, qslice []*pb.Qslice, puk, sign []byte) (uint32, error)
}

type PushTagProtocol added in v0.0.24 

type PushTagProtocol struct {
	*Node
}

func (PushTagProtocol) AggrProofReq added in v0.0.25 

func (e PushTagProtocol) AggrProofReq(peerId peer.ID, ihash, shash []byte, qslice []*pb.Qslice, puk, sign []byte) (uint32, error)

func (PushTagProtocol) FileReq added in v0.0.24 

func (e PushTagProtocol) FileReq(peerId peer.ID, filehash string, filetype pb.FileType, fpath string) (uint32, error)

func (PushTagProtocol) IdleReq added in v0.0.24 

func (e PushTagProtocol) IdleReq(peerId peer.ID, filesize, blocknum uint64, pubkey, sign []byte) (uint32, error)

func (PushTagProtocol) ReadFileAction added in v0.0.24 

func (e PushTagProtocol) ReadFileAction(id peer.ID, roothash, datahash, path string, size int64) error

func (PushTagProtocol) SetProtocolPrefix added in v0.0.37 

func (p PushTagProtocol) SetProtocolPrefix(protocolPrefix string)

func (PushTagProtocol) TagPushReq added in v0.0.24 

func (e PushTagProtocol) TagPushReq(peerid peer.ID) (uint32, error)

remote peer requests handler

func (PushTagProtocol) TagReq added in v0.0.24 

func (e PushTagProtocol) TagReq(peerId peer.ID, filename, customdata string, blocknum uint64) (uint32, error)

func (PushTagProtocol) WriteFileAction added in v0.0.24 

func (e PushTagProtocol) WriteFileAction(id peer.ID, roothash, path string) error

type ReadFileProtocol added in v0.0.24 

type ReadFileProtocol struct {
	*Node // local host
	*sync.Mutex
	// contains filtered or unexported fields
}

func (ReadFileProtocol) AggrProofReq added in v0.0.25 

func (e ReadFileProtocol) AggrProofReq(peerId peer.ID, ihash, shash []byte, qslice []*pb.Qslice, puk, sign []byte) (uint32, error)

func (ReadFileProtocol) FileReq added in v0.0.24 

func (e ReadFileProtocol) FileReq(peerId peer.ID, filehash string, filetype pb.FileType, fpath string) (uint32, error)

func (ReadFileProtocol) IdleReq added in v0.0.24 

func (e ReadFileProtocol) IdleReq(peerId peer.ID, filesize, blocknum uint64, pubkey, sign []byte) (uint32, error)

func (ReadFileProtocol) ReadFileAction added in v0.0.24 

func (e ReadFileProtocol) ReadFileAction(id peer.ID, roothash, datahash, path string, size int64) error

func (ReadFileProtocol) SetProtocolPrefix added in v0.0.37 

func (p ReadFileProtocol) SetProtocolPrefix(protocolPrefix string)

func (ReadFileProtocol) TagPushReq added in v0.0.24 

func (e ReadFileProtocol) TagPushReq(peerid peer.ID) (uint32, error)

remote peer requests handler

func (ReadFileProtocol) TagReq added in v0.0.24 

func (e ReadFileProtocol) TagReq(peerId peer.ID, filename, customdata string, blocknum uint64) (uint32, error)

func (ReadFileProtocol) WriteFileAction added in v0.0.24 

func (e ReadFileProtocol) WriteFileAction(id peer.ID, roothash, path string) error

type WriteFileProtocol added in v0.0.24 

type WriteFileProtocol struct {
	*Node
	*sync.Mutex
	// contains filtered or unexported fields
}

func (WriteFileProtocol) AggrProofReq added in v0.0.25 

func (e WriteFileProtocol) AggrProofReq(peerId peer.ID, ihash, shash []byte, qslice []*pb.Qslice, puk, sign []byte) (uint32, error)

func (WriteFileProtocol) FileReq added in v0.0.24 

func (e WriteFileProtocol) FileReq(peerId peer.ID, filehash string, filetype pb.FileType, fpath string) (uint32, error)

func (WriteFileProtocol) IdleReq added in v0.0.24 

func (e WriteFileProtocol) IdleReq(peerId peer.ID, filesize, blocknum uint64, pubkey, sign []byte) (uint32, error)

func (WriteFileProtocol) ReadFileAction added in v0.0.24 

func (e WriteFileProtocol) ReadFileAction(id peer.ID, roothash, datahash, path string, size int64) error

func (WriteFileProtocol) SetProtocolPrefix added in v0.0.37 

func (p WriteFileProtocol) SetProtocolPrefix(protocolPrefix string)

func (WriteFileProtocol) TagPushReq added in v0.0.24 

func (e WriteFileProtocol) TagPushReq(peerid peer.ID) (uint32, error)

remote peer requests handler

func (WriteFileProtocol) TagReq added in v0.0.24 

func (e WriteFileProtocol) TagReq(peerId peer.ID, filename, customdata string, blocknum uint64) (uint32, error)

func (WriteFileProtocol) WriteFileAction added in v0.0.24 

func (e WriteFileProtocol) WriteFileAction(id peer.ID, roothash, path string) error

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.