service

README

Service

Documentation

Index

• Variables
• type AlertService
  • func NewAlertService(alertBiz *biz.AlarmBiz, strategyBiz *biz.StrategyBiz) *AlertService
  • func (s *AlertService) CreateAlarmInfo(ctx context.Context, params *bo.CreateAlarmHookRawParams) error
  • func (s *AlertService) Hook(ctx context.Context, req *api.AlarmItem) (*api.HookReply, error)
  • func (s *AlertService) InnerAlarm(ctx context.Context, req *bo.Strategy) (*bo.Alarm, error)
  • func (s *AlertService) PushStrategy(ctx context.Context, strategies watch.Indexer) error
  • func (s *AlertService) SendAlertMsg(ctx context.Context, req *hookapi.SendMsgRequest) error
• type HealthService
  • func NewHealthService(houyiSrv *data.HouYiConn) *HealthService
  • func (s *HealthService) Check(ctx context.Context, req *api.CheckRequest) (*api.CheckReply, error)
• type ServerService
  • func NewServerService(serverRegisterBiz *biz.ServerRegisterBiz) *ServerService
  • func (s *ServerService) GetServerInfo(ctx context.Context, req *pb.GetServerInfoRequest) (*pb.GetServerInfoReply, error)
  • func (s *ServerService) GetServerList(ctx context.Context, req *pb.GetServerListRequest) (*pb.GetServerListReply, error)
  • func (s *ServerService) Heartbeat(ctx context.Context, req *pb.HeartbeatRequest) (*pb.HeartbeatReply, error)

Variables

var ProviderSetService = wire.NewSet(
	NewHealthService,
	user.NewUserService,
	user.NewMessageService,
	authorization.NewAuthorizationService,
	resource.NewResourceService,
	menu.NewMenuService,
	team.NewTeamService,
	team.NewRoleService,
	datasource.NewDatasourceService,
	datasource.NewMetricService,
	datasource.NewMqDatasourceService,
	strategy.NewStrategyService,
	strategy.NewTemplateService,
	dict.NewDictService,
	realtime.NewDashboardService,
	realtime.NewAlarmService,
	alarm.NewAlarmService,
	alarm.NewSendService,
	realtime.NewAlarmPageSelfService,
	subscriber.NewSubscriberService,
	hookservice.NewHookService,
	NewAlertService,
	invite.NewInviteService,
	historyservice.NewHistoryService,
	fileservice.NewFileService,
	NewServerService,
	system.NewSystemService,
)

ProviderSetService is service providers.

Types

type AlertService

type AlertService struct {
	api.UnimplementedAlertServer
	// contains filtered or unexported fields
}

AlertService alert service

func NewAlertService

func NewAlertService(alertBiz *biz.AlarmBiz, strategyBiz *biz.StrategyBiz) *AlertService

NewAlertService 创建告警服务

func (*AlertService) CreateAlarmInfo

func (s *AlertService) CreateAlarmInfo(ctx context.Context, params *bo.CreateAlarmHookRawParams) error

CreateAlarmInfo 创建告警信息

func (*AlertService) Hook

func (s *AlertService) Hook(ctx context.Context, req *api.AlarmItem) (*api.HookReply, error)

Hook 告警hook

func (*AlertService) InnerAlarm

func (s *AlertService) InnerAlarm(ctx context.Context, req *bo.Strategy) (*bo.Alarm, error)

InnerAlarm 内部告警

func (*AlertService) PushStrategy

func (s *AlertService) PushStrategy(ctx context.Context, strategies watch.Indexer) error

PushStrategy 推送策略

func (*AlertService) SendAlertMsg

func (s *AlertService) SendAlertMsg(ctx context.Context, req *hookapi.SendMsgRequest) error

SendAlertMsg 发送告警消息

type HealthService

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

HealthService 健康检查

func NewHealthService

func NewHealthService(houyiSrv *data.HouYiConn) *HealthService

NewHealthService 创建健康检查服务

func (*HealthService) Check

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

Check 检查

type ServerService

type ServerService struct {
	pb.UnimplementedServerServer
	// contains filtered or unexported fields
}

ServerService 服务管理

func NewServerService

func NewServerService(serverRegisterBiz *biz.ServerRegisterBiz) *ServerService

NewServerService 创建服务管理

func (*ServerService) GetServerInfo

func (s *ServerService) GetServerInfo(ctx context.Context, req *pb.GetServerInfoRequest) (*pb.GetServerInfoReply, error)

GetServerInfo 获取服务信息

func (*ServerService) GetServerList

func (s *ServerService) GetServerList(ctx context.Context, req *pb.GetServerListRequest) (*pb.GetServerListReply, error)

GetServerList 获取服务列表

func (*ServerService) Heartbeat

func (s *ServerService) Heartbeat(ctx context.Context, req *pb.HeartbeatRequest) (*pb.HeartbeatReply, error)

Heartbeat 心跳