Package com.linkedin.venice.pubsub

Class PubSubClientsFactory

java.lang.Object

com.linkedin.venice.pubsub.PubSubClientsFactory

public class PubSubClientsFactory
extends Object

A wrapper around pub-sub producer, consumer, and admin adapter factories This will be passed as one of the arguments to the component which depends on the pub-sub APIs.

Constructor Summary

Constructors

Constructor	Description
PubSubClientsFactory(PubSubProducerAdapterFactory producerAdapterFactory, PubSubConsumerAdapterFactory consumerAdapterFactory, PubSubAdminAdapterFactory adminAdapterFactory)
PubSubClientsFactory(VeniceProperties properties)

Method Summary

Modifier and Type	Method	Description
static PubSubAdminAdapterFactory<PubSubAdminAdapter>	createAdminFactory(VeniceProperties veniceProperties)
static PubSubConsumerAdapterFactory<PubSubConsumerAdapter>	createConsumerFactory(VeniceProperties veniceProperties)
static <T> T	createInstance(String className)
static PubSubProducerAdapterFactory<PubSubProducerAdapter>	createProducerFactory(VeniceProperties veniceProperties)
static PubSubProducerAdapterFactory<PubSubProducerAdapter>	createProducerFactory(Properties properties)
static PubSubAdminAdapterFactory<PubSubAdminAdapter>	createSourceOfTruthAdminFactory(VeniceProperties veniceProperties)
PubSubAdminAdapterFactory	getAdminAdapterFactory()
PubSubConsumerAdapterFactory	getConsumerAdapterFactory()
PubSubProducerAdapterFactory	getProducerAdapterFactory()

Methods inherited from class java.lang.Object

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

Constructor Details

PubSubClientsFactory

public PubSubClientsFactory(PubSubProducerAdapterFactory producerAdapterFactory,
 PubSubConsumerAdapterFactory consumerAdapterFactory,
 PubSubAdminAdapterFactory adminAdapterFactory)

PubSubClientsFactory

public PubSubClientsFactory(VeniceProperties properties)

Method Details

getProducerAdapterFactory

public PubSubProducerAdapterFactory getProducerAdapterFactory()

getConsumerAdapterFactory

public PubSubConsumerAdapterFactory getConsumerAdapterFactory()

getAdminAdapterFactory

public PubSubAdminAdapterFactory getAdminAdapterFactory()

createProducerFactory

public static PubSubProducerAdapterFactory<PubSubProducerAdapter> createProducerFactory(Properties properties)

createProducerFactory

public static PubSubProducerAdapterFactory<PubSubProducerAdapter> createProducerFactory(VeniceProperties veniceProperties)

createConsumerFactory

public static PubSubConsumerAdapterFactory<PubSubConsumerAdapter> createConsumerFactory(VeniceProperties veniceProperties)

createAdminFactory

public static PubSubAdminAdapterFactory<PubSubAdminAdapter> createAdminFactory(VeniceProperties veniceProperties)

createSourceOfTruthAdminFactory

public static PubSubAdminAdapterFactory<PubSubAdminAdapter> createSourceOfTruthAdminFactory(VeniceProperties veniceProperties)

createInstance

public static <T> T createInstance(String className)