peerconn

Documentation

Index

• func GetDefaultStunHosts() (string, error)
• func NewDCConn(channel *webrtc.DataChannel) io.ReadWriteCloser
• func UUID() (string, error)
• type Answer
  • func (c *Answer) Kind() string
• type AnswerCandidate
  • func (c *AnswerCandidate) Kind() string
• type AnswerCompleted
  • func (c *AnswerCompleted) Kind() string
• type AnswerFailed
  • func (c *AnswerFailed) Kind() string
• type Conn
  • func NewConn(peer string, pc *webrtc.PeerConnection) *Conn
  • func (p *Conn) AppendIceCandidate(ic *webrtc.IceCandidate)
  • func (p *Conn) ApplyIceCandidates() error
  • func (p *Conn) Close() error
  • func (p *Conn) OnDataChannel(fn func(dc *webrtc.DataChannel))
  • func (p *Conn) Peer() string
  • func (p *Conn) SetDataChannel(dc *webrtc.DataChannel)
• type Connect
  • func (c *Connect) Kind() string
• type Connections
  • func NewConnections() *Connections
  • func (p *Connections) Del(user string)
  • func (p *Connections) Get(user string) *Conn
  • func (p *Connections) Iter(fn func(string, *Conn))
  • func (p *Connections) Set(user string, peer *Conn)
• type Node
  • func NewNode(dial *client.Config, config *webrtc.Configuration) (*Node, error)
  • func (n *Node) Close() error
  • func (n *Node) Connect(peer string) (*Conn, error)
  • func (n *Node) Members() (*signaling.Members, error)
  • func (n *Node) Room() string
  • func (n *Node) Send(dest string, v signaling.Kinder) error
  • func (n *Node) Start(owner bool) error
  • func (n *Node) Stop() error
  • func (n *Node) User() string
• type Offer
  • func (c *Offer) Kind() string
• type OfferCandidate
  • func (c *OfferCandidate) Kind() string
• type OfferCompleted
  • func (c *OfferCompleted) Kind() string
• type OfferFailed
  • func (c *OfferFailed) Kind() string

Functions

func GetDefaultStunHosts

func GetDefaultStunHosts() (string, error)

GetDefaultStunHosts ...

func NewDCConn

func NewDCConn(channel *webrtc.DataChannel) io.ReadWriteCloser

NewDCConn ...

func UUID

func UUID() (string, error)

UUID generates a random UUID according to RFC 4122

Types

type Answer

type Answer webrtc.SessionDescription

Answer ...

func (*Answer) Kind

func (c *Answer) Kind() string

Kind ...

type AnswerCandidate

type AnswerCandidate webrtc.IceCandidate

AnswerCandidate ...

func (*AnswerCandidate) Kind

func (c *AnswerCandidate) Kind() string

Kind ...

type AnswerCompleted

type AnswerCompleted struct{}

AnswerCompleted ...

func (*AnswerCompleted) Kind

func (c *AnswerCompleted) Kind() string

Kind ...

type AnswerFailed

type AnswerFailed struct{}

AnswerFailed ...

func (*AnswerFailed) Kind

func (c *AnswerFailed) Kind() string

Kind ...

type Conn

type Conn struct {
	*webrtc.PeerConnection
	// contains filtered or unexported fields
}

Conn ...

func NewConn

func NewConn(peer string, pc *webrtc.PeerConnection) *Conn

NewConn ...

func (*Conn) AppendIceCandidate

func (p *Conn) AppendIceCandidate(ic *webrtc.IceCandidate)

AppendIceCandidate ...

func (*Conn) ApplyIceCandidates

func (p *Conn) ApplyIceCandidates() error

ApplyIceCandidates ...

func (*Conn) Close

func (p *Conn) Close() error

Close ...

func (*Conn) OnDataChannel

func (p *Conn) OnDataChannel(fn func(dc *webrtc.DataChannel))

OnDataChannel ...

func (*Conn) Peer

func (p *Conn) Peer() string

Peer ...

func (*Conn) SetDataChannel

func (p *Conn) SetDataChannel(dc *webrtc.DataChannel)

SetDataChannel ...

type Connect

type Connect struct{}

Connect ...

func (*Connect) Kind

func (c *Connect) Kind() string

Kind ...

type Connections

type Connections struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Connections ...

func NewConnections

func NewConnections() *Connections

NewConnections ...

func (*Connections) Del

func (p *Connections) Del(user string)

Del ...

func (*Connections) Get

func (p *Connections) Get(user string) *Conn

Get ...

func (*Connections) Iter

func (p *Connections) Iter(fn func(string, *Conn))

Iter ...

func (*Connections) Set

func (p *Connections) Set(user string, peer *Conn)

Set ...

type Node

type Node struct {
	Clients *Connections // 接続元
	Servers *Connections // 接続先

	OnJoin           func(member string)
	OnLeave          func(member string)
	OnPeerConnection func(string, *Conn) error
	// contains filtered or unexported fields
}

Node ...

func NewNode

func NewNode(dial *client.Config, config *webrtc.Configuration) (*Node, error)

NewNode ...

func (*Node) Close

func (n *Node) Close() error

Close ...

func (*Node) Connect

func (n *Node) Connect(peer string) (*Conn, error)

Connect ...

func (*Node) Members

func (n *Node) Members() (*signaling.Members, error)

Members ...

func (*Node) Room

func (n *Node) Room() string

Room ...

func (*Node) Send

func (n *Node) Send(dest string, v signaling.Kinder) error

Send ...

func (*Node) Start

func (n *Node) Start(owner bool) error

Start ...

func (*Node) Stop

func (n *Node) Stop() error

Stop ...

func (*Node) User

func (n *Node) User() string

User ...

type Offer

type Offer webrtc.SessionDescription

Offer ...

func (*Offer) Kind

func (c *Offer) Kind() string

Kind ...

type OfferCandidate

type OfferCandidate webrtc.IceCandidate

OfferCandidate ...

func (*OfferCandidate) Kind

func (c *OfferCandidate) Kind() string

Kind ...

type OfferCompleted

type OfferCompleted struct{}

OfferCompleted ...

func (*OfferCompleted) Kind

func (c *OfferCompleted) Kind() string

Kind ...

type OfferFailed

type OfferFailed struct{}

OfferFailed ...

func (*OfferFailed) Kind

func (c *OfferFailed) Kind() string

Kind ...