Shortcut for creating Aggregate actors.
Shortcut to the args of the current command.
Utility for handling boundary args that wrap around ends of sequences and count backwards when negative.
Client subscriptions to channels.
The current command - normally will be set when a Command arrives via the actor's receive method.
Timeout for a single command.
Flag that enables detailed command debugging.
Retrieves a duration config setting as milliseconds, and handles the value not being a duration value, so we can do something like set it to "off", in which case we default to 0.
Utility for dropping extraneous zeros from floats when converting to strings, for consistency with Redis' INCRBYFLOAT/HINCRBYFLOAT commands and sorted set scores.
Utility for glob-style filtering.
Client subscriptions to patterns.
Sends a message that has been receieved (published) from a client, to all matching subscriptions - either channels, or patterns.
Utility for selecting a random item.
Sends a Response (usually the result of a command) back to the command's destination (usually a ClientNode sending a Command).
Shortcut route method for sending command input without a constructed Command instance, using the state of the current command (eg: db, clientID).
Sends an unrouted Command to one or more KeyNode actors, either by routing by key, or broadcasting to all.
Utility for scan-style commands, namely SCAN/SSCAN/HSCAN/ZSCAN.
Utility for slicing sequences, for commands such as SLICE, GETRANGE, LRANGE, etc.
Stops the actor - we define this shortcut to give subclassing traits the chance to override it and inject extra shutdown behavior that concrete actors need not know about.
Handles subscribe and unsubscribe to both channels and patterns.