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

rtmp

package module

Go to main page

Versions in this module

v1

v1.2.6

Jun 8, 2021

v1.2.5

Dec 10, 2020

v1.2.4

Dec 9, 2020

Changes in this version

type CommandMessage

+ func (msg *CommandMessage) Encode() (b []byte)

+ type ReleaseStreamMessage struct

+ StreamName string

+ func (msg *ReleaseStreamMessage) Encode0()

v1.2.3

Sep 30, 2020

v1.2.2

May 5, 2020

v1.2.1

May 1, 2020

v1.2.0

Apr 12, 2020

Changes in this version

+ const AMF0_AVMPLUS_OBJECT

+ const AMF0_BOOLEAN

+ const AMF0_DATE

+ const AMF0_ECMA_ARRAY

+ const AMF0_END_OBJECT

+ const AMF0_LONG_STRING

+ const AMF0_MOVIECLIP

+ const AMF0_NULL

+ const AMF0_NUMBER

+ const AMF0_OBJECT

+ const AMF0_RECORDSET

+ const AMF0_REFERENCE

+ const AMF0_STRICT_ARRAY

+ const AMF0_STRING

+ const AMF0_TYPED_OBJECT

+ const AMF0_UNDEFINED

+ const AMF0_UNSUPPORTED

+ const AMF0_XML_DOCUMENT

+ const AMF3_ARRAY

+ const AMF3_BYTE_ARRAY

+ const AMF3_DATE

+ const AMF3_DICTIONARY

+ const AMF3_DOUBLE

+ const AMF3_FALSE

+ const AMF3_INTEGER

+ const AMF3_NULL

+ const AMF3_OBJECT

+ const AMF3_STRING

+ const AMF3_TRUE

+ const AMF3_UNDEFINED

+ const AMF3_VECTOR_DOUBLE

+ const AMF3_VECTOR_INT

+ const AMF3_VECTOR_OBJECT

+ const AMF3_VECTOR_UINT

+ const AMF3_XML

+ const AMF3_XML_DOC

+ const C1S1_DIGEST_DATA_SIZE

+ const C1S1_DIGEST_OFFSET_MAX

+ const C1S1_DIGEST_OFFSET_SIZE

+ const C1S1_DIGEST_SIZE

+ const C1S1_KEY_DATA_SIZE

+ const C1S1_KEY_OFFSET_MAX

+ const C1S1_KEY_OFFSET_SIZE

+ const C1S1_KEY_SIZE

+ const C1S1_SIZE

+ const C1S1_TIME_SIZE

+ const C1S1_VERSION_SIZE

+ const Level_Error

+ const Level_Status

+ const Level_Warning

+ const NetConnection_Call_BadVersion

+ const NetConnection_Call_Failed

+ const NetConnection_Call_Prohibited

+ const NetConnection_Connect_AppShutdown

+ const NetConnection_Connect_Closed

+ const NetConnection_Connect_Failed

+ const NetConnection_Connect_InvalidApp

+ const NetConnection_Connect_Rejected

+ const NetConnection_Connect_Success

+ const NetStream_Buffe_Flush

+ const NetStream_Buffer_Empty

+ const NetStream_Buffer_Full

+ const NetStream_Data_Start

+ const NetStream_Pause_Notify

+ const NetStream_Play_Complete

+ const NetStream_Play_Failed

+ const NetStream_Play_Reset

+ const NetStream_Play_Start

+ const NetStream_Play_Stop

+ const NetStream_Play_StreamNotFound

+ const NetStream_Play_Switch

+ const NetStream_Publish_BadName

+ const NetStream_Publish_Idle

+ const NetStream_Publish_Start

+ const NetStream_Record_Failed

+ const NetStream_Record_NoAccess

+ const NetStream_Record_Start

+ const NetStream_Record_Stop

+ const NetStream_Seek_Failed

+ const NetStream_Seek_InvalidTime

+ const NetStream_Seek_Notify

+ const NetStream_Unpause_Notify

+ const NetStream_Unpublish_Success

+ const RTMP_CHUNK_HEAD_1

+ const RTMP_CHUNK_HEAD_12

+ const RTMP_CHUNK_HEAD_4

+ const RTMP_CHUNK_HEAD_8

+ const RTMP_CSID_AUDIO

+ const RTMP_CSID_COMMAND

+ const RTMP_CSID_CONTROL

+ const RTMP_CSID_DATA

+ const RTMP_CSID_VIDEO

+ const RTMP_DEFAULT_CHUNK_SIZE

+ const RTMP_HANDSHAKE_VERSION

+ const RTMP_MAX_CHUNK_HEADER

+ const RTMP_MAX_CHUNK_SIZE

+ const RTMP_MSG_ABORT

+ const RTMP_MSG_ACK

+ const RTMP_MSG_ACK_SIZE

+ const RTMP_MSG_AGGREGATE

+ const RTMP_MSG_AMF0_COMMAND

+ const RTMP_MSG_AMF0_METADATA

+ const RTMP_MSG_AMF0_SHARED

+ const RTMP_MSG_AMF3_COMMAND

+ const RTMP_MSG_AMF3_METADATA

+ const RTMP_MSG_AMF3_SHARED

+ const RTMP_MSG_AUDIO

+ const RTMP_MSG_BANDWIDTH

+ const RTMP_MSG_CHUNK_SIZE

+ const RTMP_MSG_EDGE

+ const RTMP_MSG_USER_CONTROL

+ const RTMP_MSG_VIDEO

+ const RTMP_USER_EMPTY

+ const RTMP_USER_PING_REQUEST

+ const RTMP_USER_PING_RESPONSE

+ const RTMP_USER_SET_BUFFLEN

+ const RTMP_USER_STREAM_BEGIN

+ const RTMP_USER_STREAM_DRY

+ const RTMP_USER_STREAM_EOF

+ const RTMP_USER_STREAM_IS_RECORDED

+ const Response_Error

+ const Response_OnStatus

+ const Response_Result

+ const SEND_ACK_MESSAGE

+ const SEND_ACK_WINDOW_SIZE_MESSAGE

+ const SEND_AUDIO_MESSAGE

+ const SEND_CHUNK_SIZE_MESSAGE

+ const SEND_CONNECT_MESSAGE

+ const SEND_CONNECT_RESPONSE_MESSAGE

+ const SEND_CREATE_STREAM_MESSAGE

+ const SEND_CREATE_STREAM_RESPONSE_MESSAGE

+ const SEND_FULL_AUDIO_MESSAGE

+ const SEND_FULL_VDIEO_MESSAGE

+ const SEND_PING_REQUEST_MESSAGE

+ const SEND_PING_RESPONSE_MESSAGE

+ const SEND_PLAY_MESSAGE

+ const SEND_PLAY_RESPONSE_MESSAGE

+ const SEND_PUBLISH_RESPONSE_MESSAGE

+ const SEND_PUBLISH_START_MESSAGE

+ const SEND_SET_BUFFER_LENGTH_MESSAGE

+ const SEND_SET_PEER_BANDWIDTH_MESSAGE

+ const SEND_STREAM_BEGIN_MESSAGE

+ const SEND_STREAM_IS_RECORDED_MESSAGE

+ const SEND_UNPUBLISH_RESPONSE_MESSAGE

+ const SEND_VIDEO_MESSAGE

+ const SharedObject_BadPersistence

+ const SharedObject_Flush_Failed

+ const SharedObject_Flush_Success

+ const SharedObject_UriMismatch

+ var END_OBJ = []byte

+ var FMS_KEY = []byte

+ var FP_KEY = []byte

+ func DecodeAMFObject(obj interface{}, key string) interface

+ func GetRtmpMessage(chunk *Chunk)

+ func HMAC_SHA256(message []byte, key []byte) ([]byte, error)

+ func Handshake(brw *bufio.ReadWriter) error

+ func ListenRtmp(addr string) error

+ func ReadBuf(r io.Reader, length int) (buf []byte)

+ type AMF struct

+ type AMFObject interface

+ type AMFObjects map[string]AMFObject

+ type CURDStreamMessage struct

+ StreamId uint32

+ func (msg *CURDStreamMessage) Encode0()

+ type CallMessage struct

+ Object interface{}

+ Optional interface{}

+ func (msg *CallMessage) Encode() []byte

+ func (msg *CallMessage) Encode3() []byte

+ type Chunk struct

+ Body []byte

+ MsgData interface{}

+ func (c *Chunk) Encode(msg RtmpMessage)

+ func (c *Chunk) Recycle()

+ type ChunkBasicHeader struct

+ ChunkStreamID uint32

+ ChunkType byte

+ type ChunkExtendedTimestamp struct

+ ExtendTimestamp uint32

+ type ChunkHeader struct

+ func (h *ChunkHeader) Clone() *ChunkHeader

+ type ChunkMessageHeader struct

+ MessageLength uint32

+ MessageStreamID uint32

+ MessageTypeID byte

+ Timestamp uint32

+ type CommandMessage struct

+ CommandName string

+ TransactionId uint64

+ func (cmd *CommandMessage) GetCommand() *CommandMessage

+ type Commander interface

+ GetCommand func() *CommandMessage

+ type CreateStreamMessage struct

+ Object interface{}

+ func (msg *CreateStreamMessage) Encode() []byte

+ type HaveStreamID interface

+ GetStreamID func() uint32

+ type MetadataMessage struct

+ Proterties map[string]interface{}

+ type NetConnection struct

+ func (conn *NetConnection) OnConnect() (err error)

+ func (conn *NetConnection) RecvMessage() (msg *Chunk, err error)

+ func (conn *NetConnection) SendMessage(message string, args interface{}) error

+ type NetStatusEvent struct

+ Code string

+ Level string

+ type PauseMessage struct

+ Milliseconds uint64

+ Pause bool

+ func (msg *PauseMessage) Encode0()

+ type PingRequestMessage struct

+ Timestamp uint32

+ func (msg *PingRequestMessage) Encode() (b []byte)

+ type Play2Message struct

+ Duration uint64

+ OldStreamName string

+ StartTime uint64

+ StreamName string

+ Transition string

+ func (msg *Play2Message) Encode0()

+ type PlayMessage struct

+ Duration uint64

+ Rest bool

+ Start uint64

+ StreamName string

+ func (msg *PlayMessage) Encode() []byte

+ type PublishMessage struct

+ PublishingName string

+ PublishingType string

+ func (msg *PublishMessage) Encode0()

+ type RTMP struct

+ type ReceiveAVMessage struct

+ BoolFlag bool

+ func (msg *ReceiveAVMessage) Encode0()

+ type ResponseCallMessage struct

+ Object interface{}

+ Response interface{}

+ func (msg *ResponseCallMessage) Encode0() []byte

+ type ResponseConnectMessage struct

+ Infomation interface{}

+ Properties interface{}

+ func (msg *ResponseConnectMessage) Encode() []byte

+ type ResponseCreateStreamMessage struct

+ Object interface{}

+ StreamId uint32

+ func (msg *ResponseCreateStreamMessage) Decode0(chunk *Chunk)

+ func (msg *ResponseCreateStreamMessage) Decode3(chunk *Chunk)

+ func (msg *ResponseCreateStreamMessage) Encode() []byte

+ type ResponseMessage struct

+ Description string

+ Infomation interface{}

+ Properties interface{}

+ func (msg *ResponseMessage) Decode0(chunk *Chunk)

+ func (msg *ResponseMessage) Encode0()

+ type ResponsePauseMessage struct

+ Description string

+ func (msg *ResponsePauseMessage) Encode0()

+ type ResponsePlayMessage struct

+ Description string

+ Object interface{}

+ StreamID uint32

+ func (msg *ResponsePlayMessage) Decode0(chunk *Chunk)

+ func (msg *ResponsePlayMessage) Decode3(chunk *Chunk)

+ func (msg *ResponsePlayMessage) Encode() []byte

+ func (msg *ResponsePlayMessage) GetStreamID() uint32

+ type ResponsePublishMessage struct

+ Infomation interface{}

+ Properties interface{}

+ StreamID uint32

+ func (msg *ResponsePublishMessage) Encode() []byte

+ func (msg *ResponsePublishMessage) GetStreamID() uint32

+ type ResponseSeekMessage struct

+ Description string

+ func (msg *ResponseSeekMessage) Encode0()

+ type RtmpMessage interface

+ Encode func() []byte

+ type SeekMessage struct

+ Milliseconds uint64

+ func (msg *SeekMessage) Encode0()

+ type SetBufferMessage struct

+ Millisecond uint32

+ func (msg *SetBufferMessage) Encode() []byte

+ type SetPeerBandwidthMessage struct

+ AcknowledgementWindowsize uint32

+ LimitType byte

+ func (msg *SetPeerBandwidthMessage) Encode() (b []byte)

+ type StreamIDMessage struct

+ StreamID uint32

+ func (msg *StreamIDMessage) Encode() (b []byte)

+ type Uint32Message uint32

+ func (msg Uint32Message) Encode() (b []byte)

+ type UserControlMessage struct

+ EventData []byte

+ EventType uint16

+ func (msg *UserControlMessage) Encode() []byte

Other modules containing this package

github.com/Monibuca/plugin-rtmp/v2

github.com/Monibuca/plugin-rtmp/v3