Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Comcast/rulio
/ functions
Functions
1,122 in github.com/Comcast/rulio
⨍
Functions
1,122
◇
Types & classes
159
Method
LogLoop
LogLoop starts a loop that logs sys.stats at the given interval. If iterations is negative, the loop is endless. Otherwise the loop terminates after
sys/system.go:657
Method
LogLoop
LogLoop starts a loop that calls stats.Log at the given interval. If iterations is negative, the loop is endless. Otherwise the loop terminates afte
core/stats.go:195
Method
MarshalJSON
()
core/query.go:555
Method
MarshalJSON
()
core/query.go:626
Method
MarshalJSON
()
core/query.go:703
Method
MarshalJSON
()
core/query.go:821
Method
MarshalJSON
()
core/rules.go:139
Method
MarshalJSON
()
core/util.go:170
Function
Match
Match provides backwards compatibility around the Matcher interface.
core/match.go:26
Method
Match
Match implements the Matcher interface.
core/match.go:56
Method
Match
Match implements the Matcher interface.
core/match.go:72
Method
Metric
Metric implements part of the Logger interface.
core/loggers.go:66
Method
Modify
Modify allows you to change the Throttle's specifications. You can also change the embedded Breaker using 'Adjust()'.
core/breaker.go:524
Method
Next
()
tools/sim/gen.go:232
Function
OverlayControl
OverlayControl parses the given JSON as a SystemControl, which is then added to the given control.
sys/system.go:516
Function
ParseJSONString
ParseJSONString parses a map from a string.
core/util.go:48
Function
ParseLocationTTL
ParseLocationTTL tries to parse a duration. "never" parses to 'Never' and "forever" parses to 'Forever'. Otherwise you should provide a duration in '
sys/system.go:331
Method
Pause
Pause the instance for c.PauseDuration.
cron/cron.go:261
Method
Pending
Pending reports how many throttle submissions are pending. Also returns the load (relative to the maximum pending submissions).
core/breaker.go:513
Method
PendingCount
PendingCount returns the number of known cron jobs.
cron/cron.go:231
Method
Persistent
()
cron/croltglue.go:179
Method
Persistent
()
cron/internal.go:108
Method
ProcessBindings
(ctx *Context, bs Bindings)
core/query_test.go:557
Method
ProcessBindings
(ctx *Context, bs Bindings)
core/events_test.go:217
Method
ProcessBindings
(ctx *Context, bs Bindings)
core/http_test.go:152
Method
ProcessQuery
(ctx *Context, m map[string]interface{}, q Query)
core/query_test.go:548
Method
ProcessQuery
(_ *Context, _ map[string]interface{}, q Query)
core/events_test.go:231
Method
ProcessQuery
(_ *Context, _ map[string]interface{}, q Query)
core/http_test.go:160
Function
Profile
Profile starts CPU and memory profiling and returns a function that will stop that. Writes "cpu" + filename and "mem" + filename. Usage: defer Pro
core/util.go:308
Method
Rem
Rem removes the job with the given id from crolt. The boolean return value isn't particularly meaningful (yet?).
cron/croltglue.go:153
Method
Rem
(ctx *core.Context, id string)
cron/internal.go:104
Method
Rem
(ctx *Context, id string)
core/state_linear.go:197
Method
Rem
(ctx *Context, id string)
core/state_indexed.go:387
Method
Rem
Rem does what you'd think.
core/util.go:100
Method
RemHook
(hook RemHookFn)
core/state_linear.go:97
Method
RemHook
(hook RemHookFn)
core/state_indexed.go:122
Method
RemProp
(ctx *Context, id string, prop string)
core/location.go:274
Method
Remove
(ctx *Context, loc string, k []byte)
core/storage_none.go:36
Method
Remove
Remove removes the given data from DynamoDB. If 'CheckLastUpdated' is true, this function attempts to verify that the state in DynamoDB hasn't change
storage/dynamodb/dynamodb.go:531
Method
Remove
(ctx *Context, loc string, k []byte)
storage/cassandra/cassandra.go:266
Method
Remove
Remove a pair from a location, we only care about the key
storage/bolt/bolt.go:94
Method
Reset
Reset resets all fields to zeros. Stores are done with atomics, so ...
core/stats.go:86
Method
Reset
Reset clears the breaker's state (but does not change its capacity).
core/breaker.go:227
Method
Resume
Resume broadcasts that command to all Cron instances with this broadcaster.
cron/cron.go:97
Method
RetryEventWork
(ctx *Context, work *FindRules)
core/events.go:467
Function
RuleToJSON
RuleToJSON generates a JSON representation of the given rule.
core/rules.go:196
Method
RunJavascript
(ctx *Context, code string, libraries []string, bs *Bindings, props map[string]interface{})
core/location.go:870
Method
RuntimeLogLoop
RuntimeLogLoop runs a loop that logs Go runtime stats. The "scope" parameter is opaque. Might be useful in downstream log/metric processing.
sys/system.go:594
Method
Schedule
Schedule is a generic scheduler for HTTP request work.
cron/generic.go:103
Method
ScheduleEvent
ScheduleEvent packages up a ProcessEvent call for the simple rules HTTP API.
cron/croltglue.go:65
Method
ScheduleEvent
(ctx *core.Context, se *ScheduledEvent)
cron/internal.go:37
Method
Search
(t time.Time)
cron/cron.go:160
Method
Search
(ctx *Context, pattern Map)
core/state_linear.go:268
Method
Search
Search queries the term index for the given pattern (represented as JSON). Obtains and releases the FDS mutex.
core/state_indexed.go:606
Method
SearchRules
(ctx *Context, event Map, includeInherited bool)
core/location.go:683
Method
ServeHTTP
(w http.ResponseWriter, r *http.Request)
service/httpd.go:396
Method
Server
(ctx *Context)
storage/dynamodb/dynamodb.go:358
Function
ServiceAvailable
ToDo: EnableLocation(location string, enabled bool) ToDo: LocationEnabled(location string) bool ToDo: QuitLocation(location string) ServiceAvailable c
sys/system.go:1521
Method
SetReadOnly
(ctx *Context, readOnly bool)
core/location.go:115
Method
SetValue
SetValue just exists for backwards compatibility. Just calls AddProp().
core/context.go:143
Method
Stable
()
tools/sim/percentiles.go:27
Method
StartProfileCPU
StartProfileCPU starts pprof cpu.
sys/system.go:1423
Method
StartSpan
(opName string)
core/context.go:250
Method
Status
Rate reports the load (1.0 = 100%), current count, the breaker's interval, and whether the breaker is closed (good: true) or open (bad: false).
core/breaker.go:213
Method
StopSpan
()
core/context.go:258
Method
String
()
core/errors.go:56
Method
String
()
core/errors.go:71
Method
String
()
core/errors.go:91
Method
String
()
core/errors.go:112
Method
Suspend
Suspend broadcasts that command to all Cron instances with this broadcaster.
cron/cron.go:88
Method
Swap
(i, j int)
cron/cron.go:152
Method
Swap
(i, j int)
core/patternindex.go:197
Function
SystemForTest
(name string)
sys/system.go:529
Method
Table
(ctx *Context)
storage/dynamodb/dynamodb.go:362
Method
Temporary
()
service/httpd.go:154
Function
TestActionCodeBase64Encoding
(t *testing.T)
core/actions_test.go:183
Function
TestActionInterpreters
(t *testing.T)
core/actions_test.go:145
Function
TestAnIpAddresses
(t *testing.T)
core/util_test.go:433
Function
TestAndQueryFromMapBad1
(t *testing.T)
core/query_test.go:451
Function
TestAndQueryFromMapBad2
(t *testing.T)
core/query_test.go:459
Function
TestAndQueryFromMapGood
(t *testing.T)
core/query_test.go:468
Function
TestAppProcessQuery
(t *testing.T)
core/query_test.go:565
Function
TestBadStatelessWithExternalCron
(t *testing.T)
sys/system_test.go:547
Function
TestBindingsWarningLimit
(t *testing.T)
core/location_test.go:215
Function
TestCPULoad
(t *testing.T)
core/breaker_test.go:61
Function
TestCPULoadProbe
(t *testing.T)
core/breaker_test.go:72
Function
TestCache
(t *testing.T)
core/cache_test.go:25
Function
TestCacheZero
(t *testing.T)
core/cache_test.go:88
Function
TestCast
(t *testing.T)
core/match_test.go:9
Function
TestChooseEmit
(t *testing.T)
tools/sim/gen_test.go:9
Function
TestCodeQueryFromMapBad
(t *testing.T)
core/query_test.go:394
Function
TestCodeQueryFromMapBadArray
(t *testing.T)
core/query_test.go:426
Function
TestCodeQueryFromMapGoodArray1
(t *testing.T)
core/query_test.go:410
Function
TestCodeQueryFromMapGoodArray2
(t *testing.T)
core/query_test.go:418
Function
TestCodeQueryFromMapGoodSimple
(t *testing.T)
core/query_test.go:402
Function
TestCoerceFakeFloats
(t *testing.T)
core/util_test.go:367
Function
TestComboBreaker
(t *testing.T)
core/breaker_test.go:98
Function
TestCommandSpec
(t *testing.T)
core/javascript_test.go:220
Function
TestContextWithLocation
TextContextWithLocation creates a location with indexed state on memory storage. Also returns a Context with its location se.
core/util.go:396
Function
TestControlCopy
(t *testing.T)
core/control_test.go:23
← previous
next →
801–900 of 1,122, ranked by callers