queue

type Item struct {
	ID       []byte `bson:"_id"`
	Payload  []byte `bson:"payload"`
	Overflow bool   `bson:"overflow"`
}

type MongoStore struct {
	S *mgo.Session
	C *mgo.Collection
}

type Queue struct {
	S Store
	C chan Item
	// contains filtered or unexported fields
}

type Store interface {
	Init() (err error)
	Get() (item Item, err error)
	GetItems(count int) (items []Item, err error)
	Put(item Item) (err error)
	Del(item Item) (err error)
	Size() (n int, err error)
}