server

package
v0.1.11 Latest Latest
Warning

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

 Go to latest Published: Nov 7, 2025 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config 

type Config struct {
	ListenPort     int
	PortRangeStart int
	PortRangeEnd   int
	MaxProcesses   int
	CPUAffinity    bool
	LogLevel       string
	ResultDir      string
	IperfPath      string
}

Config contains daemon server configuration

type DaemonServer 

type DaemonServer struct {
	pb.UnimplementedDaemonServiceServer
	// contains filtered or unexported fields
}

DaemonServer implements the DaemonService gRPC service

func NewDaemonServer 

func NewDaemonServer(config *Config) (*DaemonServer, error)

NewDaemonServer creates a new daemon gRPC server

func (*DaemonServer) GetResults 

func (s *DaemonServer) GetResults(ctx context.Context, req *pb.GetResultsRequest) (*pb.GetResultsResponse, error)

GetResults retrieves test results from completed runs

func (*DaemonServer) GetStatus 

func (s *DaemonServer) GetStatus(ctx context.Context, req *pb.GetStatusRequest) (*pb.GetStatusResponse, error)

GetStatus returns current daemon health and resource usage

func (*DaemonServer) Initialize 

func (s *DaemonServer) Initialize(ctx context.Context, req *pb.InitializeRequest) (*pb.InitializeResponse, error)

Initialize initializes the daemon with configuration

func (*DaemonServer) PrepareTest 

func (s *DaemonServer) PrepareTest(ctx context.Context, req *pb.PrepareTestRequest) (*pb.PrepareTestResponse, error)

PrepareTest validates if the daemon can handle the test topology

func (*DaemonServer) StartClients 

func (s *DaemonServer) StartClients(ctx context.Context, req *pb.StartClientsRequest) (*pb.StartClientsResponse, error)

StartClients starts iperf3 clients to connect to targets

func (*DaemonServer) StartServers 

func (s *DaemonServer) StartServers(ctx context.Context, req *pb.StartServersRequest) (*pb.StartServersResponse, error)

StartServers starts iperf3 servers on allocated ports

func (*DaemonServer) StopAll 

func (s *DaemonServer) StopAll(ctx context.Context, req *pb.StopAllRequest) (*pb.StopAllResponse, error)

StopAll stops all running iperf3 processes

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.