client

Documentation

Index

• Constants
• type Client
  • func New(peerId string, ws *websocket.Conn, localNode bool) *Client
  • func (c *Client) Close() error
  • func (c *Client) EnqueueNotFoundPeer(id string)
  • func (c *Client) HasNotFoundPeer(id string) bool
  • func (c *Client) IsExpired(now, limit int64) bool
  • func (c *Client) SendMessage(msg []byte) error
  • func (c *Client) SendMsgVersion(version int) error
  • func (c *Client) SetMT(mt int)
  • func (c *Client) UpdateTs()
• type SignalVerResponse

Constants

const (
	MAX_NOT_FOUND_PEERS_LIMIT = 5
)

Types

type Client

type Client struct {
	Ws            *websocket.Conn
	MessageType   int
	PeerId        string //唯一标识
	LocalNode     bool   // 是否本地节点
	Timestamp     int64
	NotFoundPeers []string // 记录没有找到的peer的队列
}

func New

func New(peerId string, ws *websocket.Conn, localNode bool) *Client

func (*Client) Close

func (c *Client) Close() error

func (*Client) EnqueueNotFoundPeer

func (c *Client) EnqueueNotFoundPeer(id string)

func (*Client) HasNotFoundPeer

func (c *Client) HasNotFoundPeer(id string) bool

func (*Client) IsExpired

func (c *Client) IsExpired(now, limit int64) bool

func (*Client) SendMessage

func (c *Client) SendMessage(msg []byte) error

func (*Client) SendMsgVersion

func (c *Client) SendMsgVersion(version int) error

func (*Client) SetMT

func (c *Client) SetMT(mt int)

func (*Client) UpdateTs

func (c *Client) UpdateTs()

type SignalVerResponse

type SignalVerResponse struct {
	Action string `json:"action"`
	Ver    int    `json:"ver"`
}