Documentation ¶
Index ¶
- Constants
- Variables
- func JSONMarshal(t interface{}) ([]byte, error)
- func RegisterService[T any](rcvr *T, client *Client)
- type Client
- func (client *Client) Close()
- func (client *Client) Connect()
- func (client *Client) GetRpcClientForService(service any) *rpc.Client
- func (client *Client) GetServiceName(service any, method string, target *string) string
- func (client *Client) Handle(message *hub.SessionMessage, reply *string) error
- func (c *Client) JoinSession(username string, session string) string
- func (client *Client) MemberJoin(message *hub.RegisteredMessage, reply *string) error
- func (client *Client) OnBinaryMessage(data []byte, socket interface{})
- func (client *Client) OnConnectError(err error, socket interface{})
- func (client *Client) OnConnected(sock interface{})
- func (client *Client) OnDisconnected(err error, socket interface{})
- func (client *Client) OnTextMessage(message string, socket interface{})
- func (client *Client) ParticipantLeave(message *hub.LeavingMessage, reply *string) error
- func (client *Client) Registered(message *hub.RegisteredMessage, reply *string) error
- func (client *Client) SessionClosed(message *hub.ClosedMessage, reply *string) error
- func (c *Client) SessionMembers() hub.MembersMessageResponse
- func (c *Client) StartHosting(username string) string
- type SessionChangeEvent
Constants ¶
View Source
const ( SESSION_JOIN = 3 SESSION_LEAVE = 4 SESSION_END = 5 )
Variables ¶
View Source
var IncommingMessage = signals.New[[]byte]()
Functions ¶
func JSONMarshal ¶
func RegisterService ¶
Types ¶
type Client ¶
type Client struct { Id *string Session *string Host bool OnSessionChange func(event SessionChangeEvent) Interrupt chan int OnConnect func() Services map[string]*rpc.Client // contains filtered or unexported fields }
func (*Client) GetRpcClientForService ¶
func (*Client) GetServiceName ¶
func (*Client) Handle ¶
func (client *Client) Handle(message *hub.SessionMessage, reply *string) error
func (*Client) MemberJoin ¶
func (client *Client) MemberJoin(message *hub.RegisteredMessage, reply *string) error
func (*Client) OnBinaryMessage ¶
func (*Client) OnConnectError ¶
func (*Client) OnConnected ¶
func (client *Client) OnConnected(sock interface{})
func (*Client) OnDisconnected ¶
func (*Client) OnTextMessage ¶
func (*Client) ParticipantLeave ¶
func (client *Client) ParticipantLeave(message *hub.LeavingMessage, reply *string) error
func (*Client) Registered ¶
func (client *Client) Registered(message *hub.RegisteredMessage, reply *string) error
func (*Client) SessionClosed ¶
func (client *Client) SessionClosed(message *hub.ClosedMessage, reply *string) error
func (*Client) SessionMembers ¶
func (c *Client) SessionMembers() hub.MembersMessageResponse
func (*Client) StartHosting ¶
type SessionChangeEvent ¶
Click to show internal directories.
Click to hide internal directories.