live

Documentation

Index

• type Stream
  • func NewStream(name string) *Stream
  • func (s *Stream) Push(packet *m.StreamPacket)
• type StreamManager
  • func NewStreamManager() *StreamManager
  • func (s *StreamManager) GetStreamList() m.StreamList
  • func (s *StreamManager) Push(packet *m.StreamPacket)
  • func (sm *StreamManager) Run(context context.Context)
  • func (sm *StreamManager) Serve(w http.ResponseWriter, r *http.Request)

Types

type Stream

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

func NewStream

func NewStream(name string) *Stream

func (*Stream) Push

func (s *Stream) Push(packet *m.StreamPacket)

type StreamManager

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

func NewStreamManager

func NewStreamManager() *StreamManager

func (*StreamManager) GetStreamList

func (s *StreamManager) GetStreamList() m.StreamList

func (*StreamManager) Push

func (s *StreamManager) Push(packet *m.StreamPacket)

func (*StreamManager) Run

func (sm *StreamManager) Run(context context.Context)

func (*StreamManager) Serve

func (sm *StreamManager) Serve(w http.ResponseWriter, r *http.Request)