Documentation ¶
Index ¶
- func DedupeFilter(logger kitlog.Logger, in <-chan *mvccpb.KeyValue) <-chan *mvccpb.KeyValue
- func RetryFold(logger kitlog.Logger, in <-chan *mvccpb.KeyValue, opt RetryFoldOptions, ...) error
- func RevisionFilter(logger kitlog.Logger, in <-chan *mvccpb.KeyValue) <-chan *mvccpb.KeyValue
- func Tap(in <-chan *mvccpb.KeyValue, op func(*mvccpb.KeyValue)) <-chan *mvccpb.KeyValue
- type Filter
- type Operation
- type RetryFoldOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DedupeFilter ¶
DedupeFilter creates a new channel from `in` that emits events provided the value is changed from what was previously seen for that key.
func RetryFold ¶
func RetryFold(logger kitlog.Logger, in <-chan *mvccpb.KeyValue, opt RetryFoldOptions, op Operation) error
RetryFold consumes all kvs from the `in` channel and attempts to run an operation on them, retrying that operation ad-infinitum in case of errors.
func RevisionFilter ¶
RevisionFilter creates a new channel from `in` that emits every received event, provided it preserves ordering of kv ModRevision values on a per-key basis.
Types ¶
Click to show internal directories.
Click to hide internal directories.