Package com.linkedin.venice.controllerapi

Class D2ControllerClient

java.lang.Object

com.linkedin.venice.controllerapi.ControllerClient

com.linkedin.venice.controllerapi.D2ControllerClient

All Implemented Interfaces:

Closeable, AutoCloseable

public class D2ControllerClient
extends ControllerClient

Constructor Summary

Constructors

Constructor	Description
D2ControllerClient(String d2ServiceName, String clusterName, com.linkedin.d2.balancer.D2Client d2Client)
D2ControllerClient(String d2ServiceName, String clusterName, com.linkedin.d2.balancer.D2Client d2Client, Optional<SSLFactory> sslFactory)
D2ControllerClient(String d2ServiceName, String clusterName, String d2ZkHost, Optional<SSLFactory> sslFactory)
D2ControllerClient(String d2ServiceName, String clusterName, List<com.linkedin.d2.balancer.D2Client> d2Clients, Optional<SSLFactory> sslFactory)
D2ControllerClient(String d2ServiceName, String clusterName, Optional<SSLFactory> sslFactory, List<String> d2ZkHosts)

Method Summary

Modifier and Type	Method	Description
void	close()
static URL	convertToSecureUrl(URL url)	Deprecated.
static URL	convertToSecureUrl(URL url, int port)	Deprecated.
static D2ServiceDiscoveryResponse	discoverCluster(com.linkedin.d2.balancer.D2Client d2Client, String d2ServiceName, String storeName)
static D2ServiceDiscoveryResponse	discoverCluster(com.linkedin.d2.balancer.D2Client d2Client, String d2ServiceName, String storeName, int retryAttempts)
D2ServiceDiscoveryResponse	discoverCluster(String storeName)
static D2ServiceDiscoveryResponse	discoverCluster(String d2ZkHost, String d2ServiceName, String storeName, int retryAttempts)	Deprecated.
static D2ServiceDiscoveryResponse	discoverCluster(String d2ZkHost, String d2ServiceName, String storeName, int retryAttempts, Optional<SSLFactory> sslFactory)
protected String	discoverLeaderController()	Discover leader controller from a list of D2 Clients.

Methods inherited from class com.linkedin.venice.controllerapi.ControllerClient

abortMigration, addDerivedSchema, addDerivedSchema, addNodeIntoAllowList, addValueSchema, addValueSchema, addValueSchema, addVersionAndStartIngestion, checkResourceCleanupForStoreCreation, cleanupInstanceCustomizedStates, compareStore, completeMigration, configureActiveActiveReplicationForCluster, constructClusterControllerClient, constructClusterControllerClient, copyOverStoreMetadata, createNewStore, createNewStore, createNewStoreWithParameters, createNewSystemStore, createStoragePersona, dataRecovery, deleteAclForStore, deleteAllVersions, deleteKafkaTopic, deleteOldVersion, deleteStoragePersona, deleteStore, deleteValueSchemas, disableAndDeleteStore, discoverAndConstructControllerClient, discoverCluster, emptyPush, enableMaxCapacityProtection, enableQuotaRebalanced, enableStoreReads, enableStoreReadWrites, enableStoreWrites, enableThrottling, encodeQueryParams, getAclForStore, getAdminCommandExecution, getAdminTopicMetadata, getAggregatedHealthStatus, getAllReplicationMetadataSchemas, getAllValueAndDerivedSchema, getAllValueSchema, getBackupVersions, getClusterName, getClusterStaleStores, getClusterStoragePersonas, getClusterStores, getControllerDiscoveryUrls, getDeletableStoreTopics, getFutureVersions, getHeartbeatFromSystemStore, getInUseSchemaIds, getKafkaTopicConfigs, getKeySchema, getLastSucceedExecutionId, getLeaderControllerUrl, getMigrationPushStrategies, getQueryParamsToDiscoverCluster, getRegionPushDetails, getRepushInfo, getRoutersClusterConfig, getStorageEngineOverheadRatio, getStoragePersona, getStoragePersonaAssociatedWithStore, getStore, getStore, getStore, getStoreLargestUsedVersion, getValueOrDerivedSchemaId, getValueSchema, getValueSchemaID, isNodeRemovable, isNodeRemovable, isStoreMigrationAllowed, isStoreVersionReadyForDataRecovery, killOfflinePushJob, listBootstrappingVersions, listChildControllers, listInstancesStatuses, listReplicas, listStorageNodeReplicas, listStorageNodes, listStorePushInfo, listStoresStatuses, migrateStore, newParams, nodeReplicasReadiness, overrideSetActiveVersion, prepareDataRecovery, queryDetailedJobStatus, queryJobStatus, queryJobStatus, queryJobStatus, queryJobStatus, queryOverallJobStatus, queryOverallJobStatus, queryStoreList, queryStoreList, queryStoreList, removeDerivedSchema, removeNodeFromAllowList, removeNodeFromCluster, removeStoreFromGraveyard, requestTopicForWrites, requestTopicForWrites, requestTopicForWrites, retryableRequest, retryableRequest, retryableRequest, retryableRequest, rollbackToBackupVersion, rollbackToBackupVersion, rollForwardToFutureVersion, rollForwardToFutureVersion, sendEmptyPushAndWait, sendHeartbeatToSystemStore, sendPushJobDetails, setMigrationPushStrategy, setStoreOwner, setStorePartitionCount, skipAdminMessage, updateAclForStore, updateAdminTopicMetadata, updateClusterConfig, updateKafkaTopicLogCompaction, updateKafkaTopicMinInSyncReplica, updateKafkaTopicRetention, updateStoragePersona, updateStore, wipeCluster, writeEndOfPush

Methods inherited from class java.lang.Object

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

Constructor Details

D2ControllerClient

public D2ControllerClient(String d2ServiceName,
 String clusterName,
 String d2ZkHost,
 Optional<SSLFactory> sslFactory)

D2ControllerClient

public D2ControllerClient(String d2ServiceName,
 String clusterName,
 com.linkedin.d2.balancer.D2Client d2Client)

D2ControllerClient

public D2ControllerClient(String d2ServiceName,
 String clusterName,
 com.linkedin.d2.balancer.D2Client d2Client,
 Optional<SSLFactory> sslFactory)

D2ControllerClient

public D2ControllerClient(String d2ServiceName,
 String clusterName,
 List<com.linkedin.d2.balancer.D2Client> d2Clients,
 Optional<SSLFactory> sslFactory)

D2ControllerClient

public D2ControllerClient(String d2ServiceName,
 String clusterName,
 Optional<SSLFactory> sslFactory,
 List<String> d2ZkHosts)

Method Details

discoverLeaderController

protected String discoverLeaderController()

Discover leader controller from a list of D2 Clients.

Overrides:

discoverLeaderController in class ControllerClient

Returns:

leader controller url

discoverCluster

public static D2ServiceDiscoveryResponse discoverCluster(com.linkedin.d2.balancer.D2Client d2Client,
 String d2ServiceName,
 String storeName)

discoverCluster

@Deprecated
public static D2ServiceDiscoveryResponse discoverCluster(String d2ZkHost,
 String d2ServiceName,
 String storeName,
 int retryAttempts)

Deprecated.

discoverCluster

public static D2ServiceDiscoveryResponse discoverCluster(String d2ZkHost,
 String d2ServiceName,
 String storeName,
 int retryAttempts,
 Optional<SSLFactory> sslFactory)

discoverCluster

public static D2ServiceDiscoveryResponse discoverCluster(com.linkedin.d2.balancer.D2Client d2Client,
 String d2ServiceName,
 String storeName,
 int retryAttempts)

discoverCluster

public D2ServiceDiscoveryResponse discoverCluster(String storeName)

Overrides:

discoverCluster in class ControllerClient

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class ControllerClient

convertToSecureUrl

@Deprecated
public static URL convertToSecureUrl(URL url)
                              throws MalformedURLException

Deprecated.

Convert a HTTP url to HTTPS url with 1578 port number; TODO: remove the below helper functions after Controller ACL migration.

Throws:

MalformedURLException

convertToSecureUrl

@Deprecated
public static URL convertToSecureUrl(URL url,
 int port)
                              throws MalformedURLException

Deprecated.

Convert a HTTP url to HTTPS url with specific port number; TODO: remove the below helper functions after Controller ACL migration.

Throws:

MalformedURLException