Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
func NewManager ¶
func NewManager(cmdWatchSubscriptionChan chan WatchSubscription, cmdWatchChan chan dstore.CmdWatchEvent) *Manager
type WatchSubscription ¶
type WatchSubscription struct {
Subscribe bool // Subscribe is true for subscribe, false for unsubscribe. Required.
AdhocReqChan chan *cmd.DiceDBCmd // AdhocReqChan is the channel to send adhoc requests to the io-thread. Required.
WatchCmd *cmd.DiceDBCmd // WatchCmd Represents a unique key for each watch artifact, only populated for subscriptions.
Fingerprint uint32 // Fingerprint is a unique identifier for each watch artifact, only populated for unsubscriptions.
}
Click to show internal directories.
Click to hide internal directories.