gatewayservicelogic

Documentation

Index

• Variables
• func InitWsManager(svcCtx *svc.ServiceContext)
• type GetSessionDescriptionLogic
  • func NewGetSessionDescriptionLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetSessionDescriptionLogic
  • func (l *GetSessionDescriptionLogic) GetSessionDescription(in *pb.GetSessionDescriptionReq) (*pb.GetSessionDescriptionResp, error)
• type NodeLogic
  • func NewNodeLogic(ctx context.Context, svcCtx *svc.ServiceContext) *NodeLogic
  • func (l *NodeLogic) Node(in *pb.NodeReq) (*pb.NodeResp, error)
• type WsConnection
• type WsConnectionMap
  • func (w *WsConnectionMap) Delete(userId string, connectionId int64)
  • func (w *WsConnectionMap) GetAliveTime(connectionId int64) (time.Time, bool)
  • func (w *WsConnectionMap) GetAll() []*WsConnection
  • func (w *WsConnectionMap) GetByAppId(appId string) ([]*WsConnection, bool)
  • func (w *WsConnectionMap) GetByConnectionId(connectionId int64) (*WsConnection, bool)
  • func (w *WsConnectionMap) Set(connectionId int64, value *WsConnection)
  • func (w *WsConnectionMap) SetAliveTime(ctx context.Context, connectionId int64, aliveTime time.Time)

Variables

var ErrTimeout = errors.New("timeout")

var WsManager *wsManager

Functions

func InitWsManager

func InitWsManager(svcCtx *svc.ServiceContext)

Types

type GetSessionDescriptionLogic

type GetSessionDescriptionLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewGetSessionDescriptionLogic

func NewGetSessionDescriptionLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetSessionDescriptionLogic

func (*GetSessionDescriptionLogic) GetSessionDescription

func (l *GetSessionDescriptionLogic) GetSessionDescription(in *pb.GetSessionDescriptionReq) (*pb.GetSessionDescriptionResp, error)

type NodeLogic

type NodeLogic struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewNodeLogic

func NewNodeLogic(ctx context.Context, svcCtx *svc.ServiceContext) *NodeLogic

func (*NodeLogic) Node

func (l *NodeLogic) Node(in *pb.NodeReq) (*pb.NodeResp, error)

type WsConnection

type WsConnection struct {
	Id         int64
	Connection *websocket.Conn
	AppId      string
	Ctx        context.Context
}

type WsConnectionMap

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

func (*WsConnectionMap) Delete

func (w *WsConnectionMap) Delete(userId string, connectionId int64)

func (*WsConnectionMap) GetAliveTime

func (w *WsConnectionMap) GetAliveTime(connectionId int64) (time.Time, bool)

func (*WsConnectionMap) GetAll

func (w *WsConnectionMap) GetAll() []*WsConnection

func (*WsConnectionMap) GetByAppId

func (w *WsConnectionMap) GetByAppId(appId string) ([]*WsConnection, bool)

func (*WsConnectionMap) GetByConnectionId

func (w *WsConnectionMap) GetByConnectionId(connectionId int64) (*WsConnection, bool)

func (*WsConnectionMap) Set

func (w *WsConnectionMap) Set(connectionId int64, value *WsConnection)

func (*WsConnectionMap) SetAliveTime

func (w *WsConnectionMap) SetAliveTime(ctx context.Context, connectionId int64, aliveTime time.Time)