Package com.linkedin.venice.controller

Class ParticipantStoreClientsManager

java.lang.Object

com.linkedin.venice.controller.ParticipantStoreClientsManager

All Implemented Interfaces:

Closeable, AutoCloseable

public class ParticipantStoreClientsManager
extends Object
implements Closeable

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

Field Summary

Fields

Modifier and Type	Field	Description
protected final PubSubTopicRepository	pubSubTopicRepository

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

pubSubTopicRepository

protected final PubSubTopicRepository pubSubTopicRepository

Constructor Details

ParticipantStoreClientsManager

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

Method Details

getReader

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

getWriter

public VeniceWriter getWriter(String clusterName)

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable