| AbstractSchemaEntrySerializer<T extends GeneratedSchemaEntry> |
|
| CachedReadOnlyStoreRepository |
|
| CachedResourceZkStateListener |
Listener used to monitor zk connection state change and refresh venice resource once zk connection is reconnected.
|
| DerivedSchemaEntrySerializer |
This class is registered in ZKClient to handle derive schema serialization.
|
| HelixAdapterSerializer |
Serializer to adapt venice serializer to PathBasedZkSerializer.
|
| HelixBaseRoutingRepository |
Get routing data from Helix and convert it to our Venice partition and replica objects.
|
| HelixCustomizedViewOfflinePushRepository |
|
| HelixExternalViewRepository |
Extend HelixBaseRoutingRepository to leverage external view data.
|
| HelixHybridStoreQuotaRepository |
Extend RoutingTableChangeListener to leverage customized view data for hybrid store quota.
|
| HelixInstanceConfigRepository |
This repository is used to store the instance config per instance.
|
| HelixInstanceConverter |
Convert between ZNRecord in Helix instanceConfig and Venice instance.
|
| HelixLiveInstanceMonitor |
This class is used to monitor the current live instances(Helix participators).
|
| HelixPartitionStateAccessor |
A parent class to access Helix customized partition state, which is different from the states
defined in the state model.
|
| HelixPartitionStatusAccessor |
A class for accessing partition offline push and hybrid quota status in Helix customized state (per Helix
instance) on Zookeeper
|
| HelixReadOnlyLiveClusterConfigRepository |
This class is used to cache live cluster configs.
|
| HelixReadOnlySchemaRepository |
This class is used to cache store schema and provide various query operations.
|
| HelixReadOnlySchemaRepositoryAdapter |
This repository provides the read-only access to both system stores and regular stores.
|
| HelixReadOnlyStoreConfigRepository |
This class is used to fetch all store configs from ZK and cached locally, then provide the way to read those
configs.
|
| HelixReadOnlyStoreRepository |
|
| HelixReadOnlyStoreRepositoryAdapter |
This repository provides an read only interface to access both system store and regular venice store.
|
| HelixReadOnlyZKSharedSchemaRepository |
This repository is used to retrieve all the zk shared system store schemas from the system store cluster.
|
| HelixReadOnlyZKSharedSystemStoreRepository |
This repository provides an interface to access zk shared system stores only.
|
| HelixReadWriteLiveClusterConfigRepository |
This class is used to modify live cluster configs.
|
| HelixReadWriteSchemaRepository |
This class is used to add schema entries for stores.
|
| HelixReadWriteSchemaRepositoryAdapter |
This repository supports the following operations:
1.
|
| HelixReadWriteStoreRepository |
Read write store repository which uses Helix as storage.
|
| HelixReadWriteStoreRepositoryAdapter |
This repository provides an read-write interface to access both system store and regular venice store.
|
| HelixSchemaAccessor |
|
| HelixStatusMessageChannel |
The control message changed built on Helix message service.
|
| HelixStoreGraveyard |
|
| OfflinePushStatusJSONSerializer |
|
| OfflinePushStatusJSONSerializer.OfflinePushStatusSerializerMixin |
|
| OfflinePushStatusJSONSerializer.StatusSnapshotSerializerMixin |
|
| ParentHelixOfflinePushAccessor |
|
| PartitionStatusJSONSerializer |
|
| PartitionStatusJSONSerializer.PartitionStatusSerializerMixin |
|
| PartitionStatusJSONSerializer.ReplicaStatusSerializerMixin |
|
| Replica |
Replica is the basic unit to distribute data, replica is belong to a partition and running in a instance.
|
| ReplicationMetadataSchemaEntrySerializer |
This class is registered in ZKClient to handle Replication metadata schema serialization.
|
| ResourceAssignment |
Assignments for all of resources.
|
| ResourceAssignment.ResourceAssignmentChanges |
|
| RouterClusterConfigJSONSerializer |
Serializer used to convert data between RouterClusterConfig Object and JSON string
|
| SafeHelixDataAccessor |
A wrapper around HelixDataAccessor which disables the unsafe functionality.
|
| SafeHelixManager |
A wrapper around HelixManager which disables the unsafe functionality.
|
| SchemaEntrySerializer |
This class to use to serialize/deserialize Zookeeper node
|
| StoragePersonaRepository |
Cached wrapper for the StoragePersonaAccessor class, which keeps a map of store names to personas that
contain them, as well as caches Zookeeper personas. |
| StoragePersonaRepository.StoragePersonaStoreDataListener |
Helper class which listens to changes from a ReadOnlyStoreRepository and updates the caches and ZK of the
StoragePersonaRepository accordingly. |
| StoreConfigJsonSerializer |
|
| StoreConfigJsonSerializer.StoreConfigSerializerMixin |
|
| StoreJSONSerializer |
Serializer used to convert the data between Store and json.
|
| StoreJSONSerializer.ETLStoreConfigSerializerMixin |
|
| StoreJSONSerializer.HybridStoreConfigSerializerMixin |
Mixin used to add the annotation to figure out the constructor used by Jackson lib when deserialize the version
|
| StoreJSONSerializer.PartitionerConfigSerializerMixin |
|
| StoreJSONSerializer.StoreSerializerMixin |
Mixin used to add the annotation to figure out the constructor used by Jackson lib when deserialize the store.
|
| StoreJSONSerializer.VersionSerializerMixin |
Mixin used to add the annotation to figure out the constructor used by Jackson lib when deserialize the version
|
| StoreJSONSerializer.ViewConfigSerializerMixin |
|
| SubscriptionBasedStoreRepository |
|
| SystemStoreJSONSerializer |
|
| SystemStoreJSONSerializer.SystemStoreSerializerMixin |
|
| VeniceJsonSerializer<T> |
|
| VeniceOfflinePushMonitorAccessor |
|
| ZkAllowlistAccessor |
Class used to access to the allowlist stored in ZK.
|
| ZkClientFactory |
|
| ZkRoutersClusterManager |
Manage live routers through Zookeeper.
|
| ZkStoreConfigAccessor |
The class is used to access the store configs in Zookeeper.
|