webrtc_transport

package
v0.0.0-...-27c307a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 4, 2022 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	GatherTimeoutError                = fmt.Errorf("gather timeout")
	WaitDataChannelOpenedTimeoutError = fmt.Errorf("wait data channel opened timeout")
)

Functions

func AsAnswerer

func AsAnswerer() transport.NewTransportOption

func AsOfferer

func AsOfferer() transport.NewTransportOption

func NewWebrtcTransport

func NewWebrtcTransport(opts ...transport.NewTransportOption) (transport.Transport, error)

func UnsupportedRoleError

func UnsupportedRoleError(name string) error

func WithAnswerHook

func WithAnswerHook(answerHook AnswerHook) transport.NewTransportOption

func WithICEServers

func WithICEServers(iceServers []string) transport.NewTransportOption

func WithOffer

func WithOffer(offer *webrtc.SessionDescription) transport.NewTransportOption

func WithOfferHook

func WithOfferHook(offerHook OfferHook) transport.NewTransportOption

func WithWebrtcAPI

func WithWebrtcAPI(api *webrtc.API) transport.NewTransportOption

Types

type AnswerHook

type AnswerHook func(*webrtc.SessionDescription, error)

type OfferHook

type OfferHook func(*webrtc.SessionDescription) (*webrtc.SessionDescription, error)

type WebrtcDataChannel

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

func NewWebrtcDataChannel

func NewWebrtcDataChannel(logger logrus.FieldLogger, dc *webrtc.DataChannel, tp *WebrtcTransport) *WebrtcDataChannel

func (*WebrtcDataChannel) Close

func (wdc *WebrtcDataChannel) Close() error

func (*WebrtcDataChannel) Label

func (wdc *WebrtcDataChannel) Label() string

func (*WebrtcDataChannel) OnOpen

func (wdc *WebrtcDataChannel) OnOpen(f func())

func (*WebrtcDataChannel) Read

func (wdc *WebrtcDataChannel) Read(p []byte) (int, error)

func (*WebrtcDataChannel) State

func (*WebrtcDataChannel) Transport

func (wdc *WebrtcDataChannel) Transport() transport.Transport

func (*WebrtcDataChannel) Write

func (wdc *WebrtcDataChannel) Write(p []byte) (int, error)

type WebrtcTransport

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

func (*WebrtcTransport) Close

func (wt *WebrtcTransport) Close() error

func (*WebrtcTransport) CreateDataChannel

func (wt *WebrtcTransport) CreateDataChannel(label string, opts ...transport.CreateDataChannelOption) (transport.DataChannel, error)

func (*WebrtcTransport) DataChannel

func (wt *WebrtcTransport) DataChannel(label string) (transport.DataChannel, error)

func (*WebrtcTransport) DataChannels

func (wt *WebrtcTransport) DataChannels() ([]transport.DataChannel, error)

func (*WebrtcTransport) Err

func (wt *WebrtcTransport) Err() error

func (*WebrtcTransport) OnDataChannelCreate

func (wt *WebrtcTransport) OnDataChannelCreate(label string, h func(transport.DataChannel))

func (*WebrtcTransport) OnTransportState

func (wt *WebrtcTransport) OnTransportState(s transport.TransportState, f func(transport.HandleID)) transport.HandleID

func (*WebrtcTransport) OnTransportStateChange

func (wt *WebrtcTransport) OnTransportStateChange(f func(transport.TransportState))

func (*WebrtcTransport) PeerID

func (wt *WebrtcTransport) PeerID() string

func (*WebrtcTransport) TransportState

func (wt *WebrtcTransport) TransportState() transport.TransportState

func (*WebrtcTransport) UnsetOnTransportState

func (wt *WebrtcTransport) UnsetOnTransportState(s transport.TransportState, hid transport.HandleID)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL