Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

message

package

Go to main page

Versions in this module

v0

v0.0.6

Dec 12, 2023

v0.0.5

Jul 2, 2023

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

v0.0.4

Jan 1, 2023

v0.0.3

Jan 1, 2023

v0.0.2

Feb 18, 2021

v0.0.1

Dec 12, 2019