| ArrayUtils |
|
| AvroCompatibilityUtils |
|
| AvroRecordUtils |
|
| AvroSchemaUtils |
|
| AvroSupersetSchemaUtils |
|
| BoundedHashMap<K,V> |
A map implementation with a bounded size.
|
| ByteArray |
|
| ByteUtils |
Utility functions for munging on bytes
N.B.: Most functions taken from Voldemort's ByteUtils class.
|
| ChunkingTestUtils |
|
| CollectionUtils |
|
| ComplementSet<T> |
A set that uses complement representation, which is useful when universal set cardinality is unknown.
|
| ConcurrentRef<T> |
|
| DaemonThreadFactory |
A thread factory that sets the threads to run as daemons.
|
| DataProviderUtils |
This class gathers all common data provider patterns in test cases.
|
| DictionaryUtils |
|
| DiskUsage |
We define a threshold where we consider the disk to be full.
|
| EncodingUtils |
|
| EnumUtils |
|
| ExceptionCaptorNotifier |
|
| ExceptionUtils |
Static utility functions to deal with exceptions.
|
| ForkedJavaProcess |
Adapted from https://stackoverflow.com/a/723914/791758
|
| ForkedJavaProcess.LogInfo |
|
| HashCodeComparator<T> |
|
| HelixUtils |
Helper functions for Helix.
|
| InMemoryLogAppender |
|
| InMemoryLogAppender.Builder |
|
| IteratorUtils |
|
| KafkaSSLUtils |
|
| KeyAndValueSchemas |
|
| LatencyUtils |
|
| MockCircularTime |
A mock time that takes a list of synthetic timestamps in MS and return them one by one in a circular manner.
|
| MockTestStateModelFactory |
|
| MockTestStateModelFactory.OnlineOfflineStateModel |
|
| NamedThreadFactory |
A thread factory that sets the threads to create threads with a specific prefix name.
|
| NettyUtils |
|
| ObjectMapperFactory |
|
| Pair<F,S> |
Deprecated.
|
| PartitionUtils |
|
| PropertyBuilder |
PropertyBuilder is the suggested Way to construct VeniceProperties.
|
| PubSubHelper |
|
| PubSubHelper.MutablePubSubMessage |
|
| PushInputSchemaBuilder |
This class is a simple schema builder to generate Venice Push Job input file schema.
|
| RandomAccessDaemonThreadFactory |
|
| RandomGenUtils |
|
| RedundantExceptionFilter |
|
| ReferenceCounted<T> |
|
| ReflectUtils |
Utilities for reflection
TODO This class may not be needed if we decide to proceed with Guice library
for reflections and need to be discarded then
|
| RegionUtils |
|
| RetryUtils |
|
| SharedObjectFactory<T> |
A factory class to create shared objects that need to release resources cleanly.
|
| SparseConcurrentList<E> |
A List implementation with some usability improvements around resizing.
|
| SparseConcurrentListWithOffset<E> |
|
| SslUtils |
|
| SslUtils.VeniceTlsConfiguration |
This class is used to configure TLS for Venice components in integration tests.
|
| SslUtils.VeniceTlsConfiguration.Builder |
|
| StoreUtils |
|
| SystemTime |
Time implementation that just reads from the system clock |
| TestMockTime |
A Time implementation which abstracts logical time away from real
time, so that it can be deterministically controlled. |
| TestStoragePersonaUtils |
|
| TestUtils |
General-purpose utility functions for tests.
|
| TestWriteUtils |
|
| TrieBasedPathResourceRegistry<T> |
This class implements a generic trie-based lookup tree.
|
| Utils |
Helper functions
|
| Utils.ConfigEntity<T> |
This class encapsulates config entity information such as config name, default value, config document
|
| ValueHolder<T> |
|
| VeniceEnumValueTest<T extends VeniceEnumValue> |
Abstract class which makes it as easy as possible to generically test all the assumptions for enums which implement
the VeniceEnumValue interface. |
| VeniceLock |
Venice wrapper around a Lock object to record metrics and emit logs when lock acquisition is taking too long.
|
| VeniceProperties |
|