lightclient

Documentation

Index

• Variables
• func ConnP2PServer(dest string) (string, error)
• func InitRouter(conn *grpc.ClientConn) *gin.Engine
• func SendP2PMsg(remoteP2PPeerId string, msg string) error
• func StartP2PServer()
• type Client
  • func FindUserOnLine(peerId *string) (*Client, error)
  • func (client *Client) FindUser(peerId *string) (*Client, error)
  • func (client *Client) Read()
  • func (client *Client) Write()
• type ClientManager
  • func (clientManager *ClientManager) Send(message []byte, myself *Client)
  • func (clientManager *ClientManager) Start()
• type P2PChannel

Variables

var GlobalWsClientManager = ClientManager{
	Broadcast:     make(chan []byte),
	Connected:     make(chan *Client),
	Disconnected:  make(chan *Client),
	P2PData:       make(chan []byte),
	ClientsMap:    make(map[*Client]bool),
	OnlineUserMap: make(map[string]*Client),
}

var P2PLocalPeerId string

Functions

func ConnP2PServer

func ConnP2PServer(dest string) (string, error)

func InitRouter

func InitRouter(conn *grpc.ClientConn) *gin.Engine

func SendP2PMsg

func SendP2PMsg(remoteP2PPeerId string, msg string) error

func StartP2PServer

func StartP2PServer()

Types

type Client

type Client struct {
	Id          string
	User        *bean.User
	Socket      *websocket.Conn
	SendChannel chan []byte
}

func FindUserOnLine

func FindUserOnLine(peerId *string) (*Client, error)

func (*Client) FindUser

func (client *Client) FindUser(peerId *string) (*Client, error)

func (*Client) Read

func (client *Client) Read()

func (*Client) Write

func (client *Client) Write()

type ClientManager

type ClientManager struct {
	Broadcast     chan []byte
	Connected     chan *Client
	Disconnected  chan *Client
	P2PData       chan []byte
	ClientsMap    map[*Client]bool
	OnlineUserMap map[string]*Client
}

func (*ClientManager) Send

func (clientManager *ClientManager) Send(message []byte, myself *Client)

func (*ClientManager) Start

func (clientManager *ClientManager) Start()

type P2PChannel

type P2PChannel struct {
	IsLocalChannel bool
	Address        string
	// contains filtered or unexported fields
}