Documentation ¶
Index ¶
- func Client() (*redis.Client, error)
- func ClientByNode(int) (*redis.Client, error)
- func ClientByURI(uri string) (*redis.Client, error)
- func FlushDB(client *redis.Client) error
- func MatchKeys(client *redis.Client, workerID uint8, timezone uint8, now uint32, limit int) ([]models.Subscriber, error)
- func MatchShardHashes(client *redis.Client, workerID uint8, timezone uint8, now uint32, limit int) ([]models.Subscriber, error)
- func StoreKeys(client *redis.Client, subscribers []models.Subscriber) (int, error)
- func StoreShardHashes(client *redis.Client, subscribers []models.Subscriber) (int, error)
- func Update(client *redis.Client, subscribers []models.Subscriber, notifyAfter uint32) (int, error)
- type FlushHandle
- type MatchHandle
- type StoreHandle
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MatchShardHashes ¶
func StoreShardHashes ¶
Types ¶
type FlushHandle ¶
type MatchHandle ¶
type StoreHandle ¶
Click to show internal directories.
Click to hide internal directories.