p2p

Documentation

Index

• Constants
• func NewKademliaDHT(ctx context.Context, h host.Host) (*dht.IpfsDHT, error)
• type PeerService
  • func NewPeerService(ctx context.Context, config carthage.Config) (*PeerService, error)
  • func (ps *PeerService) Close()
  • func (ps *PeerService) Start(ctx context.Context, sendTopicName string, receiveTopicName string)

Constants

const (
	TOPICNAME_NODE   = "b2bda31ed1603dc57ef0fea802c117fa8f23db2c5664dd9557b95860d86dc6db"
	TOPICNAME_CLIENT = "cf7a3efe5479ce71fc7a9faee3ae9549e666f4c7613322fd996c051748e16a69"
)

Functions

func NewKademliaDHT

func NewKademliaDHT(ctx context.Context, h host.Host) (*dht.IpfsDHT, error)

Types

type PeerService

type PeerService struct {
	Recv chan *carthage.PeerMessage
	Send chan *carthage.PeerMessage
	// contains filtered or unexported fields
}

func NewPeerService

func NewPeerService(ctx context.Context, config carthage.Config) (*PeerService, error)

func (*PeerService) Close

func (ps *PeerService) Close()

func (*PeerService) Start

func (ps *PeerService) Start(ctx context.Context, sendTopicName string, receiveTopicName string)