socket

type BaseSocket struct {
	Session *Session

	SocketManager *SocketManager

	OnMessage func([]byte)

	Id string

	Logger logur.Logger

	IsClosed bool
	// contains filtered or unexported fields
}

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

type HandlerFunc func(socketManager *SocketManager, logger logur.Logger, w http.ResponseWriter, r *http.Request)

type SendRequestMessage struct {
	Id            string              `json:"id"`
	Topic         Topic               `json:"topic"`
	MessageBody   string              `json:"messageBody"`
	Headers       map[string][]string `json:"headers"`
	StatusCode    int64               `json:"statusCode"`
	Subject       string              `json:"subject"`
	ResponseTopic Topic               `json:"responseTopic"`
}

type Session titan.UserInfo

type Socket interface {
	GetId() string
	Send([]byte)
	Close()
	GetSession() *Session
}

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

type Topic string