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
DeleteHandler
(w http.ResponseWriter, r *http.Request)
crolt/handlers.go:58
Method
Dial
(network string, address string)
tools/sim/main.go:200
Method
Dial
(network string, address string)
storage/dynamodb/dynamodb.go:119
Method
Disable
Disable does what you think.
core/breaker.go:47
Method
Disable
(disabled bool)
core/breaker.go:149
Method
Disable
(disabled bool)
core/breaker.go:281
Method
Disable
(disabled bool)
core/breaker.go:353
Method
Disable
(disabled bool)
core/breaker.go:503
Method
Dispositions
()
core/events.go:169
Method
Do
(f func() error)
core/breaker.go:313
Method
Do
(f func() error)
core/breaker.go:372
Method
Do
(ctx *Context, loc *Location)
core/events.go:39
Method
Do
(ctx *Context, loc *Location)
core/events.go:155
Method
Do
(ctx *Context, loc *Location)
core/events.go:194
Method
Do
(ctx *Context, loc *Location)
core/events.go:281
Method
Do
(ctx *Context, loc *Location)
core/events.go:319
Function
DontTestJavascriptGet
(t *testing.T)
core/javascript_test.go:49
Method
Emit
()
tools/sim/gen.go:21
Method
Emit
()
tools/sim/gen.go:36
Method
Emit
()
tools/sim/gen.go:46
Method
Emit
()
tools/sim/gen.go:61
Method
Emit
()
tools/sim/gen.go:74
Method
Emit
()
tools/sim/gen.go:133
Method
Emit
(device string, f func(x interface{}) error)
tools/sim/gen.go:240
Method
Error
()
core/errors.go:45
Method
Error
()
core/errors.go:63
Method
Error
()
core/errors.go:83
Method
Error
()
core/errors.go:103
Method
Error
()
service/httpd.go:150
Method
Error
()
service/service.go:172
Function
ExampleLocation_ProcessEvent_basic
()
core/rules_test.go:67
Function
ExampleLocation_ProcessEvent_out
()
core/rules_test.go:141
Function
ExampleRunJavascript
()
core/javascript_test.go:103
Method
Exec
(ctx *Context, loc *Location, qc QueryContext, qr QueryResult)
core/query.go:195
Method
Exec
(ctx *Context, loc *Location, qc QueryContext, qr QueryResult)
core/query.go:356
Method
Exec
(ctx *Context, loc *Location, qc QueryContext, qr QueryResult)
core/query.go:495
Method
Exec
(ctx *Context, loc *Location, qc QueryContext, qr QueryResult)
core/query.go:567
Method
Exec
(ctx *Context, loc *Location, qc QueryContext, qr QueryResult)
core/query.go:641
Method
Exec
(ctx *Context, loc *Location, qc QueryContext, qr QueryResult)
core/query.go:715
Method
Exec
(ctx *Context, loc *Location, qc QueryContext, qr QueryResult)
core/query_test.go:523
Function
Expire
(ctx *Context, s State, id string, fact map[string]interface{}, now int64)
core/state.go:293
Method
FindCachedRules
FindCachedRules functions similarly to FindRules, except that an in-memory cache is used if a rule is not in the cache, it is added from persistence
core/state_linear.go:402
Method
FindCachedRules
(ctx *Context, event Map)
core/state_indexed.go:743
Method
FindRules
(ctx *Context, event Map)
core/state_linear.go:332
Method
FindRules
(ctx *Context, event Map)
core/state_indexed.go:683
Function
GenFactExample
(t *testing.T)
core/factgen_test.go:25
Method
GenerateHeaders
(ctx *Context)
core/query_test.go:553
Method
GenerateHeaders
(ctx *Context)
core/events_test.go:213
Method
GenerateHeaders
(ctx *Context)
core/http_test.go:148
Method
Get
Get returns the broadcaster's current channel. Cron instances call this method after each channel close that is detected.
cron/cron.go:80
Method
Get
()
core/query.go:825
Method
Get
(ctx *Context, id string)
core/state_linear.go:450
Method
Get
(ctx *Context, id string)
core/state_indexed.go:531
Method
Get
()
service/httpd.go:482
Method
GetFact
(ctx *Context, id string)
core/location.go:515
Method
GetHandler
(w http.ResponseWriter, r *http.Request)
crolt/handlers.go:82
Method
GetLocation
GetLocation implements core.LocationProvider. Just calls 'findLocation(,,false)'.
sys/system.go:848
Method
GetLocation
(ctx *Context, name string)
core/location.go:995
Method
GetName
GetName is used to find the ActionInterpreter based on an Action's Endpoint (which is now a very bad name).
core/actions.go:307
Method
GetName
GetName does what you'd thing. For the ActionInterpreter interface.
core/actions.go:318
Method
GetName
()
rulesys/main.go:381
Method
GetProfileBlock
GetProfileBlock returns pprof block.
sys/system.go:1489
Method
GetProfileCPU
GetProfileCPU gets/stops pprof cpu.
sys/system.go:1454
Method
GetProfileMem
GetProfileMem returns pprof mem.
sys/system.go:1476
Method
GetStats
GetStats get a clean copy of the System's current stats.
sys/system.go:641
Method
GetStats
(ctx *Context, loc string)
core/storage_none.go:48
Method
GetStats
(ctx *Context, loc string)
storage/dynamodb/dynamodb.go:618
Method
GetStats
(ctx *Context, loc string)
storage/cassandra/cassandra.go:290
Method
GetStats
GetStats returns the stats for a location ToDo: store last record times
storage/bolt/bolt.go:58
Method
GetThunk
(ctx *core.Context, loc *core.Location, bs core.Bindings, a core.Action)
rulesys/main.go:385
Method
Health
(ctx *Context)
core/storage_mem.go:99
Method
Health
(ctx *Context)
core/storage_none.go:56
Method
Health
(ctx *Context)
storage/dynamodb/dynamodb.go:642
Method
Health
(ctx *Context)
storage/cassandra/cassandra.go:310
Method
Health
(ctx *Context)
storage/bolt/bolt.go:190
Method
Intersect
Insert removes elements not in the given set. The receiver is modified.
core/util.go:114
Function
IsConstant
(s string)
core/util.go:584
Method
IsFatal
()
core/errors.go:24
Method
IsFatal
()
core/errors.go:52
Method
IsFatal
()
core/errors.go:67
Method
IsFatal
()
core/errors.go:87
Method
IsFatal
()
core/errors.go:107
Method
IsLoaded
(ctx *Context)
core/state_indexed.go:133
Function
JSON
(x interface{})
sys/system_test.go:35
Method
Keys
Keys returns a slice of the keys in the cache.
core/cache.go:91
Method
Kill
Kill the instance's loop forever. No going back.
cron/cron.go:256
Function
LatencyStatsHeader
()
tools/sim/percentiles.go:113
Method
Len
()
core/patternindex.go:194
Method
Less
(i, j int)
cron/cron.go:156
Method
Less
Less provides a somewhat generic comparison. Callers should check IsSortable() before invoking this method. If the given ThingSlice is heterogeneous,
core/patternindex.go:207
Method
ListRules
(ctx *Context, includeInherited bool)
core/location.go:715
Method
Load
(ctx *Context, loc string)
core/storage_none.go:28
Method
Load
(ctx *Context)
core/state_indexed.go:140
Method
Load
Load queries DynamoDB to get a location's state. This function also calls the location's 'Update()' function to remember the time the state was last
storage/dynamodb/dynamodb.go:402
Method
Load
(ctx *Context, loc string)
storage/cassandra/cassandra.go:234
Method
Load
Load returns data for a location ToDo: should we return an error if there was no bucket for a location?
storage/bolt/bolt.go:148
Method
Log
Log emits a log line for the given stats. The 'scope' is included in the log record. Example scopes: 'system', location.Name.
core/stats.go:168
Method
Log
(level LogLevel, args ...interface{})
core/loggers.go:28
Method
Log
(ctx *Context)
core/vars.go:224
Method
Log
(level LogLevel, op string, args ...interface{})
core/context.go:274
← previous
next →
701–800 of 1,122, ranked by callers