sink

Documentation

Index

• Constants
• func CreateSinks(p *config.PipelineConfig) (map[types.EgressType]Sink, error)
• type FileSink
  • func (s *FileSink) Cleanup()
  • func (s *FileSink) Finalize() error
  • func (s *FileSink) Start() error
• type SegmentSink
  • func (s *SegmentSink) Cleanup()
  • func (s *SegmentSink) EnqueueSegmentUpload(segmentPath string, endTime int64) error
  • func (s *SegmentSink) Finalize() error
  • func (s *SegmentSink) SetOnFailure(f func(error))
  • func (s *SegmentSink) Start() error
  • func (s *SegmentSink) StartSegment(filepath string, startTime int64) 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) Finalize() error
  • func (s *WebsocketSink) OnTrackMuted(muted bool)
  • func (s *WebsocketSink) Start() error
  • func (s *WebsocketSink) Write(p []byte) (n int, err error)

Constants

const (
	WebsocketActive websocketState = "active"
	WebsocketClosed websocketState = "closed"
)

Functions

func CreateSinks

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

Types

type FileSink

type FileSink struct {
	uploader.Uploader

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

func (*FileSink) Cleanup

func (s *FileSink) Cleanup()

func (*FileSink) Finalize

func (s *FileSink) Finalize() error

func (*FileSink) Start

func (s *FileSink) Start() error

type SegmentSink

type SegmentSink struct {
	uploader.Uploader

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

func (*SegmentSink) Cleanup

func (s *SegmentSink) Cleanup()

func (*SegmentSink) EnqueueSegmentUpload

func (s *SegmentSink) EnqueueSegmentUpload(segmentPath string, endTime int64) error

func (*SegmentSink) Finalize

func (s *SegmentSink) Finalize() error

func (*SegmentSink) SetOnFailure

func (s *SegmentSink) SetOnFailure(f func(error))

func (*SegmentSink) Start

func (s *SegmentSink) Start() error

func (*SegmentSink) StartSegment

func (s *SegmentSink) StartSegment(filepath string, startTime int64) 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
	Finalize() 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) Finalize

func (s *WebsocketSink) Finalize() error

func (*WebsocketSink) OnTrackMuted

func (s *WebsocketSink) OnTrackMuted(muted bool)

func (*WebsocketSink) Start

func (s *WebsocketSink) Start() error

func (*WebsocketSink) Write

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