clients

Documentation

Index

• type ApiClient
  • func NewApiClient(loginGetter loginGetter, shigUrl string, spaceId string, streamId string) *ApiClient
  • func (a *ApiClient) Login() (*authentication.Token, error)
  • func (a *ApiClient) PostWhepOffer(offer *webrtc.SessionDescription) (*webrtc.SessionDescription, error)
  • func (a *ApiClient) PostWhipOffer(offer *webrtc.SessionDescription) (*webrtc.SessionDescription, error)
• type Messenger
  • func NewMessenger(s msgSender) *Messenger
  • func (m *Messenger) Register(o msgObserver)
  • func (m *Messenger) SendAnswer(sdp *webrtc.SessionDescription, id uint32, number uint32) (uint32, error)
  • func (m *Messenger) SendMute(mute *message.Mute) error
  • func (m *Messenger) SendOffer(offer *webrtc.SessionDescription, number uint32) (uint32, error)

Types

type ApiClient

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

func NewApiClient

func NewApiClient(loginGetter loginGetter, shigUrl string, spaceId string, streamId string) *ApiClient

func (*ApiClient) Login

func (a *ApiClient) Login() (*authentication.Token, error)

func (*ApiClient) PostWhepOffer

func (a *ApiClient) PostWhepOffer(offer *webrtc.SessionDescription) (*webrtc.SessionDescription, error)

func (*ApiClient) PostWhipOffer

func (a *ApiClient) PostWhipOffer(offer *webrtc.SessionDescription) (*webrtc.SessionDescription, error)

type Messenger

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

func NewMessenger

func NewMessenger(s msgSender) *Messenger

func (*Messenger) Register

func (m *Messenger) Register(o msgObserver)

func (*Messenger) SendAnswer

func (m *Messenger) SendAnswer(sdp *webrtc.SessionDescription, id uint32, number uint32) (uint32, error)

func (*Messenger) SendMute

func (m *Messenger) SendMute(mute *message.Mute) error

func (*Messenger) SendOffer

func (m *Messenger) SendOffer(offer *webrtc.SessionDescription, number uint32) (uint32, error)