core

Apr 24, 2024

Changes in this version

type OnlineProtocol

+ func (e OnlineProtocol) ReadFileActionWithExtension(id peer.ID, roothash, datahash, path string, size int64, extData []byte) error

type PeerNode

+ func (e PeerNode) ReadFileActionWithExtension(id peer.ID, roothash, datahash, path string, size int64, extData []byte) error

type ReadDataProtocol

+ func (e ReadDataProtocol) ReadFileActionWithExtension(id peer.ID, roothash, datahash, path string, size int64, extData []byte) error

type ReadDataStatProtocol

+ func (e ReadDataStatProtocol) ReadFileActionWithExtension(id peer.ID, roothash, datahash, path string, size int64, extData []byte) error

type ReadFileProtocol

+ func (e *ReadFileProtocol) DefaultReadFileServerHandle(req *pb.ReadfileRequest) (*pb.ReadfileResponse, error)

+ func (e *ReadFileProtocol) SetReadFileServiceHandle(handle ReadFileServerHandle)

+ func (e ReadFileProtocol) ReadFileActionWithExtension(id peer.ID, roothash, datahash, path string, size int64, extData []byte) error

+ type ReadFileServerHandle func(req *pb.ReadfileRequest) (*pb.ReadfileResponse, error)

type WriteFileProtocol

+ func (e WriteFileProtocol) ReadFileActionWithExtension(id peer.ID, roothash, datahash, path string, size int64, extData []byte) error

Apr 18, 2024

Changes in this version

+ const OnlineRequest

+ const OnlineResponse

+ type OnlineProtocol struct

+ func (e OnlineProtocol) OnlineAction(id peer.ID) error

+ func (e OnlineProtocol) ReadDataAction(id peer.ID, roothash, datahash, path string, size int64) error

+ func (e OnlineProtocol) ReadDataStatAction(id peer.ID, roothash string, datahash string) (uint64, error)

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

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

+ func (p OnlineProtocol) SetProtocolPrefix(protocolPrefix string)

type PeerNode

+ func (e PeerNode) OnlineAction(id peer.ID) error

+ func (n *PeerNode) GetProtocolPrefix() string

+ func (n *PeerNode) NewOnlineProtocol() *OnlineProtocol

type Protocol

+ OnlineAction func(id peer.ID) error

type ReadDataProtocol

+ func (e ReadDataProtocol) OnlineAction(id peer.ID) error

type ReadDataStatProtocol

+ func (e ReadDataStatProtocol) OnlineAction(id peer.ID) error

type ReadFileProtocol

+ func (e ReadFileProtocol) OnlineAction(id peer.ID) error

type WriteFileProtocol

+ func (e WriteFileProtocol) OnlineAction(id peer.ID) error

Apr 17, 2024

Changes in this version

type P2P

+ GetNetEnv func() string

type PeerNode

+ func (n *PeerNode) GetNetEnv() string

Apr 11, 2024

Changes in this version

type P2P

+ GetBootnode func() string

+ SetBootnode func(bootnode string)

type PeerNode

+ func (n *PeerNode) GetBootnode() string

+ func (n *PeerNode) SetBootnode(bootnode string)

Apr 11, 2024

Changes in this version

type P2P

+ GetRecvFlag func() bool

type PeerNode

+ func (n *PeerNode) GetRecvFlag() bool

Apr 9, 2024

Changes in this version

+ const ZeroFileHash_8M

Mar 27, 2024

Changes in this version

+ const DefaultProtocolOverridePrefix

+ const DefaultProtocolPrefix

+ const NetworkRoom

+ func NewDHT(ctx context.Context, h host.Host, bucketsize int, version string, ...) (*dht.IpfsDHT, error)

type P2P

+ GetDHTable func() *dht.IpfsDHT

+ GetHost func() host.Host

+ type PeerNode struct

+ func NewPeerNode(ctx context.Context, cfg *config.Config) (*PeerNode, error)

+ func (e PeerNode) ReadDataAction(id peer.ID, roothash, datahash, path string, size int64) error

+ func (e PeerNode) ReadDataStatAction(id peer.ID, roothash string, datahash string) (uint64, error)

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

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

+ func (n *PeerNode) Addrs() []ma.Multiaddr

+ func (n *PeerNode) Close() error

+ func (n *PeerNode) ConnManager() connmgr.ConnManager

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

+ func (n *PeerNode) DisableRecv()

+ func (n *PeerNode) EnableRecv()

+ func (n *PeerNode) EventBus() event.Bus

+ func (n *PeerNode) GetBootstraps() []string

+ func (n *PeerNode) GetDHTable() *dht.IpfsDHT

+ func (n *PeerNode) GetDhtProtocolVersion() string

+ func (n *PeerNode) GetDirs() DataDirs

+ func (n *PeerNode) GetHost() host.Host

+ func (n *PeerNode) GetIdentityPubkey(addr string, request *pb.Request, timeout time.Duration, ...) (*pb.IdentityPubkeyResponse, error)

+ func (n *PeerNode) GetIdleFileTee() string

+ func (n *PeerNode) GetMasterPubkey(addr string, request *pb.Request, timeout time.Duration, ...) (*pb.MasterPubkeyResponse, error)

+ func (n *PeerNode) GetPeerPublickey() []byte

+ func (n *PeerNode) GetPodr2Pubkey(addr string, request *pb.Request, timeout time.Duration, ...) (*pb.Podr2PubkeyResponse, error)

+ func (n *PeerNode) GetProtocolVersion() string

+ func (n *PeerNode) GetRendezvousVersion() string

+ func (n *PeerNode) GetServiceFileTee() string

+ func (n *PeerNode) ID() peer.ID

+ func (n *PeerNode) Mux() protocol.Switch

+ func (n *PeerNode) Network() network.Network

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

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

+ func (n *PeerNode) NewPodr2ApiClient(addr string, opts ...grpc.DialOption) (pb.Podr2ApiClient, error)

+ func (n *PeerNode) NewPodr2VerifierApiClient(addr string, opts ...grpc.DialOption) (pb.Podr2VerifierApiClient, error)

+ func (n *PeerNode) NewPoisCertifierApiClient(addr string, opts ...grpc.DialOption) (pb.PoisCertifierApiClient, error)

+ func (n *PeerNode) NewPoisVerifierApiClient(addr string, opts ...grpc.DialOption) (pb.PoisVerifierApiClient, error)

+ func (n *PeerNode) NewPubkeyApiClient(addr string, opts ...grpc.DialOption) (pb.CesealPubkeysProviderClient, error)

+ func (n *PeerNode) NewReadDataProtocol() *ReadDataProtocol

+ func (n *PeerNode) NewReadDataStatProtocol() *ReadDataStatProtocol

+ func (n *PeerNode) NewReadFileProtocol() *ReadFileProtocol

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

+ func (n *PeerNode) NewWriteFileProtocol() *WriteFileProtocol

+ func (n *PeerNode) Peerstore() peerstore.Peerstore

+ func (n *PeerNode) PrivatekeyPath() string

+ func (n *PeerNode) RemoveStreamHandler(pid protocol.ID)

+ func (n *PeerNode) RequestBatchVerify(addr string, requestBatchVerify *pb.RequestBatchVerify, timeout time.Duration, ...) (*pb.ResponseBatchVerify, error)

+ func (n *PeerNode) RequestEcho(addr string, echoMessage *pb.EchoMessage, timeout time.Duration, ...) (*pb.EchoMessage, error)

+ func (n *PeerNode) RequestGenTag(c pb.Podr2ApiClient) (pb.Podr2Api_RequestGenTagClient, error)

+ func (n *PeerNode) RequestMinerCommitGenChall(addr string, commitGenChall *pb.RequestMinerCommitGenChall, ...) (*pb.Challenge, error)

+ func (n *PeerNode) RequestMinerGetNewKey(addr string, accountKey []byte, timeout time.Duration, ...) (*pb.ResponseMinerInitParam, error)

+ func (n *PeerNode) RequestSpaceProofVerifySingleBlock(addr string, requestSpaceProofVerify *pb.RequestSpaceProofVerify, ...) (*pb.ResponseSpaceProofVerify, error)

+ func (n *PeerNode) RequestVerifyCommitProof(addr string, verifyCommitAndAccProof *pb.RequestVerifyCommitAndAccProof, ...) (*pb.ResponseVerifyCommitOrDeletionProof, error)

+ func (n *PeerNode) RequestVerifyDeletionProof(addr string, requestVerifyDeletionProof *pb.RequestVerifyDeletionProof, ...) (*pb.ResponseVerifyCommitOrDeletionProof, error)

+ func (n *PeerNode) RequestVerifySpaceTotal(addr string, requestSpaceProofVerifyTotal *pb.RequestSpaceProofVerifyTotal, ...) (*pb.ResponseSpaceProofVerifyTotal, error)

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

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

+ func (n *PeerNode) SetBootstraps(bootstrap []string)

+ func (n *PeerNode) SetIdleFileTee(peerid string)

+ func (n *PeerNode) SetServiceFileTee(peerid string)

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

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

+ func (n *PeerNode) Workspace() string

+ func (p PeerNode) SetProtocolPrefix(protocolPrefix string)

Feb 2, 2024

Changes in this version

type Node

+ func (n *Node) GetIdentityPubkey(addr string, request *pb.Request, timeout time.Duration, ...) (*pb.IdentityPubkeyResponse, error)

+ func (n *Node) GetMasterPubkey(addr string, request *pb.Request, timeout time.Duration, ...) (*pb.MasterPubkeyResponse, error)

+ func (n *Node) GetPodr2Pubkey(addr string, request *pb.Request, timeout time.Duration, ...) (*pb.Podr2PubkeyResponse, error)

+ func (n *Node) NewPubkeyApiClient(addr string, opts ...grpc.DialOption) (pb.CesealPubkeysProviderClient, error)

type P2P

+ GetIdentityPubkey func(addr string, request *pb.Request, timeout time.Duration, ...) (*pb.IdentityPubkeyResponse, error)

+ GetMasterPubkey func(addr string, request *pb.Request, timeout time.Duration, ...) (*pb.MasterPubkeyResponse, error)

+ GetPodr2Pubkey func(addr string, request *pb.Request, timeout time.Duration, ...) (*pb.Podr2PubkeyResponse, error)

+ NewPubkeyApiClient func(addr string, opts ...grpc.DialOption) (pb.CesealPubkeysProviderClient, error)

Jan 23, 2024

Changes in this version

type Node

+ func (n *Node) RequestEcho(addr string, echoMessage *pb.EchoMessage, timeout time.Duration, ...) (*pb.EchoMessage, error)

type P2P

+ RequestEcho func(addr string, echoMessage *pb.EchoMessage, timeout time.Duration, ...) (*pb.EchoMessage, error)

Jan 4, 2024

Changes in this version

type Node

+ func (n *Node) DisableRecv()

+ func (n *Node) EnableRecv()

type P2P

+ DisableRecv func()

+ EnableRecv func()

Dec 18, 2023

Changes in this version

type Node

+ func (n *Node) RequestVerifySpaceTotal(addr string, requestSpaceProofVerifyTotal *pb.RequestSpaceProofVerifyTotal, ...) (*pb.ResponseSpaceProofVerifyTotal, error)

type P2P

+ RequestVerifySpaceTotal func(addr string, requestSpaceProofVerifyTotal *pb.RequestSpaceProofVerifyTotal, ...) (*pb.ResponseSpaceProofVerifyTotal, error)

Dec 18, 2023

Changes in this version

type Node

+ func (n *Node) NewPodr2ApiClient(addr string, opts ...grpc.DialOption) (pb.Podr2ApiClient, error)

+ func (n *Node) NewPodr2VerifierApiClient(addr string, opts ...grpc.DialOption) (pb.Podr2VerifierApiClient, error)

+ func (n *Node) NewPoisCertifierApiClient(addr string, opts ...grpc.DialOption) (pb.PoisCertifierApiClient, error)

+ func (n *Node) NewPoisVerifierApiClient(addr string, opts ...grpc.DialOption) (pb.PoisVerifierApiClient, error)

+ func (n *Node) RequestBatchVerify(addr string, requestBatchVerify *pb.RequestBatchVerify, timeout time.Duration, ...) (*pb.ResponseBatchVerify, error)

+ func (n *Node) RequestGenTag(addr string, requestGenTag *pb.RequestGenTag, timeout time.Duration, ...) (*pb.ResponseGenTag, error)

+ func (n *Node) RequestMinerCommitGenChall(addr string, commitGenChall *pb.RequestMinerCommitGenChall, ...) (*pb.Challenge, error)

+ func (n *Node) RequestMinerGetNewKey(addr string, accountKey []byte, timeout time.Duration, ...) (*pb.ResponseMinerInitParam, error)

+ func (n *Node) RequestSpaceProofVerifySingleBlock(addr string, requestSpaceProofVerify *pb.RequestSpaceProofVerify, ...) (*pb.ResponseSpaceProofVerify, error)

+ func (n *Node) RequestVerifyCommitProof(addr string, verifyCommitAndAccProof *pb.RequestVerifyCommitAndAccProof, ...) (*pb.ResponseVerifyCommitOrDeletionProof, error)

+ func (n *Node) RequestVerifyDeletionProof(addr string, requestVerifyDeletionProof *pb.RequestVerifyDeletionProof, ...) (*pb.ResponseVerifyCommitOrDeletionProof, error)

type P2P

+ NewPodr2ApiClient func(addr string, opts ...grpc.DialOption) (pb.Podr2ApiClient, error)

+ NewPodr2VerifierApiClient func(addr string, opts ...grpc.DialOption) (pb.Podr2VerifierApiClient, error)

+ NewPoisCertifierApiClient func(addr string, opts ...grpc.DialOption) (pb.PoisCertifierApiClient, error)

+ NewPoisVerifierApiClient func(addr string, opts ...grpc.DialOption) (pb.PoisVerifierApiClient, error)

+ RequestBatchVerify func(addr string, requestBatchVerify *pb.RequestBatchVerify, timeout time.Duration, ...) (*pb.ResponseBatchVerify, error)

+ RequestGenTag func(addr string, requestGenTag *pb.RequestGenTag, timeout time.Duration, ...) (*pb.ResponseGenTag, error)

+ RequestMinerCommitGenChall func(addr string, commitGenChall *pb.RequestMinerCommitGenChall, ...) (*pb.Challenge, error)

+ RequestMinerGetNewKey func(addr string, accountKey []byte, timeout time.Duration, ...) (*pb.ResponseMinerInitParam, error)

+ RequestSpaceProofVerifySingleBlock func(addr string, requestSpaceProofVerify *pb.RequestSpaceProofVerify, ...) (*pb.ResponseSpaceProofVerify, error)

+ RequestVerifyCommitProof func(addr string, verifyCommitAndAccProof *pb.RequestVerifyCommitAndAccProof, ...) (*pb.ResponseVerifyCommitOrDeletionProof, error)

+ RequestVerifyDeletionProof func(addr string, requestVerifyDeletionProof *pb.RequestVerifyDeletionProof, ...) (*pb.ResponseVerifyCommitOrDeletionProof, error)

Nov 27, 2023

Changes in this version

+ const P2PResponseEmpty

+ const P2PResponseRemoteFailed

+ const ZeroFileHash_16M

type Node

+ func (e Node) ReadDataStatAction(id peer.ID, roothash string, datahash string) (uint64, error)

+ func (n *Node) NewReadDataStatProtocol() *ReadDataStatProtocol

type Protocol

+ ReadDataStatAction func(id peer.ID, roothash string, datahash string) (uint64, error)

type ReadDataProtocol

+ func (e ReadDataProtocol) ReadDataStatAction(id peer.ID, roothash string, datahash string) (uint64, error)

+ type ReadDataStatProtocol struct

+ func (e ReadDataStatProtocol) ReadDataAction(id peer.ID, roothash, datahash, path string, size int64) error

+ func (e ReadDataStatProtocol) ReadDataStatAction(id peer.ID, roothash string, datahash string) (uint64, error)

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

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

+ func (p ReadDataStatProtocol) SetProtocolPrefix(protocolPrefix string)

type ReadFileProtocol

+ func (e ReadFileProtocol) ReadDataStatAction(id peer.ID, roothash string, datahash string) (uint64, error)

type WriteFileProtocol

+ func (e WriteFileProtocol) ReadDataStatAction(id peer.ID, roothash string, datahash string) (uint64, error)

Oct 26, 2023

Changes in this version

+ const FileBlockDir

type Node

+ func (n *Node) FidToCid(fid string) (string, error)

+ func (n *Node) GetBitSwap() *bitswap.Bitswap

+ func (n *Node) GetBlockstore() blockstore.Blockstore

+ func (n *Node) GetLocalDataFromBlock(wantCid string) ([]byte, error)

type P2P

+ FidToCid func(fid string) (string, error)

+ GetBitSwap func() *bitswap.Bitswap

+ GetBlockstore func() blockstore.Blockstore

+ GetLocalDataFromBlock func(wantCid string) ([]byte, error)

Sep 26, 2023

Changes in this version

+ var BlocksDir = "blocks"

+ func NewDatastore(path string) (ds.Datastore, error)

+ type Datastore struct

+ func (d *Datastore) Batch(ctx context.Context) (ds.Batch, error)

+ func (d *Datastore) Close() error

+ func (d *Datastore) Delete(ctx context.Context, key ds.Key) (err error)

+ func (d *Datastore) DiskUsage(ctx context.Context) (uint64, error)

+ func (d *Datastore) Get(ctx context.Context, key ds.Key) (value []byte, err error)

+ func (d *Datastore) GetSize(ctx context.Context, key ds.Key) (size int, err error)

+ func (d *Datastore) Has(ctx context.Context, key ds.Key) (exists bool, err error)

+ func (d *Datastore) KeyFilename(key ds.Key) string

+ func (d *Datastore) Put(ctx context.Context, key ds.Key, value []byte) (err error)

+ func (d *Datastore) Query(ctx context.Context, q query.Query) (query.Results, error)

+ func (d *Datastore) Sync(ctx context.Context, prefix ds.Key) error

type Node

+ func (n *Node) GetDataFromBlock(wantCid string) ([]byte, error)

+ func (n *Node) NewCidFromFid(fid string) (cid.Cid, error)

+ func (n *Node) NotifyData(buf []byte) error

+ func (n *Node) SaveAndNotifyDataBlock(buf []byte) (cid.Cid, error)

type P2P

+ GetDataFromBlock func(wantCid string) ([]byte, error)

+ NewCidFromFid func(fid string) (cid.Cid, error)

+ NotifyData func(buf []byte) error

+ SaveAndNotifyDataBlock func(buf []byte) (cid.Cid, error)

Sep 7, 2023

Changes in this version

type Node

+ func (n *Node) GetDht() *dht.IpfsDHT

+ func (n *Node) GetRoutingTable() *drouting.RoutingDiscovery

type P2P

+ GetDht func() *dht.IpfsDHT

+ GetRoutingTable func() *drouting.RoutingDiscovery

Aug 16, 2023

Changes in this version

+ const DataShardsTest

+ const DefaultFDCount

+ const FragmentSizeTest

+ const ParShardsTest

+ const SegmentSizeTest

type Node

+ func (n *Node) GetGrpcProtocolVersion() string

+ func (n *Node) PoisGetMinerInitParamP2P(peerid peer.ID, accountKey []byte, timeout time.Duration) (*pb.ResponseMinerInitParam, error)

+ func (n *Node) PoisMinerCommitGenChallP2P(peerid peer.ID, accountKey []byte, commit *pb.Commits, timeout time.Duration) (*pb.Challenge, error)

+ func (n *Node) PoisMinerRegisterP2P(peerid peer.ID, accountKey []byte, timeout time.Duration) (*pb.ResponseMinerRegister, error)

+ func (n *Node) PoisRequestVerifyDeletionProofP2P(peerid peer.ID, roots [][]byte, witChain *pb.AccWitnessNode, accPath [][]byte, ...) (*pb.ResponseVerifyCommitOrDeletionProof, error)

+ func (n *Node) PoisRequestVerifySpaceTotalP2P(peerid peer.ID, accountKey []byte, proofList []*pb.BlocksProof, front int64, ...) (*pb.ResponseSpaceProofVerifyTotal, error)

+ func (n *Node) PoisServiceRequestBatchVerifyP2P(peerid peer.ID, names []string, us []string, mus []string, sigma string, ...) (*pb.ResponseBatchVerify, error)

+ func (n *Node) PoisServiceRequestGenTagP2P(peerid peer.ID, fileData []byte, blockNum uint64, filehash string, ...) (*pb.ResponseGenTag, error)

+ func (n *Node) PoisSpaceProofVerifySingleBlockP2P(peerid peer.ID, accountKey []byte, spaceChals []int64, keyN []byte, ...) (*pb.ResponseSpaceProofVerify, error)

+ func (n *Node) PoisVerifyCommitProofP2P(peerid peer.ID, accountKey []byte, commitProofGroup *pb.CommitProofGroup, ...) (*pb.ResponseVerifyCommitOrDeletionProof, error)

type P2P

+ GetGrpcProtocolVersion func() string

+ PoisGetMinerInitParamP2P func(peerid peer.ID, accountKey []byte, timeout time.Duration) (*pb.ResponseMinerInitParam, error)

+ PoisMinerCommitGenChallP2P func(peerid peer.ID, accountKey []byte, commit *pb.Commits, timeout time.Duration) (*pb.Challenge, error)

+ PoisMinerRegisterP2P func(peerid peer.ID, accountKey []byte, timeout time.Duration) (*pb.ResponseMinerRegister, error)

+ PoisRequestVerifyDeletionProofP2P func(peerid peer.ID, roots [][]byte, witChain *pb.AccWitnessNode, accPath [][]byte, ...) (*pb.ResponseVerifyCommitOrDeletionProof, error)

+ PoisRequestVerifySpaceTotalP2P func(peerid peer.ID, accountKey []byte, proofList []*pb.BlocksProof, front int64, ...) (*pb.ResponseSpaceProofVerifyTotal, error)

+ PoisServiceRequestBatchVerifyP2P func(peerid peer.ID, names []string, us []string, mus []string, sigma string, ...) (*pb.ResponseBatchVerify, error)

+ PoisServiceRequestGenTagP2P func(peerid peer.ID, fileData []byte, blockNum uint64, filehash string, ...) (*pb.ResponseGenTag, error)

+ PoisSpaceProofVerifySingleBlockP2P func(peerid peer.ID, accountKey []byte, spaceChals []int64, keyN []byte, ...) (*pb.ResponseSpaceProofVerify, error)

+ PoisVerifyCommitProofP2P func(peerid peer.ID, accountKey []byte, commitProofGroup *pb.CommitProofGroup, ...) (*pb.ResponseVerifyCommitOrDeletionProof, error)

Aug 9, 2023

Changes in this version

type Node

+ func (n *Node) PoisRequestVerifyDeletionProof(addr string, roots [][]byte, witChain *pb.AccWitnessNode, accPath [][]byte, ...) (*pb.ResponseVerifyCommitOrDeletionProof, error)

+ func (n *Node) PoisRequestVerifySpaceTotal(addr string, accountKey []byte, proofList []*pb.BlocksProof, front int64, ...) (*pb.ResponseSpaceProofVerifyTotal, error)

+ func (n *Node) PoisServiceNewClient(addr string, opts ...grpc.DialOption) (pb.Podr2ApiClient, error)

+ func (n *Node) PoisServiceRequestBatchVerify(addr string, names []string, us []string, mus []string, sigma string, ...) (*pb.ResponseBatchVerify, error)

+ func (n *Node) PoisServiceRequestGenTag(addr string, fileData []byte, blockNum uint64, filehash string, ...) (*pb.ResponseGenTag, error)

type P2P

+ PoisRequestVerifyDeletionProof func(addr string, roots [][]byte, witChain *pb.AccWitnessNode, accPath [][]byte, ...) (*pb.ResponseVerifyCommitOrDeletionProof, error)

+ PoisRequestVerifySpaceTotal func(addr string, accountKey []byte, proofList []*pb.BlocksProof, front int64, ...) (*pb.ResponseSpaceProofVerifyTotal, error)

+ PoisServiceNewClient func(addr string, opts ...grpc.DialOption) (pb.Podr2ApiClient, error)

+ PoisServiceRequestBatchVerify func(addr string, names []string, us []string, mus []string, sigma string, ...) (*pb.ResponseBatchVerify, error)

+ PoisServiceRequestGenTag func(addr string, fileData []byte, blockNum uint64, filehash string, ...) (*pb.ResponseGenTag, error)

Aug 1, 2023

Changes in this version

type Node

+ func (n *Node) PoisGetMinerInitParam(cli pb.PoisApiClient, accountKey []byte) (*pb.ResponseMinerInitParam, error)

+ func (n *Node) PoisMinerCommitGenChall(cli pb.PoisApiClient, accountKey []byte, commit *pb.Commits) (*pb.Challenge, error)

+ func (n *Node) PoisMinerRegister(cli pb.PoisApiClient, accountKey []byte) (*pb.ResponseMinerRegister, error)

+ func (n *Node) PoisNewClient(addr string) (pb.PoisApiClient, error)

+ func (n *Node) PoisSpaceProofVerifySingleBlock(cli pb.PoisApiClient, accountKey []byte, spaceChals []int64, keyN []byte, ...) (*pb.ResponseSpaceProofVerify, error)

+ func (n *Node) PoisVerifyCommitProof(cli pb.PoisApiClient, accountKey []byte, commitProofGroup *pb.CommitProofGroup, ...) (*pb.ResponseVerifyCommitAndAccProof, error)

type P2P

+ PoisGetMinerInitParam func(cli pb.PoisApiClient, accountKey []byte) (*pb.ResponseMinerInitParam, error)

+ PoisMinerCommitGenChall func(cli pb.PoisApiClient, accountKey []byte, commit *pb.Commits) (*pb.Challenge, error)

+ PoisMinerRegister func(cli pb.PoisApiClient, accountKey []byte) (*pb.ResponseMinerRegister, error)

+ PoisNewClient func(addr string) (pb.PoisApiClient, error)

+ PoisSpaceProofVerifySingleBlock func(cli pb.PoisApiClient, accountKey []byte, spaceChals []int64, keyN []byte, ...) (*pb.ResponseSpaceProofVerify, error)

+ PoisVerifyCommitProof func(cli pb.PoisApiClient, accountKey []byte, commitProofGroup *pb.CommitProofGroup, ...) (*pb.ResponseVerifyCommitAndAccProof, error)

Jul 19, 2023

Changes in this version

+ func FindFile(dir, name string) string

type AggrProofProtocol

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

type CustomDataTagProtocol

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

type FileProtocol

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

type IdleDataTagProtocol

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

type Node

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

+ func (n *Node) NewReadDataProtocol() *ReadDataProtocol

type Protocol

+ ReadDataAction func(id peer.ID, roothash, datahash, path string, size int64) error

type PushTagProtocol

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

+ type ReadDataProtocol struct

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

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

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

+ func (e ReadDataProtocol) ReadDataAction(id peer.ID, roothash, datahash, path string, size int64) error

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

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

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

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

+ func (p ReadDataProtocol) SetProtocolPrefix(protocolPrefix string)

type ReadFileProtocol

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

type WriteFileProtocol

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

Jul 18, 2023

Changes in this version

+ const DefaultFDount

Jul 13, 2023

Changes in this version

+ func FreeLocalPort(port uint32) bool

Jul 12, 2023

Changes in this version

type Node

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

+ func (n *Node) RemovePeerFromRoutingTable(peerid peer.ID)

+ func (n *Node) TryAddPeerToRoutingTable(peerid peer.ID) (bool, error)

type P2P

+ PeerID func() peer.ID

+ RemovePeerFromRoutingTable func(peerid peer.ID)

+ TryAddPeerToRoutingTable func(peerid peer.ID) (bool, error)

Jul 7, 2023

Changes in this version

type Node

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

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

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

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

type P2P

+ Close func() error

+ GetCtxCancelFromRoot func() context.Context

+ GetCtxQueryFromCtxCancel func() context.Context

+ GetCtxRoot func() context.Context

+ GetDiscoveredPeers func() <-chan *routing.QueryEvent

Jul 6, 2023

Changes in this version

+ func IsIPv4(ipAddr string) bool

+ func IsIPv6(ipAddr string) bool

type Node

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

+ func (n *Node) GetRendezvousVersion() string

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

type P2P

+ DHTFindPeer func(peerid string) (peer.AddrInfo, error)

+ GetRendezvousVersion func() string

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

Jul 4, 2023

Changes in this version

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

type AggrProofProtocol

+ func (p AggrProofProtocol) SetProtocolPrefix(protocolPrefix string)

type CustomDataTagProtocol

+ func (p CustomDataTagProtocol) SetProtocolPrefix(protocolPrefix string)

type FileProtocol

+ func (p FileProtocol) SetProtocolPrefix(protocolPrefix string)

type IdleDataTagProtocol

+ func (p IdleDataTagProtocol) SetProtocolPrefix(protocolPrefix string)

type Node

+ func (n *Node) GetProtocolPrefix() string

+ func (p Node) SetProtocolPrefix(protocolPrefix string)

type P2P

+ GetProtocolPrefix func() string

type PushTagProtocol

+ func (p PushTagProtocol) SetProtocolPrefix(protocolPrefix string)

type ReadFileProtocol

+ func (p ReadFileProtocol) SetProtocolPrefix(protocolPrefix string)

type WriteFileProtocol

+ func (p WriteFileProtocol) SetProtocolPrefix(protocolPrefix string)

Jul 2, 2023

Changes in this version

+ const ERR_RespFailure

+ const ERR_RespInvalidData

+ const ERR_RespTimeOut

Jun 6, 2023

Changes in this version

type Node

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

type P2P

+ AddMultiaddrToPeerstore func(multiaddr string, t time.Duration) (peer.ID, error)

Jun 2, 2023

Changes in this version

+ func CheckExternalIpv4(ip string) bool

+ func GetLocalIp() ([]string, error)

type Node

+ func (n *Node) GetRootCtx() context.Context

type P2P

+ GetRootCtx func() context.Context

May 31, 2023

Changes in this version

type Protocol

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

May 31, 2023

Changes in this version

type CustomDataTagProtocol

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

type FileProtocol

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

type IdleDataTagProtocol

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

type Node

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

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

type P2P

+ GetPeerPublickey func() []byte

type PushTagProtocol

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

type ReadFileProtocol

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

type WriteFileProtocol

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

May 30, 2023

Changes in this version

+ const AggrProof_PROTOCOL

+ const CustomDataTag_Protocol

+ const FILE_PROTOCOL

+ const FileProtocolBufSize

+ const FileProtocolMsgBuf

+ const FileType_IdleFile

+ const FileType_MusFile

+ const FileType_NamesFile

+ const FileType_ServiceFile

+ const FileType_TagFile

+ const FileType_UsFile

+ const IdleDataTag_Protocol

+ const IdleProtocolMsgBuf

+ const MaxCustomDataLength

+ const MaxFileNameLength

+ const MusProtocolMsgBuf

+ const P2PReadReqRespTime

+ const P2PResponseFailed

+ const P2PResponseFinish

+ const P2PResponseOK

+ const P2PWriteReqRespTime

+ const PushTag_Protocol

+ const Rendezvous

+ const TagProtocolMsgBuf

+ var CustomDataLengthErr = fmt.Errorf("custom data length exceeds %d", MaxCustomDataLength)

+ var FileNameEmptyErr = fmt.Errorf("filename is empty")

+ var FileNameLengthErr = fmt.Errorf("filename length exceeds %d", MaxFileNameLength)

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

+ func CalcPathSHA256(fpath string) (string, error)

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

+ func NewProtocol() *protocols

+ type AggrProofProtocol struct

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

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

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

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

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

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

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

+ type CustomDataTagProtocol struct

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

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

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

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

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

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

+ type DataDirs struct

+ FileDir string

+ IdleDataDir string

+ IdleTagDir string

+ IproofFile string

+ ProofDir string

+ ServiceTagDir string

+ SproofFile string

+ TmpDir string

+ type DiscoveredPeer struct

+ Addr ma.Multiaddr

+ PeerID peer.ID

+ type FileProtocol struct

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

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

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

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

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

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

+ type IdleDataTagProtocol struct

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

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

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

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

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

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

type Node

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

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

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

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

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

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

+ func (n *Node) DiscoveredPeer() <-chan DiscoveredPeer

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

+ func (n *Node) GetDhtProtocolVersion() string

+ func (n *Node) GetDirs() DataDirs

+ func (n *Node) GetDiscoverSt() bool

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

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

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

+ func (n *Node) GetProtocolVersion() string

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

+ func (n *Node) NewAggrProofProtocol() *AggrProofProtocol

+ func (n *Node) NewCustomDataTagProtocol() *CustomDataTagProtocol

+ func (n *Node) NewFileProtocol() *FileProtocol

+ func (n *Node) NewIdleDataTagProtocol() *IdleDataTagProtocol

+ func (n *Node) NewPushTagProtocol() *PushTagProtocol

+ func (n *Node) NewReadFileProtocol() *ReadFileProtocol

+ func (n *Node) NewWriteFileProtocol() *WriteFileProtocol

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

+ func (n *Node) StartDiscover()

type P2P

+ AddMultiaddrToPearstore func(multiaddr string, t time.Duration) (peer.ID, error)

+ DiscoveredPeer func() <-chan DiscoveredPeer

+ GetBootstraps func() []string

+ GetDhtProtocolVersion func() string

+ GetDirs func() DataDirs

+ GetDiscoverSt func() bool

+ GetIdleDataCh func() <-chan string

+ GetIdleTagCh func() <-chan string

+ GetOwnPublickey func() []byte

+ GetPeerIdFromPubkey func(pubkey []byte) (string, error)

+ GetProtocolVersion func() string

+ GetServiceTagCh func() <-chan string

+ Multiaddr func() string

+ PrivatekeyPath func() string

+ SetBootstraps func(bootstrap []string)

+ StartDiscover func()

+ Workspace func() string

+ type ProofFileType struct

+ Mus []string

+ Names []string

+ Sigma string

+ Us []string

+ type Protocol interface

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

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

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

+ TagPushReq func(peerid peer.ID) (uint32, error)

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

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

+ type PushTagProtocol struct

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

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

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

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

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

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

+ type ReadFileProtocol struct

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

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

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

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

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

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

+ type WriteFileProtocol struct

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

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

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

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

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

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

May 15, 2023

Changes in this version

type Node

+ PeerId []byte

May 15, 2023

Changes in this version

type Node

+ PublicKey []byte

+ func (n *Node) GetPeerIdFromPubkey(pubkey []byte) (string, error)

May 12, 2023

Changes in this version

type Node

+ func (n *Node) GetIdleTagEvent() chan string

+ func (n *Node) GetServiceTagEvent() chan string

+ func (n *Node) PutIdleTagEventCh(path string)

+ func (n *Node) PutServiceTagEventCh(path string)

May 11, 2023

Changes in this version

+ const FileDataDirectionry

+ const IdleDataDirectionry

+ const IdleTagDirectionry

+ const ServiceTagDirectionry

+ const TmpDataDirectionry

type Node

+ IdleDataDir string

+ IdleTagDir string

+ ServiceTagDir string

May 11, 2023

Changes in this version

+ const IdleProofFile

+ const ServiceProofFile

type Node

+ IproofFile string

+ IproofMuFile string

+ SproofFile string

+ SproofMuFile string

+ func (n *Node) GetIdleFileTee() string

+ func (n *Node) GetServiceFileTee() string

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

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

May 5, 2023

Changes in this version

+ const FileDirectionry

+ const IdleDirectionry

+ const IdleMuFile

+ const IdleNamesFile

+ const IdleUsFile

+ const ProofDirectionry

+ const ServiceMuFile

+ const ServiceNamesFile

+ const ServiceUsFile

+ const TagDirectionry

+ const TmpDirectionry

type Node

+ FileDir string

+ IdleDir string

+ ImuPath string

+ InamesPath string

+ IusPath string

+ ProofDir string

+ SmuPath string

+ SnamesPath string

+ SusPath string

+ TagDir string

+ TmpDir string

+ func (n Node) GetIdleDataEvent() chan string

+ func (n Node) GetTagEvent() chan string

+ func (n Node) PutIdleDataEventCh(path string)

+ func (n Node) PutTagEventCh(path string)

Apr 28, 2023

Changes in this version

type Node

+ func (n Node) GetMuEvent() string

+ func (n Node) PutMuEventCh(peerid string)

type P2P

+ GetMuEvent func() string

Apr 25, 2023

Changes in this version

+ const BufferSize

type Node

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

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

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

+ func (n *Node) StarFileTransferProtocol()

Apr 11, 2023

Changes in this version

+ const DirMode

Apr 11, 2023

Changes in this version

+ const DataShards

+ const FragmentSize

+ const ParShards

+ const SIZE_1GiB

+ const SIZE_1KiB

+ const SIZE_1MiB

+ const SIZE_SLICE

+ const SegmentSize

Apr 7, 2023

Changes in this version

+ const AllIpAddress

+ const LocalAddress

+ func ExtractIp4FromMultiaddr(multiaddr string) (string, uint64, error)

+ func GetExternalIp() (string, error)

Apr 7, 2023

Changes in this version

+ type Node struct

+ func NewBasicNode(multiaddr ma.Multiaddr, workspace string, privatekeypath string) (*Node, error)

+ func (n *Node) AddAddrToPearstore(id peer.ID, addr ma.Multiaddr, t time.Duration)

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

+ func (n *Node) AuthenticateMessage(message proto.Message, data *pb.MessageData) bool

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

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

+ func (n *Node) SignProtoMessage(message proto.Message) ([]byte, error)

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

+ func (n Node) Close() error

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

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

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

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

+ func (n Node) Multiaddr() string

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

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

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

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

+ func (n Node) PrivatekeyPath() string

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

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

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

+ func (n Node) Workspace() string

+ type P2P interface