rtmp

Documentation

Index

• type Member
  • func (m *Member) Quit()
  • func (m *Member) Wait()
• type Publisher
  • func (p *Publisher) MeetingOver()
• type Steam
  • func (s *Steam) AddMember(uid int64, done func() <-chan struct{}, w http.ResponseWriter) (member *Member, err error)
  • func (s *Steam) IsPushing(uid int64) bool
  • func (s *Steam) IsRunning(uid int64) bool
  • func (s *Steam) NewPublisher(uid int64)
  • func (s *Steam) Offset(uid int64) (offset int64)
  • func (s *Steam) Push(read io.ReadCloser, uid int64) (err error)

Types

type Member

type Member struct {
	// contains filtered or unexported fields
}

func (*Member) Quit

func (m *Member) Quit()

func (*Member) Wait

func (m *Member) Wait()

type Publisher

type Publisher struct {
	// contains filtered or unexported fields
}

func (*Publisher) MeetingOver

func (p *Publisher) MeetingOver()

type Steam

type Steam struct {
	Publishers map[int64]*Publisher
	// contains filtered or unexported fields
}

var (
	S *Steam
)

func (*Steam) AddMember

func (s *Steam) AddMember(uid int64, done func() <-chan struct{}, w http.ResponseWriter) (member *Member, err error)

func (*Steam) IsPushing

func (s *Steam) IsPushing(uid int64) bool

func (*Steam) IsRunning

func (s *Steam) IsRunning(uid int64) bool

func (*Steam) NewPublisher

func (s *Steam) NewPublisher(uid int64)

func (*Steam) Offset

func (s *Steam) Offset(uid int64) (offset int64)

func (*Steam) Push

func (s *Steam) Push(read io.ReadCloser, uid int64) (err error)