Namespace Silverback.Messaging.Sequences.Chunking

Classes

ChunkEnricherFactory

Builds an IChunkEnricher instance for the ProducerEndpoint.

ChunkSequence

A sequence of chunks that belong to the same message.

ChunkSequenceReader

Creates a ChunkSequence containing all the chunks of the original message.

ChunkSequenceWriter

Creates the chunks sequence according to the ChunkSettings.

ChunkSettings

The chunking settings. To enable chunking just set the Size property to the desired (maximum) chunk size.

ChunkStream

The Stream implementation used to read the chunked messages. This stream is used by the ChunkSequenceReader and it is asynchronously pushed with the chunks being consumed.

KafkaChunkEnricher

Enriches the produced chunks adding some additional Kafka-specific headers.

Interfaces

IChunkEnricher

Enriches the produced chunks adding some additional broker-specific headers.

IChunkEnricherFactory

Builds an IChunkEnricher instance for the ProducerEndpoint.