biz

README

Biz

Documentation

Index

• Variables
• type AlertBiz
  • func NewAlertBiz(alertRepository repository.Alert, cacheRepo repository.CacheRepo) *AlertBiz
  • func (a *AlertBiz) PushAlarm(ctx context.Context, alarm *bo.Alarm) (err error)
  • func (a *AlertBiz) SaveAlarm(ctx context.Context, alarm *bo.Alarm) error
• type HeartbeatBiz
  • func NewHeartbeatBiz(heartbeatRepository repository.Heartbeat) *HeartbeatBiz
  • func (h *HeartbeatBiz) Heartbeat(ctx context.Context, in *api.HeartbeatRequest) error
• type MetricBiz
  • func NewMetricBiz(metricRepository repository.Metric) *MetricBiz
  • func (b *MetricBiz) PushMetric(req *bo.PushMetricParams) error
  • func (b *MetricBiz) Query(ctx context.Context, req *bo.QueryQLParams) ([]*datasource.QueryResponse, error)
  • func (b *MetricBiz) SyncMetrics(ctx context.Context, datasourceInfo *bo.GetMetricsParams) ([]*bo.MetricDetail, error)
• type StrategyBiz
  • func NewStrategyBiz(strategyRepository repository.Strategy) *StrategyBiz
  • func (s *StrategyBiz) Eval(ctx context.Context, strategy bo.IStrategy) (*bo.Alarm, error)
  • func (s *StrategyBiz) SaveStrategy(ctx context.Context, strategies []bo.IStrategy) error

Variables

var ProviderSetBiz = wire.NewSet(
	NewMetricBiz,
	NewStrategyBiz,
	NewAlertBiz,
	NewHeartbeatBiz,
)

ProviderSetBiz is biz providers.

Types

type AlertBiz

type AlertBiz struct {
	// contains filtered or unexported fields
}

AlertBiz .

func NewAlertBiz

func NewAlertBiz(alertRepository repository.Alert, cacheRepo repository.CacheRepo) *AlertBiz

NewAlertBiz new AlertBiz

func (*AlertBiz) PushAlarm

func (a *AlertBiz) PushAlarm(ctx context.Context, alarm *bo.Alarm) (err error)

PushAlarm 告警推送

func (*AlertBiz) SaveAlarm

func (a *AlertBiz) SaveAlarm(ctx context.Context, alarm *bo.Alarm) error

SaveAlarm 保存告警数据

type HeartbeatBiz

type HeartbeatBiz struct {
	// contains filtered or unexported fields
}

HeartbeatBiz 心跳业务

func NewHeartbeatBiz

func NewHeartbeatBiz(heartbeatRepository repository.Heartbeat) *HeartbeatBiz

NewHeartbeatBiz 创建心跳业务

func (*HeartbeatBiz) Heartbeat

func (h *HeartbeatBiz) Heartbeat(ctx context.Context, in *api.HeartbeatRequest) error

Heartbeat 心跳

type MetricBiz

type MetricBiz struct {
	// contains filtered or unexported fields
}

MetricBiz .

func NewMetricBiz

func NewMetricBiz(metricRepository repository.Metric) *MetricBiz

NewMetricBiz new MetricBiz

func (*MetricBiz) PushMetric

func (b *MetricBiz) PushMetric(req *bo.PushMetricParams) error

PushMetric 推送数据

func (*MetricBiz) Query

func (b *MetricBiz) Query(ctx context.Context, req *bo.QueryQLParams) ([]*datasource.QueryResponse, error)

Query 查询数据

func (*MetricBiz) SyncMetrics

func (b *MetricBiz) SyncMetrics(ctx context.Context, datasourceInfo *bo.GetMetricsParams) ([]*bo.MetricDetail, error)

SyncMetrics 同步数据源元数据

type StrategyBiz

type StrategyBiz struct {
	// contains filtered or unexported fields
}

StrategyBiz .

func NewStrategyBiz

func NewStrategyBiz(strategyRepository repository.Strategy) *StrategyBiz

NewStrategyBiz new StrategyBiz

func (*StrategyBiz) Eval

func (s *StrategyBiz) Eval(ctx context.Context, strategy bo.IStrategy) (*bo.Alarm, error)

Eval 根据策略信息产生告警数据

func (*StrategyBiz) SaveStrategy

func (s *StrategyBiz) SaveStrategy(ctx context.Context, strategies []bo.IStrategy) error

SaveStrategy 保存策略信息