agentv1

type AgentMessage struct {

	// Types that are valid to be assigned to Payload:
	//
	//	*AgentMessage_Hello
	//	*AgentMessage_Heartbeat
	//	*AgentMessage_Metrics
	//	*AgentMessage_CommandResult
	Payload isAgentMessage_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

type AgentMessage_CommandResult struct {
	CommandResult *CommandResult `protobuf:"bytes,4,opt,name=command_result,json=commandResult,proto3,oneof"`
}

type AgentMessage_Heartbeat struct {
	Heartbeat *Heartbeat `protobuf:"bytes,2,opt,name=heartbeat,proto3,oneof"`
}

type AgentMessage_Hello struct {
	Hello *Hello `protobuf:"bytes,1,opt,name=hello,proto3,oneof"`
}

type AgentMessage_Metrics struct {
	Metrics *MetricsReport `protobuf:"bytes,3,opt,name=metrics,proto3,oneof"`
}

type AgentServiceClient interface {
	// Connect is the only RPC: a persistent stream carrying everything that
	// flows between an agent and its hub.
	//
	// Flow: the agent sends Hello; the hub answers Welcome or Reject (and ends
	// the stream on Reject). After Welcome the agent sends Heartbeat and
	// MetricsReport messages on the intervals set by the hub, and the hub may
	// send Command messages at any time; each Command is answered by a
	// CommandResult.
	Connect(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[AgentMessage, HubMessage], error)
	// FetchUpdate streams one file of the release the hub offers in an
	// ApplyUpdate command, over the same mTLS connection. The hub serves only
	// the release it runs itself, and the archive of the caller's platform.
	FetchUpdate(ctx context.Context, in *FetchUpdateRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[FileChunk], error)
}

type AgentServiceServer interface {
	// Connect is the only RPC: a persistent stream carrying everything that
	// flows between an agent and its hub.
	//
	// Flow: the agent sends Hello; the hub answers Welcome or Reject (and ends
	// the stream on Reject). After Welcome the agent sends Heartbeat and
	// MetricsReport messages on the intervals set by the hub, and the hub may
	// send Command messages at any time; each Command is answered by a
	// CommandResult.
	Connect(grpc.BidiStreamingServer[AgentMessage, HubMessage]) error
	// FetchUpdate streams one file of the release the hub offers in an
	// ApplyUpdate command, over the same mTLS connection. The hub serves only
	// the release it runs itself, and the archive of the caller's platform.
	FetchUpdate(*FetchUpdateRequest, grpc.ServerStreamingServer[FileChunk]) error
	// contains filtered or unexported methods
}

type AgentService_ConnectClient = grpc.BidiStreamingClient[AgentMessage, HubMessage]

type AgentService_ConnectServer = grpc.BidiStreamingServer[AgentMessage, HubMessage]

type AgentService_FetchUpdateClient = grpc.ServerStreamingClient[FileChunk]

type AgentService_FetchUpdateServer = grpc.ServerStreamingServer[FileChunk]

type ApplyUpdate struct {

	// Version to install, for example "0.2.0"; the tag is "v" + version.
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// Name of the archive for the agent's platform.
	Archive string `protobuf:"bytes,2,opt,name=archive,proto3" json:"archive,omitempty"`
	// SHA-256 of the archive, lower-case hex, as listed in the signed
	// checksums.txt.
	Sha256 string `protobuf:"bytes,3,opt,name=sha256,proto3" json:"sha256,omitempty"`
	Size   uint64 `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

type Command struct {

	// Unique per stream; echoed back in CommandResult.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are valid to be assigned to Kind:
	//
	//	*Command_Ping
	//	*Command_SetIntervals
	//	*Command_ApplyUpdate
	Kind isCommand_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

type CommandResult struct {
	CommandId string `protobuf:"bytes,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	Success   bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	// Set when success is false.
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type Command_ApplyUpdate struct {
	ApplyUpdate *ApplyUpdate `protobuf:"bytes,4,opt,name=apply_update,json=applyUpdate,proto3,oneof"`
}

type Command_Ping struct {
	Ping *Ping `protobuf:"bytes,2,opt,name=ping,proto3,oneof"`
}

type Command_SetIntervals struct {
	SetIntervals *SetIntervals `protobuf:"bytes,3,opt,name=set_intervals,json=setIntervals,proto3,oneof"`
}

type CpuMetrics struct {

	// Utilisation over the last interval, 0 to 100, across all cores.
	UsagePercent float64 `protobuf:"fixed64,1,opt,name=usage_percent,json=usagePercent,proto3" json:"usage_percent,omitempty"`
	Load_1       float64 `protobuf:"fixed64,2,opt,name=load_1,json=load1,proto3" json:"load_1,omitempty"`
	Load_5       float64 `protobuf:"fixed64,3,opt,name=load_5,json=load5,proto3" json:"load_5,omitempty"`
	Load_15      float64 `protobuf:"fixed64,4,opt,name=load_15,json=load15,proto3" json:"load_15,omitempty"`
	// contains filtered or unexported fields
}

type DiskMetrics struct {
	MountPoint string `protobuf:"bytes,1,opt,name=mount_point,json=mountPoint,proto3" json:"mount_point,omitempty"`
	Filesystem string `protobuf:"bytes,2,opt,name=filesystem,proto3" json:"filesystem,omitempty"`
	TotalBytes uint64 `protobuf:"varint,3,opt,name=total_bytes,json=totalBytes,proto3" json:"total_bytes,omitempty"`
	UsedBytes  uint64 `protobuf:"varint,4,opt,name=used_bytes,json=usedBytes,proto3" json:"used_bytes,omitempty"`
	// contains filtered or unexported fields
}

type EnrollRequest struct {

	// Enrollment token from the dashboard. Valid once and for a short time.
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// PKCS #10 certificate request (DER) for a key generated on the agent; the
	// private key never leaves the machine. The hub ignores the subject of the
	// request and chooses the agent id.
	CsrDer []byte `protobuf:"bytes,2,opt,name=csr_der,json=csrDer,proto3" json:"csr_der,omitempty"`
	// Describes the machine, so the dashboard can show it right away.
	System       *SystemInfo `protobuf:"bytes,3,opt,name=system,proto3" json:"system,omitempty"`
	AgentVersion string      `protobuf:"bytes,4,opt,name=agent_version,json=agentVersion,proto3" json:"agent_version,omitempty"`
	// contains filtered or unexported fields
}

type EnrollResponse struct {

	// Identifier of the agent; also the common name of its certificate.
	AgentId string `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// Client certificate (DER) signed by the hub's internal CA.
	CertificateDer []byte `protobuf:"bytes,2,opt,name=certificate_der,json=certificateDer,proto3" json:"certificate_der,omitempty"`
	// Certificate (DER) of the hub's CA, which the agent trusts from now on.
	CaCertificateDer []byte `protobuf:"bytes,3,opt,name=ca_certificate_der,json=caCertificateDer,proto3" json:"ca_certificate_der,omitempty"`
	// contains filtered or unexported fields
}

type EnrollmentServiceClient interface {
	Enroll(ctx context.Context, in *EnrollRequest, opts ...grpc.CallOption) (*EnrollResponse, error)
}

type EnrollmentServiceServer interface {
	Enroll(context.Context, *EnrollRequest) (*EnrollResponse, error)
	// contains filtered or unexported methods
}

type FetchUpdateRequest struct {
	Version string     `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	File    UpdateFile `protobuf:"varint,2,opt,name=file,proto3,enum=regulus.agent.v1.UpdateFile" json:"file,omitempty"`
	// contains filtered or unexported fields
}

type FileChunk struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type Heartbeat struct {
	SentAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=sent_at,json=sentAt,proto3" json:"sent_at,omitempty"`
	// contains filtered or unexported fields
}

type Hello struct {

	// Highest protocol version the agent speaks (see internal/protocol).
	ProtocolVersion uint32 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	// Release version of the agent, for display and update decisions.
	AgentVersion string `protobuf:"bytes,2,opt,name=agent_version,json=agentVersion,proto3" json:"agent_version,omitempty"`
	// Stable identifier of the agent. Empty on the very first connection, when
	// the hub assigns one in Welcome.
	AgentId string      `protobuf:"bytes,3,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	System  *SystemInfo `protobuf:"bytes,4,opt,name=system,proto3" json:"system,omitempty"`
	// Lowest protocol version the agent still speaks. Zero (an agent that
	// predates this field) means it speaks only protocol_version. The hub picks
	// the highest version both sides speak.
	MinProtocolVersion uint32 `protobuf:"varint,5,opt,name=min_protocol_version,json=minProtocolVersion,proto3" json:"min_protocol_version,omitempty"`
	// contains filtered or unexported fields
}

type HubMessage struct {

	// Types that are valid to be assigned to Payload:
	//
	//	*HubMessage_Welcome
	//	*HubMessage_Reject
	//	*HubMessage_Command
	Payload isHubMessage_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

type HubMessage_Command struct {
	Command *Command `protobuf:"bytes,3,opt,name=command,proto3,oneof"`
}

type HubMessage_Reject struct {
	Reject *Reject `protobuf:"bytes,2,opt,name=reject,proto3,oneof"`
}

type HubMessage_Welcome struct {
	Welcome *Welcome `protobuf:"bytes,1,opt,name=welcome,proto3,oneof"`
}

type MemoryMetrics struct {
	TotalBytes     uint64 `protobuf:"varint,1,opt,name=total_bytes,json=totalBytes,proto3" json:"total_bytes,omitempty"`
	UsedBytes      uint64 `protobuf:"varint,2,opt,name=used_bytes,json=usedBytes,proto3" json:"used_bytes,omitempty"`
	AvailableBytes uint64 `protobuf:"varint,3,opt,name=available_bytes,json=availableBytes,proto3" json:"available_bytes,omitempty"`
	SwapTotalBytes uint64 `protobuf:"varint,4,opt,name=swap_total_bytes,json=swapTotalBytes,proto3" json:"swap_total_bytes,omitempty"`
	SwapUsedBytes  uint64 `protobuf:"varint,5,opt,name=swap_used_bytes,json=swapUsedBytes,proto3" json:"swap_used_bytes,omitempty"`
	// contains filtered or unexported fields
}

type MetricsReport struct {
	CollectedAt   *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=collected_at,json=collectedAt,proto3" json:"collected_at,omitempty"`
	Cpu           *CpuMetrics            `protobuf:"bytes,2,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Memory        *MemoryMetrics         `protobuf:"bytes,3,opt,name=memory,proto3" json:"memory,omitempty"`
	Disks         []*DiskMetrics         `protobuf:"bytes,4,rep,name=disks,proto3" json:"disks,omitempty"`
	Networks      []*NetworkMetrics      `protobuf:"bytes,5,rep,name=networks,proto3" json:"networks,omitempty"`
	UptimeSeconds uint64                 `protobuf:"varint,6,opt,name=uptime_seconds,json=uptimeSeconds,proto3" json:"uptime_seconds,omitempty"`
	// contains filtered or unexported fields
}

type NetworkMetrics struct {
	Interface string `protobuf:"bytes,1,opt,name=interface,proto3" json:"interface,omitempty"`
	// Monotonic counters since boot; the hub computes rates.
	RxBytes uint64 `protobuf:"varint,2,opt,name=rx_bytes,json=rxBytes,proto3" json:"rx_bytes,omitempty"`
	TxBytes uint64 `protobuf:"varint,3,opt,name=tx_bytes,json=txBytes,proto3" json:"tx_bytes,omitempty"`
	// contains filtered or unexported fields
}

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

type Reject struct {
	Reason Reject_Reason `protobuf:"varint,1,opt,name=reason,proto3,enum=regulus.agent.v1.Reject_Reason" json:"reason,omitempty"`
	// Human readable explanation, safe to show in the dashboard.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// Protocol versions the hub accepts, to help the operator upgrade.
	MinProtocolVersion uint32 `protobuf:"varint,3,opt,name=min_protocol_version,json=minProtocolVersion,proto3" json:"min_protocol_version,omitempty"`
	MaxProtocolVersion uint32 `protobuf:"varint,4,opt,name=max_protocol_version,json=maxProtocolVersion,proto3" json:"max_protocol_version,omitempty"`
	// contains filtered or unexported fields
}

type Reject_Reason int32

type SetIntervals struct {
	HeartbeatInterval *durationpb.Duration `protobuf:"bytes,1,opt,name=heartbeat_interval,json=heartbeatInterval,proto3" json:"heartbeat_interval,omitempty"`
	MetricsInterval   *durationpb.Duration `protobuf:"bytes,2,opt,name=metrics_interval,json=metricsInterval,proto3" json:"metrics_interval,omitempty"`
	// contains filtered or unexported fields
}

type SystemInfo struct {
	Hostname         string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Os               string `protobuf:"bytes,2,opt,name=os,proto3" json:"os,omitempty"`                                // for example "linux"
	OsVersion        string `protobuf:"bytes,3,opt,name=os_version,json=osVersion,proto3" json:"os_version,omitempty"` // for example "Ubuntu 24.04.1 LTS"
	Kernel           string `protobuf:"bytes,4,opt,name=kernel,proto3" json:"kernel,omitempty"`
	Arch             string `protobuf:"bytes,5,opt,name=arch,proto3" json:"arch,omitempty"` // for example "amd64", "arm64"
	CpuCount         uint32 `protobuf:"varint,6,opt,name=cpu_count,json=cpuCount,proto3" json:"cpu_count,omitempty"`
	MemoryTotalBytes uint64 `protobuf:"varint,7,opt,name=memory_total_bytes,json=memoryTotalBytes,proto3" json:"memory_total_bytes,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedAgentServiceServer struct{}

type UnimplementedEnrollmentServiceServer struct{}

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

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

type UpdateFile int32

type Welcome struct {

	// Protocol version negotiated for this stream.
	ProtocolVersion uint32 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	HubVersion      string `protobuf:"bytes,2,opt,name=hub_version,json=hubVersion,proto3" json:"hub_version,omitempty"`
	// Identifier of the agent; equals Hello.agent_id when it was provided.
	AgentId string `protobuf:"bytes,3,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// How often the agent must send a Heartbeat.
	HeartbeatInterval *durationpb.Duration `protobuf:"bytes,4,opt,name=heartbeat_interval,json=heartbeatInterval,proto3" json:"heartbeat_interval,omitempty"`
	// How often the agent must send a MetricsReport.
	MetricsInterval *durationpb.Duration `protobuf:"bytes,5,opt,name=metrics_interval,json=metricsInterval,proto3" json:"metrics_interval,omitempty"`
	// contains filtered or unexported fields
}