Documentation
¶
Index ¶
- Constants
- func Client() (*aerospike.Client, error)
- func Generate(shift, workerCount, timezoneCount int, startNotifyAfter uint32, limit int) []aerospike.Subscriber
- func Index(client *aerospike.Client) error
- func Match(client *aerospike.Client, workerID, timezone uint8, notifyAfter uint32, ...) ([]models.Subscriber, error)
- func Store(client *aerospike.Client, subscriber models.Subscriber) error
- func StoreBatch(client *aerospike.Client, subscribers []models.Subscriber) error
Constants ¶
View Source
const ( Namespace = "rtb" SetName = "subscribers" )
Variables ¶
This section is empty.
Functions ¶
func Generate ¶
func Generate(shift, workerCount, timezoneCount int, startNotifyAfter uint32, limit int) []aerospike.Subscriber
func Store ¶
func Store(client *aerospike.Client, subscriber models.Subscriber) error
func StoreBatch ¶
func StoreBatch(client *aerospike.Client, subscribers []models.Subscriber) error
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.