Documentation
¶
Index ¶
- Constants
- func MediamtxSourceTypeToString(s string) (string, error)
- func NoopReader(reader CloneableReader)
- func StartFileCleanup(ctx context.Context, workDir string)
- type CloneableReader
- type EOSReader
- type MediaMTXClient
- type MediaReader
- type MediaSegmenter
- type MediaWriter
- type SegmentHandler
- type SwitchableSegmentReader
Constants ¶
View Source
const ( MediaMTXWebrtcSession = "webrtcSession" MediaMTXRtmpConn = "rtmpConn" )
Variables ¶
This section is empty.
Functions ¶
func MediamtxSourceTypeToString ¶ added in v0.8.2
func NoopReader ¶
func NoopReader(reader CloneableReader)
func StartFileCleanup ¶ added in v0.8.3
StartFileCleanup starts a goroutine to periodically remove any old temporary files accidentally left behind
Types ¶
type CloneableReader ¶ added in v0.8.2
type CloneableReader interface {
io.Reader
Clone() CloneableReader
}
type EOSReader ¶
type EOSReader struct{}
func (*EOSReader) Clone ¶ added in v0.8.2
func (r *EOSReader) Clone() CloneableReader
type MediaMTXClient ¶ added in v0.8.1
type MediaMTXClient struct {
// contains filtered or unexported fields
}
func NewMediaMTXClient ¶ added in v0.8.1
func NewMediaMTXClient(host, apiPassword, sourceID, sourceType string) *MediaMTXClient
func (*MediaMTXClient) KickInputConnection ¶ added in v0.8.1
func (mc *MediaMTXClient) KickInputConnection(ctx context.Context) error
func (*MediaMTXClient) StreamExists ¶ added in v0.8.1
func (mc *MediaMTXClient) StreamExists() (bool, error)
type MediaReader ¶ added in v0.8.2
type MediaReader struct {
// contains filtered or unexported fields
}
func (*MediaReader) Clone ¶ added in v0.8.2
func (mr *MediaReader) Clone() CloneableReader
type MediaSegmenter ¶
type MediaSegmenter struct {
Workdir string
MediaMTXClient *MediaMTXClient
}
func (*MediaSegmenter) RunSegmentation ¶
func (ms *MediaSegmenter) RunSegmentation(ctx context.Context, in string, segmentHandler SegmentHandler)
type MediaWriter ¶ added in v0.8.2
type MediaWriter struct {
// contains filtered or unexported fields
}
func NewMediaWriter ¶ added in v0.8.2
func NewMediaWriter() *MediaWriter
func (*MediaWriter) Close ¶ added in v0.8.2
func (mw *MediaWriter) Close()
func (*MediaWriter) MakeReader ¶ added in v0.8.2
func (mw *MediaWriter) MakeReader() CloneableReader
type SegmentHandler ¶
type SegmentHandler func(reader CloneableReader)
type SwitchableSegmentReader ¶
type SwitchableSegmentReader struct {
// contains filtered or unexported fields
}
func NewSwitchableSegmentReader ¶
func NewSwitchableSegmentReader() *SwitchableSegmentReader
func (*SwitchableSegmentReader) Close ¶
func (sr *SwitchableSegmentReader) Close()
func (*SwitchableSegmentReader) Read ¶
func (sr *SwitchableSegmentReader) Read(reader CloneableReader)
func (*SwitchableSegmentReader) SwitchReader ¶
func (sr *SwitchableSegmentReader) SwitchReader(newReader SegmentHandler)
Source Files
Click to show internal directories.
Click to hide internal directories.