Versions in this module Expand all Collapse all v0 v0.0.8 Apr 2, 2024 Changes in this version + var CmdBodyDecoders = map[string]BodyDecoderFunc + var DataBodyDecoders = map[string]BodyDecoderFunc + func DecodeBodyAtSetDataFrame(r io.Reader, _ AMFDecoder, v *AMFConvertible) error + func DecodeBodyCloseStream(_ io.Reader, d AMFDecoder, v *AMFConvertible) error + func DecodeBodyConnect(_ io.Reader, d AMFDecoder, v *AMFConvertible) error + func DecodeBodyConnectResult(_ io.Reader, d AMFDecoder, v *AMFConvertible) error + func DecodeBodyCreateStream(_ io.Reader, d AMFDecoder, v *AMFConvertible) error + func DecodeBodyCreateStreamResult(_ io.Reader, d AMFDecoder, v *AMFConvertible) error + func DecodeBodyDeleteStream(_ io.Reader, d AMFDecoder, v *AMFConvertible) error + func DecodeBodyFCPublish(_ io.Reader, d AMFDecoder, v *AMFConvertible) error + func DecodeBodyFCUnpublish(_ io.Reader, d AMFDecoder, v *AMFConvertible) error + func DecodeBodyGetStreamLength(_ io.Reader, d AMFDecoder, v *AMFConvertible) error + func DecodeBodyPing(_ io.Reader, d AMFDecoder, v *AMFConvertible) error + func DecodeBodyPlay(_ io.Reader, d AMFDecoder, v *AMFConvertible) error + func DecodeBodyPublish(_ io.Reader, d AMFDecoder, v *AMFConvertible) error + func DecodeBodyReleaseStream(_ io.Reader, d AMFDecoder, v *AMFConvertible) error + func EncodeBodyAnyValues(e AMFEncoder, v AMFConvertible) error + type AMFConvertible interface + FromArgs func(args ...interface{}) error + ToArgs func(ty EncodingType) ([]interface{}, error) + type AMFDecoder interface + Decode func(interface{}) error + Reset func(r io.Reader) + func NewAMFDecoder(r io.Reader, encTy EncodingType) AMFDecoder + type AMFEncoder interface + Encode func(interface{}) error + Reset func(w io.Writer) + func NewAMFEncoder(w io.Writer, encTy EncodingType) AMFEncoder + type AbortMessage struct + ChunkStreamID uint32 + func (m *AbortMessage) TypeID() TypeID + type Ack struct + SequenceNumber uint32 + func (m *Ack) TypeID() TypeID + type AggregateMessage struct + func (m *AggregateMessage) TypeID() TypeID + type AudioMessage struct + Payload io.Reader + func (m *AudioMessage) TypeID() TypeID + type BodyDecoderFunc func(r io.Reader, e AMFDecoder, v *AMFConvertible) error + func CmdBodyDecoderFor(name string, transactionID int64) BodyDecoderFunc + func DataBodyDecoderFor(name string) BodyDecoderFunc + type CommandMessage struct + Body io.Reader + CommandName string + Encoding EncodingType + TransactionID int64 + func (m *CommandMessage) TypeID() TypeID + type DataMessage struct + Body io.Reader + Encoding EncodingType + Name string + func (m *DataMessage) TypeID() TypeID + type Decoder struct + func NewDecoder(r io.Reader) *Decoder + func (dec *Decoder) Decode(typeID TypeID, msg *Message) error + func (dec *Decoder) Reset(r io.Reader) + type Encoder struct + func NewEncoder(w io.Writer) *Encoder + func (enc *Encoder) Encode(msg Message) error + func (enc *Encoder) Reset(w io.Writer) + type EncodingType uint8 + const EncodingTypeAMF0 + const EncodingTypeAMF3 + type LimitType uint8 + const LimitTypeDynamic + const LimitTypeHard + const LimitTypeSoft + type Message interface + TypeID func() TypeID + type NetConnectionConnect struct + Command NetConnectionConnectCommand + func (t *NetConnectionConnect) FromArgs(args ...interface{}) error + func (t *NetConnectionConnect) ToArgs(ty EncodingType) ([]interface{}, error) + type NetConnectionConnectCode string + const NetConnectionConnectCodeClosed + const NetConnectionConnectCodeFailed + const NetConnectionConnectCodeSuccess + type NetConnectionConnectCommand struct + App string + AudioCodecs int + Capabilities int + FlashVer string + Fpad bool + ObjectEncoding EncodingType + TCURL string + Type string + VideoCodecs int + VideoFunction int + type NetConnectionConnectResult struct + Information NetConnectionConnectResultInformation + Properties NetConnectionConnectResultProperties + func (t *NetConnectionConnectResult) FromArgs(args ...interface{}) error + func (t *NetConnectionConnectResult) ToArgs(ty EncodingType) ([]interface{}, error) + type NetConnectionConnectResultInformation struct + Code NetConnectionConnectCode + Data amf0.ECMAArray + Description string + Level string + type NetConnectionConnectResultProperties struct + Capabilities int + FMSVer string + Mode int + type NetConnectionCreateStream struct + func (t *NetConnectionCreateStream) FromArgs(args ...interface{}) error + func (t *NetConnectionCreateStream) ToArgs(ty EncodingType) ([]interface{}, error) + type NetConnectionCreateStreamResult struct + StreamID uint32 + func (t *NetConnectionCreateStreamResult) FromArgs(args ...interface{}) error + func (t *NetConnectionCreateStreamResult) ToArgs(ty EncodingType) ([]interface{}, error) + type NetConnectionReleaseStream struct + StreamName string + func (t *NetConnectionReleaseStream) FromArgs(args ...interface{}) error + func (t *NetConnectionReleaseStream) ToArgs(ty EncodingType) ([]interface{}, error) + type NetStreamCloseStream struct + func (t *NetStreamCloseStream) FromArgs(args ...interface{}) error + func (t *NetStreamCloseStream) ToArgs(ty EncodingType) ([]interface{}, error) + type NetStreamDeleteStream struct + StreamID uint32 + func (t *NetStreamDeleteStream) FromArgs(args ...interface{}) error + func (t *NetStreamDeleteStream) ToArgs(ty EncodingType) ([]interface{}, error) + type NetStreamFCPublish struct + StreamName string + func (t *NetStreamFCPublish) FromArgs(args ...interface{}) error + func (t *NetStreamFCPublish) ToArgs(ty EncodingType) ([]interface{}, error) + type NetStreamFCUnpublish struct + StreamName string + func (t *NetStreamFCUnpublish) FromArgs(args ...interface{}) error + func (t *NetStreamFCUnpublish) ToArgs(ty EncodingType) ([]interface{}, error) + type NetStreamGetStreamLength struct + StreamName string + func (t *NetStreamGetStreamLength) FromArgs(args ...interface{}) error + func (t *NetStreamGetStreamLength) ToArgs(ty EncodingType) ([]interface{}, error) + type NetStreamOnStatus struct + InfoObject NetStreamOnStatusInfoObject + func (t *NetStreamOnStatus) FromArgs(args ...interface{}) error + func (t *NetStreamOnStatus) ToArgs(ty EncodingType) ([]interface{}, error) + type NetStreamOnStatusCode string + const NetStreamOnStatusCodeConnectFailed + const NetStreamOnStatusCodeConnectSuccess + const NetStreamOnStatusCodeMuticastStreamReset + const NetStreamOnStatusCodePlayComplete + const NetStreamOnStatusCodePlayFailed + const NetStreamOnStatusCodePlayStart + const NetStreamOnStatusCodePublishBadName + const NetStreamOnStatusCodePublishFailed + const NetStreamOnStatusCodePublishStart + const NetStreamOnStatusCodeUnpublishSuccess + type NetStreamOnStatusInfoObject struct + Code NetStreamOnStatusCode + Description string + Level NetStreamOnStatusLevel + type NetStreamOnStatusLevel string + const NetStreamOnStatusLevelError + const NetStreamOnStatusLevelStatus + type NetStreamPing struct + func (t *NetStreamPing) FromArgs(args ...interface{}) error + func (t *NetStreamPing) ToArgs(ty EncodingType) ([]interface{}, error) + type NetStreamPlay struct + CommandObject interface{} + Start int64 + StreamName string + func (t *NetStreamPlay) FromArgs(args ...interface{}) error + func (t *NetStreamPlay) ToArgs(ty EncodingType) ([]interface{}, error) + type NetStreamPublish struct + CommandObject interface{} + PublishingName string + PublishingType string + func (t *NetStreamPublish) FromArgs(args ...interface{}) error + func (t *NetStreamPublish) ToArgs(ty EncodingType) ([]interface{}, error) + type NetStreamReleaseStream struct + StreamName string + func (t *NetStreamReleaseStream) FromArgs(args ...interface{}) error + func (t *NetStreamReleaseStream) ToArgs(ty EncodingType) ([]interface{}, error) + type NetStreamSetDataFrame struct + AmfData interface{} + Payload []byte + func (t *NetStreamSetDataFrame) FromArgs(args ...interface{}) error + func (t *NetStreamSetDataFrame) ToArgs(ty EncodingType) ([]interface{}, error) + type SetChunkSize struct + ChunkSize uint32 + func (m *SetChunkSize) TypeID() TypeID + type SetPeerBandwidth struct + Limit LimitType + Size int32 + func (m *SetPeerBandwidth) TypeID() TypeID + type SharedObjectMessage struct + type SharedObjectMessageAMF0 struct + func (m *SharedObjectMessageAMF0) TypeID() TypeID + type SharedObjectMessageAMF3 struct + func (m *SharedObjectMessageAMF3) TypeID() TypeID + type TypeID byte + const TypeIDAbortMessage + const TypeIDAck + const TypeIDAggregateMessage + const TypeIDAudioMessage + const TypeIDCommandMessageAMF0 + const TypeIDCommandMessageAMF3 + const TypeIDDataMessageAMF0 + const TypeIDDataMessageAMF3 + const TypeIDSetChunkSize + const TypeIDSetPeerBandwidth + const TypeIDSharedObjectMessageAMF0 + const TypeIDSharedObjectMessageAMF3 + const TypeIDUserCtrl + const TypeIDVideoMessage + const TypeIDWinAckSize + type UnknownCommandBodyDecodeError struct + Name string + Objs []interface{} + TransactionID int64 + func (e *UnknownCommandBodyDecodeError) Error() string + type UnknownDataBodyDecodeError struct + Name string + Objs []interface{} + func (e *UnknownDataBodyDecodeError) Error() string + type UserControlEventDecoder struct + func NewUserControlEventDecoder(r io.Reader) *UserControlEventDecoder + func (dec *UserControlEventDecoder) Decode(msg *UserCtrlEvent) error + type UserControlEventEncoder struct + func NewUserControlEventEncoder(w io.Writer) *UserControlEventEncoder + func (enc *UserControlEventEncoder) Encode(msg UserCtrlEvent) error + type UserCtrl struct + Event UserCtrlEvent + func (m *UserCtrl) TypeID() TypeID + type UserCtrlEvent interface + type UserCtrlEventPingRequest struct + Timestamp uint32 + type UserCtrlEventPingResponse struct + Timestamp uint32 + type UserCtrlEventSetBufferLength struct + LengthMs uint32 + StreamID uint32 + type UserCtrlEventStreamBegin struct + StreamID uint32 + type UserCtrlEventStreamDry struct + StreamID uint32 + type UserCtrlEventStreamEOF struct + StreamID uint32 + type UserCtrlEventStreamIsRecorded struct + StreamID uint32 + type VideoMessage struct + Payload io.Reader + func (m *VideoMessage) TypeID() TypeID + type WinAckSize struct + Size int32 + func (m *WinAckSize) TypeID() TypeID