Package com.linkedin.venice.controller

Class VeniceControllerMultiClusterConfig

  • public class VeniceControllerMultiClusterConfig
extends java.lang.Object

    • Constructor Detail

      • VeniceControllerMultiClusterConfig

        public VeniceControllerMultiClusterConfig​(java.util.Collection<VeniceProperties> controllerClusterProperties)

      • VeniceControllerMultiClusterConfig

        public VeniceControllerMultiClusterConfig​(java.util.Map<java.lang.String,​VeniceControllerConfig> clusterToControllerConfigMap)

    • Method Detail

      • getAdminPort

        public int getAdminPort()

      • getAdminHostname

        public java.lang.String getAdminHostname()

      • getAdminSecurePort

        public int getAdminSecurePort()

      • adminCheckReadMethodForKafka

        public boolean adminCheckReadMethodForKafka()

      • isParent

        public boolean isParent()

      • getControllerName

        public java.lang.String getControllerName()

      • getZkAddress

        public java.lang.String getZkAddress()

      • getControllerClusterName

        public java.lang.String getControllerClusterName()

      • getControllerHAASSuperClusterName

        public java.lang.String getControllerHAASSuperClusterName()

      • getControllerClusterReplica

        public int getControllerClusterReplica()

      • getKafkaBootstrapServers

        public java.lang.String getKafkaBootstrapServers()

      • getSslKafkaBootstrapServers

        public java.lang.String getSslKafkaBootstrapServers()

      • isSslToKafka

        public boolean isSslToKafka()

      • getSslConfig

        public java.util.Optional<SSLConfig> getSslConfig()

      • getSslFactoryClassName

        public java.lang.String getSslFactoryClassName()

      • isDisableParentRequestTopicForStreamPushes

        public boolean isDisableParentRequestTopicForStreamPushes()

      • getDeprecatedJobTopicRetentionMs

        public long getDeprecatedJobTopicRetentionMs()

      • getDeprecatedJobTopicMaxRetentionMs

        public long getDeprecatedJobTopicMaxRetentionMs()

      • getTopicCleanupSleepIntervalBetweenTopicListFetchMs

        public long getTopicCleanupSleepIntervalBetweenTopicListFetchMs()

      • getDisabledReplicaEnablerServiceIntervalMs

        public long getDisabledReplicaEnablerServiceIntervalMs()

      • getTopicCleanupDelayFactor

        public int getTopicCleanupDelayFactor()

      • getControllerClusterZkAddress

        public java.lang.String getControllerClusterZkAddress()

      • getParentControllerWaitingTimeForConsumptionMs

        public int getParentControllerWaitingTimeForConsumptionMs()

      • getBatchJobHeartbeatStoreCluster

        public java.lang.String getBatchJobHeartbeatStoreCluster()

      • getBatchJobHeartbeatEnabled

        public boolean getBatchJobHeartbeatEnabled()

      • getBatchJobHeartbeatTimeout

        public java.time.Duration getBatchJobHeartbeatTimeout()

      • getBatchJobHeartbeatInitialBufferTime

        public java.time.Duration getBatchJobHeartbeatInitialBufferTime()

      • getTopicCreationThrottlingTimeWindowMs

        public long getTopicCreationThrottlingTimeWindowMs()

      • getClusterToD2Map

        public java.util.Map<java.lang.String,​java.lang.String> getClusterToD2Map()

      • getClusterToServerD2Map

        public java.util.Map<java.lang.String,​java.lang.String> getClusterToServerD2Map()

      • getTopicManagerKafkaOperationTimeOutMs

        public int getTopicManagerKafkaOperationTimeOutMs()

      • getTopicDeletionStatusPollIntervalMs

        public int getTopicDeletionStatusPollIntervalMs()

      • isConcurrentTopicDeleteRequestsEnabled

        public boolean isConcurrentTopicDeleteRequestsEnabled()

      • getKafkaMinLogCompactionLagInMs

        public long getKafkaMinLogCompactionLagInMs()

      • getMinNumberOfUnusedKafkaTopicsToPreserve

        public int getMinNumberOfUnusedKafkaTopicsToPreserve()

      • getMinNumberOfStoreVersionsToPreserve

        public int getMinNumberOfStoreVersionsToPreserve()

      • getParentControllerMaxErroredTopicNumToKeep

        public int getParentControllerMaxErroredTopicNumToKeep()

      • getDisabledRoutes

        public java.util.List<ControllerRoute> getDisabledRoutes()

      • getUnusedSchemaCleanupIntervalSeconds

        public int getUnusedSchemaCleanupIntervalSeconds()

      • getMinSchemaCountToKeep

        public int getMinSchemaCountToKeep()

      • getClusters

        public java.util.Set<java.lang.String> getClusters()

      • getPushJobStatusStoreClusterName

        public java.lang.String getPushJobStatusStoreClusterName()

      • getSystemSchemaClusterName

        public java.lang.String getSystemSchemaClusterName()

      • isEnableBatchPushFromAdminInChildController

        public boolean isEnableBatchPushFromAdminInChildController()

      • getBackupVersionDefaultRetentionMs

        public long getBackupVersionDefaultRetentionMs()

      • isControllerEnforceSSLOnly

        public boolean isControllerEnforceSSLOnly()

      • getTerminalStateTopicCheckerDelayMs

        public long getTerminalStateTopicCheckerDelayMs()

      • getChildDataCenterKafkaUrlMap

        public java.util.Map<java.lang.String,​java.lang.String> getChildDataCenterKafkaUrlMap()

      • getParentFabrics

        public java.util.Set<java.lang.String> getParentFabrics()

      • isZkSharedMetaSystemSchemaStoreAutoCreationEnabled

        public boolean isZkSharedMetaSystemSchemaStoreAutoCreationEnabled()

      • isZkSharedDaVinciPushStatusSystemSchemaStoreAutoCreationEnabled

        public boolean isZkSharedDaVinciPushStatusSystemSchemaStoreAutoCreationEnabled()

      • isParticipantMessageStoreEnabled

        public boolean isParticipantMessageStoreEnabled()

      • getSystemStoreAclSynchronizationDelayMs

        public long getSystemStoreAclSynchronizationDelayMs()

      • getRegionName

        public java.lang.String getRegionName()

      • getEmergencySourceRegion

        public java.lang.String getEmergencySourceRegion​(java.lang.String clusterName)

      • getGraveyardCleanupSleepIntervalBetweenListFetchMinutes

        public int getGraveyardCleanupSleepIntervalBetweenListFetchMinutes()