api

type ArtifactChunk struct {

	// Types that are valid to be assigned to Payload:
	//
	//	*ArtifactChunk_Sha256
	//	*ArtifactChunk_Data
	Payload isArtifactChunk_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

type ArtifactChunk_Data struct {
	// data is a slice of artifact bytes.
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

type ArtifactChunk_Sha256 struct {
	// sha256 is the lowercase hex digest; sent once, as the first frame.
	Sha256 string `protobuf:"bytes,1,opt,name=sha256,proto3,oneof"`
}

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

type CreateEvent struct {

	// Types that are valid to be assigned to Event:
	//
	//	*CreateEvent_Status
	//	*CreateEvent_Warning
	//	*CreateEvent_Cluster
	Event isCreateEvent_Event `protobuf_oneof:"event"`
	// contains filtered or unexported fields
}

type CreateEvent_Cluster struct {
	// cluster is the JSON-encoded provision.Cluster — emitted as the
	// terminal event on success.
	Cluster []byte `protobuf:"bytes,3,opt,name=cluster,proto3,oneof"`
}

type CreateEvent_Status struct {
	// status is a human-readable progress line.
	Status string `protobuf:"bytes,1,opt,name=status,proto3,oneof"`
}

type CreateEvent_Warning struct {
	// warning is a human-readable non-fatal warning.
	Warning string `protobuf:"bytes,2,opt,name=warning,proto3,oneof"`
}

type CreateRequest struct {

	// cluster_request is a JSON-encoded provision.ClusterRequest.
	ClusterRequest []byte `protobuf:"bytes,1,opt,name=cluster_request,json=clusterRequest,proto3" json:"cluster_request,omitempty"`
	// artifact_paths maps logical artifact names (kernel, initramfs, iso,
	// usb, uki, diskimage, ipxe) to canonical paths on the server. The
	// client populates these after uploading the corresponding local files.
	// URL-valued entries are skipped and fetched server-side instead.
	ArtifactPaths map[string]string `` /* 174-byte string literal not displayed */
	// options is a JSON-encoded subset of provision.Options (UEFI, TPM,
	// bootloader, etc.). The server reconstructs the provision.Option list
	// from it; non-serializable fields (LogWriter, Talos client) are set
	// server-side.
	Options []byte `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

type DestroyRequest struct {

	// cluster_name identifies the cluster on the server's state directory.
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	// contains filtered or unexported fields
}

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

type LogData struct {

	// machine_name is the node the line came from.
	MachineName string `protobuf:"bytes,1,opt,name=machine_name,json=machineName,proto3" json:"machine_name,omitempty"`
	// line is a single console log line (no trailing newline).
	Line string `protobuf:"bytes,2,opt,name=line,proto3" json:"line,omitempty"`
	// contains filtered or unexported fields
}

type LogsRequest struct {

	// cluster_name is the cluster the machine(s) belong to.
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	// machine_name is the node name (e.g. "talos-default-controlplane-1").
	// Empty means stream every machine in the cluster.
	MachineName string `protobuf:"bytes,2,opt,name=machine_name,json=machineName,proto3" json:"machine_name,omitempty"`
	// follow keeps the stream open and tails new output (tail -F).
	Follow bool `protobuf:"varint,3,opt,name=follow,proto3" json:"follow,omitempty"`
	// contains filtered or unexported fields
}

type PingResponse struct {

	// server_version is the talosctl version backing the server.
	ServerVersion string `protobuf:"bytes,1,opt,name=server_version,json=serverVersion,proto3" json:"server_version,omitempty"`
	// host_arch is the server's architecture ("amd64" / "arm64"). Clients
	// target this arch for remote cluster creation.
	HostArch string `protobuf:"bytes,2,opt,name=host_arch,json=hostArch,proto3" json:"host_arch,omitempty"`
	// contains filtered or unexported fields
}

type RebootRequest struct {
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	MachineName string `protobuf:"bytes,2,opt,name=machine_name,json=machineName,proto3" json:"machine_name,omitempty"`
	// contains filtered or unexported fields
}

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

type ReflectRequest struct {
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	// contains filtered or unexported fields
}

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

type RemoteProvisionServiceClient interface {
	// Ping returns server identity for connectivity sanity checks.
	Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PingResponse, error)
	// Create provisions a cluster. The stream emits progress events; the
	// terminal event carries the JSON-encoded provision.Cluster.
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[CreateEvent], error)
	// Destroy tears down a previously-created cluster.
	Destroy(ctx context.Context, in *DestroyRequest, opts ...grpc.CallOption) (*DestroyResponse, error)
	// Reflect returns a previously-created cluster's state by name.
	Reflect(ctx context.Context, in *ReflectRequest, opts ...grpc.CallOption) (*ReflectResponse, error)
	// StreamLogs tails a machine's QEMU console log from the server's state
	// directory — the remote equivalent of `tail -F <machine>.log`.
	StreamLogs(ctx context.Context, in *LogsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[LogData], error)
	// StatArtifact reports whether a content-addressed artifact is already
	// cached on the server, so the client can skip re-uploading it.
	StatArtifact(ctx context.Context, in *StatArtifactRequest, opts ...grpc.CallOption) (*StatArtifactResponse, error)
	// UploadArtifact streams a boot artifact (kernel, initramfs, ISO, ...)
	// to the server's content-addressed cache. The first frame carries the
	// sha256; the rest carry data.
	UploadArtifact(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[ArtifactChunk, ArtifactRef], error)
	// SyncBootArtifacts updates the stable kernel and initramfs references
	// used by an existing no-bootloader cluster.
	SyncBootArtifacts(ctx context.Context, in *SyncBootArtifactsRequest, opts ...grpc.CallOption) (*SyncBootArtifactsResponse, error)
	// Reboot forcefully restarts one QEMU node.
	Reboot(ctx context.Context, in *RebootRequest, opts ...grpc.CallOption) (*RebootResponse, error)
}

type RemoteProvisionServiceServer interface {
	// Ping returns server identity for connectivity sanity checks.
	Ping(context.Context, *emptypb.Empty) (*PingResponse, error)
	// Create provisions a cluster. The stream emits progress events; the
	// terminal event carries the JSON-encoded provision.Cluster.
	Create(*CreateRequest, grpc.ServerStreamingServer[CreateEvent]) error
	// Destroy tears down a previously-created cluster.
	Destroy(context.Context, *DestroyRequest) (*DestroyResponse, error)
	// Reflect returns a previously-created cluster's state by name.
	Reflect(context.Context, *ReflectRequest) (*ReflectResponse, error)
	// StreamLogs tails a machine's QEMU console log from the server's state
	// directory — the remote equivalent of `tail -F <machine>.log`.
	StreamLogs(*LogsRequest, grpc.ServerStreamingServer[LogData]) error
	// StatArtifact reports whether a content-addressed artifact is already
	// cached on the server, so the client can skip re-uploading it.
	StatArtifact(context.Context, *StatArtifactRequest) (*StatArtifactResponse, error)
	// UploadArtifact streams a boot artifact (kernel, initramfs, ISO, ...)
	// to the server's content-addressed cache. The first frame carries the
	// sha256; the rest carry data.
	UploadArtifact(grpc.ClientStreamingServer[ArtifactChunk, ArtifactRef]) error
	// SyncBootArtifacts updates the stable kernel and initramfs references
	// used by an existing no-bootloader cluster.
	SyncBootArtifacts(context.Context, *SyncBootArtifactsRequest) (*SyncBootArtifactsResponse, error)
	// Reboot forcefully restarts one QEMU node.
	Reboot(context.Context, *RebootRequest) (*RebootResponse, error)
	// contains filtered or unexported methods
}

type RemoteProvisionService_CreateClient = grpc.ServerStreamingClient[CreateEvent]

type RemoteProvisionService_CreateServer = grpc.ServerStreamingServer[CreateEvent]

type RemoteProvisionService_StreamLogsClient = grpc.ServerStreamingClient[LogData]

type RemoteProvisionService_StreamLogsServer = grpc.ServerStreamingServer[LogData]

type RemoteProvisionService_UploadArtifactClient = grpc.ClientStreamingClient[ArtifactChunk, ArtifactRef]

type RemoteProvisionService_UploadArtifactServer = grpc.ClientStreamingServer[ArtifactChunk, ArtifactRef]

type StatArtifactRequest struct {

	// sha256 is the lowercase hex digest of the artifact.
	Sha256 string `protobuf:"bytes,1,opt,name=sha256,proto3" json:"sha256,omitempty"`
	// contains filtered or unexported fields
}

type StatArtifactResponse struct {

	// exists is true when the artifact is already cached.
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	// path is the canonical server path when exists is true.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

type SyncBootArtifactsRequest struct {
	ClusterName   string            `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	ArtifactPaths map[string]string `` /* 174-byte string literal not displayed */
	// contains filtered or unexported fields
}

type SyncBootArtifactsResponse struct {
	Changed map[string]bool `` /* 142-byte string literal not displayed */
	// contains filtered or unexported fields
}

type UnimplementedRemoteProvisionServiceServer struct{}

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