grpc

package
v0.10.1 Latest Latest
Warning

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

 Go to latest Published: Apr 1, 2026 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Overview

Package grpc provides functionality for the gRPC server.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FODCService 

type FODCService struct {
	fodcv1.UnimplementedFODCServiceServer
	// contains filtered or unexported fields
}

FODCService implements the FODC gRPC service.

func NewFODCService 

func NewFODCService(
	registry *registry.AgentRegistry,
	metricsAggregator *metrics.Aggregator,
	clusterStateManager *cluster.Manager,
	lifecycleManager *lifecycle.Manager,
	logger *logger.Logger,
	heartbeatInterval time.Duration,
) *FODCService

NewFODCService creates a new FODCService instance.

func (*FODCService) HasClusterStateStream 

func (s *FODCService) HasClusterStateStream(agentID string) bool

HasClusterStateStream reports whether the given agent currently has a cluster topology stream.

func (*FODCService) HasLifecycleStream added in v0.10.1 

func (s *FODCService) HasLifecycleStream(agentID string) bool

HasLifecycleStream reports whether the given agent currently has a lifecycle stream.

func (*FODCService) RegisterAgent 

func (s *FODCService) RegisterAgent(stream fodcv1.FODCService_RegisterAgentServer) error

RegisterAgent handles bi-directional agent registration stream.

func (*FODCService) RequestClusterData 

func (s *FODCService) RequestClusterData(agentID string) error

RequestClusterData requests cluster data from an agent via the cluster state stream.

func (*FODCService) RequestLifecycleData added in v0.10.1 

func (s *FODCService) RequestLifecycleData(agentID string) error

RequestLifecycleData requests lifecycle data from an agent via the lifecycle stream.

func (*FODCService) RequestMetrics 

func (s *FODCService) RequestMetrics(agentID string, startTime, endTime *time.Time) error

RequestMetrics requests metrics from an agent via the metrics stream.

func (*FODCService) StreamClusterTopology 

func (s *FODCService) StreamClusterTopology(stream fodcv1.FODCService_StreamClusterTopologyServer) error

StreamClusterTopology handles bi-directional cluster topology streaming.

func (*FODCService) StreamLifecycle added in v0.10.1 

func (s *FODCService) StreamLifecycle(stream fodcv1.FODCService_StreamLifecycleServer) error

StreamLifecycle handles bi-directional lifecycle data streaming.

func (*FODCService) StreamMetrics 

func (s *FODCService) StreamMetrics(stream fodcv1.FODCService_StreamMetricsServer) error

StreamMetrics handles bi-directional metrics streaming.

type Server 

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

Server wraps the gRPC server.

func NewServer 

func NewServer(service *FODCService, listenAddr string, maxMsgSize int, logger *logger.Logger) *Server

NewServer creates a new gRPC server instance.

func (*Server) Start 

func (s *Server) Start() error

Start starts the gRPC server.

func (*Server) Stop 

func (s *Server) Stop()

Stop gracefully stops the gRPC server.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.