Top Level Namespace
Array
BoolChannel
Channel
ConsistentHasher
Deque
Fiber
File
Filesystem
FilesystemInfo
Hash
IO
- Buffered
LavinMQ
- AMQP
  - Argument
    - DeadLettering
      - DeadLetterer
  - ArgumentTarget
  - ArgumentValidator
    - BoolValidator
    - DeadLetteringValidator
    - IntValidator
    - MaxAgeValidator
    - StringValidator
  - Channel
    - ClosedError
    - TxAck
    - TxMessage
    - Unack
  - ChannelReplyCode
  - Client
  - ConnectionFactory
  - ConnectionReplyCode
  - ConsistentHashExchange
  - Consumer
    - ClosedError
  - DefaultExchange
  - DelayedExchangeQueue
    - DelayedMessageStore
  - Destination
  - DirectExchange
  - DurableDelayedExchangeQueue
  - DurablePriorityQueue
  - DurableQueue
  - Error
  - Exchange
  - FanoutExchange
  - FederationExchange
  - GISFilter
    - BoundingBox
    - BoundingBoxFilter
    - Point
    - Polygon
    - PolygonFilter
    - RadiusFilter
  - HeadersExchange
  - KVFilter
  - PriorityQueue
    - PriorityMessageStore
  - Queue
    - Closed
    - ClosedError
    - Error
    - ReadError
    - RejectOverFlow
  - RkIterator
  - Stream
  - StreamConsumer
  - StreamFilter
  - StreamMessageStore
    - OffsetError
  - StreamReader
  - TopicBindingKey
    - HashSegment
    - Segment
    - StarSegment
    - StringSegment
  - TopicExchange
  - XStreamFilter
- Auth
  - Authenticator
  - CacheKey
  - Chain
  - InvalidPasswordHash
  - LocalAuthenticator
  - Password
  - PermissionCache
  - User
    - Permissions
    - UnknownHashAlgoritm
  - UserStore
- BindingDetails
- BindingKey
- BytesMessage
- Client
  - Channel
    - Consumer
- Clustering
  - Action
  - AppendAction
  - AuthenticationError
  - Checksums
  - Client
    - AuthenticationError
    - Error
  - Controller
    - Error
  - DeleteAction
  - Error
  - FileIndex
  - Follower
    - State
  - InvalidStartHeaderError
  - Proxy
  - ReplaceAction
  - Replicator
  - Server
- Config
- ConnectionFactory
- ConnectionInfo
  - IPAddress
- DataDirLock
- Deduplication
  - Cache
  - Deduper
  - MemoryCache
- Destination
- Envelope
- Error
  - ExchangeTypeError
  - PreconditionFailed
  - UnexpectedFrame
- Etcd
  - Connection
  - Endpoint
  - Error
  - Lease
    - Lost
  - LeaseAlreadyExists
  - LeaseNotFound
  - NoLeader
- EventType
- Exchange
  - AccessRefused
- ExchangeEvent
- Federation
  - AckMode
  - Upstream
    - ExchangeLink
    - Link
      - State
    - QueueLink
  - UpstreamStore
- HTTP
  - ApiDefaultsHandler
  - ApiErrorHandler
  - AuthHandler
  - BindingHelpers
  - BindingsController
  - ChannelsController
  - ConnectionsController
  - ConnectionsHelper
  - ConsumersController
  - Controller
    - HaltRequest
  - DefinitionsController
    - Definitions
    - GlobalDefinitions
    - VHostDefinitions
  - ExchangeHelpers
  - ExchangesController
  - FollowerPrometheusController
  - LogsController
  - MainController
  - MetricsServer
  - NodesController
  - ParametersController
  - ParameterView
  - PermissionsController
  - PermissionsView
  - Prometheus
  - PrometheusController
  - PrometheusWriter
    - Metric
    - MetricLabels
    - MetricValue
    - NameWriter
  - QueueHelpers
  - QueuesController
  - Router
    - Action
    - Params
    - Route
    - Routes
  - Server
  - ShovelsController
  - StaticController
  - StatsHelpers
  - StrictTransportSecurity
  - UserHelpers
  - UsersController
  - UserView
  - VHostLimitsController
    - VHostLimitsView
  - VHostsController
  - VHostView
  - ViewsController
- JournalLogFormat
- Launcher
- Logger
- Message
- MessageStore
  - ClosedError
  - Error
  - MetadataError
- MQTT
  - Broker
  - Brokers
  - Client
  - ConnectionFactory
  - Consumer
  - Exchange
    - BindingKey
  - RetainStore
    - IndexTree
  - Session
  - Sessions
  - StringTokenIterator
  - SubscriptionTree
  - TopicTree
- Observable
- Observer
- OperatorPolicy
- OutdatedSchemaVersion
- Parameter
- ParameterId
- ParameterStore
- ParameterTarget
- Policy
  - Target
- PolicyTarget
- ProxyProtocol
  - Error
  - InvalidFamily
  - InvalidSignature
  - InvalidVersionCmd
  - UnsupportedTLVType
  - V1
  - V2
- Queue
- QueueEvent
- QueueFactory
- QueueState
- Schema
  - SchemaV4
    - VhostMigrator
      - QueueMigrator
  - SegmentPositionBase
  - SegmentPositionV1
  - SegmentPositionV2
  - SegmentPositionV3
- SchemaVersion
- SegmentPosition
- Server
  - Protocol
- Shovel
  - AckMode
  - AMQPDestination
  - AMQPSource
  - DeleteAfter
  - Destination
  - FailedDeliveryError
  - HTTPDestination
  - MultiDestinationHandler
  - Runner
  - State
- ShovelStore
- SNIHost
- SNIManager
- SortableJSON
- StandaloneRunner
- Stats
- StdoutLogFormat
- Tag
- UnackedMessage
- UnsupportedSchemaVersion
- VHost
- VHostStore
  - Event
- WebSocketIO
- WebsocketProxy
LavinMQCtl
- DefinitionsGenerator
  - Frame
LavinMQPerf
- AMQP
- MQTT
  - Throughput
- Perf
MFile
- Advice
NamedTuple
NameValidator
Regex
RoughTime
Set
Slice
System
- Error
- ResourceUsage

Generated using Crystal 1.16.3
2025-12-20 01:22:49 UTC

module LavinMQ::Federation

Defined in:

lavinmq/federation/constants.cr
lavinmq/federation/link.cr
lavinmq/federation/upstream.cr
lavinmq/federation/upstream_store.cr

Constant Summary

DEFAULT_ACK_MODE = AckMode::OnConfirm
DEFAULT_EXPIRES = nil
DEFAULT_MAX_HOPS = 1_i64
DEFAULT_MSG_TTL = nil
DEFAULT_PREFETCH = 1000_u16
DEFAULT_RECONNECT_DELAY = 1.second