MCPcopy Create free account

hub / github.com/Comcast/rulio / functions

Functions1,122 in github.com/Comcast/rulio

↓ 1 callersMethodSchedule
(ctx *core.Context, sw *ScheduledWork)
cron/internal.go:63
↓ 1 callersMethodScheduleEvent
ScheduleEvent schedules a rule engine event. We have this special, API-specific method due to our desire to have cron functionality that does not req
cron/generic.go:100
↓ 1 callersMethodSearch
(ctx *Context, pattern Map)
core/query.go:368
↓ 1 callersMethodSearch
(ctx *Context, pattern Map)
core/query.go:378
↓ 1 callersMethodSearchForIDs
(ctx *Context, pattern Map)
core/state_indexed.go:566
↓ 1 callersMethodSearchLocations
(ctx *Context, locations []string, pattern map[string]interface{})
core/query.go:446
↓ 1 callersMethodSearchRemoteFacts
External fact service access
core/query.go:409
↓ 1 callersMethodSetLogValue
(name string, val interface{})
core/context.go:215
↓ 1 callersFunctionSetParameters
(p *Parameters)
core/vars.go:44
↓ 1 callersMethodSetParents
SetParents sets the location's parents. Returns the id of the property (if any).
sys/system.go:1349
↓ 1 callersMethodSetParents
SetParents sets a location's parents. To remove a location's parents, just pass a zero array. See comments re 'GetParents'.
core/location.go:831
↓ 1 callersMethodSetState
SetState is an unholy method that sets the raw data structure. Just used for testing.
core/storage_mem.go:114
↓ 1 callersMethodShow
Print a JSON representation of the index.
core/termindex.go:223
↓ 1 callersMethodShow
Show prints the index to stdout in a readable way.
core/patternindex.go:518
↓ 1 callersMethodShutdown
(ctx *core.Context)
service/service.go:1297
↓ 1 callersMethodSlowMetrics
Fully populate TermIndexMetrics. This function traverses all of the sets in the index, so this function can take a while to execute. Also see 'FastM
core/termindex.go:78
↓ 1 callersMethodStart
(deviceTypes *DeviceTypes, template *Template, config map[string]interface{})
tools/sim/main.go:248
↓ 1 callersMethodStart
(ctx *core.Context, enginePort string)
service/service.go:64
↓ 1 callersMethodStartSpan
StartSpan is given a new subcontext and the name of the operation that the context is for. The function is expected to modify the context with any sp
core/context.go:47
↓ 1 callersMethodState
State is an unholy method that exposes the raw data structure. Just used for testing.
core/storage_mem.go:107
↓ 1 callersMethodStateSize
(ctx *Context)
core/location.go:190
↓ 1 callersFunctionStats
(interval time.Duration)
tools/sim/main.go:75
↓ 1 callersMethodStatus
()
core/breaker.go:287
↓ 1 callersMethodStddev
()
tools/sim/percentiles.go:78
↓ 1 callersMethodStop
(d time.Duration)
service/httpd.go:126
↓ 1 callersMethodStopSpan
StopSpan is given a context previously given to StartSpan in order to finalize the trace for the given span.
core/context.go:51
↓ 1 callersFunctionStringMaps
StringMaps tries to makes (recursively) a map[string]interface{} from a map[interface{}]interface{} (which yaml.Unmarshal tends to provide). When som
service/httpd.go:228
↓ 1 callersMethodSubmit
Submit sends a thunk to the throttle. The throttle will execute the thunk only if the embedded Breaker says it can. If the function is executed, it'
core/breaker.go:548
↓ 1 callersMethodSummary
Summary gives a one-line summary of the breaker's state.
core/breaker.go:197
↓ 1 callersFunctionTimestamp
Timestamp returns a string representing the given time in UTC in the 'RFC3339Nano' representation.
core/util.go:192
↓ 1 callersFunctionUnmarshal
(bs []byte, v interface{})
service/httpd.go:264
↓ 1 callersMethodUnmarshalJSON
UnmarshalJSON parses a string into a Duration. Go says, "cannot define new methods on non-local type time.Duration", so we have to work a little indi
core/control.go:144
↓ 1 callersMethodUpdateJavascriptRuntime
UpdateJavascriptRuntime can be used to modify the Javascript environment for actions and condition code.
core/context.go:33
↓ 1 callersMethodUpdated
Updated returns the in-memory timestamp of the last update.
core/location.go:50
↓ 1 callersMethodWorst
()
tools/sim/percentiles.go:50
↓ 1 callersMethodZap
Zap hits the circuit breaker and returns whether the breaker is then closed (good: true) or open (bad: false). If the breaker is open when zapped, th
core/breaker.go:188
↓ 1 callersFunctionabbreviateCodepath
abbreviateCodepath drops most of the leading directories from the given path. Used to strip irrelevant directories from source code paths. This func
core/log.go:440
↓ 1 callersFunctionaddCallerLine
addCallerLine, if LogCallerLine is true, adds a filename:linenum property to the given args. Looks up three levels in the call stack.
core/log.go:457
↓ 1 callersMethodaddFact
(ctx *Context, id string, fact Map)
core/location.go:480
↓ 1 callersFunctionbenchStatePropertiesBasic
(b *testing.B, ctx *Context, s State)
core/state_test.go:313
↓ 1 callersFunctionbenchmarkLogger
(b *testing.B, logger Logger)
core/log_test.go:47
↓ 1 callersMethodcheckingExistence
checkingExistence now just looks to sys.config.CheckExistence.
sys/system.go:380
↓ 1 callersFunctiondefaultLogFields
defaultLogFields makes sure we have at least one bit set for each of SEVMASK, ORIMASK, and COMPMASK. This function is called on given log levels in t
core/log.go:357
↓ 1 callersMethoddeleteDependencies
(ctx *Context, id string)
core/state_linear.go:245
↓ 1 callersMethoddeleteDependencies
(ctx *Context, id string)
core/state_indexed.go:455
↓ 1 callersFunctionduplicateId
(msg string)
core/location.go:629
↓ 1 callersFunctiondynamodbTableDescription
dynamodbTableDescription generates a standard table definition.
storage/dynamodb/dynamodb.go:335
↓ 1 callersFunctionengine
(args []string, wg *sync.WaitGroup)
rulesys/main.go:125
↓ 1 callersMethodensureStorage
(ctx *Context)
sys/system.go:700
↓ 1 callersFunctionextractTermsAux
(ctx *Context, x interface{}, terms StringSet, depth int)
core/state_indexed.go:213
↓ 1 callersMethodfetchLibrary
fetchLibrary attempts to obtain code for the given library. The given library can be a URL, a name that resolves to a URL via location.GetConfig().Li
core/query.go:128
↓ 1 callersFunctiongenFact
Generate a random Fact. 'Width' is minimum number of properties. 'Delta' indicates a random number of additional properties. `Depth` specifies the de
core/factgen.go:48
↓ 1 callersFunctiongeneric
(args []string)
rulesys/main.go:90
↓ 1 callersMethodget
(ctx *Context, id string, getLock bool)
core/state_linear.go:455
↓ 1 callersMethodget
(ctx *Context, id string, getLock bool)
core/state_indexed.go:536
↓ 1 callersFunctiongetCallerLine
getCallerLine looks up the filename:linenum in the call stack.
core/log.go:448
↓ 1 callersFunctiongetClient
()
tools/sim/main.go:241
↓ 1 callersFunctiongetCoreLogLevel
getCoreLogLevel returns a string for the severity of the given "level". Could generate Stringer methods ...
core/log.go:192
↓ 1 callersFunctiongetDynamoServer
(ctx *Context, region string)
storage/dynamodb/dynamodb.go:192
↓ 1 callersFunctiongetExpiration
getExpiration looks for 'expires' property and returns it as an int64. Value should be in UNIX seconds.
core/state.go:457
↓ 1 callersFunctiongetHTTPBreaker
getHTTPBreaker finds a breaker (if any) for the given URI in HTTPBreakers. First the URI itself is used for the key. Failing that, the URI host is u
core/http.go:60
↓ 1 callersMethodgetLibraryCode
getLibraryCode gathers up all library code. The code is concatenated (in order) and returned. Uses 'fetchLibrary()' for resolution.
core/query.go:170
↓ 1 callersFunctiongetLogComponent
getLogComponent returns a string for the component of the given "level". Could generate Stringer methods ...
core/log.go:232
↓ 1 callersFunctiongetLogOrigin
getLogOrigin returns a string for the origin of the given "level".
core/log.go:216
↓ 1 callersFunctiongetMovie
(query)
examples/imdbfs.py:56
↓ 1 callersFunctiongetPropFromFact
getPropFromFact generates the canonical id, gets the fact for that id, and returns the fact's prop value. If the fact doesn't exist, the default 'def
core/state.go:174
↓ 1 callersFunctiongetQuote
(symbol)
examples/stockfs.py:58
↓ 1 callersFunctiongetVerbosity
getVerbosity attempts to find the current LogLevel. By default, it's 'EVERYTHING'. 'ctx.Verbosity' overrides that default, and 'ctx.GetLoc().Control
core/log.go:375
↓ 1 callersFunctiongetWeather
(locale)
examples/weatherfs.py:50
↓ 1 callersMethodgot
(srs SearchResults)
core/query_test.go:81
↓ 1 callersMethodindexRule
(ctx *Context, id string, rule map[string]interface{})
core/state_indexed.go:347
↓ 1 callersMethodinit
(ctx *Context)
core/location.go:176
↓ 1 callersMethodinit
init creates the given table if it doesn't exist.
storage/dynamodb/dynamodb.go:367
↓ 1 callersMethodinit
(ctx *Context, config CassandraDBConfig)
storage/cassandra/cassandra.go:160
↓ 1 callersFunctioninitClient
()
tools/sim/main.go:237
↓ 1 callersMethodinsert
(ctx *core.Context, job *CronJob)
cron/cron.go:427
↓ 1 callersFunctionjsFun_http
(ctx *Context, runtime *otto.Otto, env map[string]interface{})
core/javascript.go:327
↓ 1 callersFunctionjsFun_httpx
(ctx *Context, runtime *otto.Otto, env map[string]interface{})
core/javascript.go:386
↓ 1 callersFunctionlegalFact
(ctx *Context, fact string)
sys/system.go:824
↓ 1 callersFunctionlegalFactWithout
legalFact will return an error if the fact includes the given property at the top level.
sys/system.go:830
↓ 1 callersFunctionlogFacti
logFacti generates a crude string representation of the given fact to give to 'Log'. We don't just let 'Log' generate a better representation because
core/log.go:657
↓ 1 callersFunctionmarkLocationCreated
(ctx *Context, loc *Location)
sys/system.go:811
↓ 1 callersMethodnewEntry
(x interface{})
core/cache.go:48
↓ 1 callersMethodnewLocation
newLocation is a primitive function to load a location in isolation. No caches are touched and no checks are made. Just create a location from stora
sys/system.go:737
↓ 1 callersFunctionnewTimerHistory
()
core/timers.go:151
↓ 1 callersFunctionparseParameter
(p, v string)
service/httpd.go:278
↓ 1 callersFunctionparseProp
parseProp reports the fact has exactly one IdProperty. If so, returns the value for the 'id' property (if any), that property, and the value of the p
core/state.go:223
↓ 1 callersMethodrem
(ctx *Context, pairs []piPair, id string)
core/patternindex.go:104
↓ 1 callersMethodrun
(ctx *core.Context, job *CronJob)
cron/cron.go:379
↓ 1 callersMethodsameAs
(bs Bindings)
core/query_test.go:43
↓ 1 callersMethodsearchFactsAncestors
(ctx *Context, pattern Map)
core/location.go:581
↓ 1 callersMethodsearchPairs
searchPairs is the core index reader. This method calls itself recursively to traverse the index. Users will call SearchPatternsMap and SearchPatter
core/patternindex.go:366
↓ 1 callersMethodsetParents
setParents is currently just a wrapper for 'SetProp' to set a location's parents. To remove a location's parents, just pass a zero array.
core/location.go:812
↓ 1 callersMethodstart
start launches the instance's processing loop.
cron/cron.go:278
↓ 1 callersMethodstopProfiling
(ctx *Context)
sys/system.go:1445
↓ 1 callersFunctionstorage
(args []string, wg *sync.WaitGroup)
rulesys/main.go:217
↓ 1 callersFunctionsubstituteInterface
substituteInterface attempts to traverse the given thing to replace variable references with their corresponding bindings. The main work is performed
core/actions.go:140
↓ 1 callersFunctiontestStateBadTTL
(t *testing.T, ctx *Context, s State)
core/state_test.go:576
↓ 1 callersFunctiontooMany
(c net.Conn)
service/httpd.go:138
↓ 1 callersMethodwork
(part string)
crolt/cron.go:365
← previousnext →501–600 of 1,122, ranked by callers