broker

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

type Event struct {
	Type EventType
	Peer Peer
	Room *Room
	Msg  *Message
}

type EventHandler func(Event)

type EventType int

type Handler interface {
	// HandleMessage 处理消息
	HandleMessage(from Peer, msg *Message)

	// HandleDisconnect 处理断开连接
	HandleDisconnect(from Peer)
}

type Message struct {
	Type    string         `json:"type"`
	Payload map[string]any `json:"payload"`
	To      string         `json:"to,omitempty"`
}

type Option func(*Options)

type Options struct {
	Logger          logger.Logger
	SendBufSize     int
	ChannelBufSize  int
	MaxMessageSize  int
	PeerIDGenerator func() string
	RoomAutoCleanup bool
}

type Peer interface {
	ID() string
	RoomID() string
	RemoteAddr() string
	Metadata() map[string]any
	SetMetadata(key string, value any)
	Send(msg *Message) error
	Close() error
}

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

type Transport interface {
	// ReadMessage 读取消息
	ReadMessage() ([]byte, error)

	// WriteMessage 写入消息
	WriteMessage([]byte) error

	// Close 关闭传输层
	Close() error

	// RemoteAddr 获取远程地址
	RemoteAddr() string
}