lightclient

package

v0.1.0 Latest Latest Go to latest Published: May 20, 2020 License: MIT Imports: 30 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/lightningonomnilayer/lightningonomni

Links

Open Source Insights

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)
type ClientManager
- func (clientManager *ClientManager) Send(message []byte, myself *Client)
- func (clientManager *ClientManager) Start()
type P2PChannel

Constants ¶

This section is empty.

Variables ¶

View Source

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),
}

View Source

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
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL