Table of Contents - adp-fluent-plugin-kinesis-0.0.2 Documentation
Classes and Modules
- Fluent
- Fluent::Plugin
- Fluent::Plugin::KinesisFirehoseOutput
- Fluent::Plugin::KinesisHelper
- Fluent::Plugin::KinesisHelper::API
- Fluent::Plugin::KinesisHelper::API::APIParams
- Fluent::Plugin::KinesisHelper::API::BatchRequest
- Fluent::Plugin::KinesisHelper::API::BatchRequest::Backoff
- Fluent::Plugin::KinesisHelper::API::BatchRequest::BatchRequestParams
- Fluent::Plugin::KinesisHelper::Aggregator
- Fluent::Plugin::KinesisHelper::Aggregator::InvalidEncodingError
- Fluent::Plugin::KinesisHelper::Aggregator::Mixin
- Fluent::Plugin::KinesisHelper::Aggregator::Mixin::Params
- Fluent::Plugin::KinesisHelper::Client
- Fluent::Plugin::KinesisHelper::Client::ClientParams
- Fluent::Plugin::KinesisOutput
- Fluent::Plugin::KinesisOutput::ExceedMaxRecordSizeError
- Fluent::Plugin::KinesisOutput::InvalidRecordError
- Fluent::Plugin::KinesisOutput::KeyNotFoundError
- Fluent::Plugin::KinesisOutput::SkipRecordError
- Fluent::Plugin::KinesisStreamsAggregatedOutput
- Fluent::Plugin::KinesisStreamsOutput
- FluentPluginKinesis
- Gzip
- Stream
Methods
- ::compress — Gzip
- ::decompress — Gzip
- ::included — Fluent::Plugin::KinesisHelper::Aggregator::Mixin
- ::included — Fluent::Plugin::KinesisHelper::API
- ::included — Fluent::Plugin::KinesisHelper::API::BatchRequest
- ::included — Fluent::Plugin::KinesisHelper::Client
- ::new — Fluent::Plugin::KinesisOutput::SkipRecordError
- ::new — Fluent::Plugin::KinesisOutput::KeyNotFoundError
- ::new — Fluent::Plugin::KinesisOutput::ExceedMaxRecordSizeError
- ::new — Fluent::Plugin::KinesisOutput::InvalidRecordError
- ::new — Fluent::Plugin::KinesisHelper::API::BatchRequest::Backoff
- ::new — Stream
- #aggregate — Fluent::Plugin::KinesisHelper::Aggregator
- #aggregated? — Fluent::Plugin::KinesisHelper::Aggregator
- #aggregated_size_offset — Fluent::Plugin::KinesisHelper::Aggregator
- #aggregator — Fluent::Plugin::KinesisHelper::Aggregator::Mixin
- #any_records_shipped? — Fluent::Plugin::KinesisHelper::API::BatchRequest
- #batch_request_with_retry — Fluent::Plugin::KinesisHelper::API::BatchRequest
- #calc — Fluent::Plugin::KinesisHelper::API::BatchRequest::Backoff
- #client — Fluent::Plugin::KinesisHelper::Client
- #client_class — Fluent::Plugin::KinesisHelper::Client
- #client_options — Fluent::Plugin::KinesisHelper::Client
- #close — Stream
- #collect_failed_records — Fluent::Plugin::KinesisHelper::API::BatchRequest
- #compressor_create — Fluent::Plugin::KinesisOutput
- #configure — Fluent::Plugin::KinesisOutput
- #configure — Fluent::Plugin::KinesisFirehoseOutput
- #configure — Fluent::Plugin::KinesisStreamsOutput
- #configure — Fluent::Plugin::KinesisStreamsAggregatedOutput
- #configure — Fluent::Plugin::KinesisHelper::API
- #configure — Fluent::Plugin::KinesisHelper::API::BatchRequest
- #configure — Fluent::Plugin::KinesisHelper::Client
- #create_partition_key_generator — Fluent::Plugin::KinesisStreamsAggregatedOutput
- #data_formatter_create — Fluent::Plugin::KinesisOutput
- #deaggregate — Fluent::Plugin::KinesisHelper::Aggregator
- #failed_count — Fluent::Plugin::KinesisHelper::API::BatchRequest
- #format — Fluent::Plugin::KinesisFirehoseOutput
- #format — Fluent::Plugin::KinesisStreamsOutput
- #format — Fluent::Plugin::KinesisStreamsAggregatedOutput
- #format_for_api — Fluent::Plugin::KinesisOutput
- #formatted_to_msgpack_binary? — Fluent::Plugin::KinesisOutput
- #give_up_retries — Fluent::Plugin::KinesisHelper::API::BatchRequest
- #increment_num_errors — Fluent::Plugin::KinesisHelper::API::BatchRequest
- #key_formatter_create — Fluent::Plugin::KinesisStreamsOutput
- #msgpack_unpacker — Fluent::Plugin::KinesisOutput
- #multi_workers_ready? — Fluent::Plugin::KinesisOutput
- #next — Fluent::Plugin::KinesisHelper::API::BatchRequest::Backoff
- #offset — Fluent::Plugin::KinesisStreamsAggregatedOutput
- #reliable_sleep — Fluent::Plugin::KinesisHelper::API::BatchRequest
- #request_type — Fluent::Plugin::KinesisOutput
- #reset — Fluent::Plugin::KinesisHelper::API::BatchRequest::Backoff
- #results — Fluent::Plugin::KinesisHelper::API::BatchRequest
- #retry_records — Fluent::Plugin::KinesisHelper::API::BatchRequest
- #scaling_factor — Fluent::Plugin::KinesisHelper::API::BatchRequest::Backoff
- #setup_credentials — Fluent::Plugin::KinesisHelper::Client
- #size_of_values — Fluent::Plugin::KinesisStreamsAggregatedOutput
- #size_of_values — Fluent::Plugin::KinesisHelper::API::BatchRequest
- #split_to_batches — Fluent::Plugin::KinesisHelper::API::BatchRequest
- #to_s — Fluent::Plugin::KinesisOutput::SkipRecordError
- #truncate — Fluent::Plugin::KinesisOutput
- #write — Fluent::Plugin::KinesisFirehoseOutput
- #write — Fluent::Plugin::KinesisStreamsOutput
- #write — Fluent::Plugin::KinesisStreamsAggregatedOutput
- #write_records_batch — Fluent::Plugin::KinesisOutput