mjpeg

Documentation

Overview

Package mjpeg provides functionality for receiving and sending MJPEG streams over HTTP

Index

• func SendFrameStream(ctx context.Context, w http.ResponseWriter, frames <-chan videostreams.Frame) (err error)
• func SendStream(ctx context.Context, w http.ResponseWriter, frames <-chan []byte) (err error)
• type Receiver
  • func NewReceiver(r io.Reader, boundary string) *Receiver
  • func NewReceiverFromResponse(res *http.Response) (*Receiver, error)
  • func NewReceiverFromURL(ctx context.Context, client *http.Client, u string) (*Receiver, error)
  • func (r *Receiver) Close()
  • func (r *Receiver) Receive() (frame *videostreams.JPEGFrame, err error)
• type StreamSender
  • func StartStream(w http.ResponseWriter) *StreamSender
  • func (ss *StreamSender) Close() error
  • func (ss *StreamSender) Send(frame []byte) error
  • func (ss *StreamSender) SendFrame(frame videostreams.Frame) error

Functions

func SendFrameStream

func SendFrameStream(
	ctx context.Context, w http.ResponseWriter, frames <-chan videostreams.Frame,
) (err error)

func SendStream

func SendStream(
	ctx context.Context, w http.ResponseWriter, frames <-chan []byte,
) (err error)

Types

type Receiver

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

func NewReceiver

func NewReceiver(r io.Reader, boundary string) *Receiver

func NewReceiverFromResponse

func NewReceiverFromResponse(res *http.Response) (*Receiver, error)

func NewReceiverFromURL

func NewReceiverFromURL(
	ctx context.Context, client *http.Client, u string,
) (*Receiver, error)

func (*Receiver) Close

func (r *Receiver) Close()

func (*Receiver) Receive

func (r *Receiver) Receive() (frame *videostreams.JPEGFrame, err error)

type StreamSender

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

func StartStream

func StartStream(w http.ResponseWriter) *StreamSender

func (*StreamSender) Close

func (ss *StreamSender) Close() error

func (*StreamSender) Send

func (ss *StreamSender) Send(frame []byte) error

func (*StreamSender) SendFrame

func (ss *StreamSender) SendFrame(frame videostreams.Frame) error