Struct AclCache 

pub struct AclCache { /* private fields */ }

Immutable ACL snapshot. Each refresh rebuilds it wholesale.

Implementations

impl AclCache

pub fn new(entries: Vec<AclEntry>) -> Self

A snapshot of entries that compares every host as text, as Kafka 4.3.1 does. Say that the cluster reads a range from a host containing / with Self::with_cidr_hosts_supported.

pub fn with_cidr_hosts_supported(self, supported: bool) -> Self

Sets whether a stored host containing / is a CIDR range (KIP-1276), which it is once the broker the entries came from has a metadata.version of 4.4-IV1 or higher. A gateway that reads a range where that broker compares text would authorize a peer the broker denies, and the other way round.

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

Trait Implementations

impl AclSource for AclCache

fn matching_acls<'a>( &'a self, rt: ResourceType, name: &'a str, ) -> AclEntries<'a>

fn acls_of_type(&self, rt: ResourceType) -> AclEntries<'_>

Every stored entry of resource type rt, regardless of resource name.

fn cidr_hosts_supported(&self) -> bool

Whether a stored host containing / is a CIDR range (KIP-1276) rather than plain text. Kafka 4.3.1 compares every host as text, and trunk reads a range only once the cluster’s metadata.version reaches 4.4-IV1, so a source says here whether the cluster it reads from has reached it. There is no default: a source that holds only entries, such as crate::AclCache, must carry the answer of the broker it fetched them from, or it would read a range where that broker compares text.

impl Clone for AclCache

fn clone(&self) -> AclCache

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AclCache

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for AclCache

fn default() -> AclCache

Returns the “default value” for a type.