MCPcopy Create free account

hub / github.com/Comcast/rulio / types & classes

Types & classes159 in github.com/Comcast/rulio

↓ 5 callersTypeAliasBindings
Bindings is a map from variables (strings starting with a '?') to their values.
core/match.go:37
↓ 4 callersTypeAliasLogLevel
Core logging granularity We have several ubiquitous dimensions for log records. Severity, "origin", and component. "Origin" should indicate the sou
core/log.go:114
↓ 4 callersTypeAliasMap
Map is a generic event, pattern, or fact. Kinda wants to be a transparent typedef.
core/util.go:525
↓ 3 callersTypeAliasDuration
Duration allows us to parse strings into durations. See Duration.UnmarshalJSON().
core/control.go:135
↓ 1 callersStructAction
Action is something that a rule performs.
core/actions.go:28
↓ 1 callersTypeAliasDeviceTypeName
tools/sim/gen.go:293
↓ 1 callersTypeAliasFact
tools/sim/gen.go:389
↓ 1 callersInterfaceMatcher
Matcher defines an interface for pattern matching algorithms to be used by core.
core/match.go:41
↓ 1 callersTypeAliasRule
tools/sim/gen.go:378
↓ 1 callersTypeAliasThingSlice
ThingSlice is a slice of interfaces. This type exists because we need to sort homogeneous arrays with various element types, and we don't want to cop
core/patternindex.go:154
StructAPIProcessEventRequest
APIProcessEventRequest helps to serialize a request for the simple ProcessEvent HTTP API.
cron/croltglue.go:57
StructAccount
tools/sim/gen.go:295
StructAccumulator
Accumulator is sliding buffer. As it fills, older entries slide off the back. Not synchronized.
core/util.go:261
InterfaceActionInterpreter
ActionInterpreter can make a thunk, which can then be executed to interpret an action. The map of available ActionInterpreters is at Location.Control
core/actions.go:300
FuncTypeAddHookFn
func(ctx *Context, state State, id string, fact Map, loading bool) error
core/state.go:27
StructAndQuery
core/query.go:551
InterfaceApp
core/context.go:27
StructBashActionInterpreter
BashActionInterpreter is an example action interpreter for Bash scripts. Bindings are added to the environment with variable names that start with an
rulesys/main.go:378
StructBindingApp
core/events_test.go:209
StructBoltStorage
BoltStorage implements Storage using boltdb This name stutters because it's convenient to dot-import core, which defines 'Storage'.
storage/bolt/bolt.go:32
InterfaceBreaker
Breaker is the basic interface for a simple circuit breaker. You can get status, submit work, and disable a circuit breaker.
core/breaker.go:38
StructBreakerStatus
BreakerStatus is used instead of return several values from Status().
core/breaker.go:62
StructCache
core/cache.go:25
StructCacheTester
core/cache_test.go:63
StructCachedLocation
CachedLocation mostly provides a mutex associated with the target location. That mutex allows use to block only on this specific location when openin
sys/system.go:191
StructCachedLocations
CachedLocations is just that: a location cache keyed by name. We have this struct in part to have a mutex dedicated to this state.
sys/system.go:71
StructCassStorage
CassStorage implements Storage using Cassandra. This name stutters because it's convenient to dot-import core, which defines 'Storage'.
storage/cassandra/cassandra.go:41
StructCassandraDBConfig
CassandraDBConfig does what'd you'd think. This name stutters because it's convenient to dot-import core, which defines 'Storage'.
storage/cassandra/cassandra.go:50
StructCastMatcher
CastMatcher is a wrapper for casting Map values to map[string]interface{}, and slices to []interface{}.
core/match.go:67
TypeAliasChoose
tools/sim/gen.go:81
TypeAliasCleanAction
core/actions.go:65
TypeAliasCleanRule
core/rules.go:111
StructCodeQuery
core/query.go:93
StructComboBreaker
ComboBreaker is a bunch of Breakers considered as one. A ComboBreaker's status is based on the worst of its constituent breaker's statuses.
core/breaker.go:271
StructCommandSpec
core/javascript.go:430
StructCondition
core/errors.go:28
StructConfig
Config are read-only, boot-time settings. Once specified, these settings cannot be changed.
core/control.go:27
StructConnStates
service/httpd.go:467
StructContext
core/context.go:54
StructControl
SystemControl represents ephemeral control options. These settings are process-specific and not stored. Note that all of these values are simple (no
core/control.go:35
StructCounter
tools/sim/main.go:176
StructCounter
core/events.go:336
StructCroltJob
CroltJob is the structure of a Crolt job. We could use the actual Crolt type. Instead, we pretend that we don't have access to it.
cron/croltglue.go:45
StructCroltSimple
cron/croltglue.go:32
StructCron
Cron implements a little in-memory cron system. Not persistent; not fair.
cron/cron.go:169
StructCron
crolt/cron.go:43
StructCronBroadcaster
CronBroadcaster can broadcast a signal to multiple Cron instances. The basis for the implementation was suggested by Bill. All channel readers hear
cron/cron.go:64
StructCronJob
CronJob packages up the basics for a job. In particular, we need a Go function that defines the work to be performed.
cron/cron.go:122
InterfaceCronner
Cronner is a generic cron service. We'll probably add some other methods later. For example, we might want a method that enables us to remove all jo
cron/generic.go:94
StructDeviceType
tools/sim/gen.go:236
StructDeviceTypes
tools/sim/gen.go:264
StructDialer
tools/sim/main.go:196
StructDialer
Instrumented Dialer.
storage/dynamodb/dynamodb.go:115
StructDynamoDBConfig
DynamoDBConfig does what'd you'd think. This name stutters because it's convenient to dot-import core, which defines 'Storage'.
storage/dynamodb/dynamodb.go:241
StructDynamoDBStorage
DynamoDBStorage implements Storage using DynamoDB. Duh. This name stutters because it's convenient to dot-import core, which defines 'Storage'.
storage/dynamodb/dynamodb.go:174
StructEmptyQuery
core/query.go:353
StructEvalRule
core/events.go:140
StructEvalRuleCondition
core/events.go:181
TypeAliasEvent
tools/sim/gen.go:188
StructEventSpec
tools/sim/gen.go:190
StructExecRuleAction
core/events.go:261
StructExpiredError
core/errors.go:60
InterfaceFactService
core/query.go:367
StructFactServiceFromURI
Want anonymous interface implementations.
core/query.go:373
StructFindRules
core/events.go:26
StructFrequency
tools/sim/gen.go:158
StructGenerate
tools/sim/gen.go:110
StructGenericQuery
core/query.go:816
TypeAliasGroupControls
GroupControls maps a group to a 'core.Control'. Used to be called 'LocControls'
sys/system.go:50
StructHTTPClientSpec
HTTPClientSpec packages up all configuration for an HTTP request. This configuration includes settings such as ResponseHeaderTimeout that are below th
core/http.go:79
StructHTTPRequest
HTTPRequest packages up all data required to make an HTTP request (that can retry). Use 'NewHTTPRequest' to make one. We no longer do/control retrie
core/http.go:123
StructHTTPResult
HTTPResult packages up everything we return to the caller of an HTTPRequest. We're trying to use only basic field types for the convenience of Javasc
core/http.go:208
StructHTTPService
Parameter
service/httpd.go:43
StructHeaderApp
core/http_test.go:144
StructIndexedState
core/state_indexed.go:34
StructInternalCron
InternalCron just wraps an internal cron so it can be a Cronner.
cron/internal.go:33
StructJob
crolt/cron.go:112
StructLatencies
tools/sim/percentiles.go:11
StructLatencyStats
tools/sim/percentiles.go:103
StructLinearState
core/state_linear.go:31
StructListener
service/httpd.go:86
FuncTypeLocToGroup
LocToGroup maps a location name to a group name. Used to be called 'GroupMap'.
sys/system.go:45
StructLocation
core/location.go:29
InterfaceLocationProvider
core/location.go:983
FuncTypeLogHook
func(level LogLevel, args ...interface{})
core/log.go:464
InterfaceLogger
Logger is a simple interface to a mostly generic logging functionality.
core/log.go:76
StructMemStorage
MemStorage is a in-memory-only implementation of Storage.
core/storage_mem.go:24
StructNoStorage
Implementation of Storage that does nothing at all.
core/storage_none.go:21
StructNoopLogger
core/loggers.go:25
StructNormal
tools/sim/gen.go:40
StructNotFoundError
core/errors.go:95
StructNotQuery
core/query.go:699
StructOrQuery
core/query.go:621
StructOttoActionInterpreter
OttoActionInterpreter is an example ActionInterpreter that does the same thing (currently) as the built-in "javascript" interpreter.
core/actions.go:312
StructOutboundBreaker
OutboundBreaker is a very simple circuit breaker. An OutboundBreaker is used to control what this process does to other components or processes. It
core/breaker.go:93
StructPair
ToDo: Use this less
core/storage.go:24
StructParameters
Parameters is a package of almost const parameters.
core/vars.go:54
StructPatternIndex
PatternIndex is the state for our in-memory pattern store. It indexes patterns. When given an event (or fact), this index should find candidates for
core/patternindex.go:52
StructPatternQuery
core/query.go:362
FuncTypePointHook
func(ctx *Context, namespace string, metric string, val interface{}, unit string, more ...string)
core/log.go:579
next →1–100 of 159, ranked by callers