Index (Aiven Commons Parent 3-SNAPSHOT API)

A B C D E F G H I J K L M N O P R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values

A

abort() - Method in class io.aiven.commons.timing.Timer: Aborts the timer.
abortTrigger - Variable in class io.aiven.commons.timing.Backoff: A function to call to abort the timer.
AbortTrigger - Interface in io.aiven.commons.timing: A functional interface that will abort the timer.
AbstractFragmentSetter<T extends AbstractFragmentSetter<T>> - Class in io.aiven.commons.kafka.config.fragment: An abstract class that is the bases for programmatic configuration easier.
AbstractFragmentSetter(Map<String, String>) - Constructor for class io.aiven.commons.kafka.config.fragment.AbstractFragmentSetter: Constructor.
add(K) - Method in class io.aiven.commons.collections.RingBuffer: Adds a new item if it is not already present.
ALLOW - Enum constant in enum class io.aiven.commons.collections.RingBuffer.DuplicateHandling: Allow duplicates in the buffer.
allowed(EnvCheck.Type, String) - Static method in class io.aiven.commons.system.EnvCheck: Checks if the URL is allowed as per the org.apache.kafka.sasl.oauthbearer.allowed.urls environment variable.
allowed(SystemCheck.Type, String) - Static method in class io.aiven.commons.system.SystemCheck: Checks if the URL is allowed as per the org.apache.kafka.sasl.oauthbearer.allowed.urls environment variable.
apply() - Method in interface io.aiven.commons.timing.AbortTrigger: Aborts the associated trigger.
applyTimerRule() - Method in interface io.aiven.commons.timing.BackoffConfig: Gets the abort timer rule flag.
applyTo(ConfigDef) - Method in class io.aiven.commons.kafka.config.SinceInfoMapBuilder: Applies the mapping to s the final versions for the specified Since values of the ExtendedConfigKeys in the ConfigDef.
artifactId() - Method in record class io.aiven.commons.kafka.config.SinceInfo.Data: Returns the value of the artifactId record component.
artifactId(String) - Method in class io.aiven.commons.kafka.config.SinceInfo.Builder: Sets the artifactId.
artifactVersion() - Method in class io.aiven.commons.kafka.config.SinceInfo: Gets the parsed ArtifactVersion for this sinceInfo.
as(CasedString.StringCase) - Method in class io.aiven.commons.strings.CasedString: Creates a new cased string from this one but with the new case.
asBytes(double) - Method in enum class io.aiven.commons.collections.Scale: Gets the number of bytes found in the specified number of units.
asMilliseconds(double) - Method in enum class io.aiven.commons.collections.TimeScale: Gets the number of milliseconds in the unitcount number of TimeUnits.
assemble(String[]) - Method in class io.aiven.commons.strings.CasedString.StringCase: Creates a cased string from a collection of segments.
atLeast(Number) - Static method in class io.aiven.commons.kafka.config.validator.TimeScaleValidator: A numeric range that checks only the lower bound.
atLeast(Number, List<Scale>) - Static method in class io.aiven.commons.kafka.config.validator.ScaleValidator: A scale range that checks only the lower bound

B

B - Enum constant in enum class io.aiven.commons.collections.Scale: A byte.
Backoff - Class in io.aiven.commons.timing: Performs a delay based on the number of successive Backoff.delay() or Backoff.cleanDelay() calls without a Backoff.reset().
Backoff(BackoffConfig) - Constructor for class io.aiven.commons.timing.Backoff: Constructor.
BackoffConfig - Interface in io.aiven.commons.timing: An interface to define the Backoff configuration.
BackoffPolicyFragment - Class in io.aiven.commons.kafka.config.fragment: Defines the backoff policy for connectors.
BackoffPolicyFragment(FragmentDataAccess) - Constructor for class io.aiven.commons.kafka.config.fragment.BackoffPolicyFragment: Constructor.
between(Number, Number) - Static method in class io.aiven.commons.kafka.config.validator.TimeScaleValidator: A numeric range that checks both the upper and lower bound.
between(Number, Number, List<Scale>) - Static method in class io.aiven.commons.kafka.config.validator.ScaleValidator: A scale range that checks both the upper and lower bound.
build() - Method in class io.aiven.commons.kafka.config.ConfigKeyBuilder: Builds a ConfigKey from the specified values.
build() - Method in class io.aiven.commons.kafka.config.DeprecatedInfo.Builder: Creates the DeprecatedInfo
build() - Method in class io.aiven.commons.kafka.config.ExtendedConfigKey.Builder
build() - Method in class io.aiven.commons.kafka.config.SinceInfo.Builder: Builds a SinceInfo without an override.
build() - Method in class io.aiven.commons.kafka.config.SinceInfoMapBuilder: Builds the final map.
build() - Method in class io.aiven.commons.kafka.config.validator.UrlValidator.Builder: Builds a UrlValidator.
builder() - Static method in class io.aiven.commons.kafka.config.DeprecatedInfo: Creates a new builder.
builder() - Static method in class io.aiven.commons.kafka.config.SinceInfo: The builder for SinceInfo and SinceInfo overrides.
builder() - Static method in class io.aiven.commons.kafka.config.validator.UrlValidator: Creates a new builder.
builder(String) - Static method in class io.aiven.commons.kafka.config.ExtendedConfigKey: Creates a builder for the ExtendedConfigKey.
Builder(String) - Constructor for class io.aiven.commons.kafka.config.ExtendedConfigKey.Builder: The builder.
bytes - Variable in enum class io.aiven.commons.collections.Scale: The number of bytes in a single unit of the scale.

C

CAMEL - Static variable in class io.aiven.commons.strings.CasedString.StringCase: Camel case tags strings like 'CamelCase' or 'camelCase'.
CasedString - Class in io.aiven.commons.strings: Handles converting from one string case to another (e.g. camel case to snake case).
CasedString(CasedString.StringCase, String) - Constructor for class io.aiven.commons.strings.CasedString: A representation of a cased string and the identified case of that string.
CasedString(CasedString.StringCase, String[]) - Constructor for class io.aiven.commons.strings.CasedString: A representation of a cased string and the identified case of that string.
CasedString.StringCase - Class in io.aiven.commons.strings: An enumeration of supported string cases.
caseInsensitive(Class<? extends Enum<?>>) - Static method in class io.aiven.commons.kafka.config.validator.EnumValidator: Creates a case insensitive EnumValidator.
caseSensitive(Class<? extends Enum<?>>) - Static method in class io.aiven.commons.kafka.config.validator.EnumValidator: Creates a case sensitive EnumValidator.
ChangeTrackingMap(Map<String, Object>) - Constructor for class io.aiven.commons.kafka.config.CommonConfig.ChangeTrackingMap: Constructor.
cleanDelay() - Method in class io.aiven.commons.timing.Backoff: Like Backoff.delay() but swallows the InterruptedException.
CMD - Enum constant in enum class io.aiven.commons.system.EnvCheck.Type: validate an external command is in the list of commands
CMD - Enum constant in enum class io.aiven.commons.system.SystemCheck.Type: validate an external command is in the list of commands
COMMENT_CHAR - Static variable in class io.aiven.commons.kafka.config.SinceInfoMapBuilder: The comment character for comment lines in input files.
CommonConfig - Class in io.aiven.commons.kafka.config: The base configuration or all connectors.
CommonConfig(CommonConfigDef, Map<String, String>) - Constructor for class io.aiven.commons.kafka.config.CommonConfig: Constructor.
CommonConfig.ChangeTrackingMap - Class in io.aiven.commons.kafka.config: A map of values that allows overrides.
CommonConfigDef - Class in io.aiven.commons.kafka.config: The ConfigDef for the CommonConfig class.
CommonConfigDef() - Constructor for class io.aiven.commons.kafka.config.CommonConfigDef: Constructor .
CommonConfigFragment - Class in io.aiven.commons.kafka.config.fragment: The common configuration fragment.
CommonConfigFragment(FragmentDataAccess) - Constructor for class io.aiven.commons.kafka.config.fragment.CommonConfigFragment: Create a fragment instance from an AbstractConfig.
CommonConfigFragment.Setter - Class in io.aiven.commons.kafka.config.fragment: Setter to programmatically set values in the configuraiotn.
compareTo(SinceInfo.Data) - Method in record class io.aiven.commons.kafka.config.SinceInfo.Data
compareTo(SinceInfo.OverrideRange) - Method in class io.aiven.commons.kafka.config.SinceInfo.OverrideRange
compress(OutputStream) - Method in enum class io.aiven.commons.io.compression.CompressionType: Compresses an output stream.
CompressionType - Enum Class in io.aiven.commons.io.compression: Enumeration of standard compression types along with methods to compress and decompress standard file extensions for the type.
ConfigFragment - Class in io.aiven.commons.kafka.config.fragment: Config fragments encapsulate logical fragments of configuration that may be used across multiple Connectors or across the source/sink of a connector pair.
ConfigFragment(FragmentDataAccess) - Constructor for class io.aiven.commons.kafka.config.fragment.ConfigFragment: Construct the ConfigFragment.
ConfigKeyBuilder<T extends ConfigKeyBuilder<?>> - Class in io.aiven.commons.kafka.config: Builds Config Keys.
ConfigKeyBuilder(String) - Constructor for class io.aiven.commons.kafka.config.ConfigKeyBuilder: Creates an instance of a ConfigKeyBuilder.
contains(K) - Method in class io.aiven.commons.collections.RingBuffer: Determines if the item is in the buffer.
create(ConfigDef.ConfigKey) - Static method in class io.aiven.commons.kafka.config.ExtendedConfigKey: Creates an extended config key from a ConfigKey.

D

data() - Method in class io.aiven.commons.kafka.config.fragment.AbstractFragmentSetter: Gets the data map.
Data(SinceInfo.Builder) - Constructor for record class io.aiven.commons.kafka.config.SinceInfo.Data: Construct the Data object from a builder.
Data(String, String, String) - Constructor for record class io.aiven.commons.kafka.config.SinceInfo.Data: Creates an instance of a Data record class.
dataAccess - Variable in class io.aiven.commons.kafka.config.fragment.ConfigFragment: The data access object for this fragment.
DAYS - Enum constant in enum class io.aiven.commons.collections.TimeScale: days
decompress(InputStream) - Method in enum class io.aiven.commons.io.compression.CompressionType: Decompresses an input stream.
decompress(IOSupplier<InputStream>) - Method in enum class io.aiven.commons.io.compression.CompressionType: Decompresses an input stream wrapped in an IOSupplier
defaultValue - Variable in class io.aiven.commons.kafka.config.ConfigKeyBuilder: The default value for the config key.
defaultValue(Object) - Method in class io.aiven.commons.kafka.config.ConfigKeyBuilder: Sets the default value.
delay() - Method in class io.aiven.commons.timing.Backoff: Delay execution based on the number of times this method has been called.
DELETE - Enum constant in enum class io.aiven.commons.collections.RingBuffer.DuplicateHandling: Move the duplicate entry to the tail of the buffer.
dependent(String) - Method in class io.aiven.commons.kafka.config.ConfigKeyBuilder: Adds a dependent to the list of dependents.
dependents - Variable in class io.aiven.commons.kafka.config.ConfigKeyBuilder: The set of names for ConfigDef.ConfigKeys that are dependent upon this key.
dependents(String...) - Method in class io.aiven.commons.kafka.config.ConfigKeyBuilder: Add a collection of dependent names to the list of dependents.
dependents(Collection<String>) - Method in class io.aiven.commons.kafka.config.ConfigKeyBuilder: Add a collection of dependent names to the list of dependents.
deprecated - Variable in class io.aiven.commons.kafka.config.ExtendedConfigKey: The deprecation information.
deprecatedInfo(DeprecatedInfo) - Method in class io.aiven.commons.kafka.config.ExtendedConfigKey.Builder: Sets the deprecation info.
deprecatedInfo(DeprecatedInfo.Builder) - Method in class io.aiven.commons.kafka.config.ExtendedConfigKey.Builder: Sets the deprecation info.
DeprecatedInfo - Class in io.aiven.commons.kafka.config: Contains the information about a deprecated ConfigKey
DeprecatedInfo.Builder - Class in io.aiven.commons.kafka.config: The Builder for DeprecatedInfo.
DeprecationReporter - Class in io.aiven.commons.kafka.config: Reports on deprecated configuration usage.
description(String) - Method in class io.aiven.commons.kafka.config.DeprecatedInfo.Builder: Sets the description.
displayName - Variable in class io.aiven.commons.kafka.config.ConfigKeyBuilder: The display name for the key.
displayName(String) - Method in class io.aiven.commons.kafka.config.ConfigKeyBuilder: Sets the display name.
displayValue(long) - Method in enum class io.aiven.commons.collections.Scale: Creates a String using the scale. if the scale is not Scale.B then it is followed by the number of bytes within a set of parenthesis.
displayValue(long) - Method in enum class io.aiven.commons.collections.TimeScale: Format the number of milliseconds in this TimeScale along with the number of Milliseconds.
documentation - Variable in class io.aiven.commons.kafka.config.ConfigKeyBuilder: The documentation for this key.
documentation(String) - Method in class io.aiven.commons.kafka.config.ConfigKeyBuilder: Sets the documentation.
DOT - Static variable in class io.aiven.commons.strings.CasedString.StringCase: Dot case tags phrases of words like 'phrase.case'.

E

ensureValid(String, Object) - Method in class io.aiven.commons.kafka.config.validator.NonEmptyList
ensureValid(String, Object) - Method in class io.aiven.commons.kafka.config.validator.NonEmptyPassword
ensureValid(String, Object) - Method in class io.aiven.commons.kafka.config.validator.PredicateGatedValidator
ensureValid(String, Object) - Method in class io.aiven.commons.kafka.config.validator.ScaleValidator
ensureValid(String, Object) - Method in class io.aiven.commons.kafka.config.validator.TimeScaleValidator
ensureValid(String, Object) - Method in class io.aiven.commons.kafka.config.validator.TimeZoneValidator
ensureValid(String, Object) - Method in class io.aiven.commons.kafka.config.validator.UrlValidator
EnumValidator - Class in io.aiven.commons.kafka.config.validator: Validates that a configuration value string is a case-insensitive match to an Enum constant.
EnvCheck - Class in io.aiven.commons.system: Checks URLs against the URLs allowed as per the org.apache.kafka.sasl.oauthbearer.allowed.urls environment variable.
EnvCheck.Type - Enum Class in io.aiven.commons.system: The type of object being checked.
envVar() - Method in enum class io.aiven.commons.system.EnvCheck.Type: Get the environment variable name for this type.
equals(Object) - Method in class io.aiven.commons.collections.RingBuffer
equals(Object) - Method in record class io.aiven.commons.kafka.config.SinceInfo.Data: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in class io.aiven.commons.kafka.config.SinceInfo.OverrideRange
estimatedDelay() - Method in class io.aiven.commons.timing.Backoff: Calculates the delay without jitter.
ExtendedConfigKey - Class in io.aiven.commons.kafka.config: An extended ConfigDef.ConfigKey that added deprecation information, and since data.
ExtendedConfigKey.Builder<T extends ExtendedConfigKey.Builder<?>> - Class in io.aiven.commons.kafka.config: The builder for an ExtendedConfigKey.
extension() - Method in enum class io.aiven.commons.io.compression.CompressionType: Gets the file name extension associated with the compression.

F

FILE - Enum constant in enum class io.aiven.commons.system.EnvCheck.Type: validate a file name is in the list of files
FILE - Enum constant in enum class io.aiven.commons.system.SystemCheck.Type: validate a file name is in the list of files
finalize() - Method in class io.aiven.commons.kafka.config.CommonConfig: Avoid Finalizer attack
format(long) - Method in enum class io.aiven.commons.collections.Scale: Formats the byteCount at this scale.
format(long) - Method in enum class io.aiven.commons.collections.TimeScale: Format the number of milliseconds into this TimeScale.
formatError(EnvCheck.Type, String) - Static method in class io.aiven.commons.system.EnvCheck: Format the error message for the specified URL.
formatError(SystemCheck.Type, String) - Static method in class io.aiven.commons.system.SystemCheck: Format the error message for the specified URL.
formatted(String) - Method in class io.aiven.commons.kafka.config.DeprecatedInfo: Gets a string that contains the deprecated information.
forName(String) - Static method in enum class io.aiven.commons.io.compression.CompressionType: Gets the compression type for the specified name.
forRemoval(boolean) - Method in class io.aiven.commons.kafka.config.DeprecatedInfo.Builder: Sets whether this option is subject to removal in a future version.
FragmentDataAccess - Interface in io.aiven.commons.kafka.config.fragment: The data access for a ConfigFragment.
fragmentPostProcess(CommonConfig.ChangeTrackingMap) - Method in class io.aiven.commons.kafka.config.CommonConfig: Allows implementations to modify the values of the map from the fragments.
from(Map<String, ConfigValue>) - Static method in interface io.aiven.commons.kafka.config.fragment.FragmentDataAccess: Creates an implementation against a map of String to ConfigValues.
from(AbstractConfig) - Static method in interface io.aiven.commons.kafka.config.fragment.FragmentDataAccess: Creates an implementation against an AbstractConfig.

G

GB - Enum constant in enum class io.aiven.commons.collections.Scale: SI Scale Gigabttes
GCPValidator - Class in io.aiven.commons.google.auth: Validates credential information for the Google Cloud Platform.
generateDocumentation() - Method in class io.aiven.commons.kafka.config.ConfigKeyBuilder: Generates the documentation.
generateDocumentation() - Method in class io.aiven.commons.kafka.config.ExtendedConfigKey.Builder
get() - Method in interface io.aiven.commons.timing.SupplierOfLong: Gets the long value.
get(String) - Method in class io.aiven.commons.kafka.config.CommonConfig.ChangeTrackingMap: Gets the current value of the key.
getAbortTrigger() - Method in interface io.aiven.commons.timing.BackoffConfig: The AbortTrigger that will abort the timer or otherwise signal that the backoff has reached the maximum delay and will no longer sleep.
getBackoffConfig() - Method in class io.aiven.commons.timing.Timer: Gets a Backoff Config for this timer.
getBoolean(String) - Method in class io.aiven.commons.kafka.config.fragment.ConfigFragment
getBoolean(String) - Method in interface io.aiven.commons.kafka.config.fragment.FragmentDataAccess: Get the boolean value associated with the key.
getConfiguredInstance(String, Class<? extends T>) - Method in class io.aiven.commons.kafka.config.fragment.ConfigFragment
getConfiguredInstance(String, Class<? extends T>) - Method in interface io.aiven.commons.kafka.config.fragment.FragmentDataAccess: Creates a configured instance of the class specified by the key.
getDeprecationMessage() - Method in class io.aiven.commons.kafka.config.ExtendedConfigKey: Gets the deprecation message.
getDescription() - Method in class io.aiven.commons.kafka.config.DeprecatedInfo: Gets the descriptions.
getEnvVars() - Static method in class io.aiven.commons.system.EnvCheck: Return an updatable version of the environment variables.
getInt(String) - Method in class io.aiven.commons.kafka.config.fragment.ConfigFragment
getInt(String) - Method in interface io.aiven.commons.kafka.config.fragment.FragmentDataAccess: Get the integer value associated with the key.
getKafkaRetryBackoffMs() - Method in class io.aiven.commons.kafka.config.CommonConfig: Gets the Kafka retry backoff time in MS.
getKafkaRetryBackoffMs() - Method in class io.aiven.commons.kafka.config.fragment.BackoffPolicyFragment: Gets the kafka retry backoff time.
getList(String) - Method in class io.aiven.commons.kafka.config.fragment.ConfigFragment
getList(String) - Method in interface io.aiven.commons.kafka.config.fragment.FragmentDataAccess: Get the list of strings associated with the key.
getLong(String) - Method in class io.aiven.commons.kafka.config.fragment.ConfigFragment
getLong(String) - Method in interface io.aiven.commons.kafka.config.fragment.FragmentDataAccess: Get the long value associated with the key.
getMaxJitter() - Method in class io.aiven.commons.timing.Backoff: Calculates the range of jitter in milliseconds.
getMaxTasks() - Method in class io.aiven.commons.kafka.config.CommonConfig: Get the maximum number of tasks that should be run by this connector configuration Max Tasks is set within the Kafka Connect framework and so is retrieved slightly differently in ConnectorConfig.java
getMaxTasks() - Method in class io.aiven.commons.kafka.config.fragment.CommonConfigFragment: Get the maximum number of tasks.
getNextEjected() - Method in class io.aiven.commons.collections.RingBuffer: Gets the next item to be ejected.
getPassword(String) - Method in class io.aiven.commons.kafka.config.fragment.ConfigFragment
getPassword(String) - Method in interface io.aiven.commons.kafka.config.fragment.FragmentDataAccess: Get the password associated with the key.
getReason(int) - Static method in class io.aiven.commons.strings.HttpStrings: Obtains the reason phrase for a status code.
getSegments() - Method in class io.aiven.commons.strings.CasedString: Returns an array of each of the segments in this CasedString.
getSegments(String) - Method in class io.aiven.commons.strings.CasedString.StringCase: Returns an array of each of the segments in this CasedString.
getSince() - Method in class io.aiven.commons.kafka.config.DeprecatedInfo: Gets version in which the option became deprecated.
getSince() - Method in class io.aiven.commons.kafka.config.ExtendedConfigKey: Gets the value of since data element.
getSpecTitle() - Method in class io.aiven.commons.system.VersionInfo: Gets the specification title of the package.
getSpecVendor() - Method in class io.aiven.commons.system.VersionInfo: Gets the specification vendor of the package.
getSpecVersion() - Method in class io.aiven.commons.system.VersionInfo: Gets the specification version of the package.
getString(String) - Method in class io.aiven.commons.kafka.config.fragment.ConfigFragment
getString(String) - Method in interface io.aiven.commons.kafka.config.fragment.FragmentDataAccess: Gets the String value from the key.
getSupplierOfTimeRemaining() - Method in interface io.aiven.commons.timing.BackoffConfig: Gets Supplier that will return the number of milliseconds remaining in the timer.
getSystemProperty() - Method in enum class io.aiven.commons.system.SystemCheck.Type: Get the environment variable name for this type.
getTaskId() - Method in class io.aiven.commons.kafka.config.CommonConfig: Get the task id for this configuration
getTaskId() - Method in class io.aiven.commons.kafka.config.fragment.CommonConfigFragment: Get the task Id.
getTitle() - Method in class io.aiven.commons.system.VersionInfo: Gets the implementation title of the package.
getVendor() - Method in class io.aiven.commons.system.VersionInfo: Gets the implementation vendor of the package.
getVersion() - Method in class io.aiven.commons.system.VersionInfo: Gets the implementation version of the package.
GiB - Enum constant in enum class io.aiven.commons.collections.Scale: IEC Scale Gigabytes (2 ^ 30)
group - Variable in class io.aiven.commons.kafka.config.ConfigKeyBuilder: The group key is a part of.
group(String) - Method in class io.aiven.commons.kafka.config.ConfigKeyBuilder: Sets the name of the group.
groupId() - Method in record class io.aiven.commons.kafka.config.SinceInfo.Data: Returns the value of the groupId record component.
groupId(String) - Method in class io.aiven.commons.kafka.config.SinceInfo.Builder: Sets the groupId.
GZIP - Enum constant in enum class io.aiven.commons.io.compression.CompressionType: GZIP compression

H

has(String) - Method in class io.aiven.commons.kafka.config.fragment.ConfigFragment
has(String) - Method in interface io.aiven.commons.kafka.config.fragment.FragmentDataAccess: Determines if a key has been set.
hashCode() - Method in class io.aiven.commons.collections.RingBuffer
hashCode() - Method in record class io.aiven.commons.kafka.config.SinceInfo.Data: Returns a hash code value for this object.
hashCode() - Method in class io.aiven.commons.kafka.config.SinceInfo.OverrideRange
head() - Method in class io.aiven.commons.collections.RingBuffer: Returns but does not remove the head of the buffer.
hosts(String...) - Method in class io.aiven.commons.kafka.config.validator.UrlValidator.Builder: Adds one or more hosts to the list of valid hosts.
HOURS - Enum constant in enum class io.aiven.commons.collections.TimeScale: hours
HttpStatus - Class in io.aiven.commons.strings: Constants enumerating the HTTP status codes.
HttpStrings - Class in io.aiven.commons.strings: English reason phrases for HTTP status codes.

I

IEC - Static variable in enum class io.aiven.commons.collections.Scale: The International Electrotechnical Commission (IEC) standardized binary prefixes.
importance - Variable in class io.aiven.commons.kafka.config.ConfigKeyBuilder: The importance of this key.
importance(ConfigDef.Importance) - Method in class io.aiven.commons.kafka.config.ConfigKeyBuilder: Sets the importance.
INSTANCE - Static variable in class io.aiven.commons.kafka.config.validator.NonEmptyList: The instance of the NonEmptyPassword validator.
INSTANCE - Static variable in class io.aiven.commons.kafka.config.validator.NonEmptyPassword: The instance of the NonEmptyPassword validator.
INSTANCE - Static variable in class io.aiven.commons.kafka.config.validator.TimeZoneValidator: A TimeZone validator that does not accept null values.
internalConfig - Variable in class io.aiven.commons.kafka.config.ConfigKeyBuilder: The internal config key for this builder.
internalConfig(boolean) - Method in class io.aiven.commons.kafka.config.ConfigKeyBuilder: Sets the ConfigKeyBuilder.internalConfig flag.
io.aiven.commons.collections - module io.aiven.commons.collections: Collections module def
io.aiven.commons.collections - package io.aiven.commons.collections
io.aiven.commons.google - module io.aiven.commons.google: Google cloud utilities module def
io.aiven.commons.google.auth - package io.aiven.commons.google.auth
io.aiven.commons.io - module io.aiven.commons.io: IO utilities module def
io.aiven.commons.io.compression - package io.aiven.commons.io.compression
io.aiven.commons.kafka.config - module io.aiven.commons.kafka.config: Kafka configuration utilities module def
io.aiven.commons.kafka.config - package io.aiven.commons.kafka.config
io.aiven.commons.kafka.config.fragment - package io.aiven.commons.kafka.config.fragment
io.aiven.commons.kafka.config.validator - package io.aiven.commons.kafka.config.validator
io.aiven.commons.strings - package io.aiven.commons.strings
io.aiven.commons.system - module io.aiven.commons.system: System utilities module def
io.aiven.commons.system - package io.aiven.commons.system
io.aiven.commons.timing - module io.aiven.commons.timing: Timing module def
io.aiven.commons.timing - package io.aiven.commons.timing
isDeprecated() - Method in class io.aiven.commons.kafka.config.ExtendedConfigKey: Get the deprecated flag.
isExpired() - Method in class io.aiven.commons.timing.Timer: Returns true if the timer has expired.
isForRemoval() - Method in class io.aiven.commons.kafka.config.DeprecatedInfo: Tests whether this option is subject to removal in a future version.
isFull() - Method in class io.aiven.commons.collections.RingBuffer: Returns true if the buffer is full.

J

JITTER_SUBTRAHEND - Static variable in class io.aiven.commons.timing.Backoff: The value subtracted from the jitter to center it.

K

KB - Enum constant in enum class io.aiven.commons.collections.Scale: SI scale Kilobytes bytes
KEBAB - Static variable in class io.aiven.commons.strings.CasedString.StringCase: Kebab case tags strings like 'kebab-case'.
KiB - Enum constant in enum class io.aiven.commons.collections.Scale: IEC Scale Kilobytes (2 ^ 10).

L

logDeprecated(Logger, String) - Static method in class io.aiven.commons.kafka.config.fragment.ConfigFragment: Logs a deprecated message for a deprecated configuration key.
logDeprecated(Logger, String, String) - Static method in class io.aiven.commons.kafka.config.fragment.ConfigFragment: Logs a deprecated message for a deprecated configuration key.
logDeprecated(Logger, String, String, Object...) - Static method in class io.aiven.commons.kafka.config.fragment.ConfigFragment: Logs a deprecated message for a deprecated configuration key.

M

main(String[]) - Static method in class io.aiven.commons.system.VersionInfo: Main class to print version information.
matches(SinceInfo) - Method in class io.aiven.commons.kafka.config.SinceInfo.OverrideRange: Checks if this OverrideRange matches a SinceInfo.
MAX_JITTER - Static variable in class io.aiven.commons.timing.Backoff: The maximum jitter random number.
maxTasks(int) - Method in class io.aiven.commons.kafka.config.fragment.CommonConfigFragment.Setter: Sets the max tasks value.
MB - Enum constant in enum class io.aiven.commons.collections.Scale: SI scale Megabytes
MiB - Enum constant in enum class io.aiven.commons.collections.Scale: IEC Scale Megabytes (2 ^ 20)
milliseconds - Variable in enum class io.aiven.commons.collections.TimeScale: The number of milliseconds in one TimeUnit.
MILLISECONDS - Enum constant in enum class io.aiven.commons.collections.TimeScale: milliseconds
millisecondsRemaining() - Method in class io.aiven.commons.timing.Timer: Gets the maximum duration for this timer.
MINUTES - Enum constant in enum class io.aiven.commons.collections.TimeScale: minutes
multiValidate(Map<String, ConfigValue>) - Method in class io.aiven.commons.kafka.config.CommonConfigDef: Gathers in depth, multi argument configuration issues.

N

name - Variable in class io.aiven.commons.kafka.config.ConfigKeyBuilder: The name for the key.
NONE - Enum constant in enum class io.aiven.commons.io.compression.CompressionType: No compression
NonEmptyList - Class in io.aiven.commons.kafka.config.validator: Validator to ensure that a list is either @{code null} or non-empty.
NonEmptyPassword - Class in io.aiven.commons.kafka.config.validator: Validator to ensure that a password is set to either @{code null} or a non-empty string.

O

of(String) - Method in class io.aiven.commons.strings.Version: Retrieve a string for the property as defined in the property file.
orderInGroup - Variable in class io.aiven.commons.kafka.config.ConfigKeyBuilder: The order within the group.
orderInGroup(int) - Method in class io.aiven.commons.kafka.config.ConfigKeyBuilder: Sets the order in the group.
override(String, Object) - Method in class io.aiven.commons.kafka.config.CommonConfig.ChangeTrackingMap: Sets the override for a key.
OverrideRange(SinceInfo.Builder) - Constructor for class io.aiven.commons.kafka.config.SinceInfo.OverrideRange: Creates an OverrideRange from a SinceInfo.Builder.
overrideSince(SinceInfo.Builder) - Method in class io.aiven.commons.kafka.config.DeprecatedInfo: Sets the override for this SinceInfo.
overrideSince(SinceInfo.Builder) - Method in class io.aiven.commons.kafka.config.ExtendedConfigKey: Sets since override.
overrideSince(Map<SinceInfo.OverrideRange, SinceInfo.Data>) - Method in class io.aiven.commons.kafka.config.DeprecatedInfo: Sets the override from the Builder associated with the matching OverrideRange in the overrideMap.
overrideSince(Map<SinceInfo.OverrideRange, SinceInfo.Data>) - Method in class io.aiven.commons.kafka.config.ExtendedConfigKey: Sets the override from the Builder associated with the matching OverrideRange in the overrideMap.

P

parse(InputStream) - Method in class io.aiven.commons.kafka.config.SinceInfoMapBuilder: Read the map from an input stream.
PASCAL - Static variable in class io.aiven.commons.strings.CasedString.StringCase: Camel case tags strings like 'PascalCase' or 'pascalCase'.
PB - Enum constant in enum class io.aiven.commons.collections.Scale: SI Scale Petabytes
PHRASE - Static variable in class io.aiven.commons.strings.CasedString.StringCase: Phrase case tags phrases of words like 'phrase case'.
PiB - Enum constant in enum class io.aiven.commons.collections.Scale: IEC Scale Petabytes (2 ^ 50)
postProcessParsedConfig(Map<String, Object>) - Method in class io.aiven.commons.kafka.config.CommonConfig
PredicateGatedValidator - Class in io.aiven.commons.kafka.config.validator: A validator that is gated by a predicate.
PredicateGatedValidator(Predicate<Object>, ConfigDef.Validator) - Constructor for class io.aiven.commons.kafka.config.validator.PredicateGatedValidator: Constructor.
put(SinceInfo.OverrideRange, SinceInfo.Data) - Method in class io.aiven.commons.kafka.config.SinceInfoMapBuilder: Put a range and data into the map.
put(SinceInfo.OverrideRange, String) - Method in class io.aiven.commons.kafka.config.SinceInfoMapBuilder: Put an override range and final version into the map.
put(String, SinceInfo.Data) - Method in class io.aiven.commons.kafka.config.SinceInfoMapBuilder: Put an override pattern and the data into the map.
put(String, String) - Method in class io.aiven.commons.kafka.config.SinceInfoMapBuilder: Put an override pattern and the final version into the map.
put(String, String, String, SinceInfo.Data) - Method in class io.aiven.commons.kafka.config.SinceInfoMapBuilder: put the range definition and the data into the map.
put(String, String, String, String) - Method in class io.aiven.commons.kafka.config.SinceInfoMapBuilder: Put the override range data and final version into the map.

R

RECOMMENDED_PROPERTY - Static variable in class io.aiven.commons.strings.Version: The recommended property name for the project.version
recommender - Variable in class io.aiven.commons.kafka.config.ConfigKeyBuilder: The recommender for this key.
recommender(ConfigDef.Recommender) - Method in class io.aiven.commons.kafka.config.ConfigKeyBuilder: Sets the ConfigKeyBuilder.recommender.
registerIssue(Map<String, ConfigValue>, String, Object, String) - Method in class io.aiven.commons.kafka.config.fragment.ConfigFragment: Registers an issue in the Config map.
REJECT - Enum constant in enum class io.aiven.commons.collections.RingBuffer.DuplicateHandling: Reject (do not add) duplicates to the buffer.
remove(K) - Method in class io.aiven.commons.collections.RingBuffer: Removes a single instance of the item from the buffer.
report(AbstractConfig, ConfigDef) - Static method in class io.aiven.commons.kafka.config.DeprecationReporter: Generates a list of deprecation notices for deprecated items that have non-default values.
reset() - Method in class io.aiven.commons.timing.Backoff: Reset the backoff time so that delay is again at the minimum.
reset() - Method in class io.aiven.commons.timing.Timer
RingBuffer<K> - Class in io.aiven.commons.collections: Implements a ring buffer of items.
RingBuffer(int) - Constructor for class io.aiven.commons.collections.RingBuffer: Create a Ring Buffer of a maximum size that rejects duplicates.
RingBuffer(int, RingBuffer.DuplicateHandling) - Constructor for class io.aiven.commons.collections.RingBuffer: Create a Ring Buffer of specified maximum size and potentially allowing duplicates.
RingBuffer.DuplicateHandling - Enum Class in io.aiven.commons.collections: How to handle the duplicates in the buffer.

S

SC_ACCEPTED - Static variable in class io.aiven.commons.strings.HttpStatus: 202 Accepted (HTTP Semantics)
SC_ALREADY_REPORTED - Static variable in class io.aiven.commons.strings.HttpStatus: 208 Already Reported (WebDAV - RFC 5842, p.30, section 7.1)
SC_BAD_GATEWAY - Static variable in class io.aiven.commons.strings.HttpStatus: 502 Bad Gateway (HTTP Semantics)
SC_BAD_REQUEST - Static variable in class io.aiven.commons.strings.HttpStatus: 400 Bad Request (HTTP Semantics)
SC_CLIENT_ERROR - Static variable in class io.aiven.commons.strings.HttpStatus: 4xx Client Error (HTTP Semantics)
SC_CONFLICT - Static variable in class io.aiven.commons.strings.HttpStatus: 409 Conflict (HTTP Semantics)
SC_CONTINUE - Static variable in class io.aiven.commons.strings.HttpStatus: 100 Continue (HTTP Semantics)
SC_CREATED - Static variable in class io.aiven.commons.strings.HttpStatus: 201 Created (HTTP Semantics)
SC_EARLY_HINTS - Static variable in class io.aiven.commons.strings.HttpStatus: 103 Early Hints (Early Hints - RFC 8297)
SC_EXPECTATION_FAILED - Static variable in class io.aiven.commons.strings.HttpStatus: 417 Expectation Failed (HTTP Semantics)
SC_FAILED_DEPENDENCY - Static variable in class io.aiven.commons.strings.HttpStatus: 424 Failed Dependency (WebDAV - RFC 2518)
SC_FORBIDDEN - Static variable in class io.aiven.commons.strings.HttpStatus: 403 Forbidden (HTTP Semantics)
SC_GATEWAY_TIMEOUT - Static variable in class io.aiven.commons.strings.HttpStatus: 504 Gateway Timeout (HTTP Semantics)
SC_GONE - Static variable in class io.aiven.commons.strings.HttpStatus: 410 Gone (HTTP Semantics)
SC_HTTP_VERSION_NOT_SUPPORTED - Static variable in class io.aiven.commons.strings.HttpStatus: 505 HTTP Version Not Supported (HTTP Semantics)
SC_IM_USED - Static variable in class io.aiven.commons.strings.HttpStatus: 226 IM Used (Delta encoding in HTTP - RFC 3229, p. 30, section 10.4.1)
SC_INFORMATIONAL - Static variable in class io.aiven.commons.strings.HttpStatus: 100 1xx Informational (HTTP Semantics)
SC_INSUFFICIENT_SPACE_ON_RESOURCE - Static variable in class io.aiven.commons.strings.HttpStatus: Static constant for a 419 error.
SC_INSUFFICIENT_STORAGE - Static variable in class io.aiven.commons.strings.HttpStatus: 507 Insufficient Storage (WebDAV - RFC 2518)
SC_INTERNAL_SERVER_ERROR - Static variable in class io.aiven.commons.strings.HttpStatus: 500 Internal Server Error (HTTP Semantics)
SC_LENGTH_REQUIRED - Static variable in class io.aiven.commons.strings.HttpStatus: 411 Length Required (HTTP Semantics)
SC_LOCKED - Static variable in class io.aiven.commons.strings.HttpStatus: 423 Locked (WebDAV - RFC 2518)
SC_LOOP_DETECTED - Static variable in class io.aiven.commons.strings.HttpStatus: 508 Loop Detected (WebDAV - RFC 5842, p.33, section 7.2)
SC_METHOD_FAILURE - Static variable in class io.aiven.commons.strings.HttpStatus: Static constant for a 420 error.
SC_METHOD_NOT_ALLOWED - Static variable in class io.aiven.commons.strings.HttpStatus: 405 Method Not Allowed (HTTP Semantics)
SC_MISDIRECTED_REQUEST - Static variable in class io.aiven.commons.strings.HttpStatus: 421 Misdirected Request (HTTP Semantics)
SC_MOVED_PERMANENTLY - Static variable in class io.aiven.commons.strings.HttpStatus: 301 Moved Permanently (HTTP Semantics)
SC_MOVED_TEMPORARILY - Static variable in class io.aiven.commons.strings.HttpStatus: 302 Moved Temporarily (Sometimes Found) (HTTP Semantics)
SC_MULTI_STATUS - Static variable in class io.aiven.commons.strings.HttpStatus: 207 Multi-Status (WebDAV - RFC 2518) or 207 Partial Update OK (HTTP/1.1 - draft-ietf-http-v11-spec-rev-01?)
SC_MULTIPLE_CHOICES - Static variable in class io.aiven.commons.strings.HttpStatus: 300 Multiple Choices (HTTP Semantics)
SC_NETWORK_AUTHENTICATION_REQUIRED - Static variable in class io.aiven.commons.strings.HttpStatus: 511 Network Authentication Required (Additional HTTP Status Codes - RFC 6585)
SC_NO_CONTENT - Static variable in class io.aiven.commons.strings.HttpStatus: 204 No Content (HTTP Semantics)
SC_NON_AUTHORITATIVE_INFORMATION - Static variable in class io.aiven.commons.strings.HttpStatus: 203 Non Authoritative Information (HTTP Semantics)
SC_NOT_ACCEPTABLE - Static variable in class io.aiven.commons.strings.HttpStatus: 406 Not Acceptable (HTTP Semantics)
SC_NOT_EXTENDED - Static variable in class io.aiven.commons.strings.HttpStatus: 510 Not Extended (An HTTP Extension Framework - RFC 2774, p. 10, section 7)
SC_NOT_FOUND - Static variable in class io.aiven.commons.strings.HttpStatus: 404 Not Found (HTTP Semantics)
SC_NOT_IMPLEMENTED - Static variable in class io.aiven.commons.strings.HttpStatus: 501 Not Implemented (HTTP Semantics)
SC_NOT_MODIFIED - Static variable in class io.aiven.commons.strings.HttpStatus: 304 Not Modified (HTTP Semantics)
SC_OK - Static variable in class io.aiven.commons.strings.HttpStatus: 200 OK (HTTP Semantics)
SC_PARTIAL_CONTENT - Static variable in class io.aiven.commons.strings.HttpStatus: 206 Partial Content (HTTP Semantics)
SC_PAYMENT_REQUIRED - Static variable in class io.aiven.commons.strings.HttpStatus: 402 Payment Required (HTTP Semantics)
SC_PERMANENT_REDIRECT - Static variable in class io.aiven.commons.strings.HttpStatus: 308 Permanent Redirect (HTTP Semantics)
SC_PRECONDITION_FAILED - Static variable in class io.aiven.commons.strings.HttpStatus: 412 Precondition Failed (HTTP Semantics)
SC_PRECONDITION_REQUIRED - Static variable in class io.aiven.commons.strings.HttpStatus: 428 Precondition Required (Additional HTTP Status Codes - RFC 6585)
SC_PROCESSING - Static variable in class io.aiven.commons.strings.HttpStatus: 102 Processing (WebDAV - RFC 2518)
SC_PROXY_AUTHENTICATION_REQUIRED - Static variable in class io.aiven.commons.strings.HttpStatus: 407 Proxy Authentication Required (HTTP Semantics)
SC_REDIRECTION - Static variable in class io.aiven.commons.strings.HttpStatus: 3xx Redirection (HTTP Semantics)
SC_REQUEST_HEADER_FIELDS_TOO_LARGE - Static variable in class io.aiven.commons.strings.HttpStatus: 431 Request Header Fields Too Large (Additional HTTP Status Codes - RFC 6585)
SC_REQUEST_TIMEOUT - Static variable in class io.aiven.commons.strings.HttpStatus: 408 Request Timeout (HTTP Semantics)
SC_REQUEST_TOO_LONG - Static variable in class io.aiven.commons.strings.HttpStatus: 413 Request Entity Too Large (HTTP Semantics)
SC_REQUEST_URI_TOO_LONG - Static variable in class io.aiven.commons.strings.HttpStatus: 414 Request-URI Too Long (HTTP Semantics)
SC_REQUESTED_RANGE_NOT_SATISFIABLE - Static variable in class io.aiven.commons.strings.HttpStatus: 416 Requested Range Not Satisfiable (HTTP Semantics)
SC_RESET_CONTENT - Static variable in class io.aiven.commons.strings.HttpStatus: 205 Reset Content (HTTP Semantics)
SC_SEE_OTHER - Static variable in class io.aiven.commons.strings.HttpStatus: 303 See Other (HTTP Semantics)
SC_SERVER_ERROR - Static variable in class io.aiven.commons.strings.HttpStatus: 500 Server Error (HTTP Semantics)
SC_SERVICE_UNAVAILABLE - Static variable in class io.aiven.commons.strings.HttpStatus: 503 Service Unavailable (HTTP Semantics)
SC_SUCCESS - Static variable in class io.aiven.commons.strings.HttpStatus: 2xx Success (HTTP Semantics)
SC_SWITCHING_PROTOCOLS - Static variable in class io.aiven.commons.strings.HttpStatus: 101 Switching Protocols (HTTP Semantics)
SC_TEMPORARY_REDIRECT - Static variable in class io.aiven.commons.strings.HttpStatus: 307 Temporary Redirect (HTTP Semantics)
SC_TOO_EARLY - Static variable in class io.aiven.commons.strings.HttpStatus: 425 Too Early (Using Early Data in HTTP - RFC 8470)
SC_TOO_MANY_REQUESTS - Static variable in class io.aiven.commons.strings.HttpStatus: 429 Too Many Requests (Additional HTTP Status Codes - RFC 6585)
SC_UNAUTHORIZED - Static variable in class io.aiven.commons.strings.HttpStatus: 401 Unauthorized (HTTP Semantics)
SC_UNAVAILABLE_FOR_LEGAL_REASONS - Static variable in class io.aiven.commons.strings.HttpStatus: 451 Unavailable For Legal Reasons (Legal Obstacles - RFC 7725)
SC_UNPROCESSABLE_CONTENT - Static variable in class io.aiven.commons.strings.HttpStatus: 422 Unprocessable Content (HTTP Semantics)
SC_UNPROCESSABLE_ENTITY - Static variable in class io.aiven.commons.strings.HttpStatus: Deprecated.
Use HttpStatus.SC_UNPROCESSABLE_CONTENT
SC_UNSUPPORTED_MEDIA_TYPE - Static variable in class io.aiven.commons.strings.HttpStatus: 415 Unsupported Media Type (HTTP Semantics)
SC_UPGRADE_REQUIRED - Static variable in class io.aiven.commons.strings.HttpStatus: 426 Upgrade Required (HTTP Semantics)
SC_USE_PROXY - Static variable in class io.aiven.commons.strings.HttpStatus: 305 Use Proxy (HTTP Semantics)
SC_VARIANT_ALSO_NEGOTIATES - Static variable in class io.aiven.commons.strings.HttpStatus: 506 Variant Also Negotiates ( Transparent Content Negotiation - RFC 2295)
Scale - Enum Class in io.aiven.commons.collections: A collection of byte prefixes with conversions and formatting.
scaleOf(long) - Static method in enum class io.aiven.commons.collections.TimeScale: Returns the largest TimeScale that will represent milliseconds with at least 1 unit.
scaleOf(long, List<Scale>) - Static method in enum class io.aiven.commons.collections.Scale: Determines the scale of the number of bytes.
ScaleValidator - Class in io.aiven.commons.kafka.config.validator: Validates input is within ranges for specific scale values.
schemes(String...) - Method in class io.aiven.commons.kafka.config.validator.UrlValidator.Builder: Adds one or more schemes to the list of valid schemes.
SECONDS - Enum constant in enum class io.aiven.commons.collections.TimeScale: seconds
self - Variable in class io.aiven.commons.kafka.config.fragment.AbstractFragmentSetter: A value to return from the setter methods.
self() - Method in class io.aiven.commons.kafka.config.ConfigKeyBuilder: Returns this cast to the actual builder type.
serialze(PrintStream) - Method in class io.aiven.commons.kafka.config.SinceInfoMapBuilder: Serialize the map to a print stream.
setMinimumDelay(Duration) - Method in class io.aiven.commons.timing.Backoff: Set the minimum wait time.
setOverride(SinceInfo.Builder) - Method in class io.aiven.commons.kafka.config.SinceInfo: Sets the override for this SinceInfo.
setOverride(Map<SinceInfo.OverrideRange, SinceInfo.Data>) - Method in class io.aiven.commons.kafka.config.SinceInfo: Sets the override from the Builder associated with the matching OverrideRange in the overrideMap.
setter(Map<String, String>) - Static method in class io.aiven.commons.kafka.config.fragment.CommonConfigFragment: Gets a setter for this fragment.
setValue(String, boolean) - Method in class io.aiven.commons.kafka.config.fragment.AbstractFragmentSetter: Sets the value.
setValue(String, int) - Method in class io.aiven.commons.kafka.config.fragment.AbstractFragmentSetter: Sets the value.
setValue(String, long) - Method in class io.aiven.commons.kafka.config.fragment.AbstractFragmentSetter: Sets the value.
setValue(String, Class<?>) - Method in class io.aiven.commons.kafka.config.fragment.AbstractFragmentSetter: Sets the value.
setValue(String, String) - Method in class io.aiven.commons.kafka.config.fragment.AbstractFragmentSetter: Sets the value.
setValue(String, URI) - Method in class io.aiven.commons.kafka.config.fragment.AbstractFragmentSetter: Sets the value.
setVersionOnly() - Method in class io.aiven.commons.kafka.config.SinceInfo: Sets the override to be just the version of this component.
SI - Static variable in enum class io.aiven.commons.collections.Scale: The SI standardized prefix scales.
simpleJoiner(char) - Static method in class io.aiven.commons.strings.CasedString.StringCase: Creates a function to join a String array with a character delimiter.
since - Variable in class io.aiven.commons.kafka.config.ExtendedConfigKey: The version in which this attribute was added.
since(SinceInfo) - Method in class io.aiven.commons.kafka.config.DeprecatedInfo.Builder: Sets the version in which the option became deprecated.
since(SinceInfo) - Method in class io.aiven.commons.kafka.config.ExtendedConfigKey.Builder: Sets the since value.
since(SinceInfo.Builder) - Method in class io.aiven.commons.kafka.config.DeprecatedInfo.Builder: Sets the version in which the option became deprecated.
SinceInfo - Class in io.aiven.commons.kafka.config: Contains the information about when this option was added.
SinceInfo.Builder - Class in io.aiven.commons.kafka.config: A builder for SinceInfo and the SinceInfo override.
SinceInfo.Data - Record Class in io.aiven.commons.kafka.config: Record of the data to display.
SinceInfo.OverrideRange - Class in io.aiven.commons.kafka.config: Matches a range of SinceInfo records.
SinceInfoMapBuilder - Class in io.aiven.commons.kafka.config: Class to build and maintain a list of Override ranges to final version.
SinceInfoMapBuilder() - Constructor for class io.aiven.commons.kafka.config.SinceInfoMapBuilder: Constructs a new SinceInfoMapBuilder.
size(int) - Static method in enum class io.aiven.commons.collections.TimeScale: Formats the milliseconds into a TimeScale that best fits the number of milliseconds.
size(int, List<Scale>) - Static method in enum class io.aiven.commons.collections.Scale: Creates a formatted string for the scale that most closely represents the byteCount.
SLASH - Static variable in class io.aiven.commons.strings.CasedString.StringCase: Slash case tags phrases of words like 'phrase.case'.
SNAKE - Static variable in class io.aiven.commons.strings.CasedString.StringCase: Snake case tags strings like 'Snake_Case'.
SNAPPY - Enum constant in enum class io.aiven.commons.io.compression.CompressionType: Snappy compression
start() - Method in class io.aiven.commons.timing.Timer
stop() - Method in class io.aiven.commons.timing.Timer
StringCase(String, char) - Constructor for class io.aiven.commons.strings.CasedString.StringCase: Create a simple string case for the delimiter.
StringCase(String, Predicate<Character>, boolean, Function<String[], String>) - Constructor for class io.aiven.commons.strings.CasedString.StringCase: Defines a String Case.
StringCase(String, Predicate<Character>, boolean, Function<String[], String>, Function<String, String>) - Constructor for class io.aiven.commons.strings.CasedString.StringCase: Defines a String Case.
strings - module strings: Aiven string utilities.
SupplierOfLong - Interface in io.aiven.commons.timing: A functional interface to return long values.
SystemCheck - Class in io.aiven.commons.system: Checks URLs against the URLs allowed as per the org.apache.kafka.sasl.oauthbearer.allowed.urls environment variable.
SystemCheck.Type - Enum Class in io.aiven.commons.system: The type of object being checked.

T

tail() - Method in class io.aiven.commons.collections.RingBuffer: Returns but does not remove the teal of the buffer.
taskId(int) - Method in class io.aiven.commons.kafka.config.fragment.CommonConfigFragment.Setter: Sets the task ID value.
TB - Enum constant in enum class io.aiven.commons.collections.Scale: SI Scale Terabytes
throwIfNotAllowed(EnvCheck.Type, String) - Static method in class io.aiven.commons.system.EnvCheck: Thorw an exception if the specified URL is not listed in the org.apache.kafka.sasl.oauthbearer.allowed.urls environment variable.
throwIfNotAllowed(SystemCheck.Type, String) - Static method in class io.aiven.commons.system.SystemCheck: Throw an exception if the specified URL is not listed in the system property.
TiB - Enum constant in enum class io.aiven.commons.collections.Scale: IEC Scale Terabytes (2 ^ 40)
Timer - Class in io.aiven.commons.timing: Calculates elapsed time and flags when expired.
Timer(Duration) - Constructor for class io.aiven.commons.timing.Timer: Constructor.
timeRemaining - Variable in class io.aiven.commons.timing.Backoff: A supplier of the time remaining (in milliseconds) on the overriding timer.
TimeScale - Enum Class in io.aiven.commons.collections: Scales milliseconds into standard human time units and standard human time units into milliseconds.
TimeScaleValidator - Class in io.aiven.commons.kafka.config.validator: A validator for time scales.
TimeZoneValidator - Class in io.aiven.commons.kafka.config.validator: A validator that ensures that a timezone string is valid.
toCase(CasedString.StringCase) - Method in class io.aiven.commons.strings.CasedString: Converts this cased string into a String of another format.
toString() - Method in class io.aiven.commons.collections.RingBuffer
toString() - Method in class io.aiven.commons.kafka.config.DeprecatedInfo
toString() - Method in record class io.aiven.commons.kafka.config.SinceInfo.Data: Returns a string representation of this record class.
toString() - Method in class io.aiven.commons.kafka.config.SinceInfo.OverrideRange
toString() - Method in class io.aiven.commons.kafka.config.SinceInfo
toString() - Method in class io.aiven.commons.kafka.config.validator.NonEmptyList
toString() - Method in class io.aiven.commons.kafka.config.validator.NonEmptyPassword
toString() - Method in class io.aiven.commons.kafka.config.validator.PredicateGatedValidator
toString() - Method in class io.aiven.commons.kafka.config.validator.ScaleValidator
toString() - Method in class io.aiven.commons.kafka.config.validator.TimeScaleValidator
toString() - Method in class io.aiven.commons.kafka.config.validator.TimeZoneValidator
toString() - Method in class io.aiven.commons.kafka.config.validator.UrlValidator
toString() - Method in class io.aiven.commons.strings.CasedString.StringCase
toString() - Method in class io.aiven.commons.strings.CasedString: Returns the string representation provided in the constructor.
toString() - Method in class io.aiven.commons.system.VersionInfo: Default string representation of the implementation information from the package.
toString() - Method in class io.aiven.commons.timing.Backoff
type - Variable in class io.aiven.commons.kafka.config.ConfigKeyBuilder: The type of the key.
type(ConfigDef.Type) - Method in class io.aiven.commons.kafka.config.ConfigKeyBuilder: Sets the data type.

U

unbuild(ConfigDef.ConfigKey) - Static method in class io.aiven.commons.kafka.config.ExtendedConfigKey.Builder: unbuilds a key.
unitName() - Method in enum class io.aiven.commons.collections.TimeScale: Gets the name of the units for this TimeScale.
units(int) - Method in enum class io.aiven.commons.collections.Scale: Formats the byteCount at this scale.
units(int) - Method in enum class io.aiven.commons.collections.TimeScale: Format the number of units of this TimeScale for output.
update(ConfigDef) - Static method in class io.aiven.commons.kafka.config.fragment.BackoffPolicyFragment: Adds configuration options to the configuration definition.
update(ConfigDef) - Static method in class io.aiven.commons.kafka.config.fragment.CommonConfigFragment: Update the ConfigDef with the values from the fragment.
URI - Enum constant in enum class io.aiven.commons.system.EnvCheck.Type: validate a URI is in the list of URIs
URI - Enum constant in enum class io.aiven.commons.system.SystemCheck.Type: validate a URI is in the list of URIs
UrlValidator - Class in io.aiven.commons.kafka.config.validator: Validates that the string is a valid URL.
UrlValidator.Builder - Class in io.aiven.commons.kafka.config.validator: Builder for UrlValidator.

V

validate() - Method in class io.aiven.commons.kafka.config.fragment.ConfigFragment: Deprecated.
validate(Map<String, String>) - Method in class io.aiven.commons.kafka.config.CommonConfigDef
validate(Map<String, ConfigValue>) - Method in class io.aiven.commons.kafka.config.fragment.ConfigFragment: Validate that the data in the configuration matches any restrictions other than those from the validator.
validateCredentialJson(byte[]) - Static method in class io.aiven.commons.google.auth.GCPValidator: Validate the JSON credential information.
validationMessage(String, Object, String) - Static method in class io.aiven.commons.kafka.config.fragment.ConfigFragment: Create a validation message.
validator - Variable in class io.aiven.commons.kafka.config.ConfigKeyBuilder: The validator (if any) for this key.
validator(ConfigDef.Validator) - Method in class io.aiven.commons.kafka.config.ConfigKeyBuilder: Sets the validator.
valueOf(String) - Static method in enum class io.aiven.commons.collections.RingBuffer.DuplicateHandling: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.aiven.commons.collections.Scale: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.aiven.commons.collections.TimeScale: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.aiven.commons.io.compression.CompressionType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.aiven.commons.system.EnvCheck.Type: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.aiven.commons.system.SystemCheck.Type: Returns the enum constant of this class with the specified name.
values() - Static method in enum class io.aiven.commons.collections.RingBuffer.DuplicateHandling: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.aiven.commons.collections.Scale: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.aiven.commons.collections.TimeScale: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.aiven.commons.io.compression.CompressionType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Method in class io.aiven.commons.kafka.config.fragment.ConfigFragment
values() - Method in interface io.aiven.commons.kafka.config.fragment.FragmentDataAccess: Gets the map of String to value.
values() - Static method in enum class io.aiven.commons.system.EnvCheck.Type: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.aiven.commons.system.SystemCheck.Type: Returns an array containing the constants of this enum class, in the order they are declared.
version() - Method in record class io.aiven.commons.kafka.config.SinceInfo.Data: Returns the value of the version record component.
version(String) - Method in class io.aiven.commons.kafka.config.SinceInfo.Builder: Sets the version.
Version - Class in io.aiven.commons.strings: Reads a list of versions from a configuration file.
Version() - Constructor for class io.aiven.commons.strings.Version: Default constructor.
Version(String) - Constructor for class io.aiven.commons.strings.Version: property loader.
VersionInfo - Class in io.aiven.commons.system: This class was originally developed by the Apache RAT project A formatter for Package information about a class.
VersionInfo() - Constructor for class io.aiven.commons.system.VersionInfo: Constructor that uses the VersionInfo package for information.
VersionInfo(Class<?>) - Constructor for class io.aiven.commons.system.VersionInfo: Constructor for a specific class.

W

width - Variable in class io.aiven.commons.kafka.config.ConfigKeyBuilder: The width of the input field for this config.
width(ConfigDef.Width) - Method in class io.aiven.commons.kafka.config.ConfigKeyBuilder: Sets the width.

Z

ZSTD - Enum constant in enum class io.aiven.commons.io.compression.CompressionType: Zstandard compression

A B C D E F G H I J K L M N O P R S T U V W Z
All Classes and Interfaces|All Packages|Constant Field Values