service

package

v0.4.6 Latest Latest Go to latest Published: Sep 8, 2026 License: MPL-2.0 Imports: 23 Imported by: 0

Documentation ¶

Rendered for

Index ¶

Variables
func IsInternalPath(path string) bool
type KeibidropServiceImpl

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrGRPCNotMounted         = status.Error(codes.FailedPrecondition, "filesystem not mounted")
	ErrGRPCInvalidArgument    = status.Error(codes.InvalidArgument, "invalid argument")
	ErrGRPCFailedPrecondition = status.Error(codes.FailedPrecondition, "failed precondition")
	ErrGRPCAlreadyExists      = status.Error(codes.AlreadyExists, "already exists")
	ErrGRPCNotFound           = status.Error(codes.NotFound, "notFound")
	ErrGRPCReadOnlyShare      = status.Error(codes.PermissionDenied, "share is read-only")
	ErrGRPCUnsafePath         = status.Error(codes.InvalidArgument, "path escapes the save root")
)

Functions ¶

func IsInternalPath ¶ added in v0.4.1

func IsInternalPath(path string) bool

IsInternalPath reports whether the path names an internal file that must never sync: FUSE hidden renames, macOS metadata, download bitmap sidecars.

Types ¶

type KeibidropServiceImpl ¶

type KeibidropServiceImpl struct {
	bindings.UnimplementedKeibiServiceServer
	Session      *session.Session
	Logger       *slog.Logger
	SyncTracker  *synctracker.SyncTracker
	OnEvent      func(string)
	OnDisconnect func() // Called (in goroutine) when peer sends DISCONNECT; cancels context to trigger cleanup.

	// ShareReadOnly rejects every inbound mutation (add/edit/remove/rename,
	// file or dir) before it touches disk or the tracker. The origin-side
	// guarantee behind the read_only share mode; DISCONNECT still passes.
	ShareReadOnly bool
	// contains filtered or unexported fields
}

func (*KeibidropServiceImpl) BatchNotify ¶

func (kd *KeibidropServiceImpl) BatchNotify(ctx context.Context, req *bindings.BatchNotifyRequest) (*bindings.BatchNotifyResponse, error)

BatchNotify processes multiple notifications in a single RPC call. This eliminates per-notification round-trip overhead during large clones.

func (*KeibidropServiceImpl) CancelPendingRemove ¶ added in v0.4.3

func (kd *KeibidropServiceImpl) CancelPendingRemove(path string)

CancelPendingRemove cancels a buffered REMOVE_FILE if one exists. Called when a peer ADD_FILE/EDIT_FILE/RENAME_FILE arrives for the same path (git's atomic .lock→rename dance) and when a LOCAL event lands new content at the path: the buffered remove would otherwise delete the fresh local bytes.

func (*KeibidropServiceImpl) Debug ¶

func (kd *KeibidropServiceImpl) Debug(context.Context, *bindings.DebugRequest) (*bindings.DebugResponse, error)

func (*KeibidropServiceImpl) FS ¶

func (kd *KeibidropServiceImpl) FS() *filesystem.FS

FS returns the current FUSE tree, or nil before the first publish or after unmount. Handlers nil-check per call.

func (*KeibidropServiceImpl) GetChunkHashes ¶ added in v0.3.6

func (kd *KeibidropServiceImpl) GetChunkHashes(req *bindings.GetChunkHashesRequest, stream bindings.KeibiService_GetChunkHashesServer) error

GetChunkHashes streams per-chunk xxh3-64 fingerprints for a file. Path resolution and authorization mirror StreamFile exactly.

func (*KeibidropServiceImpl) Heartbeat ¶

func (kd *KeibidropServiceImpl) Heartbeat(_ context.Context, req *bindings.HeartbeatRequest) (*bindings.HeartbeatResponse, error)

Heartbeat responds to connection health checks. Used by HealthMonitor to detect connection loss.

func (*KeibidropServiceImpl) Notify ¶

func (kd *KeibidropServiceImpl) Notify(_ context.Context, req *bindings.NotifyRequest) (*bindings.NotifyResponse, error)

func (*KeibidropServiceImpl) Read ¶

func (kd *KeibidropServiceImpl) Read(stream bindings.KeibiService_ReadServer) error

func (*KeibidropServiceImpl) ReadBatch ¶ added in v0.4.2

func (kd *KeibidropServiceImpl) ReadBatch(req *bindings.ReadBatchRequest, stream bindings.KeibiService_ReadBatchServer) error

ReadBatch streams a set of files in requested order. One request replaces a per-file round trip for each small file. The budget is soft: the current file finishes, no new file starts past it. A per-file failure sends an err_code frame and the batch continues.

func (*KeibidropServiceImpl) ReadOnlyRefusals ¶ added in v0.4.2

func (kd *KeibidropServiceImpl) ReadOnlyRefusals() uint64

ReadOnlyRefusals returns how many peer mutations this origin refused because the share is read-only.

func (*KeibidropServiceImpl) Rekey ¶

func (kd *KeibidropServiceImpl) Rekey(_ context.Context, req *bindings.RekeyRequest) (*bindings.RekeyResponse, error)

Rekey drives the responder side of the entropy fold: an ephemeral hybrid-KEM whose shared secret mixes into the session ratchet for post-quantum forward secrecy. Self-synchronizing on the wire (no mid-stream key swap), so a stray or forged Rekey can't brick the connection.

func (*KeibidropServiceImpl) SetFS ¶ added in v0.4.0

func (kd *KeibidropServiceImpl) SetFS(f *filesystem.FS)

SetFS publishes the FUSE tree to running handlers.

func (*KeibidropServiceImpl) StreamFile ¶

func (kd *KeibidropServiceImpl) StreamFile(req *bindings.StreamFileRequest, stream bindings.KeibiService_StreamFileServer) error

StreamFile pushes an entire file's contents to the client in sequential chunks. The client sends one request; the server streams all data from start_offset to EOF with no per-chunk round-trip overhead.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL