handshake

Documentation

Index

• Variables
• func HandshakeWithClient(r io.Reader, w io.Writer, config *Config) error
• func HandshakeWithServer(r io.Reader, w io.Writer, config *Config) error
• type Config
• type Decoder
  • func NewDecoder(r io.Reader) *Decoder
  • func (d *Decoder) DecodeS0C0(h *S0C0) error
  • func (d *Decoder) DecodeS1C1(h *S1C1) error
  • func (d *Decoder) DecodeS2C2(h *S2C2) error
• type Encoder
  • func NewEncoder(w io.Writer) *Encoder
  • func (e *Encoder) EncodeS0C0(h *S0C0) error
  • func (e *Encoder) EncodeS1C1(h *S1C1) error
  • func (e *Encoder) EncodeS2C2(h *S2C2) error
• type S0C0
• type S1C1
• type S2C2

Variables

var RTMPVersion = 3

var Version = [4]byte{0, 0, 0, 0} // TODO: fix

Functions

func HandshakeWithClient

func HandshakeWithClient(r io.Reader, w io.Writer, config *Config) error

func HandshakeWithServer

func HandshakeWithServer(r io.Reader, w io.Writer, config *Config) error

Types

type Config

type Config struct {
	SkipHandshakeVerification bool
}

type Decoder

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

func NewDecoder

func NewDecoder(r io.Reader) *Decoder

func (*Decoder) DecodeS0C0

func (d *Decoder) DecodeS0C0(h *S0C0) error

func (*Decoder) DecodeS1C1

func (d *Decoder) DecodeS1C1(h *S1C1) error

func (*Decoder) DecodeS2C2

func (d *Decoder) DecodeS2C2(h *S2C2) error

type Encoder

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

func NewEncoder

func NewEncoder(w io.Writer) *Encoder

func (*Encoder) EncodeS0C0

func (e *Encoder) EncodeS0C0(h *S0C0) error

func (*Encoder) EncodeS1C1

func (e *Encoder) EncodeS1C1(h *S1C1) error

func (*Encoder) EncodeS2C2

func (e *Encoder) EncodeS2C2(h *S2C2) error

type S0C0

type S0C0 byte // RTMP Version

type S1C1

type S1C1 struct {
	Time    uint32
	Version [4]byte
	Random  [1528]byte
}

type S2C2

type S2C2 struct {
	Time   uint32
	Time2  uint32
	Random [1528]byte
}