Versions in this module Expand all Collapse all v0 v0.26.0 Apr 9, 2022 Changes in this version + func ActiveAlertsToProto(s storepb.PartialResponseStrategy, a *rules.AlertingRule) []*rulespb.AlertInstance + func RegisterRulesServer(rulesSrv rulespb.RulesServer) func(*grpc.Server) + func ValidateAndCount(group io.Reader) (numRules int, errs errutil.MultiError) + type GRPCClient struct + func NewGRPCClient(rs rulespb.RulesServer) *GRPCClient + func NewGRPCClientWithDedup(rs rulespb.RulesServer, replicaLabels []string) *GRPCClient + func (rr *GRPCClient) Rules(ctx context.Context, req *rulespb.RulesRequest) (*rulespb.RuleGroups, storage.Warnings, error) + type Group struct + OriginalFile string + PartialResponseStrategy storepb.PartialResponseStrategy + type Manager struct + func NewManager(ctx context.Context, reg prometheus.Registerer, dataDir string, ...) *Manager + func (m *Manager) Active() []*rulespb.AlertInstance + func (m *Manager) RuleGroups() []Group + func (m *Manager) Rules(r *rulespb.RulesRequest, s rulespb.Rules_RulesServer) (err error) + func (m *Manager) Run() + func (m *Manager) Stop() + func (m *Manager) Update(evalInterval time.Duration, files []string) error + type Prometheus struct + func NewPrometheus(base *url.URL, client *promclient.Client, extLabels func() labels.Labels) *Prometheus + func (p *Prometheus) Rules(r *rulespb.RulesRequest, s rulespb.Rules_RulesServer) error + type Proxy struct + func NewProxy(logger log.Logger, rules func() []rulespb.RulesClient) *Proxy + func (s *Proxy) Rules(req *rulespb.RulesRequest, srv rulespb.Rules_RulesServer) error + type UnaryClient interface + Rules func(ctx context.Context, req *rulespb.RulesRequest) (*rulespb.RuleGroups, storage.Warnings, error)