Skip to main content

CrystalDocs builds documentation for every shard, on request. The announcement: Documentation for every shard, on CrystalBits.

CrystalDocs

    Browse DocsCrystalShardsAbout

    github.com/cloudamqp/lavinmq

    Types

    • BoolChannel
      • StateChannel
        • EndlessQueue
    • Channel
    • Fiber
    • File
    • Filesystem
    • FilesystemInfo
    • Hasher
    • IO
      • BufferPool
      • Buffered
    • JumpConsistentHasher
    • LavinMQ
      • AMQP
        • Argument
          • DeadLettering
            • DeadLetterer
              • Target
            • MessageRoutedCallback
            • Task
            • Tasks
        • ArgumentTarget
        • ArgumentValidator
          • BoolValidator
          • DeadLetteringValidator
          • IntValidator
          • MaxAgeValidator
          • StringValidator
        • BindingDetails
        • BindingKey
        • Channel
          • ClosedError
          • TxAck
          • TxMessage
          • Unack
        • ChannelReplyCode
        • Client
        • ConnectionFactory
        • ConnectionReplyCode
        • ConsistentHashExchange
        • Consumer
          • ClosedError
        • ConsumerOffsets
        • DefaultExchange
        • DelayedExchangeQueue
        • DelayedQueue
          • DelayedMessageStore
            • DelayedRequeuedStore
              • DelayedSegmentPosition
        • DelayedRetryQueue
        • Destination
        • DirectExchange
        • DurableDelayedExchangeQueue
        • DurableDelayedRetryQueue
        • DurablePriorityQueue
        • DurableQueue
        • Error
        • Exchange
          • PublishResult
        • FanoutExchange
        • FederationExchange
        • GISFilter
          • BoundingBox
          • BoundingBoxFilter
          • Point
          • Polygon
          • PolygonFilter
          • RadiusFilter
        • HeadersExchange
        • KVFilter
        • MqttTopicExchange
        • PriorityQueue
          • PriorityMessageStore
        • Queue
          • Closed
          • ClosedError
          • Error
          • PublishResult
          • ReadError
          • Settings
        • QueueStats
        • ReplyText
        • RkIterator
        • Server
        • Stream
        • StreamConsumer
        • StreamFilter
        • StreamMessageStore
          • OffsetError
        • StreamReader
        • TopicBindingKey
          • HashSegment
          • Segment
          • StarSegment
          • StringSegment
        • TopicExchange
        • XStreamFilter
      • AcceptLoop
      • Auth
        • Authenticator
        • BaseUser
          • Permissions
        • Chain
        • Context
        • InvalidPasswordHash
        • JWT
          • DecodeError
          • Error
          • ExpiredKeysError
          • Header
          • JWKSFetcher
            • JWK
            • JWKSResponse
            • JWKSResult
            • OIDCConfiguration
          • PasswordFormatError
          • Payload
          • PublicKeys
          • RS256Parser
          • ResourceRoles
          • Token
          • TokenClaim
          • TokenParser
          • TokenVerifier
          • VerificationError
        • LocalAuthenticator
        • OAuthAuthenticator
        • OAuthUser
        • Password
          • BcryptPassword
          • MD5Password
          • RabbitPassword
          • SHA256Password
          • SHA512Password
        • PermissionCache
        • PermissionKey
        • User
          • UnknownHashAlgoritm
        • UserStore
      • BytesMessage
      • Client
        • Channel
          • Consumer
      • Clustering
        • AuthenticationError
        • Checksums
          • Entry
        • Client
          • AuthenticationError
          • Error
        • Controller
          • Error
        • Coordinator
        • Error
        • EtcdCoordinator
        • FileIndex
        • Follower
          • State
        • InvalidStartHeaderError
        • Proxy
        • Replicator
        • Server
      • Config
        • CliOpt
        • EnvOpt
        • Error
        • IniOpt
        • Option
        • Options
      • ConnectionFactory
      • ConnectionInfo
        • IPAddress
      • ConnectionStore
      • ConsistentHashAlgorithm
      • DataDirLock
        • Error
      • Deduplication
        • Cache
        • Deduper
        • MemoryCache
      • DefinitionsImporter
      • DefinitionsStore
      • DeletedVHostStats
      • DirectReplyConsumerStore
      • Envelope
      • Error
        • ExchangeTypeError
        • PreconditionFailed
        • UnexpectedFrame
      • Etcd
        • Connection
        • ElectionLeader
        • Endpoint
        • Error
        • Lease
          • Expired
        • LeaseAlreadyExists
        • LeaseExpired
        • LeaseNotFound
        • NoLeader
        • StaleLeadership
      • EventType
      • Exchange
        • AccessRefused
      • Federation
        • AckMode
        • Upstream
          • ExchangeLink
          • Link
            • State
          • QueueLink
        • UpstreamStore
          • PendingDelete
      • FileSystem
      • GCPauseRecorder
      • GlobalDefinitions
      • HTTP
        • ApiDefaultsHandler
        • ApiErrorHandler
        • AuthHandler
        • BindingHelpers
        • BindingsController
        • ChannelsController
        • ConnectionsController
        • ConnectionsHelper
        • ConsumersController
        • ControlSocketError
        • ControlSocketInUseError
        • Controller
          • HaltRequest
        • DefinitionsController
        • ExchangeHelpers
        • ExchangesController
        • FollowerPrometheusController
        • LogsController
        • MainController
        • MetricsServer
        • NodesController
        • OAuth2
          • FlexibleIntConverter
          • PKCE
          • TokenExchange
            • TokenResponse
        • OAuthController
          • OAuthError
        • ParameterView
        • ParametersController
        • PermissionGroupMemberView
        • PermissionGroupSummaryView
        • PermissionGroupsController
        • PermissionsController
        • PermissionsView
        • Prometheus
        • PrometheusController
        • PrometheusWriter
          • Metric
          • MetricLabels
          • MetricValue
          • NameWriter
        • QueueHelpers
        • QueuesController
        • RequireUserHandler
        • Router
          • Action
          • Params
          • Route
          • Routes
        • Server
        • ShovelsController
        • StaticController
        • StatsHelpers
        • StrictTransportSecurity
        • UserHelpers
        • UserView
        • UsersController
        • VHostLimitsController
          • VHostLimitsView
        • VHostView
        • VHostsController
        • ViewsController
      • IPMatcher
        • Type
      • JournalLogFormat
      • Launcher
      • Logger
      • MQTT
        • Broker
        • BytesTokenIterator
        • Client
          • PendingPubAck
        • ClientIdRuleSegment
        • ClientIdValidation
        • ConnectionFactory
        • Error
        • Exchange
        • HashRuleSegment
        • PermissionGroup
          • Rule
        • PermissionService
          • Compiled
          • CompiledRule
          • Context
          • SaveError
        • PlusRuleSegment
        • Protocol
        • ProtocolVersion
        • PublishContext
          • Outcome
        • RetainStore
          • IndexTree
        • Server
        • Session
          • ClosedError
        • SessionMessageStore
        • Sessions
        • StringRuleSegment
        • StringTokenIterator
        • Subscriber
        • SubscriptionDetails
        • SubscriptionKey
        • SubscriptionTree
        • TopicFilter
        • TopicRuleSegment
        • TopicTooLong
        • TopicTree
      • Message
      • MessageStore
        • ClosedError
        • Error
        • MetadataError
        • PublishOrderedRequeuedStore
        • RequeuedStore
      • MinHeap
      • OperatorPolicy
      • OutdatedSchemaVersion
      • Parameter
      • ParameterId
      • ParameterStore
      • ParameterTarget
      • Persister
        • ConfirmTarget
        • SyncRecord
        • Unlink
      • Pidfile
      • Policy
        • Target
      • PolicyTarget
      • Protocol
      • ProtocolServer
      • ProxyProtocol
        • Error
        • InvalidFamily
        • InvalidSignature
        • InvalidVersionCmd
        • UnsupportedTLVType
        • V1
        • V2
      • Queue
      • QueueFactory
      • QueueState
      • RateLimiter
      • SNIHost
      • SNIManager
      • Schema
        • SchemaV4
          • VhostMigrator
            • QueueMigrator
        • SegmentPositionBase
        • SegmentPositionV1
        • SegmentPositionV2
        • SegmentPositionV3
      • SchemaVersion
      • SegmentPosition
      • Server
      • Shovel
        • AMQPDestination
        • AMQPSource
        • AckMode
        • ConfigError
        • DeleteAfter
        • Destination
        • Error
        • HTTPDestination
        • MultiDestination
        • NullOutcomeListener
        • Outcome
        • OutcomeListener
        • Runner
        • Source
        • State
        • Store
      • SortableJSON
      • StandaloneRunner
      • Stats
      • StdoutLogFormat
      • Tag
      • UnackedMessage
      • UnsupportedSchemaVersion
      • VHost
      • VHostDefinitions
      • VHostStore
      • WebSocketHandler
        • Protocol
      • WebSocketIO
      • WebsocketProxy
    • LavinMQCtl
      • Cmd
      • DefinitionsGenerator
        • Frame
      • Opt
    • LavinMQPerf
      • AMQP
        • BindChurn
        • ChannelChurn
        • ConnectionChurn
        • ConnectionCount
          • BasicConsumeFrame
        • ConsumerChurn
        • QueueChurn
        • QueueCount
        • Throughput
      • MQTT
        • Throughput
      • Perf
      • Ticker
    • MFile
      • Advice
    • NameValidator
    • NamedTuple
    • Regex
    • RingConsistentHasher
    • RoughTime
    • Slice
    • Socket
    • System
      • Error
      • ResourceUsage
    module

    LavinMQPerf

    Nested types

    • LavinMQPerf::AMQP
    • LavinMQPerf::MQTT
    • LavinMQPerf::Perf
    • LavinMQPerf::Ticker

    Advertisement

    Crystal jobs from CrystalGigs

    • Your posting here

      Reach Crystal developers on CrystalGigsFirst party

    CrystalDocs.org - Crystal Shard Documentation Hosting

    The CrystalBits newsletter

    Crystal tutorials, release news and community writing. One email when there is something new, never a stream.

    You will get one confirmation email to check the address is yours. Unsubscribe any time.

    GitHubCrystalShardsCrystalGigsCrystalBitsCrystal LanguageStatsSponsor

    The Bushido Collective builds and maintains this site.
    Licensed under the Apache License 2.0