agentv1

type AgentControlPlaneClient interface {
	// RegisterAgent + Heartbeat are the lifecycle calls. Unary
	// RPCs because they're rare + need explicit success/failure.
	RegisterAgent(ctx context.Context, in *RegisterAgentRequest, opts ...grpc.CallOption) (*RegisterAgentResponse, error)
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error)
	// AttachDrivers is the long-lived bidi stream the CP uses to
	// dispatch driver calls. Agent → first frame is the init
	// message ; after that, the stream is fully bidi.
	AttachDrivers(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[AttachDriversFrame, AttachDriversFrame], error)
}

type AgentControlPlaneServer interface {
	// RegisterAgent + Heartbeat are the lifecycle calls. Unary
	// RPCs because they're rare + need explicit success/failure.
	RegisterAgent(context.Context, *RegisterAgentRequest) (*RegisterAgentResponse, error)
	Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
	// AttachDrivers is the long-lived bidi stream the CP uses to
	// dispatch driver calls. Agent → first frame is the init
	// message ; after that, the stream is fully bidi.
	AttachDrivers(grpc.BidiStreamingServer[AttachDriversFrame, AttachDriversFrame]) error
	// contains filtered or unexported methods
}

type AgentControlPlane_AttachDriversClient = grpc.BidiStreamingClient[AttachDriversFrame, AttachDriversFrame]

type AgentControlPlane_AttachDriversServer = grpc.BidiStreamingServer[AttachDriversFrame, AttachDriversFrame]

type AgentDisconnect struct {
	Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

type AttachDriversFrame struct {

	// Types that are valid to be assigned to Body:
	//
	//	*AttachDriversFrame_Init
	//	*AttachDriversFrame_Dispatch
	//	*AttachDriversFrame_Result
	//	*AttachDriversFrame_Disconnect
	Body isAttachDriversFrame_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

type AttachDriversFrame_Disconnect struct {
	// disconnect frames close the stream cleanly. Either side
	// can send ; the other side acks then drops.
	Disconnect *AgentDisconnect `protobuf:"bytes,4,opt,name=disconnect,proto3,oneof"`
}

type AttachDriversFrame_Dispatch struct {
	Dispatch *DriverDispatchCall `protobuf:"bytes,2,opt,name=dispatch,proto3,oneof"` // CP → agent
}

type AttachDriversFrame_Init struct {
	Init *AttachDriversInit `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

type AttachDriversFrame_Result struct {
	Result *DriverDispatchResult `protobuf:"bytes,3,opt,name=result,proto3,oneof"` // agent → CP
}

type AttachDriversInit struct {
	HostUuid string `protobuf:"bytes,1,opt,name=host_uuid,json=hostUuid,proto3" json:"host_uuid,omitempty"`
	// Capability advertisement: which driver kinds this agent
	// can serve calls for. Control plane uses this to populate
	// the dispatch table's per-host driver tuple.
	DriverKinds []string `protobuf:"bytes,2,rep,name=driver_kinds,json=driverKinds,proto3" json:"driver_kinds,omitempty"` // {"hypervisor", "network", "volume", "image"}
	// contains filtered or unexported fields
}

type DriverDispatchCall struct {

	// call_id is a per-stream monotonic counter the agent echoes
	// back in DriverDispatchResult. Lets the CP correlate
	// concurrent calls on the same stream.
	CallId     uint64 `protobuf:"varint,1,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`
	DriverKind string `protobuf:"bytes,2,opt,name=driver_kind,json=driverKind,proto3" json:"driver_kind,omitempty"` // "hypervisor" | "network" | "volume" | "image"
	MethodName string `protobuf:"bytes,3,opt,name=method_name,json=methodName,proto3" json:"method_name,omitempty"` // "CreateVM" | "AttachPort" | "EnsureVolume" | …
	Payload    []byte `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`                         // marshalled per-method request proto
	// contains filtered or unexported fields
}

type DriverDispatchResult struct {
	CallId uint64 `protobuf:"varint,1,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`
	// Exactly one of {payload, error_message} is set.
	Payload      []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"` // marshalled per-method response proto
	ErrorMessage string `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// error_kind helps the caller distinguish driver-typed
	// errors from transport errors. Empty when no error.
	ErrorKind string `protobuf:"bytes,4,opt,name=error_kind,json=errorKind,proto3" json:"error_kind,omitempty"` // "" | "unsupported" | "not_applicable" | "not_found" | "internal"
	// contains filtered or unexported fields
}

type HeartbeatRequest struct {
	HostUuid string `protobuf:"bytes,1,opt,name=host_uuid,json=hostUuid,proto3" json:"host_uuid,omitempty"`
	// contains filtered or unexported fields
}

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

type HostRegistration struct {

	// UUID is the agent's persisted host-uuid. Empty means
	// "mint a new one" ; set means "I am this host, refresh my
	// entry idempotently".
	Uuid           string            `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Hostname       string            `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Az             string            `protobuf:"bytes,3,opt,name=az,proto3" json:"az,omitempty"`
	Rack           string            `protobuf:"bytes,4,opt,name=rack,proto3" json:"rack,omitempty"`
	Endpoint       string            `protobuf:"bytes,5,opt,name=endpoint,proto3" json:"endpoint,omitempty"` // host:port the control plane can dial back if needed
	Hypervisor     string            `protobuf:"bytes,6,opt,name=hypervisor,proto3" json:"hypervisor,omitempty"`
	Architecture   string            `protobuf:"bytes,7,opt,name=architecture,proto3" json:"architecture,omitempty"`
	NetworkTypes   []string          `protobuf:"bytes,8,rep,name=network_types,json=networkTypes,proto3" json:"network_types,omitempty"`
	VolumeBackends []string          `protobuf:"bytes,9,rep,name=volume_backends,json=volumeBackends,proto3" json:"volume_backends,omitempty"`
	Properties     map[string]string `` /* 148-byte string literal not displayed */
	// agent_version is the weft binary's compile-time build version
	// (e.g. "v0.4.55"), stamped via -X main.version at link time.
	// Empty for unstamped dev builds. The control plane stores this
	// on the host registry so weft-tui / webui can show per-host
	// agent versions.
	AgentVersion string `protobuf:"bytes,11,opt,name=agent_version,json=agentVersion,proto3" json:"agent_version,omitempty"`
	// driver_versions maps each loaded driver's kind ("vz" / "qemu"
	// / "block" / …) to its compile-time build version, harvested
	// by the agent at startup from each plugin's HostInfo() RPC.
	// Empty for legacy / unstamped builds. Persisted on the host
	// registry alongside the agent_version.
	DriverVersions map[string]string `` /* 178-byte string literal not displayed */
	// OS / kernel / hardware facts collected at register time.
	// See weft.proto HostInfo for field semantics ; the agent
	// populates these via /etc/os-release + /proc/sys/kernel/osrelease
	// + /sys/class/net + statfs(/proc/mounts). Linux-only ; other
	// platforms ship zero values.
	OsId              string                         `protobuf:"bytes,13,opt,name=os_id,json=osId,proto3" json:"os_id,omitempty"`
	OsVersion         string                         `protobuf:"bytes,14,opt,name=os_version,json=osVersion,proto3" json:"os_version,omitempty"`
	OsPretty          string                         `protobuf:"bytes,15,opt,name=os_pretty,json=osPretty,proto3" json:"os_pretty,omitempty"`
	KernelVersion     string                         `protobuf:"bytes,16,opt,name=kernel_version,json=kernelVersion,proto3" json:"kernel_version,omitempty"`
	NetworkInterfaces []*weft_proto.NetworkInterface `protobuf:"bytes,17,rep,name=network_interfaces,json=networkInterfaces,proto3" json:"network_interfaces,omitempty"`
	StorageMounts     []*weft_proto.StorageMount     `protobuf:"bytes,18,rep,name=storage_mounts,json=storageMounts,proto3" json:"storage_mounts,omitempty"`
	CpuCount          int32                          `protobuf:"varint,19,opt,name=cpu_count,json=cpuCount,proto3" json:"cpu_count,omitempty"`
	MemoryMib         int64                          `protobuf:"varint,20,opt,name=memory_mib,json=memoryMib,proto3" json:"memory_mib,omitempty"`
	Gpus              []*weft_proto.GPU              `protobuf:"bytes,21,rep,name=gpus,proto3" json:"gpus,omitempty"`
	// contains filtered or unexported fields
}

type RegisterAgentRequest struct {
	Registration *HostRegistration `protobuf:"bytes,1,opt,name=registration,proto3" json:"registration,omitempty"`
	// contains filtered or unexported fields
}

type RegisterAgentResponse struct {

	// assigned_uuid is the UUID the control plane registered the
	// host under. Matches request.registration.uuid in the
	// idempotent re-register case ; differs only when the request
	// came in with an empty uuid (the CP minted a fresh one).
	AssignedUuid string `protobuf:"bytes,1,opt,name=assigned_uuid,json=assignedUuid,proto3" json:"assigned_uuid,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedAgentControlPlaneServer struct{}

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