mjpeg

README

Useful links

• https://www.rfc-editor.org/rfc/rfc2435
• https://github.com/GStreamer/gst-plugins-good/blob/master/gst/rtp/gstrtpjpegdepay.c
• https://mjpeg.sanford.io/

Documentation

Index

• func Encoder(codec *core.Codec, handler core.HandlerFunc) core.HandlerFunc
• func FixJPEG(b []byte) []byte
• func MakeHeaders(p []byte, t byte, w, h uint16, lqt, cqt []byte) []byte
• func MakeHuffmanHeader(p, codelens, symbols []byte, tableNo, tableClass byte) []byte
• func MakeQuantHeader(p []byte, qt []byte, tableNo byte) []byte
• func MakeTables(q byte) (lqt, cqt []byte)
• func NewWriter(w io.Writer) io.Writer
• func RTPDepay(handlerFunc core.HandlerFunc) core.HandlerFunc
• func RTPPay(handlerFunc core.HandlerFunc) core.HandlerFunc
• func Transcode(b []byte) ([]byte, error)
• type Consumer
  • func NewConsumer() *Consumer
  • func (c *Consumer) AddTrack(media *core.Media, _ *core.Codec, track *core.Receiver) error
  • func (c *Consumer) WriteTo(wr io.Writer) (int64, error)

Functions

func Encoder

func Encoder(codec *core.Codec, handler core.HandlerFunc) core.HandlerFunc

func FixJPEG

func FixJPEG(b []byte) []byte

FixJPEG - reencode JPEG if it has wrong header

for example, this app produce "bad" images: https://github.com/jacksonliam/mjpg-streamer

and they can't be uploaded to the Telegram servers: {"ok":false,"error_code":400,"description":"Bad Request: IMAGE_PROCESS_FAILED"}

func MakeHeaders

func MakeHeaders(p []byte, t byte, w, h uint16, lqt, cqt []byte) []byte

func MakeHuffmanHeader

func MakeHuffmanHeader(p, codelens, symbols []byte, tableNo, tableClass byte) []byte

func MakeQuantHeader

func MakeQuantHeader(p []byte, qt []byte, tableNo byte) []byte

func MakeTables

func MakeTables(q byte) (lqt, cqt []byte)

func NewWriter

func NewWriter(w io.Writer) io.Writer

func RTPDepay

func RTPDepay(handlerFunc core.HandlerFunc) core.HandlerFunc

func RTPPay

func RTPPay(handlerFunc core.HandlerFunc) core.HandlerFunc

func Transcode

func Transcode(b []byte) ([]byte, error)

Types

type Consumer

type Consumer struct {
	core.Connection
	// contains filtered or unexported fields
}

func NewConsumer

func NewConsumer() *Consumer

func (*Consumer) AddTrack

func (c *Consumer) AddTrack(media *core.Media, _ *core.Codec, track *core.Receiver) error

func (*Consumer) WriteTo

func (c *Consumer) WriteTo(wr io.Writer) (int64, error)