Struct MetaProperties 

pub struct MetaProperties {
    pub cluster_id: ClusterId,
    pub node_id: i32,
    pub directory_id: Option<DirectoryId>,
}

The content of a version 1 meta.properties.

Kafka’s MetaProperties keeps the cluster id as a string. krabka keeps it as 16 bytes, so a cluster id that is not a Kafka Uuid does not read. The node id is Kafka’s int. The directory id is optional when the file is read, as in Kafka: a broker gives a directory without one an id at its next start.

Fields

cluster_id: ClusterId

The cluster that the directory belongs to.

node_id: i32

The node that the directory belongs to, Kafka’s node.id.

directory_id: Option<DirectoryId>

The directory’s own id (KIP-858).

Implementations

impl MetaProperties

pub fn read(dir: &Path) -> Result<Option<Self>, MetaPropertiesError>

Reads <dir>/meta.properties. Returns None when there is no such file, which is how Kafka’s MetaPropertiesEnsemble.Loader finds an empty directory.

Errors

Returns MetaPropertiesError::Io when the file is there but cannot be read, and another variant when it does not parse.

pub fn parse(bytes: &[u8]) -> Result<Self, MetaPropertiesError>

Parses the bytes of a meta.properties, as Kafka’s new MetaProperties.Builder(props).build() does after Properties.load.

The checks run in Kafka’s order, so a file with several faults is reported with Kafka’s first message.

Errors

Returns the MetaPropertiesError for the first fault.

pub fn to_file_text(&self, now: SystemTime) -> String

The text of the file that Kafka’s writePropertiesFile writes for these ids at now, with now in UTC.

No value needs an escape: a node id is digits and a sign, and Kafka’s Uuid form uses only letters, digits, - and _, which Properties.store writes as they are.

pub fn write(&self, dir: &Path) -> Result<()>

Writes <dir>/meta.properties as Kafka’s writePropertiesFile does with fsync set: the text goes to meta.properties.tmp, which is synced and renamed into place, and then, on Unix, the directory is synced. A write that stops partway therefore never leaves a truncated file.

Errors

Returns the first I/O error. A rename that fails removes the temporary file, as Kafka does.

Trait Implementations

impl Clone for MetaProperties

fn clone(&self) -> MetaProperties

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for MetaProperties

impl Debug for MetaProperties

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

Formats the value using the given formatter.

impl Eq for MetaProperties

impl PartialEq for MetaProperties

fn eq(&self, other: &MetaProperties) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for MetaProperties