mocks

Documentation

Index

• Constants
• Variables
• type LobbyManagerMock
  • func NewLobbyManager() *LobbyManagerMock
  • func (m *LobbyManagerMock) CloseLobbyHostPipe(ctx context.Context, u uuid.UUID, id uuid.UUID) (bool, error)
  • func (m *LobbyManagerMock) CreateLobbyHostIngress(_ context.Context, _ uuid.UUID, _ *webrtc.SessionDescription, _ uuid.UUID) (struct{ ... }, error)
  • func (m *LobbyManagerMock) CreateLobbyHostPipe(ctx context.Context, u uuid.UUID, offer *webrtc.SessionDescription, ...) (struct{ ... }, error)
  • func (l *LobbyManagerMock) CreateLobbyIngressEndpoint(_ context.Context, _ uuid.UUID, _ uuid.UUID, _ *webrtc.SessionDescription) (struct{ ... }, error)
  • func (l *LobbyManagerMock) CreateMainStreamLobbyEgressEndpoint(_ context.Context, _ uuid.UUID, _ uuid.UUID, _ *webrtc.SessionDescription) (struct{ ... }, error)
  • func (l *LobbyManagerMock) FinalCreateLobbyEgressEndpoint(_ context.Context, _ uuid.UUID, _ uuid.UUID, _ *webrtc.SessionDescription) (struct{ ... }, error)
  • func (l *LobbyManagerMock) InitLobbyEgressEndpoint(_ context.Context, _ uuid.UUID, _ uuid.UUID) (struct{ ... }, error)
  • func (l *LobbyManagerMock) LeaveLobby(ctx context.Context, liveStreamId uuid.UUID, userId uuid.UUID) (bool, error)
  • func (l *LobbyManagerMock) NewEgressResource(_ context.Context, _ uuid.UUID, _ uuid.UUID, _ *webrtc.SessionDescription, ...) (*resources.WebRTC, error)
  • func (l *LobbyManagerMock) NewIngressResource(_ context.Context, _ uuid.UUID, _ uuid.UUID, _ *webrtc.SessionDescription, ...) (*resources.WebRTC, error)
  • func (l *LobbyManagerMock) StartLiveStream(ctx context.Context, liveStreamId uuid.UUID, key string, rtmpUrl string, ...) error
  • func (m *LobbyManagerMock) StopLiveStream(ctx context.Context, liveStreamId uuid.UUID, userId uuid.UUID) error

Constants

const (
	Bearer              = "" /* 199-byte string literal not displayed */
	SpaceId             = "abc123"
	ResourceID          = "152cca71-7156-455b-8b30-a90a4bf8f772"
	RtpSessionId        = "dac0039e-947a-4d22-8207-4e81a5cdcf19"
	ReqTokenHeaderName  = "X-Req-Token"
	CsrfTokenHeaderName = "X-Csrf-Token"
	Offer               = "" /* 1324-byte string literal not displayed */
	Answer              = "" /* 1390-byte string literal not displayed */
	AnswerETag          = "38ee2e1fc076df403ff93ea9b18f97d8"
)

Variables

var (
	SecurityConfig = &auth.SecurityConfig{JWT: JWT, TrustedOrigins: []string{"*"}}
	RtpConfig      = &rtp.RtpConfig{ICEServer: []rtp.ICEServer{{Urls: []string{"stun:stun.l.google.com:19302"}}}}
	JWT            = &auth.JwtToken{Enabled: true, Key: "SecretValueReplaceThis", DefaultExpireTime: 604800}
)

Types

type LobbyManagerMock

type LobbyManagerMock struct {
}

func NewLobbyManager

func NewLobbyManager() *LobbyManagerMock

func (*LobbyManagerMock) CloseLobbyHostPipe

func (m *LobbyManagerMock) CloseLobbyHostPipe(ctx context.Context, u uuid.UUID, id uuid.UUID) (bool, error)

func (*LobbyManagerMock) CreateLobbyHostIngress

func (m *LobbyManagerMock) CreateLobbyHostIngress(_ context.Context, _ uuid.UUID, _ *webrtc.SessionDescription, _ uuid.UUID) (struct {
	Answer       *webrtc.SessionDescription
	Resource     uuid.UUID
	RtpSessionId uuid.UUID
}, error)

func (*LobbyManagerMock) CreateLobbyHostPipe

func (m *LobbyManagerMock) CreateLobbyHostPipe(ctx context.Context, u uuid.UUID, offer *webrtc.SessionDescription, instanceId uuid.UUID) (struct {
	Answer       *webrtc.SessionDescription
	Resource     uuid.UUID
	RtpSessionId uuid.UUID
}, error)

func (*LobbyManagerMock) CreateLobbyIngressEndpoint

func (l *LobbyManagerMock) CreateLobbyIngressEndpoint(_ context.Context, _ uuid.UUID, _ uuid.UUID, _ *webrtc.SessionDescription) (struct {
	Answer       *webrtc.SessionDescription
	Resource     uuid.UUID
	RtpSessionId uuid.UUID
}, error)

old API

func (*LobbyManagerMock) CreateMainStreamLobbyEgressEndpoint

func (l *LobbyManagerMock) CreateMainStreamLobbyEgressEndpoint(_ context.Context, _ uuid.UUID, _ uuid.UUID, _ *webrtc.SessionDescription) (struct {
	Answer       *webrtc.SessionDescription
	RtpSessionId uuid.UUID
}, error)

func (*LobbyManagerMock) FinalCreateLobbyEgressEndpoint

func (l *LobbyManagerMock) FinalCreateLobbyEgressEndpoint(_ context.Context, _ uuid.UUID, _ uuid.UUID, _ *webrtc.SessionDescription) (struct {
	Answer       *webrtc.SessionDescription
	Active       bool
	RtpSessionId uuid.UUID
}, error)

func (*LobbyManagerMock) InitLobbyEgressEndpoint

func (l *LobbyManagerMock) InitLobbyEgressEndpoint(_ context.Context, _ uuid.UUID, _ uuid.UUID) (struct {
	Offer        *webrtc.SessionDescription
	Active       bool
	RtpSessionId uuid.UUID
}, error)

func (*LobbyManagerMock) LeaveLobby

func (l *LobbyManagerMock) LeaveLobby(ctx context.Context, liveStreamId uuid.UUID, userId uuid.UUID) (bool, error)

func (*LobbyManagerMock) NewEgressResource

func (l *LobbyManagerMock) NewEgressResource(_ context.Context, _ uuid.UUID, _ uuid.UUID, _ *webrtc.SessionDescription, _ ...resources.Option) (*resources.WebRTC, error)

func (*LobbyManagerMock) NewIngressResource

func (l *LobbyManagerMock) NewIngressResource(_ context.Context, _ uuid.UUID, _ uuid.UUID, _ *webrtc.SessionDescription, _ ...resources.Option) (*resources.WebRTC, error)

func (*LobbyManagerMock) StartLiveStream

func (l *LobbyManagerMock) StartLiveStream(
	ctx context.Context,
	liveStreamId uuid.UUID,
	key string,
	rtmpUrl string,
	userId uuid.UUID,
) error

func (*LobbyManagerMock) StopLiveStream

func (m *LobbyManagerMock) StopLiveStream(
	ctx context.Context,
	liveStreamId uuid.UUID,
	userId uuid.UUID,
) error