Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
Queue is a single-reader, multi-writer distributed queue.
func (*Queue) AdvanceEpoch ¶
AdvanceEpoch submits an advance epoch request into the queue.
func (*Queue) StartReceiving ¶
func (q *Queue) StartReceiving(processFunc queue.ProcessKeyValueFunc, advanceFunc queue.AdvanceEpochFunc) (queue.Receiver, error)
StartReceiving starts receiving queue enqueued items. This function should be called as a Go routine.
Source Files
Click to show internal directories.
Click to hide internal directories.