package
1.0.5
Repository: https://github.com/cockroachdb/replicator.git
Documentation: pkg.go.dev

# Functions

GoRunner returns a Runner that executes tasks using the go keyword and the specified context.
New construct a Set that executes tasks using the given runner.
NewOutcome is a convenience method to allocate an Outcome.
NewQueue constructs a [Queue].
RetryAtHead returns an error that tasks can use to be retried later, once all preceding tasks have completed.
StatusFor constructs a successful status if err is null.
Wait returns the first non-nil error.

# Structs

A Queue implements an in-order admission queue for arbitrary values associated with a set of potentially-overlapping keys.
RetryAtHeadErr is returned by [RetryAtHead].
Set implements an in-order admission queue for actors requiring exclusive access to a set of keys.
Status is returned by [Set.Schedule].

# Interfaces

A Runner is passed to New to begin the execution of tasks.

# Type aliases

A Callback is provided to [Set.Schedule].