local

Documentation

Index

• type Hub
  • func NewHub() *Hub
  • func (hub *Hub) Find(endpoint string) *Server
  • func (hub *Hub) Register(endpoint string, server *Server)
• type Server
  • func NewServer() *Server
  • func (s *Server) Accept() (ch <-chan signaler.Session, err error)
  • func (s *Server) Close() (err error)
  • func (s *Server) Handshake(endpoint string, offer signaler.SDP) (answer *signaler.SDP, err error)
• type Session
  • func NewSession(ctx context.Context, sdp signaler.SDP) *Session
  • func (sess *Session) Description() signaler.SDP
  • func (sess *Session) Reject(err error)
  • func (sess *Session) Resolve(answer *signaler.SDP) (err error)
  • func (sess *Session) Result() (answer *signaler.SDP, err error)

Types

type Hub

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

func NewHub

func NewHub() *Hub

func (*Hub) Find

func (hub *Hub) Find(endpoint string) *Server

func (*Hub) Register

func (hub *Hub) Register(endpoint string, server *Server)

type Server

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

func NewServer

func NewServer() *Server

func (*Server) Accept

func (s *Server) Accept() (ch <-chan signaler.Session, err error)

func (*Server) Close

func (s *Server) Close() (err error)

func (*Server) Handshake

func (s *Server) Handshake(endpoint string, offer signaler.SDP) (answer *signaler.SDP, err error)

type Session

type Session struct {
	context.Context
	// contains filtered or unexported fields
}

func NewSession

func NewSession(ctx context.Context, sdp signaler.SDP) *Session

func (*Session) Description

func (sess *Session) Description() signaler.SDP

func (*Session) Reject

func (sess *Session) Reject(err error)

func (*Session) Resolve

func (sess *Session) Resolve(answer *signaler.SDP) (err error)

func (*Session) Result

func (sess *Session) Result() (answer *signaler.SDP, err error)