Package com.linkedin.venice.client.utils

Class StoreClientTestUtils

java.lang.Object

com.linkedin.venice.client.utils.StoreClientTestUtils

public class StoreClientTestUtils
extends Object

Constructor Summary

Constructors

Constructor	Description
StoreClientTestUtils()

Method Summary

Modifier and Type	Method	Description
static io.netty.handler.codec.http.FullHttpResponse	constructHttpClusterDiscoveryResponse(String storeName, String clusterName, String d2Service)
static io.netty.handler.codec.http.FullHttpResponse	constructHttpMultiSchemaIdResponse(String storeName, Map<Integer,String> valueSchemaEntries)
static io.netty.handler.codec.http.FullHttpResponse	constructHttpMultiSchemaResponse(String storeName, Map<Integer,String> valueSchemaEntries)
static io.netty.handler.codec.http.FullHttpResponse	constructHttpSchemaResponse(String storeName, int schemaId, String schemaStr)
static byte[]	constructMultiSchemaIdResponseInBytes(String storeName, Map<Integer,String> valueSchemaEntries)
static byte[]	constructMultiSchemaResponseInBytes(String storeName, Map<Integer,String> valueSchemaEntries)
static byte[]	constructSchemaResponseInBytes(String storeName, int schemaId, String schemaStr)
static io.netty.handler.codec.http.FullHttpResponse	constructStoreResponse(int schemaId, byte[] value)
static byte[]	serializeRecord(Object object, org.apache.avro.Schema schema)
static void	setupMultiValueSchemaResponse(TransportClient transportClient, String storeName, Map<Integer,org.apache.avro.Schema> valueSchemas)
static void	setupSchemaResponse(TransportClient transportClient, byte[] response, String path)

Methods inherited from class java.lang.Object

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

Constructor Details

StoreClientTestUtils

public StoreClientTestUtils()

Method Details

constructHttpSchemaResponse

public static io.netty.handler.codec.http.FullHttpResponse constructHttpSchemaResponse(String storeName,
 int schemaId,
 String schemaStr)
                                                                                throws IOException

Throws:

IOException

constructHttpClusterDiscoveryResponse

public static io.netty.handler.codec.http.FullHttpResponse constructHttpClusterDiscoveryResponse(String storeName,
 String clusterName,
 String d2Service)
                                                                                          throws IOException

Throws:

IOException

constructSchemaResponseInBytes

public static byte[] constructSchemaResponseInBytes(String storeName,
 int schemaId,
 String schemaStr)
                                             throws IOException

Throws:

IOException

constructHttpMultiSchemaResponse

public static io.netty.handler.codec.http.FullHttpResponse constructHttpMultiSchemaResponse(String storeName,
 Map<Integer,String> valueSchemaEntries)
                                                                                     throws IOException

Throws:

IOException

constructHttpMultiSchemaIdResponse

public static io.netty.handler.codec.http.FullHttpResponse constructHttpMultiSchemaIdResponse(String storeName,
 Map<Integer,String> valueSchemaEntries)
                                                                                       throws IOException

Throws:

IOException

constructMultiSchemaIdResponseInBytes

public static byte[] constructMultiSchemaIdResponseInBytes(String storeName,
 Map<Integer,String> valueSchemaEntries)
                                                    throws IOException

Throws:

IOException

constructMultiSchemaResponseInBytes

public static byte[] constructMultiSchemaResponseInBytes(String storeName,
 Map<Integer,String> valueSchemaEntries)
                                                  throws IOException

Throws:

IOException

constructStoreResponse

public static io.netty.handler.codec.http.FullHttpResponse constructStoreResponse(int schemaId,
 byte[] value)
                                                                           throws IOException

Throws:

IOException

serializeRecord

public static byte[] serializeRecord(Object object,
 org.apache.avro.Schema schema)
                              throws VeniceClientException

Throws:

VeniceClientException

setupSchemaResponse

public static void setupSchemaResponse(TransportClient transportClient,
 byte[] response,
 String path)

setupMultiValueSchemaResponse

public static void setupMultiValueSchemaResponse(TransportClient transportClient,
 String storeName,
 Map<Integer,org.apache.avro.Schema> valueSchemas)
                                          throws IOException

Throws:

IOException