output

Documentation

Index

• type Bin
  • func New(ctx context.Context, pipeline *gst.Pipeline, p *config.PipelineConfig) (*Bin, error)
  • func (b *Bin) AddStream(url string) error
  • func (b *Bin) GetStreamUrl(name string) (string, error)
  • func (b *Bin) Link(audioSrc, videoSrc *gst.GhostPad) error
  • func (b *Bin) RemoveStream(url string) error
  • func (b *Bin) SetWebsocketSink(writer *sink.WebsocketSink) error
• type FileOutput
  • func (b FileOutput) CreateGhostPads() (audioPad, videoPad *gst.GhostPad)
  • func (o *FileOutput) Link() error
  • func (b FileOutput) LinkTees(audioTee, videoTee *gst.Element) error
• type FirstSampleMetadata
• type SegmentOutput
  • func (b SegmentOutput) CreateGhostPads() (audioPad, videoPad *gst.GhostPad)
  • func (o *SegmentOutput) Link() error
  • func (b SegmentOutput) LinkTees(audioTee, videoTee *gst.Element) error
• type StreamOutput
  • func (o *StreamOutput) AddSink(bin *gst.Bin, url string) error
  • func (b StreamOutput) CreateGhostPads() (audioPad, videoPad *gst.GhostPad)
  • func (o *StreamOutput) GetUrl(name string) (string, error)
  • func (o *StreamOutput) Link() error
  • func (b StreamOutput) LinkTees(audioTee, videoTee *gst.Element) error
  • func (o *StreamOutput) RemoveSink(bin *gst.Bin, url string) error
• type WebsocketOutput
  • func (b WebsocketOutput) CreateGhostPads() (audioPad, videoPad *gst.GhostPad)
  • func (o *WebsocketOutput) Link() error
  • func (b WebsocketOutput) LinkTees(audioTee, videoTee *gst.Element) error
  • func (o *WebsocketOutput) SetSink(writer *sink.WebsocketSink)

Types

type Bin

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

func New

func New(ctx context.Context, pipeline *gst.Pipeline, p *config.PipelineConfig) (*Bin, error)

func (*Bin) AddStream

func (b *Bin) AddStream(url string) error

func (*Bin) GetStreamUrl

func (b *Bin) GetStreamUrl(name string) (string, error)

func (*Bin) Link

func (b *Bin) Link(audioSrc, videoSrc *gst.GhostPad) error

func (*Bin) RemoveStream

func (b *Bin) RemoveStream(url string) error

func (*Bin) SetWebsocketSink

func (b *Bin) SetWebsocketSink(writer *sink.WebsocketSink) error

type FileOutput

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

func (FileOutput) CreateGhostPads

func (b FileOutput) CreateGhostPads() (audioPad, videoPad *gst.GhostPad)

func (*FileOutput) Link

func (o *FileOutput) Link() error

func (FileOutput) LinkTees

func (b FileOutput) LinkTees(audioTee, videoTee *gst.Element) error

type FirstSampleMetadata

type FirstSampleMetadata struct {
	StartDate int64 // Real time date of the first media sample
}

type SegmentOutput

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

func (SegmentOutput) CreateGhostPads

func (b SegmentOutput) CreateGhostPads() (audioPad, videoPad *gst.GhostPad)

func (*SegmentOutput) Link

func (o *SegmentOutput) Link() error

func (SegmentOutput) LinkTees

func (b SegmentOutput) LinkTees(audioTee, videoTee *gst.Element) error

type StreamOutput

type StreamOutput struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*StreamOutput) AddSink

func (o *StreamOutput) AddSink(bin *gst.Bin, url string) error

func (StreamOutput) CreateGhostPads

func (b StreamOutput) CreateGhostPads() (audioPad, videoPad *gst.GhostPad)

func (*StreamOutput) GetUrl

func (o *StreamOutput) GetUrl(name string) (string, error)

func (*StreamOutput) Link

func (o *StreamOutput) Link() error

func (StreamOutput) LinkTees

func (b StreamOutput) LinkTees(audioTee, videoTee *gst.Element) error

func (*StreamOutput) RemoveSink

func (o *StreamOutput) RemoveSink(bin *gst.Bin, url string) error

type WebsocketOutput

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

func (WebsocketOutput) CreateGhostPads

func (b WebsocketOutput) CreateGhostPads() (audioPad, videoPad *gst.GhostPad)

func (*WebsocketOutput) Link

func (o *WebsocketOutput) Link() error

func (WebsocketOutput) LinkTees

func (b WebsocketOutput) LinkTees(audioTee, videoTee *gst.Element) error

func (*WebsocketOutput) SetSink

func (o *WebsocketOutput) SetSink(writer *sink.WebsocketSink)