source

Documentation

Index

• Constants
• Variables
• type SDKSource
  • func NewSDKSource(ctx context.Context, p *params.Params) (*SDKSource, error)
  • func (s *SDKSource) Close()
  • func (s *SDKSource) EndRecording() chan struct{}
  • func (s *SDKSource) GetAudioSource() (*app.Source, webrtc.RTPCodecParameters)
  • func (s *SDKSource) GetEndTime() int64
  • func (s *SDKSource) GetStartTime() int64
  • func (s *SDKSource) GetVideoSource() (*app.Source, webrtc.RTPCodecParameters)
  • func (s *SDKSource) Playing(name string)
  • func (s *SDKSource) SendEOS()
  • func (s *SDKSource) StartRecording() chan struct{}
• type Source
• type WebSource
  • func NewWebSource(ctx context.Context, conf *config.Config, p *params.Params) (*WebSource, error)
  • func (s *WebSource) Close()
  • func (s *WebSource) EndRecording() chan struct{}
  • func (s *WebSource) StartRecording() chan struct{}

Constants

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

Variables

var (
	VP8KeyFrame16x16 = []byte{0x10, 0x02, 0x00, 0x9d, 0x01, 0x2a, 0x10, 0x00, 0x10, 0x00, 0x00, 0x47, 0x08, 0x85, 0x85, 0x88, 0x85, 0x84, 0x88, 0x02, 0x02, 0x00, 0x0c, 0x0d, 0x60, 0x00, 0xfe, 0xff, 0xab, 0x50, 0x80}

	H264KeyFrame2x2SPS = []byte{0x67, 0x42, 0xc0, 0x1f, 0x0f, 0xd9, 0x1f, 0x88, 0x88, 0x84, 0x00, 0x00, 0x03, 0x00, 0x04, 0x00, 0x00, 0x03, 0x00, 0xc8, 0x3c, 0x60, 0xc9, 0x20}
	H264KeyFrame2x2PPS = []byte{0x68, 0x87, 0xcb, 0x83, 0xcb, 0x20}
	H264KeyFrame2x2IDR = []byte{0x65, 0x88, 0x84, 0x0a, 0xf2, 0x62, 0x80, 0x00, 0xa7, 0xbe}

	H264KeyFrame2x2 = [][]byte{H264KeyFrame2x2SPS, H264KeyFrame2x2PPS, H264KeyFrame2x2IDR}
)

Types

type SDKSource

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

func NewSDKSource

func NewSDKSource(ctx context.Context, p *params.Params) (*SDKSource, error)

func (*SDKSource) Close

func (s *SDKSource) Close()

func (*SDKSource) EndRecording

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

func (*SDKSource) GetAudioSource

func (s *SDKSource) GetAudioSource() (*app.Source, webrtc.RTPCodecParameters)

func (*SDKSource) GetEndTime

func (s *SDKSource) GetEndTime() int64

func (*SDKSource) GetStartTime

func (s *SDKSource) GetStartTime() int64

func (*SDKSource) GetVideoSource

func (s *SDKSource) GetVideoSource() (*app.Source, webrtc.RTPCodecParameters)

func (*SDKSource) Playing

func (s *SDKSource) Playing(name string)

func (*SDKSource) SendEOS

func (s *SDKSource) SendEOS()

func (*SDKSource) StartRecording

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

type Source

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

type WebSource

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

func NewWebSource

func NewWebSource(ctx context.Context, conf *config.Config, p *params.Params) (*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{}