[−][src]Struct nakadi_types::event_type::EventTypeInput
Definition of an event type
This struct is only used for submitting data to Nakadi.
See also Nakadi Manual
Fields
name: EventTypeName
Name of this EventType. The name is constrained by a regular expression.
Note: the name can encode the owner/responsible for this EventType and ideally should follow a common pattern that makes it easy to read and understand, but this level of structure is not enforced. For example a team name and data type can be used such as ‘acme-team.price-change’.
owning_application: OwningApplication
Indicator of the application owning this EventType.
category: Category
Defines the category of this EventType.
The value set will influence, if not set otherwise, the default set of validations, enrichment-strategies, and the effective schema for validation.
enrichment_strategies: Vec<EnrichmentStrategy>
Determines the enrichment to be performed on an Event upon reception. Enrichment is performed once upon reception (and after validation) of an Event and is only possible on fields that are not defined on the incoming Event.
For event types in categories ‘business’ or ‘data’ it’s mandatory to use metadata_enrichment strategy. For ‘undefined’ event types it’s not possible to use this strategy, since metadata field is not required.
See documentation for the write operation for details on behaviour in case of unsuccessful enrichment.
partition_strategy: PartitionStrategy
Determines how the assignment of the event to a partition should be handled.
partition_key_fields: Option<PartitionKeyFields>
Required when ‘partition_resolution_strategy’ is set to ‘hash’. Must be absent otherwise. Indicates the fields used for evaluation the partition of Events of this type.
If this is set it MUST be a valid required field as defined in the schema.
compatibility_mode: CompatibilityMode
Compatibility mode provides a mean for event owners to evolve their schema, given changes respect the semantics defined by this field.
It’s designed to be flexible enough so that producers can evolve their schemas while not inadvertently breaking existent consumers.
Once defined, the compatibility mode is fixed, since otherwise it would break a predefined contract, declared by the producer.
schema: EventTypeSchemaInput
cleanup_policy: CleanupPolicy
Event type cleanup policy. There are two possible values:
default_statistic: Option<EventTypeStatistics>
Operational statistics for an EventType. This data may be provided by users on Event Type creation. Nakadi uses this object in order to provide an optimal number of partitions from a throughput perspective.
options: Option<EventTypeOptions>
audience: Option<EventTypeAudience>
Implementations
impl EventTypeInput
[src]
pub fn builder() -> EventTypeInputBuilder
[src]
returns a builder with default values
Trait Implementations
impl Clone for EventTypeInput
[src]
pub fn clone(&self) -> EventTypeInput
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for EventTypeInput
[src]
impl<'de> Deserialize<'de> for EventTypeInput
[src]
pub fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
__D: Deserializer<'de>,
[src]
__D: Deserializer<'de>,
impl Serialize for EventTypeInput
[src]
Auto Trait Implementations
impl RefUnwindSafe for EventTypeInput
impl Send for EventTypeInput
impl Sync for EventTypeInput
impl Unpin for EventTypeInput
impl UnwindSafe for EventTypeInput
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> DeserializeOwned for T where
T: for<'de> Deserialize<'de>,
[src]
T: for<'de> Deserialize<'de>,
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,