qservice

Documentation

Index

• type BrokerConfig
• type InitHandler
• type MicroService
  • func NewService(setting *Setting) *MicroService
  • func (serv *MicroService) ResetClient(code string)
  • func (serv *MicroService) Run()
  • 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)
• type NoticeHandler
• type ReqHandler
• type Setting
  • func NewSetting(moduleName, moduleDesc, version string) *Setting
  • func (s *Setting) BindInitFunc(onInitHandler InitHandler) *Setting
  • func (s *Setting) BindNoticeFunc(onNoticeHandler NoticeHandler) *Setting
  • func (s *Setting) BindReqFunc(onReqHandler ReqHandler) *Setting
  • func (s *Setting) BindStateFunc(onStateHandler StateHandler) *Setting
  • func (s *Setting) SetDeviceCode(code string) *Setting
• type StateHandler

Types

type BrokerConfig

type BrokerConfig struct {
	Addr    string
	UId     string
	Pwd     string
	LogMode string
	TimeOut int
	Retry   int
}

BrokerConfig 主服务配置

type InitHandler

type InitHandler func()

InitHandler 初始化回调

type MicroService

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

func NewService

func NewService(setting *Setting) *MicroService

NewService 创建服务

func (*MicroService) ResetClient

func (serv *MicroService) ResetClient(code string)

ResetClient 重置客户端

func (*MicroService) Run

func (serv *MicroService) Run()

Run 启动服务

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 发送请求

type NoticeHandler

type NoticeHandler func(route string, ctx qdefine.Context)

NoticeHandler 通知回调

type ReqHandler

type ReqHandler func(route string, ctx qdefine.Context) (any, error)

ReqHandler 请求回调

type Setting

type Setting struct {
	Module  string       // 模块服务名称
	Desc    string       // 模块服务描述
	Version string       // 模块服务版本
	Broker  BrokerConfig // 主服务配置
	// contains filtered or unexported fields
}

Setting 模块配置

func NewSetting

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

NewSetting 创建模块配置

func (*Setting) BindInitFunc

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

func (*Setting) BindNoticeFunc

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

func (*Setting) BindReqFunc

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

func (*Setting) BindStateFunc

func (s *Setting) BindStateFunc(onStateHandler StateHandler) *Setting

func (*Setting) SetDeviceCode

func (s *Setting) SetDeviceCode(code string) *Setting

type StateHandler

type StateHandler func(state qdefine.ECommState)

StateHandler 状态回调