Functions — github.com/Comcast/rulio

hub / github.com/Comcast/rulio / functions

Functions1,122 in github.com/Comcast/rulio

⨍ Functions 1,122◇ Types & classes 159

↓ 1 callersMethodDefaults

Defaults sets up some reasonable values. ToDo: Move to SystemParameters

core/control.go:165

↓ 1 callersMethodDelete

(ctx *Context, loc string)

core/storage_mem.go:83

↓ 1 callersMethodDelete

(ctx *Context)

core/location.go:926

↓ 1 callersMethodDelete

(account, id string)

crolt/cron.go:279

↓ 1 callersMethodDeleteLocation

DeleteLocation should (!) clear all the state for the given location.

sys/system.go:1149

↓ 1 callersMethodDo

(client *http.Client)

crolt/work.go:49

↓ 1 callersFunctionDumpBucket

(s *Cron, bucket string)

crolt/cron_test.go:76

↓ 1 callersMethodEmit

()

tools/sim/gen.go:83

↓ 1 callersMethodEmit

(types *DeviceTypes, f func(req interface{}) error)

tools/sim/gen.go:336

↓ 1 callersMethodExecAction

(ctx *Context, bs Bindings, a Action)

core/actions.go:271

↓ 1 callersFunctionExtendBindings

Copy the given bindings into a new set of bindings.

core/query.go:479

↓ 1 callersMethodFastMetrics

Populate TermIndexMetrics with only metrics that are quick to compute. Also see 'SlowTermIndexMetrics'.

core/termindex.go:64

↓ 1 callersMethodFindCachedRules

(ctx *Context, event Map)

core/state.go:42

↓ 1 callersMethodFindDevice

↓ 1 callersMethodGenAccount

(n int)

tools/sim/gen.go:321

↓ 1 callersFunctionGenId

GenId generates, if necessary, and id suitablef or the given fact. If the fact is a property, then the id will be canonical. Otherwise, if 'def' is e

core/state.go:150

↓ 1 callersFunctionGenerateUpdateTimestamp

GenerateUpdateTimestamp returns a string consisting of the current timestamp and 'AnIpAddress'. Used by 'Update()'.

core/location.go:62

↓ 1 callersMethodGet

Get returns the location after opening it once.

↓ 1 callersMethodGetFact

GetFact returns JSON representation of a fact from the given location.

sys/system.go:978

↓ 1 callersFunctionGetHTTPRequest

(ctx *core.Context, r *http.Request)

service/httpd.go:295

↓ 1 callersMethodGetLastUpdatedMem

GetLastUpdatedMem reports what this system thinks the location's last updated timestamp is. Does not query DynamoDB to find out. Just returns what i

sys/system.go:895

↓ 1 callersMethodGetLocation

(ctx *Context, name string)

core/location.go:984

↓ 1 callersMethodGetParents

GetParents gets the location's parents (if any).

sys/system.go:1326

↓ 1 callersMethodGetParents

GetParents does what you'd think. Maybe shouldn't be a top-level location API. Instead expose 'GetProp' and document special properties?

core/location.go:791

↓ 1 callersMethodGetProp

(ctx *Context, prop string, def interface{})

core/location.go:970

↓ 1 callersMethodGetPropString

(ctx *Context, prop string, def string)

core/location.go:965

↓ 1 callersMethodGetRule

GetRule returns JSON representation of a rule from the given location.

sys/system.go:1097

↓ 1 callersMethodGetRule

(ctx *Context, id string)

core/location.go:434

↓ 1 callersFunctionGetRuntimes

GetRuntimes get a list of current the System's runtime data.

sys/system.go:576

↓ 1 callersMethodGetStats

GetStats isn't really implemented.

core/storage_mem.go:90

↓ 1 callersFunctionGetStorage

GetStorage will return a DynamoDBStorage, creating one if necessary.

storage/dynamodb/dynamodb.go:319

↓ 1 callersMethodGetThunk

GetThunk returns a function that can be executed to interpreter the given Action.

core/actions.go:303

↓ 1 callersFunctionGetTimestamp

GetTimestamp makes a timestamp from UNIX nanoseconds.

core/util.go:197

↓ 1 callersMethodGetWith

(key interface{}, thunk func() (interface{}, error))

core/cache.go:52

↓ 1 callersFunctionGoroutineBreaker

GoroutineBreaker makes a SimpleBreaker based on goroutine count.

core/breaker.go:390

↓ 1 callersMethodHealthDeeper

(ctx *core.Context)

service/service.go:1337

↓ 1 callersFunctionISlice

ISlice attempts to convert the given thing to an array of interface{}s. If the given thing isn't array, the thing is just returned. Uses reflection.

core/util.go:509

↓ 1 callersFunctionIdProperty

IdProperty returns true if the given prop starts with '!'.

↓ 1 callersFunctionIncCounter

IncCounter safely returns an increasing int.

core/util.go:218

↓ 1 callersMethodInstantiate

(params map[string]string)

tools/sim/gen.go:420

↓ 1 callersFunctionIpAddress

IpAddress tries to return a (non-loopback) IP address for this machine. If it can't find one, it returns 127.0.0.1. Exactly what this function retur

core/util.go:490

↓ 1 callersMethodIsLoaded

(ctx *Context)

core/state_linear.go:112

↓ 1 callersMethodIsReadOnly

↓ 1 callersFunctionLocationFunctions

(ctx *Context, loc *Location, runtime *otto.Otto, env map[string]interface{})

core/javascript.go:136

↓ 1 callersMethodLog

Log implements part of the Logger interface.

core/loggers.go:40

↓ 1 callersFunctionMakeLogRecord

MakeLogRecord is used by Log() to add log data to a context.

core/log.go:411

↓ 1 callersMethodMean

()

tools/sim/percentiles.go:46

↓ 1 callersMethodMerge

(more *SearchResults)

core/state.go:371

↓ 1 callersFunctionNanoStringToMilliString

NanoStringToMilliString drops microseconds from the string, which should be in the 'RFC3339Nano' representation.

core/util.go:209

↓ 1 callersFunctionNewCachedLocations

(ctx *Context)

sys/system.go:76

↓ 1 callersFunctionNewComboBreaker

(bs ...Breaker)

core/breaker.go:277

↓ 1 callersFunctionNewConnStates

()

service/httpd.go:472

↓ 1 callersFunctionNewCounter

(steps int)

core/events.go:352

↓ 1 callersFunctionNewCron

(db *bolt.DB, partitions int, maxJitter time.Duration, ttl time.Duration)

crolt/cron.go:69

↓ 1 callersFunctionNewCronBroadcaster

()

cron/cron.go:70

↓ 1 callersFunctionNewDeviceTypes

(js string)

tools/sim/gen.go:281

↓ 1 callersFunctionNewDialer

(d *net.Dialer)

tools/sim/main.go:208

↓ 1 callersFunctionNewDialer

(d *net.Dialer)

storage/dynamodb/dynamodb.go:124

↓ 1 callersFunctionNewGen

(x interface{})

tools/sim/gen.go:120

↓ 1 callersFunctionNewListener

(ctx *core.Context, s *HTTPService, port string, admin bool)

service/httpd.go:95

↓ 1 callersFunctionNewSearchTest

(bsss string)

core/query_test.go:34

↓ 1 callersFunctionNewStorage

NewStorage creates new Storage implementation based on Cassandra. The given Nodes should have the form ADDRESS:PORT, where the PORT is the CQL port (

storage/cassandra/cassandra.go:144

↓ 1 callersFunctionNewTemplate

(js string)

tools/sim/gen.go:408

↓ 1 callersFunctionNewThrottle

NewThrottle creates a new Throttle based on an embedded Breaker. 'pause' specifies how long to wait between trying the breaker. 'attempts' specifies

core/breaker.go:495

↓ 1 callersFunctionNotQueryFromMap

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

core/query.go:737

↓ 1 callersFunctionNowMicros

NowMicros returns the current time in UTC microseconds.

core/util.go:181

↓ 1 callersMethodOnce

Once is a little check to see if a job should only be executed once. The test is if job.Expression is nil.

cron/cron.go:375

↓ 1 callersMethodOpenLocation

OpenLocation wraps 'newLocation' to check for existence (optionally).

sys/system.go:199

↓ 1 callersFunctionParametersAddHook

ParametersAddHook installs a function that is called when SystemParameters change. Not thread-safe.

core/vars.go:40

↓ 1 callersFunctionParseConfig

ParseConfig generates a CassandraDBConfig from a string. Configuration is parsed from a string of the follow format: host:port,host:port;username;pass

storage/cassandra/cassandra.go:64

↓ 1 callersMethodPause

Pause stops the clock.

core/timers.go:86

↓ 1 callersMethodPending

()

service/httpd.go:56

↓ 1 callersMethodPrepareWork

(ctx *Context, event Map)

core/events.go:332

↓ 1 callersMethodPretty

()

tools/sim/gen.go:313

↓ 1 callersFunctionProbeTTL

ProbeTTL wraps a TTL cache around the given function.

core/breaker.go:397

↓ 1 callersMethodProcessBindings

(ctx *Context, bs Bindings)

core/context.go:29

↓ 1 callersMethodProcessQuery

ProcessQuery can be used to replace or wrap queries when unmarshaling a rule condition. The method gets the raw generic query data along with the que

core/context.go:38

↓ 1 callersMethodPurge

Purge is used to completely clear the cache

core/cache.go:104

↓ 1 callersMethodQuery

(ctx *Context, query string)

core/location.go:896

↓ 1 callersFunctionRandVar

()

core/factgen.go:32

↓ 1 callersFunctionRandomFactsTest

(ctx *Context, numberOfFacts int, numberOfQueries int, t *testing.T)

core/factgen.go:83

↓ 1 callersMethodRelease

Release checks whether the location has expired and, if so, closes it.

sys/system.go:167

↓ 1 callersMethodRemHook

(hook RemHookFn)

core/state.go:33

↓ 1 callersMethodRemID

Remove all entries for the given fact ID. Must check every term, so this operation is slow. Use 'RemIdTerms' if you know a fact's terms.

core/termindex.go:128

↓ 1 callersMethodRemove

(ctx *Context, loc string, k []byte)

core/storage_mem.go:67

↓ 1 callersMethodRemove

Remove removes the provided key from the cache.

core/cache.go:112

↓ 1 callersMethodRemoveOldest

RemoveOldest removes the oldest item from the cache.

core/cache.go:120

↓ 1 callersMethodRequest

Request constructs but does not issue a http.Request. If 'Env' isn't nil, that map will be used to obtain cookie data.

core/http.go:170

↓ 1 callersMethodRequest

()

crolt/work.go:33

↓ 1 callersMethodResume

Resume restarts a paused timer.

core/timers.go:68

↓ 1 callersMethodRetryEventWork

(ctx *Context, location string, work *FindRules)

sys/system.go:1285

↓ 1 callersMethodRuleEnabled

EnableRule enables or disables a rule.

sys/system.go:1052

↓ 1 callersFunctionRuleFromJSON

RuleToJSON generates a Rule from the given JSON representation.

core/rules.go:150

↓ 1 callersMethodRules

(t *Template, config map[string]interface{})

tools/sim/gen.go:440

↓ 1 callersMethodRunJavascript

RunJavascript allows location-specific Javascript testing.

sys/system.go:1399

↓ 1 callersMethodSchedule

Schedule makes the Crolt request to create a new job.

cron/croltglue.go:109

← previous next →401–500 of 1,122, ranked by callers