daemonv1

type ClientTarget struct {
	TestId          string       `protobuf:"bytes,1,opt,name=test_id,json=testId,proto3" json:"test_id,omitempty"`
	DestinationIp   string       `protobuf:"bytes,2,opt,name=destination_ip,json=destinationIp,proto3" json:"destination_ip,omitempty"`
	DestinationPort int32        `protobuf:"varint,3,opt,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"`
	Profile         *TestProfile `protobuf:"bytes,4,opt,name=profile,proto3" json:"profile,omitempty"`
	// contains filtered or unexported fields
}

type DaemonServiceClient interface {
	// Initialize prepares the daemon with configuration
	Initialize(ctx context.Context, in *InitializeRequest, opts ...grpc.CallOption) (*InitializeResponse, error)
	// PrepareTest validates if the daemon can handle the test topology
	PrepareTest(ctx context.Context, in *PrepareTestRequest, opts ...grpc.CallOption) (*PrepareTestResponse, error)
	// StartServers starts iperf3 servers on allocated ports
	StartServers(ctx context.Context, in *StartServersRequest, opts ...grpc.CallOption) (*StartServersResponse, error)
	// StartClients starts iperf3 clients to connect to targets
	StartClients(ctx context.Context, in *StartClientsRequest, opts ...grpc.CallOption) (*StartClientsResponse, error)
	// StopAll stops all running iperf3 processes
	StopAll(ctx context.Context, in *StopAllRequest, opts ...grpc.CallOption) (*StopAllResponse, error)
	// GetResults retrieves test results from completed runs
	GetResults(ctx context.Context, in *GetResultsRequest, opts ...grpc.CallOption) (*GetResultsResponse, error)
	// GetStatus returns current daemon health and resource usage
	GetStatus(ctx context.Context, in *GetStatusRequest, opts ...grpc.CallOption) (*GetStatusResponse, error)
}

type DaemonServiceServer interface {
	// Initialize prepares the daemon with configuration
	Initialize(context.Context, *InitializeRequest) (*InitializeResponse, error)
	// PrepareTest validates if the daemon can handle the test topology
	PrepareTest(context.Context, *PrepareTestRequest) (*PrepareTestResponse, error)
	// StartServers starts iperf3 servers on allocated ports
	StartServers(context.Context, *StartServersRequest) (*StartServersResponse, error)
	// StartClients starts iperf3 clients to connect to targets
	StartClients(context.Context, *StartClientsRequest) (*StartClientsResponse, error)
	// StopAll stops all running iperf3 processes
	StopAll(context.Context, *StopAllRequest) (*StopAllResponse, error)
	// GetResults retrieves test results from completed runs
	GetResults(context.Context, *GetResultsRequest) (*GetResultsResponse, error)
	// GetStatus returns current daemon health and resource usage
	GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error)
	// contains filtered or unexported methods
}

type DaemonStatus struct {
	Healthy          bool             `protobuf:"varint,1,opt,name=healthy,proto3" json:"healthy,omitempty"`
	RunningProcesses int32            `protobuf:"varint,2,opt,name=running_processes,json=runningProcesses,proto3" json:"running_processes,omitempty"`
	CompletedTests   int32            `protobuf:"varint,3,opt,name=completed_tests,json=completedTests,proto3" json:"completed_tests,omitempty"`
	FailedTests      int32            `protobuf:"varint,4,opt,name=failed_tests,json=failedTests,proto3" json:"failed_tests,omitempty"`
	CurrentCapacity  *ProcessCapacity `protobuf:"bytes,5,opt,name=current_capacity,json=currentCapacity,proto3" json:"current_capacity,omitempty"`
	UptimeSeconds    int64            `protobuf:"varint,6,opt,name=uptime_seconds,json=uptimeSeconds,proto3" json:"uptime_seconds,omitempty"`
	Version          string           `protobuf:"bytes,7,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

type GetResultsRequest struct {
	TestIds             []string `protobuf:"bytes,1,rep,name=test_ids,json=testIds,proto3" json:"test_ids,omitempty"` // Empty means all results
	ClearAfterRetrieval bool     `protobuf:"varint,2,opt,name=clear_after_retrieval,json=clearAfterRetrieval,proto3" json:"clear_after_retrieval,omitempty"`
	// contains filtered or unexported fields
}

type GetResultsResponse struct {
	Results    []*TestResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	TotalCount int32         `protobuf:"varint,2,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
	// contains filtered or unexported fields
}

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

type GetStatusResponse struct {
	Status *DaemonStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type InitializeRequest struct {
	PortRangeStart int32  `protobuf:"varint,1,opt,name=port_range_start,json=portRangeStart,proto3" json:"port_range_start,omitempty"`
	PortRangeEnd   int32  `protobuf:"varint,2,opt,name=port_range_end,json=portRangeEnd,proto3" json:"port_range_end,omitempty"`
	MaxProcesses   int32  `protobuf:"varint,3,opt,name=max_processes,json=maxProcesses,proto3" json:"max_processes,omitempty"`
	CpuAffinity    bool   `protobuf:"varint,4,opt,name=cpu_affinity,json=cpuAffinity,proto3" json:"cpu_affinity,omitempty"`
	LogLevel       string `protobuf:"bytes,5,opt,name=log_level,json=logLevel,proto3" json:"log_level,omitempty"`
	ResultDir      string `protobuf:"bytes,6,opt,name=result_dir,json=resultDir,proto3" json:"result_dir,omitempty"`
	SaveResults    bool   `protobuf:"varint,7,opt,name=save_results,json=saveResults,proto3" json:"save_results,omitempty"` // Whether to save results to timestamped files
	// contains filtered or unexported fields
}

type InitializeResponse struct {
	Success  bool      `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message  string    `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	NodeInfo *NodeInfo `protobuf:"bytes,3,opt,name=node_info,json=nodeInfo,proto3" json:"node_info,omitempty"`
	// contains filtered or unexported fields
}

type NodeInfo struct {
	Id       string           `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Hostname string           `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Ip       string           `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	Port     int32            `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	Capacity *ProcessCapacity `protobuf:"bytes,5,opt,name=capacity,proto3" json:"capacity,omitempty"`
	// contains filtered or unexported fields
}

type PrepareTestRequest struct {
	Topology *TestTopology `protobuf:"bytes,1,opt,name=topology,proto3" json:"topology,omitempty"`
	// contains filtered or unexported fields
}

type PrepareTestResponse struct {
	CanHandle         bool             `protobuf:"varint,1,opt,name=can_handle,json=canHandle,proto3" json:"can_handle,omitempty"`
	Message           string           `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	RequiredCapacity  *ProcessCapacity `protobuf:"bytes,3,opt,name=required_capacity,json=requiredCapacity,proto3" json:"required_capacity,omitempty"`
	AvailableCapacity *ProcessCapacity `protobuf:"bytes,4,opt,name=available_capacity,json=availableCapacity,proto3" json:"available_capacity,omitempty"`
	// contains filtered or unexported fields
}

type ProcessCapacity struct {
	MaxProcesses         int32    `protobuf:"varint,1,opt,name=max_processes,json=maxProcesses,proto3" json:"max_processes,omitempty"`
	AvailableProcesses   int32    `protobuf:"varint,2,opt,name=available_processes,json=availableProcesses,proto3" json:"available_processes,omitempty"`
	CpuCores             int32    `protobuf:"varint,3,opt,name=cpu_cores,json=cpuCores,proto3" json:"cpu_cores,omitempty"`
	AvailableMemoryBytes int64    `protobuf:"varint,4,opt,name=available_memory_bytes,json=availableMemoryBytes,proto3" json:"available_memory_bytes,omitempty"`
	NetworkInterfaces    []string `protobuf:"bytes,5,rep,name=network_interfaces,json=networkInterfaces,proto3" json:"network_interfaces,omitempty"`
	// contains filtered or unexported fields
}

type Protocol int32

type StartClientsRequest struct {
	Targets []*ClientTarget `protobuf:"bytes,1,rep,name=targets,proto3" json:"targets,omitempty"`
	// contains filtered or unexported fields
}

type StartClientsResponse struct {
	Success        bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message        string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	StartedTestIds []string `protobuf:"bytes,3,rep,name=started_test_ids,json=startedTestIds,proto3" json:"started_test_ids,omitempty"`
	Errors         []string `protobuf:"bytes,4,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

type StartServersRequest struct {
	Ports          []int32 `protobuf:"varint,1,rep,packed,name=ports,proto3" json:"ports,omitempty"`
	TimeoutSeconds int32   `protobuf:"varint,2,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
	// contains filtered or unexported fields
}

type StartServersResponse struct {
	Success      bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message      string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	StartedPorts []int32  `protobuf:"varint,3,rep,packed,name=started_ports,json=startedPorts,proto3" json:"started_ports,omitempty"`
	Errors       []string `protobuf:"bytes,4,rep,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

type StopAllRequest struct {
	Force bool `protobuf:"varint,1,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

type StopAllResponse struct {
	Success          bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message          string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	StoppedProcesses int32  `protobuf:"varint,3,opt,name=stopped_processes,json=stoppedProcesses,proto3" json:"stopped_processes,omitempty"`
	// contains filtered or unexported fields
}

type TestPair struct {
	SourceId        string       `protobuf:"bytes,1,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"`
	DestinationId   string       `protobuf:"bytes,2,opt,name=destination_id,json=destinationId,proto3" json:"destination_id,omitempty"`
	DestinationIp   string       `protobuf:"bytes,3,opt,name=destination_ip,json=destinationIp,proto3" json:"destination_ip,omitempty"`
	DestinationPort int32        `protobuf:"varint,4,opt,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"`
	Profile         *TestProfile `protobuf:"bytes,5,opt,name=profile,proto3" json:"profile,omitempty"`
	// contains filtered or unexported fields
}

type TestProfile struct {
	Name              string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	DurationSeconds   int32             `protobuf:"varint,2,opt,name=duration_seconds,json=durationSeconds,proto3" json:"duration_seconds,omitempty"`
	Protocol          Protocol          `protobuf:"varint,3,opt,name=protocol,proto3,enum=iperf.daemon.v1.Protocol" json:"protocol,omitempty"` // TCP or UDP
	Bandwidth         string            `protobuf:"bytes,4,opt,name=bandwidth,proto3" json:"bandwidth,omitempty"`                              // e.g., "10G", "100M", "0" for unlimited
	WindowSize        string            `protobuf:"bytes,5,opt,name=window_size,json=windowSize,proto3" json:"window_size,omitempty"`          // e.g., "416K"
	ParallelStreams   int32             `protobuf:"varint,6,opt,name=parallel_streams,json=parallelStreams,proto3" json:"parallel_streams,omitempty"`
	Bidirectional     bool              `protobuf:"varint,7,opt,name=bidirectional,proto3" json:"bidirectional,omitempty"`
	Reverse           bool              `protobuf:"varint,8,opt,name=reverse,proto3" json:"reverse,omitempty"`
	BufferLength      int32             `protobuf:"varint,9,opt,name=buffer_length,json=bufferLength,proto3" json:"buffer_length,omitempty"`
	CongestionControl string            `protobuf:"bytes,10,opt,name=congestion_control,json=congestionControl,proto3" json:"congestion_control,omitempty"` // e.g., "cubic", "bbr" (TCP only)
	Mss               int32             `protobuf:"varint,11,opt,name=mss,proto3" json:"mss,omitempty"`                                                     // Maximum segment size (TCP only)
	NoDelay           bool              `protobuf:"varint,12,opt,name=no_delay,json=noDelay,proto3" json:"no_delay,omitempty"`                              // TCP no delay (TCP only)
	Tos               int32             `protobuf:"varint,13,opt,name=tos,proto3" json:"tos,omitempty"`                                                     // Type of service
	Zerocopy          bool              `protobuf:"varint,14,opt,name=zerocopy,proto3" json:"zerocopy,omitempty"`
	OmitSeconds       int32             `protobuf:"varint,15,opt,name=omit_seconds,json=omitSeconds,proto3" json:"omit_seconds,omitempty"` // Seconds to omit at start
	JsonOutput        string            `protobuf:"bytes,16,opt,name=json_output,json=jsonOutput,proto3" json:"json_output,omitempty"`     // JSON output mode
	ExtraFlags        map[string]string ``                                                                                                 // Additional iperf3 flags
	/* 166-byte string literal not displayed */
	// contains filtered or unexported fields
}

type TestResult struct {
	TestId        string     `protobuf:"bytes,1,opt,name=test_id,json=testId,proto3" json:"test_id,omitempty"`
	SourceId      string     `protobuf:"bytes,2,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"`
	DestinationId string     `protobuf:"bytes,3,opt,name=destination_id,json=destinationId,proto3" json:"destination_id,omitempty"`
	Status        TestStatus `protobuf:"varint,4,opt,name=status,proto3,enum=iperf.daemon.v1.TestStatus" json:"status,omitempty"`
	IperfJson     string     `protobuf:"bytes,5,opt,name=iperf_json,json=iperfJson,proto3" json:"iperf_json,omitempty"` // Raw iperf3 JSON output
	ErrorMessage  string     `protobuf:"bytes,6,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	StartTimeUnix int64      `protobuf:"varint,7,opt,name=start_time_unix,json=startTimeUnix,proto3" json:"start_time_unix,omitempty"`
	EndTimeUnix   int64      `protobuf:"varint,8,opt,name=end_time_unix,json=endTimeUnix,proto3" json:"end_time_unix,omitempty"`
	ExitCode      int32      `protobuf:"varint,9,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	// contains filtered or unexported fields
}

type TestStatus int32

type TestTopology struct {
	ServerAssignments []*TestPair `protobuf:"bytes,1,rep,name=server_assignments,json=serverAssignments,proto3" json:"server_assignments,omitempty"` // Tests where this node is server
	ClientAssignments []*TestPair `protobuf:"bytes,2,rep,name=client_assignments,json=clientAssignments,proto3" json:"client_assignments,omitempty"` // Tests where this node is client
	// contains filtered or unexported fields
}

type UnimplementedDaemonServiceServer struct{}

type UnsafeDaemonServiceServer interface {
	// contains filtered or unexported methods
}