Sha256: 67944e3d05ac1b8eae298103d970ec5598870fb77ba998fdf4fbb378e357f13e
Contents?: true
Size: 1.64 KB
Versions: 26
Compression:
Stored size: 1.64 KB
Contents
# frozen_string_literal: true
module WaterDrop
# Namespace used to encapsulate all the internal errors of WaterDrop
module Errors
# Base class for all the WaterDrop internal errors
BaseError = Class.new(StandardError)
# Raised when configuration doesn't match with validation contract
ConfigurationInvalidError = Class.new(BaseError)
# Raised when we want to use a producer that was not configured
ProducerNotConfiguredError = Class.new(BaseError)
# Raised when we want to reconfigure a producer that was already configured
ProducerAlreadyConfiguredError = Class.new(BaseError)
# Raised when trying to use connected producer from a forked child process
# Producers cannot be used in forks if they were already used in the child processes
ProducerUsedInParentProcess = Class.new(BaseError)
# Raised when there was an attempt to use a closed producer
ProducerClosedError = Class.new(BaseError)
# Raised when we want to send a message that is invalid (impossible topic, etc)
MessageInvalidError = Class.new(BaseError)
# Raised when we've got an unexpected status. This should never happen. If it does, please
# contact us as it is an error.
StatusInvalidError = Class.new(BaseError)
# Raised when during messages flushing something bad happened
class FlushFailureError < BaseError
attr_reader :dispatched_messages
# @param dispatched_messages [Array<Rdkafka::Producer::DeliveryHandle>] handlers of the
# messages that we've dispatched
def initialize(dispatched_messages)
super()
@dispatched_messages = dispatched_messages
end
end
end
end
Version data entries
26 entries across 26 versions & 1 rubygems