rocketmq-runtime 1.0.0

Unofficial Rust implementation of Apache RocketMQ
Documentation
// Copyright 2023 The RocketMQ Rust Authors
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

mod budget;
mod clock;
mod dynamic;
mod limit;
mod memory;
mod queue;

pub use budget::BudgetRejection;
pub use budget::BudgetRejectionReason;
pub use budget::BudgetSnapshot;
pub use budget::PermitRebindOutcome;
pub use budget::ResourceBudget;
pub use budget::ResourceBudgetTree;
pub use budget::ResourcePermit;
pub use clock::MonotonicClock;
pub use clock::SystemMonotonicClock;
pub use dynamic::DynamicBudgetKey;
pub use dynamic::DynamicKeyAdmissionRejection;
pub use dynamic::DynamicKeyRegistrationFailure;
pub use dynamic::DynamicKeyRetirement;
pub use dynamic::DEFAULT_MAX_DYNAMIC_BUDGET_KEYS;
pub use limit::BudgetCapacity;
pub use limit::BudgetClass;
pub use limit::BudgetDimension;
pub use limit::BudgetLimit;
pub use limit::FullPolicy;
pub use limit::RateLimit;
pub use memory::HostMemoryFileView;
pub use memory::ManagedMemoryBudget;
pub use memory::ManagedMemoryPolicy;
pub use memory::ManagedMemoryRequest;
pub use memory::MemoryFileView;
pub use memory::MemoryLimitSource;
pub use memory::ProcessMemoryLimit;
pub use queue::BudgetedItem;
pub use queue::BudgetedQueue;
pub use queue::ForeignPermit;
pub use queue::QueuePushOutcome;
pub use queue::QueuePushRejection;
pub use queue::QueueSnapshot;