MCPcopy Create free account

hub / github.com/Comcast/rulio / functions

Functions1,122 in github.com/Comcast/rulio

⨍ Functions 1,122◇ Types & classes 159
↓ 3 callersFunctionParseQueryFromJSON
(ctx *Context, s string)
core/query_test.go:142
↓ 3 callersFunctionPatternQueryFromMap
(ctx *Context, m map[string]interface{})
core/query.go:530
↓ 3 callersMethodRem
Remove the given ID at the given term.
core/termindex.go:109
↓ 3 callersMethodRemFact
(ctx *Context, id string)
core/location.go:496
↓ 3 callersMethodRemPatternMap
RemPatternMap removes the given pattern from the index.
core/patternindex.go:513
↓ 3 callersMethodRemRule
(ctx *Context, id string)
core/location.go:379
↓ 3 callersMethodReset
Reset zeros the current elapsed time and resets the current time.
core/timers.go:77
↓ 3 callersMethodScan
(bucket string, f func(b, k, v string) (bool, error))
crolt/cron.go:427
↓ 3 callersMethodSetProp
(ctx *Context, id string, prop string, val interface{})
core/location.go:269
↓ 3 callersMethodStats
()
tools/sim/percentiles.go:132
↓ 3 callersMethodStats
()
core/location.go:974
↓ 3 callersMethodStopTag
StopTag computes the elapsed time (in nanosecs) and stores it in the history. This method also logs (level -1) the elapsed time with the given tag.
core/timers.go:121
↓ 3 callersMethodStripQuestionMarks
Strips '?' from variables. Warn if no '?'.
core/query.go:101
↓ 3 callersMethodSuspend
Suspend stops the instance's processing loop. Restart processing with Resume().
cron/cron.go:268
↓ 3 callersFunctionUnmarshalYAML
(bs []byte, v interface{})
service/httpd.go:255
↓ 3 callersFunctionUseCores
UseCores will use all cores unless the environment variable 'GOMAXPROCS' is set. If 'silent', then do not make a 'Log()' call. There is a proposal f
core/util.go:357
↓ 3 callersFunctionWho
(skip int)
core/util.go:549
↓ 3 callersFunctioncast
(iface interface{})
core/match.go:76
↓ 3 callersFunctionchanGet
(c chan interface{}, wait time.Duration, t *testing.T)
core/rules_test.go:125
↓ 3 callersFunctioncheckExpiration
checkExpires determines if the given fact has expired. Assumes that 'setExpires()' was called previous so that we have a good 'expires' value if any.
core/state.go:489
↓ 3 callersMethoddelete
(account, id string)
crolt/cron.go:314
↓ 3 callersMethodexpire
expire checks for expiration and removes the fact if expired. This method is mostly generic and could be dissociated from IndexedState.
core/state_linear.go:486
↓ 3 callersMethodexpire
expire checks for expiration and removes the fact if expired. This method is mostly generic and could be dissociated from IndexedState.
core/state_indexed.go:579
↓ 3 callersFunctiongenPropId
genPropId generates the canonical fact id for a property for the given id and prop.
core/state.go:127
↓ 3 callersFunctiongetJS
(js string)
tools/sim/gen.go:268
↓ 3 callersMethodinit
(ctx *Context)
core/state_indexed.go:100
↓ 3 callersMethodinit
()
crolt/cron.go:169
↓ 3 callersMethodinstantiate
(params map[string]string)
tools/sim/gen.go:380
↓ 3 callersFunctionlocationCreated
(ctx *Context, loc *Location)
sys/system.go:805
↓ 3 callersFunctionnewContext
(appId string)
core/context.go:199
↓ 3 callersFunctionnoConnection
(err error)
storage/dynamodb/dynamodb_test.go:33
↓ 3 callersFunctionpicast
(ctx *Context, x interface{})
core/patternindex.go:108
↓ 3 callersMethodrem
(ctx *Context, id string, lock bool)
core/state_linear.go:214
↓ 3 callersMethodrem
(ctx *Context, id string)
core/state_indexed.go:409
↓ 3 callersMethodresetTimer
()
cron/cron.go:404
↓ 3 callersMethodresetTimerLocked
()
cron/cron.go:421
↓ 3 callersFunctionrespond
(out, js)
examples/endpoint.py:43
↓ 3 callersMethodslide
slide moves the count entries down the line based on the current time.
core/breaker.go:252
↓ 3 callersMethodstore
Add to a timer's history.
core/timers.go:202
↓ 3 callersFunctionsubstituteString
substituteString attempts to replace variable references in the given string with their corresponding bindings. If the given string is an exact match
core/actions.go:196
↓ 3 callersFunctiontypeCode
(x interface{})
core/patternindex.go:163
↓ 3 callersMethodwithPrivilege
(ctx *Context)
core/state_indexed.go:68
↓ 3 callersMethodwithoutPrivilege
(ctx *Context)
core/state_indexed.go:72
↓ 2 callersMethodAdd
(ctx *Context, loc string, data *Pair)
core/storage.go:43
↓ 2 callersMethodAdd
Add adds the given string to the set.
core/util.go:79
↓ 2 callersMethodAddProp
(prop string, val interface{})
core/context.go:136
↓ 2 callersMethodAddStrings
(xs ...string)
core/util.go:92
↓ 2 callersMethodAtCapacity
(ctx *Context)
core/location.go:197
↓ 2 callersFunctionBenchSystem
BenchSystem makes a System that might be appropriate for benchmarks. Verbosity is 'NOTHING'. Based on 'ExampleSystem'.
sys/system.go:561
↓ 2 callersFunctionCPULoad
CPULoad gets load averages from '/proc/loadavg'.
core/breaker.go:422
↓ 2 callersMethodCSVDiv
(by int)
tools/sim/percentiles.go:117
↓ 2 callersFunctionCachedSlurp
CachedSlurp gets the contents (string) at a URL using a little LRU cache. The cache has a TTL of 5 seconds See the constants SlurpCacheSize and Slurp
core/javascript.go:91
↓ 2 callersMethodClear
(ctx *Context, loc string)
core/storage_mem.go:75
↓ 2 callersMethodCreateLocation
CreateLocation exists solely to mark a location as created.
sys/system.go:771
↓ 2 callersFunctionDecodeString
(encoding, code string)
core/actions.go:67
↓ 2 callersMethodDifference
Difference returns a new set containing the elements in receiver that are not in the given set. No sets are harmed in this operation.
core/util.go:144
↓ 2 callersMethodDoAncestors
DoAncestors calls the given function on this location and all of its ancestors in depth-first order.
core/location.go:540
↓ 2 callersMethodDoBuckets
(f func(bucket string) error)
crolt/cron.go:55
↓ 2 callersMethodDoOnce
DoOnce get a client, constructs a request, issues the request, and gathers the result.
core/http.go:230
↓ 2 callersMethodDrain
(d time.Duration)
service/httpd.go:104
↓ 2 callersFunctionEmptyStringSet
EmptyStringSet makes one of those.
core/util.go:70
↓ 2 callersFunctionExampleConfig
ExampleConfig just generates a simple config for an in-memory-only System.
sys/system.go:371
↓ 2 callersFunctionExecQuery
(ctx *Context, q Query, loc *Location, qc QueryContext, qr QueryResult)
core/query.go:84
↓ 2 callersMethodFindRules
(ctx *Context, event Map)
core/state.go:41
↓ 2 callersMethodGenerateHeaders
(ctx *Context)
core/context.go:28
↓ 2 callersMethodGetCompiledCode
(ctx *Context, loc *Location)
core/query.go:186
↓ 2 callersFunctionGetRulePatterns
GetRulesPatterns extracts the rule's 'when' pattern.
core/state_indexed.go:329
↓ 2 callersMethodGetSize
GetSize returns the number of facts (including rules) stored in the given location.
sys/system.go:876
↓ 2 callersFunctionGetStorage
GetStorage attempts to create a Storage. See '../storage/' for some implementations. Possible storage types: "none": This Storage doesn't remember
sys/system.go:397
↓ 2 callersMethodGetStringCode
()
core/actions.go:82
↓ 2 callersMethodGetThunk
GetThunk returns the thunk that will interpret the action. For the ActionInterpreter interface.
core/actions.go:325
↓ 2 callersMethodHave
(ctx *Context, id string, isRule bool)
core/location.go:218
↓ 2 callersMethodHealth
(ctx *Context)
core/storage.go:55
↓ 2 callersMethodHealthDeep
(ctx *core.Context)
service/service.go:1318
↓ 2 callersFunctionIpAddresses
IpAddresses tries to find a machine's (non-loopback) network interfaces. 127.0.0.1 and ::1 are not included in the results. Uses 'net.Interfaces()'.
core/util.go:446
↓ 2 callersFunctionIsNakedVariable
(s string)
core/actions.go:186
↓ 2 callersMethodJSON
()
core/util.go:541
↓ 2 callersMethodJitter
()
crolt/cron.go:100
↓ 2 callersMethodListRules
ListRules returns all rules (JSON) stored in the given location.
sys/system.go:1303
↓ 2 callersMethodLoad
ListLocations(ctx *Context) ([]string, error)
core/storage.go:41
↓ 2 callersMethodLoad
(ctx *Context)
core/state_linear.go:119
↓ 2 callersMethodLocControl
LocControl gets a location controls. A location's controls originate with the System's controls, which have a 'DefaultLocControl' that's used if 'Loc
sys/system.go:300
↓ 2 callersMethodMaxPending
()
service/httpd.go:68
↓ 2 callersFunctionMaybeYAML
(bs []byte)
service/httpd.go:219
↓ 2 callersMethodMetric
(name string, args ...interface{})
core/log.go:78
↓ 2 callersFunctionNewHTTPClientSpec
DefaultHTTPClientSpec generates HTTPClientSpec based on defaults given by SystemParameters.
core/http.go:94
↓ 2 callersFunctionNewHTTPService
(ctx *core.Context, service *Service)
service/httpd.go:52
↓ 2 callersFunctionNewJob
(account string, id string, expr string)
crolt/cron.go:132
↓ 2 callersFunctionNewSimpleBreaker
(probe func() (float64, error), limit float64)
core/breaker.go:349
↓ 2 callersFunctionNewSimpleLocationProvider
(locs map[string]*Location)
core/location.go:991
↓ 2 callersFunctionOneShotSchedule
(schedule string)
core/events.go:311
↓ 2 callersFunctionParseVerbosity
ParseVerbosity parses and evals and log mask. This function is a little crazy. It uses Javascript to parse and eval the given string. The various l
core/log.go:292
↓ 2 callersMethodPersistent
Persistent reports whether the Cronner's state is persistent or ephemeral. A persistent Cronner will not get updates when Locations are loaded (since
cron/generic.go:117
↓ 2 callersFunctionPost
Post issues a POST to the specified URL.
core/http.go:388
↓ 2 callersFunctionPrepareFact
(ctx *Context, givenId string, x Map)
core/state.go:313
↓ 2 callersMethodProcessRequest
(ctx *core.Context, m map[string]interface{}, out io.Writer)
service/service.go:176
↓ 2 callersMethodProp
(prop string)
core/context.go:129
↓ 2 callersMethodRem
Rem removes the job with the given id. The boolean return value might indicate whether the job was found. Probably isn't meaningful.
cron/generic.go:109
↓ 2 callersMethodRemIdTerms
Remove all entries for the given ID at the given terms.
core/termindex.go:136
↓ 2 callersMethodRemRule
RemRule removes a rule from the given location. Returns the ID of the removed rule.
sys/system.go:1073
← previousnext →201–300 of 1,122, ranked by callers