agent

Documentation

Index

• Constants
• func Scheme(ctx context.Context) meta.Scheme
• type ConditionStatus
  • func (s ConditionStatus) String() string
• type ConditionTracker
  • func NewConditionTracker(logger *zap.SugaredLogger) ConditionTracker
• type HttpServer
  • func NewHttpServer(ct ConditionTracker, lg *zap.SugaredLogger) *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 ConditionTracker, lg *zap.SugaredLogger) *MetricsNode
  • func (m *MetricsNode) AddConfigListener(ch chan<- *node.MetricsCapabilityConfig)
  • func (m *MetricsNode) GetHealth(_ context.Context, _ *emptypb.Empty) (*corev1.Health, error)
  • func (m *MetricsNode) Info(_ context.Context, _ *emptypb.Empty) (*capabilityv1.InfoResponse, error)
  • func (m *MetricsNode) SetHealthListenerClient(client controlv1.HealthListenerClient)
  • func (m *MetricsNode) SetIdentityClient(client controlv1.IdentityClient)
  • func (m *MetricsNode) SetNodeClient(client node.NodeMetricsCapabilityClient)
  • func (m *MetricsNode) SyncNow(_ context.Context, req *capabilityv1.Filter) (*emptypb.Empty, error)
• 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(ct ConditionTracker, lg *zap.SugaredLogger) *RuleStreamer
  • func (s *RuleStreamer) Run(ctx context.Context, config *v1beta1.RulesSpec) error
  • func (s *RuleStreamer) SetRemoteWriteClient(client remotewrite.RemoteWriteClient)

Constants

const (
	CondRemoteWrite = "Remote Write"
	CondRuleSync    = "Rule Sync"
	CondConfigSync  = "Config Sync"
	CondBackend     = "Backend"
)

Functions

func Scheme

func Scheme(ctx context.Context) meta.Scheme

Types

type ConditionStatus

type ConditionStatus int32

const (
	StatusPending ConditionStatus = iota
	StatusFailure
	StatusDisabled
)

func (ConditionStatus) String

func (s ConditionStatus) String() string

type ConditionTracker

type ConditionTracker interface {
	Set(key string, value ConditionStatus, reason string)
	Clear(key string, reason ...string)
	List() []string
	LastModified() time.Time

	// Adds a listener that will be called whenever any condition is changed.
	// The listener will be called in a separate goroutine. Ensure that the
	// listener does not itself set or clear any conditions.
	AddListener(listener func())
}

func NewConditionTracker

func NewConditionTracker(logger *zap.SugaredLogger) ConditionTracker

type HttpServer

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

func NewHttpServer

func NewHttpServer(ct ConditionTracker, lg *zap.SugaredLogger) *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
	// contains filtered or unexported fields
}

func NewMetricsNode

func NewMetricsNode(ct ConditionTracker, lg *zap.SugaredLogger) *MetricsNode

func (*MetricsNode) AddConfigListener

func (m *MetricsNode) AddConfigListener(ch chan<- *node.MetricsCapabilityConfig)

func (*MetricsNode) GetHealth

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

Implements controlv1.HealthServer

func (*MetricsNode) Info

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

func (*MetricsNode) SetHealthListenerClient

func (m *MetricsNode) SetHealthListenerClient(client controlv1.HealthListenerClient)

func (*MetricsNode) SetIdentityClient

func (m *MetricsNode) SetIdentityClient(client controlv1.IdentityClient)

func (*MetricsNode) SetNodeClient

func (m *MetricsNode) SetNodeClient(client node.NodeMetricsCapabilityClient)

func (*MetricsNode) SyncNow

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

Implements capabilityv1.NodeServer

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(ct ConditionTracker, lg *zap.SugaredLogger) *RuleStreamer

func (*RuleStreamer) Run

func (s *RuleStreamer) Run(ctx context.Context, config *v1beta1.RulesSpec) error

func (*RuleStreamer) SetRemoteWriteClient

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