Uses of Class
com.ibasco.agql.core.util.Option

Packages that use Option

Package	Description
com.ibasco.agql.core
com.ibasco.agql.core.util
com.ibasco.agql.protocols.valve.source.query.rcon

Uses of Option in com.ibasco.agql.core

Methods in com.ibasco.agql.core that return Option

Modifier and Type	Method and Description
default Option<T>	OptionSupplier.get()

Methods in com.ibasco.agql.core with parameters of type Option

Modifier and Type	Method and Description
protected <X> void	NettyMessenger.applyDefault(Option<X> option, X value) Apply a default option value if not specified by the user
protected <X> void	NettyMessenger.lockedOption(Options map, Option<X> option, X value) Lock an option and prevent future updates for this option

Uses of Option in com.ibasco.agql.core.util

Fields in com.ibasco.agql.core.util declared as Option

Modifier and Type	Field and Description
static Option<String>	HttpOptions.API_KEY The authentication token to use
static Option<Integer>	GeneralOptions.CLOSE_TIMEOUT The maximum number of milliseconds to wait before timing out on close channel operation
static Option<Boolean>	GeneralOptions.CONNECTION_POOLING Set to true to enable channel/connection pooling
static Option<Integer>	ConnectOptions.FAILSAFE_CIRCBREAKER_DELAY After opening, a breaker will delay for 1 second(s) by default before before transitioning to half-open.
static Option<Integer>	FailsafeOptions.FAILSAFE_CIRCBREAKER_DELAY After opening, a breaker will delay for 1 second(s) by default before before transitioning to half-open.
static Option<Boolean>	ConnectOptions.FAILSAFE_CIRCBREAKER_ENABLED Enable/disable Circuit breaker failsafe policy (Default: true)
static Option<Boolean>	FailsafeOptions.FAILSAFE_CIRCBREAKER_ENABLED Enable/disable Circuit breaker failsafe policy (Default: true)
static Option<Integer>	ConnectOptions.FAILSAFE_CIRCBREAKER_FAILURE_THRESHOLD The number of failures that must occur in order to open the circuit (Default: 3)
static Option<Integer>	FailsafeOptions.FAILSAFE_CIRCBREAKER_FAILURE_THRESHOLD The number of failures that must occur in order to open the circuit (Default: 3)
static Option<Integer>	ConnectOptions.FAILSAFE_CIRCBREAKER_FAILURE_THRESHOLDING_CAP The capacity for storing execution results when performing failure thresholding (Default: 5)
static Option<Integer>	FailsafeOptions.FAILSAFE_CIRCBREAKER_FAILURE_THRESHOLDING_CAP The capacity for storing execution results when performing failure thresholding (Default: 5)
static Option<Integer>	ConnectOptions.FAILSAFE_CIRCBREAKER_SUCCESS_THRESHOLD Configures count based success thresholding by setting the number of consecutive successful transactions that must occur when in a HALF_OPEN state in order to close the circuit, else the circuit is re-opened when a failure occurs.
static Option<Integer>	FailsafeOptions.FAILSAFE_CIRCBREAKER_SUCCESS_THRESHOLD Configures count based success thresholding by setting the number of consecutive successful transactions that must occur when in a HALF_OPEN state in order to close the circuit, else the circuit is re-opened when a failure occurs.
static Option<Boolean>	ConnectOptions.FAILSAFE_ENABLED Enable Failsafe integration for Source Query module
static Option<Boolean>	FailsafeOptions.FAILSAFE_ENABLED Enable Failsafe integration for Source Query module
static Option<Boolean>	ConnectOptions.FAILSAFE_RATELIMIT_ENABLED Enable Rate Limiter (Failsafe)
static Option<Boolean>	FailsafeOptions.FAILSAFE_RATELIMIT_ENABLED Enable Rate Limiter (Failsafe)
static Option<Long>	ConnectOptions.FAILSAFE_RATELIMIT_MAX_EXEC Maximum number of executions within the specified period (Default is 650 executions per minute)
static Option<Long>	FailsafeOptions.FAILSAFE_RATELIMIT_MAX_EXEC Maximum number of executions within the specified period (Default is 650 executions per minute)
static Option<Long>	ConnectOptions.FAILSAFE_RATELIMIT_MAX_WAIT_TIME Maximum waiting time for permits to be available (Default is 10000 ms)
static Option<Long>	FailsafeOptions.FAILSAFE_RATELIMIT_MAX_WAIT_TIME Maximum waiting time for permits to be available (Default is 10000 ms)
static Option<Long>	ConnectOptions.FAILSAFE_RATELIMIT_PERIOD The period after which permitted executions are reset to the max executions.
static Option<Long>	FailsafeOptions.FAILSAFE_RATELIMIT_PERIOD The period after which permitted executions are reset to the max executions.
static Option<RateLimitType>	ConnectOptions.FAILSAFE_RATELIMIT_TYPE Specifies the rate limiting method to use (Default is Smooth)
static Option<RateLimitType>	FailsafeOptions.FAILSAFE_RATELIMIT_TYPE Specifies the rate limiting method to use (Default is Smooth)
static Option<Long>	ConnectOptions.FAILSAFE_RETRY_BACKOFF_DELAY Sets the delay between retries (milliseconds), exponentially backing off to the maxDelay and multiplying successive delays by the delayFactor.
static Option<Long>	FailsafeOptions.FAILSAFE_RETRY_BACKOFF_DELAY Sets the delay between retries (milliseconds), exponentially backing off to the maxDelay and multiplying successive delays by the delayFactor.
static Option<Double>	ConnectOptions.FAILSAFE_RETRY_BACKOFF_DELAY_FACTOR Sets the delay between retries, exponentially backing off to the maxDelay and multiplying successive delays by the delayFactor.
static Option<Double>	FailsafeOptions.FAILSAFE_RETRY_BACKOFF_DELAY_FACTOR Sets the delay between retries, exponentially backing off to the maxDelay and multiplying successive delays by the delayFactor.
static Option<Boolean>	ConnectOptions.FAILSAFE_RETRY_BACKOFF_ENABLED Enable Failsafe's Retry Backoff Feature
static Option<Boolean>	FailsafeOptions.FAILSAFE_RETRY_BACKOFF_ENABLED Enable Failsafe's Retry Backoff Feature
static Option<Long>	ConnectOptions.FAILSAFE_RETRY_BACKOFF_MAX_DELAY Sets the delay between retries (milliseconds), exponentially backing off to the maxDelay and multiplying successive delays by the delayFactor.
static Option<Long>	FailsafeOptions.FAILSAFE_RETRY_BACKOFF_MAX_DELAY Sets the delay between retries (milliseconds), exponentially backing off to the maxDelay and multiplying successive delays by the delayFactor.
static Option<Long>	ConnectOptions.FAILSAFE_RETRY_DELAY Delay between retries (In milliseconds.
static Option<Long>	FailsafeOptions.FAILSAFE_RETRY_DELAY Delay between retries (In milliseconds.
static Option<Boolean>	ConnectOptions.FAILSAFE_RETRY_ENABLED Enable retry policy
static Option<Boolean>	FailsafeOptions.FAILSAFE_RETRY_ENABLED Enable retry policy
static Option<Integer>	ConnectOptions.FAILSAFE_RETRY_MAX_ATTEMPTS Sets the max number of execution attempts to perform.
static Option<Integer>	FailsafeOptions.FAILSAFE_RETRY_MAX_ATTEMPTS Sets the max number of execution attempts to perform.
static Option<Integer>	GeneralOptions.POOL_ACQUIRE_MAX Maximum number of allowed pending acquires.
static Option<Integer>	GeneralOptions.POOL_ACQUIRE_TIMEOUT The maximum number of milliseconds to wait before a timeout is triggered during Channel acquisition.
static Option<FixedNettyChannelPool.AcquireTimeoutAction>	GeneralOptions.POOL_ACQUIRE_TIMEOUT_ACTION The action that will be executed once an acquire timeout is thrown
static Option<ChannelHealthChecker>	GeneralOptions.POOL_CHANNEL_HEALTH_CHECKER The ChannelHealthChecker that is used by the ChannelPool implementation to check if the Channel can be acquired.
static Option<Integer>	GeneralOptions.POOL_MAX_CONNECTIONS Maximum number of connections to be maintained in the channel/connection pool.
static Option<ChannelPoolType>	GeneralOptions.POOL_TYPE The type of ChannelPool implementation to use (bounded or unbounded)
static Option<Integer>	GeneralOptions.READ_TIMEOUT Number of milliseconds to wait before we throw a ReadTimeoutException (Default: 5 seconds)
static Option<io.netty.util.ResourceLeakDetector.Level>	GeneralOptions.RESOURCE_LEAK_DETECTOR_LEVEL Monitor resource usage leaks.
static Option<Integer>	GeneralOptions.SOCKET_ALLOC_ADAPTIVE_INIT_SIZE As per netty: the initial buffer size when no feed back was received.
static Option<Integer>	GeneralOptions.SOCKET_ALLOC_ADAPTIVE_MAX_SIZE As per netty: the inclusive upper bound of the expected buffer size.
static Option<Integer>	GeneralOptions.SOCKET_ALLOC_ADAPTIVE_MIN_SIZE As per netty: the inclusive lower bound of the expected buffer size.
static Option<Integer>	GeneralOptions.SOCKET_ALLOC_FIXED_SIZE The fixed receive buffer size to allocate during channel initialization.
static Option<Integer>	GeneralOptions.SOCKET_CONNECT_TIMEOUT The connection timeout value
static Option<Boolean>	GeneralOptions.SOCKET_KEEP_ALIVE A channel option, when enabled, allows the application to enable keep-alive packets for a socket connection.
static Option<Integer>	GeneralOptions.SOCKET_RECVBUF A channel option that specifies the total per-socket buffer space reserved for receives
static Option<BufferAllocatorType>	GeneralOptions.SOCKET_RECVBUF_ALLOC_TYPE The strategy for allocating netty's inbound/outbound pooled buffers.
static Option<Integer>	GeneralOptions.SOCKET_SNDBUF A channel option that specifies the total per-socket buffer space reserved for sends
static Option<Integer>	GeneralOptions.THREAD_CORE_SIZE The number of threads to be used by the internal EventLoopGroup.
static Option<ExecutorService>	GeneralOptions.THREAD_EXECUTOR_SERVICE A custom ExecutorService that will be used by the client.
static Option<Integer>	GeneralOptions.WRITE_TIMEOUT Number of milliseconds to wait before we throw a WriteTimeoutException (Default: 5 seconds)

Methods in com.ibasco.agql.core.util that return Option

Modifier and Type	Method and Description
static <V> Option<V>	Option.create(String key) Creates a singleton instance of an Option based on the key provided
static <V> Option<V>	Option.create(String key, V defaultValue) Creates a singleton instance of an Option based on the key provided
static <V> Option<V>	Option.create(String key, V defaultValue, boolean channelAttribute) Creates a singleton instance of an Option based on the key provided
static <V> Option<V>	Option.create(String key, V defaultValue, boolean channelAttribute, boolean autoCreate) Creates a singleton instance of an Option based on the key provided.
Option<?>	Option.CacheEntry.getOption()
static <V> Option<V>	Option.of(Class<? extends Options> containerClass, Class<?> context, Option<?> option)
static <V> Option<V>	Option.of(Class<? extends Options> containerClass, Class<?> context, String key)
static <V> Option<V>	Option.of(Class<? extends Options> containerClass, String key) Retrieve an singleton Option instance using the provided class group and key combination
static <V> Option<V>	Option.of(String key) Retrieve a singleton instance of an Option using the provided key.
static <V> Option<V>	Option.ofGlobal(String key) Returns a singleton Option instance from global

Methods in com.ibasco.agql.core.util with parameters of type Option

Modifier and Type	Method and Description
boolean	Options.contains(Option<?> option) Checks if the provided Option key exists in this container
boolean	AbstractOptions.contains(Option<?> option) Checks if the provided Option key exists in this container
default <X> X	Options.get(Option<?> option, Class<? extends Options> context)
default <V> V	ConfigurationSupport.get(Option<V> option) get.
default <V> V	ConfigurationSupport.get(Option<V> option, V defaultValue) get.
<X> X	Options.get(Option<X> option) Retrieve Option value from this container
<X> X	AbstractOptions.get(Option<X> option) Retrieve Option value from this container
<X> X	Options.get(Option<X> option, X defaultValue) Retrieve option value from this container.
<X> X	AbstractOptions.get(Option<X> option, X defaultValue) Retrieve option value from this container.
static <V> V	Option.getGlobal(Option<V> option) Retrieve a global Option declared from GeneralOptions container
static <V> V	Option.getGlobal(Option<V> option, V defaultValue) Retrieve a global Option declared from GeneralOptions container
default <V> V	ConfigurationSupport.getOrDefault(Option<V> option) getOrDefault.
default <V> V	ConfigurationSupport.getOrDefault(Option<V> option, V defaultValue) getOrDefault.
<X> X	Options.getOrDefault(Option<X> option) Retrieve the option value.
<X> X	AbstractOptions.getOrDefault(Option<X> option) Retrieve the option value.
default <X> X	Options.getOrDefault(Option<X> option, Class<? extends Options> context)
boolean	Options.isLocked(Option<?> option) Check locked status of option
boolean	AbstractOptions.isLocked(Option<?> option) Check locked status of option
default <V> void	ConfigurationSupport.lock(Option<V> option, V value) lock.
static <V> Option<V>	Option.of(Class<? extends Options> containerClass, Class<?> context, Option<?> option)
<X> OptionBuilder<T>	OptionBuilder.option(Option<X> option, X value) Add a new configuration Option.
<X> void	Options.put(Option<X> option, X value) Add option value to this container
<X> void	AbstractOptions.put(Option<X> option, X value) Add option value to this container
<X> void	Options.put(Option<X> option, X value, boolean locked) Add option value to this container with the additional option to lockout the value
<X> void	AbstractOptions.put(Option<X> option, X value, boolean locked) Add option value to this container with the additional option to lockout the value
<X> X	Options.putIfAbsent(Option<X> option, X value) Add option value to this container if not yet existing
<X> X	AbstractOptions.putIfAbsent(Option<X> option, X value)
<X> void	Options.remove(Option<X> option) Remove Option value from this container.
<X> void	AbstractOptions.remove(Option<X> option) Remove Option value from this container.
default <V> void	ConfigurationSupport.set(Option<V> option, V value) set.
default <V> void	ConfigurationSupport.unlock(Option<V> option) unlock.

Uses of Option in com.ibasco.agql.protocols.valve.source.query.rcon

Fields in com.ibasco.agql.protocols.valve.source.query.rcon declared as Option

Modifier and Type	Field and Description
static Option<Integer>	SourceRconOptions.CLOSE_INACTIVE_CHANNELS Automatically close inactive channels/connections once it has reached the threshold value (value is in seconds).
static Option<CredentialsStore>	SourceRconOptions.CREDENTIALS_STORE The CredentialsStore to be used by the rcon authentication module.
static Option<Integer>	SourceRconOptions.INACTIVE_CHECK_INTERVAL Number of seconds to check for inactive Channel's/connections (Unit: Seconds, Default Value: 1 sec)
static Option<Boolean>	SourceRconOptions.REAUTHENTICATE Automatically send a re-authentication request if the connection is no longer valid.
static Option<Boolean>	SourceRconOptions.STRICT_MODE Enable strict mode.
static Option<Boolean>	SourceRconOptions.USE_TERMINATOR_PACKET Enable the use of "terminating packets" (Enabled by default).