service

Documentation

Index

• Variables
• type HookInterflowService
  • func NewHookInterflowService(interflowConf *conf.Interflow, logger log.Logger) *HookInterflowService
  • func (s *HookInterflowService) Receive(ctx context.Context, req *pb.ReceiveRequest) (*pb.ReceiveResponse, error)
• type HookService
  • func NewHookService(logger log.Logger) *HookService
  • func (s *HookService) V1(ctx context.Context, req *pb.HookV1Request) (*pb.HookV1Reply, error)
• type LoadService
  • func NewLoadService(alarmBiz *biz.AlarmBiz, evaluateBiz *biz.EvaluateBiz, logger log.Logger) *LoadService
  • func (s *LoadService) Evaluate(_ context.Context, req *pb.EvaluateRequest) (*pb.EvaluateReply, error)
  • func (s *LoadService) EvaluateV2(ctx context.Context, req *pb.EvaluateV2Request) (*pb.EvaluateV2Reply, error)
  • func (s *LoadService) GenerateRecoveryEvent(oldGroupInfo, newGroupInfo *api.EvaluateGroup) []*agent.Alarm
  • func (s *LoadService) SendRecoveryEventAlarm(ctx context.Context, alarms ...*agent.Alarm) error
• type PingService
  • func NewPingService(uc *biz.PingBiz, logger log.Logger) *PingService
  • func (s *PingService) Check(ctx context.Context, in *ping.PingRequest) (*ping.PingReply, error)

Variables

var ProviderSetService = wire.NewSet(
	NewPingService,
	NewLoadService,
	NewHookService,
	NewHookInterflowService,
)

ProviderSetService is service providers.

Types

type HookInterflowService

type HookInterflowService struct {
	pb.UnimplementedHookInterflowServer
	// contains filtered or unexported fields
}

func NewHookInterflowService

func NewHookInterflowService(interflowConf *conf.Interflow, logger log.Logger) *HookInterflowService

func (*HookInterflowService) Receive

func (s *HookInterflowService) Receive(ctx context.Context, req *pb.ReceiveRequest) (*pb.ReceiveResponse, error)

type HookService

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

func NewHookService

func NewHookService(logger log.Logger) *HookService

func (*HookService) V1

func (s *HookService) V1(ctx context.Context, req *pb.HookV1Request) (*pb.HookV1Reply, error)

type LoadService

type LoadService struct {
	pb.UnimplementedLoadServer
	// contains filtered or unexported fields
}

func NewLoadService

func NewLoadService(alarmBiz *biz.AlarmBiz, evaluateBiz *biz.EvaluateBiz, logger log.Logger) *LoadService

func (*LoadService) Evaluate

func (s *LoadService) Evaluate(_ context.Context, req *pb.EvaluateRequest) (*pb.EvaluateReply, error)

func (*LoadService) EvaluateV2

func (s *LoadService) EvaluateV2(ctx context.Context, req *pb.EvaluateV2Request) (*pb.EvaluateV2Reply, error)

EvaluateV2 批量处理groupList

func (*LoadService) GenerateRecoveryEvent

func (s *LoadService) GenerateRecoveryEvent(oldGroupInfo, newGroupInfo *api.EvaluateGroup) []*agent.Alarm

GenerateRecoveryEvent 生成告警恢复事件

func (*LoadService) SendRecoveryEventAlarm

func (s *LoadService) SendRecoveryEventAlarm(ctx context.Context, alarms ...*agent.Alarm) error

SendRecoveryEventAlarm 批量处理告警恢复事件

type PingService

type PingService struct {
	ping.UnimplementedPingServer
	// contains filtered or unexported fields
}

PingService is a Ping service.

func NewPingService

func NewPingService(uc *biz.PingBiz, logger log.Logger) *PingService

NewPingService new a Ping service.

func (*PingService) Check

func (s *PingService) Check(ctx context.Context, in *ping.PingRequest) (*ping.PingReply, error)

Check implements ping.Check