MCPcopy Create free account

hub / github.com/Comcast/rulio / functions

Functions1,122 in github.com/Comcast/rulio

MethodLogLoop
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
MethodLogLoop
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
MethodMarshalJSON
()
core/query.go:555
MethodMarshalJSON
()
core/query.go:626
MethodMarshalJSON
()
core/query.go:703
MethodMarshalJSON
()
core/query.go:821
MethodMarshalJSON
()
core/rules.go:139
MethodMarshalJSON
()
core/util.go:170
FunctionMatch
Match provides backwards compatibility around the Matcher interface.
core/match.go:26
MethodMatch
Match implements the Matcher interface.
core/match.go:56
MethodMatch
Match implements the Matcher interface.
core/match.go:72
MethodMetric
Metric implements part of the Logger interface.
core/loggers.go:66
MethodModify
Modify allows you to change the Throttle's specifications. You can also change the embedded Breaker using 'Adjust()'.
core/breaker.go:524
MethodNext
()
tools/sim/gen.go:232
FunctionOverlayControl
OverlayControl parses the given JSON as a SystemControl, which is then added to the given control.
sys/system.go:516
FunctionParseJSONString
ParseJSONString parses a map from a string.
core/util.go:48
FunctionParseLocationTTL
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
MethodPause
Pause the instance for c.PauseDuration.
cron/cron.go:261
MethodPending
Pending reports how many throttle submissions are pending. Also returns the load (relative to the maximum pending submissions).
core/breaker.go:513
MethodPendingCount
PendingCount returns the number of known cron jobs.
cron/cron.go:231
MethodPersistent
()
cron/croltglue.go:179
MethodPersistent
()
cron/internal.go:108
MethodProcessBindings
(ctx *Context, bs Bindings)
core/query_test.go:557
MethodProcessBindings
(ctx *Context, bs Bindings)
core/events_test.go:217
MethodProcessBindings
(ctx *Context, bs Bindings)
core/http_test.go:152
MethodProcessQuery
(ctx *Context, m map[string]interface{}, q Query)
core/query_test.go:548
MethodProcessQuery
(_ *Context, _ map[string]interface{}, q Query)
core/events_test.go:231
MethodProcessQuery
(_ *Context, _ map[string]interface{}, q Query)
core/http_test.go:160
FunctionProfile
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
MethodRem
Rem removes the job with the given id from crolt. The boolean return value isn't particularly meaningful (yet?).
cron/croltglue.go:153
MethodRem
(ctx *core.Context, id string)
cron/internal.go:104
MethodRem
(ctx *Context, id string)
core/state_linear.go:197
MethodRem
(ctx *Context, id string)
core/state_indexed.go:387
MethodRem
Rem does what you'd think.
core/util.go:100
MethodRemHook
(hook RemHookFn)
core/state_linear.go:97
MethodRemHook
(hook RemHookFn)
core/state_indexed.go:122
MethodRemProp
(ctx *Context, id string, prop string)
core/location.go:274
MethodRemove
(ctx *Context, loc string, k []byte)
core/storage_none.go:36
MethodRemove
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
MethodRemove
(ctx *Context, loc string, k []byte)
storage/cassandra/cassandra.go:266
MethodRemove
Remove a pair from a location, we only care about the key
storage/bolt/bolt.go:94
MethodReset
Reset resets all fields to zeros. Stores are done with atomics, so ...
core/stats.go:86
MethodReset
Reset clears the breaker's state (but does not change its capacity).
core/breaker.go:227
MethodResume
Resume broadcasts that command to all Cron instances with this broadcaster.
cron/cron.go:97
MethodRetryEventWork
(ctx *Context, work *FindRules)
core/events.go:467
FunctionRuleToJSON
RuleToJSON generates a JSON representation of the given rule.
core/rules.go:196
MethodRunJavascript
(ctx *Context, code string, libraries []string, bs *Bindings, props map[string]interface{})
core/location.go:870
MethodRuntimeLogLoop
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
MethodSchedule
Schedule is a generic scheduler for HTTP request work.
cron/generic.go:103
MethodScheduleEvent
ScheduleEvent packages up a ProcessEvent call for the simple rules HTTP API.
cron/croltglue.go:65
MethodScheduleEvent
(ctx *core.Context, se *ScheduledEvent)
cron/internal.go:37
MethodSearch
(t time.Time)
cron/cron.go:160
MethodSearch
(ctx *Context, pattern Map)
core/state_linear.go:268
MethodSearch
Search queries the term index for the given pattern (represented as JSON). Obtains and releases the FDS mutex.
core/state_indexed.go:606
MethodSearchRules
(ctx *Context, event Map, includeInherited bool)
core/location.go:683
MethodServeHTTP
(w http.ResponseWriter, r *http.Request)
service/httpd.go:396
MethodServer
(ctx *Context)
storage/dynamodb/dynamodb.go:358
FunctionServiceAvailable
ToDo: EnableLocation(location string, enabled bool) ToDo: LocationEnabled(location string) bool ToDo: QuitLocation(location string) ServiceAvailable c
sys/system.go:1521
MethodSetReadOnly
(ctx *Context, readOnly bool)
core/location.go:115
MethodSetValue
SetValue just exists for backwards compatibility. Just calls AddProp().
core/context.go:143
MethodStable
()
tools/sim/percentiles.go:27
MethodStartProfileCPU
StartProfileCPU starts pprof cpu.
sys/system.go:1423
MethodStartSpan
(opName string)
core/context.go:250
MethodStatus
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
MethodStopSpan
()
core/context.go:258
MethodString
()
core/errors.go:56
MethodString
()
core/errors.go:71
MethodString
()
core/errors.go:91
MethodString
()
core/errors.go:112
MethodSuspend
Suspend broadcasts that command to all Cron instances with this broadcaster.
cron/cron.go:88
MethodSwap
(i, j int)
cron/cron.go:152
MethodSwap
(i, j int)
core/patternindex.go:197
FunctionSystemForTest
(name string)
sys/system.go:529
MethodTable
(ctx *Context)
storage/dynamodb/dynamodb.go:362
MethodTemporary
()
service/httpd.go:154
FunctionTestActionCodeBase64Encoding
(t *testing.T)
core/actions_test.go:183
FunctionTestActionInterpreters
(t *testing.T)
core/actions_test.go:145
FunctionTestAnIpAddresses
(t *testing.T)
core/util_test.go:433
FunctionTestAndQueryFromMapBad1
(t *testing.T)
core/query_test.go:451
FunctionTestAndQueryFromMapBad2
(t *testing.T)
core/query_test.go:459
FunctionTestAndQueryFromMapGood
(t *testing.T)
core/query_test.go:468
FunctionTestAppProcessQuery
(t *testing.T)
core/query_test.go:565
FunctionTestBadStatelessWithExternalCron
(t *testing.T)
sys/system_test.go:547
FunctionTestBindingsWarningLimit
(t *testing.T)
core/location_test.go:215
FunctionTestCPULoad
(t *testing.T)
core/breaker_test.go:61
FunctionTestCPULoadProbe
(t *testing.T)
core/breaker_test.go:72
FunctionTestCache
(t *testing.T)
core/cache_test.go:25
FunctionTestCacheZero
(t *testing.T)
core/cache_test.go:88
FunctionTestCast
(t *testing.T)
core/match_test.go:9
FunctionTestChooseEmit
(t *testing.T)
tools/sim/gen_test.go:9
FunctionTestCodeQueryFromMapBad
(t *testing.T)
core/query_test.go:394
FunctionTestCodeQueryFromMapBadArray
(t *testing.T)
core/query_test.go:426
FunctionTestCodeQueryFromMapGoodArray1
(t *testing.T)
core/query_test.go:410
FunctionTestCodeQueryFromMapGoodArray2
(t *testing.T)
core/query_test.go:418
FunctionTestCodeQueryFromMapGoodSimple
(t *testing.T)
core/query_test.go:402
FunctionTestCoerceFakeFloats
(t *testing.T)
core/util_test.go:367
FunctionTestComboBreaker
(t *testing.T)
core/breaker_test.go:98
FunctionTestCommandSpec
(t *testing.T)
core/javascript_test.go:220
FunctionTestContextWithLocation
TextContextWithLocation creates a location with indexed state on memory storage. Also returns a Context with its location se.
core/util.go:396
FunctionTestControlCopy
(t *testing.T)
core/control_test.go:23
← previousnext →801–900 of 1,122, ranked by callers