FilterOversizedMessages will filter out all messages that exceed the byte size limit.

GetChunkedMessages returns an array of chunked message arrays from the original slice by taking into account three variables: 1.

NewFilterResult uses the current time as the timeOfFilter and calls newFilterResultWithTime.

NewTargetWriteResult builds a result structure to return from a target write attempt which contains the sent and failed message counts as well as several derived latency measures.

NewTransformationResult contains slices successfully tranformed, filtered and unsuccessfully transformed messages, and their lengths.

FilterResult contains the results from a target write operation.

Message holds the structure of a generic message to be sent to a target.

ObserverBuffer contains all the metrics we are processing.

SetupWriteError is a wrapper for target write error.

TargetWriteResult contains the results from a target write operation.

TransformationResult contains the results from a transformation operation.