api

package
v0.11.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 24, 2026 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Package api provides functionality for the API server.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ProfileFetcher added in v0.11.0

type ProfileFetcher interface {
	FetchPressureProfile(ctx context.Context, agentID string, fetch *fodcv1.FetchPressureProfile, onChunk func([]byte) error) error
}

ProfileFetcher streams one pressure profile's bytes from an agent, invoking onChunk per slice.

type Server

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

Server exposes REST and Prometheus-style endpoints for external consumption.

func NewServer

func NewServer(
	metricsAggregator *metrics.Aggregator,
	clusterStateCollector *cluster.Manager,
	lifecycleManager *lifecycle.Manager,
	registry *registry.AgentRegistry,
	crashDiagnosticsAggregator *diagnostics.Aggregator,
	pressureAggregator *pressure.Aggregator,
	profileFetcher ProfileFetcher,
	logger *logger.Logger,
) *Server

NewServer creates a new Server instance.

func (*Server) Start

func (s *Server) Start(listenAddr string, readTimeout, writeTimeout time.Duration) error

Start starts the HTTP server.

func (*Server) Stop

func (s *Server) Stop() error

Stop gracefully stops the HTTP server.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL