Documentation
¶
Index ¶
- func Client() (*mongo.Client, error)
- func Collection(client *mongo.Client) *mongo.Collection
- func Drop(collection *mongo.Collection) error
- func Fill(collection *mongo.Collection, subscribers []mongodb.Subscriber) error
- func FillBatch(collection *mongo.Collection, subscribers []mongodb.Subscriber) error
- func FillBatchParallel(subscribers []mongodb.Subscriber) error
- func Generate(shift int32, workerCount, timezoneCount, limit int) []mongodb.Subscriber
- func Index(collection *mongo.Collection) error
- func Match(dst []mongodb.Subscriber, collection *mongo.Collection, workerID int, ...) ([]mongodb.Subscriber, error)
- func Max(collection *mongo.Collection) (uint32, error)
- func Update(collection *mongo.Collection, ids []int32, notifyAfter int32) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Collection ¶
func Collection(client *mongo.Client) *mongo.Collection
func Drop ¶
func Drop(collection *mongo.Collection) error
func Fill ¶
func Fill(collection *mongo.Collection, subscribers []mongodb.Subscriber) error
func FillBatch ¶
func FillBatch(collection *mongo.Collection, subscribers []mongodb.Subscriber) error
func FillBatchParallel ¶
func FillBatchParallel(subscribers []mongodb.Subscriber) error
func Generate ¶
func Generate(shift int32, workerCount, timezoneCount, limit int) []mongodb.Subscriber
func Index ¶
func Index(collection *mongo.Collection) error
func Match ¶
func Match(dst []mongodb.Subscriber, collection *mongo.Collection, workerID int, timezones []int, now int32, limit int) ([]mongodb.Subscriber, error)
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.