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 Client
  • func NewClient(res *http.Response) *Client
  • func (c *Client) GetMedias() []*core.Media
  • func (c *Client) GetTrack(media *core.Media, codec *core.Codec) (*core.Receiver, error)
  • func (c *Client) Handle() error
  • func (c *Client) MarshalJSON() ([]byte, error)
  • func (c *Client) Start() error
  • func (c *Client) Stop() error
• type Consumer
  • func NewConsumer() *Consumer
  • func (c *Consumer) AddTrack(media *core.Media, _ *core.Codec, track *core.Receiver) error
  • func (c *Consumer) Stop() 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 Client

type Client struct {
	core.Listener

	UserAgent  string
	RemoteAddr string
	// contains filtered or unexported fields
}

func NewClient

func NewClient(res *http.Response) *Client

func (*Client) GetMedias

func (c *Client) GetMedias() []*core.Media

func (*Client) GetTrack

func (c *Client) GetTrack(media *core.Media, codec *core.Codec) (*core.Receiver, error)

func (*Client) Handle

func (c *Client) Handle() error

func (*Client) MarshalJSON

func (c *Client) MarshalJSON() ([]byte, error)

func (*Client) Start

func (c *Client) Start() error

func (*Client) Stop

func (c *Client) Stop() error

type Consumer

type Consumer struct {
	core.SuperConsumer
	// 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) Stop

func (c *Consumer) Stop() error

func (*Consumer) WriteTo

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