Module nakadi_types::subscription

Types for subscribing to an EventType

Re-exports

pub use crate::event_type::EventTypeName;

Structs

ConsumerGroup	The value describing the use case of this subscription.
CursorCommitResult	The result of single cursor commit with the SubscriptionCursor itself.
CursorCommitResults	The result of all cursor commits with the SubscriptionCursors themselves.
CursorToken	An opaque value defined by the server.
EventTypeCursor	Cursor of a subscription without a CursorToken.
EventTypeNames	A collection of EventTypeNames
EventTypePartition	Represents event-type/partition pair.
StreamBatchFlushTimeoutSecs	Maximum time in seconds to wait for the flushing of each chunk (per partition).
StreamBatchLimit	Maximum number of Events in each chunk (and therefore per partition) of the stream.
StreamBatchTimespanSecs	Useful for batching events based on their received_at timestamp.
StreamCommitTimeoutSecs	Maximum amount of seconds that Nakadi will be waiting for commit after sending a batch to a client.
StreamId	The id of this stream generated by Nakadi.
StreamLimit	Maximum number of Events in this stream (over all partitions being streamed in this connection).
StreamMaxUncommittedEvents	The maximum number of uncommitted events that Nakadi will stream before pausing the stream.
StreamParameters	Parameters for starting a new stream on a subscription
StreamTimeoutSecs	Maximum time in seconds a stream will live before connection is closed by the server.
Subscription	Subscription is a high level consumption unit.
SubscriptionAuthorization	Authorization section of a Subscription
SubscriptionCursor	Cursor of a subscription with a CursorToken which is usually found within a SubscriptionEventStreamBatch.
SubscriptionEventTypePartitionStats	Statistics of one partition for an EventType within a context of subscription.
SubscriptionEventTypeStats	Statistics of one EventType within a context of subscription.
SubscriptionEventTypeStatus	The value describing the use case of this subscription.
SubscriptionId	Id of subscription that was created.
SubscriptionInput	A struct to create a Subscription.
SubscriptionInputBuilder	A builder for creating a SubscriptionInput
SubscriptionPartitionStatus	Status of one event-type within a context of subscription
SubscriptionStats

Enums

CommitResult	The result of cursor commit.
PartitionAssignmentType	Assignment type of a partition within a context of subscription
PartitionState	Assignment state of a partition within a context of subscription
ReadFrom	Position to start reading events from. Currently supported values:
SubscriptionPartitionAssignmentType	See also Nakadi Manual
SubscriptionPartitionState	The state of this partition in current subscription.

Traits

EventTypePartitionLike

Something that has an event type and a partition

Type Definitions

SubscriptionCursorWithoutToken

Cursor of a subscription without a CursorToken.