p2p

Documentation

Index

• type P2PServer
  • func NewP2PServer(ctx context.Context, address string, protocol string) (*P2PServer, error)
  • func (p2p *P2PServer) Connect(peers ...string) error
  • func (p2p *P2PServer) GetConnections() map[string]string
  • func (p2p *P2PServer) MsgReceivedHandler(handle func([]byte))
  • func (ws *P2PServer) OnParseMsgHandler(src *os.File)
  • func (p2p *P2PServer) SetMsgReceivedHandler(handle func([]byte))
  • func (p2p *P2PServer) SetSendMsg(clientId string, msg []byte)
  • func (p2p *P2PServer) Shutdown()
  • func (p2p *P2PServer) Start(ctx context.Context)

Types

type P2PServer

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

func NewP2PServer

func NewP2PServer(ctx context.Context, address string, protocol string) (*P2PServer, error)

func (*P2PServer) Connect

func (p2p *P2PServer) Connect(peers ...string) error

func (*P2PServer) GetConnections

func (p2p *P2PServer) GetConnections() map[string]string

func (*P2PServer) MsgReceivedHandler

func (p2p *P2PServer) MsgReceivedHandler(handle func([]byte))

func (*P2PServer) OnParseMsgHandler

func (ws *P2PServer) OnParseMsgHandler(src *os.File)

func (*P2PServer) SetMsgReceivedHandler

func (p2p *P2PServer) SetMsgReceivedHandler(handle func([]byte))

func (*P2PServer) SetSendMsg

func (p2p *P2PServer) SetSendMsg(clientId string, msg []byte)

func (*P2PServer) Shutdown

func (p2p *P2PServer) Shutdown()

func (*P2PServer) Start

func (p2p *P2PServer) Start(ctx context.Context)