grpcproto

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 26, 2026 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AccessProtocolService_GetManifest_FullMethodName  = "/alist.ext.v1.AccessProtocolService/GetManifest"
	AccessProtocolService_ProtocolInfo_FullMethodName = "/alist.ext.v1.AccessProtocolService/ProtocolInfo"
	AccessProtocolService_ServeHTTP_FullMethodName    = "/alist.ext.v1.AccessProtocolService/ServeHTTP"
	AccessProtocolService_InitHost_FullMethodName     = "/alist.ext.v1.AccessProtocolService/InitHost"
)
View Source 
const (
	ActionService_GetManifest_FullMethodName = "/alist.ext.v1.ActionService/GetManifest"
	ActionService_Invoke_FullMethodName      = "/alist.ext.v1.ActionService/Invoke"
	ActionService_InitHost_FullMethodName    = "/alist.ext.v1.ActionService/InitHost"
)
View Source 
const (
	APIRouteService_GetManifest_FullMethodName = "/alist.ext.v1.APIRouteService/GetManifest"
	APIRouteService_Routes_FullMethodName      = "/alist.ext.v1.APIRouteService/Routes"
	APIRouteService_Handle_FullMethodName      = "/alist.ext.v1.APIRouteService/Handle"
	APIRouteService_InitHost_FullMethodName    = "/alist.ext.v1.APIRouteService/InitHost"
)
View Source 
const (
	AuthProviderService_GetManifest_FullMethodName = "/alist.ext.v1.AuthProviderService/GetManifest"
	AuthProviderService_AuthURL_FullMethodName     = "/alist.ext.v1.AuthProviderService/AuthURL"
	AuthProviderService_Exchange_FullMethodName    = "/alist.ext.v1.AuthProviderService/Exchange"
	AuthProviderService_Refresh_FullMethodName     = "/alist.ext.v1.AuthProviderService/Refresh"
	AuthProviderService_InitHost_FullMethodName    = "/alist.ext.v1.AuthProviderService/InitHost"
)
View Source 
const (
	AuthNMethodService_GetManifest_FullMethodName = "/alist.ext.v1.AuthNMethodService/GetManifest"
	AuthNMethodService_MethodInfo_FullMethodName  = "/alist.ext.v1.AuthNMethodService/MethodInfo"
	AuthNMethodService_Begin_FullMethodName       = "/alist.ext.v1.AuthNMethodService/Begin"
	AuthNMethodService_Finish_FullMethodName      = "/alist.ext.v1.AuthNMethodService/Finish"
	AuthNMethodService_InitHost_FullMethodName    = "/alist.ext.v1.AuthNMethodService/InitHost"
)
View Source 
const (
	BackgroundServiceService_GetManifest_FullMethodName = "/alist.ext.v1.BackgroundServiceService/GetManifest"
	BackgroundServiceService_Start_FullMethodName       = "/alist.ext.v1.BackgroundServiceService/Start"
	BackgroundServiceService_Stop_FullMethodName        = "/alist.ext.v1.BackgroundServiceService/Stop"
	BackgroundServiceService_Status_FullMethodName      = "/alist.ext.v1.BackgroundServiceService/Status"
	BackgroundServiceService_InitHost_FullMethodName    = "/alist.ext.v1.BackgroundServiceService/InitHost"
)
View Source 
const (
	DriverService_GetManifest_FullMethodName    = "/alist.ext.v1.DriverService/GetManifest"
	DriverService_NewInstance_FullMethodName    = "/alist.ext.v1.DriverService/NewInstance"
	DriverService_DropInstance_FullMethodName   = "/alist.ext.v1.DriverService/DropInstance"
	DriverService_List_FullMethodName           = "/alist.ext.v1.DriverService/List"
	DriverService_Link_FullMethodName           = "/alist.ext.v1.DriverService/Link"
	DriverService_Get_FullMethodName            = "/alist.ext.v1.DriverService/Get"
	DriverService_MakeDir_FullMethodName        = "/alist.ext.v1.DriverService/MakeDir"
	DriverService_Rename_FullMethodName         = "/alist.ext.v1.DriverService/Rename"
	DriverService_Move_FullMethodName           = "/alist.ext.v1.DriverService/Move"
	DriverService_Copy_FullMethodName           = "/alist.ext.v1.DriverService/Copy"
	DriverService_Remove_FullMethodName         = "/alist.ext.v1.DriverService/Remove"
	DriverService_Other_FullMethodName          = "/alist.ext.v1.DriverService/Other"
	DriverService_TryRapidUpload_FullMethodName = "/alist.ext.v1.DriverService/TryRapidUpload"
	DriverService_OpenRange_FullMethodName      = "/alist.ext.v1.DriverService/OpenRange"
	DriverService_Put_FullMethodName            = "/alist.ext.v1.DriverService/Put"
	DriverService_InitHost_FullMethodName       = "/alist.ext.v1.DriverService/InitHost"
)
View Source 
const (
	EventHookService_GetManifest_FullMethodName = "/alist.ext.v1.EventHookService/GetManifest"
	EventHookService_OnEvent_FullMethodName     = "/alist.ext.v1.EventHookService/OnEvent"
	EventHookService_InitHost_FullMethodName    = "/alist.ext.v1.EventHookService/InitHost"
)
View Source 
const (
	FileDecoratorService_GetManifest_FullMethodName = "/alist.ext.v1.FileDecoratorService/GetManifest"
	FileDecoratorService_Decorate_FullMethodName    = "/alist.ext.v1.FileDecoratorService/Decorate"
	FileDecoratorService_InitHost_FullMethodName    = "/alist.ext.v1.FileDecoratorService/InitHost"
)
View Source 
const (
	// MagicCookieKey and MagicCookieValue are go-plugin's basic mutual
	// handshake: a plugin binary launched without the matching cookie in its
	// environment refuses to serve, so a stray exec of a plugin does nothing.
	MagicCookieKey   = "ALIST_PLUGIN"
	MagicCookieValue = "alist-plugin-core-v4"

	// ProtocolVersion is bumped on breaking wire changes; the host negotiates
	// supported versions at launch.
	ProtocolVersion = 1

	// PluginName is the go-plugin dispense key for a Kind=StorageDriver plugin.
	PluginName = "storage_driver"

	// AuthPluginName is the go-plugin dispense key for a Kind=AuthProvider
	// plugin (WS-8).
	AuthPluginName = "auth_provider"

	// AuthNPluginName is the go-plugin dispense key for a Kind=AuthNMethod
	// plugin (login methods: SSO/OIDC, LDAP, TOTP, WebAuthn). Distinct from
	// AuthPluginName — different wire service (AuthNMethodService) and a
	// different trust surface (asserts user identity, never issues a token).
	AuthNPluginName = "authn_method"

	// BgServicePluginName is the go-plugin dispense key for a
	// Kind=BackgroundService plugin: a long-lived host-managed task (FRP tunnel,
	// scheduled sync, watcher) served over BackgroundServiceService.
	BgServicePluginName = "background_service"

	// HostCapProbePluginName is the go-plugin dispense key for the F0 host
	// capability probe fixture (internal/extension/grpc/testdata/hostcapplugin):
	// a plugin that serves HostCapProbeService and dials the reverse HostService
	// bridge to exercise borrowed Host capabilities in an integration test.
	HostCapProbePluginName = "hostcap_probe"

	// APIRoutePluginName is the go-plugin dispense key for a Kind=APIRoute
	// plugin (W8a): sub-routes a plugin mounts (webhook / share API / public
	// page) served over APIRouteService.
	APIRoutePluginName = "api_route"

	// ActionPluginName is the go-plugin dispense key for a Kind=Action plugin
	// (W8b): the menu actions a plugin declared, executed on the user's behalf
	// over ActionService.
	ActionPluginName = "action"

	// EventHookPluginName is the go-plugin dispense key for a Kind=EventHook
	// plugin (W7): a notification sink for host fs events, served over
	// EventHookService.
	EventHookPluginName = "event_hook"

	// ScheduledJobPluginName is the go-plugin dispense key for a
	// Kind=ScheduledJob plugin (W7): a time-driven background task, served
	// over ScheduledJobService.
	ScheduledJobPluginName = "scheduled_job"

	// NotificationPluginName is the go-plugin dispense key for a
	// Kind=NotificationChannel plugin (W7b): a notification sink the host fans
	// notices out to (email/webhook/Telegram/...), served over
	// NotificationService.
	NotificationPluginName = "notification"

	// FileDecoratorPluginName is the go-plugin dispense key for a
	// Kind=FileDecorator plugin (W9a): the extension field group(s) behind a
	// FileColumn contribution (label badges, share markers), served over
	// FileDecoratorService.
	FileDecoratorPluginName = "file_decorator"

	// AccessProtocolPluginName is the go-plugin dispense key for a
	// Kind=AccessProtocol plugin's TransportHTTP half (W9a): WebDAV/S3/MCP
	// served over AccessProtocolService. TransportConn (FTP/SFTP) protocols
	// never dispense under this name — they are native/in-process only (design
	// §5) and do not cross the gRPC boundary.
	AccessProtocolPluginName = "access_protocol"

	// ChunkSize is the byte-slice size for OpenRange streaming and Put ReadAt
	// round-trips: within gRPC's default 4 MiB frame cap, large enough to amortize
	// per-RPC overhead, small enough to bound memory.
	ChunkSize = 64 * 1024
)

Handshake parameters for the AList storage-driver plugin protocol (Step 9.2, fixing the 9.0 §9 "later, non-blocking" small decisions). This file is the single source of truth for the magic cookie and protocol version; both the host launcher (internal/extension/grpc/host) and the plugin serve helper (ext/grpcplugin) read them from here.

View Source 
const (
	HostService_FSResolve_FullMethodName             = "/alist.ext.v1.HostService/FSResolve"
	HostService_FSList_FullMethodName                = "/alist.ext.v1.HostService/FSList"
	HostService_FSGet_FullMethodName                 = "/alist.ext.v1.HostService/FSGet"
	HostService_FSLink_FullMethodName                = "/alist.ext.v1.HostService/FSLink"
	HostService_FSMkdir_FullMethodName               = "/alist.ext.v1.HostService/FSMkdir"
	HostService_FSMove_FullMethodName                = "/alist.ext.v1.HostService/FSMove"
	HostService_FSRename_FullMethodName              = "/alist.ext.v1.HostService/FSRename"
	HostService_FSCopy_FullMethodName                = "/alist.ext.v1.HostService/FSCopy"
	HostService_FSRemove_FullMethodName              = "/alist.ext.v1.HostService/FSRemove"
	HostService_StoreGet_FullMethodName              = "/alist.ext.v1.HostService/StoreGet"
	HostService_StoreSet_FullMethodName              = "/alist.ext.v1.HostService/StoreSet"
	HostService_StoreDelete_FullMethodName           = "/alist.ext.v1.HostService/StoreDelete"
	HostService_StoreList_FullMethodName             = "/alist.ext.v1.HostService/StoreList"
	HostService_SecretGet_FullMethodName             = "/alist.ext.v1.HostService/SecretGet"
	HostService_SecretSet_FullMethodName             = "/alist.ext.v1.HostService/SecretSet"
	HostService_SecretDelete_FullMethodName          = "/alist.ext.v1.HostService/SecretDelete"
	HostService_SecretList_FullMethodName            = "/alist.ext.v1.HostService/SecretList"
	HostService_TableInsert_FullMethodName           = "/alist.ext.v1.HostService/TableInsert"
	HostService_TableGet_FullMethodName              = "/alist.ext.v1.HostService/TableGet"
	HostService_TableUpdate_FullMethodName           = "/alist.ext.v1.HostService/TableUpdate"
	HostService_TableDelete_FullMethodName           = "/alist.ext.v1.HostService/TableDelete"
	HostService_TableList_FullMethodName             = "/alist.ext.v1.HostService/TableList"
	HostService_HTTPDo_FullMethodName                = "/alist.ext.v1.HostService/HTTPDo"
	HostService_LoadConfig_FullMethodName            = "/alist.ext.v1.HostService/LoadConfig"
	HostService_SaveConfig_FullMethodName            = "/alist.ext.v1.HostService/SaveConfig"
	HostService_Capabilities_FullMethodName          = "/alist.ext.v1.HostService/Capabilities"
	HostService_AuthLogin_FullMethodName             = "/alist.ext.v1.HostService/AuthLogin"
	HostService_AuthVerifyToken_FullMethodName       = "/alist.ext.v1.HostService/AuthVerifyToken"
	HostService_AuthVerifyAppPassword_FullMethodName = "/alist.ext.v1.HostService/AuthVerifyAppPassword"
	HostService_SignLink_FullMethodName              = "/alist.ext.v1.HostService/SignLink"
	HostService_SignVerifyLink_FullMethodName        = "/alist.ext.v1.HostService/SignVerifyLink"
	HostService_FSPut_FullMethodName                 = "/alist.ext.v1.HostService/FSPut"
)
View Source 
const (
	HostCapProbeService_GetManifest_FullMethodName = "/alist.ext.v1.HostCapProbeService/GetManifest"
	HostCapProbeService_Exercise_FullMethodName    = "/alist.ext.v1.HostCapProbeService/Exercise"
)
View Source 
const (
	NotificationService_GetManifest_FullMethodName = "/alist.ext.v1.NotificationService/GetManifest"
	NotificationService_Notify_FullMethodName      = "/alist.ext.v1.NotificationService/Notify"
	NotificationService_InitHost_FullMethodName    = "/alist.ext.v1.NotificationService/InitHost"
)
View Source 
const (
	ScheduledJobService_GetManifest_FullMethodName = "/alist.ext.v1.ScheduledJobService/GetManifest"
	ScheduledJobService_Schedule_FullMethodName    = "/alist.ext.v1.ScheduledJobService/Schedule"
	ScheduledJobService_Run_FullMethodName         = "/alist.ext.v1.ScheduledJobService/Run"
	ScheduledJobService_InitHost_FullMethodName    = "/alist.ext.v1.ScheduledJobService/InitHost"
)

Variables

View Source 
var APIRouteService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "alist.ext.v1.APIRouteService",
	HandlerType: (*APIRouteServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetManifest",
			Handler:    _APIRouteService_GetManifest_Handler,
		},
		{
			MethodName: "Routes",
			Handler:    _APIRouteService_Routes_Handler,
		},
		{
			MethodName: "Handle",
			Handler:    _APIRouteService_Handle_Handler,
		},
		{
			MethodName: "InitHost",
			Handler:    _APIRouteService_InitHost_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "apiroute.proto",
}

APIRouteService_ServiceDesc is the grpc.ServiceDesc for APIRouteService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var AccessProtocolService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "alist.ext.v1.AccessProtocolService",
	HandlerType: (*AccessProtocolServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetManifest",
			Handler:    _AccessProtocolService_GetManifest_Handler,
		},
		{
			MethodName: "ProtocolInfo",
			Handler:    _AccessProtocolService_ProtocolInfo_Handler,
		},
		{
			MethodName: "ServeHTTP",
			Handler:    _AccessProtocolService_ServeHTTP_Handler,
		},
		{
			MethodName: "InitHost",
			Handler:    _AccessProtocolService_InitHost_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "accessprotocol.proto",
}

AccessProtocolService_ServiceDesc is the grpc.ServiceDesc for AccessProtocolService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var ActionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "alist.ext.v1.ActionService",
	HandlerType: (*ActionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetManifest",
			Handler:    _ActionService_GetManifest_Handler,
		},
		{
			MethodName: "Invoke",
			Handler:    _ActionService_Invoke_Handler,
		},
		{
			MethodName: "InitHost",
			Handler:    _ActionService_InitHost_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "action.proto",
}

ActionService_ServiceDesc is the grpc.ServiceDesc for ActionService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var AuthNMethodService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "alist.ext.v1.AuthNMethodService",
	HandlerType: (*AuthNMethodServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetManifest",
			Handler:    _AuthNMethodService_GetManifest_Handler,
		},
		{
			MethodName: "MethodInfo",
			Handler:    _AuthNMethodService_MethodInfo_Handler,
		},
		{
			MethodName: "Begin",
			Handler:    _AuthNMethodService_Begin_Handler,
		},
		{
			MethodName: "Finish",
			Handler:    _AuthNMethodService_Finish_Handler,
		},
		{
			MethodName: "InitHost",
			Handler:    _AuthNMethodService_InitHost_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "authn.proto",
}

AuthNMethodService_ServiceDesc is the grpc.ServiceDesc for AuthNMethodService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var AuthProviderService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "alist.ext.v1.AuthProviderService",
	HandlerType: (*AuthProviderServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetManifest",
			Handler:    _AuthProviderService_GetManifest_Handler,
		},
		{
			MethodName: "AuthURL",
			Handler:    _AuthProviderService_AuthURL_Handler,
		},
		{
			MethodName: "Exchange",
			Handler:    _AuthProviderService_Exchange_Handler,
		},
		{
			MethodName: "Refresh",
			Handler:    _AuthProviderService_Refresh_Handler,
		},
		{
			MethodName: "InitHost",
			Handler:    _AuthProviderService_InitHost_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "auth.proto",
}

AuthProviderService_ServiceDesc is the grpc.ServiceDesc for AuthProviderService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var BackgroundServiceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "alist.ext.v1.BackgroundServiceService",
	HandlerType: (*BackgroundServiceServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetManifest",
			Handler:    _BackgroundServiceService_GetManifest_Handler,
		},
		{
			MethodName: "Start",
			Handler:    _BackgroundServiceService_Start_Handler,
		},
		{
			MethodName: "Stop",
			Handler:    _BackgroundServiceService_Stop_Handler,
		},
		{
			MethodName: "Status",
			Handler:    _BackgroundServiceService_Status_Handler,
		},
		{
			MethodName: "InitHost",
			Handler:    _BackgroundServiceService_InitHost_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "bgservice.proto",
}

BackgroundServiceService_ServiceDesc is the grpc.ServiceDesc for BackgroundServiceService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var DriverService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "alist.ext.v1.DriverService",
	HandlerType: (*DriverServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetManifest",
			Handler:    _DriverService_GetManifest_Handler,
		},
		{
			MethodName: "NewInstance",
			Handler:    _DriverService_NewInstance_Handler,
		},
		{
			MethodName: "DropInstance",
			Handler:    _DriverService_DropInstance_Handler,
		},
		{
			MethodName: "List",
			Handler:    _DriverService_List_Handler,
		},
		{
			MethodName: "Link",
			Handler:    _DriverService_Link_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _DriverService_Get_Handler,
		},
		{
			MethodName: "MakeDir",
			Handler:    _DriverService_MakeDir_Handler,
		},
		{
			MethodName: "Rename",
			Handler:    _DriverService_Rename_Handler,
		},
		{
			MethodName: "Move",
			Handler:    _DriverService_Move_Handler,
		},
		{
			MethodName: "Copy",
			Handler:    _DriverService_Copy_Handler,
		},
		{
			MethodName: "Remove",
			Handler:    _DriverService_Remove_Handler,
		},
		{
			MethodName: "Other",
			Handler:    _DriverService_Other_Handler,
		},
		{
			MethodName: "TryRapidUpload",
			Handler:    _DriverService_TryRapidUpload_Handler,
		},
		{
			MethodName: "InitHost",
			Handler:    _DriverService_InitHost_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "OpenRange",
			Handler:       _DriverService_OpenRange_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Put",
			Handler:       _DriverService_Put_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "driver.proto",
}

DriverService_ServiceDesc is the grpc.ServiceDesc for DriverService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var EventHookService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "alist.ext.v1.EventHookService",
	HandlerType: (*EventHookServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetManifest",
			Handler:    _EventHookService_GetManifest_Handler,
		},
		{
			MethodName: "OnEvent",
			Handler:    _EventHookService_OnEvent_Handler,
		},
		{
			MethodName: "InitHost",
			Handler:    _EventHookService_InitHost_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "eventhook.proto",
}

EventHookService_ServiceDesc is the grpc.ServiceDesc for EventHookService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var FileDecoratorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "alist.ext.v1.FileDecoratorService",
	HandlerType: (*FileDecoratorServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetManifest",
			Handler:    _FileDecoratorService_GetManifest_Handler,
		},
		{
			MethodName: "Decorate",
			Handler:    _FileDecoratorService_Decorate_Handler,
		},
		{
			MethodName: "InitHost",
			Handler:    _FileDecoratorService_InitHost_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "filedecorator.proto",
}

FileDecoratorService_ServiceDesc is the grpc.ServiceDesc for FileDecoratorService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_accessprotocol_proto protoreflect.FileDescriptor
View Source 
var File_action_proto protoreflect.FileDescriptor
View Source 
var File_apiroute_proto protoreflect.FileDescriptor
View Source 
var File_auth_proto protoreflect.FileDescriptor
View Source 
var File_authn_proto protoreflect.FileDescriptor
View Source 
var File_bgservice_proto protoreflect.FileDescriptor
View Source 
var File_driver_proto protoreflect.FileDescriptor
View Source 
var File_eventhook_proto protoreflect.FileDescriptor
View Source 
var File_filedecorator_proto protoreflect.FileDescriptor
View Source 
var File_host_proto protoreflect.FileDescriptor
View Source 
var File_notification_proto protoreflect.FileDescriptor
View Source 
var File_scheduledjob_proto protoreflect.FileDescriptor
View Source 
var HostCapProbeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "alist.ext.v1.HostCapProbeService",
	HandlerType: (*HostCapProbeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetManifest",
			Handler:    _HostCapProbeService_GetManifest_Handler,
		},
		{
			MethodName: "Exercise",
			Handler:    _HostCapProbeService_Exercise_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "host.proto",
}

HostCapProbeService_ServiceDesc is the grpc.ServiceDesc for HostCapProbeService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var HostService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "alist.ext.v1.HostService",
	HandlerType: (*HostServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "FSResolve",
			Handler:    _HostService_FSResolve_Handler,
		},
		{
			MethodName: "FSList",
			Handler:    _HostService_FSList_Handler,
		},
		{
			MethodName: "FSGet",
			Handler:    _HostService_FSGet_Handler,
		},
		{
			MethodName: "FSLink",
			Handler:    _HostService_FSLink_Handler,
		},
		{
			MethodName: "FSMkdir",
			Handler:    _HostService_FSMkdir_Handler,
		},
		{
			MethodName: "FSMove",
			Handler:    _HostService_FSMove_Handler,
		},
		{
			MethodName: "FSRename",
			Handler:    _HostService_FSRename_Handler,
		},
		{
			MethodName: "FSCopy",
			Handler:    _HostService_FSCopy_Handler,
		},
		{
			MethodName: "FSRemove",
			Handler:    _HostService_FSRemove_Handler,
		},
		{
			MethodName: "StoreGet",
			Handler:    _HostService_StoreGet_Handler,
		},
		{
			MethodName: "StoreSet",
			Handler:    _HostService_StoreSet_Handler,
		},
		{
			MethodName: "StoreDelete",
			Handler:    _HostService_StoreDelete_Handler,
		},
		{
			MethodName: "StoreList",
			Handler:    _HostService_StoreList_Handler,
		},
		{
			MethodName: "SecretGet",
			Handler:    _HostService_SecretGet_Handler,
		},
		{
			MethodName: "SecretSet",
			Handler:    _HostService_SecretSet_Handler,
		},
		{
			MethodName: "SecretDelete",
			Handler:    _HostService_SecretDelete_Handler,
		},
		{
			MethodName: "SecretList",
			Handler:    _HostService_SecretList_Handler,
		},
		{
			MethodName: "TableInsert",
			Handler:    _HostService_TableInsert_Handler,
		},
		{
			MethodName: "TableGet",
			Handler:    _HostService_TableGet_Handler,
		},
		{
			MethodName: "TableUpdate",
			Handler:    _HostService_TableUpdate_Handler,
		},
		{
			MethodName: "TableDelete",
			Handler:    _HostService_TableDelete_Handler,
		},
		{
			MethodName: "TableList",
			Handler:    _HostService_TableList_Handler,
		},
		{
			MethodName: "HTTPDo",
			Handler:    _HostService_HTTPDo_Handler,
		},
		{
			MethodName: "LoadConfig",
			Handler:    _HostService_LoadConfig_Handler,
		},
		{
			MethodName: "SaveConfig",
			Handler:    _HostService_SaveConfig_Handler,
		},
		{
			MethodName: "Capabilities",
			Handler:    _HostService_Capabilities_Handler,
		},
		{
			MethodName: "AuthLogin",
			Handler:    _HostService_AuthLogin_Handler,
		},
		{
			MethodName: "AuthVerifyToken",
			Handler:    _HostService_AuthVerifyToken_Handler,
		},
		{
			MethodName: "AuthVerifyAppPassword",
			Handler:    _HostService_AuthVerifyAppPassword_Handler,
		},
		{
			MethodName: "SignLink",
			Handler:    _HostService_SignLink_Handler,
		},
		{
			MethodName: "SignVerifyLink",
			Handler:    _HostService_SignVerifyLink_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "FSPut",
			Handler:       _HostService_FSPut_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "host.proto",
}

HostService_ServiceDesc is the grpc.ServiceDesc for HostService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var NotificationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "alist.ext.v1.NotificationService",
	HandlerType: (*NotificationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetManifest",
			Handler:    _NotificationService_GetManifest_Handler,
		},
		{
			MethodName: "Notify",
			Handler:    _NotificationService_Notify_Handler,
		},
		{
			MethodName: "InitHost",
			Handler:    _NotificationService_InitHost_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "notification.proto",
}

NotificationService_ServiceDesc is the grpc.ServiceDesc for NotificationService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var ScheduledJobService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "alist.ext.v1.ScheduledJobService",
	HandlerType: (*ScheduledJobServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetManifest",
			Handler:    _ScheduledJobService_GetManifest_Handler,
		},
		{
			MethodName: "Schedule",
			Handler:    _ScheduledJobService_Schedule_Handler,
		},
		{
			MethodName: "Run",
			Handler:    _ScheduledJobService_Run_Handler,
		},
		{
			MethodName: "InitHost",
			Handler:    _ScheduledJobService_InitHost_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "scheduledjob.proto",
}

ScheduledJobService_ServiceDesc is the grpc.ServiceDesc for ScheduledJobService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func AuthNChallengeFromProto 

func AuthNChallengeFromProto(r *BeginReply) ext.AuthNChallenge

func AuthNRequestFromProto 

func AuthNRequestFromProto(r *BeginRequest) (ext.Principal, ext.AuthNRequest)

func AuthNResponseFromProto 

func AuthNResponseFromProto(r *FinishRequest) ext.AuthNResponse

func AuthNResultFromProto 

func AuthNResultFromProto(r *AuthNResultProto) ext.AuthNResult

func ErrorFromProto 

func ErrorFromProto(e *ErrorProto) error

ErrorFromProto reconstructs an error from an ErrorProto. A nil proto or empty code+message yields nil. A non-empty code becomes an *ext.Error (so the host boundary can map it back to a sentinel via ext.CodeOf); a code-less error becomes a plain error carrying the message.

func HeaderFromProto 

func HeaderFromProto(m map[string]*HeaderValue) http.Header

func HeaderToProto 

func HeaderToProto(h http.Header) map[string]*HeaderValue

func LinkArgsFromProto 

func LinkArgsFromProto(a *LinkArgs) ext.LinkArgs

func LinkFromProto 

func LinkFromProto(l *Link) *ext.Link

func ListArgsFromProto 

func ListArgsFromProto(a *ListArgs) ext.ListArgs

func MethodInfoFromProto 

func MethodInfoFromProto(i *MethodInfoReply) ext.AuthMethodInfo

func ObjFromProto 

func ObjFromProto(o *Obj) ext.Obj

func ObjPtrFromProto 

func ObjPtrFromProto(o *Obj) *ext.Obj

ObjPtrFromProto decodes an optional *ext.Obj (nil-safe).

func ObjsFromProto 

func ObjsFromProto(objs []*Obj) []ext.Obj

func RangeFromProto 

func RangeFromProto(r *Range) ext.Range

func RefFromProto 

func RefFromProto(r *ObjRef) ext.ObjRef

func RegisterAPIRouteServiceServer 

func RegisterAPIRouteServiceServer(s grpc.ServiceRegistrar, srv APIRouteServiceServer)

func RegisterAccessProtocolServiceServer 

func RegisterAccessProtocolServiceServer(s grpc.ServiceRegistrar, srv AccessProtocolServiceServer)

func RegisterActionServiceServer 

func RegisterActionServiceServer(s grpc.ServiceRegistrar, srv ActionServiceServer)

func RegisterAuthNMethodServiceServer 

func RegisterAuthNMethodServiceServer(s grpc.ServiceRegistrar, srv AuthNMethodServiceServer)

func RegisterAuthProviderServiceServer 

func RegisterAuthProviderServiceServer(s grpc.ServiceRegistrar, srv AuthProviderServiceServer)

func RegisterBackgroundServiceServiceServer 

func RegisterBackgroundServiceServiceServer(s grpc.ServiceRegistrar, srv BackgroundServiceServiceServer)

func RegisterDriverServiceServer 

func RegisterDriverServiceServer(s grpc.ServiceRegistrar, srv DriverServiceServer)

func RegisterEventHookServiceServer 

func RegisterEventHookServiceServer(s grpc.ServiceRegistrar, srv EventHookServiceServer)

func RegisterFileDecoratorServiceServer 

func RegisterFileDecoratorServiceServer(s grpc.ServiceRegistrar, srv FileDecoratorServiceServer)

func RegisterHostCapProbeServiceServer 

func RegisterHostCapProbeServiceServer(s grpc.ServiceRegistrar, srv HostCapProbeServiceServer)

func RegisterHostServiceServer 

func RegisterHostServiceServer(s grpc.ServiceRegistrar, srv HostServiceServer)

func RegisterNotificationServiceServer 

func RegisterNotificationServiceServer(s grpc.ServiceRegistrar, srv NotificationServiceServer)

func RegisterScheduledJobServiceServer 

func RegisterScheduledJobServiceServer(s grpc.ServiceRegistrar, srv ScheduledJobServiceServer)

func TokenFromProto 

func TokenFromProto(t *Token) ext.Token

func UploadInfoFromProto 

func UploadInfoFromProto(i *UploadInfo) ext.UploadInfo

Types

type APIRouteServiceClient 

type APIRouteServiceClient interface {
	// GetManifest is the handshake: the manifest the host validates/mounts routes
	// from.
	GetManifest(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ManifestReply, error)
	// Routes declares the sub-routes this plugin serves (ext.APIRoute.Routes).
	Routes(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*RoutesReply, error)
	// Handle serves one proxied request (ext.APIRoute.Handle). Reuses
	// HTTPDoRequest/HTTPDoReply (host.proto) for the request/response encoding.
	Handle(ctx context.Context, in *HTTPDoRequest, opts ...grpc.CallOption) (*HTTPDoReply, error)
	// Reverse host bridge (F0/SP6): host serves a HostService on the broker id it
	// passes here; the plugin dials it and delivers the host to Init.
	InitHost(ctx context.Context, in *InitHostRequest, opts ...grpc.CallOption) (*ErrorReply, error)
}

APIRouteServiceClient is the client API for APIRouteService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

APIRouteService mirrors ext.APIRoute (design §2.5 FeatureBundle = APIRoute + PublicPage + …): a Kind=APIRoute plugin declares the sub-routes it serves and handles proxied requests for them. Mirrors AuthProviderService (auth.proto) one Kind over, including the reverse-host InitHost bridge (F0/SP6). Handle's request/reply reuse host.proto's HTTPDoRequest/HTTPDoReply message shapes (method/url/header/body and status/header/body) rather than defining duplicate messages — the wire encoding of ext.HTTPRequest/ext.HTTPResponse is already frozen there.

func NewAPIRouteServiceClient 

func NewAPIRouteServiceClient(cc grpc.ClientConnInterface) APIRouteServiceClient

type APIRouteServiceServer 

type APIRouteServiceServer interface {
	// GetManifest is the handshake: the manifest the host validates/mounts routes
	// from.
	GetManifest(context.Context, *Empty) (*ManifestReply, error)
	// Routes declares the sub-routes this plugin serves (ext.APIRoute.Routes).
	Routes(context.Context, *Empty) (*RoutesReply, error)
	// Handle serves one proxied request (ext.APIRoute.Handle). Reuses
	// HTTPDoRequest/HTTPDoReply (host.proto) for the request/response encoding.
	Handle(context.Context, *HTTPDoRequest) (*HTTPDoReply, error)
	// Reverse host bridge (F0/SP6): host serves a HostService on the broker id it
	// passes here; the plugin dials it and delivers the host to Init.
	InitHost(context.Context, *InitHostRequest) (*ErrorReply, error)
	// contains filtered or unexported methods
}

APIRouteServiceServer is the server API for APIRouteService service. All implementations must embed UnimplementedAPIRouteServiceServer for forward compatibility.

APIRouteService mirrors ext.APIRoute (design §2.5 FeatureBundle = APIRoute + PublicPage + …): a Kind=APIRoute plugin declares the sub-routes it serves and handles proxied requests for them. Mirrors AuthProviderService (auth.proto) one Kind over, including the reverse-host InitHost bridge (F0/SP6). Handle's request/reply reuse host.proto's HTTPDoRequest/HTTPDoReply message shapes (method/url/header/body and status/header/body) rather than defining duplicate messages — the wire encoding of ext.HTTPRequest/ext.HTTPResponse is already frozen there.

type AccessProtocolServiceClient 

type AccessProtocolServiceClient interface {
	// GetManifest is the handshake: the manifest the host validates the plugin
	// against before mounting it.
	GetManifest(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ManifestReply, error)
	// ProtocolInfo describes how the host binds this protocol
	// (ext.AccessProtocol.ProtocolInfo): scheme, transport, mount pattern.
	ProtocolInfo(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ProtocolInfoReply, error)
	// ServeHTTP handles one inbound HTTP request (ext.AccessProtocol.ServeHTTP).
	// Reuses HTTPDoRequest/HTTPDoReply (host.proto) for the request/response
	// encoding, exactly as APIRouteService.Handle does.
	ServeHTTP(ctx context.Context, in *HTTPDoRequest, opts ...grpc.CallOption) (*HTTPDoReply, error)
	// Reverse host bridge (F0/SP6): host serves a HostService on the broker id it
	// passes here; the plugin dials it and delivers the host to Init.
	InitHost(ctx context.Context, in *InitHostRequest, opts ...grpc.CallOption) (*ErrorReply, error)
}

AccessProtocolServiceClient is the client API for AccessProtocolService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

AccessProtocolService mirrors ext.AccessProtocol's TransportHTTP half (design §2.1, §5, W9a): a Kind=AccessProtocol plugin exposing the AList filesystem over WebDAV/S3/MCP. Mirrors APIRouteService (apiroute.proto) one Kind over, including the reverse-host InitHost bridge (F0/SP6).

ServeHTTP is the ONLY traffic RPC: HandleConn (TransportConn — FTP/SFTP) is NOT exposed here. A raw net.Conn is not serializable and per design §5 does not cross the gRPC boundary at all (see ext.AccessProtocol.HandleConn's doc comment) — a TransportConn protocol is native/in-process only, never a gRPC plugin. So a gRPC AccessProtocol is structurally HTTP-transport-only; its host-side client answers a HandleConn call with a "native only" error (ext.ErrCodeNotImplement) rather than attempting a wire call that has no message shape to carry it.

func NewAccessProtocolServiceClient 

func NewAccessProtocolServiceClient(cc grpc.ClientConnInterface) AccessProtocolServiceClient

type AccessProtocolServiceServer 

type AccessProtocolServiceServer interface {
	// GetManifest is the handshake: the manifest the host validates the plugin
	// against before mounting it.
	GetManifest(context.Context, *Empty) (*ManifestReply, error)
	// ProtocolInfo describes how the host binds this protocol
	// (ext.AccessProtocol.ProtocolInfo): scheme, transport, mount pattern.
	ProtocolInfo(context.Context, *Empty) (*ProtocolInfoReply, error)
	// ServeHTTP handles one inbound HTTP request (ext.AccessProtocol.ServeHTTP).
	// Reuses HTTPDoRequest/HTTPDoReply (host.proto) for the request/response
	// encoding, exactly as APIRouteService.Handle does.
	ServeHTTP(context.Context, *HTTPDoRequest) (*HTTPDoReply, error)
	// Reverse host bridge (F0/SP6): host serves a HostService on the broker id it
	// passes here; the plugin dials it and delivers the host to Init.
	InitHost(context.Context, *InitHostRequest) (*ErrorReply, error)
	// contains filtered or unexported methods
}

AccessProtocolServiceServer is the server API for AccessProtocolService service. All implementations must embed UnimplementedAccessProtocolServiceServer for forward compatibility.

AccessProtocolService mirrors ext.AccessProtocol's TransportHTTP half (design §2.1, §5, W9a): a Kind=AccessProtocol plugin exposing the AList filesystem over WebDAV/S3/MCP. Mirrors APIRouteService (apiroute.proto) one Kind over, including the reverse-host InitHost bridge (F0/SP6).

ServeHTTP is the ONLY traffic RPC: HandleConn (TransportConn — FTP/SFTP) is NOT exposed here. A raw net.Conn is not serializable and per design §5 does not cross the gRPC boundary at all (see ext.AccessProtocol.HandleConn's doc comment) — a TransportConn protocol is native/in-process only, never a gRPC plugin. So a gRPC AccessProtocol is structurally HTTP-transport-only; its host-side client answers a HandleConn call with a "native only" error (ext.ErrCodeNotImplement) rather than attempting a wire call that has no message shape to carry it.

type ActionServiceClient 

type ActionServiceClient interface {
	// GetManifest is the handshake: the manifest the host validates the
	// declared MenuActions against.
	GetManifest(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ManifestReply, error)
	// Invoke runs the action named by action_id (ext.Action.Invoke). args_json
	// is the caller's opaque args map marshaled as JSON; result_json is
	// whatever Invoke returned, marshaled the same way — neither shape is
	// known to the host, so JSON is the wire encoding rather than a typed
	// message.
	Invoke(ctx context.Context, in *InvokeRequest, opts ...grpc.CallOption) (*InvokeReply, error)
	// Reverse host bridge (F0/SP6): host serves a HostService on the broker id it
	// passes here; the plugin dials it and delivers the host to Init.
	InitHost(ctx context.Context, in *InitHostRequest, opts ...grpc.CallOption) (*ErrorReply, error)
}

ActionServiceClient is the client API for ActionService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

ActionService mirrors ext.Action (W8b): a Kind=Action plugin runs the menu actions it declared in Contributions.MenuActions when the host invokes them on the user's behalf. Mirrors AuthProviderService (auth.proto) one Kind over, including the reverse-host InitHost bridge (F0/SP6).

func NewActionServiceClient 

func NewActionServiceClient(cc grpc.ClientConnInterface) ActionServiceClient

type ActionServiceServer 

type ActionServiceServer interface {
	// GetManifest is the handshake: the manifest the host validates the
	// declared MenuActions against.
	GetManifest(context.Context, *Empty) (*ManifestReply, error)
	// Invoke runs the action named by action_id (ext.Action.Invoke). args_json
	// is the caller's opaque args map marshaled as JSON; result_json is
	// whatever Invoke returned, marshaled the same way — neither shape is
	// known to the host, so JSON is the wire encoding rather than a typed
	// message.
	Invoke(context.Context, *InvokeRequest) (*InvokeReply, error)
	// Reverse host bridge (F0/SP6): host serves a HostService on the broker id it
	// passes here; the plugin dials it and delivers the host to Init.
	InitHost(context.Context, *InitHostRequest) (*ErrorReply, error)
	// contains filtered or unexported methods
}

ActionServiceServer is the server API for ActionService service. All implementations must embed UnimplementedActionServiceServer for forward compatibility.

ActionService mirrors ext.Action (W8b): a Kind=Action plugin runs the menu actions it declared in Contributions.MenuActions when the host invokes them on the user's behalf. Mirrors AuthProviderService (auth.proto) one Kind over, including the reverse-host InitHost bridge (F0/SP6).

type AuthLoginRequest 

type AuthLoginRequest struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthLoginRequest) Descriptor deprecated 

func (*AuthLoginRequest) Descriptor() ([]byte, []int)

Deprecated: Use AuthLoginRequest.ProtoReflect.Descriptor instead.

func (*AuthLoginRequest) GetPassword 

func (x *AuthLoginRequest) GetPassword() string

func (*AuthLoginRequest) GetUsername 

func (x *AuthLoginRequest) GetUsername() string

func (*AuthLoginRequest) ProtoMessage 

func (*AuthLoginRequest) ProtoMessage()

func (*AuthLoginRequest) ProtoReflect 

func (x *AuthLoginRequest) ProtoReflect() protoreflect.Message

func (*AuthLoginRequest) Reset 

func (x *AuthLoginRequest) Reset()

func (*AuthLoginRequest) String 

func (x *AuthLoginRequest) String() string

type AuthNMethodServiceClient 

type AuthNMethodServiceClient interface {
	// GetManifest is the handshake: the manifest the host registers the method
	// from. driver_config_json is unused by AuthNMethod (empty).
	GetManifest(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ManifestReply, error)
	// MethodInfo reports how the host classifies and presents the method.
	MethodInfo(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*MethodInfoReply, error)
	// Begin starts a challenge (OIDC redirect URL, WebAuthn options, TOTP setup).
	Begin(ctx context.Context, in *BeginRequest, opts ...grpc.CallOption) (*BeginReply, error)
	// Finish verifies the client's response and returns the asserted identity.
	Finish(ctx context.Context, in *FinishRequest, opts ...grpc.CallOption) (*FinishReply, error)
	// Reverse host bridge (F0/SP6): host serves a HostService on the broker id it
	// passes here; the plugin dials it and delivers the host to Init.
	InitHost(ctx context.Context, in *InitHostRequest, opts ...grpc.CallOption) (*ErrorReply, error)
}

AuthNMethodServiceClient is the client API for AuthNMethodService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

AuthNMethodService mirrors ext.AuthNMethod (design §2.2): a Kind=AuthNMethod plugin authenticates an AList user (SSO/OIDC, LDAP, TOTP, WebAuthn). The plugin only PROVES identity over this service; the host alone decides whether to mint a session token. Nothing on this service issues or signs a token.

func NewAuthNMethodServiceClient 

func NewAuthNMethodServiceClient(cc grpc.ClientConnInterface) AuthNMethodServiceClient

type AuthNMethodServiceServer 

type AuthNMethodServiceServer interface {
	// GetManifest is the handshake: the manifest the host registers the method
	// from. driver_config_json is unused by AuthNMethod (empty).
	GetManifest(context.Context, *Empty) (*ManifestReply, error)
	// MethodInfo reports how the host classifies and presents the method.
	MethodInfo(context.Context, *Empty) (*MethodInfoReply, error)
	// Begin starts a challenge (OIDC redirect URL, WebAuthn options, TOTP setup).
	Begin(context.Context, *BeginRequest) (*BeginReply, error)
	// Finish verifies the client's response and returns the asserted identity.
	Finish(context.Context, *FinishRequest) (*FinishReply, error)
	// Reverse host bridge (F0/SP6): host serves a HostService on the broker id it
	// passes here; the plugin dials it and delivers the host to Init.
	InitHost(context.Context, *InitHostRequest) (*ErrorReply, error)
	// contains filtered or unexported methods
}

AuthNMethodServiceServer is the server API for AuthNMethodService service. All implementations must embed UnimplementedAuthNMethodServiceServer for forward compatibility.

AuthNMethodService mirrors ext.AuthNMethod (design §2.2): a Kind=AuthNMethod plugin authenticates an AList user (SSO/OIDC, LDAP, TOTP, WebAuthn). The plugin only PROVES identity over this service; the host alone decides whether to mint a session token. Nothing on this service issues or signs a token.

type AuthNResultProto 

type AuthNResultProto struct {
	Username      string              `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Verified      bool                `protobuf:"varint,2,opt,name=verified,proto3" json:"verified,omitempty"`
	AutoProvision *ProvisionHintProto `protobuf:"bytes,3,opt,name=auto_provision,json=autoProvision,proto3" json:"auto_provision,omitempty"`
	// contains filtered or unexported fields
}

AuthNResultProto mirrors ext.AuthNResult: the identity ASSERTION, not an authorization. The host gates on it (existing/disabled user, admin cap, federated auto-provision policy) before minting anything.

func AuthNResultToProto 

func AuthNResultToProto(res ext.AuthNResult) *AuthNResultProto

func (*AuthNResultProto) Descriptor deprecated 

func (*AuthNResultProto) Descriptor() ([]byte, []int)

Deprecated: Use AuthNResultProto.ProtoReflect.Descriptor instead.

func (*AuthNResultProto) GetAutoProvision 

func (x *AuthNResultProto) GetAutoProvision() *ProvisionHintProto

func (*AuthNResultProto) GetUsername 

func (x *AuthNResultProto) GetUsername() string

func (*AuthNResultProto) GetVerified 

func (x *AuthNResultProto) GetVerified() bool

func (*AuthNResultProto) ProtoMessage 

func (*AuthNResultProto) ProtoMessage()

func (*AuthNResultProto) ProtoReflect 

func (x *AuthNResultProto) ProtoReflect() protoreflect.Message

func (*AuthNResultProto) Reset 

func (x *AuthNResultProto) Reset()

func (*AuthNResultProto) String 

func (x *AuthNResultProto) String() string

type AuthProviderServiceClient 

type AuthProviderServiceClient interface {
	// GetManifest is the handshake: the manifest the host builds its wizard
	// integration from. driver_config_json is unused by AuthProvider (empty).
	GetManifest(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ManifestReply, error)
	// AuthURL builds the vendor's authorization-page URL.
	AuthURL(ctx context.Context, in *AuthURLRequest, opts ...grpc.CallOption) (*AuthURLReply, error)
	// Exchange trades an authorization code for a token, locally.
	Exchange(ctx context.Context, in *ExchangeRequest, opts ...grpc.CallOption) (*TokenReply, error)
	// Refresh trades a refresh token for a fresh access token, locally.
	Refresh(ctx context.Context, in *RefreshRequest, opts ...grpc.CallOption) (*TokenReply, error)
	// Reverse host bridge (F0/SP6): host serves a HostService on the broker id it
	// passes here; the plugin dials it and delivers the host to Init.
	InitHost(ctx context.Context, in *InitHostRequest, opts ...grpc.CallOption) (*ErrorReply, error)
}

AuthProviderServiceClient is the client API for AuthProviderService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

AuthProviderService mirrors ext.AuthProvider (WS-8): a Kind=AuthProvider plugin exchanges an OAuth authorization code for a token entirely inside its own process — calling the vendor's token endpoint directly with its own client_id/secret — so no external broker sits in the path between the host and the storage vendor.

func NewAuthProviderServiceClient 

func NewAuthProviderServiceClient(cc grpc.ClientConnInterface) AuthProviderServiceClient

type AuthProviderServiceServer 

type AuthProviderServiceServer interface {
	// GetManifest is the handshake: the manifest the host builds its wizard
	// integration from. driver_config_json is unused by AuthProvider (empty).
	GetManifest(context.Context, *Empty) (*ManifestReply, error)
	// AuthURL builds the vendor's authorization-page URL.
	AuthURL(context.Context, *AuthURLRequest) (*AuthURLReply, error)
	// Exchange trades an authorization code for a token, locally.
	Exchange(context.Context, *ExchangeRequest) (*TokenReply, error)
	// Refresh trades a refresh token for a fresh access token, locally.
	Refresh(context.Context, *RefreshRequest) (*TokenReply, error)
	// Reverse host bridge (F0/SP6): host serves a HostService on the broker id it
	// passes here; the plugin dials it and delivers the host to Init.
	InitHost(context.Context, *InitHostRequest) (*ErrorReply, error)
	// contains filtered or unexported methods
}

AuthProviderServiceServer is the server API for AuthProviderService service. All implementations must embed UnimplementedAuthProviderServiceServer for forward compatibility.

AuthProviderService mirrors ext.AuthProvider (WS-8): a Kind=AuthProvider plugin exchanges an OAuth authorization code for a token entirely inside its own process — calling the vendor's token endpoint directly with its own client_id/secret — so no external broker sits in the path between the host and the storage vendor.

type AuthURLReply 

type AuthURLReply struct {
	Url   string      `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Error *ErrorProto `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthURLReply) Descriptor deprecated 

func (*AuthURLReply) Descriptor() ([]byte, []int)

Deprecated: Use AuthURLReply.ProtoReflect.Descriptor instead.

func (*AuthURLReply) GetError 

func (x *AuthURLReply) GetError() *ErrorProto

func (*AuthURLReply) GetUrl 

func (x *AuthURLReply) GetUrl() string

func (*AuthURLReply) ProtoMessage 

func (*AuthURLReply) ProtoMessage()

func (*AuthURLReply) ProtoReflect 

func (x *AuthURLReply) ProtoReflect() protoreflect.Message

func (*AuthURLReply) Reset 

func (x *AuthURLReply) Reset()

func (*AuthURLReply) String 

func (x *AuthURLReply) String() string

type AuthURLRequest 

type AuthURLRequest struct {
	State       string   `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	RedirectUri string   `protobuf:"bytes,2,opt,name=redirect_uri,json=redirectUri,proto3" json:"redirect_uri,omitempty"`
	Scopes      []string `protobuf:"bytes,3,rep,name=scopes,proto3" json:"scopes,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthURLRequest) Descriptor deprecated 

func (*AuthURLRequest) Descriptor() ([]byte, []int)

Deprecated: Use AuthURLRequest.ProtoReflect.Descriptor instead.

func (*AuthURLRequest) GetRedirectUri 

func (x *AuthURLRequest) GetRedirectUri() string

func (*AuthURLRequest) GetScopes 

func (x *AuthURLRequest) GetScopes() []string

func (*AuthURLRequest) GetState 

func (x *AuthURLRequest) GetState() string

func (*AuthURLRequest) ProtoMessage 

func (*AuthURLRequest) ProtoMessage()

func (*AuthURLRequest) ProtoReflect 

func (x *AuthURLRequest) ProtoReflect() protoreflect.Message

func (*AuthURLRequest) Reset 

func (x *AuthURLRequest) Reset()

func (*AuthURLRequest) String 

func (x *AuthURLRequest) String() string

type AuthVerifyAppPasswordRequest 

type AuthVerifyAppPasswordRequest struct {
	Username    string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	AppPassword string `protobuf:"bytes,2,opt,name=app_password,json=appPassword,proto3" json:"app_password,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthVerifyAppPasswordRequest) Descriptor deprecated 

func (*AuthVerifyAppPasswordRequest) Descriptor() ([]byte, []int)

Deprecated: Use AuthVerifyAppPasswordRequest.ProtoReflect.Descriptor instead.

func (*AuthVerifyAppPasswordRequest) GetAppPassword 

func (x *AuthVerifyAppPasswordRequest) GetAppPassword() string

func (*AuthVerifyAppPasswordRequest) GetUsername 

func (x *AuthVerifyAppPasswordRequest) GetUsername() string

func (*AuthVerifyAppPasswordRequest) ProtoMessage 

func (*AuthVerifyAppPasswordRequest) ProtoMessage()

func (*AuthVerifyAppPasswordRequest) ProtoReflect 

func (x *AuthVerifyAppPasswordRequest) ProtoReflect() protoreflect.Message

func (*AuthVerifyAppPasswordRequest) Reset 

func (x *AuthVerifyAppPasswordRequest) Reset()

func (*AuthVerifyAppPasswordRequest) String 

func (x *AuthVerifyAppPasswordRequest) String() string

type AuthVerifyTokenRequest 

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

func (*AuthVerifyTokenRequest) Descriptor deprecated 

func (*AuthVerifyTokenRequest) Descriptor() ([]byte, []int)

Deprecated: Use AuthVerifyTokenRequest.ProtoReflect.Descriptor instead.

func (*AuthVerifyTokenRequest) GetToken 

func (x *AuthVerifyTokenRequest) GetToken() string

func (*AuthVerifyTokenRequest) ProtoMessage 

func (*AuthVerifyTokenRequest) ProtoMessage()

func (*AuthVerifyTokenRequest) ProtoReflect 

func (x *AuthVerifyTokenRequest) ProtoReflect() protoreflect.Message

func (*AuthVerifyTokenRequest) Reset 

func (x *AuthVerifyTokenRequest) Reset()

func (*AuthVerifyTokenRequest) String 

func (x *AuthVerifyTokenRequest) String() string

type BackgroundServiceServiceClient 

type BackgroundServiceServiceClient interface {
	// GetManifest is the handshake: the manifest the host builds its integration
	// from. driver_config_json is unused by BackgroundService (empty).
	GetManifest(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ManifestReply, error)
	// Start begins the background task; idempotent when already running.
	Start(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ErrorReply, error)
	// Stop halts the background task; idempotent when already stopped.
	Stop(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ErrorReply, error)
	// Status reports the current lifecycle state, a human-readable detail, and
	// plugin-specific metrics (JSON) for the host to surface.
	Status(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*StatusReply, error)
	// Reverse host bridge (F0/SP6): host serves a HostService on the broker id it
	// passes here; the plugin dials it and delivers the host to Init.
	InitHost(ctx context.Context, in *InitHostRequest, opts ...grpc.CallOption) (*ErrorReply, error)
}

BackgroundServiceServiceClient is the client API for BackgroundServiceService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

BackgroundServiceService mirrors ext.BackgroundService: a Kind=BackgroundService plugin runs a long-lived task inside its own process (an FRP-style tunnel, a scheduled sync, a watcher). The host owns its lifecycle — Start/Stop — and polls Status for liveness and metrics, but never sits in the data path.

func NewBackgroundServiceServiceClient 

func NewBackgroundServiceServiceClient(cc grpc.ClientConnInterface) BackgroundServiceServiceClient

type BackgroundServiceServiceServer 

type BackgroundServiceServiceServer interface {
	// GetManifest is the handshake: the manifest the host builds its integration
	// from. driver_config_json is unused by BackgroundService (empty).
	GetManifest(context.Context, *Empty) (*ManifestReply, error)
	// Start begins the background task; idempotent when already running.
	Start(context.Context, *Empty) (*ErrorReply, error)
	// Stop halts the background task; idempotent when already stopped.
	Stop(context.Context, *Empty) (*ErrorReply, error)
	// Status reports the current lifecycle state, a human-readable detail, and
	// plugin-specific metrics (JSON) for the host to surface.
	Status(context.Context, *Empty) (*StatusReply, error)
	// Reverse host bridge (F0/SP6): host serves a HostService on the broker id it
	// passes here; the plugin dials it and delivers the host to Init.
	InitHost(context.Context, *InitHostRequest) (*ErrorReply, error)
	// contains filtered or unexported methods
}

BackgroundServiceServiceServer is the server API for BackgroundServiceService service. All implementations must embed UnimplementedBackgroundServiceServiceServer for forward compatibility.

BackgroundServiceService mirrors ext.BackgroundService: a Kind=BackgroundService plugin runs a long-lived task inside its own process (an FRP-style tunnel, a scheduled sync, a watcher). The host owns its lifecycle — Start/Stop — and polls Status for liveness and metrics, but never sits in the data path.

type BeginReply 

type BeginReply struct {
	ChallengeId string      `protobuf:"bytes,1,opt,name=challenge_id,json=challengeId,proto3" json:"challenge_id,omitempty"`
	RedirectUrl string      `protobuf:"bytes,2,opt,name=redirect_url,json=redirectUrl,proto3" json:"redirect_url,omitempty"`
	Data        []byte      `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Error       *ErrorProto `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func AuthNChallengeToProto 

func AuthNChallengeToProto(c ext.AuthNChallenge) *BeginReply

func (*BeginReply) Descriptor deprecated 

func (*BeginReply) Descriptor() ([]byte, []int)

Deprecated: Use BeginReply.ProtoReflect.Descriptor instead.

func (*BeginReply) GetChallengeId 

func (x *BeginReply) GetChallengeId() string

func (*BeginReply) GetData 

func (x *BeginReply) GetData() []byte

func (*BeginReply) GetError 

func (x *BeginReply) GetError() *ErrorProto

func (*BeginReply) GetRedirectUrl 

func (x *BeginReply) GetRedirectUrl() string

func (*BeginReply) ProtoMessage 

func (*BeginReply) ProtoMessage()

func (*BeginReply) ProtoReflect 

func (x *BeginReply) ProtoReflect() protoreflect.Message

func (*BeginReply) Reset 

func (x *BeginReply) Reset()

func (*BeginReply) String 

func (x *BeginReply) String() string

type BeginRequest 

type BeginRequest struct {

	// principal is the opaque host-issued handle for step-up (empty for a fresh
	// primary/federated login).
	Principal   string            `protobuf:"bytes,1,opt,name=principal,proto3" json:"principal,omitempty"`
	RedirectUri string            `protobuf:"bytes,2,opt,name=redirect_uri,json=redirectUri,proto3" json:"redirect_uri,omitempty"`
	State       string            `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	Params      map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func AuthNRequestToProto 

func AuthNRequestToProto(principal ext.Principal, req ext.AuthNRequest) *BeginRequest

func (*BeginRequest) Descriptor deprecated 

func (*BeginRequest) Descriptor() ([]byte, []int)

Deprecated: Use BeginRequest.ProtoReflect.Descriptor instead.

func (*BeginRequest) GetParams 

func (x *BeginRequest) GetParams() map[string]string

func (*BeginRequest) GetPrincipal 

func (x *BeginRequest) GetPrincipal() string

func (*BeginRequest) GetRedirectUri 

func (x *BeginRequest) GetRedirectUri() string

func (*BeginRequest) GetState 

func (x *BeginRequest) GetState() string

func (*BeginRequest) ProtoMessage 

func (*BeginRequest) ProtoMessage()

func (*BeginRequest) ProtoReflect 

func (x *BeginRequest) ProtoReflect() protoreflect.Message

func (*BeginRequest) Reset 

func (x *BeginRequest) Reset()

func (*BeginRequest) String 

func (x *BeginRequest) String() string

type CapabilitiesReply 

type CapabilitiesReply struct {
	Apis  []string    `protobuf:"bytes,1,rep,name=apis,proto3" json:"apis,omitempty"`
	Error *ErrorProto `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CapabilitiesReply) Descriptor deprecated 

func (*CapabilitiesReply) Descriptor() ([]byte, []int)

Deprecated: Use CapabilitiesReply.ProtoReflect.Descriptor instead.

func (*CapabilitiesReply) GetApis 

func (x *CapabilitiesReply) GetApis() []string

func (*CapabilitiesReply) GetError 

func (x *CapabilitiesReply) GetError() *ErrorProto

func (*CapabilitiesReply) ProtoMessage 

func (*CapabilitiesReply) ProtoMessage()

func (*CapabilitiesReply) ProtoReflect 

func (x *CapabilitiesReply) ProtoReflect() protoreflect.Message

func (*CapabilitiesReply) Reset 

func (x *CapabilitiesReply) Reset()

func (*CapabilitiesReply) String 

func (x *CapabilitiesReply) String() string

type CapabilitiesRequest 

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

func (*CapabilitiesRequest) Descriptor deprecated 

func (*CapabilitiesRequest) Descriptor() ([]byte, []int)

Deprecated: Use CapabilitiesRequest.ProtoReflect.Descriptor instead.

func (*CapabilitiesRequest) ProtoMessage 

func (*CapabilitiesRequest) ProtoMessage()

func (*CapabilitiesRequest) ProtoReflect 

func (x *CapabilitiesRequest) ProtoReflect() protoreflect.Message

func (*CapabilitiesRequest) Reset 

func (x *CapabilitiesRequest) Reset()

func (*CapabilitiesRequest) String 

func (x *CapabilitiesRequest) String() string

type Chunk 

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

Chunk is one slice of OpenRange's byte stream. error set (non-empty code) terminates the stream.

func (*Chunk) Descriptor deprecated 

func (*Chunk) Descriptor() ([]byte, []int)

Deprecated: Use Chunk.ProtoReflect.Descriptor instead.

func (*Chunk) GetData 

func (x *Chunk) GetData() []byte

func (*Chunk) GetError 

func (x *Chunk) GetError() *ErrorProto

func (*Chunk) ProtoMessage 

func (*Chunk) ProtoMessage()

func (*Chunk) ProtoReflect 

func (x *Chunk) ProtoReflect() protoreflect.Message

func (*Chunk) Reset 

func (x *Chunk) Reset()

func (*Chunk) String 

func (x *Chunk) String() string

type CopyRequest 

type CopyRequest struct {
	Src    *ObjRef `protobuf:"bytes,1,opt,name=src,proto3" json:"src,omitempty"`
	DstDir *ObjRef `protobuf:"bytes,2,opt,name=dst_dir,json=dstDir,proto3" json:"dst_dir,omitempty"`
	// contains filtered or unexported fields
}

func (*CopyRequest) Descriptor deprecated 

func (*CopyRequest) Descriptor() ([]byte, []int)

Deprecated: Use CopyRequest.ProtoReflect.Descriptor instead.

func (*CopyRequest) GetDstDir 

func (x *CopyRequest) GetDstDir() *ObjRef

func (*CopyRequest) GetSrc 

func (x *CopyRequest) GetSrc() *ObjRef

func (*CopyRequest) ProtoMessage 

func (*CopyRequest) ProtoMessage()

func (*CopyRequest) ProtoReflect 

func (x *CopyRequest) ProtoReflect() protoreflect.Message

func (*CopyRequest) Reset 

func (x *CopyRequest) Reset()

func (*CopyRequest) String 

func (x *CopyRequest) String() string

type DecorateReply 

type DecorateReply struct {

	// values_json is Decorate's returned map[string]any marshaled as JSON.
	ValuesJson []byte      `protobuf:"bytes,1,opt,name=values_json,json=valuesJson,proto3" json:"values_json,omitempty"`
	Error      *ErrorProto `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*DecorateReply) Descriptor deprecated 

func (*DecorateReply) Descriptor() ([]byte, []int)

Deprecated: Use DecorateReply.ProtoReflect.Descriptor instead.

func (*DecorateReply) GetError 

func (x *DecorateReply) GetError() *ErrorProto

func (*DecorateReply) GetValuesJson 

func (x *DecorateReply) GetValuesJson() []byte

func (*DecorateReply) ProtoMessage 

func (*DecorateReply) ProtoMessage()

func (*DecorateReply) ProtoReflect 

func (x *DecorateReply) ProtoReflect() protoreflect.Message

func (*DecorateReply) Reset 

func (x *DecorateReply) Reset()

func (*DecorateReply) String 

func (x *DecorateReply) String() string

type DecorateRequest 

type DecorateRequest struct {
	Group string    `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	Refs  []*ObjRef `protobuf:"bytes,2,rep,name=refs,proto3" json:"refs,omitempty"`
	// contains filtered or unexported fields
}

func (*DecorateRequest) Descriptor deprecated 

func (*DecorateRequest) Descriptor() ([]byte, []int)

Deprecated: Use DecorateRequest.ProtoReflect.Descriptor instead.

func (*DecorateRequest) GetGroup 

func (x *DecorateRequest) GetGroup() string

func (*DecorateRequest) GetRefs 

func (x *DecorateRequest) GetRefs() []*ObjRef

func (*DecorateRequest) ProtoMessage 

func (*DecorateRequest) ProtoMessage()

func (*DecorateRequest) ProtoReflect 

func (x *DecorateRequest) ProtoReflect() protoreflect.Message

func (*DecorateRequest) Reset 

func (x *DecorateRequest) Reset()

func (*DecorateRequest) String 

func (x *DecorateRequest) String() string

type DriverServiceClient 

type DriverServiceClient interface {
	// GetManifest is the handshake: the manifest (with declared capabilities) and
	// the static driver config. The host builds its capability gate from this.
	GetManifest(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ManifestReply, error)
	// Instance lifecycle (9.0 §3): one mounted storage = one instance.
	NewInstance(ctx context.Context, in *NewInstanceRequest, opts ...grpc.CallOption) (*ErrorReply, error)
	DropInstance(ctx context.Context, in *DropInstanceRequest, opts ...grpc.CallOption) (*ErrorReply, error)
	// Required ops.
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListReply, error)
	Link(ctx context.Context, in *LinkRequest, opts ...grpc.CallOption) (*LinkReply, error)
	// Optional-capability ops. The plugin returns NOT_IMPLEMENT when the backing
	// driver lacks the capability; the host also gates on declared capabilities.
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*ObjReply, error)
	MakeDir(ctx context.Context, in *MakeDirRequest, opts ...grpc.CallOption) (*ObjReply, error)
	Rename(ctx context.Context, in *RenameRequest, opts ...grpc.CallOption) (*ObjReply, error)
	Move(ctx context.Context, in *MoveRequest, opts ...grpc.CallOption) (*ObjReply, error)
	Copy(ctx context.Context, in *CopyRequest, opts ...grpc.CallOption) (*ObjReply, error)
	Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*ErrorReply, error)
	Other(ctx context.Context, in *OtherRequest, opts ...grpc.CallOption) (*OtherReply, error)
	// TryRapidUpload tries a hash-based instant upload (SP-H). Miss is a
	// NORMAL outcome (hit=false, no error); "not supported" travels as
	// ErrorProto code NOT_SUPPORT / NOT_IMPLEMENT.
	TryRapidUpload(ctx context.Context, in *TryRapidUploadRequest, opts ...grpc.CallOption) (*TryRapidUploadReply, error)
	// OpenRange server-streams the bytes of a ByteSource==stream Link (9.0 §1).
	OpenRange(ctx context.Context, in *OpenRangeRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Chunk], error)
	// Put is the pull-model upload (9.0 §2): the host serves ReadAt over this bidi
	// stream while the plugin drives the upload. The host sends Init then ReadReply
	// messages; the plugin sends ReadRequest / Progress / Done messages.
	Put(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[PutClient, PutServer], error)
	// InitHost is the host->plugin handshake for the reverse bridge (F0): the
	// host tells the plugin the broker id its HostService is being served on so
	// the plugin can dial back and deliver a working ext.Host to impl.Init.
	InitHost(ctx context.Context, in *InitHostRequest, opts ...grpc.CallOption) (*ErrorReply, error)
}

DriverServiceClient is the client API for DriverService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

DriverService mirrors the ext.StorageDriver interface (9.2). The plugin implements it; the host forwards ext calls over gRPC. A single plugin process serves many storage instances, routed by ObjRef.storage_id (9.0 §3).

func NewDriverServiceClient 

func NewDriverServiceClient(cc grpc.ClientConnInterface) DriverServiceClient

type DriverServiceServer 

type DriverServiceServer interface {
	// GetManifest is the handshake: the manifest (with declared capabilities) and
	// the static driver config. The host builds its capability gate from this.
	GetManifest(context.Context, *Empty) (*ManifestReply, error)
	// Instance lifecycle (9.0 §3): one mounted storage = one instance.
	NewInstance(context.Context, *NewInstanceRequest) (*ErrorReply, error)
	DropInstance(context.Context, *DropInstanceRequest) (*ErrorReply, error)
	// Required ops.
	List(context.Context, *ListRequest) (*ListReply, error)
	Link(context.Context, *LinkRequest) (*LinkReply, error)
	// Optional-capability ops. The plugin returns NOT_IMPLEMENT when the backing
	// driver lacks the capability; the host also gates on declared capabilities.
	Get(context.Context, *GetRequest) (*ObjReply, error)
	MakeDir(context.Context, *MakeDirRequest) (*ObjReply, error)
	Rename(context.Context, *RenameRequest) (*ObjReply, error)
	Move(context.Context, *MoveRequest) (*ObjReply, error)
	Copy(context.Context, *CopyRequest) (*ObjReply, error)
	Remove(context.Context, *RemoveRequest) (*ErrorReply, error)
	Other(context.Context, *OtherRequest) (*OtherReply, error)
	// TryRapidUpload tries a hash-based instant upload (SP-H). Miss is a
	// NORMAL outcome (hit=false, no error); "not supported" travels as
	// ErrorProto code NOT_SUPPORT / NOT_IMPLEMENT.
	TryRapidUpload(context.Context, *TryRapidUploadRequest) (*TryRapidUploadReply, error)
	// OpenRange server-streams the bytes of a ByteSource==stream Link (9.0 §1).
	OpenRange(*OpenRangeRequest, grpc.ServerStreamingServer[Chunk]) error
	// Put is the pull-model upload (9.0 §2): the host serves ReadAt over this bidi
	// stream while the plugin drives the upload. The host sends Init then ReadReply
	// messages; the plugin sends ReadRequest / Progress / Done messages.
	Put(grpc.BidiStreamingServer[PutClient, PutServer]) error
	// InitHost is the host->plugin handshake for the reverse bridge (F0): the
	// host tells the plugin the broker id its HostService is being served on so
	// the plugin can dial back and deliver a working ext.Host to impl.Init.
	InitHost(context.Context, *InitHostRequest) (*ErrorReply, error)
	// contains filtered or unexported methods
}

DriverServiceServer is the server API for DriverService service. All implementations must embed UnimplementedDriverServiceServer for forward compatibility.

DriverService mirrors the ext.StorageDriver interface (9.2). The plugin implements it; the host forwards ext calls over gRPC. A single plugin process serves many storage instances, routed by ObjRef.storage_id (9.0 §3).

type DriverService_OpenRangeClient 

type DriverService_OpenRangeClient = grpc.ServerStreamingClient[Chunk]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type DriverService_OpenRangeServer 

type DriverService_OpenRangeServer = grpc.ServerStreamingServer[Chunk]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type DriverService_PutClient 

type DriverService_PutClient = grpc.BidiStreamingClient[PutClient, PutServer]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type DriverService_PutServer 

type DriverService_PutServer = grpc.BidiStreamingServer[PutClient, PutServer]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type DropInstanceRequest 

type DropInstanceRequest struct {
	StorageId string `protobuf:"bytes,1,opt,name=storage_id,json=storageId,proto3" json:"storage_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DropInstanceRequest) Descriptor deprecated 

func (*DropInstanceRequest) Descriptor() ([]byte, []int)

Deprecated: Use DropInstanceRequest.ProtoReflect.Descriptor instead.

func (*DropInstanceRequest) GetStorageId 

func (x *DropInstanceRequest) GetStorageId() string

func (*DropInstanceRequest) ProtoMessage 

func (*DropInstanceRequest) ProtoMessage()

func (*DropInstanceRequest) ProtoReflect 

func (x *DropInstanceRequest) ProtoReflect() protoreflect.Message

func (*DropInstanceRequest) Reset 

func (x *DropInstanceRequest) Reset()

func (*DropInstanceRequest) String 

func (x *DropInstanceRequest) String() string

type Empty 

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

func (*Empty) Descriptor deprecated 

func (*Empty) Descriptor() ([]byte, []int)

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

func (x *Empty) ProtoReflect() protoreflect.Message

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type ErrorProto 

type ErrorProto struct {
	Code    string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

ErrorProto carries the cross-boundary error code (9.0 §5). An empty code means success; the host maps a non-empty code back to the matching ext sentinel.

func ErrorToProto 

func ErrorToProto(err error) *ErrorProto

ErrorToProto encodes an error as an ErrorProto. A nil error yields nil. An *ext.Error keeps its code; any other error is carried with an empty code and its message.

func (*ErrorProto) Descriptor deprecated 

func (*ErrorProto) Descriptor() ([]byte, []int)

Deprecated: Use ErrorProto.ProtoReflect.Descriptor instead.

func (*ErrorProto) GetCode 

func (x *ErrorProto) GetCode() string

func (*ErrorProto) GetMessage 

func (x *ErrorProto) GetMessage() string

func (*ErrorProto) ProtoMessage 

func (*ErrorProto) ProtoMessage()

func (*ErrorProto) ProtoReflect 

func (x *ErrorProto) ProtoReflect() protoreflect.Message

func (*ErrorProto) Reset 

func (x *ErrorProto) Reset()

func (*ErrorProto) String 

func (x *ErrorProto) String() string

type ErrorReply 

type ErrorReply struct {
	Error *ErrorProto `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ErrorReply) Descriptor deprecated 

func (*ErrorReply) Descriptor() ([]byte, []int)

Deprecated: Use ErrorReply.ProtoReflect.Descriptor instead.

func (*ErrorReply) GetError 

func (x *ErrorReply) GetError() *ErrorProto

func (*ErrorReply) ProtoMessage 

func (*ErrorReply) ProtoMessage()

func (*ErrorReply) ProtoReflect 

func (x *ErrorReply) ProtoReflect() protoreflect.Message

func (*ErrorReply) Reset 

func (x *ErrorReply) Reset()

func (*ErrorReply) String 

func (x *ErrorReply) String() string

type EventHookServiceClient 

type EventHookServiceClient interface {
	// GetManifest is the handshake: the manifest the host validates the plugin
	// against before dispatching events to it.
	GetManifest(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ManifestReply, error)
	// OnEvent delivers one host event (ext.EventHook.OnEvent). The host runs
	// this under panic + error isolation on its side (internal/extension);
	// OnEvent's own error, if any, crosses back as ErrorReply so the host can
	// log it — it is never treated as a veto of the already-committed
	// operation.
	OnEvent(ctx context.Context, in *EventProto, opts ...grpc.CallOption) (*ErrorReply, error)
	// Reverse host bridge (F0/SP6): host serves a HostService on the broker id it
	// passes here; the plugin dials it and delivers the host to Init.
	InitHost(ctx context.Context, in *InitHostRequest, opts ...grpc.CallOption) (*ErrorReply, error)
}

EventHookServiceClient is the client API for EventHookService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

EventHookService mirrors ext.EventHook (W7): a Kind=EventHook plugin observes host events (fs mutations) after they commit — a notification sink, not a veto (see ext.EventHook's doc comment). Mirrors APIRouteService (apiroute.proto) one Kind over, including the reverse-host InitHost bridge (F0/SP6).

func NewEventHookServiceClient 

func NewEventHookServiceClient(cc grpc.ClientConnInterface) EventHookServiceClient

type EventHookServiceServer 

type EventHookServiceServer interface {
	// GetManifest is the handshake: the manifest the host validates the plugin
	// against before dispatching events to it.
	GetManifest(context.Context, *Empty) (*ManifestReply, error)
	// OnEvent delivers one host event (ext.EventHook.OnEvent). The host runs
	// this under panic + error isolation on its side (internal/extension);
	// OnEvent's own error, if any, crosses back as ErrorReply so the host can
	// log it — it is never treated as a veto of the already-committed
	// operation.
	OnEvent(context.Context, *EventProto) (*ErrorReply, error)
	// Reverse host bridge (F0/SP6): host serves a HostService on the broker id it
	// passes here; the plugin dials it and delivers the host to Init.
	InitHost(context.Context, *InitHostRequest) (*ErrorReply, error)
	// contains filtered or unexported methods
}

EventHookServiceServer is the server API for EventHookService service. All implementations must embed UnimplementedEventHookServiceServer for forward compatibility.

EventHookService mirrors ext.EventHook (W7): a Kind=EventHook plugin observes host events (fs mutations) after they commit — a notification sink, not a veto (see ext.EventHook's doc comment). Mirrors APIRouteService (apiroute.proto) one Kind over, including the reverse-host InitHost bridge (F0/SP6).

type EventProto 

type EventProto struct {
	Type      string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	UnixMilli int64  `protobuf:"varint,2,opt,name=unix_milli,json=unixMilli,proto3" json:"unix_milli,omitempty"`
	Path      string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	DstPath   string `protobuf:"bytes,4,opt,name=dst_path,json=dstPath,proto3" json:"dst_path,omitempty"`
	Actor     string `protobuf:"bytes,5,opt,name=actor,proto3" json:"actor,omitempty"`
	// contains filtered or unexported fields
}

EventProto mirrors ext.Event field-for-field (type/unix_milli/path/dst_path/ actor) — the wire encoding of the notification payload OnEvent receives.

func (*EventProto) Descriptor deprecated 

func (*EventProto) Descriptor() ([]byte, []int)

Deprecated: Use EventProto.ProtoReflect.Descriptor instead.

func (*EventProto) GetActor 

func (x *EventProto) GetActor() string

func (*EventProto) GetDstPath 

func (x *EventProto) GetDstPath() string

func (*EventProto) GetPath 

func (x *EventProto) GetPath() string

func (*EventProto) GetType 

func (x *EventProto) GetType() string

func (*EventProto) GetUnixMilli 

func (x *EventProto) GetUnixMilli() int64

func (*EventProto) ProtoMessage 

func (*EventProto) ProtoMessage()

func (*EventProto) ProtoReflect 

func (x *EventProto) ProtoReflect() protoreflect.Message

func (*EventProto) Reset 

func (x *EventProto) Reset()

func (*EventProto) String 

func (x *EventProto) String() string

type ExchangeRequest 

type ExchangeRequest struct {
	Code        string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	RedirectUri string `protobuf:"bytes,2,opt,name=redirect_uri,json=redirectUri,proto3" json:"redirect_uri,omitempty"`
	// contains filtered or unexported fields
}

func (*ExchangeRequest) Descriptor deprecated 

func (*ExchangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExchangeRequest.ProtoReflect.Descriptor instead.

func (*ExchangeRequest) GetCode 

func (x *ExchangeRequest) GetCode() string

func (*ExchangeRequest) GetRedirectUri 

func (x *ExchangeRequest) GetRedirectUri() string

func (*ExchangeRequest) ProtoMessage 

func (*ExchangeRequest) ProtoMessage()

func (*ExchangeRequest) ProtoReflect 

func (x *ExchangeRequest) ProtoReflect() protoreflect.Message

func (*ExchangeRequest) Reset 

func (x *ExchangeRequest) Reset()

func (*ExchangeRequest) String 

func (x *ExchangeRequest) String() string

type ExerciseReply 

type ExerciseReply struct {
	Result string      `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	Error  *ErrorProto `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ExerciseReply) Descriptor deprecated 

func (*ExerciseReply) Descriptor() ([]byte, []int)

Deprecated: Use ExerciseReply.ProtoReflect.Descriptor instead.

func (*ExerciseReply) GetError 

func (x *ExerciseReply) GetError() *ErrorProto

func (*ExerciseReply) GetResult 

func (x *ExerciseReply) GetResult() string

func (*ExerciseReply) ProtoMessage 

func (*ExerciseReply) ProtoMessage()

func (*ExerciseReply) ProtoReflect 

func (x *ExerciseReply) ProtoReflect() protoreflect.Message

func (*ExerciseReply) Reset 

func (x *ExerciseReply) Reset()

func (*ExerciseReply) String 

func (x *ExerciseReply) String() string

type ExerciseRequest 

type ExerciseRequest struct {
	HostBrokerId uint32 `protobuf:"varint,1,opt,name=host_broker_id,json=hostBrokerId,proto3" json:"host_broker_id,omitempty"` // Dial this broker id to reach HostService
	Op           string `protobuf:"bytes,2,opt,name=op,proto3" json:"op,omitempty"`                                            // e.g. "fs.list", "fs.mkdir", "store.set", "http.get"
	Arg          string `protobuf:"bytes,3,opt,name=arg,proto3" json:"arg,omitempty"`
	Arg2         string `protobuf:"bytes,4,opt,name=arg2,proto3" json:"arg2,omitempty"`
	// contains filtered or unexported fields
}

func (*ExerciseRequest) Descriptor deprecated 

func (*ExerciseRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExerciseRequest.ProtoReflect.Descriptor instead.

func (*ExerciseRequest) GetArg 

func (x *ExerciseRequest) GetArg() string

func (*ExerciseRequest) GetArg2 

func (x *ExerciseRequest) GetArg2() string

func (*ExerciseRequest) GetHostBrokerId 

func (x *ExerciseRequest) GetHostBrokerId() uint32

func (*ExerciseRequest) GetOp 

func (x *ExerciseRequest) GetOp() string

func (*ExerciseRequest) ProtoMessage 

func (*ExerciseRequest) ProtoMessage()

func (*ExerciseRequest) ProtoReflect 

func (x *ExerciseRequest) ProtoReflect() protoreflect.Message

func (*ExerciseRequest) Reset 

func (x *ExerciseRequest) Reset()

func (*ExerciseRequest) String 

func (x *ExerciseRequest) String() string

type FSCopyRequest 

type FSCopyRequest struct {
	Principal string  `protobuf:"bytes,1,opt,name=principal,proto3" json:"principal,omitempty"`
	Src       *ObjRef `protobuf:"bytes,2,opt,name=src,proto3" json:"src,omitempty"`
	DstDir    *ObjRef `protobuf:"bytes,3,opt,name=dst_dir,json=dstDir,proto3" json:"dst_dir,omitempty"`
	// contains filtered or unexported fields
}

func (*FSCopyRequest) Descriptor deprecated 

func (*FSCopyRequest) Descriptor() ([]byte, []int)

Deprecated: Use FSCopyRequest.ProtoReflect.Descriptor instead.

func (*FSCopyRequest) GetDstDir 

func (x *FSCopyRequest) GetDstDir() *ObjRef

func (*FSCopyRequest) GetPrincipal 

func (x *FSCopyRequest) GetPrincipal() string

func (*FSCopyRequest) GetSrc 

func (x *FSCopyRequest) GetSrc() *ObjRef

func (*FSCopyRequest) ProtoMessage 

func (*FSCopyRequest) ProtoMessage()

func (*FSCopyRequest) ProtoReflect 

func (x *FSCopyRequest) ProtoReflect() protoreflect.Message

func (*FSCopyRequest) Reset 

func (x *FSCopyRequest) Reset()

func (*FSCopyRequest) String 

func (x *FSCopyRequest) String() string

type FSGetRequest 

type FSGetRequest struct {
	Principal string  `protobuf:"bytes,1,opt,name=principal,proto3" json:"principal,omitempty"`
	Ref       *ObjRef `protobuf:"bytes,2,opt,name=ref,proto3" json:"ref,omitempty"`
	// contains filtered or unexported fields
}

func (*FSGetRequest) Descriptor deprecated 

func (*FSGetRequest) Descriptor() ([]byte, []int)

Deprecated: Use FSGetRequest.ProtoReflect.Descriptor instead.

func (*FSGetRequest) GetPrincipal 

func (x *FSGetRequest) GetPrincipal() string

func (*FSGetRequest) GetRef 

func (x *FSGetRequest) GetRef() *ObjRef

func (*FSGetRequest) ProtoMessage 

func (*FSGetRequest) ProtoMessage()

func (*FSGetRequest) ProtoReflect 

func (x *FSGetRequest) ProtoReflect() protoreflect.Message

func (*FSGetRequest) Reset 

func (x *FSGetRequest) Reset()

func (*FSGetRequest) String 

func (x *FSGetRequest) String() string

type FSLinkRequest 

type FSLinkRequest struct {
	Principal string    `protobuf:"bytes,1,opt,name=principal,proto3" json:"principal,omitempty"`
	Ref       *ObjRef   `protobuf:"bytes,2,opt,name=ref,proto3" json:"ref,omitempty"`
	Args      *LinkArgs `protobuf:"bytes,3,opt,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

func (*FSLinkRequest) Descriptor deprecated 

func (*FSLinkRequest) Descriptor() ([]byte, []int)

Deprecated: Use FSLinkRequest.ProtoReflect.Descriptor instead.

func (*FSLinkRequest) GetArgs 

func (x *FSLinkRequest) GetArgs() *LinkArgs

func (*FSLinkRequest) GetPrincipal 

func (x *FSLinkRequest) GetPrincipal() string

func (*FSLinkRequest) GetRef 

func (x *FSLinkRequest) GetRef() *ObjRef

func (*FSLinkRequest) ProtoMessage 

func (*FSLinkRequest) ProtoMessage()

func (*FSLinkRequest) ProtoReflect 

func (x *FSLinkRequest) ProtoReflect() protoreflect.Message

func (*FSLinkRequest) Reset 

func (x *FSLinkRequest) Reset()

func (*FSLinkRequest) String 

func (x *FSLinkRequest) String() string

type FSListRequest 

type FSListRequest struct {
	Principal string    `protobuf:"bytes,1,opt,name=principal,proto3" json:"principal,omitempty"`
	Dir       *ObjRef   `protobuf:"bytes,2,opt,name=dir,proto3" json:"dir,omitempty"`
	Args      *ListArgs `protobuf:"bytes,3,opt,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

func (*FSListRequest) Descriptor deprecated 

func (*FSListRequest) Descriptor() ([]byte, []int)

Deprecated: Use FSListRequest.ProtoReflect.Descriptor instead.

func (*FSListRequest) GetArgs 

func (x *FSListRequest) GetArgs() *ListArgs

func (*FSListRequest) GetDir 

func (x *FSListRequest) GetDir() *ObjRef

func (*FSListRequest) GetPrincipal 

func (x *FSListRequest) GetPrincipal() string

func (*FSListRequest) ProtoMessage 

func (*FSListRequest) ProtoMessage()

func (*FSListRequest) ProtoReflect 

func (x *FSListRequest) ProtoReflect() protoreflect.Message

func (*FSListRequest) Reset 

func (x *FSListRequest) Reset()

func (*FSListRequest) String 

func (x *FSListRequest) String() string

type FSMkdirRequest 

type FSMkdirRequest struct {
	Principal string  `protobuf:"bytes,1,opt,name=principal,proto3" json:"principal,omitempty"`
	Parent    *ObjRef `protobuf:"bytes,2,opt,name=parent,proto3" json:"parent,omitempty"`
	Name      string  `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*FSMkdirRequest) Descriptor deprecated 

func (*FSMkdirRequest) Descriptor() ([]byte, []int)

Deprecated: Use FSMkdirRequest.ProtoReflect.Descriptor instead.

func (*FSMkdirRequest) GetName 

func (x *FSMkdirRequest) GetName() string

func (*FSMkdirRequest) GetParent 

func (x *FSMkdirRequest) GetParent() *ObjRef

func (*FSMkdirRequest) GetPrincipal 

func (x *FSMkdirRequest) GetPrincipal() string

func (*FSMkdirRequest) ProtoMessage 

func (*FSMkdirRequest) ProtoMessage()

func (*FSMkdirRequest) ProtoReflect 

func (x *FSMkdirRequest) ProtoReflect() protoreflect.Message

func (*FSMkdirRequest) Reset 

func (x *FSMkdirRequest) Reset()

func (*FSMkdirRequest) String 

func (x *FSMkdirRequest) String() string

type FSMoveRequest 

type FSMoveRequest struct {
	Principal string  `protobuf:"bytes,1,opt,name=principal,proto3" json:"principal,omitempty"`
	Src       *ObjRef `protobuf:"bytes,2,opt,name=src,proto3" json:"src,omitempty"`
	DstDir    *ObjRef `protobuf:"bytes,3,opt,name=dst_dir,json=dstDir,proto3" json:"dst_dir,omitempty"`
	// contains filtered or unexported fields
}

func (*FSMoveRequest) Descriptor deprecated 

func (*FSMoveRequest) Descriptor() ([]byte, []int)

Deprecated: Use FSMoveRequest.ProtoReflect.Descriptor instead.

func (*FSMoveRequest) GetDstDir 

func (x *FSMoveRequest) GetDstDir() *ObjRef

func (*FSMoveRequest) GetPrincipal 

func (x *FSMoveRequest) GetPrincipal() string

func (*FSMoveRequest) GetSrc 

func (x *FSMoveRequest) GetSrc() *ObjRef

func (*FSMoveRequest) ProtoMessage 

func (*FSMoveRequest) ProtoMessage()

func (*FSMoveRequest) ProtoReflect 

func (x *FSMoveRequest) ProtoReflect() protoreflect.Message

func (*FSMoveRequest) Reset 

func (x *FSMoveRequest) Reset()

func (*FSMoveRequest) String 

func (x *FSMoveRequest) String() string

type FSPutClient 

type FSPutClient struct {

	// Types that are valid to be assigned to Msg:
	//
	//	*FSPutClient_Init
	//	*FSPutClient_Chunk
	Msg isFSPutClient_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

FSPutClient: plugin -> host messages on the FSPut client-streaming call.

func (*FSPutClient) Descriptor deprecated 

func (*FSPutClient) Descriptor() ([]byte, []int)

Deprecated: Use FSPutClient.ProtoReflect.Descriptor instead.

func (*FSPutClient) GetChunk 

func (x *FSPutClient) GetChunk() *Chunk

func (*FSPutClient) GetInit 

func (x *FSPutClient) GetInit() *FSPutInit

func (*FSPutClient) GetMsg 

func (x *FSPutClient) GetMsg() isFSPutClient_Msg

func (*FSPutClient) ProtoMessage 

func (*FSPutClient) ProtoMessage()

func (*FSPutClient) ProtoReflect 

func (x *FSPutClient) ProtoReflect() protoreflect.Message

func (*FSPutClient) Reset 

func (x *FSPutClient) Reset()

func (*FSPutClient) String 

func (x *FSPutClient) String() string

type FSPutClient_Chunk 

type FSPutClient_Chunk struct {
	Chunk *Chunk `protobuf:"bytes,2,opt,name=chunk,proto3,oneof"`
}

type FSPutClient_Init 

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

type FSPutInit 

type FSPutInit struct {
	Principal string      `protobuf:"bytes,1,opt,name=principal,proto3" json:"principal,omitempty"`
	DstDir    *ObjRef     `protobuf:"bytes,2,opt,name=dst_dir,json=dstDir,proto3" json:"dst_dir,omitempty"`
	Info      *UploadInfo `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*FSPutInit) Descriptor deprecated 

func (*FSPutInit) Descriptor() ([]byte, []int)

Deprecated: Use FSPutInit.ProtoReflect.Descriptor instead.

func (*FSPutInit) GetDstDir 

func (x *FSPutInit) GetDstDir() *ObjRef

func (*FSPutInit) GetInfo 

func (x *FSPutInit) GetInfo() *UploadInfo

func (*FSPutInit) GetPrincipal 

func (x *FSPutInit) GetPrincipal() string

func (*FSPutInit) ProtoMessage 

func (*FSPutInit) ProtoMessage()

func (*FSPutInit) ProtoReflect 

func (x *FSPutInit) ProtoReflect() protoreflect.Message

func (*FSPutInit) Reset 

func (x *FSPutInit) Reset()

func (*FSPutInit) String 

func (x *FSPutInit) String() string

type FSPutReply 

type FSPutReply struct {
	Obj   *Obj        `protobuf:"bytes,1,opt,name=obj,proto3" json:"obj,omitempty"`
	Error *ErrorProto `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*FSPutReply) Descriptor deprecated 

func (*FSPutReply) Descriptor() ([]byte, []int)

Deprecated: Use FSPutReply.ProtoReflect.Descriptor instead.

func (*FSPutReply) GetError 

func (x *FSPutReply) GetError() *ErrorProto

func (*FSPutReply) GetObj 

func (x *FSPutReply) GetObj() *Obj

func (*FSPutReply) ProtoMessage 

func (*FSPutReply) ProtoMessage()

func (*FSPutReply) ProtoReflect 

func (x *FSPutReply) ProtoReflect() protoreflect.Message

func (*FSPutReply) Reset 

func (x *FSPutReply) Reset()

func (*FSPutReply) String 

func (x *FSPutReply) String() string

type FSRemoveRequest 

type FSRemoveRequest struct {
	Principal string  `protobuf:"bytes,1,opt,name=principal,proto3" json:"principal,omitempty"`
	Ref       *ObjRef `protobuf:"bytes,2,opt,name=ref,proto3" json:"ref,omitempty"`
	// contains filtered or unexported fields
}

func (*FSRemoveRequest) Descriptor deprecated 

func (*FSRemoveRequest) Descriptor() ([]byte, []int)

Deprecated: Use FSRemoveRequest.ProtoReflect.Descriptor instead.

func (*FSRemoveRequest) GetPrincipal 

func (x *FSRemoveRequest) GetPrincipal() string

func (*FSRemoveRequest) GetRef 

func (x *FSRemoveRequest) GetRef() *ObjRef

func (*FSRemoveRequest) ProtoMessage 

func (*FSRemoveRequest) ProtoMessage()

func (*FSRemoveRequest) ProtoReflect 

func (x *FSRemoveRequest) ProtoReflect() protoreflect.Message

func (*FSRemoveRequest) Reset 

func (x *FSRemoveRequest) Reset()

func (*FSRemoveRequest) String 

func (x *FSRemoveRequest) String() string

type FSRenameRequest 

type FSRenameRequest struct {
	Principal string  `protobuf:"bytes,1,opt,name=principal,proto3" json:"principal,omitempty"`
	Src       *ObjRef `protobuf:"bytes,2,opt,name=src,proto3" json:"src,omitempty"`
	NewName   string  `protobuf:"bytes,3,opt,name=new_name,json=newName,proto3" json:"new_name,omitempty"`
	// contains filtered or unexported fields
}

func (*FSRenameRequest) Descriptor deprecated 

func (*FSRenameRequest) Descriptor() ([]byte, []int)

Deprecated: Use FSRenameRequest.ProtoReflect.Descriptor instead.

func (*FSRenameRequest) GetNewName 

func (x *FSRenameRequest) GetNewName() string

func (*FSRenameRequest) GetPrincipal 

func (x *FSRenameRequest) GetPrincipal() string

func (*FSRenameRequest) GetSrc 

func (x *FSRenameRequest) GetSrc() *ObjRef

func (*FSRenameRequest) ProtoMessage 

func (*FSRenameRequest) ProtoMessage()

func (*FSRenameRequest) ProtoReflect 

func (x *FSRenameRequest) ProtoReflect() protoreflect.Message

func (*FSRenameRequest) Reset 

func (x *FSRenameRequest) Reset()

func (*FSRenameRequest) String 

func (x *FSRenameRequest) String() string

type FSResolveReply 

type FSResolveReply struct {
	Ref   *ObjRef     `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	Error *ErrorProto `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*FSResolveReply) Descriptor deprecated 

func (*FSResolveReply) Descriptor() ([]byte, []int)

Deprecated: Use FSResolveReply.ProtoReflect.Descriptor instead.

func (*FSResolveReply) GetError 

func (x *FSResolveReply) GetError() *ErrorProto

func (*FSResolveReply) GetRef 

func (x *FSResolveReply) GetRef() *ObjRef

func (*FSResolveReply) ProtoMessage 

func (*FSResolveReply) ProtoMessage()

func (*FSResolveReply) ProtoReflect 

func (x *FSResolveReply) ProtoReflect() protoreflect.Message

func (*FSResolveReply) Reset 

func (x *FSResolveReply) Reset()

func (*FSResolveReply) String 

func (x *FSResolveReply) String() string

type FSResolveRequest 

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

func (*FSResolveRequest) Descriptor deprecated 

func (*FSResolveRequest) Descriptor() ([]byte, []int)

Deprecated: Use FSResolveRequest.ProtoReflect.Descriptor instead.

func (*FSResolveRequest) GetPath 

func (x *FSResolveRequest) GetPath() string

func (*FSResolveRequest) GetPrincipal 

func (x *FSResolveRequest) GetPrincipal() string

func (*FSResolveRequest) ProtoMessage 

func (*FSResolveRequest) ProtoMessage()

func (*FSResolveRequest) ProtoReflect 

func (x *FSResolveRequest) ProtoReflect() protoreflect.Message

func (*FSResolveRequest) Reset 

func (x *FSResolveRequest) Reset()

func (*FSResolveRequest) String 

func (x *FSResolveRequest) String() string

type FileDecoratorServiceClient 

type FileDecoratorServiceClient interface {
	// GetManifest is the handshake: the manifest the host validates the
	// declared FileColumns against, and the source of the client-side Groups().
	GetManifest(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ManifestReply, error)
	// Decorate computes one field group over a batch of refs
	// (ext.FileDecorator.Decorate). values_json is the returned map[string]any
	// (RefKey -> field value) marshaled as JSON — the value shape is opaque to
	// the host, so JSON is the wire encoding rather than a typed message
	// (mirrors Action's args_json/result_json).
	Decorate(ctx context.Context, in *DecorateRequest, opts ...grpc.CallOption) (*DecorateReply, error)
	// Reverse host bridge (F0/SP6): host serves a HostService on the broker id it
	// passes here; the plugin dials it and delivers the host to Init.
	InitHost(ctx context.Context, in *InitHostRequest, opts ...grpc.CallOption) (*ErrorReply, error)
}

FileDecoratorServiceClient is the client API for FileDecoratorService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

FileDecoratorService mirrors ext.FileDecorator (design §2.6, W9a): supplies the extension field group(s) behind a FileColumn contribution (label badges, share markers). Mirrors EventHookService (eventhook.proto) one Kind over, including the reverse-host InitHost bridge (F0/SP6).

There is no separate "Groups" RPC: the groups a decorator provides are the FieldGroup values it declared in its own manifest's Contributions.FileColumns (already carried by GetManifest), so the host-side client derives ext.FileDecorator.Groups() from the manifest it already loaded rather than a second round trip.

func NewFileDecoratorServiceClient 

func NewFileDecoratorServiceClient(cc grpc.ClientConnInterface) FileDecoratorServiceClient

type FileDecoratorServiceServer 

type FileDecoratorServiceServer interface {
	// GetManifest is the handshake: the manifest the host validates the
	// declared FileColumns against, and the source of the client-side Groups().
	GetManifest(context.Context, *Empty) (*ManifestReply, error)
	// Decorate computes one field group over a batch of refs
	// (ext.FileDecorator.Decorate). values_json is the returned map[string]any
	// (RefKey -> field value) marshaled as JSON — the value shape is opaque to
	// the host, so JSON is the wire encoding rather than a typed message
	// (mirrors Action's args_json/result_json).
	Decorate(context.Context, *DecorateRequest) (*DecorateReply, error)
	// Reverse host bridge (F0/SP6): host serves a HostService on the broker id it
	// passes here; the plugin dials it and delivers the host to Init.
	InitHost(context.Context, *InitHostRequest) (*ErrorReply, error)
	// contains filtered or unexported methods
}

FileDecoratorServiceServer is the server API for FileDecoratorService service. All implementations must embed UnimplementedFileDecoratorServiceServer for forward compatibility.

FileDecoratorService mirrors ext.FileDecorator (design §2.6, W9a): supplies the extension field group(s) behind a FileColumn contribution (label badges, share markers). Mirrors EventHookService (eventhook.proto) one Kind over, including the reverse-host InitHost bridge (F0/SP6).

There is no separate "Groups" RPC: the groups a decorator provides are the FieldGroup values it declared in its own manifest's Contributions.FileColumns (already carried by GetManifest), so the host-side client derives ext.FileDecorator.Groups() from the manifest it already loaded rather than a second round trip.

type FinishReply 

type FinishReply struct {
	Result *AuthNResultProto `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	Error  *ErrorProto       `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*FinishReply) Descriptor deprecated 

func (*FinishReply) Descriptor() ([]byte, []int)

Deprecated: Use FinishReply.ProtoReflect.Descriptor instead.

func (*FinishReply) GetError 

func (x *FinishReply) GetError() *ErrorProto

func (*FinishReply) GetResult 

func (x *FinishReply) GetResult() *AuthNResultProto

func (*FinishReply) ProtoMessage 

func (*FinishReply) ProtoMessage()

func (*FinishReply) ProtoReflect 

func (x *FinishReply) ProtoReflect() protoreflect.Message

func (*FinishReply) Reset 

func (x *FinishReply) Reset()

func (*FinishReply) String 

func (x *FinishReply) String() string

type FinishRequest 

type FinishRequest struct {
	ChallengeId string            `protobuf:"bytes,1,opt,name=challenge_id,json=challengeId,proto3" json:"challenge_id,omitempty"`
	Params      map[string]string `` /* 139-byte string literal not displayed */
	Data        []byte            `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func AuthNResponseToProto 

func AuthNResponseToProto(req ext.AuthNResponse) *FinishRequest

func (*FinishRequest) Descriptor deprecated 

func (*FinishRequest) Descriptor() ([]byte, []int)

Deprecated: Use FinishRequest.ProtoReflect.Descriptor instead.

func (*FinishRequest) GetChallengeId 

func (x *FinishRequest) GetChallengeId() string

func (*FinishRequest) GetData 

func (x *FinishRequest) GetData() []byte

func (*FinishRequest) GetParams 

func (x *FinishRequest) GetParams() map[string]string

func (*FinishRequest) ProtoMessage 

func (*FinishRequest) ProtoMessage()

func (*FinishRequest) ProtoReflect 

func (x *FinishRequest) ProtoReflect() protoreflect.Message

func (*FinishRequest) Reset 

func (x *FinishRequest) Reset()

func (*FinishRequest) String 

func (x *FinishRequest) String() string

type GetRequest 

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

func (*GetRequest) Descriptor deprecated 

func (*GetRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetPath 

func (x *GetRequest) GetPath() string

func (*GetRequest) GetStorageId 

func (x *GetRequest) GetStorageId() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

func (x *GetRequest) ProtoReflect() protoreflect.Message

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type HTTPDoReply 

type HTTPDoReply struct {
	Status int32                   `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Header map[string]*HeaderValue `` /* 139-byte string literal not displayed */
	Body   []byte                  `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	Error  *ErrorProto             `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*HTTPDoReply) Descriptor deprecated 

func (*HTTPDoReply) Descriptor() ([]byte, []int)

Deprecated: Use HTTPDoReply.ProtoReflect.Descriptor instead.

func (*HTTPDoReply) GetBody 

func (x *HTTPDoReply) GetBody() []byte

func (*HTTPDoReply) GetError 

func (x *HTTPDoReply) GetError() *ErrorProto

func (*HTTPDoReply) GetHeader 

func (x *HTTPDoReply) GetHeader() map[string]*HeaderValue

func (*HTTPDoReply) GetStatus 

func (x *HTTPDoReply) GetStatus() int32

func (*HTTPDoReply) ProtoMessage 

func (*HTTPDoReply) ProtoMessage()

func (*HTTPDoReply) ProtoReflect 

func (x *HTTPDoReply) ProtoReflect() protoreflect.Message

func (*HTTPDoReply) Reset 

func (x *HTTPDoReply) Reset()

func (*HTTPDoReply) String 

func (x *HTTPDoReply) String() string

type HTTPDoRequest 

type HTTPDoRequest struct {
	Method string                  `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Url    string                  `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Header map[string]*HeaderValue `` /* 139-byte string literal not displayed */
	Body   []byte                  `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*HTTPDoRequest) Descriptor deprecated 

func (*HTTPDoRequest) Descriptor() ([]byte, []int)

Deprecated: Use HTTPDoRequest.ProtoReflect.Descriptor instead.

func (*HTTPDoRequest) GetBody 

func (x *HTTPDoRequest) GetBody() []byte

func (*HTTPDoRequest) GetHeader 

func (x *HTTPDoRequest) GetHeader() map[string]*HeaderValue

func (*HTTPDoRequest) GetMethod 

func (x *HTTPDoRequest) GetMethod() string

func (*HTTPDoRequest) GetUrl 

func (x *HTTPDoRequest) GetUrl() string

func (*HTTPDoRequest) ProtoMessage 

func (*HTTPDoRequest) ProtoMessage()

func (*HTTPDoRequest) ProtoReflect 

func (x *HTTPDoRequest) ProtoReflect() protoreflect.Message

func (*HTTPDoRequest) Reset 

func (x *HTTPDoRequest) Reset()

func (*HTTPDoRequest) String 

func (x *HTTPDoRequest) String() string

type HeaderValue 

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

Header is a repeatable HTTP header field (http.Header is a multimap).

func (*HeaderValue) Descriptor deprecated 

func (*HeaderValue) Descriptor() ([]byte, []int)

Deprecated: Use HeaderValue.ProtoReflect.Descriptor instead.

func (*HeaderValue) GetValues 

func (x *HeaderValue) GetValues() []string

func (*HeaderValue) ProtoMessage 

func (*HeaderValue) ProtoMessage()

func (*HeaderValue) ProtoReflect 

func (x *HeaderValue) ProtoReflect() protoreflect.Message

func (*HeaderValue) Reset 

func (x *HeaderValue) Reset()

func (*HeaderValue) String 

func (x *HeaderValue) String() string

type HostCapProbeServiceClient 

type HostCapProbeServiceClient interface {
	GetManifest(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ManifestReply, error)
	Exercise(ctx context.Context, in *ExerciseRequest, opts ...grpc.CallOption) (*ExerciseReply, error)
}

HostCapProbeServiceClient is the client API for HostCapProbeService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

HostCapProbeService is the F0 integration fixture: a PLUGIN-served service whose only job is to exercise each borrowed Host capability over the reverse bridge and report the outcome, so a real subprocess drives HostService end to end. Exercise receives the host_broker_id to Dial back for HostService.

func NewHostCapProbeServiceClient 

func NewHostCapProbeServiceClient(cc grpc.ClientConnInterface) HostCapProbeServiceClient

type HostCapProbeServiceServer 

type HostCapProbeServiceServer interface {
	GetManifest(context.Context, *Empty) (*ManifestReply, error)
	Exercise(context.Context, *ExerciseRequest) (*ExerciseReply, error)
	// contains filtered or unexported methods
}

HostCapProbeServiceServer is the server API for HostCapProbeService service. All implementations must embed UnimplementedHostCapProbeServiceServer for forward compatibility.

HostCapProbeService is the F0 integration fixture: a PLUGIN-served service whose only job is to exercise each borrowed Host capability over the reverse bridge and report the outcome, so a real subprocess drives HostService end to end. Exercise receives the host_broker_id to Dial back for HostService.

type HostServiceClient 

type HostServiceClient interface {
	// --- FS: every op runs core Authorize against the acting principal ---
	FSResolve(ctx context.Context, in *FSResolveRequest, opts ...grpc.CallOption) (*FSResolveReply, error)
	FSList(ctx context.Context, in *FSListRequest, opts ...grpc.CallOption) (*ListReply, error)
	FSGet(ctx context.Context, in *FSGetRequest, opts ...grpc.CallOption) (*ObjReply, error)
	FSLink(ctx context.Context, in *FSLinkRequest, opts ...grpc.CallOption) (*LinkReply, error)
	FSMkdir(ctx context.Context, in *FSMkdirRequest, opts ...grpc.CallOption) (*ObjReply, error)
	FSMove(ctx context.Context, in *FSMoveRequest, opts ...grpc.CallOption) (*ErrorReply, error)
	FSRename(ctx context.Context, in *FSRenameRequest, opts ...grpc.CallOption) (*ErrorReply, error)
	FSCopy(ctx context.Context, in *FSCopyRequest, opts ...grpc.CallOption) (*ErrorReply, error)
	FSRemove(ctx context.Context, in *FSRemoveRequest, opts ...grpc.CallOption) (*ErrorReply, error)
	// --- Store: KV namespaced by the caller plugin's id (server-side) ---
	StoreGet(ctx context.Context, in *StoreGetRequest, opts ...grpc.CallOption) (*StoreGetReply, error)
	StoreSet(ctx context.Context, in *StoreSetRequest, opts ...grpc.CallOption) (*ErrorReply, error)
	StoreDelete(ctx context.Context, in *StoreDeleteRequest, opts ...grpc.CallOption) (*ErrorReply, error)
	StoreList(ctx context.Context, in *StoreListRequest, opts ...grpc.CallOption) (*StoreListReply, error)
	// --- Secrets: same shape/namespacing as Store, but the host encrypts
	// values at rest (AES-256-GCM) before they touch disk. Mirrors StoreGet/
	// StoreSet/StoreDelete/StoreList exactly; only the message names differ. ---
	SecretGet(ctx context.Context, in *SecretGetRequest, opts ...grpc.CallOption) (*SecretGetReply, error)
	SecretSet(ctx context.Context, in *SecretSetRequest, opts ...grpc.CallOption) (*ErrorReply, error)
	SecretDelete(ctx context.Context, in *SecretDeleteRequest, opts ...grpc.CallOption) (*ErrorReply, error)
	SecretList(ctx context.Context, in *SecretListRequest, opts ...grpc.CallOption) (*SecretListReply, error)
	// --- Table: per-plugin schemaless document tables (JSON rows, PK-addressed)
	// over the SAME backend as Store — a structured view over KV's storage
	// extent (unlike Secrets, which is fully disjoint). Namespaced by plugin id
	// (server-side) and by table name (a "table:<name>:" key prefix); gated by
	// the same CapStore capability as Store/Secrets. ---
	TableInsert(ctx context.Context, in *TableInsertRequest, opts ...grpc.CallOption) (*TableInsertReply, error)
	TableGet(ctx context.Context, in *TableGetRequest, opts ...grpc.CallOption) (*TableGetReply, error)
	TableUpdate(ctx context.Context, in *TableUpdateRequest, opts ...grpc.CallOption) (*ErrorReply, error)
	TableDelete(ctx context.Context, in *TableDeleteRequest, opts ...grpc.CallOption) (*ErrorReply, error)
	TableList(ctx context.Context, in *TableListRequest, opts ...grpc.CallOption) (*TableListReply, error)
	// --- HTTP: outbound gated by global allowlist ∩ Grant.Network ---
	HTTPDo(ctx context.Context, in *HTTPDoRequest, opts ...grpc.CallOption) (*HTTPDoReply, error)
	// LoadConfig returns the calling plugin's persisted config_form value JSON
	// (server-side bound to the plugin this HostService instance was built for).
	LoadConfig(ctx context.Context, in *LoadConfigRequest, opts ...grpc.CallOption) (*LoadConfigReply, error)
	// SaveConfig persists the calling plugin's own config_form value JSON
	// (server-side bound to the plugin this HostService instance was built for).
	// Mirrors LoadConfig's leg exactly, in the write direction.
	SaveConfig(ctx context.Context, in *SaveConfigRequest, opts ...grpc.CallOption) (*SaveConfigReply, error)
	// Capabilities returns the names of the Host APIs the calling plugin was
	// granted (introspection over its own Grant.HostAPIs) — server-side bound,
	// never a wire input.
	Capabilities(ctx context.Context, in *CapabilitiesRequest, opts ...grpc.CallOption) (*CapabilitiesReply, error)
	// --- Auth: credential/token -> Principal (gated by CapAuth) ---
	AuthLogin(ctx context.Context, in *AuthLoginRequest, opts ...grpc.CallOption) (*PrincipalReply, error)
	AuthVerifyToken(ctx context.Context, in *AuthVerifyTokenRequest, opts ...grpc.CallOption) (*PrincipalReply, error)
	AuthVerifyAppPassword(ctx context.Context, in *AuthVerifyAppPasswordRequest, opts ...grpc.CallOption) (*PrincipalReply, error)
	// --- Sign: mint/verify signed links (gated by CapSign) ---
	SignLink(ctx context.Context, in *SignLinkRequest, opts ...grpc.CallOption) (*SignLinkReply, error)
	SignVerifyLink(ctx context.Context, in *SignVerifyLinkRequest, opts ...grpc.CallOption) (*SignVerifyLinkReply, error)
	// FSPut is the reverse-direction upload (the plugin already holds the
	// bytes via its own ext.UploadStream, unlike the driver-side pull model in
	// driver.proto's Put): the plugin pushes an Init frame then Chunk frames,
	// the host lands them and calls FS().Put, returning the resulting Obj.
	FSPut(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[FSPutClient, FSPutReply], error)
}

HostServiceClient is the client API for HostService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

HostService is the REVERSE bridge (F0): it is served by the HOST and dialed by a plugin subprocess over go-plugin's GRPCBroker, so a plugin can borrow core capabilities (FS/Store/HTTP) instead of touching storage/db/network directly (design v4-plugin-extensions-design.md §0, §3).

SECURITY ANCHOR: the identity of the CALLING PLUGIN is NOT carried in any request on this service. The host constructs one HostService server instance per plugin subprocess, bound to that plugin's id + Grant + restricted principal; every handler closes over those. A plugin therefore cannot spoof which plugin it is, cannot address another plugin's Store namespace, and cannot widen its own network allowlist — those are server-side facts, not wire inputs. `principal` fields below are host-issued opaque handles (empty = the plugin's own bound principal); FS still runs core Authorize on every call regardless of what the plugin passes.

func NewHostServiceClient 

func NewHostServiceClient(cc grpc.ClientConnInterface) HostServiceClient

type HostServiceServer 

type HostServiceServer interface {
	// --- FS: every op runs core Authorize against the acting principal ---
	FSResolve(context.Context, *FSResolveRequest) (*FSResolveReply, error)
	FSList(context.Context, *FSListRequest) (*ListReply, error)
	FSGet(context.Context, *FSGetRequest) (*ObjReply, error)
	FSLink(context.Context, *FSLinkRequest) (*LinkReply, error)
	FSMkdir(context.Context, *FSMkdirRequest) (*ObjReply, error)
	FSMove(context.Context, *FSMoveRequest) (*ErrorReply, error)
	FSRename(context.Context, *FSRenameRequest) (*ErrorReply, error)
	FSCopy(context.Context, *FSCopyRequest) (*ErrorReply, error)
	FSRemove(context.Context, *FSRemoveRequest) (*ErrorReply, error)
	// --- Store: KV namespaced by the caller plugin's id (server-side) ---
	StoreGet(context.Context, *StoreGetRequest) (*StoreGetReply, error)
	StoreSet(context.Context, *StoreSetRequest) (*ErrorReply, error)
	StoreDelete(context.Context, *StoreDeleteRequest) (*ErrorReply, error)
	StoreList(context.Context, *StoreListRequest) (*StoreListReply, error)
	// --- Secrets: same shape/namespacing as Store, but the host encrypts
	// values at rest (AES-256-GCM) before they touch disk. Mirrors StoreGet/
	// StoreSet/StoreDelete/StoreList exactly; only the message names differ. ---
	SecretGet(context.Context, *SecretGetRequest) (*SecretGetReply, error)
	SecretSet(context.Context, *SecretSetRequest) (*ErrorReply, error)
	SecretDelete(context.Context, *SecretDeleteRequest) (*ErrorReply, error)
	SecretList(context.Context, *SecretListRequest) (*SecretListReply, error)
	// --- Table: per-plugin schemaless document tables (JSON rows, PK-addressed)
	// over the SAME backend as Store — a structured view over KV's storage
	// extent (unlike Secrets, which is fully disjoint). Namespaced by plugin id
	// (server-side) and by table name (a "table:<name>:" key prefix); gated by
	// the same CapStore capability as Store/Secrets. ---
	TableInsert(context.Context, *TableInsertRequest) (*TableInsertReply, error)
	TableGet(context.Context, *TableGetRequest) (*TableGetReply, error)
	TableUpdate(context.Context, *TableUpdateRequest) (*ErrorReply, error)
	TableDelete(context.Context, *TableDeleteRequest) (*ErrorReply, error)
	TableList(context.Context, *TableListRequest) (*TableListReply, error)
	// --- HTTP: outbound gated by global allowlist ∩ Grant.Network ---
	HTTPDo(context.Context, *HTTPDoRequest) (*HTTPDoReply, error)
	// LoadConfig returns the calling plugin's persisted config_form value JSON
	// (server-side bound to the plugin this HostService instance was built for).
	LoadConfig(context.Context, *LoadConfigRequest) (*LoadConfigReply, error)
	// SaveConfig persists the calling plugin's own config_form value JSON
	// (server-side bound to the plugin this HostService instance was built for).
	// Mirrors LoadConfig's leg exactly, in the write direction.
	SaveConfig(context.Context, *SaveConfigRequest) (*SaveConfigReply, error)
	// Capabilities returns the names of the Host APIs the calling plugin was
	// granted (introspection over its own Grant.HostAPIs) — server-side bound,
	// never a wire input.
	Capabilities(context.Context, *CapabilitiesRequest) (*CapabilitiesReply, error)
	// --- Auth: credential/token -> Principal (gated by CapAuth) ---
	AuthLogin(context.Context, *AuthLoginRequest) (*PrincipalReply, error)
	AuthVerifyToken(context.Context, *AuthVerifyTokenRequest) (*PrincipalReply, error)
	AuthVerifyAppPassword(context.Context, *AuthVerifyAppPasswordRequest) (*PrincipalReply, error)
	// --- Sign: mint/verify signed links (gated by CapSign) ---
	SignLink(context.Context, *SignLinkRequest) (*SignLinkReply, error)
	SignVerifyLink(context.Context, *SignVerifyLinkRequest) (*SignVerifyLinkReply, error)
	// FSPut is the reverse-direction upload (the plugin already holds the
	// bytes via its own ext.UploadStream, unlike the driver-side pull model in
	// driver.proto's Put): the plugin pushes an Init frame then Chunk frames,
	// the host lands them and calls FS().Put, returning the resulting Obj.
	FSPut(grpc.ClientStreamingServer[FSPutClient, FSPutReply]) error
	// contains filtered or unexported methods
}

HostServiceServer is the server API for HostService service. All implementations must embed UnimplementedHostServiceServer for forward compatibility.

HostService is the REVERSE bridge (F0): it is served by the HOST and dialed by a plugin subprocess over go-plugin's GRPCBroker, so a plugin can borrow core capabilities (FS/Store/HTTP) instead of touching storage/db/network directly (design v4-plugin-extensions-design.md §0, §3).

SECURITY ANCHOR: the identity of the CALLING PLUGIN is NOT carried in any request on this service. The host constructs one HostService server instance per plugin subprocess, bound to that plugin's id + Grant + restricted principal; every handler closes over those. A plugin therefore cannot spoof which plugin it is, cannot address another plugin's Store namespace, and cannot widen its own network allowlist — those are server-side facts, not wire inputs. `principal` fields below are host-issued opaque handles (empty = the plugin's own bound principal); FS still runs core Authorize on every call regardless of what the plugin passes.

type HostService_FSPutClient 

type HostService_FSPutClient = grpc.ClientStreamingClient[FSPutClient, FSPutReply]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type HostService_FSPutServer 

type HostService_FSPutServer = grpc.ClientStreamingServer[FSPutClient, FSPutReply]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type InitHostRequest 

type InitHostRequest struct {
	BrokerId uint32 `protobuf:"varint,1,opt,name=broker_id,json=brokerId,proto3" json:"broker_id,omitempty"`
	// contains filtered or unexported fields
}

InitHostRequest carries the go-plugin GRPCBroker id the host is serving its HostService on, so the plugin can broker.Dial it and build a host client.

func (*InitHostRequest) Descriptor deprecated 

func (*InitHostRequest) Descriptor() ([]byte, []int)

Deprecated: Use InitHostRequest.ProtoReflect.Descriptor instead.

func (*InitHostRequest) GetBrokerId 

func (x *InitHostRequest) GetBrokerId() uint32

func (*InitHostRequest) ProtoMessage 

func (*InitHostRequest) ProtoMessage()

func (*InitHostRequest) ProtoReflect 

func (x *InitHostRequest) ProtoReflect() protoreflect.Message

func (*InitHostRequest) Reset 

func (x *InitHostRequest) Reset()

func (*InitHostRequest) String 

func (x *InitHostRequest) String() string

type InvokeReply 

type InvokeReply struct {

	// result_json is Invoke's returned value (any) marshaled as JSON.
	ResultJson []byte      `protobuf:"bytes,1,opt,name=result_json,json=resultJson,proto3" json:"result_json,omitempty"`
	Error      *ErrorProto `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*InvokeReply) Descriptor deprecated 

func (*InvokeReply) Descriptor() ([]byte, []int)

Deprecated: Use InvokeReply.ProtoReflect.Descriptor instead.

func (*InvokeReply) GetError 

func (x *InvokeReply) GetError() *ErrorProto

func (*InvokeReply) GetResultJson 

func (x *InvokeReply) GetResultJson() []byte

func (*InvokeReply) ProtoMessage 

func (*InvokeReply) ProtoMessage()

func (*InvokeReply) ProtoReflect 

func (x *InvokeReply) ProtoReflect() protoreflect.Message

func (*InvokeReply) Reset 

func (x *InvokeReply) Reset()

func (*InvokeReply) String 

func (x *InvokeReply) String() string

type InvokeRequest 

type InvokeRequest struct {

	// principal is the host-issued identity handle of the acting user
	// (ext.Principal); empty means the plugin's own bound identity.
	Principal string `protobuf:"bytes,1,opt,name=principal,proto3" json:"principal,omitempty"`
	ActionId  string `protobuf:"bytes,2,opt,name=action_id,json=actionId,proto3" json:"action_id,omitempty"`
	// args_json is the caller's args map[string]any marshaled as JSON.
	ArgsJson []byte `protobuf:"bytes,3,opt,name=args_json,json=argsJson,proto3" json:"args_json,omitempty"`
	// contains filtered or unexported fields
}

func (*InvokeRequest) Descriptor deprecated 

func (*InvokeRequest) Descriptor() ([]byte, []int)

Deprecated: Use InvokeRequest.ProtoReflect.Descriptor instead.

func (*InvokeRequest) GetActionId 

func (x *InvokeRequest) GetActionId() string

func (*InvokeRequest) GetArgsJson 

func (x *InvokeRequest) GetArgsJson() []byte

func (*InvokeRequest) GetPrincipal 

func (x *InvokeRequest) GetPrincipal() string

func (*InvokeRequest) ProtoMessage 

func (*InvokeRequest) ProtoMessage()

func (*InvokeRequest) ProtoReflect 

func (x *InvokeRequest) ProtoReflect() protoreflect.Message

func (*InvokeRequest) Reset 

func (x *InvokeRequest) Reset()

func (*InvokeRequest) String 

func (x *InvokeRequest) String() string
type Link struct {
	ByteSource   string                  `protobuf:"bytes,1,opt,name=byte_source,json=byteSource,proto3" json:"byte_source,omitempty"`
	Url          string                  `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Header       map[string]*HeaderValue `` /* 139-byte string literal not displayed */
	StreamId     string                  `protobuf:"bytes,4,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	RangeSupport bool                    `protobuf:"varint,5,opt,name=range_support,json=rangeSupport,proto3" json:"range_support,omitempty"`
	Expiration   int64                   `protobuf:"varint,6,opt,name=expiration,proto3" json:"expiration,omitempty"`
	IpCacheKey   bool                    `protobuf:"varint,7,opt,name=ip_cache_key,json=ipCacheKey,proto3" json:"ip_cache_key,omitempty"`
	Concurrency  int32                   `protobuf:"varint,8,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	PartSize     int32                   `protobuf:"varint,9,opt,name=part_size,json=partSize,proto3" json:"part_size,omitempty"`
	// contains filtered or unexported fields
}

Link mirrors ext.Link (9.0 §1). byte_source is "url" or "stream".

func LinkToProto 

func LinkToProto(l *ext.Link) *Link

func (*Link) Descriptor deprecated 

func (*Link) Descriptor() ([]byte, []int)

Deprecated: Use Link.ProtoReflect.Descriptor instead.

func (*Link) GetByteSource 

func (x *Link) GetByteSource() string

func (*Link) GetConcurrency 

func (x *Link) GetConcurrency() int32

func (*Link) GetExpiration 

func (x *Link) GetExpiration() int64

func (*Link) GetHeader 

func (x *Link) GetHeader() map[string]*HeaderValue

func (*Link) GetIpCacheKey 

func (x *Link) GetIpCacheKey() bool

func (*Link) GetPartSize 

func (x *Link) GetPartSize() int32

func (*Link) GetRangeSupport 

func (x *Link) GetRangeSupport() bool

func (*Link) GetStreamId 

func (x *Link) GetStreamId() string

func (*Link) GetUrl 

func (x *Link) GetUrl() string

func (*Link) ProtoMessage 

func (*Link) ProtoMessage()

func (*Link) ProtoReflect 

func (x *Link) ProtoReflect() protoreflect.Message

func (*Link) Reset 

func (x *Link) Reset()

func (*Link) String 

func (x *Link) String() string

type LinkArgs 

type LinkArgs struct {
	Ip       string                  `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Header   map[string]*HeaderValue `` /* 139-byte string literal not displayed */
	Type     string                  `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Redirect bool                    `protobuf:"varint,4,opt,name=redirect,proto3" json:"redirect,omitempty"`
	// contains filtered or unexported fields
}

func LinkArgsToProto 

func LinkArgsToProto(a ext.LinkArgs) *LinkArgs

func (*LinkArgs) Descriptor deprecated 

func (*LinkArgs) Descriptor() ([]byte, []int)

Deprecated: Use LinkArgs.ProtoReflect.Descriptor instead.

func (*LinkArgs) GetHeader 

func (x *LinkArgs) GetHeader() map[string]*HeaderValue

func (*LinkArgs) GetIp 

func (x *LinkArgs) GetIp() string

func (*LinkArgs) GetRedirect 

func (x *LinkArgs) GetRedirect() bool

func (*LinkArgs) GetType 

func (x *LinkArgs) GetType() string

func (*LinkArgs) ProtoMessage 

func (*LinkArgs) ProtoMessage()

func (*LinkArgs) ProtoReflect 

func (x *LinkArgs) ProtoReflect() protoreflect.Message

func (*LinkArgs) Reset 

func (x *LinkArgs) Reset()

func (*LinkArgs) String 

func (x *LinkArgs) String() string

type LinkReply 

type LinkReply struct {
	Link  *Link       `protobuf:"bytes,1,opt,name=link,proto3" json:"link,omitempty"`
	Error *ErrorProto `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*LinkReply) Descriptor deprecated 

func (*LinkReply) Descriptor() ([]byte, []int)

Deprecated: Use LinkReply.ProtoReflect.Descriptor instead.

func (*LinkReply) GetError 

func (x *LinkReply) GetError() *ErrorProto
func (x *LinkReply) GetLink() *Link

func (*LinkReply) ProtoMessage 

func (*LinkReply) ProtoMessage()

func (*LinkReply) ProtoReflect 

func (x *LinkReply) ProtoReflect() protoreflect.Message

func (*LinkReply) Reset 

func (x *LinkReply) Reset()

func (*LinkReply) String 

func (x *LinkReply) String() string

type LinkRequest 

type LinkRequest struct {
	File *ObjRef   `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	Args *LinkArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

func (*LinkRequest) Descriptor deprecated 

func (*LinkRequest) Descriptor() ([]byte, []int)

Deprecated: Use LinkRequest.ProtoReflect.Descriptor instead.

func (*LinkRequest) GetArgs 

func (x *LinkRequest) GetArgs() *LinkArgs

func (*LinkRequest) GetFile 

func (x *LinkRequest) GetFile() *ObjRef

func (*LinkRequest) ProtoMessage 

func (*LinkRequest) ProtoMessage()

func (*LinkRequest) ProtoReflect 

func (x *LinkRequest) ProtoReflect() protoreflect.Message

func (*LinkRequest) Reset 

func (x *LinkRequest) Reset()

func (*LinkRequest) String 

func (x *LinkRequest) String() string

type ListArgs 

type ListArgs struct {
	ReqPath string `protobuf:"bytes,1,opt,name=req_path,json=reqPath,proto3" json:"req_path,omitempty"`
	Refresh bool   `protobuf:"varint,2,opt,name=refresh,proto3" json:"refresh,omitempty"`
	// contains filtered or unexported fields
}

func ListArgsToProto 

func ListArgsToProto(a ext.ListArgs) *ListArgs

func (*ListArgs) Descriptor deprecated 

func (*ListArgs) Descriptor() ([]byte, []int)

Deprecated: Use ListArgs.ProtoReflect.Descriptor instead.

func (*ListArgs) GetRefresh 

func (x *ListArgs) GetRefresh() bool

func (*ListArgs) GetReqPath 

func (x *ListArgs) GetReqPath() string

func (*ListArgs) ProtoMessage 

func (*ListArgs) ProtoMessage()

func (*ListArgs) ProtoReflect 

func (x *ListArgs) ProtoReflect() protoreflect.Message

func (*ListArgs) Reset 

func (x *ListArgs) Reset()

func (*ListArgs) String 

func (x *ListArgs) String() string

type ListReply 

type ListReply struct {
	Objs  []*Obj      `protobuf:"bytes,1,rep,name=objs,proto3" json:"objs,omitempty"`
	Error *ErrorProto `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ListReply) Descriptor deprecated 

func (*ListReply) Descriptor() ([]byte, []int)

Deprecated: Use ListReply.ProtoReflect.Descriptor instead.

func (*ListReply) GetError 

func (x *ListReply) GetError() *ErrorProto

func (*ListReply) GetObjs 

func (x *ListReply) GetObjs() []*Obj

func (*ListReply) ProtoMessage 

func (*ListReply) ProtoMessage()

func (*ListReply) ProtoReflect 

func (x *ListReply) ProtoReflect() protoreflect.Message

func (*ListReply) Reset 

func (x *ListReply) Reset()

func (*ListReply) String 

func (x *ListReply) String() string

type ListRequest 

type ListRequest struct {
	Dir  *ObjRef   `protobuf:"bytes,1,opt,name=dir,proto3" json:"dir,omitempty"`
	Args *ListArgs `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRequest) Descriptor deprecated 

func (*ListRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetArgs 

func (x *ListRequest) GetArgs() *ListArgs

func (*ListRequest) GetDir 

func (x *ListRequest) GetDir() *ObjRef

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect 

func (x *ListRequest) ProtoReflect() protoreflect.Message

func (*ListRequest) Reset 

func (x *ListRequest) Reset()

func (*ListRequest) String 

func (x *ListRequest) String() string

type LoadConfigReply 

type LoadConfigReply struct {
	Config []byte      `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	Error  *ErrorProto `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*LoadConfigReply) Descriptor deprecated 

func (*LoadConfigReply) Descriptor() ([]byte, []int)

Deprecated: Use LoadConfigReply.ProtoReflect.Descriptor instead.

func (*LoadConfigReply) GetConfig 

func (x *LoadConfigReply) GetConfig() []byte

func (*LoadConfigReply) GetError 

func (x *LoadConfigReply) GetError() *ErrorProto

func (*LoadConfigReply) ProtoMessage 

func (*LoadConfigReply) ProtoMessage()

func (*LoadConfigReply) ProtoReflect 

func (x *LoadConfigReply) ProtoReflect() protoreflect.Message

func (*LoadConfigReply) Reset 

func (x *LoadConfigReply) Reset()

func (*LoadConfigReply) String 

func (x *LoadConfigReply) String() string

type LoadConfigRequest 

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

func (*LoadConfigRequest) Descriptor deprecated 

func (*LoadConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use LoadConfigRequest.ProtoReflect.Descriptor instead.

func (*LoadConfigRequest) ProtoMessage 

func (*LoadConfigRequest) ProtoMessage()

func (*LoadConfigRequest) ProtoReflect 

func (x *LoadConfigRequest) ProtoReflect() protoreflect.Message

func (*LoadConfigRequest) Reset 

func (x *LoadConfigRequest) Reset()

func (*LoadConfigRequest) String 

func (x *LoadConfigRequest) String() string

type MakeDirRequest 

type MakeDirRequest struct {
	Parent *ObjRef `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	Name   string  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*MakeDirRequest) Descriptor deprecated 

func (*MakeDirRequest) Descriptor() ([]byte, []int)

Deprecated: Use MakeDirRequest.ProtoReflect.Descriptor instead.

func (*MakeDirRequest) GetName 

func (x *MakeDirRequest) GetName() string

func (*MakeDirRequest) GetParent 

func (x *MakeDirRequest) GetParent() *ObjRef

func (*MakeDirRequest) ProtoMessage 

func (*MakeDirRequest) ProtoMessage()

func (*MakeDirRequest) ProtoReflect 

func (x *MakeDirRequest) ProtoReflect() protoreflect.Message

func (*MakeDirRequest) Reset 

func (x *MakeDirRequest) Reset()

func (*MakeDirRequest) String 

func (x *MakeDirRequest) String() string

type ManifestReply 

type ManifestReply struct {

	// manifest_json is the ext.Manifest marshaled as JSON (it is already a JSON
	// contract; re-encoding it in proto would duplicate the frozen shape).
	ManifestJson []byte `protobuf:"bytes,1,opt,name=manifest_json,json=manifestJson,proto3" json:"manifest_json,omitempty"`
	// driver_config_json is the ext.DriverConfig marshaled as JSON.
	DriverConfigJson []byte `protobuf:"bytes,2,opt,name=driver_config_json,json=driverConfigJson,proto3" json:"driver_config_json,omitempty"`
	// contains filtered or unexported fields
}

func (*ManifestReply) Descriptor deprecated 

func (*ManifestReply) Descriptor() ([]byte, []int)

Deprecated: Use ManifestReply.ProtoReflect.Descriptor instead.

func (*ManifestReply) GetDriverConfigJson 

func (x *ManifestReply) GetDriverConfigJson() []byte

func (*ManifestReply) GetManifestJson 

func (x *ManifestReply) GetManifestJson() []byte

func (*ManifestReply) ProtoMessage 

func (*ManifestReply) ProtoMessage()

func (*ManifestReply) ProtoReflect 

func (x *ManifestReply) ProtoReflect() protoreflect.Message

func (*ManifestReply) Reset 

func (x *ManifestReply) Reset()

func (*ManifestReply) String 

func (x *ManifestReply) String() string

type MethodInfoReply 

type MethodInfoReply struct {
	Id      string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Kind    uint32            `protobuf:"varint,2,opt,name=kind,proto3" json:"kind,omitempty"`
	Display map[string]string `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

AuthKind mirrors ext.AuthKind. The numbering is pinned by the SDK enum (primary=0, second_factor=1, federated=2) and carried verbatim.

func MethodInfoToProto 

func MethodInfoToProto(i ext.AuthMethodInfo) *MethodInfoReply

MethodInfoToProto/MethodInfoFromProto carry ext.AuthMethodInfo. AuthKind is a uint8 in Go, widened to the proto's uint32 (proto3 has no uint8) and narrowed back; the enum numbering is pinned by the SDK.

func (*MethodInfoReply) Descriptor deprecated 

func (*MethodInfoReply) Descriptor() ([]byte, []int)

Deprecated: Use MethodInfoReply.ProtoReflect.Descriptor instead.

func (*MethodInfoReply) GetDisplay 

func (x *MethodInfoReply) GetDisplay() map[string]string

func (*MethodInfoReply) GetId 

func (x *MethodInfoReply) GetId() string

func (*MethodInfoReply) GetKind 

func (x *MethodInfoReply) GetKind() uint32

func (*MethodInfoReply) ProtoMessage 

func (*MethodInfoReply) ProtoMessage()

func (*MethodInfoReply) ProtoReflect 

func (x *MethodInfoReply) ProtoReflect() protoreflect.Message

func (*MethodInfoReply) Reset 

func (x *MethodInfoReply) Reset()

func (*MethodInfoReply) String 

func (x *MethodInfoReply) String() string

type MoveRequest 

type MoveRequest struct {
	Src    *ObjRef `protobuf:"bytes,1,opt,name=src,proto3" json:"src,omitempty"`
	DstDir *ObjRef `protobuf:"bytes,2,opt,name=dst_dir,json=dstDir,proto3" json:"dst_dir,omitempty"`
	// contains filtered or unexported fields
}

func (*MoveRequest) Descriptor deprecated 

func (*MoveRequest) Descriptor() ([]byte, []int)

Deprecated: Use MoveRequest.ProtoReflect.Descriptor instead.

func (*MoveRequest) GetDstDir 

func (x *MoveRequest) GetDstDir() *ObjRef

func (*MoveRequest) GetSrc 

func (x *MoveRequest) GetSrc() *ObjRef

func (*MoveRequest) ProtoMessage 

func (*MoveRequest) ProtoMessage()

func (*MoveRequest) ProtoReflect 

func (x *MoveRequest) ProtoReflect() protoreflect.Message

func (*MoveRequest) Reset 

func (x *MoveRequest) Reset()

func (*MoveRequest) String 

func (x *MoveRequest) String() string

type NewInstanceRequest 

type NewInstanceRequest struct {
	StorageId string `protobuf:"bytes,1,opt,name=storage_id,json=storageId,proto3" json:"storage_id,omitempty"`
	Config    []byte `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"` // Addition JSON
	// contains filtered or unexported fields
}

func (*NewInstanceRequest) Descriptor deprecated 

func (*NewInstanceRequest) Descriptor() ([]byte, []int)

Deprecated: Use NewInstanceRequest.ProtoReflect.Descriptor instead.

func (*NewInstanceRequest) GetConfig 

func (x *NewInstanceRequest) GetConfig() []byte

func (*NewInstanceRequest) GetStorageId 

func (x *NewInstanceRequest) GetStorageId() string

func (*NewInstanceRequest) ProtoMessage 

func (*NewInstanceRequest) ProtoMessage()

func (*NewInstanceRequest) ProtoReflect 

func (x *NewInstanceRequest) ProtoReflect() protoreflect.Message

func (*NewInstanceRequest) Reset 

func (x *NewInstanceRequest) Reset()

func (*NewInstanceRequest) String 

func (x *NewInstanceRequest) String() string

type NoticeProto 

type NoticeProto struct {
	Level     string `protobuf:"bytes,1,opt,name=level,proto3" json:"level,omitempty"`
	Title     string `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	Body      string `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	Source    string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
	UnixMilli int64  `protobuf:"varint,5,opt,name=unix_milli,json=unixMilli,proto3" json:"unix_milli,omitempty"`
	// contains filtered or unexported fields
}

NoticeProto mirrors ext.Notice field-for-field (level/title/body/source/ unix_milli) — the wire encoding of the notification payload Notify receives.

func (*NoticeProto) Descriptor deprecated 

func (*NoticeProto) Descriptor() ([]byte, []int)

Deprecated: Use NoticeProto.ProtoReflect.Descriptor instead.

func (*NoticeProto) GetBody 

func (x *NoticeProto) GetBody() string

func (*NoticeProto) GetLevel 

func (x *NoticeProto) GetLevel() string

func (*NoticeProto) GetSource 

func (x *NoticeProto) GetSource() string

func (*NoticeProto) GetTitle 

func (x *NoticeProto) GetTitle() string

func (*NoticeProto) GetUnixMilli 

func (x *NoticeProto) GetUnixMilli() int64

func (*NoticeProto) ProtoMessage 

func (*NoticeProto) ProtoMessage()

func (*NoticeProto) ProtoReflect 

func (x *NoticeProto) ProtoReflect() protoreflect.Message

func (*NoticeProto) Reset 

func (x *NoticeProto) Reset()

func (*NoticeProto) String 

func (x *NoticeProto) String() string

type NotificationServiceClient 

type NotificationServiceClient interface {
	// GetManifest is the handshake: the manifest the host validates the plugin
	// against before dispatching notices to it.
	GetManifest(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ManifestReply, error)
	// Notify delivers one host notice (ext.Notification.Notify). The host runs
	// this under panic + error isolation on its side (internal/extension);
	// Notify's own error, if any, crosses back as ErrorReply so the host can
	// log it — it is never treated as a veto.
	Notify(ctx context.Context, in *NoticeProto, opts ...grpc.CallOption) (*ErrorReply, error)
	// Reverse host bridge (F0/SP6): host serves a HostService on the broker id it
	// passes here; the plugin dials it and delivers the host to Init.
	InitHost(ctx context.Context, in *InitHostRequest, opts ...grpc.CallOption) (*ErrorReply, error)
}

NotificationServiceClient is the client API for NotificationService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

NotificationService mirrors ext.Notification (W7b): a Kind=NotificationChannel plugin is a sink the host fans notices out to (email/webhook/Telegram/...) — a notification sink, not a veto (see ext.Notification's doc comment). Mirrors EventHookService (eventhook.proto) one Kind over, including the reverse-host InitHost bridge (F0/SP6).

func NewNotificationServiceClient 

func NewNotificationServiceClient(cc grpc.ClientConnInterface) NotificationServiceClient

type NotificationServiceServer 

type NotificationServiceServer interface {
	// GetManifest is the handshake: the manifest the host validates the plugin
	// against before dispatching notices to it.
	GetManifest(context.Context, *Empty) (*ManifestReply, error)
	// Notify delivers one host notice (ext.Notification.Notify). The host runs
	// this under panic + error isolation on its side (internal/extension);
	// Notify's own error, if any, crosses back as ErrorReply so the host can
	// log it — it is never treated as a veto.
	Notify(context.Context, *NoticeProto) (*ErrorReply, error)
	// Reverse host bridge (F0/SP6): host serves a HostService on the broker id it
	// passes here; the plugin dials it and delivers the host to Init.
	InitHost(context.Context, *InitHostRequest) (*ErrorReply, error)
	// contains filtered or unexported methods
}

NotificationServiceServer is the server API for NotificationService service. All implementations must embed UnimplementedNotificationServiceServer for forward compatibility.

NotificationService mirrors ext.Notification (W7b): a Kind=NotificationChannel plugin is a sink the host fans notices out to (email/webhook/Telegram/...) — a notification sink, not a veto (see ext.Notification's doc comment). Mirrors EventHookService (eventhook.proto) one Kind over, including the reverse-host InitHost bridge (F0/SP6).

type Obj 

type Obj struct {
	Name     string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Size     int64             `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Modified int64             `protobuf:"varint,3,opt,name=modified,proto3" json:"modified,omitempty"` // unix milliseconds
	Created  int64             `protobuf:"varint,4,opt,name=created,proto3" json:"created,omitempty"`   // unix milliseconds
	IsDir    bool              `protobuf:"varint,5,opt,name=is_dir,json=isDir,proto3" json:"is_dir,omitempty"`
	Id       string            `protobuf:"bytes,6,opt,name=id,proto3" json:"id,omitempty"`
	Path     string            `protobuf:"bytes,7,opt,name=path,proto3" json:"path,omitempty"`
	Hashes   map[string]string `` /* 139-byte string literal not displayed */
	Thumb    string            `protobuf:"bytes,9,opt,name=thumb,proto3" json:"thumb,omitempty"`
	Url      string            `protobuf:"bytes,10,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

Obj is the flat serializable filesystem object DTO (9.0 §7).

func ObjPtrToProto 

func ObjPtrToProto(o *ext.Obj) *Obj

ObjPtrToProto encodes an optional *ext.Obj (nil-safe).

func ObjToProto 

func ObjToProto(o ext.Obj) *Obj

func ObjsToProto 

func ObjsToProto(objs []ext.Obj) []*Obj

func (*Obj) Descriptor deprecated 

func (*Obj) Descriptor() ([]byte, []int)

Deprecated: Use Obj.ProtoReflect.Descriptor instead.

func (*Obj) GetCreated 

func (x *Obj) GetCreated() int64

func (*Obj) GetHashes 

func (x *Obj) GetHashes() map[string]string

func (*Obj) GetId 

func (x *Obj) GetId() string

func (*Obj) GetIsDir 

func (x *Obj) GetIsDir() bool

func (*Obj) GetModified 

func (x *Obj) GetModified() int64

func (*Obj) GetName 

func (x *Obj) GetName() string

func (*Obj) GetPath 

func (x *Obj) GetPath() string

func (*Obj) GetSize 

func (x *Obj) GetSize() int64

func (*Obj) GetThumb 

func (x *Obj) GetThumb() string

func (*Obj) GetUrl 

func (x *Obj) GetUrl() string

func (*Obj) ProtoMessage 

func (*Obj) ProtoMessage()

func (*Obj) ProtoReflect 

func (x *Obj) ProtoReflect() protoreflect.Message

func (*Obj) Reset 

func (x *Obj) Reset()

func (*Obj) String 

func (x *Obj) String() string

type ObjRef 

type ObjRef struct {
	StorageId string `protobuf:"bytes,1,opt,name=storage_id,json=storageId,proto3" json:"storage_id,omitempty"`
	Anchor    string `protobuf:"bytes,2,opt,name=anchor,proto3" json:"anchor,omitempty"`
	// contains filtered or unexported fields
}

ObjRef identifies a resource by storage plus an opaque anchor (9.0 §7).

func RefToProto 

func RefToProto(r ext.ObjRef) *ObjRef

func (*ObjRef) Descriptor deprecated 

func (*ObjRef) Descriptor() ([]byte, []int)

Deprecated: Use ObjRef.ProtoReflect.Descriptor instead.

func (*ObjRef) GetAnchor 

func (x *ObjRef) GetAnchor() string

func (*ObjRef) GetStorageId 

func (x *ObjRef) GetStorageId() string

func (*ObjRef) ProtoMessage 

func (*ObjRef) ProtoMessage()

func (*ObjRef) ProtoReflect 

func (x *ObjRef) ProtoReflect() protoreflect.Message

func (*ObjRef) Reset 

func (x *ObjRef) Reset()

func (*ObjRef) String 

func (x *ObjRef) String() string

type ObjReply 

type ObjReply struct {
	Obj   *Obj        `protobuf:"bytes,1,opt,name=obj,proto3" json:"obj,omitempty"`
	Error *ErrorProto `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjReply) Descriptor deprecated 

func (*ObjReply) Descriptor() ([]byte, []int)

Deprecated: Use ObjReply.ProtoReflect.Descriptor instead.

func (*ObjReply) GetError 

func (x *ObjReply) GetError() *ErrorProto

func (*ObjReply) GetObj 

func (x *ObjReply) GetObj() *Obj

func (*ObjReply) ProtoMessage 

func (*ObjReply) ProtoMessage()

func (*ObjReply) ProtoReflect 

func (x *ObjReply) ProtoReflect() protoreflect.Message

func (*ObjReply) Reset 

func (x *ObjReply) Reset()

func (*ObjReply) String 

func (x *ObjReply) String() string

type OpenRangeRequest 

type OpenRangeRequest struct {
	Ref      *ObjRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	StreamId string  `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Range    *Range  `protobuf:"bytes,3,opt,name=range,proto3" json:"range,omitempty"`
	// contains filtered or unexported fields
}

func (*OpenRangeRequest) Descriptor deprecated 

func (*OpenRangeRequest) Descriptor() ([]byte, []int)

Deprecated: Use OpenRangeRequest.ProtoReflect.Descriptor instead.

func (*OpenRangeRequest) GetRange 

func (x *OpenRangeRequest) GetRange() *Range

func (*OpenRangeRequest) GetRef 

func (x *OpenRangeRequest) GetRef() *ObjRef

func (*OpenRangeRequest) GetStreamId 

func (x *OpenRangeRequest) GetStreamId() string

func (*OpenRangeRequest) ProtoMessage 

func (*OpenRangeRequest) ProtoMessage()

func (*OpenRangeRequest) ProtoReflect 

func (x *OpenRangeRequest) ProtoReflect() protoreflect.Message

func (*OpenRangeRequest) Reset 

func (x *OpenRangeRequest) Reset()

func (*OpenRangeRequest) String 

func (x *OpenRangeRequest) String() string

type OtherReply 

type OtherReply struct {
	Data  []byte      `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // json.RawMessage
	Error *ErrorProto `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*OtherReply) Descriptor deprecated 

func (*OtherReply) Descriptor() ([]byte, []int)

Deprecated: Use OtherReply.ProtoReflect.Descriptor instead.

func (*OtherReply) GetData 

func (x *OtherReply) GetData() []byte

func (*OtherReply) GetError 

func (x *OtherReply) GetError() *ErrorProto

func (*OtherReply) ProtoMessage 

func (*OtherReply) ProtoMessage()

func (*OtherReply) ProtoReflect 

func (x *OtherReply) ProtoReflect() protoreflect.Message

func (*OtherReply) Reset 

func (x *OtherReply) Reset()

func (*OtherReply) String 

func (x *OtherReply) String() string

type OtherRequest 

type OtherRequest struct {
	Obj    *ObjRef `protobuf:"bytes,1,opt,name=obj,proto3" json:"obj,omitempty"`
	Method string  `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Data   []byte  `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` // json.RawMessage
	// contains filtered or unexported fields
}

func (*OtherRequest) Descriptor deprecated 

func (*OtherRequest) Descriptor() ([]byte, []int)

Deprecated: Use OtherRequest.ProtoReflect.Descriptor instead.

func (*OtherRequest) GetData 

func (x *OtherRequest) GetData() []byte

func (*OtherRequest) GetMethod 

func (x *OtherRequest) GetMethod() string

func (*OtherRequest) GetObj 

func (x *OtherRequest) GetObj() *ObjRef

func (*OtherRequest) ProtoMessage 

func (*OtherRequest) ProtoMessage()

func (*OtherRequest) ProtoReflect 

func (x *OtherRequest) ProtoReflect() protoreflect.Message

func (*OtherRequest) Reset 

func (x *OtherRequest) Reset()

func (*OtherRequest) String 

func (x *OtherRequest) String() string

type PrincipalReply 

type PrincipalReply struct {
	Principal string      `protobuf:"bytes,1,opt,name=principal,proto3" json:"principal,omitempty"`
	Error     *ErrorProto `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

PrincipalReply carries the opaque host-issued Principal handle minted by an Auth call.

func (*PrincipalReply) Descriptor deprecated 

func (*PrincipalReply) Descriptor() ([]byte, []int)

Deprecated: Use PrincipalReply.ProtoReflect.Descriptor instead.

func (*PrincipalReply) GetError 

func (x *PrincipalReply) GetError() *ErrorProto

func (*PrincipalReply) GetPrincipal 

func (x *PrincipalReply) GetPrincipal() string

func (*PrincipalReply) ProtoMessage 

func (*PrincipalReply) ProtoMessage()

func (*PrincipalReply) ProtoReflect 

func (x *PrincipalReply) ProtoReflect() protoreflect.Message

func (*PrincipalReply) Reset 

func (x *PrincipalReply) Reset()

func (*PrincipalReply) String 

func (x *PrincipalReply) String() string

type Progress 

type Progress struct {
	Fraction float64 `protobuf:"fixed64,1,opt,name=fraction,proto3" json:"fraction,omitempty"`
	// contains filtered or unexported fields
}

func (*Progress) Descriptor deprecated 

func (*Progress) Descriptor() ([]byte, []int)

Deprecated: Use Progress.ProtoReflect.Descriptor instead.

func (*Progress) GetFraction 

func (x *Progress) GetFraction() float64

func (*Progress) ProtoMessage 

func (*Progress) ProtoMessage()

func (*Progress) ProtoReflect 

func (x *Progress) ProtoReflect() protoreflect.Message

func (*Progress) Reset 

func (x *Progress) Reset()

func (*Progress) String 

func (x *Progress) String() string

type ProtocolInfoReply 

type ProtocolInfoReply struct {
	Scheme string `protobuf:"bytes,1,opt,name=scheme,proto3" json:"scheme,omitempty"`
	// transport mirrors ext.Transport: 0 = TransportHTTP, 1 = TransportConn.
	Transport    int32  `protobuf:"varint,2,opt,name=transport,proto3" json:"transport,omitempty"`
	DefaultPort  int32  `protobuf:"varint,3,opt,name=default_port,json=defaultPort,proto3" json:"default_port,omitempty"`
	MountPattern string `protobuf:"bytes,4,opt,name=mount_pattern,json=mountPattern,proto3" json:"mount_pattern,omitempty"`
	// contains filtered or unexported fields
}

ProtocolInfoReply mirrors ext.ProtocolInfo field-for-field.

func (*ProtocolInfoReply) Descriptor deprecated 

func (*ProtocolInfoReply) Descriptor() ([]byte, []int)

Deprecated: Use ProtocolInfoReply.ProtoReflect.Descriptor instead.

func (*ProtocolInfoReply) GetDefaultPort 

func (x *ProtocolInfoReply) GetDefaultPort() int32

func (*ProtocolInfoReply) GetMountPattern 

func (x *ProtocolInfoReply) GetMountPattern() string

func (*ProtocolInfoReply) GetScheme 

func (x *ProtocolInfoReply) GetScheme() string

func (*ProtocolInfoReply) GetTransport 

func (x *ProtocolInfoReply) GetTransport() int32

func (*ProtocolInfoReply) ProtoMessage 

func (*ProtocolInfoReply) ProtoMessage()

func (*ProtocolInfoReply) ProtoReflect 

func (x *ProtocolInfoReply) ProtoReflect() protoreflect.Message

func (*ProtocolInfoReply) Reset 

func (x *ProtocolInfoReply) Reset()

func (*ProtocolInfoReply) String 

func (x *ProtocolInfoReply) String() string

type ProvisionHintProto 

type ProvisionHintProto struct {
	DisplayName string            `protobuf:"bytes,1,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	Email       string            `protobuf:"bytes,2,opt,name=email,proto3" json:"email,omitempty"`
	Attributes  map[string]string `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ProvisionHintProto) Descriptor deprecated 

func (*ProvisionHintProto) Descriptor() ([]byte, []int)

Deprecated: Use ProvisionHintProto.ProtoReflect.Descriptor instead.

func (*ProvisionHintProto) GetAttributes 

func (x *ProvisionHintProto) GetAttributes() map[string]string

func (*ProvisionHintProto) GetDisplayName 

func (x *ProvisionHintProto) GetDisplayName() string

func (*ProvisionHintProto) GetEmail 

func (x *ProvisionHintProto) GetEmail() string

func (*ProvisionHintProto) ProtoMessage 

func (*ProvisionHintProto) ProtoMessage()

func (*ProvisionHintProto) ProtoReflect 

func (x *ProvisionHintProto) ProtoReflect() protoreflect.Message

func (*ProvisionHintProto) Reset 

func (x *ProvisionHintProto) Reset()

func (*ProvisionHintProto) String 

func (x *ProvisionHintProto) String() string

type PutClient 

type PutClient struct {

	// Types that are valid to be assigned to Msg:
	//
	//	*PutClient_Init
	//	*PutClient_ReadReply
	Msg isPutClient_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

PutClient: host -> plugin messages on the Put bidi stream.

func (*PutClient) Descriptor deprecated 

func (*PutClient) Descriptor() ([]byte, []int)

Deprecated: Use PutClient.ProtoReflect.Descriptor instead.

func (*PutClient) GetInit 

func (x *PutClient) GetInit() *PutInit

func (*PutClient) GetMsg 

func (x *PutClient) GetMsg() isPutClient_Msg

func (*PutClient) GetReadReply 

func (x *PutClient) GetReadReply() *ReadReply

func (*PutClient) ProtoMessage 

func (*PutClient) ProtoMessage()

func (*PutClient) ProtoReflect 

func (x *PutClient) ProtoReflect() protoreflect.Message

func (*PutClient) Reset 

func (x *PutClient) Reset()

func (*PutClient) String 

func (x *PutClient) String() string

type PutClient_Init 

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

type PutClient_ReadReply 

type PutClient_ReadReply struct {
	ReadReply *ReadReply `protobuf:"bytes,2,opt,name=read_reply,json=readReply,proto3,oneof"`
}

type PutInit 

type PutInit struct {
	DstDir *ObjRef     `protobuf:"bytes,1,opt,name=dst_dir,json=dstDir,proto3" json:"dst_dir,omitempty"`
	Info   *UploadInfo `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*PutInit) Descriptor deprecated 

func (*PutInit) Descriptor() ([]byte, []int)

Deprecated: Use PutInit.ProtoReflect.Descriptor instead.

func (*PutInit) GetDstDir 

func (x *PutInit) GetDstDir() *ObjRef

func (*PutInit) GetInfo 

func (x *PutInit) GetInfo() *UploadInfo

func (*PutInit) ProtoMessage 

func (*PutInit) ProtoMessage()

func (*PutInit) ProtoReflect 

func (x *PutInit) ProtoReflect() protoreflect.Message

func (*PutInit) Reset 

func (x *PutInit) Reset()

func (*PutInit) String 

func (x *PutInit) String() string

type PutServer 

type PutServer struct {

	// Types that are valid to be assigned to Msg:
	//
	//	*PutServer_ReadRequest
	//	*PutServer_Progress
	//	*PutServer_Done
	Msg isPutServer_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

PutServer: plugin -> host messages on the Put bidi stream.

func (*PutServer) Descriptor deprecated 

func (*PutServer) Descriptor() ([]byte, []int)

Deprecated: Use PutServer.ProtoReflect.Descriptor instead.

func (*PutServer) GetDone 

func (x *PutServer) GetDone() *ObjReply

func (*PutServer) GetMsg 

func (x *PutServer) GetMsg() isPutServer_Msg

func (*PutServer) GetProgress 

func (x *PutServer) GetProgress() *Progress

func (*PutServer) GetReadRequest 

func (x *PutServer) GetReadRequest() *ReadRequest

func (*PutServer) ProtoMessage 

func (*PutServer) ProtoMessage()

func (*PutServer) ProtoReflect 

func (x *PutServer) ProtoReflect() protoreflect.Message

func (*PutServer) Reset 

func (x *PutServer) Reset()

func (*PutServer) String 

func (x *PutServer) String() string

type PutServer_Done 

type PutServer_Done struct {
	Done *ObjReply `protobuf:"bytes,3,opt,name=done,proto3,oneof"`
}

type PutServer_Progress 

type PutServer_Progress struct {
	Progress *Progress `protobuf:"bytes,2,opt,name=progress,proto3,oneof"`
}

type PutServer_ReadRequest 

type PutServer_ReadRequest struct {
	ReadRequest *ReadRequest `protobuf:"bytes,1,opt,name=read_request,json=readRequest,proto3,oneof"`
}

type Range 

type Range struct {
	Start  int64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	Length int64 `protobuf:"varint,2,opt,name=length,proto3" json:"length,omitempty"`
	// contains filtered or unexported fields
}

Range is a byte range; length < 0 means "to the end" (9.0 §1).

func RangeToProto 

func RangeToProto(r ext.Range) *Range

func (*Range) Descriptor deprecated 

func (*Range) Descriptor() ([]byte, []int)

Deprecated: Use Range.ProtoReflect.Descriptor instead.

func (*Range) GetLength 

func (x *Range) GetLength() int64

func (*Range) GetStart 

func (x *Range) GetStart() int64

func (*Range) ProtoMessage 

func (*Range) ProtoMessage()

func (*Range) ProtoReflect 

func (x *Range) ProtoReflect() protoreflect.Message

func (*Range) Reset 

func (x *Range) Reset()

func (*Range) String 

func (x *Range) String() string

type ReadReply 

type ReadReply struct {
	Data  []byte      `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Eof   bool        `protobuf:"varint,2,opt,name=eof,proto3" json:"eof,omitempty"`
	Error *ErrorProto `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

ReadReply answers a ReadRequest with bytes read from the host-held upload source. eof mirrors io.ReaderAt semantics; error terminates the upload.

func (*ReadReply) Descriptor deprecated 

func (*ReadReply) Descriptor() ([]byte, []int)

Deprecated: Use ReadReply.ProtoReflect.Descriptor instead.

func (*ReadReply) GetData 

func (x *ReadReply) GetData() []byte

func (*ReadReply) GetEof 

func (x *ReadReply) GetEof() bool

func (*ReadReply) GetError 

func (x *ReadReply) GetError() *ErrorProto

func (*ReadReply) ProtoMessage 

func (*ReadReply) ProtoMessage()

func (*ReadReply) ProtoReflect 

func (x *ReadReply) ProtoReflect() protoreflect.Message

func (*ReadReply) Reset 

func (x *ReadReply) Reset()

func (*ReadReply) String 

func (x *ReadReply) String() string

type ReadRequest 

type ReadRequest struct {
	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Length int64 `protobuf:"varint,2,opt,name=length,proto3" json:"length,omitempty"`
	// contains filtered or unexported fields
}

ReadRequest asks the host to ReadAt(offset, length) on the upload source.

func (*ReadRequest) Descriptor deprecated 

func (*ReadRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReadRequest.ProtoReflect.Descriptor instead.

func (*ReadRequest) GetLength 

func (x *ReadRequest) GetLength() int64

func (*ReadRequest) GetOffset 

func (x *ReadRequest) GetOffset() int64

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) ProtoReflect 

func (x *ReadRequest) ProtoReflect() protoreflect.Message

func (*ReadRequest) Reset 

func (x *ReadRequest) Reset()

func (*ReadRequest) String 

func (x *ReadRequest) String() string

type RefreshRequest 

type RefreshRequest struct {
	RefreshToken string `protobuf:"bytes,1,opt,name=refresh_token,json=refreshToken,proto3" json:"refresh_token,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshRequest) Descriptor deprecated 

func (*RefreshRequest) Descriptor() ([]byte, []int)

Deprecated: Use RefreshRequest.ProtoReflect.Descriptor instead.

func (*RefreshRequest) GetRefreshToken 

func (x *RefreshRequest) GetRefreshToken() string

func (*RefreshRequest) ProtoMessage 

func (*RefreshRequest) ProtoMessage()

func (*RefreshRequest) ProtoReflect 

func (x *RefreshRequest) ProtoReflect() protoreflect.Message

func (*RefreshRequest) Reset 

func (x *RefreshRequest) Reset()

func (*RefreshRequest) String 

func (x *RefreshRequest) String() string

type RemoveRequest 

type RemoveRequest struct {
	Obj *ObjRef `protobuf:"bytes,1,opt,name=obj,proto3" json:"obj,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveRequest) Descriptor deprecated 

func (*RemoveRequest) Descriptor() ([]byte, []int)

Deprecated: Use RemoveRequest.ProtoReflect.Descriptor instead.

func (*RemoveRequest) GetObj 

func (x *RemoveRequest) GetObj() *ObjRef

func (*RemoveRequest) ProtoMessage 

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) ProtoReflect 

func (x *RemoveRequest) ProtoReflect() protoreflect.Message

func (*RemoveRequest) Reset 

func (x *RemoveRequest) Reset()

func (*RemoveRequest) String 

func (x *RemoveRequest) String() string

type RenameRequest 

type RenameRequest struct {
	Src     *ObjRef `protobuf:"bytes,1,opt,name=src,proto3" json:"src,omitempty"`
	NewName string  `protobuf:"bytes,2,opt,name=new_name,json=newName,proto3" json:"new_name,omitempty"`
	// contains filtered or unexported fields
}

func (*RenameRequest) Descriptor deprecated 

func (*RenameRequest) Descriptor() ([]byte, []int)

Deprecated: Use RenameRequest.ProtoReflect.Descriptor instead.

func (*RenameRequest) GetNewName 

func (x *RenameRequest) GetNewName() string

func (*RenameRequest) GetSrc 

func (x *RenameRequest) GetSrc() *ObjRef

func (*RenameRequest) ProtoMessage 

func (*RenameRequest) ProtoMessage()

func (*RenameRequest) ProtoReflect 

func (x *RenameRequest) ProtoReflect() protoreflect.Message

func (*RenameRequest) Reset 

func (x *RenameRequest) Reset()

func (*RenameRequest) String 

func (x *RenameRequest) String() string

type RouteDecl 

type RouteDecl struct {
	Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Public bool   `protobuf:"varint,2,opt,name=public,proto3" json:"public,omitempty"`
	// contains filtered or unexported fields
}

RouteDecl mirrors ext.RouteDecl.

func (*RouteDecl) Descriptor deprecated 

func (*RouteDecl) Descriptor() ([]byte, []int)

Deprecated: Use RouteDecl.ProtoReflect.Descriptor instead.

func (*RouteDecl) GetPrefix 

func (x *RouteDecl) GetPrefix() string

func (*RouteDecl) GetPublic 

func (x *RouteDecl) GetPublic() bool

func (*RouteDecl) ProtoMessage 

func (*RouteDecl) ProtoMessage()

func (*RouteDecl) ProtoReflect 

func (x *RouteDecl) ProtoReflect() protoreflect.Message

func (*RouteDecl) Reset 

func (x *RouteDecl) Reset()

func (*RouteDecl) String 

func (x *RouteDecl) String() string

type RoutesReply 

type RoutesReply struct {
	Routes []*RouteDecl `protobuf:"bytes,1,rep,name=routes,proto3" json:"routes,omitempty"`
	// contains filtered or unexported fields
}

func (*RoutesReply) Descriptor deprecated 

func (*RoutesReply) Descriptor() ([]byte, []int)

Deprecated: Use RoutesReply.ProtoReflect.Descriptor instead.

func (*RoutesReply) GetRoutes 

func (x *RoutesReply) GetRoutes() []*RouteDecl

func (*RoutesReply) ProtoMessage 

func (*RoutesReply) ProtoMessage()

func (*RoutesReply) ProtoReflect 

func (x *RoutesReply) ProtoReflect() protoreflect.Message

func (*RoutesReply) Reset 

func (x *RoutesReply) Reset()

func (*RoutesReply) String 

func (x *RoutesReply) String() string

type SaveConfigReply 

type SaveConfigReply struct {
	Error *ErrorProto `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*SaveConfigReply) Descriptor deprecated 

func (*SaveConfigReply) Descriptor() ([]byte, []int)

Deprecated: Use SaveConfigReply.ProtoReflect.Descriptor instead.

func (*SaveConfigReply) GetError 

func (x *SaveConfigReply) GetError() *ErrorProto

func (*SaveConfigReply) ProtoMessage 

func (*SaveConfigReply) ProtoMessage()

func (*SaveConfigReply) ProtoReflect 

func (x *SaveConfigReply) ProtoReflect() protoreflect.Message

func (*SaveConfigReply) Reset 

func (x *SaveConfigReply) Reset()

func (*SaveConfigReply) String 

func (x *SaveConfigReply) String() string

type SaveConfigRequest 

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

func (*SaveConfigRequest) Descriptor deprecated 

func (*SaveConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use SaveConfigRequest.ProtoReflect.Descriptor instead.

func (*SaveConfigRequest) GetConfig 

func (x *SaveConfigRequest) GetConfig() []byte

func (*SaveConfigRequest) ProtoMessage 

func (*SaveConfigRequest) ProtoMessage()

func (*SaveConfigRequest) ProtoReflect 

func (x *SaveConfigRequest) ProtoReflect() protoreflect.Message

func (*SaveConfigRequest) Reset 

func (x *SaveConfigRequest) Reset()

func (*SaveConfigRequest) String 

func (x *SaveConfigRequest) String() string

type ScheduleReply 

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

func (*ScheduleReply) Descriptor deprecated 

func (*ScheduleReply) Descriptor() ([]byte, []int)

Deprecated: Use ScheduleReply.ProtoReflect.Descriptor instead.

func (*ScheduleReply) GetSpec 

func (x *ScheduleReply) GetSpec() string

func (*ScheduleReply) ProtoMessage 

func (*ScheduleReply) ProtoMessage()

func (*ScheduleReply) ProtoReflect 

func (x *ScheduleReply) ProtoReflect() protoreflect.Message

func (*ScheduleReply) Reset 

func (x *ScheduleReply) Reset()

func (*ScheduleReply) String 

func (x *ScheduleReply) String() string

type ScheduledJobServiceClient 

type ScheduledJobServiceClient interface {
	// GetManifest is the handshake: the manifest the host validates the plugin
	// against before scheduling it.
	GetManifest(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ManifestReply, error)
	// Schedule returns the job's cadence spec (ext.ScheduledJob.Schedule),
	// parsed host-side by ParseSchedule.
	Schedule(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ScheduleReply, error)
	// Run performs one execution (ext.ScheduledJob.Run). The host calls this
	// synchronously per tick, never overlapping two Runs of the same job.
	Run(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ErrorReply, error)
	// Reverse host bridge (F0/SP6): host serves a HostService on the broker id it
	// passes here; the plugin dials it and delivers the host to Init.
	InitHost(ctx context.Context, in *InitHostRequest, opts ...grpc.CallOption) (*ErrorReply, error)
}

ScheduledJobServiceClient is the client API for ScheduledJobService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

ScheduledJobService mirrors ext.ScheduledJob (W7): a Kind=ScheduledJob plugin declares its cadence and runs a time-driven task under the host's supervision (see ext.ScheduledJob's doc comment — panic-isolated, non-overlapping Run). Mirrors APIRouteService (apiroute.proto) one Kind over, including the reverse-host InitHost bridge (F0/SP6). Unlike APIRoute/Action, both Schedule and Run take no plugin-supplied arguments (Empty) — the host calls Schedule once at scheduler-start to read the cadence and Run once per tick, mirroring ext.ScheduledJob's argument-free methods exactly.

func NewScheduledJobServiceClient 

func NewScheduledJobServiceClient(cc grpc.ClientConnInterface) ScheduledJobServiceClient

type ScheduledJobServiceServer 

type ScheduledJobServiceServer interface {
	// GetManifest is the handshake: the manifest the host validates the plugin
	// against before scheduling it.
	GetManifest(context.Context, *Empty) (*ManifestReply, error)
	// Schedule returns the job's cadence spec (ext.ScheduledJob.Schedule),
	// parsed host-side by ParseSchedule.
	Schedule(context.Context, *Empty) (*ScheduleReply, error)
	// Run performs one execution (ext.ScheduledJob.Run). The host calls this
	// synchronously per tick, never overlapping two Runs of the same job.
	Run(context.Context, *Empty) (*ErrorReply, error)
	// Reverse host bridge (F0/SP6): host serves a HostService on the broker id it
	// passes here; the plugin dials it and delivers the host to Init.
	InitHost(context.Context, *InitHostRequest) (*ErrorReply, error)
	// contains filtered or unexported methods
}

ScheduledJobServiceServer is the server API for ScheduledJobService service. All implementations must embed UnimplementedScheduledJobServiceServer for forward compatibility.

ScheduledJobService mirrors ext.ScheduledJob (W7): a Kind=ScheduledJob plugin declares its cadence and runs a time-driven task under the host's supervision (see ext.ScheduledJob's doc comment — panic-isolated, non-overlapping Run). Mirrors APIRouteService (apiroute.proto) one Kind over, including the reverse-host InitHost bridge (F0/SP6). Unlike APIRoute/Action, both Schedule and Run take no plugin-supplied arguments (Empty) — the host calls Schedule once at scheduler-start to read the cadence and Run once per tick, mirroring ext.ScheduledJob's argument-free methods exactly.

type SecretDeleteRequest 

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

func (*SecretDeleteRequest) Descriptor deprecated 

func (*SecretDeleteRequest) Descriptor() ([]byte, []int)

Deprecated: Use SecretDeleteRequest.ProtoReflect.Descriptor instead.

func (*SecretDeleteRequest) GetKey 

func (x *SecretDeleteRequest) GetKey() string

func (*SecretDeleteRequest) ProtoMessage 

func (*SecretDeleteRequest) ProtoMessage()

func (*SecretDeleteRequest) ProtoReflect 

func (x *SecretDeleteRequest) ProtoReflect() protoreflect.Message

func (*SecretDeleteRequest) Reset 

func (x *SecretDeleteRequest) Reset()

func (*SecretDeleteRequest) String 

func (x *SecretDeleteRequest) String() string

type SecretGetReply 

type SecretGetReply struct {
	Value []byte      `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Found bool        `protobuf:"varint,2,opt,name=found,proto3" json:"found,omitempty"`
	Error *ErrorProto `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*SecretGetReply) Descriptor deprecated 

func (*SecretGetReply) Descriptor() ([]byte, []int)

Deprecated: Use SecretGetReply.ProtoReflect.Descriptor instead.

func (*SecretGetReply) GetError 

func (x *SecretGetReply) GetError() *ErrorProto

func (*SecretGetReply) GetFound 

func (x *SecretGetReply) GetFound() bool

func (*SecretGetReply) GetValue 

func (x *SecretGetReply) GetValue() []byte

func (*SecretGetReply) ProtoMessage 

func (*SecretGetReply) ProtoMessage()

func (*SecretGetReply) ProtoReflect 

func (x *SecretGetReply) ProtoReflect() protoreflect.Message

func (*SecretGetReply) Reset 

func (x *SecretGetReply) Reset()

func (*SecretGetReply) String 

func (x *SecretGetReply) String() string

type SecretGetRequest 

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

func (*SecretGetRequest) Descriptor deprecated 

func (*SecretGetRequest) Descriptor() ([]byte, []int)

Deprecated: Use SecretGetRequest.ProtoReflect.Descriptor instead.

func (*SecretGetRequest) GetKey 

func (x *SecretGetRequest) GetKey() string

func (*SecretGetRequest) ProtoMessage 

func (*SecretGetRequest) ProtoMessage()

func (*SecretGetRequest) ProtoReflect 

func (x *SecretGetRequest) ProtoReflect() protoreflect.Message

func (*SecretGetRequest) Reset 

func (x *SecretGetRequest) Reset()

func (*SecretGetRequest) String 

func (x *SecretGetRequest) String() string

type SecretListReply 

type SecretListReply struct {
	Keys  []string    `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	Error *ErrorProto `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*SecretListReply) Descriptor deprecated 

func (*SecretListReply) Descriptor() ([]byte, []int)

Deprecated: Use SecretListReply.ProtoReflect.Descriptor instead.

func (*SecretListReply) GetError 

func (x *SecretListReply) GetError() *ErrorProto

func (*SecretListReply) GetKeys 

func (x *SecretListReply) GetKeys() []string

func (*SecretListReply) ProtoMessage 

func (*SecretListReply) ProtoMessage()

func (*SecretListReply) ProtoReflect 

func (x *SecretListReply) ProtoReflect() protoreflect.Message

func (*SecretListReply) Reset 

func (x *SecretListReply) Reset()

func (*SecretListReply) String 

func (x *SecretListReply) String() string

type SecretListRequest 

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

func (*SecretListRequest) Descriptor deprecated 

func (*SecretListRequest) Descriptor() ([]byte, []int)

Deprecated: Use SecretListRequest.ProtoReflect.Descriptor instead.

func (*SecretListRequest) GetPrefix 

func (x *SecretListRequest) GetPrefix() string

func (*SecretListRequest) ProtoMessage 

func (*SecretListRequest) ProtoMessage()

func (*SecretListRequest) ProtoReflect 

func (x *SecretListRequest) ProtoReflect() protoreflect.Message

func (*SecretListRequest) Reset 

func (x *SecretListRequest) Reset()

func (*SecretListRequest) String 

func (x *SecretListRequest) String() string

type SecretSetRequest 

type SecretSetRequest struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*SecretSetRequest) Descriptor deprecated 

func (*SecretSetRequest) Descriptor() ([]byte, []int)

Deprecated: Use SecretSetRequest.ProtoReflect.Descriptor instead.

func (*SecretSetRequest) GetKey 

func (x *SecretSetRequest) GetKey() string

func (*SecretSetRequest) GetValue 

func (x *SecretSetRequest) GetValue() []byte

func (*SecretSetRequest) ProtoMessage 

func (*SecretSetRequest) ProtoMessage()

func (*SecretSetRequest) ProtoReflect 

func (x *SecretSetRequest) ProtoReflect() protoreflect.Message

func (*SecretSetRequest) Reset 

func (x *SecretSetRequest) Reset()

func (*SecretSetRequest) String 

func (x *SecretSetRequest) String() string

type SignLinkReply 

type SignLinkReply struct {
	Token string      `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	Error *ErrorProto `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*SignLinkReply) Descriptor deprecated 

func (*SignLinkReply) Descriptor() ([]byte, []int)

Deprecated: Use SignLinkReply.ProtoReflect.Descriptor instead.

func (*SignLinkReply) GetError 

func (x *SignLinkReply) GetError() *ErrorProto

func (*SignLinkReply) GetToken 

func (x *SignLinkReply) GetToken() string

func (*SignLinkReply) ProtoMessage 

func (*SignLinkReply) ProtoMessage()

func (*SignLinkReply) ProtoReflect 

func (x *SignLinkReply) ProtoReflect() protoreflect.Message

func (*SignLinkReply) Reset 

func (x *SignLinkReply) Reset()

func (*SignLinkReply) String 

func (x *SignLinkReply) String() string

type SignLinkRequest 

type SignLinkRequest struct {
	Principal string  `protobuf:"bytes,1,opt,name=principal,proto3" json:"principal,omitempty"`
	Ref       *ObjRef `protobuf:"bytes,2,opt,name=ref,proto3" json:"ref,omitempty"`
	Scope     string  `protobuf:"bytes,3,opt,name=scope,proto3" json:"scope,omitempty"`
	TtlMs     int64   `protobuf:"varint,4,opt,name=ttl_ms,json=ttlMs,proto3" json:"ttl_ms,omitempty"` // 0 means "no expiry" (mirrors ttl<=0 in ext.Signer.SignLink)
	// contains filtered or unexported fields
}

func (*SignLinkRequest) Descriptor deprecated 

func (*SignLinkRequest) Descriptor() ([]byte, []int)

Deprecated: Use SignLinkRequest.ProtoReflect.Descriptor instead.

func (*SignLinkRequest) GetPrincipal 

func (x *SignLinkRequest) GetPrincipal() string

func (*SignLinkRequest) GetRef 

func (x *SignLinkRequest) GetRef() *ObjRef

func (*SignLinkRequest) GetScope 

func (x *SignLinkRequest) GetScope() string

func (*SignLinkRequest) GetTtlMs 

func (x *SignLinkRequest) GetTtlMs() int64

func (*SignLinkRequest) ProtoMessage 

func (*SignLinkRequest) ProtoMessage()

func (*SignLinkRequest) ProtoReflect 

func (x *SignLinkRequest) ProtoReflect() protoreflect.Message

func (*SignLinkRequest) Reset 

func (x *SignLinkRequest) Reset()

func (*SignLinkRequest) String 

func (x *SignLinkRequest) String() string

type SignVerifyLinkReply 

type SignVerifyLinkReply struct {
	Ref   *ObjRef     `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	Scope string      `protobuf:"bytes,2,opt,name=scope,proto3" json:"scope,omitempty"`
	Error *ErrorProto `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*SignVerifyLinkReply) Descriptor deprecated 

func (*SignVerifyLinkReply) Descriptor() ([]byte, []int)

Deprecated: Use SignVerifyLinkReply.ProtoReflect.Descriptor instead.

func (*SignVerifyLinkReply) GetError 

func (x *SignVerifyLinkReply) GetError() *ErrorProto

func (*SignVerifyLinkReply) GetRef 

func (x *SignVerifyLinkReply) GetRef() *ObjRef

func (*SignVerifyLinkReply) GetScope 

func (x *SignVerifyLinkReply) GetScope() string

func (*SignVerifyLinkReply) ProtoMessage 

func (*SignVerifyLinkReply) ProtoMessage()

func (*SignVerifyLinkReply) ProtoReflect 

func (x *SignVerifyLinkReply) ProtoReflect() protoreflect.Message

func (*SignVerifyLinkReply) Reset 

func (x *SignVerifyLinkReply) Reset()

func (*SignVerifyLinkReply) String 

func (x *SignVerifyLinkReply) String() string

type SignVerifyLinkRequest 

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

func (*SignVerifyLinkRequest) Descriptor deprecated 

func (*SignVerifyLinkRequest) Descriptor() ([]byte, []int)

Deprecated: Use SignVerifyLinkRequest.ProtoReflect.Descriptor instead.

func (*SignVerifyLinkRequest) GetToken 

func (x *SignVerifyLinkRequest) GetToken() string

func (*SignVerifyLinkRequest) ProtoMessage 

func (*SignVerifyLinkRequest) ProtoMessage()

func (*SignVerifyLinkRequest) ProtoReflect 

func (x *SignVerifyLinkRequest) ProtoReflect() protoreflect.Message

func (*SignVerifyLinkRequest) Reset 

func (x *SignVerifyLinkRequest) Reset()

func (*SignVerifyLinkRequest) String 

func (x *SignVerifyLinkRequest) String() string

type StatusReply 

type StatusReply struct {
	State       string      `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	Detail      string      `protobuf:"bytes,2,opt,name=detail,proto3" json:"detail,omitempty"`
	MetricsJson []byte      `protobuf:"bytes,3,opt,name=metrics_json,json=metricsJson,proto3" json:"metrics_json,omitempty"`
	Error       *ErrorProto `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusReply) Descriptor deprecated 

func (*StatusReply) Descriptor() ([]byte, []int)

Deprecated: Use StatusReply.ProtoReflect.Descriptor instead.

func (*StatusReply) GetDetail 

func (x *StatusReply) GetDetail() string

func (*StatusReply) GetError 

func (x *StatusReply) GetError() *ErrorProto

func (*StatusReply) GetMetricsJson 

func (x *StatusReply) GetMetricsJson() []byte

func (*StatusReply) GetState 

func (x *StatusReply) GetState() string

func (*StatusReply) ProtoMessage 

func (*StatusReply) ProtoMessage()

func (*StatusReply) ProtoReflect 

func (x *StatusReply) ProtoReflect() protoreflect.Message

func (*StatusReply) Reset 

func (x *StatusReply) Reset()

func (*StatusReply) String 

func (x *StatusReply) String() string

type StoreDeleteRequest 

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

func (*StoreDeleteRequest) Descriptor deprecated 

func (*StoreDeleteRequest) Descriptor() ([]byte, []int)

Deprecated: Use StoreDeleteRequest.ProtoReflect.Descriptor instead.

func (*StoreDeleteRequest) GetKey 

func (x *StoreDeleteRequest) GetKey() string

func (*StoreDeleteRequest) ProtoMessage 

func (*StoreDeleteRequest) ProtoMessage()

func (*StoreDeleteRequest) ProtoReflect 

func (x *StoreDeleteRequest) ProtoReflect() protoreflect.Message

func (*StoreDeleteRequest) Reset 

func (x *StoreDeleteRequest) Reset()

func (*StoreDeleteRequest) String 

func (x *StoreDeleteRequest) String() string

type StoreGetReply 

type StoreGetReply struct {
	Value []byte      `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Found bool        `protobuf:"varint,2,opt,name=found,proto3" json:"found,omitempty"`
	Error *ErrorProto `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreGetReply) Descriptor deprecated 

func (*StoreGetReply) Descriptor() ([]byte, []int)

Deprecated: Use StoreGetReply.ProtoReflect.Descriptor instead.

func (*StoreGetReply) GetError 

func (x *StoreGetReply) GetError() *ErrorProto

func (*StoreGetReply) GetFound 

func (x *StoreGetReply) GetFound() bool

func (*StoreGetReply) GetValue 

func (x *StoreGetReply) GetValue() []byte

func (*StoreGetReply) ProtoMessage 

func (*StoreGetReply) ProtoMessage()

func (*StoreGetReply) ProtoReflect 

func (x *StoreGetReply) ProtoReflect() protoreflect.Message

func (*StoreGetReply) Reset 

func (x *StoreGetReply) Reset()

func (*StoreGetReply) String 

func (x *StoreGetReply) String() string

type StoreGetRequest 

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

func (*StoreGetRequest) Descriptor deprecated 

func (*StoreGetRequest) Descriptor() ([]byte, []int)

Deprecated: Use StoreGetRequest.ProtoReflect.Descriptor instead.

func (*StoreGetRequest) GetKey 

func (x *StoreGetRequest) GetKey() string

func (*StoreGetRequest) ProtoMessage 

func (*StoreGetRequest) ProtoMessage()

func (*StoreGetRequest) ProtoReflect 

func (x *StoreGetRequest) ProtoReflect() protoreflect.Message

func (*StoreGetRequest) Reset 

func (x *StoreGetRequest) Reset()

func (*StoreGetRequest) String 

func (x *StoreGetRequest) String() string

type StoreListReply 

type StoreListReply struct {
	Keys  []string    `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	Error *ErrorProto `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreListReply) Descriptor deprecated 

func (*StoreListReply) Descriptor() ([]byte, []int)

Deprecated: Use StoreListReply.ProtoReflect.Descriptor instead.

func (*StoreListReply) GetError 

func (x *StoreListReply) GetError() *ErrorProto

func (*StoreListReply) GetKeys 

func (x *StoreListReply) GetKeys() []string

func (*StoreListReply) ProtoMessage 

func (*StoreListReply) ProtoMessage()

func (*StoreListReply) ProtoReflect 

func (x *StoreListReply) ProtoReflect() protoreflect.Message

func (*StoreListReply) Reset 

func (x *StoreListReply) Reset()

func (*StoreListReply) String 

func (x *StoreListReply) String() string

type StoreListRequest 

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

func (*StoreListRequest) Descriptor deprecated 

func (*StoreListRequest) Descriptor() ([]byte, []int)

Deprecated: Use StoreListRequest.ProtoReflect.Descriptor instead.

func (*StoreListRequest) GetPrefix 

func (x *StoreListRequest) GetPrefix() string

func (*StoreListRequest) ProtoMessage 

func (*StoreListRequest) ProtoMessage()

func (*StoreListRequest) ProtoReflect 

func (x *StoreListRequest) ProtoReflect() protoreflect.Message

func (*StoreListRequest) Reset 

func (x *StoreListRequest) Reset()

func (*StoreListRequest) String 

func (x *StoreListRequest) String() string

type StoreSetRequest 

type StoreSetRequest struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreSetRequest) Descriptor deprecated 

func (*StoreSetRequest) Descriptor() ([]byte, []int)

Deprecated: Use StoreSetRequest.ProtoReflect.Descriptor instead.

func (*StoreSetRequest) GetKey 

func (x *StoreSetRequest) GetKey() string

func (*StoreSetRequest) GetValue 

func (x *StoreSetRequest) GetValue() []byte

func (*StoreSetRequest) ProtoMessage 

func (*StoreSetRequest) ProtoMessage()

func (*StoreSetRequest) ProtoReflect 

func (x *StoreSetRequest) ProtoReflect() protoreflect.Message

func (*StoreSetRequest) Reset 

func (x *StoreSetRequest) Reset()

func (*StoreSetRequest) String 

func (x *StoreSetRequest) String() string

type TableDeleteRequest 

type TableDeleteRequest struct {
	Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	Id    string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*TableDeleteRequest) Descriptor deprecated 

func (*TableDeleteRequest) Descriptor() ([]byte, []int)

Deprecated: Use TableDeleteRequest.ProtoReflect.Descriptor instead.

func (*TableDeleteRequest) GetId 

func (x *TableDeleteRequest) GetId() string

func (*TableDeleteRequest) GetTable 

func (x *TableDeleteRequest) GetTable() string

func (*TableDeleteRequest) ProtoMessage 

func (*TableDeleteRequest) ProtoMessage()

func (*TableDeleteRequest) ProtoReflect 

func (x *TableDeleteRequest) ProtoReflect() protoreflect.Message

func (*TableDeleteRequest) Reset 

func (x *TableDeleteRequest) Reset()

func (*TableDeleteRequest) String 

func (x *TableDeleteRequest) String() string

type TableGetReply 

type TableGetReply struct {
	Row   []byte      `protobuf:"bytes,1,opt,name=row,proto3" json:"row,omitempty"` // JSON-encoded row
	Found bool        `protobuf:"varint,2,opt,name=found,proto3" json:"found,omitempty"`
	Error *ErrorProto `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*TableGetReply) Descriptor deprecated 

func (*TableGetReply) Descriptor() ([]byte, []int)

Deprecated: Use TableGetReply.ProtoReflect.Descriptor instead.

func (*TableGetReply) GetError 

func (x *TableGetReply) GetError() *ErrorProto

func (*TableGetReply) GetFound 

func (x *TableGetReply) GetFound() bool

func (*TableGetReply) GetRow 

func (x *TableGetReply) GetRow() []byte

func (*TableGetReply) ProtoMessage 

func (*TableGetReply) ProtoMessage()

func (*TableGetReply) ProtoReflect 

func (x *TableGetReply) ProtoReflect() protoreflect.Message

func (*TableGetReply) Reset 

func (x *TableGetReply) Reset()

func (*TableGetReply) String 

func (x *TableGetReply) String() string

type TableGetRequest 

type TableGetRequest struct {
	Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	Id    string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*TableGetRequest) Descriptor deprecated 

func (*TableGetRequest) Descriptor() ([]byte, []int)

Deprecated: Use TableGetRequest.ProtoReflect.Descriptor instead.

func (*TableGetRequest) GetId 

func (x *TableGetRequest) GetId() string

func (*TableGetRequest) GetTable 

func (x *TableGetRequest) GetTable() string

func (*TableGetRequest) ProtoMessage 

func (*TableGetRequest) ProtoMessage()

func (*TableGetRequest) ProtoReflect 

func (x *TableGetRequest) ProtoReflect() protoreflect.Message

func (*TableGetRequest) Reset 

func (x *TableGetRequest) Reset()

func (*TableGetRequest) String 

func (x *TableGetRequest) String() string

type TableInsertReply 

type TableInsertReply struct {
	Id    string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // host-assigned primary key
	Error *ErrorProto `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*TableInsertReply) Descriptor deprecated 

func (*TableInsertReply) Descriptor() ([]byte, []int)

Deprecated: Use TableInsertReply.ProtoReflect.Descriptor instead.

func (*TableInsertReply) GetError 

func (x *TableInsertReply) GetError() *ErrorProto

func (*TableInsertReply) GetId 

func (x *TableInsertReply) GetId() string

func (*TableInsertReply) ProtoMessage 

func (*TableInsertReply) ProtoMessage()

func (*TableInsertReply) ProtoReflect 

func (x *TableInsertReply) ProtoReflect() protoreflect.Message

func (*TableInsertReply) Reset 

func (x *TableInsertReply) Reset()

func (*TableInsertReply) String 

func (x *TableInsertReply) String() string

type TableInsertRequest 

type TableInsertRequest struct {
	Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	Row   []byte `protobuf:"bytes,2,opt,name=row,proto3" json:"row,omitempty"` // JSON-encoded row
	// contains filtered or unexported fields
}

func (*TableInsertRequest) Descriptor deprecated 

func (*TableInsertRequest) Descriptor() ([]byte, []int)

Deprecated: Use TableInsertRequest.ProtoReflect.Descriptor instead.

func (*TableInsertRequest) GetRow 

func (x *TableInsertRequest) GetRow() []byte

func (*TableInsertRequest) GetTable 

func (x *TableInsertRequest) GetTable() string

func (*TableInsertRequest) ProtoMessage 

func (*TableInsertRequest) ProtoMessage()

func (*TableInsertRequest) ProtoReflect 

func (x *TableInsertRequest) ProtoReflect() protoreflect.Message

func (*TableInsertRequest) Reset 

func (x *TableInsertRequest) Reset()

func (*TableInsertRequest) String 

func (x *TableInsertRequest) String() string

type TableListReply 

type TableListReply struct {
	Rows  []*TableRowProto `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
	Error *ErrorProto      `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*TableListReply) Descriptor deprecated 

func (*TableListReply) Descriptor() ([]byte, []int)

Deprecated: Use TableListReply.ProtoReflect.Descriptor instead.

func (*TableListReply) GetError 

func (x *TableListReply) GetError() *ErrorProto

func (*TableListReply) GetRows 

func (x *TableListReply) GetRows() []*TableRowProto

func (*TableListReply) ProtoMessage 

func (*TableListReply) ProtoMessage()

func (*TableListReply) ProtoReflect 

func (x *TableListReply) ProtoReflect() protoreflect.Message

func (*TableListReply) Reset 

func (x *TableListReply) Reset()

func (*TableListReply) String 

func (x *TableListReply) String() string

type TableListRequest 

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

func (*TableListRequest) Descriptor deprecated 

func (*TableListRequest) Descriptor() ([]byte, []int)

Deprecated: Use TableListRequest.ProtoReflect.Descriptor instead.

func (*TableListRequest) GetTable 

func (x *TableListRequest) GetTable() string

func (*TableListRequest) ProtoMessage 

func (*TableListRequest) ProtoMessage()

func (*TableListRequest) ProtoReflect 

func (x *TableListRequest) ProtoReflect() protoreflect.Message

func (*TableListRequest) Reset 

func (x *TableListRequest) Reset()

func (*TableListRequest) String 

func (x *TableListRequest) String() string

type TableRowProto 

type TableRowProto struct {
	Id  string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Row []byte `protobuf:"bytes,2,opt,name=row,proto3" json:"row,omitempty"`
	// contains filtered or unexported fields
}

TableRowProto pairs a row's primary key with its JSON-encoded value.

func (*TableRowProto) Descriptor deprecated 

func (*TableRowProto) Descriptor() ([]byte, []int)

Deprecated: Use TableRowProto.ProtoReflect.Descriptor instead.

func (*TableRowProto) GetId 

func (x *TableRowProto) GetId() string

func (*TableRowProto) GetRow 

func (x *TableRowProto) GetRow() []byte

func (*TableRowProto) ProtoMessage 

func (*TableRowProto) ProtoMessage()

func (*TableRowProto) ProtoReflect 

func (x *TableRowProto) ProtoReflect() protoreflect.Message

func (*TableRowProto) Reset 

func (x *TableRowProto) Reset()

func (*TableRowProto) String 

func (x *TableRowProto) String() string

type TableUpdateRequest 

type TableUpdateRequest struct {
	Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	Id    string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Row   []byte `protobuf:"bytes,3,opt,name=row,proto3" json:"row,omitempty"` // JSON-encoded replacement row
	// contains filtered or unexported fields
}

func (*TableUpdateRequest) Descriptor deprecated 

func (*TableUpdateRequest) Descriptor() ([]byte, []int)

Deprecated: Use TableUpdateRequest.ProtoReflect.Descriptor instead.

func (*TableUpdateRequest) GetId 

func (x *TableUpdateRequest) GetId() string

func (*TableUpdateRequest) GetRow 

func (x *TableUpdateRequest) GetRow() []byte

func (*TableUpdateRequest) GetTable 

func (x *TableUpdateRequest) GetTable() string

func (*TableUpdateRequest) ProtoMessage 

func (*TableUpdateRequest) ProtoMessage()

func (*TableUpdateRequest) ProtoReflect 

func (x *TableUpdateRequest) ProtoReflect() protoreflect.Message

func (*TableUpdateRequest) Reset 

func (x *TableUpdateRequest) Reset()

func (*TableUpdateRequest) String 

func (x *TableUpdateRequest) String() string

type Token 

type Token struct {
	AccessToken  string `protobuf:"bytes,1,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"`
	RefreshToken string `protobuf:"bytes,2,opt,name=refresh_token,json=refreshToken,proto3" json:"refresh_token,omitempty"`
	ExpiresIn    int64  `protobuf:"varint,3,opt,name=expires_in,json=expiresIn,proto3" json:"expires_in,omitempty"`
	TokenType    string `protobuf:"bytes,4,opt,name=token_type,json=tokenType,proto3" json:"token_type,omitempty"`
	RawJson      []byte `protobuf:"bytes,5,opt,name=raw_json,json=rawJson,proto3" json:"raw_json,omitempty"`
	// contains filtered or unexported fields
}

Token mirrors ext.Token. raw_json is the provider-specific map[string]any (ext.Token.Raw) marshaled as JSON, round-tripped verbatim.

func TokenToProto 

func TokenToProto(t ext.Token) *Token

TokenToProto encodes an ext.Token. Raw (map[string]any) is carried as json.Marshal'd bytes (raw_json) — same "it's already a JSON contract" rationale as ManifestReply.manifest_json.

func (*Token) Descriptor deprecated 

func (*Token) Descriptor() ([]byte, []int)

Deprecated: Use Token.ProtoReflect.Descriptor instead.

func (*Token) GetAccessToken 

func (x *Token) GetAccessToken() string

func (*Token) GetExpiresIn 

func (x *Token) GetExpiresIn() int64

func (*Token) GetRawJson 

func (x *Token) GetRawJson() []byte

func (*Token) GetRefreshToken 

func (x *Token) GetRefreshToken() string

func (*Token) GetTokenType 

func (x *Token) GetTokenType() string

func (*Token) ProtoMessage 

func (*Token) ProtoMessage()

func (*Token) ProtoReflect 

func (x *Token) ProtoReflect() protoreflect.Message

func (*Token) Reset 

func (x *Token) Reset()

func (*Token) String 

func (x *Token) String() string

type TokenReply 

type TokenReply struct {
	Token *Token      `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	Error *ErrorProto `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*TokenReply) Descriptor deprecated 

func (*TokenReply) Descriptor() ([]byte, []int)

Deprecated: Use TokenReply.ProtoReflect.Descriptor instead.

func (*TokenReply) GetError 

func (x *TokenReply) GetError() *ErrorProto

func (*TokenReply) GetToken 

func (x *TokenReply) GetToken() *Token

func (*TokenReply) ProtoMessage 

func (*TokenReply) ProtoMessage()

func (*TokenReply) ProtoReflect 

func (x *TokenReply) ProtoReflect() protoreflect.Message

func (*TokenReply) Reset 

func (x *TokenReply) Reset()

func (*TokenReply) String 

func (x *TokenReply) String() string

type TryRapidUploadReply 

type TryRapidUploadReply struct {
	Obj   *Obj        `protobuf:"bytes,1,opt,name=obj,proto3" json:"obj,omitempty"`
	Hit   bool        `protobuf:"varint,2,opt,name=hit,proto3" json:"hit,omitempty"`
	Error *ErrorProto `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

TryRapidUploadReply: hit=false + error=nil 是合法「未命中」状态, 不能复用 ObjReply。

func (*TryRapidUploadReply) Descriptor deprecated 

func (*TryRapidUploadReply) Descriptor() ([]byte, []int)

Deprecated: Use TryRapidUploadReply.ProtoReflect.Descriptor instead.

func (*TryRapidUploadReply) GetError 

func (x *TryRapidUploadReply) GetError() *ErrorProto

func (*TryRapidUploadReply) GetHit 

func (x *TryRapidUploadReply) GetHit() bool

func (*TryRapidUploadReply) GetObj 

func (x *TryRapidUploadReply) GetObj() *Obj

func (*TryRapidUploadReply) ProtoMessage 

func (*TryRapidUploadReply) ProtoMessage()

func (*TryRapidUploadReply) ProtoReflect 

func (x *TryRapidUploadReply) ProtoReflect() protoreflect.Message

func (*TryRapidUploadReply) Reset 

func (x *TryRapidUploadReply) Reset()

func (*TryRapidUploadReply) String 

func (x *TryRapidUploadReply) String() string

type TryRapidUploadRequest 

type TryRapidUploadRequest struct {
	DstDir *ObjRef           `protobuf:"bytes,1,opt,name=dst_dir,json=dstDir,proto3" json:"dst_dir,omitempty"`
	Name   string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Size   int64             `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	Hashes map[string]string `` // keys: "md5"/"sha1"/"sha256"
	/* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TryRapidUploadRequest) Descriptor deprecated 

func (*TryRapidUploadRequest) Descriptor() ([]byte, []int)

Deprecated: Use TryRapidUploadRequest.ProtoReflect.Descriptor instead.

func (*TryRapidUploadRequest) GetDstDir 

func (x *TryRapidUploadRequest) GetDstDir() *ObjRef

func (*TryRapidUploadRequest) GetHashes 

func (x *TryRapidUploadRequest) GetHashes() map[string]string

func (*TryRapidUploadRequest) GetName 

func (x *TryRapidUploadRequest) GetName() string

func (*TryRapidUploadRequest) GetSize 

func (x *TryRapidUploadRequest) GetSize() int64

func (*TryRapidUploadRequest) ProtoMessage 

func (*TryRapidUploadRequest) ProtoMessage()

func (*TryRapidUploadRequest) ProtoReflect 

func (x *TryRapidUploadRequest) ProtoReflect() protoreflect.Message

func (*TryRapidUploadRequest) Reset 

func (x *TryRapidUploadRequest) Reset()

func (*TryRapidUploadRequest) String 

func (x *TryRapidUploadRequest) String() string

type UnimplementedAPIRouteServiceServer 

type UnimplementedAPIRouteServiceServer struct{}

UnimplementedAPIRouteServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedAPIRouteServiceServer) GetManifest 

func (UnimplementedAPIRouteServiceServer) GetManifest(context.Context, *Empty) (*ManifestReply, error)

func (UnimplementedAPIRouteServiceServer) Handle 

func (UnimplementedAPIRouteServiceServer) Handle(context.Context, *HTTPDoRequest) (*HTTPDoReply, error)

func (UnimplementedAPIRouteServiceServer) InitHost 

func (UnimplementedAPIRouteServiceServer) InitHost(context.Context, *InitHostRequest) (*ErrorReply, error)

func (UnimplementedAPIRouteServiceServer) Routes 

func (UnimplementedAPIRouteServiceServer) Routes(context.Context, *Empty) (*RoutesReply, error)

type UnimplementedAccessProtocolServiceServer 

type UnimplementedAccessProtocolServiceServer struct{}

UnimplementedAccessProtocolServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedAccessProtocolServiceServer) GetManifest 

func (UnimplementedAccessProtocolServiceServer) GetManifest(context.Context, *Empty) (*ManifestReply, error)

func (UnimplementedAccessProtocolServiceServer) InitHost 

func (UnimplementedAccessProtocolServiceServer) InitHost(context.Context, *InitHostRequest) (*ErrorReply, error)

func (UnimplementedAccessProtocolServiceServer) ProtocolInfo 

func (UnimplementedAccessProtocolServiceServer) ProtocolInfo(context.Context, *Empty) (*ProtocolInfoReply, error)

func (UnimplementedAccessProtocolServiceServer) ServeHTTP 

func (UnimplementedAccessProtocolServiceServer) ServeHTTP(context.Context, *HTTPDoRequest) (*HTTPDoReply, error)

type UnimplementedActionServiceServer 

type UnimplementedActionServiceServer struct{}

UnimplementedActionServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedActionServiceServer) GetManifest 

func (UnimplementedActionServiceServer) GetManifest(context.Context, *Empty) (*ManifestReply, error)

func (UnimplementedActionServiceServer) InitHost 

func (UnimplementedActionServiceServer) InitHost(context.Context, *InitHostRequest) (*ErrorReply, error)

func (UnimplementedActionServiceServer) Invoke 

func (UnimplementedActionServiceServer) Invoke(context.Context, *InvokeRequest) (*InvokeReply, error)

type UnimplementedAuthNMethodServiceServer 

type UnimplementedAuthNMethodServiceServer struct{}

UnimplementedAuthNMethodServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedAuthNMethodServiceServer) Begin 

func (UnimplementedAuthNMethodServiceServer) Begin(context.Context, *BeginRequest) (*BeginReply, error)

func (UnimplementedAuthNMethodServiceServer) Finish 

func (UnimplementedAuthNMethodServiceServer) Finish(context.Context, *FinishRequest) (*FinishReply, error)

func (UnimplementedAuthNMethodServiceServer) GetManifest 

func (UnimplementedAuthNMethodServiceServer) GetManifest(context.Context, *Empty) (*ManifestReply, error)

func (UnimplementedAuthNMethodServiceServer) InitHost 

func (UnimplementedAuthNMethodServiceServer) InitHost(context.Context, *InitHostRequest) (*ErrorReply, error)

func (UnimplementedAuthNMethodServiceServer) MethodInfo 

func (UnimplementedAuthNMethodServiceServer) MethodInfo(context.Context, *Empty) (*MethodInfoReply, error)

type UnimplementedAuthProviderServiceServer 

type UnimplementedAuthProviderServiceServer struct{}

UnimplementedAuthProviderServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedAuthProviderServiceServer) AuthURL 

func (UnimplementedAuthProviderServiceServer) AuthURL(context.Context, *AuthURLRequest) (*AuthURLReply, error)

func (UnimplementedAuthProviderServiceServer) Exchange 

func (UnimplementedAuthProviderServiceServer) Exchange(context.Context, *ExchangeRequest) (*TokenReply, error)

func (UnimplementedAuthProviderServiceServer) GetManifest 

func (UnimplementedAuthProviderServiceServer) GetManifest(context.Context, *Empty) (*ManifestReply, error)

func (UnimplementedAuthProviderServiceServer) InitHost 

func (UnimplementedAuthProviderServiceServer) InitHost(context.Context, *InitHostRequest) (*ErrorReply, error)

func (UnimplementedAuthProviderServiceServer) Refresh 

func (UnimplementedAuthProviderServiceServer) Refresh(context.Context, *RefreshRequest) (*TokenReply, error)

type UnimplementedBackgroundServiceServiceServer 

type UnimplementedBackgroundServiceServiceServer struct{}

UnimplementedBackgroundServiceServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedBackgroundServiceServiceServer) GetManifest 

func (UnimplementedBackgroundServiceServiceServer) GetManifest(context.Context, *Empty) (*ManifestReply, error)

func (UnimplementedBackgroundServiceServiceServer) InitHost 

func (UnimplementedBackgroundServiceServiceServer) InitHost(context.Context, *InitHostRequest) (*ErrorReply, error)

func (UnimplementedBackgroundServiceServiceServer) Start 

func (UnimplementedBackgroundServiceServiceServer) Start(context.Context, *Empty) (*ErrorReply, error)

func (UnimplementedBackgroundServiceServiceServer) Status 

func (UnimplementedBackgroundServiceServiceServer) Status(context.Context, *Empty) (*StatusReply, error)

func (UnimplementedBackgroundServiceServiceServer) Stop 

func (UnimplementedBackgroundServiceServiceServer) Stop(context.Context, *Empty) (*ErrorReply, error)

type UnimplementedDriverServiceServer 

type UnimplementedDriverServiceServer struct{}

UnimplementedDriverServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedDriverServiceServer) Copy 

func (UnimplementedDriverServiceServer) Copy(context.Context, *CopyRequest) (*ObjReply, error)

func (UnimplementedDriverServiceServer) DropInstance 

func (UnimplementedDriverServiceServer) DropInstance(context.Context, *DropInstanceRequest) (*ErrorReply, error)

func (UnimplementedDriverServiceServer) Get 

func (UnimplementedDriverServiceServer) Get(context.Context, *GetRequest) (*ObjReply, error)

func (UnimplementedDriverServiceServer) GetManifest 

func (UnimplementedDriverServiceServer) GetManifest(context.Context, *Empty) (*ManifestReply, error)

func (UnimplementedDriverServiceServer) InitHost 

func (UnimplementedDriverServiceServer) InitHost(context.Context, *InitHostRequest) (*ErrorReply, error)
func (UnimplementedDriverServiceServer) Link(context.Context, *LinkRequest) (*LinkReply, error)

func (UnimplementedDriverServiceServer) List 

func (UnimplementedDriverServiceServer) List(context.Context, *ListRequest) (*ListReply, error)

func (UnimplementedDriverServiceServer) MakeDir 

func (UnimplementedDriverServiceServer) MakeDir(context.Context, *MakeDirRequest) (*ObjReply, error)

func (UnimplementedDriverServiceServer) Move 

func (UnimplementedDriverServiceServer) Move(context.Context, *MoveRequest) (*ObjReply, error)

func (UnimplementedDriverServiceServer) NewInstance 

func (UnimplementedDriverServiceServer) NewInstance(context.Context, *NewInstanceRequest) (*ErrorReply, error)

func (UnimplementedDriverServiceServer) OpenRange 

func (UnimplementedDriverServiceServer) OpenRange(*OpenRangeRequest, grpc.ServerStreamingServer[Chunk]) error

func (UnimplementedDriverServiceServer) Other 

func (UnimplementedDriverServiceServer) Other(context.Context, *OtherRequest) (*OtherReply, error)

func (UnimplementedDriverServiceServer) Put 

func (UnimplementedDriverServiceServer) Put(grpc.BidiStreamingServer[PutClient, PutServer]) error

func (UnimplementedDriverServiceServer) Remove 

func (UnimplementedDriverServiceServer) Remove(context.Context, *RemoveRequest) (*ErrorReply, error)

func (UnimplementedDriverServiceServer) Rename 

func (UnimplementedDriverServiceServer) Rename(context.Context, *RenameRequest) (*ObjReply, error)

func (UnimplementedDriverServiceServer) TryRapidUpload 

func (UnimplementedDriverServiceServer) TryRapidUpload(context.Context, *TryRapidUploadRequest) (*TryRapidUploadReply, error)

type UnimplementedEventHookServiceServer 

type UnimplementedEventHookServiceServer struct{}

UnimplementedEventHookServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedEventHookServiceServer) GetManifest 

func (UnimplementedEventHookServiceServer) GetManifest(context.Context, *Empty) (*ManifestReply, error)

func (UnimplementedEventHookServiceServer) InitHost 

func (UnimplementedEventHookServiceServer) InitHost(context.Context, *InitHostRequest) (*ErrorReply, error)

func (UnimplementedEventHookServiceServer) OnEvent 

func (UnimplementedEventHookServiceServer) OnEvent(context.Context, *EventProto) (*ErrorReply, error)

type UnimplementedFileDecoratorServiceServer 

type UnimplementedFileDecoratorServiceServer struct{}

UnimplementedFileDecoratorServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedFileDecoratorServiceServer) Decorate 

func (UnimplementedFileDecoratorServiceServer) Decorate(context.Context, *DecorateRequest) (*DecorateReply, error)

func (UnimplementedFileDecoratorServiceServer) GetManifest 

func (UnimplementedFileDecoratorServiceServer) GetManifest(context.Context, *Empty) (*ManifestReply, error)

func (UnimplementedFileDecoratorServiceServer) InitHost 

func (UnimplementedFileDecoratorServiceServer) InitHost(context.Context, *InitHostRequest) (*ErrorReply, error)

type UnimplementedHostCapProbeServiceServer 

type UnimplementedHostCapProbeServiceServer struct{}

UnimplementedHostCapProbeServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedHostCapProbeServiceServer) Exercise 

func (UnimplementedHostCapProbeServiceServer) Exercise(context.Context, *ExerciseRequest) (*ExerciseReply, error)

func (UnimplementedHostCapProbeServiceServer) GetManifest 

func (UnimplementedHostCapProbeServiceServer) GetManifest(context.Context, *Empty) (*ManifestReply, error)

type UnimplementedHostServiceServer 

type UnimplementedHostServiceServer struct{}

UnimplementedHostServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedHostServiceServer) AuthLogin 

func (UnimplementedHostServiceServer) AuthLogin(context.Context, *AuthLoginRequest) (*PrincipalReply, error)

func (UnimplementedHostServiceServer) AuthVerifyAppPassword 

func (UnimplementedHostServiceServer) AuthVerifyAppPassword(context.Context, *AuthVerifyAppPasswordRequest) (*PrincipalReply, error)

func (UnimplementedHostServiceServer) AuthVerifyToken 

func (UnimplementedHostServiceServer) AuthVerifyToken(context.Context, *AuthVerifyTokenRequest) (*PrincipalReply, error)

func (UnimplementedHostServiceServer) Capabilities 

func (UnimplementedHostServiceServer) Capabilities(context.Context, *CapabilitiesRequest) (*CapabilitiesReply, error)

func (UnimplementedHostServiceServer) FSCopy 

func (UnimplementedHostServiceServer) FSCopy(context.Context, *FSCopyRequest) (*ErrorReply, error)

func (UnimplementedHostServiceServer) FSGet 

func (UnimplementedHostServiceServer) FSGet(context.Context, *FSGetRequest) (*ObjReply, error)
func (UnimplementedHostServiceServer) FSLink(context.Context, *FSLinkRequest) (*LinkReply, error)

func (UnimplementedHostServiceServer) FSList 

func (UnimplementedHostServiceServer) FSList(context.Context, *FSListRequest) (*ListReply, error)

func (UnimplementedHostServiceServer) FSMkdir 

func (UnimplementedHostServiceServer) FSMkdir(context.Context, *FSMkdirRequest) (*ObjReply, error)

func (UnimplementedHostServiceServer) FSMove 

func (UnimplementedHostServiceServer) FSMove(context.Context, *FSMoveRequest) (*ErrorReply, error)

func (UnimplementedHostServiceServer) FSPut 

func (UnimplementedHostServiceServer) FSPut(grpc.ClientStreamingServer[FSPutClient, FSPutReply]) error

func (UnimplementedHostServiceServer) FSRemove 

func (UnimplementedHostServiceServer) FSRemove(context.Context, *FSRemoveRequest) (*ErrorReply, error)

func (UnimplementedHostServiceServer) FSRename 

func (UnimplementedHostServiceServer) FSRename(context.Context, *FSRenameRequest) (*ErrorReply, error)

func (UnimplementedHostServiceServer) FSResolve 

func (UnimplementedHostServiceServer) FSResolve(context.Context, *FSResolveRequest) (*FSResolveReply, error)

func (UnimplementedHostServiceServer) HTTPDo 

func (UnimplementedHostServiceServer) HTTPDo(context.Context, *HTTPDoRequest) (*HTTPDoReply, error)

func (UnimplementedHostServiceServer) LoadConfig 

func (UnimplementedHostServiceServer) LoadConfig(context.Context, *LoadConfigRequest) (*LoadConfigReply, error)

func (UnimplementedHostServiceServer) SaveConfig 

func (UnimplementedHostServiceServer) SaveConfig(context.Context, *SaveConfigRequest) (*SaveConfigReply, error)

func (UnimplementedHostServiceServer) SecretDelete 

func (UnimplementedHostServiceServer) SecretDelete(context.Context, *SecretDeleteRequest) (*ErrorReply, error)

func (UnimplementedHostServiceServer) SecretGet 

func (UnimplementedHostServiceServer) SecretGet(context.Context, *SecretGetRequest) (*SecretGetReply, error)

func (UnimplementedHostServiceServer) SecretList 

func (UnimplementedHostServiceServer) SecretList(context.Context, *SecretListRequest) (*SecretListReply, error)

func (UnimplementedHostServiceServer) SecretSet 

func (UnimplementedHostServiceServer) SecretSet(context.Context, *SecretSetRequest) (*ErrorReply, error)
func (UnimplementedHostServiceServer) SignLink(context.Context, *SignLinkRequest) (*SignLinkReply, error)
func (UnimplementedHostServiceServer) SignVerifyLink(context.Context, *SignVerifyLinkRequest) (*SignVerifyLinkReply, error)

func (UnimplementedHostServiceServer) StoreDelete 

func (UnimplementedHostServiceServer) StoreDelete(context.Context, *StoreDeleteRequest) (*ErrorReply, error)

func (UnimplementedHostServiceServer) StoreGet 

func (UnimplementedHostServiceServer) StoreGet(context.Context, *StoreGetRequest) (*StoreGetReply, error)

func (UnimplementedHostServiceServer) StoreList 

func (UnimplementedHostServiceServer) StoreList(context.Context, *StoreListRequest) (*StoreListReply, error)

func (UnimplementedHostServiceServer) StoreSet 

func (UnimplementedHostServiceServer) StoreSet(context.Context, *StoreSetRequest) (*ErrorReply, error)

func (UnimplementedHostServiceServer) TableDelete 

func (UnimplementedHostServiceServer) TableDelete(context.Context, *TableDeleteRequest) (*ErrorReply, error)

func (UnimplementedHostServiceServer) TableGet 

func (UnimplementedHostServiceServer) TableGet(context.Context, *TableGetRequest) (*TableGetReply, error)

func (UnimplementedHostServiceServer) TableInsert 

func (UnimplementedHostServiceServer) TableInsert(context.Context, *TableInsertRequest) (*TableInsertReply, error)

func (UnimplementedHostServiceServer) TableList 

func (UnimplementedHostServiceServer) TableList(context.Context, *TableListRequest) (*TableListReply, error)

func (UnimplementedHostServiceServer) TableUpdate 

func (UnimplementedHostServiceServer) TableUpdate(context.Context, *TableUpdateRequest) (*ErrorReply, error)

type UnimplementedNotificationServiceServer 

type UnimplementedNotificationServiceServer struct{}

UnimplementedNotificationServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedNotificationServiceServer) GetManifest 

func (UnimplementedNotificationServiceServer) GetManifest(context.Context, *Empty) (*ManifestReply, error)

func (UnimplementedNotificationServiceServer) InitHost 

func (UnimplementedNotificationServiceServer) InitHost(context.Context, *InitHostRequest) (*ErrorReply, error)

func (UnimplementedNotificationServiceServer) Notify 

func (UnimplementedNotificationServiceServer) Notify(context.Context, *NoticeProto) (*ErrorReply, error)

type UnimplementedScheduledJobServiceServer 

type UnimplementedScheduledJobServiceServer struct{}

UnimplementedScheduledJobServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedScheduledJobServiceServer) GetManifest 

func (UnimplementedScheduledJobServiceServer) GetManifest(context.Context, *Empty) (*ManifestReply, error)

func (UnimplementedScheduledJobServiceServer) InitHost 

func (UnimplementedScheduledJobServiceServer) InitHost(context.Context, *InitHostRequest) (*ErrorReply, error)

func (UnimplementedScheduledJobServiceServer) Run 

func (UnimplementedScheduledJobServiceServer) Run(context.Context, *Empty) (*ErrorReply, error)

func (UnimplementedScheduledJobServiceServer) Schedule 

func (UnimplementedScheduledJobServiceServer) Schedule(context.Context, *Empty) (*ScheduleReply, error)

type UnsafeAPIRouteServiceServer 

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

UnsafeAPIRouteServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to APIRouteServiceServer will result in compilation errors.

type UnsafeAccessProtocolServiceServer 

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

UnsafeAccessProtocolServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AccessProtocolServiceServer will result in compilation errors.

type UnsafeActionServiceServer 

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

UnsafeActionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ActionServiceServer will result in compilation errors.

type UnsafeAuthNMethodServiceServer 

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

UnsafeAuthNMethodServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AuthNMethodServiceServer will result in compilation errors.

type UnsafeAuthProviderServiceServer 

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

UnsafeAuthProviderServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AuthProviderServiceServer will result in compilation errors.

type UnsafeBackgroundServiceServiceServer 

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

UnsafeBackgroundServiceServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BackgroundServiceServiceServer will result in compilation errors.

type UnsafeDriverServiceServer 

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

UnsafeDriverServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DriverServiceServer will result in compilation errors.

type UnsafeEventHookServiceServer 

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

UnsafeEventHookServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EventHookServiceServer will result in compilation errors.

type UnsafeFileDecoratorServiceServer 

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

UnsafeFileDecoratorServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FileDecoratorServiceServer will result in compilation errors.

type UnsafeHostCapProbeServiceServer 

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

UnsafeHostCapProbeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HostCapProbeServiceServer will result in compilation errors.

type UnsafeHostServiceServer 

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

UnsafeHostServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HostServiceServer will result in compilation errors.

type UnsafeNotificationServiceServer 

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

UnsafeNotificationServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NotificationServiceServer will result in compilation errors.

type UnsafeScheduledJobServiceServer 

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

UnsafeScheduledJobServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ScheduledJobServiceServer will result in compilation errors.

type UploadInfo 

type UploadInfo struct {
	Name     string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Size     int64             `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Mimetype string            `protobuf:"bytes,3,opt,name=mimetype,proto3" json:"mimetype,omitempty"`
	Hashes   map[string]string `` /* 139-byte string literal not displayed */
	Exist    *Obj              `protobuf:"bytes,5,opt,name=exist,proto3" json:"exist,omitempty"`
	// contains filtered or unexported fields
}

UploadInfo mirrors ext.UploadInfo (9.0 §2).

func UploadInfoToProto 

func UploadInfoToProto(i ext.UploadInfo) *UploadInfo

func (*UploadInfo) Descriptor deprecated 

func (*UploadInfo) Descriptor() ([]byte, []int)

Deprecated: Use UploadInfo.ProtoReflect.Descriptor instead.

func (*UploadInfo) GetExist 

func (x *UploadInfo) GetExist() *Obj

func (*UploadInfo) GetHashes 

func (x *UploadInfo) GetHashes() map[string]string

func (*UploadInfo) GetMimetype 

func (x *UploadInfo) GetMimetype() string

func (*UploadInfo) GetName 

func (x *UploadInfo) GetName() string

func (*UploadInfo) GetSize 

func (x *UploadInfo) GetSize() int64

func (*UploadInfo) ProtoMessage 

func (*UploadInfo) ProtoMessage()

func (*UploadInfo) ProtoReflect 

func (x *UploadInfo) ProtoReflect() protoreflect.Message

func (*UploadInfo) Reset 

func (x *UploadInfo) Reset()

func (*UploadInfo) String 

func (x *UploadInfo) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.