media

package

v0.8.1 Latest Latest Go to latest Published: Dec 5, 2024 License: MIT Imports: 17 Imported by: 0

Details

Rendered for

View Source

const (
	MediaMTXWebrtcSession = "webrtcSession"
	MediaMTXRtmpConn      = "rtmpConn"
)

This section is empty.

func NoopReader(reader io.Reader)

type EOSReader struct{}

func (r EOSReader) Read(p []byte) (n int, err error)

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

func NewMediaMTXClient(apiPassword string) *MediaMTXClient

func (mc *MediaMTXClient) KickInputConnection(mediaMTXHost, sourceID, sourceType string) error

func (mc *MediaMTXClient) StreamExists(mediaMTXHost, sourceID, sourceType string) (bool, error)

type MediaSegmenter struct {
	Workdir        string
	MediaMTXClient *MediaMTXClient
	MediaMTXHost   string
}

func (ms *MediaSegmenter) RunSegmentation(ctx context.Context, in string, segmentHandler SegmentHandler, id, sourceType string)

type SegmentHandler func(reader io.Reader)

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

func NewSwitchableSegmentReader() *SwitchableSegmentReader

func (sr *SwitchableSegmentReader) Close()

func (sr *SwitchableSegmentReader) Read(reader io.Reader)

func (sr *SwitchableSegmentReader) SwitchReader(newReader SegmentHandler)