peermgr

Documentation

Index

• Constants
• func AddrToPeerInfo(multiAddr string) (*peer.AddrInfo, error)
• func DataToPayload(msg *pb.Message) *model.Payload
• func Message(typ pb.Message_Type, ok bool, data []byte) *pb.Message
• func MessageWithPayload(typ pb.Message_Type, pd *model.Payload) *pb.Message
• type DHTManager
• type PeerManager
• type Swarm
  • func New(config *repo.Config, nodePrivKey crypto.PrivateKey, privKey crypto.PrivateKey, ...) (*Swarm, error)
  • func (swarm *Swarm) AsyncSend(id basicMgr.KeyType, msg *pb.Message) error
  • func (swarm *Swarm) AsyncSendWithStream(s network.Stream, msg *pb.Message) error
  • func (swarm *Swarm) Connect(addrInfo *peer.AddrInfo) (string, error)
  • func (swarm *Swarm) ConnectedPeerIDs() []string
  • func (swarm *Swarm) CountConnectedPeers() uint64
  • func (swarm *Swarm) FindProviders(id string) (string, error)
  • func (swarm *Swarm) Peers() map[string]*peer.AddrInfo
  • func (swarm *Swarm) Provider(key string, passed bool) error
  • func (swarm *Swarm) RegisterConnectHandler(handler func(string)) error
  • func (swarm *Swarm) RegisterMsgHandler(messageType pb.Message_Type, handler func(network.Stream, *pb.Message)) error
  • func (swarm *Swarm) RegisterMultiMsgHandler(messageTypes []pb.Message_Type, handler func(network.Stream, *pb.Message)) error
  • func (swarm *Swarm) Send(id basicMgr.KeyType, msg *pb.Message) (*pb.Message, error)
  • func (swarm *Swarm) SendWithStream(s network.Stream, msg *pb.Message) (*pb.Message, error)
  • func (swarm *Swarm) Start() error
  • func (swarm *Swarm) Stop() error

Constants

const (
	V1 = "1.0"
)

Functions

func AddrToPeerInfo

func AddrToPeerInfo(multiAddr string) (*peer.AddrInfo, error)

AddrToPeerInfo transfer addr to PeerInfo addr example: "/ip4/104.236.76.40/tcp/4001/ipfs/QmSoLV4Bbm51jM9C4gDYZQ9Cy3U6aXMJDAbzgu2fzaDs64"

func DataToPayload

func DataToPayload(msg *pb.Message) *model.Payload

func Message

func Message(typ pb.Message_Type, ok bool, data []byte) *pb.Message

func MessageWithPayload

func MessageWithPayload(typ pb.Message_Type, pd *model.Payload) *pb.Message

Types

type DHTManager

type DHTManager interface {
	// FindProviders Search for peers who are able to provide a given key
	FindProviders(id string) (string, error)

	// Provider adds the given cid to the content routing system. If 'true' is
	// passed, it also announces it, otherwise it is just kept in the local
	// accounting of which objects are being provided.
	Provider(string, bool) error
}

type PeerManager

type PeerManager interface {
	basicMgr.BasicPeerManager

	DHTManager

	Connect(info *peer.AddrInfo) (string, error)

	// AsyncSendWithStream sends message using existed stream
	AsyncSendWithStream(network.Stream, *pb.Message) error

	// ConnectedPeerIDs find connectedPeers
	ConnectedPeerIDs() []string

	// RegisterMsgHandler
	RegisterMsgHandler(pb.Message_Type, func(network.Stream, *pb.Message)) error

	// RegisterMultiMsgHandler
	RegisterMultiMsgHandler([]pb.Message_Type, func(network.Stream, *pb.Message)) error

	// RegisterConnectHandler
	RegisterConnectHandler(func(string)) error
}

type Swarm

type Swarm struct {
	// contains filtered or unexported fields
}

func New

func New(config *repo.Config, nodePrivKey crypto.PrivateKey, privKey crypto.PrivateKey, providers uint64, logger logrus.FieldLogger) (*Swarm, error)

func (*Swarm) AsyncSend

func (swarm *Swarm) AsyncSend(id basicMgr.KeyType, msg *pb.Message) error

func (*Swarm) AsyncSendWithStream

func (swarm *Swarm) AsyncSendWithStream(s network.Stream, msg *pb.Message) error

func (*Swarm) Connect

func (swarm *Swarm) Connect(addrInfo *peer.AddrInfo) (string, error)

func (*Swarm) ConnectedPeerIDs

func (swarm *Swarm) ConnectedPeerIDs() []string

ConnectedPeerIDs gets connected PeerIDs TODO

func (*Swarm) CountConnectedPeers

func (swarm *Swarm) CountConnectedPeers() uint64

func (*Swarm) FindProviders

func (swarm *Swarm) FindProviders(id string) (string, error)

func (*Swarm) Peers

func (swarm *Swarm) Peers() map[string]*peer.AddrInfo

Peers maps remote peer's pierID to addrInfo, pierID indicate the appchainID for remote pier request from appchain

func (*Swarm) Provider

func (swarm *Swarm) Provider(key string, passed bool) error

func (*Swarm) RegisterConnectHandler

func (swarm *Swarm) RegisterConnectHandler(handler func(string)) error

func (*Swarm) RegisterMsgHandler

func (swarm *Swarm) RegisterMsgHandler(messageType pb.Message_Type, handler func(network.Stream, *pb.Message)) error

func (*Swarm) RegisterMultiMsgHandler

func (swarm *Swarm) RegisterMultiMsgHandler(messageTypes []pb.Message_Type, handler func(network.Stream, *pb.Message)) error

func (*Swarm) Send

func (swarm *Swarm) Send(id basicMgr.KeyType, msg *pb.Message) (*pb.Message, error)

func (*Swarm) SendWithStream

func (swarm *Swarm) SendWithStream(s network.Stream, msg *pb.Message) (*pb.Message, error)

func (*Swarm) Start

func (swarm *Swarm) Start() error

func (*Swarm) Stop

func (swarm *Swarm) Stop() error