Functions — github.com/Comcast/rulio

hub / github.com/Comcast/rulio / functions

Functions1,122 in github.com/Comcast/rulio

⨍ Functions 1,122◇ Types & classes 159

↓ 7 callersFunctionprotest

(response, message)

examples/stockfs.py:52

↓ 7 callersFunctionprotest

(response, message)

examples/imdbfs.py:50

↓ 7 callersFunctionprotest

(response, message)

examples/weatherfs.py:44

↓ 6 callersFunctionCodeQueryFromMap

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

core/query.go:288

↓ 6 callersFunctionCoerceFakeFloats

CoerceFakeFloats will make ints out of floats when possible. Since al JSON all numbers are floats, big "integers" can cause trouble. Example: millise

core/util.go:426

↓ 6 callersMethodControl

Control atomically gets the System's controls.

sys/system.go:285

↓ 6 callersMethodCount

(ctx *Context)

core/state.go:31

↓ 6 callersFunctionGorep

Gorep returns a string that represents the given thing in Go -- except for plain strings. This function is used in logging generic data. All log rec

core/util.go:342

↓ 6 callersMethodMatch

Match takes a pattern and a fact built from map[string]interface{} and []interface{} structures, along with an initial set of bindings (may be empty),

core/match.go:46

↓ 6 callersFunctionMatches

Matches provides backwards compatibility around the Matcher interface.

core/match.go:31

↓ 6 callersFunctionNewAccumulator

NewAccumulator returns an Accumulator with the given size.

core/util.go:276

↓ 6 callersFunctionOrQueryFromMap

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

core/query.go:659

↓ 6 callersFunctionParseMap

ParseMap tries to parse a Map from JSON.

core/util.go:528

↓ 6 callersFunctionParseQuery

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

core/query.go:755

↓ 6 callersMethodPartition

(account string)

crolt/cron.go:107

↓ 6 callersMethodSearchFacts

SearchFacts finds facts that match the given pattern (JSON).

sys/system.go:1167

↓ 6 callersFunctiondoQueryBenchmark

(b *testing.B, facts []string, query string, bss string)

core/query_test.go:285

↓ 6 callersFunctiongenFacts

(ctx *Context, n int, width int, delta int, depth int, makeVar bool)

core/factgen.go:75

↓ 6 callersFunctionmapToPairs

mapToPairs generates an array of key/value Pairs in the map. We need to order the pairs and be able to write recursive functions to consume them.

core/patternindex.go:74

↓ 6 callersMethodstep

()

core/events.go:341

↓ 6 callersFunctiontestMemStorageLoad

(t *testing.T, ctx *Context, s *MemStorage, loc string)

core/storage_mem_test.go:38

↓ 5 callersMethodAdd

Add adds a value to the cache.

core/cache.go:66

↓ 5 callersMethodGetStats

(ctx *Context, loc string)

core/storage.go:51

↓ 5 callersFunctionInitialQueryResult

Make a QueryResult that contains one empty Bindings.

core/query.go:68

↓ 5 callersFunctionNewCache

(limit int, ttl time.Duration)

core/cache.go:31

↓ 5 callersFunctionNewSimpleLogger

(w io.Writer)

core/loggers.go:35

↓ 5 callersFunctionNowSecs

NowSecs returns the current time in UTC seconds.

core/util.go:186

↓ 5 callersFunctionParseConfig

ParseConfig generates a DynamoDBConfig from a string. Input should look like region[:tableName[:(true|false)]], where the boolean indicates whether t

storage/dynamodb/dynamodb.go:253

↓ 5 callersMethodPercentile

(p float64)

tools/sim/percentiles.go:54

↓ 5 callersMethodRemFact

RemFact remove a fact from the given location. Returns the ID of the removed fact.

sys/system.go:954

↓ 5 callersFunctionfromJSON

(s string)

core/util_test.go:30

↓ 5 callersFunctionmaybeInjectId

maybeInjectId might add KW_id:id to the given fact according to 'IdInjectionTime'. If it does, the function returns true; otherwise false.

core/state.go:80

↓ 5 callersFunctionpairFromStrings

(k, v string)

core/storage_mem_test.go:24

↓ 5 callersMethodstopTimerLocked

()

cron/cron.go:398

↓ 5 callersFunctiontestHTTPRequest

ToDo: More HTTPRequest tests.

core/http_test.go:31

↓ 4 callersMethodAdd

Add adds the thing to the Accumulator. If there isn't room, then room.

core/util.go:284

↓ 4 callersMethodAddAll

AddAll adds all elements of the given set to the set.

core/util.go:85

↓ 4 callersFunctionAndQueryFromMap

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

core/query.go:583

↓ 4 callersFunctionBenchFactsEventsRules

(b *testing.B, rules []string, facts []string, events []string, actionsPerEvent int, resetTimerBeforeEvents

core/rules_test.go:190

↓ 4 callersFunctionCompileJavascript

compileJavascript compiles a code with specified libraries

core/javascript.go:118

↓ 4 callersMethodCopy

Copy makes a shallow (except for DefaultControl) copy. The DefaultControl is Copy()ed.

core/vars.go:148

↓ 4 callersFunctionDefaultControl

DefaultControl makes a Control using Control.Defaults()

core/control.go:177

↓ 4 callersMethodEnableRule

EnableRule enables or disables a rule.

sys/system.go:1032

↓ 4 callersFunctionExtractRule

(ctx *Context, fact Map, required bool)

core/location.go:406

↓ 4 callersFunctionGetTimerHistory

GetTimerHistory gets a history for timers with the given name. 'after' is sequence number corresponding to 'Seq' in entries you've previously gotten.

core/timers.go:242

↓ 4 callersFunctionIsSortable

(xs []interface{})

core/patternindex.go:178

↓ 4 callersFunctionNamedTestingLocation

(t *testing.T, name string)

core/rules_test.go:98

↓ 4 callersFunctionNewDefaultCron

(db *bolt.DB)

crolt/cron.go:51

↓ 4 callersFunctionNewNoStorage

(ctx *Context)

core/storage_none.go:24

↓ 4 callersFunctionNewOutboundBreaker

NewOutboundBreaker makes a circuit breaker that will open if the Send rate exceeds the given rate (limit/interval).

core/breaker.go:137

↓ 4 callersFunctionNewStorage

(ctx *Context, config DynamoDBConfig)

storage/dynamodb/dynamodb.go:291

↓ 4 callersFunctionNewStringSet

NewStringSet does what you'd expect.

core/util.go:59

↓ 4 callersFunctionNowString

NowString returns a string representing the current time in UTC in the 'RFC3339Nano' representation.

core/util.go:203

↓ 4 callersMethodOpen

Open gets a location from the cache after first creating it. This function the top-level location cache API, and it uses 'CachedLocations.Get()' to d

sys/system.go:127

↓ 4 callersFunctionParseJSON

ParseJSON parses a map from bytes.

core/util.go:36

↓ 4 callersFunctionParseSchedule

(schedule string)

cron/generic.go:120

↓ 4 callersMethodPeekStorage

PeekStorage is an unholy API to expose underlying storage. Used by 'service' for testing purposes.

sys/system.go:1510

↓ 4 callersMethodPurge

Purge should never be called. ToDo: Remove this method from the interface, and kill the old mutation code.

storage/dynamodb/dynamodb.go:633

↓ 4 callersMethodRem

Rem deletes the job with the given ID. Returns true if the job was found and false if not.

cron/cron.go:532

↓ 4 callersFunctionRemProp

RemProp does what you'd think. The given id is the target id.

core/state.go:288

↓ 4 callersMethodResume

Resume restarts the instance's processing loop.

cron/cron.go:273

↓ 4 callersFunctionRuleTest

RuleTest loads the given facts and rule. Then submits the given events. If 'ctx' is nil, creates a 'SimpleSystem' and clears it.

core/rules_test.go:34

↓ 4 callersMethodSearchPatternsMap

SearchPatternsMap searchs the index for patterns that match the given fact (or event).

core/patternindex.go:503

↓ 4 callersFunctionSend

(client *http.Client, name string, uri string, js []byte)

tools/sim/main.go:103

↓ 4 callersMethodSetControl

(c *Control)

core/location.go:107

↓ 4 callersMethodStart

Start starts up a goroutine that operates the cron system. This method returns after the goroutine is started. You need to call this method for the

cron/cron.go:217

↓ 4 callersFunctionSubstituteBindings

(ctx *Context, code string, bs Bindings)

core/actions.go:121

↓ 4 callersFunctionUUID

UUID generates what is likely a v4 UUID using data from `crypto/Reader`. If crypto/Reader fails, returns the empty string instead. The implementation

core/util.go:246

↓ 4 callersFunctionbenchmarkSystemSimple

(b *testing.B, checking bool, unindexed bool)

sys/system_test.go:391

↓ 4 callersMethodcommand

control is the low-level method for controlling the Cron instance. Gets the lock and sends the given command to the Cron's control channel.

cron/cron.go:241

↓ 4 callersFunctiongetLocationsFromMap

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

core/query.go:255

↓ 4 callersMethodloc

(loc string)

core/storage_mem.go:37

↓ 4 callersFunctionloggable

loggable determines if we should emit a log record at the given level. The decision is based on a call to 'getVerbosity(ctx)'. A message is loggable

core/log.go:401

↓ 4 callersFunctionprotest

(ctx *core.Context, err error, w http.ResponseWriter)

service/httpd.go:391

↓ 4 callersFunctionradians

(num)

examples/libs/haversine.js:1

↓ 4 callersFunctiontestRuleFromMapBad

(t *testing.T, tag string, js string)

core/rules_test.go:440

↓ 3 callersMethodAdd

(n int)

tools/sim/percentiles.go:32

↓ 3 callersMethodAdd

(ctx *Context, loc string, m *Pair)

core/storage_mem.go:58

↓ 3 callersFunctionDWIMURI

(ctx *core.Context, uri string)

service/service.go:68

↓ 3 callersFunctionDefaultParameters

()

core/vars.go:161

↓ 3 callersMethodDestroy

Destroy closes the database and deletes it

storage/bolt/bolt.go:171

↓ 3 callersMethodDo

Do will execute the given thunk only if the circuit breaker is open. Returns whether the function executed was attempted and, if it was, any error ge

core/breaker.go:162

↓ 3 callersMethodElapse

Elapsed computes the elapsed time in nanoseconds. This method does not change the timer state.

core/timers.go:57

↓ 3 callersMethodEnableRule

(ctx *Context, id string, enable bool)

core/location.go:279

↓ 3 callersFunctionExampleSystemControl

ExampleSystemControl uses default SystemControl fields, except for Timing, which is turned on.

sys/system.go:508

↓ 3 callersMethodExec

(ctx *Context)

core/javascript.go:453

↓ 3 callersFunctionExtractTerms

ExtractTerms gets the terms from the given fact (or pattern). Since our TermIndex currently uses hash tables, it cannot do searches based on prefixes.

core/state_indexed.go:205

↓ 3 callersFunctionGenWalk

(e map[string]interface{})

tools/sim/gen.go:195

↓ 3 callersMethodGetCachedLocations

GetCachedLocations gets the set of cached locations. Gets the System's mutex.

sys/system.go:689

↓ 3 callersFunctionGetCode

GetCode makes a single string from either a string or an array of strings. If the given thing is an array of strings, they are joined with newlines.

core/actions.go:522

↓ 3 callersMethodGetLocationStats

GetLocationStats returns ServiceStats for the given location.

sys/system.go:1370

↓ 3 callersFunctionGetTimerNames

GetTimerNames returns a list of all know timer names.

core/timers.go:276

↓ 3 callersFunctionHaveProc

↓ 3 callersFunctionIsVariable

(s string)

core/util.go:580

↓ 3 callersMethodLen

Len returns the number of items in the cache.

core/cache.go:96

↓ 3 callersMethodMaxed

()

service/httpd.go:77

↓ 3 callersFunctionNewLatencies

(size int)

tools/sim/percentiles.go:17

↓ 3 callersFunctionNewStorage

NewStorage returns a BoltStorage based Storage

storage/bolt/bolt.go:42

↓ 3 callersFunctionNewSystem

NewSystem does about what you'd think.

sys/system.go:662

← previous next →101–200 of 1,122, ranked by callers