rtmprelay

Documentation

Index

• Variables
• func GetStaticPushList(appname string) ([]string, error)
• func ReleaseStaticPushObject(rtmpurl string)
• type RtmpRelay
  • func NewRtmpRelay(playurl *string, publishurl *string) *RtmpRelay
  • func (self *RtmpRelay) Start() error
  • func (self *RtmpRelay) Stop()
• type StaticPush
  • func GetAndCreateStaticPushObject(rtmpurl string) *StaticPush
  • func GetStaticPushObject(rtmpurl string) (*StaticPush, error)
  • func NewStaticPush(rtmpurl string) *StaticPush
  • func (self *StaticPush) HandleAvPacket()
  • func (self *StaticPush) IsStart() bool
  • func (self *StaticPush) Start() error
  • func (self *StaticPush) Stop()
  • func (self *StaticPush) WriteAvPacket(packet *av.Packet)

Variables

var G_PushUrlList []string = nil

var G_StaticPushMap = make(map[string](*StaticPush))

var (
	STATIC_RELAY_STOP_CTRL = "STATIC_RTMPRELAY_STOP"
)

var (
	STOP_CTRL = "RTMPRELAY_STOP"
)

Functions

func GetStaticPushList

func GetStaticPushList(appname string) ([]string, error)

func ReleaseStaticPushObject

func ReleaseStaticPushObject(rtmpurl string)

Types

type RtmpRelay

type RtmpRelay struct {
	PlayUrl    string
	PublishUrl string
	// contains filtered or unexported fields
}

func NewRtmpRelay

func NewRtmpRelay(playurl *string, publishurl *string) *RtmpRelay

func (*RtmpRelay) Start

func (self *RtmpRelay) Start() error

func (*RtmpRelay) Stop

func (self *RtmpRelay) Stop()

type StaticPush

type StaticPush struct {
	RtmpUrl string
	// contains filtered or unexported fields
}

func GetAndCreateStaticPushObject

func GetAndCreateStaticPushObject(rtmpurl string) *StaticPush

func GetStaticPushObject

func GetStaticPushObject(rtmpurl string) (*StaticPush, error)

func NewStaticPush

func NewStaticPush(rtmpurl string) *StaticPush

func (*StaticPush) HandleAvPacket

func (self *StaticPush) HandleAvPacket()

func (*StaticPush) IsStart

func (self *StaticPush) IsStart() bool

func (*StaticPush) Start

func (self *StaticPush) Start() error

func (*StaticPush) Stop

func (self *StaticPush) Stop()

func (*StaticPush) WriteAvPacket

func (self *StaticPush) WriteAvPacket(packet *av.Packet)