service

README

Service

Documentation

Index

• Variables
• type AlertService
  • func NewAlertService(alertBiz *biz.AlertBiz, strategyBiz *biz.StrategyBiz) *AlertService
  • func (s *AlertService) Alarm(ctx context.Context, req *alertapi.AlarmRequest) (*alertapi.AlarmReply, error)
  • func (s *AlertService) Hook(ctx context.Context, req *api.AlarmItem) (*api.HookReply, error)
  • func (s *AlertService) InnerAlarm(ctx context.Context, req bo.IStrategy) (*bo.Alarm, error)
• type HealthService
  • func NewHealthService(heartbeatBiz *biz.HeartbeatBiz) *HealthService
  • func (s *HealthService) Check(ctx context.Context, req *api.CheckRequest) (*api.CheckReply, error)
  • func (s *HealthService) Heartbeat(ctx context.Context, in *api.HeartbeatRequest) error
• type MetricService
  • func NewMetricService(metricBiz *biz.MetricBiz) *MetricService
  • func (s *MetricService) Query(ctx context.Context, req *metadataapi.QueryRequest) (*metadataapi.QueryReply, error)
  • func (s *MetricService) SyncMetadata(ctx context.Context, req *metadataapi.SyncMetadataRequest) (*metadataapi.SyncMetadataReply, error)
  • func (s *MetricService) SyncMetadataV2(ctx context.Context, req *metadataapi.SyncMetadataV2Request) (*metadataapi.SyncMetadataV2Reply, error)
• type StrategyService
  • func NewStrategyService(strategyBiz *biz.StrategyBiz) *StrategyService
  • func (s *StrategyService) PushStrategy(ctx context.Context, req *strategyapi.PushStrategyRequest) (*strategyapi.PushStrategyReply, error)

Variables

var ProviderSetService = wire.NewSet(
	NewMetricService,
	NewHealthService,
	NewStrategyService,
	NewAlertService,
)

ProviderSetService is service providers.

Types

type AlertService

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

AlertService 告警服务

func NewAlertService

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

NewAlertService 创建告警服务

func (*AlertService) Alarm

func (s *AlertService) Alarm(ctx context.Context, req *alertapi.AlarmRequest) (*alertapi.AlarmReply, error)

Alarm 告警

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.IStrategy) (*bo.Alarm, error)

InnerAlarm 内部告警

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(ctx context.Context, req *api.CheckRequest) (*api.CheckReply, error)

Check 检查

func (*HealthService) Heartbeat

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

type MetricService

type MetricService struct {
	metadataapi.UnimplementedMetricServer
	// contains filtered or unexported fields
}

MetricService 指标服务

func NewMetricService

func NewMetricService(metricBiz *biz.MetricBiz) *MetricService

NewMetricService 创建指标服务

func (*MetricService) Query

func (s *MetricService) Query(ctx context.Context, req *metadataapi.QueryRequest) (*metadataapi.QueryReply, error)

Query query metric data

func (*MetricService) SyncMetadata

func (s *MetricService) SyncMetadata(ctx context.Context, req *metadataapi.SyncMetadataRequest) (*metadataapi.SyncMetadataReply, error)

SyncMetadata sync metric data

func (*MetricService) SyncMetadataV2

func (s *MetricService) SyncMetadataV2(ctx context.Context, req *metadataapi.SyncMetadataV2Request) (*metadataapi.SyncMetadataV2Reply, error)

SyncMetadataV2 sync metric data

type StrategyService

type StrategyService struct {
	strategyapi.UnimplementedStrategyServer
	// contains filtered or unexported fields
}

StrategyService 策略服务

func NewStrategyService

func NewStrategyService(strategyBiz *biz.StrategyBiz) *StrategyService

NewStrategyService 创建策略服务

func (*StrategyService) PushStrategy

func (s *StrategyService) PushStrategy(ctx context.Context, req *strategyapi.PushStrategyRequest) (*strategyapi.PushStrategyReply, error)

PushStrategy 推送策略