rwmessage

Documentation

Index

• Variables
• func NewHdOp(send chan *SendData) *admin
• type Data
• type HdGroup
  • func NewHdGroup(id int, serveSend chan *SendData) *HdGroup
  • func (u *HdGroup) GetStatus() string
  • func (u *HdGroup) Kill() (string, error)
  • func (u *HdGroup) Restart() (string, error)
  • func (u *HdGroup) Run()
  • func (u *HdGroup) RunCmd(commd string) (string, error)
  • func (u *HdGroup) Send_all_group_msg(msg string, a ...interface{})
  • func (u *HdGroup) Send_group_msg(group int, msg string, a ...interface{})
  • func (u *HdGroup) Start() (string, error)
  • func (u *HdGroup) Stop() (string, error)
• type InstanceConfig
• type MsgData
• type RemoteStatus
• type SendData
• type Server
  • func NewServer(url string) *Server
  • func (s *Server) Run()

Variables

var (
	// 已监听群组 map[id](*HdGroup)
	GOnlineMap = make(map[int]*HdGroup)

	// map[群号](id)
	GroupToId = make(map[int]([]int))

	// map[id](config index)
	IdToOd  = make(map[int]int)
	Mconfig = gconfig.Mconfig
	Qconfig = gconfig.Qconfig
	AllId   = gconfig.GetAllId()
)

Functions

func NewHdOp

func NewHdOp(send chan *SendData) *admin

Types

type Data

type Data struct {
	Data string `json:"data"`
}

type HdGroup

type HdGroup struct {
	ChGroupMsg chan *MsgData
	SendChan   chan *SendData
	// contains filtered or unexported fields
}

func NewHdGroup

func NewHdGroup(id int, serveSend chan *SendData) *HdGroup

func (*HdGroup) GetStatus

func (u *HdGroup) GetStatus() string

func (*HdGroup) Kill

func (u *HdGroup) Kill() (string, error)

func (*HdGroup) Restart

func (u *HdGroup) Restart() (string, error)

func (*HdGroup) Run

func (u *HdGroup) Run()

func (*HdGroup) RunCmd

func (u *HdGroup) RunCmd(commd string) (string, error)

返回控制台结果，如果未查询到则返回 "运行成功"

func (*HdGroup) Send_all_group_msg

func (u *HdGroup) Send_all_group_msg(msg string, a ...interface{})

func (*HdGroup) Send_group_msg

func (u *HdGroup) Send_group_msg(group int, msg string, a ...interface{})

func (*HdGroup) Start

func (u *HdGroup) Start() (string, error)

func (*HdGroup) Stop

func (u *HdGroup) Stop() (string, error)

type InstanceConfig

type InstanceConfig struct {
	Data struct {
		Status int `json:"status"`
		Config struct {
			Nickname       string `json:"nickname"`
			EndTime        string `json:"endTime"`
			ProcessType    string `json:"processType"`
			TerminalOption struct {
				Pty bool `json:"pty"`
			} `json:"terminalOption"`
			PingConfig struct {
				PingIp string `json:"ip"`
			} `json:"pingConfig"`
		} `json:"config"`
		Info struct {
			CurrentPlayers string `json:"currentPlayers"`
			MaxPlayers     string `json:"maxPlayers"`
			Version        string `json:"version"`
		} `json:"info"`
	} `json:"data"`
}

type MsgData

type MsgData struct {
	Post_type    string `json:"post_type"`
	Message_type string `json:"message_type"`
	Message_id   int    `json:"message_id"`
	User_id      int    `json:"user_id"`
	Group_id     int    `json:"group_id"`
	Message      string `json:"message"`
	Sender       struct {
		Nickname string `json:"nickname"`
	} `json:"sender"`

	Params []string
}

type RemoteStatus

type RemoteStatus struct {
	Data struct {
		RemoteCount struct {
			Total     int `json:"total"`
			Available int `json:"available"`
		} `json:"remoteCount"`
		Remote []struct {
			Instance struct {
				Total   int `json:"total"`
				Running int `json:"running"`
			} `json:"instance"`
			System struct {
				Platform string  `json:"platform"`
				CpuUsage float64 `json:"cpuUsage"`
				MemUsage float64 `json:"memUsage"`
			} `json:"system"`
			Ip        string `json:"ip"`
			Port      string `json:"port"`
			Available bool   `json:"available"`
			Remarks   string `json:"remarks"`
		} `json:"remote"`
	} `json:"data"`
}

type SendData

type SendData struct {
	Action string `json:"action"`
	Params struct {
		Group_id int    `json:"group_id"`
		User_id  int    `json:"user_id"`
		Message  string `json:"message"`
	} `json:"params"`
}

type Server

type Server struct {
	Url         string
	SendMessage chan *SendData
	// contains filtered or unexported fields
}

func NewServer

func NewServer(url string) *Server

func (*Server) Run

func (s *Server) Run()