websocket

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

type HeartBeatPacket struct {
	Action string `json:"action"`
	Id     string `json:"id"`
}

type IDataPacket interface {
	GetLength() int
	GetData() []byte
	GetSendTo() string
	GetReceiveFrom() string
}

type ISession interface {
	OnClosed()
	OnStart(sSessionID string)
	OnReceive(datapacket IDataPacket) bool
	Send(datapacket IDataPacket)
	GetSessionID() string
}

type MsgHandler func(sReceiveFrom string, jsonPacket []byte)

type PushLogPacket struct {
	Action    string `json:"action"`
	Api       string `json:"api"`
	UserId    string `json:"user_id"`
	ServiceId string `json:"service_id"`
	VersionId string `json:"version_id"`
	Log       string `json:"log"`
	Id        string `json:"id"`
}

type ResponsePacket struct {
	Action    string `json:"action"`
	Response  string `json:"response"`
	IdAck     string `json:"id_ack"`
	ErrorCode int    `json:"error_code"`
	ErrorMsg  string `json:"error_msg"`
}

type ServerConfig struct {
	// ServerIP is the IP of server.
	ServerIP string `yml:"ServerIp"`
	// Port is the port of server.
	Port int `yml:"ServerPort"`
	// MaxConnectionNumber is maximum number of connections.
	MaxConnectionNumber int `yml:"MaxConnectionNumber"`
	// IdleSessionTimeOut is the timeout for idle sessions.
	IdleSessionTimeOut int64 `yml:"IdleSessionTimeOut"`
	// IdleCheckInterval is the interval for idle checks.
	IdleCheckInterval int `yml:"IdleCheckInterval"`
	// ServerCertificate is the certificate of server.
	ServerCertificate string `yml:"ServerCertificate"`
	// ServerKey is the key of server.
	ServerKey string `yml:"ServerKey"`
}

type SessionList struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type WSSession struct {

	//sync log for tapic enable flags
	sync.RWMutex
	// contains filtered or unexported fields
}

type WatchLogPacket struct {
	Action    string `json:"action"`
	Api       string `json:"api"`
	UserId    string `json:"user_id"`
	ServiceId string `json:"service_id"`
	VersionId string `json:"version_id"`
	Operation string `json:"operation"`
	Id        string `json:"id"`
}

type WorkerPushLogPacket struct {
	Action string `json:"action"`
	Topic  string `json:"topic"`
	Log    string `json:"log"`
}