service

README

Service

Documentation

Index

• Variables
• type ConfigService
  • func NewConfigService(configBiz *biz.ConfigBiz) *ConfigService
  • func (s *ConfigService) LoadNotifyObject(ctx context.Context) error
  • func (s *ConfigService) NotifyObject(ctx context.Context, req *pushapi.NotifyObjectRequest) (*pushapi.NotifyObjectReply, error)
• type HealthService
  • func NewHealthService(heartbeatBiz *biz.HeartbeatBiz) *HealthService
  • func (s *HealthService) Check(_ context.Context, _ *api.CheckRequest) (*api.CheckReply, error)
  • func (s *HealthService) Heartbeat(ctx context.Context, in *api.HeartbeatRequest) error
• type HookService
  • func NewHookService(msgBiz *biz.MsgBiz) *HookService
  • func (s *HookService) HookSendMsgHTTPHandler() func(ctx http.Context) error
  • func (s *HookService) Send(ctx context.Context, req *bo.SendMsgParams) error
  • func (s *HookService) SendMsg(ctx context.Context, req *hookapi.SendMsgRequest) (*hookapi.SendMsgReply, error)

Variables

var ProviderSetService = wire.NewSet(
	NewConfigService,
	NewHookService,
	NewHealthService,
)

ProviderSetService is service providers.

Types

type ConfigService

type ConfigService struct {
	pushapi.UnimplementedConfigServer
	// contains filtered or unexported fields
}

ConfigService 配置服务

func NewConfigService

func NewConfigService(configBiz *biz.ConfigBiz) *ConfigService

NewConfigService 创建配置服务

func (*ConfigService) LoadNotifyObject

func (s *ConfigService) LoadNotifyObject(ctx context.Context) error

LoadNotifyObject 加载配置

func (*ConfigService) NotifyObject

func (s *ConfigService) NotifyObject(ctx context.Context, req *pushapi.NotifyObjectRequest) (*pushapi.NotifyObjectReply, error)

NotifyObject 配置模板同步

type HealthService

type HealthService struct {
	api.UnimplementedHealthServer
	// contains filtered or unexported fields
}

HealthService 健康检查

func NewHealthService

func NewHealthService(heartbeatBiz *biz.HeartbeatBiz) *HealthService

NewHealthService 创建健康检查服务

func (*HealthService) Check

func (s *HealthService) Check(_ context.Context, _ *api.CheckRequest) (*api.CheckReply, error)

Check 检查

func (*HealthService) Heartbeat

func (s *HealthService) Heartbeat(ctx context.Context, in *api.HeartbeatRequest) error

Heartbeat 心跳包

type HookService

type HookService struct {
	hookapi.UnimplementedHookServer
	// contains filtered or unexported fields
}

HookService hook服务

func NewHookService

func NewHookService(msgBiz *biz.MsgBiz) *HookService

NewHookService 创建hook服务

func (*HookService) HookSendMsgHTTPHandler

func (s *HookService) HookSendMsgHTTPHandler() func(ctx http.Context) error

HookSendMsgHTTPHandler hook发送消息http handler

func (*HookService) Send

func (s *HookService) Send(ctx context.Context, req *bo.SendMsgParams) error

Send 发送消息

func (*HookService) SendMsg

func (s *HookService) SendMsg(ctx context.Context, req *hookapi.SendMsgRequest) (*hookapi.SendMsgReply, error)

SendMsg 发送消息