rtmp

Documentation

Index

• Constants
• type DataPacket
  • func UnmarshalDataPacket(data []byte) (*DataPacket, error)
  • func (dp *DataPacket) Marshal() ([]byte, error)
• type NetworkTuple
  • func (nt *NetworkTuple) Size() int
• type RequestPacket
  • func UnmarshalRequestPacket(data []byte) (*RequestPacket, error)
  • func (rp *RequestPacket) Marshal() ([]byte, error)
• type ResponsePacket
  • func UnmarshalResponsePacket(data []byte) (*ResponsePacket, error)
  • func (rp *ResponsePacket) Marshal() ([]byte, error)

Constants

const (
	FunctionRequest         = 1
	FunctionRDRSplitHorizon = 2
	FunctionRDRComplete     = 3
	FunctionLoopProbe       = 4 // AURP Ch.4 pp 94
)

Types

type DataPacket

type DataPacket struct {
	RouterAddr    ddp.Addr
	Extended      bool
	NetworkTuples []NetworkTuple
}

DataPacket represents an RTMP Data packet.

func UnmarshalDataPacket

func UnmarshalDataPacket(data []byte) (*DataPacket, error)

UnmarshalDataPacket unmarshals a DataPacket.

func (*DataPacket) Marshal

func (dp *DataPacket) Marshal() ([]byte, error)

Marshal marshals an RTMP Data packet.

type NetworkTuple

type NetworkTuple struct {
	Extended   bool
	RangeStart ddp.Network
	RangeEnd   ddp.Network
	Distance   uint8
}

NetworkTuple represents routing information.

func (*NetworkTuple) Size

func (nt *NetworkTuple) Size() int

type RequestPacket

type RequestPacket struct {
	Function uint8
	Data     []byte // only for LoopProbe
}

RequestPacket represents an RTMP Request, Route Data Request, or Loop Probe.

func UnmarshalRequestPacket

func UnmarshalRequestPacket(data []byte) (*RequestPacket, error)

UnmarshalRequestPacket unmarshals an RTMP Request or RTMP RDR packet.

func (*RequestPacket) Marshal

func (rp *RequestPacket) Marshal() ([]byte, error)

Marshal marshals an RTMP Request or RTMP RDR packet.

type ResponsePacket

type ResponsePacket struct {
	SenderAddr ddp.Addr
	Extended   bool
	RangeStart ddp.Network
	RangeEnd   ddp.Network
}

ResponsePacket represents an RTMP Response packet.

func UnmarshalResponsePacket

func UnmarshalResponsePacket(data []byte) (*ResponsePacket, error)

UnmarshalResponsePacket unmarshals an RTMP Response packet.

func (*ResponsePacket) Marshal

func (rp *ResponsePacket) Marshal() ([]byte, error)

Marshal marshals an RTMP Response packet.