sink

Documentation

Index

• func CreateSinks(p *config.PipelineConfig, callbacks *gstreamer.Callbacks, ...) (map[types.EgressType][]Sink, error)
• type FileSink
  • func (s *FileSink) Close() error
  • func (s *FileSink) Start() error
  • func (s *FileSink) UploadManifest(filepath string) (string, bool, error)
• type ImageSink
  • func (s *ImageSink) Close() error
  • func (s *ImageSink) NewImage(filepath string, ts uint64) error
  • func (s *ImageSink) Start() error
  • func (s *ImageSink) UploadManifest(filepath string) (string, bool, error)
• type SegmentSink
  • func (s *SegmentSink) Close() error
  • func (s *SegmentSink) FragmentClosed(filepath string, endTime uint64) error
  • func (s *SegmentSink) FragmentOpened(filepath string, startTime uint64) error
  • func (s *SegmentSink) Start() error
  • func (s *SegmentSink) UpdateStartDate(t time.Time)
  • func (s *SegmentSink) UploadManifest(filepath string) (string, bool, error)
• type SegmentUpdate
• type Sink
• type WebsocketSink
  • func (s *WebsocketSink) Close() error
  • func (s *WebsocketSink) OnTrackMuted(_ string)
  • func (s *WebsocketSink) OnTrackUnmuted(_ string)
  • func (s *WebsocketSink) SinkCallbacks() *app.SinkCallbacks
  • func (s *WebsocketSink) Start() error
  • func (s *WebsocketSink) UploadManifest(_ string) (string, bool, error)
  • func (s *WebsocketSink) Write(p []byte) (int, error)

Functions

func CreateSinks

func CreateSinks(p *config.PipelineConfig, callbacks *gstreamer.Callbacks, monitor *stats.HandlerMonitor) (map[types.EgressType][]Sink, error)

Types

type FileSink

type FileSink struct {
	*uploader.Uploader

	*config.FileConfig
	// contains filtered or unexported fields
}

func (*FileSink) Close

func (s *FileSink) Close() error

func (*FileSink) Start

func (s *FileSink) Start() error

func (*FileSink) UploadManifest

func (s *FileSink) UploadManifest(filepath string) (string, bool, error)

type ImageSink

type ImageSink struct {
	*uploader.Uploader

	*config.ImageConfig
	// contains filtered or unexported fields
}

func (*ImageSink) Close

func (s *ImageSink) Close() error

func (*ImageSink) NewImage

func (s *ImageSink) NewImage(filepath string, ts uint64) error

func (*ImageSink) Start

func (s *ImageSink) Start() error

func (*ImageSink) UploadManifest

func (s *ImageSink) UploadManifest(filepath string) (string, bool, error)

type SegmentSink

type SegmentSink struct {
	*uploader.Uploader

	*config.SegmentConfig
	// contains filtered or unexported fields
}

func (*SegmentSink) Close

func (s *SegmentSink) Close() error

func (*SegmentSink) FragmentClosed

func (s *SegmentSink) FragmentClosed(filepath string, endTime uint64) error

func (*SegmentSink) FragmentOpened

func (s *SegmentSink) FragmentOpened(filepath string, startTime uint64) error

func (*SegmentSink) Start

func (s *SegmentSink) Start() error

func (*SegmentSink) UpdateStartDate

func (s *SegmentSink) UpdateStartDate(t time.Time)

func (*SegmentSink) UploadManifest

func (s *SegmentSink) UploadManifest(filepath string) (string, bool, error)

type SegmentUpdate

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

type Sink

type Sink interface {
	Start() error
	Close() error
	UploadManifest(string) (string, bool, error)
}

type WebsocketSink

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

func (*WebsocketSink) Close

func (s *WebsocketSink) Close() error

func (*WebsocketSink) OnTrackMuted

func (s *WebsocketSink) OnTrackMuted(_ string)

func (*WebsocketSink) OnTrackUnmuted

func (s *WebsocketSink) OnTrackUnmuted(_ string)

func (*WebsocketSink) SinkCallbacks

func (s *WebsocketSink) SinkCallbacks() *app.SinkCallbacks

func (*WebsocketSink) Start

func (s *WebsocketSink) Start() error

func (*WebsocketSink) UploadManifest

func (s *WebsocketSink) UploadManifest(_ string) (string, bool, error)

func (*WebsocketSink) Write

func (s *WebsocketSink) Write(p []byte) (int, error)