redgrease
latest
Contents:
Introduction
Quickstart Guide
RedGrease Client
Executing Gear Functions
Builtin Runtime Functions
GearFunction
Operations
Actions
Operation Callback Types
Serverside Redis Commands
Syntactic Sugar
Command Line Tool
Utils Module
Typing Module
Data Module
Advanced Concepts
Support
Contribute
redgrease
»
Index
Edit on GitHub
Index
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
K
|
L
|
M
|
N
|
O
|
P
|
R
|
S
|
T
|
U
|
V
|
W
|
Z
A
Abort (redgrease.FailurePolicy attribute)
(redgrease.sugar.FailurePolicy attribute)
aborted (redgrease.data.ExecutionStatus attribute)
,
[1]
abortexecution() (redgrease.Gears method)
Accumulate (class in redgrease.gears)
accumulate() (redgrease.gears.OpenGearFunction method)
(redgrease.runtime.GearsBuilder method)
Accumulator (in module redgrease.typing)
,
[1]
Aggregate (class in redgrease.gears)
aggregate() (redgrease.gears.OpenGearFunction method)
(redgrease.runtime.GearsBuilder method)
AggregateBy (class in redgrease.gears)
aggregateby() (redgrease.gears.OpenGearFunction method)
(redgrease.runtime.GearsBuilder method)
apply() (redgrease.reader.CommandReader method)
arg (redgrease.data.ExecutionStep attribute)
,
[1]
(redgrease.gears.Run attribute)
args (redgrease.data.RegData attribute)
,
[1]
args() (redgrease.reader.CommandReader method)
as_is() (in module redgrease.utils)
,
[1]
Async (redgrease.sugar.TriggerMode attribute)
(redgrease.TriggerMode attribute)
AsyncLocal (redgrease.sugar.TriggerMode attribute)
(redgrease.TriggerMode attribute)
atomic (class in redgrease.runtime)
Avg (class in redgrease.gears)
avg() (redgrease.gears.OpenGearFunction method)
(redgrease.runtime.GearsBuilder method)
B
BatchGroupBy (class in redgrease.gears)
batchgroupby() (redgrease.gears.OpenGearFunction method)
(redgrease.runtime.GearsBuilder method)
BatchReducer (in module redgrease.typing)
,
[1]
bool_ok() (in module redgrease.utils)
,
[1]
C
CaseInsensitiveDict (class in redgrease.utils)
,
[1]
ClosedGearFunction (class in redgrease.gears)
Cluster (redgrease.data.ExecLocality attribute)
ClusterInfo (class in redgrease.data)
,
[1]
Collect (class in redgrease.gears)
collect (redgrease.gears.Register attribute)
(redgrease.gears.Run attribute)
collect() (redgrease.gears.OpenGearFunction method)
(redgrease.runtime.GearsBuilder method)
combOp (redgrease.gears.Aggregate attribute)
(redgrease.gears.AggregateBy attribute)
command() (in module redgrease)
CommandReader (class in redgrease.reader)
(redgrease.ReaderType attribute)
(redgrease.sugar.ReaderType attribute)
CompiledOs (redgrease.data.PyRequirementInfo attribute)
,
[1]
compose() (in module redgrease.utils)
,
[1]
Config (class in redgrease.config)
configGet() (in module redgrease.runtime)
Constructor (in module redgrease.typing)
constructor() (redgrease.sugar.KeyType static method)
Continue (redgrease.FailurePolicy attribute)
(redgrease.sugar.FailurePolicy attribute)
continueFail() (redgrease.runtime.gearsFuture method)
continueRun() (redgrease.runtime.gearsFuture method)
convertToStr (redgrease.gears.Register attribute)
(redgrease.gears.Run attribute)
Count (class in redgrease.gears)
count() (redgrease.gears.OpenGearFunction method)
(redgrease.runtime.GearsBuilder method)
CountBy (class in redgrease.gears)
countby() (redgrease.gears.OpenGearFunction method)
(redgrease.runtime.GearsBuilder method)
created (redgrease.data.ExecutionStatus attribute)
,
[1]
CreateVenv (redgrease.config.Config property)
CurrAllocated (redgrease.data.PyStats attribute)
,
[1]
D
Debug (redgrease.LogLevel attribute)
(redgrease.sugar.LogLevel attribute)
DependenciesSha256 (redgrease.config.Config property)
DependenciesUrl (redgrease.config.Config property)
desc (redgrease.data.Registration attribute)
,
[1]
dict_filter() (in module redgrease.utils)
,
[1]
dict_of() (in module redgrease.utils)
,
[1]
Distinct (class in redgrease.gears)
distinct() (redgrease.gears.OpenGearFunction method)
(redgrease.runtime.GearsBuilder method)
done (redgrease.data.ExecutionStatus attribute)
,
[1]
DownloadDeps (redgrease.config.Config property)
dropexecution() (redgrease.Gears method)
dumpexecutions() (redgrease.Gears method)
dumpregistrations() (redgrease.Gears method)
duration (redgrease.data.ExecutionStep attribute)
,
[1]
E
errors (redgrease.data.ExecutionPlan attribute)
,
[1]
(redgrease.data.ExecutionResult property)
event (redgrease.utils.Record attribute)
,
[1]
(redgrease.utils.StreamRecord attribute)
,
[1]
ExecID (class in redgrease.data)
,
[1]
ExecLocality (class in redgrease.data)
,
[1]
execute() (in module redgrease.runtime)
executionId (redgrease.data.ExecutionInfo attribute)
,
[1]
ExecutionInfo (class in redgrease.data)
,
[1]
ExecutionMaxIdleTime (redgrease.config.Config property)
ExecutionPlan (class in redgrease.data)
,
[1]
ExecutionResult (class in redgrease.data)
,
[1]
ExecutionStatus (class in redgrease.data)
,
[1]
ExecutionStep (class in redgrease.data)
,
[1]
ExecutionThreadPool (redgrease.data.Registration attribute)
ExecutionThreads (redgrease.config.Config property)
Expander (in module redgrease.typing)
,
[1]
Extractor (in module redgrease.typing)
,
[1]
extractor (redgrease.gears.AggregateBy attribute)
(redgrease.gears.Avg attribute)
(redgrease.gears.BatchGroupBy attribute)
(redgrease.gears.CountBy attribute)
(redgrease.gears.GroupBy attribute)
(redgrease.gears.LocalGroupBy attribute)
F
FailurePolicy (class in redgrease.sugar)
Filter (class in redgrease.gears)
filter() (redgrease.gears.OpenGearFunction method)
(redgrease.runtime.GearsBuilder method)
Filterer (in module redgrease.typing)
,
[1]
FlatMap (class in redgrease.gears)
flatmap() (redgrease.gears.OpenGearFunction method)
(redgrease.runtime.GearsBuilder method)
ForEach (class in redgrease.gears)
foreach() (redgrease.gears.OpenGearFunction method)
(redgrease.runtime.GearsBuilder method)
from_redis() (redgrease.data.RedisObject class method)
,
[1]
G
Gear Function
GearFunction
gearfunction (redgrease.runtime.GearsBuilder property)
GearReqVersion (redgrease.data.PyRequirementInfo attribute)
,
[1]
GearsBuilder (class in redgrease.runtime)
gearsConfigGet() (in module redgrease.runtime)
gearsFuture (class in redgrease.runtime)
get() (redgrease.config.Config method)
(redgrease.utils.CaseInsensitiveDict method)
,
[1]
get_single() (redgrease.config.Config method)
getexecution() (redgrease.Gears method)
getresults() (redgrease.Gears method)
GroupBy (class in redgrease.gears)
groupby() (redgrease.gears.OpenGearFunction method)
(redgrease.runtime.GearsBuilder method)
H
Hash (redgrease.KeyType attribute)
(redgrease.sugar.KeyType attribute)
hashtag() (in module redgrease.runtime)
hashtag3() (in module redgrease.runtime)
I
id (redgrease.data.Registration attribute)
,
[1]
(redgrease.data.ShardInfo attribute)
,
[1]
infocluster() (redgrease.Gears method)
InputRecord (in module redgrease.typing)
ip (redgrease.data.ShardInfo attribute)
,
[1]
IsDownloaded (redgrease.data.PyRequirementInfo attribute)
,
[1]
IsInstalled (redgrease.data.PyRequirementInfo attribute)
,
[1]
K
Key (in module redgrease.typing)
key (redgrease.utils.Record attribute)
,
[1]
(redgrease.utils.StreamRecord attribute)
,
[1]
keys() (redgrease.reader.KeysReader method)
(redgrease.reader.StreamReader method)
KeysOnlyReader (class in redgrease.reader)
(redgrease.ReaderType attribute)
(redgrease.sugar.ReaderType attribute)
KeysReader (class in redgrease.reader)
(redgrease.ReaderType attribute)
(redgrease.sugar.ReaderType attribute)
KeyType (class in redgrease.sugar)
L
lastError (redgrease.data.RegData attribute)
,
[1]
length (redgrease.gears.Limit attribute)
Limit (class in redgrease.gears)
limit() (redgrease.gears.OpenGearFunction method)
(redgrease.runtime.GearsBuilder method)
List (redgrease.KeyType attribute)
(redgrease.sugar.KeyType attribute)
list_of_str() (in module redgrease.utils)
list_parser() (in module redgrease.utils)
,
[1]
LocalGroupBy (class in redgrease.gears)
localgroupby() (redgrease.gears.OpenGearFunction method)
(redgrease.runtime.GearsBuilder method)
log() (in module redgrease.runtime)
LogLevel (class in redgrease.sugar)
M
Map (class in redgrease.gears)
map() (redgrease.gears.OpenGearFunction method)
(redgrease.runtime.GearsBuilder method)
Mapper (in module redgrease.typing)
,
[1]
MaxExecutions (redgrease.config.Config property)
MaxExecutionsPerRegistration (redgrease.config.Config property)
maxHslot (redgrease.data.ShardInfo attribute)
,
[1]
minHslot (redgrease.data.ShardInfo attribute)
,
[1]
mode (redgrease.data.RegData attribute)
,
[1]
(redgrease.gears.Register attribute)
module
redgrease.data
,
[1]
redgrease.sugar
redgrease.typing
redgrease.utils
,
[1]
Module (redgrease.KeyType attribute)
(redgrease.sugar.KeyType attribute)
my_id (redgrease.data.ClusterInfo attribute)
,
[1]
my_run_id (redgrease.data.ClusterInfo attribute)
N
name (redgrease.data.ExecutionStep attribute)
,
[1]
Name (redgrease.data.PyRequirementInfo attribute)
,
[1]
Notice (redgrease.LogLevel attribute)
(redgrease.sugar.LogLevel attribute)
numAborted (redgrease.data.RegData attribute)
,
[1]
numFailures (redgrease.data.RegData attribute)
,
[1]
numSuccess (redgrease.data.RegData attribute)
,
[1]
numTriggered (redgrease.data.RegData attribute)
,
[1]
O
of() (redgrease.sugar.KeyType static method)
on() (redgrease.ClosedGearFunction method)
(redgrease.gears.ClosedGearFunction method)
,
[1]
onRegistered (redgrease.gears.Register attribute)
op (redgrease.gears.FlatMap attribute)
(redgrease.gears.Map attribute)
OpenGearFunction (class in redgrease.gears)
optional() (in module redgrease.utils)
,
[1]
OutputRecord (in module redgrease.typing)
P
parse() (redgrease.data.ClusterInfo static method)
,
[1]
(redgrease.data.ExecID static method)
,
[1]
(redgrease.data.ExecutionPlan static method)
,
[1]
parse_execute_response() (in module redgrease.data)
,
[1]
parse_PD() (in module redgrease.data)
,
[1]
parse_trigger_response() (in module redgrease.data)
,
[1]
passfun() (in module redgrease.utils)
,
[1]
PD (redgrease.data.Registration attribute)
,
[1]
PeakAllocated (redgrease.data.PyStats attribute)
,
[1]
pending_cluster (redgrease.data.ExecutionStatus attribute)
,
[1]
pending_receive (redgrease.data.ExecutionStatus attribute)
,
[1]
pending_run (redgrease.data.ExecutionStatus attribute)
,
[1]
pending_termination (redgrease.data.ExecutionStatus attribute)
,
[1]
pendingMessages (redgrease.data.ShardInfo attribute)
,
[1]
port (redgrease.data.ShardInfo attribute)
,
[1]
prefix (redgrease.gears.Register attribute)
Processor (in module redgrease.typing)
,
[1]
ProfileExecutions (redgrease.config.Config property)
pydumpreqs() (redgrease.Gears method)
pyexecute() (redgrease.Gears method)
,
[1]
PyRequirementInfo (class in redgrease.data)
,
[1]
PyStats (class in redgrease.data)
,
[1]
pystats() (redgrease.Gears method)
PythonAttemptTraceback (redgrease.config.Config property)
PythonInstallationDir (redgrease.config.Config property)
PythonInstallReqMaxIdleTime (redgrease.config.Config property)
PythonReader (class in redgrease.reader)
(redgrease.ReaderType attribute)
(redgrease.sugar.ReaderType attribute)
R
read_duration (redgrease.data.ExecutionPlan attribute)
,
[1]
reader (redgrease.data.Registration attribute)
,
[1]
(redgrease.runtime.GearsBuilder property)
ReaderType (class in redgrease.sugar)
Record (class in redgrease.utils)
,
[1]
(in module redgrease.typing)
record() (in module redgrease.utils)
,
[1]
records() (redgrease.reader.KeysReader method)
(redgrease.reader.StreamReader method)
redgrease.data
module
,
[1]
redgrease.sugar
module
redgrease.typing
module
redgrease.utils
module
,
[1]
redis (redgrease.config.Config attribute)
RedisKey (in module redgrease.typing)
RedisObject (class in redgrease.data)
,
[1]
RedisType (in module redgrease.typing)
Reducer (in module redgrease.typing)
,
[1]
reducer (redgrease.gears.BatchGroupBy attribute)
(redgrease.gears.GroupBy attribute)
(redgrease.gears.LocalGroupBy attribute)
refreshcluster() (redgrease.Gears method)
RegData (class in redgrease.data)
,
[1]
Register (class in redgrease.gears)
register() (redgrease.gears.OpenGearFunction method)
(redgrease.runtime.GearsBuilder method)
registered (redgrease.data.ExecutionInfo attribute)
,
[1]
Registration (class in redgrease.data)
,
[1]
RegistrationData (redgrease.data.Registration attribute)
,
[1]
Registrator (in module redgrease.typing)
,
[1]
Repartition (class in redgrease.gears)
repartition() (redgrease.gears.OpenGearFunction method)
(redgrease.runtime.GearsBuilder method)
results (redgrease.data.ExecutionPlan attribute)
,
[1]
Retry (redgrease.FailurePolicy attribute)
(redgrease.sugar.FailurePolicy attribute)
reverse (redgrease.gears.Sort attribute)
Run (class in redgrease.gears)
run() (redgrease.gears.OpenGearFunction method)
(redgrease.runtime.GearsBuilder method)
runid (redgrease.data.ShardInfo attribute)
,
[1]
running (redgrease.data.ExecutionStatus attribute)
,
[1]
S
safe_bool() (in module redgrease.utils)
,
[1]
safe_str() (in module redgrease.utils)
,
[1]
safe_str_upper() (in module redgrease.utils)
,
[1]
SafeType (in module redgrease.typing)
SendMsgRetries (redgrease.config.Config property)
seqOp (redgrease.gears.Aggregate attribute)
(redgrease.gears.AggregateBy attribute)
sequence (redgrease.data.ExecID attribute)
,
[1]
,
[2]
Set (redgrease.KeyType attribute)
(redgrease.sugar.KeyType attribute)
set() (redgrease.config.Config method)
Shard (redgrease.data.ExecLocality attribute)
shard_id (redgrease.data.ExecID attribute)
,
[1]
,
[2]
ShardInfo (class in redgrease.data)
,
[1]
shards (redgrease.data.ClusterInfo attribute)
,
[1]
shards_completed (redgrease.data.ExecutionPlan attribute)
,
[1]
shards_received (redgrease.data.ExecutionPlan attribute)
,
[1]
ShardsIDReader (class in redgrease.reader)
(redgrease.ReaderType attribute)
(redgrease.sugar.ReaderType attribute)
Sort (class in redgrease.gears)
sort() (redgrease.gears.OpenGearFunction method)
(redgrease.runtime.GearsBuilder method)
start (redgrease.gears.Limit attribute)
status (redgrease.data.ExecutionInfo attribute)
,
[1]
(redgrease.data.ExecutionPlan attribute)
,
[1]
(redgrease.data.RegData attribute)
,
[1]
steps (redgrease.data.ExecutionPlan attribute)
,
[1]
str_if_bytes() (in module redgrease.utils)
,
[1]
Stream (redgrease.KeyType attribute)
(redgrease.sugar.KeyType attribute)
stream_record() (in module redgrease.utils)
,
[1]
StreamReader (class in redgrease.reader)
(redgrease.ReaderType attribute)
(redgrease.sugar.ReaderType attribute)
StreamRecord (class in redgrease.utils)
,
[1]
String (redgrease.KeyType attribute)
(redgrease.sugar.KeyType attribute)
SupportedType (in module redgrease.typing)
supports_batch_mode (redgrease.runtime.GearsBuilder property)
supports_event_mode (redgrease.runtime.GearsBuilder property)
Sync (redgrease.sugar.TriggerMode attribute)
(redgrease.TriggerMode attribute)
T
to_bytes() (in module redgrease.utils)
to_dict() (in module redgrease.utils)
,
[1]
to_int_if_bool() (in module redgrease.utils)
,
[1]
to_kwargs() (in module redgrease.utils)
,
[1]
to_list() (in module redgrease.utils)
,
[1]
to_logging_level() (redgrease.sugar.LogLevel static method)
to_redis_type() (in module redgrease.utils)
,
[1]
total_duration (redgrease.data.ExecutionPlan attribute)
,
[1]
TotalAllocated (redgrease.data.PyStats attribute)
,
[1]
transform() (in module redgrease.utils)
,
[1]
trigger() (redgrease.Gears method)
TriggerMode (class in redgrease.sugar)
type (redgrease.data.ExecutionStep attribute)
,
[1]
(redgrease.utils.Record attribute)
,
[1]
(redgrease.utils.StreamRecord attribute)
,
[1]
U
unixSocket (redgrease.data.ShardInfo attribute)
,
[1]
unregister() (redgrease.Gears method)
update() (redgrease.utils.CaseInsensitiveDict method)
,
[1]
V
Val (in module redgrease.typing)
value (redgrease.data.ExecutionResult property)
,
[1]
(redgrease.utils.Record attribute)
,
[1]
(redgrease.utils.StreamRecord attribute)
,
[1]
values() (redgrease.reader.KeysReader method)
(redgrease.reader.StreamReader method)
ValueTypes (redgrease.config.Config attribute)
Verbose (redgrease.LogLevel attribute)
(redgrease.sugar.LogLevel attribute)
W
Warning (redgrease.LogLevel attribute)
(redgrease.sugar.LogLevel attribute)
Wheels (redgrease.data.PyRequirementInfo attribute)
,
[1]
Z
zero (redgrease.gears.Aggregate attribute)
(redgrease.gears.AggregateBy attribute)
ZSet (redgrease.KeyType attribute)
(redgrease.sugar.KeyType attribute)
Read the Docs
v: latest
Versions
latest
docs
Downloads
pdf
On Read the Docs
Project Home
Builds