slice

type Buf struct {
	Head, Tail BufPos

	Size  int
	Count int
	// contains filtered or unexported fields
}

type BufPos int

type DataSliceInfo struct {
	SliceId      uint64 // slice id
	FrameId      uint32 // frame id
	SliceSizeMax int
}

type DemuxCloser interface {
	Demuxer
	Close() error
}

type Demuxer interface {
	PacketReader                // read slice packets
	Headers() ([]Packet, error) // reads the file header, contains flv header infomations
}

type Extend map[uint8]uint32

type Header struct {
	Datas   []Packet
	BeginAt BufPos
}

type MuxCloser interface {
	Muxer
	Close() error
}

type Muxer interface {
	WriteHeader(pkt []Packet) error // write the file header
	PacketWriter                    // write slice packets
	WriteTrailer() error            // finish writing file, this func can be called only once
}

type Option func(*Options)

type Options struct {
	SID                    string
	HandlerName            string
	ConnectedTimestamp     time.Time
	AfterReadSlicePacket   func(*Packet) error
	AfterWriteSlicePacket  func(*Packet) error
	AfterReadSliceHeaders  func([]Packet) error
	AfterWriteSliceHeaders func([]Packet) error
}

type Packet struct {
	Size       uint16 // slice size
	SliceType  uint8  // slice type
	SliceId    uint64 // slice id
	FrameId    uint32 // frame id
	PosFlag    uint8
	FrameType  uint8
	Reserved   uint8
	ExtendFlag uint8
	Extend     Extend
	Data       []byte // slice data

	// no encode， for p2p quickOffset
	FrameDts      int32 // frame dts
	HeaderBeginAt int   // header pos in queue
	HeaderChanged bool  // indicates if the sps/pps info changed
}

type PacketReader interface {
	ReadPacket() (Packet, error)
}

type PacketWriter interface {
	WritePacket(Packet) error
}

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

type QueueCursor struct {

	// P2P quickTime req
	TimeOffset int

	// slice req
	SliceStartId     uint64
	SliceSubstreamId []uint8
	SliceStreamBase  uint8
	// contains filtered or unexported fields
}

type Stat struct {
	PktCount     uint32 `json:"pkt_count"`
	GopCount     uint32 `json:"gop_count"`
	PktDuration  int32  `json:"pkt_duration"`
	LossPktCount uint32 `json:"loss_pkt_count"`
	HeadPos      int    `json:"head_pos"`
	TailPos      int    `json:"tail_pos"`
	Closed       bool   `json:"closed"`
	MaxSliceId   uint64 `json:"max_slice_id"`
}

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