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
↓ 1 callers
Method
Schedule
(ctx *core.Context, sw *ScheduledWork)
cron/internal.go:63
↓ 1 callers
Method
ScheduleEvent
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 callers
Method
Search
(ctx *Context, pattern Map)
core/query.go:368
↓ 1 callers
Method
Search
(ctx *Context, pattern Map)
core/query.go:378
↓ 1 callers
Method
SearchForIDs
(ctx *Context, pattern Map)
core/state_indexed.go:566
↓ 1 callers
Method
SearchLocations
(ctx *Context, locations []string, pattern map[string]interface{})
core/query.go:446
↓ 1 callers
Method
SearchRemoteFacts
External fact service access
core/query.go:409
↓ 1 callers
Method
SetLogValue
(name string, val interface{})
core/context.go:215
↓ 1 callers
Function
SetParameters
(p *Parameters)
core/vars.go:44
↓ 1 callers
Method
SetParents
SetParents sets the location's parents. Returns the id of the property (if any).
sys/system.go:1349
↓ 1 callers
Method
SetParents
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 callers
Method
SetState
SetState is an unholy method that sets the raw data structure. Just used for testing.
core/storage_mem.go:114
↓ 1 callers
Method
Show
Print a JSON representation of the index.
core/termindex.go:223
↓ 1 callers
Method
Show
Show prints the index to stdout in a readable way.
core/patternindex.go:518
↓ 1 callers
Method
Shutdown
(ctx *core.Context)
service/service.go:1297
↓ 1 callers
Method
SlowMetrics
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 callers
Method
Start
(deviceTypes *DeviceTypes, template *Template, config map[string]interface{})
tools/sim/main.go:248
↓ 1 callers
Method
Start
(ctx *core.Context, enginePort string)
service/service.go:64
↓ 1 callers
Method
StartSpan
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 callers
Method
State
State is an unholy method that exposes the raw data structure. Just used for testing.
core/storage_mem.go:107
↓ 1 callers
Method
StateSize
(ctx *Context)
core/location.go:190
↓ 1 callers
Function
Stats
(interval time.Duration)
tools/sim/main.go:75
↓ 1 callers
Method
Status
()
core/breaker.go:287
↓ 1 callers
Method
Stddev
()
tools/sim/percentiles.go:78
↓ 1 callers
Method
Stop
(d time.Duration)
service/httpd.go:126
↓ 1 callers
Method
StopSpan
StopSpan is given a context previously given to StartSpan in order to finalize the trace for the given span.
core/context.go:51
↓ 1 callers
Function
StringMaps
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 callers
Method
Submit
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 callers
Method
Summary
Summary gives a one-line summary of the breaker's state.
core/breaker.go:197
↓ 1 callers
Function
Timestamp
Timestamp returns a string representing the given time in UTC in the 'RFC3339Nano' representation.
core/util.go:192
↓ 1 callers
Function
Unmarshal
(bs []byte, v interface{})
service/httpd.go:264
↓ 1 callers
Method
UnmarshalJSON
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 callers
Method
UpdateJavascriptRuntime
UpdateJavascriptRuntime can be used to modify the Javascript environment for actions and condition code.
core/context.go:33
↓ 1 callers
Method
Updated
Updated returns the in-memory timestamp of the last update.
core/location.go:50
↓ 1 callers
Method
Worst
()
tools/sim/percentiles.go:50
↓ 1 callers
Method
Zap
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 callers
Function
abbreviateCodepath
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 callers
Function
addCallerLine
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 callers
Method
addFact
(ctx *Context, id string, fact Map)
core/location.go:480
↓ 1 callers
Function
benchStatePropertiesBasic
(b *testing.B, ctx *Context, s State)
core/state_test.go:313
↓ 1 callers
Function
benchmarkLogger
(b *testing.B, logger Logger)
core/log_test.go:47
↓ 1 callers
Method
checkingExistence
checkingExistence now just looks to sys.config.CheckExistence.
sys/system.go:380
↓ 1 callers
Function
defaultLogFields
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 callers
Method
deleteDependencies
(ctx *Context, id string)
core/state_linear.go:245
↓ 1 callers
Method
deleteDependencies
(ctx *Context, id string)
core/state_indexed.go:455
↓ 1 callers
Function
duplicateId
(msg string)
core/location.go:629
↓ 1 callers
Function
dynamodbTableDescription
dynamodbTableDescription generates a standard table definition.
storage/dynamodb/dynamodb.go:335
↓ 1 callers
Function
engine
(args []string, wg *sync.WaitGroup)
rulesys/main.go:125
↓ 1 callers
Method
ensureStorage
(ctx *Context)
sys/system.go:700
↓ 1 callers
Function
extractTermsAux
(ctx *Context, x interface{}, terms StringSet, depth int)
core/state_indexed.go:213
↓ 1 callers
Method
fetchLibrary
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 callers
Function
genFact
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 callers
Function
generic
(args []string)
rulesys/main.go:90
↓ 1 callers
Method
get
(ctx *Context, id string, getLock bool)
core/state_linear.go:455
↓ 1 callers
Method
get
(ctx *Context, id string, getLock bool)
core/state_indexed.go:536
↓ 1 callers
Function
getCallerLine
getCallerLine looks up the filename:linenum in the call stack.
core/log.go:448
↓ 1 callers
Function
getClient
()
tools/sim/main.go:241
↓ 1 callers
Function
getCoreLogLevel
getCoreLogLevel returns a string for the severity of the given "level". Could generate Stringer methods ...
core/log.go:192
↓ 1 callers
Function
getDynamoServer
(ctx *Context, region string)
storage/dynamodb/dynamodb.go:192
↓ 1 callers
Function
getExpiration
getExpiration looks for 'expires' property and returns it as an int64. Value should be in UNIX seconds.
core/state.go:457
↓ 1 callers
Function
getHTTPBreaker
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 callers
Method
getLibraryCode
getLibraryCode gathers up all library code. The code is concatenated (in order) and returned. Uses 'fetchLibrary()' for resolution.
core/query.go:170
↓ 1 callers
Function
getLogComponent
getLogComponent returns a string for the component of the given "level". Could generate Stringer methods ...
core/log.go:232
↓ 1 callers
Function
getLogOrigin
getLogOrigin returns a string for the origin of the given "level".
core/log.go:216
↓ 1 callers
Function
getMovie
(query)
examples/imdbfs.py:56
↓ 1 callers
Function
getPropFromFact
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 callers
Function
getQuote
(symbol)
examples/stockfs.py:58
↓ 1 callers
Function
getVerbosity
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 callers
Function
getWeather
(locale)
examples/weatherfs.py:50
↓ 1 callers
Method
got
(srs SearchResults)
core/query_test.go:81
↓ 1 callers
Method
indexRule
(ctx *Context, id string, rule map[string]interface{})
core/state_indexed.go:347
↓ 1 callers
Method
init
(ctx *Context)
core/location.go:176
↓ 1 callers
Method
init
init creates the given table if it doesn't exist.
storage/dynamodb/dynamodb.go:367
↓ 1 callers
Method
init
(ctx *Context, config CassandraDBConfig)
storage/cassandra/cassandra.go:160
↓ 1 callers
Function
initClient
()
tools/sim/main.go:237
↓ 1 callers
Method
insert
(ctx *core.Context, job *CronJob)
cron/cron.go:427
↓ 1 callers
Function
jsFun_http
(ctx *Context, runtime *otto.Otto, env map[string]interface{})
core/javascript.go:327
↓ 1 callers
Function
jsFun_httpx
(ctx *Context, runtime *otto.Otto, env map[string]interface{})
core/javascript.go:386
↓ 1 callers
Function
legalFact
(ctx *Context, fact string)
sys/system.go:824
↓ 1 callers
Function
legalFactWithout
legalFact will return an error if the fact includes the given property at the top level.
sys/system.go:830
↓ 1 callers
Function
logFacti
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 callers
Function
markLocationCreated
(ctx *Context, loc *Location)
sys/system.go:811
↓ 1 callers
Method
newEntry
(x interface{})
core/cache.go:48
↓ 1 callers
Method
newLocation
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 callers
Function
newTimerHistory
()
core/timers.go:151
↓ 1 callers
Function
parseParameter
(p, v string)
service/httpd.go:278
↓ 1 callers
Function
parseProp
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 callers
Method
rem
(ctx *Context, pairs []piPair, id string)
core/patternindex.go:104
↓ 1 callers
Method
run
(ctx *core.Context, job *CronJob)
cron/cron.go:379
↓ 1 callers
Method
sameAs
(bs Bindings)
core/query_test.go:43
↓ 1 callers
Method
searchFactsAncestors
(ctx *Context, pattern Map)
core/location.go:581
↓ 1 callers
Method
searchPairs
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 callers
Method
setParents
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 callers
Method
start
start launches the instance's processing loop.
cron/cron.go:278
↓ 1 callers
Method
stopProfiling
(ctx *Context)
sys/system.go:1445
↓ 1 callers
Function
storage
(args []string, wg *sync.WaitGroup)
rulesys/main.go:217
↓ 1 callers
Function
substituteInterface
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 callers
Function
testStateBadTTL
(t *testing.T, ctx *Context, s State)
core/state_test.go:576
↓ 1 callers
Function
tooMany
(c net.Conn)
service/httpd.go:138
↓ 1 callers
Method
work
(part string)
crolt/cron.go:365
← previous
next →
501–600 of 1,122, ranked by callers