Versions in this module Expand all Collapse all v2 v2.0.6 Jul 6, 2022 Changes in this version + type AllMembers struct + Members []string + type Connector struct + func NewConnector(app pitaya.Pitaya) *Connector + func (c *Connector) GetSessionData(ctx context.Context) (*SessionData, error) + func (c *Connector) NotifySessionData(ctx context.Context, data *SessionData) + func (c *Connector) SendPushToUser(ctx context.Context, msg *UserMessage) (*Response, error) + func (c *Connector) SetSessionData(ctx context.Context, data *SessionData) (*Response, error) + type ConnectorRemote struct + func (c *ConnectorRemote) RemoteFunc(ctx context.Context, msg *protos.RPCMsg) (*protos.RPCRes, error) + type JoinResponse struct + Code int + Result string + type NewUser struct + Content string + type Response struct + Code int32 + Msg string + type Room struct + Stats *Stats + func NewRoom(app pitaya.Pitaya) *Room + func (r *Room) AfterInit() + func (r *Room) Entry(ctx context.Context, msg []byte) (*JoinResponse, error) + func (r *Room) GetSessionData(ctx context.Context) (*SessionData, error) + func (r *Room) Init() + func (r *Room) Join(ctx context.Context) (*JoinResponse, error) + func (r *Room) Message(ctx context.Context, msg *UserMessage) + func (r *Room) MessageRemote(ctx context.Context, msg *UserMessage, b bool, s string) (*UserMessage, error) + func (r *Room) SendRPC(ctx context.Context, msg *protos.RPCMsg) (*protos.RPCRes, error) + func (r *Room) SetSessionData(ctx context.Context, data *SessionData) ([]byte, error) + type SendRPCMsg struct + Msg string + Route string + ServerID string + type SessionData struct + Data map[string]interface{} + type Stats struct + func (Stats *Stats) Inbound(ctx context.Context, in []byte) ([]byte, error) + func (Stats *Stats) Outbound(ctx context.Context, in []byte) ([]byte, error) + type UserMessage struct + Content string + Name string Other modules containing this package github.com/ltellesfl/pitaya
Go to main page