agent

Documentation

Index

• Constants
• Variables
• func Scheme(ctx context.Context) meta.Scheme
• type AlertingNode
  • func NewAlertingNode(ctx context.Context, lg *slog.Logger, ct health.ConditionTracker) *AlertingNode
  • func (s *AlertingNode) AddConfigListener(p ConfigPropagator)
  • func (s *AlertingNode) Conditions() health.ConditionTracker
  • func (s *AlertingNode) GetHealth(_ context.Context, _ *emptypb.Empty) (*corev1.Health, error)
  • func (s *AlertingNode) SetClients(healthListenerClient controlv1.HealthListenerClient, ...)
  • func (s *AlertingNode) SyncNow(_ context.Context, req *capabilityv1.Filter) (*emptypb.Empty, error)
• type ConfigPropagator
• type Plugin
  • func NewPlugin(ctx context.Context) *Plugin
  • func (p *Plugin) StreamServers() []streamext.Server
  • func (p *Plugin) UseStreamClient(cc grpc.ClientConnInterface)
• type RuleStreamer
  • func NewRuleStreamer(ctx context.Context, lg *slog.Logger, ct healthpkg.ConditionTracker, ...) *RuleStreamer
  • func (r *RuleStreamer) ConfigureNode(nodeId string, cfg *node.AlertingCapabilityConfig) error
  • func (r *RuleStreamer) SetClients(ruleClient rules.RuleSyncClient)

Constants

const (
	CondRuleSync = "Rule Sync"
)

Variables

var RuleSyncInterval = time.Minute * 2

Functions

func Scheme

func Scheme(ctx context.Context) meta.Scheme

Types

type AlertingNode

type AlertingNode struct {
	capabilityv1.UnsafeNodeServer
	controlv1.UnsafeHealthServer
	// contains filtered or unexported fields
}

func NewAlertingNode

func NewAlertingNode(
	ctx context.Context,
	lg *slog.Logger,
	ct health.ConditionTracker,
) *AlertingNode

func (*AlertingNode) AddConfigListener

func (s *AlertingNode) AddConfigListener(p ConfigPropagator)

func (*AlertingNode) Conditions

func (s *AlertingNode) Conditions() health.ConditionTracker

func (*AlertingNode) GetHealth

func (s *AlertingNode) GetHealth(_ context.Context, _ *emptypb.Empty) (*corev1.Health, error)

func (*AlertingNode) SetClients

func (s *AlertingNode) SetClients(
	healthListenerClient controlv1.HealthListenerClient,
	nodeSyncClient node.NodeAlertingCapabilityClient,
	identityClient controlv1.IdentityClient,
)

func (*AlertingNode) SyncNow

func (s *AlertingNode) SyncNow(_ context.Context, req *capabilityv1.Filter) (*emptypb.Empty, error)

type ConfigPropagator

type ConfigPropagator interface {
	ConfigureNode(nodeId string, config *node.AlertingCapabilityConfig) error
}

type Plugin

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

func NewPlugin

func NewPlugin(ctx context.Context) *Plugin

func (*Plugin) StreamServers

func (p *Plugin) StreamServers() []streamext.Server

func (*Plugin) UseStreamClient

func (p *Plugin) UseStreamClient(cc grpc.ClientConnInterface)

type RuleStreamer

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

func NewRuleStreamer

func NewRuleStreamer(
	ctx context.Context,
	lg *slog.Logger,
	ct healthpkg.ConditionTracker,
	nodeDriver drivers.NodeDriver,
) *RuleStreamer

func (*RuleStreamer) ConfigureNode

func (r *RuleStreamer) ConfigureNode(nodeId string, cfg *node.AlertingCapabilityConfig) error

func (*RuleStreamer) SetClients

func (r *RuleStreamer) SetClients(
	ruleClient rules.RuleSyncClient,
)