[−][src]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 |
CursorCommitResults | The result of all cursor commits with the |
CursorToken | An opaque value defined by the server. |
EventTypeCursor | Cursor of a subscription without a |
EventTypeNames | A collection of |
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 |
SubscriptionEventTypePartitionStats | Statistics of one partition for an |
SubscriptionEventTypeStats | Statistics of one |
SubscriptionEventTypeStatus | The value describing the use case of this subscription. |
SubscriptionId | Id of subscription that was created. |
SubscriptionInput | A struct to create a |
SubscriptionInputBuilder | A builder for creating a |
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 |