pub struct Limits {
pub max_memory: Option<i64>,
pub max_storage: Option<i64>,
pub max_streams: Option<i64>,
pub max_consumers: Option<i64>,
pub max_bytes_required: bool,
pub max_ack_pending: i64,
pub memory_max_stream_bytes: Option<i64>,
pub storage_max_stream_bytes: Option<i64>,
}Fields
max_memory: Option<i64>The maximum amount of Memory storage Stream Messages may consume
max_storage: Option<i64>The maximum amount of File storage Stream Messages may consume
max_streams: Option<i64>The maximum number of Streams an account can create
max_consumers: Option<i64>The maximum number of Consumer an account can create
max_bytes_required: boolIndicates if Streams created in this account requires the max_bytes property set
max_ack_pending: i64The maximum number of outstanding ACKs any consumer may configure
memory_max_stream_bytes: Option<i64>The maximum size any single memory stream may be
storage_max_stream_bytes: Option<i64>The maximum size any single storage based stream may be
Trait Implementations
sourceimpl<'de> Deserialize<'de> for Limits
impl<'de> Deserialize<'de> for Limits
sourcefn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
sourceimpl PartialEq<Limits> for Limits
impl PartialEq<Limits> for Limits
impl Copy for Limits
impl Eq for Limits
impl StructuralEq for Limits
impl StructuralPartialEq for Limits
Auto Trait Implementations
impl RefUnwindSafe for Limits
impl Send for Limits
impl Sync for Limits
impl Unpin for Limits
impl UnwindSafe for Limits
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
fn vzip(self) -> V
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber to this type, returning a
WithDispatch wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber to this type, returning a
WithDispatch wrapper. Read more