api

Documentation

Index

• type AllOrderUser
  • func NewAllOrderUser() *AllOrderUser
• type ClusterUserNum
• type Conn
• type GroupInfo
• type GroupMsg
• type History
• type MachineInfo
• type MachineInfos
• type OrderUser
• type Page
  • func NewPage() *Page
  • func (p *Page) AddNum(num int)
  • func (p *Page) AddPage(page *Page)
  • func (p *Page) AddPageUser(list []*PageUser)
• type PageTimeWheelLog
• type PageUser
• type Query
  • func NewQuery(context *core.Context, server core.IHttpServer) *Query
  • func (query *Query) AddQuery(handleName string, handle core.RegisterHandle, ...)
  • func (query *Query) Init()
• type ResponseMsg
  • func NewResponseMsg(fa bool) *ResponseMsg
• type Server
  • func NewServer() *Server
  • func (server *Server) Init(context *core.Context)
  • func (server *Server) Name() string
  • func (server *Server) Start() error
• type TimeWheelLog
• type TimeWheelLogsByAsc
  • func (p TimeWheelLogsByAsc) Len() int
  • func (p TimeWheelLogsByAsc) Less(i, j int) bool
  • func (p TimeWheelLogsByAsc) Swap(i, j int)
• type User

Types

type AllOrderUser

type AllOrderUser struct {
	OrderUser      []*OrderUser
	MachineId      string
	MachineAddress string
}

func NewAllOrderUser

func NewAllOrderUser() *AllOrderUser

type ClusterUserNum

type ClusterUserNum struct {
	UserNum   any
	MachineId string
}

type Conn

type Conn struct {
	RemoteAddress string
	LastLiveTime  string
	CreateTime    string
	GroupIds      []string
}

type GroupInfo

type GroupInfo struct {
	MachineAddress string
	MachineId      string
	GroupInfo      map[string]int
}

type GroupMsg

type GroupMsg struct {
	MachineAddress string
	Num            int32
	MachineId      string
}

type History

type History struct {
	Machine string
	History *user.HistoryMessage
}

type MachineInfo

type MachineInfo struct {
	Address   string
	UserNum   int
	MachineId string
}

type MachineInfos

type MachineInfos struct {
	List  []*MachineInfo `json:"cluster"`
	Total int            `json:"total"`
}

type OrderUser

type OrderUser struct {
	Priority  int
	MachineId string
	OrderTime string
}

type Page

type Page struct {
	Num  int
	List []*PageUser
}

func NewPage

func NewPage() *Page

func (*Page) AddNum

func (p *Page) AddNum(num int)

func (*Page) AddPage

func (p *Page) AddPage(page *Page)

func (*Page) AddPageUser

func (p *Page) AddPageUser(list []*PageUser)

type PageTimeWheelLog

type PageTimeWheelLog struct {
	MachineAddress string
	MachineId      string
	TimeWheelLogs  []*TimeWheelLog
}

type PageUser

type PageUser struct {
	UserName       string
	MachineAddress string
	CreateTime     string
	MachineId      string
	Conn           []*Conn
}

type Query

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

func NewQuery

func NewQuery(context *core.Context, server core.IHttpServer) *Query

func (*Query) AddQuery

func (query *Query) AddQuery(handleName string, handle core.RegisterHandle, handler func(http.ResponseWriter, *http.Request))

func (*Query) Init

func (query *Query) Init()

type ResponseMsg

type ResponseMsg struct {
	Time   string
	Result string
}

func NewResponseMsg

func NewResponseMsg(fa bool) *ResponseMsg

type Server

type Server struct {
	core.IHttpServer
	// contains filtered or unexported fields
}

func NewServer

func NewServer() *Server

func (*Server) Init

func (server *Server) Init(context *core.Context)

func (*Server) Name

func (server *Server) Name() string

func (*Server) Start

func (server *Server) Start() error

type TimeWheelLog

type TimeWheelLog struct {
	Num       int
	Cha       int
	StartTime string
	EndTime   string
}

type TimeWheelLogsByAsc

type TimeWheelLogsByAsc []*TimeWheelLog

func (TimeWheelLogsByAsc) Len

func (p TimeWheelLogsByAsc) Len() int

func (TimeWheelLogsByAsc) Less

func (p TimeWheelLogsByAsc) Less(i, j int) bool

func (TimeWheelLogsByAsc) Swap

func (p TimeWheelLogsByAsc) Swap(i, j int)

type User

type User struct {
	Username   string
	Conn       []*Conn
	Machine    any
	CreateTime string
}