server

Nov 3, 2023

Changes in this version

type Channel

+ func (c *Channel) GenM3U8File(tsPath func(tsName string) (tsPath string)) ([]byte, error)

+ func (c *Channel) HlsPlayer() *hls.Source

Oct 19, 2023

Changes in this version

+ type AuthFunc func(ReqAppName, ReqChannelName string, IsPublisher bool) (*Channel, error)

type Channel

+ func NewChannel(channelName string, conf ...ChannelConf) *Channel

+ type ChannelConf func(*Channel)

Oct 5, 2023

Changes in this version

+ var ErrAppAlreadyExists = errors.New("app already exists")

+ var ErrAppNotFount = errors.New("app not found")

+ var ErrChannelAlreadyExists = errors.New("channel already exists")

+ var ErrChannelNotFound = errors.New("channel not found")

+ var ErrClosed = errors.New("channel closed")

+ var ErrHlsPlayerNotInit = errors.New("hls player not init")

+ var ErrPusherAlreadyInPublication = errors.New("pusher already in publication")

+ var ErrPusherIsNil = errors.New("pusher is nil")

+ var ErrPusherNotInPublication = errors.New("pusher not in publication")

+ type App struct

+ func NewApp(appName string) *App

+ func (a *App) Close() error

+ func (a *App) Closed() bool

+ func (a *App) DelChannel(channelName string) error

+ func (a *App) GetChannel(channelName string) (*Channel, error)

+ func (a *App) GetChannels() ([]*Channel, error)

+ func (a *App) GetOrNewChannel(channelName string) (*Channel, error)

+ func (a *App) NewChannel(channelName string) (*Channel, error)

+ type Channel struct

+ func (c *Channel) AddPlayer(w av.WriteCloser) error

+ func (c *Channel) Close() error

+ func (c *Channel) Closed() bool

+ func (c *Channel) DelPlayer(w av.WriteCloser) error

+ func (c *Channel) GenM3U8PlayList(tsBashPath string) (*bytes.Buffer, error)

+ func (c *Channel) GetPlayers() ([]av.WriteCloser, error)

+ func (c *Channel) GetTsFile(tsName string) ([]byte, error)

+ func (c *Channel) InPublication() bool

+ func (c *Channel) InitHlsPlayer() error

+ func (c *Channel) InitdHlsPlayer() bool

+ func (c *Channel) PushStart(pusher av.Reader) error

+ type Server struct

+ func DefaultRtmpServer() *Server

+ func NewRtmpServer(c ...ServerConf) *Server

+ func (s *Server) DelApp(appName string) error

+ func (s *Server) GetApp(appName string) (*App, error)

+ func (s *Server) GetChannelWithApp(appName, channelName string) (*Channel, error)

+ func (s *Server) GetOrNewApp(appName string) *App

+ func (s *Server) GetOrNewChannelWithApp(appName, channelName string) (*Channel, error)

+ func (s *Server) NewApp(appName string) (*App, error)

+ func (s *Server) Serve(l net.Listener) error

+ func (s *Server) SetConnBufferSize(bufferSize int32)

+ func (s *Server) SetParseChannelFunc(f parseChannelFunc)

+ type ServerConf func(*Server)

+ func WithAutoCreateAppOrChannel(auto bool) ServerConf

+ func WithConnBufferSize(bufferSize int32) ServerConf

+ func WithInitHlsPlayer(init bool) ServerConf

+ func WithParseChannelFunc(f parseChannelFunc) ServerConf