models

Documentation

Index

• Constants
• type ChatRequest
• type ChatResponse
• type ISession
• type MyClaims
• type Session
  • func (s *Session) Close() error
  • func (s *Session) ReadLoop()
  • func (s *Session) WriteMessage(msg ChatResponse) error

Constants

const (
	ErrorMessageType     = "error"
	ChatMessageType      = "chat"
	SubscribeMessageType = "subscribe"
)

Types

type ChatRequest

type ChatRequest struct {
	Type        string `json:"type" validate:"required,oneof=chat subscribe"`
	Data        string `json:"data" validate:"required,max=500"`
	Destination string `json:"destination" validate:"max=50"`
}

type ChatResponse

type ChatResponse struct {
	Type      string `json:"type"`
	Data      string `json:"data"`
	From      string `json:"from"`
	Timestamp string `json:"timestamp"`
}

type ISession

type ISession interface {
	WriteMessage(msg ChatResponse) error
	ReadLoop()
	Close() error
}

type MyClaims

type MyClaims struct {
	UserID   string
	UserName string
}

type Session

type Session struct {
	Id               string
	Conn             net.Conn
	Validator        *validator.Validate
	Log              *zap.SugaredLogger
	Authenticated    bool
	Claims           MyClaims
	OnMessageHandler func(session *Session, msg ChatRequest)
	OnErrorHandler   func(session *Session, err error)
	OnClose          func(session *Session)
}

func (*Session) Close

func (s *Session) Close() error

func (*Session) ReadLoop

func (s *Session) ReadLoop()

func (*Session) WriteMessage

func (s *Session) WriteMessage(msg ChatResponse) error