Top Level Namespace
Array
AvalancheMQ
- AMQP
- AMQPConnection
- AMQPWebsocket
- ArgumentNumber
- BindingDetails
- BindingKey
- BytesMessage
- ChainedLogger
- Client
  - Channel
    - Consumer
    - Unack
- Config
- ConnectionInfo
- ConsistentHashExchange
- ConsumerStore
  - ConsumerGroup
- DefaultExchange
- DelayedExchangeQueue
- DelayedExchangeQueueMixin
- Destination
- DirectExchange
- DurableDelayedExchangeQueue
- DurablePriorityQueue
- DurableQueue
- Envelope
- Error
  - ExchangeTypeError
  - PreconditionFailed
  - UnexpectedFrame
- EventType
- Exchange
- FanoutExchange
- Federation
  - AckMode
  - Upstream
    - ExchangeLink
    - Link
      - State
    - QueueLink
  - UpstreamStore
- FederationExchange
- HeadersExchange
- HTTP
  - ApiDefaultsHandler
  - ApiErrorHandler
  - BasicAuthHandler
  - BindingHelpers
  - BindingsController
  - ChannelsController
  - ConnectionsController
  - ConnectionsHelper
  - ConsumersController
  - Controller
    - HaltRequest
  - DefinitionsController
  - ExchangeHelpers
  - ExchangesController
  - MainController
  - NodesController
  - ParametersController
  - ParameterView
  - PermissionsController
  - PermissionsView
  - PrometheusController
  - QueueHelpers
  - QueuesController
  - ResourceHelpers
  - Server
    - ExpectedBodyError
    - NotFoundError
    - PayloadTooLarge
    - UnknownContentType
  - StaticController
    - Release
  - StatsHelpers
  - UserHelpers
  - UsersController
  - UserView
  - VHostsController
  - VHostView
- LogFormatter
- Message
- MessageMetadata
- OutdatedSchemaVersion
- Parameter
- ParameterId
- ParameterStore
- ParameterTarget
- PersistentExchangeQueue
- Policy
  - Target
- PolicyTarget
- PriorityQueue
- PriorityQueueMixin
- ProxyProtocol
  - InvalidFamily
  - InvalidSignature
  - InvalidVersionCmd
  - UnsupportedTLVType
  - V1
  - V2
    - Family
    - SSLCLIENT
    - SSLSubType
    - TLVType
- Queue
  - Error
  - ExpirationReadyQueue
  - PriorityReadyQueue
  - ReadyQueue
  - RejectOverFlow
  - SortedReadyQueue
  - UnackQueue
    - Unack
- QueueFactory
- QueueState
- Reporter
- SchemaVersion
  - MigrateIndexV1toV2
    - SegmentPositionV1
- SegmentPosition
  - SPFlags
- Server
  - Event
- ServerCLI
- Shovel
  - AckMode
  - AMQPDestination
  - AMQPSource
  - DeleteAfter
  - Destination
  - FailedDeliveryError
  - HTTPDestination
  - Runner
  - State
- ShovelStore
- SortableJSON
- Stats
- Tag
- TopicExchange
- UnsupportedSchemaVersion
- User
  - BcryptPassword
  - InvalidPasswordHash
  - MD5Password
  - Password
  - Permissions
  - RabbitPassword
  - SHA256Password
  - SHA512Password
  - UnknownHashAlgoritm
- UserStore
- VHost
  - Hole
  - PriorityQueue
  - QueueBinding
  - ReferencedSPs
    - NotInOrderError
  - SPQueue
  - SPReadyQueue
  - SPUnackQueue
  - SPUnsortedReadyQueue
- VHostStore
- WebSocketIO
AvalancheMQCtl
BindChurn
ChannelChurn
ConnectionChurn
ConsistentHasher
Deque
Fiber
File
- Advice
Filesystem
FilesystemInfo
Hash
IO
- Buffered
- Evented
- FileDescriptor
- Memory
MFile
- Advice
Mutex
Observable
Observer
Perf
QueueChurn
Regex
RoughTime
Set
Slice
Socket
StringPool
System
- Error
- ResourceUsage
Throughput

Built with Crystal 1.9.2
2023-10-08 07:18:00 UTC

module AvalancheMQ::Shovel

Defined in:

avalanchemq/shovel/shovel.cr

Constant Summary

DEFAULT_ACK_MODE = AckMode::OnConfirm
DEFAULT_DELETE_AFTER = DeleteAfter::Never
DEFAULT_PREFETCH = 1000_u16
DEFAULT_RECONNECT_DELAY = 5