sink

Documentation

Index

• func CreateSinks(p *config.PipelineConfig, callbacks *gstreamer.Callbacks) (map[types.EgressType][]Sink, error)
• type FileSink
  • func (s *FileSink) Cleanup()
  • func (s *FileSink) Close() error
  • func (s *FileSink) Start() error
• type Image
• type ImageManifest
• type ImageSink
  • func (s *ImageSink) Cleanup()
  • func (s *ImageSink) Close() error
  • func (s *ImageSink) NewImage(filepath string, ts uint64) error
  • func (s *ImageSink) Start() error
• type Manifest
• type SegmentSink
  • func (s *SegmentSink) Cleanup()
  • 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)
• type SegmentUpdate
• type Sink
• type WebsocketSink
  • func (s *WebsocketSink) Cleanup()
  • func (s *WebsocketSink) Close() error
  • func (s *WebsocketSink) OnTrackMuted(_ string)
  • func (s *WebsocketSink) OnTrackUnmuted(_ string, _ time.Duration)
  • func (s *WebsocketSink) SinkCallbacks() *app.SinkCallbacks
  • func (s *WebsocketSink) Start() error
  • func (s *WebsocketSink) Write(p []byte) (int, error)

Functions

func CreateSinks

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

Types

type FileSink

type FileSink struct {
	uploader.Uploader

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

func (*FileSink) Cleanup

func (s *FileSink) Cleanup()

func (*FileSink) Close

func (s *FileSink) Close() error

func (*FileSink) Start

func (s *FileSink) Start() error

type Image

type Image struct {
	Name      string    `json:"name"`
	Timestamp time.Time `json:"timestamp"`
	Size      int64     `json:"size"`
}

type ImageManifest

type ImageManifest struct {
	Manifest `json:",inline"`

	Images []*Image `json:"images"`
}

type ImageSink

type ImageSink struct {
	uploader.Uploader

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

func (*ImageSink) Cleanup

func (s *ImageSink) Cleanup()

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

type Manifest

type Manifest struct {
	EgressID          string `json:"egress_id,omitempty"`
	RoomID            string `json:"room_id,omitempty"`
	RoomName          string `json:"room_name,omitempty"`
	Url               string `json:"url,omitempty"`
	StartedAt         int64  `json:"started_at,omitempty"`
	EndedAt           int64  `json:"ended_at,omitempty"`
	PublisherIdentity string `json:"publisher_identity,omitempty"`
	TrackID           string `json:"track_id,omitempty"`
	TrackKind         string `json:"track_kind,omitempty"`
	TrackSource       string `json:"track_source,omitempty"`
	AudioTrackID      string `json:"audio_track_id,omitempty"`
	VideoTrackID      string `json:"video_track_id,omitempty"`
	SegmentCount      int64  `json:"segment_count,omitempty"`
}

type SegmentSink

type SegmentSink struct {
	uploader.Uploader

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

func (*SegmentSink) Cleanup

func (s *SegmentSink) Cleanup()

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)

type SegmentUpdate

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

type Sink

type Sink interface {
	Start() error
	Close() error
	Cleanup()
}

type WebsocketSink

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

func (*WebsocketSink) Cleanup

func (s *WebsocketSink) Cleanup()

func (*WebsocketSink) Close

func (s *WebsocketSink) Close() error

func (*WebsocketSink) OnTrackMuted

func (s *WebsocketSink) OnTrackMuted(_ string)

func (*WebsocketSink) OnTrackUnmuted

func (s *WebsocketSink) OnTrackUnmuted(_ string, _ time.Duration)

func (*WebsocketSink) SinkCallbacks

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

func (*WebsocketSink) Start

func (s *WebsocketSink) Start() error

func (*WebsocketSink) Write

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