Functions — github.com/Comcast/rulio

hub / github.com/Comcast/rulio / functions

Functions1,122 in github.com/Comcast/rulio

⨍ Functions 1,122◇ Types & classes 159

↓ 2 callersMethodResolveService

(ctx *Context, name string)

core/location.go:947

↓ 2 callersMethodRuleEnabled

(ctx *Context, id string)

core/location.go:238

↓ 2 callersMethodSearchRules

SearchRules finds rules with 'when' patterns that match the given event (JSON).

sys/system.go:1218

↓ 2 callersFunctionSearchTermsTest

(ctx *Context, ti *TermIndex, terms []string, expected []string)

core/termindex_test.go:26

↓ 2 callersMethodSetControl

SetControl atomically gets the System's controls.

sys/system.go:290

↓ 2 callersMethodSetMaxPending

(max int32)

service/httpd.go:72

↓ 2 callersFunctionSimpleSystem

SimpleSystem ia a basic system with 'FOREVER' TTL and 'DefaultVerbosity' Verbosity.

sys/system.go:535

↓ 2 callersFunctionSlurp

Slurp gets the contents (string) at a URL. Also see CachedSlurp.

core/javascript.go:57

↓ 2 callersMethodSort

()

tools/sim/percentiles.go:70

↓ 2 callersFunctionSortValues

SortValues attempts to sort the slice generically.

core/patternindex.go:223

↓ 2 callersMethodStart

(ctx *core.Context, servicePort string)

service/httpd.go:492

↓ 2 callersMethodStatus

Status report the breaker load (but where 100% is represented by 1.0), whether the breaker is closed (good) or open (bad), whether the breaker is disa

core/breaker.go:44

↓ 2 callersMethodStatus

()

core/breaker.go:359

↓ 2 callersFunctionStructToMap

StructToMap converts a struct to a map.

core/util.go:374

↓ 2 callersMethodSubContext

()

core/context.go:219

↓ 2 callersMethodSubtract

Subtract subtracts the given stats from the receiver. The receiver is cloned first, and the updated clone is returned.

core/stats.go:111

↓ 2 callersMethodTermCard

How big is the set of IDs for the given term?

core/termindex.go:144

↓ 2 callersMethodWorkLoops

()

crolt/cron.go:450

↓ 2 callersMethodWorkWalk

(ctx *Context, w *FindRules, steps int)

core/events.go:359

↓ 2 callersMethodadd

(ctx *Context, id string, x Map)

core/state_indexed.go:280

↓ 2 callersMethodadd

(ctx *Context, pairs []piPair, id string)

core/patternindex.go:100

↓ 2 callersFunctionaddSome

(ctx *Context, bolt *BoltStorage, b *testing.B, n int, m int)

storage/bolt/bolt_test.go:88

↓ 2 callersFunctionbenchSetup

(b *testing.B)

storage/bolt/bolt_test.go:72

↓ 2 callersFunctionbenchStateAdd

(b *testing.B, ctx *Context, s State)

core/state_test.go:51

↓ 2 callersFunctionbenchStateSearch

(b *testing.B, ctx *Context, s State)

core/state_test.go:64

↓ 2 callersFunctioncheckInjectedId

(t *testing.T, fact string, id string)

core/state_test.go:26

↓ 2 callersMethoddoFindRules

(ctx *Context, event Map)

core/state_linear.go:340

↓ 2 callersMethoddoFindRules

(ctx *Context, event Map)

core/state_indexed.go:691

↓ 2 callersFunctiondoSearchTest

(t *testing.T, facts []string, pattern string, bsss string)

core/query_test.go:98

↓ 2 callersMethodexpire

expire checks the cache for the given location and determines if the cache value has expired. Either way, returns the location (if any). If the cach

sys/system.go:99

↓ 2 callersMethodgetActionFunc

(ctx *Context, bs Bindings, a Action)

core/actions.go:394

↓ 2 callersFunctiongetBoolParam

(m map[string]interface{}, prop string, required bool)

service/service.go:110

↓ 2 callersMethodgetParents

getParents is current just a wrapper around 'GetProp' to read a location's parents (if any).

core/location.go:760

↓ 2 callersFunctiongetProp

getProp attempts to find the property value for the target 'id' and prop. Calls 'getPropFromFact' after 'genPropId'.

core/state.go:258

↓ 2 callersFunctiongetSchedule

(ctx *core.Context, fact core.Map)

cron/corehooks.go:25

↓ 2 callersMethodgrantPrivilege

(region string)

core/context.go:158

↓ 2 callersFunctionidProperty

idProperty prepends a '!' to the given prop (if necessary).

core/state.go:137

↓ 2 callersMethodinc

()

tools/sim/main.go:185

↓ 2 callersMethodincPending

(add bool)

service/httpd.go:60

↓ 2 callersMethodinit

init initializes the breaker's state. Mostly just allocates the count array.

core/breaker.go:239

↓ 2 callersMethodinit

()

core/context.go:188

↓ 2 callersFunctioninstantiate

(m map[string]interface{}, params map[string]string)

tools/sim/gen.go:354

↓ 2 callersFunctionisURL

(library string)

core/query.go:119

↓ 2 callersMethodjson

()

core/util.go:123

↓ 2 callersFunctionloggableFor

(level LogLevel, given LogLevel)

core/log.go:405

↓ 2 callersFunctionmakeClient

()

tools/sim/main.go:214

↓ 2 callersFunctionmaybeCopyEvent

maybeCopyEvent will make a copy of the binding for "?event" if SystemParameters.CopyEvent says so. See issue #20. Watch out for concurrent access to

core/actions.go:257

↓ 2 callersMethodmod

Mod (for modification) is the primary write/update function. The method calls itself recursively to modify the index. Users will call AddPatternMap,

core/patternindex.go:240

↓ 2 callersFunctionmultiline

(s interface{})

doc/api/rulesapi.go:41

↓ 2 callersFunctionnotAfter

(ctx *Context, secs int64, then int64)

core/state.go:474

↓ 2 callersFunctionparseAId

(aid string)

crolt/cron.go:162

↓ 2 callersFunctionprotest

(response, message)

examples/executor.py:25

↓ 2 callersFunctionprotest

(response, message)

examples/endpoint.py:36

↓ 2 callersFunctionprotest

(response, message)

examples/actionendpoint.py:32

↓ 2 callersMethodrem

(ctx *core.Context, id string)

cron/cron.go:545

↓ 2 callersMethodremHooks

(ctx *Context)

core/state_indexed.go:474

↓ 2 callersMethodrevokePrivilege

()

core/context.go:164

↓ 2 callersFunctionsameBindingss

(x []Bindings, y []Bindings)

core/query_test.go:60

↓ 2 callersMethodschedule

(ctx *core.Context, job *CronJob, checkLimit bool)

cron/cron.go:442

↓ 2 callersMethodsearch

(ctx *Context, pattern Map, lock bool)

core/state_linear.go:272

↓ 2 callersMethodsearch

(ctx *Context, pattern Map)

core/state_indexed.go:617

↓ 2 callersMethodsearchFacts

(ctx *Context, pattern Map)

core/location.go:601

↓ 2 callersMethodsearchRules

(ctx *Context, event Map)

core/location.go:657

↓ 2 callersMethodsearchRulesAncestors

(ctx *Context, event Map)

↓ 2 callersFunctionsetExpires

setExpires looks for a given 'ttl' or 'expires' property, canonicalizes the value, and returns a rewritten Javascript representation of the fact, the

core/state.go:388

↓ 2 callersMethodstartProfiling

(ctx *Context)

sys/system.go:1435

↓ 2 callersFunctiontestDeleteStateDependencies

(t *testing.T, ctx *Context, s State)

core/state_test.go:406

↓ 2 callersFunctiontestStateBasic

(t *testing.T, ctx *Context, s State)

core/state_test.go:81

↓ 2 callersFunctiontestStateExpires

(t *testing.T, newState func(ctx *Context, store Storage, loc string) (State, error))

core/state_test.go:468

↓ 2 callersFunctiontestStateIdPropertiesBasic

(t *testing.T, ctx *Context, s State)

core/state_test.go:255

↓ 2 callersFunctiontestStateIdPropertiesOverwrite

(t *testing.T, ctx *Context, s State)

core/state_test.go:345

↓ 2 callersFunctiontestStatePropTTL

(t *testing.T, ctx *Context, s State)

core/state_test.go:588

↓ 2 callersFunctiontestStatePropertiesBasic

(t *testing.T, ctx *Context, s State)

core/state_test.go:218

↓ 2 callersFunctiontestStateRuleTTL

(t *testing.T, ctx *Context, s State)

core/state_test.go:618

↓ 2 callersFunctiontestStateTTL

(t *testing.T, ctx *Context, s State)

core/state_test.go:542

↓ 2 callersMethodtoggle

toggle sends the signal to all Cron instances with this broadcaster. Assumes the broacaster (write) lock is held by the caller. Creates a new channe

cron/cron.go:110

↓ 2 callersMethodunindexRule

(ctx *Context, id string, rule map[string]interface{})

core/state_indexed.go:370

↓ 2 callersMethodupdate

(j *Job)

crolt/cron.go:245

↓ 2 callersFunctionusage

()

rulesys/main.go:316

↓ 2 callersFunctionweather

(where,appid)

examples/libs/wind.js:1

↓ 1 callersMethodAdd

(ctx *Context, id string, x Map)

core/state_linear.go:155

↓ 1 callersMethodAdd

(j *Job)

crolt/cron.go:206

↓ 1 callersMethodAddHook

(hook AddHookFn)

core/state.go:32

↓ 1 callersFunctionAddHooks

(ctx *core.Context, cronner Cronner, state core.State)

cron/corehooks.go:49

↓ 1 callersMethodAddr

()

service/httpd.go:204

↓ 1 callersMethodAggregate

Aggregate from given ServiceStats. Updates the receiver.

core/stats.go:137

↓ 1 callersFunctionAsThingSlice

(xs []interface{})

core/patternindex.go:156

↓ 1 callersMethodBind

Replace all variables in the given pattern with their bindings (when possible).

core/query.go:29

↓ 1 callersMethodClear

(ctx *Context, loc string)

storage/dynamodb/dynamodb.go:587

↓ 1 callersMethodClear

(ctx *Context, loc string)

storage/cassandra/cassandra.go:275

↓ 1 callersMethodClear

Clear removes a location and returns the number of records dropped

storage/bolt/bolt.go:114

↓ 1 callersMethodClearStats

ClearStats clear the System's stats.

sys/system.go:647

↓ 1 callersFunctionClearTimerHistories

ClearTimerHistories resets all timer histories.

core/timers.go:192

↓ 1 callersMethodClient

Client returns an http.Client appropriate for the given request. This function first consults HTTPClientCache. If a client with a matching HTTPClien

core/http.go:361

↓ 1 callersMethodClose

(ctx *Context)

core/storage_mem.go:94

↓ 1 callersMethodCloseLocation

CloseLocation currently does nothing.

sys/system.go:871

↓ 1 callersFunctionConditionalCheckFailedException

(err error)

storage/dynamodb/dynamodb.go:458

↓ 1 callersMethodCopy

We'll need to make an atomic copy of a history for API GetTimerHistory.

core/timers.go:159

↓ 1 callersMethodCount

Count returns an approximate count of the number of facts. Only an approximation because we will count expired facts that have not been removed.

core/state_linear.go:105

← previous next →301–400 of 1,122, ranked by callers