worker

Jul 16, 2023

Changes in this version

type PeerWorker

+ func (w *PeerWorker) Error(v string)

+ func (w *PeerWorker) Info(v string)

+ func (w *PeerWorker) Stack(v ...string)

+ func (w *PeerWorker) Warn(v string)

Jul 4, 2023

Changes in this version

+ type PeerWorker struct

+ func (w *PeerWorker) AddAudioFwd(trackID *string)

+ func (w *PeerWorker) AddConnection(signalID *string, configs *peer.Configs, ...) (peer.Connection, error)

+ func (w *PeerWorker) AddConnections(signalID *string)

+ func (w *PeerWorker) AddDCConnection(signalID *string, configs *peer.Configs, ...) (peer.Connection, error)

+ func (w *PeerWorker) AddUpList(peerConnectionID *string, c *UpPeer)

+ func (w *PeerWorker) AddVideoFwd(trackID *string)

+ func (w *PeerWorker) AppendUpList(pcID *string, obj *UpPeer)

+ func (w *PeerWorker) DeleteUpList(peerConnectionID *string)

+ func (w *PeerWorker) GetAllConnectionID() map[string][]string

+ func (w *PeerWorker) GetAudioReceiveTime() map[string]int64

+ func (w *PeerWorker) GetAudioReceiveTimeby(trackID string) int64

+ func (w *PeerWorker) GetConnection(signalID, peerConnectionID *string) (peer.Connection, error)

+ func (w *PeerWorker) GetConnections(signalID *string) peer.Connections

+ func (w *PeerWorker) GetRemoteTrack(trackID *string) *webrtc.TrackRemote

+ func (w *PeerWorker) GetStates() map[string]string

+ func (w *PeerWorker) GetTrackMeta(trackID string) bool

+ func (w *PeerWorker) GetVideoReceiveTime() map[string]int64

+ func (w *PeerWorker) GetVideoReceiveTimeby(trackID string) int64

+ func (w *PeerWorker) Register(signalID, peerConnectionID *string, videoTrackIDs, audioTrackIDs []string, ...) error

+ func (w *PeerWorker) RegisterAudio(signalID, audioTrackID, peerConnectionID *string, ...) error

+ func (w *PeerWorker) RegisterVideo(signalID, videoTrackID, peerConnectionID *string, ...) error

+ func (w *PeerWorker) RemoveConnection(signalID, peerConnectionID, cookieID *string) error

+ func (w *PeerWorker) RemoveConnections(signalID *string)

+ func (w *PeerWorker) SetHandleNoConnection(handler func(signalID *string))

+ func (w *PeerWorker) SetHandleReadDeadline(f func(pcID, trackID *string, codec, kind string))

+ func (w *PeerWorker) SetTrackMeta(trackID string, state bool)

+ func (w *PeerWorker) SetUpList(lst map[string]*UpPeer)

+ func (w *PeerWorker) Start() error

+ func (w *PeerWorker) UnRegister(peerConnectionID *string)

+ func (w *PeerWorker) UnRegisterAudio(peerConnectionID, audioTrackID *string)

+ func (w *PeerWorker) UnRegisterVideo(peerConnectionID, videoTrackID *string)

+ type UpPeer struct

+ func (u *UpPeer) GetAudioArr() []string

+ func (u *UpPeer) GetAudioList() map[string]string

+ func (u *UpPeer) GetVideoArr() []string

+ func (u *UpPeer) GetVideoList() map[string]string

+ func (u *UpPeer) SetAudioList(arr map[string]string)

+ func (u *UpPeer) SetVideoList(arr map[string]string)

+ type Worker interface

+ AddAudioFwd func(trackID *string)

+ AddConnection func(signalID *string, configs *peer.Configs, ...) (peer.Connection, error)

+ AddConnections func(signalID *string)

+ AddDCConnection func(signalID *string, configs *peer.Configs, ...) (peer.Connection, error)

+ AddUpList func(peerConnectionID *string, c *UpPeer)

+ AddVideoFwd func(trackID *string)

+ AppendUpList func(pcID *string, obj *UpPeer)

+ DeleteUpList func(peerConnectionID *string)

+ GetAllConnectionID func() map[string][]string

+ GetAudioReceiveTime func() map[string]int64

+ GetAudioReceiveTimeby func(trackID string) int64

+ GetConnection func(signalID, peerConnectionID *string) (peer.Connection, error)

+ GetConnections func(signalID *string) peer.Connections

+ GetRemoteTrack func(trackID *string) *webrtc.TrackRemote

+ GetStates func() map[string]string

+ GetTrackMeta func(trackID string) bool

+ GetVideoReceiveTime func() map[string]int64

+ GetVideoReceiveTimeby func(trackID string) int64

+ Register func(signalID, peerConnectionID *string, videoTrackIDs, audioTrackIDs []string, ...) error

+ RegisterAudio func(signalID, audioTrackID, peerConnectionID *string, ...) error

+ RegisterVideo func(signalID, videoTrackID, peerConnectionID *string, ...) error

+ RemoveConnection func(signalID, peerConnectionID, cookieID *string) error

+ RemoveConnections func(signalID *string)

+ SetHandleNoConnection func(handler func(signalID *string))

+ SetHandleReadDeadline func(f func(pcID, trackID *string, codec, kind string))

+ SetTrackMeta func(trackID string, state bool)

+ SetUpList func(lst map[string]*UpPeer)

+ Start func() error

+ UnRegister func(peerConnectionID *string)

+ UnRegisterAudio func(peerConnectionID, trackID *string)

+ UnRegisterVideo func(peerConnectionID, trackID *string)

+ func NewPeerWorker(id *string, upList map[string]*UpPeer) Worker