Documentation
¶
Index ¶
- Variables
- type FFProbeData
- type FFProbeDataFormat
- type FFProbeDataStream
- type FFProbeDataStreamDisposition
- type GetInFo
- type PackWriterCloser
- type RtmpStream
- type Server
- type StaticsBW
- type Stream
- func (s *Stream) AddReader(r av.ReadCloser)
- func (s *Stream) AddWriter(w av.WriteCloser)
- func (s *Stream) CheckAlive() (n int)
- func (s *Stream) Copy(dst *Stream)
- func (s *Stream) GetReader() av.ReadCloser
- func (s *Stream) GetWs() *sync.Map
- func (s *Stream) ID() string
- func (s *Stream) TransStart()
- func (s *Stream) TransStop()
- type StreamReadWriteCloser
- type VirReader
- type VirWriter
Constants ¶
This section is empty.
Variables ¶
View Source
var (
EmptyID = ""
)
Functions ¶
This section is empty.
Types ¶
type FFProbeData ¶
type FFProbeData struct {
Streams []FFProbeDataStream `json:"streams"`
Format FFProbeDataFormat `json:"format"`
}
func (FFProbeData) GetAudio ¶
func (d FFProbeData) GetAudio() FFProbeDataStream
func (FFProbeData) GetVideo ¶
func (d FFProbeData) GetVideo() FFProbeDataStream
type FFProbeDataFormat ¶
type FFProbeDataFormat struct {
FormatLongName string `json:"format_long_name"`
Duration string `json:"duration"`
Filename string `json:"filename"`
NbPrograms float64 `json:"nb_programs"`
FormatName string `json:"format_name"`
StartTime string `json:"start_time"`
ProbeScore float64 `json:"probe_score"`
Tags map[string]string `json:"tags"`
NbStreams float64 `json:"nb_streams"`
}
type FFProbeDataStream ¶
type FFProbeDataStream struct {
AvgFrameRate string `json:"avg_frame_rate"`
CodecName string `json:"codec_name"`
CodecType string `json:"codec_type"`
SampleFmt string `json:"sample_fmt"`
BitsPerSample float64 `json:"bits_per_sample"`
RFrameRate string `json:"r_frame_rate"`
Profile string `json:"profile"`
Channels float64 `json:"channels"`
StartPts float64 `json:"start_pts"`
BitRate string `json:"bit_rate"`
Index float64 `json:"index"`
ChannelLayout string `json:"channel_layout"`
TimeBase string `json:"time_base"`
CodecLongName string `json:"codec_long_name"`
CodecTagString string `json:"codec_tag_string"`
CodecTag string `json:"codec_tag"`
SampleRate string `json:"sample_rate"`
StartTime string `json:"start_time"`
FilmGrain float64 `json:"film_grain"`
HasBFrames float64 `json:"has_b_frames"`
ColorSpace string `json:"color_space"`
FieldOrder string `json:"field_order"`
ClosedCaptions float64 `json:"closed_captions"`
PixFmt string `json:"pix_fmt"`
Level float64 `json:"level"`
ColorTransfer string `json:"color_transfer"`
IsAvc string `json:"is_avc"`
SampleAspectRatio string `json:"sample_aspect_ratio"`
ColorRange string `json:"color_range"`
ColorPrimaries string `json:"color_primaries"`
NalLengthSize string `json:"nal_length_size"`
Height float64 `json:"height"`
DisplayAspectRatio string `json:"display_aspect_ratio"`
CodedHeight float64 `json:"coded_height"`
Width float64 `json:"width"`
CodedWidth float64 `json:"coded_width"`
ChromaLocation string `json:"chroma_location"`
Refs float64 `json:"refs"`
BitsPerRawSample string `json:"bits_per_raw_sample"`
Disposition FFProbeDataStreamDisposition `json:"disposition"`
}
type FFProbeDataStreamDisposition ¶
type FFProbeDataStreamDisposition struct {
AttachedPic float64 `json:"attached_pic"`
TimedThumbnails float64 `json:"timed_thumbnails"`
Metadata float64 `json:"metadata"`
HearingImpaired float64 `json:"hearing_impaired"`
Karaoke float64 `json:"karaoke"`
CleanEffects float64 `json:"clean_effects"`
Descriptions float64 `json:"descriptions"`
Comment float64 `json:"comment"`
Original float64 `json:"original"`
Lyrics float64 `json:"lyrics"`
Dependent float64 `json:"dependent"`
Dub float64 `json:"dub"`
Forced float64 `json:"forced"`
VisualImpaired float64 `json:"visual_impaired"`
Captions float64 `json:"captions"`
StillImage float64 `json:"still_image"`
Default float64 `json:"default"`
}
type PackWriterCloser ¶
type PackWriterCloser struct {
// contains filtered or unexported fields
}
func (*PackWriterCloser) GetWriter ¶
func (p *PackWriterCloser) GetWriter() av.WriteCloser
type RtmpStream ¶
type RtmpStream struct {
// contains filtered or unexported fields
}
func NewRtmpStream ¶
func NewRtmpStream() *RtmpStream
func (*RtmpStream) CheckAlive ¶
func (rs *RtmpStream) CheckAlive()
func (*RtmpStream) GetStreams ¶
func (rs *RtmpStream) GetStreams() *sync.Map
func (*RtmpStream) HandleReader ¶
func (rs *RtmpStream) HandleReader(r av.ReadCloser)
func (*RtmpStream) HandleWriter ¶
func (rs *RtmpStream) HandleWriter(w av.WriteCloser)
type Stream ¶
type Stream struct {
// contains filtered or unexported fields
}
func (*Stream) AddReader ¶
func (s *Stream) AddReader(r av.ReadCloser)
func (*Stream) AddWriter ¶
func (s *Stream) AddWriter(w av.WriteCloser)
func (*Stream) CheckAlive ¶
func (*Stream) GetReader ¶
func (s *Stream) GetReader() av.ReadCloser
func (*Stream) TransStart ¶
func (s *Stream) TransStart()
type StreamReadWriteCloser ¶
type StreamReadWriteCloser interface {
GetInFo
Close() error
Write(core.ChunkStream) error
Read(c *core.ChunkStream) error
}
type VirReader ¶
type VirReader struct {
Uid string
Key string
av.RWBaser
ReadBWInfo StaticsBW
// contains filtered or unexported fields
}
func NewVirReader ¶
func NewVirReader(conn StreamReadWriteCloser, id string, key string) *VirReader
func (*VirReader) SaveStatics ¶
type VirWriter ¶
func NewVirWriter ¶
func NewVirWriter(conn StreamReadWriteCloser) *VirWriter
func (*VirWriter) SendPacket ¶
Click to show internal directories.
Click to hide internal directories.