domain

Documentation

Index

• Variables
• type BroadcastCreate
• type BroadcastEvent
• type BroadcastSession
  • func (b *BroadcastSession) AddViewer(viewer *Viewer)
  • func (b *BroadcastSession) Close(cause error)
  • func (b *BroadcastSession) ContextClose() <-chan struct{}
  • func (b *BroadcastSession) ListenEvent() <-chan BroadcastEvent
  • func (b *BroadcastSession) MakeRTCConnection(config *config.Config)
  • func (b *BroadcastSession) RemoveViewer(viewer *Viewer)
  • func (b *BroadcastSession) SendEvent(event BroadcastEvent)
  • func (b *BroadcastSession) SendEventToViewers(event ViewerEvent)
  • func (b *BroadcastSession) SetTrack(trackChan <-chan *webrtc.TrackLocalStaticRTP)
• type BroadcastUpdate
• type BroadcastsRepository
• type BroadcastsUsecases
• type Viewer
  • func (v *Viewer) Close(cause error)
  • func (v *Viewer) ContextClose() <-chan struct{}
  • func (v *Viewer) HandleViewer(track *webrtc.TrackLocalStaticRTP, config *config.Config)
  • func (v *Viewer) ListenEvent() <-chan ViewerEvent
  • func (v *Viewer) SendEvent(event ViewerEvent)
• type ViewerCreate
• type ViewerEvent

Variables

var (
	ErrUnknown               = errors.New("unknown error")
	ErrBroadcastNotFound     = errors.New("broadcast not found")
	ErrBroadcastInvalidEvent = errors.New("broadcast invalid event")

	ErrViewerNotFound = errors.New("viewer not found")
)

Types

type BroadcastCreate

type BroadcastCreate struct {
	Title string
}

type BroadcastEvent

type BroadcastEvent struct {
	Response chan<- string
	Data     any
	Event    string
}

type BroadcastSession

type BroadcastSession struct {
	Track    *webrtc.TrackLocalStaticRTP
	Viewers  map[*Viewer]struct{}
	EventOut chan BroadcastEvent
	EventIn  chan BroadcastEvent

	ID    string
	Title string
	// contains filtered or unexported fields
}

func (*BroadcastSession) AddViewer

func (b *BroadcastSession) AddViewer(viewer *Viewer)

func (*BroadcastSession) Close

func (b *BroadcastSession) Close(cause error)

func (*BroadcastSession) ContextClose

func (b *BroadcastSession) ContextClose() <-chan struct{}

func (*BroadcastSession) ListenEvent

func (b *BroadcastSession) ListenEvent() <-chan BroadcastEvent

func (*BroadcastSession) MakeRTCConnection

func (b *BroadcastSession) MakeRTCConnection(config *config.Config)

func (*BroadcastSession) RemoveViewer

func (b *BroadcastSession) RemoveViewer(viewer *Viewer)

func (*BroadcastSession) SendEvent

func (b *BroadcastSession) SendEvent(event BroadcastEvent)

func (*BroadcastSession) SendEventToViewers

func (b *BroadcastSession) SendEventToViewers(event ViewerEvent)

func (*BroadcastSession) SetTrack

func (b *BroadcastSession) SetTrack(trackChan <-chan *webrtc.TrackLocalStaticRTP)

type BroadcastUpdate

type BroadcastUpdate struct {
	Title string
}

type BroadcastsRepository

type BroadcastsRepository interface {
	GetBroadcast(id string) (*BroadcastSession, error)
	GetBroadcasts() ([]*BroadcastSession, error)
	CreateBroadcast(broadcast BroadcastCreate) (*BroadcastSession, error)
	UpdateBroadcast(id string, broadcast BroadcastUpdate) (*BroadcastSession, error)
	DeleteBroadcast(id string) error

	// Viewer related repository methods
	GetViewer(id string) (*Viewer, error)
	CreateViewer(viewer ViewerCreate) (*Viewer, error)
	DeleteViewer(id string) error
}

type BroadcastsUsecases

type BroadcastsUsecases interface {
	Get(id string) (*BroadcastSession, error)
	GetBroadcasts() ([]*BroadcastSession, error)
	Create(broadcastTitle string) (*BroadcastSession, error)
	SaveICECandidate(id string, candidate any) error
	SaveOffer(id, sdp string) (string, error)
	Delete(id string) error

	// Viewer related use cases
	Connect(broadcastId string) (*Viewer, error)
	SaveViewerICECandidate(broadcastId string, candidate any) error
	SaveViewerOffer(broadcastId, sdp string) (string, error)
	DeleteViewer(viewerId string) error
}

FIXME: Use cases should receive a context.Context to handle timeouts and cancellations.

type Viewer

type Viewer struct {
	EventOut chan ViewerEvent
	EventIn  chan ViewerEvent

	BroadcastID string
	ID          string
	// contains filtered or unexported fields
}

func (*Viewer) Close

func (v *Viewer) Close(cause error)

func (*Viewer) ContextClose

func (v *Viewer) ContextClose() <-chan struct{}

func (*Viewer) HandleViewer

func (v *Viewer) HandleViewer(track *webrtc.TrackLocalStaticRTP, config *config.Config)

func (*Viewer) ListenEvent

func (v *Viewer) ListenEvent() <-chan ViewerEvent

func (*Viewer) SendEvent

func (v *Viewer) SendEvent(event ViewerEvent)

type ViewerCreate

type ViewerCreate struct {
	BroadcastID string
}

type ViewerEvent

type ViewerEvent struct {
	Response chan<- string
	Data     any
	Event    string
}