package
2.5.1
Repository: https://github.com/datawire/ambassador.git
Documentation: pkg.go.dev

# Functions

NewQueue constructs a new queue with the supplied timeout.

# Structs

The Queue struct implements a multi-writer/multi-reader concurrent queue where the dequeue operation (the Get() method) takes a predicate that allows it to skip past queue entries until it finds one that satisfies the specified predicate.