webrtc

Documentation

Index

• Constants
• Variables
• func Decode(in string, obj interface{}) error
• func Encode(obj interface{}) (string, error)
• type DataChannelMessage
• type Peer
  • func NewPeer(urls []string) *Peer
  • func (c *Peer) Answer(offerSdp string) error
  • func (c *Peer) Close() error
  • func (c *Peer) IsConnected() bool
  • func (c *Peer) Offer(label string) error
  • func (c *Peer) ReadMessage() (messageType int, data []byte, err error)
  • func (c *Peer) SetPongHandler(f func(string) error)
  • func (c *Peer) SetReadDeadline(t time.Time) error
  • func (c *Peer) SetReadLimit(l int64)
  • func (c *Peer) SetRemoteSdp(sdp string) error
  • func (c *Peer) SetWriteDeadline(t time.Time) error
  • func (c *Peer) WriteJSON(v interface{}) error
  • func (c *Peer) WriteMessage(messageType int, data []byte) (err error)

Constants

const (
	UnknownMessage = 0
	TextMessage    = 1
	BinaryMessage  = 2
	CloseMessage   = 8
	PingMessage    = 9
	PongMessage    = 10

	PingData = "ping"
	PongData = "pong"
)

compitable to websocket

Variables

var NewConnection func(conn session.Conn, r *http.Request)

Functions

func Decode

func Decode(in string, obj interface{}) error

Decode the input from base64

func Encode

func Encode(obj interface{}) (string, error)

Encode the input in base64

Types

type DataChannelMessage

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

type Peer

type Peer struct {
	OnSdp            chan string
	OnMessage        chan DataChannelMessage
	OnOfferConnected chan struct{}
	// contains filtered or unexported fields
}

func NewPeer

func NewPeer(urls []string) *Peer

func (*Peer) Answer

func (c *Peer) Answer(offerSdp string) error

func (*Peer) Close

func (c *Peer) Close() error

func (*Peer) IsConnected

func (c *Peer) IsConnected() bool

func (*Peer) Offer

func (c *Peer) Offer(label string) error

func (*Peer) ReadMessage

func (c *Peer) ReadMessage() (messageType int, data []byte, err error)

func (*Peer) SetPongHandler

func (c *Peer) SetPongHandler(f func(string) error)

func (*Peer) SetReadDeadline

func (c *Peer) SetReadDeadline(t time.Time) error

func (*Peer) SetReadLimit

func (c *Peer) SetReadLimit(l int64)

func (*Peer) SetRemoteSdp

func (c *Peer) SetRemoteSdp(sdp string) error

func (*Peer) SetWriteDeadline

func (c *Peer) SetWriteDeadline(t time.Time) error

func (*Peer) WriteJSON

func (c *Peer) WriteJSON(v interface{}) error

WriteJSON writes the JSON encoding of v as a message.

func (*Peer) WriteMessage

func (c *Peer) WriteMessage(messageType int, data []byte) (err error)