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()

    • 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()

    • getParentControllerMetadataStoreClusterName

      public String getParentControllerMetadataStoreClusterName()

    • getSystemSchemaClusterName

      public String getSystemSchemaClusterName()

    • getBackupVersionDefaultRetentionMs

      public long getBackupVersionDefaultRetentionMs()

    • getBackupVersionCleanupSleepMs

      public long getBackupVersionCleanupSleepMs()

    • getDeferredVersionSwapSleepMs

      public long getDeferredVersionSwapSleepMs()

    • getDeferredVersionSwapBufferTime

      public double getDeferredVersionSwapBufferTime()

    • isDeferredVersionSwapServiceEnabled

      public boolean isDeferredVersionSwapServiceEnabled()

    • isSkipDeferredVersionSwapForDVCEnabled

      public boolean isSkipDeferredVersionSwapForDVCEnabled()

    • 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()

    • getPubSubPositionTypeRegistry

      public PubSubPositionTypeRegistry getPubSubPositionTypeRegistry()

    • getPubSubPositionDeserializer

      public PubSubPositionDeserializer getPubSubPositionDeserializer()

    • 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()

    • getHelixGlobalRebalancePreference

      public Map<org.apache.helix.model.ClusterConfig.GlobalRebalancePreferenceKey,Integer> getHelixGlobalRebalancePreference()

    • getHelixCapacityConfig

      public HelixCapacityConfig getHelixCapacityConfig()

    • isControllerClusterHelixCloudEnabled

      public boolean isControllerClusterHelixCloudEnabled()

    • getHelixCloudConfig

      public org.apache.helix.model.CloudConfig getHelixCloudConfig()

    • getControllerHelixParticipantDeregistrationTimeoutMs

      public long getControllerHelixParticipantDeregistrationTimeoutMs()

    • getRepushOrchestratorClassName

      public String getRepushOrchestratorClassName()

    • getRepushCandidateFilterClassNames

      public Set<String> getRepushCandidateFilterClassNames()

    • getRepushOrchestratorConfigs

      public VeniceProperties getRepushOrchestratorConfigs()

    • isLogCompactionEnabled

      public boolean isLogCompactionEnabled()

    • isLogCompactionSchedulingEnabled

      public boolean isLogCompactionSchedulingEnabled()

    • getLogCompactionThreadCount

      public int getLogCompactionThreadCount()

    • getLogCompactionIntervalMS

      public long getLogCompactionIntervalMS()

    • getLogCompactionThresholdMS

      public long getLogCompactionThresholdMS()

    • isRealTimeTopicVersioningEnabled

      public boolean isRealTimeTopicVersioningEnabled()

    • getLogContext

      public LogContext getLogContext()

    • getPubSubTopicRepository

      public PubSubTopicRepository getPubSubTopicRepository()