Versions in this module Expand all Collapse all v0 v0.0.9 Oct 30, 2019 Changes in this version + type CallPacket struct + Args amf0.Amf0 + func NewCallPacket() *CallPacket + func NewCloseStreamPacket() *CallPacket + func (v *CallPacket) BetterCid() chunkID + func (v *CallPacket) MarshalBinary() (data []byte, err error) + func (v *CallPacket) Size() int + func (v *CallPacket) Type() MessageType + func (v *CallPacket) UnmarshalBinary(data []byte) (err error) + type ConnectAppPacket struct + func NewConnectAppPacket() *ConnectAppPacket + func (v *ConnectAppPacket) BetterCid() chunkID + func (v *ConnectAppPacket) MarshalBinary() (data []byte, err error) + func (v *ConnectAppPacket) Size() int + func (v *ConnectAppPacket) Type() MessageType + func (v *ConnectAppPacket) UnmarshalBinary(data []byte) (err error) + type ConnectAppResPacket struct + func NewConnectAppResPacket(tid amf0.Number) *ConnectAppResPacket + func (v *ConnectAppResPacket) BetterCid() chunkID + func (v *ConnectAppResPacket) MarshalBinary() (data []byte, err error) + func (v *ConnectAppResPacket) Size() int + func (v *ConnectAppResPacket) Type() MessageType + func (v *ConnectAppResPacket) UnmarshalBinary(data []byte) (err error) + type CreateStreamPacket struct + func NewCreateStreamPacket() *CreateStreamPacket + func (v *CreateStreamPacket) BetterCid() chunkID + func (v *CreateStreamPacket) MarshalBinary() (data []byte, err error) + func (v *CreateStreamPacket) Size() int + func (v *CreateStreamPacket) Type() MessageType + func (v *CreateStreamPacket) UnmarshalBinary(data []byte) (err error) + type CreateStreamResPacket struct + StreamID amf0.Number + func NewCreateStreamResPacket(tid amf0.Number) *CreateStreamResPacket + func (v *CreateStreamResPacket) BetterCid() chunkID + func (v *CreateStreamResPacket) MarshalBinary() (data []byte, err error) + func (v *CreateStreamResPacket) Size() int + func (v *CreateStreamResPacket) Type() MessageType + func (v *CreateStreamResPacket) UnmarshalBinary(data []byte) (err error) + type Handshake struct + func NewHandshake(r *rand.Rand) *Handshake + func (v *Handshake) ReadC0S0(r io.Reader) (c0 []byte, err error) + func (v *Handshake) ReadC1S1(r io.Reader) (c1 []byte, err error) + func (v *Handshake) ReadC2S2(r io.Reader) (c2 []byte, err error) + func (v *Handshake) WriteC0S0(w io.Writer) (err error) + func (v *Handshake) WriteC1S1(w io.Writer) (err error) + func (v *Handshake) WriteC2S2(w io.Writer, s1c1 []byte) (err error) + type LimitType uint8 + const LimitTypeDynamic + const LimitTypeHard + const LimitTypeSoft + type Message struct + Payload []byte + func NewMessage() *Message + func NewStreamMessage(streamID int) *Message + type MessageType uint8 + const MessageTypeAMF0Command + const MessageTypeAMF0Data + const MessageTypeAMF3Command + const MessageTypeAMF3Data + const MessageTypeAbort + const MessageTypeAcknowledgement + const MessageTypeAudio + const MessageTypeEdgeAndOriginServerCommand + const MessageTypeSetChunkSize + const MessageTypeSetPeerBandwidth + const MessageTypeUserControl + const MessageTypeVideo + const MessageTypeWindowAcknowledgementSize + type Packet interface + BetterCid func() chunkID + Size func() int + Type func() MessageType + type Protocol struct + func NewProtocol(rw io.ReadWriter) *Protocol + func (v *Protocol) DecodeMessage(m *Message) (pkt Packet, err error) + func (v *Protocol) ExpectMessage(types ...MessageType) (m *Message, err error) + func (v *Protocol) ExpectPacket(ppkt interface{}) (m *Message, err error) + func (v *Protocol) ReadMessage() (m *Message, err error) + func (v *Protocol) WriteMessage(m *Message) (err error) + func (v *Protocol) WritePacket(pkt Packet, streamID int) (err error) + type PublishPacket struct + StreamName amf0.String + StreamType amf0.String + func NewPublishPacket() *PublishPacket + func (v *PublishPacket) BetterCid() chunkID + func (v *PublishPacket) MarshalBinary() (data []byte, err error) + func (v *PublishPacket) Size() int + func (v *PublishPacket) Type() MessageType + func (v *PublishPacket) UnmarshalBinary(data []byte) (err error) + type SetChunkSize struct + ChunkSize uint32 + func NewSetChunkSize() *SetChunkSize + func (v *SetChunkSize) BetterCid() chunkID + func (v *SetChunkSize) MarshalBinary() (data []byte, err error) + func (v *SetChunkSize) Size() int + func (v *SetChunkSize) Type() MessageType + func (v *SetChunkSize) UnmarshalBinary(data []byte) (err error) + type SetPeerBandwidth struct + Bandwidth uint32 + LimitType LimitType + func NewSetPeerBandwidth() *SetPeerBandwidth + func (v *SetPeerBandwidth) BetterCid() chunkID + func (v *SetPeerBandwidth) MarshalBinary() (data []byte, err error) + func (v *SetPeerBandwidth) Size() int + func (v *SetPeerBandwidth) Type() MessageType + func (v *SetPeerBandwidth) UnmarshalBinary(data []byte) (err error) + type WindowAcknowledgementSize struct + AckSize uint32 + func NewWindowAcknowledgementSize() *WindowAcknowledgementSize + func (v *WindowAcknowledgementSize) BetterCid() chunkID + func (v *WindowAcknowledgementSize) MarshalBinary() (data []byte, err error) + func (v *WindowAcknowledgementSize) Size() int + func (v *WindowAcknowledgementSize) Type() MessageType + func (v *WindowAcknowledgementSize) UnmarshalBinary(data []byte) (err error)