protoo

Feb 19, 2021

Changes in this version

+ var NewEventEmitter = eventemitter.NewEventEmitter

+ var NewLogger = func(name string) logr.Logger

+ type Error struct

+ ErrorCode int

+ ErrorReason string

+ func NewError(code int, reason string) *Error

+ func (e Error) Error() string

+ type IEventEmitter = eventemitter.IEventEmitter

+ type Message struct

+ Data json.RawMessage

+ Id uint32

+ Method string

+ Notification bool

+ OK bool

+ Request bool

+ Response bool

+ func CreateErrorResponse(request Message, err *Error) Message

+ func CreateNotification(method string, data interface{}) Message

+ func CreateRequest(method string, data interface{}) Message

+ func CreateSuccessResponse(request Message, data interface{}) Message

+ func (m Message) Marshal() []byte

+ func (m Message) String() string

+ type Peer struct

+ func NewPeer(peerId string, data interface{}, transport Transport) *Peer

+ func (peer *Peer) Close()

+ func (peer *Peer) Data() interface{}

+ func (peer *Peer) Id() string

+ func (peer *Peer) Notify(method string, data interface{}) error

+ func (peer *Peer) Request(method string, data interface{}) (rsp PeerResponse)

+ type PeerResponse struct

+ func (r PeerResponse) Data() []byte

+ func (r PeerResponse) Err() error

+ func (r PeerResponse) Unmarshal(v interface{}) error

+ type Room struct

+ func NewRoom() *Room

+ func (r *Room) Close()

+ func (r *Room) Closed() bool

+ func (r *Room) CreatePeer(peerId string, peerData interface{}, transport Transport) (peer *Peer, err error)

+ func (r *Room) GetPeer(peerId string) *Peer

+ func (r *Room) HasPeer(peerId string) bool

+ func (r *Room) Peers() (peers []*Peer)

+ type Transport interface

+ Close func()

+ Closed func() bool

+ Run func() error

+ Send func(data []byte) error