Package com.linkedin.venice.router

Class MetaDataHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.SimpleChannelInboundHandler<io.netty.handler.codec.http.HttpRequest>

com.linkedin.venice.router.MetaDataHandler

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

@Sharable
public class MetaDataHandler
extends io.netty.channel.SimpleChannelInboundHandler<io.netty.handler.codec.http.HttpRequest>

This MetaDataHandle is used to handle the following meta data requests: 1. Controller lookup: /controller, and it will return leader controller url as the content. 2. Key schema lookup: /key_schema/${storeName}, and it will return key schema in json format. The client can use SchemaResponse to parse it. 3. Single value schema lookup: /value_schema/${storeName}/${valueSchemaId}, and it will return the corresponding value schema in json format. The client can use SchemaResponse to parse it. 4. All value schema lookup: /value_schema/{$storeName}, and it will return all the value schema of the specified store in json format. The client can use MultiSchemaResponse to parse it.

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor

Description

MetaDataHandler(HelixCustomizedViewOfflinePushRepository routingDataRepository, ReadOnlySchemaRepository schemaRepo, ReadOnlyStoreConfigRepository storeConfigRepo, Map<String,String> clusterToD2Map, Map<String,String> clusterToServerD2Map, ReadOnlyStoreRepository storeRepository, Optional<HelixHybridStoreQuotaRepository> hybridStoreQuotaRepository, String clusterName, String zkAddress, String kafkaBootstrapServers, boolean isSslToKafka, VeniceVersionFinder versionFinder, PushStatusStoreReader pushStatusStoreReader)

Method Summary

Modifier and Type	Method	Description
void	channelRead0(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http.HttpRequest req)
void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable e)

Methods inherited from class io.netty.channel.SimpleChannelInboundHandler

acceptInboundMessage, channelRead

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.ChannelHandler

handlerAdded, handlerRemoved

Constructor Details

MetaDataHandler

public MetaDataHandler(HelixCustomizedViewOfflinePushRepository routingDataRepository,
 ReadOnlySchemaRepository schemaRepo,
 ReadOnlyStoreConfigRepository storeConfigRepo,
 Map<String,String> clusterToD2Map,
 Map<String,String> clusterToServerD2Map,
 ReadOnlyStoreRepository storeRepository,
 Optional<HelixHybridStoreQuotaRepository> hybridStoreQuotaRepository,
 String clusterName,
 String zkAddress,
 String kafkaBootstrapServers,
 boolean isSslToKafka,
 VeniceVersionFinder versionFinder,
 PushStatusStoreReader pushStatusStoreReader)

Method Details

channelRead0

public void channelRead0(io.netty.channel.ChannelHandlerContext ctx,
 io.netty.handler.codec.http.HttpRequest req)
                  throws IOException

Specified by:

channelRead0 in class io.netty.channel.SimpleChannelInboundHandler<io.netty.handler.codec.http.HttpRequest>

Throws:

IOException

exceptionCaught

public void exceptionCaught(io.netty.channel.ChannelHandlerContext ctx,
 Throwable e)
                     throws Exception

Specified by:

exceptionCaught in interface io.netty.channel.ChannelHandler

Specified by:

exceptionCaught in interface io.netty.channel.ChannelInboundHandler

Overrides:

exceptionCaught in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception