agentpb

type AgentCommand struct {
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Types that are valid to be assigned to Command:
	//
	//	*AgentCommand_Logs
	//	*AgentCommand_Cancel
	Command isAgentCommand_Command `protobuf_oneof:"command"`
	// contains filtered or unexported fields
}

type AgentCommand_Cancel struct {
	Cancel *CancelRequest `protobuf:"bytes,11,opt,name=cancel,proto3,oneof"` // stop work on request_id (viewer went away)
}

type AgentCommand_Logs struct {
	Logs *LogsRequest `protobuf:"bytes,10,opt,name=logs,proto3,oneof"`
}

type AgentConfig struct {

	// Server-side defaults pushed once at registration. The agent does NOT
	// accept dynamic reconfiguration during streaming — push-only invariant.
	ResourceSampleIntervalSeconds uint32 `` // default 10
	/* 153-byte string literal not displayed */
	CertificateScanIntervalSeconds uint32 `` // default 60
	/* 156-byte string literal not displayed */
	MaxEventsPerSecond uint32 `protobuf:"varint,3,opt,name=max_events_per_second,json=maxEventsPerSecond,proto3" json:"max_events_per_second,omitempty"` // default 1000
	// contains filtered or unexported fields
}

type AgentEvent struct {
	AgentId    string                 `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	EventId    string                 `protobuf:"bytes,2,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"` // UUID v4 generated by agent
	ObservedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=observed_at,json=observedAt,proto3" json:"observed_at,omitempty"`
	Seq        uint64                 `protobuf:"varint,4,opt,name=seq,proto3" json:"seq,omitempty"`           // monotonic per-stream, used for EventAck
	Replayed   bool                   `protobuf:"varint,5,opt,name=replayed,proto3" json:"replayed,omitempty"` // set when the event comes out of the agent's spool
	// Types that are valid to be assigned to Body:
	//
	//	*AgentEvent_Container
	//	*AgentEvent_Endpoint
	//	*AgentEvent_Heartbeat
	//	*AgentEvent_Resource
	//	*AgentEvent_Certificate
	//	*AgentEvent_Swarm
	//	*AgentEvent_Kubernetes
	//	*AgentEvent_Inventory
	//	*AgentEvent_HostOs
	Body isAgentEvent_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

type AgentEvent_Certificate struct {
	Certificate *CertificateInfo `protobuf:"bytes,14,opt,name=certificate,proto3,oneof"`
}

type AgentEvent_Container struct {
	Container *ContainerEvent `protobuf:"bytes,10,opt,name=container,proto3,oneof"`
}

type AgentEvent_Endpoint struct {
	Endpoint *EndpointEvent `protobuf:"bytes,11,opt,name=endpoint,proto3,oneof"`
}

type AgentEvent_Heartbeat struct {
	Heartbeat *HeartbeatEvent `protobuf:"bytes,12,opt,name=heartbeat,proto3,oneof"`
}

type AgentEvent_HostOs struct {
	HostOs *HostOSMsg `protobuf:"bytes,18,opt,name=host_os,json=hostOs,proto3,oneof"`
}

type AgentEvent_Inventory struct {
	Inventory *ContainerInventory `protobuf:"bytes,17,opt,name=inventory,proto3,oneof"`
}

type AgentEvent_Kubernetes struct {
	Kubernetes *KubernetesTopology `protobuf:"bytes,16,opt,name=kubernetes,proto3,oneof"`
}

type AgentEvent_Resource struct {
	Resource *ResourceSample `protobuf:"bytes,13,opt,name=resource,proto3,oneof"`
}

type AgentEvent_Swarm struct {
	Swarm *SwarmTopology `protobuf:"bytes,15,opt,name=swarm,proto3,oneof"`
}

type AuthChallenge struct {
	Nonce []byte `protobuf:"bytes,1,opt,name=nonce,proto3" json:"nonce,omitempty"` // exactly 32 bytes random, generated server-side per stream
	// contains filtered or unexported fields
}

type AuthResponse struct {
	AgentId   string `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"` // UUID v4
	Timestamp int64  `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`           // unix seconds, client clock at signing time
	Signature []byte `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`            // Ed25519.Sign(privkey, signing_payload)
	// Reported on every connect, unlike RegisterRequest.agent_version which is
	// frozen at enrollment time and goes stale the moment the agent is upgraded.
	// The server refreshes the stored version from this.
	AgentVersion string `protobuf:"bytes,4,opt,name=agent_version,json=agentVersion,proto3" json:"agent_version,omitempty"`
	// Command families this build understands, e.g. ["logs"]. Absent on agents
	// predating the command channel, which is exactly how the server detects them.
	// NOT part of the signing payload — adding fields here never breaks the
	// signature, so old and new agents interoperate with old and new servers.
	Capabilities []string `protobuf:"bytes,5,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
	// contains filtered or unexported fields
}

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

type CertificateInfo struct {
	Host              string                 `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port              uint32                 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	SubjectCn         string                 `protobuf:"bytes,3,opt,name=subject_cn,json=subjectCn,proto3" json:"subject_cn,omitempty"`
	IssuerCn          string                 `protobuf:"bytes,4,opt,name=issuer_cn,json=issuerCn,proto3" json:"issuer_cn,omitempty"`
	NotBefore         *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=not_before,json=notBefore,proto3" json:"not_before,omitempty"`
	NotAfter          *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=not_after,json=notAfter,proto3" json:"not_after,omitempty"`
	FingerprintSha256 []byte                 `protobuf:"bytes,7,opt,name=fingerprint_sha256,json=fingerprintSha256,proto3" json:"fingerprint_sha256,omitempty"`
	SanDns            []string               `protobuf:"bytes,8,rep,name=san_dns,json=sanDns,proto3" json:"san_dns,omitempty"`
	// contains filtered or unexported fields
}

type ClientMessage struct {

	// Types that are valid to be assigned to Payload:
	//
	//	*ClientMessage_Auth
	//	*ClientMessage_Event
	//	*ClientMessage_Result
	//	*ClientMessage_Status
	Payload isClientMessage_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

type ClientMessage_Auth struct {
	Auth *AuthResponse `protobuf:"bytes,1,opt,name=auth,proto3,oneof"` // first message only
}

type ClientMessage_Event struct {
	Event *AgentEvent `protobuf:"bytes,2,opt,name=event,proto3,oneof"` // every subsequent message
}

type ClientMessage_Result struct {
	Result *CommandResult `protobuf:"bytes,3,opt,name=result,proto3,oneof"` // reply to a server-issued AgentCommand
}

type ClientMessage_Status struct {
	Status *SpoolStatus `protobuf:"bytes,4,opt,name=status,proto3,oneof"` // spool state, out of band from telemetry
}

type CommandResult struct {
	RequestId    string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	ErrorCode    string `protobuf:"bytes,2,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"` // empty on success; terminal when set
	ErrorMessage string `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	Last         bool   `protobuf:"varint,4,opt,name=last,proto3" json:"last,omitempty"` // final message for this request_id
	// Types that are valid to be assigned to Result:
	//
	//	*CommandResult_Logs
	Result isCommandResult_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

type CommandResult_Logs struct {
	Logs *LogsChunk `protobuf:"bytes,10,opt,name=logs,proto3,oneof"`
}

type ContainerEvent struct {
	ContainerId   string                 `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Name          string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Image         string                 `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	ImageDigest   string                 `protobuf:"bytes,4,opt,name=image_digest,json=imageDigest,proto3" json:"image_digest,omitempty"`
	State         ContainerState         `protobuf:"varint,5,opt,name=state,proto3,enum=maintenant.agent.v1.ContainerState" json:"state,omitempty"`
	StatusMessage string                 `protobuf:"bytes,6,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
	StartedAt     *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	Labels        map[string]string      `` /* 139-byte string literal not displayed */
	// Docker healthcheck state ("healthy", "unhealthy", "starting"); empty when the container has no healthcheck.
	HealthStatus   string `protobuf:"bytes,9,opt,name=health_status,json=healthStatus,proto3" json:"health_status,omitempty"`
	HasHealthCheck bool   `protobuf:"varint,10,opt,name=has_health_check,json=hasHealthCheck,proto3" json:"has_health_check,omitempty"`
	// Set when the container was removed from the host; state is then EXITED so an older server treats it as a stop.
	Destroyed bool `protobuf:"varint,11,opt,name=destroyed,proto3" json:"destroyed,omitempty"`
	// contains filtered or unexported fields
}

type ContainerInventory struct {
	Containers []*ContainerEvent `protobuf:"bytes,1,rep,name=containers,proto3" json:"containers,omitempty"`
	// True when discovery succeeded; an empty complete snapshot is authoritative and retires every container of the agent.
	Complete bool `protobuf:"varint,2,opt,name=complete,proto3" json:"complete,omitempty"`
	// contains filtered or unexported fields
}

type ContainerState int32

type EndpointEvent struct {
	EndpointId   string         `protobuf:"bytes,1,opt,name=endpoint_id,json=endpointId,proto3" json:"endpoint_id,omitempty"` // server-assigned, originally distributed via AgentConfig or label
	Url          string         `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Status       EndpointStatus `protobuf:"varint,3,opt,name=status,proto3,enum=maintenant.agent.v1.EndpointStatus" json:"status,omitempty"`
	StatusCode   uint32         `protobuf:"varint,4,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"` // 0 if non-HTTP probe
	LatencyMs    uint64         `protobuf:"varint,5,opt,name=latency_ms,json=latencyMs,proto3" json:"latency_ms,omitempty"`
	ErrorMessage string         `protobuf:"bytes,6,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

type EndpointStatus int32

type EventAck struct {
	LastEventSeq uint64                 `protobuf:"varint,1,opt,name=last_event_seq,json=lastEventSeq,proto3" json:"last_event_seq,omitempty"` // monotonic counter assigned by client per-stream
	ReceivedAt   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=received_at,json=receivedAt,proto3" json:"received_at,omitempty"`
	// contains filtered or unexported fields
}

type HeartbeatEvent struct {
	HeartbeatToken string `protobuf:"bytes,1,opt,name=heartbeat_token,json=heartbeatToken,proto3" json:"heartbeat_token,omitempty"` // matches existing heartbeat token in DB
	SourceIp       string `protobuf:"bytes,2,opt,name=source_ip,json=sourceIp,proto3" json:"source_ip,omitempty"`
	// contains filtered or unexported fields
}

type HostOSMsg struct {
	Id                string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                                   // os-release ID=, or the family derived from a Kubernetes osImage
	VersionId         string       `protobuf:"bytes,2,opt,name=version_id,json=versionId,proto3" json:"version_id,omitempty"`    // os-release VERSION_ID=, raw
	PrettyName        string       `protobuf:"bytes,3,opt,name=pretty_name,json=prettyName,proto3" json:"pretty_name,omitempty"` // os-release PRETTY_NAME=, or the raw osImage
	Source            HostOSSource `protobuf:"varint,4,opt,name=source,proto3,enum=maintenant.agent.v1.HostOSSource" json:"source,omitempty"`
	UnavailableReason string       `protobuf:"bytes,5,opt,name=unavailable_reason,json=unavailableReason,proto3" json:"unavailable_reason,omitempty"` // "mount_missing" | "file_unreadable" | "node_not_found"; empty when the identity is present
	// contains filtered or unexported fields
}

type HostOSSource int32

type IngestClient interface {
	// RegisterAgent — first-boot enrollment.
	// Called once per agent identity. Idempotent on the server side: re-calling
	// with the same agent_id and a previously-consumed token returns
	// FailedPrecondition.
	RegisterAgent(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error)
	// Push — long-lived bidirectional stream.
	// Server first sends AuthChallenge. Client sends AuthResponse, then a
	// continuous stream of AgentEvent. Server may send error ServerMessage
	// and close the stream at any time (e.g., revocation, rate-limit).
	Push(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[ClientMessage, ServerMessage], error)
}

type IngestServer interface {
	// RegisterAgent — first-boot enrollment.
	// Called once per agent identity. Idempotent on the server side: re-calling
	// with the same agent_id and a previously-consumed token returns
	// FailedPrecondition.
	RegisterAgent(context.Context, *RegisterRequest) (*RegisterResponse, error)
	// Push — long-lived bidirectional stream.
	// Server first sends AuthChallenge. Client sends AuthResponse, then a
	// continuous stream of AgentEvent. Server may send error ServerMessage
	// and close the stream at any time (e.g., revocation, rate-limit).
	Push(grpc.BidiStreamingServer[ClientMessage, ServerMessage]) error
	// contains filtered or unexported methods
}

type Ingest_PushClient = grpc.BidiStreamingClient[ClientMessage, ServerMessage]

type Ingest_PushServer = grpc.BidiStreamingServer[ClientMessage, ServerMessage]

type K8SContainerStatusMsg struct {
	Name         string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Image        string `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	Ready        bool   `protobuf:"varint,3,opt,name=ready,proto3" json:"ready,omitempty"`
	RestartCount int32  `protobuf:"varint,4,opt,name=restart_count,json=restartCount,proto3" json:"restart_count,omitempty"`
	State        string `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"` // running, waiting, terminated
	StateReason  string `protobuf:"bytes,6,opt,name=state_reason,json=stateReason,proto3" json:"state_reason,omitempty"`
	// contains filtered or unexported fields
}

type K8SEventMsg struct {
	Type              string                 `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` // Normal, Warning
	Reason            string                 `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	Message           string                 `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Source            string                 `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
	FirstSeen         *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=first_seen,json=firstSeen,proto3" json:"first_seen,omitempty"`
	LastSeen          *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"`
	Count             int32                  `protobuf:"varint,7,opt,name=count,proto3" json:"count,omitempty"`
	InvolvedKind      string                 `protobuf:"bytes,8,opt,name=involved_kind,json=involvedKind,proto3" json:"involved_kind,omitempty"` // Pod, Deployment, StatefulSet, DaemonSet, Job
	InvolvedNamespace string                 `protobuf:"bytes,9,opt,name=involved_namespace,json=involvedNamespace,proto3" json:"involved_namespace,omitempty"`
	InvolvedName      string                 `protobuf:"bytes,10,opt,name=involved_name,json=involvedName,proto3" json:"involved_name,omitempty"`
	// contains filtered or unexported fields
}

type K8SNodeMsg struct {
	Name                     string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Roles                    []string               `protobuf:"bytes,2,rep,name=roles,proto3" json:"roles,omitempty"`
	Status                   string                 `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"` // ready, not-ready, unknown
	RunningPods              int32                  `protobuf:"varint,4,opt,name=running_pods,json=runningPods,proto3" json:"running_pods,omitempty"`
	KubernetesVersion        string                 `protobuf:"bytes,5,opt,name=kubernetes_version,json=kubernetesVersion,proto3" json:"kubernetes_version,omitempty"`
	OsImage                  string                 `protobuf:"bytes,6,opt,name=os_image,json=osImage,proto3" json:"os_image,omitempty"`
	Architecture             string                 `protobuf:"bytes,7,opt,name=architecture,proto3" json:"architecture,omitempty"`
	CapacityCpuMillicores    int64                  `` /* 127-byte string literal not displayed */
	CapacityMemoryBytes      int64                  `protobuf:"varint,9,opt,name=capacity_memory_bytes,json=capacityMemoryBytes,proto3" json:"capacity_memory_bytes,omitempty"`
	CapacityPods             int64                  `protobuf:"varint,10,opt,name=capacity_pods,json=capacityPods,proto3" json:"capacity_pods,omitempty"`
	AllocatableCpuMillicores int64                  `` /* 137-byte string literal not displayed */
	AllocatableMemoryBytes   int64                  `` /* 131-byte string literal not displayed */
	AllocatablePods          int64                  `protobuf:"varint,13,opt,name=allocatable_pods,json=allocatablePods,proto3" json:"allocatable_pods,omitempty"`
	CreatedAt                *timestamppb.Timestamp `protobuf:"bytes,14,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

type K8SPodMsg struct {
	Name         string                   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace    string                   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Status       string                   `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`                                 // Running, Pending, Succeeded, Failed, Unknown
	StatusReason string                   `protobuf:"bytes,4,opt,name=status_reason,json=statusReason,proto3" json:"status_reason,omitempty"` // CrashLoopBackOff, ImagePullBackOff, ...
	RestartCount int32                    `protobuf:"varint,5,opt,name=restart_count,json=restartCount,proto3" json:"restart_count,omitempty"`
	NodeName     string                   `protobuf:"bytes,6,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	PodIp        string                   `protobuf:"bytes,7,opt,name=pod_ip,json=podIp,proto3" json:"pod_ip,omitempty"`
	HostIp       string                   `protobuf:"bytes,8,opt,name=host_ip,json=hostIp,proto3" json:"host_ip,omitempty"`
	WorkloadRef  string                   `protobuf:"bytes,9,opt,name=workload_ref,json=workloadRef,proto3" json:"workload_ref,omitempty"` // owning workload ID
	Containers   []*K8SContainerStatusMsg `protobuf:"bytes,10,rep,name=containers,proto3" json:"containers,omitempty"`
	CreatedAt    *timestamppb.Timestamp   `protobuf:"bytes,11,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

type K8SWorkloadMsg struct {
	Id              string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // "{namespace}/{kind}/{name}"
	Name            string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Namespace       string                 `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Kind            string                 `protobuf:"bytes,4,opt,name=kind,proto3" json:"kind,omitempty"` // Deployment, StatefulSet, DaemonSet, Job
	Images          []string               `protobuf:"bytes,5,rep,name=images,proto3" json:"images,omitempty"`
	ReadyReplicas   int32                  `protobuf:"varint,6,opt,name=ready_replicas,json=readyReplicas,proto3" json:"ready_replicas,omitempty"`
	DesiredReplicas int32                  `protobuf:"varint,7,opt,name=desired_replicas,json=desiredReplicas,proto3" json:"desired_replicas,omitempty"`
	Status          string                 `protobuf:"bytes,8,opt,name=status,proto3" json:"status,omitempty"` // healthy, degraded, progressing, failed
	CreatedAt       *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

type KubernetesTopology struct {
	Namespaces []string          `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	Workloads  []*K8SWorkloadMsg `protobuf:"bytes,2,rep,name=workloads,proto3" json:"workloads,omitempty"`
	Pods       []*K8SPodMsg      `protobuf:"bytes,3,rep,name=pods,proto3" json:"pods,omitempty"`
	Nodes      []*K8SNodeMsg     `protobuf:"bytes,4,rep,name=nodes,proto3" json:"nodes,omitempty"`
	Events     []*K8SEventMsg    `protobuf:"bytes,5,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

type LogsChunk struct {
	Lines []string `protobuf:"bytes,1,rep,name=lines,proto3" json:"lines,omitempty"`
	// contains filtered or unexported fields
}

type LogsRequest struct {
	ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"` // runtime external id, not the maintenant UUID
	Lines       uint32 `protobuf:"varint,2,opt,name=lines,proto3" json:"lines,omitempty"`                               // tail length; clamped server- and agent-side
	Timestamps  bool   `protobuf:"varint,3,opt,name=timestamps,proto3" json:"timestamps,omitempty"`
	Follow      bool   `protobuf:"varint,4,opt,name=follow,proto3" json:"follow,omitempty"` // stream until cancelled instead of a one-shot tail
	// contains filtered or unexported fields
}

type RegisterRequest struct {
	AgentId         string  `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`                         // UUID v4 (lowercase, no braces) — canonical key
	PublicKey       []byte  `protobuf:"bytes,2,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`                   // raw 32 bytes Ed25519
	EnrollmentToken string  `protobuf:"bytes,3,opt,name=enrollment_token,json=enrollmentToken,proto3" json:"enrollment_token,omitempty"` // "mnt_enr_..." — one-time, TTL 24h
	Hostname        string  `protobuf:"bytes,4,opt,name=hostname,proto3" json:"hostname,omitempty"`
	OsArch          string  `protobuf:"bytes,5,opt,name=os_arch,json=osArch,proto3" json:"os_arch,omitempty"`                   // e.g. "linux/amd64"
	AgentVersion    string  `protobuf:"bytes,6,opt,name=agent_version,json=agentVersion,proto3" json:"agent_version,omitempty"` // semver — server checks major compat
	DetectedRuntime Runtime ``                                                                                                  /* 140-byte string literal not displayed */
	// Optional display label suggested by the agent (from --label= flag or
	// the operator's preference). If empty, the server falls back to using
	// `hostname` as the initial display value. Display-only — never used as
	// an identifier in API/MCP/gRPC requests; agent_id is the only key.
	// Max 64 chars enforced server-side. Editable later via PATCH /agents/:id.
	Label string `protobuf:"bytes,8,opt,name=label,proto3" json:"label,omitempty"`
	// contains filtered or unexported fields
}

type RegisterResponse struct {
	ServerTime  *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=server_time,json=serverTime,proto3" json:"server_time,omitempty"` // for clock-skew calibration
	AgentConfig *AgentConfig           `protobuf:"bytes,2,opt,name=agent_config,json=agentConfig,proto3" json:"agent_config,omitempty"`
	// contains filtered or unexported fields
}

type ResourceSample struct {
	ContainerId      string  `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`                   // empty for host-level samples
	CpuPercent       float64 `protobuf:"fixed64,2,opt,name=cpu_percent,json=cpuPercent,proto3" json:"cpu_percent,omitempty"`                    // host CPU% when container_id empty
	MemoryBytes      uint64  `protobuf:"varint,3,opt,name=memory_bytes,json=memoryBytes,proto3" json:"memory_bytes,omitempty"`                  // host mem used when container_id empty
	MemoryLimitBytes uint64  `protobuf:"varint,4,opt,name=memory_limit_bytes,json=memoryLimitBytes,proto3" json:"memory_limit_bytes,omitempty"` // host mem total when container_id empty
	NetworkRxBytes   uint64  `protobuf:"varint,5,opt,name=network_rx_bytes,json=networkRxBytes,proto3" json:"network_rx_bytes,omitempty"`
	NetworkTxBytes   uint64  `protobuf:"varint,6,opt,name=network_tx_bytes,json=networkTxBytes,proto3" json:"network_tx_bytes,omitempty"`
	DiskReadBytes    uint64  `protobuf:"varint,7,opt,name=disk_read_bytes,json=diskReadBytes,proto3" json:"disk_read_bytes,omitempty"`
	DiskWriteBytes   uint64  `protobuf:"varint,8,opt,name=disk_write_bytes,json=diskWriteBytes,proto3" json:"disk_write_bytes,omitempty"`
	// Host-level only (container_id empty): root filesystem capacity.
	HostDiskTotalBytes uint64 `protobuf:"varint,9,opt,name=host_disk_total_bytes,json=hostDiskTotalBytes,proto3" json:"host_disk_total_bytes,omitempty"`
	HostDiskUsedBytes  uint64 `protobuf:"varint,10,opt,name=host_disk_used_bytes,json=hostDiskUsedBytes,proto3" json:"host_disk_used_bytes,omitempty"`
	// contains filtered or unexported fields
}

type Runtime int32

type ServerMessage struct {

	// Types that are valid to be assigned to Payload:
	//
	//	*ServerMessage_Challenge
	//	*ServerMessage_Ack
	//	*ServerMessage_Error
	//	*ServerMessage_Command
	Payload isServerMessage_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

type ServerMessage_Ack struct {
	Ack *EventAck `protobuf:"bytes,2,opt,name=ack,proto3,oneof"` // optional periodic ack (every N events or T seconds)
}

type ServerMessage_Challenge struct {
	Challenge *AuthChallenge `protobuf:"bytes,1,opt,name=challenge,proto3,oneof"` // first message only
}

type ServerMessage_Command struct {
	Command *AgentCommand `protobuf:"bytes,4,opt,name=command,proto3,oneof"` // server asks the agent to do something
}

type ServerMessage_Error struct {
	Error *StreamError `protobuf:"bytes,3,opt,name=error,proto3,oneof"` // server-initiated termination signal
}

type SpoolStatus struct {
	Queued              uint64 `protobuf:"varint,1,opt,name=queued,proto3" json:"queued,omitempty"`
	Draining            bool   `protobuf:"varint,2,opt,name=draining,proto3" json:"draining,omitempty"`
	DroppedSinceConnect uint64 `protobuf:"varint,3,opt,name=dropped_since_connect,json=droppedSinceConnect,proto3" json:"dropped_since_connect,omitempty"` // discarded for lack of room since this connect
	// contains filtered or unexported fields
}

type StreamError struct {
	Code         string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`                                        // e.g. "agent_revoked", "rate_limited", "incompatible_version"
	Message      string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`                                  // human-readable
	RetryAfterMs uint32 `protobuf:"varint,3,opt,name=retry_after_ms,json=retryAfterMs,proto3" json:"retry_after_ms,omitempty"` // hint for client backoff (rate-limit case)
	// contains filtered or unexported fields
}

type SwarmNodeMsg struct {
	NodeId        string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Hostname      string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Role          string `protobuf:"bytes,3,opt,name=role,proto3" json:"role,omitempty"`                 // "manager" or "worker"
	Status        string `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`             // "ready", "down", "disconnected", "unknown"
	Availability  string `protobuf:"bytes,5,opt,name=availability,proto3" json:"availability,omitempty"` // "active", "pause", "drain"
	EngineVersion string `protobuf:"bytes,6,opt,name=engine_version,json=engineVersion,proto3" json:"engine_version,omitempty"`
	Address       string `protobuf:"bytes,7,opt,name=address,proto3" json:"address,omitempty"`
	TaskCount     int32  `protobuf:"varint,8,opt,name=task_count,json=taskCount,proto3" json:"task_count,omitempty"`
	// contains filtered or unexported fields
}

type SwarmServiceMsg struct {
	ServiceId       string                 `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	Name            string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Image           string                 `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	Mode            string                 `protobuf:"bytes,4,opt,name=mode,proto3" json:"mode,omitempty"` // "replicated" or "global"
	DesiredReplicas int32                  `protobuf:"varint,5,opt,name=desired_replicas,json=desiredReplicas,proto3" json:"desired_replicas,omitempty"`
	RunningReplicas int32                  `protobuf:"varint,6,opt,name=running_replicas,json=runningReplicas,proto3" json:"running_replicas,omitempty"`
	Labels          map[string]string      `` /* 139-byte string literal not displayed */
	StackName       string                 `protobuf:"bytes,8,opt,name=stack_name,json=stackName,proto3" json:"stack_name,omitempty"`
	CreatedAt       *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

type SwarmTaskMsg struct {
	TaskId       string                 `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	ServiceId    string                 `protobuf:"bytes,2,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	NodeId       string                 `protobuf:"bytes,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Slot         int32                  `protobuf:"varint,4,opt,name=slot,proto3" json:"slot,omitempty"`
	State        string                 `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	DesiredState string                 `protobuf:"bytes,6,opt,name=desired_state,json=desiredState,proto3" json:"desired_state,omitempty"`
	ContainerId  string                 `protobuf:"bytes,7,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Error        string                 `protobuf:"bytes,8,opt,name=error,proto3" json:"error,omitempty"`
	ExitCode     int32                  `protobuf:"varint,9,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	HasExitCode  bool                   `protobuf:"varint,10,opt,name=has_exit_code,json=hasExitCode,proto3" json:"has_exit_code,omitempty"` // proto3 has no nullable int; gate exit_code with this
	Timestamp    *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	NodeHostname string                 `protobuf:"bytes,12,opt,name=node_hostname,json=nodeHostname,proto3" json:"node_hostname,omitempty"`
	// contains filtered or unexported fields
}

type SwarmTopology struct {
	Services []*SwarmServiceMsg `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	Tasks    []*SwarmTaskMsg    `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty"`
	Nodes    []*SwarmNodeMsg    `protobuf:"bytes,3,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedIngestServer struct{}

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