Module pipeline 

Consumer-side pipelining: a subscription settles in a window, and a handler queues its own Redis commands into the delivery’s segment of that window.

• pipeline: RedisPipelineSteps, the .pipeline() step that opens the window.
• atomic: .atomic(), one MULTI / EXEC per delivery.
• Commands: RedisPipeline, the commands a handler queues through keys::Pipeline.
• bind: Bindable, a slot’s publishes in the delivery’s round.
• InRound: InRound, the reply in the delivery’s round.
• Flush: when a window leaves, and what each outcome does to what a handler queued.

Structs

Atomic

The window’s mode after .atomic(): a segment is MULTI, the handler’s commands, the settle, EXEC.

InRound

The reply transform that puts a reply in the round of the delivery it answers.

Pipelined

A subscription source with a window, as the .pipeline() mount step makes it.

PipelinedSubscriber

A pipelined subscription: the form’s own subscriber and the window its deliveries settle in.

Plain

The window’s mode before .atomic(): a segment is the handler’s commands, in the window’s pipeline.

RedisPipeline

The delivery’s own buffer in the window: what a handler queues its Redis commands into.

RoundMessage

A delivery of a .pipeline() subscription.

Traits

AtomicStep

The builder step behind RedisPipelineSteps::atomic.

Bindable

A publisher of this crate, which pipeline.bind(out) can bind to a delivery’s round.

OpensWindow

A subscription source a window can open on: a descriptor of this crate, possibly under the core’s start_at(..) wrapper.

PipelineStep

The builder step behind RedisPipelineSteps::pipeline.

RedisPipelineSteps

The window steps of a mount site: .pipeline() opens a consumer window on the subscription, and .atomic() after it makes each delivery’s segment one MULTI / EXEC.

WindowMode

The two modes of a window, Plain and Atomic.

Windowed

A source that already has a window, which is what .atomic() needs.

Type Aliases

RedisListAtomic

A list subscription with an atomic window: what .pipeline().atomic() at the mount site makes of a RedisList.

RedisListPipeline

A list subscription with a window: what .pipeline() at the mount site makes of a RedisList.

RedisPubSubAtomic

A Pub/Sub channel subscription with an atomic window: what .pipeline().atomic() at the mount site makes of a RedisPubSub.

RedisPubSubPatternAtomic

A Pub/Sub pattern subscription with an atomic window: what .pipeline().atomic() at the mount site makes of a RedisPubSubPattern.

RedisPubSubPatternPipeline

A Pub/Sub pattern subscription with a window: what .pipeline() at the mount site makes of a RedisPubSubPattern.

RedisPubSubPipeline

A Pub/Sub channel subscription with a window: what .pipeline() at the mount site makes of a RedisPubSub.

RedisStreamAtomic

A stream subscription with an atomic window: what .pipeline().atomic() at the mount site makes of a RedisStream.

RedisStreamPipeline

A stream subscription with a window: what .pipeline() at the mount site makes of a RedisStream.