Package com.linkedin.venice.controller

Class ParticipantStoreClientsManager

java.lang.Object

com.linkedin.venice.controller.ParticipantStoreClientsManager

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class ParticipantStoreClientsManager
extends java.lang.Object
implements java.io.Closeable

A helper class that wraps the readers and writers for the participant stores.

Field Summary

Fields

Modifier and Type	Field	Description
protected PubSubTopicRepository	pubSubTopicRepository

Constructor Summary

Constructors

Constructor	Description
ParticipantStoreClientsManager(com.linkedin.d2.balancer.D2Client d2Client, java.lang.String clusterDiscoveryD2ServiceName, TopicManagerRepository topicManagerRepository, VeniceWriterFactory veniceWriterFactory, PubSubTopicRepository pubSubTopicRepository)

Method Summary

Modifier and Type	Method	Description
void	close()
AvroSpecificStoreClient<ParticipantMessageKey,ParticipantMessageValue>	getReader(java.lang.String clusterName)
VeniceWriter	getWriter(java.lang.String clusterName)

Methods inherited from class java.lang.Object

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

Field Detail

pubSubTopicRepository

protected final PubSubTopicRepository pubSubTopicRepository

Constructor Detail

ParticipantStoreClientsManager

public ParticipantStoreClientsManager(com.linkedin.d2.balancer.D2Client d2Client,
                                      java.lang.String clusterDiscoveryD2ServiceName,
                                      TopicManagerRepository topicManagerRepository,
                                      VeniceWriterFactory veniceWriterFactory,
                                      PubSubTopicRepository pubSubTopicRepository)

Method Detail

getReader

public AvroSpecificStoreClient<ParticipantMessageKey,ParticipantMessageValue> getReader(java.lang.String clusterName)

getWriter

public VeniceWriter getWriter(java.lang.String clusterName)

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable