agent

Documentation

Index

• Variables
• func Scheme(ctx context.Context) meta.Scheme
• type HttpServer
  • func NewHttpServer(ct health.ConditionTracker, lg *slog.Logger) *HttpServer
  • func (s *HttpServer) ConfigureRoutes(router *gin.Engine)
  • func (s *HttpServer) SetEnabled(enabled bool)
  • func (s *HttpServer) SetRemoteWriteClient(client clients.Locker[remotewrite.RemoteWriteClient])
• type MetricsNode
  • func NewMetricsNode(ct health.ConditionTracker, lg *slog.Logger) *MetricsNode
  • func (m *MetricsNode) AddConfigListener(ch drivers.MetricsNodeConfigurator)
  • func (m *MetricsNode) AddNodeDriver(driver drivers.MetricsNodeDriver)
  • func (m *MetricsNode) Discover(ctx context.Context, request *remoteread.DiscoveryRequest) (*remoteread.DiscoveryResponse, error)
  • func (m *MetricsNode) GetHealth(_ context.Context, _ *emptypb.Empty) (*corev1.Health, error)
  • func (m *MetricsNode) GetTargetStatus(_ context.Context, request *remoteread.TargetStatusRequest) (*remoteread.TargetStatus, error)
  • func (m *MetricsNode) Info(_ context.Context, _ *emptypb.Empty) (*capabilityv1.Details, error)
  • func (m *MetricsNode) SetClients(nodeClient node.NodeMetricsCapabilityClient, ...)
  • func (m *MetricsNode) SetRemoteWriter(client clients.Locker[remotewrite.RemoteWriteClient])
  • func (m *MetricsNode) Start(_ context.Context, request *remoteread.StartReadRequest) (*emptypb.Empty, error)
  • func (m *MetricsNode) Stop(_ context.Context, request *remoteread.StopReadRequest) (*emptypb.Empty, error)
  • func (m *MetricsNode) SyncNow(_ context.Context, req *capabilityv1.Filter) (*emptypb.Empty, error)
• type Plugin
  • func NewPlugin(ctx context.Context) *Plugin
  • func (p *Plugin) ConfigureNode(nodeId string, cfg *node.MetricsCapabilityConfig) error
  • func (p *Plugin) StreamServers() []streamext.Server
  • func (p *Plugin) UseStreamClient(cc grpc.ClientConnInterface)
• type RemoteReader
  • func NewRemoteReader(prometheusClient *http.Client) RemoteReader
• type RuleStreamer
  • func NewRuleStreamer(ct health.ConditionTracker, lg *slog.Logger) *RuleStreamer
  • func (s *RuleStreamer) Run(ctx context.Context, config *v1beta1.RulesSpec, ...) error
  • func (s *RuleStreamer) SetRemoteWriteClient(client remotewrite.RemoteWriteClient)
• type TargetRunMetadata
• type TargetRunner
  • func NewTargetRunner(logger *slog.Logger) TargetRunner

Variables

var TimeDeltaMillis = time.Minute.Milliseconds()

Functions

func Scheme

func Scheme(ctx context.Context) meta.Scheme

Types

type HttpServer

type HttpServer struct {
	apiextensions.UnsafeHTTPAPIExtensionServer
	// contains filtered or unexported fields
}

func NewHttpServer

func NewHttpServer(ct health.ConditionTracker, lg *slog.Logger) *HttpServer

func (*HttpServer) ConfigureRoutes

func (s *HttpServer) ConfigureRoutes(router *gin.Engine)

func (*HttpServer) SetEnabled

func (s *HttpServer) SetEnabled(enabled bool)

func (*HttpServer) SetRemoteWriteClient

func (s *HttpServer) SetRemoteWriteClient(client clients.Locker[remotewrite.RemoteWriteClient])

type MetricsNode

type MetricsNode struct {
	capabilityv1.UnsafeNodeServer
	controlv1.UnsafeHealthServer

	// we only need a subset of the methods
	remoteread.UnsafeRemoteReadAgentServer
	// contains filtered or unexported fields
}

func NewMetricsNode

func NewMetricsNode(ct health.ConditionTracker, lg *slog.Logger) *MetricsNode

func (*MetricsNode) AddConfigListener

func (m *MetricsNode) AddConfigListener(ch drivers.MetricsNodeConfigurator)

func (*MetricsNode) AddNodeDriver

func (m *MetricsNode) AddNodeDriver(driver drivers.MetricsNodeDriver)

func (*MetricsNode) Discover

func (m *MetricsNode) Discover(ctx context.Context, request *remoteread.DiscoveryRequest) (*remoteread.DiscoveryResponse, error)

func (*MetricsNode) GetHealth

func (m *MetricsNode) GetHealth(_ context.Context, _ *emptypb.Empty) (*corev1.Health, error)

func (*MetricsNode) GetTargetStatus

func (m *MetricsNode) GetTargetStatus(_ context.Context, request *remoteread.TargetStatusRequest) (*remoteread.TargetStatus, error)

func (*MetricsNode) Info

func (m *MetricsNode) Info(_ context.Context, _ *emptypb.Empty) (*capabilityv1.Details, error)

func (*MetricsNode) SetClients

func (m *MetricsNode) SetClients(
	nodeClient node.NodeMetricsCapabilityClient,
	identityClient controlv1.IdentityClient,
	healthListenerClient controlv1.HealthListenerClient,
)

func (*MetricsNode) SetRemoteWriter

func (m *MetricsNode) SetRemoteWriter(client clients.Locker[remotewrite.RemoteWriteClient])

func (*MetricsNode) Start

func (m *MetricsNode) Start(_ context.Context, request *remoteread.StartReadRequest) (*emptypb.Empty, error)

func (*MetricsNode) Stop

func (m *MetricsNode) Stop(_ context.Context, request *remoteread.StopReadRequest) (*emptypb.Empty, error)

func (*MetricsNode) SyncNow

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

type Plugin

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

func NewPlugin

func NewPlugin(ctx context.Context) *Plugin

func (*Plugin) ConfigureNode

func (p *Plugin) ConfigureNode(nodeId string, cfg *node.MetricsCapabilityConfig) error

func (*Plugin) StreamServers

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

func (*Plugin) UseStreamClient

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

type RemoteReader

type RemoteReader interface {
	Read(ctx context.Context, endpoint string, request *prompb.ReadRequest) (*prompb.ReadResponse, error)
}

func NewRemoteReader

func NewRemoteReader(prometheusClient *http.Client) RemoteReader

type RuleStreamer

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

func NewRuleStreamer

func NewRuleStreamer(ct health.ConditionTracker, lg *slog.Logger) *RuleStreamer

func (*RuleStreamer) Run

func (s *RuleStreamer) Run(ctx context.Context, config *v1beta1.RulesSpec, finder notifier.Finder[rules.RuleGroup]) error

func (*RuleStreamer) SetRemoteWriteClient

func (s *RuleStreamer) SetRemoteWriteClient(client remotewrite.RemoteWriteClient)

type TargetRunMetadata

type TargetRunMetadata struct {
	Target *remoteread.Target
	Query  *remoteread.Query
}

type TargetRunner

type TargetRunner interface {
	Start(target *remoteread.Target, query *remoteread.Query) error
	Stop(name string) error
	GetStatus(name string) (*remoteread.TargetStatus, error)
	SetRemoteWriteClient(client clients.Locker[remotewrite.RemoteWriteClient])
	SetRemoteReaderClient(client RemoteReader)
}

func NewTargetRunner

func NewTargetRunner(logger *slog.Logger) TargetRunner