proto

type CandidateRequest struct {

	// Session identifier
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// LSH hash computed by client
	LshHash []byte `protobuf:"bytes,2,opt,name=lsh_hash,json=lshHash,proto3" json:"lsh_hash,omitempty"`
	// Maximum number of candidates to return
	NumCandidates int32 `protobuf:"varint,3,opt,name=num_candidates,json=numCandidates,proto3" json:"num_candidates,omitempty"`
	// Use multi-probe LSH (check neighboring buckets)
	MultiProbe bool `protobuf:"varint,4,opt,name=multi_probe,json=multiProbe,proto3" json:"multi_probe,omitempty"`
	// Number of probes for multi-probe LSH
	NumProbes int32 `protobuf:"varint,5,opt,name=num_probes,json=numProbes,proto3" json:"num_probes,omitempty"`
	// contains filtered or unexported fields
}

type CandidateResponse struct {

	// Candidate vector IDs
	Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	// Hamming distances to query hash
	Distances []int32 `protobuf:"varint,2,rep,packed,name=distances,proto3" json:"distances,omitempty"`
	// contains filtered or unexported fields
}

type GetPlanesRequest struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

type GetPlanesResponse struct {

	// Flattened hyperplanes (num_planes * dimension floats)
	Planes []float64 `protobuf:"fixed64,1,rep,packed,name=planes,proto3" json:"planes,omitempty"`
	// Number of planes (hash bits)
	NumPlanes int32 `protobuf:"varint,2,opt,name=num_planes,json=numPlanes,proto3" json:"num_planes,omitempty"`
	// Vector dimension
	Dimension int32 `protobuf:"varint,3,opt,name=dimension,proto3" json:"dimension,omitempty"`
	// contains filtered or unexported fields
}

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

type HealthCheckResponse struct {
	Status HealthCheckResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=opaque.v1.HealthCheckResponse_Status" json:"status,omitempty"`
	// Additional info
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// Number of active sessions
	ActiveSessions int64 `protobuf:"varint,3,opt,name=active_sessions,json=activeSessions,proto3" json:"active_sessions,omitempty"`
	// Number of vectors in index
	VectorCount int64 `protobuf:"varint,4,opt,name=vector_count,json=vectorCount,proto3" json:"vector_count,omitempty"`
	// contains filtered or unexported fields
}

type HealthCheckResponse_Status int32

type OpaqueSearchClient interface {
	// RegisterKey registers a client's public key and creates a session.
	RegisterKey(ctx context.Context, in *RegisterKeyRequest, opts ...grpc.CallOption) (*RegisterKeyResponse, error)
	// GetPlanes retrieves the LSH hyperplanes for client-side hashing.
	GetPlanes(ctx context.Context, in *GetPlanesRequest, opts ...grpc.CallOption) (*GetPlanesResponse, error)
	// GetCandidates performs LSH lookup to find candidate vectors.
	GetCandidates(ctx context.Context, in *CandidateRequest, opts ...grpc.CallOption) (*CandidateResponse, error)
	// ComputeScores computes encrypted similarity scores for candidates.
	ComputeScores(ctx context.Context, in *ScoreRequest, opts ...grpc.CallOption) (*ScoreResponse, error)
	// ComputeScoresStream streams encrypted scores one at a time (for large responses).
	ComputeScoresStream(ctx context.Context, in *ScoreRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ScoreChunk], error)
	// Search performs the complete search flow in one call (convenience method).
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*SearchResponse, error)
	// HealthCheck checks service health.
	HealthCheck(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
}

type OpaqueSearchServer interface {
	// RegisterKey registers a client's public key and creates a session.
	RegisterKey(context.Context, *RegisterKeyRequest) (*RegisterKeyResponse, error)
	// GetPlanes retrieves the LSH hyperplanes for client-side hashing.
	GetPlanes(context.Context, *GetPlanesRequest) (*GetPlanesResponse, error)
	// GetCandidates performs LSH lookup to find candidate vectors.
	GetCandidates(context.Context, *CandidateRequest) (*CandidateResponse, error)
	// ComputeScores computes encrypted similarity scores for candidates.
	ComputeScores(context.Context, *ScoreRequest) (*ScoreResponse, error)
	// ComputeScoresStream streams encrypted scores one at a time (for large responses).
	ComputeScoresStream(*ScoreRequest, grpc.ServerStreamingServer[ScoreChunk]) error
	// Search performs the complete search flow in one call (convenience method).
	Search(context.Context, *SearchRequest) (*SearchResponse, error)
	// HealthCheck checks service health.
	HealthCheck(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
	// contains filtered or unexported methods
}

type OpaqueSearch_ComputeScoresStreamClient = grpc.ServerStreamingClient[ScoreChunk]

type OpaqueSearch_ComputeScoresStreamServer = grpc.ServerStreamingServer[ScoreChunk]

type RegisterKeyRequest struct {

	// Serialized public key (Lattigo format)
	PublicKey []byte `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	// Requested session TTL in seconds (server may enforce max)
	SessionTtlSeconds int32 `protobuf:"varint,2,opt,name=session_ttl_seconds,json=sessionTtlSeconds,proto3" json:"session_ttl_seconds,omitempty"`
	// contains filtered or unexported fields
}

type RegisterKeyResponse struct {

	// Unique session identifier
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Actual TTL granted (may be less than requested)
	SessionTtlSeconds int32 `protobuf:"varint,2,opt,name=session_ttl_seconds,json=sessionTtlSeconds,proto3" json:"session_ttl_seconds,omitempty"`
	// contains filtered or unexported fields
}

type ScoreChunk struct {

	// Vector ID
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Encrypted score (serialized ciphertext)
	EncryptedScore []byte `protobuf:"bytes,2,opt,name=encrypted_score,json=encryptedScore,proto3" json:"encrypted_score,omitempty"`
	// contains filtered or unexported fields
}

type ScoreRequest struct {

	// Session identifier
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Encrypted query vector (serialized ciphertext)
	EncryptedQuery []byte `protobuf:"bytes,2,opt,name=encrypted_query,json=encryptedQuery,proto3" json:"encrypted_query,omitempty"`
	// Candidate IDs to score
	CandidateIds []string `protobuf:"bytes,3,rep,name=candidate_ids,json=candidateIds,proto3" json:"candidate_ids,omitempty"`
	// contains filtered or unexported fields
}

type ScoreResponse struct {

	// Encrypted scores (serialized ciphertexts)
	EncryptedScores [][]byte `protobuf:"bytes,1,rep,name=encrypted_scores,json=encryptedScores,proto3" json:"encrypted_scores,omitempty"`
	// Corresponding IDs (same order as scores)
	Ids []string `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

type SearchRequest struct {

	// Session identifier
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// LSH hash computed by client
	LshHash []byte `protobuf:"bytes,2,opt,name=lsh_hash,json=lshHash,proto3" json:"lsh_hash,omitempty"`
	// Encrypted query vector
	EncryptedQuery []byte `protobuf:"bytes,3,opt,name=encrypted_query,json=encryptedQuery,proto3" json:"encrypted_query,omitempty"`
	// Maximum candidates to consider
	MaxCandidates int32 `protobuf:"varint,4,opt,name=max_candidates,json=maxCandidates,proto3" json:"max_candidates,omitempty"`
	// Number of scores to compute and return
	TopN int32 `protobuf:"varint,5,opt,name=top_n,json=topN,proto3" json:"top_n,omitempty"`
	// contains filtered or unexported fields
}

type SearchResponse struct {

	// Encrypted scores
	EncryptedScores [][]byte `protobuf:"bytes,1,rep,name=encrypted_scores,json=encryptedScores,proto3" json:"encrypted_scores,omitempty"`
	// Corresponding IDs
	Ids []string `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"`
	// LSH distances (for debugging/analysis)
	LshDistances []int32 `protobuf:"varint,3,rep,packed,name=lsh_distances,json=lshDistances,proto3" json:"lsh_distances,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedOpaqueSearchServer struct{}

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