libp2p

Documentation

Index

• type Client
  • func CreateClient() *Client
• type Messenger
  • func CreateMessenger(port int, name string) (*Messenger, error)
  • func CreateMessengerWithBindAddr(bindAddr string, port int, name string) (*Messenger, error)
  • func (m *Messenger) ListenForever(msgChan chan p2p.Message, ctx context.Context) error
  • func (m *Messenger) Send(msg p2p.Message, ctx context.Context) error
• type Server
  • func CreateServer(port int, handler func(msg p2p.Message)) (*Server, error)
  • func (s *Server) ServerForever()
  • func (s *Server) Shutdown()

Types

type Client

type Client struct {
}

func CreateClient

func CreateClient() *Client

type Messenger

type Messenger struct {
	Node p2p.Node
	// contains filtered or unexported fields
}

func CreateMessenger

func CreateMessenger(port int, name string) (*Messenger, error)

func CreateMessengerWithBindAddr

func CreateMessengerWithBindAddr(bindAddr string, port int, name string) (*Messenger, error)

func (*Messenger) ListenForever

func (m *Messenger) ListenForever(msgChan chan p2p.Message, ctx context.Context) error

func (*Messenger) Send

func (m *Messenger) Send(msg p2p.Message, ctx context.Context) error

type Server

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

func CreateServer

func CreateServer(port int, handler func(msg p2p.Message)) (*Server, error)

func (*Server) ServerForever

func (s *Server) ServerForever()

func (*Server) Shutdown

func (s *Server) Shutdown()