C D E G H K N O P R S T V
All Classes All Packages

C

callback(Callback) - Method in class ru.tinkoff.qa.neptune.kafka.functions.send.KafkaSendRecordsActionSupplier

consumedArray(String, Deserializer<K>, Deserializer<V>, TypeReference<R>, Function<ConsumerRecord<K, V>, R>) - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollArraySupplier

Creates a step that returns array of values which are calculated by data of read messages.

consumedArray(String, Deserializer<K>, Deserializer<V>, Class<R>, Function<ConsumerRecord<K, V>, R>) - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollArraySupplier

Creates a step that returns array of values which are calculated by data of read messages.

consumedArrayKeyData(String, Deserializer<K>, TypeReference<R>, Function<K, R>) - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollArraySupplier

Creates a step that returns array of values which are calculated by key data of read messages.

consumedArrayKeyData(String, Deserializer<K>, Class<R>, Function<K, R>) - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollArraySupplier

Creates a step that returns array of values which are calculated by key data of read messages.

consumedArrayKeys() - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollArraySupplier

Creates a step that returns array of string keys

consumedArrayKeys(TypeReference<K>, Deserializer<K>) - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollArraySupplier

Creates a step that returns array of message keys.

consumedArrayKeys(Class<K>, Deserializer<K>) - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollArraySupplier

Creates a step that returns array of message keys.

consumedArrayValueData(String, Deserializer<V>, TypeReference<R>, Function<V, R>) - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollArraySupplier

Creates a step that returns array of values which are calculated by value data of read messages.

consumedArrayValueData(String, Deserializer<V>, Class<R>, Function<V, R>) - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollArraySupplier

Creates a step that returns array of values which are calculated by value data of read messages.

consumedArrayValues() - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollArraySupplier

Creates a step that returns array of string values

consumedArrayValues(TypeReference<V>, Deserializer<V>) - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollArraySupplier

Creates a step that returns array of message values.

consumedArrayValues(Class<V>, Deserializer<V>) - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollArraySupplier

Creates a step that returns array of message values.

consumedItem(String, Deserializer<K>, Deserializer<V>, Function<ConsumerRecord<K, V>, R>) - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollIterableItemSupplier

Creates a step that returns an item from list of values which are calculated by data of read messages.

consumedItemKeyData(String, Deserializer<K>, Function<K, R>) - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollIterableItemSupplier

Creates a step that returns an item from list of values which are calculated by key data of read messages.

consumedItemValueData(String, Deserializer<V>, Function<V, R>) - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollIterableItemSupplier

Creates a step that returns an item from list of values which are calculated by value data of read messages.

consumedKey() - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollIterableItemSupplier

Creates a step that returns a message key as text.

consumedKey(Deserializer<K>) - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollIterableItemSupplier

Creates a step that returns a message key.

consumedKeys() - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollIterableSupplier

Creates a step that returns list of string keys.

consumedKeys(Deserializer<K>) - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollIterableSupplier

Creates a step that returns list of message keys.

consumedList(String, Deserializer<K>, Deserializer<V>, Function<ConsumerRecord<K, V>, R>) - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollIterableSupplier

Creates a step that returns list of values which are calculated by data of read messages.

consumedListKeyData(String, Deserializer<K>, Function<K, R>) - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollIterableSupplier

Creates a step that returns list of values which are calculated by key data of read messages.

consumedListValueData(String, Deserializer<V>, Function<V, R>) - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollIterableSupplier

Creates a step that returns list of values which are calculated by value data of read messages.

consumedValue() - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollIterableItemSupplier

Creates a step that returns a message value as text.

consumedValue(Deserializer<V>) - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollIterableItemSupplier

Creates a step that returns a message value.

consumedValues() - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollIterableSupplier

Creates a step that returns list of message string values.

consumedValues(Deserializer<V>) - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollIterableSupplier

Creates a step that returns list of message values.

consumerRecords() - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.GetRecordSupplier

consumerRecords(Deserializer<K>, Deserializer<V>) - Static method in class ru.tinkoff.qa.neptune.kafka.functions.poll.GetRecordSupplier

ConsumerRecordSerializer - Class in ru.tinkoff.qa.neptune.kafka.jackson.desrializer

ConsumerRecordSerializer() - Constructor for class ru.tinkoff.qa.neptune.kafka.jackson.desrializer.ConsumerRecordSerializer

createConsumer(Deserializer<K>, Deserializer<V>, Map<String, String>) - Method in class ru.tinkoff.qa.neptune.kafka.KafkaStepContext

createProducer(Serializer<K>, Serializer<V>, Map<String, String>) - Method in class ru.tinkoff.qa.neptune.kafka.KafkaStepContext

D

DEFAULT_TOPIC_FOR_SEND - Static variable in class ru.tinkoff.qa.neptune.kafka.properties.KafkaDefaultTopicForSendProperty

DEFAULT_TOPICS_FOR_POLL - Static variable in class ru.tinkoff.qa.neptune.kafka.properties.KafkaDefaultTopicsForPollProperty

DefaultKafkaProperties - Enum in ru.tinkoff.qa.neptune.kafka.properties

E

excludeWithNullKeys() - Method in class ru.tinkoff.qa.neptune.kafka.functions.poll.GetRecordSupplier

Says to exclude records with null keys (keys of records are empty or not properly deserialized) from the result.

excludeWithNullValues() - Method in class ru.tinkoff.qa.neptune.kafka.functions.poll.GetRecordSupplier

Says to exclude records with null values (values of records are empty or not properly deserialized) from the result.

G

get() - Method in class ru.tinkoff.qa.neptune.kafka.functions.poll.GetRecordSupplier

get() - Method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollArraySupplier

get() - Method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollIterableItemSupplier

get() - Method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollIterableSupplier

getCaptured(Object) - Method in class ru.tinkoff.qa.neptune.kafka.captors.KafkaConsumerRecordsCaptor

getCaptured(Object) - Method in class ru.tinkoff.qa.neptune.kafka.captors.ReceivedArrayCaptor

getCaptured(Object) - Method in class ru.tinkoff.qa.neptune.kafka.captors.ReceivedListCaptor

getData(Object) - Method in class ru.tinkoff.qa.neptune.kafka.captors.ReceivedArrayCaptor

getData(Object) - Method in class ru.tinkoff.qa.neptune.kafka.captors.ReceivedListCaptor

getData(List<? extends ConsumerRecord<?, ?>>) - Method in class ru.tinkoff.qa.neptune.kafka.captors.KafkaConsumerRecordsCaptor

getParameters() - Method in class ru.tinkoff.qa.neptune.kafka.functions.send.KafkaSendRecordsActionSupplier

GetRecordSupplier<K,V> - Class in ru.tinkoff.qa.neptune.kafka.functions.poll

H

header(String, byte[]) - Method in class ru.tinkoff.qa.neptune.kafka.functions.send.KafkaSendRecordsActionSupplier

header(String, String) - Method in class ru.tinkoff.qa.neptune.kafka.functions.send.KafkaSendRecordsActionSupplier

header(Header) - Method in class ru.tinkoff.qa.neptune.kafka.functions.send.KafkaSendRecordsActionSupplier

HeaderJsonSerializer - Class in ru.tinkoff.qa.neptune.kafka.jackson.desrializer

HeaderJsonSerializer() - Constructor for class ru.tinkoff.qa.neptune.kafka.jackson.desrializer.HeaderJsonSerializer

howToPerform(KafkaProducer<K, V>) - Method in class ru.tinkoff.qa.neptune.kafka.functions.send.KafkaSendRecordsActionSupplier

K

kafka() - Static method in class ru.tinkoff.qa.neptune.kafka.KafkaStepContext

KAFKA_CALLBACK - Static variable in class ru.tinkoff.qa.neptune.kafka.properties.KafkaCallbackProperty

KAFKA_CONSUMER_PROPERTIES - ru.tinkoff.qa.neptune.kafka.properties.DefaultKafkaProperties

KAFKA_PRODUCER_PROPERTIES - ru.tinkoff.qa.neptune.kafka.properties.DefaultKafkaProperties

KafkaCallbackProperty - Class in ru.tinkoff.qa.neptune.kafka.properties

KafkaConsumerRecordsCaptor - Class in ru.tinkoff.qa.neptune.kafka.captors

KafkaConsumerRecordsCaptor() - Constructor for class ru.tinkoff.qa.neptune.kafka.captors.KafkaConsumerRecordsCaptor

KafkaDefaultTopicForSendProperty - Class in ru.tinkoff.qa.neptune.kafka.properties

KafkaDefaultTopicForSendProperty() - Constructor for class ru.tinkoff.qa.neptune.kafka.properties.KafkaDefaultTopicForSendProperty

KafkaDefaultTopicsForPollProperty - Class in ru.tinkoff.qa.neptune.kafka.properties

KafkaDefaultTopicsForPollProperty() - Constructor for class ru.tinkoff.qa.neptune.kafka.properties.KafkaDefaultTopicsForPollProperty

KafkaJacksonModule - Class in ru.tinkoff.qa.neptune.kafka.jackson.desrializer

KafkaJacksonModule() - Constructor for class ru.tinkoff.qa.neptune.kafka.jackson.desrializer.KafkaJacksonModule

KafkaLocalizationPartition - Class in ru.tinkoff.qa.neptune.kafka.localization

KafkaLocalizationPartition() - Constructor for class ru.tinkoff.qa.neptune.kafka.localization.KafkaLocalizationPartition

KafkaObjectResultCaptor - Class in ru.tinkoff.qa.neptune.kafka.captors

KafkaObjectResultCaptor() - Constructor for class ru.tinkoff.qa.neptune.kafka.captors.KafkaObjectResultCaptor

KafkaPollArraySupplier<K,V,R> - Class in ru.tinkoff.qa.neptune.kafka.functions.poll

KafkaPollItemFromRecordSupplier<K,V,R> - Class in ru.tinkoff.qa.neptune.kafka.functions.poll

KafkaPollIterableItemSupplier<K,V,R> - Class in ru.tinkoff.qa.neptune.kafka.functions.poll

KafkaPollIterableSupplier<K,V,R> - Class in ru.tinkoff.qa.neptune.kafka.functions.poll

KafkaPollListFromRecordSupplier<K,V,R> - Class in ru.tinkoff.qa.neptune.kafka.functions.poll

KafkaSendRecordsActionSupplier<K,V> - Class in ru.tinkoff.qa.neptune.kafka.functions.send

KafkaStepContext - Class in ru.tinkoff.qa.neptune.kafka

KafkaStepContext() - Constructor for class ru.tinkoff.qa.neptune.kafka.KafkaStepContext

N

NO_DESC_ERROR_TEXT - Static variable in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollArraySupplier

NO_DESC_ERROR_TEXT - Static variable in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollItemFromRecordSupplier

NO_DESC_ERROR_TEXT - Static variable in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollIterableItemSupplier

NO_DESC_ERROR_TEXT - Static variable in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollIterableSupplier

NO_DESC_ERROR_TEXT - Static variable in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollListFromRecordSupplier

O

onStart(KafkaStepContext) - Method in class ru.tinkoff.qa.neptune.kafka.functions.send.KafkaSendRecordsActionSupplier

P

parse(String) - Method in class ru.tinkoff.qa.neptune.kafka.properties.KafkaDefaultTopicsForPollProperty

partition(Integer) - Method in class ru.tinkoff.qa.neptune.kafka.functions.send.KafkaSendRecordsActionSupplier

poll(GetRecordSupplier<K, V>) - Method in class ru.tinkoff.qa.neptune.kafka.KafkaStepContext

Polls topics and returns a list of ConsumerRecord

poll(KafkaPollArraySupplier<?, ?, T>) - Method in class ru.tinkoff.qa.neptune.kafka.KafkaStepContext

Polls topics and returns an array of values

poll(KafkaPollItemFromRecordSupplier<?, ?, T>) - Method in class ru.tinkoff.qa.neptune.kafka.KafkaStepContext

poll(KafkaPollIterableItemSupplier<?, ?, T>) - Method in class ru.tinkoff.qa.neptune.kafka.KafkaStepContext

Polls topics and returns some value

poll(KafkaPollIterableSupplier<?, ?, T>) - Method in class ru.tinkoff.qa.neptune.kafka.KafkaStepContext

Polls topics and returns a list of values

poll(KafkaPollListFromRecordSupplier<?, ?, T>) - Method in class ru.tinkoff.qa.neptune.kafka.KafkaStepContext

producerRecord(String) - Static method in class ru.tinkoff.qa.neptune.kafka.functions.send.KafkaSendRecordsActionSupplier

Sends a message to topic as text.

producerRecord(Serializer<V>, V) - Static method in class ru.tinkoff.qa.neptune.kafka.functions.send.KafkaSendRecordsActionSupplier

Sends a message to topic.

ProducerRecordKeyCaptor - Class in ru.tinkoff.qa.neptune.kafka.captors

ProducerRecordKeyCaptor() - Constructor for class ru.tinkoff.qa.neptune.kafka.captors.ProducerRecordKeyCaptor

ProducerRecordValueCaptor - Class in ru.tinkoff.qa.neptune.kafka.captors

ProducerRecordValueCaptor() - Constructor for class ru.tinkoff.qa.neptune.kafka.captors.ProducerRecordValueCaptor

R

ReceivedArrayCaptor - Class in ru.tinkoff.qa.neptune.kafka.captors

ReceivedArrayCaptor() - Constructor for class ru.tinkoff.qa.neptune.kafka.captors.ReceivedArrayCaptor

ReceivedListCaptor - Class in ru.tinkoff.qa.neptune.kafka.captors

ReceivedListCaptor() - Constructor for class ru.tinkoff.qa.neptune.kafka.captors.ReceivedListCaptor

ru.tinkoff.qa.neptune.kafka - package ru.tinkoff.qa.neptune.kafka

ru.tinkoff.qa.neptune.kafka.captors - package ru.tinkoff.qa.neptune.kafka.captors

ru.tinkoff.qa.neptune.kafka.functions.poll - package ru.tinkoff.qa.neptune.kafka.functions.poll

ru.tinkoff.qa.neptune.kafka.functions.send - package ru.tinkoff.qa.neptune.kafka.functions.send

ru.tinkoff.qa.neptune.kafka.jackson.desrializer - package ru.tinkoff.qa.neptune.kafka.jackson.desrializer

ru.tinkoff.qa.neptune.kafka.localization - package ru.tinkoff.qa.neptune.kafka.localization

ru.tinkoff.qa.neptune.kafka.properties - package ru.tinkoff.qa.neptune.kafka.properties

S

send(KafkaSendRecordsActionSupplier<?, ?>) - Method in class ru.tinkoff.qa.neptune.kafka.KafkaStepContext

Sends something to a topic

serialize(ConsumerRecord, JsonGenerator, SerializerProvider) - Method in class ru.tinkoff.qa.neptune.kafka.jackson.desrializer.ConsumerRecordSerializer

serialize(Headers, JsonGenerator, SerializerProvider) - Method in class ru.tinkoff.qa.neptune.kafka.jackson.desrializer.HeaderJsonSerializer

setKey(K) - Method in class ru.tinkoff.qa.neptune.kafka.functions.send.KafkaSendRecordsActionSupplier

setKey(K2, Serializer<K2>) - Method in class ru.tinkoff.qa.neptune.kafka.functions.send.KafkaSendRecordsActionSupplier

setProperty(String, String) - Method in class ru.tinkoff.qa.neptune.kafka.functions.send.KafkaSendRecordsActionSupplier

Defines producer property value

T

thenGetItem(String, Function<ConsumerRecord<K, V>, R>) - Method in class ru.tinkoff.qa.neptune.kafka.functions.poll.GetRecordSupplier

thenGetList(String, Function<ConsumerRecord<K, V>, R>) - Method in class ru.tinkoff.qa.neptune.kafka.functions.poll.GetRecordSupplier

timeOut(Duration) - Method in class ru.tinkoff.qa.neptune.kafka.functions.poll.GetRecordSupplier

timeOut(Duration) - Method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollArraySupplier

timeOut(Duration) - Method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollIterableItemSupplier

timeOut(Duration) - Method in class ru.tinkoff.qa.neptune.kafka.functions.poll.KafkaPollIterableSupplier

timestamp(Long) - Method in class ru.tinkoff.qa.neptune.kafka.functions.send.KafkaSendRecordsActionSupplier

topic(String) - Method in class ru.tinkoff.qa.neptune.kafka.functions.send.KafkaSendRecordsActionSupplier

V

valueOf(String) - Static method in enum ru.tinkoff.qa.neptune.kafka.properties.DefaultKafkaProperties

Returns the enum constant of this type with the specified name.

values() - Static method in enum ru.tinkoff.qa.neptune.kafka.properties.DefaultKafkaProperties

Returns an array containing the constants of this enum type, in the order they are declared.

C D E G H K N O P R S T V
All Classes All Packages