rtmps

Documentation

Index

• Constants
• type DecodeError
  • func (e *DecodeError) Error() string
• type Rtmp
  • func NewRtmp(tc, swf, page string, opt ...interface{}) (rtmp *Rtmp, err error)
  • func (rtmp *Rtmp) CheckStatus(label string, ts int, data interface{}, waitPause bool) (done, incomplete, pauseFound bool, err error)
  • func (rtmp *Rtmp) Close() (err error)
  • func (rtmp *Rtmp) Command(name string, args []interface{}) (trData interface{}, err error)
  • func (rtmp *Rtmp) Connect() (err error)
  • func (rtmp *Rtmp) CreateStream() (err error)
  • func (rtmp *Rtmp) GetTimestamp() int
  • func (rtmp *Rtmp) Pause(timestamp int) (err error)
  • func (rtmp *Rtmp) PauseRaw() (err error)
  • func (rtmp *Rtmp) PauseUnpause(timestamp int) (done, incomplete bool, err error)
  • func (rtmp *Rtmp) Play(stream string) error
  • func (rtmp *Rtmp) PlayTime(stream string, timestamp int) (err error)
  • func (rtmp *Rtmp) Seek(timestamp int) (err error)
  • func (rtmp *Rtmp) SetBufferLength(streamId, len int) (err error)
  • func (rtmp *Rtmp) SetConnectOpt(opt ...interface{})
  • func (rtmp *Rtmp) SetFixAggrTimestamp(sw bool)
  • func (rtmp *Rtmp) SetFlush(b bool)
  • func (rtmp *Rtmp) SetFlvName(name string)
  • func (rtmp *Rtmp) SetNoSeek(b bool)
  • func (rtmp *Rtmp) SetPeerBandwidth(wsz, lim int) (err error)
  • func (rtmp *Rtmp) SetTimestamp(t int)
  • func (rtmp *Rtmp) Unpause(timestamp int) (err error)
  • func (rtmp *Rtmp) Wait() (done, incomplete bool, err error)
  • func (rtmp *Rtmp) WaitPause() (done, incomplete bool, err error)
  • func (rtmp *Rtmp) WaitTest(testTimeout int) (done, incomplete bool, err error)
  • func (rtmp *Rtmp) WindowAckSize(asz int) (err error)

Constants

const (
	TID_SETCHUNKSIZE     = 1
	TID_ABORT            = 2
	TID_ACKNOWLEDGEMENT  = 3
	TID_USERCONTROL      = 4
	TID_WINDOW_ACK_SIZE  = 5
	TID_SETPEERBANDWIDTH = 6
	TID_AUDIO            = 8
	TID_VIDEO            = 9
	TID_AMF3COMMAND      = 17
	TID_AMF0COMMAND      = 20
	TID_AMF0DATA         = 18
	TID_AMF3DATA         = 15
	TID_AGGREGATE        = 22
)

const (
	UC_STREAMBEGIN      = 0
	UC_STREAMEOF        = 1
	UC_STREAMDRY        = 2
	UC_SETBUFFERLENGTH  = 3
	UC_STREAMISRECORDED = 4
	UC_PINGREQUEST      = 6
	UC_PINGRESPONSE     = 7

	UC_BUFFEREMPTY = 31
	UC_BUFFERREADY = 32
)

const (
	NORMAL = iota
	COMMAND
	PAUSE
	TEST
)

Types

type DecodeError

type DecodeError struct {
	Fun string
	Msg string
}

func (*DecodeError) Error

func (e *DecodeError) Error() string

type Rtmp

type Rtmp struct {
	VideoExists bool
	// contains filtered or unexported fields
}

func NewRtmp

func NewRtmp(tc, swf, page string, opt ...interface{}) (rtmp *Rtmp, err error)

func (*Rtmp) CheckStatus

func (rtmp *Rtmp) CheckStatus(label string, ts int, data interface{}, waitPause bool) (done, incomplete, pauseFound bool, err error)

func (*Rtmp) Close

func (rtmp *Rtmp) Close() (err error)

func (*Rtmp) Command

func (rtmp *Rtmp) Command(name string, args []interface{}) (trData interface{}, err error)

command name, transaction ID, and command object

func (*Rtmp) Connect

func (rtmp *Rtmp) Connect() (err error)

func (*Rtmp) CreateStream

func (rtmp *Rtmp) CreateStream() (err error)

func (*Rtmp) GetTimestamp

func (rtmp *Rtmp) GetTimestamp() int

func (*Rtmp) Pause

func (rtmp *Rtmp) Pause(timestamp int) (err error)

func (*Rtmp) PauseRaw

func (rtmp *Rtmp) PauseRaw() (err error)

func (*Rtmp) PauseUnpause

func (rtmp *Rtmp) PauseUnpause(timestamp int) (done, incomplete bool, err error)

func (*Rtmp) Play

func (rtmp *Rtmp) Play(stream string) error

func (*Rtmp) PlayTime

func (rtmp *Rtmp) PlayTime(stream string, timestamp int) (err error)

func (*Rtmp) Seek

func (rtmp *Rtmp) Seek(timestamp int) (err error)

func (*Rtmp) SetBufferLength

func (rtmp *Rtmp) SetBufferLength(streamId, len int) (err error)

func (*Rtmp) SetConnectOpt

func (rtmp *Rtmp) SetConnectOpt(opt ...interface{})

func (*Rtmp) SetFixAggrTimestamp

func (rtmp *Rtmp) SetFixAggrTimestamp(sw bool)

func (*Rtmp) SetFlush

func (rtmp *Rtmp) SetFlush(b bool)

func (*Rtmp) SetFlvName

func (rtmp *Rtmp) SetFlvName(name string)

func (*Rtmp) SetNoSeek

func (rtmp *Rtmp) SetNoSeek(b bool)

func (*Rtmp) SetPeerBandwidth

func (rtmp *Rtmp) SetPeerBandwidth(wsz, lim int) (err error)

func (*Rtmp) SetTimestamp

func (rtmp *Rtmp) SetTimestamp(t int)

func (*Rtmp) Unpause

func (rtmp *Rtmp) Unpause(timestamp int) (err error)

func (*Rtmp) Wait

func (rtmp *Rtmp) Wait() (done, incomplete bool, err error)

func (*Rtmp) WaitPause

func (rtmp *Rtmp) WaitPause() (done, incomplete bool, err error)

func (*Rtmp) WaitTest

func (rtmp *Rtmp) WaitTest(testTimeout int) (done, incomplete bool, err error)

func (*Rtmp) WindowAckSize

func (rtmp *Rtmp) WindowAckSize(asz int) (err error)