queue

type Queue ¶

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

Queue implements a simple de-duplicating queue that assumes that when a consumer runs Pop it will finish its job, and that all the Add calls up to the Pop call are fulfilled.

It is safe for concurrent use by multiple goroutines AND processes.

The Queue keeps no memory of Pop-ed names, so the populator is supposed to know when a Pop happened more recently than the event triggering the Add.

func Open(dataSourceName string) (*Queue, error)

func (q *Queue) Add(name, parent string) error

func (q *Queue) Close() error

func (q *Queue) Len() (int, error)

func (q *Queue) Pop() (name, parent string, err error)