room

package
v0.2.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 16, 2023 License: AGPL-3.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrRoomIdEmpty        = errors.New("roomid is empty")
	ErrRoomIdTooLong      = errors.New("roomid is too long")
	ErrAdminPassWordEmpty = errors.New("admin password is empty")
)
View Source 
var (
	ErrRoomNotFound     = errors.New("room not found")
	ErrUserNotFound     = errors.New("user not found")
	ErrRoomAlreadyExist = errors.New("room already exist")
)
View Source 
var (
	ErrUsernameEmpty       = errors.New("user name is empty")
	ErrUsernameTooLong     = errors.New("user name is too long")
	ErrUserPasswordEmpty   = errors.New("user password is empty")
	ErrUserPasswordTooLong = errors.New("user password is too long")
)
View Source 
var (
	ErrAlreadyClosed = fmt.Errorf("already closed")
)

Functions

This section is empty.

Types

type BaseMovieInfo added in v0.2.4 

type BaseMovieInfo struct {
	Url        string            `json:"url"`
	Name       string            `json:"name"`
	Live       bool              `json:"live"`
	Proxy      bool              `json:"proxy"`
	RtmpSource bool              `json:"rtmpSource"`
	Type       string            `json:"type"`
	Headers    map[string]string `json:"headers"`
}

type BroadcastConf 

type BroadcastConf func(*broadcastMessage)

func WithIgnoreId added in v0.2.4 

func WithIgnoreId(id ...string) BroadcastConf

func WithSendToSelf 

func WithSendToSelf() BroadcastConf

func WithSender 

func WithSender(sender string) BroadcastConf

type Client 

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

func NewClient 

func NewClient(user *User, conn *websocket.Conn) (*Client, error)

func (*Client) Broadcast 

func (c *Client) Broadcast(msg Message, conf ...BroadcastConf) error

func (*Client) Close 

func (c *Client) Close() error

func (*Client) Closed 

func (c *Client) Closed() bool

func (*Client) GetReadChan 

func (c *Client) GetReadChan() <-chan Message

func (*Client) NextReader 

func (c *Client) NextReader() (int, io.Reader, error)

func (*Client) NextWriter 

func (c *Client) NextWriter(messageType int) (io.WriteCloser, error)

func (*Client) Room 

func (c *Client) Room() *Room

func (*Client) Send 

func (c *Client) Send(msg Message) error

func (*Client) Unregister 

func (c *Client) Unregister() error

func (*Client) User 

func (c *Client) User() *User

func (*Client) Username 

func (c *Client) Username() string

type Current 

type Current struct {
	Movie  MovieInfo `json:"movie"`
	Status Status    `json:"status"`
}

func (*Current) Proto added in v0.2.4 

func (c *Current) Proto() *pb.Current

func (*Current) SetSeek added in v0.2.0 

func (c *Current) SetSeek(seek, timeDiff float64) Status

func (*Current) SetSeekRate 

func (c *Current) SetSeekRate(seek, rate, timeDiff float64) Status

func (*Current) SetStatus 

func (c *Current) SetStatus(playing bool, seek, rate, timeDiff float64) Status

type ElementJsonMessage added in v0.2.4 

type ElementJsonMessage struct {
	*pb.ElementMessage
}

func (*ElementJsonMessage) Encode added in v0.2.4 

func (em *ElementJsonMessage) Encode(w io.Writer) error

func (*ElementJsonMessage) MessageType added in v0.2.4 

func (em *ElementJsonMessage) MessageType() int

func (*ElementJsonMessage) String added in v0.2.4 

func (em *ElementJsonMessage) String() string

type ElementMessage 

type ElementMessage struct {
	*pb.ElementMessage
}

func (*ElementMessage) Encode 

func (em *ElementMessage) Encode(w io.Writer) error

func (*ElementMessage) MessageType 

func (em *ElementMessage) MessageType() int

func (*ElementMessage) String 

func (em *ElementMessage) String() string

type FormatErrMovieAlreadyExist 

type FormatErrMovieAlreadyExist uint64

func (FormatErrMovieAlreadyExist) Error 

func (e FormatErrMovieAlreadyExist) Error() string

type FormatErrMovieNotFound 

type FormatErrMovieNotFound uint64

func (FormatErrMovieNotFound) Error 

func (e FormatErrMovieNotFound) Error() string

type Message 

type Message interface {
	MessageType() int
	String() string
	Encode(w io.Writer) error
}

type Movie 

type Movie struct {
	BaseMovieInfo
	PullKey   string `json:"pullKey"`
	CreatedAt int64  `json:"createdAt"`
	// contains filtered or unexported fields
}

Url will be `PullKey` when Live and Proxy are true

func NewMovie 

func NewMovie(id uint64, url, name, type_ string, live, proxy, rtmpSource bool, headers map[string]string, conf ...MovieConf) (*Movie, error)

func NewMovieWithBaseMovie 

func NewMovieWithBaseMovie(id uint64, baseMovie BaseMovieInfo, conf ...MovieConf) (*Movie, error)

func (*Movie) Channel 

func (m *Movie) Channel() *rtmps.Channel

func (*Movie) Check 

func (m *Movie) Check() error

func (*Movie) Creator 

func (m *Movie) Creator() *User

func (*Movie) Id 

func (m *Movie) Id() uint64

func (*Movie) Init 

func (m *Movie) Init(conf ...MovieConf)

func (*Movie) SetChannel 

func (m *Movie) SetChannel(channel *rtmps.Channel)

func (*Movie) SetCreator 

func (m *Movie) SetCreator(creator *User)

type MovieConf 

type MovieConf func(m *Movie)

func WithChannel 

func WithChannel(channel *rtmps.Channel) MovieConf

func WithCreator 

func WithCreator(creator *User) MovieConf

func WithPullKey 

func WithPullKey(PullKey string) MovieConf

type MovieInfo 

type MovieInfo struct {
	Id            uint64        `json:"id"`
	BaseMovieInfo BaseMovieInfo `json:"base"`
	PullKey       string        `json:"pullKey"`
	CreatedAt     int64         `json:"createdAt"`
	Creator       string        `json:"creator"`
}

type PingMessage 

type PingMessage struct{}

func (*PingMessage) Encode 

func (pm *PingMessage) Encode(w io.Writer) error

func (*PingMessage) MessageType 

func (pm *PingMessage) MessageType() int

func (*PingMessage) String 

func (pm *PingMessage) String() string

type Room 

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

func NewRoom 

func NewRoom(RoomId string, Password string, rtmps *rtmps.Server, conf ...RoomConf) (*Room, error)

Version cant is 0

func (*Room) AddUser 

func (r *Room) AddUser(u *User) error

func (*Room) Broadcast 

func (r *Room) Broadcast(msg Message, conf ...BroadcastConf) error

func (*Room) ChangeCurrentMovie 

func (r *Room) ChangeCurrentMovie(id uint64) error

Seek will be set to 0

func (*Room) CheckPassword 

func (r *Room) CheckPassword(password string) (ok bool)

func (*Room) CheckVersion 

func (r *Room) CheckVersion(version uint64) bool

func (Room) Clear 

func (m Room) Clear() error

func (*Room) ClearMovies 

func (r *Room) ClearMovies() (err error)

func (*Room) ClientNum 

func (r *Room) ClientNum() int64

func (*Room) Close 

func (r *Room) Close() error

func (*Room) Closed 

func (r *Room) Closed() bool

func (*Room) CreatedAt added in v0.2.4 

func (r *Room) CreatedAt() int64

func (*Room) Current 

func (r *Room) Current() *Current

func (*Room) DelMovie 

func (r *Room) DelMovie(id ...uint64) error

func (*Room) DelUser 

func (r *Room) DelUser(id string) error

func (Room) GetAndClear 

func (m Room) GetAndClear() (movies []*Movie)

func (Room) GetAndDelMovie 

func (m Room) GetAndDelMovie(id ...uint64) (movies []*Movie, err error)

func (*Room) GetAndDelUser 

func (r *Room) GetAndDelUser(id string) (u *User, ok bool)

func (Room) GetMovie 

func (m Room) GetMovie(id uint64) (movie *Movie, err error)

func (Room) GetMovieWithPullKey 

func (m Room) GetMovieWithPullKey(pullKey string) (movie *Movie, err error)

func (*Room) GetOrNewUser 

func (r *Room) GetOrNewUser(id string, password string, conf ...UserConf) (*User, error)

func (*Room) GetUser 

func (r *Room) GetUser(id string) (*User, error)

func (Room) HasMovie 

func (m Room) HasMovie(id uint64) bool

func (*Room) Hidden 

func (r *Room) Hidden() bool

func (*Room) Id added in v0.2.4 

func (r *Room) Id() string

func (*Room) Init added in v0.2.4 

func (r *Room) Init()

func (*Room) LateActiveTime 

func (r *Room) LateActiveTime() int64

func (Room) MovieList 

func (m Room) MovieList() (movies []MovieInfo)

func (*Room) NeedPassword 

func (r *Room) NeedPassword() bool

func (*Room) NewLiveChannel 

func (r *Room) NewLiveChannel(channel string) (*rtmps.Channel, error)

func (*Room) NewUser 

func (r *Room) NewUser(id string, password string, conf ...UserConf) (*User, error)

func (*Room) PushBackMovie 

func (r *Room) PushBackMovie(movie *Movie) error

func (*Room) PushFrontMovie 

func (r *Room) PushFrontMovie(movie *Movie) error

func (Room) Range 

func (m Room) Range(f func(e *dllist.Element[*Movie]) bool) (interrupt bool)

func (*Room) RegClient 

func (r *Room) RegClient(user *User, conn *websocket.Conn) (*Client, error)

func (*Room) RootUser 

func (r *Room) RootUser() *User

func (*Room) Serve 

func (r *Room) Serve()

func (*Room) SetHidden 

func (r *Room) SetHidden(hidden bool)

func (*Room) SetPassword 

func (r *Room) SetPassword(password string) error

func (*Room) SetPasswordAndCloseAll added in v0.2.4 

func (r *Room) SetPasswordAndCloseAll(password string) error

func (*Room) SetRootUser 

func (r *Room) SetRootUser(u *User)

func (*Room) SetSeekRate 

func (r *Room) SetSeekRate(seek, rate, timeDiff float64) Status

func (*Room) SetStatus 

func (r *Room) SetStatus(playing bool, seek, rate, timeDiff float64) Status

func (*Room) SetVersion 

func (r *Room) SetVersion(version uint64)

func (*Room) Start 

func (r *Room) Start()

func (*Room) SwapMovie 

func (r *Room) SwapMovie(id1, id2 uint64) error

func (*Room) UnRegClient 

func (r *Room) UnRegClient(user *User) error

func (*Room) UpdateActiveTime 

func (r *Room) UpdateActiveTime()

func (*Room) UserList 

func (r *Room) UserList() (users []User)

func (*Room) Version 

func (r *Room) Version() uint64

type RoomConf 

type RoomConf func(r *Room)

func WithHidden 

func WithHidden(hidden bool) RoomConf

func WithRootUser 

func WithRootUser(u *User) RoomConf

func WithVersion 

func WithVersion(version uint64) RoomConf

type Rooms added in v0.2.4 

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

func NewRooms added in v0.2.4 

func NewRooms() *Rooms

func (*Rooms) CreateRoom added in v0.2.4 

func (rs *Rooms) CreateRoom(id string, password string, s *rtmps.Server, conf ...RoomConf) (*Room, error)

func (*Rooms) DelRoom added in v0.2.4 

func (rs *Rooms) DelRoom(id string) error

func (*Rooms) GetRoom added in v0.2.4 

func (rs *Rooms) GetRoom(id string) (*Room, error)

func (*Rooms) HasRoom added in v0.2.4 

func (rs *Rooms) HasRoom(id string) bool

func (*Rooms) List added in v0.2.4 

func (rs *Rooms) List() (rooms []*Room)

func (*Rooms) ListHidden added in v0.2.4 

func (rs *Rooms) ListHidden() (rooms []*Room)

func (*Rooms) ListNonHidden added in v0.2.4 

func (rs *Rooms) ListNonHidden() (rooms []*Room)

type Status 

type Status struct {
	Seek    float64 `json:"seek"`
	Rate    float64 `json:"rate"`
	Playing bool    `json:"playing"`
	// contains filtered or unexported fields
}

type User 

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

func NewUser 

func NewUser(id string, password string, room *Room, conf ...UserConf) (*User, error)

func (*User) Broadcast 

func (u *User) Broadcast(msg Message, conf ...BroadcastConf) error

func (*User) CheckPassword 

func (u *User) CheckPassword(password string) bool

func (*User) CheckVersion 

func (u *User) CheckVersion(version uint64) bool

func (*User) CloseHub 

func (u *User) CloseHub()

func (*User) EditMovie added in v0.2.4 

func (u *User) EditMovie(id uint64, movie BaseMovieInfo) error

func (*User) IsAdmin 

func (u *User) IsAdmin() bool

func (*User) IsRoot 

func (u *User) IsRoot() bool

func (*User) LastAct 

func (u *User) LastAct() int64

func (*User) LastActTime 

func (u *User) LastActTime() time.Time

func (*User) Movie 

func (u *User) Movie(id uint64) (*MovieInfo, error)

func (*User) Movies added in v0.2.4 

func (u *User) Movies() []*MovieInfo

func (*User) Name 

func (u *User) Name() string

func (*User) NewMovie 

func (u *User) NewMovie(url string, name string, type_ string, live bool, proxy bool, rtmpSource bool, headers map[string]string, conf ...MovieConf) (*Movie, error)

func (*User) NewMovieWithBaseMovie 

func (u *User) NewMovieWithBaseMovie(baseMovie BaseMovieInfo, conf ...MovieConf) (*Movie, error)

func (*User) RegClient 

func (u *User) RegClient(conn *websocket.Conn) (*Client, error)

func (*User) Room 

func (u *User) Room() *Room

func (*User) SetAdmin 

func (u *User) SetAdmin(admin bool)

func (*User) SetPassword 

func (u *User) SetPassword(password string) error

func (*User) SetVersion 

func (u *User) SetVersion(version uint64)

func (*User) UpdateLastAct 

func (u *User) UpdateLastAct() int64

func (*User) Version 

func (u *User) Version() uint64

type UserConf 

type UserConf func(*User)

func WithUserAdmin 

func WithUserAdmin(admin bool) UserConf

func WithUserVersion 

func WithUserVersion(version uint64) UserConf

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.