_3_send_func_to_channel

Documentation

Index

• type Host
  • func NewHost() *Host
  • func (h *Host) AddPeer(p *Peer)
  • func (h *Host) Broadcast(msg string)
  • func (h *Host) GetPeer(pid string) *Peer
  • func (h *Host) Remove(pid string)
  • func (h *Host) SendTo(pid, msg string)
• type Operation
• type Peer
  • func (p *Peer) WriteMsg(msg string)

Types

type Host

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

func NewHost

func NewHost() *Host

func (*Host) AddPeer

func (h *Host) AddPeer(p *Peer)

func (*Host) Broadcast

func (h *Host) Broadcast(msg string)

func (*Host) GetPeer

func (h *Host) GetPeer(pid string) *Peer

获取

func (*Host) Remove

func (h *Host) Remove(pid string)

func (*Host) SendTo

func (h *Host) SendTo(pid, msg string)

只向一个Peer发送消息

type Operation

type Operation func(peers map[string]*Peer)

type Peer

type Peer struct {
	ID string
}

Peer代表一个节点

func (*Peer) WriteMsg

func (p *Peer) WriteMsg(msg string)