queues

type BoltDbQueue struct {
	Db           *bolt.DB
	ElementTypes []interface{}
	// contains filtered or unexported fields
}

type ChanQueue struct {
	Capacity int
	// contains filtered or unexported fields
}

type ComposeFunc func(q Queue) (Queue, error)

type FilterFunc func(v interface{}) (bool, error)

type ForkJoinFunc func(v interface{}) (map[int]interface{}, error)

type ListQueue struct {
	// contains filtered or unexported fields
}

type MapFunc func(v interface{}) (interface{}, error)

type PartitionFunc func(partition, v interface{}) (interface{}, error)

type Queue interface {
	Open() error
	Close() error
	Enqueue(v interface{}) error
	Dequeue(peek ...bool) (interface{}, bool, error)
}

type ReduceFunc func(acc, v interface{}) (interface{}, error)