Package com.linkedin.venice.controller

Class VeniceControllerMultiClusterConfig

java.lang.Object
com.linkedin.venice.controller.VeniceControllerMultiClusterConfig
public class VeniceControllerMultiClusterConfig extends Object

  • Constructor Details

  • Method Details

    • addClusterConfig

      public void addClusterConfig(VeniceControllerClusterConfig controllerConfig)

    • getControllerConfig

      public VeniceControllerClusterConfig getControllerConfig(String clusterName)

    • getAdminPort

      public int getAdminPort()

    • getAdminHostname

      public String getAdminHostname()

    • getAdminSecurePort

      public int getAdminSecurePort()

    • getAdminGrpcPort

      public int getAdminGrpcPort()

    • getAdminSecureGrpcPort

      public int getAdminSecureGrpcPort()

    • adminCheckReadMethodForKafka

      public boolean adminCheckReadMethodForKafka()

    • isMultiRegion

      public boolean isMultiRegion()

    • isParent

      public boolean isParent()

    • getParentControllerRegionState

      public ParentControllerRegionState getParentControllerRegionState()

    • getControllerName

      public String getControllerName()

    • getZkAddress

      public String getZkAddress()

    • getControllerClusterName

      public String getControllerClusterName()

    • getControllerHAASSuperClusterName

      public String getControllerHAASSuperClusterName()

    • getControllerClusterReplica

      public int getControllerClusterReplica()

    • getKafkaBootstrapServers

      public String getKafkaBootstrapServers()

    • getSslKafkaBootstrapServers

      public String getSslKafkaBootstrapServers()

    • isSslToKafka

      public boolean isSslToKafka()

    • getSslConfig

      public Optional<SSLConfig> getSslConfig()

    • getSslFactoryClassName

      public String getSslFactoryClassName()

    • getDeprecatedJobTopicRetentionMs

      public long getDeprecatedJobTopicRetentionMs()

    • getFatalDataValidationFailureRetentionMs

      public long getFatalDataValidationFailureRetentionMs()

    • getDeprecatedJobTopicMaxRetentionMs

      public long getDeprecatedJobTopicMaxRetentionMs()

    • getTopicCleanupSleepIntervalBetweenTopicListFetchMs

      public long getTopicCleanupSleepIntervalBetweenTopicListFetchMs()

    • getDisabledReplicaEnablerServiceIntervalMs

      public long getDisabledReplicaEnablerServiceIntervalMs()

    • getTopicCleanupDelayFactor

      public int getTopicCleanupDelayFactor()

    • getControllerClusterZkAddress

      public String getControllerClusterZkAddress()

    • getParentControllerWaitingTimeForConsumptionMs

      public int getParentControllerWaitingTimeForConsumptionMs()

    • getBatchJobHeartbeatStoreCluster

      public String getBatchJobHeartbeatStoreCluster()

    • getBatchJobHeartbeatEnabled

      public boolean getBatchJobHeartbeatEnabled()

    • getBatchJobHeartbeatTimeout

      public Duration getBatchJobHeartbeatTimeout()

    • getBatchJobHeartbeatInitialBufferTime

      public Duration getBatchJobHeartbeatInitialBufferTime()

    • getClusterToD2Map

      public Map<String,String> getClusterToD2Map()

    • getClusterToServerD2Map

      public Map<String,String> getClusterToServerD2Map()

    • getMinNumberOfUnusedKafkaTopicsToPreserve

      public int getMinNumberOfUnusedKafkaTopicsToPreserve()

    • getMinNumberOfStoreVersionsToPreserve

      public int getMinNumberOfStoreVersionsToPreserve()

    • getParentControllerMaxErroredTopicNumToKeep

      public int getParentControllerMaxErroredTopicNumToKeep()

    • getCommonConfig

      public VeniceControllerClusterConfig getCommonConfig()

    • getDisabledRoutes

      public List<ControllerRoute> getDisabledRoutes()

    • getUnusedSchemaCleanupIntervalSeconds

      public int getUnusedSchemaCleanupIntervalSeconds()

    • getMinSchemaCountToKeep

      public int getMinSchemaCountToKeep()

    • getClusters

      public Set<String> getClusters()

    • getPushJobStatusStoreClusterName

      public String getPushJobStatusStoreClusterName()

    • getSystemSchemaClusterName

      public String getSystemSchemaClusterName()

    • getBackupVersionDefaultRetentionMs

      public long getBackupVersionDefaultRetentionMs()

    • getBackupVersionCleanupSleepMs

      public long getBackupVersionCleanupSleepMs()

    • isControllerEnforceSSLOnly

      public boolean isControllerEnforceSSLOnly()

    • isGrpcServerEnabled

      public boolean isGrpcServerEnabled()

    • getGrpcServerThreadCount

      public int getGrpcServerThreadCount()

    • getTerminalStateTopicCheckerDelayMs

      public long getTerminalStateTopicCheckerDelayMs()

    • getChildDataCenterKafkaUrlMap

      public Map<String,String> getChildDataCenterKafkaUrlMap()

    • getParentFabrics

      public Set<String> getParentFabrics()

    • isZkSharedMetaSystemSchemaStoreAutoCreationEnabled

      public boolean isZkSharedMetaSystemSchemaStoreAutoCreationEnabled()

    • isZkSharedDaVinciPushStatusSystemSchemaStoreAutoCreationEnabled

      public boolean isZkSharedDaVinciPushStatusSystemSchemaStoreAutoCreationEnabled()

    • isParticipantMessageStoreEnabled

      public boolean isParticipantMessageStoreEnabled()

    • getSystemStoreAclSynchronizationDelayMs

      public long getSystemStoreAclSynchronizationDelayMs()

    • getRegionName

      public String getRegionName()

    • getEmergencySourceRegion

      public String getEmergencySourceRegion(String clusterName)

    • getGraveyardCleanupSleepIntervalBetweenListFetchMinutes

      public int getGraveyardCleanupSleepIntervalBetweenListFetchMinutes()

    • getPubSubClientsFactory

      public PubSubClientsFactory getPubSubClientsFactory()

    • getSourceOfTruthAdminAdapterFactory

      public PubSubAdminAdapterFactory getSourceOfTruthAdminAdapterFactory()

    • getDanglingTopicCleanupIntervalSeconds

      public long getDanglingTopicCleanupIntervalSeconds()

    • getDanglingTopicOccurrenceThresholdForCleanup

      public int getDanglingTopicOccurrenceThresholdForCleanup()

    • getDefaultMaxRecordSizeBytes

      public int getDefaultMaxRecordSizeBytes()

    • getServiceDiscoveryRegistrationRetryMS

      public long getServiceDiscoveryRegistrationRetryMS()

    • getControllerInstanceTagList

      public List<String> getControllerInstanceTagList()