Struct nakadion::publisher::partitioner::Partitioner

pub struct Partitioner<B: BuildHasher + Clone = DefaultBuildHasher> { /* fields omitted */ }

Determines partitions based on hashes

Methods

impl Partitioner<DefaultBuildHasher>

pub fn new(partitions: Vec<PartitionId>) -> Self

Create a new instance with the given partitions.

The order of the given partitions will not be changed.

Panics

If partitions is empty

pub fn new_sorted(partitions: Vec<PartitionId>) -> Self

Create a new instance with the given partitions.

The partitions will be sorted by first trying to convert the partitions to numbers and sorting by these. Otherwise they will be sorted ba their contained string.

Panics

If partitions is empty

pub async fn from_event_type<'_, C>(
    event_type: &'_ EventTypeName,
    api_client: C
) -> Result<Self, NakadiApiError> where
    C: MonitoringApi, 

Create a new instance for the partitions of the given event type.

The partitions will be sorted by first trying to convert the partitions to numbers and sorting by these. Otherwise they will be sorted ba their contained string.

Fails if the event type has no partitions.

impl<B> Partitioner<B> where
    B: BuildHasher + Clone, 

pub fn new_with_hasher(partitions: Vec<PartitionId>, build_hasher: B) -> Self

Create a new instance with the given partitions and a provided hashing algorithm.

The order of the given partitions will not be changed.

Panics

If partitions is empty

pub fn new_sorted_with_hasher(
    partitions: Vec<PartitionId>,
    build_hasher: B
) -> Self

Create a new instance with the given partitions and a provided hashing algorithm.

The partitions will be sorted by first trying to convert the partitions to numbers and sorting by these. Otherwise they will be sorted ba their contained string.

Panics

If partitions is empty

pub async fn from_event_type_with_hasher<'_, C>(
    event_type: &'_ EventTypeName,
    api_client: C,
    build_hasher: B
) -> Result<Self, NakadiApiError> where
    C: MonitoringApi, 

Create a new instance for the partitions of the given event type and a provided hashing algorithm.

The partitions will be sorted by first trying to convert the partitions to numbers and sorting by these. Otherwise they will be sorted ba their contained string.

Fails if the event type has no partitions.

pub fn assign<E: PartitionKeyExtractable + PartitionAssignable>(
    self,
    event: &mut E
)

Determines and assigns partitions

pub fn partitions(&self) -> &[PartitionId]

Returns the partitions as used by the Partitioner

Trait Implementations

impl<B: Clone + BuildHasher> Clone for Partitioner<B>

fn clone(&self) -> Partitioner<B>

Returns a copy of the value.

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

Performs copy-assignment from source.