Index

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 class for Callback Reader.

AbstractCallbackReader() - Constructor for class io.sbk.api.AbstractCallbackReader

AbstractRWLogger - Class in io.sbk.logger.impl

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

Interface ActionParameter.

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

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.ServiceFutureStub

addLatenciesRecord(MessageLatenciesRecord, StreamObserver<Empty>) - Method in interface io.sbp.grpc.ServiceGrpc.AsyncService

addLatenciesRecord(MessageLatenciesRecord, StreamObserver<Empty>) - 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.

addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.sbp.grpc.ClientID.Builder

addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.sbp.grpc.Config.Builder

addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder

addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.sbp.grpc.Version.Builder

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[]) - 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

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

Interface BiConsumer.

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.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

Interface Callback.

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;

clearField(Descriptors.FieldDescriptor) - Method in class io.sbp.grpc.ClientID.Builder

clearField(Descriptors.FieldDescriptor) - Method in class io.sbp.grpc.Config.Builder

clearField(Descriptors.FieldDescriptor) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder

clearField(Descriptors.FieldDescriptor) - Method in class io.sbp.grpc.Version.Builder

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;

clearOneof(Descriptors.OneofDescriptor) - Method in class io.sbp.grpc.ClientID.Builder

clearOneof(Descriptors.OneofDescriptor) - Method in class io.sbp.grpc.Config.Builder

clearOneof(Descriptors.OneofDescriptor) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder

clearOneof(Descriptors.OneofDescriptor) - Method in class io.sbp.grpc.Version.Builder

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

clone() - Method in class io.sbp.grpc.ClientID.Builder

clone() - Method in class io.sbp.grpc.Config.Builder

clone() - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder

clone() - Method in class io.sbp.grpc.Version.Builder

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(ParsedOptions) - Method in class io.sbk.logger.impl.PrometheusLogger

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.ServiceFutureStub

closeClient(ClientID, StreamObserver<Empty>) - Method in interface io.sbp.grpc.ServiceGrpc.AsyncService

closeClient(ClientID, StreamObserver<Empty>) - 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

Sealed interface CountReaders which permits CountRW.

CountRW - Interface in io.sbk.logger

non-sealed interface CountRW which extends CountReaders and CountWriters.

CountWriters - Interface in io.sbk.logger

sealed interface CountWriters which permits CountRW.

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

Interface for Basic Data Readers.

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

Interface for Data Records Writers.

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

Decrement Readers.

decrementReaders() - Method in class io.sbk.logger.impl.AbstractRWLogger

decrementWriters() - Method in interface io.sbk.logger.CountWriters

Decrement 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;.

FORK - Static variable in class io.sbk.config.Config

FORK = true;.

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<T>, Time, DataRecordsReader.RecordTime<T>) - Method in interface io.sbk.api.DataRecordsReader

Benchmarking reader by reading given number of records.

genericRecordsReader(Worker, long, DataType<T>, Time, DataRecordsReader.RecordTimeRequests<T>, ReadRequestsLogger) - Method in interface io.sbk.api.DataRecordsReader

Benchmarking reader by reading given number of records.

genericRecordsReaderRateControl(Worker, long, DataType<T>, Time, RateController, DataRecordsReader.RecordTime<T>) - Method in interface io.sbk.api.DataRecordsReader

Benchmarking reader with Rate controlled.

genericRecordsReaderRateControl(Worker, long, DataType<T>, Time, RateController, DataRecordsReader.RecordTimeRequests<T>, ReadRequestsLogger) - Method in interface io.sbk.api.DataRecordsReader

Benchmarking reader with Rate controlled.

genericRecordsTimeReader(Worker, long, DataType<T>, Time, DataRecordsReader.RecordTime<T>) - Method in interface io.sbk.api.DataRecordsReader

Benchmarking reader by reading events/records for specific time duration.

genericRecordsTimeReader(Worker, long, DataType<T>, Time, DataRecordsReader.RecordTimeRequests<T>, ReadRequestsLogger) - Method in interface io.sbk.api.DataRecordsReader

Benchmarking reader by reading events/records for specific time duration.

genericRecordsTimeReaderRateControl(Worker, long, DataType<T>, Time, RateController, DataRecordsReader.RecordTime<T>) - Method in interface io.sbk.api.DataRecordsReader

Benchmarking reader by reading events/records with Rate Controls.

genericRecordsTimeReaderRateControl(Worker, long, DataType<T>, Time, RateController, DataRecordsReader.RecordTimeRequests<T>, 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 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.ServiceFutureStub

getConfig(Empty, StreamObserver<Config>) - Method in interface io.sbp.grpc.ServiceGrpc.AsyncService

getConfig(Empty, StreamObserver<Config>) - 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.Config.Builder

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.Version.Builder

getFileName() - Method in class io.sbk.params.impl.SbkYalParameters

getFileName() - Method in interface io.sbk.params.YalParameters

getFileOptionDescription() - Method in class io.sbk.params.impl.SbkYalParameters

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

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

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

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

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;

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.ServiceFutureStub

getVersion(Empty, StreamObserver<Version>) - Method in interface io.sbp.grpc.ServiceGrpc.AsyncService

getVersion(Empty, StreamObserver<Version>) - 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<? extends YmlMap>) - Static method in class io.sbk.params.YmlMap

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

calls its super class PrometheusLogger.

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 in io.sbk.exception

class HelpException.

HelpException(String) - Constructor for exception 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

Increment Readers.

incrementReaders() - Method in class io.sbk.logger.impl.AbstractRWLogger

incrementWriters() - Method in interface io.sbk.logger.CountWriters

Increment Writers.

incrementWriters() - Method in class io.sbk.logger.impl.AbstractRWLogger

initialize(Worker, long, long, DataType<T>, Time, Callback<T>) - Method in class io.sbk.api.AbstractCallbackReader

Default Implementation to initialize the callback reader.

InputOptions - Interface in io.sbk.params

InputParameterOptions - Interface in io.sbk.params

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.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.ServiceFutureStub

isVersionSupported(Version, StreamObserver<BoolValue>) - Method in interface io.sbp.grpc.ServiceGrpc.AsyncService

isVersionSupported(Version, StreamObserver<BoolValue>) - 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

Interface for recoding/printing results.

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

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<String, String>, 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

mergeUnknownFields(UnknownFieldSet) - Method in class io.sbp.grpc.ClientID.Builder

mergeUnknownFields(UnknownFieldSet) - Method in class io.sbp.grpc.Config.Builder

mergeUnknownFields(UnknownFieldSet) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder

mergeUnknownFields(UnknownFieldSet) - 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

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

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(GeneratedMessageV3.BuilderParent) - Method in class io.sbp.grpc.ClientID

newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class io.sbp.grpc.Config

newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class io.sbp.grpc.MessageLatenciesRecord

newBuilderForType(GeneratedMessageV3.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

newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class io.sbp.grpc.ClientID

newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class io.sbp.grpc.Config

newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class io.sbp.grpc.MessageLatenciesRecord

newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class io.sbp.grpc.Version

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(ParsedOptions, String, Action, Time) - Method in class io.sbk.logger.impl.PrometheusLogger

open(ParsedOptions, String, Action, Time) - Method in interface io.sbk.logger.Logger

Open the Logger.

openCSV() - Method in class io.sbk.logger.impl.CSVLogger

final public method to Open CSV.

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

Package(String) - Constructor for class io.sbk.api.Package

ParameterOptions - Interface in io.sbk.params

class for Command Line Parameters.

Parameters - Interface in io.sbk.params

Interface 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

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

parseArgs(String[]) - Method in class io.sbk.params.impl.SbkParameters

parseArgs(String[]) - Method in class io.sbk.params.impl.SbkYalParameters

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

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

Interface InputOptions.

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

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[]) - 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[]) - 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[]) - 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[]) - 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[]) - 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[]) - Method in class io.sbk.logger.impl.SbkPrometheusServer

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[]) - Method in class io.sbk.logger.impl.Sl4jLogger

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[]) - Method in class io.sbk.logger.impl.SystemLogger

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[]) - 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[]) - 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[]) - 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[]) - 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[]) - Method in class io.sbk.logger.impl.Sl4jLogger

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[]) - Method in class io.sbk.logger.impl.SystemLogger

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[]) - Method in interface io.sbk.logger.RWLogger

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<Long, Long>) - 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

Interface for Readers.

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

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 every latency.

recordLatency(long, int, int, long) - Method in interface io.sbk.logger.RWLogger

Default method to record latency of every/multiple event(s).

recordRead(DataType<T>, 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<T>, int, Time, Status, PerlChannel) - Method in interface io.sbk.api.DataRecordsReader

Record the single or multiple reads performance statistics.

recordRead(DataType<T>, int, Time, Status, PerlChannel) - Method in interface io.sbk.api.DataRecordsReader.RecordTime

Method to Read records.

recordRead(DataType<T>, 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<T>, 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<T>, int, Time, Status, PerlChannel, int, ReadRequestsLogger) - Method in interface io.sbk.api.DataRecordsReader

Record the single or multiple reads performance statistics.

recordRead(DataType<T>, int, Time, Status, PerlChannel, int, ReadRequestsLogger) - Method in interface io.sbk.api.DataRecordsReader.RecordTimeRequests

Method to Read records.

recordRead(DataType<T>, 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

recordReadRequests(int, long, long, long) - Method in interface io.sbk.logger.ReadRequestsLogger

recordReadRequests(int, long, long, long) - Method in interface io.sbk.logger.RWLogger

Default method to record every/multiple read event(s).

recordReadTime(DataType<T>, 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<T>, 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<T>, 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<T>, 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<T>, 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<T>, 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

recordReadTimeoutEvents(int, long, long) - Method in interface io.sbk.logger.ReadRequestsLogger

records - Variable in class io.sbk.api.Status

RecordsReader(Worker, long, DataType<T>, Time) - Method in class io.sbk.api.AbstractCallbackReader

Implementation for benchmarking reader by reading given number of records.

RecordsReader(Worker, long, DataType<T>, Time) - Method in interface io.sbk.api.DataReader

Benchmarking reader by reading given number of records.

RecordsReader(Worker, long, DataType<T>, Time) - Method in interface io.sbk.api.DataRecordsReader

Default implementation for benchmarking reader by reading given number of records.

RecordsReader(Worker, long, DataType<T>, Time, ReadRequestsLogger) - Method in class io.sbk.api.AbstractCallbackReader

Implementation for benchmarking reader by reading given number of records.

RecordsReader(Worker, long, DataType<T>, Time, ReadRequestsLogger) - Method in interface io.sbk.api.DataReader

Benchmarking reader by reading given number of records.

RecordsReader(Worker, long, DataType<T>, Time, ReadRequestsLogger) - Method in interface io.sbk.api.DataRecordsReader

Default implementation for benchmarking reader by reading given number of records.

RecordsReaderRateControl(Worker, long, DataType<T>, Time, RateController) - Method in class io.sbk.api.AbstractCallbackReader

Benchmarking reader by reading given number of records with Rate controlled.

RecordsReaderRateControl(Worker, long, DataType<T>, Time, RateController) - Method in interface io.sbk.api.DataReader

Benchmarking reader by reading given number of records with Rate controlled.

RecordsReaderRateControl(Worker, long, DataType<T>, Time, RateController) - Method in interface io.sbk.api.DataRecordsReader

Benchmarking reader by reading given number of records with Rate controlled.

RecordsReaderRateControl(Worker, long, DataType<T>, 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<T>, 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<T>, 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<T>, Time) - Method in class io.sbk.api.AbstractCallbackReader

Default implementation for benchmarking reader by reading given number of records.

RecordsReaderRW(Worker, long, DataType<T>, Time) - Method in interface io.sbk.api.DataReader

Benchmarking reader by reading given number of records.

RecordsReaderRW(Worker, long, DataType<T>, Time) - Method in interface io.sbk.api.DataRecordsReader

Default implementation for benchmarking reader by reading given number of records.

RecordsReaderRW(Worker, long, DataType<T>, Time, ReadRequestsLogger) - Method in class io.sbk.api.AbstractCallbackReader

Default implementation for benchmarking reader by reading given number of records.

RecordsReaderRW(Worker, long, DataType<T>, Time, ReadRequestsLogger) - Method in interface io.sbk.api.DataReader

Benchmarking reader by reading given number of records.

RecordsReaderRW(Worker, long, DataType<T>, Time, ReadRequestsLogger) - Method in interface io.sbk.api.DataRecordsReader

Default implementation for benchmarking reader by reading given number of records.

RecordsReaderRWRateControl(Worker, long, DataType<T>, Time, RateController) - Method in class io.sbk.api.AbstractCallbackReader

Benchmarking reader by reading given number of records with Rate controlled.

RecordsReaderRWRateControl(Worker, long, DataType<T>, Time, RateController) - Method in interface io.sbk.api.DataReader

Benchmarking reader by reading given number of records with Rate controlled.

RecordsReaderRWRateControl(Worker, long, DataType<T>, Time, RateController) - Method in interface io.sbk.api.DataRecordsReader

Benchmarking reader by reading given number of records with Rate controlled.

RecordsReaderRWRateControl(Worker, long, DataType<T>, 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<T>, 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<T>, 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<T>, 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<T>, Time) - Method in interface io.sbk.api.DataReader

Benchmarking reader by reading events/records for specific time duration.

RecordsTimeReader(Worker, long, DataType<T>, 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<T>, 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<T>, Time, ReadRequestsLogger) - Method in interface io.sbk.api.DataReader

Benchmarking reader by reading events/records for specific time duration.

RecordsTimeReader(Worker, long, DataType<T>, 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<T>, 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<T>, 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<T>, 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<T>, 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<T>, 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<T>, 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<T>, 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<T>, Time) - Method in interface io.sbk.api.DataReader

Benchmarking reader by reading events/records for specific time duration.

RecordsTimeReaderRW(Worker, long, DataType<T>, 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<T>, 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<T>, Time, ReadRequestsLogger) - Method in interface io.sbk.api.DataReader

Benchmarking reader by reading events/records for specific time duration.

RecordsTimeReaderRW(Worker, long, DataType<T>, 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<T>, 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<T>, 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<T>, 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<T>, 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<T>, 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<T>, 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>, 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>, T, int, Time) - Method in interface io.sbk.api.DataWriter

writer benchmarking by writing given number of records.

RecordsWriter(Worker, long, DataType<T>, 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>, T, int, Time, WriteRequestsLogger) - Method in interface io.sbk.api.DataWriter

writer benchmarking by writing given number of records.

RecordsWriterRO(Worker, long, DataType<T>, T, int, Time, RateController) - Method in interface io.sbk.api.DataRecordsWriter

Default implementation for writing given number of records.

RecordsWriterRO(Worker, long, DataType<T>, T, int, Time, RateController) - Method in interface io.sbk.api.DataWriter

Write given number of records.

RecordsWriterRO(Worker, long, DataType<T>, 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>, T, int, Time, RateController, WriteRequestsLogger) - Method in interface io.sbk.api.DataWriter

Write given number of records.

RecordsWriterRW(Worker, long, DataType<T>, T, int, Time, RateController) - Method in interface io.sbk.api.DataRecordsWriter

Default implementation for writing given number of records.

RecordsWriterRW(Worker, long, DataType<T>, T, int, Time, RateController) - Method in interface io.sbk.api.DataWriter

Write given number of records.

RecordsWriterRW(Worker, long, DataType<T>, 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>, T, int, Time, RateController, WriteRequestsLogger) - Method in interface io.sbk.api.DataWriter

Write given number of records.

RecordsWriterSync(Worker, long, DataType<T>, 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>, 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>, 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>, 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>, 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>, 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>, 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>, 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>, 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>, T, int, Time, RateController) - Method in interface io.sbk.api.DataWriter

Writing data records for specific time duration.

RecordsWriterTimeRO(Worker, long, DataType<T>, 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>, T, int, Time, RateController, WriteRequestsLogger) - Method in interface io.sbk.api.DataWriter

Writing data records for specific time duration.

RecordsWriterTimeRW(Worker, long, DataType<T>, 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>, T, int, Time, RateController) - Method in interface io.sbk.api.DataWriter

Writing data records for specific time duration.

RecordsWriterTimeRW(Worker, long, DataType<T>, 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>, T, int, Time, RateController, WriteRequestsLogger) - Method in interface io.sbk.api.DataWriter

Writing data records for specific time duration.

RecordsWriterTimeSync(Worker, long, DataType<T>, 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>, 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>, 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>, 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>, T, int, Time, Status, PerlChannel) - Method in interface io.sbk.api.DataRecordsWriter

Write the data and record the benchmark statistics.

recordWrite(DataType<T>, 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>, 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>, 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

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

recordWriteTimeoutEvents(int, long, long) - Method in class io.sbk.logger.impl.AbstractRWLogger

recordWriteTimeoutEvents(int, long, long) - Method in class io.sbk.logger.impl.GrpcLogger

recordWriteTimeoutEvents(int, long, long) - Method in interface io.sbk.logger.WriteRequestsLogger

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.ServiceFutureStub

registerClient(Config, StreamObserver<ClientID>) - Method in interface io.sbp.grpc.ServiceGrpc.AsyncService

registerClient(Config, StreamObserver<ClientID>) - 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<T>, Time, Callback<T>) - 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

Interface for recoding/printing results.

RWLoggerPackage - Class in io.sbk.api

RWLoggerPackage(String) - Constructor for class io.sbk.api.RWLoggerPackage

rwMetricPrefix - Variable in class io.sbk.logger.impl.SbkPrometheusServer

RWPrint - Interface in io.sbk.logger

S

Sbk - Class in io.sbk.api.impl

Main class of SBK.

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<Object>, DataType<Object>, 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<Object>, Time) - Constructor for class io.sbk.api.impl.SbkCallbackReader

Deprecated.

SbkDriversParameters - Class in io.sbk.params.impl

SbkDriversParameters(String, String[], String[]) - Constructor for class io.sbk.params.impl.SbkDriversParameters

SbkDriversParameters(String, String, String[], String[]) - Constructor for class io.sbk.params.impl.SbkDriversParameters

SbkInputOptions - Class in io.sbk.params.impl

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

Class for processing command Line arguments/parameters.

SbkParameters(String) - Constructor for class io.sbk.params.impl.SbkParameters

SbkParameters(String, String) - Constructor for class io.sbk.params.impl.SbkParameters

SbkPrometheusServer - Class in io.sbk.logger.impl

SbkPrometheusServer(String, String, String, double[], Time, MetricsConfig) - Constructor for class io.sbk.logger.impl.SbkPrometheusServer

SbkRateController - Class in io.sbk.api.impl

SbkRateController() - Constructor for class io.sbk.api.impl.SbkRateController

SbkReader - Class in io.sbk.api.impl

Reader Benchmarking Implementation.

SbkReader(int, ParameterOptions, PerlChannel, DataType<Object>, Time, DataReader<Object>, 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<Object>, Time, DataWriter<Object>, 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

SbmHostConfig - Class in io.sbk.logger

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

Sends Latencies Records.

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 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.

setField(Descriptors.FieldDescriptor, Object) - Method in class io.sbp.grpc.ClientID.Builder

setField(Descriptors.FieldDescriptor, Object) - Method in class io.sbp.grpc.Config.Builder

setField(Descriptors.FieldDescriptor, Object) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder

setField(Descriptors.FieldDescriptor, Object) - Method in class io.sbp.grpc.Version.Builder

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

Set Max Readers.

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

Set Max Writers.

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 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;

setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class io.sbp.grpc.ClientID.Builder

setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class io.sbp.grpc.Config.Builder

setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder

setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class io.sbp.grpc.Version.Builder

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;

setUnknownFields(UnknownFieldSet) - Method in class io.sbp.grpc.ClientID.Builder

setUnknownFields(UnknownFieldSet) - Method in class io.sbp.grpc.Config.Builder

setUnknownFields(UnknownFieldSet) - Method in class io.sbp.grpc.MessageLatenciesRecord.Builder

setUnknownFields(UnknownFieldSet) - Method in class io.sbp.grpc.Version.Builder

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 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

Class for recoding/printing results on Sl4j.

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<T>) - 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

class for Read and Write status.

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

Interface for Benchmarking.

STORAGENAME_FIELD_NUMBER - Static variable in class io.sbp.grpc.Config

StoragePackage - Class in io.sbk.api

class StoragePackage.

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

Class for recoding/printing results on System.out.

SystemLogger() - Constructor for class io.sbk.logger.impl.SystemLogger

T

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.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.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

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>, T, int, Time, Status) - Method in interface io.sbk.api.DataRecordsWriter

Write the Data and attach the start time to data.

write(DataType<T>, 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>, 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>, 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

Interface for Writers.

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

WRITERS_FIELD_NUMBER - Static variable in class io.sbp.grpc.MessageLatenciesRecord

writeSetTime(DataType<T>, T, int, Time, Status) - Method in interface io.sbk.api.DataRecordsWriter

Write the Data and attach the start time to data.

writeSetTime(DataType<T>, 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>, 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>, 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[]) - Method in class io.sbk.logger.impl.CSVLogger

final public method to write CSV.

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

yamlFileName - Variable in class io.sbk.config.YalConfig

String yamlFileName.

YmlMap - Class in io.sbk.params

YmlMap(Map<String, String>) - Constructor for class io.sbk.params.YmlMap

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