ws

Documentation

Index

• Constants
• func MsgUnpackWsPayload(data []byte, p *WsPayload) error
• type Flag
• type WsPayload
  • func (p *WsPayload) MsgPack() ([]byte, error)
• type WsService
  • func NewWsService(mainCtx *context.Context) *WsService
  • func (p *WsService) HandleConnection(w http.ResponseWriter, r *http.Request)

Constants

const (
	SubescriptionRequest client.RequestType = "WRITE:__subscribe__"
)

Functions

func MsgUnpackWsPayload

func MsgUnpackWsPayload(data []byte, p *WsPayload) error

Types

type Flag

type Flag string

type WsPayload

type WsPayload struct {
	Id            string                 `json:"id"`
	RequestType   client.RequestType     `json:"rTy"`
	Params        map[string]interface{} `json:"params"`
	ClientPayload entities.ClientPayload `json:"pl"`
}

func (*WsPayload) MsgPack

func (p *WsPayload) MsgPack() ([]byte, error)

type WsService

type WsService struct {
	Ctx *context.Context
	Cfg *configs.MainConfiguration
	// ClientHandshakeChannel    *chan *entities.ClientHandshake
	// ClientSubscriptionChannel *chan *entities.ClientWsSubscription
	RequestProcess *client.ClientRequestProcessor
}

func NewWsService

func NewWsService(mainCtx *context.Context) *WsService

func (*WsService) HandleConnection

func (p *WsService) HandleConnection(w http.ResponseWriter, r *http.Request)