room

Nov 13, 2024

Changes in this version

+ const BroadcastType

+ const ClientError

+ const CloseType

+ const ConnectType

+ const ErrorType

+ const JoinType

+ const LeaveType

+ const MessageContentError

+ const MessageType

+ const NetWorkTimeoutError

+ const PingType

+ const PongType

+ const RoomCloseError

+ const RoomNotFoundError

+ const ServeError

+ const StartType

+ const UnknownError

+ const UnknownType

+ const UpdateRoomInfoType

+ func IsPublicMessageType(messageType string) bool

+ func NewMessageContent(messageType string) interface

+ func NotMessageType(messageType string) bool

+ type BasicInfo struct

+ Group string

+ Name string

+ Tags map[string]string

+ type BasicRpcResponse struct

+ Error *Error

+ func (b *BasicRpcResponse) GetError() error

+ func (b *BasicRpcResponse) SetError(err error) error

+ type BasicRpcResponseInterface interface

+ GetError func() error

+ type BroadcastMessageContent struct

+ Data json.RawMessage

+ From *Connection

+ IncludeSelf bool

+ type ConnectMessageContent struct

+ RoomConnections []*Connection

+ SelfConnection *Connection

+ type Connection struct

+ Address *event.Address

+ CreatedAt time.Time

+ Name string

+ UserID string

+ type Error struct

+ Code ErrorCode

+ Message string

+ func NewClientError(msg string, a ...any) *Error

+ func NewError(msg string) *Error

+ func NewErrorWithCode(msg string, code ErrorCode) *Error

+ func NewMessageContentError(msg string, a ...any) *Error

+ func NewNetWorkTimeoutError(msg string, a ...any) *Error

+ func NewRoomCloseError(msg string, a ...any) *Error

+ func NewRoomNotFoundError(msg string, a ...any) *Error

+ func NewServeError(msg string, a ...any) *Error

+ func (e *Error) Error() string

+ type ErrorCode string

+ type ErrorMessageContent struct

+ Code string

+ Message string

+ type Info struct

+ ActiveAt time.Time

+ Address *event.Address

+ Connections []*Connection

+ CreatedAt time.Time

+ Secret string

+ UseSecret bool

+ func NewRoomInfo(name string, secret string, useSecret bool, tags map[string]string, ...) *Info

+ func (i *Info) Update(info *Info)

+ type JoinOrLeaveMessageContent struct

+ Connection *Connection

+ type ManagerRoom interface

+ Close func(ctx context.Context, closeCode string) error

+ IsClose func() bool

+ ShouldRemove func() (string, bool)

+ type Message struct

+ Content interface{}

+ CreatedAt int64

+ RequestId string

+ Type string

+ func NewBroadcastMessage(data json.RawMessage, from *Connection) *Message

+ func NewCloseMessage(roomAddress event.Address, reason string) *Message

+ func NewConnectMessage(selfConnection *Connection, roomConnections []*Connection) *Message

+ func NewJoinMessage(connection *Connection) *Message

+ func NewLeaveMessage(connection *Connection) *Message

+ func NewPingMessage(from event.Address) *Message

+ func NewSendMessage(data json.RawMessage, from *Connection, to *Connection) *Message

+ func NewStartMessage(roomAddress event.Address) *Message

+ func (m *Message) GetPong() *Message

+ func (m *Message) ToString() string

+ type MessageMessageContent struct

+ Data json.RawMessage

+ From *Connection

+ To *Connection

+ type PingContent struct

+ From event.Address

+ type RawMessage struct

+ Content json.RawMessage

+ CreatedAt int64

+ RequestId string

+ Type string

+ func (rm *RawMessage) ToMessage() (*Message, error)

+ type RemoteRoom interface

+ Done func() chan struct{}

+ OnMessage func() chan *Message

+ SendMessage func(ctx context.Context, msg *Message) error

+ Start func(ctx context.Context) error

+ type Room interface

+ GetRoomUsers func() []*Connection

+ Join func(ctx context.Context, connection *Connection, opt *Info) error

+ Leave func(ctx context.Context, connection *Connection, opt *Info) error

+ Ping func()

+ type RpcRoom interface

+ GetInfo func() *Info

+ GetRoomAddress func() *event.Address

+ UpdateInfo func(info *Info)

+ type StartOrCloseMessageContent struct

+ Reason string

+ RoomAddress event.Address

+ type UpdateRoomInfoContent struct

+ Info *Info