service

package

v0.3.6 Latest Latest Go to latest Published: Jun 28, 2026 License: MPL-2.0 Imports: 19 Imported by: 0

Documentation ¶

Index ¶

Variables
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")
)

Functions ¶

This section is empty.

Types ¶

type KeibidropServiceImpl ¶

type KeibidropServiceImpl struct {
	bindings.UnimplementedKeibiServiceServer
	Session      *session.Session
	Logger       *slog.Logger
	FS           *filesystem.FS
	SyncTracker  *synctracker.SyncTracker
	OnEvent      func(string)
	OnDisconnect func() // Called (in goroutine) when peer sends DISCONNECT; cancels context to trigger cleanup.
	// 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) Debug ¶

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

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) Rekey ¶

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

Rekey handles key rotation requests for forward secrecy.

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

service.go

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