server

package

v0.0.70 Latest Latest Go to latest Published: Mar 16, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type ClientSubscription struct {
	ID        string
	Channel   chan *gen.MpaStreamResponse
	Interests []WorkloadInterest
}

type MpaServer struct {
	gen.UnimplementedMpaServiceServer
	// contains filtered or unexported fields
}

MpaServer implements the gRPC service for in-cluster MPA metric streaming

func NewMpaServer(logger logr.Logger, historicalCollector *collector.HistoricalMetricsCollector, healthManager *health.HealthManager) *MpaServer

NewMpaServer creates a new MpaServer. historicalCollector may be nil if Prometheus is not available.

func (s *MpaServer) PublishMetrics(metrics *collector.ContainerMetricsSnapshot, timestamp time.Time)

PublishMetrics is called by the collector to broadcast new metrics

func (s *MpaServer) Start(port int) error

Start starts the gRPC server on the given port

func (s *MpaServer) Stop()

Stop gracefully stops the gRPC server

func (s *MpaServer) StreamWorkloadMetrics(stream gen.MpaService_StreamWorkloadMetricsServer) error

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

SubscriptionManager manages active streams and their interests

func NewSubscriptionManager(logger logr.Logger) *SubscriptionManager

func (sm *SubscriptionManager) Broadcast(data *collector.ContainerMetricsSnapshot, timestamp time.Time)

Broadcast filters and dispatches metrics to interested clients

func (sm *SubscriptionManager) GetInterests(clientID string) []WorkloadInterest

GetInterests returns the current interests for a client.

func (sm *SubscriptionManager) Register(ch chan *gen.MpaStreamResponse) string

func (sm *SubscriptionManager) Unregister(id string)

func (sm *SubscriptionManager) UpdateSubscription(clientID string, sub *gen.MpaWorkloadSubscription)

type WorkloadInterest struct {
	Namespace string
	Name      string
	Kind      string
	Selector  map[string]string
}