Documentation ¶
Index ¶
- Constants
- func Scheme(ctx context.Context) meta.Scheme
- type HttpServer
- type 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
- type RuleStreamer
Constants ¶
View Source
const ( CondRemoteWrite = "Remote Write" CondRuleSync = "Rule Sync" )
Variables ¶
This section is empty.
Functions ¶
Types ¶
type HttpServer ¶
type HttpServer struct { apiextensions.UnsafeHTTPAPIExtensionServer // contains filtered or unexported fields }
func NewHttpServer ¶
func NewHttpServer(ct health.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 health.ConditionTracker, lg *zap.SugaredLogger) *MetricsNode
func (*MetricsNode) AddConfigListener ¶
func (m *MetricsNode) AddConfigListener(ch chan<- *node.MetricsCapabilityConfig)
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 (*Plugin) StreamServers ¶
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 health.ConditionTracker, lg *zap.SugaredLogger) *RuleStreamer
func (*RuleStreamer) SetRemoteWriteClient ¶
func (s *RuleStreamer) SetRemoteWriteClient(client remotewrite.RemoteWriteClient)
Click to show internal directories.
Click to hide internal directories.