Package com.linkedin.venice.admin

Class InMemoryAdminTopicMetadataAccessor

java.lang.Object

com.linkedin.venice.controller.AdminTopicMetadataAccessor

com.linkedin.venice.admin.InMemoryAdminTopicMetadataAccessor

public class InMemoryAdminTopicMetadataAccessor
extends AdminTopicMetadataAccessor

In memory implementation of AdminTopicMetadataAccessor, should only be used for testing purposes.

Field Summary

Fields inherited from class com.linkedin.venice.controller.AdminTopicMetadataAccessor

ADMIN_OPERATION_PROTOCOL_VERSION_KEY, EXECUTION_ID_KEY, OFFSET_KEY, POSITION_KEY, UNDEFINED_VALUE, UPSTREAM_OFFSET_KEY, UPSTREAM_POSITION_KEY

Constructor Summary

Constructors

Constructor	Description
InMemoryAdminTopicMetadataAccessor()

Method Summary

Modifier and Type	Method	Description
AdminMetadata	getMetadata(String clusterName)	Retrieve the latest metadata.
void	updateMetadata(String clusterName, AdminMetadata metadataDelta)	Update specific metadata for a given cluster in a single transaction with information provided in metadata.

Methods inherited from class com.linkedin.venice.controller.AdminTopicMetadataAccessor

generateMetadataMap, getAdminOperationProtocolVersion, getExecutionId, getExecutionId, getOffsets, getOffsets, getPositions

Methods inherited from class java.lang.Object

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

Constructor Details

InMemoryAdminTopicMetadataAccessor

public InMemoryAdminTopicMetadataAccessor()

Method Details

updateMetadata

public void updateMetadata(String clusterName,
 AdminMetadata metadataDelta)

Description copied from class: AdminTopicMetadataAccessor

Update specific metadata for a given cluster in a single transaction with information provided in metadata.

Specified by:

updateMetadata in class AdminTopicMetadataAccessor

Parameters:

clusterName - of the cluster at interest.

metadataDelta - AdminMetadata containing relevant information.

getMetadata

public AdminMetadata getMetadata(String clusterName)

Description copied from class: AdminTopicMetadataAccessor

Retrieve the latest metadata.

Specified by:

getMetadata in class AdminTopicMetadataAccessor

Parameters:

clusterName - of the cluster at interest.

Returns:

AdminMetadata containing all metadata information