Package com.linkedin.venice.controller.grpc.server

Class SchemaGrpcServiceImpl

java.lang.Object

com.linkedin.venice.protocols.controller.SchemaGrpcServiceGrpc.SchemaGrpcServiceImplBase

com.linkedin.venice.controller.grpc.server.SchemaGrpcServiceImpl

All Implemented Interfaces:

SchemaGrpcServiceGrpc.AsyncService, io.grpc.BindableService

public class SchemaGrpcServiceImpl
extends SchemaGrpcServiceGrpc.SchemaGrpcServiceImplBase

gRPC service implementation for schema operations. Extracts primitives from protobuf, calls handler, and converts POJO response back to protobuf.

Constructor Summary

Constructors

Constructor	Description
SchemaGrpcServiceImpl(SchemaRequestHandler schemaRequestHandler)

Method Summary

Modifier and Type	Method	Description
void	getKeySchema(GetKeySchemaGrpcRequest request, io.grpc.stub.StreamObserver<GetKeySchemaGrpcResponse> responseObserver)	Retrieves the key schema for a store.
void	getValueSchema(GetValueSchemaGrpcRequest request, io.grpc.stub.StreamObserver<GetValueSchemaGrpcResponse> responseObserver)	Retrieves the value schema for a store by schema ID.

Methods inherited from class com.linkedin.venice.protocols.controller.SchemaGrpcServiceGrpc.SchemaGrpcServiceImplBase

bindService

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SchemaGrpcServiceImpl

public SchemaGrpcServiceImpl(SchemaRequestHandler schemaRequestHandler)

Method Details

getValueSchema

public void getValueSchema(GetValueSchemaGrpcRequest request,
 io.grpc.stub.StreamObserver<GetValueSchemaGrpcResponse> responseObserver)

Retrieves the value schema for a store by schema ID. No ACL check is required for this operation as it only reads store metadata.

getKeySchema

public void getKeySchema(GetKeySchemaGrpcRequest request,
 io.grpc.stub.StreamObserver<GetKeySchemaGrpcResponse> responseObserver)

Retrieves the key schema for a store. No ACL check is required for this operation as it only reads store metadata.