qservice

Documentation

Index

• func GetErrors(moduleName string, lineCount int) string
• type Args
• type EServerMode
  • func (mode EServerMode) IsClient() bool
  • func (mode EServerMode) IsServer() bool
• type LogConfig
• type MicroService
  • func NewService(setting *Setting) *MicroService
  • func (serv *MicroService) Adapter() easyCon.IAdapter
  • func (serv *MicroService) ResetClient()
  • func (serv *MicroService) Run()
  • func (serv *MicroService) SendAlarm(alarmType string, alarmValue string) error
  • func (serv *MicroService) SendLog(logType qdefine.ELog, content string, err error)
  • func (serv *MicroService) SendNotice(route string, content any)
  • func (serv *MicroService) SendRequest(module, route string, params any) (qdefine.Context, error)
  • func (serv *MicroService) Setting() Setting
  • func (serv *MicroService) Stop()
• type Setting
  • func NewSetting(moduleName, moduleDesc, version string) *Setting
  • func (s *Setting) BindCommStateFunc(onStateHandler qdefine.StateHandler) *Setting
  • func (s *Setting) BindInitFunc(onInitHandler qdefine.InitHandler) *Setting
  • func (s *Setting) BindNoticeFunc(onNoticeHandler qdefine.NoticeHandler) *Setting
  • func (s *Setting) BindReqFunc(onReqHandler qdefine.ReqHandler) *Setting
  • func (s *Setting) BindRespDetectedFunc(onDetectedHandler qdefine.DetectedHandler) *Setting
  • func (s *Setting) ReloadByCustomArgs(args Args)

Functions

func GetErrors

func GetErrors(moduleName string, lineCount int) string

Types

type Args

type Args struct {
	Module     string
	Broker     qdefine.BrokerConfig
	DeviceCode string
	DeviceName string
	ConfigPath string
	LogPath    string
}

type EServerMode

type EServerMode string

const (
	EModeClient EServerMode = "client"
	EModeServer EServerMode = "server"
)

func (EServerMode) IsClient

func (mode EServerMode) IsClient() bool

func (EServerMode) IsServer

func (mode EServerMode) IsServer() bool

type LogConfig

type LogConfig struct {
	Path        string
	RemainDay   int
	RemainLevel int
}

type MicroService

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

func NewService

func NewService(setting *Setting) *MicroService

NewService 创建服务

func (*MicroService) Adapter

func (serv *MicroService) Adapter() easyCon.IAdapter

Adapter 获取访问器

func (*MicroService) ResetClient

func (serv *MicroService) ResetClient()

ResetClient 重置客户端

func (*MicroService) Run

func (serv *MicroService) Run()

Run 启动服务

func (*MicroService) SendAlarm

func (serv *MicroService) SendAlarm(alarmType string, alarmValue string) error

func (*MicroService) SendLog

func (serv *MicroService) SendLog(logType qdefine.ELog, content string, err error)

SendLog 发送日志

func (*MicroService) SendNotice

func (serv *MicroService) SendNotice(route string, content any)

SendNotice 发送通知

func (*MicroService) SendRequest

func (serv *MicroService) SendRequest(module, route string, params any) (qdefine.Context, error)

SendRequest 向服务器其他模块发送请求，单机两者效果一致

func (*MicroService) Setting

func (serv *MicroService) Setting() Setting

Setting 获取设置

func (*MicroService) Stop

func (serv *MicroService) Stop()

Stop 停止

type Setting

type Setting struct {
	Mode           EServerMode          // 路由模式
	Module         string               // 模块服务名称
	Desc           string               // 模块服务描述
	Version        string               // 模块服务版本
	DevCode        string               // 设备码
	Broker         qdefine.BrokerConfig // 主服务配置
	DetectedRoutes []string             // 需要对外暴露的方法列表
	// contains filtered or unexported fields
}

Setting 模块配置

func NewSetting

func NewSetting(moduleName, moduleDesc, version string) *Setting

NewSetting 创建模块配置

func (*Setting) BindCommStateFunc

func (s *Setting) BindCommStateFunc(onStateHandler qdefine.StateHandler) *Setting

func (*Setting) BindInitFunc

func (s *Setting) BindInitFunc(onInitHandler qdefine.InitHandler) *Setting

func (*Setting) BindNoticeFunc

func (s *Setting) BindNoticeFunc(onNoticeHandler qdefine.NoticeHandler) *Setting

func (*Setting) BindReqFunc

func (s *Setting) BindReqFunc(onReqHandler qdefine.ReqHandler) *Setting

func (*Setting) BindRespDetectedFunc

func (s *Setting) BindRespDetectedFunc(onDetectedHandler qdefine.DetectedHandler) *Setting

func (*Setting) ReloadByCustomArgs

func (s *Setting) ReloadByCustomArgs(args Args)