aerospike

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

const (
	Namespace = "rtb"
	SetName   = "subscribers"
)

Functions

func Client

func Client() (*aerospike.Client, error)

func Generate

func Generate(shift, workerCount, timezoneCount int, startNotifyAfter uint32, limit int) []aerospike.Subscriber

func Index

func Index(client *aerospike.Client) error

func Match

func Match(client *aerospike.Client, workerID, timezone uint8, notifyAfter uint32, limit int) ([]models.Subscriber, error)

func Store

func Store(client *aerospike.Client, subscriber models.Subscriber) error

func StoreBatch

func StoreBatch(client *aerospike.Client, subscribers []models.Subscriber) error