Package com.linkedin.venice.controller.server

Class ControllerRoutes

java.lang.Object

com.linkedin.venice.controller.server.AbstractRoute

com.linkedin.venice.controller.server.ControllerRoutes

public class ControllerRoutes
extends AbstractRoute

Constructor Summary

Constructors

Constructor	Description
ControllerRoutes(boolean sslEnabled, Optional<DynamicAccessController> accessController, PubSubTopicRepository pubSubTopicRepository, VeniceControllerRequestHandler requestHandler)

Method Summary

Modifier and Type	Method	Description
spark.Route	getAggregatedHealthStatus(Admin admin)
spark.Route	getChildControllers(Admin admin)
spark.Route	getKafkaTopicConfigs(Admin admin)	No ACL check; any user is allowed to check topic configs.
spark.Route	getLeaderController(Admin admin)	No ACL check; any user is allowed to check leader controller.
spark.Route	updateKafkaTopicLogCompaction(Admin admin)
spark.Route	updateKafkaTopicMinInSyncReplica(Admin admin)
spark.Route	updateKafkaTopicRetention(Admin admin)

Methods inherited from class com.linkedin.venice.controller.server.AbstractRoute

getCertificate, getPrincipalId, hasAccessToStore, hasReadAccessToTopic, hasWriteAccessToTopic, isAclEnabled, isAllowListUser, isSslEnabled

Methods inherited from class java.lang.Object

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

Constructor Details

ControllerRoutes

public ControllerRoutes(boolean sslEnabled,
 Optional<DynamicAccessController> accessController,
 PubSubTopicRepository pubSubTopicRepository,
 VeniceControllerRequestHandler requestHandler)

Method Details

getLeaderController

public spark.Route getLeaderController(Admin admin)

No ACL check; any user is allowed to check leader controller.

See Also:

• Admin.getLeaderController(String)

getChildControllers

public spark.Route getChildControllers(Admin admin)

See Also:

• Admin.getChildDataCenterControllerUrlMap(String)
• Admin.getChildDataCenterControllerD2Map(String)
• Admin.getChildControllerD2ServiceName(String)

updateKafkaTopicLogCompaction

public spark.Route updateKafkaTopicLogCompaction(Admin admin)

See Also:

• TopicManager.updateTopicCompactionPolicy(PubSubTopic, boolean)

getKafkaTopicConfigs

public spark.Route getKafkaTopicConfigs(Admin admin)

No ACL check; any user is allowed to check topic configs.

updateKafkaTopicRetention

public spark.Route updateKafkaTopicRetention(Admin admin)

See Also:

• TopicManager.updateTopicRetention(PubSubTopic, long)

updateKafkaTopicMinInSyncReplica

public spark.Route updateKafkaTopicMinInSyncReplica(Admin admin)

getAggregatedHealthStatus

public spark.Route getAggregatedHealthStatus(Admin admin)