Package com.linkedin.venice

Enum Class Command

java.lang.Object

java.lang.Enum<Command>

com.linkedin.venice.Command

All Implemented Interfaces:

Serializable, Comparable<Command>, Constable

public enum Command
extends Enum<Command>

TODO: Merge this with ControllerRoute COMMAND ( "long-name", "short-name", "description", "required-args", "optional-args" )

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Enum

Enum.EnumDesc<E extends Enum<E>>

Enum Constant Summary

Enum Constants

Enum Constant	Description
ABORT_MIGRATION
ADD_DERIVED_SCHEMA
ADD_SCHEMA
ADD_SCHEMA_TO_ZK
ADD_TO_STORE_ACL
AGGREGATED_HEALTH_STATUS
ALLOW_LIST_ADD_NODE
ALLOW_LIST_REMOVE_NODE
BACKFILL_SYSTEM_STORES
BACKUP_STORE_METADATA_FROM_GRAVEYARD
CHECK_FABRIC_BUILDOUT_STATUS
CLEANUP_INSTANCE_CUSTOMIZED_STATES
CLUSTER_BATCH_TASK
CLUSTER_HEALTH_INSTANCES
CLUSTER_HEALTH_STORES
COMPARE_STORE
COMPLETE_MIGRATION
CONFIGURE_STORE_VIEW
CONVERT_VSON_SCHEMA
DELETE_ALL_VERSIONS
DELETE_KAFKA_TOPIC
DELETE_OLD_VERSION
DELETE_STORAGE_PERSONA
DELETE_STORE
DELETE_STORE_ACL
DESCRIBE_STORE
DESCRIBE_STORES
DISABLE_ACTIVE_ACTIVE_REPLICATION_FOR_CLUSTER
DISABLE_MAX_CAPACITY_PROTECTION
DISABLE_QUTOA_REBALANCE
DISABLE_STORE
DISABLE_STORE_READ
DISABLE_STORE_WRITE
DISABLE_THROTTLING
DUMP_ADMIN_MESSAGES
DUMP_CONTROL_MESSAGES
DUMP_HOST_HEARTBEAT
DUMP_INGESTION_STATE
DUMP_KAFKA_TOPIC
DUMP_TOPIC_PARTITION_INGESTION_CONTEXT
EMPTY_PUSH
ENABLE_ACTIVE_ACTIVE_REPLICATION_FOR_CLUSTER
ENABLE_MAX_CAPACITY_PROTECTION
ENABLE_QUTOA_REBALANCE
ENABLE_STORE
ENABLE_STORE_READ
ENABLE_STORE_WRITE
ENABLE_THROTTLING
END_FABRIC_BUILDOUT
END_MIGRATION
ESTIMATE_DATA_RECOVERY_TIME
EXECUTE_DATA_RECOVERY
EXTRACT_VENICE_ZK_PATHS
GET_ALL_MIGRATION_PUSH_STRATEGIES
GET_DELETABLE_STORE_TOPICS
GET_EXECUTION
GET_KAFKA_TOPIC_CONFIGS
GET_MIGRATION_PUSH_STRATEGY
GET_ROUTERS_CLUSTER_CONFIG
GET_STORAGE_PERSONA
GET_STORAGE_PERSONA_FOR_STORE
GET_STORE_ACL
JOB_STATUS
KILL_JOB
LIST_BOOTSTRAPPING_VERSIONS
LIST_CLUSTER_STALE_STORES
LIST_CLUSTER_STORAGE_PERSONAS
LIST_STORAGE_NODES
LIST_STORE_PUSH_INFO
LIST_STORES
MIGRATE_STORE
MIGRATE_VENICE_ZK_PATHS
MIGRATION_STATUS
MONITOR_DATA_RECOVERY
NEW_STORAGE_PERSONA
NEW_STORE
NEW_STORE_ACL
NODE_REMOVABLE
QUERY
QUERY_KAFKA_TOPIC
RECOVER_STORE_METADATA
REMOVE_DERIVED_SCHEMA
REMOVE_FROM_STORE_ACL
REMOVE_NODE
REPLICAS_OF_STORE
REPLICAS_ON_STORAGE_NODE
REPLICAS_READINESS_ON_STORAGE_NODE
REPLICATE_META_DATA
REQUEST_BASED_METADATA
REQUEST_BASED_STORE_PROPERTIES
SEND_END_OF_PUSH
SET_MIGRATION_PUSH_STRATEGY
SET_OWNER
SET_PARTITION_COUNT
SET_VERSION
SHOW_SCHEMAS
SKIP_ADMIN
START_FABRIC_BUILDOUT
UPDATE_CLUSTER_CONFIG
UPDATE_KAFKA_TOPIC_LOG_COMPACTION
UPDATE_KAFKA_TOPIC_MIN_IN_SYNC_REPLICA
UPDATE_KAFKA_TOPIC_RETENTION
UPDATE_STORAGE_PERSONA
UPDATE_STORE
UPDATE_STORE_ACL
WIPE_CLUSTER

Field Summary

Fields

Modifier and Type	Field	Description
static final Comparator<Command>	commandComparator

Method Summary

Modifier and Type	Method	Description
static Command	getCommand(String name, org.apache.commons.cli.CommandLine cmdLine)
String	getDesc()
Arg[]	getOptionalArgs()
Arg[]	getRequiredArgs()
String	toString()
static Command	valueOf(String name)	Returns the enum constant of this class with the specified name.
static Command[]	values()	Returns an array containing the constants of this enum class, in the order they are declared.

Methods inherited from class java.lang.Enum

clone, compareTo, describeConstable, equals, finalize, getDeclaringClass, hashCode, name, ordinal, valueOf

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Enum Constant Details

LIST_STORES

public static final Command LIST_STORES

DESCRIBE_STORE

public static final Command DESCRIBE_STORE

DESCRIBE_STORES

public static final Command DESCRIBE_STORES

DISABLE_STORE_WRITE

public static final Command DISABLE_STORE_WRITE

ENABLE_STORE_WRITE

public static final Command ENABLE_STORE_WRITE

DISABLE_STORE_READ

public static final Command DISABLE_STORE_READ

ENABLE_STORE_READ

public static final Command ENABLE_STORE_READ

DISABLE_STORE

public static final Command DISABLE_STORE

ENABLE_STORE

public static final Command ENABLE_STORE

JOB_STATUS

public static final Command JOB_STATUS

KILL_JOB

public static final Command KILL_JOB

SKIP_ADMIN

public static final Command SKIP_ADMIN

NEW_STORE

public static final Command NEW_STORE

DELETE_STORE

public static final Command DELETE_STORE

BACKFILL_SYSTEM_STORES

public static final Command BACKFILL_SYSTEM_STORES

CLUSTER_BATCH_TASK

public static final Command CLUSTER_BATCH_TASK

SET_VERSION

public static final Command SET_VERSION

ADD_SCHEMA

public static final Command ADD_SCHEMA

ADD_SCHEMA_TO_ZK

public static final Command ADD_SCHEMA_TO_ZK

ADD_DERIVED_SCHEMA

public static final Command ADD_DERIVED_SCHEMA

REMOVE_DERIVED_SCHEMA

public static final Command REMOVE_DERIVED_SCHEMA

LIST_STORAGE_NODES

public static final Command LIST_STORAGE_NODES

CLUSTER_HEALTH_INSTANCES

public static final Command CLUSTER_HEALTH_INSTANCES

CLUSTER_HEALTH_STORES

public static final Command CLUSTER_HEALTH_STORES

NODE_REMOVABLE

public static final Command NODE_REMOVABLE

ALLOW_LIST_ADD_NODE

public static final Command ALLOW_LIST_ADD_NODE

ALLOW_LIST_REMOVE_NODE

public static final Command ALLOW_LIST_REMOVE_NODE

REMOVE_NODE

public static final Command REMOVE_NODE

REPLICAS_OF_STORE

public static final Command REPLICAS_OF_STORE

REPLICAS_ON_STORAGE_NODE

public static final Command REPLICAS_ON_STORAGE_NODE

QUERY

public static final Command QUERY

SHOW_SCHEMAS

public static final Command SHOW_SCHEMAS

DELETE_ALL_VERSIONS

public static final Command DELETE_ALL_VERSIONS

DELETE_OLD_VERSION

public static final Command DELETE_OLD_VERSION

GET_EXECUTION

public static final Command GET_EXECUTION

SET_OWNER

public static final Command SET_OWNER

SET_PARTITION_COUNT

public static final Command SET_PARTITION_COUNT

UPDATE_STORE

public static final Command UPDATE_STORE

UPDATE_CLUSTER_CONFIG

public static final Command UPDATE_CLUSTER_CONFIG

EMPTY_PUSH

public static final Command EMPTY_PUSH

ENABLE_THROTTLING

public static final Command ENABLE_THROTTLING

DISABLE_THROTTLING

public static final Command DISABLE_THROTTLING

ENABLE_MAX_CAPACITY_PROTECTION

public static final Command ENABLE_MAX_CAPACITY_PROTECTION

DISABLE_MAX_CAPACITY_PROTECTION

public static final Command DISABLE_MAX_CAPACITY_PROTECTION

ENABLE_QUTOA_REBALANCE

public static final Command ENABLE_QUTOA_REBALANCE

DISABLE_QUTOA_REBALANCE

public static final Command DISABLE_QUTOA_REBALANCE

GET_ROUTERS_CLUSTER_CONFIG

public static final Command GET_ROUTERS_CLUSTER_CONFIG

CONVERT_VSON_SCHEMA

public static final Command CONVERT_VSON_SCHEMA

GET_ALL_MIGRATION_PUSH_STRATEGIES

public static final Command GET_ALL_MIGRATION_PUSH_STRATEGIES

GET_MIGRATION_PUSH_STRATEGY

public static final Command GET_MIGRATION_PUSH_STRATEGY

SET_MIGRATION_PUSH_STRATEGY

public static final Command SET_MIGRATION_PUSH_STRATEGY

LIST_BOOTSTRAPPING_VERSIONS

public static final Command LIST_BOOTSTRAPPING_VERSIONS

DELETE_KAFKA_TOPIC

public static final Command DELETE_KAFKA_TOPIC

DUMP_ADMIN_MESSAGES

public static final Command DUMP_ADMIN_MESSAGES

DUMP_CONTROL_MESSAGES

public static final Command DUMP_CONTROL_MESSAGES

DUMP_KAFKA_TOPIC

public static final Command DUMP_KAFKA_TOPIC

QUERY_KAFKA_TOPIC

public static final Command QUERY_KAFKA_TOPIC

MIGRATE_STORE

public static final Command MIGRATE_STORE

MIGRATION_STATUS

public static final Command MIGRATION_STATUS

COMPLETE_MIGRATION

public static final Command COMPLETE_MIGRATION

ABORT_MIGRATION

public static final Command ABORT_MIGRATION

END_MIGRATION

public static final Command END_MIGRATION

SEND_END_OF_PUSH

public static final Command SEND_END_OF_PUSH

NEW_STORE_ACL

public static final Command NEW_STORE_ACL

UPDATE_STORE_ACL

public static final Command UPDATE_STORE_ACL

GET_STORE_ACL

public static final Command GET_STORE_ACL

DELETE_STORE_ACL

public static final Command DELETE_STORE_ACL

ADD_TO_STORE_ACL

public static final Command ADD_TO_STORE_ACL

REMOVE_FROM_STORE_ACL

public static final Command REMOVE_FROM_STORE_ACL

ENABLE_ACTIVE_ACTIVE_REPLICATION_FOR_CLUSTER

public static final Command ENABLE_ACTIVE_ACTIVE_REPLICATION_FOR_CLUSTER

DISABLE_ACTIVE_ACTIVE_REPLICATION_FOR_CLUSTER

public static final Command DISABLE_ACTIVE_ACTIVE_REPLICATION_FOR_CLUSTER

GET_DELETABLE_STORE_TOPICS

public static final Command GET_DELETABLE_STORE_TOPICS

WIPE_CLUSTER

public static final Command WIPE_CLUSTER

REPLICAS_READINESS_ON_STORAGE_NODE

public static final Command REPLICAS_READINESS_ON_STORAGE_NODE

COMPARE_STORE

public static final Command COMPARE_STORE

REPLICATE_META_DATA

public static final Command REPLICATE_META_DATA

LIST_CLUSTER_STALE_STORES

public static final Command LIST_CLUSTER_STALE_STORES

LIST_STORE_PUSH_INFO

public static final Command LIST_STORE_PUSH_INFO

GET_KAFKA_TOPIC_CONFIGS

public static final Command GET_KAFKA_TOPIC_CONFIGS

UPDATE_KAFKA_TOPIC_LOG_COMPACTION

public static final Command UPDATE_KAFKA_TOPIC_LOG_COMPACTION

UPDATE_KAFKA_TOPIC_RETENTION

public static final Command UPDATE_KAFKA_TOPIC_RETENTION

UPDATE_KAFKA_TOPIC_MIN_IN_SYNC_REPLICA

public static final Command UPDATE_KAFKA_TOPIC_MIN_IN_SYNC_REPLICA

START_FABRIC_BUILDOUT

public static final Command START_FABRIC_BUILDOUT

CHECK_FABRIC_BUILDOUT_STATUS

public static final Command CHECK_FABRIC_BUILDOUT_STATUS

END_FABRIC_BUILDOUT

public static final Command END_FABRIC_BUILDOUT

NEW_STORAGE_PERSONA

public static final Command NEW_STORAGE_PERSONA

GET_STORAGE_PERSONA

public static final Command GET_STORAGE_PERSONA

DELETE_STORAGE_PERSONA

public static final Command DELETE_STORAGE_PERSONA

UPDATE_STORAGE_PERSONA

public static final Command UPDATE_STORAGE_PERSONA

GET_STORAGE_PERSONA_FOR_STORE

public static final Command GET_STORAGE_PERSONA_FOR_STORE

LIST_CLUSTER_STORAGE_PERSONAS

public static final Command LIST_CLUSTER_STORAGE_PERSONAS

CLEANUP_INSTANCE_CUSTOMIZED_STATES

public static final Command CLEANUP_INSTANCE_CUSTOMIZED_STATES

EXECUTE_DATA_RECOVERY

public static final Command EXECUTE_DATA_RECOVERY

ESTIMATE_DATA_RECOVERY_TIME

public static final Command ESTIMATE_DATA_RECOVERY_TIME

MONITOR_DATA_RECOVERY

public static final Command MONITOR_DATA_RECOVERY

REQUEST_BASED_METADATA

public static final Command REQUEST_BASED_METADATA

REQUEST_BASED_STORE_PROPERTIES

public static final Command REQUEST_BASED_STORE_PROPERTIES

DUMP_INGESTION_STATE

public static final Command DUMP_INGESTION_STATE

DUMP_TOPIC_PARTITION_INGESTION_CONTEXT

public static final Command DUMP_TOPIC_PARTITION_INGESTION_CONTEXT

CONFIGURE_STORE_VIEW

public static final Command CONFIGURE_STORE_VIEW

RECOVER_STORE_METADATA

public static final Command RECOVER_STORE_METADATA

BACKUP_STORE_METADATA_FROM_GRAVEYARD

public static final Command BACKUP_STORE_METADATA_FROM_GRAVEYARD

MIGRATE_VENICE_ZK_PATHS

public static final Command MIGRATE_VENICE_ZK_PATHS

EXTRACT_VENICE_ZK_PATHS

public static final Command EXTRACT_VENICE_ZK_PATHS

AGGREGATED_HEALTH_STATUS

public static final Command AGGREGATED_HEALTH_STATUS

DUMP_HOST_HEARTBEAT

public static final Command DUMP_HOST_HEARTBEAT

Field Details

commandComparator

public static final Comparator<Command> commandComparator

Method Details

values

public static Command[] values()

Returns an array containing the constants of this enum class, in the order they are declared.

Returns:

an array containing the constants of this enum class, in the order they are declared

valueOf

public static Command valueOf(String name)

Returns the enum constant of this class with the specified name. The string must match exactly an identifier used to declare an enum constant in this class. (Extraneous whitespace characters are not permitted.)

Parameters:

name - the name of the enum constant to be returned.

Returns:

the enum constant with the specified name

Throws:

IllegalArgumentException - if this enum class has no constant with the specified name

NullPointerException - if the argument is null

toString

public String toString()

Overrides:

toString in class Enum<Command>

getRequiredArgs

public Arg[] getRequiredArgs()

getOptionalArgs

public Arg[] getOptionalArgs()

getDesc

public String getDesc()

getCommand

public static Command getCommand(String name,
 org.apache.commons.cli.CommandLine cmdLine)