p2p

Documentation

Index

• type P2PServer
  • func NewP2PServer(ctx context.Context, address string) P2PServer
  • func (p2p *P2PServer) BroadcastMessage(message string)
  • func (p2p *P2PServer) ExposeFirstPeerForInput()
  • func (p2p *P2PServer) GetConnectedClients() map[string]*websocket.Conn
  • func (p2p *P2PServer) GetConnections() map[string]string
  • func (p2p *P2PServer) Shutdown()
  • func (p2p *P2PServer) Start(peers ...string)
  • func (p2p *P2PServer) StartTls(certFile, certKey string, peers ...string)

Types

type P2PServer

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

func NewP2PServer

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

func (*P2PServer) BroadcastMessage

func (p2p *P2PServer) BroadcastMessage(message string)

func (*P2PServer) ExposeFirstPeerForInput

func (p2p *P2PServer) ExposeFirstPeerForInput()

func (*P2PServer) GetConnectedClients

func (p2p *P2PServer) GetConnectedClients() map[string]*websocket.Conn

func (*P2PServer) GetConnections

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

func (*P2PServer) Shutdown

func (p2p *P2PServer) Shutdown()

func (*P2PServer) Start

func (p2p *P2PServer) Start(peers ...string)

func (*P2PServer) StartTls

func (p2p *P2PServer) StartTls(certFile, certKey string, peers ...string)