relay

Documentation

Index

• Variables
• type Hub
  • func NewHub(listenAddr string) (Hub, error)
• type Peer
  • func NewPeer(name string, listenAddr string, relayAddr string) (Peer, error)

Variables

var (
	ErrNotInit = errors.New("not_init")
)

Types

type Hub

type Hub interface {
	ListenAndServe() error
	Close() error
}

func NewHub

func NewHub(listenAddr string) (Hub, error)

type Peer

type Peer interface {
	Write(m *relay_pb.Message) error
	DialAndServe(serve func(m *relay_pb.Message)) error
	Close() error
}

func NewPeer

func NewPeer(name string, listenAddr string, relayAddr string) (Peer, error)