Index (sbk-api 9.0 API)

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

A

AbstractCallbackReader<T> - Class in io.sbk.api: Abstract helper for callback-style readers.
AbstractCallbackReader() - Constructor for class io.sbk.api.AbstractCallbackReader
AbstractRWLogger - Class in io.sbk.logger.impl: Base implementation of RWLogger providing shared read/write request accounting, periodic aggregation, and printing helpers.
AbstractRWLogger() - Constructor for class io.sbk.logger.impl.AbstractRWLogger
Action - Enum Class in io.sbk.action: enum Action { Writing, Reading, Write_Reading, Write_OnlyReading, Read_Writing, Read_OnlyWriting}.
ACTION_FIELD_NUMBER - Static variable in class io.sbp.grpc.Config
ActionParameter - Interface in io.sbk.params: Supplies the benchmark Action (READ/WRITE variants) selected via CLI.
addArgs(InputOptions) - Method in interface io.sbk.api.Storage: Add the driver specific command line arguments.
addArgs(InputOptions) - Method in class io.sbk.logger.impl.AbstractRWLogger
addArgs(InputOptions) - Method in class io.sbk.logger.impl.CSVLogger
addArgs(InputOptions) - Method in class io.sbk.logger.impl.GrpcLogger: Add SBM host/port options and load defaults from sbmhost.properties.
addArgs(InputOptions) - Method in class io.sbk.logger.impl.PrometheusLogger
addArgs(InputOptions) - Method in interface io.sbk.logger.Logger: Add the Metric type specific command line arguments.
addLatenciesRecord(MessageLatenciesRecord) - Method in class io.sbp.grpc.ServiceGrpc.ServiceBlockingStub
addLatenciesRecord(MessageLatenciesRecord) - Method in class io.sbp.grpc.ServiceGrpc.ServiceBlockingV2Stub
addLatenciesRecord(MessageLatenciesRecord) - Method in class io.sbp.grpc.ServiceGrpc.ServiceFutureStub
addLatenciesRecord(MessageLatenciesRecord, StreamObserver) - Method in interface io.sbp.grpc.ServiceGrpc.AsyncService
addLatenciesRecord(MessageLatenciesRecord, StreamObserver) - Method in class io.sbp.grpc.ServiceGrpc.ServiceStub
addOption(String, boolean, String) - Method in class io.sbk.params.impl.SbkInputOptions
addOption(String, boolean, String) - Method in interface io.sbk.params.InputOptions: Add the driver specific command line arguments.
allocate(int) - Method in interface io.sbk.data.DataType: allocate the data.
allocate(int) - Method in class io.sbk.data.impl.ByteArray: Create byte array data.
allocate(int) - Method in class io.sbk.data.impl.NioByteBuffer: Create byte buffer.
allocate(int) - Method in class io.sbk.data.impl.ProtoBufByteString: Create byte array data.
allocate(int) - Method in class io.sbk.data.impl.SbkString: Create byte array data.
appendResultString(StringBuilder, int, int, int, int, long, double, long, double, long, double, long, double, long, long, long, long, long, long, long, double, long, double, double, long, long, double, double, double, long, long, long, long, long, long, long, long[], long[]) - Method in class io.sbk.logger.impl.AbstractRWLogger
appendWriteAndReadRequests(StringBuilder, long, double, long, double, long, double, long, double) - Method in class io.sbk.logger.impl.AbstractRWLogger
appendWriteAndReadRequestsPending(StringBuilder, long, long, long, long, long, long) - Method in class io.sbk.logger.impl.AbstractRWLogger
appendWriteAndReadTimeoutEvents(StringBuilder, long, double, long, double) - Method in class io.sbk.logger.impl.AbstractRWLogger
appendWritesAndReaders(StringBuilder, int, int, int, int) - Method in class io.sbk.logger.impl.AbstractRWLogger
apply(long, long) - Method in interface io.sbk.api.BiConsumer: Apply the Benchmark.
ARG_PREFIX - Static variable in class io.sbk.config.Config: ARG_PREFIX = "-";.
args - Variable in class io.sbk.params.YmlMap: Key-value pairs that will be transformed into CLI arguments.
argsToMap(String[], boolean) - Static method in class io.sbk.utils.SbkUtils
AsyncReader<T> - Interface in io.sbk.api: Interface for Asynchronous Readers.

B

Benchmark - Interface in io.sbk.api: Interface for Benchmark.
BiConsumer - Interface in io.sbk.api: Functional-style BiConsumer used by internal harness code to represent a benchmark invocation that accepts a time budget and a records limit.
bindService() - Method in class io.sbp.grpc.ServiceGrpc.ServiceImplBase
bindService(ServiceGrpc.AsyncService) - Static method in class io.sbp.grpc.ServiceGrpc
build() - Method in class io.sbp.grpc.ClientID.Builder
build() - Method in class io.sbp.grpc.Config.Builder
build() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder
build() - Method in class io.sbp.grpc.Version.Builder
build(Channel, CallOptions) - Method in class io.sbp.grpc.ServiceGrpc.ServiceBlockingStub
build(Channel, CallOptions) - Method in class io.sbp.grpc.ServiceGrpc.ServiceBlockingV2Stub
build(Channel, CallOptions) - Method in class io.sbp.grpc.ServiceGrpc.ServiceFutureStub
build(Channel, CallOptions) - Method in class io.sbp.grpc.ServiceGrpc.ServiceStub
buildBenchmark(String[], String, String, String) - Static method in class io.sbk.api.impl.Sbk: Build the Benchmark Object.
buildPartial() - Method in class io.sbp.grpc.ClientID.Builder
buildPartial() - Method in class io.sbp.grpc.Config.Builder
buildPartial() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder
buildPartial() - Method in class io.sbp.grpc.Version.Builder
ByteArray - Class in io.sbk.data.impl: Class for processing byte[] data.
ByteArray() - Constructor for class io.sbk.data.impl.ByteArray
bytes - Variable in class io.sbk.api.Status

C

Callback<T> - Interface in io.sbk.api: Callback interface used by callback-driven drivers to receive data and optionally report per-record benchmarking metrics.
CLASS_OPTION - Static variable in class io.sbk.config.Config: CLASS_OPTION = "class";.
CLASS_OPTION_ARG - Static variable in class io.sbk.config.Config: CLASS_OPTION_ARG = ARG_PREFIX + CLASS_OPTION;.
clear() - Method in class io.sbp.grpc.ClientID.Builder
clear() - Method in class io.sbp.grpc.Config.Builder
clear() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder
clear() - Method in class io.sbp.grpc.Version.Builder
clearAction() - Method in class io.sbp.grpc.Config.Builder: .EnumAction action = 2;
clearClientID() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 clientID = 1;
clearHigherLatencyDiscardRecords() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 higherLatencyDiscardRecords = 16;
clearId() - Method in class io.sbp.grpc.ClientID.Builder: int64 id = 1;
clearInvalidLatencyRecords() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 invalidLatencyRecords = 17;
clearIsReadRequests() - Method in class io.sbp.grpc.Config.Builder: bool isReadRequests = 7;
clearIsWriteRequests() - Method in class io.sbp.grpc.Config.Builder: bool isWriteRequests = 6;
clearLatency() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder
clearLowerLatencyDiscardRecords() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 lowerLatencyDiscardRecords = 15;
clearMajor() - Method in class io.sbp.grpc.Version.Builder: int32 major = 1;
clearMaxLatency() - Method in class io.sbp.grpc.Config.Builder: int64 maxLatency = 5;
clearMaxLatency() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 maxLatency = 21;
clearMaxReaders() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int32 maxReaders = 6;
clearMaxWriters() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int32 maxWriters = 5;
clearMinLatency() - Method in class io.sbp.grpc.Config.Builder: int64 minLatency = 4;
clearMinLatency() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 minLatency = 20;
clearMinor() - Method in class io.sbp.grpc.Version.Builder: int32 minor = 2;
clearReaders() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int32 readers = 4;
clearReadRequestBytes() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 readRequestBytes = 9;
clearReadRequestRecords() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 readRequestRecords = 10;
clearReadTimeoutEvents() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 readTimeoutEvents = 12;
clearSequenceNumber() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 sequenceNumber = 2;
clearStorageName() - Method in class io.sbp.grpc.Config.Builder: string storageName = 1;
clearTimeUnit() - Method in class io.sbp.grpc.Config.Builder: .EnumTimeUnit timeUnit = 3;
clearTotalBytes() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 totalBytes = 18;
clearTotalLatency() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 totalLatency = 19;
clearTotalRecords() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 totalRecords = 13;
clearValidLatencyRecords() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 validLatencyRecords = 14;
clearWriteRequestBytes() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 writeRequestBytes = 7;
clearWriteRequestRecords() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 writeRequestRecords = 8;
clearWriters() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int32 writers = 3;
clearWriteTimeoutEvents() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 writeTimeoutEvents = 11;
ClientID - Class in io.sbp.grpc: Protobuf type ClientID
CLIENTID_FIELD_NUMBER - Static variable in class io.sbp.grpc.MessageLatenciesRecord
ClientID.Builder - Class in io.sbp.grpc: Protobuf type ClientID
ClientIDOrBuilder - Interface in io.sbp.grpc
close() - Method in class io.sbk.api.AbstractCallbackReader: Close the CallBack Reader.
close() - Method in interface io.sbk.api.AsyncReader: Close the Reader.
close() - Method in interface io.sbk.api.DataReader: ß Close the Reader.
close() - Method in interface io.sbk.api.DataWriter: Close the Writer.
close() - Method in interface io.sbk.api.Reader: Close the Reader.
close() - Method in interface io.sbk.api.Writer: Close the Writer.
close(ParsedOptions) - Method in class io.sbk.logger.impl.AbstractRWLogger
close(ParsedOptions) - Method in class io.sbk.logger.impl.CSVLogger
close(ParsedOptions) - Method in class io.sbk.logger.impl.GrpcLogger: Close the logger, unregister the client, and shutdown the gRPC channel.
close(ParsedOptions) - Method in class io.sbk.logger.impl.PrometheusLogger: Close the logger and stop the HTTP server if it was started.
close(ParsedOptions) - Method in interface io.sbk.logger.Logger: Close the Logger.
closeClient(ClientID) - Method in class io.sbp.grpc.ServiceGrpc.ServiceBlockingStub
closeClient(ClientID) - Method in class io.sbp.grpc.ServiceGrpc.ServiceBlockingV2Stub
closeClient(ClientID) - Method in class io.sbp.grpc.ServiceGrpc.ServiceFutureStub
closeClient(ClientID, StreamObserver) - Method in interface io.sbp.grpc.ServiceGrpc.AsyncService
closeClient(ClientID, StreamObserver) - Method in class io.sbp.grpc.ServiceGrpc.ServiceStub
closeStorage(ParameterOptions) - Method in interface io.sbk.api.Storage: Close the Storage device / client.
complete() - Method in class io.sbk.api.AbstractCallbackReader: Default Implementation complete the read.
config - Variable in class io.sbk.params.impl.SbkYalParameters
Config - Class in io.sbk.config: Class Config.
Config - Class in io.sbp.grpc: Protobuf type Config
Config() - Constructor for class io.sbk.config.Config
Config.Builder - Class in io.sbp.grpc: Protobuf type Config
ConfigOrBuilder - Interface in io.sbp.grpc
consume(Object) - Method in class io.sbk.api.impl.SbkCallbackReader: Deprecated.
consume(T) - Method in interface io.sbk.api.Callback: Consume the data.
containsLatency(long) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: map<int64, int64> latency = 22;
containsLatency(long) - Method in class io.sbp.grpc.MessageLatenciesRecord: map<int64, int64> latency = 22;
containsLatency(long) - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: map<int64, int64> latency = 22;
context - Variable in class io.sbk.logger.MetricsConfig
control(long, double) - Method in class io.sbk.api.impl.SbkRateController: Blocks for small amounts of time to achieve target Throughput/events per sec.
control(long, double) - Method in interface io.sbk.api.RateController: Blocks for small amounts of time to achieve target Throughput/events per sec.
CountReaders - Interface in io.sbk.logger: Interface for tracking the count of active readers in the benchmarking system.
CountRW - Interface in io.sbk.logger: Combined interface for tracking both readers and writers in the benchmarking system.
CountWriters - Interface in io.sbk.logger: Interface for tracking the count of active writers in the benchmarking system.
create(int) - Method in interface io.sbk.data.DataType: Create the data with payload content.
create(int) - Method in class io.sbk.data.impl.ByteArray: Create byte array data and fill the random data.
create(int) - Method in class io.sbk.data.impl.NioByteBuffer: Create byte buffer data and will with random data.
create(int) - Method in class io.sbk.data.impl.ProtoBufByteString: Create byte array data and fill the random data.
create(int) - Method in class io.sbk.data.impl.SbkString: Create byte array data and fill the random data.
createReader(int, ParameterOptions) - Method in interface io.sbk.api.Storage: Create a Single Reader / Consumer.
createWriter(int, ParameterOptions) - Method in interface io.sbk.api.Storage: Create a Single Data Writer / Producer.
CSVLogger - Class in io.sbk.logger.impl: Class for recoding/printing results to a CSV file called `out.csv`.
CSVLogger() - Constructor for class io.sbk.logger.impl.CSVLogger: calls its super class SystemLogger.

D

DataReader<T> - Interface in io.sbk.api: Abstraction for data-reading capabilities used by SBK drivers.
DataRecordsReader<T> - Interface in io.sbk.api: Interface for Data Record Readers.
DataRecordsReader.RecordTime<T> - Interface in io.sbk.api: interface RecordTime.
DataRecordsReader.RecordTimeRequests<T> - Interface in io.sbk.api
DataRecordsWriter<T> - Interface in io.sbk.api: Higher-level writer abstraction that exposes methods for recording write metrics and provides default harness-driven write workloads.
DataType<T> - Interface in io.sbk.data: Interface for Data Type operations.
DataWriter<T> - Interface in io.sbk.api: Interface for Basic Data Writers.
decrementReaders() - Method in interface io.sbk.logger.CountReaders: Decrements the count of active readers.
decrementReaders() - Method in class io.sbk.logger.impl.AbstractRWLogger
decrementWriters() - Method in interface io.sbk.logger.CountWriters: Decrements the count of active writers.
decrementWriters() - Method in class io.sbk.logger.impl.AbstractRWLogger
DESC - Static variable in class io.sbk.config.Config: DESC = "Storage Benchmark Kit";.
DISABLE_STRING - Static variable in class io.sbk.logger.impl.CSVLogger: DISABLE_STRING = "no".

E

endTime - Variable in class io.sbk.api.Status
EnumAction - Enum Class in io.sbp.grpc: Protobuf enum EnumAction
EnumTimeUnit - Enum Class in io.sbp.grpc: Protobuf enum EnumTimeUnit
equals(Object) - Method in class io.sbp.grpc.ClientID
equals(Object) - Method in class io.sbp.grpc.Config
equals(Object) - Method in class io.sbp.grpc.MessageLatenciesRecord
equals(Object) - Method in class io.sbp.grpc.Version

F

FILE_OPTION - Static variable in class io.sbk.config.YalConfig: FILE_OPTION = "FILE_OPTION";.
FILE_OPTION_ARG - Static variable in class io.sbk.config.YalConfig: FILE_OPTION_ARG = ARG_PREFIX + FILE_OPTION;.
ForkJoin - Enum constant in enum class io.sbk.thread.ThreadType: ForkJoin threads - Work-stealing threads for parallel algorithms.
forNumber(int) - Static method in enum class io.sbp.grpc.EnumAction
forNumber(int) - Static method in enum class io.sbp.grpc.EnumTimeUnit

G

genericRecordsReader(Worker, long, DataType, Time, DataRecordsReader.RecordTime) - Method in interface io.sbk.api.DataRecordsReader: Benchmarking reader by reading given number of records.
genericRecordsReader(Worker, long, DataType, Time, DataRecordsReader.RecordTimeRequests, ReadRequestsLogger) - Method in interface io.sbk.api.DataRecordsReader: Benchmarking reader by reading given number of records.
genericRecordsReaderRateControl(Worker, long, DataType, Time, RateController, DataRecordsReader.RecordTime) - Method in interface io.sbk.api.DataRecordsReader: Benchmarking reader with Rate controlled.
genericRecordsReaderRateControl(Worker, long, DataType, Time, RateController, DataRecordsReader.RecordTimeRequests, ReadRequestsLogger) - Method in interface io.sbk.api.DataRecordsReader: Benchmarking reader with Rate controlled.
genericRecordsTimeReader(Worker, long, DataType, Time, DataRecordsReader.RecordTime) - Method in interface io.sbk.api.DataRecordsReader: Benchmarking reader by reading events/records for specific time duration.
genericRecordsTimeReader(Worker, long, DataType, Time, DataRecordsReader.RecordTimeRequests, ReadRequestsLogger) - Method in interface io.sbk.api.DataRecordsReader: Benchmarking reader by reading events/records for specific time duration.
genericRecordsTimeReaderRateControl(Worker, long, DataType, Time, RateController, DataRecordsReader.RecordTime) - Method in interface io.sbk.api.DataRecordsReader: Benchmarking reader by reading events/records with Rate Controls.
genericRecordsTimeReaderRateControl(Worker, long, DataType, Time, RateController, DataRecordsReader.RecordTimeRequests, ReadRequestsLogger) - Method in interface io.sbk.api.DataRecordsReader: Benchmarking reader by reading events/records with Rate Controls.
getAction() - Method in class io.sbk.logger.impl.AbstractRWLogger
getAction() - Method in interface io.sbk.params.ActionParameter: Get the selected benchmark action.
getAction() - Method in class io.sbp.grpc.Config.Builder: .EnumAction action = 2;
getAction() - Method in class io.sbp.grpc.Config: .EnumAction action = 2;
getAction() - Method in interface io.sbp.grpc.ConfigOrBuilder: .EnumAction action = 2;
getActionValue() - Method in class io.sbp.grpc.Config.Builder: .EnumAction action = 2;
getActionValue() - Method in class io.sbp.grpc.Config: .EnumAction action = 2;
getActionValue() - Method in interface io.sbp.grpc.ConfigOrBuilder: .EnumAction action = 2;
getAddLatenciesRecordMethod() - Static method in class io.sbp.grpc.ServiceGrpc
getArgValue(String[], String) - Static method in class io.sbk.utils.SbkUtils
getClass(String) - Method in class io.sbk.api.Package
getClasses(String) - Method in class io.sbk.api.Package: Get the set of Available Storage classes.
getClasses(String) - Method in class io.sbk.api.RWLoggerPackage
getClasses(String) - Method in class io.sbk.api.StoragePackage: Get the set of Available Storage classes.
getClassName(String[]) - Static method in class io.sbk.utils.SbkUtils
getClassNames() - Method in class io.sbk.api.Package
getClientID() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 clientID = 1;
getClientID() - Method in class io.sbp.grpc.MessageLatenciesRecord: int64 clientID = 1;
getClientID() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: int64 clientID = 1;
getCloseClientMethod() - Static method in class io.sbp.grpc.ServiceGrpc
getConfig(Empty) - Method in class io.sbp.grpc.ServiceGrpc.ServiceBlockingStub
getConfig(Empty) - Method in class io.sbp.grpc.ServiceGrpc.ServiceBlockingV2Stub
getConfig(Empty) - Method in class io.sbp.grpc.ServiceGrpc.ServiceFutureStub
getConfig(Empty, StreamObserver) - Method in interface io.sbp.grpc.ServiceGrpc.AsyncService
getConfig(Empty, StreamObserver) - Method in class io.sbp.grpc.ServiceGrpc.ServiceStub
getCsvFile() - Method in class io.sbk.logger.impl.CSVLogger
getDataType() - Method in interface io.sbk.api.Storage: Default implementation to create a payload or data to write/read.
getDefaultInstance() - Static method in class io.sbp.grpc.ClientID
getDefaultInstance() - Static method in class io.sbp.grpc.Config
getDefaultInstance() - Static method in class io.sbp.grpc.MessageLatenciesRecord
getDefaultInstance() - Static method in class io.sbp.grpc.Version
getDefaultInstanceForType() - Method in class io.sbp.grpc.ClientID.Builder
getDefaultInstanceForType() - Method in class io.sbp.grpc.ClientID
getDefaultInstanceForType() - Method in class io.sbp.grpc.Config.Builder
getDefaultInstanceForType() - Method in class io.sbp.grpc.Config
getDefaultInstanceForType() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder
getDefaultInstanceForType() - Method in class io.sbp.grpc.MessageLatenciesRecord
getDefaultInstanceForType() - Method in class io.sbp.grpc.Version.Builder
getDefaultInstanceForType() - Method in class io.sbp.grpc.Version
getDescriptor() - Static method in class io.sbp.grpc.ClientID.Builder
getDescriptor() - Static method in class io.sbp.grpc.ClientID
getDescriptor() - Static method in class io.sbp.grpc.Config.Builder
getDescriptor() - Static method in class io.sbp.grpc.Config
getDescriptor() - Static method in enum class io.sbp.grpc.EnumAction
getDescriptor() - Static method in enum class io.sbp.grpc.EnumTimeUnit
getDescriptor() - Static method in class io.sbp.grpc.MessageLatenciesRecord.Builder
getDescriptor() - Static method in class io.sbp.grpc.MessageLatenciesRecord
getDescriptor() - Static method in class io.sbp.grpc.SbpGrpc
getDescriptor() - Static method in class io.sbp.grpc.Version.Builder
getDescriptor() - Static method in class io.sbp.grpc.Version
getDescriptorForType() - Method in class io.sbp.grpc.ClientID.Builder
getDescriptorForType() - Method in class io.sbp.grpc.ClientID
getDescriptorForType() - Method in class io.sbp.grpc.Config.Builder
getDescriptorForType() - Method in class io.sbp.grpc.Config
getDescriptorForType() - Method in enum class io.sbp.grpc.EnumAction
getDescriptorForType() - Method in enum class io.sbp.grpc.EnumTimeUnit
getDescriptorForType() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder
getDescriptorForType() - Method in class io.sbp.grpc.MessageLatenciesRecord
getDescriptorForType() - Method in class io.sbp.grpc.Version.Builder
getDescriptorForType() - Method in class io.sbp.grpc.Version
getFileName() - Method in class io.sbk.params.impl.SbkYalParameters
getFileName() - Method in interface io.sbk.params.YalParameters: Get the configured YAML file name.
getFileOptionDescription() - Method in class io.sbk.params.impl.SbkYalParameters: Build description text for the -file option including the default path.
getGetConfigMethod() - Static method in class io.sbp.grpc.ServiceGrpc
getGetVersionMethod() - Static method in class io.sbp.grpc.ServiceGrpc
getHelpText() - Method in class io.sbk.params.impl.SbkInputOptions: Build and return the formatted help text for all registered options.
getHelpText() - Method in interface io.sbk.params.ParsedOptions: Get the -help output.
getHigherLatencyDiscardRecords() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 higherLatencyDiscardRecords = 16;
getHigherLatencyDiscardRecords() - Method in class io.sbp.grpc.MessageLatenciesRecord: int64 higherLatencyDiscardRecords = 16;
getHigherLatencyDiscardRecords() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: int64 higherLatencyDiscardRecords = 16;
getId() - Method in class io.sbp.grpc.ClientID.Builder: int64 id = 1;
getId() - Method in class io.sbp.grpc.ClientID: int64 id = 1;
getId() - Method in interface io.sbp.grpc.ClientIDOrBuilder: int64 id = 1;
getIdleSleepMilliSeconds() - Method in interface io.sbk.params.Parameters: get duration idle sleep in Milliseconds.
getInvalidLatencyRecords() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 invalidLatencyRecords = 17;
getInvalidLatencyRecords() - Method in class io.sbp.grpc.MessageLatenciesRecord: int64 invalidLatencyRecords = 17;
getInvalidLatencyRecords() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: int64 invalidLatencyRecords = 17;
getIsReadRequests() - Method in class io.sbp.grpc.Config.Builder: bool isReadRequests = 7;
getIsReadRequests() - Method in class io.sbp.grpc.Config: bool isReadRequests = 7;
getIsReadRequests() - Method in interface io.sbp.grpc.ConfigOrBuilder: bool isReadRequests = 7;
getIsVersionSupportedMethod() - Static method in class io.sbp.grpc.ServiceGrpc
getIsWriteRequests() - Method in class io.sbp.grpc.Config.Builder: bool isWriteRequests = 6;
getIsWriteRequests() - Method in class io.sbp.grpc.Config: bool isWriteRequests = 6;
getIsWriteRequests() - Method in interface io.sbp.grpc.ConfigOrBuilder: bool isWriteRequests = 6;
getLatency() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: Deprecated.
getLatency() - Method in class io.sbp.grpc.MessageLatenciesRecord: Deprecated.
getLatency() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: Deprecated.
getLatencyCount() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder
getLatencyCount() - Method in class io.sbp.grpc.MessageLatenciesRecord
getLatencyCount() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: map<int64, int64> latency = 22;
getLatencyMap() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: map<int64, int64> latency = 22;
getLatencyMap() - Method in class io.sbp.grpc.MessageLatenciesRecord: map<int64, int64> latency = 22;
getLatencyMap() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: map<int64, int64> latency = 22;
getLatencyOrDefault(long, long) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: map<int64, int64> latency = 22;
getLatencyOrDefault(long, long) - Method in class io.sbp.grpc.MessageLatenciesRecord: map<int64, int64> latency = 22;
getLatencyOrDefault(long, long) - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: map<int64, int64> latency = 22;
getLatencyOrThrow(long) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: map<int64, int64> latency = 22;
getLatencyOrThrow(long) - Method in class io.sbp.grpc.MessageLatenciesRecord: map<int64, int64> latency = 22;
getLatencyOrThrow(long) - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: map<int64, int64> latency = 22;
getLoggerConfigStream() - Method in class io.sbk.logger.impl.AbstractRWLogger
getLoggerName(String[]) - Static method in class io.sbk.utils.SbkUtils
getLowerLatencyDiscardRecords() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 lowerLatencyDiscardRecords = 15;
getLowerLatencyDiscardRecords() - Method in class io.sbp.grpc.MessageLatenciesRecord: int64 lowerLatencyDiscardRecords = 15;
getLowerLatencyDiscardRecords() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: int64 lowerLatencyDiscardRecords = 15;
getMajor() - Method in class io.sbp.grpc.Version.Builder: int32 major = 1;
getMajor() - Method in class io.sbp.grpc.Version: int32 major = 1;
getMajor() - Method in interface io.sbp.grpc.VersionOrBuilder: int32 major = 1;
getMaxLatency() - Method in class io.sbp.grpc.Config.Builder: int64 maxLatency = 5;
getMaxLatency() - Method in class io.sbp.grpc.Config: int64 maxLatency = 5;
getMaxLatency() - Method in interface io.sbp.grpc.ConfigOrBuilder: int64 maxLatency = 5;
getMaxLatency() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 maxLatency = 21;
getMaxLatency() - Method in class io.sbp.grpc.MessageLatenciesRecord: int64 maxLatency = 21;
getMaxLatency() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: int64 maxLatency = 21;
getMaxReaderIDs() - Method in class io.sbk.logger.impl.AbstractRWLogger
getMaxReaderIDs() - Method in interface io.sbk.logger.ReadRequestsLogger: Maximum number of reader IDs the logger expects to track.
getMaxReaderIDs() - Method in interface io.sbk.logger.RWLogger: Default method to indicate to record read requests or not.
getMaxReaders() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int32 maxReaders = 6;
getMaxReaders() - Method in class io.sbp.grpc.MessageLatenciesRecord: int32 maxReaders = 6;
getMaxReaders() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: int32 maxReaders = 6;
getMaxReadersCount() - Method in class io.sbk.logger.impl.AbstractRWLogger
getMaxWriterIDs() - Method in class io.sbk.logger.impl.AbstractRWLogger
getMaxWriterIDs() - Method in interface io.sbk.logger.RWLogger: Default method to indicate to record write requests or not.
getMaxWriterIDs() - Method in interface io.sbk.logger.WriteRequestsLogger: Maximum number of writer IDs the logger expects to track.
getMaxWriters() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int32 maxWriters = 5;
getMaxWriters() - Method in class io.sbp.grpc.MessageLatenciesRecord: int32 maxWriters = 5;
getMaxWriters() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: int32 maxWriters = 5;
getMaxWritersCount() - Method in class io.sbk.logger.impl.AbstractRWLogger
getMetricsConfig() - Method in class io.sbk.logger.impl.PrometheusLogger
getMetricsConfigStream() - Method in class io.sbk.logger.impl.PrometheusLogger
getMinLatency() - Method in class io.sbp.grpc.Config.Builder: int64 minLatency = 4;
getMinLatency() - Method in class io.sbp.grpc.Config: int64 minLatency = 4;
getMinLatency() - Method in interface io.sbp.grpc.ConfigOrBuilder: int64 minLatency = 4;
getMinLatency() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 minLatency = 20;
getMinLatency() - Method in class io.sbp.grpc.MessageLatenciesRecord: int64 minLatency = 20;
getMinLatency() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: int64 minLatency = 20;
getMinor() - Method in class io.sbp.grpc.Version.Builder: int32 minor = 2;
getMinor() - Method in class io.sbp.grpc.Version: int32 minor = 2;
getMinor() - Method in interface io.sbp.grpc.VersionOrBuilder: int32 minor = 2;
getMutableLatency() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: Deprecated.
getNumber() - Method in enum class io.sbp.grpc.EnumAction
getNumber() - Method in enum class io.sbp.grpc.EnumTimeUnit
getOptionValue(String) - Method in class io.sbk.params.impl.SbkInputOptions
getOptionValue(String) - Method in interface io.sbk.params.ParsedOptions: Retrieve the Option matching the parameter name specified.
getOptionValue(String, String) - Method in class io.sbk.params.impl.SbkInputOptions
getOptionValue(String, String) - Method in interface io.sbk.params.ParsedOptions: Retrieve the Option matching the parameter name specified.
getParserForType() - Method in class io.sbp.grpc.ClientID
getParserForType() - Method in class io.sbp.grpc.Config
getParserForType() - Method in class io.sbp.grpc.MessageLatenciesRecord
getParserForType() - Method in class io.sbp.grpc.Version
getPrintingIntervalSeconds() - Method in class io.sbk.logger.impl.AbstractRWLogger
getPrintOptionDescription() - Method in class io.sbk.params.impl.SbkYalParameters: Build description text for the -print option.
getPrometheusRWMetricsServer() - Method in class io.sbk.logger.impl.PrometheusLogger
getReaders() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int32 readers = 4;
getReaders() - Method in class io.sbp.grpc.MessageLatenciesRecord: int32 readers = 4;
getReaders() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: int32 readers = 4;
getReadersCount() - Method in class io.sbk.logger.impl.AbstractRWLogger
getReadersCount() - Method in interface io.sbk.params.Parameters: Number of Readers/Consumers.
getReadersStep() - Method in interface io.sbk.params.Parameters: get the number of readers / step to increase.
getReadersStepSeconds() - Method in interface io.sbk.params.Parameters: get duration of readers step in seconds.
getReadRequestBytes() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 readRequestBytes = 9;
getReadRequestBytes() - Method in class io.sbp.grpc.MessageLatenciesRecord: int64 readRequestBytes = 9;
getReadRequestBytes() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: int64 readRequestBytes = 9;
getReadRequestRecords() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 readRequestRecords = 10;
getReadRequestRecords() - Method in class io.sbp.grpc.MessageLatenciesRecord: int64 readRequestRecords = 10;
getReadRequestRecords() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: int64 readRequestRecords = 10;
getReadTimeoutEvents() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 readTimeoutEvents = 12;
getReadTimeoutEvents() - Method in class io.sbp.grpc.MessageLatenciesRecord: int64 readTimeoutEvents = 12;
getReadTimeoutEvents() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: int64 readTimeoutEvents = 12;
getRecordSize() - Method in interface io.sbk.params.Parameters: Size of the record/event to read or write.
getRecordsPerSec() - Method in interface io.sbk.params.Parameters: Number of records/events to write/read per Second.
getRecordsPerSync() - Method in interface io.sbk.params.Parameters: Number of records/events to write/read per single flush/sync.
getRegisterClientMethod() - Static method in class io.sbp.grpc.ServiceGrpc
getSequenceNumber() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 sequenceNumber = 2;
getSequenceNumber() - Method in class io.sbp.grpc.MessageLatenciesRecord: int64 sequenceNumber = 2;
getSequenceNumber() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: int64 sequenceNumber = 2;
getSerializedSize() - Method in class io.sbp.grpc.ClientID
getSerializedSize() - Method in class io.sbp.grpc.Config
getSerializedSize() - Method in class io.sbp.grpc.MessageLatenciesRecord
getSerializedSize() - Method in class io.sbp.grpc.Version
getServiceDescriptor() - Static method in class io.sbp.grpc.ServiceGrpc
getStorageName() - Method in class io.sbk.logger.impl.AbstractRWLogger
getStorageName() - Method in class io.sbp.grpc.Config.Builder: string storageName = 1;
getStorageName() - Method in class io.sbp.grpc.Config: string storageName = 1;
getStorageName() - Method in interface io.sbp.grpc.ConfigOrBuilder: string storageName = 1;
getStorageNameBytes() - Method in class io.sbp.grpc.Config.Builder: string storageName = 1;
getStorageNameBytes() - Method in class io.sbp.grpc.Config: string storageName = 1;
getStorageNameBytes() - Method in interface io.sbp.grpc.ConfigOrBuilder: string storageName = 1;
getThreadType() - Method in interface io.sbk.params.ThreadTypeParameter: Gets the thread type to be used for benchmark execution.
getTime() - Method in class io.sbk.logger.impl.AbstractRWLogger
getTime(byte[]) - Method in class io.sbk.data.impl.ByteArray: Get the time of data.
getTime(ByteString) - Method in class io.sbk.data.impl.ProtoBufByteString: Get the time of data.
getTime(String) - Method in class io.sbk.data.impl.SbkString: Get the time of data.
getTime(ByteBuffer) - Method in class io.sbk.data.impl.NioByteBuffer: Get the time of data.
getTime(T) - Method in interface io.sbk.data.DataType: Get the time of data.
getTimeoutMS() - Method in interface io.sbk.params.Parameters: Time out for data to read.
getTimeUnit() - Method in class io.sbp.grpc.Config.Builder: .EnumTimeUnit timeUnit = 3;
getTimeUnit() - Method in class io.sbp.grpc.Config: .EnumTimeUnit timeUnit = 3;
getTimeUnit() - Method in interface io.sbp.grpc.ConfigOrBuilder: .EnumTimeUnit timeUnit = 3;
getTimeUnitValue() - Method in class io.sbp.grpc.Config.Builder: .EnumTimeUnit timeUnit = 3;
getTimeUnitValue() - Method in class io.sbp.grpc.Config: .EnumTimeUnit timeUnit = 3;
getTimeUnitValue() - Method in interface io.sbp.grpc.ConfigOrBuilder: .EnumTimeUnit timeUnit = 3;
getTotalBytes() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 totalBytes = 18;
getTotalBytes() - Method in class io.sbp.grpc.MessageLatenciesRecord: int64 totalBytes = 18;
getTotalBytes() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: int64 totalBytes = 18;
getTotalLatency() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 totalLatency = 19;
getTotalLatency() - Method in class io.sbp.grpc.MessageLatenciesRecord: int64 totalLatency = 19;
getTotalLatency() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: int64 totalLatency = 19;
getTotalRecords() - Method in interface io.sbk.params.Parameters: Get the Total Number of records to read/writer.
getTotalRecords() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 totalRecords = 13;
getTotalRecords() - Method in class io.sbp.grpc.MessageLatenciesRecord: int64 totalRecords = 13;
getTotalRecords() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: int64 totalRecords = 13;
getTotalSecondsToRun() - Method in interface io.sbk.params.Parameters: Get the execution time in seconds.
getValidLatencyRecords() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 validLatencyRecords = 14;
getValidLatencyRecords() - Method in class io.sbp.grpc.MessageLatenciesRecord: int64 validLatencyRecords = 14;
getValidLatencyRecords() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: int64 validLatencyRecords = 14;
getValueDescriptor() - Method in enum class io.sbp.grpc.EnumAction
getValueDescriptor() - Method in enum class io.sbp.grpc.EnumTimeUnit
getVersion() - Static method in class io.sbp.api.Sbp
getVersion(Empty) - Method in class io.sbp.grpc.ServiceGrpc.ServiceBlockingStub
getVersion(Empty) - Method in class io.sbp.grpc.ServiceGrpc.ServiceBlockingV2Stub
getVersion(Empty) - Method in class io.sbp.grpc.ServiceGrpc.ServiceFutureStub
getVersion(Empty, StreamObserver) - Method in interface io.sbp.grpc.ServiceGrpc.AsyncService
getVersion(Empty, StreamObserver) - Method in class io.sbp.grpc.ServiceGrpc.ServiceStub
getWriteReadMinSize() - Method in interface io.sbk.data.DataType: Get minimum Write and Read Data Size.
getWriteReadMinSize() - Method in class io.sbk.data.impl.ByteArray: Get minimum Write and Read Data Size.
getWriteReadMinSize() - Method in class io.sbk.data.impl.NioByteBuffer: Get minimum Write and Read Data Size.
getWriteReadMinSize() - Method in class io.sbk.data.impl.ProtoBufByteString: Get minimum Write and Read Data Size.
getWriteReadMinSize() - Method in class io.sbk.data.impl.SbkString
getWriteRequestBytes() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 writeRequestBytes = 7;
getWriteRequestBytes() - Method in class io.sbp.grpc.MessageLatenciesRecord: int64 writeRequestBytes = 7;
getWriteRequestBytes() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: int64 writeRequestBytes = 7;
getWriteRequestRecords() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 writeRequestRecords = 8;
getWriteRequestRecords() - Method in class io.sbp.grpc.MessageLatenciesRecord: int64 writeRequestRecords = 8;
getWriteRequestRecords() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: int64 writeRequestRecords = 8;
getWriters() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int32 writers = 3;
getWriters() - Method in class io.sbp.grpc.MessageLatenciesRecord: int32 writers = 3;
getWriters() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: int32 writers = 3;
getWritersCount() - Method in class io.sbk.logger.impl.AbstractRWLogger
getWritersCount() - Method in interface io.sbk.params.Parameters: Number of Writers/Producers.
getWritersStep() - Method in interface io.sbk.params.Parameters: get the number of writers / step to increase.
getWritersStepSeconds() - Method in interface io.sbk.params.Parameters: get duration of writers step in seconds.
getWriteTimeoutEvents() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 writeTimeoutEvents = 11;
getWriteTimeoutEvents() - Method in class io.sbp.grpc.MessageLatenciesRecord: int64 writeTimeoutEvents = 11;
getWriteTimeoutEvents() - Method in interface io.sbp.grpc.MessageLatenciesRecordOrBuilder: int64 writeTimeoutEvents = 11;
getYmlArgs(String, Class) - Static method in class io.sbk.params.YmlMap: Read a YAML file and convert its args map into a CLI argument array.
GrpcLogger - Class in io.sbk.logger.impl: Class for Recoding/Printing benchmark results on micrometer Composite Meter Registry.
GrpcLogger() - Constructor for class io.sbk.logger.impl.GrpcLogger: Construct a gRPC logger.

H

hasArg(String[], String) - Static method in class io.sbk.utils.SbkUtils
hashCode() - Method in class io.sbp.grpc.ClientID
hashCode() - Method in class io.sbp.grpc.Config
hashCode() - Method in class io.sbp.grpc.MessageLatenciesRecord
hashCode() - Method in class io.sbp.grpc.Version
hasHelp(String[]) - Static method in class io.sbk.utils.SbkUtils
hasOption(String) - Method in class io.sbk.params.impl.SbkInputOptions
hasOption(String) - Method in interface io.sbk.params.InputOptions: Returns whether the named Option exists.
hasOptionValue(String) - Method in class io.sbk.params.impl.SbkInputOptions
hasOptionValue(String) - Method in interface io.sbk.params.ParsedOptions: Returns whether the named Option has the value after parsing.
HELP_OPTION - Static variable in class io.sbk.config.Config: HELP_OPTION = "help";.
HELP_OPTION_ARG - Static variable in class io.sbk.config.Config: HELP_OPTION_ARG = ARG_PREFIX + HELP_OPTION;.
HelpException - Exception Class in io.sbk.exception: class HelpException.
HelpException(String) - Constructor for exception class io.sbk.exception.HelpException: this.helpText = helpText.
HIGHERLATENCYDISCARDRECORDS_FIELD_NUMBER - Static variable in class io.sbp.grpc.MessageLatenciesRecord
host - Variable in class io.sbk.logger.SbmHostConfig

I

id - Variable in class io.sbk.api.Worker
ID_FIELD_NUMBER - Static variable in class io.sbp.grpc.ClientID
incrementReaders() - Method in interface io.sbk.logger.CountReaders: Increments the count of active readers.
incrementReaders() - Method in class io.sbk.logger.impl.AbstractRWLogger
incrementWriters() - Method in interface io.sbk.logger.CountWriters: Increments the count of active writers.
incrementWriters() - Method in class io.sbk.logger.impl.AbstractRWLogger
initialize(Worker, long, long, DataType, Time, Callback) - Method in class io.sbk.api.AbstractCallbackReader: Default Implementation to initialize the callback reader.
InputOptions - Interface in io.sbk.params: Builder/registry for supported command-line options before parsing.
InputParameterOptions - Interface in io.sbk.params: Composite interface bundling option registration, parsing, and typed parameter access.
internalGetFieldAccessorTable() - Method in class io.sbp.grpc.ClientID.Builder
internalGetFieldAccessorTable() - Method in class io.sbp.grpc.ClientID
internalGetFieldAccessorTable() - Method in class io.sbp.grpc.Config.Builder
internalGetFieldAccessorTable() - Method in class io.sbp.grpc.Config
internalGetFieldAccessorTable() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder
internalGetFieldAccessorTable() - Method in class io.sbp.grpc.MessageLatenciesRecord
internalGetFieldAccessorTable() - Method in class io.sbp.grpc.Version.Builder
internalGetFieldAccessorTable() - Method in class io.sbp.grpc.Version
internalGetMapFieldReflection(int) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder
internalGetMapFieldReflection(int) - Method in class io.sbp.grpc.MessageLatenciesRecord
internalGetMutableMapFieldReflection(int) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder
internalGetValueMap() - Static method in enum class io.sbp.grpc.EnumAction
internalGetValueMap() - Static method in enum class io.sbp.grpc.EnumTimeUnit
INVALID_VERSION - Static variable in class io.sbp.config.SbpVersion
INVALIDLATENCYRECORDS_FIELD_NUMBER - Static variable in class io.sbp.grpc.MessageLatenciesRecord
io.sbk.action - package io.sbk.action
io.sbk.api - package io.sbk.api
io.sbk.api.impl - package io.sbk.api.impl
io.sbk.config - package io.sbk.config
io.sbk.data - package io.sbk.data
io.sbk.data.impl - package io.sbk.data.impl
io.sbk.exception - package io.sbk.exception
io.sbk.logger - package io.sbk.logger
io.sbk.logger.impl - package io.sbk.logger.impl
io.sbk.main - package io.sbk.main
io.sbk.params - package io.sbk.params
io.sbk.params.impl - package io.sbk.params.impl
io.sbk.system - package io.sbk.system
io.sbk.thread - package io.sbk.thread
io.sbk.utils - package io.sbk.utils
io.sbp.api - package io.sbp.api
io.sbp.config - package io.sbp.config
io.sbp.grpc - package io.sbp.grpc
isCsvEnable() - Method in class io.sbk.logger.impl.CSVLogger
isEmpty() - Method in class io.sbk.api.Package
isInitialized() - Method in class io.sbp.grpc.ClientID.Builder
isInitialized() - Method in class io.sbp.grpc.ClientID
isInitialized() - Method in class io.sbp.grpc.Config.Builder
isInitialized() - Method in class io.sbp.grpc.Config
isInitialized() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder
isInitialized() - Method in class io.sbp.grpc.MessageLatenciesRecord
isInitialized() - Method in class io.sbp.grpc.Version.Builder
isInitialized() - Method in class io.sbp.grpc.Version
ISREADREQUESTS_FIELD_NUMBER - Static variable in class io.sbp.grpc.Config
isReadRequestsEnabled() - Method in class io.sbk.logger.impl.AbstractRWLogger
isVersionSupported(Version) - Method in class io.sbp.grpc.ServiceGrpc.ServiceBlockingStub
isVersionSupported(Version) - Method in class io.sbp.grpc.ServiceGrpc.ServiceBlockingV2Stub
isVersionSupported(Version) - Method in class io.sbp.grpc.ServiceGrpc.ServiceFutureStub
isVersionSupported(Version, StreamObserver) - Method in interface io.sbp.grpc.ServiceGrpc.AsyncService
isVersionSupported(Version, StreamObserver) - Method in class io.sbp.grpc.ServiceGrpc.ServiceStub
ISWRITEREQUESTS_FIELD_NUMBER - Static variable in class io.sbp.grpc.Config
isWriteRequestsEnabled() - Method in class io.sbk.logger.impl.AbstractRWLogger

L

LATENCY_FIELD_NUMBER - Static variable in class io.sbp.grpc.MessageLatenciesRecord
latencyTimeUnit - Variable in class io.sbk.logger.MetricsConfig
length(byte[]) - Method in class io.sbk.data.impl.ByteArray: Get the size of the given data in terms of number of bytes for writers.
length(ByteString) - Method in class io.sbk.data.impl.ProtoBufByteString: Get the size of the given data in terms of number of bytes for writers.
length(String) - Method in class io.sbk.data.impl.SbkString: Get the size of the given data in terms of number of bytes for writers.
length(ByteBuffer) - Method in class io.sbk.data.impl.NioByteBuffer: Get the size of the given data in terms of number of bytes, for writers.
length(T) - Method in interface io.sbk.data.DataType: Get the size of the given data in terms of number of bytes.
log - Static variable in class io.sbk.system.Printer
Logger - Interface in io.sbk.logger: Primary logging interface for SBK benchmarks to configure, open, and close metrics reporting.
LOGGER_OPTION - Static variable in class io.sbk.config.Config: LOGGER_OPTION = "out";.
LOGGER_OPTION_ARG - Static variable in class io.sbk.config.Config: LOGGER_OPTION_ARG = ARG_PREFIX + LOGGER_OPTION;.
LoggerConfig - Class in io.sbk.logger: Configuration model for logger behavior and latency bounds.
LoggerConfig() - Constructor for class io.sbk.logger.LoggerConfig
LOWERLATENCYDISCARDRECORDS_FIELD_NUMBER - Static variable in class io.sbp.grpc.MessageLatenciesRecord

M

main(String[]) - Static method in class io.sbk.main.SbkMain
major - Variable in class io.sbp.config.SbpVersion
MAJOR_FIELD_NUMBER - Static variable in class io.sbp.grpc.Version
mapToArgs(Map, boolean) - Static method in class io.sbk.utils.SbkUtils
maxLatency - Variable in class io.sbk.logger.LoggerConfig
MAXLATENCY_FIELD_NUMBER - Static variable in class io.sbp.grpc.Config
MAXLATENCY_FIELD_NUMBER - Static variable in class io.sbp.grpc.MessageLatenciesRecord
MAXREADERS_FIELD_NUMBER - Static variable in class io.sbp.grpc.MessageLatenciesRecord
maxRecordSizeMB - Variable in class io.sbk.logger.SbmHostConfig
MAXWRITERS_FIELD_NUMBER - Static variable in class io.sbp.grpc.MessageLatenciesRecord
mcs - Enum constant in enum class io.sbp.grpc.EnumTimeUnit: mcs = 1;
mcs_VALUE - Static variable in enum class io.sbp.grpc.EnumTimeUnit: mcs = 1;
mergeArgs(String[], String[]) - Static method in class io.sbk.utils.SbkUtils
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.sbp.grpc.ClientID.Builder
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.sbp.grpc.Config.Builder
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.sbp.grpc.Version.Builder
mergeFrom(Message) - Method in class io.sbp.grpc.ClientID.Builder
mergeFrom(Message) - Method in class io.sbp.grpc.Config.Builder
mergeFrom(Message) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder
mergeFrom(Message) - Method in class io.sbp.grpc.Version.Builder
mergeFrom(ClientID) - Method in class io.sbp.grpc.ClientID.Builder
mergeFrom(Config) - Method in class io.sbp.grpc.Config.Builder
mergeFrom(MessageLatenciesRecord) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder
mergeFrom(Version) - Method in class io.sbp.grpc.Version.Builder
MessageLatenciesRecord - Class in io.sbp.grpc: Protobuf type MessageLatenciesRecord
MessageLatenciesRecord.Builder - Class in io.sbp.grpc: Protobuf type MessageLatenciesRecord
MessageLatenciesRecordOrBuilder - Interface in io.sbp.grpc
MetricsConfig - Class in io.sbk.logger: Configuration for metrics exporters (e.g., Prometheus).
MetricsConfig() - Constructor for class io.sbk.logger.MetricsConfig
minLatency - Variable in class io.sbk.logger.LoggerConfig
MINLATENCY_FIELD_NUMBER - Static variable in class io.sbp.grpc.Config
MINLATENCY_FIELD_NUMBER - Static variable in class io.sbp.grpc.MessageLatenciesRecord
minor - Variable in class io.sbp.config.SbpVersion
MINOR_FIELD_NUMBER - Static variable in class io.sbp.grpc.Version
ms - Enum constant in enum class io.sbp.grpc.EnumTimeUnit: ms = 0;
ms_VALUE - Static variable in enum class io.sbp.grpc.EnumTimeUnit: ms = 0;

N

NAME - Static variable in class io.sbk.config.Config: NAME = "sbk";.
newBlockingStub(Channel) - Static method in class io.sbp.grpc.ServiceGrpc: Creates a new blocking-style stub that supports unary and streaming output calls on the service
newBlockingV2Stub(Channel) - Static method in class io.sbp.grpc.ServiceGrpc: Creates a new blocking-style stub that supports all types of calls on the service
newBuilder() - Static method in class io.sbp.grpc.ClientID
newBuilder() - Static method in class io.sbp.grpc.Config
newBuilder() - Static method in class io.sbp.grpc.MessageLatenciesRecord
newBuilder() - Static method in class io.sbp.grpc.Version
newBuilder(ClientID) - Static method in class io.sbp.grpc.ClientID
newBuilder(Config) - Static method in class io.sbp.grpc.Config
newBuilder(MessageLatenciesRecord) - Static method in class io.sbp.grpc.MessageLatenciesRecord
newBuilder(Version) - Static method in class io.sbp.grpc.Version
newBuilderForType() - Method in class io.sbp.grpc.ClientID
newBuilderForType() - Method in class io.sbp.grpc.Config
newBuilderForType() - Method in class io.sbp.grpc.MessageLatenciesRecord
newBuilderForType() - Method in class io.sbp.grpc.Version
newBuilderForType(AbstractMessage.BuilderParent) - Method in class io.sbp.grpc.ClientID
newBuilderForType(AbstractMessage.BuilderParent) - Method in class io.sbp.grpc.Config
newBuilderForType(AbstractMessage.BuilderParent) - Method in class io.sbp.grpc.MessageLatenciesRecord
newBuilderForType(AbstractMessage.BuilderParent) - Method in class io.sbp.grpc.Version
newFutureStub(Channel) - Static method in class io.sbp.grpc.ServiceGrpc: Creates a new ListenableFuture-style stub that supports unary calls on the service
newStub(Channel) - Static method in class io.sbp.grpc.ServiceGrpc: Creates a new async stub that supports all call types for the service
NioByteBuffer - Class in io.sbk.data.impl: Class for processing ByteBuffer data.
NioByteBuffer() - Constructor for class io.sbk.data.impl.NioByteBuffer
ns - Enum constant in enum class io.sbp.grpc.EnumTimeUnit: ns = 2;
ns_VALUE - Static variable in enum class io.sbp.grpc.EnumTimeUnit: ns = 2;

O

open(ParsedOptions, String, Action, Time) - Method in class io.sbk.logger.impl.AbstractRWLogger
open(ParsedOptions, String, Action, Time) - Method in class io.sbk.logger.impl.CSVLogger
open(ParsedOptions, String, Action, Time) - Method in class io.sbk.logger.impl.GrpcLogger: Open the logger, establish a gRPC channel, validate configuration with SBM, and prepare buffers.
open(ParsedOptions, String, Action, Time) - Method in class io.sbk.logger.impl.PrometheusLogger: Open the logger and, if metrics are enabled, start the Prometheus HTTP server.
open(ParsedOptions, String, Action, Time) - Method in interface io.sbk.logger.Logger: Open the Logger.
openCSV() - Method in class io.sbk.logger.impl.CSVLogger: Open the CSV and write the header line.
openStorage(ParameterOptions) - Method in interface io.sbk.api.Storage: Open the storage device / client to perform the benchmarking.

P

Package<T> - Class in io.sbk.api: Utility base class for discovering implementation classes in a package.
Package(String) - Constructor for class io.sbk.api.Package
ParameterOptions - Interface in io.sbk.params: Composite interface combining parsed CLI access with typed benchmark parameters.
Parameters - Interface in io.sbk.params: Typed accessors for common SBK benchmark parameters.
params - Variable in class io.sbk.api.Worker
parseArgs(ParameterOptions) - Method in interface io.sbk.api.Storage: Parse the driver specific command line arguments.
parseArgs(ParsedOptions) - Method in class io.sbk.logger.impl.AbstractRWLogger
parseArgs(ParsedOptions) - Method in class io.sbk.logger.impl.CSVLogger
parseArgs(ParsedOptions) - Method in class io.sbk.logger.impl.GrpcLogger: Parse SBM options and decide if gRPC export is enabled.
parseArgs(ParsedOptions) - Method in class io.sbk.logger.impl.PrometheusLogger
parseArgs(ParsedOptions) - Method in interface io.sbk.logger.Logger: Parse the Metric specific command line arguments.
parseArgs(String[]) - Method in class io.sbk.params.impl.SbkInputOptions: Parse the provided arguments into a CommandLine.
parseArgs(String[]) - Method in class io.sbk.params.impl.SbkParameters
parseArgs(String[]) - Method in class io.sbk.params.impl.SbkYalParameters: Parse arguments and update YalConfig.yamlFileName to reflect any override from CLI.
parseArgs(String[]) - Method in interface io.sbk.params.ParseInputOptions: Parse the command line arguments.
parseDelimitedFrom(InputStream) - Static method in class io.sbp.grpc.ClientID
parseDelimitedFrom(InputStream) - Static method in class io.sbp.grpc.Config
parseDelimitedFrom(InputStream) - Static method in class io.sbp.grpc.MessageLatenciesRecord
parseDelimitedFrom(InputStream) - Static method in class io.sbp.grpc.Version
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.sbp.grpc.ClientID
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.sbp.grpc.Config
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.sbp.grpc.MessageLatenciesRecord
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.sbp.grpc.Version
ParsedOptions - Interface in io.sbk.params: Parsed command-line options accessor.
parseFrom(byte[]) - Static method in class io.sbp.grpc.ClientID
parseFrom(byte[]) - Static method in class io.sbp.grpc.Config
parseFrom(byte[]) - Static method in class io.sbp.grpc.MessageLatenciesRecord
parseFrom(byte[]) - Static method in class io.sbp.grpc.Version
parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.sbp.grpc.ClientID
parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.sbp.grpc.Config
parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.sbp.grpc.MessageLatenciesRecord
parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.sbp.grpc.Version
parseFrom(ByteString) - Static method in class io.sbp.grpc.ClientID
parseFrom(ByteString) - Static method in class io.sbp.grpc.Config
parseFrom(ByteString) - Static method in class io.sbp.grpc.MessageLatenciesRecord
parseFrom(ByteString) - Static method in class io.sbp.grpc.Version
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.sbp.grpc.ClientID
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.sbp.grpc.Config
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.sbp.grpc.MessageLatenciesRecord
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.sbp.grpc.Version
parseFrom(CodedInputStream) - Static method in class io.sbp.grpc.ClientID
parseFrom(CodedInputStream) - Static method in class io.sbp.grpc.Config
parseFrom(CodedInputStream) - Static method in class io.sbp.grpc.MessageLatenciesRecord
parseFrom(CodedInputStream) - Static method in class io.sbp.grpc.Version
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.sbp.grpc.ClientID
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.sbp.grpc.Config
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.sbp.grpc.MessageLatenciesRecord
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.sbp.grpc.Version
parseFrom(InputStream) - Static method in class io.sbp.grpc.ClientID
parseFrom(InputStream) - Static method in class io.sbp.grpc.Config
parseFrom(InputStream) - Static method in class io.sbp.grpc.MessageLatenciesRecord
parseFrom(InputStream) - Static method in class io.sbp.grpc.Version
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.sbp.grpc.ClientID
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.sbp.grpc.Config
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.sbp.grpc.MessageLatenciesRecord
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.sbp.grpc.Version
parseFrom(ByteBuffer) - Static method in class io.sbp.grpc.ClientID
parseFrom(ByteBuffer) - Static method in class io.sbp.grpc.Config
parseFrom(ByteBuffer) - Static method in class io.sbp.grpc.MessageLatenciesRecord
parseFrom(ByteBuffer) - Static method in class io.sbp.grpc.Version
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.sbp.grpc.ClientID
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.sbp.grpc.Config
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.sbp.grpc.MessageLatenciesRecord
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.sbp.grpc.Version
ParseInputOptions - Interface in io.sbk.params: Contract for parsing command-line arguments into ParsedOptions.
parser() - Static method in class io.sbp.grpc.ClientID
parser() - Static method in class io.sbp.grpc.Config
parser() - Static method in class io.sbp.grpc.MessageLatenciesRecord
parser() - Static method in class io.sbp.grpc.Version
percentiles - Variable in class io.sbk.logger.LoggerConfig
perlChannel - Variable in class io.sbk.api.Worker
Platform - Enum constant in enum class io.sbk.thread.ThreadType: Platform threads - Traditional OS threads for CPU-intensive workloads.
port - Variable in class io.sbk.logger.MetricsConfig
port - Variable in class io.sbk.logger.SbmHostConfig
print(double, long, long, double, double, double, long, long, long, long, long, long, long, long[], long[]) - Method in class io.sbk.logger.impl.AbstractRWLogger
print(int, int, int, int, long, double, long, double, long, double, long, double, long, long, long, long, long, long, long, double, long, double, double, long, long, double, double, double, long, long, long, long, long, long, long, long[], long[]) - Method in class io.sbk.logger.impl.AbstractRWLogger
print(int, int, int, int, long, double, long, double, long, double, long, double, long, long, long, long, long, long, long, double, long, double, double, long, long, double, double, double, long, long, long, long, long, long, long, long[], long[]) - Method in class io.sbk.logger.impl.CSVLogger
print(int, int, int, int, long, double, long, double, long, double, long, double, long, long, long, long, long, long, long, double, long, double, double, long, long, double, double, double, long, long, long, long, long, long, long, long[], long[]) - Method in class io.sbk.logger.impl.GrpcLogger
print(int, int, int, int, long, double, long, double, long, double, long, double, long, long, long, long, long, long, long, double, long, double, double, long, long, double, double, double, long, long, long, long, long, long, long, long[], long[]) - Method in class io.sbk.logger.impl.PrometheusLogger
print(int, int, int, int, long, double, long, double, long, double, long, double, long, long, long, long, long, long, long, double, long, double, double, long, long, double, double, double, long, long, long, long, long, long, long, long[], long[]) - Method in class io.sbk.logger.impl.SbkPrometheusServer: Update Micrometer counters/gauges and delegate latency stats to the base server.
print(int, int, int, int, long, double, long, double, long, double, long, double, long, long, long, long, long, long, long, double, long, double, double, long, long, double, double, double, long, long, long, long, long, long, long, long[], long[]) - Method in class io.sbk.logger.impl.Sl4jLogger: Log the periodic results using SLF4J at info level.
print(int, int, int, int, long, double, long, double, long, double, long, double, long, long, long, long, long, long, long, double, long, double, double, long, long, double, double, double, long, long, long, long, long, long, long, long[], long[]) - Method in class io.sbk.logger.impl.SystemLogger: Print the periodic results to System.out at the end of each interval.
print(int, int, int, int, long, double, long, double, long, double, long, double, long, long, long, long, long, long, long, double, long, double, double, long, long, double, double, double, long, long, long, long, long, long, long, long[], long[]) - Method in interface io.sbk.logger.RWPrint: Print the Periodic performance results.
PRINT_OPTION - Static variable in class io.sbk.config.YalConfig: PRINT_OPTION = "PRINT_OPTION";.
PRINT_OPTION_ARG - Static variable in class io.sbk.config.YalConfig: PRINT_OPTION_ARG = ARG_PREFIX + PRINT_OPTION;.
printClasses(String) - Method in class io.sbk.api.Package
Printer - Class in io.sbk.system
Printer() - Constructor for class io.sbk.system.Printer
printHelp() - Method in interface io.sbk.params.ParsedOptions: Print the -help output.
printTotal(double, long, long, double, double, double, long, long, long, long, long, long, long, long[], long[]) - Method in class io.sbk.logger.impl.AbstractRWLogger
printTotal(int, int, int, int, long, double, long, double, long, double, long, double, long, long, long, long, long, long, long, double, long, double, double, long, long, double, double, double, long, long, long, long, long, long, long, long[], long[]) - Method in class io.sbk.logger.impl.AbstractRWLogger
printTotal(int, int, int, int, long, double, long, double, long, double, long, double, long, long, long, long, long, long, long, double, long, double, double, long, long, double, double, double, long, long, long, long, long, long, long, long[], long[]) - Method in class io.sbk.logger.impl.CSVLogger
printTotal(int, int, int, int, long, double, long, double, long, double, long, double, long, long, long, long, long, long, long, double, long, double, double, long, long, double, double, double, long, long, long, long, long, long, long, long[], long[]) - Method in class io.sbk.logger.impl.Sl4jLogger: Log the final accumulated totals using SLF4J at info level.
printTotal(int, int, int, int, long, double, long, double, long, double, long, double, long, long, long, long, long, long, long, double, long, double, double, long, long, double, double, double, long, long, long, long, long, long, long, long[], long[]) - Method in class io.sbk.logger.impl.SystemLogger: Print the final accumulated totals to System.out at the end of the run.
printTotal(int, int, int, int, long, double, long, double, long, double, long, double, long, long, long, long, long, long, long, double, long, double, double, long, long, double, double, double, long, long, long, long, long, long, long, long[], long[]) - Method in interface io.sbk.logger.RWLogger: Print the "Total" roll-up, typically at the end of a benchmark run.
PrometheusLogger - Class in io.sbk.logger.impl: Class for Recoding/Printing benchmark results on micrometer Composite Meter Registry.
PrometheusLogger() - Constructor for class io.sbk.logger.impl.PrometheusLogger
ProtoBufByteString - Class in io.sbk.data.impl: Class for processing Byte String data.
ProtoBufByteString() - Constructor for class io.sbk.data.impl.ProtoBufByteString
putAllLatency(Map) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: map<int64, int64> latency = 22;
putLatency(long, long) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: map<int64, int64> latency = 22;

R

RateController - Interface in io.sbk.api: Interface for Rate or Throughput Controller.
read() - Method in interface io.sbk.api.Reader: Read the data.
Read_OnlyWriting - Enum constant in enum class io.sbk.action.Action: Read_OnlyWriting = 5.
Read_OnlyWriting - Enum constant in enum class io.sbp.grpc.EnumAction: Read_OnlyWriting = 5;
Read_OnlyWriting_VALUE - Static variable in enum class io.sbp.grpc.EnumAction: Read_OnlyWriting = 5;
Read_Writing - Enum constant in enum class io.sbk.action.Action: Read_Writing = 4.
Read_Writing - Enum constant in enum class io.sbp.grpc.EnumAction: Read_Writing = 4;
Read_Writing_VALUE - Static variable in enum class io.sbp.grpc.EnumAction: Read_Writing = 4;
readAsync(int) - Method in interface io.sbk.api.AsyncReader: Read the dat asynchronously.
Reader<T> - Interface in io.sbk.api: Reader abstraction used by SBK drivers to provide synchronous read semantics.
READERS_FIELD_NUMBER - Static variable in class io.sbp.grpc.MessageLatenciesRecord
Reading - Enum constant in enum class io.sbk.action.Action: Reading = 1.
Reading - Enum constant in enum class io.sbp.grpc.EnumAction: Reading = 1;
Reading_VALUE - Static variable in enum class io.sbp.grpc.EnumAction: Reading = 1;
READREQUESTBYTES_FIELD_NUMBER - Static variable in class io.sbp.grpc.MessageLatenciesRecord
READREQUESTRECORDS_FIELD_NUMBER - Static variable in class io.sbp.grpc.MessageLatenciesRecord
ReadRequestsLogger - Interface in io.sbk.logger: Read-side request logging hooks used by SBK loggers.
READTIMEOUTEVENTS_FIELD_NUMBER - Static variable in class io.sbp.grpc.MessageLatenciesRecord
record(long, long, int, int) - Method in interface io.sbk.api.Callback: Accept the benchmarking data.
record(long, long, int, int) - Method in class io.sbk.api.impl.SbkCallbackReader: Deprecated.
recordBenchmark(long, long, int, int) - Method in class io.sbk.api.AbstractCallbackReader: Keeps record of Benchmark if record gets completed it call complete function.
recordLatency(long, int, int, long) - Method in class io.sbk.logger.impl.GrpcLogger: Record individual latency values into the local LatencyRecorder and stage them for gRPC export.
recordRead(DataType, int, Time, Status, PerlChannel) - Method in interface io.sbk.api.AsyncReader: Default implementation for Reading data using AsyncReader.readAsync(int) ()} and recording the benchmark statistics.
recordRead(DataType, int, Time, Status, PerlChannel) - Method in interface io.sbk.api.DataRecordsReader: Record the single or multiple reads performance statistics.
recordRead(DataType, int, Time, Status, PerlChannel) - Method in interface io.sbk.api.DataRecordsReader.RecordTime: Method to Read records.
recordRead(DataType, int, Time, Status, PerlChannel) - Method in interface io.sbk.api.Reader: Default implementation for Reading data using Reader.read() and recording the benchmark statistics.
recordRead(DataType, int, Time, Status, PerlChannel, int, ReadRequestsLogger) - Method in interface io.sbk.api.AsyncReader: Default implementation for Reading data using AsyncReader.readAsync(int) ()} and recording the benchmark statistics.
recordRead(DataType, int, Time, Status, PerlChannel, int, ReadRequestsLogger) - Method in interface io.sbk.api.DataRecordsReader: Record the single or multiple reads performance statistics.
recordRead(DataType, int, Time, Status, PerlChannel, int, ReadRequestsLogger) - Method in interface io.sbk.api.DataRecordsReader.RecordTimeRequests: Method to Read records.
recordRead(DataType, int, Time, Status, PerlChannel, int, ReadRequestsLogger) - Method in interface io.sbk.api.Reader: Default implementation for Reading data using Reader.read() and recording the benchmark statistics.
recordReadRequests(int, long, long, long) - Method in class io.sbk.logger.impl.AbstractRWLogger
recordReadRequests(int, long, long, long) - Method in class io.sbk.logger.impl.GrpcLogger: Record read requests locally and mirror them into RAM buffers for gRPC export when enabled.
recordReadRequests(int, long, long, long) - Method in interface io.sbk.logger.ReadRequestsLogger: Record one or more read requests attributed to a reader.
recordReadRequests(int, long, long, long) - Method in interface io.sbk.logger.RWLogger: Default method to record every/multiple read event(s).
recordReadTime(DataType, int, Time, Status, PerlChannel) - Method in interface io.sbk.api.AsyncReader: Default implementation for Reading data using Reader.read(), extracting start time from data and recording the benchmark statistics.
recordReadTime(DataType, int, Time, Status, PerlChannel) - Method in interface io.sbk.api.DataRecordsReader: Record the single or multiple reads performance statistics along with the starting time in the data.
recordReadTime(DataType, int, Time, Status, PerlChannel) - Method in interface io.sbk.api.Reader: Default implementation for Reading data using Reader.read(), extracting start time from data and recording the benchmark statistics.
recordReadTime(DataType, int, Time, Status, PerlChannel, int, ReadRequestsLogger) - Method in interface io.sbk.api.AsyncReader: Default implementation for Reading data using Reader.read(), extracting start time from data and recording the benchmark statistics.
recordReadTime(DataType, int, Time, Status, PerlChannel, int, ReadRequestsLogger) - Method in interface io.sbk.api.DataRecordsReader: Record the single or multiple reads performance statistics along with the starting time in the data.
recordReadTime(DataType, int, Time, Status, PerlChannel, int, ReadRequestsLogger) - Method in interface io.sbk.api.Reader: Default implementation for Reading data using Reader.read(), extracting start time from data and recording the benchmark statistics.
recordReadTimeoutEvents(int, long, long) - Method in class io.sbk.logger.impl.AbstractRWLogger
recordReadTimeoutEvents(int, long, long) - Method in class io.sbk.logger.impl.GrpcLogger: Record read timeout events and mirror them into RAM buffers for gRPC export when enabled.
recordReadTimeoutEvents(int, long, long) - Method in interface io.sbk.logger.ReadRequestsLogger: Record read timeout events for a reader.
records - Variable in class io.sbk.api.Status
RecordsReader(Worker, long, DataType, Time) - Method in class io.sbk.api.AbstractCallbackReader: Implementation for benchmarking reader by reading given number of records.
RecordsReader(Worker, long, DataType, Time) - Method in interface io.sbk.api.DataReader: Benchmarking reader by reading given number of records.
RecordsReader(Worker, long, DataType, Time) - Method in interface io.sbk.api.DataRecordsReader: Default implementation for benchmarking reader by reading given number of records.
RecordsReader(Worker, long, DataType, Time, ReadRequestsLogger) - Method in class io.sbk.api.AbstractCallbackReader: Implementation for benchmarking reader by reading given number of records.
RecordsReader(Worker, long, DataType, Time, ReadRequestsLogger) - Method in interface io.sbk.api.DataReader: Benchmarking reader by reading given number of records.
RecordsReader(Worker, long, DataType, Time, ReadRequestsLogger) - Method in interface io.sbk.api.DataRecordsReader: Default implementation for benchmarking reader by reading given number of records.
RecordsReaderRateControl(Worker, long, DataType, Time, RateController) - Method in class io.sbk.api.AbstractCallbackReader: Benchmarking reader by reading given number of records with Rate controlled.
RecordsReaderRateControl(Worker, long, DataType, Time, RateController) - Method in interface io.sbk.api.DataReader: Benchmarking reader by reading given number of records with Rate controlled.
RecordsReaderRateControl(Worker, long, DataType, Time, RateController) - Method in interface io.sbk.api.DataRecordsReader: Benchmarking reader by reading given number of records with Rate controlled.
RecordsReaderRateControl(Worker, long, DataType, Time, RateController, ReadRequestsLogger) - Method in class io.sbk.api.AbstractCallbackReader: Benchmarking reader by reading given number of records with Rate controlled.
RecordsReaderRateControl(Worker, long, DataType, Time, RateController, ReadRequestsLogger) - Method in interface io.sbk.api.DataReader: Benchmarking reader by reading given number of records with Rate controlled.
RecordsReaderRateControl(Worker, long, DataType, Time, RateController, ReadRequestsLogger) - Method in interface io.sbk.api.DataRecordsReader: Benchmarking reader by reading given number of records with Rate controlled.
RecordsReaderRW(Worker, long, DataType, Time) - Method in class io.sbk.api.AbstractCallbackReader: Default implementation for benchmarking reader by reading given number of records.
RecordsReaderRW(Worker, long, DataType, Time) - Method in interface io.sbk.api.DataReader: Benchmarking reader by reading given number of records.
RecordsReaderRW(Worker, long, DataType, Time) - Method in interface io.sbk.api.DataRecordsReader: Default implementation for benchmarking reader by reading given number of records.
RecordsReaderRW(Worker, long, DataType, Time, ReadRequestsLogger) - Method in class io.sbk.api.AbstractCallbackReader: Default implementation for benchmarking reader by reading given number of records.
RecordsReaderRW(Worker, long, DataType, Time, ReadRequestsLogger) - Method in interface io.sbk.api.DataReader: Benchmarking reader by reading given number of records.
RecordsReaderRW(Worker, long, DataType, Time, ReadRequestsLogger) - Method in interface io.sbk.api.DataRecordsReader: Default implementation for benchmarking reader by reading given number of records.
RecordsReaderRWRateControl(Worker, long, DataType, Time, RateController) - Method in class io.sbk.api.AbstractCallbackReader: Benchmarking reader by reading given number of records with Rate controlled.
RecordsReaderRWRateControl(Worker, long, DataType, Time, RateController) - Method in interface io.sbk.api.DataReader: Benchmarking reader by reading given number of records with Rate controlled.
RecordsReaderRWRateControl(Worker, long, DataType, Time, RateController) - Method in interface io.sbk.api.DataRecordsReader: Benchmarking reader by reading given number of records with Rate controlled.
RecordsReaderRWRateControl(Worker, long, DataType, Time, RateController, ReadRequestsLogger) - Method in class io.sbk.api.AbstractCallbackReader: Benchmarking reader by reading given number of records with Rate controlled.
RecordsReaderRWRateControl(Worker, long, DataType, Time, RateController, ReadRequestsLogger) - Method in interface io.sbk.api.DataReader: Benchmarking reader by reading given number of records with Rate controlled.
RecordsReaderRWRateControl(Worker, long, DataType, Time, RateController, ReadRequestsLogger) - Method in interface io.sbk.api.DataRecordsReader: Benchmarking reader by reading given number of records with Rate controlled.
RecordsTimeReader(Worker, long, DataType, Time) - Method in class io.sbk.api.AbstractCallbackReader: Default implementation for benchmarking reader by reading events/records for specific time duration.
RecordsTimeReader(Worker, long, DataType, Time) - Method in interface io.sbk.api.DataReader: Benchmarking reader by reading events/records for specific time duration.
RecordsTimeReader(Worker, long, DataType, Time) - Method in interface io.sbk.api.DataRecordsReader: Default implementation for benchmarking reader by reading events/records for specific time duration.
RecordsTimeReader(Worker, long, DataType, Time, ReadRequestsLogger) - Method in class io.sbk.api.AbstractCallbackReader: Default implementation for benchmarking reader by reading events/records for specific time duration.
RecordsTimeReader(Worker, long, DataType, Time, ReadRequestsLogger) - Method in interface io.sbk.api.DataReader: Benchmarking reader by reading events/records for specific time duration.
RecordsTimeReader(Worker, long, DataType, Time, ReadRequestsLogger) - Method in interface io.sbk.api.DataRecordsReader: Default implementation for benchmarking reader by reading events/records for specific time duration.
RecordsTimeReaderRateControl(Worker, long, DataType, Time, RateController) - Method in class io.sbk.api.AbstractCallbackReader: Benchmarking reader by reading events/records for specific time duration with Rate controlled.
RecordsTimeReaderRateControl(Worker, long, DataType, Time, RateController) - Method in interface io.sbk.api.DataReader: Benchmarking reader by reading events/records for specific time duration with Rate controlled.
RecordsTimeReaderRateControl(Worker, long, DataType, Time, RateController) - Method in interface io.sbk.api.DataRecordsReader: Benchmarking reader by reading events/records for specific time duration with Rate controlled.
RecordsTimeReaderRateControl(Worker, long, DataType, Time, RateController, ReadRequestsLogger) - Method in class io.sbk.api.AbstractCallbackReader: Benchmarking reader by reading events/records for specific time duration with Rate controlled.
RecordsTimeReaderRateControl(Worker, long, DataType, Time, RateController, ReadRequestsLogger) - Method in interface io.sbk.api.DataReader: Benchmarking reader by reading events/records for specific time duration with Rate controlled.
RecordsTimeReaderRateControl(Worker, long, DataType, Time, RateController, ReadRequestsLogger) - Method in interface io.sbk.api.DataRecordsReader: Benchmarking reader by reading events/records for specific time duration with Rate controlled.
RecordsTimeReaderRW(Worker, long, DataType, Time) - Method in class io.sbk.api.AbstractCallbackReader: Default implementation for benchmarking reader by reading events/records for specific time duration.
RecordsTimeReaderRW(Worker, long, DataType, Time) - Method in interface io.sbk.api.DataReader: Benchmarking reader by reading events/records for specific time duration.
RecordsTimeReaderRW(Worker, long, DataType, Time) - Method in interface io.sbk.api.DataRecordsReader: Default implementation for benchmarking reader by reading events/records for specific time duration.
RecordsTimeReaderRW(Worker, long, DataType, Time, ReadRequestsLogger) - Method in class io.sbk.api.AbstractCallbackReader: Default implementation for benchmarking reader by reading events/records for specific time duration.
RecordsTimeReaderRW(Worker, long, DataType, Time, ReadRequestsLogger) - Method in interface io.sbk.api.DataReader: Benchmarking reader by reading events/records for specific time duration.
RecordsTimeReaderRW(Worker, long, DataType, Time, ReadRequestsLogger) - Method in interface io.sbk.api.DataRecordsReader: Default implementation for benchmarking reader by reading events/records for specific time duration.
RecordsTimeReaderRWRateControl(Worker, long, DataType, Time, RateController) - Method in class io.sbk.api.AbstractCallbackReader: Benchmarking reader by reading events/records for specific time duration with Rate controlled.
RecordsTimeReaderRWRateControl(Worker, long, DataType, Time, RateController) - Method in interface io.sbk.api.DataReader: Benchmarking reader by reading events/records for specific time duration with Rate controlled.
RecordsTimeReaderRWRateControl(Worker, long, DataType, Time, RateController) - Method in interface io.sbk.api.DataRecordsReader: Benchmarking reader by reading events/records for specific time duration with Rate controlled.
RecordsTimeReaderRWRateControl(Worker, long, DataType, Time, RateController, ReadRequestsLogger) - Method in class io.sbk.api.AbstractCallbackReader: Benchmarking reader by reading events/records for specific time duration with Rate controlled.
RecordsTimeReaderRWRateControl(Worker, long, DataType, Time, RateController, ReadRequestsLogger) - Method in interface io.sbk.api.DataReader: Benchmarking reader by reading events/records for specific time duration with Rate controlled.
RecordsTimeReaderRWRateControl(Worker, long, DataType, Time, RateController, ReadRequestsLogger) - Method in interface io.sbk.api.DataRecordsReader: Benchmarking reader by reading events/records for specific time duration with Rate controlled.
RecordsWriter(Worker, long, DataType, T, int, Time) - Method in interface io.sbk.api.DataRecordsWriter: Default implementation for writer benchmarking by writing given number of records.
RecordsWriter(Worker, long, DataType, T, int, Time) - Method in interface io.sbk.api.DataWriter: writer benchmarking by writing given number of records.
RecordsWriter(Worker, long, DataType, T, int, Time, WriteRequestsLogger) - Method in interface io.sbk.api.DataRecordsWriter: Default implementation for writer benchmarking by writing given number of records.
RecordsWriter(Worker, long, DataType, T, int, Time, WriteRequestsLogger) - Method in interface io.sbk.api.DataWriter: writer benchmarking by writing given number of records.
RecordsWriterRO(Worker, long, DataType, T, int, Time, RateController) - Method in interface io.sbk.api.DataRecordsWriter: Default implementation for writing given number of records.
RecordsWriterRO(Worker, long, DataType, T, int, Time, RateController) - Method in interface io.sbk.api.DataWriter: Write given number of records.
RecordsWriterRO(Worker, long, DataType, T, int, Time, RateController, WriteRequestsLogger) - Method in interface io.sbk.api.DataRecordsWriter: Default implementation for writing given number of records.
RecordsWriterRO(Worker, long, DataType, T, int, Time, RateController, WriteRequestsLogger) - Method in interface io.sbk.api.DataWriter: Write given number of records.
RecordsWriterRW(Worker, long, DataType, T, int, Time, RateController) - Method in interface io.sbk.api.DataRecordsWriter: Default implementation for writing given number of records.
RecordsWriterRW(Worker, long, DataType, T, int, Time, RateController) - Method in interface io.sbk.api.DataWriter: Write given number of records.
RecordsWriterRW(Worker, long, DataType, T, int, Time, RateController, WriteRequestsLogger) - Method in interface io.sbk.api.DataRecordsWriter: Default implementation for writing given number of records.
RecordsWriterRW(Worker, long, DataType, T, int, Time, RateController, WriteRequestsLogger) - Method in interface io.sbk.api.DataWriter: Write given number of records.
RecordsWriterSync(Worker, long, DataType, T, int, Time, RateController) - Method in interface io.sbk.api.DataRecordsWriter: Default implementation for writer benchmarking by writing given number of records.
RecordsWriterSync(Worker, long, DataType, T, int, Time, RateController) - Method in interface io.sbk.api.DataWriter: Writer benchmarking by writing given number of records and data should synced is invoked after writing given set of records.
RecordsWriterSync(Worker, long, DataType, T, int, Time, RateController, WriteRequestsLogger) - Method in interface io.sbk.api.DataRecordsWriter: Default implementation for writer benchmarking by writing given number of records.
RecordsWriterSync(Worker, long, DataType, T, int, Time, RateController, WriteRequestsLogger) - Method in interface io.sbk.api.DataWriter: Writer benchmarking by writing given number of records and data should synced is invoked after writing given set of records.
RecordsWriterTime(Worker, long, DataType, T, int, Time) - Method in interface io.sbk.api.DataRecordsWriter: Default implementation for writer benchmarking by continuously writing data records for specific time duration.
RecordsWriterTime(Worker, long, DataType, T, int, Time) - Method in interface io.sbk.api.DataWriter: Writer benchmarking by continuously writing data records for specific time duration.
RecordsWriterTime(Worker, long, DataType, T, int, Time, WriteRequestsLogger) - Method in interface io.sbk.api.DataRecordsWriter: Default implementation for writer benchmarking by continuously writing data records for specific time duration.
RecordsWriterTime(Worker, long, DataType, T, int, Time, WriteRequestsLogger) - Method in interface io.sbk.api.DataWriter: Writer benchmarking by continuously writing data records for specific time duration.
RecordsWriterTimeRO(Worker, long, DataType, T, int, Time, RateController) - Method in interface io.sbk.api.DataRecordsWriter: Default implementation for writing data records for specific time duration.
RecordsWriterTimeRO(Worker, long, DataType, T, int, Time, RateController) - Method in interface io.sbk.api.DataWriter: Writing data records for specific time duration.
RecordsWriterTimeRO(Worker, long, DataType, T, int, Time, RateController, WriteRequestsLogger) - Method in interface io.sbk.api.DataRecordsWriter: Default implementation for writing data records for specific time duration.
RecordsWriterTimeRO(Worker, long, DataType, T, int, Time, RateController, WriteRequestsLogger) - Method in interface io.sbk.api.DataWriter: Writing data records for specific time duration.
RecordsWriterTimeRW(Worker, long, DataType, T, int, Time, RateController) - Method in interface io.sbk.api.DataRecordsWriter: Default implementation for writing data records for specific time duration.
RecordsWriterTimeRW(Worker, long, DataType, T, int, Time, RateController) - Method in interface io.sbk.api.DataWriter: Writing data records for specific time duration.
RecordsWriterTimeRW(Worker, long, DataType, T, int, Time, RateController, WriteRequestsLogger) - Method in interface io.sbk.api.DataRecordsWriter: Default implementation for writing data records for specific time duration.
RecordsWriterTimeRW(Worker, long, DataType, T, int, Time, RateController, WriteRequestsLogger) - Method in interface io.sbk.api.DataWriter: Writing data records for specific time duration.
RecordsWriterTimeSync(Worker, long, DataType, T, int, Time, RateController) - Method in interface io.sbk.api.DataRecordsWriter: Default implementation for writer benchmarking by continuously writing data records for specific time duration.
RecordsWriterTimeSync(Worker, long, DataType, T, int, Time, RateController) - Method in interface io.sbk.api.DataWriter: writer benchmarking by continuously writing data records for specific time duration.
RecordsWriterTimeSync(Worker, long, DataType, T, int, Time, RateController, WriteRequestsLogger) - Method in interface io.sbk.api.DataRecordsWriter: Default implementation for writer benchmarking by continuously writing data records for specific time duration.
RecordsWriterTimeSync(Worker, long, DataType, T, int, Time, RateController, WriteRequestsLogger) - Method in interface io.sbk.api.DataWriter: writer benchmarking by continuously writing data records for specific time duration.
recordWrite(DataType, T, int, Time, Status, PerlChannel) - Method in interface io.sbk.api.DataRecordsWriter: Write the data and record the benchmark statistics.
recordWrite(DataType, T, int, Time, Status, PerlChannel) - Method in interface io.sbk.api.Writer: Default implementation for writing data using Writer.write(DataType, Object, int, Time, Status) and recording the benchmark statistics.
recordWrite(DataType, T, int, Time, Status, PerlChannel, int, WriteRequestsLogger) - Method in interface io.sbk.api.DataRecordsWriter: Write the data and record the benchmark statistics.
recordWrite(DataType, T, int, Time, Status, PerlChannel, int, WriteRequestsLogger) - Method in interface io.sbk.api.Writer: Default implementation for writing data using Writer.write(DataType, Object, int, Time, Status) and recording the benchmark statistics.
recordWriteRequests(int, long, long, long) - Method in class io.sbk.logger.impl.AbstractRWLogger
recordWriteRequests(int, long, long, long) - Method in class io.sbk.logger.impl.GrpcLogger: Record write requests locally and mirror them into RAM buffers for gRPC export when enabled.
recordWriteRequests(int, long, long, long) - Method in interface io.sbk.logger.RWLogger: Default method to record every/multiple write event(s).
recordWriteRequests(int, long, long, long) - Method in interface io.sbk.logger.WriteRequestsLogger: Record one or more write requests attributed to a writer.
recordWriteTimeoutEvents(int, long, long) - Method in class io.sbk.logger.impl.AbstractRWLogger
recordWriteTimeoutEvents(int, long, long) - Method in class io.sbk.logger.impl.GrpcLogger: Record write timeout events and mirror them into RAM buffers for gRPC export when enabled.
recordWriteTimeoutEvents(int, long, long) - Method in interface io.sbk.logger.WriteRequestsLogger: Record write timeout events for a writer.
registerAllExtensions(ExtensionRegistry) - Static method in class io.sbp.grpc.SbpGrpc
registerAllExtensions(ExtensionRegistryLite) - Static method in class io.sbp.grpc.SbpGrpc
registerClient(Config) - Method in class io.sbp.grpc.ServiceGrpc.ServiceBlockingStub
registerClient(Config) - Method in class io.sbp.grpc.ServiceGrpc.ServiceBlockingV2Stub
registerClient(Config) - Method in class io.sbp.grpc.ServiceGrpc.ServiceFutureStub
registerClient(Config, StreamObserver) - Method in interface io.sbp.grpc.ServiceGrpc.AsyncService
registerClient(Config, StreamObserver) - Method in class io.sbp.grpc.ServiceGrpc.ServiceStub
REGULAR_PRINT - Static variable in class io.sbk.logger.impl.CSVLogger: REGULAR_PRINT = "Regular".
removeLatency(long) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: map<int64, int64> latency = 22;
removeOptionArgs(String[], String[]) - Static method in class io.sbk.utils.SbkUtils
removeOptionArgsAndValues(String[], String[]) - Static method in class io.sbk.utils.SbkUtils
reportingSeconds - Variable in class io.sbk.logger.LoggerConfig
run(long, long) - Method in class io.sbk.api.impl.SbkReader
run(long, long) - Method in class io.sbk.api.impl.SbkWriter
run(Worker, long, long, DataType, Time, Callback) - Method in class io.sbk.api.AbstractCallbackReader: Default Implementation run the Benchmark.
run(String[], String, String, String) - Static method in class io.sbk.api.impl.Sbk: Run the Performance Benchmarking .
RWLogger - Interface in io.sbk.logger: Read/Write logger interface that combines request logging and printing hooks.
RWLoggerPackage - Class in io.sbk.api: Package helper for discovering RWLogger implementations on the classpath.
RWLoggerPackage(String) - Constructor for class io.sbk.api.RWLoggerPackage
rwMetricPrefix - Variable in class io.sbk.logger.impl.SbkPrometheusServer: Metric name prefix derived from the header (upper-cased and '_' separated).
RWPrint - Interface in io.sbk.logger

S

Sbk - Class in io.sbk.api.impl: Central SBK bootstrap and factory helper.
Sbk() - Constructor for class io.sbk.api.impl.Sbk
SBK_APP_HOME - Static variable in class io.sbk.config.Config: SBK_APP_HOME = "sbk.appHome";.
SBK_APP_NAME - Static variable in class io.sbk.config.Config: SBK_APP_NAME = "sbk.applicationName";.
SBK_CLASS_NAME - Static variable in class io.sbk.config.Config: SBK_CLASS_NAME = "sbk.className";.
SBK_FOOTER - Static variable in class io.sbk.config.Config: SBK_FOOTER = "\nPlease report issues at " + SBK_WEBSITE_NAME;.
SBK_LOGGER_PACKAGE_NAME - Static variable in class io.sbk.config.Config: SBK_LOGGER_PACKAGE_NAME = "io.sbk.logger";.
SBK_STORAGE_PACKAGE_NAME - Static variable in class io.sbk.config.Config: SBK_STORAGE_PACKAGE_NAME = "io.sbk.driver";.
SBK_WEBSITE_NAME - Static variable in class io.sbk.config.Config: SBK_WEBSITE_NAME = "https://github.com/kmgowda/SBK";.
SbkBenchmark - Class in io.sbk.api.impl: Class for performing the benchmark.
SbkBenchmark(ParameterOptions, Storage, DataType, RWLogger, Time) - Constructor for class io.sbk.api.impl.SbkBenchmark: Create SBK Benchmark.
SbkCallbackReader - Class in io.sbk.api.impl: Deprecated.
This interface is replaced by Abstract class AbstractCallbackReader and SbkReader.
SbkCallbackReader(int, ParameterOptions, PerlChannel, int, DataType, Time) - Constructor for class io.sbk.api.impl.SbkCallbackReader: Deprecated.
SbkDriversParameters - Class in io.sbk.params.impl: Parameters implementation that exposes storage driver and logger selection options.
SbkDriversParameters(String, String[], String[]) - Constructor for class io.sbk.params.impl.SbkDriversParameters: Convenience constructor using the default description.
SbkDriversParameters(String, String, String[], String[]) - Constructor for class io.sbk.params.impl.SbkDriversParameters: Create parameters with custom help description and available drivers/loggers.
SbkInputOptions - Class in io.sbk.params.impl: Default implementation of ParseInputOptions based on Apache Commons CLI.
SbkInputOptions(String, String) - Constructor for class io.sbk.params.impl.SbkInputOptions
SbkMain - Class in io.sbk.main: Main class of SBK.
SbkMain() - Constructor for class io.sbk.main.SbkMain
SbkParameters - Class in io.sbk.params.impl: Parses and exposes common SBK benchmark parameters.
SbkParameters(String) - Constructor for class io.sbk.params.impl.SbkParameters: Construct parameters using the default description.
SbkParameters(String, String) - Constructor for class io.sbk.params.impl.SbkParameters: Construct parameters with the given benchmark name and description.
SbkPrometheusServer - Class in io.sbk.logger.impl: Prometheus metrics server adapter for SBK read/write benchmarks.
SbkPrometheusServer(String, String, String, double[], Time, MetricsConfig) - Constructor for class io.sbk.logger.impl.SbkPrometheusServer: Construct the SBK Prometheus metrics server.
SbkRateController - Class in io.sbk.api.impl: Simple rate controller used by SBK to pace operations to a target records-per-second value.
SbkRateController() - Constructor for class io.sbk.api.impl.SbkRateController
SbkReader - Class in io.sbk.api.impl: Reader Benchmarking Implementation.
SbkReader(int, ParameterOptions, PerlChannel, DataType, Time, DataReader, CountReaders, ReadRequestsLogger, ExecutorService) - Constructor for class io.sbk.api.impl.SbkReader
SbkString - Class in io.sbk.data.impl: Class for processing byte[] data.
SbkString() - Constructor for class io.sbk.data.impl.SbkString
SbkUtils - Class in io.sbk.utils
SbkUtils() - Constructor for class io.sbk.utils.SbkUtils
SbkWriter - Class in io.sbk.api.impl: Writer Benchmarking Implementation.
SbkWriter(int, ParameterOptions, PerlChannel, DataType, Time, DataWriter, CountWriters, WriteRequestsLogger, ExecutorService) - Constructor for class io.sbk.api.impl.SbkWriter
SbkYalParameters - Class in io.sbk.params.impl
SbkYalParameters(String, String, YalConfig) - Constructor for class io.sbk.params.impl.SbkYalParameters: Create a YAML parameters handler.
SbmHostConfig - Class in io.sbk.logger: Configuration for the SBK Benchmark Manager (SBM) gRPC endpoint.
SbmHostConfig() - Constructor for class io.sbk.logger.SbmHostConfig
Sbp - Class in io.sbp.api
Sbp() - Constructor for class io.sbp.api.Sbp
SbpGrpc - Class in io.sbp.grpc
SbpVersion - Class in io.sbp.config
SbpVersion() - Constructor for class io.sbp.config.SbpVersion
sendLatenciesRecord() - Method in class io.sbk.logger.impl.GrpcLogger: Send the accumulated request/latency counters to SBM and reset local accumulators.
SEQUENCENUMBER_FIELD_NUMBER - Static variable in class io.sbp.grpc.MessageLatenciesRecord
SERVICE_NAME - Static variable in class io.sbp.grpc.ServiceGrpc
ServiceGrpc - Class in io.sbp.grpc
ServiceGrpc.AsyncService - Interface in io.sbp.grpc
ServiceGrpc.ServiceBlockingStub - Class in io.sbp.grpc: A stub to allow clients to do limited synchronous rpc calls to service Service.
ServiceGrpc.ServiceBlockingV2Stub - Class in io.sbp.grpc: A stub to allow clients to do synchronous rpc calls to service Service.
ServiceGrpc.ServiceFutureStub - Class in io.sbp.grpc: A stub to allow clients to do ListenableFuture-style rpc calls to service Service.
ServiceGrpc.ServiceImplBase - Class in io.sbp.grpc: Base class for the server implementation of the service Service.
ServiceGrpc.ServiceStub - Class in io.sbp.grpc: A stub to allow clients to do asynchronous rpc calls to service Service.
ServiceImplBase() - Constructor for class io.sbp.grpc.ServiceGrpc.ServiceImplBase
setAction(EnumAction) - Method in class io.sbp.grpc.Config.Builder: .EnumAction action = 2;
setActionValue(int) - Method in class io.sbp.grpc.Config.Builder: .EnumAction action = 2;
setClientID(long) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 clientID = 1;
setExceptionHandler(ExceptionHandler) - Method in class io.sbk.logger.impl.GrpcLogger
setExceptionHandler(ExceptionHandler) - Method in interface io.sbk.logger.Logger: Default implementation for setting exception handler.
setHigherLatencyDiscardRecords(long) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 higherLatencyDiscardRecords = 16;
setId(long) - Method in class io.sbp.grpc.ClientID.Builder: int64 id = 1;
setInvalidLatencyRecords(long) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 invalidLatencyRecords = 17;
setIsReadRequests(boolean) - Method in class io.sbp.grpc.Config.Builder: bool isReadRequests = 7;
setIsWriteRequests(boolean) - Method in class io.sbp.grpc.Config.Builder: bool isWriteRequests = 6;
setLowerLatencyDiscardRecords(long) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 lowerLatencyDiscardRecords = 15;
setMajor(int) - Method in class io.sbp.grpc.Version.Builder: int32 major = 1;
setMaxLatency(long) - Method in class io.sbp.grpc.Config.Builder: int64 maxLatency = 5;
setMaxLatency(long) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 maxLatency = 21;
setMaxReaders(int) - Method in class io.sbk.logger.impl.AbstractRWLogger
setMaxReaders(int) - Method in interface io.sbk.logger.SetRW: Update the max number of readers seen so far.
setMaxReaders(int) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int32 maxReaders = 6;
setMaxReadersIds(int) - Method in class io.sbk.logger.impl.AbstractRWLogger
setMaxWriters(int) - Method in class io.sbk.logger.impl.AbstractRWLogger
setMaxWriters(int) - Method in interface io.sbk.logger.SetRW: Update the max number of writers seen so far.
setMaxWriters(int) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int32 maxWriters = 5;
setMaxWritersIds(int) - Method in class io.sbk.logger.impl.AbstractRWLogger
setMinLatency(long) - Method in class io.sbp.grpc.Config.Builder: int64 minLatency = 4;
setMinLatency(long) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 minLatency = 20;
setMinor(int) - Method in class io.sbp.grpc.Version.Builder: int32 minor = 2;
setReaders(int) - Method in class io.sbk.logger.impl.AbstractRWLogger
setReaders(int) - Method in interface io.sbk.logger.SetRW: Set current number of active readers.
setReaders(int) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int32 readers = 4;
setReadRequestBytes(long) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 readRequestBytes = 9;
setReadRequestRecords(long) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 readRequestRecords = 10;
setReadTimeoutEvents(long) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 readTimeoutEvents = 12;
SetRW - Interface in io.sbk.logger: Interface SetRW.
setSequenceNumber(long) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 sequenceNumber = 2;
setStorageName(String) - Method in class io.sbp.grpc.Config.Builder: string storageName = 1;
setStorageNameBytes(ByteString) - Method in class io.sbp.grpc.Config.Builder: string storageName = 1;
setTime(byte[], long) - Method in class io.sbk.data.impl.ByteArray: Set the time for data.
setTime(ByteString, long) - Method in class io.sbk.data.impl.ProtoBufByteString: Set the time for data.
setTime(String, long) - Method in class io.sbk.data.impl.SbkString: Set the time for data.
setTime(ByteBuffer, long) - Method in class io.sbk.data.impl.NioByteBuffer: Set the time for data.
setTime(T, long) - Method in interface io.sbk.data.DataType: Set the time for data.
setTimeUnit(EnumTimeUnit) - Method in class io.sbp.grpc.Config.Builder: .EnumTimeUnit timeUnit = 3;
setTimeUnitValue(int) - Method in class io.sbp.grpc.Config.Builder: .EnumTimeUnit timeUnit = 3;
setTotalBytes(long) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 totalBytes = 18;
setTotalLatency(long) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 totalLatency = 19;
setTotalRecords(long) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 totalRecords = 13;
setValidLatencyRecords(long) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 validLatencyRecords = 14;
setWriteRequestBytes(long) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 writeRequestBytes = 7;
setWriteRequestRecords(long) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 writeRequestRecords = 8;
setWriters(int) - Method in class io.sbk.logger.impl.AbstractRWLogger
setWriters(int) - Method in interface io.sbk.logger.SetRW: Set current number of active writers.
setWriters(int) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int32 writers = 3;
setWriteTimeoutEvents(long) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder: int64 writeTimeoutEvents = 11;
Sl4jLogger - Class in io.sbk.logger.impl: Logger implementation that prints periodic and total benchmark results using SLF4J.
Sl4jLogger() - Constructor for class io.sbk.logger.impl.Sl4jLogger
start() - Method in interface io.sbk.api.Benchmark: Start the Benchmark.
start() - Method in class io.sbk.api.impl.SbkBenchmark: Start SBK Benchmark.
start() - Method in class io.sbk.api.impl.SbkCallbackReader: Deprecated.
start(int) - Method in class io.sbk.api.impl.SbkRateController: Start the Rate Controller.
start(int) - Method in interface io.sbk.api.RateController: Start the Rate Controller.
start(Callback) - Method in class io.sbk.api.AbstractCallbackReader: set the Callback and start the CallBack Reader.
startTime - Variable in class io.sbk.api.Status
Status - Class in io.sbk.api: Holder for per-operation read/write status used by the SBK harness.
Status() - Constructor for class io.sbk.api.Status
stop() - Method in class io.sbk.api.AbstractCallbackReader: Stop the CallBack Reader.
stop() - Method in interface io.sbk.api.Benchmark: stop/shutdown the Benchmark.
stop() - Method in class io.sbk.api.impl.SbkBenchmark: Stop/shutdown SBK Benchmark.
stop() - Method in class io.sbk.api.impl.SbkCallbackReader: Deprecated.
Storage<T> - Interface in io.sbk.api: Storage driver interface used by the SBK harness.
STORAGENAME_FIELD_NUMBER - Static variable in class io.sbp.grpc.Config
StoragePackage - Class in io.sbk.api: Concrete Package implementation for discovering Storage implementations on the classpath.
StoragePackage(String) - Constructor for class io.sbk.api.StoragePackage
sync() - Method in interface io.sbk.api.DataRecordsWriter: Flush / Sync the data.
sync() - Method in interface io.sbk.api.Writer: Flush / Sync the data.
SystemLogger - Class in io.sbk.logger.impl: Logger implementation that prints periodic and total benchmark results to System.out.
SystemLogger() - Constructor for class io.sbk.logger.impl.SystemLogger

T

ThreadType - Enum Class in io.sbk.thread: Thread types available in Java 25 for SBK benchmarking.
ThreadTypeParameter - Interface in io.sbk.params: Interface for parameters that provide thread type configuration.
TIME_HEADER_BYTES - Static variable in interface io.sbk.data.DataType: TIME_HEADER_BYTES = 8;.
timeUnit - Variable in class io.sbk.logger.LoggerConfig
TIMEUNIT_FIELD_NUMBER - Static variable in class io.sbp.grpc.Config
toBuilder() - Method in class io.sbp.grpc.ClientID
toBuilder() - Method in class io.sbp.grpc.Config
toBuilder() - Method in class io.sbp.grpc.MessageLatenciesRecord
toBuilder() - Method in class io.sbp.grpc.Version
TOTAL_PRINT - Static variable in class io.sbk.logger.impl.CSVLogger: TOTAL_PRINT = "Total".
TOTALBYTES_FIELD_NUMBER - Static variable in class io.sbp.grpc.MessageLatenciesRecord
TOTALLATENCY_FIELD_NUMBER - Static variable in class io.sbp.grpc.MessageLatenciesRecord
TOTALRECORDS_FIELD_NUMBER - Static variable in class io.sbp.grpc.MessageLatenciesRecord

U

UNRECOGNIZED - Enum constant in enum class io.sbp.grpc.EnumAction
UNRECOGNIZED - Enum constant in enum class io.sbp.grpc.EnumTimeUnit

V

VALIDLATENCYRECORDS_FIELD_NUMBER - Static variable in class io.sbp.grpc.MessageLatenciesRecord
valueOf(int) - Static method in enum class io.sbp.grpc.EnumAction: Deprecated.
valueOf(int) - Static method in enum class io.sbp.grpc.EnumTimeUnit: Deprecated.
valueOf(Descriptors.EnumValueDescriptor) - Static method in enum class io.sbp.grpc.EnumAction: Returns the enum constant of this class with the specified name.
valueOf(Descriptors.EnumValueDescriptor) - Static method in enum class io.sbp.grpc.EnumTimeUnit: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.sbk.action.Action: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.sbk.thread.ThreadType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.sbp.grpc.EnumAction: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.sbp.grpc.EnumTimeUnit: Returns the enum constant of this class with the specified name.
values() - Static method in enum class io.sbk.action.Action: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.sbk.thread.ThreadType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.sbp.grpc.EnumAction: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.sbp.grpc.EnumTimeUnit: Returns an array containing the constants of this enum class, in the order they are declared.
Version - Class in io.sbp.grpc: Protobuf type Version
Version.Builder - Class in io.sbp.grpc: Protobuf type Version
VersionOrBuilder - Interface in io.sbp.grpc
Virtual - Enum constant in enum class io.sbk.thread.ThreadType: Virtual threads - Lightweight threads for I/O-bound operations.

W

waitToComplete() - Method in class io.sbk.api.AbstractCallbackReader: Default Implementation to wait for the readers to complete.
Worker - Class in io.sbk.api: Abstract class for Writers and Readers.
Worker(int, Parameters, PerlChannel) - Constructor for class io.sbk.api.Worker
write(DataType, T, int, Time, Status) - Method in interface io.sbk.api.DataRecordsWriter: Write the Data and attach the start time to data.
write(DataType, T, int, Time, Status) - Method in interface io.sbk.api.Writer: Default implementation for writing data using Writer.writeAsync(Object))} with start time.
write(DataType, T, int, Time, Status, int, WriteRequestsLogger) - Method in interface io.sbk.api.DataRecordsWriter: Write the Data and attach the start time to data.
write(DataType, T, int, Time, Status, int, WriteRequestsLogger) - Method in interface io.sbk.api.Writer: Default implementation for writing data using Writer.writeAsync(Object))} with start time.
Write_OnlyReading - Enum constant in enum class io.sbk.action.Action: Write_OnlyReading = 3.
Write_OnlyReading - Enum constant in enum class io.sbp.grpc.EnumAction: Write_OnlyReading = 3;
Write_OnlyReading_VALUE - Static variable in enum class io.sbp.grpc.EnumAction: Write_OnlyReading = 3;
Write_Reading - Enum constant in enum class io.sbk.action.Action: Write_Reading = 2.
Write_Reading - Enum constant in enum class io.sbp.grpc.EnumAction: Write_Reading = 2;
Write_Reading_VALUE - Static variable in enum class io.sbp.grpc.EnumAction: Write_Reading = 2;
writeAsync(T) - Method in interface io.sbk.api.Writer: Asynchronously Writes the data .
Writer<T> - Interface in io.sbk.api: Writer interface used by SBK drivers to provide asynchronous write semantics.
WRITEREQUESTBYTES_FIELD_NUMBER - Static variable in class io.sbp.grpc.MessageLatenciesRecord
WRITEREQUESTRECORDS_FIELD_NUMBER - Static variable in class io.sbp.grpc.MessageLatenciesRecord
WriteRequestsLogger - Interface in io.sbk.logger: Write-side request logging hooks used by SBK loggers.
WRITERS_FIELD_NUMBER - Static variable in class io.sbp.grpc.MessageLatenciesRecord
writeSetTime(DataType, T, int, Time, Status) - Method in interface io.sbk.api.DataRecordsWriter: Write the Data and attach the start time to data.
writeSetTime(DataType, T, int, Time, Status) - Method in interface io.sbk.api.Writer: Default implementation for writing data using Writer.writeAsync(Object) with start time If you are intend to NOT use the CompletableFuture returned by Writer.writeAsync(Object) )} then you can override this method.
writeSetTime(DataType, T, int, Time, Status, int, WriteRequestsLogger) - Method in interface io.sbk.api.DataRecordsWriter: Write the Data and attach the start time to data.
writeSetTime(DataType, T, int, Time, Status, int, WriteRequestsLogger) - Method in interface io.sbk.api.Writer: Default implementation for writing data using Writer.writeAsync(Object) with start time If you are intend to NOT use the CompletableFuture returned by Writer.writeAsync(Object) )} then you can override this method.
WRITETIMEOUTEVENTS_FIELD_NUMBER - Static variable in class io.sbp.grpc.MessageLatenciesRecord
writeTo(CodedOutputStream) - Method in class io.sbp.grpc.ClientID
writeTo(CodedOutputStream) - Method in class io.sbp.grpc.Config
writeTo(CodedOutputStream) - Method in class io.sbp.grpc.MessageLatenciesRecord
writeTo(CodedOutputStream) - Method in class io.sbp.grpc.Version
writeToCSV(String, String, long, long, int, int, int, int, long, double, long, double, long, double, long, double, long, long, long, long, long, long, long, double, long, double, double, long, long, double, double, double, long, long, long, long, long, long, long, long[], long[]) - Method in class io.sbk.logger.impl.CSVLogger: Write a single record (row) to the CSV file.
Writing - Enum constant in enum class io.sbk.action.Action: Writing = 0.
Writing - Enum constant in enum class io.sbp.grpc.EnumAction: Writing = 0;
Writing_VALUE - Static variable in enum class io.sbp.grpc.EnumAction: Writing = 0;

Y

YalConfig - Class in io.sbk.config: Class YalConfig.
YalConfig() - Constructor for class io.sbk.config.YalConfig
YalParameters - Interface in io.sbk.params: Parameters contract for YAML-based configuration (YAL) support.
yamlFileName - Variable in class io.sbk.config.YalConfig: String yamlFileName.
YmlMap - Class in io.sbk.params: Helper base class for mapping YAML files to CLI argument arrays.
YmlMap(Map) - Constructor for class io.sbk.params.YmlMap: Create a YmlMap with the provided arguments map.

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