link

Documentation

Index

• type Link
  • func NewLink(id common.PeerId, c net.Conn, msgChan chan *types.MsgPayload) *Link
  • func (this *Link) CloseConn()
  • func (this *Link) GetAddr() string
  • func (this *Link) GetConn() net.Conn
  • func (this *Link) GetRXTime() int64
  • func (this *Link) Rx()
  • func (this *Link) Send(msg types.Message) error
  • func (this *Link) SendRaw(rawPacket []byte) error
  • func (this *Link) SetConn(conn net.Conn)
  • func (this *Link) UpdateRXTime(t time.Time)

Types

type Link

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

Link used to establish

func NewLink

func NewLink(id common.PeerId, c net.Conn, msgChan chan *types.MsgPayload) *Link

func (*Link) CloseConn

func (this *Link) CloseConn()

close connection

func (*Link) GetAddr

func (this *Link) GetAddr() string

get address

func (*Link) GetConn

func (this *Link) GetConn() net.Conn

get connection

func (*Link) GetRXTime

func (this *Link) GetRXTime() int64

GetRXTime return the latest message time

func (*Link) Rx

func (this *Link) Rx()

func (*Link) Send

func (this *Link) Send(msg types.Message) error

func (*Link) SendRaw

func (this *Link) SendRaw(rawPacket []byte) error

func (*Link) SetConn

func (this *Link) SetConn(conn net.Conn)

set connection

func (*Link) UpdateRXTime

func (this *Link) UpdateRXTime(t time.Time)

record latest message time