source

Documentation

Index

• Constants
• type SDKSource
  • func NewSDKSource(ctx context.Context, p *config.PipelineConfig) (*SDKSource, error)
  • func (s *SDKSource) Close()
  • func (s *SDKSource) CloseWriters()
  • func (s *SDKSource) EndRecording() chan struct{}
  • func (s *SDKSource) GetEndTime() int64
  • func (s *SDKSource) GetStartTime() int64
  • func (s *SDKSource) OnTrackMuted(onTrackMuted func(bool))
  • func (s *SDKSource) Playing(name string)
  • func (s *SDKSource) StartRecording() chan struct{}
  • func (s *SDKSource) StreamStopped(name string)
• type Source
  • func New(ctx context.Context, p *config.PipelineConfig) (Source, error)
• type WebSource
  • func NewWebSource(ctx context.Context, p *config.PipelineConfig) (*WebSource, error)
  • func (s *WebSource) Close()
  • func (s *WebSource) EndRecording() chan struct{}
  • func (s *WebSource) StartRecording() chan struct{}

Constants

const (
	AudioAppSource = "audioAppSrc"
	VideoAppSource = "videoAppSrc"
)

Types

type SDKSource

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

func NewSDKSource

func NewSDKSource(ctx context.Context, p *config.PipelineConfig) (*SDKSource, error)

func (*SDKSource) Close

func (s *SDKSource) Close()

func (*SDKSource) CloseWriters

func (s *SDKSource) CloseWriters()

func (*SDKSource) EndRecording

func (s *SDKSource) EndRecording() chan struct{}

func (*SDKSource) GetEndTime

func (s *SDKSource) GetEndTime() int64

func (*SDKSource) GetStartTime

func (s *SDKSource) GetStartTime() int64

func (*SDKSource) OnTrackMuted

func (s *SDKSource) OnTrackMuted(onTrackMuted func(bool))

func (*SDKSource) Playing

func (s *SDKSource) Playing(name string)

func (*SDKSource) StartRecording

func (s *SDKSource) StartRecording() chan struct{}

func (*SDKSource) StreamStopped

func (s *SDKSource) StreamStopped(name string)

type Source

type Source interface {
	StartRecording() chan struct{}
	EndRecording() chan struct{}
	Close()
}

func New

func New(ctx context.Context, p *config.PipelineConfig) (Source, error)

type WebSource

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

func NewWebSource

func NewWebSource(ctx context.Context, p *config.PipelineConfig) (*WebSource, error)

func (*WebSource) Close

func (s *WebSource) Close()

func (*WebSource) EndRecording

func (s *WebSource) EndRecording() chan struct{}

func (*WebSource) StartRecording

func (s *WebSource) StartRecording() chan struct{}